From 54bc6913ede1bcae727f7b1c89b7aa9efc3ea7fd Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Fri, 20 Aug 2021 17:05:16 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90=E5=8F=91=E9=80=81=E6=B6=88=E6=81=AF?=
 =?UTF-8?q?=E3=80=91=E6=88=91=E6=94=B6=E5=88=B0=E3=80=81=E6=88=91=E5=8F=91?=
 =?UTF-8?q?=E9=80=81=E7=BA=A2=E7=82=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../message/result/InfoRedDotResultDTO.java   |  5 +++--
 .../dao/epmetmessage/InfoReceiversDao.java    | 16 ++++++++++++++
 .../impl/EpmetMessageServiceImpl.java         |  5 ++++-
 .../mapper/epmetmessage/InfoReceiversDao.xml  | 21 +++++++++++++++++++
 4 files changed, 44 insertions(+), 3 deletions(-)

diff --git a/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/InfoRedDotResultDTO.java b/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/InfoRedDotResultDTO.java
index ce159b6a33..40f96878c5 100644
--- a/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/InfoRedDotResultDTO.java
+++ b/epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/message/result/InfoRedDotResultDTO.java
@@ -1,5 +1,6 @@
 package com.epmet.dataaggre.dto.message.result;
 
+import com.epmet.commons.tools.constant.NumConstant;
 import lombok.Data;
 
 import java.io.Serializable;
@@ -17,10 +18,10 @@ public class InfoRedDotResultDTO implements Serializable {
     /**
      * 我发出的，新回复数量
      */
-    private Integer sentNewReplyCount;
+    private Integer sentNewReplyCount = NumConstant.ZERO;
 
     /**
      * 我收到的未读的消息数量
      */
-    private Integer receivedUnReadCount;
+    private Integer receivedUnReadCount = NumConstant.ZERO;
 }
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/epmetmessage/InfoReceiversDao.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/epmetmessage/InfoReceiversDao.java
index c0d8b4c86d..5d232ffe09 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/epmetmessage/InfoReceiversDao.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/dao/epmetmessage/InfoReceiversDao.java
@@ -90,4 +90,20 @@ public interface InfoReceiversDao extends BaseDao<InfoReceiversEntity> {
      * @date 2021/8/20 2:31 下午
      */
     List<FileCommonDTO> selectReplyAtt(String replyId);
+
+    /**
+     * @Description  查询我收到的未读的消息数量
+     * @Param userId
+     * @author zxc
+     * @date 2021/8/20 4:16 下午
+     */
+    Integer selectUnReadCount(@Param("userId") String userId);
+
+    /**
+     * @Description  我发出的，新回复数量
+     * @Param userId
+     * @author zxc
+     * @date 2021/8/20 4:20 下午
+     */
+    Integer selectNewReplyCount(@Param("userId") String userId);
 }
\ No newline at end of file
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java
index 6d1c3ff183..69ebdbb38d 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetmessage/impl/EpmetMessageServiceImpl.java
@@ -187,7 +187,10 @@ public class EpmetMessageServiceImpl implements EpmetMessageService {
      */
     @Override
     public InfoRedDotResultDTO redDot(String userId) {
-        return null;
+        InfoRedDotResultDTO result = new InfoRedDotResultDTO();
+        result.setReceivedUnReadCount(infoReceiversDao.selectUnReadCount(userId));
+        result.setSentNewReplyCount(infoReceiversDao.selectNewReplyCount(userId));
+        return result;
     }
 
 
diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoReceiversDao.xml b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoReceiversDao.xml
index 179b3469fd..bd57d3da72 100644
--- a/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoReceiversDao.xml
+++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/epmetmessage/InfoReceiversDao.xml
@@ -104,4 +104,25 @@
         ORDER BY
             m.SORT ASC
     </select>
+
+    <!-- 查询我收到的未读的消息数量	 -->
+    <select id="selectUnReadCount" resultType="java.lang.Integer">
+        SELECT
+            IFNULL(COUNT(INFO_ID),0)
+        FROM info_receivers
+        WHERE
+            DEL_FLAG = '0'
+          AND STAFF_ID = #{userId}
+          AND READ_FLAG = 0
+    </select>
+
+    <!-- 我发出的，新回复数量 -->
+    <select id="selectNewReplyCount" resultType="java.lang.Integer">
+        SELECT
+            IFNULL(SUM(UN_READ_REPLY_NUM) ,0)
+        FROM info_profile
+        WHERE
+            DEL_FLAG = '0'
+          AND CREATED_BY = #{userId}
+    </select>
 </mapper>
\ No newline at end of file