完成巡检 通知员工功能

wuxw

2022-05-12 54e7f06671f70cee10f82576dbe412a14a957084

 service-job/src/main/java/com/java110/job/task/car/CarToMachineTemplate.java

old mode 100644
new mode 100755
@@ -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);
        }
    }
}