修改参数采集

cl

2024-07-04 743e2e0100528790c04256106438122e8c50f819

修改参数采集

 jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java

@@ -527,8 +527,11 @@
     */
    private static Integer saveParamCollection(String thoroughfare, String device,List<String> cellCodeList){
        Integer result = 21;//返回结果
        List<List<ChildVO>> mesList = new ArrayList<>();//存储4个电芯的发送给MES的值

        List<ChildVO> mesChildList1 = new ArrayList<>();//封装给工厂MES发送的childlist1
        List<ChildVO> mesChildList2 = new ArrayList<>();//封装给工厂MES发送的childlist2
        List<ChildVO> mesChildList3 = new ArrayList<>();//封装给工厂MES发送的childlist3
        List<ChildVO> mesChildList4 = new ArrayList<>();//封装给工厂MES发送的childlist4
        List<ChildVO> mesChildList0 = new ArrayList<>();//封装给工厂MES发送的childlist4
        try {
            //查询参数配置表
            List<DaCollectionParamConf> list = collectionParamConfService.list(new LambdaQueryWrapper<DaCollectionParamConf>()
@@ -565,7 +568,6 @@

                //第一个电芯的数据
                if (CollUtil.isNotEmpty(paramCollectionList1) && !cellCodeList.get(0).isEmpty()) {
                    List<ChildVO> mesChildList1 = new ArrayList<>();//封装给工厂MES发送的childlist1
                    for (int i = 0; i < paramCollectionList1.size(); i++) {
                        DaParamCollection daParamCollection = new DaParamCollection();
                        daParamCollection.setSfcCode(cellCodeList.get(0));//电芯码
@@ -590,10 +592,9 @@
                        childVO.setCheckTime(new Date().toString());
                        mesChildList1.add(childVO);
                    }
                    mesList.add(0, mesChildList1);

                }
                if (CollUtil.isNotEmpty(paramCollectionList2) && !cellCodeList.get(1).isEmpty()) {
                    List<ChildVO> mesChildList2 = new ArrayList<>();//封装给工厂MES发送的childlist2

                    for (int i = 0; i < paramCollectionList2.size(); i++) {
                        DaParamCollection daParamCollection = new DaParamCollection();
@@ -619,10 +620,8 @@
                        childVO.setCheckTime(new Date().toString());
                        mesChildList2.add(childVO);
                    }
                    mesList.add(1, mesChildList2);
                }
                if (CollUtil.isNotEmpty(paramCollectionList3) && !cellCodeList.get(2).isEmpty()) {
                    List<ChildVO> mesChildList3 = new ArrayList<>();//封装给工厂MES发送的childlist3
                    for (int i = 0; i < paramCollectionList3.size(); i++) {
                        DaParamCollection daParamCollection = new DaParamCollection();
                        daParamCollection.setSfcCode(cellCodeList.get(2));//电芯码
@@ -647,10 +646,8 @@
                        childVO.setCheckTime(new Date().toString());
                        mesChildList3.add(childVO);
                    }
                    mesList.add(2, mesChildList3);
                }
                if (CollUtil.isNotEmpty(paramCollectionList4)&& !cellCodeList.get(3).isEmpty()) {
                    List<ChildVO> mesChildList4 = new ArrayList<>();//封装给工厂MES发送的childlist4
                    for (int i = 0; i < paramCollectionList4.size(); i++) {
                        DaParamCollection daParamCollection = new DaParamCollection();
                        daParamCollection.setSfcCode(cellCodeList.get(3));//电芯码
@@ -675,14 +672,12 @@
                        childVO.setCheckTime(new Date().toString());
                        mesChildList4.add(childVO);
                    }
                    mesList.add(3, mesChildList4);
                }

                //公共参数
                if (CollUtil.isNotEmpty(paramCollectionList0)) {
                    for (int i = 0; i < cellCodeList.size(); i++) {//循环4个电芯
                        if(!cellCodeList.get(i).isEmpty()){
                            List<ChildVO> mesChildList0 = new ArrayList<>();//封装给工厂MES发送的childlist0
                            for (int j = 0; j < paramCollectionList0.size(); j++) {
                                DaParamCollection daParamCollection = new DaParamCollection();
                                daParamCollection.setSfcCode(cellCodeList.get(i));//电芯码
@@ -710,7 +705,6 @@
                                childVO.setCheckTime(new Date().toString());
                                mesChildList0.add(childVO);
                            }
                            mesList.add(i, mesChildList0);
                        }

                        //mesList.get(i).addAll(mesChildList0);
@@ -732,7 +726,24 @@
                    for (int i = 0; i < cellCodeList.size(); i++) {//循环4个电芯
                        if(!cellCodeList.get(i).isEmpty()){
                            parentVO.setProductNum(cellCodeList.get(i));//电芯码
                            parentVO.setCheckList(mesList.get(i));//参数
                            //封装给工厂MES发送的childlist4
                            List<ChildVO> mesChildList = new ArrayList<>(mesChildList0);
                            switch (i) {
                                case 0 :
                                    mesChildList.addAll(mesChildList1);
                                    break;
                                case 1 :
                                    mesChildList.addAll(mesChildList2);
                                    break;
                                case 2 :
                                    mesChildList.addAll(mesChildList3);
                                    break;
                                case 3 :
                                    mesChildList.addAll(mesChildList4);
                                    break;

                            }
                            parentVO.setCheckList(mesChildList);//参数
                            //CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> {
                            log.info("执行工厂MES方法start，传入数据：{}",parentVO);
                            HttpResponse execute = HttpRequest.post(orderLineUrl).body(JSONUtil.toJsonStr(parentVO)).execute();
@@ -742,6 +753,7 @@
                });
            }
        }catch (Exception e) {
            log.error(e.getMessage());
            throw new RuntimeException(e);
        }
        return result;