feat:家庭医生im添加reids实现10分钟之内重复发送消息

family-doctor-server/src/main/java/com/ebaiyihui/family/doctor/server/controller/ImMsgTemplateController.java

@@ -43,7 +43,7 @@ public class ImMsgTemplateController {
     public BaseResponse<String> sendImMsg(@RequestBody SendImMsgDTO reqVo,
                                           BindingResult bindingResult) {
 
-        BaseResponse<String> response = null;
+        String response = null;
         try {
             Object sendImMsgKey = redisUtil.get(JTYS_SEND_IM_MESSAGE + reqVo.getAdmId() + "_" + reqVo.getType());
             log.info("sendImMsgKey={}", String.valueOf(sendImMsgKey));
@@ -55,7 +55,7 @@ public class ImMsgTemplateController {
 
             return BaseResponse.error(e.getMessage());
         }
-        return BaseResponse.success("消息推送成功");
+        return BaseResponse.success(response);
     }
 
     @RequestMapping(value = "/unReadMsgCount", method = RequestMethod.POST)

family-doctor-server/src/main/java/com/ebaiyihui/family/doctor/server/service/ImMsgTemplateService.java

@@ -13,7 +13,7 @@ import com.ebaiyihui.framework.response.BaseResponse;
 
 public interface ImMsgTemplateService {
 
-    BaseResponse<String> sendImMsg(SendImMsgDTO reqVo);
+    String sendImMsg(SendImMsgDTO reqVo);
 
     BaseResponse<String> unReadMsgCount(ImMessageDTO imMessageEntity);
 }

family-doctor-server/src/main/java/com/ebaiyihui/family/doctor/server/service/impl/ImMsgTemplateServiceImpl.java

@@ -70,7 +70,7 @@ public class ImMsgTemplateServiceImpl implements ImMsgTemplateService {
 
     @Async
     @Override
-    public BaseResponse<String> sendImMsg(SendImMsgDTO sendImMsgDTO) {
+    public String sendImMsg(SendImMsgDTO sendImMsgDTO) {
 
         QueryWrapper<ImMsgTemplateEntity> wrapper = new QueryWrapper<>();
         ImMsgTemplateEntity imMsgTemplate = new ImMsgTemplateEntity();
@@ -86,7 +86,7 @@ public class ImMsgTemplateServiceImpl implements ImMsgTemplateService {
         if (!flag) {
             throw new BusinessException("消息推送失败");
         }
-        return BaseResponse.success("消息推送成功");
+        return "消息推送成功";
     }
 
     @Override