理清SpringBoot CURD处理逻辑、顺序
- Controller（控制器）：
- 控制器接收来自客户端的请求，并负责处理请求的路由和参数解析。
- 控制器通常会调用相应的服务层方法来处理业务逻辑，并将结果返回给客户端。
- Service（服务层）：
- 服务层包含了应用程序的业务逻辑。
- 服务层通常会调用数据访问对象（DAO）来进行数据的读取、写入和修改。
- 服务层可以对数据进行处理、验证和转换，并协调多个数据访问对象的操作。
- 服务层的方法可以被控制器调用，也可以被其他服务层方法调用。
- DAO（数据访问对象）：
- 数据访问对象负责与数据源（如数据库）进行交互，执行数据的读取、写入和修改操作。
- DAO通常会定义一组方法，用于执行CRUD操作（创建、读取、更新、删除）。
- DAO可以使用ORM（对象关系映射）工具或手动编写SQL语句来与数据源进行交互。
- DAO的实现可以是直接操作数据库的类，也可以是使用ORM框架生成的类。
- PO（持久化对象）：
- 持久化对象是与数据源中的表或集合相对应的对象。
- 持久化对象通常具有与数据表字段相对应的属性，并提供了用于读取和写入数据的方法。
- 持久化对象可以由ORM框架自动生成，也可以手动编写。
- Repo（仓库接口）：
- 仓库接口定义了对领域对象的持久化和查询方法。
- 仓库接口通常包含根据特定条件查询领域对象的方法，如根据ID查询、根据条件查询等。
- 仓库接口提供了抽象的方法，用于与具体的数据访问对象进行交互。
- RepoImpl（仓库实现类）：
- 仓库实现类是仓库接口的具体实现。
- 仓库实现类负责将仓库接口定义的方法与具体的数据访问对象（DAO）进行关联。
- 仓库实现类实现了仓库接口中定义的方法，并根据需要调用相应的DAO方法。
- Mapper（映射器）：
- 映射器是一种用于将持久化对象与数据库表之间进行映射的工具。
- 映射器可以根据配置文件或注解来定义对象与表之间的映射关系。
- 映射器可以将持久化对象的属性映射到数据库表的列，并提供了CRUD操作的方法
联表查询接口
- Controller
@GetMapping("status") @ApiOperation("公告状态") @Logger(menu = "首页", action = "公告状态") public Result noticeStatus() { List<SystemNoticeResponse> responses = systemNoticeService.SystemNoticeStatus(); return Result.succ(responses); }
- Service
/** * 公告状态 * * @param * @return */ public List<SystemNoticeResponse> SystemNoticeStatus() { Long merchantId = AuthContextHolder.getLoginMerchant().getId(); List<SystemNoticeReaderResponse> systemNoticeReaderResponses = systemNoticeReaderRepo.SystemNoticeReaderStatus(merchantId); Map<String, Integer> idNoticeIdMap = new HashMap<>(); for (SystemNoticeReaderResponse response : systemNoticeReaderResponses) { if (response.getId().equals(response.getNoticeId())) { idNoticeIdMap.put(response.getId(), 1);//已阅读:1 } else { idNoticeIdMap.put(response.getId(), 0);//待阅读:0 } } List<SystemNoticeResponse> noticeResponses = new ArrayList<>(); for (Map.Entry<String, Integer> entry : idNoticeIdMap.entrySet()) { String id = entry.getKey(); long parseLong = Long.parseLong(id); SystemNoticeResponse response = new SystemNoticeResponse( parseLong, systemNoticeRepo.getById(parseLong).getNoticeTitle(), systemNoticeRepo.getById(parseLong).getNoticeContent(), systemNoticeRepo.getById(parseLong).getCreateAt(), entry.getValue() ); noticeResponses.add(response); } noticeResponses = noticeResponses.stream() .sorted(Comparator.comparing(SystemNoticeResponse::getReadStatus) .thenComparing(Comparator.comparing(SystemNoticeResponse::getCreateAt).reversed())) .collect(Collectors.toList()); return noticeResponses; }
- Repo
List<SystemNoticeReaderResponse> SystemNoticeReaderStatus(Long merchantId);
- RepoImpl
@Override public List<SystemNoticeReaderResponse> SystemNoticeReaderStatus(Long merchantId) { return baseMapper.systemNoticeStatus(merchantId); }
- Mapper
List<SystemNoticeReaderResponse> systemNoticeStatus(Long id);
- Mapper.xml
<select id="systemNoticeStatus" parameterType="java.lang.Long" resultMap="systemNoticeStatusResultMap"> SELECT y.id, s.notice_id FROM "system_notice" as y LEFT JOIN "system_notice_reader" as s ON y."id" = s.notice_id AND s.merchant_id = #{id} </select> <resultMap id="systemNoticeStatusResultMap" type="com.moozumi.bean.response.notice.SystemNoticeReaderResponse"> <result column="id" property="id" /> <result column="notice_id" property="NoticeId" /> </resultMap>
- Dao
@Data @Builder @NoArgsConstructor @AllArgsConstructor @TableName("system_notice_reader") public class SystemNoticeReader { /** * null | system_notice_reader.id | @mbg.generated */ @ApiModelProperty("null") @TableId private Long id; /** * 公告 ID | system_notice_reader.notice_id | @mbg.generated */ @ApiModelProperty("公告 ID") private Long noticeId; /** * 已阅读商户 ID | system_notice_reader.merchant_id | @mbg.generated */ @ApiModelProperty("已阅读商户 ID") private Long merchantId; }
- DaoCol：实体类字段对应的枚举类字段
public class SystemNoticeReaderCol { public static final String ID = "id"; public static final String NOTICE_ID = "notice_id"; public static final String MERCHANT_ID = "merchant_id"; }
- DTO（VO）:数据传输对象
@Data @AllArgsConstructor public class SystemNoticeReaderResponse { @ApiModelProperty("ID") private String id; @ApiModelProperty("阅读公告ID") private String NoticeId; }
@Data @AllArgsConstructor public class SystemNoticeResponse { @ApiModelProperty("id") private Long id; @ApiModelProperty("标题") private String noticeTitle; @ApiModelProperty("内容") private String noticeContent; @ApiModelProperty("创建时间") private Date createAt; @ApiModelProperty("阅读状态, 0: 待阅读, 1: 已阅读") private Integer readStatus; }
CURD接口
add
- Controller
@PostMapping("add") @ApiOperation("新增公告") @Logger(menu = "公告管理", action = "新增公告") public Result noticeAdd(@Validated @RequestBody SystemNoticeResponse insert) { systemNoticeService.addSystemNotice(insert); return Result.succ("添加成功"); }
- Service
/** * 公告添加 * * @param insert * @return */ public SystemNotice addSystemNotice(SystemNoticeResponse insert) { SystemNotice notice = new SystemNotice( null, insert.getNoticeTitle(), insert.getNoticeContent(), new Date(), AuthContextHolder.getLoginManager().getUserRealName() ); systemNoticeRepo.save(notice); return notice; }
delete
- Controller
@PostMapping("delete") @ApiOperation("删除公告") @Logger(menu = "公告管理", action = "删除公告") public Result noticeDelete(@Validated @RequestBody CommonRequestId request) { systemNoticeRepo.removeById(request.getId()); return Result.succ("删除成功"); }
update
- Controller
@PostMapping("update") @ApiOperation("编辑公告") @Logger(menu = "公告管理", action = "编辑公告") public Result noticeUpdate(@Validated @RequestBody SystemNoticeResponse insert) { systemNoticeService.updateSystemNotice(insert); return Result.succ("更新成功"); }
- Service
/** * 编辑公告 * * @param insert * @return */ public SystemNotice updateSystemNotice(SystemNoticeResponse insert) { SystemNotice notice = systemNoticeRepo.getById(insert.getId()); if (notice != null) { notice.setNoticeTitle(insert.getNoticeTitle()); notice.setNoticeContent(insert.getNoticeContent()); notice.setCreateAt(new Date()); systemNoticeRepo.updateById(notice); } return notice; }
list
- Controller
@GetMapping("list") @ApiOperation("展示公告") @Logger(menu = "公告管理", action = "展示公告") public Result<PageResult<SystemNotice>> list(SystemNoticeQuery query) { Page<SystemNotice> systemNoticePage = systemNoticeRepo.systemNoticeQuery(query); return Result.succ(PageResult.toPage(systemNoticePage)); }
insert
- Controller
@PostMapping("insert") @ApiOperation("已阅读") @Logger(menu = "首页", action = "已阅读") public Result noticeReader(@Validated @RequestBody CommonRequestId request) { systemNoticeService.SystemNoticeReader(request.getId()); return Result.succ("已阅读"); }
- Service
/** * 公告 已阅读 * * @param * @return */ public SystemNoticeReader SystemNoticeReader(Long noticeId) { SystemNoticeReader notice = new SystemNoticeReader( null, noticeId, AuthContextHolder.getLoginMerchant().getId() ); systemNoticeReaderRepo.save(notice); return notice; }
GetMapping和PostMapping辨析
- @GetMapping：用于获取（查询）资源，不应该用于修改数据（数据库获取）
- @PostMapping：用于创建资源，不应该用于查询数据（数据库编辑、修改）
Request和Response辨析
前端（客户端）—— 后端（服务器端）
- Request（请求）：客户端向服务器发送的一种信息，用于请求操作或获取资源（ 前端 ==》后端 ）
- Response（响应）：Response是服务器对客户端请求的回应，包含服务器处理结果的数据（ 后端 ==》前端 ）
🌼 结语：创作不易，如果觉得博主的文章赏心悦目，还请——
点赞👍收藏⭐️评论📝
