From 3011ff8ae9f5f1d0270f05e7fad40d748f15226c Mon Sep 17 00:00:00 2001
From: "1378012178@qq.com" <1378012178@qq.com>
Date: Thu, 12 Mar 2026 16:18:11 +0800
Subject: [PATCH] =?UTF-8?q?=E5=91=98=E5=B7=A5=E4=BF=A1=E6=81=AF=E8=B0=83?=
 =?UTF-8?q?=E6=95=B4=EF=BC=8C=E6=8C=89=E9=92=AE=E8=B0=83=E6=95=B4=EF=BC=8C?=
 =?UTF-8?q?=E6=A0=B7=E5=BC=8F=E8=B0=83=E6=95=B4=EF=BC=8C=E5=A2=9E=E5=8A=A0?=
 =?UTF-8?q?=E9=87=8D=E7=BD=AE=E5=AF=86=E7=A0=81=E3=80=81=E5=86=BB=E7=BB=93?=
 =?UTF-8?q?=E3=80=81=E8=A7=A3=E5=86=BB=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../employees/mapper/EmployeesOrgMapper.java     |  3 +++
 .../employees/mapper/xml/EmployeesOrgMapper.xml  | 14 ++++++++++----
 .../employees/service/IEmployeesOrgService.java  |  3 +++
 .../service/impl/EmployeesOrgServiceImpl.java    |  8 ++++++++
 .../employees/listener/EmployeesMQListener.java  | 16 +++++++++++++++-
 5 files changed, 39 insertions(+), 5 deletions(-)

diff --git a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/mapper/EmployeesOrgMapper.java b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/mapper/EmployeesOrgMapper.java
index 6e69ec5..89da436 100644
--- a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/mapper/EmployeesOrgMapper.java
+++ b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/mapper/EmployeesOrgMapper.java
@@ -2,6 +2,7 @@ package com.nu.modules.employees.mapper;
 
 import java.util.List;
 
+import com.nu.dto.EmployeesStatusMQDto;
 import org.apache.ibatis.annotations.Param;
 import com.nu.modules.employees.entity.EmployeesOrg;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
@@ -14,4 +15,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface EmployeesOrgMapper extends BaseMapper<EmployeesOrg> {
     List<EmployeesOrg> getEmployeesOrgListByEmpId(@Param("employeesId") String employeesId);
+
+    int updateByOpenAndOrgCode(@Param("dto") EmployeesStatusMQDto dto);
 }
diff --git a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/mapper/xml/EmployeesOrgMapper.xml b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/mapper/xml/EmployeesOrgMapper.xml
index 7697f7d..a532902 100644
--- a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/mapper/xml/EmployeesOrgMapper.xml
+++ b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/mapper/xml/EmployeesOrgMapper.xml
@@ -1,12 +1,18 @@
 <?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.employees.mapper.EmployeesOrgMapper">
