添加统计用户与商家聊天次数接口

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/controller/MessageController.java

@@ -166,4 +166,11 @@ public class MessageController  extends BaseController{
     public Integer timeTypeById(@ApiParam(value = "购买聊天时长的类型id，唯一识别id", required = true)  Integer typeId, Integer userId){
         return messageService.timeTypeById(typeId,userId);
     }
+
+    @ApiOperation(value = "获取用户商家聊天次数")
+    @ApiResponses({@ApiResponse(code = 200, message = "OK", response = ResultBody.class)})
+    @PostMapping("/getUserMessageNum")
+    public ResultBody getUserMessageNum(){
+        return messageService.getUserMessageNum();
+    }
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/dao/MessageDao.java

@@ -118,4 +118,6 @@ public interface MessageDao {
     List<MessageTimeVO> listTimeType();
     void updateTimeType(MessageTimeVO messageTimeVO);
     void insertTimeType(MessageTimeVO messageTimeVO);
+
+    Integer getUserMessageNum();
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/MessageService.java

@@ -94,4 +94,6 @@ public interface MessageService {
     ResultBody insertTimeType(MessageTimeVO messageTimeVO);
 
     Integer timeTypeById(Integer id,Integer userId);
+
+    ResultBody getUserMessageNum();
 }

csm-service/cms-service-user/src/main/java/com/mmc/iuav/user/service/impl/MessageServiceImpl.java

@@ -428,4 +428,10 @@ public class MessageServiceImpl implements MessageService {
         // 如果时间差大于 180 秒（即三分钟），返回 true
         return secondsDiff > 180;
     }
+
+    @Override
+    public ResultBody getUserMessageNum() {
+        Integer userMessageNum = messageDao.getUserMessageNum();
+        return ResultBody.success(userMessageNum);
+    }
 }

csm-service/cms-service-user/src/main/resources/mapper/MessageDao.xml

@@ -122,6 +122,12 @@ ORDER BY create_time desc
         from user_message_time_type
     </select>
 
+    <select id="getUserMessageNum" resultType="java.lang.Integer">
+        SELECT COUNT(DISTINCT back_user_id)
+        FROM user_message
+        WHERE DATE(create_time) = CURDATE() AND back_user_id IS NOT NULL
+    </select>
+
     <insert id="insertSystemMessage">
         insert into message
         <trim prefix="(" suffix=")" suffixOverrides=",">