From 55ef2c60f82df80d67a3c112de39d780c83c155d Mon Sep 17 00:00:00 2001
From: "1378012178@qq.com" <1378012178@qq.com>
Date: Tue, 22 Apr 2025 17:10:35 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E6=B3=A8=E5=86=8C=E6=9C=8D?=
 =?UTF-8?q?=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 nursing-unit-admin/nu-admin-biz/pom.xml       |  7 +-
 .../impl/NuBizAdvisoryInfoServiceImpl.java    | 11 ++-
 .../java/com/nu/config/RabbitMQConfig.java    | 14 ++++
 .../java/com/nu/dto/NuBizAdvisoryInfoDto.java | 80 +++++++++++++++++++
 4 files changed, 110 insertions(+), 2 deletions(-)
 create mode 100644 nursing-unit-common/src/main/java/com/nu/dto/NuBizAdvisoryInfoDto.java

diff --git a/nursing-unit-admin/nu-admin-biz/pom.xml b/nursing-unit-admin/nu-admin-biz/pom.xml
index 020a5ba..85ecdc9 100644
--- a/nursing-unit-admin/nu-admin-biz/pom.xml
+++ b/nursing-unit-admin/nu-admin-biz/pom.xml
@@ -29,7 +29,12 @@
 			<groupId>org.jeecgframework</groupId>
 			<artifactId>weixin4j</artifactId>
 		</dependency>
-
+		<!-- COMMON 通用工具模块 -->
+		<dependency>
+			<groupId>com.nursingunit.boot</groupId>
+			<artifactId>nursing-unit-common</artifactId>
+			<version>${nursingunit.version}</version>
+		</dependency>
 	</dependencies>
 
 </project>
diff --git a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/nuBizAdvisoryInfo/service/impl/NuBizAdvisoryInfoServiceImpl.java b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/nuBizAdvisoryInfo/service/impl/NuBizAdvisoryInfoServiceImpl.java
index 06ac00e..3ed1e08 100644
--- a/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/nuBizAdvisoryInfo/service/impl/NuBizAdvisoryInfoServiceImpl.java
+++ b/nursing-unit-admin/nu-admin-biz/src/main/java/com/nu/modules/nuBizAdvisoryInfo/service/impl/NuBizAdvisoryInfoServiceImpl.java
@@ -1,5 +1,6 @@
 package com.nu.modules.nuBizAdvisoryInfo.service.impl;
 
+import com.nu.dto.NuBizAdvisoryInfoDto;
 import com.nu.modules.nuBaseInfo.entity.NuBaseInfo;
 import com.nu.modules.nuBaseInfo.service.INuBaseInfoService;
 import com.nu.modules.nuBizAdvisoryInfo.entity.NuBizAdvisoryInfo;
@@ -10,7 +11,9 @@ import com.nu.modules.bizEmployeesInfo.entity.BizEmployeesInfo;
 import com.nu.modules.bizEmployeesInfo.service.IBizEmployeesInfoService;
 import com.nu.modules.nuBizCustomerInfo.entity.NuBizCustomerInfo;
 import com.nu.modules.nuBizCustomerInfo.service.INuBizCustomerInfoService;
+import com.nu.utils.RabbitMQUtil;
 import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -35,10 +38,16 @@ public class NuBizAdvisoryInfoServiceImpl extends ServiceImpl<NuBizAdvisoryInfoM
     private INuBizCustomerInfoService nuBizCustomerInfoService;
     @Autowired
     private INuBaseInfoService nuBaseInfoService;
+    @Autowired
+    private RabbitMQUtil rabbitMQUtil;
 
     public boolean save(NuBizAdvisoryInfo entity) {
+
         baseMapper.insert(entity);//插入业务数据
-        serverAdvisoryInfoService.save(entity);//插入运维数据
+//        serverAdvisoryInfoService.save(entity);//插入运维数据
+        NuBizAdvisoryInfoDto nuBizAdvisoryInfoDto = new NuBizAdvisoryInfoDto();
+        BeanUtils.copyProperties(entity,nuBizAdvisoryInfoDto);
+        rabbitMQUtil.sendToExchange("hldy.register","register.addData",nuBizAdvisoryInfoDto);
         return true;
     }
 