+    <update id="updateByOpenAndOrgCode">
+        UPDATE nu_biz_employees_org
+        SET update_time= now(),
+            iz_freeze=#{dto.izFreeze}
+        WHERE (open_id = #{dto.openId} AND org_code = #{dto.orgCode})
+    </update>
 
     <select id="getEmployeesOrgListByEmpId" resultType="com.nu.modules.employees.entity.EmployeesOrg">
-        SELECT
-            a.org_code as orgCode,
-            concat(CASE WHEN RIGHT(b.url, 1) = '/' THEN LEFT(b.url, LENGTH(b.url)) ELSE b.url END, b.context_path )  AS serverUrl,
-            b.depart_name
+        SELECT a.org_code             as orgCode,
+               concat(CASE WHEN RIGHT (b.url, 1) = '/' THEN LEFT (b.url, LENGTH (b.url)) ELSE b.url END,
+                      b.context_path) AS serverUrl,
+               b.depart_name
         FROM nu_biz_employees_org a
                  LEFT JOIN sys_depart b
                            ON a.org_code = b.org_code
diff --git a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/service/IEmployeesOrgService.java b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/service/IEmployeesOrgService.java
index d4ceba3..9f4dfb8 100644
--- a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/service/IEmployeesOrgService.java
+++ b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/service/IEmployeesOrgService.java
@@ -1,5 +1,6 @@
 package com.nu.modules.employees.service;
 
+import com.nu.dto.EmployeesStatusMQDto;
 import com.nu.modules.employees.entity.EmployeesOrg;
 import com.baomidou.mybatisplus.extension.service.IService;
 
@@ -13,4 +14,6 @@ import java.util.List;
  */
 public interface IEmployeesOrgService extends IService<EmployeesOrg> {
     List<EmployeesOrg> getEmployeesOrgListByEmpId(String employeesId);
+
+    void updateByOpenAndOrgCode(EmployeesStatusMQDto dto);
 }
diff --git a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/service/impl/EmployeesOrgServiceImpl.java b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/service/impl/EmployeesOrgServiceImpl.java
index 3956871..b66725a 100644
--- a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/service/impl/EmployeesOrgServiceImpl.java
+++ b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/employees/service/impl/EmployeesOrgServiceImpl.java
@@ -3,6 +3,7 @@ package com.nu.modules.employees.service.impl;
 import cn.hutool.core.bean.BeanUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.nu.dto.EmployeesStatusMQDto;
 import com.nu.entity.EmployeesApplyEntity;
 import com.nu.modules.EmployeesInfo.api.EmployeesOrgLocalApi;
 import com.nu.entity.EmployeesOrgApiEntity;
@@ -32,6 +33,11 @@ public class EmployeesOrgServiceImpl extends ServiceImpl<EmployeesOrgMapper, Emp
     @Autowired
     private INuEmployeesAdvisoryInfoService employeesAdvisoryInfoService;
 
+    @Override
+    public void updateByOpenAndOrgCode(EmployeesStatusMQDto dto) {
+        baseMapper.updateByOpenAndOrgCode(dto);
+    }
+
     @Override
     public String apply(EmployeesApplyEntity dto) {
         //先将旧数据置为历史状态
@@ -184,4 +190,6 @@ public class EmployeesOrgServiceImpl extends ServiceImpl<EmployeesOrgMapper, Emp
     public List<EmployeesOrg> getEmployeesOrgListByEmpId(String employeesId){
         return baseMapper.getEmployeesOrgListByEmpId(employeesId);
     }
+
+
 }
diff --git a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/mq/employees/listener/EmployeesMQListener.java b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/mq/employees/listener/EmployeesMQListener.java
index 25e74de..9f5cd2b 100644
--- a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/mq/employees/listener/EmployeesMQListener.java
+++ b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/mq/employees/listener/EmployeesMQListener.java
@@ -491,7 +491,7 @@ public class EmployeesMQListener {
             employeeInfo.setStartTime(dto.getStartTime());
             employeeInfo.setEndTime(dto.getEndTime());
             employeesAdvisoryInfoService.updateById(employeeInfo);
-            System.out.println("员工咨询表信息修改成功"+employeeInfo);
+            System.out.println("员工咨询表信息修改成功" + employeeInfo);
             //通知其余机构修改此员工信息 并拉取资源文件
             LambdaQueryWrapper<EmployeesOrg> qw = new LambdaQueryWrapper<>();
             qw.select(EmployeesOrg::getOrgCode);
@@ -573,4 +573,18 @@ public class EmployeesMQListener {
         wxNotice.setLogMainInfo("员工信息变更审核");
         wxNoticeApi.sendWechartMessage_SHENHE(wxNotice, nuWxNotice);
     }
+
+    /**
+     * 冻结或解冻
+     *
+     * @param dto
+     */
+    @RabbitListener(bindings = @QueueBinding(value = @Queue(name = "employees.account.freezeOrEnabled", durable = "true"),
+            exchange = @Exchange(name = "hldy.employees", type = ExchangeTypes.DIRECT),
+            key = "employees.account.freezeOrEnabled"), errorHandler = "employeesMQErrorHandler")
+    public void handleFreezeOrEnabled(EmployeesStatusMQDto dto) {
+        EmployeesOrg employeesOrg = new EmployeesOrg();
+        employeesOrg.setIzFreeze(dto.getIzFreeze());
+        employeesOrgService.updateByOpenAndOrgCode(dto);
+    }
 }