message_bus / message_bus_service · 提交

转到一个项目

作者 王勇
提交 5e9c81de47fadb2e29407de9e70ba4ff661f1e90 1 个父辈 41e6cbc1

简单优化Controller层代码

内嵌 并排对比
正在显示 2 个修改的文件 包含 35 行增加 和 71 行删除
... ... @@ -54,7 +54,7 @@ public class UserMessageBindingController {
* @return 列表 {@link ResultJson}
*/
@GetMapping("/list")
public ResultJson<PageInfo> selectUserMessageBindingList(
public ResultJson selectUserMessageBindingList(
@RequestParam(value = "username", required = false) String username,
@RequestParam(value = "serverName", required = false) String serverName,
@RequestParam(value = "virtualHostName", required = false) String virtualHostName,
... ... @@ -64,35 +64,13 @@ public class UserMessageBindingController {
@RequestParam(value = "subscriber", required = false) String subscriber,
@RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
@RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize) {
ResultJson<PageInfo> result = new ResultJson<>();
UserMessageBinding userMessageBinding = new UserMessageBinding();
// 获取参数，所属用户登陆名称
userMessageBinding.setUsername(username);
// 获取参数，所属服务器名称
userMessageBinding.setServerName(serverName);
// 获取参数，所属虚拟主机名称
userMessageBinding.setVirtualHostName(virtualHostName);
// 获取参数，所属交换机名称
userMessageBinding.setExchangeName(exchangeName);
// 获取参数，所属队列名称
userMessageBinding.setQueueName(queueName);
// 获取参数，所属路由键名称
userMessageBinding.setRoutingKeyName(routingKeyName);
// 获取参数，订阅者
userMessageBinding.setSubscriber(subscriber);
// 获取查询参数
UserMessageBinding userMessageBinding = new UserMessageBinding(username, serverName, virtualHostName, exchangeName, queueName, routingKeyName, subscriber);
// 分页查询
PageInfo pageInfo = userMessageBindingService.selectUserMessageBindingList(userMessageBinding, pageNum, pageSize);
if (pageInfo.getTotal() > 0) {
result.setCode("200");
result.setData(pageInfo);
result.setMsg("查询-账户消息绑定配置列表,成功!");
} else {
result.setCode("500");
result.setMsg("查询-账户消息绑定配置列表,失败!");
}
return result;
return pageInfo.getTotal() > 0
? new ResultJson<>("200", "查询-账户消息绑定配置列表,成功!", pageInfo)
: new ResultJson<>("500", "查询-账户消息绑定配置列表,失败!");
}
/**
... ... @@ -103,16 +81,10 @@ public class UserMessageBindingController {
*/
@DeleteMapping("/delete")
public ResultJson deleteUserMessageBinding(@RequestBody UserMessageBinding userMessageBinding) {
ResultJson result = new ResultJson<>();
int num = userMessageBindingService.deleteByPrimaryKey(userMessageBinding.getId());
if (num > 0) {
result.setCode("200");
result.setMsg("删除-账户消息配置信息，成功");
} else {
result.setCode("500");
result.setMsg("删除-账户消息配置信息，失败");
}
return result;
// 执行删除方法
return userMessageBindingService.deleteByPrimaryKey(userMessageBinding.getId()) > 0
? new ResultJson<>("200", "删除-账户消息配置信息，成功")
: new ResultJson<>("500", "删除-账户消息配置信息，失败");
}
/**
... ... @@ -123,16 +95,10 @@ public class UserMessageBindingController {
*/
@GetMapping("/batchRemove")
public ResultJson batchRemoveUserMessageBinding(String ids) {
ResultJson result = new ResultJson<>();
int num = userMessageBindingService.deleteByPrimaryKey(ids);
if (num > 0) {
result.setCode("200");
result.setMsg("批量删除-账户消息配置-信息,成功!");
} else {
result.setCode("500");
result.setMsg("批量删除-账户消息配置-信息,失败!");
}
return result;
// 执行批量删除
return userMessageBindingService.deleteByPrimaryKey(ids) > 0
? new ResultJson<>("200", "批量删除-账户消息配置信息，成功")
: new ResultJson<>("500", "批量删除-账户消息配置信息，失败");
}
/**
... ... @@ -143,16 +109,10 @@ public class UserMessageBindingController {
*/
@PutMapping("/update")
public ResultJson updateUserMessageBinding(@RequestBody UserMessageBinding userMessageBinding) {
ResultJson result = new ResultJson<>();
int num = userMessageBindingService.updateByPrimaryKeySelective(umb_fillName(userMessageBinding));
if (num > 0) {
result.setCode("200");
result.setMsg("编辑-账户消息配置-信息，成功");
} else {
result.setCode("500");
result.setMsg("编辑-账户消息配置-信息，失败");
}
return result;
// 执行编辑
return userMessageBindingService.updateByPrimaryKeySelective(umb_fillName(userMessageBinding)) > 0
? new ResultJson<>("200", "编辑-账户消息配置-信息，成功")
: new ResultJson<>("500", "编辑-账户消息配置-信息，失败");
}
/**
... ... @@ -163,18 +123,12 @@ public class UserMessageBindingController {
*/
@PostMapping("/insert")
public ResultJson insertUserMessageBinding(@RequestBody UserMessageBinding userMessageBinding) {
ResultJson result = new ResultJson<>();
// 设置id
userMessageBinding.setId(IdUtils.generateId());
int num = userMessageBindingService.insertSelective(umb_fillName(userMessageBinding));
if (num > 0) {
result.setCode("200");
result.setMsg("添加-账户消息配置-信息，成功");
} else {
result.setCode("500");
result.setMsg("添加-账户消息配置-信息，失败");
}
return result;
// 执行新增
return userMessageBindingService.insertSelective(umb_fillName(userMessageBinding)) > 0
? new ResultJson<>("200", "添加-账户消息配置-信息，成功")
: new ResultJson<>("500", "添加-账户消息配置-信息，失败");
}
/**
... ...
package com.sunyo.wlpt.message.bus.service.domain;
import java.io.Serializable;
import java.util.Date;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.io.Serializable;
import java.util.Date;
/**
* @author 子诚
* Description：账户信息绑定配置表
... ... @@ -103,4 +103,14 @@ public class UserMessageBinding implements Serializable {
* 修改时间
*/
private Date gmtModified;
public UserMessageBinding(String username, String serverName, String virtualHostName, String exchangeName, String queueName, String routingKeyName, String subscriber) {
this.username = username;
this.serverName = serverName;
this.virtualHostName = virtualHostName;
this.exchangeName = exchangeName;
this.queueName = queueName;
this.routingKeyName = routingKeyName;
this.subscriber = subscriber;
}
}
\ No newline at end of file
... ...