Controller

  1. package com.shiers.controller.center;
  3. import com.shiers.controller.BaseController;
  4. import com.shiers.enums.YesOrNo;
  5. import com.shiers.pojo.OrderItems;
  6. import com.shiers.pojo.Orders;
  7. import com.shiers.pojo.bo.center.OrderItemsCommentBO;
  8. import com.shiers.service.center.MyCommentsService;
  9. import com.shiers.utils.MyJSONResult;
  10. import com.shiers.utils.PagedGridResult;
  11. import io.swagger.annotations.Api;
  12. import io.swagger.annotations.ApiOperation;
  13. import io.swagger.annotations.ApiParam;
  14. import org.apache.commons.lang3.StringUtils;
  15. import org.springframework.beans.factory.annotation.Autowired;
  16. import org.springframework.http.HttpStatus;
  17. import org.springframework.web.bind.annotation.*;
  19. import java.util.List;
  21. /**
  22.  * Demo class
  23.  *
  24.  * @author shierS
  25.  * @date 2021/6/9
  26.  */
  27. @Api(value = "用户中心评价模块", tags = {"用户中心评价模块相关接口"})
  28. @RestController
  29. @RequestMapping("mycomments")
  30. public class MyCommentsController extends BaseController {
  32.     @Autowired
  33.     private MyCommentsService myCommentsService;
  36.     @ApiOperation(value = "查询订单列表", notes = "查询订单列表", httpMethod = "POST")
  37.     @PostMapping("/pending")
  38.     public MyJSONResult pending(
  39.         @ApiParam(name = "userId", value = "用户id", required = true)
  40.         @RequestParam String userId,
  41.         @ApiParam(name = "orderId", value = "订单id", required = true)
  42.         @RequestParam String orderId) {
  44.         // 判断用户和订单是否关联
  45.         MyJSONResult checkResult = checkUserOrder(userId, orderId);
  46.         if (checkResult.getStatus() != HttpStatus.OK.value()) {
  47.             return checkResult;
  48.         }
  49.         // 判断该笔订单是否已经评价过，评价过了就不再继续
  50.         Orders myOrder = (Orders)checkResult.getData();
  51.         if (myOrder.getIsComment() == YesOrNo.YES.type) {
  52.             return MyJSONResult.errorMsg("该笔订单已经评价");
  53.         }
  55.         List<OrderItems> list = myCommentsService.queryPendingComment(orderId);
  57.         return MyJSONResult.ok(list);
  58.     }
  61.     @ApiOperation(value = "保存评论列表", notes = "保存评论列表", httpMethod = "POST")
  62.     @PostMapping("/saveList")
  63.     public MyJSONResult saveList(
  64.         @ApiParam(name = "userId", value = "用户id", required = true)
  65.         @RequestParam String userId,
  66.         @ApiParam(name = "orderId", value = "订单id", required = true)
  67.         @RequestParam String orderId,
  68.         @RequestBody List<OrderItemsCommentBO> commentList) {
  70.         System.out.println(commentList);
  72.         // 判断用户和订单是否关联
  73.         MyJSONResult checkResult = checkUserOrder(userId, orderId);
  74.         if (checkResult.getStatus() != HttpStatus.OK.value()) {
  75.             return checkResult;
  76.         }
  77.         // 判断评论内容list不能为空
  78.         if (commentList == null || commentList.isEmpty() || commentList.size() == 0) {
  79.             return MyJSONResult.errorMsg("评论内容不能为空！");
  80.         }
  82.         myCommentsService.saveComments(orderId, userId, commentList);
  83.         return MyJSONResult.ok();
  84.     }
  86.     @ApiOperation(value = "查询我的评价", notes = "查询我的评价", httpMethod = "POST")
  87.     @PostMapping("/query")
  88.     public MyJSONResult query(
  89.         @ApiParam(name = "userId", value = "用户id", required = true)
  90.         @RequestParam String userId,
  91.         @ApiParam(name = "page", value = "查询下一页的第几页", required = false)
  92.         @RequestParam Integer page,
  93.         @ApiParam(name = "pageSize", value = "分页的每一页显示的条数", required = false)
  94.         @RequestParam Integer pageSize) {
  96.         if (StringUtils.isBlank(userId)) {
  97.             return MyJSONResult.errorMsg(null);
  98.         }
  99.         if (page == null) {
  100.             page = 1;
  101.         }
  102.         if (pageSize == null) {
  103.             pageSize = COMMON_PAGE_SIZE;
  104.         }
  106.         PagedGridResult grid = myCommentsService.queryMyComments(userId,
  107.                                                                  page,
  108.                                                                  pageSize);
  110.         return MyJSONResult.ok(grid);
  111.     }
  114. }

