|
|
@ -198,14 +198,14 @@ public class WeatherForecastController extends BaseController { |
|
|
|
&& Objects.equals(ite.getWarningType(), UniversalEnum.TWO.getValue())).collect(Collectors.toList()); |
|
|
|
if (collect.size() == UniversalEnum.ZERO.getNumber()) { |
|
|
|
String content= WeatherTrafficProposeUtil.content(Integer.parseInt(warningLevel), earlyWarningType); |
|
|
|
jsonObject.put("earlyWorningContent", jsonObject.getString("earlyWorningContent")+content); |
|
|
|
WebSocketService.broadcast(UniversalEnum.THREE.getValue(), jsonObject); //推送事件消息 不是感知事件
|
|
|
|
DcNoStakeWarningTable dcNoStakeWarningTable = new DcNoStakeWarningTable(); |
|
|
|
dcNoStakeWarningTable.setWarningDescription(jsonObject.getString("earlyWorningContent")); |
|
|
|
dcNoStakeWarningTable.setWarningType(UniversalEnum.TWO.getValue()); |
|
|
|
dcNoStakeWarningTable.setWarningTime(jsonObject.getDate("earlyWorningIssueDate")); |
|
|
|
dcNoStakeWarningTable.setOtherConfig(String.valueOf(jsonObject)); |
|
|
|
noStakeWarningTableService.addDcNoStakeWarningTable(dcNoStakeWarningTable); |
|
|
|
jsonObject.put("earlyWorningContent", jsonObject.getString("earlyWorningContent")+content); |
|
|
|
WebSocketService.broadcast(UniversalEnum.THREE.getValue(), jsonObject); //推送事件消息 不是感知事件
|
|
|
|
} |
|
|
|
|
|
|
|
}); |
|
|
|