From 77d5094d358a01025be32111d960dd750ed175aa Mon Sep 17 00:00:00 2001
From: "1378012178@qq.com" <1378012178@qq.com>
Date: Fri, 6 Mar 2026 09:44:16 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9C=BA=E6=9E=84=E5=8A=A0=E7=9B=9F=E6=90=AD?=
 =?UTF-8?q?=E5=BB=BA=E5=AE=8C=E5=B9=B3=E5=8F=B0=E5=9C=A8=E4=B8=9A=E5=8A=A1?=
 =?UTF-8?q?=E4=B8=AD=E5=A2=9E=E5=8A=A0=E5=91=98=E5=B7=A5=E4=BF=A1=E6=81=AF?=
 =?UTF-8?q?=E3=80=81=E7=94=A8=E6=88=B7=E8=A1=A8=E4=B8=AD=E6=9C=BA=E6=9E=84?=
 =?UTF-8?q?=E8=B4=9F=E8=B4=A3=E4=BA=BA=E6=95=B0=E6=8D=AE=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?employees=5Fid=E7=9A=84=E5=80=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mapper/BizEmployeesInfoMapper.java        |  3 +
 .../mapper/xml/BizEmployeesInfoMapper.xml     |  3 +
 .../service/IBizEmployeesInfoService.java     |  2 +
 .../impl/BizEmployeesInfoServiceImpl.java     |  5 ++
 .../listener/DynamicQueueNameProvider.java    | 13 +++
 .../listener/EmployeesMQListener.java         | 89 +++++++++++++------
 6 files changed, 87 insertions(+), 28 deletions(-)

diff --git a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/mapper/BizEmployeesInfoMapper.java b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/mapper/BizEmployeesInfoMapper.java
index fbcea9fa..689cc09b 100644
--- a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/mapper/BizEmployeesInfoMapper.java
+++ b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/mapper/BizEmployeesInfoMapper.java
@@ -2,6 +2,7 @@ package com.nu.modules.employeesInfo.mapper;
 
 import com.nu.modules.employeesInfo.entity.BizEmployeesInfo;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * @Description: 员工信息
@@ -11,4 +12,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface BizEmployeesInfoMapper extends BaseMapper<BizEmployeesInfo> {
     BizEmployeesInfo findById(BizEmployeesInfo bizEmployeesInfo);
+
+    void UpUserEmployeesId(@Param("userId") String userId);
 }
diff --git a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/mapper/xml/BizEmployeesInfoMapper.xml b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/mapper/xml/BizEmployeesInfoMapper.xml
index 19ad6c8f..6fcebd5f 100644
--- a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/mapper/xml/BizEmployeesInfoMapper.xml
+++ b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/mapper/xml/BizEmployeesInfoMapper.xml
@@ -1,6 +1,9 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.nu.modules.employeesInfo.mapper.BizEmployeesInfoMapper">
+    <update id="UpUserEmployeesId">
+        update sys_user set employees_id = id where id = #{userId}
+    </update>
 
     <select id="findById" resultType="com.nu.modules.employeesInfo.entity.BizEmployeesInfo">
         select
diff --git a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/service/IBizEmployeesInfoService.java b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/service/IBizEmployeesInfoService.java
index 671c6579..1aba161c 100644
--- a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/service/IBizEmployeesInfoService.java
+++ b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/service/IBizEmployeesInfoService.java
@@ -11,4 +11,6 @@ import com.baomidou.mybatisplus.extension.service.IService;
  */
 public interface IBizEmployeesInfoService extends IService<BizEmployeesInfo> {
     BizEmployeesInfo findById(BizEmployeesInfo bizEmployeesInfo);
+
+    void UpUserEmployeesId(String userId);
 }
diff --git a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/service/impl/BizEmployeesInfoServiceImpl.java b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/service/impl/BizEmployeesInfoServiceImpl.java
index 4b2f1023..96adbe31 100644
--- a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/service/impl/BizEmployeesInfoServiceImpl.java
+++ b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/modules/employeesInfo/service/impl/BizEmployeesInfoServiceImpl.java
@@ -38,6 +38,11 @@ public class BizEmployeesInfoServiceImpl extends ServiceImpl<BizEmployeesInfoMap
         return baseMapper.findById(bizEmployeesInfo);
     }
 
