新增悟空api基础接口

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/WuKongMessageController.java

@@ -0,0 +1,43 @@
+package com.citu.module.menduner.im.controller.app;
+
+import com.citu.framework.common.pojo.CommonResult;
+import com.citu.module.menduner.im.controller.app.base.wukong.ChannelMessageSyncReqVo;
+import com.citu.module.menduner.im.service.wukong.WuKongMessageService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+
+/**
+ * @eo.api-type http
+ * @eo.groupName 新门墩儿.聊天.消息相关
+ * @eo.path /app-api/im
+ */
+@RestController
+@RequestMapping("/im")
+public class WuKongMessageController {
+
+    private WuKongMessageService service;
+
+
+
+    /**
+     * @eo.name 拉取频道消息
+     * @eo.url im/channel/messagesync
+     * @eo.method post
+     * @eo.request-type json
+     * @param reqVo
+     * @return CommonResult
+     */
+    @PostMapping("/im/channel/messagesync")
+    public CommonResult channelMessageSync(@RequestBody ChannelMessageSyncReqVo reqVo){
+      return service.channelMessageSync(reqVo);
+    }
+
+    @Autowired
+    public void setService(WuKongMessageService service) {
+        this.service = service;
+    }
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/WuKongSessionController.java

@@ -0,0 +1,65 @@
+package com.citu.module.menduner.im.controller.app;
+
+import com.citu.framework.common.pojo.CommonResult;
+import com.citu.module.menduner.im.controller.app.base.wukong.ConversationSyncReqVo;
+import com.citu.module.menduner.im.controller.app.base.wukong.ConversationsDeleteReqVo;
+import com.citu.module.menduner.im.service.wukong.WuKongSessionService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @eo.api-type http
+ * @eo.groupName 新门墩儿.聊天.回话相关
+ * @eo.path /app-api/im
+ */
+
+@RestController
+@RequestMapping("/im")
+public class WuKongSessionController {
+
+    WuKongSessionService service;
+
+    /**
+     * @eo.name 同步最近会话
+     * @eo.url /conversation/sync
+     * @eo.method post
+     * @eo.request-type json
+     * @param reqVo
+     * @return CommonResult
+     */
+    @PostMapping("/conversation/sync")
+    public CommonResult conversatioSync(@RequestBody ConversationSyncReqVo reqVo){
+        return  service.conversatioSync(reqVo);
+    }
+
+    /**
+     * @eo.name 删除最近回话
+     * @eo.url /conversation/sync
+     * @eo.method post
+     * @eo.request-type json
+     * @param reqVo
+     * @return CommonResult
+     */
+    @PostMapping("/conversation/delete")
+    public CommonResult conversatioSyncDelete(@RequestBody ConversationsDeleteReqVo reqVo){
+        return service.conversatioSyncDelete(reqVo);
+    }
+
+
+
+    /**
+     * @eo.name setService
+     * @eo.url
+     * @eo.method get
+     * @eo.request-type formdata
+     * @param service
+     * @return void
+     */
+    @Autowired
+    public void setService(WuKongSessionService service) {
+        this.service = service;
+    }
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/WuKongWebhookController.java

@@ -0,0 +1,19 @@
+package com.citu.module.menduner.im.controller.app;
+
+import com.citu.framework.common.pojo.CommonResult;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
+
+@RestController
+public class WuKongWebhookController {
+
+
+//    @PostMapping("/wukong/webhook")
+//    public CommonResult wukongWebhook(@RequestParam("event")String event, @RequestParam Map reqVo){
+//
+//    }
+
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/base/wukong/ChannelMessageSyncReqVo.java

@@ -0,0 +1,104 @@
+package com.citu.module.menduner.im.controller.app.base.wukong;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public class ChannelMessageSyncReqVo {
+
+    /**
+     *  当前登录用户uid,后台自动填充
+     */
+    @JsonProperty("login_uid")
+    private String  loginUid;
+
+    /**
+     * 频道ID
+     */
+    @JsonProperty("channel_id")
+    private String channelId;
+
+    /**
+     * 频道类型
+     */
+    @JsonProperty("channel_type")
+    private Integer channelType;
+
+    /**
+     * 开始消息列号
+     */
+    @JsonProperty("start_message_seq")
+    private Integer startMessageSeq=1;
+
+    /**
+     * 开始消息列号
+     */
+    @JsonProperty("end_message_seq")
+    private Integer endMessageSeq=100;
+
+    /**
+     * 消息数量限制
+     */
+    @JsonProperty("limit")
+    private Integer limit=100;
+
+    /**
+     * 拉取模式 0:向下拉取 1:向上拉取
+     */
+    @JsonProperty("pull_mode")
+    private Integer pullMode=0;
+
+    public String getLoginUid() {
+        return loginUid;
+    }
+
+    public void setLoginUid(String loginUid) {
+        this.loginUid = loginUid;
+    }
+
+    public String getChannelId() {
+        return channelId;
+    }
+
+    public void setChannelId(String channelId) {
+        this.channelId = channelId;
+    }
+
+    public Integer getChannelType() {
+        return channelType;
+    }
+
+    public void setChannelType(Integer channelType) {
+        this.channelType = channelType;
+    }
+
+    public Integer getStartMessageSeq() {
+        return startMessageSeq;
+    }
+
+    public void setStartMessageSeq(Integer startMessageSeq) {
+        this.startMessageSeq = startMessageSeq;
+    }
+
+    public Integer getEndMessageSeq() {
+        return endMessageSeq;
+    }
+
+    public void setEndMessageSeq(Integer endMessageSeq) {
+        this.endMessageSeq = endMessageSeq;
+    }
+
+    public Integer getLimit() {
+        return limit;
+    }
+
+    public void setLimit(Integer limit) {
+        this.limit = limit;
+    }
+
+    public Integer getPullMode() {
+        return pullMode;
+    }
+
+    public void setPullMode(Integer pullMode) {
+        this.pullMode = pullMode;
+    }
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/base/wukong/ChannelMessageSyncResp.java

@@ -0,0 +1,239 @@
+package com.citu.module.menduner.im.controller.app.base.wukong;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.util.List;
+
+public class ChannelMessageSyncResp {
+
+
+    /**
+     * 查询的start_message_seq
+     */
+    @JsonProperty("start_message_seq")
+    private Integer   startMessageSeq=0;
+
+
+
+    /**
+     * 查询的end_message_seq
+     */
+    @JsonProperty("end_message_seq")
+    private Integer   endMessageSeq =100;
+
+    /**
+     * 是否有更多  0.无 1.有
+     */
+    private Integer more=1;
+
+
+    private List<Message> messages;
+
+
+
+    class Message {
+        private  MessageHeader header;
+        /**
+         * 消息设置 消息设置是一个 uint8的数字类型 为1个字节，完全由第三方自定义 比如定义第8位为已读未读回执标记，开启则为0000 0001 = 1
+         */
+         private Integer  setting;
+
+        /**
+         *  消息全局唯一ID
+         */
+        @JsonProperty("message_id")
+         private Long messageId;
+
+        /**
+         * 客户端消息编号，可用此字段去重
+         */
+        @JsonProperty("client_msg_no")
+        private String clientMsgNo;
+        /**
+         *  消息序列号 （用户唯一，有序递增）
+         */
+        @JsonProperty("message_seq")
+        private String messageSeq;
+
+        /**
+         * 发送者用户id
+         */
+        @JsonProperty("from_uid")
+        private String fromUid;
+        /**
+         * 频道ID
+         */
+        @JsonProperty("channel_id")
+        private String channelId;
+        /**
+         * 频道类型 1.个人频道 2.群频道
+         */
+        @JsonProperty("channel_type")
+        private Integer channelType;
+        /**
+         * 消息10位到秒的时间戳
+         */
+        @JsonProperty("timestamp")
+        private Long timestamp;
+        /**
+         * base64编码的消息内容
+         */
+        @JsonProperty("payload")
+        private String payload;
+
+        public MessageHeader getHeader() {
+            return header;
+        }
+
+        public void setHeader(MessageHeader header) {
+            this.header = header;
+        }
+
+        public Integer getSetting() {
+            return setting;
+        }
+
+        public void setSetting(Integer setting) {
+            this.setting = setting;
+        }
+
+        public Long getMessageId() {
+            return messageId;
+        }
+
+        public void setMessageId(Long messageId) {
+            this.messageId = messageId;
+        }
+
+        public String getClientMsgNo() {
+            return clientMsgNo;
+        }
+
+        public void setClientMsgNo(String clientMsgNo) {
+            this.clientMsgNo = clientMsgNo;
+        }
+
+        public String getMessageSeq() {
+            return messageSeq;
+        }
+
+        public void setMessageSeq(String messageSeq) {
+            this.messageSeq = messageSeq;
+        }
+
+        public String getFromUid() {
+            return fromUid;
+        }
+
+        public void setFromUid(String fromUid) {
+            this.fromUid = fromUid;
+        }
+
+        public String getChannelId() {
+            return channelId;
+        }
+
+        public void setChannelId(String channelId) {
+            this.channelId = channelId;
+        }
+
+        public Integer getChannelType() {
+            return channelType;
+        }
+
+        public void setChannelType(Integer channelType) {
+            this.channelType = channelType;
+        }
+
+        public Long getTimestamp() {
+            return timestamp;
+        }
+
+        public void setTimestamp(Long timestamp) {
+            this.timestamp = timestamp;
+        }
+
+        public String getPayload() {
+            return payload;
+        }
+
+        public void setPayload(String payload) {
+            this.payload = payload;
+        }
+    }
+    class  MessageHeader {
+        /**
+         * 否不存储消息 0.存储 1.不存储
+         */
+        @JsonProperty("no_persist")
+        private Integer noPersist;
+
+        /**
+         * 是否显示红点计数，0.不显示 1.显示
+         */
+        @JsonProperty("red_dot")
+        private Integer redDot;
+
+        /**
+         * 否是写扩散，这里一般是0，只有cmd消息才是1
+         */
+        @JsonProperty("sync_once")
+        private Integer syncOnce;
+
+        public Integer getNoPersist() {
+            return noPersist;
+        }
+
+        public void setNoPersist(Integer noPersist) {
+            this.noPersist = noPersist;
+        }
+
+        public Integer getRedDot() {
+            return redDot;
+        }
+
+        public void setRedDot(Integer redDot) {
+            this.redDot = redDot;
+        }
+
+        public Integer getSyncOnce() {
+            return syncOnce;
+        }
+
+        public void setSyncOnce(Integer syncOnce) {
+            this.syncOnce = syncOnce;
+        }
+    }
+
+    public Integer getStartMessageSeq() {
+        return startMessageSeq;
+    }
+
+    public void setStartMessageSeq(Integer startMessageSeq) {
+        this.startMessageSeq = startMessageSeq;
+    }
+
+    public Integer getEndMessageSeq() {
+        return endMessageSeq;
+    }
+
+    public void setEndMessageSeq(Integer endMessageSeq) {
+        this.endMessageSeq = endMessageSeq;
+    }
+
+    public Integer getMore() {
+        return more;
+    }
+
+    public void setMore(Integer more) {
+        this.more = more;
+    }
+
+    public List<Message> getMessages() {
+        return messages;
+    }
+
+    public void setMessages(List<Message> messages) {
+        this.messages = messages;
+    }
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/base/wukong/ConversationSyncReqVo.java

@@ -0,0 +1,41 @@
+package com.citu.module.menduner.im.controller.app.base.wukong;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public class ConversationSyncReqVo {
+
+    private String uid;
+
+    private String version;
+
+
+//    private String last_msg_seqs;
+
+    @JsonProperty("msg_count")
+    private Integer msgCount=50;
+
+
+    public String getUid() {
+        return uid;
+    }
+
+    public void setUid(String uid) {
+        this.uid = uid;
+    }
+
+    public String getVersion() {
+        return version;
+    }
+
+    public void setVersion(String version) {
+        this.version = version;
+    }
+
+    public Integer getMsgCount() {
+        return msgCount;
+    }
+
+    public void setMsgCount(Integer msgCount) {
+        this.msgCount = msgCount;
+    }
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/base/wukong/ConversationSyncRespVo.java

@@ -0,0 +1,123 @@
+package com.citu.module.menduner.im.controller.app.base.wukong;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.util.List;
+import java.util.Map;
+
+public class ConversationSyncRespVo {
+
+    /**
+     * 频道ID
+     */
+    @JsonProperty("channel_id")
+    private String channelId;
+
+    /**
+     *  频道类型 1.单聊 2.群聊 3.客服
+     */
+    @JsonProperty("channel_type")
+
+    private String channelType;
+
+    /**
+     * 消息未读数量
+     */
+    @JsonProperty("unread")
+
+    private String unread;
+
+    /**
+     * 10位到秒的时间戳;
+     */
+    @JsonProperty("timestamp")
+
+    private Long  timestamp ;
+
+    /**
+     * last_msg_seq
+     */
+    @JsonProperty("last_msg_seq")
+
+    private Integer lastMsgSeq;
+
+    /**
+     * 最后一条消息的客户端消息编号
+     */
+    @JsonProperty("last_client_msg_no")
+
+    private String lastClientMsgNo;
+    /**
+     * 数据版本编号
+     */
+     private String       version;
+    /**
+     * 最近消息
+     */
+    private List<Map> recents;
+
+
+    public String getChannelId() {
+        return channelId;
+    }
+
+    public void setChannelId(String channelId) {
+        this.channelId = channelId;
+    }
+
+    public String getChannelType() {
+        return channelType;
+    }
+
+    public void setChannelType(String channelType) {
+        this.channelType = channelType;
+    }
+
+    public String getUnread() {
+        return unread;
+    }
+
+    public void setUnread(String unread) {
+        this.unread = unread;
+    }
+
+    public Long getTimestamp() {
+        return timestamp;
+    }
+
+    public void setTimestamp(Long timestamp) {
+        this.timestamp = timestamp;
+    }
+
+    public Integer getLastMsgSeq() {
+        return lastMsgSeq;
+    }
+
+    public void setLastMsgSeq(Integer lastMsgSeq) {
+        this.lastMsgSeq = lastMsgSeq;
+    }
+
+    public String getLastClientMsgNo() {
+        return lastClientMsgNo;
+    }
+
+    public void setLastClientMsgNo(String lastClientMsgNo) {
+        this.lastClientMsgNo = lastClientMsgNo;
+    }
+
+    public String getVersion() {
+        return version;
+    }
+
+    public void setVersion(String version) {
+        this.version = version;
+    }
+
+    public List<Map> getRecents() {
+        return recents;
+    }
+
+    public void setRecents(List<Map> recents) {
+        this.recents = recents;
+    }
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/base/wukong/ConversationsDeleteReqVo.java

@@ -0,0 +1,42 @@
+package com.citu.module.menduner.im.controller.app.base.wukong;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public class ConversationsDeleteReqVo {
+
+    /**
+     * 此参数不用传
+     */
+    private String uid;
+
+    @JsonProperty("channel_id")
+    private String channelId;
+
+    @JsonProperty("channel_type")
+    private Integer channelType;
+
+
+    public String getUid() {
+        return uid;
+    }
+
+    public void setUid(String uid) {
+        this.uid = uid;
+    }
+
+    public String getChannelId() {
+        return channelId;
+    }
+
+    public void setChannelId(String channelId) {
+        this.channelId = channelId;
+    }
+
+    public Integer getChannelType() {
+        return channelType;
+    }
+
+    public void setChannelType(Integer channelType) {
+        this.channelType = channelType;
+    }
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/base/wukong/WukongEventBaseVo.java

@@ -0,0 +1,31 @@
+package com.citu.module.menduner.im.controller.app.base.wukong;
+
+import java.time.LocalDateTime;
+
+public class WukongEventBaseVo {
+
+    /**
+     * 事件名称
+     */
+    private String eventName;
+
+
+
+    private LocalDateTime eventTime=LocalDateTime.now();
+
+    public String getEventName() {
+        return eventName;
+    }
+
+    public void setEventName(String eventName) {
+        this.eventName = eventName;
+    }
+
+    public LocalDateTime getEventTime() {
+        return eventTime;
+    }
+
+    public void setEventTime(LocalDateTime eventTime) {
+        this.eventTime = eventTime;
+    }
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/controller/app/base/wukong/WukongOnlineStatusEventVo.java

@@ -0,0 +1,7 @@
+package com.citu.module.menduner.im.controller.app.base.wukong;
+
+public class WukongOnlineStatusEventVo extends WukongEventBaseVo{
+
+
+
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/service/UserService.java

@@ -6,4 +6,6 @@ import com.citu.module.menduner.im.controller.app.base.user.ImUserResoVO;
 
 public interface UserService {
     CommonResult<ImUserResoVO> getUser(ImUserReqVo reqVo);
+
+    String getCurrentLoginUid();
 }

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/service/UserServiceImpl.java

@@ -55,7 +55,29 @@ public class UserServiceImpl implements UserService{
         return CommonResult.success(imUserResoVO);
     }
 
+    @Override
+    public String getCurrentLoginUid() {
+
+        Long userLoginId = LoginUserContext.getUserId();
+        UserDO userDO = mapper.selectById(userLoginId);
 
+        if(null == userDO){
+            // 开始注册
+            userDO =new UserDO();
+            userDO.setCreateTime(LocalDateTime.now());
+            userDO.setUpdateTime(LocalDateTime.now());
+            userDO.setUserId(userLoginId);
+            userDO.setToken(IdUtil.fastSimpleUUID());
+            userDO.setUid(IdUtil.fastSimpleUUID());
+            mapper.insert(userDO);
+            CommonResult<Boolean> booleanCommonResult = wuKongUserService.userToken(userDO.getUid(), userDO.getToken());
+            if(!booleanCommonResult.isSuccess()){
+//                 throw new Exception("系统异常!"); //todo
+            }
+        }
+
+        return userDO.getUid();
+    }
 
 
     @Autowired

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/service/wukong/WuKongApiService.java

@@ -1,8 +1,7 @@
 package com.citu.module.menduner.im.service.wukong;
 
 
-import com.citu.module.menduner.im.controller.app.base.wukong.UserTokenReqVO;
-import com.citu.module.menduner.im.controller.app.base.wukong.WukongApiResp;
+import com.citu.module.menduner.im.controller.app.base.wukong.*;
 //import com.citu.module.menduner.im.interceptor.WuKongWuKongApiInterceptor;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -18,4 +17,18 @@ public interface WuKongApiService {
 
     @PostMapping("/user/onlinestatus")
     public  List<String> userOnlinestatus(@RequestBody List<String> uids );
+
+
+    @PostMapping("/conversation/sync")
+    public List<ConversationSyncRespVo> conversationSync(@RequestBody ConversationSyncReqVo reqVo);
+
+
+    @PostMapping("/conversations/delete")
+    public WukongApiResp conversationsDelete(@RequestBody ConversationsDeleteReqVo reqVO);
+
+
+    @PostMapping("/channel/messagesync")
+    public ChannelMessageSyncResp channelMessageSync(@RequestBody ChannelMessageSyncReqVo reqVo);
+
+
 }

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/service/wukong/WuKongMessageService.java

@@ -0,0 +1,8 @@
+package com.citu.module.menduner.im.service.wukong;
+
+import com.citu.framework.common.pojo.CommonResult;
+import com.citu.module.menduner.im.controller.app.base.wukong.ChannelMessageSyncReqVo;
+
+public interface WuKongMessageService {
+    CommonResult channelMessageSync(ChannelMessageSyncReqVo reqVo);
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/service/wukong/WuKongMessageServiceImpl.java

@@ -0,0 +1,36 @@
+package com.citu.module.menduner.im.service.wukong;
+
+import com.citu.framework.common.pojo.CommonResult;
+import com.citu.module.menduner.im.controller.app.base.wukong.ChannelMessageSyncReqVo;
+import com.citu.module.menduner.im.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class WuKongMessageServiceImpl implements WuKongMessageService{
+
+    UserService userService;
+
+    WuKongApiService wuKongApiService;
+
+
+
+    @Override
+    public CommonResult channelMessageSync(ChannelMessageSyncReqVo reqVo) {
+        String currentLoginUid = userService.getCurrentLoginUid();
+        reqVo.setLoginUid(currentLoginUid);
+        return CommonResult.success(wuKongApiService.channelMessageSync(reqVo));
+    }
+
+    @Autowired
+    public void setWuKongApiService(WuKongApiService wuKongApiService) {
+        this.wuKongApiService = wuKongApiService;
+    }
+
+    @Autowired
+    public void setUserService(UserService userService) {
+        this.userService = userService;
+    }
+
+
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/service/wukong/WuKongSessionService.java

@@ -0,0 +1,11 @@
+package com.citu.module.menduner.im.service.wukong;
+
+import com.citu.framework.common.pojo.CommonResult;
+import com.citu.module.menduner.im.controller.app.base.wukong.ConversationSyncReqVo;
+import com.citu.module.menduner.im.controller.app.base.wukong.ConversationsDeleteReqVo;
+
+public interface WuKongSessionService {
+    CommonResult conversatioSync(ConversationSyncReqVo reqVo);
+
+    CommonResult conversatioSyncDelete(ConversationsDeleteReqVo reqVo);
+}

menduner/menduner-im-biz/src/main/java/com/citu/module/menduner/im/service/wukong/WuKongSessionServiceImpl.java

@@ -0,0 +1,40 @@
+package com.citu.module.menduner.im.service.wukong;
+
+import com.citu.framework.common.pojo.CommonResult;
+import com.citu.module.menduner.im.controller.app.base.wukong.ConversationSyncReqVo;
+import com.citu.module.menduner.im.controller.app.base.wukong.ConversationsDeleteReqVo;
+import com.citu.module.menduner.im.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class WuKongSessionServiceImpl implements WuKongSessionService{
+
+    WuKongApiService wuKongApiService;
+
+    UserService userService;
+
+
+    @Override
+    public CommonResult conversatioSync(ConversationSyncReqVo reqVo) {
+         String uid  =  userService.getCurrentLoginUid();
+        return CommonResult.success(wuKongApiService.conversationSync(reqVo));
+    }
+
+    @Override
+    public CommonResult conversatioSyncDelete(ConversationsDeleteReqVo reqVo) {
+        String uid  =  userService.getCurrentLoginUid();
+        reqVo.setUid(uid);
+        return CommonResult.success(wuKongApiService.conversationsDelete(reqVo));
+    }
+
+    @Autowired
+    public void setUserService(UserService userService) {
+        this.userService = userService;
+    }
+
+    @Autowired
+    public void setWuKongApiService(WuKongApiService wuKongApiService) {
+        this.wuKongApiService = wuKongApiService;
+    }
+}