$admin) { InformAdminClass::addInform($params, $admin, $type, $TMList); } } //消费通知内容 shish 2020.1.1 public static function consumeInformQueue($data) { //['messageType'=>'inform','informWay'=>'wx','userType'=>'admin','id'=>1,'mobile'=>'15280215347','tMessage'=>'','content'=>'','briefContent'=>''] $informWay = $data['informWay']; $id = $data['id']; $admin = AdminService::getAdminById($id); $merchantId = $admin['merchantId']; $mobile = $data['mobile']; $merchant = MerchantService::getMerchantById($merchantId); $hasSend = 0; $noticeWay = 0; if ($informWay == 'wx') { $tMessage = json_decode($data['tMessage'], true); $r = wxUtil::sendTaskInform($tMessage, $merchant); print_r($r); $hasSend = 1; $noticeWay = 0; } if ($informWay == 'sms') { $msg = $data['content']; sms::merchantSend($mobile, $msg, $merchant); $hasSend = 1; $noticeWay = 1; } //存入数据库 $informData = [ 'userId' => $admin['userId'], 'adminId' => $id, 'merchantId' => $merchantId, 'noticeType' => 0, 'content' => $data['briefContent'], 'noticeWay' => $noticeWay, 'status' => $hasSend, 'sourceType' => 0, 'sourceId' => 0, 'addTime' => time(), 'createTime' => date("Y-m-d H:i:s"), ]; InformAdminClass::addData($informData); return true; } }