|
@@ -46,6 +46,16 @@ class ECommerceUserActionsDataUpload extends Command
|
46
|
46
|
{
|
47
|
47
|
$this->info(date('m-d H:i:s') . ' 执行开始~');
|
48
|
48
|
|
|
49
|
+ $length = RedisModel::lLen(TencentAdAuth::ECOMMERCE_USER_ACTIONS_ADD_RDS);
|
|
50
|
+ if($length > 0) {
|
|
51
|
+ EmailQueue::rPush(
|
|
52
|
+ '电商直投数据回传队列堆积',
|
|
53
|
+ '队列:' . TencentAdAuth::ECOMMERCE_USER_ACTIONS_ADD_RDS . ' 当前长度:' . $length,
|
|
54
|
+ self::NOTICE_EMAIL,
|
|
55
|
+ '电商直投'
|
|
56
|
+ );
|
|
57
|
+ }
|
|
58
|
+
|
49
|
59
|
$curTime = time();
|
50
|
60
|
while(true) {
|
51
|
61
|
if(time() - $curTime >= 60) {
|