| | |
| | | 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.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 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; |
| | |
| | | |
| | | @Autowired |
| | | private ICalibrationOrderReportService calibrationOrderReportService; |
| | | |
| | | @Autowired |
| | | private IEquipmentCategoryService equipmentCategoryService; |
| | | /** |
| | | * å页å表æ¥è¯¢ |
| | | * |
| | |
| | | IPage<Equipment> pageList = equipmentService.page(page, queryWrapper); |
| | | return Result.OK(pageList); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * æ·»å |
| | | * |
| | |
| | | } |
| | | return Result.OK("æ·»å æåï¼"); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * ç¼è¾ |
| | | * |
| | |
| | | } |
| | | return Result.OK("ç¼è¾æå!"); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * éè¿idå é¤ |
| | | * |
| | |
| | | equipmentService.updateById(equipment); |
| | | return Result.OK("å 餿å!"); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * æ¹éå é¤ |
| | | * |
| | |
| | | // this.equipmentService.removeByIds(Arrays.asList(ids.split(","))); |
| | | return Result.OK("æ¹éå 餿å!"); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * éè¿idæ¥è¯¢ |
| | | * |
| | |
| | | return super.exportXls(request, equipment, Equipment.class, "mom_eam_equipment"); |
| | | } |
| | | |
| | | /** |
| | | * éè¿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); |
| | | } |
| | | // /** |
| | | // * éè¿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); |
| | | // } |
| | | |
| | | |
| | | /** |
| | |
| | | @GetMapping(value = "/getResumeInspectionRecordList") |
| | | public Result<?> getResumeInspectionRecordList(@RequestParam("pageNo") Integer pageNo, @RequestParam("pageSize") Integer pageSize, @RequestParam Map<String, Object> params) { |
| | | IPage<Map<String, Object>> resumeInspectionRecordList = equipmentService.getResumeInspectionRecordList(pageNo, pageSize, params); |
| | | LoginUser user= (LoginUser) SecurityUtils.getSubject().getPrincipal(); |
| | | for (Map<String, Object> record : resumeInspectionRecordList.getRecords()) { |
| | | String id = (String)record.get("id"); |
| | | String inspectionType = (String)record.get("inspectionType"); |
| | |
| | | queryWrapper.in("equipment_status",statusList); |
| | | IPage<Equipment> 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<String, MultipartFile> fileMap = multipartRequest.getFileMap(); |
| | | String exceptionInfo = ""; |
| | | int exceptionNum = 0; |
| | | for (Map.Entry<String, MultipartFile> entity : fileMap.entrySet()) { |
| | | MultipartFile file = entity.getValue(); |
| | | ImportParams params = new ImportParams(); |
| | | params.setNeedSave(true); |
| | | try { |
| | | List<EquipmentImportVo> list = ExcelImportUtil.importExcel(file.getInputStream(), EquipmentImportVo.class, params); |
| | | for(int i = 0;i<list.size();i++){ |
| | | EquipmentImportVo equipmentImportVo = list.get(i); |
| | | EquipmentCategory equipmentCategory = equipmentCategoryService.getOne(new QueryWrapper<EquipmentCategory>().eq("name",equipmentImportVo.getEquipmentCategoryName()),false); |
| | | if( |
| | | StringUtils.isBlank(equipmentImportVo.getNum()) |
| | | || StringUtils.isBlank(equipmentImportVo.getName()) |
| | | || StringUtils.isBlank(equipmentImportVo.getUseId()) |
| | | || StringUtils.isBlank(equipmentImportVo.getEquipmentUda1()) |
| | | || StringUtils.isBlank(equipmentImportVo.getManageId()) |
| | | || StringUtils.isBlank(equipmentImportVo.getTeamId()) |
| | | || StringUtils.isBlank(equipmentImportVo.getEquipmentImportanceId()) |
| | | || StringUtils.isBlank(equipmentImportVo.getEquipmentCategoryName()) |
| | | || StringUtils.isBlank(equipmentImportVo.getEquipmentStatus()) |
| | | || StringUtils.isBlank(equipmentImportVo.getEquipmentUda3()) |
| | | || StringUtils.isBlank(equipmentImportVo.getEquipmentUda5()) |
| | | || StringUtils.isBlank(equipmentImportVo.getEquipmentUda2()) |
| | | || StringUtils.isBlank(equipmentImportVo.getLeaveFactoryDate()) |
| | | || StringUtils.isBlank(equipmentImportVo.getProjectApprovalNo()) |
| | | || StringUtils.isBlank(equipmentImportVo.getFundSource()) |
| | | || StringUtils.isBlank(equipmentImportVo.getAcceptanceCheckDate()) |
| | | || StringUtils.isBlank(equipmentImportVo.getLeaveFactoryDate()) |
| | | || StringUtils.isBlank(equipmentImportVo.getFactoryNo()) |
| | | || StringUtils.isBlank(equipmentImportVo.getConstructorId()) |
| | | || StringUtils.isBlank(equipmentImportVo.getSourceCountry()) |
| | | || StringUtils.isBlank(equipmentImportVo.getModel()) |
| | | || StringUtils.isBlank(equipmentImportVo.getSpecification()) |
| | | || StringUtils.isBlank(equipmentImportVo.getGpo()) |
| | | ){ |
| | | exceptionInfo = exceptionInfo+"第"+(i+2)+"è¡å¯¼å
¥å¤±è´¥,åå :æ°æ®ææªå¡«é¡¹,请填åå¿
填项åå导å
¥;"; |
| | | exceptionNum++; |
| | | }else if(ObjectUtils.isNull(equipmentCategory)) |
| | | { |
| | | 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()) |
| | | .setKeyEquipmentIdentification(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()) |
| | | .setEquipmentUda2(equipmentImportVo.getEquipmentUda2()) |
| | | .setLastVerificationDate(equipmentImportVo.getLeaveFactoryDate()) |
| | | .setProjectApprovalNo(equipmentImportVo.getProjectApprovalNo()) |
| | | .setFundSource(equipmentImportVo.getFundSource()) |
| | | .setAcceptanceCheckDate(equipmentImportVo.getAcceptanceCheckDate()) |
| | | .setFactoryNo(equipmentImportVo.getFactoryNo()) |
| | | .setConstructorId(equipmentImportVo.getConstructorId()) |
| | | .setSourceCountry(equipmentImportVo.getSourceCountry()) |
| | | .setModel(equipmentImportVo.getModel()) |
| | | .setSpecification(equipmentImportVo.getSpecification()) |
| | | .setGpo(equipmentImportVo.getGpo()); |
| | | 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("æä»¶å¯¼å
¥å¤±è´¥ï¼"); |
| | | } |
| | | |
| | | |
| | | } |