CombinationController.java 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220
  1. package com.txz.mall.controller;
  2. import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
  3. import com.github.pagehelper.PageHelper;
  4. import com.github.pagehelper.PageInfo;
  5. import com.txz.mall.core.Result;
  6. import com.txz.mall.core.ResultCode;
  7. import com.txz.mall.core.ServiceException;
  8. import com.txz.mall.model.StoreCombination;
  9. import com.txz.mall.service.StoreCombinationService;
  10. import io.swagger.annotations.Api;
  11. import io.swagger.annotations.ApiOperation;
  12. import org.slf4j.Logger;
  13. import org.slf4j.LoggerFactory;
  14. import org.springframework.web.bind.annotation.*;
  15. import tk.mybatis.mapper.entity.Condition;
  16. import tk.mybatis.mapper.entity.Example;
  17. import vo.GoPinkResponse;
  18. import javax.annotation.Resource;
  19. import java.util.Date;
  20. import java.util.List;
  21. import java.util.stream.Collectors;
  22. /**
  23. * Created by CodeGenerator on 2025/07/14.
  24. */
  25. @Api(tags = "[后台]拼团商品管理")
  26. @RestController
  27. @RequestMapping("/combination")
  28. public class CombinationController {
  29. private static Logger log = LoggerFactory.getLogger(CombinationController.class);
  30. @Resource
  31. private StoreCombinationService storeCombinationService;
  32. @PostMapping("/add")
  33. @ApiOperation(value = "拼团商品表新增")
  34. public Result add(@RequestBody StoreCombination storeCombination) {
  35. if (storeCombination == null) {
  36. return Result.fail(ResultCode.OBJECT_IS_NULL);
  37. }
  38. try {
  39. storeCombination.setCreateTime(new Date());
  40. // storeCombination.setCreateUserId(userId);
  41. storeCombinationService.save(storeCombination);
  42. } catch (Exception e) {
  43. log.error("新增对象操作异常e:{}", e);
  44. return Result.fail(ResultCode.INTERNAL_SERVER_ERROR);
  45. }
  46. return Result.success();
  47. }
  48. @PostMapping("/delete")
  49. @ApiOperation(value = "拼团商品表删除")
  50. public Result delete(@RequestParam Long id) {
  51. if (id == null) {
  52. return Result.fail(ResultCode.ID_IS_NULL);
  53. }
  54. StoreCombination combination = storeCombinationService.findById(id);
  55. if (combination == null) {
  56. return Result.fail(ResultCode.OBJECT_IS_NULL);
  57. }
  58. Date date = new Date();
  59. if (combination.getIsShow().equals(1) && combination.getStartTime().before(date) && combination.getStopTime().after(date)) {
  60. throw new ServiceException("活动开启中,商品不支持删除");
  61. }
  62. try {
  63. StoreCombination storeCombination = new StoreCombination();
  64. storeCombination.setId(id);
  65. storeCombination.setIsDelete(1);
  66. storeCombinationService.update(storeCombination);
  67. } catch (Exception e) {
  68. log.error("删除对象操作异常e:{}", e);
  69. return Result.fail(ResultCode.INTERNAL_SERVER_ERROR);
  70. }
  71. return Result.success();
  72. }
  73. @PostMapping("/update")
  74. @ApiOperation(value = "拼团商品表更新")
  75. public Result update(@RequestBody StoreCombination storeCombination) {
  76. if (storeCombination == null) {
  77. return Result.fail(ResultCode.OBJECT_IS_NULL);
  78. }
  79. if (storeCombination.getId() == null) {
  80. return Result.fail(ResultCode.ID_IS_NULL);
  81. }
  82. try {
  83. storeCombination.setUpdateTime(new Date());
  84. // storeCombination.setUpdateUserId(userId);
  85. storeCombinationService.update(storeCombination);
  86. } catch (Exception e) {
  87. log.error("更新对象操作异常e:{}", e);
  88. return Result.fail(ResultCode.INTERNAL_SERVER_ERROR);
  89. }
  90. return Result.success();
  91. }
  92. @PostMapping("/detail")
  93. @ApiOperation(value = "拼团商品表获取详情")
  94. public Result<StoreCombination> detail(@RequestParam Long id) {
  95. if (id == null) {
  96. return Result.fail(ResultCode.ID_IS_NULL);
  97. }
  98. StoreCombination storeCombination = null;
  99. try {
  100. storeCombination = storeCombinationService.findById(id);
  101. } catch (Exception e) {
  102. log.error("查询对象操作异常e:{}", e);
  103. return Result.fail(ResultCode.INTERNAL_SERVER_ERROR);
  104. }
  105. return Result.success(storeCombination);
  106. }
  107. @PostMapping("/list")
  108. @ApiOperation(value = "拼团商品表获取列表")
  109. public Result<List<StoreCombination>> list(@RequestBody StoreCombination storeCombination, @RequestParam(defaultValue = "1") Integer page, @RequestParam(defaultValue = "10") Integer size) {
  110. PageHelper.startPage(page, size);
  111. Condition condition = new Condition(storeCombination.getClass());
  112. Example.Criteria criteria = condition.createCriteria();
  113. criteria.andEqualTo("isDelete", 0);
  114. condition.setOrderByClause("create_time DESC");
  115. PageInfo pageInfo = null;
  116. try {
  117. List<StoreCombination> list = storeCombinationService.findByCondition(condition);
  118. pageInfo = new PageInfo(list);
  119. } catch (Exception e) {
  120. log.error("查询对象操作异常e:{}", e);
  121. return Result.fail(ResultCode.INTERNAL_SERVER_ERROR);
  122. }
  123. return Result.success(pageInfo);
  124. }
  125. @PostMapping("/addActivityProduct")
  126. @ApiOperation(value = "添加活动商品")
  127. public Result addActivityProduct(@RequestBody List<StoreCombination> list, @RequestParam("activityId") Long activityId) {
  128. if (CollectionUtils.isEmpty(list)) {
  129. return Result.fail(ResultCode.OBJECT_IS_NULL);
  130. }
  131. if (activityId == null) {
  132. return Result.fail(ResultCode.USERID_IS_NULL);
  133. }
  134. try {
  135. storeCombinationService.addActivityProduct(list, activityId);
  136. } catch (Exception e) {
  137. log.error("新增对象操作异常e:{}", e);
  138. return Result.fail(ResultCode.INTERNAL_SERVER_ERROR);
  139. }
  140. return Result.success();
  141. }
  142. // @PostMapping("/getActivityProduct")
  143. // @ApiOperation(value = "获取活动商品列表")
  144. // public Result<PageInfo<ActivityProductVO>> productList(@RequestParam("activityId") Long activityId, @RequestParam(defaultValue = "1") Integer page, @RequestParam(defaultValue = "10") Integer size) {
  145. // if (activityId == null) {
  146. // return Result.fail(ResultCode.ID_IS_NULL);
  147. // }
  148. // PageInfo<ActivityProductVO> list = storeCombinationService.getActivityProduct(activityId, page, size);
  149. // return Result.success(list);
  150. // }
  151. @PostMapping("/getActivityProductIds")
  152. @ApiOperation(value = "获取活动商品ids")
  153. public Result<List<Long>> getActivityProductIds(@RequestParam("activityId") Long activityId) {
  154. Condition condition = new Condition(StoreCombination.class);
  155. Example.Criteria criteria = condition.createCriteria();
  156. criteria.andEqualTo("isDelete", 0);
  157. criteria.andEqualTo("activityId", activityId);
  158. List<StoreCombination> combinationList = storeCombinationService.findByCondition(condition);
  159. List<Long> arrayList = combinationList.stream().map(StoreCombination::getProductId).collect(Collectors.toList());
  160. return Result.success(arrayList);
  161. }
  162. /**
  163. * 去开团
  164. */
  165. @ApiOperation(value = "支付成功-去开团")
  166. @PostMapping(value = "/open")
  167. public Result goOpen(@RequestParam("orderId") Long orderId) {
  168. storeCombinationService.goOpen(orderId);
  169. return Result.success();
  170. }
  171. /**
  172. * 去拼团
  173. *
  174. * @param pinkId 拼团团长单id
  175. */
  176. @ApiOperation(value = "去拼团")
  177. @GetMapping(value = "/pink/{pinkId}")
  178. public Result<GoPinkResponse> goPink(@PathVariable(value = "pinkId") Long pinkId) {
  179. GoPinkResponse goPinkResponse = storeCombinationService.goPink(pinkId);
  180. return Result.success(goPinkResponse);
  181. }
  182. /**
  183. * 更多拼团
  184. */
  185. @ApiOperation(value = "更多拼团")
  186. @GetMapping(value = "/more")
  187. public Result<PageInfo<StoreCombination>> getMore(@RequestParam Integer comId, @RequestParam(defaultValue = "1") Integer page, @RequestParam(defaultValue = "10") Integer size) {
  188. PageHelper.startPage(page, size);
  189. PageInfo pageInfo = null;
  190. try {
  191. List<StoreCombination> list = storeCombinationService.getMore(comId);
  192. pageInfo = new PageInfo(list);
  193. } catch (Exception e) {
  194. log.error("查询对象操作异常e:{}", e);
  195. return Result.fail(ResultCode.INTERNAL_SERVER_ERROR);
  196. }
  197. return Result.success(pageInfo);
  198. }
  199. }