灵明光子获取车载不同客户问卷和消费客户问卷回收数

mjava-lingmingguangzi/pom.xml

@@ -62,7 +62,7 @@
     </dependencies>
 
     <build>
-        <finalName>shantai</finalName>
+        <finalName>lingmingguangzi</finalName>
         <plugins>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>

mjava-lingmingguangzi/src/main/java/com/malk/lingmingguangzi/controller/LingmingguangziController.java

@@ -17,4 +17,15 @@ public class LingmingguangziController {
     public McR test() {
         return lingmingguangziService.test();
     }
+
+    //获取‘客户满意度调查-车载’不同客户数量
+    @GetMapping("/getVehicleCustomerCount")
+    public McR getVehicleCustomerCount() {
+        return lingmingguangziService.getVehicleCustomerCount();
+    }
+
+    @GetMapping("/getConsumeCustomerCount")
+    public McR getConsumeCustomerCount() {
+        return lingmingguangziService.getConsumeCustomerCount();
+    }
 }

mjava-lingmingguangzi/src/main/java/com/malk/lingmingguangzi/service/LingmingguangziService.java

@@ -5,4 +5,16 @@ import com.malk.server.common.McR;
 public interface LingmingguangziService {
     McR test();
 
+    /**
+     * 获取车载不同客户问卷数量
+     * @return
+     */
+    McR getVehicleCustomerCount();
+
+    /**
+     * 获取消费客户问卷数量
+     * @return
+     */
+    McR getConsumeCustomerCount();
+
 }

mjava-lingmingguangzi/src/main/java/com/malk/lingmingguangzi/service/LingmingguangziServiceImpl.java

@@ -1,15 +1,104 @@
 package com.malk.lingmingguangzi.service;
 
+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.DDR_New;
+import com.malk.service.aliwork.YDClient;
+import com.malk.utils.UtilMap;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.*;
+
 @Service
 @Slf4j
 public class LingmingguangziServiceImpl implements LingmingguangziService {
+    @Autowired
+    private YDClient ydClient;
+
+    @Autowired
+    private YDConf ydConf;
+
     @Override
     public McR test() {
         log.info("test");
         return McR.success();
     }
+
+    @Override
+    public McR getVehicleCustomerCount() {
+        DDR_New ddrNew = ydClient.queryData(YDParam.builder()
+                .formUuid("FORM-5CC9748D283C49FC8C8A86EE0529730A4I1D")
+                .build(), YDConf.FORM_QUERY.retrieve_list);
+        List<Map> dataList = (List<Map>) ddrNew.getData();
+        int importantCustomerCount = 0;
+        int orderCustomerCount = 0;
+        int strategicCustomerCount = 0;
+
+        for (Map data : dataList) {
+            Map formData = (Map) data.get("formData");
+            String customerLevel = String.valueOf(formData.get("textField_lx4fx2u1"));
+            switch (customerLevel){
+                case "重要客户": importantCustomerCount++; break;
+                case "订单客户": orderCustomerCount++; break;
+                case "战略客户": strategicCustomerCount++; break;
+            }
+        }
+
+        Map<String,Integer> result = new HashMap<>();
+        result.put("importantCustomerCount", importantCustomerCount);
+        result.put("orderCustomerCount", orderCustomerCount);
+        result.put("strategicCustomerCount", strategicCustomerCount);
+
+        return McR.success(result);
+    }
+
+    @Override
+    public McR getConsumeCustomerCount() {
+        Set<String> customerSet = new HashSet<>();
+
+        //商务端
+        DDR_New ddrNew1 = ydClient.queryData(YDParam.builder()
+                .formUuid("FORM-36BF81FD5E43496FABB060190302A7615WBT")
+                .build(), YDConf.FORM_QUERY.retrieve_list);
+        List<Map> dataList1 = (List<Map>) ddrNew1.getData();
+
+        for (Map data : dataList1) {
+            Map formData = (Map) data.get("formData");
+            String customer = String.valueOf(formData.get("textField_lwq1vxnj"));
+            System.out.println(customer);
+            customerSet.add(customer);
+        }
+
+        //技术端
+        DDR_New ddrNew2 = ydClient.queryData(YDParam.builder()
+                .formUuid("FORM-7AB4677010554E81BAA0AC26A46F1940PTIR")
+                .build(), YDConf.FORM_QUERY.retrieve_list);
+        List<Map> dataList2 = (List<Map>) ddrNew2.getData();
+
+        for (Map data : dataList2) {
+            Map formData = (Map) data.get("formData");
+            String customer = String.valueOf(formData.get("textField_lwq1vxnj"));
+            System.out.println(customer);
+            customerSet.add(customer);
+        }
+
+        //质量端
+        DDR_New ddrNew3 = ydClient.queryData(YDParam.builder()
+                .formUuid("FORM-06A0188FF4E840CA82CBE51604C8C0D6SYTU")
+                .build(), YDConf.FORM_QUERY.retrieve_list);
+        List<Map> dataList3 = (List<Map>) ddrNew3.getData();
+
+        for (Map data : dataList3) {
+            Map formData = (Map) data.get("formData");
+            String customer = String.valueOf(formData.get("textField_lwq1vxnj"));
+            System.out.println(customer);
+            customerSet.add(customer);
+        }
+
+        return McR.success(customerSet.size());
+    }
 }

mjava-lingmingguangzi/src/main/resources/application-dev.yml

@@ -31,12 +31,12 @@ mybatis-plus:
 
 # dingtalk
 dingtalk:
-  agentId: 3088485347
-  appKey: dingryt7ulefpiziveoj
-  appSecret: qBdVqoK1UP9J3yN0ulaKuBmse4nrZPfNbVxjLGjaODGoRqbtws0__f3A5GpD5bLz
-  corpId: ding2c2e3f1dbf2b3ffebc961a6cb783455b
-  aesKey: uCSTfCFVU18QJjECfZTBWyC9mi10qqY1Spuqjl4ghct
-  token: Adib7WsRXHYrLGkOAUNcgl6gLY9nBIIaeprkhfmxGg6ca6atYWWKDkuE
+  agentId: 3128251568
+  appKey: dingptadvrtbwyh9lyyn
+  appSecret: fGWLVUpiYjbw-DDEuK-fJyMwh7av2XfhDhiDNSh28TYciH5So4-SSIwHPDMF_tWx
+  corpId:
+  aesKey:
+  token:
 
   #poc
   #agentId: 2995824312
@@ -55,6 +55,6 @@ teambition:
   OperatorId:    # 公共账号, 需要有操作权限 [牧语]
 # aliwork
 aliwork:
-  appType:
-  systemToken:
+  appType: APP_MOIYIC856NRIBCMXEXVD
+  systemToken: G9666BC1BUHLKS20E7YQRATFDE4F39EOK5QWL06
 

mjava-lingmingguangzi/src/main/resources/application.yml

@@ -1,6 +1,6 @@
 spring:
   profiles:
-    active: prod
+    active: dev
   servlet:
     multipart:
       max-file-size: 100MB

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

@@ -40,7 +40,7 @@ public class DdTest {
 //        stDingProcService.fkdSync("_ynuK9h3RYW4oE06B-D44A06971715048029");
 //        stDingProcService.fkdSync("lReoTnLiRbSreZKodGsyRg06971715650847");
 //        stDingProcService.fkdSync("o2zdfQO-TP6ipxqzZh9cjA06971715405894");
-        stDingProcService.fkdSync("7exy_23hSbmeenjL5oIrsg06971715765099");
+        stDingProcService.fkdSync("XCjqMX0gQ-yyacyP6RpZEw06971717501752");
 
 
     }