Service

  1. package com.shiers.service.center;
  3. import com.shiers.pojo.OrderItems;
  4. import com.shiers.pojo.bo.center.OrderItemsCommentBO;
  5. import com.shiers.utils.PagedGridResult;
  7. import java.util.List;
  9. /**
  10.  * Demo class
  11.  *
  12.  * @author shierS
  13.  * @date 2021/6/9
  14.  */
  15. public interface MyCommentsService {
  17.     /**
  18.      * 根据订单id查询关联的商品
  19.      *
  20.      * @param orderId
  21.      * @return
  22.      */
  23.     public List<OrderItems> queryPendingComment(String orderId);
  25.     /**
  26.      * 保存用户的评论
  27.      *
  28.      * @param orderId
  29.      * @param userId
  30.      * @param commentList
  31.      */
  32.     public void saveComments(String orderId, String userId, List<OrderItemsCommentBO> commentList);
  35.     /**
  36.      * 我的评价查询 分页
  37.      *
  38.      * @param userId
  39.      * @param page
  40.      * @param pageSize
  41.      * @return
  42.      */
  43.     public PagedGridResult queryMyComments(String userId, Integer page, Integer pageSize);
  44. }

ServiceImpl

  1. package com.shiers.service.impl.center;
  3. import com.github.pagehelper.PageHelper;
  4. import com.shiers.enums.YesOrNo;
  5. import com.shiers.mapper.ItemsCommentsMapperCustom;
  6. import com.shiers.mapper.OrderItemsMapper;
  7. import com.shiers.mapper.OrderStatusMapper;
  8. import com.shiers.mapper.OrdersMapper;
  9. import com.shiers.pojo.OrderItems;
  10. import com.shiers.pojo.OrderStatus;
  11. import com.shiers.pojo.Orders;
  12. import com.shiers.pojo.bo.center.OrderItemsCommentBO;
  13. import com.shiers.pojo.vo.MyCommentVO;
  14. import com.shiers.service.center.MyCommentsService;
  15. import com.shiers.utils.PagedGridResult;
  16. import org.n3r.idworker.Sid;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.stereotype.Service;
  19. import org.springframework.transaction.annotation.Propagation;
  20. import org.springframework.transaction.annotation.Transactional;
  22. import java.util.Date;
  23. import java.util.HashMap;
  24. import java.util.List;
  25. import java.util.Map;
  27. /**
  28.  * Demo class
  29.  *
  30.  * @author shierS
  31.  * @date 2021/6/9
  32.  */
  33. @Service
  34. public class MyCommentsServiceImpl extends BaseService implements MyCommentsService {
  36.     @Autowired
  37.     public OrderItemsMapper orderItemsMapper;
  39.     @Autowired
  40.     public OrdersMapper ordersMapper;
  42.     @Autowired
  43.     public OrderStatusMapper orderStatusMapper;
  45.     @Autowired
  46.     public ItemsCommentsMapperCustom itemsCommentsMapperCustom;
  48.     @Autowired
  49.     private Sid sid;
  51.     @Transactional(propagation = Propagation.SUPPORTS)
  52.     @Override
  53.     public List<OrderItems> queryPendingComment(String orderId) {
  54.         OrderItems query = new OrderItems();
  55.         query.setOrderId(orderId);
  56.         return orderItemsMapper.select(query);
  57.     }
  59.     @Transactional(propagation = Propagation.REQUIRED)
  60.     @Override
  61.     public void saveComments(String orderId, String userId,
  62.                              List<OrderItemsCommentBO> commentList) {
  64.         // 1. 保存评价 items_comments
  65.         for (OrderItemsCommentBO oic : commentList) {
  66.             oic.setCommentId(sid.nextShort());
  67.         }
  68.         Map<String, Object> map = new HashMap<>();
  69.         map.put("userId", userId);
  70.         map.put("commentList", commentList);
  71.         itemsCommentsMapperCustom.saveComments(map);
  73.         // 2. 修改订单表改已评价 orders
  74.         Orders order = new Orders();
  75.         order.setId(orderId);
  76.         order.setIsComment(YesOrNo.YES.type);
  77.         ordersMapper.updateByPrimaryKeySelective(order);
  79.         // 3. 修改订单状态表的留言时间 order_status
  80.         OrderStatus orderStatus = new OrderStatus();
  81.         orderStatus.setOrderId(orderId);
  82.         orderStatus.setCommentTime(new Date());
  83.         orderStatusMapper.updateByPrimaryKeySelective(orderStatus);
  84.     }
  86.     @Transactional(propagation = Propagation.SUPPORTS)
  87.     @Override
  88.     public PagedGridResult queryMyComments(String userId,
  89.                                            Integer page,
  90.                                            Integer pageSize) {
  92.         Map<String, Object> map = new HashMap<>();
  93.         map.put("userId", userId);
  95.         PageHelper.startPage(page, pageSize);
  96.         List<MyCommentVO> list = itemsCommentsMapperCustom.queryMyComments(map);
  98.         return setterPagedGrid(list, page);
  99.     }
  101.     //    public PagedGridResult setterPagedGrid(List<?> list, Integer page) {
  102.     //        PageInfo<?> pageList = new PageInfo<>(list);
  103.     //        PagedGridResult grid = new PagedGridResult();
  104.     //        grid.setPage(page);
  105.     //        grid.setRows(list);
  106.     //        grid.setTotal(pageList.getPages());
  107.     //        grid.setRecords(pageList.getTotal());
  108.     //        return grid;
  109.     //    }
  110. }