拨打电话未打跟进

application/api_broker/service/CallPhoneService.php

@@ -14,10 +14,12 @@ use app\api_broker\untils\RongDemo;
 use app\extra\RedisExt;
 use app\model\AliYunPhone;
 use app\model\BindingPhone;
+use app\model\AliYunSecretReport;
 use app\model\SecretReport;
 use app\model\UPhoneFollowUp;
 use app\model\UPhoneFollowUpTemporary;
 use app\model\Users;
+use app\model\AAgents;
 use think\Log;
 
 class CallPhoneService
@@ -540,41 +542,50 @@ class CallPhoneService
      */
     public function defaultFollowUp()
     {
-
-        /*$current_time = time();
-        $time = $current_time - 3600;
-//        $start_date = date('Y-m-d', $time);
-        $end_date = date('Y-m-d');
-        $user_key = 'call_phone_user_' . $end_date;
-        $user_data = $this->redis->hKeys($user_key);
-        $content = '拨打电话，未打跟进。';
-        $follow_where['create_time'] = ['between', [date('Y-m-d H:i:s', $time), date('Y-m-d H:i:s')]];
-
+        $secret_model = new AliYunSecretReport();
+        $agent_model = new AAgents();
+        $current_time = time();
+        $end_time = $current_time - 3600;
+        $start_time = $end_time - 3600;
+
+        $save_follow['content'] = '拨打电话，未打跟进。';
+        $follow_where['create_time'] = $bind_where['create_time'] = [
+            'between', [date('Y-m-d H:i:s', $start_time), date('Y-m-d H:i:s',$end_time)]
+        ];
+        $bind_where['time'] = ['>', 0];
+        $num = $secret_model->getTotal($bind_where);
         //用户
-        if (!empty($user_data)) {
+        if ($num > 0) {
+            for ($i=1; $i <= $num; $i++) { 
+                $secret_data = $secret_model->getList($i, 500, '', 'agents_id,users_id,create_time', $bind_where);
+                foreach ($secret_data as $key => $value) {
+                    if (empty($value['agents_id']) || empty($value['users_id'])) {
+                        continue;
+                    }
 
-            foreach ($user_data as $k => $v) {
-                $call_time = $this->redis->hGet($user_key, $v);
+                    $site_id = $agent_model->getAgentsById($value['agents_id'], 'site_id');
+                    if (empty($site_id)) {
+                        continue;
+                    }
 
-                if ($current_time - $call_time > 3600) {
-                    $array = explode('-', $v);
-                    $follow_where['agent_id'] = $array[0];
-                    $follow_where['user_id'] = $array[1];
-                    if(empty($array[2])){
-                        $this->redis->hDel($user_key, $v);
-                    } else {
-                        $m_follow_up = new UPhoneFollowUpTemporary($array[2]);
-                        $num = $m_follow_up->getFollowTotal($follow_where);
-                        if (empty($num) && !empty($array[1])) {
-                            //$agent_id, $user_id, $content, $type
-                            $m_follow_up->insertDefaultFollow($array[0], $array[1], $content, 0);
-                            $this->redis->hDel($user_key, $v);
-                        }
+                    $follow_model = new UPhoneFollowUpTemporary($site_id);
+                    $follow_where['user_id'] = $value['users_id'];
+                    $follow_where['agent_id'] = $value['agents_id'];
+                    $count = $follow_model->getFollowTotal($follow_where);
+
+                    if (empty($count)) {
+                        $save_follow['user_id'] = $value['users_id'];
+                        $save_follow['agent_id'] = $value['agents_id'];
+                        $save_follow['user_status'] = -1;
+                        $save_follow['type'] = 0;
+                        $save_follow['labels_id'] = 0;
+                        $save_follow['create_time'] = $value['create_time'];
+                        $follow_model->savePhoneFollow($save_follow);
                     }
                 }
             }
         }
-        return;*/
+        return;
     }
 
     /**

application/model/UPhoneFollowUpTemporary.php

@@ -63,6 +63,9 @@ class UPhoneFollowUpTemporary extends BaseModel
         if (isset($params["user_status"])) {
             $arr["user_status"] = $params["user_status"];
         }
+        if (isset($params['create_time'])) {
+            $arr["create_time"] = $params["create_time"];
+        }
 
         if (isset($this->siteId)) {
             switch ($this->siteId) {