消息加台账导入

“linengliang”

2023-10-29 db1d7484b7114f9f91decef684280866dac34dfe

 lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EamEquipmentController.java

@@ -18,6 +18,9 @@
import org.jeecg.common.system.base.entity.SysUpload;
import org.jeecg.common.system.query.QueryGenerator;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.modules.base.entity.Constructor;
import org.jeecg.modules.base.service.IConstructorService;
import org.jeecg.modules.base.service.IFactoryModelService;
import org.jeecg.modules.eam.entity.*;
import org.jeecg.modules.eam.model.DepartVo;
import org.jeecg.modules.eam.service.*;
@@ -29,6 +32,8 @@

import org.jeecg.common.system.base.controller.JeecgController;

import org.jeecg.modules.system.entity.SysDepart;
import org.jeecg.modules.system.service.ISysDepartService;
import org.jeecgframework.poi.excel.ExcelImportUtil;
import org.jeecgframework.poi.excel.entity.ImportParams;
import org.springframework.beans.factory.annotation.Autowired;
@@ -74,8 +79,6 @@
    @Autowired
    private IProcessParametersTemplateService processParametersTemplateService;



    @Autowired
    private ISysBaseAPI sysBaseApi;

@@ -99,6 +102,22 @@

    @Autowired
    private IEquipmentCategoryService equipmentCategoryService;

    @Autowired
    private ISysDepartService departService;

    @Autowired
    private ITeamService teamService;

    @Autowired
    private IConstructorService constructorService;

    @Autowired
    private IAreaService areaService;




   /**
    * 分页列表查询
    *
@@ -543,119 +562,181 @@
          try {
             List<EquipmentImportVo> list = ExcelImportUtil.importExcel(file.getInputStream(), EquipmentImportVo.class, params);
             for(int i = 0;i<list.size();i++){
                Equipment equipment = new Equipment();
                     EquipmentImportVo equipmentImportVo = list.get(i);
                EquipmentCategory equipmentCategory = equipmentCategoryService.getOne(new QueryWrapper<EquipmentCategory>().eq("name",equipmentImportVo.getEquipmentCategoryName()),false);
                String equipmentCategoryName = equipmentImportVo.getEquipmentCategoryName();
                String useId = equipmentImportVo.getUseId();
                String areaId = equipmentImportVo.getFactoryModelId();
                String manageId = equipmentImportVo.getManageId();
                String constructorId = equipmentImportVo.getConstructorId();
                String teamId = equipmentImportVo.getTeamId();
                     if(StringUtils.isBlank(equipmentImportVo.getNum())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:统一编码缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                     else if(StringUtils.isBlank(equipmentImportVo.getName())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备名称缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
                     else if(StringUtils.isBlank(equipmentImportVo.getUseId())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:使用部门缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
//                     else if(StringUtils.isBlank(equipmentImportVo.getEquipmentUda1())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:工区缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
                     else if(StringUtils.isBlank(equipmentImportVo.getManageId())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:维护部门缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                     else if(StringUtils.isBlank(equipmentImportVo.getTeamId())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:维修班组缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                     else if(StringUtils.isBlank(equipmentImportVo.getEquipmentImportanceId())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:ABC标识缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
                     else if(StringUtils.isBlank(equipmentImportVo.getEquipmentCategoryName())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备分类缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                     else if(StringUtils.isBlank(equipmentImportVo.getEquipmentStatus())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备状态缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                else if(StringUtils.isBlank(equipmentImportVo.getTechnologyStatus())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备技术缺失,请填写必填项后再导入;";
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备技术状态缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                else if(StringUtils.isBlank(equipmentImportVo.getFactoryModelId())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:车间缺失,请填写必填项后再导入;";
                else if(StringUtils.isBlank(equipmentImportVo.getModel())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备型号缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                else if(StringUtils.isBlank(equipmentImportVo.getWorkCenterId())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:产线缺失,请填写必填项后再导入;";
                else if(StringUtils.isBlank(useId)){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:使用部门缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                else if(ObjectUtils.isNotNull(equipmentImportVo.getWarrantyStart())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:质保开始日期缺失,请填写必填项后再导入;";
                else if(StringUtils.isBlank(areaId)){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:工区缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                else if(StringUtils.isBlank(equipmentImportVo.getPropertyStatus())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:资产状态缺失,请填写必填项后再导入;";
                else if(StringUtils.isBlank(manageId)){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:维护部门缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                     //非必填项
//                     else if(StringUtils.isBlank(equipmentImportVo.getEquipmentUda5())){
                else if(StringUtils.isBlank(equipmentCategoryName)){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备分类缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                else if(StringUtils.isBlank(teamId)){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:维修班组缺失,请填写必填项后再导入;";
                   exceptionNum++;
                   continue;
                }
                //非必填项
                // else if(ObjectUtils.isNotNull(equipmentImportVo.getWarrantyStart())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:质保开始日期缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                else if(StringUtils.isBlank(equipmentImportVo.getPropertyStatus())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:资产状态缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                   else if(StringUtils.isBlank(equipmentImportVo.getEquipmentUda5())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:功能位置缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                     else if(StringUtils.isBlank(equipmentImportVo.getLocation())){
//                   else if(StringUtils.isBlank(equipmentImportVo.getLocation())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:安装位置缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                     else if(StringUtils.isBlank(equipmentImportVo.getLeaveFactoryDate())){
//                   else if(StringUtils.isBlank(equipmentImportVo.getLeaveFactoryDate())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:出厂日期缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                     else if(StringUtils.isBlank(equipmentImportVo.getProjectApprovalNo())){
//                   else if(StringUtils.isBlank(equipmentImportVo.getProjectApprovalNo())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:立项卡号缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                     else if(StringUtils.isBlank(equipmentImportVo.getFundSource())){
//                   else if(StringUtils.isBlank(equipmentImportVo.getFundSource())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:资金来源缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                     else if(StringUtils.isBlank(equipmentImportVo.getAcceptanceCheckDate())){
//                   else if(StringUtils.isBlank(equipmentImportVo.getAcceptanceCheckDate())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:验收日期缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                     else if(StringUtils.isBlank(equipmentImportVo.getLeaveFactoryDate())){
//                   else if(StringUtils.isBlank(equipmentImportVo.getLeaveFactoryDate())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:出厂日期缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                     else if(StringUtils.isBlank(equipmentImportVo.getFactoryNo())){
//                   else if(StringUtils.isBlank(equipmentImportVo.getFactoryNo())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:出厂编号缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                     else if( StringUtils.isBlank(equipmentImportVo.getConstructorId())){
//                   else if( StringUtils.isBlank(equipmentImportVo.getConstructorId())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:资产制造商缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
                     else if(StringUtils.isBlank(equipmentImportVo.getModel())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备型号缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
                     else if(StringUtils.isBlank(equipmentImportVo.getSpecification())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备规格缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
//                   else if(StringUtils.isBlank(equipmentImportVo.getSpecification())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备规格缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
//                else if(StringUtils.isBlank(equipmentImportVo.getGpo())){
//                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备功率缺失,请填写必填项后再导入;";
//                   exceptionNum++;
//                }
                else if(ObjectUtils.isNull(equipmentCategory))
                      {
                       exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:该设备所属类别不存在，请先维护设备类别;";
                       exceptionNum++;
                     }
                else{
                   SysDepart use = departService.getOne(new QueryWrapper<SysDepart>().eq("depart_name",useId.trim()),false);
                   if(ObjectUtils.isNull(useId)){
                      equipment.setUseId(use.getId());
                   }else {
                      exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:不存在该使用部门,请维护部门数据后再导入;";
                      exceptionNum++;
                      continue;
                   }
                   Area area = areaService.getOne(new QueryWrapper<Area>().eq("name",areaId.trim()));
                   if(ObjectUtils.isNotNull(area)){
                      equipment.setFactoryModelId(area.getId());
                   }else {
                      exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:不存在该工区,请维护工区数据后再导入;";
                      exceptionNum++;
                      continue;
                   }
                   SysDepart manage = departService.getOne(new QueryWrapper<SysDepart>().eq("depart_name",manageId.trim()));
                   if(ObjectUtils.isNotNull(manage)){
                      equipment.setManageId(manage.getId());
                   }else{
                      exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:不存在该维护部门,请先维护部门数据后再导入;";
                      exceptionNum++;
                      continue;
                   }
                   EquipmentCategory equipmentCategory = equipmentCategoryService.getOne(new QueryWrapper<EquipmentCategory>().eq("name",equipmentCategoryName.trim()),false);
                   if(ObjectUtils.isNotNull(equipmentCategory)){
                      equipment.setEquipmentCategoryId(equipmentCategory.getId());
                   }
                   else {
                      exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:不存在该设备分类,请先维护设备分类数据后再导入;";
                      exceptionNum++;
                      continue;
                   }
                   Team team = teamService.getOne(new QueryWrapper<Team>().eq("name",teamId.trim()),false);
                   if(ObjectUtils.isNotNull(team)){
                      equipment.setTeamId(team.getId());
                   }else {
                      exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:不存在该班组,请先维护班组数据后再导入;";
                      exceptionNum++;
                      continue;
                   }
                   if(StringUtils.isNotBlank(constructorId)){
                      Constructor constructor = constructorService.getByName(constructorId.trim());
                      if(ObjectUtils.isNotNull(constructor)){
                         equipment.setConstructorId(constructor.getId());
                      }else {
                         constructor = new Constructor();
                         constructor.setName(constructorId);
                         constructor.setDelFlag(0);
                         constructorService.save(constructor);
                         equipment.setConstructorId(constructor.getId());
                      }
                   }
                         if(equipmentImportVo.getPropertyStatus().equals("warranty")){
                      if(
                            ObjectUtils.isNull(equipmentImportVo.getWarrantyStart())
@@ -666,24 +747,19 @@
                      }

                   }else{
                      Equipment oriEquipment = equipmentService.getOne(new QueryWrapper<Equipment>().eq("num",equipmentImportVo.getNum()),false);
                      Equipment oriEquipment = equipmentService
                            .getOne(new QueryWrapper<Equipment>()
                                  .eq("num",equipmentImportVo.getNum()),false);
                      if(ObjectUtils.isNull(oriEquipment)){
                         Equipment equipment = new Equipment();
                         equipment.setNum(equipmentImportVo.getNum())
                               .setName(equipmentImportVo.getName())
                               .setUseId(equipmentImportVo.getUseId())
                               .setEquipmentUda1(equipmentImportVo.getEquipmentUda1())
                               .setManageId(equipmentImportVo.getManageId())
                               .setTeamId(equipmentImportVo.getTeamId())
                               .setTechnologyStatus(equipmentImportVo.getTechnologyStatus())
                               .setEquipmentImportanceId(equipmentImportVo.getEquipmentImportanceId())
                               .setEquipmentCategoryId(equipmentCategory.getId())
                               .setSpecificEquipment(equipmentImportVo.getKeyEquipmentIdentification())
                               .setSecurityConfiguration(equipmentImportVo.getSecurityConfiguration())
                               .setCoolingSystem(equipmentImportVo.getCoolingSystem())
                               .setFireExtinguisher(equipmentImportVo.getFireExtinguisher())
                               .setFireExtinguisherValidityPeriod(equipmentImportVo.getFireExtinguisherValidityPeriod())
                               .setOperatingSystem(equipmentImportVo.getOperatingSystem())
                               .setSystem(equipmentImportVo.getSystem())
                               .setPort(equipmentImportVo.getPort())
                               .setCoordinateNum(equipmentImportVo.getCoordinateNum())
@@ -697,12 +773,9 @@
                               .setFundSource(equipmentImportVo.getFundSource())
                               .setAcceptanceCheckDate(equipmentImportVo.getAcceptanceCheckDate())
                               .setFactoryNumber(equipmentImportVo.getFactoryNumber())
                               .setConstructorId(equipmentImportVo.getConstructorId())
                               .setSourceCountry(equipmentImportVo.getSourceCountry())
                               .setModel(equipmentImportVo.getModel())
                               .setSpecification(equipmentImportVo.getSpecification())
                               .setFactoryModelId(equipmentImportVo.getFactoryModelId())
                               .setWorkCenterId(equipmentImportVo.getWorkCenterId())
                               .setPropertyStatus(equipmentImportVo.getPropertyStatus())
                               .setWarrantyStart(equipmentImportVo.getWarrantyStart())
                               .setWarrantyEnd(equipmentImportVo.getWarrantyEnd())
@@ -737,9 +810,9 @@
                      }else {
                         exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败，原因：统一编码已存在，数据重复导入;";
                         exceptionNum++;
                         continue;
                      }
                   }

                }
             }
             if(exceptionNum!=0){