From 124ecca15d3c5d6dcefa9a27aaa3c07c556674e9 Mon Sep 17 00:00:00 2001 From: zss <zss@example.com> Date: 星期二, 30 七月 2024 12:34:42 +0800 Subject: [PATCH] PK8000逻辑处理 --- inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java | 519 ++++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 488 insertions(+), 31 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 4cc7203..1b61451 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,36 +1,47 @@ package com.yuanchu.mom.service.impl; -import cn.hutool.core.bean.BeanUtil; 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.LongestMatchColumnWidthStyleStrategy; import com.alibaba.fastjson.JSON; import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.core.toolkit.ObjectUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.yuanchu.mom.common.GetLook; import com.yuanchu.mom.common.PrintChina; -import com.yuanchu.mom.dto.InsOderDto; -import com.yuanchu.mom.dto.OrderThingDto; -import com.yuanchu.mom.dto.SampleOrderDto; -import com.yuanchu.mom.dto.SampleProductDto; -import com.yuanchu.mom.mapper.InsOrderMapper; -import com.yuanchu.mom.mapper.InsProductMapper; -import com.yuanchu.mom.mapper.InsSampleMapper; -import com.yuanchu.mom.mapper.InsSampleUserMapper; -import com.yuanchu.mom.pojo.InsOrder; -import com.yuanchu.mom.pojo.InsProduct; -import com.yuanchu.mom.pojo.InsSample; -import com.yuanchu.mom.pojo.InsSampleUser; +import com.yuanchu.mom.dto.*; +import com.yuanchu.mom.exception.ErrorException; +import com.yuanchu.mom.mapper.*; +import com.yuanchu.mom.pojo.*; import com.yuanchu.mom.service.InsOrderService; +import com.yuanchu.mom.service.InsProductService; import com.yuanchu.mom.utils.GiveCode; 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.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import javax.servlet.ServletException; +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; /** * @author gaoaoy @@ -49,35 +60,94 @@ private InsSampleMapper insSampleMapper; private InsProductMapper insProductMapper; + private InsProductService insProductService; private GiveCode giveCode; private InsSampleUserMapper insSampleUserMapper; + + private InsOrderStateMapper insOrderStateMapper; + + UserMapper userMapper; + + PowerMapper powerMapper; + + private InsBushingMapper insBushingMapper; + + private InsFibersMapper insFibersMapper; + + private InsFiberMapper insFiberMapper; + + CustomMapper customMapper; + //鑾峰彇妫�楠屼笅鍗曟暟鎹� @Override public Map<String, Object> selectInsOrderParameter(IPage<InsOrder> page, SampleOrderDto sampleOrderDto) { Map<String, Object> map = new HashMap<>(); map.put("head", PrintChina.printChina(SampleOrderDto.class)); + //鍒ゆ柇鍏ㄩ儴,涓汉,缁勭粐鐨勬潈闄� Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("selectInsOrderParameter"); - if (map1.get("look") == 1) sampleOrderDto.setCreateUser(map1.get("userId")); - map.put("body", insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto))); + User user = userMapper.selectById(map1.get("userId"));//褰撳墠鐧诲綍鐨勪汉 + Integer roleId = user.getRoleId(); + //鑾峰彇褰撳墠浜烘墍灞炲疄楠屽id + String departLimsId = user.getDepartLimsId(); + String laboratory = null; + 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, "selectAllInsOrder")); + if (ObjectUtils.isEmpty(power)) { + if (map1.get("look") == 1) { + //涓汉 + sampleOrderDto.setCreateUser(map1.get("userId")); + } else { + //缁勭粐 + try { + sampleOrderDto.setCompany(customMapper.selectById(user.getCompany()).getCompany()); + } catch (NullPointerException e) { + throw new ErrorException("鎵句笉鍒版墍灞炲崟浣�"); + } + } + } + map.put("body", insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto), laboratory)); 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); - if(userId!=null){ + 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); + } + if (userId != null) { InsSampleUser insSampleUser = new InsSampleUser(); insSampleUser.setState(0); insSampleUser.setUserId(userId); insSampleUser.setInsSampleId(orderId); + insSampleUser.setSonLaboratory(sonLaboratory); insSampleUserMapper.insert(insSampleUser); } return 1; @@ -85,38 +155,277 @@ @Override @Transactional(rollbackFor = Exception.class) - public int addInsOrder(List<SampleProductDto> list, InsOrder insOrder) { + public int addInsOrder(List<SampleProductDto> list, InsOrder insOrder, List<List<Integer>> pairing) { insOrder.setState(0); - String code = insOrderMapper.getLaboratoryCode(insOrder.getLaboratory()); - insOrder.setEntrustCode(giveCode.giveCode("JCZX-" + code + "-", "ins_order", "-", "yyyyMMdd")); + String code = customMapper.selectById(insOrder.getCompanyId()).getCode2(); + //insOrder.setEntrustCode(giveCode.giveCode("JCZX-" + code + "-", "ins_order", "", "yyMMdd")); + 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.giveCode("", "ins_sample", "", "yyMMdd")); + if (StrUtil.isEmpty(a.getSampleCode())) { + a.setSampleCode(giveCode.split("-")[2] + "-" + count.get()); } insSampleMapper.insert(a); if (ObjectUtil.isNotEmpty(a.getInsProduct())) { - for (InsProduct product : a.getInsProduct()) { - product.setId(null); - product.setCreateTime(null); - product.setUpdateTime(null); - product.setUpdateTime(null); - product.setUpdateUser(null); - product.setInsSampleId(a.getId()); - insProductMapper.insert(product); + 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); + } + } + } + } + } + if (ObjectUtil.isNotEmpty(a.getInsulating())) { + List<InsProduct> ip2 = new ArrayList<>(); + for (Integer i = 0; i < a.getInsulating().getNum(); i++) { + ip2.addAll(a.getInsulating().getInsProduct()); + } + for (InsProduct product : ip2) { + product.setStandardMethodListId(a.getInsulating().getStandardMethodListId()); + } + addInsProductMethod(a.getId(), ip2, null, 0, false); + } + 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); + } + if (ObjectUtil.isNotEmpty(a.getChildSampleList())) { + for (SampleProductDto b : a.getChildSampleList()) { + for (int i = 0; i < b.getNum(); i++) { + b.setId(null); + b.setInsOrderId(insOrder.getId()); + b.setParentId(a.getId()); + if (StrUtil.isEmpty(b.getSampleCode())) { + b.setSampleCode(this.giveCode.giveCode("", "ins_sample", "", "yyMMdd")); + } + insSampleMapper.insert(b); + if (ObjectUtil.isNotEmpty(b.getInsProduct())) { + addInsProductMethod(b.getId(), b.getInsProduct(), null, 0, false); + } + } + } + } + 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, 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(), fiberDto.getProductList(), fiberDto.getId(), 2, false); + } + addInsProductMethod(a.getId(), fibersDto.getProductList(), fibersDto.getId(), 1, false); + } + } } } }); + 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) { + } + } 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()); + 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(";"); + + 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); + } + //鍒ゆ柇鐑惊鐜」鐩殑娣诲姞鍜屾俯鍗囪瘯楠岄」鐩殑娣诲姞 + else if (product.getInspectionItem().equals("鐑惊鐜�") || product.getInspectionItem().equals("娓╁崌璇曢獙")) { + List<InsProduct> insProductess = new ArrayList<>(); + product.setId(null); + product.setInsSampleId(sampleId); + 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"); + if (product.getInspectionItem().equals("鐑惊鐜�")) { + insProduct.setInspectionItemClass("鐩存祦鐢甸樆");//妫�楠屽瓙瀛愰」--鐩存祦鐢甸樆 + insProduct.setInspectionItemClassEn("DC resistance");//妫�楠屽瓙瀛愰」鑻辨枃--鐩存祦鐢甸樆 + insProduct.setUnit("惟/km");//鍗曚綅 + } + insProducts.add(insProduct); + insProductes.add(insProduct); + insProductess.add(insProduct); + } + //鐑惊鐜墠鏈夊娆″惊鐜鏁� + 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); + } + } + } + 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); + } + } + } + } } @Override public Map<String, Object> getInsOrder(Integer id) { Map<String, Object> map = new HashMap<>(); - List<SampleProductDto> list = insSampleMapper.selectSampleProductListByOrderId(id); InsOrder insOrder = insOrderMapper.selectById(id); + List<SampleProductDto> list = insSampleMapper.selectSampleProductListByOrderId2(id); map.put("insOrder", insOrder); map.put("sampleProduct", list); return map; @@ -124,8 +433,156 @@ @Override public int upInsOrderOfState(InsOrder insOrder) { + insOrder.setExamineTime(LocalDateTime.now()); + if (insOrder.getState() == 1) { + //瀹℃牳閫氳繃鎵嶄細鐢熸垚濮旀墭缂栧彿 + String code = baseMapper.selLaboratoryCode(insOrder.getLaboratory()); + if (StringUtils.isEmpty(code)) { + code = ""; + } + String code2 = customMapper.selectById(insOrder.getCompanyId()).getCode2(); + insOrder.setEntrustCode(giveCode.giveCode2("JCZX/" + code + "-" + code2 + "-", insOrder.getCompanyId(), insOrder.getLaboratory(), "ins_order", "", "yyMM")); + } return insOrderMapper.updateById(insOrder); } + + @Override + public Map<String, Object> getInsOrderAndSample(Integer id, String laboratory) { + Map<String, Object> map = new HashMap<>(); + InsOrder insOrder = insOrderMapper.selectById(id); + List<SampleProductDto> list = insSampleMapper.getInsOrderAndSample(id, laboratory); + map.put("insOrder", insOrder); + map.put("sampleProduct", list); + //鏌ヨ鎵�鏈夎褰曟ā鐗堝幓閲� + List<Map<Integer, Object>> list2 = insOrderMapper.selectReportModelByOrderId(id, laboratory); + map.put("reportModel", list2); + return map; + } + + @Override + 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))); + return map; + } + + @Override + public Map<String, Object> costStatistics(IPage<CostStatisticsDto> page, CostStatisticsDto costStatisticsDto) { + String dates = costStatisticsDto.getDates(); + String[] split = dates.replaceAll("\\[", "").replaceAll("]", "").replaceAll("\"", "").split(","); + costStatisticsDto.setDates(null); + Map<String, Object> map = new HashMap<>(); + map.put("head", PrintChina.printChina(CostStatisticsDto.class)); + Map<String, Integer> map1 = getLook.selectPowerByMethodAndUserId("costStatistics"); + if (map1.get("look") == 1) costStatisticsDto.setCreateUser(map1.get("userId")); + 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; + } + + @Override + public Map<String, Object> costStatistics2(CostStatisticsDto costStatisticsDto) { + Map<String, Object> map = new HashMap<>(); + 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")); + double totalPrice = costStatisticsDtos.stream() + .filter(dto -> dto.getPrice() != null) // 杩囨护鎺変环鏍间负 null 鐨勫璞� + .mapToDouble(value -> value.getPrice().doubleValue() * value.getNum()) + .sum(); + map.put("total", totalPrice); + return map; + } + + @Override + public Map<String, Object> selectSampleDefects(Page page, String inspectionItems, String orderNumber) { + List<SampleDefectsFatherVo> sampleDefectsFatherVos = insOrderMapper.selectSampleDefects(page, inspectionItems, orderNumber); + Map<String, Object> map = new HashMap<>(); + map.put("records", sampleDefectsFatherVos); + Long aLong = insOrderMapper.getCount(inspectionItems, orderNumber); + map.put("total", aLong); + return map; + } + + @Override + public int updateStatus(Integer id) { + return insOrderMapper.updateStatus(id); + } + + //鏍囩鎵撳嵃 + @Override + public List<SampleProductDto3> labelPrinting(String ids) { + 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 { + processedCodes.add(sampleProductDto3.getCode()); + return true; + } + }).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"); + try { + // 鏂板缓ExcelWriter + ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream()).registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()).build(); + + WriteSheet mainSheet = EasyExcel.writerSheet( "鏍峰搧璐圭敤缁熻瀵煎嚭").head(CostStatisticsDto.class).build(); + excelWriter.write(costStatisticsDtos, mainSheet); + + // 鍏抽棴娴� + excelWriter.finish(); + } catch (IOException e) { + throw new RuntimeException("瀵煎嚭澶辫触"); + } + } } -- Gitblit v1.9.3