+    @Override
+    public void UpUserEmployeesId(String userId) {
+        baseMapper.UpUserEmployeesId(userId);
+    }
+
     @Override
     public List<Map<String, Object>> getPermissionList(String employeesId) {
         List<NuAppEmployeesPermission> permissionList = nuAppEmployeesPermissionService.listByEmployeesId(employeesId);
diff --git a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/mq/employees/listener/DynamicQueueNameProvider.java b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/mq/employees/listener/DynamicQueueNameProvider.java
index 5903d861..382a1d7c 100644
--- a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/mq/employees/listener/DynamicQueueNameProvider.java
+++ b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/mq/employees/listener/DynamicQueueNameProvider.java
@@ -125,5 +125,18 @@ public class DynamicQueueNameProvider {
         return getSysUserInfoQueueName();
     }
 
+    public String getUpUserEmployeesIdQueueName() {
+        JSONObject deptInfo = sysBaseAPI.getDeptInfo();
+        String orgCode = deptInfo.getString("code");
+        if (StringUtils.isNotBlank(orgCode)) {
+            return orgCode + ".orgapply.upuseremployeesid";
+        } else {
+            return "";
+        }
+    }
+
+    public String getUpUserEmployeesIdKeyName() {
+        return getUpUserEmployeesIdQueueName();
+    }
 
 }
