Merge remote-tracking branch 'origin/developer' into developer

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/java/com/yeejoin/amos/boot/module/ccs/api/dto/FireLatentDangerDto.java

@@ -65,10 +65,10 @@ public class FireLatentDangerDto extends BaseDto {
     @ApiModelProperty(value = "纬度")
     private String lat;
 
-    @ApiModelProperty(value ="隐患经度")
-    private String sourceLng;
+    @ApiModelProperty(value = "换流站经度")
+    private String stationLng;
 
-    @ApiModelProperty(value = "隐患纬度")
-    private String sourceLat;
+    @ApiModelProperty(value = "换流站纬度")
+    private String stationLat;
 
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-ccs-api/src/main/resources/mapper/FireLatentDangerMapper.xml

@@ -13,18 +13,10 @@
         s.name as station_name,
         d.station_code,
         d.discovery_date,
-        <choose>
-            <when test="stationCode != null and stationCode != ''">
-                d.lat,
         d.lng,
-            </when>
-            <otherwise>
-                s.lng,
-                s.lat,
-            </otherwise>
-        </choose>
-        d.lng as sourceLng,
-        d.lat as sourceLat
+        d.lat,
+        s.lng as stationLng,
+        s.lat as stationLat
         from
         asf_fire_latent_danger d,
         asf_fire_station_info s

amos-boot-module/amos-boot-module-api/amos-boot-module-latentdanger-api/src/main/java/com/yeejoin/amos/latentdanger/common/enums/LatentDangerState.java

@@ -45,7 +45,7 @@ public interface LatentDangerState {
         /**
          * 检查组长确认
          */
-        检查组长确认("检查组长确认", "leaderConfirm", "secondConfirm","onSiteConfirm", "1", ""),
+        检查组长确认("检查组长确认", "leaderConfirm", "secondConfirm","onSiteConfirm", "1", "auditRecordPage"),
         /**
          * 隐患二次审核确认
          */

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/ESOrgUsrService.java

@@ -92,9 +92,15 @@ public class ESOrgUsrService {
     public ESOrgUsrDto saveAlertCalledToES(OrgUsr orgUsr) throws Exception
     {
     	ESOrgUsrDto esOrgUsrDto = new ESOrgUsrDto();
-    	esOrgUsrDto.setSequenceNbr(orgUsr.getSequenceNbr());
+    	String seqStr = String.valueOf(orgUsr.getSequenceNbr());
+    	try {
+			Long seq = Long.parseLong(seqStr);
+			esOrgUsrDto.setSequenceNbr(seq);
 			esOrgUsrDto.setBizOrgName(orgUsr.getBizOrgName());
 			esOrgUsrDtoRepository.save(esOrgUsrDto);
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
     	return esOrgUsrDto;
     }
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/FireStationServiceImpl.java

@@ -116,8 +116,12 @@ public class FireStationServiceImpl extends BaseService<FireStationDto, FireStat
             if (model.getAddress() != null) {
                 JSONObject address = WaterResourceServiceImpl.getLongLatFromAddress(model.getAddress());
                 model.setAddress(address.getString(BizConstant.ADDRESS));
+                if(!"0".equals(address.getString(BizConstant.LONGITUDE))) {
                     model.setLongitude(Double.valueOf(address.getString(BizConstant.LONGITUDE)));
-                model.setLatitude(Double.valueOf(address.getString(BizConstant.LATITUDE)));
+                }
+                if(!"0".equals(address.getString(BizConstant.LATITUDE))) {
+                    model.setLongitude(Double.valueOf(address.getString(BizConstant.LATITUDE)));
+                }
             }
         }
         FireStation entity = this.prepareEntity(model);
@@ -139,8 +143,12 @@ public class FireStationServiceImpl extends BaseService<FireStationDto, FireStat
         if (model.getAddress() != null) {
             JSONObject address = WaterResourceServiceImpl.getLongLatFromAddress(model.getAddress());
             model.setAddress(address.getString(BizConstant.ADDRESS));
+            if(!"0".equals(address.getString(BizConstant.LONGITUDE))) {
                 model.setLongitude(Double.valueOf(address.getString(BizConstant.LONGITUDE)));
-            model.setLatitude(Double.valueOf(address.getString(BizConstant.LATITUDE)));
+            }
+            if(!"0".equals(address.getString(BizConstant.LATITUDE))) {
+                model.setLongitude(Double.valueOf(address.getString(BizConstant.LATITUDE)));
+            }
         }
 
         FireStation entity = this.prepareEntity(model);

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/OrgUsrServiceImpl.java

@@ -544,7 +544,7 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
 
 		Map<Long, DynamicFormInstanceDto> resourceMap = new HashMap<>();
 		Map<Long, DynamicFormInstance> newResourceMap = new HashMap<>();
-		formList.parallelStream().forEach(form -> {
+		formList.forEach(form -> {
 			resourceMap.put(form.getFormColumnId(), form);
 		});
 
@@ -552,7 +552,7 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
 		List<DynamicFormInstance> addList = new ArrayList<>();
 		List<Long> deleteList = new ArrayList<>();
 
-		fromValueList.parallelStream().forEach(submitFormItem -> {
+		fromValueList.forEach(submitFormItem -> {
 			if (resourceMap.containsKey(submitFormItem.getFormColumnId())) {
 				DynamicFormInstanceDto oldForm = resourceMap.get(submitFormItem.getFormColumnId());
 				submitFormItem.setSequenceNbr(oldForm.getSequenceNbr());
@@ -563,11 +563,11 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
 			newResourceMap.put(submitFormItem.getFormColumnId(), submitFormItem);
 		});
 
-		newResourceMap.keySet().parallelStream().forEach(form -> {
+		newResourceMap.keySet().forEach(form -> {
 			resourceMap.remove(form);
 		});
 
-		resourceMap.keySet().parallelStream().forEach(action -> {
+		resourceMap.keySet().forEach(action -> {
 			deleteList.add(resourceMap.get(action).getSequenceNbr());
 		});
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/controller/AlertSubmittedController.java

@@ -262,26 +262,6 @@ public class AlertSubmittedController extends BaseController {
         return ResponseHelper.buildResponse(schedulingContent);
     }
 
-    /**
-     * 获取警情续报内容
-     *
-     * @return 返回结果
-     */
-    @TycloudOperation(ApiLevel = UserType.AGENCY)
-    @RequestMapping(value = "/alert_submitted/ddd", method = RequestMethod.GET)
-    @ApiOperation(httpMethod = "GET", value = "获取警情续报内容和模板", notes = "获取警情续报内容和模板")
-    public ResponseModel<Object> getAlertSubmittedContentDD() {
-        try {
-            AlertCalledFormDto alertCalledFormDto = (AlertCalledFormDto)alertCalledService.selectAlertCalledByIdNoRedis(1455815417061728258L);
-
-            alertSubmittedService.generateMob(alertCalledFormDto.getAlertCalled());
-        }  catch (FileNotFoundException e) {
-            e.printStackTrace();
-        } catch (ParseException e) {
-            e.printStackTrace();
-        }
-        return ResponseHelper.buildResponse(null);
-    }
 
     private String getTaskInformation(String content, Map<String, String> definitions) {
         int size = definitions.size();

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/AlertSubmittedServiceImpl.java

@@ -206,6 +206,7 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
                     definitions.put("$callTime", DateUtils.dateTimeToDateString(alertCalled.getCallTime()));
                     definitions.put("$replaceContent",replaceContent);
                     definitions.put("$address",alertCalled.getAddress());
+                    definitions.put("$recDate",DateUtils.dateTimeToDateString(alertCalled.getRecDate()));
                     String content = getTaskInformation( template.getRichContent(),definitions);
 
                     alertSubmittedExtDto.setSubmissionContentValue(JSONObject.parseObject(alertSubmittedExtDto.getSubmissionContent()));
@@ -848,16 +849,21 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
         }
     }
     void handleFunc(AlertCalledPowerInfoDto dto,Map<String, Object> map) {
+        if (map.containsKey("carName")) {
             dto.setCarName(map.get("carName").toString());
+        }
+
         dto.setStation(map.get("companyName").toString());
         // 随车人员
+        if (map.containsKey("id")) {
             List<PowerData> powerDataOne = powerTransferMapper.getPowerDataOne(Long.valueOf(map.get("id").toString()));
-        if(!ValidationUtil.isEmpty(powerDataOne)) {
+            if (!ValidationUtil.isEmpty(powerDataOne)) {
                 dto.setPersonNum(String.valueOf(powerDataOne.size()));
             } else {
                 dto.setPersonNum("0");
             }
         }
+    }
 
     static int dangerListDataStartRow = 2; // 表头占两行
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/ExcelServiceImpl.java

@@ -1480,7 +1480,9 @@ public class ExcelServiceImpl {
 				list.add(row.getAndIncrement());
 				list.add(o.getFireTeamName() + "@" + o.getFireTeamId());
 				list.add(o.getName() + "@" + o.getSequenceNbr());
+				if(!ValidationUtil.isEmpty(o.getJobTitle())) {
 					list.add(o.getJobTitle() + "@" + o.getJobTitleCode());
+				}
 				data.add(list);
 			});
 		}

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/PowerTransferServiceImpl.java

@@ -187,16 +187,16 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
         }
         if (fullTimeList.size() > 0) {
             ruleAlertCalledService.powerTransferCalledRule(fullTimeList, powerTransferDto.getAlertCalledId(),
-                    FireBrigadeTypeEnum.专职消防队.getKey());
+                    FireBrigadeTypeEnum.专职消防队.getKey(), powerTransferDto.getCompanyName());
         }
         if (medicalTeamList.size() > 0) {
             ruleAlertCalledService.powerTransferCalledRule(medicalTeamList, powerTransferDto.getAlertCalledId(),
-                    FireBrigadeTypeEnum.医疗救援队.getKey());
+                    FireBrigadeTypeEnum.医疗救援队.getKey(), powerTransferDto.getCompanyName());
 
         }
         if (monitorTeamList.size() > 0) {
             ruleAlertCalledService.powerTransferCalledRule(monitorTeamList, powerTransferDto.getAlertCalledId(),
-                    FireBrigadeTypeEnum.监控大队.getKey());
+                    FireBrigadeTypeEnum.监控大队.getKey(), powerTransferDto.getCompanyName());
 
         }
     }

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/PowerrTransferLogServiceImpl.java

@@ -73,7 +73,7 @@ public class PowerrTransferLogServiceImpl extends BaseService<PowerrTransferLogD
             PowerTransferCompany company = powerTransferCompanyService.getById(id);
 
             list.stream().forEach(e->{
-                dto.setReceiveName(dto.getReceiveName() == null ? "".concat(e.getReceiveName() == null ? "" : e.getReceiveName()) : dto.getReceiveName().concat("/").concat(e.getReceiveName() == null ? "" : e.getReceiveName()) );
+                dto.setReceiveName(dto.getReceiveName() == null ? "".concat(e.getReceiveName() == null ? "" : e.getReceiveName()) : "".equals(e.getReceiveName()) ?  "".concat(e.getReceiveName()) : dto.getReceiveName().concat("/").concat(e.getReceiveName() == null ? "" : e.getReceiveName()) );
                 dto.setSendTime(e.getSendTime());
                 dto.setSendContent(e.getSendContent());
                 dto.setRecUserName(e.getRecUserName());
@@ -92,10 +92,12 @@ public class PowerrTransferLogServiceImpl extends BaseService<PowerrTransferLogD
             PowerrTransferLogDto dto = new PowerrTransferLogDto();
             queryWrapper.eq(PowerrTransferLog::getResourceId,id);
             PowerrTransferLog powerrTransferLog = this.getOne(queryWrapper);
+            if(null != powerrTransferLog) {
                 PowerTransferCompanyResources resources = powerTransferCompanyResourcesService.getById(id);
                 PowerTransferCompany byId = powerTransferCompanyService.getById(resources.getPowerTransferCompanyId());
                 powerrTransferLog.setSendContent(byId.getTaskInformation());
                 Bean.toPo(powerrTransferLog,dto);
+            }
             return dto;
         }
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/RuleAlertCalledService.java

@@ -235,7 +235,7 @@ public class RuleAlertCalledService {
 		return replaceContent;
 	}
 
-	public boolean powerTransferCalledRule(Set<PowerTransferCompanyDto> i, Long alertCalledId, String type) throws Exception {
+	public boolean powerTransferCalledRule(Set<PowerTransferCompanyDto> i, Long alertCalledId, String type,String companyName) throws Exception {
 		if (ValidationUtil.isEmpty(alertCalledId)) {
 			throw new BadRequest("参数校验失败.");
 		}
@@ -255,7 +255,7 @@ public class RuleAlertCalledService {
 		alertCallePowerTransferRo.setAddress(alertCalled.getAddress());
 		alertCallePowerTransferRo.setAlertType(alertCalled.getAlertType());
 		alertCallePowerTransferRo.setAlertTypeCode(alertCalled.getAlertTypeCode());
-		alertCallePowerTransferRo.setCompanyName(alertCalled.getCompanyName());
+		alertCallePowerTransferRo.setCompanyName(companyName);
 		alertCallePowerTransferRo.setTrappedNum(Integer.toString(alertCalled.getTrappedNum()));
 		alertCallePowerTransferRo.setCasualtiesNum(Integer.toString(alertCalled.getCasualtiesNum()));
 		alertCallePowerTransferRo.setContactPhone(alertCalled.getContactPhone());