商旅(云快报)人员同步

# 1.系统内置服务 ![image.png](https://cos.easydoc.net/24916735/files/k57uhilo.png) 修正为true # 3.自建服务功能说明一次性处理全部用户调用接口 http://ip:port/fssc/cctv/sync/userSync 数据库关联 fssc 模块： t_sys_user updateYkbUser为单用户调用。注意需使用产品方法调用。 ![image.png](https://cos.easydoc.net/24916735/files/k4m2ngm7.png) # 2.controller ```java package com.epoch.customproject.cctv.controller; import com.epoch.customproject.cctv.service.sync.UserSyncServiceImpl; import com.epoch.infrastructure.util.model.ResultValue; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /** * @Author: hecore * @Date: 2019/12/25 16:26 * @Description: */ @RestController @RequestMapping("/cctv/sync") public class CctvUserSyncController { @Autowired private UserSyncServiceImpl userSyncService; @RequestMapping("/userSync") public ResultValue select(){ ResultValue resultValue = new ResultValue(); userSyncService.syncData(); resultValue.setSuccess(true); return resultValue; } } ``` # 3.service ```java package com.epoch.customproject.cctv.service.sync; import com.epoch.bdp.masterdata.dao.ISysUserDAO; import com.epoch.bdp.masterdata.model.enums.UserStatusEnum; import com.epoch.bdp.masterdata.model.vo.SysUserVO; import com.epoch.bdp.masterdata.service.user.ISysUserService; import com.epoch.bdp.masterdata.service.user.ISysUserValidateService; import com.epoch.bdp.masterdata.util.YKBMasterDataUserUtils; import com.epoch.infrastructure.util.model.ResultValue; import com.google.common.collect.Lists; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.*; /** * @Author: hecore * @Date: 2019/12/25 15:30 * @Description: */ @Service("UserSyncService") public class UserSyncServiceImpl { @Autowired private ISysUserDAO iSysUserDAO; @Autowired private ISysUserValidateService iSysUserValidateService; @Autowired private ISysUserService iSysUserService; private Logger logger = LoggerFactory.getLogger(UserSyncServiceImpl.class); /** * 统一全量更新用户 */ public void syncData() { logger.info("====================== 人员变量接口数据同步start ======================"); List<SysUserVO> sysUserVOList=getSysUserListBySearch(UserStatusEnum.ENABLE); System.out.println(sysUserVOList.size()); sysUserVOList.forEach(sysUserVO -> { updateYkbUser(sysUserVO); }); logger.info("====================== 人员变量接口数据同步end ======================"); } /** * // loginName=15313161331; * // {"userCode":"1923461436674927","userName":"刘宇","sex":"MAN","loginName":"15313161331","mobilePhone":"15313161331","email":"","wechatNo":"","identityCard":"","defaultDeptId":"1df03650d86c11e984f4471c5a8a8fc2","rankId":"99c225f8de9211e984f4f5983de25150","directLeaderId":"","userGroupIdList":[{"groupId":"8c350f24051911eaab985716a9b82375"}],"userRoleIdList":[{"roleId":"e837fa12b29311e99707877f16998721"}],"workStatus":"ONLINE","externalAttr":{},"status":"ENABLE","orgId":"1df03650d86c11e984f4471c5a8a8fc2","id":"088e5487deab11e984f41d06a1b243fd"} * @param sysUserVO */ private void updateYkbUser(SysUserVO sysUserVO) { /** * 只更新有性别用户 */ String str=this.iSysUserService.getDeleteUserIdByLoginName(sysUserVO.getLoginName()); if(StringUtils.isBlank(str)){ // 执行更新 ResultValue<?> canUpdateUser = this.iSysUserValidateService.isCanUpdateUser(sysUserVO); if (canUpdateUser.isSuccess()) { // this.iSysUserService.updateUserAndToConsole(sysUserVO); Optional<SysUserVO> sysUserById = this.iSysUserService.getSysUserById(sysUserVO.getId()); if (sysUserById.isPresent()) { if(null!=sysUserVO.getSex()&&StringUtils.isNotBlank(sysUserVO.getSex().getValue())){ sysUserVO.setLoginName(((SysUserVO) sysUserById.get()).getLoginName()); YKBMasterDataUserUtils.sendUserInfoToYKB(Lists.newArrayList(new SysUserVO[]{sysUserVO})); } } } } } public List<SysUserVO> getSysUserListBySearch(UserStatusEnum status) { return this.iSysUserDAO.getSysUserListBySearch(null, status); } } ```

商旅(云快报)人员同步

商旅(云快报)人员同步

接口描述

请求头

参数名

类型

描述

必填

说明 / 示例