调整新用户推送，添加短信模板

app/Http/Controllers/CronController.php

@@ -266,7 +266,7 @@ class CronController extends Controller
         $user = $UserMainModel->where('is_type', 0)
                 ->where('is_test', 0)
                 ->whereBetween('create_time', [$start_time, $last_time])
-                ->select('user_id', 'is_new')
+                ->select('user_id', 'is_new', 'create_time')
                 ->get()
                 ->toArray();
 
@@ -277,7 +277,8 @@ class CronController extends Controller
 
         foreach ($user as $k=>$v) {
             if ($v['is_new'] == 0) { // 未下单用户
-                $user_send_msg[] = $v['user_id'];
+                $user_send_msg[$k]['user_id']     = $v['user_id'];
+                $user_send_msg[$k]['create_time'] = $v['create_time'];
 
                 $crm_params[$k]['user_id']         = $v['user_id'];
                 $crm_params[$k]['is_create_order'] = 0;
@@ -287,7 +288,10 @@ class CronController extends Controller
             // 已下单用户，判断订单是否有支付
             $count = $OrderModel->where('user_id', $v['user_id'])->where('status', '>', 2)->count();
 
-            if (!$count) $user_send_msg[] = $v['user_id']; // 不存在，则表示没有已付款的订单
+            if (!$count) { // 不存在，则表示没有已付款的订单
+                $user_send_msg[$k]['user_id']     = $v['user_id'];
+                $user_send_msg[$k]['create_time'] = $v['create_time'];
+            }
 
             $crm_params[$k]['user_id']         = $v['user_id'];
             $crm_params[$k]['is_create_order'] = 1; // 标记已下单
@@ -297,27 +301,39 @@ class CronController extends Controller
 
         //调用消息接口
         $url = Config('website.api_domain').'msg/sendmessagebyauto';
-        $keyword = 'new_user_activity_msg';
+        
 
         $data['k1']  = time();
         $data['k2']  = md5(md5($data['k1']).'fh6y5t4rr351d2c3bryi');
 
-        foreach ($user_send_msg as $uid) {
+        foreach ($user_send_msg as $msg) {
+            // 判断用户注册时间
+            $time    = time() - $msg['create_time'];
+            $reg_day = intval(ceil($time / 86400));
+
+            switch ($reg_day) {
+                case 1: $keyword = 'new_user_activity_msg_1'; break;
+                case 3: $keyword = 'new_user_activity_msg_3'; break;
+                case 7: $keyword = 'new_user_activity_msg_7'; break;
+                case 15: $keyword = 'new_user_activity_msg_15'; break;
+                default : $keyword = ''; break;
+            }
+
+            if (!$keyword) continue;
+
             $userData = [
                 "keyword"  => $keyword, 
                 "pf"       => 1, 
                 "k1"       => $data['k1'], 
                 "k2"       => $data['k2'],
-                'touser'   => json_encode($uid),
+                'touser'   => json_encode($msg['user_id']),
             ];
 
             $temp = json_decode(curlApi($url, $userData, "POST"), true);
 
-            if ($temp['err_code'] == 0) {
-                continue;
-            } else {
-                errorLog($temp['err_code'], $temp['err_msg'].'，用户ID：'.$uid); // 消息推送失败记录
-            }
+            if (empty($temp) || $temp['err_code'] != 0) errorLog(10001, '消息推送失败记录，用户ID：'.$uid);             
+            
+            continue;     
         }
 
         // 推送到crm
@@ -326,10 +342,7 @@ class CronController extends Controller
 
         $res = json_decode(curlApi($crm_url, $crm_params, "POST", false, $crm_header), true);
 
-        if (!$res || $res['err_code'] != 0) {
-            errorLog(10001, '新用户推送到crm失败 '.$res['err_msg']); // 推送crm失败记录
-        }
-
+        if (!$res || $res['err_code'] != 0) errorLog(10002, '新用户推送到crm失败 '.$res['err_msg']);
     }
 
 }
\ No newline at end of file