From a14a26c04bc5863248b9a9d387610a143c3a4efd Mon Sep 17 00:00:00 2001
From: zss <zss@example.com>
Date: 星期五, 27 九月 2024 08:51:34 +0800
Subject: [PATCH] 电路站点报告ing

---
 inspect-server/src/main/java/com/yuanchu/mom/service/impl/InsOrderServiceImpl.java |  481 ++++++++++++++++++++++++++++------------------------
 1 files changed, 260 insertions(+), 221 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 2e1b90b..efcae29 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,14 @@
 
 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.alibaba.fastjson.JSONArray;
 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;
@@ -17,6 +23,7 @@
 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;
@@ -25,6 +32,9 @@
 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;
@@ -39,17 +49,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;
 
@@ -61,24 +77,23 @@
 
     PowerMapper powerMapper;
 
-    private InsBushingMapper insBushingMapper;
-
-    private InsFibersMapper insFibersMapper;
-
-    private InsFiberMapper insFiberMapper;
-
     CustomMapper customMapper;
+
+    QYWXApi qywxApi;
 
 
     //鑾峰彇妫�楠屼笅鍗曟暟鎹�
     @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");
-        User user = userMapper.selectById(map1.get("userId"));
+        User user = userMapper.selectById(map1.get("userId"));//褰撳墠鐧诲綍鐨勪汉
         Integer roleId = user.getRoleId();
+        String laboratory = null;
         //鍒ゆ柇鏄惁鏄叏閮ㄦ潈闄�
-        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) {
                 //涓汉
@@ -92,39 +107,40 @@
                 }
             }
         }
-        Map<String, Object> map = new HashMap<>();
-        map.put("head", PrintChina.printChina(SampleOrderDto.class));
-        map.put("body", insOrderMapper.selectInsOrderPage(page, QueryWrappers.queryWrappers(sampleOrderDto)));
+        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.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);
+        insOrderState.setNum(1);//鍒濆鏄涓�娆�
+        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;
@@ -134,50 +150,45 @@
     @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();
+        }
+        //澶栭儴濮旀墭缂栧彿
+        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();
         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("YP-" + a.getModel()+"-" + 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());
             }
+            //鏍峰搧鐨勬楠屾爣鍑�
             if (ObjectUtil.isNotEmpty(a.getInsulating())) {
                 List<InsProduct> ip2 = new ArrayList<>();
                 for (Integer i = 0; i < a.getInsulating().getNum(); i++) {
@@ -186,14 +197,16 @@
                 for (InsProduct product : ip2) {
                     product.setStandardMethodListId(a.getInsulating().getStandardMethodListId());
                 }
-                addInsProductMethod(a.getId(), ip2, null, 0, false);
+                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, false);
+                addInsProductMethod(a.getId(), a.getSheath().getInsProduct());
             }
+            //瀛愭牱鍝侀厤缃�
             if (ObjectUtil.isNotEmpty(a.getChildSampleList())) {
                 for (SampleProductDto b : a.getChildSampleList()) {
                     for (int i = 0; i < b.getNum(); i++) {
@@ -205,141 +218,34 @@
                         }
                         insSampleMapper.insert(b);
                         if (ObjectUtil.isNotEmpty(b.getInsProduct())) {
-                            addInsProductMethod(b.getId(), b.getInsProduct(), null, 0, false);
+                            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, 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) {
-            }
+        //閫氫俊:濡傛灉鏄疌绫昏鍗曟棤闇�瀹℃牳鐩存帴閫氳繃
+        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) {
         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 (!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);
-                    }
+            if (product.getState() == 1) {
+                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);
             }
         }
     }
@@ -349,6 +255,9 @@
         Map<String, Object> map = new HashMap<>();
         InsOrder insOrder = insOrderMapper.selectById(id);
         List<SampleProductDto> list = insSampleMapper.selectSampleProductListByOrderId2(id);
+        if (list.size() == 0) {
+            list = insSampleMapper.selectSampleProductListByOrder2Id2(id);
+        }
         map.put("insOrder", insOrder);
         map.put("sampleProduct", list);
         return map;
@@ -356,24 +265,103 @@
 
     @Override
     public int upInsOrderOfState(InsOrder insOrder) {
+        InsOrder order = insOrderMapper.selectById(insOrder.getId());
+        insOrder.setCompany(order.getCompany());
         insOrder.setExamineTime(LocalDateTime.now());
         if (insOrder.getState() == 1) {
             //瀹℃牳閫氳繃鎵嶄細鐢熸垚濮旀墭缂栧彿
-            String code = baseMapper.selLaboratoryCode(insOrder.getLaboratory());
-            if (StringUtils.isEmpty(code)) {
-                code = "";
+            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 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 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);
+        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());
+            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);
         //鏌ヨ鎵�鏈夎褰曟ā鐗堝幓閲�
@@ -386,7 +374,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;
     }
 
@@ -399,34 +399,22 @@
         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> costStatisticsDtoIPage = insOrderMapper.selectCostStatistics(page, QueryWrappers.queryWrappers(costStatisticsDto).ge("create_time", split[0]).le("create_time", split[1] + " 23:59:59"));
-        List<CostStatisticsDto> costStatisticsDtoList = costStatisticsDtoIPage.getRecords();
-        for (CostStatisticsDto statisticsDto : costStatisticsDtoList) {
-            statisticsDto.setNum(1);
-        }
-        List<CostStatisticsDto> costStatisticsDtoList1 = deduplicateAndSumCounts(costStatisticsDtoList);
-        costStatisticsDtoIPage.setRecords(costStatisticsDtoList1);
-        map.put("body", costStatisticsDtoIPage);
-        return map;
-    }
-    private static List<CostStatisticsDto> deduplicateAndSumCounts(List<CostStatisticsDto> list) {
-        // 浣跨敤涓�涓� Map 鏉ュ瓨鏀惧凡缁忓嚭鐜拌繃鐨� inspectionItem + entrustCode + sample 鐨勭粍鍚�
-        Map<String, CostStatisticsDto> map = new HashMap<>();
-        // 閬嶅巻鍒楄〃杩涜鍘婚噸鍜岃鏁�
-        for (CostStatisticsDto dto : list) {
-            String key = dto.getInspectionItem() + dto.getEntrustCode() + dto.getSample();
-            if (map.containsKey(key)) {
-                // 濡傛灉宸茬粡瀛樺湪锛屽垯绱姞鏁伴噺
-                CostStatisticsDto existingDto = map.get(key);
-                existingDto.setNum(existingDto.getNum() + dto.getNum());
-                existingDto.setPrice(existingDto.getPrice().add(dto.getPrice()));
+        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 {
-                // 濡傛灉涓嶅瓨鍦紝鍒欐斁鍏� Map 涓�
-                map.put(key, dto);
+                uniqueTags.add(dto.getInspectionItem().split("@")[0]);
             }
-        }
-        // 灏� Map 涓殑鍊艰浆涓� List 杩斿洖
-        return new ArrayList<>(map.values());
+            dto.setInspectionItem(uniqueTags.toString());
+            return dto;
+        }).collect(Collectors.toList());
+        dtoIPage.setRecords(collect);
+        map.put("body", dtoIPage);
+        return map;
     }
 
     @Override
@@ -438,9 +426,9 @@
         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())
+                .mapToDouble(value -> value.getPrice().doubleValue() * value.getNum())
                 .sum();
-        map.put("total",totalPrice);
+        map.put("total", totalPrice);
         return map;
     }
 
@@ -479,6 +467,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