diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/api/riskmessageslog/RiskMessagesLogVos.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/api/riskmessageslog/RiskMessagesLogVos.java new file mode 100644 index 00000000..ad33566d --- /dev/null +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/api/riskmessageslog/RiskMessagesLogVos.java @@ -0,0 +1,105 @@ +package com.yxt.supervise.report.api.riskmessageslog; + +import cn.hutool.core.util.StrUtil; +import com.yxt.common.core.vo.Vo; +import com.yxt.supervise.report.api.imgmessageslog.Linkers; +import lombok.Data; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @author wangpengfei + * @date 2023/11/22 8:46 + */ +@Data +public class RiskMessagesLogVos implements Vo { + private String id; + private String sid; + private String messageTime; + private String pagepath; + private String content; + //消息状态 + private String oState; + private Map map; + private String riskSid; + private String shName; + private List devices; + private String text; + List linkers; + private String shSid; + private Integer count; + private List message; + private String type; + private TemplateMessageVo templateMessageVo; + private String isImg; + private String riskLevel="二级风险"; + //{time4=2023-09-14 17:17:35, thing8=中通樊家屯仓, thing2=东北角的摄像头,111,22,33} + //{thing3=中通樊家屯仓, thing2=东北角的摄像头,111,22,33, time5=2023-09-14 17:18:00} + public TemplateMessageVo getTemplateMessageVo() { + TemplateMessageVo vo=new TemplateMessageVo(); + //{time4=2023-09-14 17:17:35, thing8=中通樊家屯仓, thing2=东北角的摄像头,111,22,33} + //{thing3=中通樊家屯仓, thing2=东北角的摄像头,111,22,33, time5=2023-09-14 17:18:00} + if(StrUtil.isNotEmpty(type)){ + if(type.equals("设备离线")){ + vo.setTime(map.get("time4")); + vo.setShName(map.get("thing8")+"设备离线"); + }else if(type.equals("设备离线解除")){ + vo.setTime(map.get("time5")); + vo.setShName(map.get("thing3")+"设备离线解除"); + }else if(type.equals("系统异常")){ + vo.setTime(map.get("time4")); + vo.setShName("环境监控未向平台推送数据"); + }else if(type.equals("系统异常解除")){ + vo.setTime(map.get("time5")); + vo.setShName("环境监控已正常推送数据"); + }else if(type.equals("图片对比异常")){ + //{thing3=瀚川商贸仓库, thing4=图片对比异常, time5=2023-11-06 05:04:08} + vo.setTime(map.get("time5")); + vo.setShName(map.get("thing3")+"图片对比异常"); + }else if(type.equals("每日数据上报")){ + //{time1=2023-08-15 09:57, thing3=赵丽晓, thing2=监管数据总览(喜相随生产加工动产质押项…} + vo.setTime(map.get("time1")); + vo.setShName(map.get("thing2")+")每日数据上报"); + } + } + this.templateMessageVo=vo; + return templateMessageVo; + } + + public List getMessage() { + List l=new ArrayList<>(); + String[] keyValuePairs = content.split("[{;,}]"); + for (String pair : keyValuePairs) { + // 按照等号拆分键和值 + String[] keyValue = pair.split("="); + if (keyValue.length == 2) { + String key = keyValue[0].trim(); + String value = keyValue[1].trim(); + l.add(value); + } + } + this.message=l; + return message; + } + + public Map getMap() { + Map strMap = new HashMap<>(); + + String[] keyValuePairs = content.split("[{;,}]"); + + for (String pair : keyValuePairs) { + // 按照等号拆分键和值 + String[] keyValue = pair.split("="); + if (keyValue.length == 2) { + String key = keyValue[0].trim(); + String value = keyValue[1].trim(); + strMap.put(key, value); + } + } + this.map = strMap; + return map; + } +} diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageslog/RiskMessagesLogMapper.java b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageslog/RiskMessagesLogMapper.java index 6e2ff33a..2f00f6a7 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageslog/RiskMessagesLogMapper.java +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageslog/RiskMessagesLogMapper.java @@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Constants; import com.yxt.supervise.report.api.riskmessageslog.RiskMessagesLog; import com.yxt.supervise.report.api.riskmessageslog.RiskMessagesLogVo; +import com.yxt.supervise.report.api.riskmessageslog.RiskMessagesLogVos; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; @@ -30,5 +31,5 @@ public interface RiskMessagesLogMapper extends BaseMapper { @Select("select count(*) from risk_messages_log i left join risk_message_user m on m.messageSid=i.sid where m.state='0' and m.openId =#{openId}") Integer getMessageCount(@Param("openId") String openId); - List messageNotice(@Param(Constants.WRAPPER) Wrapper qw); + List messageNotice(@Param(Constants.WRAPPER) Wrapper qw); } diff --git a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageslog/RiskMessagesLogMapper.xml b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageslog/RiskMessagesLogMapper.xml index d1ec1a26..96fe4e9e 100644 --- a/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageslog/RiskMessagesLogMapper.xml +++ b/yxt_supervise/supervise-report/supervise-report-biz/src/main/java/com/yxt/supervise/report/biz/riskmessageslog/RiskMessagesLogMapper.xml @@ -67,7 +67,7 @@ report_sales_day_store ${ew.sqlSegment} - SELECT log.messageTime, log.content,