diff --git a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/mq/employees/listener/EmployeesMQListener.java b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/mq/employees/listener/EmployeesMQListener.java
index 41161c1e..680a4d9d 100644
--- a/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/mq/employees/listener/EmployeesMQListener.java
+++ b/nursing-unit-employee/nu-employee-biz/src/main/java/com/nu/mq/employees/listener/EmployeesMQListener.java
@@ -1297,14 +1297,14 @@ public class EmployeesMQListener {
                 bizEmployeesMedia.setCardFmPath("2");
                 employeesMediaService.update(bizEmployeesMedia, mqw);
 //                new Thread(() -> {
-                    //去管理平台拉取资源
-                    {
+                //去管理平台拉取资源
+                {
 //                        JSONObject opeOpenUrl = sysConfigApi.getByKeyByDS("master", "ope_open_url");
 //                        String baseUrl = opeOpenUrl.getString("configValue");
 //                        if (baseUrl.endsWith("/")) {
 //                            baseUrl = baseUrl.substring(0, baseUrl.length() - 1);
 //                        }
-                        //身份证正面
+                    //身份证正面
 //                        {
 //                            if (StringUtils.isNotBlank(idCardPositive)) {
 //                                if (StringUtils.isNotBlank(idCardPositive)) {
@@ -1319,7 +1319,7 @@ public class EmployeesMQListener {
 //                                    }
 //                                    try {
 //                                        FileDownloader.downloadFile(url, upLoadPath + File.separator + filePath, fileName);
-                        employeesApply2.setIdCardPositive(idCardPositive);
+                    employeesApply2.setIdCardPositive(idCardPositive);
 //                                        bizEmployeesMedia.setCardZmPath("2");
 //                                    } catch (Exception e) {
 //                                        e.printStackTrace();
@@ -1331,7 +1331,7 @@ public class EmployeesMQListener {
 //                                }
 //                            }
 //                        }
-                        //身份证反面
+                    //身份证反面
 //                        {
 //                            if (StringUtils.isNotBlank(idCardNegative)) {
 //                                if (StringUtils.isNotBlank(idCardNegative)) {
@@ -1346,7 +1346,7 @@ public class EmployeesMQListener {
 //                                    }
 //                                    try {
 //                                        FileDownloader.downloadFile(url, upLoadPath + File.separator + filePath, fileName);
-                        employeesApply2.setIdCardNegative(idCardNegative);
+                    employeesApply2.setIdCardNegative(idCardNegative);
 //                                        bizEmployeesMedia.setCardFmPath("2");
 //                                    } catch (Exception e) {
 //                                        e.printStackTrace();
@@ -1358,9 +1358,9 @@ public class EmployeesMQListener {
 //                                }
 //                            }
 //                        }
-                        employeesApplyService.updateById(employeesApply2);
+                    employeesApplyService.updateById(employeesApply2);
 //                        employeesMediaService.update(bizEmployeesMedia, mqw);
-                    }
+                }
 //                }).start();
             }
         }
@@ -1385,13 +1385,13 @@ public class EmployeesMQListener {
         String employeeId = dto.getEmployeeId();
 
         //需要初始化
-        if(izInit.equals("Y")){
+        if (izInit.equals("Y")) {
 
             QueryWrapper<BizEmployeesInfo> qw = new QueryWrapper<>();
             qw.eq("id", employeeId);
             BizEmployeesInfo employeesInfo = employeesInfoService.getOne(qw);
             SysUserEntity user = sysUserAPI.getOne(employeeId);
-            if(user==null) {
+            if (user == null) {
 //                user = new SysUserEntity();
 //                user.setUsername(employeesInfo.getTel());
 //                user.setRealname(employeesInfo.getName());
@@ -1422,14 +1422,14 @@ public class EmployeesMQListener {
                 //审核通过 - 给员工添加账号
                 JSONObject deptInfo = sysBaseAPI.getDeptInfo();
                 JSONObject j = new JSONObject();
-                j.put("userName",employeesInfo.getTel());
-                j.put("realname",employeesInfo.getName());
-                j.put("orgCode",deptInfo.getString("id"));//这个参数要的是机构的id
-                j.put("opeType","employee");
-                j.put("o_c_",deptInfo.getString("code"));
-                j.put("employees_id",employeeId);
+                j.put("userName", employeesInfo.getTel());
+                j.put("realname", employeesInfo.getName());
+                j.put("orgCode", deptInfo.getString("id"));//这个参数要的是机构的id
+                j.put("opeType", "employee");
+                j.put("o_c_", deptInfo.getString("code"));
+                j.put("employees_id", employeeId);
                 employeesApplyService.initialization(j);
-            }else{
+            } else {
                 user.setUsername(employeesInfo.getTel());
                 user.setRealname(employeesInfo.getName());
                 String salt = oConvertUtils.randomGen(8);
@@ -1441,11 +1441,11 @@ public class EmployeesMQListener {
                 Date birthday = employeesInfo.getDateOfBirth();
                 user.setBirthday(birthday);
                 String sex = employeesInfo.getSex();
-                if(sex.equals("男")){
+                if (sex.equals("男")) {
                     user.setSex(1);
-                }else if(sex.equals("女")){
+                } else if (sex.equals("女")) {
                     user.setSex(2);
-                }else{
+                } else {
                     user.setSex(0);
                 }
                 user.setPhone(employeesInfo.getTel());
@@ -1455,10 +1455,10 @@ public class EmployeesMQListener {
                 user.setUpdateTime(new Date());//设置创建时间
                 sysUserAPI.updateById(user);
             }
-        }else{
+        } else {
             //不需要初始化，从其他业务结构复制过来
             SysUserEntity user = sysUserAPI.getOne(employeeId);
-            if(user==null) {
+            if (user == null) {
                 user = new SysUserEntity();
                 user.setUsername(dto.getUsername());
                 user.setRealname(dto.getRealname());
@@ -1474,7 +1474,7 @@ public class EmployeesMQListener {
                 user.setCreateTime(new Date());//设置创建时间
                 user.setEmployeesId(employeeId);
                 sysUserAPI.save(user);
-            }else{
+            } else {
                 user.setUsername(dto.getUsername());
                 user.setRealname(dto.getRealname());
                 user.setPassword(dto.getPassword());
@@ -1491,16 +1491,16 @@ public class EmployeesMQListener {
             }
         }
 
-        if(izInitPassword.equals("1")){
+        if (izInitPassword.equals("1")) {
             //需要更新其他业务平台密码
             SysUserEntity user = sysUserAPI.getOne(employeeId);
-            if(user!=null){
+            if (user != null) {
                 SysUserMQDto sysUserMQDto = new SysUserMQDto();
                 BeanUtils.copyProperties(user, sysUserMQDto);
                 sysUserMQDto.setEmployeeId(user.getEmployeesId());
                 rabbitMQUtil.sendToExchange("hldy.employees", "hldy.employeesorg.sysuser.sync", sysUserMQDto);
             }
-        }else{
+        } else {
             JSONObject deptInfo = sysBaseAPI.getDeptInfo();
             String orgCode = deptInfo.getString("code");
             SysUserMQDto sysUserMQDto = new SysUserMQDto();
@@ -1525,7 +1525,7 @@ public class EmployeesMQListener {
     )
     public void handleSyncSysUserPwd(SysUserMQDto dto) {
         SysUserEntity user = sysUserAPI.getOne(dto.getEmployeeId());
-        if(user!=null) {
+        if (user != null) {
             user.setPassword(dto.getPassword());
             user.setSalt(dto.getSalt());
             sysUserAPI.updateById(user);
@@ -1550,7 +1550,7 @@ public class EmployeesMQListener {
 //        QueryWrapper<SysUserEntity> queryWrapper = new QueryWrapper<>();
 //        queryWrapper.eq("employees_id", employeeId);
         SysUserEntity user = sysUserAPI.getOne(dto.getEmployeeId());
-        if(user!=null) {
+        if (user != null) {
             SysUserMQDto sysUserMQDto = new SysUserMQDto();
             BeanUtils.copyProperties(user, sysUserMQDto);
             sysUserMQDto.setTargetOrgCode(dto.getTargetOrgCode());
@@ -1562,6 +1562,7 @@ public class EmployeesMQListener {
 
     /**
      * 同步更新密码
+     *
      * @param dto
      */
     @RabbitListener(
@@ -1582,4 +1583,36 @@ public class EmployeesMQListener {
         en.setPassword(dto.getPassword());
         sysUserAPI.updateById(en);
     }
+
+    /**
+     * 更新机构负责人用户表employees_id
+     *
+     */
+    @RabbitListener(
+            bindings = @QueueBinding(
+                    value = @Queue(name = "#{employeesAsyncDQNP.getUpUserEmployeesIdQueueName()}"),
+                    exchange = @Exchange(name = "hldy.org", type = ExchangeTypes.DIRECT),
+                    key = "#{employeesAsyncDQNP.getUpUserEmployeesIdKeyName()}"
+            ),
+            errorHandler = "employeesMQErrorHandler"
+    )
+    public void handleResetPW(EmployeesApplyMQDto dto) {
+        //入职时间 entryTime用当前时间
+        BizEmployeesInfo bizEmployeesInfo = new BizEmployeesInfo();
+        bizEmployeesInfo.setId(dto.getId());//机构负责人的数据id跟sys_user表id一致
+        bizEmployeesInfo.setName(dto.getName());//姓名
+        bizEmployeesInfo.setSex(dto.getSex());//性别
+        bizEmployeesInfo.setNational(dto.getNational());//民族
+        bizEmployeesInfo.setIdCard(dto.getIdCard());//身份证号
+        bizEmployeesInfo.setDateOfBirth(dto.getDateOfBirth());//出生日期
+        bizEmployeesInfo.setHouseAddress(dto.getHouseAddress());//地址
+        bizEmployeesInfo.setIdCardPositive(dto.getIdCardPositive());//身份证正面
+        bizEmployeesInfo.setIdCardNegative(dto.getIdCardNegative());//身份证反面
+        bizEmployeesInfo.setTel(dto.getTel());
+        bizEmployeesInfo.setOpenId(dto.getOpenId());
+        employeesInfoService.save(bizEmployeesInfo);
+
+
+        employeesInfoService.UpUserEmployeesId(dto.getId());
+    }
 }