Browse Source

获取上报市平台异常数据定时任务

feature/dangjian
zhaoqifeng 3 years ago
parent
commit
e27edbc86e
  1. 2
      esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java

2
esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java

@ -1426,7 +1426,7 @@ public class PushToCityGridServiceImpl implements PushToCityGridService {
//替换反斜线 //替换反斜线
String data = pushToCityResult.getData().replace("\\", ""); String data = pushToCityResult.getData().replace("\\", "");
List<PushToCityResultDTO> list = JSON.parseArray(data, PushToCityResultDTO.class); List<PushToCityResultDTO> list = JSON.parseArray(data, PushToCityResultDTO.class);
list.stream().filter(i -> i.getData().contains("数据异常")).collect(Collectors.toList()).forEach(item -> { list.stream().filter(i -> i.getData().contains("不合规")).collect(Collectors.toList()).forEach(item -> {
String msg = item.getData(); String msg = item.getData();
ItemReportErrorLogEntity entity = new ItemReportErrorLogEntity(); ItemReportErrorLogEntity entity = new ItemReportErrorLogEntity();
entity.setItemId(msg.substring("诉求ID ".length(), "诉求ID ".length() + 32)); entity.setItemId(msg.substring("诉求ID ".length(), "诉求ID ".length() + 32));

Loading…
Cancel
Save