zenglf
2023-10-25 f2e8dc200f4ec9c1021e908f65e6e1e458c2ef70
lxzn-module-eam/src/main/java/org/jeecg/modules/eam/controller/EamEquipmentController.java
@@ -12,6 +12,7 @@
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.api.dto.message.MessageDTO;
import org.jeecg.common.api.vo.Result;
import org.jeecg.common.aspect.annotation.PermissionData;
import org.jeecg.common.constant.CommonConstant;
import org.jeecg.common.system.api.ISysBaseAPI;
import org.jeecg.common.system.base.entity.SysUpload;
@@ -61,10 +62,10 @@
   @Autowired
   private IProcessParametersTemplateDetailService processParametersTemplateDetailService;
    @Autowired
   @Autowired
   private IEquipmentProcessParametersService equipmentProcessParametersService;
    @Autowired
   @Autowired
   private IEquipmentPrecisionParametersService equipmentPrecisionParametersService;
    @Autowired
@@ -179,16 +180,22 @@
     * 设备保修  获取设备列表组件
     * qsw 2023-7-14
     */
    @GetMapping(value = "/getEquipmentList")
    @PermissionData
    public Result<IPage<Equipment>> getEquipmentList(Equipment equipment,
                                       @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                       @RequestParam(name="pageSize", defaultValue="10") Integer pageSize,
                                       HttpServletRequest req) {
       QueryWrapper<Equipment> queryWrapper = QueryGenerator.initQueryWrapper(equipment, req.getParameterMap());
       queryWrapper.eq("status","1");
       queryWrapper.eq("del_flag",0);
       Page<Equipment> page = new Page<Equipment>(pageNo, pageSize);
       IPage<Equipment> pageList = equipmentService.page(page, queryWrapper);
       IPage<Equipment> pageList = equipmentService.getEquipmentList(page, equipment);
       return Result.OK(pageList);
    }
    @GetMapping(value = "/pageEquipment")
    public Result<IPage<Equipment>> pageEquipment(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) {
       IPage<Equipment> pageList = equipmentService.pageEquipment(pageNo, pageSize, params);
       return Result.OK(pageList);
    }
@@ -461,34 +468,34 @@
    @GetMapping(value = "/getResumeCalibrationRecordList")
    public Result<?> getResumeCalibrationRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) {
       IPage<Map<String, Object>> resumeCalibrationRecordList = equipmentService.getResumeCalibrationRecordList(pageNo, pageSize, params);
       for (Map<String, Object> record : resumeCalibrationRecordList.getRecords()) {
          String id = (String)record.get("id");
          String status = (String)record.get("status");
          String managementMode = (String)record.get("managementMode");
          if("4".equals(status)){
             if("data".equals(managementMode)){
                List<CalibrationOrderDetail> calibrationOrderDetails = calibrationOrderDetailService.lambdaQuery()
                      .eq(CalibrationOrderDetail::getCalibrationOrderId, id)
                      .eq(CalibrationOrderDetail::getJudgmentResult, "fail")
                      .eq(CalibrationOrderDetail::getDelFlag,"0").list();
                if(calibrationOrderDetails.size()>0){
                   record.put("calibrationResult","异常");
                }else{
                   record.put("calibrationResult","正常常");
                }
             }else{
                List<CalibrationOrderReport> calibrationOrderReports = calibrationOrderReportService.lambdaQuery()
                      .eq(CalibrationOrderReport::getCalibrationOrderId, id)
                      .eq(CalibrationOrderReport::getJudgmentResult, "fail")
                      .eq(CalibrationOrderReport::getDelFlag, "0").list();
                if(calibrationOrderReports.size()>0){
                   record.put("calibrationResult","异常");
                }else{
                   record.put("calibrationResult","正常常");
                }
             }
          }
       }
//       for (Map<String, Object> record : resumeCalibrationRecordList.getRecords()) {
//          String id = (String)record.get("id");
//          String status = (String)record.get("status");
//          String managementMode = (String)record.get("managementMode");
//          if("4".equals(status)){
//             if("data".equals(managementMode)){
//                List<CalibrationOrderDetail> calibrationOrderDetails = calibrationOrderDetailService.lambdaQuery()
//                      .eq(CalibrationOrderDetail::getCalibrationOrderId, id)
//                      .eq(CalibrationOrderDetail::getJudgmentResult, "fail")
//                      .eq(CalibrationOrderDetail::getDelFlag,"0").list();
//                if(calibrationOrderDetails.size()>0){
//                   record.put("calibrationResult","异常");
//                }else{
//                   record.put("calibrationResult","正常常");
//                }
//             }else{
//                List<CalibrationOrderReport> calibrationOrderReports = calibrationOrderReportService.lambdaQuery()
//                      .eq(CalibrationOrderReport::getCalibrationOrderId, id)
//                      .eq(CalibrationOrderReport::getJudgmentResult, "fail")
//                      .eq(CalibrationOrderReport::getDelFlag, "0").list();
//                if(calibrationOrderReports.size()>0){
//                   record.put("calibrationResult","异常");
//                }else{
//                   record.put("calibrationResult","正常常");
//                }
//             }
//          }
//       }
       return Result.ok(resumeCalibrationRecordList);
    }
@@ -516,7 +523,8 @@
       queryWrapper.in("equipment_status",statusList);
       IPage<Equipment> pageList = equipmentService.page(page, queryWrapper);
       return Result.OK(pageList);
    }/**
    }
    /**
     * 导入
     * @return
     */
