guohongjin
2024-05-01 1901fceb6ddaa56a57f3131191454554c3e77e68
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;
@@ -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;
    }
}