集晨开发V1完结版

mjava-luyi/src/main/java/com/malk/luyi/controller/KSJC_timer.java

@@ -1,9 +1,11 @@
 package com.malk.luyi.controller;
 
 
+import cn.hutool.json.JSONObject;
 import com.alibaba.fastjson.JSON;
 import com.malk.server.aliwork.YDConf;
 import com.malk.server.aliwork.YDParam;
+import com.malk.server.dingtalk.DDR_New;
 import com.malk.service.aliwork.YDClient;
 import com.malk.utils.UtilMap;
 import lombok.extern.slf4j.Slf4j;
@@ -13,6 +15,10 @@ import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
 @Slf4j
 @Configuration
 @EnableScheduling
@@ -23,44 +29,34 @@ public class KSJC_timer {
     private YDClient ydClient;
     /*集晨判断是否能打卡*/
     //每天早晨7点05分同步数据
- @Scheduled(cron = "0 5 7 * * ?")
-//  @Scheduled(fixedRate = 1000)
+ //@Scheduled(cron = "0 5 7 * * ?")
+ // @Scheduled(fixedRate = 500)
     public void LegalEntityList(){
         log.info("k");
+      System.out.println("开始同步");
         try{
-           legalEntityService.insetTHXM_TMER();
-//            String XMCSLID="FINST-3RB66I91VT5OZPGY8CWOD9237ZDD2KPZ5KH0MYK8";
-//            if (true)
-//            {
-//                ydClient.operateData(YDParam.builder()
-//                        .appType("APP_X89Y00KKTG36B8JYGZVR")
-//                        .systemToken("QIA66091HJPLRHM3AUFJLCN24CUP2VNMO41XLW4")
-//                        .formInstanceId(String.valueOf(XMCSLID))
-//                        //data.get("shop_name")
-//                        .updateFormDataJson(JSON.toJSONString(UtilMap.map("textField_m0hk58mb", "ceshi")))
-//                        .build(), YDConf.FORM_OPERATION.update);
-//            }
-            System.out.println("集晨判断，同步完成");
+            legalEntityService.insetTHXM_TMER();
+             System.out.println("集晨判断，同步完成");
         }catch (Exception e){
             //记录错误信息
             e.printStackTrace();
         }
-
     }
 
 
 
     //    @Scheduled(cron = "0 5 7 * * ?")
-    public void LegalEntityList1(){
-        log.info("k");
-        try{
-            legalEntityService.insetTHXM_TMER1();
-            System.out.println("集晨判断，同步完成");
-        }catch (Exception e){
-            //记录错误信息
-            e.printStackTrace();
-        }
-
-    }
+//    public void LegalEntityList1(){
+//        log.info("k");
+//        try{
+//            System.out.println("开始同步项目数据");
+//            legalEntityService.insetTHXM_TMER1();
+//            System.out.println("集晨判断，同步完成");
+//        }catch (Exception e){
+//            //记录错误信息
+//            e.printStackTrace();
+//        }
+//
+//    }
 
 }

mjava/src/main/java/com/malk/service/dingtalk/DDClient.java

@@ -1,5 +1,6 @@
 package com.malk.service.dingtalk;
 
+import java.time.LocalDate;
 import java.util.Map;
 
 public interface DDClient {
@@ -42,5 +43,6 @@ public interface DDClient {
 
     Map getgroupquery(String op_user_id,String  group_id );//调用本接口，可获取考勤组名称、考勤组主负责人和考勤类型等信息。
     Map updateuploadss(String userid,String  device_name,String device_id,String user_check_time );//上传打卡记录。
+    Map getupdatedata(String userid, LocalDate  work_date);//获取用户考勤数据
 }
 

mjava/src/main/java/com/malk/service/dingtalk/impl/DDImplClient.java

@@ -12,6 +12,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDate;
 import java.util.HashMap;
 import java.util.Map;
 
@@ -215,4 +216,19 @@ public class DDImplClient implements DDClient {
 
     }
 
+    public Map  getupdatedata(String userid, LocalDate  work_date){
+        Map param = new HashMap();
+        param.put("appkey", "dingapqprcbwk5bvahc1");
+        param.put("appsecret", "V_YgI8ZYx3lSf_Fw3qNH6k-U9umKhxglpPrnPkdb73CVrXWFme_SwUCdQxR2poFi");
+        DDR r = (DDR) UtilHttp.doGet("https://oapi.dingtalk.com/gettoken", param, DDR.class);
+        log.info("响应token, {}", r.getAccessToken());
+        String accessToken = r.getAccessToken();
+        // token失效自动重置: DD重新调用会重置过期时间
+        UtilToken.put("invalid-token-dingtalk", accessToken, r.getExpiresIn() * 1000L);
+        Map param_post = new HashMap();
+        param_post.put("userid",userid);//获取考勤信息的员工userId
+    param_post.put("work_date",work_date);//查询日期
+        return  (Map)  DDR.doPost("https://oapi.dingtalk.com/topapi/attendance/getupdatedata", null, DDConf.initTokenParams(accessToken), param_post ).getResult();
+    }
+
 }