Browse Source

1.工作流插件优化
2.Moka工具类优化

Tyx 1 day ago
parent
commit
5455eb7256

+ 1 - 0
code/jyyy/nckd-jimin-jyyy-hr/src/main/java/nckd/jimin/jyyy/hr/plugin/workflow/GetFirstDeptChargerWorkflowPlugin.java

@@ -26,6 +26,7 @@ public class GetFirstDeptChargerWorkflowPlugin implements IWorkflowPlugin {
         log.info(" 获取流程变量 personId : {} ", personId);
         log.info(" 获取流程变量 personId : {} ", personId);
         //获取人员主职部门
         //获取人员主职部门
         Map<String, Object> posOrgRel = DispatchServiceHelper.invokeBizService("hrmp", "hrpi", "IHRPIPersonService", "getPrimaryEmpposorgrel", Long.valueOf(personId));
         Map<String, Object> posOrgRel = DispatchServiceHelper.invokeBizService("hrmp", "hrpi", "IHRPIPersonService", "getPrimaryEmpposorgrel", Long.valueOf(personId));
+        log.info(" posOrgRel : {}", posOrgRel);
         Long adminOrgId = Long.valueOf(posOrgRel.get("adminorg_id").toString());
         Long adminOrgId = Long.valueOf(posOrgRel.get("adminorg_id").toString());
         log.info(" personId对应部门Id : {}", adminOrgId);
         log.info(" personId对应部门Id : {}", adminOrgId);
         //获取一级部门
         //获取一级部门

+ 26 - 0
code/jyyy/nckd-jimin-jyyy-hr/src/main/java/nckd/jimin/jyyy/hr/tsrsc/plugin/util/MokaApiUtil.java

@@ -17,6 +17,8 @@ import nckd.jimin.jyyy.hr.wtc.wtis.util.DingTalkSyncUtil;
 import org.apache.commons.net.util.Base64;
 import org.apache.commons.net.util.Base64;
 
 
 import java.io.IOException;
 import java.io.IOException;
+import java.time.Duration;
+import java.time.LocalDateTime;
 import java.util.Date;
 import java.util.Date;
 import java.util.HashMap;
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Map;
@@ -72,6 +74,18 @@ public class MokaApiUtil {
         return result;
         return result;
     }
     }
 
 
+    public static JSONObject doKingdeePostByHttpClient(String url, JSONObject bodyData) throws IOException {
+        Map<String, String> headers = new HashMap();
+        headers.put("Content-Type", "application/json");
+        headers.put("Accept", "*/*");
+        logger.info(String.format("url[%s],data[%s]", url, bodyData.toJSONString()));
+        System.out.println(String.format("url[%s],data[%s]", url, bodyData.toJSONString()));
+        String responseEntify = HttpClientUtils.postjson(url, headers, bodyData.toJSONString(), 10000, 10000);
+        logger.info(responseEntify);
+        JSONObject result = (JSONObject)JSONObject.parse(responseEntify);
+        return result;
+    }
+
 
 
     /**
     /**
      * 新增调用日志
      * 新增调用日志
@@ -145,5 +159,17 @@ public class MokaApiUtil {
         }
         }
     }
     }
 
 
+    /**
+     * 按分钟漂移
+     * @param offset
+     * @return
+     */
+    public static LocalDateTime offsetMinute(int offset) {
+        LocalDateTime now = LocalDateTime.now();
+        Duration fiveMinutes = Duration.ofMinutes(offset);
+        LocalDateTime fiveMinutesAgo = now.minus(fiveMinutes);
+        return fiveMinutesAgo;
+    }
+
 
 
 }
 }