package org.jeecg.modules.eam.controller; import java.util.Arrays; import java.util.List; import java.util.Map; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.StringUtils; 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; import org.jeecg.common.system.query.QueryGenerator; import org.jeecg.common.system.vo.LoginUser; import org.jeecg.modules.eam.entity.*; import org.jeecg.modules.eam.model.DepartVo; import org.jeecg.modules.eam.service.*; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import lombok.extern.slf4j.Slf4j; import org.jeecg.common.system.base.controller.JeecgController; import org.jeecgframework.poi.excel.ExcelImportUtil; import org.jeecgframework.poi.excel.entity.ImportParams; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.transaction.annotation.Transactional; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartHttpServletRequest; import org.springframework.web.servlet.ModelAndView; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import org.jeecg.common.aspect.annotation.AutoLog; /** * @Description: mom_eam_equipment * @Author: jeecg-boot * @Date: 2023-03-23 * @Version: V1.0 */ @Api(tags="mom_eam_equipment") @RestController @RequestMapping("/eam/equipment") @Slf4j public class EamEquipmentController extends JeecgController { @Autowired private IEamEquipmentService equipmentService; @Autowired private IPrecisionParametersTemplateDetailService precisionParametersTemplateDetailService; @Autowired private IProcessParametersTemplateDetailService processParametersTemplateDetailService; @Autowired private IEquipmentProcessParametersService equipmentProcessParametersService; @Autowired private IEquipmentPrecisionParametersService equipmentPrecisionParametersService; @Autowired private IPrecisionParametersTemplateService precisionParametersTemplateService; @Autowired private IProcessParametersTemplateService processParametersTemplateService; @Autowired private ISysBaseAPI sysBaseApi; @Autowired @Lazy private IEquipmentSealDetailService equipmentSealDetailService; @Autowired @Lazy private IInspectionOrderDetailService inspectionOrderDetailService; @Autowired @Lazy private ISpecialtyInspectionOrderDetailService specialtyInspectionOrderDetailService; @Autowired private ICalibrationOrderDetailService calibrationOrderDetailService; @Autowired private ICalibrationOrderReportService calibrationOrderReportService; @Autowired private IEquipmentCategoryService equipmentCategoryService; /** * 分页列表查询 * * @param equipment * @param pageNo * @param pageSize * @param req * @return */ //@AutoLog(value = "mom_eam_equipment-分页列表查询") @ApiOperation(value="mom_eam_equipment-分页列表查询", notes="mom_eam_equipment-分页列表查询") @GetMapping(value = "/list") public Result> queryPageList(Equipment equipment, @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, HttpServletRequest req) { //QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(equipment, req.getParameterMap()); QueryWrapper queryWrapper = new QueryWrapper<>(); if(StringUtils.isNotBlank(equipment.getNum())){ queryWrapper.like("num",equipment.getNum()); } if(StringUtils.isNotBlank(equipment.getName())){ queryWrapper.like("name",equipment.getName()); } if(StringUtils.isNotBlank(equipment.getEquipmentStatus())){ queryWrapper.eq("equipment_status",equipment.getEquipmentStatus()); } if(StringUtils.isNotBlank(equipment.getTechnologyStatus())){ queryWrapper.eq("technology_status",equipment.getTechnologyStatus()); } if(StringUtils.isNotBlank(equipment.getEquipmentCategoryId())){ queryWrapper.eq("equipment_category_id",equipment.getEquipmentCategoryId()); } queryWrapper.eq("status","1"); queryWrapper.eq("del_flag",0); queryWrapper.orderByDesc("create_time"); Page page = new Page(pageNo, pageSize); IPage pageList = equipmentService.page(page, queryWrapper); List equipmentList = pageList.getRecords(); for (Equipment eq : equipmentList) { String precisionParametersTemplateId = eq.getPrecisionParametersTemplateId(); if(StringUtils.isNotBlank(precisionParametersTemplateId)){ PrecisionParametersTemplate precisionParametersTemplate = precisionParametersTemplateService.getById(precisionParametersTemplateId); if(precisionParametersTemplate != null){ eq.setPrecisionParametersTemplateName(precisionParametersTemplate.getName()); }else{ eq.setPrecisionParametersTemplateName(""); } }else{ eq.setPrecisionParametersTemplateName(""); } String processParametersTemplateId = eq.getProcessParametersTemplateId(); if(StringUtils.isNotBlank(processParametersTemplateId)){ ProcessParametersTemplate processParametersTemplate = processParametersTemplateService.getById(processParametersTemplateId); if(processParametersTemplate != null){ eq.setProcessParametersTemplateName(processParametersTemplate.getName()); }else{ eq.setProcessParametersTemplateName(""); } }else{ eq.setProcessParametersTemplateName(""); } //查询封存原因和封存日期 List equipmentSealDetailList = equipmentSealDetailService.lambdaQuery().eq(EquipmentSealDetail::getEquipmentId,eq.getId()) .eq(EquipmentSealDetail::getDelFlag, CommonConstant.DEL_FLAG_0).orderByDesc(EquipmentSealDetail::getCreateTime).list(); if(CollectionUtils.isNotEmpty(equipmentSealDetailList)){ eq.setSealReason(equipmentSealDetailList.get(0).getSealReason()); eq.setSealDate(equipmentSealDetailList.get(0).getSealDate()); } } return Result.OK(pageList); } /** * 设备保修 获取设备列表组件 * qsw 2023-7-14 */ @GetMapping(value = "/getEquipmentList") @PermissionData public Result> getEquipmentList(Equipment equipment, @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, HttpServletRequest req) { QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(equipment, req.getParameterMap()); Page page = new Page(pageNo, pageSize); IPage pageList = equipmentService.getEquipmentList(page, equipment); return Result.OK(pageList); } @GetMapping(value = "/pageEquipment") public Result> pageEquipment(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage pageList = equipmentService.pageEquipment(pageNo, pageSize, params); return Result.OK(pageList); } /** * 添加 * * @param equipment * @return */ @AutoLog(value = "mom_eam_equipment-添加") @ApiOperation(value="mom_eam_equipment-添加", notes="mom_eam_equipment-添加") @PostMapping(value = "/add") @Transactional(rollbackFor = { Exception.class }) public Result add(@RequestBody Equipment equipment) { equipmentService.save(equipment); //获取工艺参数模板明细 String processParametersTemplateId = equipment.getProcessParametersTemplateId(); List processParameters = processParametersTemplateDetailService.lambdaQuery() .eq(ProcessParametersTemplateDetail::getProcessParametersTemplateId, processParametersTemplateId) .eq(ProcessParametersTemplateDetail::getDelFlag, 0).list(); for (ProcessParametersTemplateDetail processParameter : processParameters) { EquipmentProcessParameters equipmentProcessParameters = new EquipmentProcessParameters(); equipmentProcessParameters.setEquipmentId(equipment.getId()); equipmentProcessParameters.setProcessParametersId(processParameter.getProcessParametersId()); equipmentProcessParametersService.save(equipmentProcessParameters); } //获取设备精度参数模板明细 String precisionParametersTemplateId = equipment.getPrecisionParametersTemplateId(); List precisionParameters = precisionParametersTemplateDetailService.lambdaQuery() .eq(PrecisionParametersTemplateDetail::getPrecisionParametersTemplateId, precisionParametersTemplateId) .eq(PrecisionParametersTemplateDetail::getDelFlag, 0).list(); for (PrecisionParametersTemplateDetail precisionParameter : precisionParameters) { EquipmentPrecisionParameters equipmentPrecisionParameters = new EquipmentPrecisionParameters(); equipmentPrecisionParameters.setEquipmentId(equipment.getId()); equipmentPrecisionParameters.setPrecisionParametersId(precisionParameter.getPrecisionParametersId()); equipmentPrecisionParametersService.save(equipmentPrecisionParameters); } List sysUploads = equipment.getSysUploadList(); if (sysUploads!= null){ // uploadRelaService.saveOrUpdateUploadRale(equipment.getId(), "equipment_photo",sysUploads.get(0).getId()); sysBaseApi.saveOrUpdateUploadRale(equipment.getId(), "equipment_photo",sysUploads.get(0).getId()); } return Result.OK("添加成功!"); } /** * 编辑 * * @param equipment * @return */ @AutoLog(value = "mom_eam_equipment-编辑") @ApiOperation(value="mom_eam_equipment-编辑", notes="mom_eam_equipment-编辑") @RequestMapping(value = "/edit", method = {RequestMethod.PUT,RequestMethod.POST}) @Transactional(rollbackFor = { Exception.class }) public Result edit(@RequestBody Equipment equipment) { List proParameters = equipmentProcessParametersService.lambdaQuery() .eq(EquipmentProcessParameters::getEquipmentId, equipment.getId()) .eq(EquipmentProcessParameters::getDelFlag, 0).list(); for (EquipmentProcessParameters proParameter : proParameters) { equipmentProcessParametersService.removeById(proParameter); } List preParameters = equipmentPrecisionParametersService.lambdaQuery() .eq(EquipmentPrecisionParameters::getEquipmentId, equipment.getId()) .eq(EquipmentPrecisionParameters::getDelFlag, 0).list(); for (EquipmentPrecisionParameters preParameter : preParameters) { equipmentPrecisionParametersService.removeById(preParameter); } //获取工艺参数模板明细 String processParametersTemplateId = equipment.getProcessParametersTemplateId(); List processParameters = processParametersTemplateDetailService.lambdaQuery() .eq(ProcessParametersTemplateDetail::getProcessParametersTemplateId, processParametersTemplateId) .eq(ProcessParametersTemplateDetail::getDelFlag, 0).list(); for (ProcessParametersTemplateDetail processParameter : processParameters) { EquipmentProcessParameters equipmentProcessParameters = new EquipmentProcessParameters(); equipmentProcessParameters.setEquipmentId(equipment.getId()); equipmentProcessParameters.setProcessParametersId(processParameter.getProcessParametersId()); equipmentProcessParametersService.save(equipmentProcessParameters); } //获取设备精度参数模板明细 String precisionParametersTemplateId = equipment.getPrecisionParametersTemplateId(); List precisionParameters = precisionParametersTemplateDetailService.lambdaQuery() .eq(PrecisionParametersTemplateDetail::getPrecisionParametersTemplateId, precisionParametersTemplateId) .eq(PrecisionParametersTemplateDetail::getDelFlag, 0).list(); for (PrecisionParametersTemplateDetail precisionParameter : precisionParameters) { EquipmentPrecisionParameters equipmentPrecisionParameters = new EquipmentPrecisionParameters(); equipmentPrecisionParameters.setEquipmentId(equipment.getId()); equipmentPrecisionParameters.setPrecisionParametersId(precisionParameter.getPrecisionParametersId()); equipmentPrecisionParametersService.save(equipmentPrecisionParameters); } equipmentService.updateById(equipment); List sysUploads = equipment.getSysUploadList(); if (sysUploads!= null){ // uploadRelaService.saveOrUpdateUploadRale(equipment.getId(), "equipment_photo",sysUploads.get(0).getId()); sysBaseApi.saveOrUpdateUploadRale(equipment.getId(), "equipment_photo",sysUploads.get(0).getId()); } return Result.OK("编辑成功!"); } /** * 通过id删除 * * @param id * @return */ @AutoLog(value = "mom_eam_equipment-通过id删除") @ApiOperation(value="mom_eam_equipment-通过id删除", notes="mom_eam_equipment-通过id删除") //@RequiresPermissions("org.jeecg.modules.demo:mom_eam_equipment:delete") @DeleteMapping(value = "/delete") public Result delete(@RequestParam(name="id",required=true) String id) { Equipment equipment = equipmentService.getById(id); equipment.setDelFlag(1); equipmentService.updateById(equipment); return Result.OK("删除成功!"); } /** * 批量删除 * * @param ids * @return */ @AutoLog(value = "mom_eam_equipment-批量删除") @ApiOperation(value="mom_eam_equipment-批量删除", notes="mom_eam_equipment-批量删除") //@RequiresPermissions("org.jeecg.modules.demo:mom_eam_equipment:deleteBatch") @DeleteMapping(value = "/deleteBatch") public Result deleteBatch(@RequestParam(name="ids",required=true) String ids) { List stringList = Arrays.asList(ids.split(",")); for (String id : stringList) { Equipment equipment = equipmentService.getById(id); equipment.setDelFlag(1); equipmentService.updateById(equipment); } // this.equipmentService.removeByIds(Arrays.asList(ids.split(","))); return Result.OK("批量删除成功!"); } /** * 通过id查询 * * @param id * @return */ //@AutoLog(value = "mom_eam_equipment-通过id查询") @ApiOperation(value="mom_eam_equipment-通过id查询", notes="mom_eam_equipment-通过id查询") @GetMapping(value = "/queryById") public Result queryById(@RequestParam(name="id",required=true) String id) { Equipment equipment = equipmentService.getById(id); if(equipment==null) { return Result.error("未找到对应数据"); } return Result.OK(equipment); } /** * 导出excel * * @param request * @param equipment */ //@RequiresPermissions("org.jeecg.modules.demo:mom_eam_equipment:exportXls") @RequestMapping(value = "/exportXls") public ModelAndView exportXls(HttpServletRequest request, Equipment equipment) { return super.exportXls(request, equipment, Equipment.class, "设备台账导出"); } // /** // * 通过excel导入数据 // * // * @param request // * @param response // * @return // */ // //@RequiresPermissions("mom_eam_equipment:importExcel") // @RequestMapping(value = "/importExcel", method = RequestMethod.POST) // public Result importExcel(HttpServletRequest request, HttpServletResponse response) { // return super.importExcel(request, response, Equipment.class); // } /** * 设备建账 获取组织部门 * qsw 2023-4-28 */ @GetMapping("getSysDeparts") public Result getSysDeparts() { List sysDeparts = equipmentService.getSysDeparts(); return Result.ok(sysDeparts); } /** *设备履历 获取设备使用记录 * qsw 2023-7-28 */ @GetMapping(value = "/getResumeUseRecordList") public Result getResumeUseRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> resumeUseRecordList = equipmentService.getResumeUseRecordList(pageNo, pageSize, params); return Result.ok(resumeUseRecordList); } /** *设备履历 获取设备点检记录 * qsw 2023-7-28 */ @GetMapping(value = "/getResumeInspectionRecordList") public Result getResumeInspectionRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> resumeInspectionRecordList = equipmentService.getResumeInspectionRecordList(pageNo, pageSize, params); LoginUser user= (LoginUser) SecurityUtils.getSubject().getPrincipal(); for (Map record : resumeInspectionRecordList.getRecords()) { String id = (String)record.get("id"); String inspectionType = (String)record.get("inspectionType"); if("日常点检".equals(inspectionType)){ List failCount = inspectionOrderDetailService.lambdaQuery() .eq(InspectionOrderDetail::getInspectionOrderId, id) .eq(InspectionOrderDetail::getJudgmentResult, "fail") .eq(InspectionOrderDetail::getDelFlag, 0).list(); List passCount = inspectionOrderDetailService.lambdaQuery() .eq(InspectionOrderDetail::getInspectionOrderId, id) .eq(InspectionOrderDetail::getJudgmentResult,"pass") .eq(InspectionOrderDetail::getDelFlag, 0).list(); record.put("result","正常:"+passCount.size()+","+"异常:"+failCount.size()); }else{ List failCount = specialtyInspectionOrderDetailService.lambdaQuery() .eq(SpecialtyInspectionOrderDetail::getSpecialtyInspectionOrderId, id) .eq(SpecialtyInspectionOrderDetail::getJudgmentResult,"fail") .eq(SpecialtyInspectionOrderDetail::getDelFlag, 0).list(); List passCount = specialtyInspectionOrderDetailService.lambdaQuery() .eq(SpecialtyInspectionOrderDetail::getSpecialtyInspectionOrderId, id) .eq(SpecialtyInspectionOrderDetail::getJudgmentResult,"pass") .eq(SpecialtyInspectionOrderDetail::getDelFlag, 0).list(); record.put("result","正常:"+passCount.size()+","+"异常:"+failCount.size()); } } return Result.ok(resumeInspectionRecordList); } /** *设备履历 获取设备保养记录 * qsw 2023-7-31 */ @GetMapping(value = "/getResumeMaintenanceRecordList") public Result getResumeMaintenanceRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> resumeMaintenanceRecordList = equipmentService.getResumeMaintenanceRecordList(pageNo, pageSize, params); return Result.ok(resumeMaintenanceRecordList); } /** *设备履历 获取设备维修记录 * qsw 2023-7-31 */ @GetMapping(value = "/getResumeRepairRecordList") public Result getResumeRepairRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> resumeRepairRecordList = equipmentService.getResumeRepairRecordList(pageNo, pageSize, params); return Result.ok(resumeRepairRecordList); } /** *设备履历 获取设备检定记录 * qsw 2023-7-31 */ @GetMapping(value = "/getResumeCalibrationRecordList") public Result getResumeCalibrationRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> resumeCalibrationRecordList = equipmentService.getResumeCalibrationRecordList(pageNo, pageSize, params); for (Map 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 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 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); } /** *设备履历 获取设备处置记录 * qsw 2023-7-31 */ @GetMapping(value = "/getResumeChangeRecordList") public Result getResumeChangeRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map params) { IPage> resumeChangeRecordList = equipmentService.getResumeChangeRecordList(pageNo, pageSize, params); return Result.ok(resumeChangeRecordList); } /** * 根据状态查询设备列表 */ @GetMapping(value = "/getEquipmentListByStatus") public Result> getEquipmentList(Equipment equipment,String status, @RequestParam(name="pageNo", defaultValue="1") Integer pageNo, @RequestParam(name="pageSize", defaultValue="10") Integer pageSize, HttpServletRequest req) { QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(equipment, req.getParameterMap()); List statusList = Arrays.asList(status.split(",")); Page page = new Page(pageNo, pageSize); queryWrapper.in("equipment_status",statusList); IPage pageList = equipmentService.page(page, queryWrapper); return Result.OK(pageList); } /** * 导入 * @return */ @RequestMapping(value = "/importExcel", method = RequestMethod.POST) @Transactional(rollbackFor = Exception.class) public Result importExcel(HttpServletRequest request, HttpServletResponse response) { MultipartHttpServletRequest multipartRequest = (MultipartHttpServletRequest) request; LoginUser user= (LoginUser) SecurityUtils.getSubject().getPrincipal(); Map fileMap = multipartRequest.getFileMap(); String exceptionInfo = ""; int exceptionNum = 0; for (Map.Entry entity : fileMap.entrySet()) { MultipartFile file = entity.getValue(); ImportParams params = new ImportParams(); params.setNeedSave(true); try { List list = ExcelImportUtil.importExcel(file.getInputStream(), EquipmentImportVo.class, params); for(int i = 0;i().eq("name",equipmentImportVo.getEquipmentCategoryName()),false); if(StringUtils.isBlank(equipmentImportVo.getNum())){ exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:统一编码缺失,请填写必填项后再导入;"; exceptionNum++; } 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++; } else if(StringUtils.isBlank(equipmentImportVo.getTeamId())){ exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:维修班组缺失,请填写必填项后再导入;"; exceptionNum++; } else if(StringUtils.isBlank(equipmentImportVo.getEquipmentImportanceId())){ exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:ABC标识缺失,请填写必填项后再导入;"; exceptionNum++; } else if(StringUtils.isBlank(equipmentImportVo.getEquipmentCategoryName())){ exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备分类缺失,请填写必填项后再导入;"; exceptionNum++; } else if(StringUtils.isBlank(equipmentImportVo.getEquipmentStatus())){ 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)+"行导入失败,原因:功能位置缺失,请填写必填项后再导入;"; // exceptionNum++; // } // else if(StringUtils.isBlank(equipmentImportVo.getLocation())){ // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:安装位置缺失,请填写必填项后再导入;"; // exceptionNum++; // } // else if(StringUtils.isBlank(equipmentImportVo.getLeaveFactoryDate())){ // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:出厂日期缺失,请填写必填项后再导入;"; // exceptionNum++; // } // else if(StringUtils.isBlank(equipmentImportVo.getProjectApprovalNo())){ // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:立项卡号缺失,请填写必填项后再导入;"; // exceptionNum++; // } // else if(StringUtils.isBlank(equipmentImportVo.getFundSource())){ // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:资金来源缺失,请填写必填项后再导入;"; // exceptionNum++; // } // else if(StringUtils.isBlank(equipmentImportVo.getAcceptanceCheckDate())){ // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:验收日期缺失,请填写必填项后再导入;"; // exceptionNum++; // } // else if(StringUtils.isBlank(equipmentImportVo.getLeaveFactoryDate())){ // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:出厂日期缺失,请填写必填项后再导入;"; // exceptionNum++; // } // else if(StringUtils.isBlank(equipmentImportVo.getFactoryNo())){ // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:出厂编号缺失,请填写必填项后再导入;"; // exceptionNum++; // } // 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.getGpo())){ // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备功率缺失,请填写必填项后再导入;"; // exceptionNum++; // } else if(ObjectUtils.isNull(equipmentCategory)) { 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().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){ String headInfo = "小导提醒您!设备台账:导入成功"+(list.size()-exceptionNum)+"条,失败"+exceptionNum+"条"; MessageDTO messageDTO = new MessageDTO(); messageDTO.setTitle(headInfo); messageDTO.setFromUser("数据导入小助手-小导"); messageDTO.setCategory("导入操作附加信息"); messageDTO.setContent(exceptionInfo); messageDTO.setToUser(user.getUsername()); sysBaseApi.sendSysAnnouncement(messageDTO); return Result.OK(headInfo+",可在-系统消息-查看导入详情"); } return Result.OK("导入成功,已导入全部数据。"); } catch (Exception e) { log.error(e.getMessage(), e); return Result.error("文件导入失败:" + e.getMessage()); } } return Result.error("文件导入失败!"); } }