蓝云项目点档案本周未出库标识逻辑更新

mjava-lanyun/src/main/java/com/malk/lanyun/service/impl/TimerServiceImpl.java

@@ -813,9 +813,87 @@ public class TimerServiceImpl implements TimerService {
         }
     }
 
+    //    public void projectUnshipped() {
+//        //无需出库项目
+//        List<Map> materialList = ydService.queryFormData_all(YDParam.builder()
+//                .appType("APP_ERBDTFS82HOVBPL3NFH0")
+//                .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+//                .formUuid("FORM-38649DA9003B48F4A7DC476122E4D6C1JNKU")
+//                .build());
+//        List<Map<String,Object>> result = new ArrayList<>();
+//        Set<String> set = materialList.stream().map(map -> map.get("textField_ltxutdfi").toString()).collect(Collectors.toSet());
+//        Map<String, List<Map>> codeList = materialList.stream().collect(Collectors.groupingBy(map -> map.get("textField_ltxutdfi").toString()));
+//        codeList.forEach((k,sList)->{
+//            Map<String, Object> hashMap = new HashMap<>();
+//            IntSummaryStatistics sum = sList.stream().collect(Collectors.summarizingInt(e -> parseInt(e.get("numberField_lu24bwd0").toString())));
+//            if (sum.getSum() == 0){
+//                hashMap.put("code",sList.get(0).get("textField_ltxutdfi"));
+//                hashMap.put("sum",sum.getSum());
+//                result.add(hashMap);
+//            }
+//        });
+//        List<Map<String,Object>> noNeedResult = result;
+//        //本周已出库项目
+//        long beginWeek = DateUtil.beginOfWeek(DateUtil.date()).getTime();
+//        long endWeek = DateUtil.endOfWeek(DateUtil.date()).getTime();
+//        String[] dateList = new String[2];
+//        dateList[0] = String.valueOf(beginWeek);
+//        dateList[1] = String.valueOf(endWeek);
+//        List<Map> alredyList = ydService.queryFormData_all(YDParam.builder()
+//                .appType("APP_ERBDTFS82HOVBPL3NFH0")
+//                .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+//                .formUuid("FORM-38649DA9003B48F4A7DC476122E4D6C1JNKU")
+//                .searchFieldJson(JSON.toJSONString(UtilMap.map("dateField_lvvthng6", (Object) dateList)))
+//                .build());
+//        if (alredyList.size()>0 && ObjectUtil.isNotNull(alredyList)){
+//            alredyList = alredyList.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() ->
+//                    new TreeSet<>(Comparator.comparing(o-> o.get("textField_ltxutdfi").toString()))), ArrayList::new));
+//
+//            //合并无需出库项目和本周已出库项目
+//            alredyList.forEach(o->{
+//                HashMap<String, Object> map = new HashMap<>();
+//                map.put("code",o.get("textField_ltxutdfi"));
+//                noNeedResult.add(map);
+//            });
+//        }
+//        //处理数据
+//        List<Map> allProjectList = ydService.queryFormData_all(YDParam.builder()
+//                .appType("APP_ERBDTFS82HOVBPL3NFH0")
+//                .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+//                .formUuid("FORM-38649DA9003B48F4A7DC476122E4D6C1JNKU")
+//                .build());
+//        allProjectList.forEach(e->{
+//            int status = 1;
+//            if (ObjectUtil.isNotEmpty(e.get("selectField_lrn2oy4a")) && "已撤场".equals(e.get("selectField_lrn2oy4a").toString())){
+//                status = 0;
+//            }else {
+//                for (int i = 0; i < noNeedResult.size(); i++) {
+//                    if (e.get("textField_ltxrn8h1").equals(noNeedResult.get(i).get("code"))){
+//                        status = 0;
+//                        break;
+//                    }
+//                }
+//                for (String s : set) {
+//
+//                }
+//            }
+//            ydClient.operateData(YDParam.builder()
+//                    .appType("APP_ERBDTFS82HOVBPL3NFH0")
+//                    .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+//                    .formInstanceId(e.get("formInstanceId").toString())
+//                    .updateFormDataJson(JSON.toJSONString(UtilMap.map("numberField_m230rjg5",status)))
+//                    .build(), YDConf.FORM_OPERATION.update);
+//        });
+//    }
     @Override
     public void projectUnshipped() {
-        //无需出库项目
+        List<Map> allProjectList = ydService.queryFormData_all(YDParam.builder()
+                .appType("APP_ERBDTFS82HOVBPL3NFH0")
+                .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+                .formUuid("FORM-97BA6C6C8C50416A9E5854F2F4B5C3F3R4WC")
+//                .searchFieldJson(JSON.toJSONString(UtilMap.map("selectField_lrn2oy4a","进行中")))
+                .build());
+        //有库存的非无需出库项目
         List<Map> materialList = ydService.queryFormData_all(YDParam.builder()
                 .appType("APP_ERBDTFS82HOVBPL3NFH0")
                 .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
@@ -826,13 +904,12 @@ public class TimerServiceImpl implements TimerService {
         codeList.forEach((k,sList)->{
             Map<String, Object> hashMap = new HashMap<>();
             IntSummaryStatistics sum = sList.stream().collect(Collectors.summarizingInt(e -> parseInt(e.get("numberField_lu24bwd0").toString())));
-            if (sum.getSum() == 0){
+            if (sum.getSum() > 0){
                 hashMap.put("code",sList.get(0).get("textField_ltxutdfi"));
                 hashMap.put("sum",sum.getSum());
                 result.add(hashMap);
             }
         });
-        List<Map<String,Object>> noNeedResult = result;
         //本周已出库项目
         long beginWeek = DateUtil.beginOfWeek(DateUtil.date()).getTime();
         long endWeek = DateUtil.endOfWeek(DateUtil.date()).getTime();
@@ -849,43 +926,38 @@ public class TimerServiceImpl implements TimerService {
             alredyList = alredyList.stream().collect(Collectors.collectingAndThen(Collectors.toCollection(() ->
                     new TreeSet<>(Comparator.comparing(o-> o.get("textField_ltxutdfi").toString()))), ArrayList::new));
 
-            //合并无需出库项目和本周已出库项目
-            alredyList.forEach(o->{
-                HashMap<String, Object> map = new HashMap<>();
-                map.put("code",o.get("textField_ltxutdfi"));
-                noNeedResult.add(map);
-            });
-        }
-        //处理数据
-        List<Map> allProjectList = ydService.queryFormData_all(YDParam.builder()
-                .appType("APP_ERBDTFS82HOVBPL3NFH0")
-                .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
-                .formUuid("FORM-97BA6C6C8C50416A9E5854F2F4B5C3F3R4WC")
-                .build());
-        final int[] sum = {0};
-        allProjectList.forEach(e->{
-            System.out.println(e.toString());
-            int status = 1;
-            if (ObjectUtil.isNotEmpty(e.get("selectField_lrn2oy4a")) && "已撤场".equals(e.get("selectField_lrn2oy4a").toString())){
-                status = 0;
-            }else {
-                for (int i = 0; i < noNeedResult.size(); i++) {
-                    if (e.get("textField_ltxrn8h1").equals(noNeedResult.get(i).get("code"))){
+            for (Map<String, Object> stringObjectMap : result) {
+                int status = 1;
+                for (Map value : alredyList) {
+                    if (stringObjectMap.get("code").equals(value.get("textField_ltxutdfi"))) {
                         status = 0;
                         break;
-                    }else {
-                        sum[0]++;
+                    }
+                }
+
+                for (Map map : allProjectList) {
+                    if (stringObjectMap.get("code").equals(map.get("textField_ltxrn8h1"))) {
+                        if ("进行中".equals(map.get("selectField_lrn2oy4a"))){
+                            ydClient.operateData(YDParam.builder()
+                                    .appType("APP_ERBDTFS82HOVBPL3NFH0")
+                                    .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+                                    .formInstanceId(map.get("formInstanceId").toString())
+                                    .updateFormDataJson(JSON.toJSONString(UtilMap.map("numberField_m230rjg5", status)))
+                                    .build(), YDConf.FORM_OPERATION.update);
+                        }
+                        else {
+                            ydClient.operateData(YDParam.builder()
+                                    .appType("APP_ERBDTFS82HOVBPL3NFH0")
+                                    .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
+                                    .formInstanceId(map.get("formInstanceId").toString())
+                                    .updateFormDataJson(JSON.toJSONString(UtilMap.map("numberField_m230rjg5", 0)))
+                                    .build(), YDConf.FORM_OPERATION.update);
+                        }
+                        break;
                     }
                 }
             }
-            System.out.println(sum[0]);
-//            ydClient.operateData(YDParam.builder()
-//                    .appType("APP_ERBDTFS82HOVBPL3NFH0")
-//                    .systemToken("RRB66F91T97H1WN89QZYC47PKLZO2ZQOUMOQLP")
-//                    .formInstanceId(e.get("formInstanceId").toString())
-//                    .updateFormDataJson(JSON.toJSONString(UtilMap.map("numberField_m230rjg5",status)))
-//                    .build(), YDConf.FORM_OPERATION.update);
-        });
+        }
     }
 
     @Override