From 1214b18558c19b09c02161b1dbbef342ad2c1e8f Mon Sep 17 00:00:00 2001 From: zss <zss@example.com> Date: 星期六, 12 十月 2024 17:14:46 +0800 Subject: [PATCH] 试验前后样品检查+开始结束时间 --- inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java | 325 +++++++++++++++++++++-------------------------------- 1 files changed, 131 insertions(+), 194 deletions(-) diff --git a/inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java b/inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java index 8b7e91f..e1d1bc2 100644 --- a/inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java +++ b/inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java @@ -1,5 +1,6 @@ package com.yuanchu.mom.service.impl; +import cn.hutool.core.lang.UUID; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.excel.EasyExcel; @@ -7,6 +8,7 @@ import com.alibaba.excel.write.metadata.WriteSheet; import com.alibaba.excel.write.style.column.SimpleColumnWidthStyleStrategy; import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; @@ -19,18 +21,24 @@ import com.yuanchu.mom.exception.ErrorException; import com.yuanchu.mom.mapper.*; import com.yuanchu.mom.pojo.*; +import com.yuanchu.mom.service.InsOrderPlanService; import com.yuanchu.mom.service.InsOrderService; import com.yuanchu.mom.service.InsProductService; import com.yuanchu.mom.utils.GiveCode; +import com.yuanchu.mom.utils.QYWXApi; import com.yuanchu.mom.utils.QueryWrappers; import com.yuanchu.mom.vo.SampleDefectsFatherVo; import lombok.AllArgsConstructor; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; +import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import org.springframework.web.multipart.MultipartFile; +import javax.annotation.Resource; import javax.servlet.http.HttpServletResponse; +import java.io.File; import java.io.IOException; import java.net.URLEncoder; import java.time.LocalDate; @@ -46,42 +54,47 @@ * @createDate 2024-03-12 16:17:55 */ @Service -@AllArgsConstructor @Transactional(rollbackFor = Exception.class) -public class InsOrderServiceImpl extends ServiceImpl<InsOrderMapper, InsOrder> - implements InsOrderService { +public class InsOrderServiceImpl extends ServiceImpl<InsOrderMapper, InsOrder> implements InsOrderService { + @Resource private GetLook getLook; - + @Resource private RoleMapper roleMapper; - + @Resource private InsOrderMapper insOrderMapper; + @Value("${file.path}") + private String imgUrl; + + @Value("${wordUrl}") + private String wordUrl; + @Resource + private InsOrderFileMapper insOrderFileMapper; + @Resource private InsSampleMapper insSampleMapper; + @Resource private WarehouseHistoryMapper warehouseHistoryMapper; - + @Resource private InsProductMapper insProductMapper; + @Resource private InsProductService insProductService; - + @Resource private InsProductUserMapper insProductUserMapper; - + @Resource private GiveCode giveCode; - + @Resource private InsSampleUserMapper insSampleUserMapper; - + @Resource private InsOrderStateMapper insOrderStateMapper; - + @Resource UserMapper userMapper; - + @Resource PowerMapper powerMapper; - - private InsBushingMapper insBushingMapper; - - private InsFibersMapper insFibersMapper; - - private InsFiberMapper insFiberMapper; - + @Resource CustomMapper customMapper; + @Resource + QYWXApi qywxApi; //鑾峰彇妫�楠屼笅鍗曟暟鎹� @@ -94,16 +107,6 @@ User user = userMapper.selectById(map1.get("userId"));//褰撳墠鐧诲綍鐨勪汉 Integer roleId = user.getRoleId(); String laboratory = null; - //鑾峰彇褰撳墠浜烘墍灞炲疄楠屽id - /*String departLimsId = user.getDepartLimsId(); - if (ObjectUtils.isNotEmpty(departLimsId) && !departLimsId.equals("")) { - String[] split = departLimsId.split(","); - //鏌ヨ瀵瑰簲鏋舵瀯鍚嶇О(閫氫俊瀹為獙瀹�,鐢靛姏瀹為獙瀹�,妫�娴嬪姙) - String departLims = baseMapper.seldepLimsId(Integer.parseInt(split[split.length - 1])); - if (departLims.contains("瀹為獙瀹�")) { - laboratory = departLims; - } - }*/ //鍒ゆ柇鏄惁鏄叏閮ㄦ潈闄� Power power = powerMapper.selectOne(Wrappers.<Power>lambdaQuery().eq(Power::getRoleId, roleId).eq(Power::getMenuMethod, "selectAllInsOrderParameter")); if (ObjectUtils.isEmpty(power)) { @@ -136,7 +139,7 @@ public int upInsOrder(Integer orderId, Integer sampleId, String appointed, Integer userId, String sonLaboratory) { InsOrder insOrder = new InsOrder(); insOrder.setId(orderId); - insOrder.setAppointed(LocalDate.parse(appointed)); + //insOrder.setAppointed(LocalDate.parse(appointed)); insOrder.setSendTime(LocalDateTime.now()); insOrderMapper.updateById(insOrder); //淇敼鎴愬彧缁欏綋鍓嶉�夋嫨鐨勮瘯楠屽涓嬪彂鍗曞瓙 @@ -160,7 +163,7 @@ @Override @Transactional(rollbackFor = Exception.class) - public int addInsOrder(List<SampleProductDto> list, InsOrder insOrder, List<List<Integer>> pairing) { + public int addInsOrder(List<SampleProductDto> list, InsOrder insOrder, List<List<Integer>> pairing, List<MultipartFile> files) { insOrder.setState(0); //鍒ゆ柇閫夋嫨鐨勫鎵樺崟浣嶄笌鍒跺崟浜虹殑濮旀墭鍗曚綅鏄惁涓�鑷� Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); @@ -182,13 +185,8 @@ insOrder.setCompanyId(one.getId()); code = one.getCode2(); } - //瀹為獙瀹ょ紪鍙� - String code2 = baseMapper.selLaboratoryCode(insOrder.getLaboratory()); - if (StringUtils.isEmpty(code2)) { - code2 = ""; - } //澶栭儴濮旀墭缂栧彿 - insOrder.setOutEntrustCode(giveCode.giveCode3("ZT/" + code2 + "-" + code + "-", insOrder.getCompanyId(), insOrder.getLaboratory(), "ins_order", "", "yyMM")); + insOrder.setOutEntrustCode(giveCode.giveCode("WT-", "ins_order", "-", "yyMMdd")); String giveCode = this.giveCode.giveCode("JCZX-" + code + "-", "ins_sample", "", "yyMMdd"); insOrderMapper.insert(insOrder); AtomicInteger count = new AtomicInteger(); @@ -198,12 +196,12 @@ a.setInsOrderId(insOrder.getId()); //鏍峰搧缂栧彿 if (StrUtil.isEmpty(a.getSampleCode())) { - a.setSampleCode("TX(WYQJ)-" + giveCode.split("-")[2] + "-" + count.get()); + a.setSampleCode("YP-" + a.getModel() + "-" + giveCode.split("-")[2] + "-" + count.get()); } insSampleMapper.insert(a); //鏍峰搧鐨勬楠岄」鐩� if (ObjectUtil.isNotEmpty(a.getInsProduct())) { - addInsProductMethod(a.getId(), a.getInsProduct(), null, 0); + addInsProductMethod(a.getId(), a.getInsProduct()); } //鏍峰搧鐨勬楠屾爣鍑� if (ObjectUtil.isNotEmpty(a.getInsulating())) { @@ -214,14 +212,14 @@ for (InsProduct product : ip2) { product.setStandardMethodListId(a.getInsulating().getStandardMethodListId()); } - addInsProductMethod(a.getId(), ip2, null, 0); + addInsProductMethod(a.getId(), ip2); } //鏍峰搧鐨勬楠屾爣鍑� if (ObjectUtil.isNotEmpty(a.getSheath())) { for (InsProduct product : a.getSheath().getInsProduct()) { product.setStandardMethodListId(a.getSheath().getStandardMethodListId()); } - addInsProductMethod(a.getId(), a.getSheath().getInsProduct(), null, 0); + addInsProductMethod(a.getId(), a.getSheath().getInsProduct()); } //瀛愭牱鍝侀厤缃� if (ObjectUtil.isNotEmpty(a.getChildSampleList())) { @@ -235,73 +233,60 @@ } insSampleMapper.insert(b); if (ObjectUtil.isNotEmpty(b.getInsProduct())) { - addInsProductMethod(b.getId(), b.getInsProduct(), null, 0); + addInsProductMethod(b.getId(), b.getInsProduct()); } } } } - //鍏夌氦閰嶇疆 - /*if (ObjectUtil.isEmpty(a.getInsProduct()) && ObjectUtil.isNotEmpty(a.getBushing())) { - for (BushingDto bushingDto : a.getBushing()) { - bushingDto.setInsSampleId(a.getId()); - insBushingMapper.insert(bushingDto); - if (bushingDto.getFiber().size() != 0) { - for (FiberDto fiberDto : bushingDto.getFiber()) { - fiberDto.setInsBushingId(bushingDto.getId()); - insFiberMapper.insert(fiberDto); - addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2); - } - } else { - for (FibersDto fibersDto : bushingDto.getFibers()) { - fibersDto.setInsBushingId(bushingDto.getId()); - fibersDto.setCode(this.giveCode.giveCode("", "ins_fibers", "", "yyMMdd")); - insFibersMapper.insert(fibersDto); - for (FiberDto fiberDto : fibersDto.getFiber()) { - fiberDto.setInsFibersId(fibersDto.getId()); - insFiberMapper.insert(fiberDto); - addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2); - } - addInsProductMethod(a.getId(), fibersDto.getProductList(), fibersDto.getId(), 1); - } - } - } - }*/ + }); - //澶氫釜鏍峰搧灏辨嫾鎺� - /*for (List<Integer> i : pairing) { - SampleProductDto sample = JSON.parseObject(JSON.toJSONString(list.get(i.get(0) - 1)), SampleProductDto.class); - sample.setSampleCode(list.get(i.get(0) - 1).getSampleCode() + "/" + list.get(i.get(1) - 1).getSampleCode()); - sample.setId(null); - insSampleMapper.insert(sample); - try { - List<InsProduct> insProducts = sample.getInsProduct().stream().filter(a -> Objects.equals(a.getInspectionItem(), "鍏夌氦鎺ュご鎹熻��")).collect(Collectors.toList()); - for (InsProduct insProduct : insProducts) { - insProduct.setId(null); - insProduct.setInsSampleId(sample.getId()); - insProductMapper.insert(insProduct); - } - } catch (Exception e) { - } - }*/ //閫氫俊:濡傛灉鏄疌绫昏鍗曟棤闇�瀹℃牳鐩存帴閫氳繃 if (insOrder.getOrderType().equals("C")) { insOrder.setState(1); upInsOrderOfState(insOrder); } + //濡傛灉鏈変笂浼犵殑闄勪欢 + if (CollectionUtils.isNotEmpty(files)) { + for (MultipartFile file : files ) { + String urlString; + String pathName; + String path; + String filename = file.getOriginalFilename(); + String contentType = file.getContentType(); + InsOrderFile insOrderFile = new InsOrderFile(); + insOrderFile.setInsOrderId(insOrder.getId()); + insOrderFile.setFileName(filename); + if (contentType != null && contentType.startsWith("image/")) { + // 鏄浘鐗� + path = imgUrl; + insOrderFile.setType(1); + } else { + // 鏄枃浠� + path = wordUrl; + insOrderFile.setType(2); + } + try { + File realpath = new File(path); + if (!realpath.exists()) { + realpath.mkdirs(); + } + pathName = UUID.randomUUID() + "_" + file.getOriginalFilename(); + urlString = realpath + "/" + pathName; + file.transferTo(new File(urlString)); + insOrderFile.setFileUrl(pathName); + insOrderFileMapper.insert(insOrderFile); + } catch (Exception e) { + e.printStackTrace(); + System.err.println("闄勪欢涓婁紶閿欒"); + } + } + } return insOrder.getId(); } - private void addInsProductMethod(Integer sampleId, List<InsProduct> productList, Integer id, Integer type) { + private void addInsProductMethod(Integer sampleId, List<InsProduct> productList) { for (InsProduct product : productList) { - if (product.getState() == 1 ) { - switch (type) { - case 1: - product.setInsFibersId(id); - break; - case 2: - product.setInsFiberId(id); - break; - } + if (product.getState() == 1) { product.setId(null); product.setCreateTime(null); product.setCreateUser(null); @@ -316,73 +301,12 @@ } } - //娓╁害寰幆鐨勫鐞� - private void dealWithTemperatureLoop(Integer type, Integer id, Integer sampleId, InsProduct product) { - List<InsProduct> insProductes = new ArrayList<>(); - List<InsProduct> insProducts = new ArrayList<>(); - String[] strings = product.getAsk().split(";"); - for (int i = 0; i < strings.length; i++) { - int count = Integer.parseInt(strings[strings.length - 1]); - if (i != strings.length - 1) { - InsProduct insProduct = new InsProduct(); - switch (type) { - case 1: - insProduct.setInsFibersId(id); - break; - case 2: - insProduct.setInsFiberId(id); - break; - } - String[] split = strings[i].split(","); - if (split[0].equals("20鈩�")) { - insProduct.setInspectionItem(count + "");//妫�楠岄」--寰幆娆℃暟 - } else { - insProduct.setInspectionItem("1");//妫�楠岄」--寰幆娆℃暟 - } - insProduct.setInspectionItemSubclass(split[0]);//妫�楠岄」--娓╁害 - insProduct.setInspectionItemClass(split[1]);//妫�楠岄」--鍏夌氦椤圭洰 - insProduct.setAsk(split[2]);//妫�楠岃姹� - insProduct.setTell(strings[i]);//妫�楠屾弿杩� - insProduct.setInsSampleId(sampleId); - insProduct.setState(1); - insProduct.setFactory(product.getFactory()); - insProduct.setLaboratory(product.getLaboratory()); - insProduct.setSampleType(product.getSampleType()); - insProduct.setSample(product.getSample()); - insProduct.setModel(product.getModel()); - insProduct.setSonLaboratory(product.getSonLaboratory()); - insProduct.setUnit(product.getUnit()); - insProduct.setManHourGroup(product.getManHourGroup()); - insProduct.setInspectionItemType("0"); - insProduct.setInspectionValueType("1"); - insProducts.add(insProduct); - insProductes.add(insProduct); - } else { - //鏈�鍚庝竴涓暟鎹槸璇存槑浼氬惊鐜灏戞 - if (count > 1) { - //寰幆瓒呰繃1娆� - for (int j = 2; j <= count; j++) { - for (InsProduct insProduct : insProducts) { - if (!insProduct.getInspectionItemSubclass().equals("20鈩�") && !insProduct.getInspectionItemSubclass().equals("20鈩�(甯告俯)")) { - InsProduct insProduct1 = new InsProduct(); - BeanUtils.copyProperties(insProduct, insProduct1); - insProduct1.setInspectionItem(j + ""); - insProductes.add(insProduct1); - } - } - } - } - } - } - insProductService.saveBatch(insProductes); - } - @Override public Map<String, Object> getInsOrder(Integer id) { Map<String, Object> map = new HashMap<>(); InsOrder insOrder = insOrderMapper.selectById(id); List<SampleProductDto> list = insSampleMapper.selectSampleProductListByOrderId2(id); - if (list.size()==0){ + if (list.size() == 0) { list = insSampleMapper.selectSampleProductListByOrder2Id2(id); } map.put("insOrder", insOrder); @@ -397,39 +321,28 @@ insOrder.setExamineTime(LocalDateTime.now()); if (insOrder.getState() == 1) { //瀹℃牳閫氳繃鎵嶄細鐢熸垚濮旀墭缂栧彿 - Custom custom = customMapper.selectById(order.getCompanyId()); - System.out.println("=============" + custom.getCompany()); - System.out.println("-------------" + order.getCompany()); - insOrder.setEntrustCode(giveCode.giveCode2("TXJC-", insOrder.getCompanyId(), insOrder.getLaboratory(), "ins_order", "", "yyMMdd")); - //绯荤粺鏌ヨ绔欑偣浠诲姟鍒嗗竷鎯呭喌,灏嗘楠屼换鍔′笅鍙戣嚦鏈�灏戠殑绔欏彴 - List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery() - .eq(InsSample::getInsOrderId, insOrder.getId()).select(InsSample::getId)); - List<Integer> ids = insSamples.stream().map(a -> a.getId()).collect(Collectors.toList()); - List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery() - .eq(InsProduct::getState, 1) - .in(InsProduct::getInsSampleId, ids)); - List<String> collect = insProducts.stream().map(InsProduct::getSonLaboratory).distinct().collect(Collectors.toList()); - //瑕佸垽鏂墿浣欒瘯楠屽涓摢涓渶绌洪棽灏卞畨鎺掔粰鍝釜 - Map<String, Long> dataCounts = new HashMap<>(); - for (String sonLaboratory : collect) { - Long count = insOrderStateMapper.selectCount(Wrappers.<InsOrderState>lambdaQuery() - .eq(InsOrderState::getLaboratory, sonLaboratory) - .ne(InsOrderState::getInsState, 4) - .ne(InsOrderState::getInsState, 5) - .ne(InsOrderState::getInsState, 6)); - dataCounts.put(sonLaboratory, count); + insOrder.setEntrustCode(giveCode.giveCode2("WT-", "ins_order", "-", "yyMMdd")); + //纭畾璁㈠崟鐨勪笅鍙戞椂闂村拰绾﹀畾鏃堕棿 + //int day = insProductService.selectOrderManDay(insOrder.getId());//棰勮瀹屾垚鏃堕棿 + //insOrder.setAppointed(LocalDate.parse(LocalDateTime.now().plusHours(day).format(DateTimeFormatter.ofPattern("yyyy-MM-dd")))); + insOrder.setSendTime(LocalDateTime.now()); + /*todo 鏍规嵁璁㈠崟绫诲瀷鍒ゆ柇鏄惁闇�瑕佹帹閫佷紒涓氬井淇� @zss*/ + if (!order.getFormType().equals("鍏朵粬鎴愬搧")) { + /* HashMap<String, Object> map = new HashMap<>(); + String account = userMapper.selectById(order.getIssueUser()).getAccount(); + map.put("touser", account);//鎺ユ敹娑堟伅鎴愬憳鐨勮处鍙�'ZT-031292'杩欑绫诲瀷(濡傛灉鏈夊涓敤'|'鍒嗛殧) + map.put("toparty", "");//鎺ユ敹閮ㄩ棬id + map.put("totag", "");//娑堟伅鏍囩id + map.put("msgtype", "text");//娑堟伅绫诲瀷 text:鏂囨湰 + map.put("agentid", 1000513);//搴旂敤id + HashMap<String, Object> hashMap = new HashMap<>(); + hashMap.put("content", "鎮ㄦ湁涓�鏉¤鍗曢渶鐢熸垚妫�楠�,璇峰墠寰�LIMS绯荤粺鏌ョ湅銆�<a href=\"http://10.1.13.77/enter\"> </a>"); + map.put("text", JSONArray.toJSONString(hashMap));//娑堟伅鍐呭 + map.put("safe", 0);//鏄惁淇濆瘑娑堟伅.0鍚� + map.put("enable_id_trans", 0);//鏄惁寮�鍚痠d杞瘧.0鍚� + map.put("enable_duplicate_check", 0);//鏄惁寮�鍚噸澶嶆秷鎭鏌�.0鍚� + qywxApi.send(map);*/ } - // 鏌ユ壘鏁版嵁閲忔渶灏戠殑鍏冪礌 - String minElement = null; - Long minCount = Long.MAX_VALUE; - for (Map.Entry<String, Long> entry : dataCounts.entrySet()) { - if (entry.getValue() < minCount) { - minCount = entry.getValue(); - minElement = entry.getKey(); - } - } - int day = insProductService.selectOrderManDay(insOrder.getId());//棰勮瀹屾垚鏃堕棿 - upInsOrder(insOrder.getId(), null, LocalDateTime.now().plusHours(day).format(DateTimeFormatter.ofPattern("yyyy-MM-dd")), null, minElement); } return insOrderMapper.updateById(insOrder); } @@ -487,8 +400,8 @@ Map<String, Object> map = new HashMap<>(); InsOrder insOrder = insOrderMapper.selectById2(id); List<SampleProductDto> list = insSampleMapper.getInsOrderAndSample(id, laboratory); - if (list.size()==0){ - list=insSampleMapper.getInsOrderAndSample2(id, laboratory); + if (list.size() == 0) { + list = insSampleMapper.getInsOrderAndSample2(id, laboratory); } for (SampleProductDto sampleProductDto : list) { List<Integer> ids = sampleProductDto.getInsProduct().stream().map(InsProduct::getId).collect(Collectors.toList()); @@ -591,11 +504,7 @@ List<Integer> list = Arrays.stream(ids.split(",")).map(Integer::parseInt).collect(Collectors.toList()); List<SampleProductDto3> sampleProductDtos = insSampleMapper.selectSampleProductListByOrderId3(list); Set<String> processedCodes = new HashSet<>(); - //濡傛灉鏄厜绾ゆ垨鑰呮槸鍏夌氦甯﹂粯璁ゅ彧鎵撳嵃绗竴涓� List<SampleProductDto3> sampleProductDto3s = sampleProductDtos.stream().filter(sampleProductDto3 -> { - if (!"鍏夌氦".equals(sampleProductDto3.getIoSampleType()) && !"鍏夌氦甯�".equals(sampleProductDto3.getIoSampleType())) { - return true; - } if (processedCodes.contains(sampleProductDto3.getCode())) { return false; } else { @@ -604,6 +513,26 @@ } }).collect(Collectors.toList()); return sampleProductDto3s; + } + + //鏍¢獙鐢垫満缂栧彿 + @Override + public Map<String, List<InsSample>> checkNumber(String ids) { + List<InsSample> samples = new ArrayList<>(); + List<Integer> list = Arrays.stream(ids.split(",")).map(Integer::parseInt).collect(Collectors.toList()); + List<InsSample> sampleDtos = insSampleMapper.selectInsSample(list); + //鍒ゆ柇鏍峰搧鍨嬪彿鏄惁鏄疊Z + for (InsSample sampleDto : sampleDtos) { + if (sampleDto.getModel().contains("BZ")) { + if (ObjectUtils.isEmpty(sampleDto.getMotorNumber())) { + samples.add(sampleDto); + } + } + } + if (CollectionUtils.isNotEmpty(samples)) { + Map<String, List<InsSample>> collect = samples.stream().collect(Collectors.groupingBy(InsSample::getEntrustCode)); + return collect; + } else return null; } @Override @@ -656,6 +585,14 @@ throw new RuntimeException("瀵煎嚭澶辫触"); } } + + @Override + public int addNumber(List<InsSample> insSamples) { + for (InsSample insSample : insSamples) { + insSampleMapper.updateById(insSample); + } + return 0; + } } -- Gitblit v1.9.3