黑名单发送消息优化2

app/enterprise/model/Message.php

@@ -144,6 +144,20 @@ class Message extends BaseModel
         if ($sendInterval) {
             Cache::set('send_' . $uid, time(), $sendInterval);
         }
+        // 判断是否存在及数据有效性
+        if (isset($param['msg_id']) && is_numeric($param['msg_id'])) {
+            $where = [
+                'msg_id' => $param['msg_id'],
+                'status' => 2,
+                'from_user' => $uid,
+                'to_user' => $param['toContactId'],
+            ];
+            $message = $this->where($where)->find();
+            if (!$message) {
+                $this->error = lang('system.error');
+                return false;
+            }
+        }
         return self::sendMsg($param,$is_group);
     }
 
@@ -212,9 +226,15 @@ class Message extends BaseModel
         if (isset($param['del_user']) && $param['del_user']) {
             $data['del_user'] = $param['del_user'];
             $data['status'] = 2;
+        } else {
+            $data['del_user'] = '';
+            $data['status'] = 1;
         }
         $message=new self();
         $message->update(['is_last'=>0],['chat_identify'=>$chat_identify]);
+        if (isset($param['msg_id'])) {
+            $message = $message->where('msg_id', $param['msg_id'])->find();
+        }
         $message->save($data);
         
         // 拼接消息推送