Skip to content

A
amos-boot-biz
Commit 9f538f19 authored by tianyiming's avatar tianyiming
Browse files
Options

一码通更新功能修改

parent 5eddb4ea
Show whitespace changes
Inline Side-by-side
Showing with 199 additions and 124 deletions
amos-boot-system-tzs/amos-boot-module-ymt/amos-boot-module-ymt-api/src/main/resources/mapper/EquipmentCategoryMapper.xml
View file @ 9f538f19
......@@ -452,7 +452,7 @@
USE_UNIT_CREDIT_CODE,
USE_UNIT_NAME,
RECORD as id,
RECORD as sequenceNbr
SEQUENCE_NBR as sequenceNbr
from idx_biz_jg_use_info
where RECORD = #{record}
</select>
......@@ -467,7 +467,7 @@
jdi.DESIGN_UNIT_NAME,
jdi.DESIGN_USE_DATE,
jdi.DRAWING_DO,
jdi.RECORD as sequenceNbr,
jdi.SEQUENCE_NBR as sequenceNbr,
jdi.RECORD as id,
jfi.FACTORY_NUM,
jfi.FACTORY_STANDARD,
......@@ -549,7 +549,7 @@
jri.ENGINE_NUMBER,
jri.MOTOR_NUMBER,
jri.RECORD as id,
jri.RECORD as sequenceNbr,
jri.SEQUENCE_NBR as sequenceNbr,
t.*
from idx_biz_jg_register_info jri
LEFT JOIN ${tableName} t on jri.RECORD = t.RECORD
......
amos-boot-system-tzs/amos-boot-module-ymt/amos-boot-module-ymt-biz/src/main/java/com/yeejoin/amos/boot/module/ymt/biz/service/impl/EquipmentCategoryServiceImpl.java
View file @ 9f538f19
......@@ -56,6 +56,7 @@ import org.typroject.tyboot.core.foundation.context.RequestContext;
import org.typroject.tyboot.core.foundation.utils.DateUtil;
import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel;
import java.io.IOException;
......@@ -453,11 +454,11 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
String useOrgCode = (String) obj.get("USE_ORG_CODE");
String record = (String) obj.get("id");
Map<String, Long> map = categoryOtherInfoMapper.checkCode(type, code96333, equCode, useOrgCode, record);
if(map.containsKey("equCode") && map.get("equCode") > 0){
if (map.containsKey("equCode") && map.get("equCode") > 0) {
result = "设备代码重复，请确认数据是否输入正确，或联系管辖机构处理。";
} else if (map.containsKey("useOrgCode") && map.get("useOrgCode") > 0){
} else if (map.containsKey("useOrgCode") && map.get("useOrgCode") > 0) {
result = "使用登记证编号重复，请确认数据是否输入正确，或联系管辖机构处理。";
} else if (map.containsKey("code") && map.get("code") > 0){
} else if (map.containsKey("code") && map.get("code") > 0) {
result = "96333码重复，请确认数据是否输入正确，或联系管辖机构处理。";
}
return result;
......@@ -648,7 +649,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
return new HashMap<>();
}
EquipmentTypeEnum equipmentMessage = EquipmentTypeEnum.getEnumByCode(alias);
if (equipmentMessage == null && ObjectUtils.isEmpty(equipmentMessage)){
if (equipmentMessage == null && ObjectUtils.isEmpty(equipmentMessage)) {
return new HashMap<>();
}
HashMap<String, Map<String, Object>> result = new HashMap<>();
......@@ -691,7 +692,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
*/
private Map<String, Object> getUseInfo(Map<String, Object> map) {
Map<String, Object> useInfo = equipmentCategoryMapper.selectTzsUseInfo(String.valueOf(map.get("id")));
if (ObjectUtils.isEmpty(useInfo)){
if (ObjectUtils.isEmpty(useInfo)) {
return new HashMap<>();
}
useInfo.put("LONGITUDE_LATITUDE", JSON.parse(String.valueOf(useInfo.get("LONGITUDE_LATITUDE"))));
......@@ -721,7 +722,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
case "3000":
// 电梯
result = equipmentCategoryMapper.selectTzsqzjJriInfo(String.valueOf(map.get("id")), equipmentMessage.getTableName());
if (ObjectUtils.isEmpty(result)){
if (ObjectUtils.isEmpty(result)) {
return new HashMap<>();
}
result.put("EXPLOSIONPROOF_SIGN_COMPLETE", JSON.parseArray(String.valueOf(result.get("EXPLOSIONPROOF_SIGN_COMPLETE"))));
......@@ -729,7 +730,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
case "4000":
// 起重机械
result = equipmentCategoryMapper.selectTzsqzjJriInfo(String.valueOf(map.get("id")), equipmentMessage.getTableName());
if (ObjectUtils.isEmpty(result)){
if (ObjectUtils.isEmpty(result)) {
return new HashMap<>();
}
List<Map<String, Object>> lbjJriInfo = equipmentCategoryMapper.selectTzslbjJriInfo(String.valueOf(map.get("id")));
......@@ -741,7 +742,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
case "5000":
// 厂车
result = equipmentCategoryMapper.selectTzsqzjJriInfo(String.valueOf(map.get("id")), equipmentMessage.getTableName());
if (ObjectUtils.isEmpty(result)){
if (ObjectUtils.isEmpty(result)) {
return new HashMap<>();
}
List<Map<String, Object>> celbjJriInfo = equipmentCategoryMapper.selectTzslbjJriInfo(String.valueOf(map.get("id")));
......@@ -751,7 +752,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
case "1000":
// 锅炉
result = equipmentCategoryMapper.selectTzsqzjJriInfo(String.valueOf(map.get("id")), equipmentMessage.getTableName());
if (ObjectUtils.isEmpty(result)){
if (ObjectUtils.isEmpty(result)) {
return new HashMap<>();
}
List<Map<String, Object>> glaqfjJriInfo = equipmentCategoryMapper.selectTzsaqfjJriInfo(String.valueOf(map.get("id")));
......@@ -760,7 +761,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
case "2000":
// 压力容器
result = equipmentCategoryMapper.selectTzsqzjJriInfo(String.valueOf(map.get("id")), equipmentMessage.getTableName());
if (ObjectUtils.isEmpty(result)){
if (ObjectUtils.isEmpty(result)) {
return new HashMap<>();
}
List<Map<String, Object>> ylrqaqfjJriInfo = equipmentCategoryMapper.selectTzsaqfjJriInfo(String.valueOf(map.get("id")));
......@@ -771,7 +772,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
case "8000":
// 压力容器
result = equipmentCategoryMapper.selectTzsqzjJriInfo(String.valueOf(map.get("id")), equipmentMessage.getTableName());
if (ObjectUtils.isEmpty(result)){
if (ObjectUtils.isEmpty(result)) {
return new HashMap<>();
}
List<Map<String, Object>> ylgdjJriInfo = equipmentCategoryMapper.selectTzslbjJriInfo(String.valueOf(map.get("id")));
......@@ -780,14 +781,14 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
case "6000":
// 游乐设施
result = equipmentCategoryMapper.selectTzsqzjJriInfo(String.valueOf(map.get("id")), equipmentMessage.getTableName());
if (ObjectUtils.isEmpty(result)){
if (ObjectUtils.isEmpty(result)) {
return new HashMap<>();
}
break;
case "9000":
// 游乐设施
result = equipmentCategoryMapper.selectTzsqzjJriInfo(String.valueOf(map.get("id")), equipmentMessage.getTableName());
if (ObjectUtils.isEmpty(result)){
if (ObjectUtils.isEmpty(result)) {
return new HashMap<>();
}
List<Map<String, Object>> sdJriLbjInfo = equipmentCategoryMapper.selectTzslbjJriInfo(String.valueOf(map.get("id")));
......@@ -810,7 +811,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
*/
private Map<String, Object> getInsInfo(Map<String, Object> map) {
List<Map<String, Object>> InsInfo = equipmentCategoryMapper.selectTzsInsInfo(String.valueOf(map.get("id")));
if (ObjectUtils.isEmpty(InsInfo)){
if (ObjectUtils.isEmpty(InsInfo)) {
return new HashMap<>();
}
HashMap<String, Object> insInfoMap = new HashMap<>();
......@@ -820,7 +821,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
insInfoMap.put("id", item.get("RECORD"));
}
if (!insInfoMap.containsKey("sequenceNbr")) {
insInfoMap.put("sequenceNbr", item.get("RECORD"));
insInfoMap.put("sequenceNbr", item.get("SEQUENCE_NBR"));
}
item.put("Symbol_key", item.get("SEQUENCE_NBR"));
});
......@@ -836,7 +837,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
*/
private Map<String, Object> getMainInfo(Map<String, Object> map) {
List<Map<String, Object>> mainInfo = equipmentCategoryMapper.selectTzsMainInfo(String.valueOf(map.get("id")));
if (ObjectUtils.isEmpty(mainInfo)){
if (ObjectUtils.isEmpty(mainInfo)) {
return new HashMap<>();
}
HashMap<String, Object> mainInfoMap = new HashMap<>();
......@@ -846,7 +847,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
mainInfoMap.put("id", item.get("RECORD"));
}
if (!mainInfoMap.containsKey("sequenceNbr")) {
mainInfoMap.put("sequenceNbr", item.get("RECORD"));
mainInfoMap.put("sequenceNbr", item.get("SEQUENCE_NBR"));
}
item.put("Symbol_key", item.get("SEQUENCE_NBR"));
});
......@@ -871,7 +872,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
comMap.put("id", item.get("RECORD"));
}
if (!comMap.containsKey("sequenceNbr")) {
comMap.put("sequenceNbr", item.get("RECORD"));
comMap.put("sequenceNbr", item.get("SEQUENCE_NBR"));
}
item.put("Symbol_key", item.get("SEQUENCE_NBR"));
});
......@@ -887,7 +888,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
*/
private Map<String, Object> getDesInfo(Map<String, Object> map) {
Map<String, Object> desInfo = equipmentCategoryMapper.selectTzsDesInfo(String.valueOf(map.get("id")));
if (ObjectUtils.isEmpty(desInfo)){
if (ObjectUtils.isEmpty(desInfo)) {
return new HashMap<>();
}
desInfo.put("DESIGN_DOC", JSON.parseArray(String.valueOf(desInfo.get("DESIGN_DOC"))));
......@@ -899,6 +900,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
desInfo.put("PRODUCT_QUALITY_YIELD_PROVE", JSON.parseArray(String.valueOf(desInfo.get("PRODUCT_QUALITY_YIELD_PROVE"))));
return desInfo;
}
/**
* 分页查询数据
*/
......@@ -1176,12 +1178,12 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
list.add(equipmentCategoryData);
}
}
if (!ObjectUtils.isEmpty(unitCodes) && !ObjectUtils.isEmpty(orgBranchCodes) ) {
if (!ObjectUtils.isEmpty(unitCodes) && !ObjectUtils.isEmpty(orgBranchCodes)) {
equipmentCategoryDataMapper.delete(new QueryWrapper<EquipmentCategoryData>()
.in("unit_code", unitCodes)
.in("org_branch_code",orgBranchCodes));
.in("org_branch_code", orgBranchCodes));
}
if (!ObjectUtils.isEmpty(unitCodes) && ObjectUtils.isEmpty(orgBranchCodes) ) {
if (!ObjectUtils.isEmpty(unitCodes) && ObjectUtils.isEmpty(orgBranchCodes)) {
equipmentCategoryDataMapper.delete(new QueryWrapper<EquipmentCategoryData>()
.in("unit_code", unitCodes));
}
......@@ -1301,7 +1303,6 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
StopWatch stopWatch3 = new StopWatch();
stopWatch3.start();
SupervisoryCodeInfo supervisoryCodeInfo = new SupervisoryCodeInfo();
ResponseModel responseModel = new ResponseModel();
LinkedHashMap useInfoFrom = (LinkedHashMap) map.get(use_info_form_id);
Calendar calendar = Calendar.getInstance();
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
......@@ -1342,12 +1343,11 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
log.info("已生成对应监管码或96333电梯识别码");
flag = true;
}
if(flag){
if (flag) {
lock.unlock(); // 释放锁
log.info("释放锁");
}
//删除map中的冗余数据，添加对应监管码和96333码调用idx多表单页提交接口吧保存数据
map.remove("data");
//添加对应监管码和96333码调用通用新增保存接口进行修改
supervisionMap.put("CODE96333", codeMap.get("code96333"));
supervisionMap.put("SUPERVISORY_CODE", codeMap.get("superviseCode"));
map.put(supervision_form_id, supervisionMap);
......@@ -1357,8 +1357,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
}
StopWatch stopWatch1 = new StopWatch();
stopWatch1.start();
// 根据操作状态判断是调用新增还是修改接口
record = "save".equals(operateType) ? batchSubmit(map, equCategory) : null;
record = batchSubmitOrUpdate(map, equCategory, operateType);
stopWatch1.stop();
if (log.isInfoEnabled()) {
log.info("业务存数据耗时：{} 秒", stopWatch1.getTotalTimeSeconds());
......@@ -1370,14 +1369,12 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
supervisoryCodeInfo.setStatus(EquipmentCategoryEnum.BF.getCode());
}
} else if (EquipmentCategoryEnum.DRL.getName().equals(claimStatus)) {
map.remove("data");
supervisionMap.put("CODE96333", "null".equals(code96333) ? null : code96333);
map.put(supervision_form_id, supervisionMap);
//根据操作状态判断是调用新增还是修改接口
record = "save".equals(operateType) ? batchSubmit(map, equCategory) : null;
record = batchSubmitOrUpdate(map, equCategory, operateType);
} else {
map.remove("data");
record = null;
record = batchSubmitOrUpdate(map, equCategory, operateType);
}
StopWatch stopWatch4 = new StopWatch();
stopWatch4.start();
......@@ -1426,7 +1423,7 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
response.setStatus(HttpStatus.BAD_REQUEST.value());
return response;
}
return responseModel;
return ResponseHelper.buildResponse("SUCCESS");
}
@Autowired
......@@ -1439,12 +1436,18 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
IdxBizJgOtherInfoServiceImpl idxBizJgOtherInfoService;
@Autowired
IdxBizJgOtherInfoMapper idxBizJgOtherInfoMapper;
@Autowired
IdxBizJgDesignInfoServiceImpl idxBizJgDesignInfoService;
@Autowired
IdxBizJgFactoryInfoServiceImpl idxBizJgFactoryInfoService;
@Autowired
IdxBizJgFactoryInfoMapper idxBizJgFactoryInfoMapper;
@Autowired
IdxBizJgInspectionDetectionInfoServiceImpl idxBizJgInspectionDetectionInfoService;
@Autowired
......@@ -1460,250 +1463,322 @@ public class EquipmentCategoryServiceImpl extends BaseService<EquipmentCategoryD
IdxBizJgTechParamsElevatorServiceImpl idxBizJgTechParamsElevatorService;
@Autowired
IdxBizJgTechParamsElevatorMapper idxBizJgTechParamsElevatorMapper;
@Autowired
IdxBizJgTechParamsVehicleServiceImpl idxBizJgTechParamsVehicleService;
@Autowired
IdxBizJgTechParamsVehicleMapper idxBizJgTechParamsVehicleMapper;
@Autowired
IdxBizJgTechParamsRopewayServiceImpl idxBizJgTechParamsRopewayService;
@Autowired
IdxBizJgTechParamsRopewayMapper idxBizJgTechParamsRopewayMapper;
@Autowired
IdxBizJgTechParamsRidesServiceImpl idxBizJgTechParamsRidesService;
@Autowired
IdxBizJgTechParamsRidesMapper idxBizJgTechParamsRidesMapper;
@Autowired
IdxBizJgTechParamsBoilerServiceImpl idxBizJgTechParamsBoilerService;
@Autowired
IdxBizJgTechParamsBoilerMapper idxBizJgTechParamsBoilerMapper;
@Autowired
IdxBizJgTechParamsVesselServiceImpl idxBizJgTechParamsVesselService;
@Autowired
IdxBizJgTechParamsVesselMapper idxBizJgTechParamsVesselMapper;
@Autowired
IdxBizJgTechParamsPipelineServiceImpl idxBizJgTechParamsPipelineService;
@Autowired
IdxBizJgTechParamsPipelineMapper idxBizJgTechParamsPipelineMapper;
@Autowired
IdxBizJgTechParamsLiftingServiceImpl idxBizJgTechParamsLiftingService;
@Autowired
IdxBizJgTechParamsLiftingMapper idxBizJgTechParamsLiftingMapper;
@Autowired
IdxBizJgMainPartsServiceImpl idxBizJgMainPartsService;
@Autowired
IdxBizJgMainPartsMapper idxBizJgMainPartsMapper;
@Autowired
IdxBizJgProtectionDevicesServiceImpl idxBizJgProtectionDevicesService;
@Autowired
IdxBizJgProtectionDevicesMapper idxBizJgProtectionDevicesMapper;
private String batchSubmit(Map<String, Object> map,String equCategory) {
private String batchSubmitOrUpdate(Map<String, Object> map, String equCategory, String type) {
Date date = new Date();
String record = UUID.randomUUID().toString();
// 使用信息
String record = null;
LinkedHashMap useInfoForm = (LinkedHashMap) map.get(use_info_form_id);
IdxBizJgFactoryInfo idxBizJgFactoryInfo = null;
IdxBizJgOtherInfo otherInfo = null;
IdxBizJgTechParamsElevator techParamsElevator = null;
IdxBizJgTechParamsVehicle techParamsVehicle = null;
IdxBizJgTechParamsRopeway techParamsRopeway = null;
IdxBizJgTechParamsRides techParamsRides = null;
IdxBizJgTechParamsBoiler techParamsBoiler = null;
IdxBizJgTechParamsVessel techParamsVessel = null;
IdxBizJgTechParamsPipeline techParamsPipeline = null;
IdxBizJgTechParamsLifting techParamsLifting = null;
if ("save".equals(type)) {
record = UUID.randomUUID().toString();
} else {
record = useInfoForm.get("id").toString();
idxBizJgFactoryInfo = idxBizJgFactoryInfoMapper.selectOne(new QueryWrapper<IdxBizJgFactoryInfo>().eq("RECORD", record));
otherInfo = idxBizJgOtherInfoMapper.selectOne(new QueryWrapper<IdxBizJgOtherInfo>().eq("RECORD", record));
techParamsElevator = idxBizJgTechParamsElevatorMapper.selectOne(new QueryWrapper<IdxBizJgTechParamsElevator>().eq("RECORD", record));
techParamsVehicle = idxBizJgTechParamsVehicleMapper.selectOne(new QueryWrapper<IdxBizJgTechParamsVehicle>().eq("RECORD", record));
techParamsRopeway = idxBizJgTechParamsRopewayMapper.selectOne(new QueryWrapper<IdxBizJgTechParamsRopeway>().eq("RECORD", record));
techParamsRides = idxBizJgTechParamsRidesMapper.selectOne(new QueryWrapper<IdxBizJgTechParamsRides>().eq("RECORD", record));
techParamsBoiler = idxBizJgTechParamsBoilerMapper.selectOne(new QueryWrapper<IdxBizJgTechParamsBoiler>().eq("RECORD", record));
techParamsVessel = idxBizJgTechParamsVesselMapper.selectOne(new QueryWrapper<IdxBizJgTechParamsVessel>().eq("RECORD", record));
techParamsPipeline = idxBizJgTechParamsPipelineMapper.selectOne(new QueryWrapper<IdxBizJgTechParamsPipeline>().eq("RECORD", record));
techParamsLifting = idxBizJgTechParamsLiftingMapper.selectOne(new QueryWrapper<IdxBizJgTechParamsLifting>().eq("RECORD", record));
}
// 使用信息
IdxBizJgUseInfo useInfo = JSON.parseObject(JSON.toJSONString(useInfoForm), IdxBizJgUseInfo.class);
useInfo.setRecord(record);
useInfo.setRecDate(date);
idxBizJgUseInfoService.save(useInfo);
idxBizJgUseInfoService.saveOrUpdate(useInfo);
//监督管理信息
LinkedHashMap supervisionForm = (LinkedHashMap) map.get(supervision_form_id);
IdxBizJgSupervisionInfo supervisionInfo = JSON.parseObject(JSON.toJSONString(supervisionForm), IdxBizJgSupervisionInfo.class);
supervisionInfo.setRecord(record);
supervisionInfo.setRecDate(date);
idxBizJgSupervisionInfoService.save(supervisionInfo);
idxBizJgSupervisionInfoService.saveOrUpdate(supervisionInfo);
IdxBizJgOtherInfo idxBizJgOtherInfo = JSON.parseObject(JSON.toJSONString(supervisionForm), IdxBizJgOtherInfo.class);
if (!ObjectUtils.isEmpty(idxBizJgOtherInfo)) {
idxBizJgOtherInfo.setRecord(record);
idxBizJgOtherInfo.setRecDate(date);
idxBizJgOtherInfoService.save(idxBizJgOtherInfo);
idxBizJgOtherInfo.setSequenceNbr("save".equals(type) ? null : otherInfo.getSequenceNbr());
idxBizJgOtherInfoService.saveOrUpdate(idxBizJgOtherInfo);
}
//设计制造信息
LinkedHashMap designForm = (LinkedHashMap) map.get(design_from_id);
IdxBizJgDesignInfo designInfo = JSON.parseObject(JSON.toJSONString(designForm), IdxBizJgDesignInfo.class);
designInfo.setRecord(record);
designInfo.setRecDate(date);
idxBizJgDesignInfoService.save(designInfo);
designInfo.setSequenceNbr("save".equals(type) ? null : designInfo.getSequenceNbr());
idxBizJgDesignInfoService.saveOrUpdate(designInfo);
IdxBizJgFactoryInfo factoryInfo = JSON.parseObject(JSON.toJSONString(designForm), IdxBizJgFactoryInfo.class);
if (!ObjectUtils.isEmpty(factoryInfo)) {
factoryInfo.setRecord(record);
factoryInfo.setRecDate(date);
idxBizJgFactoryInfoService.save(factoryInfo);
factoryInfo.setSequenceNbr("save".equals(type) ? null : idxBizJgFactoryInfo.getSequenceNbr());
idxBizJgFactoryInfoService.saveOrUpdate(factoryInfo);
}
//检验检测信息
LinkedHashMap inspectionForm = (LinkedHashMap) map.get(inspection_form_id);
List inspectionList = (ArrayList)inspectionForm.get("subForm_pbim1pfid8");
List inspectionList = (ArrayList) inspectionForm.get("subForm_pbim1pfid8");
List<IdxBizJgInspectionDetectionInfo> detectionInfoList = new ArrayList<>();
for (Object obj : inspectionList) {
IdxBizJgInspectionDetectionInfo inspectionDetectionInfo = JSON.parseObject(JSON.toJSONString(obj), IdxBizJgInspectionDetectionInfo.class);
inspectionDetectionInfo.setRecord(record);
inspectionDetectionInfo.setRecDate(date);
inspectionDetectionInfo.setSequenceNbr(null);
inspectionDetectionInfo.setSequenceNbr("save".equals(type) ? null : inspectionDetectionInfo.getSequenceNbr());
detectionInfoList.add(inspectionDetectionInfo);
}
idxBizJgInspectionDetectionInfoService.saveBatch(detectionInfoList);
idxBizJgInspectionDetectionInfoService.saveOrUpdateBatch(detectionInfoList);
//施工信息
LinkedHashMap constructionForm = (LinkedHashMap) map.get(construction_form_id);
List constructionlist = (ArrayList)constructionForm.get("subForm_b2x2wmcy2s");
List constructionlist = (ArrayList) constructionForm.get("subForm_b2x2wmcy2s");
if (!ObjectUtils.isEmpty(constructionlist)) {
List<IdxBizJgConstructionInfo> constructionInfoList = new ArrayList<>();
for (Object obj : constructionlist) {
IdxBizJgConstructionInfo constructionInfo = JSON.parseObject(JSON.toJSONString(obj), IdxBizJgConstructionInfo.class);
constructionInfo.setRecord(record);
constructionInfo.setRecDate(date);
constructionInfo.setSequenceNbr(null);
constructionInfo.setSequenceNbr("save".equals(type) ? null : constructionInfo.getSequenceNbr());
constructionInfoList.add(constructionInfo);
}
idxBizJgConstructionInfoService.saveBatch(constructionInfoList);
idxBizJgConstructionInfoService.saveOrUpdateBatch(constructionInfoList);
}
//八大类技术参数实体填充
List<IdxBizJgMainParts> mainPartsList = new ArrayList<>();
List<IdxBizJgProtectionDevices> protectionDevicesList = new ArrayList<>();
if(equCategory.startsWith("3")){
LinkedHashMap registerForm = null;
if (equCategory.startsWith("3")) {
//维保备案信息
LinkedHashMap maintenanceForm = (LinkedHashMap) map.get(maintenance_form_id);
List subFormMaintenanceList = (ArrayList)maintenanceForm.get("subForm_6i16fox27e");
List subFormMaintenanceList = (ArrayList) maintenanceForm.get("subForm_6i16fox27e");
if (!ObjectUtils.isEmpty(subFormMaintenanceList)) {
List<IdxBizJgMaintenanceRecordInfo> maintenanceList = new ArrayList<>();
for (Object obj : subFormMaintenanceList) {
IdxBizJgMaintenanceRecordInfo maintenanceRecordInfo = JSON.parseObject(JSON.toJSONString(obj), IdxBizJgMaintenanceRecordInfo.class);
maintenanceRecordInfo.setRecord(record);
maintenanceRecordInfo.setRecDate(date);
maintenanceRecordInfo.setSequenceNbr(null);
maintenanceRecordInfo.setSequenceNbr("save".equals(type) ? null : maintenanceRecordInfo.getSequenceNbr());
maintenanceList.add(maintenanceRecordInfo);
}
idxBizJgMaintenanceRecordInfoService.saveBatch(maintenanceList);
idxBizJgMaintenanceRecordInfoService.saveOrUpdateBatch(maintenanceList);
}
//技术参数
LinkedHashMap registerForm = (LinkedHashMap) map.get(dt_register_from_id);
IdxBizJgRegisterInfo registerInfo = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgRegisterInfo.class);
registerInfo.setRecord(record);
registerInfo.setRecDate(date);
idxBizJgRegisterInfoService.save(registerInfo);
registerForm = (LinkedHashMap) map.get(dt_register_from_id);
IdxBizJgTechParamsElevator elevator = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgTechParamsElevator.class);
if (!ObjectUtils.isEmpty(elevator)) {
elevator.setRecord(record);
elevator.setRecDate(date);
elevator.setSequenceNbr(null);
idxBizJgTechParamsElevatorService.save(elevator);
} else if(equCategory.startsWith("1")){
LinkedHashMap registerForm = (LinkedHashMap) map.get(gl_register_from_id);
elevator.setSequenceNbr("save".equals(type) ? null : techParamsElevator.getSequenceNbr());
idxBizJgTechParamsElevatorService.saveOrUpdate(elevator);
}
} else if (equCategory.startsWith("1")) {
registerForm = (LinkedHashMap) map.get(gl_register_from_id);
IdxBizJgTechParamsBoiler boiler = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgTechParamsBoiler.class);
if (!ObjectUtils.isEmpty(boiler)) {
boiler.setRecord(record);
boiler.setRecDate(date);
idxBizJgTechParamsBoilerService.save(boiler);
List<String> subFormMainPartsList = new ArrayList<>() ;
boiler.setSequenceNbr("save".equals(type) ? null : techParamsBoiler.getSequenceNbr());
idxBizJgTechParamsBoilerService.saveOrUpdate(boiler);
List<String> subFormMainPartsList = new ArrayList<>();
subFormMainPartsList.add("subForm_1hh88r4m69");
mainPartsList = getAccessoryEntity(registerForm,subFormMainPartsList, main_parts, record, date);
} else if(equCategory.startsWith("2")){
LinkedHashMap registerForm = (LinkedHashMap) map.get(ylrq_register_from_id);
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date, type);
}
} else if (equCategory.startsWith("2")) {
registerForm = (LinkedHashMap) map.get(ylrq_register_from_id);
IdxBizJgTechParamsVessel vessel = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgTechParamsVessel.class);
if (!ObjectUtils.isEmpty(vessel)) {
vessel.setRecord(record);
vessel.setRecDate(date);
idxBizJgTechParamsVesselService.save(vessel);
vessel.setSequenceNbr("save".equals(type) ? null : techParamsVessel.getSequenceNbr());
idxBizJgTechParamsVesselService.saveOrUpdate(vessel);
List<String> subFormMainPartsList = new ArrayList<>();
subFormMainPartsList.add("subForm_fie04854f2");
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date);
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date, type);
List<String> subFormProtectionDevicesList = new ArrayList<>();
subFormProtectionDevicesList.add("subForm_d4xdzhsgdj");
protectionDevicesList = getAccessoryEntity(registerForm, subFormProtectionDevicesList, protection_devices, record, date);
} else if(equCategory.startsWith("4")){
LinkedHashMap registerForm = (LinkedHashMap) map.get(qzjx_register_from_id);
protectionDevicesList = getAccessoryEntity(registerForm, subFormProtectionDevicesList, protection_devices, record, date, type);
}
} else if (equCategory.startsWith("4")) {
registerForm = (LinkedHashMap) map.get(qzjx_register_from_id);
IdxBizJgTechParamsLifting lifting = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgTechParamsLifting.class);
if (!ObjectUtils.isEmpty(lifting)) {
lifting.setRecord(record);
lifting.setRecDate(date);
idxBizJgTechParamsLiftingService.save(lifting);
lifting.setSequenceNbr("save".equals(type) ? null : techParamsLifting.getSequenceNbr());
idxBizJgTechParamsLiftingService.saveOrUpdate(lifting);
List<String> subFormMainPartsList = new ArrayList<>();
subFormMainPartsList.add("subForm_bqirdyvztt");
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date);
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date, type);
List<String> subFormProtectionDevicesList = new ArrayList<>();
subFormProtectionDevicesList.add("subForm_29yy3pdzhl");
subFormProtectionDevicesList.add("subForm_h5h4x0zhur");
protectionDevicesList = getAccessoryEntity(registerForm, subFormProtectionDevicesList, protection_devices, record, date);
} else if(equCategory.startsWith("5")){
LinkedHashMap registerForm = (LinkedHashMap) map.get(cc_register_from_id);
protectionDevicesList = getAccessoryEntity(registerForm, subFormProtectionDevicesList, protection_devices, record, date, type);
}
} else if (equCategory.startsWith("5")) {
registerForm = (LinkedHashMap) map.get(cc_register_from_id);
IdxBizJgTechParamsVehicle vehicle = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgTechParamsVehicle.class);
if (!ObjectUtils.isEmpty(vehicle)) {
vehicle.setRecord(record);
vehicle.setRecDate(date);
idxBizJgTechParamsVehicleService.save(vehicle);
vehicle.setSequenceNbr("save".equals(type) ? null : techParamsVehicle.getSequenceNbr());
idxBizJgTechParamsVehicleService.saveOrUpdate(vehicle);
List<String> subFormMainPartsList = new ArrayList<>();
subFormMainPartsList.add("subForm_sey164b51a");
subFormMainPartsList.add("subForm_tef7yf5fbr");
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date);
} else if(equCategory.startsWith("6")){
LinkedHashMap registerForm = (LinkedHashMap) map.get(ylss_register_from_id);
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date, type);
}
} else if (equCategory.startsWith("6")) {
registerForm = (LinkedHashMap) map.get(ylss_register_from_id);
IdxBizJgTechParamsRides rides = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgTechParamsRides.class);
if (!ObjectUtils.isEmpty(rides)) {
rides.setRecord(record);
rides.setRecDate(date);
idxBizJgTechParamsRidesService.save(rides);
} else if(equCategory.startsWith("8")){
LinkedHashMap registerForm = (LinkedHashMap) map.get(ylgd_register_from_id);
rides.setSequenceNbr("save".equals(type) ? null : techParamsRides.getSequenceNbr());
idxBizJgTechParamsRidesService.saveOrUpdate(rides);
}
} else if (equCategory.startsWith("8")) {
registerForm = (LinkedHashMap) map.get(ylgd_register_from_id);
IdxBizJgTechParamsPipeline pipeline = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgTechParamsPipeline.class);
if (!ObjectUtils.isEmpty(pipeline)) {
pipeline.setRecord(record);
pipeline.setRecDate(date);
idxBizJgTechParamsPipelineService.save(pipeline);
pipeline.setSequenceNbr("save".equals(type) ? null : techParamsPipeline.getSequenceNbr());
idxBizJgTechParamsPipelineService.saveOrUpdate(pipeline);
List<String> subFormMainPartsList = new ArrayList<>();
subFormMainPartsList.add("subForm_9n7nu55z8r");
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date);
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date, type);
}
} else {
LinkedHashMap registerForm = (LinkedHashMap) map.get(kysd_register_from_id);
registerForm = (LinkedHashMap) map.get(kysd_register_from_id);
IdxBizJgTechParamsRopeway ropeway = JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgTechParamsRopeway.class);
if (!ObjectUtils.isEmpty(ropeway)) {
ropeway.setRecord(record);
ropeway.setRecDate(date);
idxBizJgTechParamsRopewayService.save(ropeway);
ropeway.setSequenceNbr("save".equals(type) ? null : techParamsRopeway.getSequenceNbr());
idxBizJgTechParamsRopewayService.saveOrUpdate(ropeway);
List<String> subFormMainPartsList = new ArrayList<>();
subFormMainPartsList.add("subForm_5fi0jewuyh");
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date);
mainPartsList = getAccessoryEntity(registerForm, subFormMainPartsList, main_parts, record, date, type);
}
}
IdxBizJgRegisterInfo registerInfo =JSON.parseObject(JSON.toJSONString(registerForm), IdxBizJgRegisterInfo.class);
registerInfo.setRecord(record);
registerInfo.setRecDate(date);
registerInfo.setSequenceNbr("save".equals(type) ? null : registerForm.get("sequenceNbr").toString());
idxBizJgRegisterInfoService.saveOrUpdate(registerInfo);
idxBizJgMainPartsService.saveBatch(mainPartsList);
idxBizJgProtectionDevicesService.saveBatch(protectionDevicesList);
if (!ObjectUtils.isEmpty(mainPartsList)) {
idxBizJgMainPartsService.saveOrUpdateBatch(mainPartsList);
}
if (!ObjectUtils.isEmpty(protectionDevicesList)) {
idxBizJgProtectionDevicesService.saveOrUpdateBatch(protectionDevicesList);
}
return record;
}
private List getAccessoryEntity(Map<String, Object> map, List<String> list, String type, String record, Date date) {
private List getAccessoryEntity(Map<String, Object> map, List<String> list, String subFormType, String record, Date date,String type) {
List<IdxBizJgMainParts> mainPartsList = new ArrayList<>();
List<IdxBizJgProtectionDevices> protectionDevicesList = new ArrayList<>();
if ("mainParts".equals(type)) {
if ("mainParts".equals(subFormType)) {
for (Object s : list) {
List subFormMainPartsList = (ArrayList) map.get(s);
if(!ObjectUtils.isEmpty(subFormMainPartsList)){
for (Object obj : subFormMainPartsList) {
IdxBizJgMainParts mainParts = JSON.parseObject(JSON.toJSONString(obj), IdxBizJgMainParts.class);
mainParts.setRecord(record);
mainParts.setRecDate(date);
mainParts.setSequenceNbr(null);
mainParts.setSequenceNbr("save".equals(type) ? null : mainParts.getSequenceNbr());
mainPartsList.add(mainParts);
}
}
}
return mainPartsList;
} else {
for (Object s : list) {
List subFormProtectionDevicesList = (ArrayList) map.get(s);
if(!ObjectUtils.isEmpty(subFormProtectionDevicesList)){
for (Object obj : subFormProtectionDevicesList) {
IdxBizJgProtectionDevices protectionDevices = JSON.parseObject(JSON.toJSONString(obj), IdxBizJgProtectionDevices.class);
protectionDevices.setRecord(record);
protectionDevices.setRecDate(date);
protectionDevices.setSequenceNbr(null);
protectionDevices.setSequenceNbr("save".equals(type) ? null : protectionDevices.getSequenceNbr());
protectionDevicesList.add(protectionDevices);
}
}
}
return protectionDevicesList;
}
}
......
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