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);
+                }
+
+            }
+        }
+    }
 }

mjava-mc/src/main/java/com/malk/mc/controller/McCjController.java

@@ -0,0 +1,249 @@
+package com.malk.mc.controller;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.malk.server.aliwork.YDConf;
+import com.malk.server.aliwork.YDParam;
+import com.malk.server.common.McR;
+import com.malk.server.dingtalk.DDConf;
+import com.malk.service.aliwork.YDClient;
+import com.malk.service.dingtalk.DDClient;
+import com.malk.utils.UtilMap;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.MDC;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.Map;
+
+@Slf4j
+@RestController
+@RequestMapping("/fangan")
+public class McCjController {
+
+    @Autowired
+    private YDClient ydClient;
+    @Autowired
+    private YDConf ydConf;
+    @Autowired
+    private DDConf ddConf;
+    @Autowired
+    private DDClient dd;
+    @SneakyThrows
+    @PostMapping("/insetXMC")
+    McR insetXMC(@RequestBody JSONObject param) {
+        MDC.put("MDC_KEY_PID","1059");
+//        Map data = UtilServlet.getParamMap(request);
+        String formInstanceId = param.getString("formInstanceId");
+//        String type = param.getString("type");
+        log.info("formInstanceId:{}", formInstanceId);
+//        log.info("type:{}", type);
+        //根据实例ID获取表单数据
+        Map data = (Map) ydClient.queryData(YDParam.builder().formInstId(formInstanceId)
+                .appType(ydConf.getAppType()).systemToken(ydConf.getSystemToken())
+                .userId(ddConf.getOperator()).build(), YDConf.FORM_QUERY.retrieve_id).getFormData();
+        log.info("data:{}", data);
+        String UUID = "";
+
+        String FORMID = "";
+
+        String ZD = "";
+
+
+        String XMLX = data.get("selectField_lt1iahs9").toString();
+
+        String hangye1 = data.get("selectField_lt1iahsi").toString();//行业1
+
+        String hangye2 = data.get("selectField_lt1iahsj").toString();//行业2
+
+        String zyyw = data.get("textField_ltr1vksn").toString();//主营业务
+
+        if (XMLX.equals("投前项目")) {
+
+            FORMID = "textField_ltjj7pre";
+
+            UUID = "FORM-6195AAEC573C4B8C897F173ABA583710X9UE";
+
+            ZD = "associationFormField_lt1jaec6, textField_lt1jaecd, textField_lt1jaecc, selectField_lt1iahs9, selectField_lt1iahsi, selectField_lt1iahsj, textField_ltr1vksn";
+
+
+        } else if (XMLX.equals("投后项目")) {
+
+            FORMID = "textField_ltjj7prg";
+
+            UUID = "FORM-0D46B270FD8D4A7187267CC6E39C5B58QXNP";
+
+            ZD = "associationFormField_lt1ouopy, textField_lt1ouopz, textField_lt1ouoq2, selectField_lt1oy6qj";
+
+        }
+
+
+        log.info("项目池, {}", data);
+
+        if (XMLX.equals("投前项目") || XMLX.equals("投后项目")) {
+
+            List<Map> associations = YDConf.associationForm("APP_PSYQ8H0CVYMKA5PVG8X1", "FORM-496C6B71B5D34E62AA46FB8CAA4FAB69BYTF", formInstanceId, data.get("serialNumberField_lt1i52jt").toString(), null, false);
+
+            log.info("associations: {}", associations);
+
+            log.info("UUID, {}", UUID);
+
+            log.info("ZD, {}", ZD);
+
+            String tquid = ydClient.operateData(YDParam.builder()
+
+                    .appType("APP_PSYQ8H0CVYMKA5PVG8X1")
+
+                    .systemToken("ULD66N81VLRUVLB5E1R6A71CSI0N2NNW5NQ9MP71")
+
+                    .formUuid(UUID)
+
+                    .formDataJson(JSON.toJSONString(UtilMap.map(ZD, associations, data.get("textField_lt1i52ju"), data.get("serialNumberField_lt1i52jt"), XMLX, hangye1, hangye2, zyyw)))//这里
+
+                    .build(), YDConf.FORM_OPERATION.create).toString();////
+
+            if (tquid != "") {
+
+                ydClient.operateData(YDParam.builder()
+
+                        .appType("APP_PSYQ8H0CVYMKA5PVG8X1")
+
+                        .systemToken("ULD66N81VLRUVLB5E1R6A71CSI0N2NNW5NQ9MP71")
+
+                        .formInstanceId(formInstanceId)
+
+                        .updateFormDataJson(JSON.toJSONString(UtilMap.map(FORMID, tquid)))
+
+                        .build(), YDConf.FORM_OPERATION.update);
+
+            }
+
+
+        }
+
+        return McR.success();
+
+    }
+
+    @SneakyThrows
+
+    @PostMapping("/insetTHXM")
+    McR insetTHXM(@RequestBody JSONObject param) {
+        MDC.put("MDC_KEY_PID","1059");
+        String formInstanceId = param.getString("formInstanceId");
+//        String type = param.getString("type");
+        log.info("formInstanceId:{}", formInstanceId);
+//        log.info("type:{}", type);
+        //根据实例ID获取表单数据
+        Map data = (Map) ydClient.queryData(YDParam.builder().formInstId(formInstanceId)
+                .appType(ydConf.getAppType()).systemToken(ydConf.getSystemToken())
+                .userId(ddConf.getOperator()).build(), YDConf.FORM_QUERY.retrieve_id).getFormData();
+        log.info("data:{}", data);
+//        Map data = UtilServlet.getParamMap(request);
+
+
+        if (data.get("selectField_ltxs7o0g").toString().equals("否")) {
+
+
+            List<Map> dataList = (List<Map>) ydClient.queryData(YDParam.builder()
+
+                    .appType("APP_PSYQ8H0CVYMKA5PVG8X1")
+
+                    .systemToken("ULD66N81VLRUVLB5E1R6A71CSI0N2NNW5NQ9MP71")
+
+                    .formUuid("FORM-496C6B71B5D34E62AA46FB8CAA4FAB69BYTF")
+
+                    .searchFieldJson(JSON.toJSONString(UtilMap.map("serialNumberField_lt1i52jt", data.get("textField_lt1jaecc").toString())))
+
+                    .build(), YDConf.FORM_QUERY.retrieve_search_form).getData();
+
+            if (dataList != null && dataList.size() > 0) {
+
+                log.info("dataList:" + dataList);
+
+                String XMCSLID = dataList.get(0).get("formInstanceId").toString();
+
+                String FORMID = "textField_ltjj7prg";
+
+                String UUID = "FORM-0D46B270FD8D4A7187267CC6E39C5B58QXNP";
+
+                String ZD = "associationFormField_lt1ouopy, textField_lt1ouopz, textField_lt1ouoq2, selectField_lt1oy6qj";
+
+                List<Map> associations = YDConf.associationForm("APP_PSYQ8H0CVYMKA5PVG8X1", "FORM-496C6B71B5D34E62AA46FB8CAA4FAB69BYTF", XMCSLID, data.get("textField_lt1jaecc").toString(), null, false);
+
+                String tquid = ydClient.operateData(YDParam.builder()
+
+                        .appType("APP_PSYQ8H0CVYMKA5PVG8X1")
+
+                        .systemToken("ULD66N81VLRUVLB5E1R6A71CSI0N2NNW5NQ9MP71")
+
+                        .formUuid(UUID)
+
+                        .formDataJson(JSON.toJSONString(UtilMap.map(ZD, associations, data.get("textField_lt1jaecd"), data.get("textField_lt1jaecc"), "投后项目")))
+
+                        .build(), YDConf.FORM_OPERATION.create).toString();////
+
+                if (tquid != "") {
+
+                    ydClient.operateData(YDParam.builder()
+
+                            .appType("APP_PSYQ8H0CVYMKA5PVG8X1")
+
+                            .systemToken("ULD66N81VLRUVLB5E1R6A71CSI0N2NNW5NQ9MP71")
+
+                            .formInstanceId(String.valueOf(XMCSLID))
+
+                            .updateFormDataJson(JSON.toJSONString(UtilMap.map(FORMID, tquid)))
+
+                            .build(), YDConf.FORM_OPERATION.update);
+
+                }
+
+            }
+
+            log.info("request, {}", dataList);
+
+        }
+
+        return McR.success();
+
+    }
+
+    @SneakyThrows
+
+    @PostMapping("/report/FAtemporary")
+    McR temporary(@RequestBody Map<String, String> data) {
+
+        MDC.put("MDC_KEY_PID","1059");
+        String formid = data.get("fomid");
+
+        log.info("formid,{}", formid);
+
+        Map formdata = ydClient.queryData(YDParam.builder()
+
+                .appType("APP_PSYQ8H0CVYMKA5PVG8X1")
+
+                .systemToken("ULD66N81VLRUVLB5E1R6A71CSI0N2NNW5NQ9MP71")
+
+                .formUuid("FORM-82D513EC7BA24BD592EB7484C58F6604PWOZ")
+
+                .formInstanceId(String.valueOf(formid))
+
+                .build(), YDConf.FORM_QUERY.retrieve_id).getFormData();
+
+
+        List<Map> list = (List<Map>) JSON.parse(String.valueOf(formdata.get("attachmentField_lt468w10")));
+
+
+        return McR.success(ydClient.convertTemporaryUrl(list.get(0).get("url").toString()));
+
+
+
+    }
+
+}