diff --git a/.idea/workspace.xml b/.idea/workspace.xml index 0717e5c..3701a31 100644 --- a/.idea/workspace.xml +++ b/.idea/workspace.xml @@ -5,13 +5,16 @@ + + + + + - - @@ -68,33 +71,34 @@ - { - "keyToString": { - "RequestMappingsPanelOrder0": "0", - "RequestMappingsPanelOrder1": "1", - "RequestMappingsPanelWidth0": "75", - "RequestMappingsPanelWidth1": "75", - "WebServerToolWindowFactoryState": "false", - "node.js.detected.package.eslint": "true", - "node.js.detected.package.tslint": "true", - "node.js.selected.package.eslint": "(autodetect)", - "node.js.selected.package.tslint": "(autodetect)", - "nodejs_package_manager_path": "npm", - "settings.editor.selected.configurable": "reference.settings.project.maven.repository.indices", - "spring.configuration.checksum": "647853898192e405c7aff8ecac5564ea", - "vue.rearranger.settings.migration": "true" + +}]]> - - - - - + + + + + @@ -182,7 +186,8 @@ - + + 1724047244829 @@ -422,7 +427,14 @@ - diff --git a/cloud-market-common/src/main/java/com/muyu/market/domain/ReqMsg.java b/cloud-market-common/src/main/java/com/muyu/market/domain/ReqMsg.java new file mode 100644 index 0000000..7fd3d67 --- /dev/null +++ b/cloud-market-common/src/main/java/com/muyu/market/domain/ReqMsg.java @@ -0,0 +1,67 @@ +package com.muyu.market.domain; + +import com.muyu.common.core.annotation.Excel; +import com.muyu.common.core.web.domain.BaseEntity; +import lombok.*; +import lombok.experimental.SuperBuilder; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.baomidou.mybatisplus.annotation.IdType; + +/** + * 请求报文对象 req_msg + * + * @author 2112A + * @date 2024-09-05 + */ + +@Data +@Setter +@Getter +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +@TableName("req_msg") +public class ReqMsg extends BaseEntity{ + private static final long serialVersionUID = 1L; + + /** $column.columnComment */ + @TableId( type = IdType.AUTO) + private Long reqId; + + /** $column.columnComment */ + @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()") + private String reqName; + + /** $column.columnComment */ + @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()") + private String reqType; + + /** $column.columnComment */ + @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()") + private String reqYorn; + + /** $column.columnComment */ + @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()") + private String reqMsg; + + /** $column.columnComment */ + @Excel(name = "${comment}", readConverterExp = "$column.readConverterExp()") + private Long sysId; + + + + @Override + public String toString() { + return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE) + .append("reqId", getReqId()) + .append("reqName", getReqName()) + .append("reqType", getReqType()) + .append("reqYorn", getReqYorn()) + .append("reqMsg", getReqMsg()) + .append("sysId", getSysId()) + .toString(); + } +} diff --git a/cloud-market-server/src/main/java/com/muyu/market/controller/ReqMsgController.java b/cloud-market-server/src/main/java/com/muyu/market/controller/ReqMsgController.java new file mode 100644 index 0000000..f20ef76 --- /dev/null +++ b/cloud-market-server/src/main/java/com/muyu/market/controller/ReqMsgController.java @@ -0,0 +1,112 @@ +package com.muyu.market.controller; + +import java.util.Arrays; +import java.util.List; +import jakarta.servlet.http.HttpServletResponse; +import javax.annotation.Resource; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import com.muyu.common.security.annotation.RequiresPermissions; +import com.muyu.market.domain.ReqMsg; +import com.muyu.market.service.IReqMsgService; +import com.muyu.common.core.web.controller.BaseController; +import com.muyu.common.core.domain.Result; +import com.muyu.common.core.utils.poi.ExcelUtil; +import com.muyu.common.security.utils.SecurityUtils; +import org.springframework.validation.annotation.Validated; +import com.muyu.common.core.web.page.TableDataInfo; + +/** + * 请求报文Controller + * + * @author 2112A + * @date 2024-09-05 + */ +@RestController +@RequestMapping("/msg") +public class ReqMsgController extends BaseController +{ + @Resource + private IReqMsgService reqMsgService; + + /** + * 查询请求报文列表 + */ + @RequiresPermissions("reqmsg:msg:list") + @GetMapping("/list") + public Result> list(ReqMsg reqMsg) + { + startPage(); + List list = reqMsgService.selectReqMsgList(reqMsg); + return getDataTable(list); + } + + /** + * 导出请求报文列表 + */ + @RequiresPermissions("reqmsg:msg:export") + @PostMapping("/export") + public void export(HttpServletResponse response, ReqMsg reqMsg) + { + List list = reqMsgService.selectReqMsgList(reqMsg); + ExcelUtil util = new ExcelUtil(ReqMsg.class); + util.exportExcel(response, list, "请求报文数据"); + } + + /** + * 获取请求报文详细信息 + */ + @RequiresPermissions("reqmsg:msg:query") + @GetMapping(value = "/{reqId}") + public Result> getInfo(@PathVariable("reqId") Long reqId) + { + return success(reqMsgService.selectReqMsgByReqId(reqId)); + } + + /** + * 新增请求报文 + */ + @RequiresPermissions("reqmsg:msg:add") + @PostMapping + public Result add( + @Validated @RequestBody ReqMsg reqMsg) + { + if (reqMsgService.checkIdUnique(reqMsg)) { + return error("新增 请求报文 '" + reqMsg + "'失败，请求报文已存在"); + } + reqMsg.setCreateBy(SecurityUtils.getUsername()); + return toAjax(reqMsgService.save(reqMsg)); + } + + /** + * 修改请求报文 + */ + @RequiresPermissions("reqmsg:msg:edit") + @PutMapping + public Result edit( + @Validated @RequestBody ReqMsg reqMsg) + { + if (!reqMsgService.checkIdUnique(reqMsg)) { + return error("修改 请求报文 '" + reqMsg + "'失败，请求报文不存在"); + } + reqMsg.setUpdateBy(SecurityUtils.getUsername()); + return toAjax(reqMsgService.updateById(reqMsg)); + } + + /** + * 删除请求报文 + */ + @RequiresPermissions("reqmsg:msg:remove") + @DeleteMapping("/{reqIds}") + public Result remove(@PathVariable("reqIds") Long[] reqIds) + { + reqMsgService.removeBatchByIds(Arrays.asList(reqIds)); + return success(); + } +} diff --git a/cloud-market-server/src/main/java/com/muyu/market/mapper/ReqMsgMapper.java b/cloud-market-server/src/main/java/com/muyu/market/mapper/ReqMsgMapper.java new file mode 100644 index 0000000..2ddc90a --- /dev/null +++ b/cloud-market-server/src/main/java/com/muyu/market/mapper/ReqMsgMapper.java @@ -0,0 +1,17 @@ +package com.muyu.market.mapper; + +import java.util.List; +import com.muyu.market.domain.ReqMsg; +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import org.apache.ibatis.annotations.Mapper; + +/** + * 请求报文Mapper接口 + * + * @author 2112A + * @date 2024-09-05 + */ +@Mapper +public interface ReqMsgMapper extends BaseMapper{ + +} diff --git a/cloud-market-server/src/main/java/com/muyu/market/service/IReqMsgService.java b/cloud-market-server/src/main/java/com/muyu/market/service/IReqMsgService.java new file mode 100644 index 0000000..e1eaf03 --- /dev/null +++ b/cloud-market-server/src/main/java/com/muyu/market/service/IReqMsgService.java @@ -0,0 +1,37 @@ +package com.muyu.market.service; + +import java.util.List; +import com.muyu.market.domain.ReqMsg; +import com.baomidou.mybatisplus.extension.service.IService; + +/** + * 请求报文Service接口 + * + * @author 2112A + * @date 2024-09-05 + */ +public interface IReqMsgService extends IService { + /** + * 精确查询请求报文 + * + * @param reqId 请求报文主键 + * @return 请求报文 + */ + public ReqMsg selectReqMsgByReqId(Long reqId); + + /** + * 查询请求报文列表 + * + * @param reqMsg 请求报文 + * @return 请求报文集合 + */ + public List selectReqMsgList(ReqMsg reqMsg); + + /** + * 判断 请求报文 id是否唯一 + * @param reqMsg 请求报文 + * @return 结果 + */ + Boolean checkIdUnique(ReqMsg reqMsg); + +} diff --git a/cloud-market-server/src/main/java/com/muyu/market/service/impl/ReqMsgServiceImpl.java b/cloud-market-server/src/main/java/com/muyu/market/service/impl/ReqMsgServiceImpl.java new file mode 100644 index 0000000..828285c --- /dev/null +++ b/cloud-market-server/src/main/java/com/muyu/market/service/impl/ReqMsgServiceImpl.java @@ -0,0 +1,80 @@ +package com.muyu.market.service.impl; + +import java.util.List; +import org.springframework.stereotype.Service; +import com.muyu.market.mapper.ReqMsgMapper; +import com.muyu.market.domain.ReqMsg; +import com.muyu.market.service.IReqMsgService; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.common.core.utils.StringUtils; +import org.springframework.util.Assert; + +/** + * 请求报文Service业务层处理 + * + * @author 2112A + * @date 2024-09-05 + */ +@Service +public class ReqMsgServiceImpl + extends ServiceImpl + implements IReqMsgService { + + /** + * 精确查询请求报文 + * + * @param reqId 请求报文主键 + * @return 请求报文 + */ + @Override + public ReqMsg selectReqMsgByReqId(Long reqId) + { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + Assert.notNull(reqId, "reqId不可为空"); + queryWrapper.eq(ReqMsg::getReqId, reqId); + return this.getOne(queryWrapper); + } + + + /** + * 查询请求报文列表 + * + * @param reqMsg 请求报文 + * @return 请求报文 + */ + @Override + public List selectReqMsgList(ReqMsg reqMsg) + { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + if (StringUtils.isNotEmpty(reqMsg.getReqName())){ + queryWrapper.like(ReqMsg::getReqName, reqMsg.getReqName()); + } + if (StringUtils.isNotEmpty(reqMsg.getReqType())){ + queryWrapper.eq(ReqMsg::getReqType, reqMsg.getReqType()); + } + if (StringUtils.isNotEmpty(reqMsg.getReqYorn())){ + queryWrapper.eq(ReqMsg::getReqYorn, reqMsg.getReqYorn()); + } + if (StringUtils.isNotEmpty(reqMsg.getReqMsg())){ + queryWrapper.eq(ReqMsg::getReqMsg, reqMsg.getReqMsg()); + } + if (StringUtils.isNotEmpty(new Long[]{reqMsg.getSysId()})){ + queryWrapper.eq(ReqMsg::getSysId, reqMsg.getSysId()); + } + return this.list(queryWrapper); + } + + /** + * 唯一 判断 + * @param reqMsg 请求报文 + * @return 请求报文 + */ + @Override + public Boolean checkIdUnique(ReqMsg reqMsg) { + LambdaQueryWrapper queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.eq(ReqMsg::getReqId, reqMsg.getReqId()); + return this.count(queryWrapper) > 0; + } + +}