dot = \app\main\service\UserdotService::instance();
}*/
public function testSendSingleProcess()
{
$export = ExportFansService::instance()->checkFansLead(1807, 22288)->data;
$data = nl2br($export['content']);
$url = getCurrentDomain(1807, '/index/share/leadpage?id='.$export['id'].'&from=wx');
$content = '';
if (strrpos($data, '
') != false) {
foreach (explode('
', $data) as $v) {
$v = preg_replace('|\s|', '', $v);
//$v = str_replace([PHP_EOL, ' ', '\r\n'], ['', '', ''], $v);
var_dump($v);
//$content .= "{$v}\r\n";
}
} else {
$content .= "{$export['content']}\r\n\r\n";
}
//var_dump($content);
die;
//\app\main\service\ReferralService::instance()->sendReferralAdData(989, ['admin_id' => 1734, 'url' => "http://wx5c755b34fe1d1111.dev.kpread.com/index/user/recent", 'orders' => ['money' =>0.01, 'productName' => "测试一下001"], 'openid' => "oiYYI1r5ZYS78UECy-6xJnr4Wk5U"]);
//\app\main\service\ReferralService::instance()->sendReferralAdData(989, ['admin_id' => 1734, 'url' => "http://wx5c755b34fe1d1111.dev.kpread.com/index/user/index", 'sub' => ['productName' => "测试一下001"], 'openid' => "oIOef0ZFczbEvg4I6d12FLgpAcI0"]);
$dot = \app\main\service\UserdotService::instance();
$message = [
'user_id' => 19335706,
'channel_id' => 3,
'action_type' => 'obscuresubscribe.referral',
'referral_id' => 706,
'type' => 4,
'event_time' => time(),
];
$messageObj = (new \app\main\model\object\DotObject())->bind($message);
for ($i = 0; $i < 1000; $i++) {
$dot->handleTask($messageObj);
}
}
public function testSendMultiProcess_10()
{
$dot = \app\main\service\UserdotService::instance();
$message = [
'user_id' => 19335706,
'channel_id' => 3,
'action_type' => 'obscuresubscribe.referral',
'referral_id' => 706,
'type' => 4,
'event_time' => time(),
];
$messageObj = (new \app\main\model\object\DotObject())->bind($message);
$i = 0;
while ($i < 10) {
$pid = pcntl_fork();
echo "pid:" . $pid . ",$i\n";
echo "current_id:" . getmypid() . ",$i\n";
switch ($pid) {
case -1:
// @fail
die('Fork failed');
break;
case 0:
$j = 0;
while ($j < 1000) {
$dot->handleTask($messageObj);
$j++;
}
exit(0);
break;
}
$i++;
}
}
public function testSendMultiProcess_50()
{
$dot = \app\main\service\UserdotService::instance();
$message = [
'user_id' => 19335706,
'channel_id' => 3,
'action_type' => 'obscuresubscribe.referral',
'referral_id' => 706,
'type' => 4,
'event_time' => time(),
];
$messageObj = (new \app\main\model\object\DotObject())->bind($message);
$i = 0;
while ($i < 50) {
$pid = pcntl_fork();
echo "pid:" . $pid . ",$i\n";
echo "current_id:" . getmypid() . ",$i\n";
switch ($pid) {
case -1:
// @fail
die('Fork failed');
break;
case 0:
$j = 0;
while ($j < 200) {
$dot->handleTask($messageObj);
$j++;
}
exit(0);
break;
}
$i++;
}
}
public function testSendMultiProcess_100()
{
$dot = \app\main\service\UserdotService::instance();
$message = [
'user_id' => 19335706,
'channel_id' => 3,
'action_type' => 'obscuresubscribe.referral',
'referral_id' => 706,
'type' => 4,
'event_time' => time(),
];
$messageObj = (new \app\main\model\object\DotObject())->bind($message);
$i = 0;
while ($i < 100) {
$pid = pcntl_fork();
echo "pid:" . $pid . ",$i\n";
echo "current_id:" . getmypid() . ",$i\n";
switch ($pid) {
case -1:
// @fail
die('Fork failed');
break;
case 0:
$j = 0;
while ($j < 100) {
$dot->handleTask($messageObj);
$j++;
}
exit(0);
break;
}
$i++;
}
}
public function testUvTest()
{
$dotData = \app\main\service\SmartPushDotService::instance()->generateKefuData(
1022,
17,
0,
time(),
3
);
\app\main\service\SmartPushDotService::instance()->dotSmartPushInfo($dotData);
}
public function testSubTest()
{
$dotData = \app\main\service\SmartPushDotService::instance()->generateSubData(
1022,
17,
time(),
3
);
\app\main\service\SmartPushDotService::instance()->dotSmartPushInfo($dotData);
}
public function testPay()
{
$dotData = \app\main\service\SmartPushDotService::instance()->generatePayData(
1022,
17,
2,
time(),
10
);
\app\main\service\SmartPushDotService::instance()->dotSmartPushInfo($dotData);
}
public function testBooklistDot()
{
(new \app\common\model\Platform())->delCacheAll(3);
\app\main\service\OpenPlatformService::instance()->getProfixconfigById(3);
die;
$redisKey = 'text1234';
$res = \app\common\library\Redis::instance()->hMSet($redisKey, []);
var_dump($res);
\app\common\library\Redis::instance()->expire($redisKey, 600);
/* $ext_data = [
'mark' => 3501,
'push_id' => 7,
'push_idx' => '11000000040',
'push_time' => time(),
'admin_id' => 1734
];
$dotData = \app\main\service\SmartPushDotService::instance()->generateDotData(
$ext_data['mark'],
$ext_data['push_id'] ?? 0,
$ext_data['push_idx'] ?? BigData::DEFAULT_PUSH_IDX,
$ext_data['push_time'] ?? time(),
time(),
array_merge(['type' => 1, 'user_id' => 3], $ext_data)
);
\app\main\service\SmartPushDotService::instance()->dotSmartPushInfo($dotData);*/
}
public function testCustomDot()
{
$data['user_id'] = 20001433;
$data['openid'] = 'oiYYI1l0kANcDG6Ti8B7Tjr45xbU';
$data['goods_id'] = '3';
$data['channel_id'] = '1734';
$msg2 = [];
$msg2['title'] = '首充';
$msg2['image'] = 'http://cpsn.dev.kpread.com/assets/img/qrcode.png';
$msg2['url'] = 'http://wx5c755b34fe1d1111.dev.kpread.com/s/100?user_id=20001433';
$msg2['description'] = '书币半价，仅限前100名';
$data['msg'] = $msg2;
MqUserPayCancelService::instance()->sendFirstCancel($data, 0);
}
}