ShShopService.java 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. package com.bofeng.service;
  2. import com.baomidou.mybatisplus.toolkit.IdWorker;
  3. import com.bofeng.dao.ShShopMapper;
  4. import com.bofeng.entity.ShShop;
  5. import lombok.var;
  6. import org.apache.commons.collections.CollectionUtils;
  7. import org.joda.time.DateTime;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.stereotype.Service;
  10. import org.springframework.transaction.annotation.Propagation;
  11. import org.springframework.transaction.annotation.Transactional;
  12. import java.util.List;
  13. @Service
  14. @Transactional(readOnly = true)
  15. public class ShShopService {
  16. @Autowired
  17. private ShShopMapper shShopMapper;
  18. //我的商店新增
  19. @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
  20. public int addShShop(Long userId, Integer shopType, String shopName, String adddr,
  21. DateTime startDate, DateTime endDate, String linkman, String phone) throws Exception {
  22. DateTime dateTime = new DateTime();
  23. var shShopDb = shShopMapper.selectById(userId);
  24. if (null == shShopDb) {
  25. var shop = new ShShop();
  26. shop.setShopId(IdWorker.getId());
  27. shop.setUserId(userId);
  28. shop.setShopType(shopType);
  29. shop.setShopName(shopName);
  30. shop.setAddr(adddr);
  31. shop.setStartDate(startDate);
  32. shop.setEndDate(endDate);
  33. shop.setLinkman(linkman);
  34. shop.setPhone(phone);
  35. /*long userId = Long.parseLong(JwtHelper.getUserId());
  36. qzTak.setUserId(userId);
  37. qzTak.setUserCreate(userId);*/
  38. shop.setTimeCreate(dateTime);
  39. /* qzTak.setUserUpdate(userId);*/
  40. shop.setTimeUpdate(dateTime);
  41. return shShopMapper.insert(shop);
  42. } else {
  43. throw new Exception("您已有一个商店,请勿重复添加");
  44. }
  45. /* else {
  46. shShopDb.setUserId(userId);
  47. shShopDb.setShopType(shopType);
  48. shShopDb.setShopName(shopName);
  49. shShopDb.setAddr(adddr);
  50. shShopDb.setStartDate(startDate);
  51. shShopDb.setEndDate(endDate);
  52. shShopDb.setLinkman(linkman);
  53. shShopDb.setPhone(phone);
  54. *//*long userId = Long.parseLong(JwtHelper.getUserId());
  55. qzTak.setUserId(userId);
  56. qzTak.setUserCreate(userId);*//*
  57. shShopDb.setTimeCreate(dateTime);
  58. *//* qzTak.setUserUpdate(userId);*//*
  59. shShopDb.setTimeUpdate(dateTime);
  60. return shShopMapper.updateById(shShopDb);
  61. }*/
  62. }
  63. public List<ShShop> queryMyShShop(Long userId) throws Exception {
  64. List<ShShop> shShopDb = shShopMapper.queryMyShShop(userId);
  65. if (CollectionUtils.isEmpty(shShopDb)) {
  66. throw new Exception("获取失败");
  67. }
  68. return shShopDb;
  69. }
  70. //
  71. // public List<QzTask> selectAll() {
  72. // return qzTaskDao.selectAll();
  73. // }
  74. //
  75. // public List<QzTask> queryByHouseNumber(String houseNumber, Integer status) {
  76. // return qzTaskDao.queryByHouseNumber(houseNumber, status);
  77. // }
  78. //
  79. // public QzTask queryByTaskId(Long taskId) {
  80. // return qzTaskDao.queryByTaskId(taskId);
  81. // }
  82. //
  83. // //求助的新增
  84. // @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
  85. // public int addHelp(String taskTitle, String taskTarget, String remark) {
  86. // var qzTak = new QzTask();
  87. // qzTak.setTaskId(IdWorker.getId());
  88. // qzTak.setTaskTitle(taskTitle);
  89. // qzTak.setRemark(remark);
  90. // qzTak.setTaskTarget(taskTarget);
  91. // qzTak.setTaskStatus(1);
  92. //
  93. // /*long userId = Long.parseLong(JwtHelper.getUserId());
  94. // qzTak.setUserId(userId);
  95. // qzTak.setUserCreate(userId);*/
  96. // qzTak.setTimeCreate(new DateTime());
  97. // /* qzTak.setUserUpdate(userId);*/
  98. // qzTak.setTimeUpdate(new DateTime());
  99. // return qzTaskDao.insert(qzTak);
  100. // }
  101. //
  102. //
  103. // public List<QzTask> queryQzTask(Integer taskStatus) {
  104. // return qzTaskDao.queryQzTask(taskStatus);
  105. // }
  106. }