同步

sys-api-service/src/main/java/com/xy/service/MsgSysMonitorNoticeServiceImpl.java

@@ -76,7 +76,13 @@ public class MsgSysMonitorNoticeServiceImpl extends ServiceImpl<MsgSysMonitorNot
         save(saveInfo);
         Long userId = save.getUserId();
         if (userId != null) {
+            String channelType = save.getChannelType();
+
             MsgUserMessageDto.Save mum = new MsgUserMessageDto.Save();
+            if ("ORDER_CUT".equals(channelType)) {
+                //补扣设置为已读
+                mum.setReadState("2");
+            }
             mum.setMsgId(saveInfo.getMsgId());
             mum.setMsgType(saveInfo.getMsgType());
             mum.setPriority(saveInfo.getPriority());

sys-api-service/src/main/java/com/xy/service/MsgUserMessageServiceImpl.java

@@ -10,6 +10,7 @@ import com.xy.dto.MsgUserMessageDto;
 import com.xy.entity.MsgSysMonitorNotice;
 import com.xy.entity.MsgUserMessage;
 import com.xy.enums.MsgReadStatus;
+import com.xy.enums.MsgType;
 import com.xy.mapper.MsgUserMessageMapper;
 import com.xy.utils.*;
 import io.swagger.annotations.Api;
@@ -19,6 +20,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.RequestBody;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -102,12 +104,30 @@ public class MsgUserMessageServiceImpl extends ServiceImpl<MsgUserMessageMapper,
     @ApiOperation("我的消息")
     @Override
     public R<PageBean<MsgUserMessageDto.PageVO>> myMsgPage(MsgUserMessageDto.Page page) {
+        //类型 1故障通知、2交易通知、3其他通知
+        String type = page.getType();
+        Integer msgType = null;
+        List<Integer> msgTypes = new ArrayList<>();
+        List<Integer> msgTypesNotIn = new ArrayList<>();
+        if ("1".equals(type)) {
+            msgTypes.add(MsgType.TYPE6.getCode());
+        }
+        if ("2".equals(type)) {
+            msgTypes.add(MsgType.TYPE8.getCode());
+        }
+        if ("3".equals(type)) {
+            msgTypesNotIn.add(MsgType.TYPE6.getCode());
+            msgTypesNotIn.add(MsgType.TYPE8.getCode());
+        }
         page.setUserId(AuthorizeUtils.getLoginId(Long.class));
         PageBean pageBean = page.getPage();
         LambdaQueryWrapper<MsgUserMessage> lambdaQueryWrapper = new MybatisPlusQuery().eqWrapper(page, MsgUserMessage.class)
                 .ge(MsgUserMessage::getCreateTime, page.getBeginCreateTime())
                 .le(MsgUserMessage::getCreateTime, page.getEndCreateTime())
-                .build().orderByDesc(MsgUserMessage::getCreateTime);
+                .build()
+                .in(CollUtil.isNotEmpty(msgTypes), MsgUserMessage::getMsgType, msgTypes)
+                .notIn(CollUtil.isNotEmpty(msgTypesNotIn), MsgUserMessage::getMsgType, msgTypesNotIn)
+                .orderByDesc(MsgUserMessage::getCreateTime);
         IPage<MsgUserMessage> iPage = page(toIPage(pageBean), lambdaQueryWrapper);
         PageBean<MsgUserMessageDto.PageVO> pageVo = toPageBean(MsgUserMessageDto.PageVO.class, iPage);
         List<MsgUserMessageDto.PageVO> records = pageVo.getRecords();

sys-api-service/src/main/java/com/xy/service/SmsUtilAliImplService.java

@@ -7,6 +7,7 @@ import cn.hutool.json.JSONUtil;
 import com.xy.dto.MsgConfigDto;
 import com.xy.dto.MsgConfigTestDto;
 import com.xy.enums.ChannelType;
+import com.xy.enums.MsgConfigId;
 import com.xy.enums.SmsSceneEnum;
 import com.xy.utils.R;
 import com.xy.utils.RedisService;
@@ -79,7 +80,7 @@ public class SmsUtilAliImplService implements SmsUtil {
     public void sendSmsCode(String mobile, SmsSceneEnum smsSceneEnum, String uid) {
         //验证码
         String code = getRandomNum();
-        Long configId = 15L;
+        Long configId = MsgConfigId.SMS_CODE.getId();
         MsgConfigDto.Vo msgConfig = R.feignCheckData(msgSendApiService.getMsgConfig(new MsgConfigDto.Vo().setId(configId)));
         List<MsgConfigTestDto.BizParam> bizParams = R.feignCheckData(msgSendApiService.getBizParamByMsgConfig(new MsgConfigTestDto.MsgConfig().setConfigId(configId)));
         if (CollUtil.isNotEmpty(bizParams) && msgConfig != null) {

sys-api/src/main/java/com/xy/dto/MsgUserMessageDto.java

@@ -29,6 +29,9 @@ public class MsgUserMessageDto {
     @Accessors(chain = true)
     public static class Page extends Vo {
 
+        @ApiModelProperty(value = "类型(1故障通知、2交易通知、3其他通知)", required = false)
+        private String type;
+
         @ApiModelProperty(value = "分页对象", required = true)
         private PageBean page;
 

sys-api/src/main/java/com/xy/enums/MsgConfigId.java

@@ -18,7 +18,8 @@ public enum MsgConfigId {
 
     RISK_ORDER(14L, "异常订单通知"),
     CUT_ORDER(13L, "补扣成功通知"),
-    DEVICE_EXCEPTION(12L, "设备故障提醒");
+    DEVICE_EXCEPTION(12L, "设备故障提醒"),
+    SMS_CODE(15L, "短信验证码");
 
     /**
      * 编码值