From 76d0b5f0b7111f8aa04c28ac398add48ff6ed1c2 Mon Sep 17 00:00:00 2001 From: zhangyue Date: Fri, 24 Apr 2026 11:44:35 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=90=8C=E6=AD=A5=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=E5=8A=9F=E8=83=BD=E5=AE=9E=E7=8E=B0=E5=88=86=E9=A1=B5?= =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- web-adapter/pom.xml | 4 + .../aspect/SyncResponseEncryptAspect.java | 221 ++++++++++++++++++ .../basic/info/web/sync/SyncController.java | 38 +++ .../sync/SyncDepartmentCoConvertor.java | 25 ++ .../convertor/sync/SyncUserCoConvertor.java | 31 +++ .../info/command/query/sync/SyncQueryExe.java | 52 +++++ .../info/service/CorpInfoKeyService.java | 17 ++ .../info/service/sync/SyncServiceImpl.java | 38 +++ web-client/pom.xml | 8 + .../basic/info/api/sync/SyncServiceI.java | 19 ++ .../clientobject/sync/SyncDepartmentCO.java | 25 ++ .../dto/clientobject/sync/SyncUserCO.java | 61 +++++ .../dto/sync/SyncDepartmentQryPageCmd.java | 36 +++ .../basic/info/dto/sync/SyncUserQryCmd.java | 48 ++++ .../info/dto/sync/SyncUserQryPageCmd.java | 43 ++++ .../persistence/dataobject/CorpInfoKeyDO.java | 29 +++ .../dataobject/sync/SyncDepartmentDO.java | 33 +++ .../dataobject/sync/SyncUserDO.java | 73 ++++++ .../persistence/mapper/CorpInfoKeyMapper.java | 9 + .../mapper/sync/SyncDepartmentMapper.java | 23 ++ .../mapper/sync/SyncUserMapper.java | 30 +++ .../repository/CorpInfoKeyRepository.java | 9 + .../impl/CorpInfoKeyRepositoryImpl.java | 19 ++ .../sync/SyncDepartmentRepositoryImpl.java | 40 ++++ .../impl/sync/SyncUserRepositoryImpl.java | 38 +++ .../sync/SyncDepartmentRepository.java | 19 ++ .../repository/sync/SyncUserRepository.java | 25 ++ .../basic/info/utils/SyncPageResponse.java | 129 ++++++++++ .../mapper/sync/SyncDepartmentMapper.xml | 27 +++ .../resources/mapper/sync/SyncUserMapper.xml | 67 ++++++ 30 files changed, 1236 insertions(+) create mode 100644 web-adapter/src/main/java/com/zcloud/basic/info/aspect/SyncResponseEncryptAspect.java create mode 100644 web-adapter/src/main/java/com/zcloud/basic/info/web/sync/SyncController.java create mode 100644 web-app/src/main/java/com/zcloud/basic/info/command/convertor/sync/SyncDepartmentCoConvertor.java create mode 100644 web-app/src/main/java/com/zcloud/basic/info/command/convertor/sync/SyncUserCoConvertor.java create mode 100644 web-app/src/main/java/com/zcloud/basic/info/command/query/sync/SyncQueryExe.java create mode 100644 web-app/src/main/java/com/zcloud/basic/info/service/CorpInfoKeyService.java create mode 100644 web-app/src/main/java/com/zcloud/basic/info/service/sync/SyncServiceImpl.java create mode 100644 web-client/src/main/java/com/zcloud/basic/info/api/sync/SyncServiceI.java create mode 100644 web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/sync/SyncDepartmentCO.java create mode 100644 web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/sync/SyncUserCO.java create mode 100644 web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncDepartmentQryPageCmd.java create mode 100644 web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncUserQryCmd.java create mode 100644 web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncUserQryPageCmd.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/CorpInfoKeyDO.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/sync/SyncDepartmentDO.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/sync/SyncUserDO.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/CorpInfoKeyMapper.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/sync/SyncDepartmentMapper.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/sync/SyncUserMapper.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/CorpInfoKeyRepository.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/CorpInfoKeyRepositoryImpl.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/sync/SyncDepartmentRepositoryImpl.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/sync/SyncUserRepositoryImpl.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/sync/SyncDepartmentRepository.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/sync/SyncUserRepository.java create mode 100644 web-infrastructure/src/main/java/com/zcloud/basic/info/utils/SyncPageResponse.java create mode 100644 web-infrastructure/src/main/resources/mapper/sync/SyncDepartmentMapper.xml create mode 100644 web-infrastructure/src/main/resources/mapper/sync/SyncUserMapper.xml diff --git a/web-adapter/pom.xml b/web-adapter/pom.xml index ad4ea89d..74b50006 100644 --- a/web-adapter/pom.xml +++ b/web-adapter/pom.xml @@ -30,5 +30,9 @@ com.jjb.saas jjb-saas-framework-job + + org.springframework.boot + spring-boot-starter-aop + diff --git a/web-adapter/src/main/java/com/zcloud/basic/info/aspect/SyncResponseEncryptAspect.java b/web-adapter/src/main/java/com/zcloud/basic/info/aspect/SyncResponseEncryptAspect.java new file mode 100644 index 00000000..887f2e1b --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/basic/info/aspect/SyncResponseEncryptAspect.java @@ -0,0 +1,221 @@ +package com.zcloud.basic.info.aspect; + +import com.alibaba.cola.dto.SingleResponse; +import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONArray; +import com.alibaba.fastjson.JSONObject; +import com.zcloud.basic.info.persistence.dataobject.CorpInfoKeyDO; +import com.zcloud.basic.info.service.CorpInfoKeyService; +import com.zcloud.basic.info.utils.SyncPageResponse; +import com.zcloud.gbscommon.utils.Sm2Util; +import lombok.extern.slf4j.Slf4j; +import org.aspectj.lang.ProceedingJoinPoint; +import org.aspectj.lang.annotation.Around; +import org.aspectj.lang.annotation.Aspect; +import org.aspectj.lang.annotation.Pointcut; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import javax.servlet.http.HttpServletRequest; +import java.util.ArrayList; +import java.util.List; +import java.util.Objects; + +//@Aspect +//@Component +@Slf4j +public class SyncResponseEncryptAspect { + + @Autowired + private CorpInfoKeyService corpInfoKeyService; + + private static final long TIMESTAMP_TOLERANCE = 5 * 60 * 1000L; + + @Pointcut("execution(* com.zcloud.basic.info.web.sync.SyncController.*(..))") + public void syncControllerPointcut() {} + + @Around("syncControllerPointcut()") + public Object encrypt(ProceedingJoinPoint joinPoint) throws Throwable { + HttpServletRequest request = getHttpServletRequest(); + + String corpinfoId = request.getHeader("X-CORPINFO-ID"); + String timestamp = request.getHeader("X-TIMESTAMP"); + String signature = request.getHeader("X-SIGNATURE"); + + if (corpinfoId == null || timestamp == null || signature == null) { + throw new SecurityException("缺少必要的认证头信息"); + } + + long requestTime = Long.parseLong(timestamp); +// if (Math.abs(System.currentTimeMillis() - requestTime) > TIMESTAMP_TOLERANCE) { +// throw new SecurityException("请求已过期"); +// } + + CorpInfoKeyDO keyDO = corpInfoKeyService.getByCorpinfoId(Long.parseLong(corpinfoId)); + if (keyDO == null) { + throw new SecurityException("未找到对应的密钥配置"); + } + if (keyDO.getPublicKey() == null || keyDO.getSignKey() == null) { + throw new SecurityException("密钥配置不完整"); + } + + String body = getRequestBody(joinPoint); + + if (!sm2Verify(signature, corpinfoId, timestamp, body, keyDO)) { + throw new SecurityException("签名验证失败"); + } + + Object result = joinPoint.proceed(); + if (result == null) { + return result; + } + + String className = result.getClass().getName(); + if (className.contains("SingleResponse")) { + SingleResponse response = (SingleResponse) result; + Object data = response.getData(); + if (data != null) { + response.setData(encryptData(data, keyDO.getPublicKey())); + } + } else if (className.contains("SyncPageResponse") || className.contains("PageResponse") || className.contains("MultiResponse")) { + SyncPageResponse response = (SyncPageResponse) result; + Object data = response.getData(); + if (data != null) { + response.setData(encryptData(data, keyDO.getPublicKey())); + } + } + + return result; + } + + private HttpServletRequest getHttpServletRequest() { + return ((org.springframework.web.context.request.ServletRequestAttributes) + org.springframework.web.context.request.RequestContextHolder.getRequestAttributes()) + .getRequest(); + } + + private String getRequestBody(ProceedingJoinPoint joinPoint) { + Object[] args = joinPoint.getArgs(); + if (args != null && args.length > 0) { + for (Object arg : args) { + if (arg != null && !(arg instanceof HttpServletRequest)) { + return JSON.toJSONString(arg); + } + } + } + return ""; + } + +private boolean sm2Verify(String signature, String corpinfoId, String timestamp, String body, CorpInfoKeyDO keyDO) { + try { + String decrypted = Sm2Util.decryptBase64(signature, keyDO.getSignPrivateKey()); + JSONObject json = JSON.parseObject(decrypted); + + String jsonCorpinfoId = json.getString("corpinfoId"); + String jsonTimestamp = json.getString("timestamp"); + String jsonBody = json.getString("body"); + + if (!corpinfoId.equals(jsonCorpinfoId)) { + log.warn("corpinfoId不匹配: expected={}, actual={}", corpinfoId, jsonCorpinfoId); + return false; + } + if (!timestamp.equals(jsonTimestamp)) { + log.warn("timestamp不匹配: expected={}, actual={}", timestamp, jsonTimestamp); + return false; + } + // 将body 和 jsonBody 都转换成 JSONObject 并比较其中的字段是否相同，值是否相同 + JSONObject jsonBodyObject = JSON.parseObject(jsonBody); + JSONObject bodyObject = JSON.parseObject(body); + + if (!isJsonEqualsIgnoreArrayOrder(jsonBodyObject, bodyObject)) { + log.warn("body不匹配: expected={}, actual={}", body, jsonBody); + return false; + } + return true; + } catch (Exception e) { + log.error("SM2解密或验证异常: {}", e.getMessage()); + return false; + } + } + private Object encryptData(Object data, String publicKey) { + return Sm2Util.encryptHex(JSON.toJSONString(data), publicKey); + } + + private boolean isJsonEqualsIgnoreArrayOrder(Object obj1, Object obj2) { + // 都是 null + if (obj1 == null && obj2 == null) { + return true; + } + // 一个 null 一个不是 + if (obj1 == null || obj2 == null) { + return false; + } + + // 类型不一样 + if (!obj1.getClass().equals(obj2.getClass())) { + return false; + } + + // 如果是 JSONObject + if (obj1 instanceof JSONObject) { + JSONObject json1 = (JSONObject) obj1; + JSONObject json2 = (JSONObject) obj2; + + // 对比 key 集合是否一致 + if (!json1.keySet().equals(json2.keySet())) { + return false; + } + + // 递归对比每个 value + for (String key : json1.keySet()) { + Object val1 = json1.get(key); + Object val2 = json2.get(key); + if (!isJsonEqualsIgnoreArrayOrder(val1, val2)) { + return false; + } + } + return true; + } else if (obj1 instanceof JSONArray) { + JSONArray arr1 = (JSONArray) obj1; + JSONArray arr2 = (JSONArray) obj2; + + if (arr1.size() != arr2.size()) { + return false; + } + + // 转成 List 后排序 + List list1 = new ArrayList<>(arr1); + List list2 = new ArrayList<>(arr2); + + // 排序（基础类型、对象都能排） + sortJsonList(list1); + sortJsonList(list2); + + // 递归对比每一个元素 + for (int i = 0; i < list1.size(); i++) { + if (!isJsonEqualsIgnoreArrayOrder(list1.get(i), list2.get(i))) { + return false; + } + } + return true; + } + + // 普通值（字符串、数字、布尔、null）直接对比 + else { + return Objects.equals(obj1, obj2); + } + } + /** + * 排序 JSON 数组（支持对象、基础类型） + */ + private void sortJsonList(List list) { + list.sort((o1, o2) -> { + if (o1 == null && o2 == null) return 0; + if (o1 == null) return -1; + if (o2 == null) return 1; + // 转成字符串比较（保证任何类型都能排序） + return o1.toString().compareTo(o2.toString()); + }); + } + +} diff --git a/web-adapter/src/main/java/com/zcloud/basic/info/web/sync/SyncController.java b/web-adapter/src/main/java/com/zcloud/basic/info/web/sync/SyncController.java new file mode 100644 index 00000000..7d187813 --- /dev/null +++ b/web-adapter/src/main/java/com/zcloud/basic/info/web/sync/SyncController.java @@ -0,0 +1,38 @@ +package com.zcloud.basic.info.web.sync; + +import com.zcloud.basic.info.api.sync.SyncServiceI; +import com.zcloud.basic.info.dto.sync.SyncDepartmentQryPageCmd; +import com.zcloud.basic.info.dto.sync.SyncUserQryPageCmd; +import com.zcloud.basic.info.utils.SyncPageResponse; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.AllArgsConstructor; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @author zhangyue + * @date 2026/4/23 9:45 + */ +@Api(tags = "同步信息") +@RequestMapping("/${application.gateway}/sync") +@RestController +@AllArgsConstructor +public class SyncController { + + private final SyncServiceI syncServiceI; + @ApiOperation("获取用户数据") + @PostMapping("/user/listPage") + public SyncPageResponse listPageSyncUser(@Validated @RequestBody SyncUserQryPageCmd cmd) { + return syncServiceI.listPageSyncUser(cmd); + } + + @ApiOperation("获取部门数据") + @PostMapping("/department/listPage") + public SyncPageResponse listPageSyncDepartment(@Validated @RequestBody SyncDepartmentQryPageCmd cmd) { + return syncServiceI.listPageSyncDepartment(cmd); + } +} diff --git a/web-app/src/main/java/com/zcloud/basic/info/command/convertor/sync/SyncDepartmentCoConvertor.java b/web-app/src/main/java/com/zcloud/basic/info/command/convertor/sync/SyncDepartmentCoConvertor.java new file mode 100644 index 00000000..f5342cd3 --- /dev/null +++ b/web-app/src/main/java/com/zcloud/basic/info/command/convertor/sync/SyncDepartmentCoConvertor.java @@ -0,0 +1,25 @@ +package com.zcloud.basic.info.command.convertor.sync; + +import com.zcloud.basic.info.dto.clientobject.sync.SyncDepartmentCO; +import com.zcloud.basic.info.dto.clientobject.sync.SyncUserCO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncDepartmentDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; +import org.mapstruct.Mapper; + +import java.util.List; + + +/** +* web-app +* @Author zhangyue +* @Date 2025-11-04 14:07:34 +*/ +@Mapper(componentModel = "spring") +public interface SyncDepartmentCoConvertor { + /** + * @param userDOs + * @return + */ + List converDOsToCOs(List departmentDOs); +} + diff --git a/web-app/src/main/java/com/zcloud/basic/info/command/convertor/sync/SyncUserCoConvertor.java b/web-app/src/main/java/com/zcloud/basic/info/command/convertor/sync/SyncUserCoConvertor.java new file mode 100644 index 00000000..9fba32d6 --- /dev/null +++ b/web-app/src/main/java/com/zcloud/basic/info/command/convertor/sync/SyncUserCoConvertor.java @@ -0,0 +1,31 @@ +package com.zcloud.basic.info.command.convertor.sync; + +import com.jjb.saas.system.client.user.request.FacadeUserAddCmd; +import com.zcloud.basic.info.domain.model.UserE; +import com.zcloud.basic.info.dto.clientobject.UserCO; +import com.zcloud.basic.info.dto.clientobject.UserXmfCO; +import com.zcloud.basic.info.dto.clientobject.sync.SyncUserCO; +import com.zcloud.basic.info.persistence.dataobject.UserDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; +import com.zcloud.gbscommon.excelEntity.UserExcelExportEntity; +import com.zcloud.gbscommon.excelEntity.UserExcelImportEntity; +import com.zcloud.gbscommon.zclouduser.response.ZcloudUserCo; +import org.mapstruct.Mapper; + +import java.util.List; + + +/** +* web-app +* @Author zhangyue +* @Date 2025-11-04 14:07:34 +*/ +@Mapper(componentModel = "spring") +public interface SyncUserCoConvertor { + /** + * @param userDOs + * @return + */ + List converDOsToCOs(List userDOs); +} + diff --git a/web-app/src/main/java/com/zcloud/basic/info/command/query/sync/SyncQueryExe.java b/web-app/src/main/java/com/zcloud/basic/info/command/query/sync/SyncQueryExe.java new file mode 100644 index 00000000..9b3e3972 --- /dev/null +++ b/web-app/src/main/java/com/zcloud/basic/info/command/query/sync/SyncQueryExe.java @@ -0,0 +1,52 @@ +package com.zcloud.basic.info.command.query.sync; + +import com.alibaba.cola.dto.PageResponse; +import com.alibaba.fastjson.JSON; +import com.zcloud.basic.info.command.convertor.sync.SyncDepartmentCoConvertor; +import com.zcloud.basic.info.command.convertor.sync.SyncUserCoConvertor; +import com.zcloud.basic.info.dto.clientobject.sync.SyncDepartmentCO; +import com.zcloud.basic.info.dto.clientobject.sync.SyncUserCO; +import com.zcloud.basic.info.dto.sync.SyncDepartmentQryPageCmd; +import com.zcloud.basic.info.dto.sync.SyncUserQryPageCmd; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncDepartmentDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; +import com.zcloud.basic.info.persistence.repository.sync.SyncDepartmentRepository; +import com.zcloud.basic.info.persistence.repository.sync.SyncUserRepository; +import com.zcloud.basic.info.utils.SyncPageResponse; +import com.zcloud.gbscommon.utils.PageQueryHelper; +import lombok.AllArgsConstructor; +import org.springframework.stereotype.Component; + +import java.util.List; +import java.util.Map; + + +/** + * web-app + * + * @Author zhangyue + * @Date 2025-11-04 14:07:36 + */ +@Component +@AllArgsConstructor +public class SyncQueryExe { + private final SyncUserRepository syncUserRepository; + private final SyncUserCoConvertor syncUserCoConvertor; + private final SyncDepartmentRepository syncDepartmentRepository; + private final SyncDepartmentCoConvertor syncDepartmentCoConvertor; + public SyncPageResponse listPageSyncUser(SyncUserQryPageCmd cmd) { + Map params = PageQueryHelper.toHashMap(cmd); + PageResponse pageResponse = syncUserRepository.listPageSyncUser(params); + List userCOList = syncUserCoConvertor.converDOsToCOs(pageResponse.getData()); + + return SyncPageResponse.of(userCOList, pageResponse.getTotalCount(), pageResponse.getPageSize(), pageResponse.getPageIndex()); + } + public SyncPageResponse listPageSyncDepartment(SyncDepartmentQryPageCmd cmd) { + Map params = PageQueryHelper.toHashMap(cmd); + PageResponse pageResponse = syncDepartmentRepository.listPageSyncDepartment(params); + List userCOList = syncDepartmentCoConvertor.converDOsToCOs(pageResponse.getData()); + + return SyncPageResponse.of(userCOList, pageResponse.getTotalCount(), pageResponse.getPageSize(), pageResponse.getPageIndex()); + } +} + diff --git a/web-app/src/main/java/com/zcloud/basic/info/service/CorpInfoKeyService.java b/web-app/src/main/java/com/zcloud/basic/info/service/CorpInfoKeyService.java new file mode 100644 index 00000000..e1085072 --- /dev/null +++ b/web-app/src/main/java/com/zcloud/basic/info/service/CorpInfoKeyService.java @@ -0,0 +1,17 @@ +package com.zcloud.basic.info.service; + +import com.zcloud.basic.info.persistence.dataobject.CorpInfoKeyDO; +import com.zcloud.basic.info.persistence.repository.CorpInfoKeyRepository; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Service; + +@Service +@RequiredArgsConstructor +public class CorpInfoKeyService { + + private final CorpInfoKeyRepository corpInfoKeyRepository; + + public CorpInfoKeyDO getByCorpinfoId(Long corpinfoId) { + return corpInfoKeyRepository.getByCorpinfoId(corpinfoId); + } +} diff --git a/web-app/src/main/java/com/zcloud/basic/info/service/sync/SyncServiceImpl.java b/web-app/src/main/java/com/zcloud/basic/info/service/sync/SyncServiceImpl.java new file mode 100644 index 00000000..43a280e6 --- /dev/null +++ b/web-app/src/main/java/com/zcloud/basic/info/service/sync/SyncServiceImpl.java @@ -0,0 +1,38 @@ +package com.zcloud.basic.info.service.sync; + +import com.alibaba.cola.dto.PageResponse; +import com.zcloud.basic.info.api.sync.SyncServiceI; +import com.zcloud.basic.info.command.query.sync.SyncQueryExe; +import com.zcloud.basic.info.dto.clientobject.sync.SyncUserCO; +import com.zcloud.basic.info.dto.sync.SyncDepartmentQryPageCmd; +import com.zcloud.basic.info.dto.sync.SyncUserQryCmd; +import com.zcloud.basic.info.dto.sync.SyncUserQryPageCmd; +import com.zcloud.basic.info.utils.SyncPageResponse; +import lombok.AllArgsConstructor; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * web-app + * + * @Author zhangyue + * @Date 2025-11-04 14:07:37 + */ +@Service +@AllArgsConstructor +public class SyncServiceImpl implements SyncServiceI { + private final SyncQueryExe syncQueryExe; + + @Override + public SyncPageResponse listPageSyncUser(SyncUserQryPageCmd cmd) { + return syncQueryExe.listPageSyncUser(cmd); + } + + @Override + public SyncPageResponse listPageSyncDepartment(SyncDepartmentQryPageCmd cmd) { + return syncQueryExe.listPageSyncDepartment(cmd); + } + +} + diff --git a/web-client/pom.xml b/web-client/pom.xml index 21e5eab0..2481acab 100644 --- a/web-client/pom.xml +++ b/web-client/pom.xml @@ -46,5 +46,13 @@ javax.validation validation-api + + com.zcloud.basic.info + web-infrastructure + + + com.zcloud.basic.info + web-infrastructure + diff --git a/web-client/src/main/java/com/zcloud/basic/info/api/sync/SyncServiceI.java b/web-client/src/main/java/com/zcloud/basic/info/api/sync/SyncServiceI.java new file mode 100644 index 00000000..191723c5 --- /dev/null +++ b/web-client/src/main/java/com/zcloud/basic/info/api/sync/SyncServiceI.java @@ -0,0 +1,19 @@ +package com.zcloud.basic.info.api.sync; + + +import com.zcloud.basic.info.dto.sync.SyncDepartmentQryPageCmd; +import com.zcloud.basic.info.dto.sync.SyncUserQryPageCmd; +import com.zcloud.basic.info.utils.SyncPageResponse; + +/** +* web-client +* @Author zhangyue +* @Date 2025-11-04 14:07:37 +*/ +public interface SyncServiceI { + SyncPageResponse listPageSyncUser(SyncUserQryPageCmd cmd); + SyncPageResponse listPageSyncDepartment(SyncDepartmentQryPageCmd cmd); + + +} + diff --git a/web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/sync/SyncDepartmentCO.java b/web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/sync/SyncDepartmentCO.java new file mode 100644 index 00000000..c1024ac8 --- /dev/null +++ b/web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/sync/SyncDepartmentCO.java @@ -0,0 +1,25 @@ +package com.zcloud.basic.info.dto.clientobject.sync; + +import com.alibaba.cola.dto.ClientObject; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * web-client + * + * @Author zhangyue + * @Date 2025-11-04 14:07:33 + */ +@Data +public class SyncDepartmentCO extends ClientObject { + + @ApiModelProperty(value = "部门id") + private Long id; + + @ApiModelProperty(value = "部门名称") + private String name; + @ApiModelProperty(value = "父部门id") + private Long parentId; + + +} diff --git a/web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/sync/SyncUserCO.java b/web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/sync/SyncUserCO.java new file mode 100644 index 00000000..8fae1012 --- /dev/null +++ b/web-client/src/main/java/com/zcloud/basic/info/dto/clientobject/sync/SyncUserCO.java @@ -0,0 +1,61 @@ +package com.zcloud.basic.info.dto.clientobject.sync; + +import com.alibaba.cola.dto.ClientObject; +import com.baomidou.mybatisplus.annotation.TableField; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * web-client + * + * @Author zhangyue + * @Date 2025-11-04 14:07:33 + */ +@Data +public class SyncUserCO extends ClientObject { + + @ApiModelProperty(value = "用户id") + private Long id; + + @ApiModelProperty(value = "姓名") + private String name; + + + + @ApiModelProperty(value = "部门id") + private Long departmentId; + + @ApiModelProperty(value = "部门名称") + private String departmentName; + + + @ApiModelProperty(value = "岗位名称") + private String postName; + + + @ApiModelProperty(value = "邮箱") + private String email; + + @ApiModelProperty(value = "手机号") + private String phone; + + + @ApiModelProperty(value = "人员类型翻译") + private String personnelTypeName; + + + @ApiModelProperty(value = "民族名称") + private String nationName; + + @ApiModelProperty(value = "身份证号") + private String userIdCard; + + @ApiModelProperty(value = "年龄") + private Integer age; + + @ApiModelProperty(value = "生日") + private String birthday; + + @ApiModelProperty(value = "性别") + private String sex; +} diff --git a/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncDepartmentQryPageCmd.java b/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncDepartmentQryPageCmd.java new file mode 100644 index 00000000..41b9bdd6 --- /dev/null +++ b/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncDepartmentQryPageCmd.java @@ -0,0 +1,36 @@ +package com.zcloud.basic.info.dto.sync; + +import lombok.Data; + +import javax.validation.constraints.NotNull; + + +/** + * web-client + * + * @Author zhangyue + * @Date 2025-11-04 14:07:36 + */ +@Data +public class SyncDepartmentQryPageCmd { + + private int pageSize = 10; + private int pageIndex = 1; + /** + * 查询条件操作前缀,支持以下几种数据库查询操作： + * - `like`: 模糊匹配查询，对应SQL的LIKE操作符 + * - `eq`: 等值查询，对应SQL的=操作符 + * - `gt`: 大于比较查询 + * - `lt`: 小于比较查询 + * - `ge`: 大于等于比较查询 + * - `le`: 小于等于比较查询 + * - `ne`: 不等比较查询，对应SQL的!=操作符 + */ + + @NotNull(message = "corpinfoId不能为空") + private Long corpinfoId; + private String name; + private String parentId; // 父部门id + +} + diff --git a/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncUserQryCmd.java b/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncUserQryCmd.java new file mode 100644 index 00000000..1f86a1ae --- /dev/null +++ b/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncUserQryCmd.java @@ -0,0 +1,48 @@ +package com.zcloud.basic.info.dto.sync; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + + +/** + * web-client + * + * @Author zhangyue + * @Date 2025-11-04 14:07:36 + */ +@Data +public class SyncUserQryCmd { + + /** + * 查询条件操作前缀,支持以下几种数据库查询操作： + * - `like`: 模糊匹配查询，对应SQL的LIKE操作符 + * - `eq`: 等值查询，对应SQL的=操作符 + * - `gt`: 大于比较查询 + * - `lt`: 小于比较查询 + * - `ge`: 大于等于比较查询 + * - `le`: 小于等于比较查询 + * - `ne`: 不等比较查询，对应SQL的!=操作符 + */ + private String eqCorpinfoId; + private String eqDepartmentId; + private String eqPostId; + + private Long corpinfoId; + private Long departmentId; + private Long postId; + private String username; + private Integer noMain; + private String isMyCorp; + + @ApiModelProperty(value = "是否流动人员，1-流动，0-固定人员", name = "flowFlag") + private Integer flowFlag; + // 入职状态 + @ApiModelProperty(value = "入职状态 入职状态，0-离职, 1-在职, 2-信息变更中, 3-未入职, 4-实习生, 5-实习结束, 6-退休, 7-劳务派遣, 8-劳务派遣结束, 11-入职待审核, 10-离职待审核") + private Integer employmentFlag; + @ApiModelProperty(value = "是否存在人资系统, 1-是, 0-否") + private Integer rzFlag; + @ApiModelProperty(value = "是否有人脸, 1-是, 0-否") + private Integer faceFlag; + +} + diff --git a/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncUserQryPageCmd.java b/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncUserQryPageCmd.java new file mode 100644 index 00000000..99520e4a --- /dev/null +++ b/web-client/src/main/java/com/zcloud/basic/info/dto/sync/SyncUserQryPageCmd.java @@ -0,0 +1,43 @@ +package com.zcloud.basic.info.dto.sync; + +import com.alibaba.cola.dto.PageQuery; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotNull; + + +/** + * web-client + * + * @Author zhangyue + * @Date 2025-11-04 14:07:36 + */ +@Data +public class SyncUserQryPageCmd { + + private int pageSize = 10; + private int pageIndex = 1; + /** + * 查询条件操作前缀,支持以下几种数据库查询操作： + * - `like`: 模糊匹配查询，对应SQL的LIKE操作符 + * - `eq`: 等值查询，对应SQL的=操作符 + * - `gt`: 大于比较查询 + * - `lt`: 小于比较查询 + * - `ge`: 大于等于比较查询 + * - `le`: 小于等于比较查询 + * - `ne`: 不等比较查询，对应SQL的!=操作符 + */ + + @NotNull(message = "corpinfoId不能为空") + private Long corpinfoId; + + private String name; + private Long departmentId; + private String departmentName; + private String postName; + private String phone; + private String userIdCard; + +} + diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/CorpInfoKeyDO.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/CorpInfoKeyDO.java new file mode 100644 index 00000000..42b2bcb8 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/CorpInfoKeyDO.java @@ -0,0 +1,29 @@ +package com.zcloud.basic.info.persistence.dataobject; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.jjb.saas.framework.repository.basedo.BaseDO; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; + +@Data +@TableName("corp_info_key") +@EqualsAndHashCode(callSuper = true) +public class CorpInfoKeyDO extends BaseDO { + + @ApiModelProperty(value = "企业id") + private Long corpinfoId; + + @ApiModelProperty(value = "公钥") + private String publicKey; + + @ApiModelProperty(value = "私钥") + private String privateKey; + + @ApiModelProperty(value = "签名密钥公钥") + private String signKey; + + @ApiModelProperty(value = "签名密钥私钥") + private String signPrivateKey; +} diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/sync/SyncDepartmentDO.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/sync/SyncDepartmentDO.java new file mode 100644 index 00000000..b980bcfc --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/sync/SyncDepartmentDO.java @@ -0,0 +1,33 @@ +package com.zcloud.basic.info.persistence.dataobject.sync; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.jjb.saas.framework.repository.basedo.BaseDO; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; + +/** + * web-infrastructure + * + * @Author zhangyue + * @Date 2025-11-04 14:07:35 + */ +@Data +@TableName("department") +@NoArgsConstructor +@EqualsAndHashCode(callSuper = true) +public class SyncDepartmentDO extends BaseDO { + + @ApiModelProperty(value = "部门id") + private Long id; + + @ApiModelProperty(value = "部门名称") + private String name; + + @ApiModelProperty(value = "父部门id") + private Long parentId; + + +} diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/sync/SyncUserDO.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/sync/SyncUserDO.java new file mode 100644 index 00000000..ac0e0d60 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/dataobject/sync/SyncUserDO.java @@ -0,0 +1,73 @@ +package com.zcloud.basic.info.persistence.dataobject.sync; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.jjb.saas.framework.repository.basedo.BaseDO; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; + +/** + * web-infrastructure + * + * @Author zhangyue + * @Date 2025-11-04 14:07:35 + */ +@Data +@TableName("user") +@NoArgsConstructor +@EqualsAndHashCode(callSuper = true) +public class SyncUserDO extends BaseDO { + + @ApiModelProperty(value = "用户id") + private Long id; + + @ApiModelProperty(value = "姓名") + private String name; + + + + @ApiModelProperty(value = "部门id") + private Long departmentId; + + @ApiModelProperty(value = "部门名称") + @TableField(exist = false) + private String departmentName; + + + @ApiModelProperty(value = "岗位名称") + @TableField(exist = false) + private String postName; + + + @ApiModelProperty(value = "邮箱") + private String email; + + @ApiModelProperty(value = "手机号") + private String phone; + + + @ApiModelProperty(value = "人员类型翻译") + private String personnelTypeName; + + + @ApiModelProperty(value = "民族名称") + private String nationName; + + @ApiModelProperty(value = "身份证号") + private String userIdCard; + + @ApiModelProperty(value = "年龄") + @TableField(exist = false) + private Integer age; + + @ApiModelProperty(value = "生日") + @TableField(exist = false) + private String birthday; + + @ApiModelProperty(value = "性别") + @TableField(exist = false) + private String sex; + +} diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/CorpInfoKeyMapper.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/CorpInfoKeyMapper.java new file mode 100644 index 00000000..9d1e9207 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/CorpInfoKeyMapper.java @@ -0,0 +1,9 @@ +package com.zcloud.basic.info.persistence.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.zcloud.basic.info.persistence.dataobject.CorpInfoKeyDO; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface CorpInfoKeyMapper extends BaseMapper { +} \ No newline at end of file diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/sync/SyncDepartmentMapper.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/sync/SyncDepartmentMapper.java new file mode 100644 index 00000000..f2e6a545 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/sync/SyncDepartmentMapper.java @@ -0,0 +1,23 @@ +package com.zcloud.basic.info.persistence.mapper.sync; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncDepartmentDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.Map; + +/** + * web-infrastructure + * + * @Author zhangyue + * @Date 2025-11-04 14:07:36 + */ +@Mapper +public interface SyncDepartmentMapper extends BaseMapper { + IPage listPageSyncDepartment(IPage page, @Param("params") Map params); + +} + diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/sync/SyncUserMapper.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/sync/SyncUserMapper.java new file mode 100644 index 00000000..781a7f1d --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/mapper/sync/SyncUserMapper.java @@ -0,0 +1,30 @@ +package com.zcloud.basic.info.persistence.mapper.sync; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.jjb.saas.framework.datascope.annotation.DataScope; +import com.jjb.saas.framework.datascope.annotation.DataScopes; +import com.zcloud.basic.info.persistence.dataobject.DepartmentLeaderStatictiscDO; +import com.zcloud.basic.info.persistence.dataobject.UserCorpInfoDO; +import com.zcloud.basic.info.persistence.dataobject.UserDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +/** + * web-infrastructure + * + * @Author zhangyue + * @Date 2025-11-04 14:07:36 + */ +@Mapper +public interface SyncUserMapper extends BaseMapper { + + IPage listPageSyncUser(IPage page, @Param("params") Map params); + +} + diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/CorpInfoKeyRepository.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/CorpInfoKeyRepository.java new file mode 100644 index 00000000..60a96b42 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/CorpInfoKeyRepository.java @@ -0,0 +1,9 @@ +package com.zcloud.basic.info.persistence.repository; + +import com.jjb.saas.framework.repository.repo.BaseRepository; +import com.zcloud.basic.info.persistence.dataobject.CorpInfoKeyDO; + +public interface CorpInfoKeyRepository extends BaseRepository { + + CorpInfoKeyDO getByCorpinfoId(Long corpinfoId); +} diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/CorpInfoKeyRepositoryImpl.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/CorpInfoKeyRepositoryImpl.java new file mode 100644 index 00000000..4d535545 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/CorpInfoKeyRepositoryImpl.java @@ -0,0 +1,19 @@ +package com.zcloud.basic.info.persistence.repository.impl; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.jjb.saas.framework.repository.repo.impl.BaseRepositoryImpl; +import com.zcloud.basic.info.persistence.dataobject.CorpInfoKeyDO; +import com.zcloud.basic.info.persistence.mapper.CorpInfoKeyMapper; +import com.zcloud.basic.info.persistence.repository.CorpInfoKeyRepository; +import org.springframework.stereotype.Service; + +@Service +public class CorpInfoKeyRepositoryImpl extends BaseRepositoryImpl implements CorpInfoKeyRepository { + + @Override + public CorpInfoKeyDO getByCorpinfoId(Long corpinfoId) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("corpinfo_id", corpinfoId); + return baseMapper.selectOne(queryWrapper); + } +} diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/sync/SyncDepartmentRepositoryImpl.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/sync/SyncDepartmentRepositoryImpl.java new file mode 100644 index 00000000..ecc37fc1 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/sync/SyncDepartmentRepositoryImpl.java @@ -0,0 +1,40 @@ +package com.zcloud.basic.info.persistence.repository.impl.sync; + +import com.alibaba.cola.dto.PageResponse; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.jjb.saas.framework.repository.common.PageHelper; +import com.jjb.saas.framework.repository.repo.impl.BaseRepositoryImpl; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncDepartmentDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; +import com.zcloud.basic.info.persistence.mapper.sync.SyncDepartmentMapper; +import com.zcloud.basic.info.persistence.mapper.sync.SyncUserMapper; +import com.zcloud.basic.info.persistence.repository.sync.SyncDepartmentRepository; +import com.zcloud.basic.info.persistence.repository.sync.SyncUserRepository; +import com.zcloud.gbscommon.utils.Query; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.util.Map; + +/** + * web-infrastructure + * + * @Author zhangyue + * @Date 2025-11-04 14:07:37 + */ +@Service +@RequiredArgsConstructor +@Slf4j +public class SyncDepartmentRepositoryImpl extends BaseRepositoryImpl implements SyncDepartmentRepository { + private final SyncDepartmentMapper syncDepartmentMapper; + + @Override + public PageResponse listPageSyncDepartment(Map params) { + IPage iPage = new Query().getPage(params); + IPage result = syncDepartmentMapper.listPageSyncDepartment(iPage, params); + return PageHelper.pageToResponse(result, result.getRecords()); + } + +} + diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/sync/SyncUserRepositoryImpl.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/sync/SyncUserRepositoryImpl.java new file mode 100644 index 00000000..c6a4a453 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/impl/sync/SyncUserRepositoryImpl.java @@ -0,0 +1,38 @@ +package com.zcloud.basic.info.persistence.repository.impl.sync; + +import com.alibaba.cola.dto.PageResponse; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.jjb.saas.framework.repository.common.PageHelper; +import com.jjb.saas.framework.repository.repo.impl.BaseRepositoryImpl; +import com.zcloud.basic.info.persistence.dataobject.UserDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; +import com.zcloud.basic.info.persistence.mapper.sync.SyncUserMapper; +import com.zcloud.basic.info.persistence.repository.sync.SyncUserRepository; +import com.zcloud.gbscommon.utils.Query; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +import java.util.Map; + +/** + * web-infrastructure + * + * @Author zhangyue + * @Date 2025-11-04 14:07:37 + */ +@Service +@RequiredArgsConstructor +@Slf4j +public class SyncUserRepositoryImpl extends BaseRepositoryImpl implements SyncUserRepository { + private final SyncUserMapper syncUserMapper; + + @Override + public PageResponse listPageSyncUser(Map params) { + IPage iPage = new Query().getPage(params); + IPage result = syncUserMapper.listPageSyncUser(iPage, params); + return PageHelper.pageToResponse(result, result.getRecords()); + } + +} + diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/sync/SyncDepartmentRepository.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/sync/SyncDepartmentRepository.java new file mode 100644 index 00000000..27f3f003 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/sync/SyncDepartmentRepository.java @@ -0,0 +1,19 @@ +package com.zcloud.basic.info.persistence.repository.sync; + +import com.alibaba.cola.dto.PageResponse; +import com.jjb.saas.framework.repository.repo.BaseRepository; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncDepartmentDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; + +import java.util.Map; + +/** +* web-infrastructure +* @Author zhangyue +* @Date 2025-11-04 14:07:36 +*/ +public interface SyncDepartmentRepository extends BaseRepository { + + PageResponse listPageSyncDepartment(Map params); +} + diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/sync/SyncUserRepository.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/sync/SyncUserRepository.java new file mode 100644 index 00000000..e88d4db8 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/persistence/repository/sync/SyncUserRepository.java @@ -0,0 +1,25 @@ +package com.zcloud.basic.info.persistence.repository.sync; + +import com.alibaba.cola.dto.PageResponse; +import com.alibaba.cola.dto.Response; +import com.jjb.saas.framework.repository.repo.BaseRepository; +import com.zcloud.basic.info.domain.model.UserE; +import com.zcloud.basic.info.persistence.dataobject.UserCorpInfoDO; +import com.zcloud.basic.info.persistence.dataobject.UserDO; +import com.zcloud.basic.info.persistence.dataobject.sync.SyncUserDO; + +import javax.validation.constraints.NotEmpty; +import java.util.List; +import java.util.Map; + +/** +* web-infrastructure +* @Author zhangyue +* @Date 2025-11-04 14:07:36 +*/ +public interface SyncUserRepository extends BaseRepository { + + + PageResponse listPageSyncUser(Map params); +} + diff --git a/web-infrastructure/src/main/java/com/zcloud/basic/info/utils/SyncPageResponse.java b/web-infrastructure/src/main/java/com/zcloud/basic/info/utils/SyncPageResponse.java new file mode 100644 index 00000000..d975e4d9 --- /dev/null +++ b/web-infrastructure/src/main/java/com/zcloud/basic/info/utils/SyncPageResponse.java @@ -0,0 +1,129 @@ +package com.zcloud.basic.info.utils; + +import cn.hutool.core.util.ObjectUtil; +import com.alibaba.cola.dto.Response; +import com.alibaba.fastjson.JSONObject; +import com.zcloud.gbscommon.utils.Sm2Util; +import org.slf4j.MDC; + +import java.util.Collections; + +/** + * @author zhangyue + * @date 2026/4/23 11:39 + */ +public class SyncPageResponse extends Response { + private static final long serialVersionUID = 1L; + private int totalCount = 0; + private int pageSize = 1; + private int pageIndex = 1; + private Object data; + + public SyncPageResponse() { + } + + public int getTotalCount() { + return this.totalCount; + } + + public void setTotalCount(int totalCount) { + this.totalCount = totalCount; + } + + public int getPageSize() { + return this.pageSize < 1 ? 1 : this.pageSize; + } + + public void setPageSize(int pageSize) { + if (pageSize < 1) { + this.pageSize = 1; + } else { + this.pageSize = pageSize; + } + + } + + public int getPageIndex() { + return this.pageIndex < 1 ? 1 : this.pageIndex; + } + + public void setPageIndex(int pageIndex) { + if (pageIndex < 1) { + this.pageIndex = 1; + } else { + this.pageIndex = pageIndex; + } + + } + + public Object getData() { + return this.data; + } + + public void setData(Object data) { + this.data = data; + } + + public int getTotalPages() { + return this.totalCount % this.pageSize == 0 ? this.totalCount / this.pageSize : this.totalCount / this.pageSize + 1; + } + + public boolean isEmpty() { + return ObjectUtil.isEmpty(this.data); + } + + public boolean isNotEmpty() { + return !this.isEmpty(); + } + + public static SyncPageResponse buildSuccess() { + SyncPageResponse response = new SyncPageResponse(); + response.setSuccess(true); + response.setTraceId(MDC.get("tlogTraceId")); + return response; + } + + public static SyncPageResponse buildFailure(String errCode, String errMessage) { + SyncPageResponse response = new SyncPageResponse(); + response.setSuccess(false); + response.setErrCode(errCode); + response.setErrMessage(errMessage); + response.setTraceId(MDC.get("tlogTraceId")); + return response; + } + + public static SyncPageResponse of(int pageSize, int pageIndex) { + SyncPageResponse response = new SyncPageResponse(); + response.setSuccess(true); + response.setData(Collections.emptyList()); + response.setTotalCount(0); + response.setPageSize(pageSize); + response.setPageIndex(pageIndex); + response.setTraceId(MDC.get("tlogTraceId")); + return response; + } + + public static SyncPageResponse of(Object data, int totalCount, int pageSize, int pageIndex) { + SyncPageResponse response = new SyncPageResponse(); + response.setSuccess(true); + response.setData(data); + response.setTotalCount(totalCount); + response.setPageSize(pageSize); + response.setPageIndex(pageIndex); + response.setTraceId(MDC.get("tlogTraceId")); + return response; + } + + public static void main(String[] args) { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("corpinfoId", 2003302008103952384L); + jsonObject.put("timestamp", 1776902400000l); + JSONObject jsonbody = new JSONObject(); + jsonbody.put("corpinfoId", 2003302008103952384L); + jsonbody.put("pageIndex", 1); + jsonbody.put("pageSize", 10); + jsonObject.put("body", jsonbody); + String str = jsonObject.toJSONString(); + System.out.println(str); + } +} diff --git a/web-infrastructure/src/main/resources/mapper/sync/SyncDepartmentMapper.xml b/web-infrastructure/src/main/resources/mapper/sync/SyncDepartmentMapper.xml new file mode 100644 index 00000000..aacd9346 --- /dev/null +++ b/web-infrastructure/src/main/resources/mapper/sync/SyncDepartmentMapper.xml @@ -0,0 +1,27 @@ + + + + + + + + diff --git a/web-infrastructure/src/main/resources/mapper/sync/SyncUserMapper.xml b/web-infrastructure/src/main/resources/mapper/sync/SyncUserMapper.xml new file mode 100644 index 00000000..ec55456f --- /dev/null +++ b/web-infrastructure/src/main/resources/mapper/sync/SyncUserMapper.xml @@ -0,0 +1,67 @@ + + + + + + + +