From c1ca1d53725ae935cd09113a68ed9a36528323ae Mon Sep 17 00:00:00 2001 From: yangchaojin <549193112@qq.com> Date: Wed, 21 Jan 2026 17:26:41 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=BB=E5=8A=A1717=E3=80=81718=EF=BC=8C?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0iwork=E5=90=8C=E6=AD=A5=E5=8F=82=E6=95=B0?= =?UTF-8?q?=E4=BB=A5=E5=8F=8A=E5=BD=93=E6=97=A5=E5=8F=98=E6=9B=B4=E7=94=A8?= =?UTF-8?q?=E6=88=B7=E5=90=8C=E6=AD=A5=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iwork/vo/IWorkFullSyncReqVO.java | 61 +++++++++++++++++++ .../job/sync/SyncIWorkUserChangeJob.java | 39 ++++++++++++ .../sync/SyncIWorkUserChangeService.java | 14 +++++ .../sync/SyncIWorkUserChangeServiceImpl.java | 34 +++++++++++ 4 files changed, 148 insertions(+) create mode 100644 zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/job/sync/SyncIWorkUserChangeJob.java create mode 100644 zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/sync/SyncIWorkUserChangeService.java create mode 100644 zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/sync/SyncIWorkUserChangeServiceImpl.java diff --git a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/controller/admin/integration/iwork/vo/IWorkFullSyncReqVO.java b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/controller/admin/integration/iwork/vo/IWorkFullSyncReqVO.java index e3793181..fb95db8a 100644 --- a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/controller/admin/integration/iwork/vo/IWorkFullSyncReqVO.java +++ b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/controller/admin/integration/iwork/vo/IWorkFullSyncReqVO.java @@ -1,5 +1,6 @@ package com.zt.plat.module.system.controller.admin.integration.iwork.vo; +import com.fasterxml.jackson.annotation.JsonProperty; import com.zt.plat.module.system.enums.integration.IWorkSyncEntityTypeEnum; import io.swagger.v3.oas.annotations.media.Schema; import jakarta.validation.constraints.Max; @@ -42,6 +43,66 @@ public class IWorkFullSyncReqVO { @Schema(description = "是否允许更新已存在的本地实体", example = "false") private Boolean allowUpdate = Boolean.FALSE; + @JsonProperty("departmentcode") + @Schema(description = "部门编号") + private String departmentCode; + + @JsonProperty("departmentname") + @Schema(description = "部门名称") + private String departmentName; + + @JsonProperty("subcompanycode") + @Schema(description = "分部编号") + private String subcompanyCode; + + @JsonProperty("subcompanyname") + @Schema(description = "分部名称") + private String subcompanyName; + + @JsonProperty("subcompanyid1") + @Schema(description = "分部 ID") + private String subcompanyId1; + + @JsonProperty("jobtitlename") + @Schema(description = "岗位名称") + private String jobTitleName; + + @JsonProperty("workcode") + @Schema(description = "人员编号") + private String workCode; + + @JsonProperty("loginid") + @Schema(description = "登录名") + private String loginId; + + @JsonProperty("created") + @Schema(description = "创建时间戳（>=）") + private String created; + + @JsonProperty("modified") + @Schema(description = "修改时间戳（>=）") + private String modified; + + @JsonProperty("canceled") + @Schema(description = "封存标志，默认查询非封存数据。1:封存") + private String canceled; + + @JsonProperty("custom_data") + @Schema(description = "自定义字段列表（逗号分隔）") + private String customData; + + @JsonProperty("base_custom_data") + @Schema(description = "基本信息自定义字段列表（逗号分隔）") + private String baseCustomData; + + @JsonProperty("person_custom_data") + @Schema(description = "个人信息自定义字段列表（逗号分隔）") + private String personCustomData; + + @JsonProperty("work_custom_data") + @Schema(description = "工作信息自定义字段列表（逗号分隔）") + private String workCustomData; + public Set resolveScopes() { EnumSet defaults = EnumSet.allOf(IWorkSyncEntityTypeEnum.class); if (scopes == null || scopes.isEmpty()) { diff --git a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/job/sync/SyncIWorkUserChangeJob.java b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/job/sync/SyncIWorkUserChangeJob.java new file mode 100644 index 00000000..602c8402 --- /dev/null +++ b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/job/sync/SyncIWorkUserChangeJob.java @@ -0,0 +1,39 @@ +package com.zt.plat.module.system.job.sync; + +import com.xxl.job.core.handler.annotation.XxlJob; +import com.zt.plat.framework.tenant.core.job.TenantJob; +import com.zt.plat.module.system.service.sync.SyncIWorkUserChangeService; +import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +/** + * 用于定时同步iWork当日修改的用户数据 + * 同步时间：每日23:00 + */ +@Component +@Slf4j +public class SyncIWorkUserChangeJob { + + @Resource + private SyncIWorkUserChangeService syncIWorkUserChangeService; + + /** + * 执行批量重跑任务 + * 配置执行频率：每日23:00时执行一次 + * cron表达式：0 0 23 * * ? + */ + @XxlJob("syncIWorkUserChangeJob") + @TenantJob + public void execute() { + log.info("[syncLogBatchRerunJob][开始执行同步iWork当日变更用户任务]"); + try{ + int processedCount = syncIWorkUserChangeService.process(); + if (processedCount > 0) { + log.info("[syncLogBatchRerunJob][同步任务执行完成，处理了 {} 条记录]", processedCount); + } + } catch (Exception e) { + log.error("[syncLogBatchRerunJob][同步iWork当日变更用户任务执行异常]", e); + } + } +} diff --git a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/sync/SyncIWorkUserChangeService.java b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/sync/SyncIWorkUserChangeService.java new file mode 100644 index 00000000..dc3f3418 --- /dev/null +++ b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/sync/SyncIWorkUserChangeService.java @@ -0,0 +1,14 @@ +package com.zt.plat.module.system.service.sync; + +/** + * 同步iWork当日修改的用户数据 + */ +public interface SyncIWorkUserChangeService { + + /** + * 同步入口 + * @return + */ + int process(); + +} diff --git a/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/sync/SyncIWorkUserChangeServiceImpl.java b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/sync/SyncIWorkUserChangeServiceImpl.java new file mode 100644 index 00000000..fb70d8d3 --- /dev/null +++ b/zt-module-system/zt-module-system-server/src/main/java/com/zt/plat/module/system/service/sync/SyncIWorkUserChangeServiceImpl.java @@ -0,0 +1,34 @@ +package com.zt.plat.module.system.service.sync; + +import com.zt.plat.module.system.controller.admin.integration.iwork.vo.IWorkFullSyncReqVO; +import com.zt.plat.module.system.controller.admin.integration.iwork.vo.IWorkFullSyncRespVO; +import com.zt.plat.module.system.service.integration.iwork.IWorkSyncService; +import jakarta.annotation.Resource; +import org.springframework.stereotype.Service; + +import java.time.LocalDate; +import java.time.ZoneId; +import java.time.format.DateTimeFormatter; + +@Service +public class SyncIWorkUserChangeServiceImpl implements SyncIWorkUserChangeService { + + @Resource + private IWorkSyncService iWorkSyncService; + + @Override + public int process() { + IWorkFullSyncReqVO reqVO = new IWorkFullSyncReqVO(); + reqVO.setPageSize(10); + // 设置修改日期的查询条件为当日0时起 + ZoneId zone = ZoneId.of("Asia/Shanghai"); + String startOfToday = LocalDate.now(zone) + .atStartOfDay(zone) + .format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); + reqVO.setModified(startOfToday); + IWorkFullSyncRespVO respVO = iWorkSyncService.fullSyncUsers(reqVO); + if(respVO!=null && respVO.getProcessedPages()!=null && respVO.getPageSize()!=null) + return respVO.getProcessedPages() * respVO.getPageSize(); + return 0; + } +}