UserOrderService.java 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146
  1. package com.qxgmat.service.inline;
  2. import com.github.pagehelper.Page;
  3. import com.nuliji.tools.AbstractService;
  4. import com.nuliji.tools.Tools;
  5. import com.nuliji.tools.Transform;
  6. import com.nuliji.tools.exception.ParameterException;
  7. import com.nuliji.tools.exception.SystemException;
  8. import com.nuliji.tools.mybatis.Example;
  9. import com.qxgmat.data.constants.enums.module.ProductType;
  10. import com.qxgmat.data.constants.enums.status.DirectionStatus;
  11. import com.qxgmat.data.dao.UserOrderMapper;
  12. import com.qxgmat.data.dao.entity.UserOrder;
  13. import com.qxgmat.data.relation.UserOrderRelationMapper;
  14. import org.slf4j.Logger;
  15. import org.slf4j.LoggerFactory;
  16. import org.springframework.stereotype.Service;
  17. import javax.annotation.Resource;
  18. import java.util.Collection;
  19. import java.util.HashMap;
  20. import java.util.List;
  21. import java.util.Map;
  22. @Service
  23. public class UserOrderService extends AbstractService {
  24. private static final Logger logger = LoggerFactory.getLogger(UserOrderService.class);
  25. @Resource
  26. private UserOrderMapper userOrderMapper;
  27. @Resource
  28. private UserOrderRelationMapper userOrderRelationMapper;
  29. private Map<String, String> adminMap = new HashMap<String, String>(){{
  30. put("", "uo");
  31. }};
  32. public Page<UserOrder> list(int page, int size, Integer userId, String order, DirectionStatus direction){
  33. Example example = new Example(UserOrder.class);
  34. if(userId != null){
  35. example.and(
  36. example.createCriteria()
  37. .andEqualTo("userId", userId)
  38. );
  39. }
  40. if(order == null || order.isEmpty()) order = "id";
  41. switch(direction){
  42. case ASC:
  43. example.orderBy(order).asc();
  44. break;
  45. case DESC:
  46. default:
  47. example.orderBy(order).desc();
  48. }
  49. return select(userOrderMapper, example, page, size);
  50. }
  51. public Page<UserOrder> listAdmin(int page, int size, Integer userId, String productType, String payMethod, Integer orderId, String order, DirectionStatus direction){
  52. if(order == null || order.isEmpty()){
  53. order = "id";
  54. }
  55. if(adminMap.containsKey(order)){
  56. order = adminMap.get(order)+".`"+Tools.underscoreName(order)+"`";
  57. }else{
  58. order = adminMap.get("")+".`"+Tools.underscoreName(order)+"`";
  59. }
  60. if (direction == null){
  61. direction = DirectionStatus.DESC;
  62. }
  63. String finalOrder = order;
  64. DirectionStatus finalDirection = direction;
  65. Page<UserOrder> p = page(()->{
  66. userOrderRelationMapper.listAdmin(userId, productType, payMethod, orderId, finalOrder, finalDirection.key);
  67. }, page, size);
  68. Collection ids = Transform.getIds(p, UserOrder.class, "id");
  69. // 获取详细数据
  70. List<UserOrder> list = select(ids);
  71. Transform.replace(p, list, UserOrder.class, "id");
  72. return p;
  73. }
  74. /**
  75. * 合并用户信息,将old转移至new
  76. * @param oldUserId
  77. * @param newUserId
  78. */
  79. public void mergeUser(Number oldUserId, Integer newUserId){
  80. Example example = new Example(UserOrder.class);
  81. example.and(
  82. example.createCriteria().andEqualTo("userId", oldUserId)
  83. );
  84. update(userOrderMapper, example, UserOrder.builder().userId(newUserId).build());
  85. }
  86. public UserOrder add(UserOrder pay){
  87. int result = insert(userOrderMapper, pay);
  88. pay = one(userOrderMapper, pay.getId());
  89. if(pay == null){
  90. throw new SystemException("支付添加失败");
  91. }
  92. return pay;
  93. }
  94. public UserOrder edit(UserOrder pay){
  95. UserOrder in = one(userOrderMapper, pay.getId());
  96. if(in == null){
  97. throw new ParameterException("支付记录不存在");
  98. }
  99. int result = update(userOrderMapper, pay);
  100. return pay;
  101. }
  102. public boolean delete(Number id){
  103. UserOrder in = one(userOrderMapper, id);
  104. if(in == null){
  105. throw new ParameterException("支付记录不存在");
  106. }
  107. int result = delete(userOrderMapper, id);
  108. return result > 0;
  109. }
  110. public UserOrder get(Number id){
  111. UserOrder in = one(userOrderMapper, id);
  112. if(in == null){
  113. throw new ParameterException("支付记录不存在");
  114. }
  115. return in;
  116. }
  117. public Page<UserOrder> select(int page, int pageSize){
  118. return select(userOrderMapper, page, pageSize);
  119. }
  120. public Page<UserOrder> select(Integer[] ids){
  121. return page(()->select(userOrderMapper, ids), 1, ids.length);
  122. }
  123. public List<UserOrder> select(Collection ids){
  124. return select(userOrderMapper, ids);
  125. }
  126. }