新增最近回话未读数量

citu-gateway/src/main/java/com/citu/gateway/util/BannerApplicationRunner.java

@@ -19,33 +19,33 @@ public class BannerApplicationRunner implements ApplicationRunner {
 
     @Override
     public void run(ApplicationArguments args) {
-        ThreadUtil.execute(() -> {
-            ThreadUtil.sleep(1, TimeUnit.SECONDS); // 延迟 1 秒，保证输出到结尾
-            log.info("\n----------------------------------------------------------\n\t" +
-                            "项目启动成功！\n\t" +
-                            "接口文档: \t{} \n\t" +
-                            "开发文档: \t{} \n\t" +
-                            "视频教程: \t{} \n" +
-                            "----------------------------------------------------------",
-                    "https://cloud.iocoder.cn/api-doc/",
-                    "https://cloud.iocoder.cn",
-                    "https://t.zsxq.com/02Yf6M7Qn");
-
-            // 数据报表
-            System.out.println("[报表模块 citu-module-report 教程][参考 https://cloud.iocoder.cn/report/ 开启]");
-            // 工作流
-            System.out.println("[工作流模块 citu-module-bpm 教程][参考 https://cloud.iocoder.cn/bpm/ 开启]");
-            // 商城系统
-            System.out.println("[商城系统 citu-module-mall 教程][参考 https://cloud.iocoder.cn/mall/build/ 开启]");
-            // ERP 系统
-            System.out.println("[ERP 系统 citu-module-erp - 教程][参考 https://cloud.iocoder.cn/erp/build/ 开启]");
-            // CRM 系统
-            System.out.println("[CRM 系统 citu-module-crm - 教程][参考 https://cloud.iocoder.cn/crm/build/ 开启]");
-            // 微信公众号
-            System.out.println("[微信公众号 citu-module-mp 教程][参考 https://cloud.iocoder.cn/mp/build/ 开启]");
-            // 支付平台
-            System.out.println("[支付系统 citu-module-pay - 教程][参考 https://doc.iocoder.cn/pay/build/ 开启]");
-        });
+//        ThreadUtil.execute(() -> {
+//            ThreadUtil.sleep(1, TimeUnit.SECONDS); // 延迟 1 秒，保证输出到结尾
+//            log.info("\n----------------------------------------------------------\n\t" +
+//                            "项目启动成功！\n\t" +
+//                            "接口文档: \t{} \n\t" +
+//                            "开发文档: \t{} \n\t" +
+//                            "视频教程: \t{} \n" +
+//                            "----------------------------------------------------------",
+//                    "https://cloud.iocoder.cn/api-doc/",
+//                    "https://cloud.iocoder.cn",
+//                    "https://t.zsxq.com/02Yf6M7Qn");
+//
+//            // 数据报表
+//            System.out.println("[报表模块 citu-module-report 教程][参考 https://cloud.iocoder.cn/report/ 开启]");
+//            // 工作流
+//            System.out.println("[工作流模块 citu-module-bpm 教程][参考 https://cloud.iocoder.cn/bpm/ 开启]");
+//            // 商城系统
+//            System.out.println("[商城系统 citu-module-mall 教程][参考 https://cloud.iocoder.cn/mall/build/ 开启]");
+//            // ERP 系统
+//            System.out.println("[ERP 系统 citu-module-erp - 教程][参考 https://cloud.iocoder.cn/erp/build/ 开启]");
+//            // CRM 系统
+//            System.out.println("[CRM 系统 citu-module-crm - 教程][参考 https://cloud.iocoder.cn/crm/build/ 开启]");
+//            // 微信公众号
+//            System.out.println("[微信公众号 citu-module-mp 教程][参考 https://cloud.iocoder.cn/mp/build/ 开启]");
+//            // 支付平台
+//            System.out.println("[支付系统 citu-module-pay - 教程][参考 https://doc.iocoder.cn/pay/build/ 开启]");
+//        });
     }
 
 }

citu-gateway/src/main/resources/banner.txt

@@ -1,17 +1,4 @@
-芋道源码 http://www.iocoder.cn
+
 Application Version: ${citu.info.version}
 Spring Boot Version: ${spring-boot.version}
 