diff --git a/nursing-unit-common/src/main/java/com/nu/config/RabbitMQConfig.java b/nursing-unit-common/src/main/java/com/nu/config/RabbitMQConfig.java
index 2d30697..02e2cc9 100644
--- a/nursing-unit-common/src/main/java/com/nu/config/RabbitMQConfig.java
+++ b/nursing-unit-common/src/main/java/com/nu/config/RabbitMQConfig.java
@@ -65,4 +65,18 @@ public class RabbitMQConfig {
     public Binding binding4(Queue nu002FwzlStatusQueue, DirectExchange fwzlExchange) {
         return BindingBuilder.bind(nu002FwzlStatusQueue).to(fwzlExchange).with("nu002.fwzl.status");
     }
+
+    //注册
+    @Bean
+    public DirectExchange registerExchange() {
+        return new DirectExchange("hldy.register");
+    }
+    @Bean
+    public Queue registerAddQueue() {
+        return new Queue("register.addData", true);
+    }
+    @Bean
+    public Binding binding5(Queue registerAddQueue, DirectExchange registerExchange) {
+        return BindingBuilder.bind(registerAddQueue).to(registerExchange).with("register.addData");
+    }
 }
diff --git a/nursing-unit-common/src/main/java/com/nu/dto/NuBizAdvisoryInfoDto.java b/nursing-unit-common/src/main/java/com/nu/dto/NuBizAdvisoryInfoDto.java
new file mode 100644
index 0000000..2ca6656
--- /dev/null
+++ b/nursing-unit-common/src/main/java/com/nu/dto/NuBizAdvisoryInfoDto.java
@@ -0,0 +1,80 @@
+package com.nu.dto;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+import org.jeecg.common.aspect.annotation.Dict;
+import org.jeecgframework.poi.excel.annotation.Excel;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+
+/**
+ * @Description: 咨询信息
+ * @Author: jeecg-boot
+ * @Date:   2025-04-07
+ * @Version: V1.0
+ */
+@Data
+public class NuBizAdvisoryInfoDto implements Serializable {
+    private static final long serialVersionUID = 1L;
+
+	/**id*/
+    private String id;
+    /**微信id*/
+    private String openId;
+    /**微信名称*/
+    private String wechatName;
+	/**咨询人姓名*/
+    private String name;
+	/**性别*/
+    private String sex;
+	/**联系电话*/
+    private String tel;
+	/**咨询类型 1入住nu   2入驻机构  3我要加盟*/
+    private String advisoryType;
+	/**状态 1审核中 2审核完成  3驳回*/
+    private String status;
+	/**审核备注*/
+    private String content;
+    /**机构访问地址*/
+    private String serverUrl;
+	/**创建人*/
+    private String createBy;
+	/**创建日期*/
+    private java.util.Date createTime;
+	/**更新人*/
+    private String updateBy;
+	/**更新日期*/
+    private java.util.Date updateTime;
+	/**所属部门*/
+    private String sysOrgCode;
+    /**老人姓名*/
+    private String oldManName;
+    /**老人年龄*/
+    private String oldManAge;
+    /**医保类型*/
+    private String medicalInsuranceType;
+    /**老人性别*/
+    private String oldManSex;
+    /**报销类型*/
+    private String reimbType;
+    /**护理单元*/
+    private String nuId;
+    private String advisoryTypeName;
+    private String sexName;
+    private String sysOrgCodeName;
+    private String statusName;
+    private String oldManSexName;
+    private String medicalInsuranceTypeName;
+    private String reimbTypeName;
+
+
+}