作者 王勇

配置表字段修改

... ... @@ -28,6 +28,7 @@ public class UserMessageBindingController {
/**
* 分页查询,账户消息绑定配置表,列表
*
* @param serverName 所属服务器名称
* @param username 所属用户登陆名称
* @param virtualHostName 所属虚拟主机名称
* @param exchangeName 所属交换机名称
... ... @@ -41,6 +42,7 @@ public class UserMessageBindingController {
@GetMapping("/list")
public ResultJson<PageInfo> selectUserMessageBindingList(
@RequestParam(value = "username", required = false) String username,
@RequestParam(value = "serverName", required = false) String serverName,
@RequestParam(value = "virtualHostName", required = false) String virtualHostName,
@RequestParam(value = "exchangeName", required = false) String exchangeName,
@RequestParam(value = "queueName", required = false) String queueName,
... ... @@ -54,6 +56,8 @@ public class UserMessageBindingController {
UserMessageBinding userMessageBinding = new UserMessageBinding();
// 获取参数,所属用户登陆名称
userMessageBinding.setUsername(username);
// 获取参数,所属服务器名称
userMessageBinding.setServerName(serverName);
// 获取参数,所属虚拟主机名称
userMessageBinding.setVirtualHostName(virtualHostName);
// 获取参数,所属交换机名称
... ...
... ... @@ -30,6 +30,26 @@ public class MessageNote implements Serializable {
* 用户的ID
*/
private String userId;
/**
* 所属虚拟主机的ID
*/
private String virtualHostId;
/**
* 所属交换机的ID
*/
private String exchangeId;
/**
* 所属队列的ID
*/
private String queueId;
/**
* 所属路由键的ID
*/
private String routingKeyId;
/**
* 用户登陆名称
... ...
... ... @@ -10,14 +10,15 @@ import lombok.NoArgsConstructor;
/**
* @author 子诚
* Description:账户信息绑定配置表
* 时间:2020/7/13 14:24
* 时间:2020/7/13 18:03
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class UserMessageBinding implements Serializable {
private static final long serialVersionUID = -7983498309821536414L;
private static final long serialVersionUID = 7133408333518754607L;
/**
* 账户信息绑定配置表的ID
... ... @@ -35,6 +36,16 @@ public class UserMessageBinding implements Serializable {
private String username;
/**
* 所属服务器的ID
*/
private String serverId;
/**
* 所属服务器名称
*/
private String serverName;
/**
* 所属虚拟主机的ID
*/
private String virtualHostId;
... ...
package com.sunyo.wlpt.message.bus.service.mapper;
import com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding;
import org.apache.ibatis.annotations.Mapper;import org.apache.ibatis.annotations.Param;import java.util.List;
import org.apache.ibatis.annotations.Mapper;import java.util.List;
/**
* @author 子诚
* Description:
* 时间:2020/7/13 14:24
* 时间:2020/7/13 18:03
*/
@Mapper
public interface UserMessageBindingMapper {
... ... @@ -58,7 +58,6 @@ public interface UserMessageBindingMapper {
*/
int updateByPrimaryKey(UserMessageBinding record);
/**
* 分页查询,获取账户信息绑定配置列表
*
... ...
... ... @@ -70,3 +70,4 @@ public interface UserMessageBindingService {
}
... ...
... ... @@ -91,3 +91,4 @@ public class UserMessageBindingServiceImpl implements UserMessageBindingService
}
... ...
... ... @@ -7,6 +7,8 @@
<id column="id" jdbcType="VARCHAR" property="id" />
<result column="user_id" jdbcType="VARCHAR" property="userId" />
<result column="username" jdbcType="VARCHAR" property="username" />
<result column="server_id" jdbcType="VARCHAR" property="serverId" />
<result column="server_name" jdbcType="VARCHAR" property="serverName" />
<result column="virtual_host_id" jdbcType="VARCHAR" property="virtualHostId" />
<result column="virtual_host_name" jdbcType="VARCHAR" property="virtualHostName" />
<result column="exchange_id" jdbcType="VARCHAR" property="exchangeId" />
... ... @@ -21,8 +23,9 @@
</resultMap>
<sql id="Base_Column_List">
<!--@mbg.generated-->
id, user_id, username, virtual_host_id, virtual_host_name, exchange_id, exchange_name,
queue_id, queue_name, routing_key_id, routing_key_name, subscriber, gmt_create, gmt_modified
id, user_id, username, server_id, `server_name`, virtual_host_id, virtual_host_name,
exchange_id, exchange_name, queue_id, queue_name, routing_key_id, routing_key_name,
subscriber, gmt_create, gmt_modified
</sql>
<select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap">
<!--@mbg.generated-->
... ... @@ -39,15 +42,17 @@
<insert id="insert" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
insert into user_message_binding (id, user_id, username,
virtual_host_id, virtual_host_name, exchange_id,
exchange_name, queue_id, queue_name,
routing_key_id, routing_key_name, subscriber,
gmt_create, gmt_modified)
server_id, `server_name`, virtual_host_id,
virtual_host_name, exchange_id, exchange_name,
queue_id, queue_name, routing_key_id,
routing_key_name, subscriber, gmt_create,
gmt_modified)
values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{username,jdbcType=VARCHAR},
#{virtualHostId,jdbcType=VARCHAR}, #{virtualHostName,jdbcType=VARCHAR}, #{exchangeId,jdbcType=VARCHAR},
#{exchangeName,jdbcType=VARCHAR}, #{queueId,jdbcType=VARCHAR}, #{queueName,jdbcType=VARCHAR},
#{routingKeyId,jdbcType=VARCHAR}, #{routingKeyName,jdbcType=VARCHAR}, #{subscriber,jdbcType=VARCHAR},
#{gmtCreate,jdbcType=TIMESTAMP}, #{gmtModified,jdbcType=TIMESTAMP})
#{serverId,jdbcType=VARCHAR}, #{serverName,jdbcType=VARCHAR}, #{virtualHostId,jdbcType=VARCHAR},
#{virtualHostName,jdbcType=VARCHAR}, #{exchangeId,jdbcType=VARCHAR}, #{exchangeName,jdbcType=VARCHAR},
#{queueId,jdbcType=VARCHAR}, #{queueName,jdbcType=VARCHAR}, #{routingKeyId,jdbcType=VARCHAR},
#{routingKeyName,jdbcType=VARCHAR}, #{subscriber,jdbcType=VARCHAR}, #{gmtCreate,jdbcType=TIMESTAMP},
#{gmtModified,jdbcType=TIMESTAMP})
</insert>
<insert id="insertSelective" parameterType="com.sunyo.wlpt.message.bus.service.domain.UserMessageBinding">
<!--@mbg.generated-->
... ... @@ -62,6 +67,12 @@
<if test="username != null">
username,
</if>
<if test="serverId != null">
server_id,
</if>
<if test="serverName != null">
`server_name`,
</if>
<if test="virtualHostId != null">
virtual_host_id,
</if>
... ... @@ -106,6 +117,12 @@
<if test="username != null">
#{username,jdbcType=VARCHAR},
</if>
<if test="serverId != null">
#{serverId,jdbcType=VARCHAR},
</if>
<if test="serverName != null">
#{serverName,jdbcType=VARCHAR},
</if>
<if test="virtualHostId != null">
#{virtualHostId,jdbcType=VARCHAR},
</if>
... ... @@ -151,6 +168,12 @@
<if test="username != null">
username = #{username,jdbcType=VARCHAR},
</if>
<if test="serverId != null">
server_id = #{serverId,jdbcType=VARCHAR},
</if>
<if test="serverName != null">
`server_name` = #{serverName,jdbcType=VARCHAR},
</if>
<if test="virtualHostId != null">
virtual_host_id = #{virtualHostId,jdbcType=VARCHAR},
</if>
... ... @@ -192,6 +215,8 @@
update user_message_binding
set user_id = #{userId,jdbcType=VARCHAR},
username = #{username,jdbcType=VARCHAR},
server_id = #{serverId,jdbcType=VARCHAR},
`server_name` = #{serverName,jdbcType=VARCHAR},
virtual_host_id = #{virtualHostId,jdbcType=VARCHAR},
virtual_host_name = #{virtualHostName,jdbcType=VARCHAR},
exchange_id = #{exchangeId,jdbcType=VARCHAR},
... ... @@ -215,6 +240,10 @@
<if test="username != null and username !=''">
username = #{username,jdbcType=VARCHAR}
</if>
<!-- 所属服务器名称 -->
<if test="serverName != null and serverName !=''">
AND `server_name` = #{serverName,jdbcType=VARCHAR}
</if>
<!-- 所属虚拟主机名称 -->
<if test="virtualHostName != null and virtualHostName !=''">
AND virtual_host_name = #{virtualHostName,jdbcType=VARCHAR}
... ...