From 5a697e6fafbe3855336ca5fd7e1785de12840d16 Mon Sep 17 00:00:00 2001 From: lxp <1928192722@qq.com> Date: 星期六, 15 三月 2025 10:49:27 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev --- inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java | 96 +++++++++++++++++++----------------------------- 1 files changed, 38 insertions(+), 58 deletions(-) diff --git a/cnas-require/src/main/java/com/ruoyi/require/service/impl/InsOrderPlanServiceImpl.java b/inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java similarity index 97% rename from cnas-require/src/main/java/com/ruoyi/require/service/impl/InsOrderPlanServiceImpl.java rename to inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java index e75d5fa..133dc4c 100644 --- a/cnas-require/src/main/java/com/ruoyi/require/service/impl/InsOrderPlanServiceImpl.java +++ b/inspect-server/src/main/java/com/ruoyi/inspect/service/impl/InsOrderPlanServiceImpl.java @@ -1,4 +1,4 @@ -package com.ruoyi.require.service.impl; +package com.ruoyi.inspect.service.impl; import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.lang.UUID; @@ -37,37 +37,32 @@ import com.ruoyi.basic.mapper.StandardProductListMapper; import com.ruoyi.basic.service.StandardTemplateService; import com.ruoyi.basic.vo.StandardProductVO; -import com.ruoyi.common.constant.ExchangeConstants; -import com.ruoyi.common.constant.RouterKeyConstants; import com.ruoyi.common.core.domain.entity.Custom; import com.ruoyi.common.core.domain.entity.SysDictData; import com.ruoyi.common.core.domain.entity.User; -import com.ruoyi.common.utils.DictUtils; import com.ruoyi.common.utils.JackSonUtil; import com.ruoyi.common.utils.QueryWrappers; import com.ruoyi.common.utils.SecurityUtils; import com.ruoyi.framework.exception.ErrorException; import com.ruoyi.framework.util.MatrixToImageWriter; import com.ruoyi.framework.util.RedisUtil; +import com.ruoyi.framework.util.SheetWriteHandlerUtil; +import com.ruoyi.inspect.amqp.constants.ExchangeConstants; +import com.ruoyi.inspect.amqp.constants.RouterKeyConstants; import com.ruoyi.inspect.dto.*; +import com.ruoyi.inspect.handler.*; import com.ruoyi.inspect.mapper.*; import com.ruoyi.inspect.pojo.*; import com.ruoyi.inspect.service.InsBushingService; +import com.ruoyi.inspect.service.InsOrderPlanService; import com.ruoyi.inspect.service.InsOrderService; import com.ruoyi.inspect.service.InsUnPassService; -import com.ruoyi.inspect.service.impl.InsOrderServiceImpl; -import com.ruoyi.framework.util.SheetWriteHandlerUtil; -import com.ruoyi.inspect.service.impl.InsReportServiceImpl; import com.ruoyi.inspect.vo.*; -import com.ruoyi.performance.mapper.AuxiliaryOutputWorkingHoursMapper; -import com.ruoyi.performance.mapper.PerformanceShiftMapper; -import com.ruoyi.performance.mapper.ShiftTimeMapper; -import com.ruoyi.require.handler.*; -import com.ruoyi.require.pojo.InformationNotification; -import com.ruoyi.require.service.InformationNotificationService; -import com.ruoyi.require.service.InsOrderPlanService; +import com.ruoyi.notice.pojo.InformationNotification; +import com.ruoyi.notice.service.InformationNotificationService; import com.ruoyi.system.mapper.CustomMapper; import com.ruoyi.system.mapper.UserMapper; +import com.ruoyi.system.service.ISysDictTypeService; import lombok.extern.slf4j.Slf4j; import org.apache.commons.io.IOUtils; import org.apache.commons.lang3.StringUtils; @@ -126,6 +121,7 @@ private InsSampleMapper insSampleMapper; @Resource private InsSampleUserMapper insSampleUserMapper; + @Resource private InsOrderMapper insOrderMapper; @Resource @@ -140,10 +136,6 @@ private InsOrderStateMapper insOrderStateMapper; @Resource private InsProductMapper insProductMapper; - @Resource - private ShiftTimeMapper shiftTimeMapper; - @Resource - private PerformanceShiftMapper performanceShiftMapper; @Resource private StandardProductListMapper standardProductListMapper; @@ -167,7 +159,7 @@ private InsUnPassService insUnPassService; @Resource - AuxiliaryOutputWorkingHoursMapper auxiliaryOutputWorkingHoursMapper; + private ISysDictTypeService dictTypeService; @Resource private InformationNotificationService informationNotificationService; @@ -202,24 +194,18 @@ @Autowired private RabbitTemplate rabbitTemplate; - - private ReentrantLock lock = new ReentrantLock(); - @Resource - private ThreadPoolTaskExecutor threadPoolTaskExecutor; - @Override - public void exportInsOrderPlanResult(Map<String, Object> data, HttpServletResponse response) { + public void exportInsOrderPlanResult(QueryResultDTO data, HttpServletResponse response) { List<Map<String,Object>> dataList = new ArrayList<>(); ObjectMapper objectMapper = new ObjectMapper(); try { - Object o = getTabHeader(data.get("sonLaboratory").toString(), data.get("samples").toString()).get("tableHeader");// 鑾峰彇鍔ㄦ�佽〃澶� + Object o = getTabHeader(data.getSonLaboratory(), data.getSampleType()).get("tableHeader");// 鑾峰彇鍔ㄦ�佽〃澶� List<Map<String, Object>> tableHeader = objectMapper.readValue(JSONUtil.toJsonStr(o), new TypeReference<List<Map<String, Object>>>() { - });// 琛ㄥご鏁版嵁 - Map<String, Object> table = objectMapper.readValue(JSONUtil.toJsonStr(data.get("trendsTable")), new TypeReference<Map<String, Object>>() { }); - List<Map<String, Object>> trendsTable = getInsOrderPlanList(table); // 琛ㄦ牸鏁版嵁 + // 琛ㄥご鏁版嵁 + List<Map<String, Object>> trendsTable = getInsOrderPlanList(data); // 琛ㄦ牸鏁版嵁 for (Map<String, Object> trend : trendsTable) { Map<String, Object> addMap = new HashMap<>(); addMap.put("濮旀墭鍗曞彿", trend.get("entrustCode")); @@ -250,7 +236,7 @@ ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream()) .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) - .registerWriteHandler(new SheetWriteHandlerUtil(data.get("samples").toString(),head.size())) + .registerWriteHandler(new SheetWriteHandlerUtil(data.getSampleType(),head.size())) .useDefaultStyle(true).relativeHeadRowIndex(1) .registerWriteHandler(horizontalCellStyleStrategy) .build(); @@ -346,29 +332,28 @@ return headWriteCellStyle; } @Override - public List<Map<String, Object>> getInsOrderPlanList(Map<String,Object> data) { - String sampleType = data.get("sampleType").toString(); - String sonLaboratory = data.get("sonLaboratory").toString(); - String entrustCode = data.get("entrustCode").toString(); + public List<Map<String, Object>> getInsOrderPlanList(QueryResultDTO data) { + String sampleType = data.getSampleType(); + String sonLaboratory = data.getSonLaboratory(); + String entrustCode = data.getEntrustCode(); Integer createUser = null; String name = ""; - if(StringUtils.isNotBlank(data.get("createUser").toString())) { - createUser = Integer.parseInt(data.get("createUser").toString()); + if(StringUtils.isNotBlank(data.getCreateUser())) { + createUser = Integer.parseInt(data.getCreateUser()); name = userMapper.selectById(createUser).getName(); } - String sampleCode = data.get("sampleCode").toString(); + String sampleCode = data.getSampleCode(); String startTime = ""; String endTime = ""; List<Map<String, Object>> maps = new ArrayList<>(); ObjectMapper objectMapper = new ObjectMapper(); try { - if(StringUtils.isNotBlank(data.get("insTime").toString()) && !Objects.isNull(data.get("insTime"))) { - List insTime = objectMapper.readValue(JSONUtil.toJsonStr(data.get("insTime")), List.class); - startTime = insTime.get(0).toString(); - endTime = insTime.get(1).toString(); + if(CollectionUtils.isNotEmpty(data.getInsTime())) { + startTime = data.getInsTime().get(0); + endTime = data.getInsTime().get(1); } // 琛ㄥご淇℃伅 - List<Map<String, Object>> headerS = objectMapper.readValue(JSONUtil.toJsonStr(data.get("headerS")), new TypeReference<List<Map<String, Object>>>() { + List<Map<String, Object>> headerS = objectMapper.readValue(JSONUtil.toJsonStr(data.getHeaderS()), new TypeReference<List<Map<String, Object>>>() { }); // 鍒ゆ柇鏄惁鏄俯搴﹀惊鐜� if(sampleType.equals("娓╁害寰幆")) { @@ -446,8 +431,7 @@ */ private String getCurrentUserLaboratory(){ // 鑾峰彇褰撳墠浜烘墍鍦ㄥ疄楠屽 - Integer userId = SecurityUtils.getUserId().intValue(); - String departLimsId = userMapper.selectById(userId).getDepartLimsId(); + String departLimsId = userMapper.selectById(SecurityUtils.getUserId()).getDepartLimsId(); String laboratory = ""; if(StringUtils.isNotBlank(departLimsId)) { String[] split = departLimsId.split(","); @@ -619,7 +603,7 @@ } } - if (samples.contains("娓╁害寰幆")){ + if (Objects.nonNull(samples)&&samples.contains("娓╁害寰幆")){ addElementToMaps(maps, "寰幆娆℃暟", "inspectionItems"); addElementToMaps(maps, "娓╁害鐐�", "inspectionItemSubclass"); addElementToMaps(maps, "琛板噺绯绘暟1310", "attenuationCoefficient1310"); @@ -663,6 +647,7 @@ @Override public IPage<InsOrderPlanVO> selectInsOrderPlanList(Page page, InsOrderPlanDTO insOrderPlanDTO) { User user = userMapper.selectById(SecurityUtils.getUserId());//褰撳墠鐧诲綍鐨勪汉 + //鑾峰彇褰撳墠浜烘墍灞炲疄楠屽id String departLimsId = user.getDepartLimsId(); String laboratory = null; @@ -685,8 +670,7 @@ } insOrderPlanDTO.setUserId(null); } - InsOrderPlanDTO planDTO = new InsOrderPlanDTO(); - QueryWrapper<InsOrderPlanDTO> wrappers = QueryWrappers.queryWrappers(planDTO); + QueryWrapper<InsOrderPlanDTO> wrappers = QueryWrappers.queryWrappers(new InsOrderPlanDTO()); IPage<InsOrderPlanVO> insOrderPage = insSampleMapper.findInsSampleAndOrder( page, userName, @@ -705,8 +689,7 @@ @Override public IPage<InsOrderPlanTaskSwitchVo> inspectionOrderDetailsTaskSwitching(Page page, InsOrderPlanDTO insOrderPlanDTO) { - Integer userId = SecurityUtils.getUserId().intValue(); - User user = userMapper.selectById(userId);//褰撳墠鐧诲綍鐨勪汉 + User user = userMapper.selectById(SecurityUtils.getUserId());//褰撳墠鐧诲綍鐨勪汉 //鑾峰彇褰撳墠浜烘墍灞炲疄楠屽id String departLimsId = user.getDepartLimsId(); @@ -720,11 +703,10 @@ } } if (ObjectUtil.isNotEmpty(insOrderPlanDTO.getUserId())) { - insOrderPlanDTO.setUserId(userId.longValue()); + insOrderPlanDTO.setUserId(Long.valueOf(user.getId())); } String sonLaboratory = insOrderPlanDTO.getSonLaboratory();//璇曢獙瀹� - IPage<InsOrderPlanTaskSwitchVo> insOrderPage = insSampleMapper.inspectionOrderDetailsTaskSwitching(page, QueryWrappers.queryWrappers(insOrderPlanDTO), userId, sonLaboratory, laboratory); - return insOrderPage; + return insSampleMapper.inspectionOrderDetailsTaskSwitching(page, QueryWrappers.queryWrappers(insOrderPlanDTO), user.getId(), sonLaboratory, laboratory); } //璁ら浠诲姟 @@ -740,8 +722,6 @@ @Override public Map<String, Object> doInsOrder(Integer id, String laboratory) { -// InsOrder insOrder = new InsOrder(); -// insOrder.setId(id); InsOrder order = insOrderMapper.selectById(id); InsOrderState insOrderState = insOrderStateMapper.selectOne(new LambdaQueryWrapper<InsOrderState>() @@ -859,8 +839,7 @@ public IPage<InsOrderFile> getFileList(Page page, InsOrderFile insOrderFile) { Integer insOrderId = insOrderFile.getInsOrderId(); insOrderFile.setInsOrderId(null); - IPage<InsOrderFile> insOrderFileIPage = insOrderFileMapper.getFileList(page, QueryWrappers.queryWrappers(insOrderFile),insOrderId); - return insOrderFileIPage; + return insOrderFileMapper.getFileList(page, QueryWrappers.queryWrappers(insOrderFile),insOrderId); } @Override @@ -2088,9 +2067,10 @@ .and(i->i.isNull(InsProduct::getInspectionItemClass).or().eq(InsProduct::getInspectionItemClass,"")) );//鐢ㄦ楠屽垎椤瑰瓧娈靛尯鍒厜绾ら厤缃笌娓╁害寰幆 //鏌ヨ鍏ㄨ壊璋憋紝杩囨护鑹叉爣骞舵帓搴� - List<String> colorList = DictUtils.getDictCache("鑹叉爣").stream() + + List<String> colorList = dictTypeService.selectDictDataByType("fiber_color_type").stream() .sorted(Comparator.comparing(SysDictData::getDictSort)) - .map(SysDictData::getDictValue) + .map(SysDictData::getDictLabel) .collect(Collectors.toList()); //鏉惧绠¢檮浠跺鐞� long piperCount = insProducts.stream().filter(f->!Objects.isNull(f.getInsBushId())).count(); -- Gitblit v1.9.3