-.__   __.   ______      .______    __    __    _______
-|  \ |  |  /  __  \     |   _  \  |  |  |  |  /  _____|
-|   \|  | |  |  |  |    |  |_)  | |  |  |  | |  |  __
-|  . `  | |  |  |  |    |   _  <  |  |  |  | |  | |_ |
-|  |\   | |  `--'  |    |  |_)  | |  `--'  | |  |__| |
-|__| \__|  \______/     |______/   \______/   \______|
-
-███╗   ██╗ ██████╗     ██████╗ ██╗   ██╗ ██████╗
-████╗  ██║██╔═══██╗    ██╔══██╗██║   ██║██╔════╝
-██╔██╗ ██║██║   ██║    ██████╔╝██║   ██║██║  ███╗
-██║╚██╗██║██║   ██║    ██╔══██╗██║   ██║██║   ██║
-██║ ╚████║╚██████╔╝    ██████╔╝╚██████╔╝╚██████╔╝
-╚═╝  ╚═══╝ ╚═════╝     ╚═════╝  ╚═════╝  ╚═════╝

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

@@ -4,6 +4,7 @@ import com.citu.framework.common.pojo.CommonResult;
 import com.citu.framework.security.core.annotations.PreAuthenticated;
 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.controller.app.base.wukong.ConversationsUnreadReqVo;
 import com.citu.module.menduner.im.service.wukong.WuKongSessionService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -52,6 +53,22 @@ public class WuKongSessionController {
     }
 
 
+    /**
+     * @eo.name 设置最近会话未读数量
+     * @eo.urlconversations/setUnread
+     * @eo.method post
+     * @eo.request-type json
+     * @param reqVo
+     * @return CommonResult
+     */
+    @PreAuthenticated
+    @PostMapping("/conversations/setUnread")
+    public CommonResult conversatioSetUnread(@RequestBody ConversationsUnreadReqVo reqVo){
+        return service.conversatioSetUnread(reqVo);
+    }
+
+
+
 
     /**
      * @eo.name setService

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

@@ -0,0 +1,58 @@
+package com.citu.module.menduner.im.controller.app.base.wukong;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+public class ConversationsUnreadReqVo {
+
+    private Long enterpriseId;
+    private String uid;
+
+    @JsonProperty("channel_id")
+    private String channelId;
+
+    @JsonProperty("channelType")
+    private Integer channelType;
+
+    private Integer unread;
+
+
+    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;
+    }
+
+    public Integer getUnread() {
+        return unread;
+    }
+
+    public void setUnread(Integer unread) {
+        this.unread = unread;
+    }
+
+    public Long getEnterpriseId() {
+        return enterpriseId;
+    }
+
+    public void setEnterpriseId(Long enterpriseId) {
+        this.enterpriseId = enterpriseId;
+    }
+}

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

@@ -30,5 +30,8 @@ public interface WuKongApiService {
     @PostMapping("/channel/messagesync")
     public ChannelMessageSyncResp channelMessageSync(@RequestBody ChannelMessageSyncReqVo reqVo);
 
+    @PostMapping("/conversations/setUnread")
+    public WukongApiResp   conversationsSetUnread(@RequestBody ConversationsUnreadReqVo reqVo);
+
 
 }

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

@@ -3,9 +3,12 @@ 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.controller.app.base.wukong.ConversationsUnreadReqVo;
 
 public interface WuKongSessionService {
     CommonResult conversatioSync(ConversationSyncReqVo reqVo);
 
     CommonResult conversatioSyncDelete(ConversationsDeleteReqVo reqVo);
+
+    CommonResult conversatioSetUnread(ConversationsUnreadReqVo reqVo);
 }

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

@@ -7,6 +7,7 @@ import com.citu.module.menduner.im.controller.app.base.user.ImUserResoVO;
 import com.citu.module.menduner.im.controller.app.base.wukong.ConversationSyncReqVo;
 import com.citu.module.menduner.im.controller.app.base.wukong.ConversationSyncRespVo;
 import com.citu.module.menduner.im.controller.app.base.wukong.ConversationsDeleteReqVo;
+import com.citu.module.menduner.im.controller.app.base.wukong.ConversationsUnreadReqVo;
 import com.citu.module.menduner.im.service.UserService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -49,6 +50,13 @@ public class WuKongSessionServiceImpl implements WuKongSessionService{
         return CommonResult.success(wuKongApiService.conversationsDelete(reqVo));
     }
 
+    @Override
+    public CommonResult conversatioSetUnread(ConversationsUnreadReqVo reqVo) {
+        String uid  =  userService.getCurrentLoginUid(reqVo.getEnterpriseId());
+        reqVo.setUid(uid);
+        return CommonResult.success(wuKongApiService.conversationsSetUnread(reqVo));
+    }
+
     @Autowired
     public void setUserService(UserService userService) {
         this.userService = userService;