violet/ensign-crm-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat:sync user

Browse Source
This commit is contained in:
zzs 2024-10-11 11:49:15 +08:00
parent 3efaf7d90c
commit 363e10506e
3 changed files with 10 additions and 4 deletions
ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm
job
UserSyncKingdeeTask.java
service
ProxyService.java
ensign-module-system/ensign-module-system-biz/src/main/java/com/ensign/crm/module/system/service/user
AdminUserServiceImpl.java

8
ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm/job/UserSyncKingdeeTask.java
View File

@ -4,6 +4,8 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ensign.crm.framework.common.enums.CommonStatusEnum; import com.ensign.crm.framework.common.enums.CommonStatusEnum;
import com.ensign.crm.framework.common.enums.CrmUserTypeEnum;
import com.ensign.crm.framework.common.enums.UserTypeEnum;
import com.ensign.crm.framework.quartz.core.handler.JobHandler; import com.ensign.crm.framework.quartz.core.handler.JobHandler;
import com.ensign.crm.framework.tenant.core.aop.TenantIgnore; import com.ensign.crm.framework.tenant.core.aop.TenantIgnore;
import com.ensign.crm.module.crm.exception.AllKingdeeException; import com.ensign.crm.module.crm.exception.AllKingdeeException;
@ -46,9 +48,9 @@ public class UserSyncKingdeeTask implements JobHandler {
@TenantIgnore @TenantIgnore
public String execute(String param) throws Exception { public String execute(String param) throws Exception {
LambdaQueryWrapper<AdminUserDO> queryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<AdminUserDO> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.eq(AdminUserDO::getStatus, 0) queryWrapper.eq(AdminUserDO::getStatus, CommonStatusEnum.ENABLE.getStatus())
.eq(AdminUserDO::getIsSyncKingdee, 1) .eq(AdminUserDO::getIsSyncKingdee, CommonStatusEnum.DISABLE.getStatus())
.eq(AdminUserDO::getCrmUserType, 1); .eq(AdminUserDO::getCrmUserType, CrmUserTypeEnum.DEALER.getValue());
List<AdminUserDO> users = userMapper.selectList(queryWrapper); List<AdminUserDO> users = userMapper.selectList(queryWrapper);
List<AdminUserDO> errors = new ArrayList<>(); List<AdminUserDO> errors = new ArrayList<>();

5
ensign-module-crm/ensign-module-crm-biz/src/main/java/com/ensign/crm/module/crm/service/ProxyService.java
View File

@ -282,7 +282,12 @@ public class ProxyService {
} }
if (request != null) { if (request != null) {
request.addHeader("access_token", initAccessToken()); request.addHeader("access_token", initAccessToken());
request.addHeader("Content-Type", "application/json; charset=utf-8");
log.info("Requesting: {}", request); log.info("Requesting: {}", request);
Header[] headers = request.getAllHeaders();
for (Header hd : headers) {
log.info("header: {}", hd);
}
} }
HttpResponse response = httpClient.execute(request); HttpResponse response = httpClient.execute(request);

1
ensign-module-system/ensign-module-system-biz/src/main/java/com/ensign/crm/module/system/service/user/AdminUserServiceImpl.java
View File

@ -102,7 +102,6 @@ public class AdminUserServiceImpl implements AdminUserService {
// 2.1 插入用户 // 2.1 插入用户
AdminUserDO user = BeanUtils.toBean(createReqVO, AdminUserDO.class); AdminUserDO user = BeanUtils.toBean(createReqVO, AdminUserDO.class);
user.setStatus(CommonStatusEnum.ENABLE.getStatus()); // 默认开启 user.setStatus(CommonStatusEnum.ENABLE.getStatus()); // 默认开启
user.setIsSyncKingdee(CommonStatusEnum.DISABLE.getStatus());//未同步
user.setPassword(encodePassword(createReqVO.getPassword())); // 加密密码 user.setPassword(encodePassword(createReqVO.getPassword())); // 加密密码
userMapper.insert(user); userMapper.insert(user);
// 2.2 插入关联岗位 // 2.2 插入关联岗位