Prechádzať zdrojové kódy

增加消息队列消息处理配置类

lixing 4 rokov pred
rodič
commit
7e12eddc25

+ 2 - 2
fm-person/src/main/java/com/persagy/fm/department/constant/DepJmsTypeConstants.java

@@ -10,9 +10,9 @@ public class DepJmsTypeConstants {
     /**
      * 超级管理员账号创建
      */
-    public static final String GROUP_CREATE = "groupCreate";
+    public static final String GROUP_CREATE = "create";
     /**
      * 超级管理员账号更新
      */
-    public static final String GROUP_UPDATE = "groupUpdate";
+    public static final String GROUP_UPDATE = "update";
 }

+ 3 - 2
fm-person/src/main/java/com/persagy/fm/department/jms/handler/GroupMsgHandler.java

@@ -78,7 +78,8 @@ public class GroupMsgHandler extends MsgBaseHandler {
      * @param groupUpdateMsg 集团更新消息
      */
     private void updateGroup(GroupUpdateMsg groupUpdateMsg) {
-
+        // 找到部门类型为集团的部门
+        // 更新部门的名称
     }
 
     /**
@@ -94,7 +95,7 @@ public class GroupMsgHandler extends MsgBaseHandler {
         // 给全局参数赋值
         DefaultAppContext.getContext().setAppId("pc");
         DefaultAppContext.getContext().setGroupCode(groupCreateMsg.getGroupCode());
-        DefaultAppContext.getContext().setAccountId(groupCreateMsg.getUserId());
+        DefaultAppContext.getContext().setAccountId(groupCreateMsg.getUpdateUser());
 
         departmentService.createDepartment(addDepartmentDTO);
     }

+ 3 - 3
fm-person/src/main/java/com/persagy/fm/department/jms/model/GroupCreateMsg.java

@@ -22,10 +22,10 @@ public class GroupCreateMsg extends BaseMsg {
     /**
      * 集团名称
      */
-    private String name;
+    private String groupName;
 
     /**
-     * 创建
+     * 操作
      */
-    private String userId;
+    private String updateUser;
 }

+ 3 - 3
fm-person/src/main/java/com/persagy/fm/department/jms/model/GroupUpdateMsg.java

@@ -22,10 +22,10 @@ public class GroupUpdateMsg extends BaseMsg {
     /**
      * 集团名称
      */
-    private String name;
+    private String groupName;
 
     /**
-     * 更新
+     * 操作
      */
-    private String userId;
+    private String updateUser;
 }

+ 41 - 2
fm-person/src/main/resources/bootstrap.yml

@@ -1,8 +1,47 @@
 spring:
   application:
     name: fm-person
-#  datasource:
-#    dynamic:
+  datasource:
+    druid:
+      stat-view-servlet:
+        enabled: true
+        urlPattern: /druid/*
+        resetEnable: true
+        loginUsername: admin
+        loginPassword: admin
+      web-stat-filter:
+        enabled: true
+        urlPattern: /*
+        sessionStatEnable: false
+        sessionStatMaxCount: 1000
+        profileEnable: true
+    dynamic:
+      druid: #以下是支持的全局默认值
+        initial-size: 5
+        max-active: 20
+        min-idle: 5
+        max-wait: 60000
+        pool-prepared-statements: true
+        max-pool-prepared-statement-per-connection-size: 20
+        validation-query: SELECT 1
+        test-while-idle: true
+        test-on-borrow: false
+        test-on-return: false
+        time-between-eviction-runs-millis: 60000
+        min-evictable-idle-time-millis: 300000
+        max-evictable-idle-time-millis: 900000
+        keep-alive: true
+      datasource:
+        fm-person:
+          url: jdbc:mysql://192.168.64.15:9934/${spring.application.name}?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=GMT%2B8
+          username: root
+          password: brzj123456
+          driver-class-name: com.mysql.jdbc.Driver
+          druid: # 以下是独立参数,每个库可以重新设置
+            initial-size:
+            validation-query: select 1 FROM DUAL #比如oracle就需要重新设置这个
+            public-key: #(非全局参数)设置即表示启用加密,底层会自动帮你配置相关的连接参数和filter,推荐使用本项目自带的加密方法。
+
 server:
   port: ${SERVER_PORT:8814}
 

+ 1 - 1
fm-person/src/main/resources/mapper/DepartmentMapper.xml

@@ -1,6 +1,6 @@
 <?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.persagy.fm.department.dao.DepartmentDao">
+<mapper namespace="com.persagy.fm.department.dao.DepartmentMapper">
 <!--    <resultMap id="DepartmentMap" type="com.persagy.fm.department.model.Department">-->
 <!--        <result column="id" property="id"/>-->
 <!--        <result column="name" property="name"/>-->