message_bus / message_bus_service · 提交

转到一个项目

作者 王勇
提交 b270b25fecb692cff427ae378a5969255694bbc7 1 个父辈 81d93605

简单优化Controller层代码

内嵌 并排对比
正在显示 6 个修改的文件 包含 76 行增加 和 113 行删除
@@ -13,5 +13,5 @@ public class Constant { @@ -13,5 +13,5 @@ public class Constant {
13 13
14 public static final String EXIST_EXCHANGE_INFO = "该-交换机（交换机名称）-信息已存在，请谨慎输入"; 14 public static final String EXIST_EXCHANGE_INFO = "该-交换机（交换机名称）-信息已存在，请谨慎输入";
15 15
16 - 16 + public static final String EXIST_QUEUE_INFO = "该-消息队列-信息已存在，请谨慎输入";
17 } 17 }
@@ -88,8 +88,8 @@ public class BusExchangeController { @@ -88,8 +88,8 @@ public class BusExchangeController {
88 String message = validateBusExchange(busExchange); 88 String message = validateBusExchange(busExchange);
89 return message == null 89 return message == null
90 ? busExchangeService.updateByPrimaryKeySelective(busExchange) > 0 90 ? busExchangeService.updateByPrimaryKeySelective(busExchange) > 0
91 - ? new ResultJson<>("200", "编辑MQ交换机信息，成功")  
92 - : new ResultJson<>("500", "编辑MQ交换机信息，失败") 91 + ? new ResultJson<>("200", "编辑MQ交换机信息，成功")
  92 + : new ResultJson<>("500", "编辑MQ交换机信息，失败")
93 : new ResultJson<>("400", message); 93 : new ResultJson<>("400", message);
94 } 94 }
95 95
@@ -103,15 +103,13 @@ public class BusExchangeController { @@ -103,15 +103,13 @@ public class BusExchangeController {
103 public ResultJson insertBusExchange(@RequestBody BusExchange busExchange) { 103 public ResultJson insertBusExchange(@RequestBody BusExchange busExchange) {
104 //先验证，增加的虚拟主机的核心信息（交换机名称）是否已存在 104 //先验证，增加的虚拟主机的核心信息（交换机名称）是否已存在
105 String message = validateBusExchange(busExchange); 105 String message = validateBusExchange(busExchange);
106 - //验证通过  
107 - if (message == null) {  
108 - // 设置id  
109 - busExchange.setId(IdUtils.generateId());  
110 - return busExchangeService.insertSelective(busExchange) > 0  
111 - ? new ResultJson<>("200", "添加交换机信息，成功")  
112 - : new ResultJson<>("500", "添加交换机信息，失败");  
113 - }  
114 - return new ResultJson<>("400", message); 106 + // 设置id
  107 + busExchange.setId(IdUtils.generateId());
  108 + return message == null
  109 + ? busExchangeService.insertSelective(busExchange) > 0
  110 + ? new ResultJson<>("200", "新增MQ交换机信息，成功")
  111 + : new ResultJson<>("500", "新增MQ交换机信息，失败")
  112 + : new ResultJson<>("400", message);
115 } 113 }
116 114
117 115
1 package com.sunyo.wlpt.message.bus.service.controller; 1 package com.sunyo.wlpt.message.bus.service.controller;
2 2
3 import com.github.pagehelper.PageInfo; 3 import com.github.pagehelper.PageInfo;
4 -import com.sunyo.wlpt.message.bus.service.domain.BusExchange;  
5 import com.sunyo.wlpt.message.bus.service.domain.BusQueue; 4 import com.sunyo.wlpt.message.bus.service.domain.BusQueue;
6 import com.sunyo.wlpt.message.bus.service.response.ResultJson; 5 import com.sunyo.wlpt.message.bus.service.response.ResultJson;
7 import com.sunyo.wlpt.message.bus.service.service.BusQueueService; 6 import com.sunyo.wlpt.message.bus.service.service.BusQueueService;
@@ -11,6 +10,8 @@ import org.springframework.web.bind.annotation.*; @@ -11,6 +10,8 @@ import org.springframework.web.bind.annotation.*;
11 import javax.annotation.Resource; 10 import javax.annotation.Resource;
12 import java.util.List; 11 import java.util.List;
13 12
  13 +import static com.sunyo.wlpt.message.bus.service.common.Constant.EXIST_QUEUE_INFO;
  14 +
14 /** 15 /**
15 * @author 子诚 16 * @author 子诚
16 * Description：关于消息队列的控制器 17 * Description：关于消息队列的控制器
@@ -28,34 +29,23 @@ public class BusQueueController { @@ -28,34 +29,23 @@ public class BusQueueController {
28 * 分页查询，消息队列-列表 29 * 分页查询，消息队列-列表
29 * 30 *
30 * @param virtualHostId 所属虚拟主机id 31 * @param virtualHostId 所属虚拟主机id
31 - * @param queueName 消息队列名称  
32 - * @param pageNum 当前页数  
33 - * @param pageSize 每页数量 32 + * @param queueName 消息队列名称
  33 + * @param pageNum 当前页数
  34 + * @param pageSize 每页数量
34 * @return 成功返回，消息队列-列表 35 * @return 成功返回，消息队列-列表
35 */ 36 */
36 @GetMapping("/list") 37 @GetMapping("/list")
37 public ResultJson<PageInfo> selectBusQueueList( 38 public ResultJson<PageInfo> selectBusQueueList(
38 - @RequestParam(value = "virtualHostId", required = false) String virtualHostId,  
39 @RequestParam(value = "queueName", required = false) String queueName, 39 @RequestParam(value = "queueName", required = false) String queueName,
  40 + @RequestParam(value = "virtualHostId", required = false) String virtualHostId,
40 @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum, 41 @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
41 @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize) { 42 @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize) {
42 - ResultJson<PageInfo> result = new ResultJson<>();  
43 - BusQueue busQueue = new BusQueue();  
44 - // 获取参数，所属虚拟主机id  
45 - busQueue.setVirtualHostId(virtualHostId);  
46 - // 获取参数，队列名称  
47 - busQueue.setQueueName(queueName); 43 +
48 // 分页查询 44 // 分页查询
49 - PageInfo pageInfo = busQueueService.selectBusQueueList(busQueue, pageNum, pageSize);  
50 - if (pageInfo.getTotal() > 0) {  
51 - result.setCode("200");  
52 - result.setData(pageInfo);  
53 - result.setMsg("查询-消息队列-列表,成功!");  
54 - } else {  
55 - result.setCode("500");  
56 - result.setMsg("查询-消息队列-列表,失败!");  
57 - }  
58 - return result; 45 + PageInfo pageInfo = busQueueService.selectBusQueueList(new BusQueue(queueName, virtualHostId), pageNum, pageSize);
  46 + return pageInfo.getTotal() > 0
  47 + ? new ResultJson<>("200", "查询-消息队列-列表,成功!", pageInfo)
  48 + : new ResultJson<>("500", "查询-消息队列-列表,失败!");
59 } 49 }
60 50
61 /** 51 /**
@@ -66,16 +56,10 @@ public class BusQueueController { @@ -66,16 +56,10 @@ public class BusQueueController {
66 */ 56 */
67 @DeleteMapping("/delete") 57 @DeleteMapping("/delete")
68 public ResultJson deleteBusQueue(@RequestBody BusQueue busQueue) { 58 public ResultJson deleteBusQueue(@RequestBody BusQueue busQueue) {
69 - ResultJson result = new ResultJson<>();  
70 - int num = busQueueService.deleteByPrimaryKey(busQueue.getId());  
71 - if (num > 0) {  
72 - result.setCode("200");  
73 - result.setMsg("删除-消息队列，成功");  
74 - } else {  
75 - result.setCode("500");  
76 - result.setMsg("删除-消息交换机，失败");  
77 - }  
78 - return result; 59 +
  60 + return busQueueService.deleteByPrimaryKey(busQueue.getId()) > 0
  61 + ? new ResultJson<>("200", "删除消息队列，成功")
  62 + : new ResultJson<>("500", "删除消息队列，失败");
79 } 63 }
80 64
81 /** 65 /**
@@ -87,16 +71,9 @@ public class BusQueueController { @@ -87,16 +71,9 @@ public class BusQueueController {
87 @GetMapping("/batchRemove") 71 @GetMapping("/batchRemove")
88 public ResultJson batchRemoveBusQueue(String ids) { 72 public ResultJson batchRemoveBusQueue(String ids) {
89 73
90 - ResultJson result = new ResultJson<>();  
91 - int num = busQueueService.deleteByPrimaryKey(ids);  
92 - if (num > 0) {  
93 - result.setCode("200");  
94 - result.setMsg("批量删除消息队列,成功!");  
95 - } else {  
96 - result.setCode("500");  
97 - result.setMsg("批量删除消息队列,失败!");  
98 - }  
99 - return result; 74 + return busQueueService.deleteByPrimaryKey(ids) > 0
  75 + ? new ResultJson<>("200", "批量删除消息队列，成功")
  76 + : new ResultJson<>("500", "批量删除消息队列，失败");
100 } 77 }
101 78
102 /** 79 /**
@@ -109,20 +86,11 @@ public class BusQueueController { @@ -109,20 +86,11 @@ public class BusQueueController {
109 public ResultJson updateBusQueue(@RequestBody BusQueue busQueue) { 86 public ResultJson updateBusQueue(@RequestBody BusQueue busQueue) {
110 // 先校验队列名称 87 // 先校验队列名称
111 String message = validateBusQueue(busQueue); 88 String message = validateBusQueue(busQueue);
112 - // 验证通过  
113 - if (message == null) {  
114 - ResultJson result = new ResultJson<>();  
115 - int num = busQueueService.updateByPrimaryKeySelective(busQueue);  
116 - if (num > 0) {  
117 - result.setCode("200");  
118 - result.setMsg("编辑-消息队列-信息，成功");  
119 - } else {  
120 - result.setCode("500");  
121 - result.setMsg("编辑-消息队列-信息，失败");  
122 - }  
123 - return result;  
124 - }  
125 - return new ResultJson("400", message != null ? message : "编辑-消息队列-信息,失败!"); 89 + return message == null
  90 + ? busQueueService.updateByPrimaryKeySelective(busQueue) > 0
  91 + ? new ResultJson<>("200", "编辑消息队列信息，成功")
  92 + : new ResultJson<>("500", "编辑消息队列信息，失败")
  93 + : new ResultJson<>("400", message);
126 } 94 }
127 95
128 /** 96 /**
@@ -135,22 +103,14 @@ public class BusQueueController { @@ -135,22 +103,14 @@ public class BusQueueController {
135 public ResultJson insertBusQueue(@RequestBody BusQueue busQueue) { 103 public ResultJson insertBusQueue(@RequestBody BusQueue busQueue) {
136 //先验证，增加的虚拟主机的核心信息（交换机名称）是否已存在 104 //先验证，增加的虚拟主机的核心信息（交换机名称）是否已存在
137 String message = validateBusQueue(busQueue); 105 String message = validateBusQueue(busQueue);
  106 + // 设置id
  107 + busQueue.setId(IdUtils.generateId());
138 //验证通过 108 //验证通过
139 - if (message == null) {  
140 - ResultJson result = new ResultJson<>();  
141 - // 设置id  
142 - busQueue.setId(IdUtils.generateId());  
143 - int num = busQueueService.insertSelective(busQueue);  
144 - if (num > 0) {  
145 - result.setCode("200");  
146 - result.setMsg("添加-消息队列-信息，成功!");  
147 - } else {  
148 - result.setCode("500");  
149 - result.setMsg("添加-消息队列-信息，失败!");  
150 - }  
151 - return result;  
152 - }  
153 - return new ResultJson("400", message != null ? message : "添加-消息队列-信息,失败!"); 109 + return message == null
  110 + ? busQueueService.insertSelective(busQueue) > 0
  111 + ? new ResultJson<>("200", "添加消息队列，成功")
  112 + : new ResultJson<>("500", "添加消息队列，失败")
  113 + : new ResultJson<>("400", message);
154 } 114 }
155 115
156 /** 116 /**
@@ -175,7 +135,7 @@ public class BusQueueController { @@ -175,7 +135,7 @@ public class BusQueueController {
175 List<BusQueue> info = busQueueService.validateBusQueue(busQueue); 135 List<BusQueue> info = busQueueService.validateBusQueue(busQueue);
176 // 多于0个，则代表已存在；否则则是，校验通过 136 // 多于0个，则代表已存在；否则则是，校验通过
177 if (info.size() > 0) { 137 if (info.size() > 0) {
178 - return "该-消息队列（队列名称）-信息已存在，请谨慎输入"; 138 + return EXIST_QUEUE_INFO;
179 } 139 }
180 return null; 140 return null;
181 } 141 }
@@ -188,7 +148,7 @@ public class BusQueueController { @@ -188,7 +148,7 @@ public class BusQueueController {
188 List<BusQueue> info = busQueueService.validateBusQueue(busQueue); 148 List<BusQueue> info = busQueueService.validateBusQueue(busQueue);
189 // 多于0个，则代表已存在；否则则是，校验通过 149 // 多于0个，则代表已存在；否则则是，校验通过
190 if (info.size() > 0) { 150 if (info.size() > 0) {
191 - return "该-消息队列-信息已存在，请谨慎输入"; 151 + return EXIST_QUEUE_INFO;
192 } 152 }
193 return null; 153 return null;
194 } 154 }
@@ -10,8 +10,8 @@ import org.springframework.web.bind.annotation.*; @@ -10,8 +10,8 @@ import org.springframework.web.bind.annotation.*;
10 import javax.annotation.Resource; 10 import javax.annotation.Resource;
11 import java.util.List; 11 import java.util.List;
12 12
13 -import static com.sunyo.wlpt.message.bus.service.common.Constant.EXIST_SERVER_INFO;  
14 import static com.sunyo.wlpt.message.bus.service.common.Constant.EXIST_SERVERNAME; 13 import static com.sunyo.wlpt.message.bus.service.common.Constant.EXIST_SERVERNAME;
  14 +import static com.sunyo.wlpt.message.bus.service.common.Constant.EXIST_SERVER_INFO;
15 15
16 /** 16 /**
17 * @author 子诚 17 * @author 子诚
@@ -85,13 +85,11 @@ public class BusServerController { @@ -85,13 +85,11 @@ public class BusServerController {
85 if (EXIST_SERVERNAME.equals(message)) { 85 if (EXIST_SERVERNAME.equals(message)) {
86 return new ResultJson<>("402", "MQ服务器名称已存在"); 86 return new ResultJson<>("402", "MQ服务器名称已存在");
87 } 87 }
88 - //验证通过  
89 - if (message == null) {  
90 - return busServerService.updateByPrimaryKeySelective(busServer) > 0  
91 - ? new ResultJson<>("200", "修改服务器信息，成功")  
92 - : new ResultJson<>("500", "修改服务器信息，失败");  
93 - }  
94 - return new ResultJson<>("400", message); 88 + return message == null
  89 + ? busServerService.updateByPrimaryKeySelective(busServer) > 0
  90 + ? new ResultJson<>("200", "修改服务器信息，成功")
  91 + : new ResultJson<>("500", "修改服务器信息，失败")
  92 + : new ResultJson<>("400", message);
95 } 93 }
96 94
97 /** 95 /**
@@ -107,15 +105,13 @@ public class BusServerController { @@ -107,15 +105,13 @@ public class BusServerController {
107 if (EXIST_SERVERNAME.equals(message)) { 105 if (EXIST_SERVERNAME.equals(message)) {
108 return new ResultJson<>("402", "MQ服务器名称已存在"); 106 return new ResultJson<>("402", "MQ服务器名称已存在");
109 } 107 }
110 - //验证通过  
111 - if (message == null) {  
112 - // 设置id  
113 - busServer.setId(IdUtils.generateId());  
114 - return busServerService.insertSelective(busServer) > 0  
115 - ? new ResultJson<>("200", "添加服务器信息，成功")  
116 - : new ResultJson<>("500", "添加服务器信息，失败");  
117 - }  
118 - return new ResultJson<>("400", message); 108 + // 设置id
  109 + busServer.setId(IdUtils.generateId());
  110 + return message == null
  111 + ? busServerService.insertSelective(busServer) > 0
  112 + ? new ResultJson<>("200", "添加服务器信息，成功")
  113 + : new ResultJson<>("500", "添加服务器信息，失败")
  114 + : new ResultJson<>("400", message);
119 } 115 }
120 116
121 /** 117 /**
@@ -100,15 +100,13 @@ public class VirtualHostController { @@ -100,15 +100,13 @@ public class VirtualHostController {
100 public ResultJson insertVirtualHost(@RequestBody VirtualHost virtualHost) { 100 public ResultJson insertVirtualHost(@RequestBody VirtualHost virtualHost) {
101 //先验证，增加的虚拟主机的核心信息（虚拟主机名称）是否已存在 101 //先验证，增加的虚拟主机的核心信息（虚拟主机名称）是否已存在
102 String message = validateVirtualHost(virtualHost); 102 String message = validateVirtualHost(virtualHost);
103 - //验证通过  
104 - if (message == null) {  
105 - // 设置id  
106 - virtualHost.setId(IdUtils.generateId());  
107 - return virtualHostService.insertSelective(virtualHost) > 0  
108 - ? new ResultJson<>("200", "添加虚拟主机信息，成功")  
109 - : new ResultJson<>("500", "添加虚拟主机信息，失败");  
110 - }  
111 - return new ResultJson<>("400", message); 103 + // 设置id
  104 + virtualHost.setId(IdUtils.generateId());
  105 + return message == null
  106 + ? virtualHostService.insertSelective(virtualHost) > 0
  107 + ? new ResultJson<>("200", "新增虚拟主机信息，成功")
  108 + : new ResultJson<>("500", "新增虚拟主机信息，失败")
  109 + : new ResultJson<>("400", message);
112 } 110 }
113 111
114 /** 112 /**
1 package com.sunyo.wlpt.message.bus.service.domain; 1 package com.sunyo.wlpt.message.bus.service.domain;
2 2
3 -import java.io.Serializable;  
4 -import java.util.Date;  
5 -  
6 import com.fasterxml.jackson.annotation.JsonFormat; 3 import com.fasterxml.jackson.annotation.JsonFormat;
7 import lombok.AllArgsConstructor; 4 import lombok.AllArgsConstructor;
8 import lombok.Data; 5 import lombok.Data;
9 import lombok.NoArgsConstructor; 6 import lombok.NoArgsConstructor;
10 7
  8 +import java.io.Serializable;
  9 +import java.util.Date;
  10 +
11 /** 11 /**
12 * @author 子诚 12 * @author 子诚
13 * Description：队列表 13 * Description：队列表
@@ -76,4 +76,15 @@ public class BusQueue implements Serializable { @@ -76,4 +76,15 @@ public class BusQueue implements Serializable {
76 * 一个队列对应一个虚拟主机 76 * 一个队列对应一个虚拟主机
77 */ 77 */
78 private VirtualHost virtualHost; 78 private VirtualHost virtualHost;
  79 +
  80 + /**
  81 + * 定义有参构造器，封装 BusQueueController 的查询参数
  82 + *
  83 + * @param queueName 队列名称
  84 + * @param virtualHostId 所属虚拟主机ID
  85 + */
  86 + public BusQueue(String queueName, String virtualHostId) {
  87 + this.queueName = queueName;
  88 + this.virtualHostId = virtualHostId;
  89 + }
79 } 90 }