消息接收数据

Server/application/chukebao/controller/DataProcessing.php

@@ -4,6 +4,8 @@ namespace app\chukebao\controller;
 
 use library\ResponseHelper;
 use app\api\model\WechatFriendModel;
+use app\api\controller\MessageController;
+
 
 class DataProcessing extends BaseController
 {
@@ -20,11 +22,17 @@ class DataProcessing extends BaseController
         $labels = $this->request->param('labels', []);
         //微信群
         $wechatChatroomId = $this->request->param('wechatChatroomId', '');
+
+        //新消息
+        $friendMessage = $this->request->param('friendMessage', '');
+        $chatroomMessage = $this->request->param('chatroomMessage', '');
+
         $typeData = [
             'CmdModifyFriendRemark', //好友修改备注  {newRemark、wechatAccountId、wechatFriendId}
             'CmdModifyFriendLabel', //好友修改标签  {labels、wechatAccountId、wechatFriendId}
             'CmdAllotFriend', //转让好友  {labels、wechatAccountId、wechatFriendId}
             'CmdChatroomOperate', //修改群信息  {chatroomName（群名）、announce（公告）、extra（公告）、wechatAccountId、wechatChatroomId}
+            'CmdNewMessage', //接收消息
         ];
 
         if (empty($type) || empty($wechatAccountId)) {
@@ -76,6 +84,26 @@ class DataProcessing extends BaseController
                 $friend->save();
                 $msg = '好友转移成功';
                 break;
+            case 'CmdNewMessage':
+                if(empty($friendMessage) || empty($chatroomMessage)){
+                    return ResponseHelper::error('参数缺失');
+                }
+
+                if(is_array($friendMessage) || is_array($chatroomMessage)){
+                    return ResponseHelper::error('参数缺失');
+                }
+
+                $messageController = new MessageController();
+                if (!empty($friendMessage)){
+                    $res = $messageController->saveMessage($friendMessage);
+                }else{
+                    $res = $messageController->saveChatroomMessage($friendMessage);
+                }
+                if (!empty($res)){
+                    $msg = '消息记录成功';
+                }else{
+                    $msg = '消息记录失败';
+                }
         }
         return ResponseHelper::success('',$msg);
     }