| | |
| | | import com.ruoyi.common.core.domain.AjaxResult; |
| | | |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | |
| | | /** |
| | | * OA数据同步定时任务(组合任务) |
| | |
| | | private List<OrderClassDTO> getDispatchOrdCode() { |
| | | return orderClassDataService.getDispatchOrderClass(); |
| | | } |
| | | |
| | | private List<Map<String,Object>> getAddressList() { |
| | | return departmentSyncDataService.getAddressList(); |
| | | } |
| | | /** |
| | | * 同步OA数据(部门+用户) |
| | | * 按顺序执行:1. 部门同步 2. 用户同步 |
| | |
| | | log.info("##########开始执行OA数据同步定时任务##########"); |
| | | |
| | | // 第一步:同步部门 |
| | | log.info("【步骤1/2】开始同步部门数据..."); |
| | | AjaxResult deptResult = departmentSyncService.syncBranchDepartments(this.getDept(),this.getServiceOrdCode(),this.getDispatchOrdCode()); |
| | | // log.info("【步骤1/2】开始同步部门数据..."); |
| | | AjaxResult deptResult = departmentSyncService.syncBranchDepartments(this.getDept(),this.getServiceOrdCode(),this.getDispatchOrdCode(),this.getAddressList()); |
| | | |
| | | if (deptResult.get("code").equals(200)) |
| | | { |
| | | log.info("【步骤1/2】部门同步成功: {}", deptResult.get("msg")); |
| | | // log.info("【步骤1/2】部门同步成功: {}", deptResult.get("msg")); |
| | | |
| | | // 第二步:同步用户(只有部门同步成功才执行) |
| | | log.info("【步骤2/2】开始同步用户数据..."); |
| | | // log.info("【步骤2/2】开始同步用户数据..."); |
| | | AjaxResult userResult = userSyncService.syncOaUsers(this.getUserData()); |
| | | |
| | | if (userResult.get("code").equals(200)) |
| | | { |
| | | log.info("【步骤2/2】用户同步成功: {}", userResult.get("msg")); |
| | | log.info("##########OA数据同步定时任务执行完成##########"); |
| | | log.info("总结:部门同步成功,用户同步成功"); |
| | | } |
| | | else |
| | | { |
| | | log.error("【步骤2/2】用户同步失败: {}", userResult.get("msg")); |
| | | log.warn("##########OA数据同步定时任务部分完成##########"); |
| | | log.warn("总结:部门同步成功,用户同步失败"); |
| | | } |
| | | // if (userResult.get("code").equals(200)) |
| | | // { |
| | | // log.info("【步骤2/2】用户同步成功: {}", userResult.get("msg")); |
| | | // log.info("##########OA数据同步定时任务执行完成##########"); |
| | | // log.info("总结:部门同步成功,用户同步成功"); |
| | | // } |
| | | // else |
| | | // { |
| | | // log.error("【步骤2/2】用户同步失败: {}", userResult.get("msg")); |
| | | // log.warn("##########OA数据同步定时任务部分完成##########"); |
| | | // log.warn("总结:部门同步成功,用户同步失败"); |
| | | // } |
| | | } |
| | | else |
| | | { |
| | |
| | | */ |
| | | public void syncOaData(String params) |
| | | { |
| | | log.info("OA数据同步任务参数: {}", params); |
| | | // log.info("OA数据同步任务参数: {}", params); |
| | | syncOaData(); |
| | | } |
| | | |
| | |
| | | { |
| | | try |
| | | { |
| | | log.info("==========开始执行部门同步任务=========="); |
| | | AjaxResult result = departmentSyncService.syncBranchDepartments(this.getDept(),this.getServiceOrdCode(),this.getDispatchOrdCode()); |
| | | // log.info("==========开始执行部门同步任务=========="); |
| | | AjaxResult result = departmentSyncService.syncBranchDepartments(this.getDept(),this.getServiceOrdCode(),this.getDispatchOrdCode(),this.getAddressList()); |
| | | |
| | | if (result.get("code").equals(200)) |
| | | { |