Преглед изворни кода

【深爱-4A】【定时调用】

DINGYL пре 2 месеци
родитељ
комит
b5d317138d

+ 16 - 0
src/main/java/com/uas/eis/serviceImpl/SyncResService.java

@@ -0,0 +1,16 @@
+package com.uas.eis.serviceImpl;
+
+import com.uas.eis.dao.BaseDao;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class SyncResService {
+    @Autowired
+    private BaseDao baseDao;
+
+    public void updateSyncResult(String key,String result,String err){
+        String resultSql="update ssoAccountSyncItem set SSO_LASTSYNCTIME=sysdate, SSO_INFO='"+ result +"',SSO_err='"+err+"' where SSO_KEY='"+key+"'";
+        baseDao.execute(resultSql);
+    }
+}

+ 46 - 0
src/main/java/com/uas/eis/task/SyncAccountTask.java

@@ -0,0 +1,46 @@
+package com.uas.eis.task;
+
+import com.uas.eis.serviceImpl.ADSyncService;
+import com.uas.eis.serviceImpl.NetEasyService;
+import com.uas.eis.serviceImpl.SyncResService;
+import com.uas.eis.serviceImpl.YongHService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.Map;
+
+@Component
+public class SyncAccountTask {
+    @Autowired
+    private NetEasyService netEasyService;
+    @Autowired
+    private ADSyncService adSyncService;
+    @Autowired
+    private YongHService yongHService;
+    @Autowired
+    private SyncResService syncResService;
+
+    @Scheduled(cron = "0 0 12,20 * * ?")
+    public void syncNetEasy(){
+        netEasyService.syncNetEasyOrg();
+        netEasyService.syncEmployee();
+    }
+
+    @Scheduled(cron = "0 0 12,20 * * ?")
+    public void syncAD(){
+        adSyncService.syncOrg();
+        adSyncService.syncUser();
+    }
+
+    @Scheduled(cron = "0 0 12,20 * * ?")
+    public void syncYongH() throws Exception {
+        String key="yonghong";
+        String err="";
+        String message="";
+        Map<String,Object> resMap=yongHService.syncEmployee();
+        err = resMap.get("err")==null?"":resMap.get("err").toString();
+        message=resMap.get("message")==null?"":resMap.get("message").toString();
+        syncResService.updateSyncResult(key,message,err);
+    }
+}