From 54e7f06671f70cee10f82576dbe412a14a957084 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 12 五月 2022 17:25:08 +0800
Subject: [PATCH] 完成巡检 通知员工功能
---
service-job/src/main/java/com/java110/job/task/car/CarToMachineTemplate.java | 89 +++++++++++++++++++++++++++-----------------
1 files changed, 55 insertions(+), 34 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/task/car/CarToMachineTemplate.java b/service-job/src/main/java/com/java110/job/task/car/CarToMachineTemplate.java
old mode 100644
new mode 100755
index b1456f4..f69f021
--- a/service-job/src/main/java/com/java110/job/task/car/CarToMachineTemplate.java
+++ b/service-job/src/main/java/com/java110/job/task/car/CarToMachineTemplate.java
@@ -2,10 +2,12 @@
import com.alibaba.fastjson.JSONObject;
import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.machine.MachineDto;
import com.java110.dto.machine.MachineTranslateDto;
import com.java110.dto.order.OrderDto;
import com.java110.dto.owner.OwnerCarDto;
import com.java110.dto.task.TaskDto;
+import com.java110.intf.common.IMachineInnerServiceSMO;
import com.java110.intf.common.IMachineTranslateInnerServiceSMO;
import com.java110.intf.order.IOrderInnerServiceSMO;
import com.java110.intf.user.IOwnerCarInnerServiceSMO;
@@ -13,7 +15,7 @@
import com.java110.job.quartz.TaskSystemQuartz;
import com.java110.utils.constant.BusinessTypeConstant;
import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import com.java110.core.log.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@@ -52,6 +54,9 @@
@Autowired
private IMachineTranslateInnerServiceSMO machineTranslateInnerServiceSMOImpl;
+ @Autowired
+ private IMachineInnerServiceSMO machineInnerServiceSMOImpl;
+
@Override
protected void process(TaskDto taskDto) throws Exception {
@@ -71,6 +76,10 @@
ownerCarDto = new OwnerCarDto();
ownerCarDto.setbId(tmpOrderDto.getbId());
+
+ if(BusinessTypeConstant.BUSINESS_TYPE_DELETE_OWNER_CAR.equals(tmpOrderDto.getBusinessTypeCd())){
+ ownerCarDto.setStatusCd("1");
+ }
List<OwnerCarDto> ownerCarDtos = null;
@@ -107,16 +116,25 @@
//鎷垮埌灏忓尯ID
String communityId = ownerCarDtos.get(0).getCommunityId();
+ MachineDto machineDto = new MachineDto();
+ machineDto.setCommunityId(communityId);
+ machineDto.setMachineTypeCd(MachineDto.MACHINE_TYPE_CAR);
+ List<MachineDto> machineDtos = machineInnerServiceSMOImpl.queryMachines(machineDto);
+ if (machineDtos == null || machineDtos.size() < 1) {
+ return;
+ }
//鏍规嵁灏忓尯ID鏌ヨ鐜版湁璁惧
+
for (OwnerCarDto ownerCarDto : ownerCarDtos) {
- if (BusinessTypeConstant.BUSINESS_TYPE_SAVE_OWNER_CAR.equals(tmpOrderDto.getBusinessTypeCd())
- || BusinessTypeConstant.BUSINESS_TYPE_UPDATE_OWNER_CAR.equals(tmpOrderDto.getBusinessTypeCd())) {
- saveMachineTranslate(tmpOrderDto, ownerCarDto);
+ if (BusinessTypeConstant.BUSINESS_TYPE_SAVE_OWNER_CAR.equals(tmpOrderDto.getBusinessTypeCd())) {
+ saveOrUpdateMachineTranslate(tmpOrderDto, ownerCarDto, machineDtos, CREATE_OWNER_CAR);
+ } else if (BusinessTypeConstant.BUSINESS_TYPE_UPDATE_OWNER_CAR.equals(tmpOrderDto.getBusinessTypeCd())) {
+ saveOrUpdateMachineTranslate(tmpOrderDto, ownerCarDto, machineDtos, UPDATE_OWNER_CAR);
} else if (BusinessTypeConstant.BUSINESS_TYPE_DELETE_OWNER_CAR.equals(tmpOrderDto.getBusinessTypeCd())
) {
- deleteMachineTranslate(tmpOrderDto, ownerCarDto);
+ deleteMachineTranslate(tmpOrderDto, ownerCarDto, machineDtos);
} else {
}
@@ -126,38 +144,41 @@
}
- private void saveMachineTranslate(OrderDto tmpOrderDto, OwnerCarDto ownerCarDto) {
+ private void saveOrUpdateMachineTranslate(OrderDto tmpOrderDto, OwnerCarDto ownerCarDto, List<MachineDto> machineDtos, String cmd) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setMachineTranslateId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_machineTranslateId));
- machineTranslateDto.setMachineId(ownerCarDto.getCommunityId());
- machineTranslateDto.setMachineCode(ownerCarDto.getCommunityId());
- machineTranslateDto.setTypeCd(TYPE_OWNER_CAR);
- machineTranslateDto.setObjId(ownerCarDto.getCarId());
- machineTranslateDto.setObjName(ownerCarDto.getCarNum());
- machineTranslateDto.setState(STATE_NO_TRANSLATE);
- machineTranslateDto.setCommunityId(ownerCarDto.getCommunityId());
- machineTranslateDto.setbId("-1");
- machineTranslateDto.setMachineCmd(CREATE_OWNER_CAR);
- machineTranslateDto.setObjBId(tmpOrderDto.getbId());
- machineTranslateInnerServiceSMOImpl.saveMachineTranslate(machineTranslateDto);
+ for (MachineDto machineDto : machineDtos) {
+ MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
+ machineTranslateDto.setMachineTranslateId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_machineTranslateId));
+ machineTranslateDto.setMachineId(machineDto.getMachineId());
+ machineTranslateDto.setMachineCode(machineDto.getMachineCode());
+ machineTranslateDto.setTypeCd(TYPE_OWNER_CAR);
+ machineTranslateDto.setObjId(ownerCarDto.getCarId());
+ machineTranslateDto.setObjName(ownerCarDto.getCarNum());
+ machineTranslateDto.setState(STATE_NO_TRANSLATE);
+ machineTranslateDto.setCommunityId(ownerCarDto.getCommunityId());
+ machineTranslateDto.setbId("-1");
+ machineTranslateDto.setMachineCmd(cmd);
+ machineTranslateDto.setObjBId(tmpOrderDto.getbId());
+ machineTranslateInnerServiceSMOImpl.saveMachineTranslate(machineTranslateDto);
+ }
}
- private void deleteMachineTranslate(OrderDto tmpOrderDto, OwnerCarDto ownerCarDto) {
- MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
- machineTranslateDto.setMachineTranslateId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_machineTranslateId));
- machineTranslateDto.setMachineId(ownerCarDto.getCommunityId());
- machineTranslateDto.setMachineCode(ownerCarDto.getCommunityId());
- machineTranslateDto.setTypeCd(TYPE_OWNER_CAR);
- machineTranslateDto.setObjId(ownerCarDto.getCarId());
- machineTranslateDto.setObjName(ownerCarDto.getCarNum());
- machineTranslateDto.setState(STATE_NO_TRANSLATE);
- machineTranslateDto.setCommunityId(ownerCarDto.getCommunityId());
- machineTranslateDto.setbId("-1");
- machineTranslateDto.setMachineCmd(DELETE_OWNER_CAR);
- machineTranslateDto.setObjBId(tmpOrderDto.getbId());
- machineTranslateInnerServiceSMOImpl.saveMachineTranslate(machineTranslateDto);
-
+ private void deleteMachineTranslate(OrderDto tmpOrderDto, OwnerCarDto ownerCarDto, List<MachineDto> machineDtos) {
+ for (MachineDto machineDto : machineDtos) {
+ MachineTranslateDto machineTranslateDto = new MachineTranslateDto();
+ machineTranslateDto.setMachineTranslateId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_machineTranslateId));
+ machineTranslateDto.setMachineId(machineDto.getMachineId());
+ machineTranslateDto.setMachineCode(machineDto.getMachineCode());
+ machineTranslateDto.setTypeCd(TYPE_OWNER_CAR);
+ machineTranslateDto.setObjId(ownerCarDto.getCarId());
+ machineTranslateDto.setObjName(ownerCarDto.getCarNum());
+ machineTranslateDto.setState(STATE_NO_TRANSLATE);
+ machineTranslateDto.setCommunityId(ownerCarDto.getCommunityId());
+ machineTranslateDto.setbId("-1");
+ machineTranslateDto.setMachineCmd(DELETE_OWNER_CAR);
+ machineTranslateDto.setObjBId(tmpOrderDto.getbId());
+ machineTranslateInnerServiceSMOImpl.saveMachineTranslate(machineTranslateDto);
+ }
}
}
--
Gitblit v1.8.0