diff --git a/admin/application/admin/controller/Wxmessage.php b/admin/application/admin/controller/Wxmessage.php new file mode 100644 index 0000000..201e631 --- /dev/null +++ b/admin/application/admin/controller/Wxmessage.php @@ -0,0 +1,23 @@ +
- +
- +
diff --git a/admin/application/admin/view/firmcustomerfollowuptimelist/edit.html b/admin/application/admin/view/firmcustomerfollowuptimelist/edit.html index 7eaebb9..baf54d4 100755 --- a/admin/application/admin/view/firmcustomerfollowuptimelist/edit.html +++ b/admin/application/admin/view/firmcustomerfollowuptimelist/edit.html @@ -1,7 +1,7 @@
- +
@@ -15,7 +15,7 @@
- +
diff --git a/admin/application/api/logic/MessageLogic.php b/admin/application/api/logic/MessageLogic.php new file mode 100644 index 0000000..5498591 --- /dev/null +++ b/admin/application/api/logic/MessageLogic.php @@ -0,0 +1,34 @@ +$data['appId'], + 'toWxid'=>$data['toWxid'], + 'content'=>$data['content'], + //@的好友，多个英文逗号分隔。群主或管理员@全部的人，则填写'notify@all' + 'ats'=>$data['ats'], + ]; + Tools::log_to_write_txt(['发送文字消息，入参：$post_data'=>$post_data]); + $res = $this->curl_post_json($url, $post_data); + Tools::log_to_write_txt(['发送文字消息，出参：$res'=>$res]); + return $res; + } +} \ No newline at end of file diff --git a/admin/application/index/controller/Tasktimer.php b/admin/application/index/controller/Tasktimer.php index 8c09501..8147c2d 100755 --- a/admin/application/index/controller/Tasktimer.php +++ b/admin/application/index/controller/Tasktimer.php @@ -9,8 +9,12 @@ namespace app\index\controller; +use app\api\logic\MessageLogic; +use app\api\logic\TokenLogic; use think\Controller; +use think\Db; use wanghua\general_utility_tools_php\Mmodel; +use wanghua\general_utility_tools_php\tool\Tools; //定时任务 class Tasktimer extends Controller @@ -19,8 +23,102 @@ class Tasktimer extends Controller //按分钟执行 function runMinutes(){ + //客户回访计划 Mmodel::catchJson(function (){ + //回访记录 + $return_record = Db::table('fa_firmcustomerfollowuprecord') + ->where('status','no') + ->select(); + if(empty($return_record)){ + Tools::log_to_write_txt(['无回访记录计划，无需回访']); + return ''; + } + foreach ($return_record as $k=>$item){ + Tools::log_to_write_txt(['客户回访计划，开始：$item'=>$item]); + $ret = $this->postText($item); + dump($ret); + Tools::log_to_write_txt(['客户回访计划，结束：$res'=>$ret]); + } + + //Tools::log_to_write_txt(['runMinutes，出参：$res'=>$ret]); + //dump($ret); + return ''; }); } + + + /** + * desc：发送文字消息 + * author：wh + * @return array + */ + private function postText($return_record){ + //$firmcustomerfollowuprecord_id = input('firmcustomerfollowuprecord_id',1); + //查询客户 + $cust = Db::table('fa_firmcustomer') + ->where('id',$return_record['firmcustomer_id']) + ->find(); + if(empty($cust)){ + return Tools::set_fail('有回访计划，客户不存在'); + } + //查询客户所绑定的ai客服 + $ai_config = Db::table('fa_aicustomerservice') + ->where('id',$cust['aicustomerservice_ids']) + ->find(); + if(empty($ai_config)){ + return Tools::set_fail('有回访计划，无ai客服服务该客户'); + } + $base_url = $ai_config['server_url']; + //查询回访计划 + $plan = Db::table('fa_firmcustomerfollowuptimelist') + ->where('firmcustomerfollowuprecord_id',$return_record['id']) + ->order('followup_time asc') + ->find(); + if(empty($plan)){ + return Tools::set_fail('该客户没有回访计划'); + } + //记录创建时间 + $create_time = $return_record['create_time']; + $day = (int)$plan['day']; + //在记录创建后的N天N点执行 + $day_time = strtotime($create_time) + ($day * 86400);//N天后 + if($day_time > time()){ + return Tools::set_fail('未到回访时间'); + } + + $date = date('Y-m-d ',$day_time).$plan['followup_time']; + $exc_time = strtotime($date);//最终的执行时间 + + //校验时间是否达到执行计划时间 + if($exc_time > time()){ + return Tools::set_fail('未到计划回访时间'); + } + + $logic = new MessageLogic(); + $logic->setBaseUrl($base_url); + + $tokenArr = (new TokenLogic())->getToken(); + $data = [ + 'appId'=>$tokenArr['appId'], + 'toWxid'=>$cust['rel_wx'], + 'content'=>$return_record['visit_msg'], + //@的好友，多个英文逗号分隔。群主或管理员@全部的人，则填写'notify@all' + 'ats'=>$cust['rel_wx'], + ]; + Tools::log_to_write_txt(['回访客户，开始：$post_data'=>$data]); + $res = $logic->postText($data); + Tools::log_to_write_txt(['回访客户，结束：$res'=>$res]); + + //修改回访记录回访状态 + Db::table('fa_firmcustomerfollowuprecord') + ->where('id',$return_record['id']) + ->update([ + 'status'=>'yes', + 'send_time'=>Tools::get_now_date(), + ]); + + + return Tools::set_ok('发送成功'); + } } \ No newline at end of file diff --git a/admin/public/assets/js/backend/firmcustomerfollowuprecord.js b/admin/public/assets/js/backend/firmcustomerfollowuprecord.js index 12ac9d9..54846c3 100755 --- a/admin/public/assets/js/backend/firmcustomerfollowuprecord.js +++ b/admin/public/assets/js/backend/firmcustomerfollowuprecord.js @@ -134,9 +134,9 @@ define(['jquery', 'bootstrap', 'backend', 'table', 'form'], function ($, undefin let txt = $('#c-hui-fang-yao-dian').val(); // console.log(wx_id); // console.log(e); - // let load_index = layer.load(1); + let load_index = layer.load(1); $.post('ai/talk_skill',{txt:txt},function (res) { - // layer.close(load_index); + layer.close(load_index); //回显 $('#c-visit_msg').val(res.data); },'json'); diff --git a/admin/public/assets/js/backend/firmcustomerfollowuptimelist.js b/admin/public/assets/js/backend/firmcustomerfollowuptimelist.js index d4d199c..f5034c2 100755 --- a/admin/public/assets/js/backend/firmcustomerfollowuptimelist.js +++ b/admin/public/assets/js/backend/firmcustomerfollowuptimelist.js @@ -34,7 +34,7 @@ define(['jquery', 'bootstrap', 'backend', 'table', 'form'], function ($, undefin {checkbox: true}, {field: 'id', title: __('Id'), operate:false}, {field: 'day', title: __('Day'), operate:false}, - {field: 'followup_time', title: __('Followup_time'), operate:false, addclass:'datetimerange', autocomplete:false, formatter: Table.api.formatter.datetime}, + {field: 'followup_time', title: __('Followup_time'), operate:false}, {field: 'firmcustomerfollowuprecord.name', title: __('Firmcustomerfollowuprecord.name'), operate: false, table: table, class: 'autocontent', formatter: Table.api.formatter.content}, {field: 'operate', title: __('Operate'), table: table, events: Table.api.events.operate, formatter: Table.api.formatter.operate} ] diff --git a/admin/public/assets/js/backend/firmfollowuptemplate.js b/admin/public/assets/js/backend/firmfollowuptemplate.js index 7e4627b..6464b0e 100755 --- a/admin/public/assets/js/backend/firmfollowuptemplate.js +++ b/admin/public/assets/js/backend/firmfollowuptemplate.js @@ -77,7 +77,9 @@ define(['jquery', 'bootstrap', 'backend', 'table', 'form'], function ($, undefin add: function () { $('.shi_li_huashu').on('click',function () { let txt = $('#c-main_points').val(); + let index = layer.load(1); $.post('ai/talk_skill',{txt:txt},function (res) { + layer.close(index); $('#c-ai_text').val(res.data); },'json'); });