Skip to content

A
amos-boot-biz
Commit 2ca6c409 authored by helinlin's avatar helinlin
Browse files
Options

添加APP接口 警情通话录音文件地址字段

parent 34994fb4
Hide whitespace changes
Inline Side-by-side
Showing with 834 additions and 855 deletions
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/AlertCalledServiceImpl.java
View file @ 2ca6c409
...@@ -9,7 +9,10 @@ import java.util.Set; ...@@ -9,7 +9,10 @@ import java.util.Set;
import java.util.function.Function; import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import com.yeejoin.amos.boot.module.jcs.api.dto.*;
import com.yeejoin.amos.boot.module.jcs.api.entity.*;
import com.yeejoin.amos.boot.module.jcs.api.enums.AlertBusinessTypeEnum; import com.yeejoin.amos.boot.module.jcs.api.enums.AlertBusinessTypeEnum;
import com.yeejoin.amos.boot.module.jcs.api.service.IVoiceRecordFileService;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
...@@ -45,20 +48,6 @@ import com.yeejoin.amos.boot.module.common.biz.service.impl.FirefightersServiceI ...@@ -45,20 +48,6 @@ import com.yeejoin.amos.boot.module.common.biz.service.impl.FirefightersServiceI
import com.yeejoin.amos.boot.module.common.biz.service.impl.KeySiteServiceImpl; import com.yeejoin.amos.boot.module.common.biz.service.impl.KeySiteServiceImpl;
import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl; import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
import com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceServiceImpl; import com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceServiceImpl;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledFormDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledObjsDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledTodyDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledZhDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.ControllerDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.ControllerEquipDto;
import com.yeejoin.amos.boot.module.jcs.api.dto.KeyValueLabel;
import com.yeejoin.amos.boot.module.jcs.api.dto.PowerData;
import com.yeejoin.amos.boot.module.jcs.api.entity.Aircraft;
import com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled;
import com.yeejoin.amos.boot.module.jcs.api.entity.AlertFormValue;
import com.yeejoin.amos.boot.module.jcs.api.entity.AlertLocationLog;
import com.yeejoin.amos.boot.module.jcs.api.entity.Template;
import com.yeejoin.amos.boot.module.jcs.api.enums.AlertStageEnums; import com.yeejoin.amos.boot.module.jcs.api.enums.AlertStageEnums;
import com.yeejoin.amos.boot.module.jcs.api.enums.ControllerTypeEnum; import com.yeejoin.amos.boot.module.jcs.api.enums.ControllerTypeEnum;
import com.yeejoin.amos.boot.module.jcs.api.enums.DutyInfoEnum; import com.yeejoin.amos.boot.module.jcs.api.enums.DutyInfoEnum;
...@@ -77,96 +66,98 @@ import com.yeejoin.amos.component.rule.config.RuleConfig; ...@@ -77,96 +66,98 @@ import com.yeejoin.amos.component.rule.config.RuleConfig;
*/ */
@Service @Service
public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCalled, AlertCalledMapper> public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCalled, AlertCalledMapper>
implements IAlertCalledService { implements IAlertCalledService {
private final Logger logger = LogManager.getLogger(AlertCalledServiceImpl.class); private final Logger logger = LogManager.getLogger(AlertCalledServiceImpl.class);
@Autowired @Autowired
RedisUtils redisUtils; RedisUtils redisUtils;
@Autowired @Autowired
AlertCalledMapper alertCalledMapper; AlertCalledMapper alertCalledMapper;
@Autowired @Autowired
RuleAlertCalledService ruleAlertCalledService; RuleAlertCalledService ruleAlertCalledService;
@Autowired @Autowired
TemplateMapper templateMapper; TemplateMapper templateMapper;
@Autowired @Autowired
PowerTransferMapper powerTransferMapper; PowerTransferMapper powerTransferMapper;
@Autowired @Autowired
AlertSubmittedMapper alertSubmittedMapper; AlertSubmittedMapper alertSubmittedMapper;
@Autowired @Autowired
private JcsControlServerClient jcsControlServerClient; private JcsControlServerClient jcsControlServerClient;
@Autowired @Autowired
private AlertFormValueServiceImpl iAlertFormValueService; private AlertFormValueServiceImpl iAlertFormValueService;
@Autowired @Autowired
private ESAlertCalledService eSAlertCalledService; private ESAlertCalledService eSAlertCalledService;
@Autowired @Autowired
private ControllerServiceImpl controllerService; private ControllerServiceImpl controllerService;
@Autowired @Autowired
private ControllerEquipServiceImpl controllerEquipService; private ControllerEquipServiceImpl controllerEquipService;
@Autowired @Autowired
FirefightersServiceImpl firefightersService; FirefightersServiceImpl firefightersService;
@Autowired @Autowired
KeySiteServiceImpl keySiteService; KeySiteServiceImpl keySiteService;
@Autowired @Autowired
AlertSubmittedServiceImpl alertSubmittedService; AlertSubmittedServiceImpl alertSubmittedService;
@Autowired @Autowired
private AlertLocationLogServiceImpl alertLocationLogService; private AlertLocationLogServiceImpl alertLocationLogService;
@Autowired @Autowired
private EmqKeeper emqKeeper; private EmqKeeper emqKeeper;
@Value("${mqtt.topic.command.alert.notice}") @Value("${mqtt.topic.command.alert.notice}")
private String topic; private String topic;
@Value("${redis.cache.failure.time}") @Value("${redis.cache.failure.time}")
private long time; private long time;
@Value("${mqtt.topic.command.power.deployment}") @Value("${mqtt.topic.command.power.deployment}")
private String topic1; private String topic1;
@Autowired @Autowired
private OrgUsrServiceImpl iOrgUsrService; private OrgUsrServiceImpl iOrgUsrService;
@Autowired @Autowired
AircraftServiceImpl aircraftService; AircraftServiceImpl aircraftService;
@Autowired @Autowired
AlertFormValueServiceImpl alertFormValueService; AlertFormValueServiceImpl alertFormValueService;
@Autowired @Autowired
OrgUsrServiceImpl orgUsrServiceImpl; OrgUsrServiceImpl orgUsrServiceImpl;
@Autowired
private static int comparingByGroupVal(Map<String, Object> map, Map<String, Object> map2, String key) { VoiceRecordFileServiceImpl voiceRecordFileService;
int result = 0;
if (map.get(key) instanceof DateTime) { private static int comparingByGroupVal(Map<String, Object> map, Map<String, Object> map2, String key) {
long r1 = ((Date) map.get(key)).getTime(); int result = 0;
long r2 = ((Date) map2.get(key)).getTime(); if (map.get(key) instanceof DateTime) {
result = Long.compare(r1, r2); long r1 = ((Date) map.get(key)).getTime();
} long r2 = ((Date) map2.get(key)).getTime();
return result; result = Long.compare(r1, r2);
} }
return result;
/** }
* 指挥系统 未结束的警情列表
**/ /**
@Override * 指挥系统 未结束的警情列表
public List<AlertCalledZhDto> alertCalledListByAlertStatus(Integer pageNum, Integer pageSize, RequestData par) { **/
@Override
List<AlertCalledZhDto> list = alertCalledMapper.alertCalledListByAlertStatus(pageNum, pageSize, par); public List<AlertCalledZhDto> alertCalledListByAlertStatus(Integer pageNum, Integer pageSize, RequestData par) {
return list;
List<AlertCalledZhDto> list = alertCalledMapper.alertCalledListByAlertStatus(pageNum, pageSize, par);
} return list;
@Override }
public int alertCalledListByAlertStatusCount(RequestData par) {
return alertCalledMapper.alertCalledListByAlertStatusCount(par); @Override
} public int alertCalledListByAlertStatusCount(RequestData par) {
return alertCalledMapper.alertCalledListByAlertStatusCount(par);
/** }
* 接警记录 列表分页查询
**/ /* /**
* bug2407 筛选参数解析异常 修改筛选条件方法 XML中添加了selectAllPage 方法 data代表排序条件 lift 升降序 陈召 * 接警记录 列表分页查询
* 2021-09-03 开始 **/ /*
*/ * bug2407 筛选参数解析异常 修改筛选条件方法 XML中添加了selectAllPage 方法 data代表排序条件 lift 升降序 陈召
* 2021-09-03 开始
*/
// public IPage<AlertCalled> queryForCalledList(Page pageBean, Integer alertStatus, // public IPage<AlertCalled> queryForCalledList(Page pageBean, Integer alertStatus,
// String alertTypeCode, // String alertTypeCode,
// String alertSourceCode, // String alertSourceCode,
...@@ -183,467 +174,467 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal ...@@ -183,467 +174,467 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
// //
// List<AlertCalled> list = alertCalledMapper.selectAllPage(pageBean.getCurrent(), pageBean.getSize(), alertStatus, alertTypeCode, alertSourceCode, startTime, endTime, data, lift); // List<AlertCalled> list = alertCalledMapper.selectAllPage(pageBean.getCurrent(), pageBean.getSize(), alertStatus, alertTypeCode, alertSourceCode, startTime, endTime, data, lift);
// } // }
public IPage<AlertCalled> queryForCalledList(Page pageBean, Integer alertStatus, String alertTypeCode, public IPage<AlertCalled> queryForCalledList(Page pageBean, Integer alertStatus, String alertTypeCode,
String alertSourceCode, String startTime, String endTime, String sort,String isFatherAlert) { String alertSourceCode, String startTime, String endTime, String sort, String isFatherAlert) {
String[] split = sort != null ? sort.split(",") : null; String[] split = sort != null ? sort.split(",") : null;
/* 2407 【web】日常值班>警情记录>接警记录，表头排序功能失效 chenzhao 09-28 start */ /* 2407 【web】日常值班>警情记录>接警记录，表头排序功能失效 chenzhao 09-28 start */
if (split != null) { if (split != null) {
if (split[0] != null) { if (split[0] != null) {
if (split[0].equals("alertType") || split[0].equals("alertSource") || split[0].equals("alarmType")) { if (split[0].equals("alertType") || split[0].equals("alertSource") || split[0].equals("alarmType")) {
split[0] = split[0] + "Code"; split[0] = split[0] + "Code";
} }
if (split[0].equals("alertStatusStr")) { if (split[0].equals("alertStatusStr")) {
split[0] = "alertStatus"; split[0] = "alertStatus";
} }
} }
if (split[1] != null) { if (split[1] != null) {
if (split[1].equals("ascend")) { if (split[1].equals("ascend")) {
split[1] = "ASC"; split[1] = "ASC";
} }
if (split[1].equals("descend")) { if (split[1].equals("descend")) {
split[1] = "DESC"; split[1] = "DESC";
} }
} }
} }
String data = split != null ? RedisKey.humpToLine(split[0]) : null; String data = split != null ? RedisKey.humpToLine(split[0]) : null;
/* 2407 【web】日常值班>警情记录>接警记录，表头排序功能失效 chenzhao 09-28 end */ /* 2407 【web】日常值班>警情记录>接警记录，表头排序功能失效 chenzhao 09-28 end */
String lift = split != null ? split[1] : null; String lift = split != null ? split[1] : null;
List<AlertCalled> list = alertCalledMapper.selectAllPage(pageBean.getCurrent(), pageBean.getSize(), alertStatus, List<AlertCalled> list = alertCalledMapper.selectAllPage(pageBean.getCurrent(), pageBean.getSize(), alertStatus,
alertTypeCode, alertSourceCode, startTime, endTime, data, lift,isFatherAlert); alertTypeCode, alertSourceCode, startTime, endTime, data, lift, isFatherAlert);
IPage<AlertCalled> iPage = new Page<>(); IPage<AlertCalled> iPage = new Page<>();
iPage.setRecords(list); iPage.setRecords(list);
iPage.setTotal( iPage.setTotal(
alertCalledMapper.selectAllCount(alertStatus, alertTypeCode, alertSourceCode, startTime, endTime,isFatherAlert)); alertCalledMapper.selectAllCount(alertStatus, alertTypeCode, alertSourceCode, startTime, endTime, isFatherAlert));
//iPage.setSize(pageBean.getSize()); //iPage.setSize(pageBean.getSize());
return iPage; return iPage;
/* bug2407 表头筛选失效 补充条件方法 XML中添加了排序条件判断 data代表排序条件 lift 升降序 陈召 2021-09-03 结束 */ /* bug2407 表头筛选失效 补充条件方法 XML中添加了排序条件判断 data代表排序条件 lift 升降序 陈召 2021-09-03 结束 */
} }
/** /**
* 根据灾情id 查询灾情详情 * 根据灾情id 查询灾情详情
**/ **/
@Override @Override
public Object selectAlertCalledById(Long id) { public Object selectAlertCalledById(Long id) {
if (redisUtils.hasKey(RedisKey.ALERTCALLED_ID + id)) { if (redisUtils.hasKey(RedisKey.ALERTCALLED_ID + id)) {
Object obj = redisUtils.get(RedisKey.ALERTCALLED_ID + id); Object obj = redisUtils.get(RedisKey.ALERTCALLED_ID + id);
return obj; return obj;
} else { } else {
// 警情基本信息 // 警情基本信息
AlertCalled alertCalled = this.getById(id); AlertCalled alertCalled = this.getById(id);
QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>(); QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("alert_called_id", id); queryWrapper.eq("alert_called_id", id);
// 警情动态表单数据 // 警情动态表单数据
List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper); List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper);
List<FormValue> formValue = new ArrayList<FormValue>(); List<FormValue> formValue = new ArrayList<FormValue>();
if (list != null && list.size() > 0) { if (list != null && list.size() > 0) {
for (AlertFormValue alertFormValue : list) { for (AlertFormValue alertFormValue : list) {
FormValue value = new FormValue(alertFormValue.getFieldCode(), alertFormValue.getFieldName(), FormValue value = new FormValue(alertFormValue.getFieldCode(), alertFormValue.getFieldName(),
"text", alertFormValue.getFieldValue(), alertFormValue.getBlock()); "text", alertFormValue.getFieldValue(), alertFormValue.getBlock());
formValue.add(value); formValue.add(value);
} }
} }
AlertCalledFormDto alertCalledFormVo = new AlertCalledFormDto(alertCalled, formValue); AlertCalledFormDto alertCalledFormVo = new AlertCalledFormDto(alertCalled, formValue);
redisUtils.set(RedisKey.ALERTCALLED_ID + id, JSON.toJSON(alertCalledFormVo), time); redisUtils.set(RedisKey.ALERTCALLED_ID + id, JSON.toJSON(alertCalledFormVo), time);
return alertCalledFormVo; return alertCalledFormVo;
} }
} }
/** /**
* 根据灾情id 查询灾情详情 * 根据灾情id 查询灾情详情
**/ **/
@Override @Override
public Object selectAlertCalledByIdNoRedis(Long id) { public Object selectAlertCalledByIdNoRedis(Long id) {
// 警情基本信息 // 警情基本信息
AlertCalled alertCalled = this.getById(id); AlertCalled alertCalled = this.getById(id);
QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>(); QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("alert_called_id", id); queryWrapper.eq("alert_called_id", id);
// 警情动态表单数据 // 警情动态表单数据
List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper); List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper);
List<FormValue> formValue = new ArrayList<FormValue>(); List<FormValue> formValue = new ArrayList<FormValue>();
if (list != null && list.size() > 0) { if (list != null && list.size() > 0) {
for (AlertFormValue alertFormValue : list) { for (AlertFormValue alertFormValue : list) {
FormValue value = new FormValue(alertFormValue.getFieldCode(), alertFormValue.getFieldName(), FormValue value = new FormValue(alertFormValue.getFieldCode(), alertFormValue.getFieldName(),
"text", alertFormValue.getFieldValue(), alertFormValue.getBlock()); "text", alertFormValue.getFieldValue(), alertFormValue.getBlock());
formValue.add(value); formValue.add(value);
} }
} }
AlertCalledFormDto alertCalledFormVo = new AlertCalledFormDto(alertCalled, formValue); AlertCalledFormDto alertCalledFormVo = new AlertCalledFormDto(alertCalled, formValue);
return alertCalledFormVo; return alertCalledFormVo;
} }
/** /**
* 根据灾情id 查询灾情详情 * 根据灾情id 查询灾情详情
**/ **/
@Override @Override
public Object selectAlertCalledByIdNoRedisNew(Long id) { public Object selectAlertCalledByIdNoRedisNew(Long id) {
// 警情基本信息 // 警情基本信息
AlertCalled alertCalled = this.getById(id); AlertCalled alertCalled = this.getById(id);
QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>(); QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("alert_called_id", id); queryWrapper.eq("alert_called_id", id);
// 警情动态表单数据 // 警情动态表单数据
List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper); List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper);
List<FormValue> formValue = new ArrayList<FormValue>(); List<FormValue> formValue = new ArrayList<FormValue>();
// //
AlertCalledObjsDto alertCalledFormVo = new AlertCalledObjsDto(); AlertCalledObjsDto alertCalledFormVo = new AlertCalledObjsDto();
alertCalledFormVo.setAlertCalled(alertCalled); alertCalledFormVo.setAlertCalled(alertCalled);
alertCalledFormVo.setAlertFormValue(list); alertCalledFormVo.setAlertFormValue(list);
return alertCalledFormVo; return alertCalledFormVo;
} }
/** /**
* <pre> * <pre>
* 保存警情信息 * 保存警情信息
* </pre> * </pre>
* *
* @param alertCalledObjsDto * @param alertCalledObjsDto
* @return * @return
*/ */
@Transactional(rollbackFor = RuntimeException.class) @Transactional(rollbackFor = RuntimeException.class)
public AlertCalledObjsDto createAlertCalled(AlertCalledObjsDto alertCalledObjsDto) { public AlertCalledObjsDto createAlertCalled(AlertCalledObjsDto alertCalledObjsDto) {
try { try {
// 警情基本信息 // 警情基本信息
AlertCalled alertCalled = alertCalledObjsDto.getAlertCalled(); AlertCalled alertCalled = alertCalledObjsDto.getAlertCalled();
//主表增加备注字段 //主表增加备注字段
if (alertCalled.getAddress() != null) { if (alertCalled.getAddress() != null) {
JSONObject address = WaterResourceServiceImpl.getLongLatFromAddress(alertCalled.getAddress()); JSONObject address = WaterResourceServiceImpl.getLongLatFromAddress(alertCalled.getAddress());
alertCalled.setAddress(address.getString(BizConstant.ADDRESS)); alertCalled.setAddress(address.getString(BizConstant.ADDRESS));
alertCalled.setCoordinateX(Double.valueOf(address.getString(BizConstant.LONGITUDE))); alertCalled.setCoordinateX(Double.valueOf(address.getString(BizConstant.LONGITUDE)));
alertCalled.setCoordinateY(Double.valueOf(address.getString(BizConstant.LATITUDE))); alertCalled.setCoordinateY(Double.valueOf(address.getString(BizConstant.LATITUDE)));
} }
alertCalled.setCallTime(new Date()); alertCalled.setCallTime(new Date());
if (AlertStageEnums.RG.getValue().equals(alertCalled.getAlertSourceCode()) if (AlertStageEnums.RG.getValue().equals(alertCalled.getAlertSourceCode())
|| AlertStageEnums.RG.getValue().equals(alertCalled.getAlertSourceCode())) { || AlertStageEnums.RG.getValue().equals(alertCalled.getAlertSourceCode())) {
alertCalled.setType("0"); alertCalled.setType("0");
} else { } else {
alertCalled.setType("1"); alertCalled.setType("1");
} }
// 动态表单 // 动态表单
List<AlertFormValue> alertFormValuelist = alertCalledObjsDto.getAlertFormValue(); List<AlertFormValue> alertFormValuelist = alertCalledObjsDto.getAlertFormValue();
// 判断是否航空器救援 如果为航空器救援则保存冗余字段 response_level_code bug2542 bykongfm // 判断是否航空器救援 如果为航空器救援则保存冗余字段 response_level_code bug2542 bykongfm
if (AlertStageEnums.HKJY.getCode().equals(alertCalled.getAlertTypeCode())) { if (AlertStageEnums.HKJY.getCode().equals(alertCalled.getAlertTypeCode())) {
alertFormValuelist.stream().forEach(alertFormValue -> { alertFormValuelist.stream().forEach(alertFormValue -> {
if (alertFormValue.getFieldCode().equals("responseLevel")) { if (alertFormValue.getFieldCode().equals("responseLevel")) {
alertCalled.setResponseLevelCode(alertFormValue.getFieldValueCode()); alertCalled.setResponseLevelCode(alertFormValue.getFieldValueCode());
alertCalled.setResponseLevel(alertFormValue.getFieldValue()); alertCalled.setResponseLevel(alertFormValue.getFieldValue());
} }
}); });
} }
// 判断是否归并警情 // 判断是否归并警情
if (alertCalled.getFatherAlert() != null) { if (alertCalled.getFatherAlert() != null) {
// 警情归并，设置当前警情状态为结束。 // 警情归并，设置当前警情状态为结束。
alertCalled.setAlertStatus(true); alertCalled.setAlertStatus(true);
alertCalled.setAlertStage(AlertStageEnums.JQJB.getValue()); alertCalled.setAlertStage(AlertStageEnums.JQJB.getValue());
alertCalled.setAlarmType(AlertStageEnums.JQGB.getValue()); alertCalled.setAlarmType(AlertStageEnums.JQGB.getValue());
alertCalled.setAlarmTypeCode(AlertStageEnums.JQGB.getCode()); alertCalled.setAlarmTypeCode(AlertStageEnums.JQGB.getCode());
alertCalled.setUpdateTime(new Date()); alertCalled.setUpdateTime(new Date());
alertCalled.setRemark(alertCalledObjsDto.getRemark()); alertCalled.setRemark(alertCalledObjsDto.getRemark());
this.save(alertCalled); this.save(alertCalled);
// 填充警情主键 // 填充警情主键
alertFormValuelist.stream().forEach(alertFormValue -> { alertFormValuelist.stream().forEach(alertFormValue -> {
alertFormValue.setAlertCalledId(alertCalled.getSequenceNbr()); alertFormValue.setAlertCalledId(alertCalled.getSequenceNbr());
alertFormValue.setAlertTypeCode(alertCalled.getAlertTypeCode()); alertFormValue.setAlertTypeCode(alertCalled.getAlertTypeCode());
}); });
// 保存动态表单数据 // 保存动态表单数据
iAlertFormValueService.saveBatch(alertFormValuelist); iAlertFormValueService.saveBatch(alertFormValuelist);
emqKeeper.getMqttClient().publish(topic1, "1".getBytes(), RuleConfig.DEFAULT_QOS, true); emqKeeper.getMqttClient().publish(topic1, "1".getBytes(), RuleConfig.DEFAULT_QOS, true);
} else { } else {
// 警情报送 // 警情报送
// ****************************************************待确认开发 // ****************************************************待确认开发
alertCalled.setAlertStatus(false); alertCalled.setAlertStatus(false);
alertCalled.setIsDelete(false); alertCalled.setIsDelete(false);
alertCalled.setAlertStage(AlertStageEnums.LLDP.getValue()); alertCalled.setAlertStage(AlertStageEnums.LLDP.getValue());
alertCalled.setAlarmType(AlertStageEnums.JQCB.getValue()); alertCalled.setAlarmType(AlertStageEnums.JQCB.getValue());
alertCalled.setAlarmTypeCode(AlertStageEnums.JQCB.getCode()); alertCalled.setAlarmTypeCode(AlertStageEnums.JQCB.getCode());
alertCalled.setRemark(alertCalledObjsDto.getRemark()); alertCalled.setRemark(alertCalledObjsDto.getRemark());
this.save(alertCalled); this.save(alertCalled);
// 填充警情主键 // 填充警情主键
alertFormValuelist.stream().forEach(alertFormValue -> { alertFormValuelist.stream().forEach(alertFormValue -> {
alertFormValue.setAlertCalledId(alertCalled.getSequenceNbr()); alertFormValue.setAlertCalledId(alertCalled.getSequenceNbr());
alertFormValue.setAlertTypeCode(alertCalled.getAlertTypeCode()); alertFormValue.setAlertTypeCode(alertCalled.getAlertTypeCode());
}); });
// 保存动态表单数据 // 保存动态表单数据
iAlertFormValueService.saveBatch(alertFormValuelist); iAlertFormValueService.saveBatch(alertFormValuelist);
alertCalledObjsDto.setAlertCalled(alertCalled); alertCalledObjsDto.setAlertCalled(alertCalled);
alertCalledObjsDto.setAlertFormValue(alertFormValuelist); alertCalledObjsDto.setAlertFormValue(alertFormValuelist);
// 警情报送 // 警情报送
// 调用规则 警情初报 // 调用规则 警情初报
ruleAlertCalledService.fireAlertCalledRule(alertCalledObjsDto, AlertBusinessTypeEnum.警情初报.getCode(), null,null,null); ruleAlertCalledService.fireAlertCalledRule(alertCalledObjsDto, AlertBusinessTypeEnum.警情初报.getCode(), null, null, null);
// 通知实战指挥页面发送mqtt 默认发送 String 类型 0, 新警情 1 警情状态变化 // 通知实战指挥页面发送mqtt 默认发送 String 类型 0, 新警情 1 警情状态变化
emqKeeper.getMqttClient().publish(topic, "0".getBytes(), RuleConfig.DEFAULT_QOS, true); emqKeeper.getMqttClient().publish(topic, "0".getBytes(), RuleConfig.DEFAULT_QOS, true);
/** /**
* 同步保存ES * 同步保存ES
*/ */
eSAlertCalledService.saveAlertCalledToES(alertCalled); eSAlertCalledService.saveAlertCalledToES(alertCalled);
} }
return alertCalledObjsDto; return alertCalledObjsDto;
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
throw new RuntimeException("报送失败，系统异常!"); throw new RuntimeException("报送失败，系统异常!");
} }
} }
/** /**
* 根据id 修改警情 type：警情相关 操作类型 0警情续报 1非警情确认 2 警情结案 * 根据id 修改警情 type：警情相关 操作类型 0警情续报 1非警情确认 2 警情结案
*/ */
@Override @Override
@Transactional(rollbackFor = RuntimeException.class) @Transactional(rollbackFor = RuntimeException.class)
public boolean updateAlertCalled(Long id, String code) { public boolean updateAlertCalled(Long id, String code) {
// TODO Auto-generated method stub // TODO Auto-generated method stub
try { try {
switch (code) { switch (code) {
case "314": case "314":
alertCalledMapper.update(null, alertCalledMapper.update(null,
new UpdateWrapper<AlertCalled>().eq("sequence_nbr", id).set("alert_status", 1) new UpdateWrapper<AlertCalled>().eq("sequence_nbr", id).set("alert_status", 1)
.set("alert_stage", AlertStageEnums.ZBQJ.getValue()) .set("alert_stage", AlertStageEnums.ZBQJ.getValue())
.set("update_time", new Date()) .set("update_time", new Date())
.set("alarm_type", AlertStageEnums.FJQ.getValue()) .set("alarm_type", AlertStageEnums.FJQ.getValue())
.set("alarm_type_code", AlertStageEnums.FJQ.getCode())); .set("alarm_type_code", AlertStageEnums.FJQ.getCode()));
break; break;
case "315": case "315":
alertCalledMapper.update(null, new UpdateWrapper<AlertCalled>().eq("sequence_nbr", id) alertCalledMapper.update(null, new UpdateWrapper<AlertCalled>().eq("sequence_nbr", id)
.set("alert_status", 1).set("update_time", new Date()).set("alert_stage", AlertStageEnums.CZJS.getValue())); .set("alert_status", 1).set("update_time", new Date()).set("alert_stage", AlertStageEnums.CZJS.getValue()));
break; break;
default: default:
alertCalledMapper.update(null, new UpdateWrapper<AlertCalled>().eq("sequence_nbr", id) alertCalledMapper.update(null, new UpdateWrapper<AlertCalled>().eq("sequence_nbr", id)
.set("update_time", new Date()).set("alert_stage", AlertStageEnums.CZGZ.getValue())); .set("update_time", new Date()).set("alert_stage", AlertStageEnums.CZGZ.getValue()));
break; break;
} }
AlertCalled alertCalled = this.getById(id); AlertCalled alertCalled = this.getById(id);
// 删除缓存 // 删除缓存
redisUtils.del(RedisKey.ALERTCALLED_ID + id); redisUtils.del(RedisKey.ALERTCALLED_ID + id);
/** /**
* 同步更新存ES * 同步更新存ES
*/ */
eSAlertCalledService.saveAlertCalledToES(alertCalled); eSAlertCalledService.saveAlertCalledToES(alertCalled);
// 通知实战指挥页面发送mqtt 默认发送 String 类型 0新警情， 1警情状态变化 // 通知实战指挥页面发送mqtt 默认发送 String 类型 0新警情， 1警情状态变化
emqKeeper.getMqttClient().publish(topic, "1".getBytes(), RuleConfig.DEFAULT_QOS, true); emqKeeper.getMqttClient().publish(topic, "1".getBytes(), RuleConfig.DEFAULT_QOS, true);
return true; return true;
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException("系统异常!"); throw new RuntimeException("系统异常!");
} }
} }
/** /**
* 根据时间区间查询警情列表信息 * 根据时间区间查询警情列表信息
* *
* @param beginDate 开始时间 * @param beginDate 开始时间
* @param endDate 结束时间 * @param endDate 结束时间
*/ */
public List<Map<String, Object>> listByDateRange(String beginDate, String endDate) { public List<Map<String, Object>> listByDateRange(String beginDate, String endDate) {
// 查询指定日期内的警情列表 // 查询指定日期内的警情列表
List<AlertCalled> alertCalledList = this.list(new LambdaQueryWrapper<AlertCalled>() List<AlertCalled> alertCalledList = this.list(new LambdaQueryWrapper<AlertCalled>()
.apply(!ValidationUtil.isEmpty(beginDate), "call_time >= '" + beginDate + "'") .apply(!ValidationUtil.isEmpty(beginDate), "call_time >= '" + beginDate + "'")
.le(true, AlertCalled::getCallTime, endDate)); .le(true, AlertCalled::getCallTime, endDate));
Map<String, String> queryParams = Maps.newHashMap(); Map<String, String> queryParams = Maps.newHashMap();
queryParams.put("beginDate", beginDate); queryParams.put("beginDate", beginDate);
queryParams.put("endDate", endDate); queryParams.put("endDate", endDate);
List<Map<String, Object>> allList = Lists.newArrayList(); List<Map<String, Object>> allList = Lists.newArrayList();
if (!ValidationUtil.isEmpty(alertCalledList)) { if (!ValidationUtil.isEmpty(alertCalledList)) {
Map<String, List<AlertCalled>> alertCalledMap = alertCalledList.stream() Map<String, List<AlertCalled>> alertCalledMap = alertCalledList.stream()
.collect(Collectors.groupingBy(AlertCalled::getAlertTypeCode)); .collect(Collectors.groupingBy(AlertCalled::getAlertTypeCode));
Map<Long, AlertCalled> calledMap = alertCalledList.stream() Map<Long, AlertCalled> calledMap = alertCalledList.stream()
.collect(Collectors.toMap(AlertCalled::getSequenceNbr, Function.identity())); .collect(Collectors.toMap(AlertCalled::getSequenceNbr, Function.identity()));
alertCalledMap.forEach((alertTypeCode, list) -> { alertCalledMap.forEach((alertTypeCode, list) -> {
allList.addAll(iAlertFormValueService.listAll(alertTypeCode, queryParams)); allList.addAll(iAlertFormValueService.listAll(alertTypeCode, queryParams));
}); });
allList.forEach(i -> { allList.forEach(i -> {
// 增加非空判断 cz 2021-10-08 // 增加非空判断 cz 2021-10-08
if (calledMap.get(Long.parseLong(i.get("instanceId").toString())) != null) { if (calledMap.get(Long.parseLong(i.get("instanceId").toString())) != null) {
AlertCalled alertCalled = calledMap.get(Long.parseLong(i.get("instanceId").toString())); AlertCalled alertCalled = calledMap.get(Long.parseLong(i.get("instanceId").toString()));
i.putAll(Bean.BeantoMap(alertCalled)); i.putAll(Bean.BeantoMap(alertCalled));
} }
}); });
} }
// 按接警时间正序排序 // 按接警时间正序排序
allList.sort((e, o) -> comparingByGroupVal(e, o, "recDate")); allList.sort((e, o) -> comparingByGroupVal(e, o, "recDate"));
return allList; return allList;
} }
public Map<String, Object> getAlertInfoList(String beginDate, String endDate) { public Map<String, Object> getAlertInfoList(String beginDate, String endDate) {
Map<String, Object> result = Maps.newHashMap(); Map<String, Object> result = Maps.newHashMap();
List<Map<String, Object>> list = listByDateRange(beginDate, endDate); List<Map<String, Object>> list = listByDateRange(beginDate, endDate);
// 获取接警情况模板 // 获取接警情况模板
List<Template> templateList = templateMapper.selectList(new LambdaQueryWrapper<Template>() List<Template> templateList = templateMapper.selectList(new LambdaQueryWrapper<Template>()
.eq(Template::getFormat, false).like(Template::getTypeCode, DutyInfoEnum.接警情况.getKey() + "-")); .eq(Template::getFormat, false).like(Template::getTypeCode, DutyInfoEnum.接警情况.getKey() + "-"));
Map<String, Template> templateMap = templateList.stream() Map<String, Template> templateMap = templateList.stream()
.collect(Collectors.toMap(Template::getTypeCode, Function.identity())); .collect(Collectors.toMap(Template::getTypeCode, Function.identity()));
List<String> contentList = Lists.newArrayList(); List<String> contentList = Lists.newArrayList();
// 增加非空判断 cz 2021-10-08 // 增加非空判断 cz 2021-10-08
list.forEach(i -> { list.forEach(i -> {
if (i.get("alertTypeCode") != null) { if (i.get("alertTypeCode") != null) {
String tempContent = templateMap.get(DutyInfoEnum.接警情况.getKey() + "-" + i.get("alertTypeCode")) String tempContent = templateMap.get(DutyInfoEnum.接警情况.getKey() + "-" + i.get("alertTypeCode"))
.getContent(); .getContent();
contentList.add(replaceTemplate(tempContent, i)); contentList.add(replaceTemplate(tempContent, i));
} }
}); });
Map<String, Integer> statusCountMap = alertCalledMapper.queryAlertStatusCount(beginDate, endDate); Map<String, Integer> statusCountMap = alertCalledMapper.queryAlertStatusCount(beginDate, endDate);
Integer unFinishedCount = this Integer unFinishedCount = this
.count(new LambdaQueryWrapper<AlertCalled>().eq(AlertCalled::getAlertStatus, false));// bug2532 .count(new LambdaQueryWrapper<AlertCalled>().eq(AlertCalled::getAlertStatus, false));// bug2532
// 未结案警情统计错误 // 未结案警情统计错误
// bykongfm // bykongfm
result.put("alertInfoList", contentList); result.put("alertInfoList", contentList);
result.putAll(statusCountMap); result.putAll(statusCountMap);
result.put("unFinishedCount", unFinishedCount); result.put("unFinishedCount", unFinishedCount);
return result; return result;
} }
/** /**
* 替换模板 * 替换模板
* *
* @param tempContent 模板 * @param tempContent 模板
* @param objMap 对象map * @param objMap 对象map
* @return * @return
*/ */
private String replaceTemplate(String tempContent, Map<String, Object> objMap) { private String replaceTemplate(String tempContent, Map<String, Object> objMap) {
int size = objMap.size(); int size = objMap.size();
String[] keys = objMap.keySet().toArray(new String[size]); String[] keys = objMap.keySet().toArray(new String[size]);
Object[] values = objMap.values().toArray(new Object[size]); Object[] values = objMap.values().toArray(new Object[size]);
List<String> strList = Lists.newArrayList(); List<String> strList = Lists.newArrayList();
for (Object obj : values) { for (Object obj : values) {
if (!ValidationUtil.isEmpty(obj)) { if (!ValidationUtil.isEmpty(obj)) {
if (obj instanceof Date) { if (obj instanceof Date) {
obj = DateUtils.date2LongStr((Date) obj); obj = DateUtils.date2LongStr((Date) obj);
} }
strList.add(obj.toString()); strList.add(obj.toString());
} else { } else {
strList.add(""); strList.add("");
} }
} }
return StringUtils.replaceEach(tempContent, keys, strList.toArray(new String[strList.size()])); return StringUtils.replaceEach(tempContent, keys, strList.toArray(new String[strList.size()]));
} }
@Override @Override
public Map<String, Object> selectAlertCalledKeyValueLabelById(Long id) { public Map<String, Object> selectAlertCalledKeyValueLabelById(Long id) {
// 警情基本信息 // 警情基本信息
AlertCalled alertCalled = this.getById(id); AlertCalled alertCalled = this.getById(id);
QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>(); QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>();
Map<String, Object> map = new HashMap<String, Object>(); Map<String, Object> map = new HashMap<String, Object>();
map.put("title", "【" + alertCalled.getAlertType() + "】" + alertCalled.getAddress()); map.put("title", "【" + alertCalled.getAlertType() + "】" + alertCalled.getAddress());
queryWrapper.eq("alert_called_id", id); queryWrapper.eq("alert_called_id", id);
// 警情动态表单数据 // 警情动态表单数据
List<KeyValueLabel> listdate = new ArrayList<>(); List<KeyValueLabel> listdate = new ArrayList<>();
List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper); List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper);
listdate.add(new KeyValueLabel("接警时间", "callTime", alertCalled.getCallTime())); listdate.add(new KeyValueLabel("接警时间", "callTime", alertCalled.getCallTime()));
listdate.add(new KeyValueLabel("警情地点", "address", alertCalled.getAddress())); listdate.add(new KeyValueLabel("警情地点", "address", alertCalled.getAddress()));
listdate.add(new KeyValueLabel("警情类型", "alertType", alertCalled.getAlertType())); listdate.add(new KeyValueLabel("警情类型", "alertType", alertCalled.getAlertType()));
listdate.add(new KeyValueLabel("警情阶段", "alertStage", alertCalled.getAlertStage())); listdate.add(new KeyValueLabel("警情阶段", "alertStage", alertCalled.getAlertStage()));
listdate.add(new KeyValueLabel("警情等级", "responseLevel", "无")); listdate.add(new KeyValueLabel("警情等级", "responseLevel", "无"));
listdate.add(new KeyValueLabel("被困人数", "trappedNum", alertCalled.getTrappedNum())); listdate.add(new KeyValueLabel("被困人数", "trappedNum", alertCalled.getTrappedNum()));
listdate.add(new KeyValueLabel("伤亡人数", "casualtiesNum", alertCalled.getCasualtiesNum())); listdate.add(new KeyValueLabel("伤亡人数", "casualtiesNum", alertCalled.getCasualtiesNum()));
listdate.add(new KeyValueLabel("联系人", "contactUser", alertCalled.getContactUser())); listdate.add(new KeyValueLabel("联系人", "contactUser", alertCalled.getContactUser()));
listdate.add(new KeyValueLabel("联系电话", "contactPhone", alertCalled.getContactPhone())); listdate.add(new KeyValueLabel("联系电话", "contactPhone", alertCalled.getContactPhone()));
// listdate.add(new KeyValueLabel("联系人电话", "contactPhone", alertCalled.getContactPhone())); // listdate.add(new KeyValueLabel("联系人电话", "contactPhone", alertCalled.getContactPhone()));
list.stream().forEach(alertFormValue -> { list.stream().forEach(alertFormValue -> {
/* 2661 灾情详情中字典类数据错误显示为code 改为value值 2021-09-23 陈召 开始 */ /* 2661 灾情详情中字典类数据错误显示为code 改为value值 2021-09-23 陈召 开始 */
String valueCode = alertFormValue.getFieldValue(); String valueCode = alertFormValue.getFieldValue();
/* 2661 灾情详情中字典类数据错误显示为code 改为value值 2021-09-23 陈召 结束 */ /* 2661 灾情详情中字典类数据错误显示为code 改为value值 2021-09-23 陈召 结束 */
/* /*
* if(null == valueCode) { valueCode = alertFormValue.getFieldValue(); } * if(null == valueCode) { valueCode = alertFormValue.getFieldValue(); }
*/ */
listdate.add(new KeyValueLabel(alertFormValue.getFieldName(), alertFormValue.getFieldCode(), valueCode)); listdate.add(new KeyValueLabel(alertFormValue.getFieldName(), alertFormValue.getFieldCode(), valueCode));
}); });
map.put("data", listdate); map.put("data", listdate);
return map; return map;
} }
@Override @Override
public List<KeyValueLabel> selectAlertCalledcount(Long id) { public List<KeyValueLabel> selectAlertCalledcount(Long id) {
// 警情基本信息 // 警情基本信息
AlertCalled alertCalled = this.getById(id); AlertCalled alertCalled = this.getById(id);
List<KeyValueLabel> listdate = new ArrayList<>(); List<KeyValueLabel> listdate = new ArrayList<>();
listdate.add(new KeyValueLabel("被困人数", "trappedNum", alertCalled.getTrappedNum())); listdate.add(new KeyValueLabel("被困人数", "trappedNum", alertCalled.getTrappedNum()));
listdate.add(new KeyValueLabel("伤亡人数", "casualtiesNum", alertCalled.getCasualtiesNum())); listdate.add(new KeyValueLabel("伤亡人数", "casualtiesNum", alertCalled.getCasualtiesNum()));
return listdate; return listdate;
} }
@Override @Override
public List<KeyValueLabel> powercount(Long id) { public List<KeyValueLabel> powercount(Long id) {
Map<String, Integer> map = powerTransferMapper.getCarNum(id); Map<String, Integer> map = powerTransferMapper.getCarNum(id);
// Map<String,Integer> mapc=powerTransferMapper.getCompanyNum(id); // Map<String,Integer> mapc=powerTransferMapper.getCompanyNum(id);
// Map<String,Integer> mapu= alertSubmittedMapper.getUseNum(id); // Map<String,Integer> mapu= alertSubmittedMapper.getUseNum(id);
// 统计参与人员 // 统计参与人员
List<KeyValueLabel> listdate = new ArrayList<>(); List<KeyValueLabel> listdate = new ArrayList<>();
listdate.add(new KeyValueLabel("调动人力", "useNum", "0", "人")); listdate.add(new KeyValueLabel("调动人力", "useNum", "0", "人"));
// 统计参与车辆 // 统计参与车辆
listdate.add(new KeyValueLabel("调动人力", "carNum", map.get("carNum"), "辆")); listdate.add(new KeyValueLabel("调动人力", "carNum", map.get("carNum"), "辆"));
// 统计参与队伍 // 统计参与队伍
listdate.add(new KeyValueLabel("调动单位", "companyNum", map.get("companyNum"), "个")); listdate.add(new KeyValueLabel("调动单位", "companyNum", map.get("companyNum"), "个"));
return listdate; return listdate;
} }
@Override @Override
public List<PowerData> getPowerDataList(Long id) { public List<PowerData> getPowerDataList(Long id) {
List<PowerData> list = powerTransferMapper.getPowerDataList(id); List<PowerData> list = powerTransferMapper.getPowerDataList(id);
return list; return list;
} }
@Override @Override
public AlertCalled getAlertCalledById(Long id) { public AlertCalled getAlertCalledById(Long id) {
return this.getById(id); return this.getById(id);
} }
@Override @Override
public Integer AlertCalledcountTime(int type) { public Integer AlertCalledcountTime(int type) {
return alertCalledMapper.AlertCalledcountTime(type); return alertCalledMapper.AlertCalledcountTime(type);
} }
@Override @Override
public List<AlertCalledTodyDto> getTodayAlertCalled() { public List<AlertCalledTodyDto> getTodayAlertCalled() {
return alertCalledMapper.getTodayAlertCalled(); return alertCalledMapper.getTodayAlertCalled();
} }
public Boolean controlEquip() { public Boolean controlEquip() {
/** /**
* 获取控制器设备 * 获取控制器设备
*/ */
List<ControllerEquipDto> controllerEquipDtoList = controllerEquipService.queryAllForList(); List<ControllerEquipDto> controllerEquipDtoList = controllerEquipService.queryAllForList();
Map<Long, List<String>> controllerEquipMap = new HashMap<>(); Map<Long, List<String>> controllerEquipMap = new HashMap<>();
for (ControllerEquipDto controllerEquipDto : controllerEquipDtoList) { for (ControllerEquipDto controllerEquipDto : controllerEquipDtoList) {
List<String> numList = controllerEquipMap.get(controllerEquipDto.getControllerSeq()); List<String> numList = controllerEquipMap.get(controllerEquipDto.getControllerSeq());
if (ValidationUtil.isEmpty(numList)) { if (ValidationUtil.isEmpty(numList)) {
numList = new ArrayList<>(); numList = new ArrayList<>();
} }
numList.add(controllerEquipDto.getNum()); numList.add(controllerEquipDto.getNum());
controllerEquipMap.put(controllerEquipDto.getControllerSeq(), numList); controllerEquipMap.put(controllerEquipDto.getControllerSeq(), numList);
} }
/** /**
* 获取联动控制器 * 获取联动控制器
*/ */
List<ControllerDto> controllerDtoList = controllerService.queryAllForList(); List<ControllerDto> controllerDtoList = controllerService.queryAllForList();
StringBuilder bellNumSb = new StringBuilder(); StringBuilder bellNumSb = new StringBuilder();
// StringBuilder broadcastNumSb = new StringBuilder(); // StringBuilder broadcastNumSb = new StringBuilder();
for (ControllerDto controllerDto : controllerDtoList) { for (ControllerDto controllerDto : controllerDtoList) {
// 消防警铃 // 消防警铃
if (controllerDto.getType().equals(ControllerTypeEnum.BELL.getCode())) { if (controllerDto.getType().equals(ControllerTypeEnum.BELL.getCode())) {
List<String> bellNumList = controllerEquipMap.get(controllerDto.getSequenceNbr()); List<String> bellNumList = controllerEquipMap.get(controllerDto.getSequenceNbr());
if (!ValidationUtil.isEmpty(bellNumList)) { if (!ValidationUtil.isEmpty(bellNumList)) {
for (String num : bellNumList) { for (String num : bellNumList) {
bellNumSb.append(num).append(","); bellNumSb.append(num).append(",");
} }
} }
} }
// 广播 // 广播
// if (controllerDto.getType().equals(ControllerTypeEnum.BROADCAST.getCode())) { // if (controllerDto.getType().equals(ControllerTypeEnum.BROADCAST.getCode())) {
// List<String> broadcastList = controllerEquipMap.get(controllerDto.getSequenceNbr()); // List<String> broadcastList = controllerEquipMap.get(controllerDto.getSequenceNbr());
// if (!ValidationUtil.isEmpty(broadcastList)) { // if (!ValidationUtil.isEmpty(broadcastList)) {
...@@ -652,278 +643,266 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal ...@@ -652,278 +643,266 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
// } // }
// } // }
// } // }
} }
/** /**
* 打开消防警铃 * 打开消防警铃
*/ */
if (!ValidationUtil.isEmpty(bellNumSb.toString())) { if (!ValidationUtil.isEmpty(bellNumSb.toString())) {
String bellNum = bellNumSb.toString(); String bellNum = bellNumSb.toString();
bellNum = bellNum.substring(0, bellNum.length() - 1); bellNum = bellNum.substring(0, bellNum.length() - 1);
String[] bellNums = bellNum.split(","); String[] bellNums = bellNum.split(",");
for (int i = 0; i < bellNums.length; i++) for (int i = 0; i < bellNums.length; i++) {
{ //打开15s后自动关闭
//打开15s后自动关闭 try {
try jcsControlServerClient.sendBellActionWithTime(bellNums[i], "1", 15);
{ } catch (Exception e) {
jcsControlServerClient.sendBellActionWithTime(bellNums[i], "1", 15); logger.info("打开警铃【" + bellNums[i] + "】异常！");
} }
catch (Exception e) }
{ }
logger.info("打开警铃【"+bellNums[i]+"】异常！"); /**
} * 播放广播
} */
}
/**
* 播放广播
*/
// if (!ValidationUtil.isEmpty(broadcastNumSb.toString())) { // if (!ValidationUtil.isEmpty(broadcastNumSb.toString())) {
// String broadcastNum = broadcastNumSb.toString(); // String broadcastNum = broadcastNumSb.toString();
// broadcastNum = broadcastNum.substring(0, broadcastNum.length() - 1); // broadcastNum = broadcastNum.substring(0, broadcastNum.length() - 1);
// jcsControlServerClient.sendFileAction(broadcastNum, "1490075199246.mp3"); // jcsControlServerClient.sendFileAction(broadcastNum, "1490075199246.mp3");
// } // }
/** /**
* 打开北站车库门 * 打开北站车库门
*/ */
List<ControllerDto> northDoor = controllerService.queryForList("3", ControllerTypeEnum.DOOR.getCode()); List<ControllerDto> northDoor = controllerService.queryForList("3", ControllerTypeEnum.DOOR.getCode());
if (!ValidationUtil.isEmpty(northDoor)) { if (!ValidationUtil.isEmpty(northDoor)) {
ControllerDto controllerDto = northDoor.get(0); ControllerDto controllerDto = northDoor.get(0);
// 打开北站车库门 // 打开北站车库门
try try {
{ jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 100, "1,1,1,1");
jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 100, "1,1,1,1"); } catch (Exception e) {
} logger.info("打开北站车库门【" + controllerDto.getIp() + "】异常！");
catch (Exception e) }
{ // 打开北站车库门弱电警铃
logger.info("打开北站车库门【"+controllerDto.getIp()+"】异常！"); try {
} jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 107, "1");
// 打开北站车库门弱电警铃 } catch (Exception e) {
try logger.info("打开北站弱电警铃【" + controllerDto.getIp() + "】异常！");
{ }
jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 107, "1"); }
} /**
catch (Exception e) * 打开南站车库门
{ */
logger.info("打开北站弱电警铃【"+controllerDto.getIp()+"】异常！"); List<ControllerDto> southDoor = controllerService.queryForList("2", ControllerTypeEnum.DOOR.getCode());
} if (!ValidationUtil.isEmpty(southDoor)) {
} ControllerDto controllerDto = southDoor.get(0);
/** // 打开南站车库门
* 打开南站车库门 try {
*/ jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 100, "1");
List<ControllerDto> southDoor = controllerService.queryForList("2", ControllerTypeEnum.DOOR.getCode()); } catch (Exception e) {
if (!ValidationUtil.isEmpty(southDoor)) { logger.info("打开南站车库门【" + controllerDto.getIp() + "】异常！");
ControllerDto controllerDto = southDoor.get(0); }
// 打开南站车库门 // 打开南站车库门弱电警铃
try try {
{ jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 107, "1");
jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 100, "1"); } catch (Exception e) {
} logger.info("打开南站弱电警铃【" + controllerDto.getIp() + "】异常！");
catch (Exception e) }
{ }
logger.info("打开南站车库门【"+controllerDto.getIp()+"】异常！");
} return true;
// 打开南站车库门弱电警铃 }
try
{ /**
jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 107, "1"); * 警情重新定位
} *
catch (Exception e) * @param alertId 警情id
{ * @param longitude 经度
logger.info("打开南站弱电警铃【"+controllerDto.getIp()+"】异常！"); * @param latitude 纬度
} * @return
} */
public Boolean reLocate(String alertId, String longitude, String latitude) {
return true; try {
} // 更新警情主表
AlertCalled alertCalled = this.baseMapper.selectById(alertId);
/** alertCalled.setCoordinateX(Double.valueOf(longitude));
* 警情重新定位 alertCalled.setCoordinateY(Double.valueOf(latitude));
* this.updateById(alertCalled);
* @param alertId 警情id // 插入定位日志表
* @param longitude 经度 AlertLocationLog alertLocationLog = new AlertLocationLog();
* @param latitude 纬度 alertLocationLog.setAlertId(Long.valueOf(alertId));
* @return alertLocationLog.setLongitude(longitude);
*/ alertLocationLog.setLatitude(latitude);
public Boolean reLocate(String alertId, String longitude, String latitude) { alertLocationLogService.save(alertLocationLog);
try {
// 更新警情主表 return true;
AlertCalled alertCalled = this.baseMapper.selectById(alertId); } catch (Exception e) {
alertCalled.setCoordinateX(Double.valueOf(longitude)); log.error(e.toString());
alertCalled.setCoordinateY(Double.valueOf(latitude)); e.printStackTrace();
this.updateById(alertCalled); throw new RuntimeException("警情定位失败!");
// 插入定位日志表 }
AlertLocationLog alertLocationLog = new AlertLocationLog(); }
alertLocationLog.setAlertId(Long.valueOf(alertId));
alertLocationLog.setLongitude(longitude); @Override
alertLocationLog.setLatitude(latitude); public Map<String, Object> queryAlertCalledById(Long id) {
alertLocationLogService.save(alertLocationLog);
// 警情基本信息
return true; AlertCalled alertCalled = this.getById(id);
} catch (Exception e) { QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>();
log.error(e.toString()); Map<String, Object> map = new HashMap<>();
e.printStackTrace(); map.put("title", "【" + alertCalled.getAlertType() + "】" + alertCalled.getAddress());
throw new RuntimeException("警情定位失败!"); queryWrapper.eq("alert_called_id", id);
}
} // 警情动态表单数据
List<KeyValueLabel> listdate = new ArrayList<>();
@Override List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper);
public Map<String, Object> queryAlertCalledById(Long id) { listdate.add(new KeyValueLabel("接警时间", "callTime", alertCalled.getCallTime()));
listdate.add(new KeyValueLabel("警情地点", "address", alertCalled.getAddress()));
// 警情基本信息 listdate.add(new KeyValueLabel("警情类型", "alertType", alertCalled.getAlertType()));
AlertCalled alertCalled = this.getById(id); listdate.add(new KeyValueLabel("警情阶段", "alertStage", alertCalled.getAlertStage()));
QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>(); listdate.add(new KeyValueLabel("警情等级", "responseLevel", "无"));
Map<String, Object> map = new HashMap<String, Object>(); listdate.add(new KeyValueLabel("被困人数", "trappedNum", alertCalled.getTrappedNum()));
map.put("title", "【" + alertCalled.getAlertType() + "】" + alertCalled.getAddress()); listdate.add(new KeyValueLabel("伤亡人数", "casualtiesNum", alertCalled.getCasualtiesNum()));
queryWrapper.eq("alert_called_id", id); listdate.add(new KeyValueLabel("联系人", "contactUser", alertCalled.getContactUser()));
listdate.add(new KeyValueLabel("联系电话", "contactPhone", alertCalled.getContactPhone()));
// 警情动态表单数据 listdate.add(new KeyValueLabel("联系人电话", "contactPhone", alertCalled.getContactPhone()));
List<KeyValueLabel> listdate = new ArrayList<>(); list.stream().forEach(alertFormValue -> {
List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper); String valueCode = alertFormValue.getFieldValueCode();
listdate.add(new KeyValueLabel("接警时间", "callTime", alertCalled.getCallTime())); if (null == valueCode) {
listdate.add(new KeyValueLabel("警情地点", "address", alertCalled.getAddress())); valueCode = alertFormValue.getFieldValue();
listdate.add(new KeyValueLabel("警情类型", "alertType", alertCalled.getAlertType())); }
listdate.add(new KeyValueLabel("警情阶段", "alertStage", alertCalled.getAlertStage())); listdate.add(new KeyValueLabel(alertFormValue.getFieldName(), alertFormValue.getFieldCode(), valueCode));
listdate.add(new KeyValueLabel("警情等级", "responseLevel", "无")); if ("fireTime".equals(alertFormValue.getFieldCode())) {
listdate.add(new KeyValueLabel("被困人数", "trappedNum", alertCalled.getTrappedNum())); map.put("occurrenceTime", alertFormValue.getFieldValue());
listdate.add(new KeyValueLabel("伤亡人数", "casualtiesNum", alertCalled.getCasualtiesNum())); }
listdate.add(new KeyValueLabel("联系人", "contactUser", alertCalled.getContactUser())); });
listdate.add(new KeyValueLabel("联系电话", "contactPhone", alertCalled.getContactPhone())); map.put("data", listdate);
listdate.add(new KeyValueLabel("联系人电话", "contactPhone", alertCalled.getContactPhone()));
list.stream().forEach(alertFormValue -> { // app警情首页使用alarmDetailInfo，alarmContactInfo
String valueCode = alertFormValue.getFieldValueCode(); if (!AlertStageEnums.YBHZ.getCode().equals(alertCalled.getAlertTypeCode())) {
if (null == valueCode) { map.put("occurrenceTime", alertCalled.getCallTime());
valueCode = alertFormValue.getFieldValue(); }
} map.put("alertType", alertCalled.getAlertType());
listdate.add(new KeyValueLabel(alertFormValue.getFieldName(), alertFormValue.getFieldCode(), valueCode)); map.put("address", alertCalled.getAddress());
if ("fireTime".equals(alertFormValue.getFieldCode())) { map.put("contactUser", alertCalled.getContactUser());
map.put("occurrenceTime", alertFormValue.getFieldValue()); map.put("contactPhone", alertCalled.getContactPhone());
} map.put("callTime", alertCalled.getCallTime());
}); //获取通话录音文件地址
map.put("data", listdate); List<VoiceRecordFileDto> voiceRecordFileDtos = voiceRecordFileService.listByAlertId(alertCalled.getSequenceNbr());
if (!voiceRecordFileDtos.isEmpty()) {
// app警情首页使用alarmDetailInfo，alarmContactInfo map.put("voiceRecordFile", voiceRecordFileDtos.get(0).getFilePath());
if (!AlertStageEnums.YBHZ.getCode().equals(alertCalled.getAlertTypeCode())) { }
map.put("occurrenceTime", alertCalled.getCallTime()); return map;
} }
map.put("alertType", alertCalled.getAlertType());
map.put("address", alertCalled.getAddress()); // 未结案警情统计
@Override
map.put("contactUser", alertCalled.getContactUser()); public Integer AlertCalledcount(int type) {
map.put("contactPhone", alertCalled.getContactPhone()); return alertCalledMapper.AlertCalledcount(0);
map.put("callTime", alertCalled.getCallTime()); }
return map;
} @Override
public List<AlertCalled> AlertCalledStatusPage(Integer current, Integer size) {
// 未结案警情统计 return alertCalledMapper.AlertCalledStatusPage(current, size);
@Override }
public Integer AlertCalledcount(int type) {
return alertCalledMapper.AlertCalledcount(0); @Override
} public List<JSONObject> queryDisposalObjectList(String alertId) {
AlertCalled alertCalled = this.getById(Long.valueOf(alertId));
@Override String alertTypeCode = alertCalled.getAlertTypeCode();
public List<AlertCalled> AlertCalledStatusPage(Integer current, Integer size) { AlertStageEnums alertStage = AlertStageEnums.getEnum(alertTypeCode);
return alertCalledMapper.AlertCalledStatusPage(current, size); List<JSONObject> resultList = Lists.newArrayList();
} if (alertStage != null) {
switch (alertStage) {
@Override case YBHZ:
public List<JSONObject> queryDisposalObjectList(String alertId) { case TFSJ:
AlertCalled alertCalled = this.getById(Long.valueOf(alertId)); case QTJQ:
String alertTypeCode = alertCalled.getAlertTypeCode(); resultList = queryDisposalObjectUnit(alertCalled);
AlertStageEnums alertStage = AlertStageEnums.getEnum(alertTypeCode); break;
List<JSONObject> resultList = Lists.newArrayList(); case HKJY:
if (alertStage != null) { case LYXC:
switch (alertStage) { case ZJBZ:
case YBHZ: resultList = queryDisposalObjectAircraft(alertCalled);
case TFSJ: default:
case QTJQ: break;
resultList = queryDisposalObjectUnit(alertCalled); }
break; }
case HKJY: return resultList;
case LYXC: }
case ZJBZ:
resultList = queryDisposalObjectAircraft(alertCalled); private List<JSONObject> queryDisposalObjectUnit(AlertCalled alertCalled) {
default: List<JSONObject> resultList = Lists.newArrayList();
break; if (!ValidationUtil.isEmpty(alertCalled.getUnitInvolved())) {
} List<OrgUsrzhDto> unitInvolvedDto = iOrgUsrService.getOrgUsrzhDto(alertCalled.getUnitInvolved());
} JSONObject a1 = new JSONObject();
return resultList; a1.put("name", "单位名称");
} a1.put("value",
!ValidationUtil.isEmpty(unitInvolvedDto.get(0)) ? unitInvolvedDto.get(0).getBizOrgName() : "");
private List<JSONObject> queryDisposalObjectUnit(AlertCalled alertCalled) { JSONObject a2 = new JSONObject();
List<JSONObject> resultList = Lists.newArrayList(); a2.put("name", "单位性质");
if (!ValidationUtil.isEmpty(alertCalled.getUnitInvolved())) { a2.put("value",
List<OrgUsrzhDto> unitInvolvedDto = iOrgUsrService.getOrgUsrzhDto(alertCalled.getUnitInvolved()); !ValidationUtil.isEmpty(unitInvolvedDto.get(0)) ? unitInvolvedDto.get(0).getCompanyNature() : "");
JSONObject a1 = new JSONObject(); JSONObject a3 = new JSONObject();
a1.put("name", "单位名称"); a3.put("name", "单位电话");
a1.put("value", a3.put("value",
!ValidationUtil.isEmpty(unitInvolvedDto.get(0)) ? unitInvolvedDto.get(0).getBizOrgName() : ""); !ValidationUtil.isEmpty(unitInvolvedDto.get(0)) ? unitInvolvedDto.get(0).getCompanyPhone() : "");
JSONObject a2 = new JSONObject(); JSONObject a4 = new JSONObject();
a2.put("name", "单位性质"); a4.put("name", "单位地址");
a2.put("value", a4.put("value",
!ValidationUtil.isEmpty(unitInvolvedDto.get(0)) ? unitInvolvedDto.get(0).getCompanyNature() : ""); !ValidationUtil.isEmpty(unitInvolvedDto.get(0)) ? unitInvolvedDto.get(0).getCompanyLocation() : "");
JSONObject a3 = new JSONObject(); JSONObject a5 = new JSONObject();
a3.put("name", "单位电话"); a5.put("name", "重点部位数量");
a3.put("value", a5.put("value", !ValidationUtil.isEmpty(unitInvolvedDto.get(0))
!ValidationUtil.isEmpty(unitInvolvedDto.get(0)) ? unitInvolvedDto.get(0).getCompanyPhone() : ""); ? unitInvolvedDto.get(0).getKeySiteCount() != null ? unitInvolvedDto.get(0).getKeySiteCount() : 0
JSONObject a4 = new JSONObject(); : 0 + "个");
a4.put("name", "单位地址"); resultList.add(a1);
a4.put("value", resultList.add(a2);
!ValidationUtil.isEmpty(unitInvolvedDto.get(0)) ? unitInvolvedDto.get(0).getCompanyLocation() : ""); resultList.add(a3);
JSONObject a5 = new JSONObject(); resultList.add(a4);
a5.put("name", "重点部位数量"); resultList.add(a5);
a5.put("value", !ValidationUtil.isEmpty(unitInvolvedDto.get(0)) }
? unitInvolvedDto.get(0).getKeySiteCount() != null ? unitInvolvedDto.get(0).getKeySiteCount() : 0 return resultList;
: 0 + "个"); }
resultList.add(a1);
resultList.add(a2); private List<JSONObject> queryDisposalObjectAircraft(AlertCalled alertCalled) {
resultList.add(a3); // 警情动态表单数据
resultList.add(a4); List<AlertFormValue> list = alertFormValueService.getzqlist(alertCalled.getSequenceNbr());
resultList.add(a5); Aircraft aircraft = new Aircraft();
} for (AlertFormValue alertFormValue : list) {
return resultList; if ("aircraftModel".equals(alertFormValue.getFieldCode())) {
} String aircraftModel = alertFormValue.getFieldValue();
aircraft = aircraftService.queryAircraftInfoByModel(aircraftModel);
private List<JSONObject> queryDisposalObjectAircraft(AlertCalled alertCalled) { break;
// 警情动态表单数据 }
List<AlertFormValue> list = alertFormValueService.getzqlist(alertCalled.getSequenceNbr()); }
Aircraft aircraft = new Aircraft(); List<JSONObject> resultList = Lists.newArrayList();
for (AlertFormValue alertFormValue : list) { if (!ValidationUtil.isEmpty(aircraft)) {
if ("aircraftModel".equals(alertFormValue.getFieldCode())) { JSONObject a1 = new JSONObject();
String aircraftModel = alertFormValue.getFieldValue(); a1.put("name", "飞机型号");
aircraft = aircraftService.queryAircraftInfoByModel(aircraftModel); a1.put("value", aircraft.getAircraftModel());
break; JSONObject a2 = new JSONObject();
} a2.put("name", "发动机类型");
} a2.put("value", aircraft.getEngineType());
List<JSONObject> resultList = Lists.newArrayList(); JSONObject a3 = new JSONObject();
if (!ValidationUtil.isEmpty(aircraft)) { a3.put("name", "发动机数量");
JSONObject a1 = new JSONObject(); a3.put("value", aircraft.getEnginesmNum());
a1.put("name", "飞机型号"); JSONObject a4 = new JSONObject();
a1.put("value", aircraft.getAircraftModel()); a4.put("name", "燃油类型");
JSONObject a2 = new JSONObject(); a4.put("value", aircraft.getFuelType());
a2.put("name", "发动机类型"); JSONObject a5 = new JSONObject();
a2.put("value", aircraft.getEngineType()); a5.put("name", "主要燃烧物质");
JSONObject a3 = new JSONObject(); a5.put("value", aircraft.getCombustionMaterial());
a3.put("name", "发动机数量"); resultList.add(a1);
a3.put("value", aircraft.getEnginesmNum()); resultList.add(a2);
JSONObject a4 = new JSONObject(); resultList.add(a3);
a4.put("name", "燃油类型"); resultList.add(a4);
a4.put("value", aircraft.getFuelType()); resultList.add(a5);
JSONObject a5 = new JSONObject(); }
a5.put("name", "主要燃烧物质"); return resultList;
a5.put("value", aircraft.getCombustionMaterial()); }
resultList.add(a1);
resultList.add(a2); /* 2304 地址 联系人模糊查询缺失 陈召 2021-09-23 开始 */
resultList.add(a3); public List<Map<String, String>> getContactName() {
resultList.add(a4); // List<Map<String,String>> firefightersName =
resultList.add(a5); // firefightersService.getFirefightersName();
} // firefightersName.forEach(r->{
return resultList;
}
/* 2304 地址 联系人模糊查询缺失 陈召 2021-09-23 开始 */
public List<Map<String, String>> getContactName() {
// List<Map<String,String>> firefightersName =
// firefightersService.getFirefightersName();
// firefightersName.forEach(r->{
// String phone = r.get("phone"); // String phone = r.get("phone");
// phone = QRCodeUtil.generateQRCode()+"@"+phone; // phone = QRCodeUtil.generateQRCode()+"@"+phone;
// r.put("phone",phone); // r.put("phone",phone);
...@@ -937,32 +916,32 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal ...@@ -937,32 +916,32 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
// } // }
// ); // );
// firefightersName.addAll(contactNames); // firefightersName.addAll(contactNames);
List<Map<String, String>> list = orgUsrServiceImpl.getPersonSimpleDetail(); List<Map<String, String>> list = orgUsrServiceImpl.getPersonSimpleDetail();
list.stream().forEach(i->{ list.stream().forEach(i -> {
String phone=""; String phone = "";
if(i.containsKey("phone")) { if (i.containsKey("phone")) {
phone = QRCodeUtil.generateQRCode()+"@"+ i.get("phone").toString(); phone = QRCodeUtil.generateQRCode() + "@" + i.get("phone").toString();
i.replace("phone", phone); i.replace("phone", phone);
}else { } else {
phone = QRCodeUtil.generateQRCode()+"@"+ phone; phone = QRCodeUtil.generateQRCode() + "@" + phone;
i.put("phone", phone); i.put("phone", phone);
} }
}); });
return list; return list;
} }
public List<String> getCalledAddress() { public List<String> getCalledAddress() {
List<String> keyAddress = keySiteService.getAddress(); List<String> keyAddress = keySiteService.getAddress();
List<String> alertAddress = alertCalledMapper.getAddress(); List<String> alertAddress = alertCalledMapper.getAddress();
keyAddress.addAll(alertAddress); keyAddress.addAll(alertAddress);
return keyAddress; return keyAddress;
} }
/* 2304 地址 联系人模糊查询缺失 陈召 2021-09-23 结束 */ /* 2304 地址 联系人模糊查询缺失 陈召 2021-09-23 结束 */
public Set<Map<String, Object>> getLocationLike(String locationt) { public Set<Map<String, Object>> getLocationLike(String locationt) {
Set<Map<String, Object>> set= alertCalledMapper.getLocation(); Set<Map<String, Object>> set = alertCalledMapper.getLocation();
set.remove(null); set.remove(null);
return set; return set;
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment