From 7bae2c55ff2d9c94d30df77ad2dfbc66bb703209 Mon Sep 17 00:00:00 2001 From: zss <zss@example.com> Date: 星期五, 06 九月 2024 17:40:33 +0800 Subject: [PATCH] 电路试验 --- inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java | 558 ++++++++++++++++++++++++++++++++++--------------------- 1 files changed, 345 insertions(+), 213 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 830f53e..bafa574 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 @@ -2,8 +2,13 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; +import com.alibaba.excel.EasyExcel; +import com.alibaba.excel.ExcelWriter; +import com.alibaba.excel.write.metadata.WriteSheet; +import com.alibaba.excel.write.style.column.SimpleColumnWidthStyleStrategy; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; @@ -25,14 +30,14 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import javax.servlet.http.HttpServletResponse; +import java.io.IOException; +import java.net.URLEncoder; import java.time.LocalDate; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; import java.util.*; -import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicInteger; -import java.util.function.Function; -import java.util.function.Predicate; import java.util.stream.Collectors; /** @@ -42,17 +47,23 @@ */ @Service @AllArgsConstructor +@Transactional(rollbackFor = Exception.class) public class InsOrderServiceImpl extends ServiceImpl<InsOrderMapper, InsOrder> implements InsOrderService { private GetLook getLook; + private RoleMapper roleMapper; + private InsOrderMapper insOrderMapper; private InsSampleMapper insSampleMapper; + private WarehouseHistoryMapper warehouseHistoryMapper; private InsProductMapper insProductMapper; private InsProductService insProductService; + + private InsProductUserMapper insProductUserMapper; private GiveCode giveCode; @@ -82,19 +93,19 @@ Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("selectInsOrderParameter"); User user = userMapper.selectById(map1.get("userId"));//褰撳墠鐧诲綍鐨勪汉 Integer roleId = user.getRoleId(); + String laboratory = null; //鑾峰彇褰撳墠浜烘墍灞炲疄楠屽id - String departLimsId = user.getDepartLimsId(); - String laboratory=null; - if (ObjectUtils.isNotEmpty(departLimsId) && !departLimsId.equals("")){ + /*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; + //鏌ヨ瀵瑰簲鏋舵瀯鍚嶇О(閫氫俊瀹為獙瀹�,鐢靛姏瀹為獙瀹�,妫�娴嬪姙) + 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, "selectAllInsOrder")); + Power power = powerMapper.selectOne(Wrappers.<Power>lambdaQuery().eq(Power::getRoleId, roleId).eq(Power::getMenuMethod, "selectAllInsOrderParameter")); if (ObjectUtils.isEmpty(power)) { if (map1.get("look") == 1) { //涓汉 @@ -108,37 +119,39 @@ } } } - map.put("body", insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto),laboratory)); + IPage<SampleOrderDto> sampleOrderDtoIPage = insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto), laboratory); + sampleOrderDtoIPage.getRecords().forEach(i -> { + if (ObjectUtils.isNotEmpty(i.getSampleCode()) && i.getSampleCode().contains("锛�")) { + String[] split = i.getSampleCode().split("锛�"); + i.setSampleCode(split[0]); + } + }); + map.put("body", sampleOrderDtoIPage); return map; } + //鍒嗛厤绔欑偣 @Override @Transactional(rollbackFor = Exception.class) - public int upInsOrder(Integer orderId, Integer sampleId, String appointed, Integer userId) { + 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.setSendTime(LocalDateTime.now()); insOrderMapper.updateById(insOrder); - List<InsSample> insSamples = insSampleMapper.selectList(Wrappers.<InsSample>lambdaQuery().eq(InsSample::getInsOrderId, orderId).select(InsSample::getId)); - List<Integer> ids = insSamples.stream().map(a -> a.getId()).collect(Collectors.toList()); - List<InsProduct> insProducts = insProductMapper.selectList(Wrappers.<InsProduct>lambdaQuery().in(InsProduct::getInsSampleId, ids).eq(InsProduct::getState, 1).isNull(InsProduct::getInsFibersId).isNull(InsProduct::getInsFiberId).select(InsProduct::getSonLaboratory).groupBy(InsProduct::getSonLaboratory)); - for (InsProduct insProduct : insProducts) { - InsOrderState insOrderState = new InsOrderState(); - insOrderState.setInsOrderId(orderId); - try { - insOrderState.setLaboratory(insProduct.getSonLaboratory()); - } catch (NullPointerException e) { - throw new ErrorException("璇ユ楠屽崟鏈夋湭缁存姢瀹為獙瀹ょ殑妫�楠岄」鐩�"); - } - insOrderState.setInsState(0); - insOrderStateMapper.insert(insOrderState); - } + //淇敼鎴愬彧缁欏綋鍓嶉�夋嫨鐨勮瘯楠屽涓嬪彂鍗曞瓙 + InsOrderState insOrderState = new InsOrderState(); + insOrderState.setInsOrderId(orderId); + insOrderState.setLaboratory(sonLaboratory); + insOrderState.setInsState(0); + insOrderStateMapper.insert(insOrderState); + //杩欓噷鏄湪缁欏垎閰嶇殑鎸囧畾鐨勪汉鍜岃瘯楠屽涓嬪彂妫�楠屼汉 if (userId != null) { InsSampleUser insSampleUser = new InsSampleUser(); insSampleUser.setState(0); insSampleUser.setUserId(userId); insSampleUser.setInsSampleId(orderId); + insSampleUser.setSonLaboratory(sonLaboratory); insSampleUserMapper.insert(insSampleUser); } return 1; @@ -148,50 +161,50 @@ @Transactional(rollbackFor = Exception.class) public int addInsOrder(List<SampleProductDto> list, InsOrder insOrder, List<List<Integer>> pairing) { insOrder.setState(0); - String code = customMapper.selectById(insOrder.getCompanyId()).getCode2(); - //insOrder.setEntrustCode(giveCode.giveCode("JCZX-" + code + "-", "ins_order", "", "yyMMdd")); - String giveCode = this.giveCode.giveCode("JCZX-" + code + "-", "ins_order", "", "yyMMdd"); + //鍒ゆ柇閫夋嫨鐨勫鎵樺崟浣嶄笌鍒跺崟浜虹殑濮旀墭鍗曚綅鏄惁涓�鑷� + Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); + String company = userMapper.selectById(userId).getCompany(); + if (!company.equals(insOrder.getCompanyId() + "")) { + //濡傛灉涓嶄竴鑷撮偅涔堝鎵樹汉瀛楁蹇呭~ + if (ObjectUtils.isEmpty(insOrder.getPrepareUser())) { + throw new ErrorException("濮旀墭浜轰笉鑳戒负绌�"); + } + } else { + //濡傛灉涓�鑷�,閭d箞鍒跺崟浜哄氨鏄鎵樹汉 + insOrder.setPrepareUser(insOrder.getCustom()); + } + //瀹㈡埛浠e彿 + Custom custom = customMapper.selectById(insOrder.getCompanyId()); + String code = custom.getCode2(); + if (!custom.getCompany().equals(insOrder.getCompany())) { + Custom one = customMapper.selectOne(Wrappers.<Custom>lambdaQuery().eq(Custom::getCompany, insOrder.getCompany())); + 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")); + String giveCode = this.giveCode.giveCode("JCZX-" + code + "-", "ins_sample", "", "yyMMdd"); insOrderMapper.insert(insOrder); AtomicInteger count = new AtomicInteger(); list.forEach(a -> { count.getAndIncrement(); a.setId(null); a.setInsOrderId(insOrder.getId()); + //鏍峰搧缂栧彿 if (StrUtil.isEmpty(a.getSampleCode())) { - a.setSampleCode(giveCode.split("-")[2] + "-" + count.get()); + a.setSampleCode("TX(WYQJ)-" + giveCode.split("-")[2] + "-" + count.get()); } insSampleMapper.insert(a); + //鏍峰搧鐨勬楠岄」鐩� if (ObjectUtil.isNotEmpty(a.getInsProduct())) { - addInsProductMethod(a.getId(), a.getInsProduct(), null, 0, false); - if (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(), a.getInsProduct(), fiberDto.getId(), 2, true); - addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2, false); - } - } 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(), a.getInsProduct(), fiberDto.getId(), 2, true); - addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2, false); - } - //addInsProductMethod(a.getId(), a.getInsProduct(), fibersDto.getId(), 1); - addInsProductMethod(a.getId(), fibersDto.getProductList(), fibersDto.getId(), 1, false); - } - } - } - } + addInsProductMethod(a.getId(), a.getInsProduct(), null, 0); } + //鏍峰搧鐨勬楠屾爣鍑� if (ObjectUtil.isNotEmpty(a.getInsulating())) { List<InsProduct> ip2 = new ArrayList<>(); for (Integer i = 0; i < a.getInsulating().getNum(); i++) { @@ -200,14 +213,16 @@ for (InsProduct product : ip2) { product.setStandardMethodListId(a.getInsulating().getStandardMethodListId()); } - addInsProductMethod(a.getId(), ip2, null, 0, false); + addInsProductMethod(a.getId(), ip2, null, 0); } + //鏍峰搧鐨勬楠屾爣鍑� if (ObjectUtil.isNotEmpty(a.getSheath())) { for (InsProduct product : a.getSheath().getInsProduct()) { product.setStandardMethodListId(a.getSheath().getStandardMethodListId()); } - addInsProductMethod(a.getId(), a.getSheath().getInsProduct(), null, 0, false); + addInsProductMethod(a.getId(), a.getSheath().getInsProduct(), null, 0); } + //瀛愭牱鍝侀厤缃� if (ObjectUtil.isNotEmpty(a.getChildSampleList())) { for (SampleProductDto b : a.getChildSampleList()) { for (int i = 0; i < b.getNum(); i++) { @@ -219,12 +234,13 @@ } insSampleMapper.insert(b); if (ObjectUtil.isNotEmpty(b.getInsProduct())) { - addInsProductMethod(b.getId(), b.getInsProduct(), null, 0, false); + addInsProductMethod(b.getId(), b.getInsProduct(), null, 0); } } } } - if (ObjectUtil.isEmpty(a.getInsProduct()) && ObjectUtil.isNotEmpty(a.getBushing())) { + //鍏夌氦閰嶇疆 + /*if (ObjectUtil.isEmpty(a.getInsProduct()) && ObjectUtil.isNotEmpty(a.getBushing())) { for (BushingDto bushingDto : a.getBushing()) { bushingDto.setInsSampleId(a.getId()); insBushingMapper.insert(bushingDto); @@ -232,7 +248,7 @@ for (FiberDto fiberDto : bushingDto.getFiber()) { fiberDto.setInsBushingId(bushingDto.getId()); insFiberMapper.insert(fiberDto); - addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2, false); + addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2); } } else { for (FibersDto fibersDto : bushingDto.getFibers()) { @@ -242,15 +258,16 @@ for (FiberDto fiberDto : fibersDto.getFiber()) { fiberDto.setInsFibersId(fibersDto.getId()); insFiberMapper.insert(fiberDto); - addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2, false); + addInsProductMethod(a.getId(), fiberDto.getProductList(), fiberDto.getId(), 2); } - addInsProductMethod(a.getId(), fibersDto.getProductList(), fibersDto.getId(), 1, false); + addInsProductMethod(a.getId(), fibersDto.getProductList(), fibersDto.getId(), 1); } } } - } + }*/ }); - for (List<Integer> i : pairing) { + //澶氫釜鏍峰搧灏辨嫾鎺� + /*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); @@ -264,158 +281,99 @@ } } catch (Exception e) { } + }*/ + //閫氫俊:濡傛灉鏄疌绫昏鍗曟棤闇�瀹℃牳鐩存帴閫氳繃 + if (insOrder.getOrderType().equals("C")) { + insOrder.setState(1); + upInsOrderOfState(insOrder); } return insOrder.getId(); } - private void addInsProductMethod(Integer sampleId, List<InsProduct> productList, Integer id, Integer type, Boolean is) { - InsOrder insOrder = insOrderMapper.selectById(insSampleMapper.selectById(sampleId).getInsOrderId()); + private void addInsProductMethod(Integer sampleId, List<InsProduct> productList, Integer id, Integer type) { for (InsProduct product : productList) { - if (product.getState() == 1 && !product.getInspectionItem().equals("鍏夌氦鎺ュご鎹熻��")) { - //鍒ゆ柇鍏夌紗鐨勬俯搴﹀惊鐜」鐩坊鍔� - if (insOrder.getSampleType().equals("鍏夌紗") && product.getInspectionItem().equals("娓╁害寰幆") && type != 0) { - List<InsProduct> insProductes = new ArrayList<>(); - List<InsProduct> insProducts = new ArrayList<>(); - String[] strings = product.getAsk().split(";"); + if (product.getState() == 1 ) { + switch (type) { + case 1: + product.setInsFibersId(id); + break; + case 2: + product.setInsFiberId(id); + break; + } + product.setId(null); + product.setCreateTime(null); + product.setCreateUser(null); + product.setUpdateTime(null); + product.setUpdateUser(null); + product.setInsSampleId(sampleId); + if (product.getInspectionItemSubclass() == null) { + product.setInspectionItemSubclass(""); + } + insProductMapper.insert(product); + } + } + } - 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); + //娓╁害寰幆鐨勫鐞� + 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; } - //鍒ゆ柇鐑惊鐜」鐩殑娣诲姞鍜屾俯鍗囪瘯楠岄」鐩殑娣诲姞 - else if (product.getInspectionItem().equals("鐑惊鐜�") || product.getInspectionItem().equals("娓╁崌璇曢獙")) { - List<InsProduct> insProductess = new ArrayList<>(); - insProductess.add(product); - List<InsProduct> insProductes = new ArrayList<>(); - List<InsProduct> insProducts = new ArrayList<>(); - String[] strings = product.getAsk().split(";"); - //寰幆娆℃暟 - int count = Integer.parseInt(strings[strings.length - 1]); - for (int i = 0; i < strings.length - 1; i++) { - String[] split = strings[i].split(","); - InsProduct insProduct = new InsProduct(); - insProduct.setInspectionItem("1");//妫�楠岀埗椤�--寰幆娆℃暟 - insProduct.setInspectionItemSubclass(split[0]);//妫�楠屽瓙椤�--鐜娓╁害/瀵肩嚎娓╁害/鑰愬紶娓╁害/鎺ョ画娓╁害 - insProduct.setInspectionItemSubclassEn(split[1]);//妫�楠屽瓙椤硅嫳鏂�--鐜娓╁害/瀵肩嚎娓╁害/鑰愬紶娓╁害/鎺ョ画娓╁害 - insProduct.setAsk(null);//妫�楠岃姹� - insProduct.setTell(null);//妫�楠屾弿杩� - 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("鈩�");//鍗曚綅 - insProduct.setManHourGroup(product.getManHourGroup()); - insProduct.setInspectionItemType("0"); - insProduct.setInspectionValueType("1"); - insProducts.add(insProduct); - insProductes.add(insProduct); - insProductess.add(insProduct); - } - //鐑惊鐜墠鏈夊娆″惊鐜鏁� - if (product.getInspectionItem().equals("鐑惊鐜�")) { - //鐑惊鐜繕瑕佸姞涓婄洿娴佺數闃� + 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) { - InsProduct insProduct1 = new InsProduct(); - BeanUtils.copyProperties(insProduct, insProduct1); - insProduct1.setInspectionItemClass("鐩存祦鐢甸樆");//妫�楠屽瓙瀛愰」--鐩存祦鐢甸樆 - insProduct1.setInspectionItemClassEn("DC resistance");//妫�楠屽瓙瀛愰」鑻辨枃--鐩存祦鐢甸樆 - insProduct1.setUnit("惟/km");//鍗曚綅 - insProductes.add(insProduct1); - insProductess.add(insProduct1); - } - } - if (count > 1) { - //寰幆瓒呰繃1娆� - for (int j = 2; j <= count; j++) { - for (InsProduct insProduct : insProductes) { - InsProduct insProduct1 = new InsProduct(); - BeanUtils.copyProperties(insProduct, insProduct1); - insProduct1.setInspectionItem(j + "");//寰幆娆℃暟 - insProductess.add(insProduct1); - } + 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(insProductess); - } - else { - if (!is) { - switch (type) { - case 1: - product.setInsFibersId(id); - break; - case 2: - product.setInsFiberId(id); - break; - } - product.setId(null); - product.setCreateTime(null); - product.setUpdateTime(null); - product.setUpdateTime(null); - product.setUpdateUser(null); - product.setInsSampleId(sampleId); - if (product.getInspectionItemSubclass() == null) { - product.setInspectionItemSubclass(""); - } - insProductMapper.insert(product); } } } } + insProductService.saveBatch(insProductes); } @Override @@ -430,6 +388,8 @@ @Override public int upInsOrderOfState(InsOrder insOrder) { + InsOrder order = insOrderMapper.selectById(insOrder.getId()); + insOrder.setCompany(order.getCompany()); insOrder.setExamineTime(LocalDateTime.now()); if (insOrder.getState() == 1) { //瀹℃牳閫氳繃鎵嶄細鐢熸垚濮旀墭缂栧彿 @@ -437,17 +397,112 @@ if (StringUtils.isEmpty(code)) { code = ""; } - String code2 = customMapper.selectById(insOrder.getCompanyId()).getCode2(); + Custom custom = customMapper.selectById(order.getCompanyId()); + System.out.println("=============" + custom.getCompany()); + System.out.println("-------------" + order.getCompany()); + String code2 = custom.getCode2(); + if (!custom.getCompany().equals(order.getCompany())) { + Custom one = customMapper.selectOne(Wrappers.<Custom>lambdaQuery().eq(Custom::getCompany, order.getCompany())); + insOrder.setCompanyId(one.getId()); + code2 = one.getCode2(); + } insOrder.setEntrustCode(giveCode.giveCode2("JCZX/" + code + "-" + code2 + "-", insOrder.getCompanyId(), insOrder.getLaboratory(), "ins_order", "", "yyMM")); + //绯荤粺鏌ヨ绔欑偣浠诲姟鍒嗗竷鎯呭喌,灏嗘楠屼换鍔′笅鍙戣嚦鏈�灏戠殑绔欏彴 + 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); + } + // 鏌ユ壘鏁版嵁閲忔渶灏戠殑鍏冪礌 + 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); } @Override + public int upInsOrderOfState2(InsOrder insOrder) { + InsOrder order = insOrderMapper.selectById(insOrder.getId()); + //鑾峰彇褰撳墠浜� + Integer userId = getLook.selectPowerByMethodAndUserId(null).get("userId"); + //鑾峰彇褰撳墠浜虹殑瑙掕壊 + String roleName = roleMapper.selectById(userMapper.selectById(userId).getRoleId()).getName(); + //鍒ゆ柇鏄娴嬩腑蹇冧富浠�/鐮斿彂閮ㄧ粡鐞�/鎶�鏈礋璐d汉 + switch (roleName) { + case "妫�娴嬩腑蹇冧富浠�": + order.setCheckState1(insOrder.getState()); + order.setCheckState1User(userId); + break; + case "鐮斿彂閮ㄧ粡鐞�": + order.setCheckState2(insOrder.getState()); + order.setCheckState2User(userId); + break; + case "鎶�鏈礋璐d汉": + order.setCheckState3(insOrder.getState()); + order.setCheckState3User(userId); + break; + default: + throw new ErrorException("褰撳墠鐧诲綍鐢ㄦ埛鐨勮鑹蹭笉鏄娴嬩腑蹇冧富浠�/鐮斿彂閮ㄧ粡鐞�/鎶�鏈礋璐d汉,鏃犳硶杩涜瀹℃牳"); + } + insOrderMapper.updateById(order); + //鏌ヨ璇ヨ鍗曟槸A绫昏繕鏄疊绫� + if (order.getOrderType().equals("A")) { + //濡傛灉鏄疉绫�,1鍜�2鍜�3閮藉鏍搁�氳繃杩欎釜鍗曞瓙灏卞鏍搁�氳繃 + if (order.getCheckState1() == 1 && order.getCheckState2() == 1 && order.getCheckState3() == 1) { + order.setState(1); + upInsOrderOfState(order); + } else if (order.getCheckState1() == 2 || order.getCheckState2() == 2 || order.getCheckState3() == 2) { + order.setState(2); + upInsOrderOfState(order); + } + } else if (order.getOrderType().equals("B")) { + //濡傛灉鏄疊绫�,1鍜�2瀹℃牳閫氳繃鍚庤繖涓崟瀛愬氨瀹℃牳閫氳繃 + if (order.getCheckState1() == 1 && order.getCheckState2() == 1) { + order.setState(1); + upInsOrderOfState(order); + } else if (order.getCheckState1() == 2 || order.getCheckState2() == 2) { + order.setState(2); + upInsOrderOfState(order); + } + } + return 1; + } + + @Override public Map<String, Object> getInsOrderAndSample(Integer id, String laboratory) { Map<String, Object> map = new HashMap<>(); - InsOrder insOrder = insOrderMapper.selectById(id); + InsOrder insOrder = insOrderMapper.selectById2(id); List<SampleProductDto> list = insSampleMapper.getInsOrderAndSample(id, laboratory); + for (SampleProductDto sampleProductDto : list) { + List<Integer> ids = sampleProductDto.getInsProduct().stream().map(InsProduct::getId).collect(Collectors.toList()); + List<InsProductUser> insProductUsers = insProductUserMapper.selectList(Wrappers.<InsProductUser>lambdaQuery() + .in(InsProductUser::getInsProductId, ids)); + if (CollectionUtils.isNotEmpty(insProductUsers)) { + List<Integer> userIds = insProductUsers.stream().map(InsProductUser::getCreateUser).distinct().collect(Collectors.toList()); + String collect = userMapper.selectBatchIds(userIds).stream().map(User::getName).collect(Collectors.joining(",")); + sampleProductDto.setCheckName(collect); + } + } map.put("insOrder", insOrder); map.put("sampleProduct", list); //鏌ヨ鎵�鏈夎褰曟ā鐗堝幓閲� @@ -460,7 +515,19 @@ public Map<String, Object> selectSampleAndProductByOrderId(IPage<SampleProductDto2> page, SampleProductDto2 sampleProductDto) { Map<String, Object> map = new HashMap<>(); map.put("head", PrintChina.printChina(SampleProductDto2.class)); - map.put("body", insOrderMapper.selectSampleAndProductByOrderId(page, QueryWrappers.queryWrappers(sampleProductDto))); + IPage<SampleProductDto2> productDto2IPage = insOrderMapper.selectSampleAndProductByOrderId(page, QueryWrappers.queryWrappers(sampleProductDto).orderByAsc("inspection_item"), sampleProductDto.getId()); + for (SampleProductDto2 record : productDto2IPage.getRecords()) { + InsProductUser insProductUser = insProductUserMapper.selectOne(Wrappers.<InsProductUser>lambdaQuery() + .eq(InsProductUser::getInsProductId, record.getInsProductId()) + .orderByDesc(InsProductUser::getCreateTime) + .last("limit 1")); + if (ObjectUtils.isNotEmpty(insProductUser)) { + record.setCheckName(userMapper.selectById(insProductUser.getCreateUser()).getName()); + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + record.setCheckTime(insProductUser.getCreateTime().format(formatter)); + } + } + map.put("body", productDto2IPage); return map; } @@ -473,7 +540,21 @@ map.put("head", PrintChina.printChina(CostStatisticsDto.class)); Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("costStatistics"); if (map1.get("look") == 1) costStatisticsDto.setCreateUser(map1.get("userId")); - map.put("body",insOrderMapper.selectCostStatistics(page, QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59"))); + IPage<CostStatisticsDto> dtoIPage = insOrderMapper.selectCostStatistics(page, QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59")); + List<CostStatisticsDto> collect = dtoIPage.getRecords().stream().map(dto -> { + Set<String> uniqueTags = new HashSet<>(); + if (dto.getInspectionItem().contains(",")) { + for (String s : dto.getInspectionItem().split(",")) { + uniqueTags.add(s.split("@")[0]); + } + } else { + uniqueTags.add(dto.getInspectionItem().split("@")[0]); + } + dto.setInspectionItem(uniqueTags.toString()); + return dto; + }).collect(Collectors.toList()); + dtoIPage.setRecords(collect); + map.put("body", dtoIPage); return map; } @@ -486,7 +567,7 @@ List<CostStatisticsDto> costStatisticsDtos = insOrderMapper.selectCostStatistics2(QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59")); double totalPrice = costStatisticsDtos.stream() .filter(dto -> dto.getPrice() != null) // 杩囨护鎺変环鏍间负 null 鐨勫璞� - .mapToDouble(value -> value.getPrice().doubleValue()*value.getNum()) + .mapToDouble(value -> value.getPrice().doubleValue() * value.getNum()) .sum(); map.put("total", totalPrice); return map; @@ -527,6 +608,57 @@ }).collect(Collectors.toList()); return sampleProductDto3s; } + + @Override + public void export(CostStatisticsDto costStatisticsDto, HttpServletResponse response) throws IOException { + //鏌ヨ瀵煎嚭鐨勮垂鐢ㄧ粺璁℃暟鎹� + String dates = costStatisticsDto.getDates(); + String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(","); + costStatisticsDto.setDates(null); + List<CostStatisticsDto> costStatisticsDtos = insOrderMapper.selectCostStatistics2(QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59")); + costStatisticsDtos = costStatisticsDtos.stream().map(dto -> { + Set<String> uniqueTags = new HashSet<>(); + if (dto.getInspectionItem().contains(",")) { + for (String s : dto.getInspectionItem().split(",")) { + uniqueTags.add(s.split("@")[0]); + } + } else { + uniqueTags.add(dto.getInspectionItem().split("@")[0]); + } + dto.setInspectionItem(uniqueTags.toString()); + return dto; + }).collect(Collectors.toList()); + + response.setContentType("application/vnd.ms-excel"); + response.setCharacterEncoding("UTF-8"); + // 杩欓噷URLEncoder.encode鍙互闃叉涓枃涔辩爜 褰撶劧鍜宔asyexcel娌℃湁鍏崇郴 + String fileName = URLEncoder.encode("鏍峰搧璐圭敤缁熻瀵煎嚭", "UTF-8"); + response.setHeader("Content-disposition", "attachment;filename=" + fileName + ".xlsx"); + Map<String, List<CostStatisticsDto>> groupByCompany = + costStatisticsDtos.stream().filter(e -> StrUtil.isNotEmpty(e.getCompany())) + .collect(Collectors.groupingBy(CostStatisticsDto::getCompany)); + try { + // 鏂板缓ExcelWriter + // 鏂板缓ExcelWriter + ExcelWriter excelWriter = + EasyExcel.write(response.getOutputStream()) + .registerWriteHandler(new SimpleColumnWidthStyleStrategy(25)) + .build(); + for (Map.Entry<String, List<CostStatisticsDto>> companyDataEntry : groupByCompany.entrySet()) { + String sheetName = companyDataEntry.getKey(); + List<CostStatisticsDto> dataList = companyDataEntry.getValue(); + WriteSheet mainSheet = EasyExcel.writerSheet(sheetName) + .head(CostStatisticsDto.class) + .registerWriteHandler(new SimpleColumnWidthStyleStrategy(25)) + .build(); + excelWriter.write(dataList, mainSheet); + } + // 鍏抽棴娴� + excelWriter.finish(); + } catch (IOException e) { + throw new RuntimeException("瀵煎嚭澶辫触"); + } + } } -- Gitblit v1.9.3