where('id',$msg['template_id'])->find();
}
else{
$template = Db::name('Template')->where('name',$msg['template_id'])->find();
}
if(empty($template)){
return true;
}
$title_field = 'msg_title_'.$msg['template_field'];
$content_field = 'msg_content_'.$msg['template_field'];
$title = $template[$title_field];
$content = $template[$content_field];
$msg_link = $template['msg_link'];
$data = $msg['content'];
$data['from_user'] = Db::name('Admin')->where('id',$msg['from_uid'])->value('name');
$data['date'] = date('Y-m-d');
if(!isset($data['action_id'])){
$data['action_id'] = 0;
}
foreach ($data as $key => $val) {
$title = str_replace('{' . $key . '}', $val, $title);
$content = str_replace('{' . $key . '}', $val, $content);
}
$wxmsg_link ='';
if(!empty($msg_link)){
$wxmsg_link = str_replace('{action_id}', $data['action_id'], $msg_link);
}
if (!is_array($msg['to_uids'])) {
$users = explode(",", strval($msg['to_uids']));
} else {
$users = $msg['to_uids'];
}
$users = array_unique(array_filter($users));
//组合要发的消息
$send_data = [];
foreach ($users as $key => $value) {
$send_data[] = array(
'to_uid' => $value,//接收人
'action_id' => $data['action_id'],
'title' => $title,
'content' => $content,
'template' => $template['id'],
'create_time' => time()
);
}
$res = Db::name('Msg')->strict(false)->field(true)->insertAll($send_data);
$this->qiyeMessage($users,$title,$content,$wxmsg_link);
} catch (\Exception $e) {
// 处理异常，记录日志或者其他逻辑
// 但不要抛出异常，以免中断主程序流程
}
}
//获取access_token
function get_access_token($corpid,$corpsecret)
{
$url="https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid=$corpid&corpsecret=$corpsecret";
$ch=curl_init();
curl_setopt($ch,CURLOPT_URL,$url);
curl_setopt($ch,CURLOPT_SSL_VERIFYPEER,FALSE);
curl_setopt($ch,CURLOPT_SSL_VERIFYHOST,FALSE);
curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
$output=curl_exec($ch);
curl_close($ch);
$jsoninfo = json_decode($output,true);
return $jsoninfo["access_token"];
}
function qiyeMessage($users,$title,$content,$msg_link)
{
$workchat = get_config('workchat');
if($workchat['workweixin']==false){
return false;
}
$userid = Db::name('Admin')->where([['id','in',$users],['userid','<>','']])->column('userid');
if (empty($userid)) {
return false;
}
$users = implode('|' ,$userid);
$corpid=$workchat['corpid'];
$corpsecret=$workchat['corpsecret'];
$agentid=$workchat['agentid'];
$host=$workchat['host'];
//$message_array =['title'=>$title,'tips'=>$content,'url'=>$msg_link];
//获取access_token
$accesstoken=$this->get_access_token($corpid,$corpsecret);
$url = "https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token=$accesstoken";
$time_str = date('Y年m月d日 H:i:s',time());
$data = array(
'touser' => $users,
'agentid' => $agentid,
'msgtype' => 'textcard',
"textcard" => array(
"title" => $title,
"description" => "".$time_str."
".$content."
点击【详情】可查看详细内容。
",
"url" => $host.$msg_link,
"btntxt"=>"详情"
)
);
$res=curl_post($url,json_encode($data));
$ret= json_decode($res,true);
$errcode = $ret['errcode'];
if ($errcode == 0) {
return true;
} else {
return false;
//echo '消息发送失败，错误码：' . $errcode;
}
}
}