feats

src/main/java/com/yunzhi/marketing/controller/TaChatController.java

@@ -54,6 +54,18 @@ public class TaChatController extends BaseController {
         return taChatService.getChatWithList(openid, pageNumber, pageSize);
     }
 
+    /**
+     * 获取未读消息总数
+     * @param request
+     * @return
+     */
+    @GetMapping("/wx/chat/unReaded")
+    public ResponseBean getChatUnReaded(HttpServletRequest request) {
+        Integer i = taChatService.getChatUnReaded(getPersonId(request));
+
+        return ResponseBean.success(i);
+    }
+
     /**
      * 更新所有消息为已读
      * @param request

src/main/java/com/yunzhi/marketing/service/ITaChatService.java

@@ -22,4 +22,6 @@ public interface ITaChatService extends IService<TaChat> {
     ResponseBean chat(JSONObject taChat);
 
     ResponseBean updateMessageReadedOf(String openid);
+
+    Integer getChatUnReaded(String personId);
 }

src/main/java/com/yunzhi/marketing/service/impl/TaChatServiceImpl.java

@@ -183,6 +183,11 @@ public class TaChatServiceImpl extends ServiceImpl<TaChatMapper, TaChat> impleme
         return ResponseBean.success("");
     }
 
+    @Override
+    public Integer getChatUnReaded(String personId) {
+        return taChatMapper.getAllUnReadMessage(personId);
+    }
+
     private int updateMessageStatus(String from, String to, int status) {
         // 更新所有未读为已读
         UpdateWrapper<TaChat> wrapper = new UpdateWrapper<>();