From 5b7639f0bd9e056738ec15100ed0532e965c6cd5 Mon Sep 17 00:00:00 2001
From: guohongjin <guohongjin@test.com>
Date: 星期三, 15 五月 2024 17:15:18 +0800
Subject: [PATCH] 添加日志
---
roses/kernel-s-customer/customer-business/src/main/java/cn/stylefeng/roses/kernel/customer/modular/service/impl/CustomerServiceImpl.java | 35 +++++++++++++++++++++++++++++++++--
1 files changed, 33 insertions(+), 2 deletions(-)
diff --git a/roses/kernel-s-customer/customer-business/src/main/java/cn/stylefeng/roses/kernel/customer/modular/service/impl/CustomerServiceImpl.java b/roses/kernel-s-customer/customer-business/src/main/java/cn/stylefeng/roses/kernel/customer/modular/service/impl/CustomerServiceImpl.java
index 5527398..c090c4c 100644
--- a/roses/kernel-s-customer/customer-business/src/main/java/cn/stylefeng/roses/kernel/customer/modular/service/impl/CustomerServiceImpl.java
+++ b/roses/kernel-s-customer/customer-business/src/main/java/cn/stylefeng/roses/kernel/customer/modular/service/impl/CustomerServiceImpl.java
@@ -13,7 +13,6 @@
import cn.stylefeng.roses.kernel.auth.api.context.LoginContext;
import cn.stylefeng.roses.kernel.auth.api.exception.AuthException;
import cn.stylefeng.roses.kernel.auth.api.exception.enums.AuthExceptionEnum;
-import cn.stylefeng.roses.kernel.auth.api.expander.AuthConfigExpander;
import cn.stylefeng.roses.kernel.auth.api.password.PasswordStoredEncryptApi;
import cn.stylefeng.roses.kernel.auth.api.pojo.auth.LoginRequest;
import cn.stylefeng.roses.kernel.auth.api.pojo.auth.LoginResponse;
@@ -217,7 +216,7 @@
synchronized (SESSION_OPERATE_LOCK) {
// 缓存用户信息，创建会话
sessionManagerApi.createSession(jwtToken, loginUser, loginRequest.getCreateCookie());
-
+ System.err.println("已修改");
// 如果开启了单账号单端在线，则踢掉已经上线的该用户
// if (AuthConfigExpander.getSingleAccountLoginFlag()) {
sessionManagerApi.removeSessionExcludeToken(jwtToken);
@@ -736,4 +735,36 @@
return postIds;
}
+
+ @Override
+ public Boolean userBindClassConsultWorkerId(Long customerId, String workerNo) {
+ // 幸福顾问
+ PostIdEnum post11Enum = PostIdEnum.PO_11;
+ // 咨询顾问
+ PostIdEnum post21Enum = PostIdEnum.PO_21;
+
+ // 获取绑定顾问岗位ID
+ String[] bindWorkerPostIds = this.getBindWorkerPostIds(workerNo, post11Enum, post21Enum);
+ Customer workerByNo = this.getOne(
+ Wrappers.<Customer>lambdaUpdate().eq(Customer::getWorkerNo, workerNo).last("LIMIT 1")
+ );
+
+ Customer newCustomer = new Customer();
+ newCustomer.setCustomerId(customerId);
+ for (String postId : bindWorkerPostIds) {
+ if (postId.equals(post11Enum.getCode().toString())) {
+ newCustomer.setClassWorkerId(workerByNo.getCustomerId());
+ } else if (postId.equals(post21Enum.getCode().toString())) {
+ newCustomer.setConsultWorkerId(workerByNo.getCustomerId());
+ }
+ }
+
+ Boolean update = false;
+ if (customerId != null && (newCustomer.getClassWorkerId() != null || newCustomer.getConsultWorkerId() != null)) {
+ // 修改用户信息
+ update = this.updateCustomerRemoveCache(newCustomer);
+ }
+
+ return update;
+ }
}
--
Gitblit v1.7.1