@@ -573,6 +581,26 @@
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备状态缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
                else if(StringUtils.isBlank(equipmentImportVo.getTechnologyStatus())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备技术缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
                else if(StringUtils.isBlank(equipmentImportVo.getFactoryModelId())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:车间缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
                else if(StringUtils.isBlank(equipmentImportVo.getWorkCenterId())){
                   exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:产线缺失,请填写必填项后再导入;";
                   exceptionNum++;
                }
                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)+"行导入失败,原因:功能位置缺失,请填写必填项后再导入;";
@@ -627,47 +655,91 @@
                       exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:该设备所属类别不存在,请先维护设备类别;";
                       exceptionNum++;
                     }
                      else{
                   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())
                            .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())
                            .setEquipmentStatus(equipmentImportVo.getEquipmentStatus())
                            .setEquipmentUda3(equipmentImportVo.getEquipmentUda3())
                            .setEquipmentUda4(equipmentImportVo.getEquipmentUda4())
                            .setEquipmentUda5(equipmentImportVo.getEquipmentUda5())
                            .setLocation(equipmentImportVo.getLocation())
                            .setLastVerificationDate(equipmentImportVo.getLeaveFactoryDate())
                            .setProjectApprovalNo(equipmentImportVo.getProjectApprovalNo())
                            .setFundSource(equipmentImportVo.getFundSource())
                            .setAcceptanceCheckDate(equipmentImportVo.getAcceptanceCheckDate())
                            .setFactoryNumber(equipmentImportVo.getFactoryNumber())
                            .setConstructorId(equipmentImportVo.getConstructorId())
                            .setSourceCountry(equipmentImportVo.getSourceCountry())
                            .setModel(equipmentImportVo.getModel())
                            .setSpecification(equipmentImportVo.getSpecification())
                            .setGpo(equipmentImportVo.getGpo());
                      equipmentService.save(equipment);
                   }else {
                      exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:统一编码已存在,数据重复导入;";
                      exceptionNum++;
                else{
                         if(equipmentImportVo.getPropertyStatus().equals("warranty")){
                      if(
                            ObjectUtils.isNull(equipmentImportVo.getWarrantyStart())
                            ||ObjectUtils.isNull(equipmentImportVo.getWarrantyEnd())
                      ){
                         exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:该设备处于质保期,质保信息缺失,请先维护质保开始时间或结束时间;";
                         exceptionNum++;
                      }
                   }else{
                      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())
                               .setEquipmentStatus(equipmentImportVo.getEquipmentStatus())
                               .setEquipmentUda3(equipmentImportVo.getEquipmentUda3())
                               .setEquipmentUda4(equipmentImportVo.getEquipmentUda4())
                               .setEquipmentUda5(equipmentImportVo.getEquipmentUda5())
                               .setLocation(equipmentImportVo.getLocation())
                               .setLastVerificationDate(equipmentImportVo.getLeaveFactoryDate())
                               .setProjectApprovalNo(equipmentImportVo.getProjectApprovalNo())
                               .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())
                               .setNextTechnologyStatusQualificationTime(equipmentImportVo.getNextTechnologyStatusQualificationTime())
                               .setGpo(equipmentImportVo.getGpo());
                         if(equipmentCategory.getEquipmentCategoryUda1().equals("weldingMachine")){
                            equipment.setCheckPeriod(365*3+"");
                         }
                         if(equipmentCategory.getEquipmentCategoryUda1().equals("filesCarousel")){
                            equipment.setCheckPeriod(365*4+"");
                         }
                         if(equipmentCategory.getEquipmentCategoryUda1().equals("tester")){
                            equipment.setCheckPeriod(365*1+"");
                         }
                         if(
                               !equipmentCategory.getEquipmentCategoryUda1().equals("weldingMachine")
                               &&!equipmentCategory.getEquipmentCategoryUda1().equals("filesCarousel")
                               &&!equipmentCategory.getEquipmentCategoryUda1().equals("tester")
                         ){
                            if(equipmentImportVo.getEquipmentImportanceId().equals("A")){
                              equipment.setCheckPeriod(365*3+"");
                           }
                            if(
                                  equipmentImportVo.getEquipmentImportanceId().equals("B")
                                 ||equipmentImportVo.getEquipmentImportanceId().equals("C")
                                 ||equipmentImportVo.getEquipmentImportanceId().equals("D")
                           ){
                               equipment.setCheckPeriod(365*4+"");
                            }
                         }
                         equipmentService.save(equipment);
                      }else {
                         exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:统一编码已存在,数据重复导入;";
                         exceptionNum++;
                      }
                   }
                }
             }
             if(exceptionNum!=0){
@@ -689,6 +761,17 @@
       }
       return Result.error("文件导入失败!");
    }
    @GetMapping(value = "/getEquipmentStansdardList")
    @PermissionData
    public Result<IPage<DailyInspectionStandardDetail>> getEquipmentStansdardList(DailyInspectionStandardDetail standardDetail,
                                         @RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
                                         @RequestParam(name="pageSize", defaultValue="10") Integer pageSize,
                                         HttpServletRequest req) {
       QueryWrapper<DailyInspectionStandardDetail> queryWrapper = QueryGenerator.initQueryWrapper(standardDetail, req.getParameterMap());
       Page<DailyInspectionStandardDetail> page = new Page<DailyInspectionStandardDetail>(pageNo, pageSize);
       IPage<DailyInspectionStandardDetail> pageList = equipmentService.getStandardList(page,standardDetail.getEquipmentId());
       return Result.OK(pageList);
    }
}