| | |
| | | package org.jeecg.modules.eam.controller; |
| | | |
| | | import java.time.LocalDate; |
| | | import java.util.Arrays; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | |
| | | 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.common.util.DateUtils; |
| | | import org.jeecg.modules.base.entity.Constructor; |
| | | import org.jeecg.modules.base.service.IConstructorService; |
| | | import org.jeecg.modules.base.service.IFactoryModelService; |
| | |
| | | import org.jeecg.common.system.base.controller.JeecgController; |
| | | |
| | | import org.jeecg.modules.system.entity.SysDepart; |
| | | import org.jeecg.modules.system.entity.SysUser; |
| | | import org.jeecg.modules.system.service.ISysDepartService; |
| | | import org.jeecg.modules.system.service.ISysUserService; |
| | | import org.jeecgframework.poi.excel.ExcelImportUtil; |
| | | import org.jeecgframework.poi.excel.entity.ImportParams; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | @Autowired |
| | | private IMaintenanceStandardService maintenanceStandardService; |
| | | |
| | | |
| | | @Autowired |
| | | private ISysUserService sysUserService; |
| | | |
| | | |
| | | /** |
| | |
| | | } |
| | | if(StringUtils.isNotBlank(equipment.getEquipmentCategoryId())){ |
| | | queryWrapper.eq("equipment_category_id",equipment.getEquipmentCategoryId()); |
| | | } |
| | | List<String> userWorkCenterIds = getUserWorkCenterIds(); |
| | | if(CollectionUtils.isNotEmpty(userWorkCenterIds)) { |
| | | queryWrapper.in("work_center_id",userWorkCenterIds); |
| | | } |
| | | if(StringUtils.isNotBlank(equipment.getWorkCenterId())){ |
| | | queryWrapper.eq("work_center_id",equipment.getWorkCenterId()); |
| | |
| | | @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<Equipment> queryWrapper = QueryGenerator.initQueryWrapper(equipment, req.getParameterMap()); |
| | | Page<Equipment> page = new Page<Equipment>(pageNo, pageSize); |
| | | IPage<Equipment> pageList = equipmentService.getEquipmentTZList(page, equipment); |
| | | List<Equipment> list = pageList.getRecords(); |
| | | list.forEach(equip -> { |
| | | String id = equip.getId(); |
| | | List<DailyInspectionStandard> dailyInspectionStandards = dailyInspectionStandardService.lambdaQuery() |
| | | .eq(DailyInspectionStandard::getEquipmentId, id) |
| | | .eq(DailyInspectionStandard::getVersionStatus, "2") |
| | | .list(); |
| | | if (dailyInspectionStandards.size() > 0) { |
| | | equip.setYseNoInspectionStandard("0"); |
| | | } else { |
| | | equip.setYseNoInspectionStandard("1"); |
| | | } |
| | | List<MaintenanceStandard> maintenance2Standards = maintenanceStandardService.lambdaQuery() |
| | | .eq(MaintenanceStandard::getEquipmentId, id) |
| | | .eq(MaintenanceStandard::getMaintenanceType, "2") |
| | | .eq(MaintenanceStandard::getVersionStatus, "2").list(); |
| | | if (maintenance2Standards.size() > 0) { |
| | | equip.setYseNoMaintenance2Standard("0"); |
| | | } else { |
| | | equip.setYseNoMaintenance2Standard("1"); |
| | | } |
| | | |
| | | List<MaintenanceStandard> maintenance3Standards = maintenanceStandardService.lambdaQuery() |
| | | .eq(MaintenanceStandard::getEquipmentId, id) |
| | | .eq(MaintenanceStandard::getMaintenanceType, "3") |
| | | .eq(MaintenanceStandard::getVersionStatus, "2").list(); |
| | | if (maintenance3Standards.size() > 0) { |
| | | equip.setYseNoMaintenance3Standard("0"); |
| | | } else { |
| | | equip.setYseNoMaintenance3Standard("1"); |
| | | } |
| | | }); |
| | | return Result.OK(pageList); |
| | | } |
| | | |
| | |
| | | @PostMapping(value = "/add") |
| | | @Transactional(rollbackFor = { Exception.class }) |
| | | public Result<String> add(@RequestBody Equipment equipment) { |
| | | //下次三保日期处理 |
| | | if(equipment.getThirdMaintenanceTime() == null && equipment.getAcceptanceCheckDate() != null && StringUtils.isNotBlank(equipment.getCheckPeriod())){ |
| | | //如果没有三保日期 按照验收日期计算下次三保日期 |
| | | int checkPeriod = Integer.parseInt(equipment.getCheckPeriod()) - 1; |
| | | LocalDate acceptanceCheckDate = LocalDate.parse(equipment.getAcceptanceCheckDate()); |
| | | LocalDate localDate = acceptanceCheckDate.plusDays(checkPeriod); |
| | | Date date = DateUtils.str2Date(localDate.toString(), DateUtils.date_sdf.get()); |
| | | equipment.setNextThirdMaintenanceTime(date); |
| | | }else if(equipment.getThirdMaintenanceTime() != null && StringUtils.isNotBlank(equipment.getCheckPeriod())){ |
| | | //如果有三保日期 则使用三保日期计算 下次三保日期 |
| | | int checkPeriod = Integer.parseInt(equipment.getCheckPeriod()) - 1; |
| | | Date date = DateUtils.getDayAfter(equipment.getThirdMaintenanceTime(), checkPeriod); |
| | | equipment.setNextThirdMaintenanceTime(date); |
| | | } |
| | | equipmentService.save(equipment); |
| | | //获取工艺参数模板明细 |
| | | String processParametersTemplateId = equipment.getProcessParametersTemplateId(); |
| | |
| | | equipmentPrecisionParameters.setEquipmentId(equipment.getId()); |
| | | equipmentPrecisionParameters.setPrecisionParametersId(precisionParameter.getPrecisionParametersId()); |
| | | equipmentPrecisionParametersService.save(equipmentPrecisionParameters); |
| | | } |
| | | |
| | | //下次三保日期处理 |
| | | if(equipment.getThirdMaintenanceTime() == null && equipment.getAcceptanceCheckDate() != null && StringUtils.isNotBlank(equipment.getCheckPeriod())){ |
| | | //如果没有三保日期 按照验收日期计算下次三保日期 |
| | | int checkPeriod = Integer.parseInt(equipment.getCheckPeriod()) - 1; |
| | | LocalDate acceptanceCheckDate = LocalDate.parse(equipment.getAcceptanceCheckDate()); |
| | | LocalDate localDate = acceptanceCheckDate.plusDays(checkPeriod); |
| | | Date date = DateUtils.str2Date(localDate.toString(), DateUtils.date_sdf.get()); |
| | | equipment.setNextThirdMaintenanceTime(date); |
| | | }else if(equipment.getThirdMaintenanceTime() != null && StringUtils.isNotBlank(equipment.getCheckPeriod())){ |
| | | //如果有三保日期 则使用三保日期计算 下次三保日期 |
| | | int checkPeriod = Integer.parseInt(equipment.getCheckPeriod()) - 1; |
| | | Date date = DateUtils.getDayAfter(equipment.getThirdMaintenanceTime(), checkPeriod); |
| | | equipment.setNextThirdMaintenanceTime(date); |
| | | } |
| | | |
| | | equipmentService.updateById(equipment); |
| | |
| | | EquipmentImportVo equipmentImportVo = list.get(i); |
| | | String equipmentCategoryName = equipmentImportVo.getEquipmentCategoryName(); |
| | | String useId = equipmentImportVo.getUseId(); |
| | | String areaId = equipmentImportVo.getFactoryModelId(); |
| | | String workCenterId = equipmentImportVo.getWorkCenterId();//中心 |
| | | String areaId = equipmentImportVo.getFactoryModelId();//工区 |
| | | String productionId = equipmentImportVo.getAreaId();//工段 |
| | | String manageId = equipmentImportVo.getManageId(); |
| | | String constructorId = equipmentImportVo.getConstructorId(); |
| | | String teamId = equipmentImportVo.getTeamId(); |
| | |
| | | exceptionNum++; |
| | | continue; |
| | | } |
| | | else if(StringUtils.isBlank(equipmentImportVo.getModel())){ |
| | | exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备型号缺失,请填写必填项后再导入;"; |
| | | // else if(StringUtils.isBlank(equipmentImportVo.getModel())){ |
| | | // exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:设备型号缺失,请填写必填项后再导入;"; |
| | | // exceptionNum++; |
| | | // continue; |
| | | // } |
| | | else if(StringUtils.isBlank(useId)){ |
| | | exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:使用部门缺失,请填写必填项后再导入;"; |
| | | exceptionNum++; |
| | | continue; |
| | | } |
| | | else if(StringUtils.isBlank(useId)){ |
| | | exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:使用部门缺失,请填写必填项后再导入;"; |
| | | else if(StringUtils.isBlank(workCenterId)){ |
| | | exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:中心缺失,请填写必填项后再导入;"; |
| | | exceptionNum++; |
| | | continue; |
| | | } |
| | |
| | | exceptionNum++; |
| | | continue; |
| | | } |
| | | //中心 |
| | | Area workCenterArea = areaService.getOne(new QueryWrapper<Area>().eq("name",workCenterId.trim()).eq("del_flag",0)); |
| | | if(ObjectUtils.isNotNull(workCenterArea)){ |
| | | equipment.setWorkCenterId(workCenterArea.getId()); |
| | | // }else if(ObjectUtils.isNotNull(area1)) { |
| | | // equipment.setFactoryModelId(area1.getId()); |
| | | }else { |
| | | exceptionInfo = exceptionInfo+"第"+(i+2)+"行导入失败,原因:不存在该中心,请维护中心数据后再导入;"; |
| | | exceptionNum++; |
| | | continue; |
| | | } |
| | | //工区 |
| | | Area area = areaService.getOne(new QueryWrapper<Area>().eq("name",areaId.trim()).eq("del_flag",0)); |
| | | Area area1 = areaService.getOne(new QueryWrapper<Area>().eq("num",areaId.trim()).eq("del_flag",0)); |
| | | if(ObjectUtils.isNotNull(area)){ |
| | |
| | | exceptionNum++; |
| | | continue; |
| | | } |
| | | |
| | | //工段 |
| | | Area productionArea = areaService.getOne(new QueryWrapper<Area>().eq("name",productionId.trim()).eq("del_flag",0)); |
| | | if(ObjectUtils.isNotNull(productionArea)){ |
| | | equipment.setAreaId(productionArea.getId()); |
| | | } |
| | | |
| | | SysDepart manage = departService.getOne(new QueryWrapper<SysDepart>().eq("depart_name",manageId.trim()).eq("del_flag",0)); |
| | | if(ObjectUtils.isNotNull(manage)){ |
| | | equipment.setManageId(manage.getId()); |
| | |
| | | equipment.setCheckPeriod(365*4+""); |
| | | } |
| | | } |
| | | } |
| | | //下次三保日期处理 |
| | | if(equipment.getThirdMaintenanceTime() == null && equipment.getAcceptanceCheckDate() != null && StringUtils.isNotBlank(equipment.getCheckPeriod())){ |
| | | //如果没有三保日期 按照验收日期计算下次三保日期 |
| | | int checkPeriod = Integer.parseInt(equipment.getCheckPeriod()) - 1; |
| | | LocalDate acceptanceCheckDate = LocalDate.parse(equipment.getAcceptanceCheckDate()); |
| | | LocalDate localDate = acceptanceCheckDate.plusDays(checkPeriod); |
| | | Date date = DateUtils.str2Date(localDate.toString(), DateUtils.date_sdf.get()); |
| | | equipment.setNextThirdMaintenanceTime(date); |
| | | }else if(equipment.getThirdMaintenanceTime() != null && StringUtils.isNotBlank(equipment.getCheckPeriod())){ |
| | | //如果有三保日期 则使用三保日期计算 下次三保日期 |
| | | int checkPeriod = Integer.parseInt(equipment.getCheckPeriod()) - 1; |
| | | Date date = DateUtils.getDayAfter(equipment.getThirdMaintenanceTime(), checkPeriod); |
| | | equipment.setNextThirdMaintenanceTime(date); |
| | | } |
| | | equipmentService.save(equipment); |
| | | }else { |
| | |
| | | return Result.OK(pageList); |
| | | } |
| | | |
| | | private List<String> getUserWorkCenterIds(){ |
| | | LoginUser user= (LoginUser) SecurityUtils.getSubject().getPrincipal(); |
| | | SysUser sysUser = sysUserService.getById(user.getId()); |
| | | String areaId = sysUser.getAreaId(); |
| | | List<String> workCenterIds = null; |
| | | if(StringUtils.isNotBlank(areaId)){ |
| | | // strings = new ArrayList<>(); |
| | | String[] split = areaId.split(","); |
| | | workCenterIds = Arrays.asList(split); |
| | | } |
| | | return workCenterIds; |
| | | } |
| | | |
| | | } |