143 lines
4.5 KiB
PHP
Executable File
143 lines
4.5 KiB
PHP
Executable File
<?php
|
||
/*
|
||
* description：
|
||
* author：wh
|
||
* email：
|
||
* createTime：{2025/3/24} {17:23}
|
||
*/
|
||
|
||
namespace app\index\controller;
|
||
|
||
|
||
use app\api\logic\MessageLogic;
|
||
use app\api\logic\PyappLofic;
|
||
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
|
||
{
|
||
|
||
/**
|
||
* desc：按分钟执行
|
||
* author：wh
|
||
*
|
||
*/
|
||
function runMinutes(){
|
||
|
||
//客户回访计划
|
||
Mmodel::catch(function (){
|
||
$this->returnPlan();
|
||
});
|
||
}
|
||
|
||
/**
|
||
* desc：客户回访计划
|
||
* author：wh
|
||
* @return string
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
*/
|
||
function returnPlan(){
|
||
//回访记录
|
||
$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);//最终的执行时间
|
||
|
||
//dump(date('Y-m-d H:i:s',$exc_time));
|
||
//校验时间是否达到执行计划时间
|
||
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_group'],//是群则发送群消息,否则发个人私人消息
|
||
'content'=>"@".$cust['wx_nickname']." ".$return_record['visit_msg'],
|
||
//@的好友，多个英文逗号分隔。群主或管理员@全部的人，则填写'notify@all'
|
||
'ats'=>$cust['rel_wx'],
|
||
];
|
||
Tools::log_to_write_txt(['回访客户，开始：$post_data'=>$data]);
|
||
$res = $logic->postGroupText($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(),
|
||
]);
|
||
|
||
//设置AI客服回访模式
|
||
(new PyappLofic())->setFollowupModel($cust['rel_group'],$return_record['visit_msg']);
|
||
|
||
return Tools::set_ok('发送成功');
|
||
}
|
||
} |