1

mjava-kabeiyi/src/test/java/com/malk/kabeiyi/DdTest.java

@@ -1,12 +1,19 @@
 package com.malk.kabeiyi;
 
+import com.alibaba.fastjson.JSONObject;
 import com.malk.kabeiyi.service.KabeiyiService;
+import com.malk.server.aliwork.YDConf;
+import com.malk.server.aliwork.YDParam;
+import com.malk.service.aliwork.YDClient;
 import com.malk.service.dingtalk.DDClient;
 import com.malk.service.dingtalk.DDClient_Workflow;
 import com.malk.utils.UtilDateTime;
+import com.malk.utils.UtilMap;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.logging.log4j.util.Strings;
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.slf4j.MDC;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.junit4.SpringRunner;
@@ -29,6 +36,9 @@ public class DdTest {
     @Autowired
     private KabeiyiService kabeiyiService;
 
+    @Autowired
+    private YDClient ydClient;
+
 
     @Test
     public void test(){
@@ -63,4 +73,98 @@ public class DdTest {
     public void test3(){
         kabeiyiService.testInnerTable();
     }
+
+    @Test
+    public void test4(){
+        //分层审核
+        MDC.put("MDC_KEY_PID","1009");
+
+        List<Map> dataList = (List<Map>) ydClient.queryData(YDParam.builder()
+                .formUuid("FORM-89F515967FF94C62A9031F28EF6000B1YV5Q")//问题清单
+                .pageNumber(3)
+                .pageSize(100)
+                .build(), YDConf.FORM_QUERY.retrieve_list).getData();
+
+        for (Map data : dataList) {
+            String formInstanceId = UtilMap.getString(data, "formInstanceId");
+
+            Map formData = (Map) data.get("formData");
+
+            String status = UtilMap.getString(formData, "selectField_m0d9pkzx");//整改状态
+
+            if (Strings.isNotBlank(status)){
+                Long deadLine = (Long) formData.get("dateField_m061zyev");
+
+                Long date = (Long) formData.get("dateField_m0dbp77k");
+
+                Map updateFormDate = new HashMap();
+
+                if (Objects.isNull(date)){
+                    updateFormDate.put("selectField_m0d9pkzx","已超期");
+                }else {
+                    if (date <= deadLine && !"未超期".equals(status)){
+                        updateFormDate.put("selectField_m0d9pkzx","未超期");
+                    }
+                    if (date > deadLine && !"已超期".equals(status)){
+                        updateFormDate.put("selectField_m0d9pkzx","已超期");
+                    }
+                }
+
+                if (!updateFormDate.keySet().isEmpty()){
+                    ydClient.operateData(YDParam.builder()
+                            .formInstId(formInstanceId)
+                            .updateFormDataJson(JSONObject.toJSONString(updateFormDate))
+                            .build(), YDConf.FORM_OPERATION.update);
+                }
+
+            }
+        }
+    }
+
+    @Test
+    public void test5(){
+        //分层审核
+        MDC.put("MDC_KEY_PID","1009");
+
+        List<Map> dataList = (List<Map>) ydClient.queryData(YDParam.builder()
+                .formUuid("FORM-F4ED246EADD8427381BC13C4F0FEF7FDYMKJ")//审核任务
+                .pageNumber(1)
+                .pageSize(100)
+                .build(), YDConf.FORM_QUERY.retrieve_list).getData();
+
+        for (Map data : dataList) {
+            String formInstanceId = UtilMap.getString(data, "formInstanceId");
+
+            Map formData = (Map) data.get("formData");
+
+            String status = UtilMap.getString(formData, "selectField_m0dbmfxd");//审核状态
+
+            if (Strings.isNotBlank(status)){
+                Long deadLine = (Long) formData.get("dateField_m061zye7");
+
+                Long date = (Long) formData.get("dateField_m1hod4tv");
+
+                Map updateFormDate = new HashMap();
+
+                if (Objects.isNull(date)){
+                    updateFormDate.put("selectField_m0dbmfxd","已超期");
+                }else {
+                    if (date <= deadLine && !"未超期".equals(status)){
+                        updateFormDate.put("selectField_m0dbmfxd","未超期");
+                    }
+                    if (date > deadLine && !"已超期".equals(status)){
+                        updateFormDate.put("selectField_m0dbmfxd","已超期");
+                    }
+                }
+
+                if (!updateFormDate.keySet().isEmpty()){
+                    ydClient.operateData(YDParam.builder()
+                            .formInstId(formInstanceId)
+                            .updateFormDataJson(JSONObject.toJSONString(updateFormDate))
+                            .build(), YDConf.FORM_OPERATION.update);
+                }
+
+            }
+        }
+    }
 }