后台添加IM接口

xx-im/xx-im-server/src/main/java/com/xxfc/platform/im/biz/MsgBiz.java

@@ -384,8 +384,24 @@ public class MsgBiz {
             UpdateResult updateResult = mongoTemplate.updateFirst(query, update, MusicInfo.class, "musicInfo");
             log.info("修改音乐使用次数： updateResult = {}", updateResult);
         }
+    }
 
-
+    //修改消息信息
+    public ObjectRestResponse update(Msg msg) {
+        if (msg == null || msg.getId() == null) {
+            return ObjectRestResponse.paramIsEmpty();
+        }
+        Query query = new Query(Criteria.where("_id").is(msg.getId()));
+        Msg oldValue = mongoTemplate.findOne(query, Msg.class, "s_msg");
+        if (oldValue == null) {
+            return ObjectRestResponse.createFailedResult(ResultCode.IM_MSG_NOT_EXIST_CODE, ResultCode.getMsg(ResultCode.IM_MSG_NOT_EXIST_CODE));
+        }
+        BeanUtil.copyProperties(msg, oldValue, CopyOptions.create().setIgnoreNullValue(true).setIgnoreError(true));
+        Msg newValue = mongoTemplate.save(oldValue, "s_msg");
+        if(newValue == null) {
+            return ObjectRestResponse.createFailedResult(ResultCode.FAILED_CODE, "更新失败");
+        }
+        return ObjectRestResponse.succ(newValue);
     }
 
 }

xx-im/xx-im-server/src/main/java/com/xxfc/platform/im/rest/MsgController.java

@@ -3,6 +3,7 @@ package com.xxfc.platform.im.rest;
 import com.github.wxiaoqi.security.common.msg.ObjectRestResponse;
 import com.xxfc.platform.im.biz.MsgBiz;
 import com.xxfc.platform.im.model.AddMsgParam;
+import com.xxfc.platform.im.model.Msg;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -44,4 +45,9 @@ public class MsgController {
     public ObjectRestResponse addMsg(@RequestBody AddMsgParam param) {
         return ObjectRestResponse.succ(msgBiz.add(param));
     }
+
+    @PostMapping(value = "/bg/app/unauth/update")
+    public ObjectRestResponse updateMsg(@RequestBody Msg msg) {
+        return msgBiz.update(msg);
+    }
 }