OrderInfoService.java 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593
  1. package com.izouma.tcg.service.orderInfo;
  2. import com.github.benmanes.caffeine.cache.Cache;
  3. import com.izouma.tcg.domain.MemberInfo;
  4. import com.izouma.tcg.domain.User;
  5. import com.izouma.tcg.domain.card.CardBox;
  6. import com.izouma.tcg.domain.card.CardCase;
  7. import com.izouma.tcg.domain.customizeStore.Store;
  8. import com.izouma.tcg.domain.orderInfo.CaseResult;
  9. import com.izouma.tcg.domain.orderInfo.OrderInfo;
  10. import com.izouma.tcg.domain.orderInfo.TransactionRecord;
  11. import com.izouma.tcg.dto.OrderInfoDTO;
  12. import com.izouma.tcg.dto.PageQuery;
  13. import com.izouma.tcg.dto.cardCase.OrderBoxDTO;
  14. import com.izouma.tcg.enums.CaseStatus;
  15. import com.izouma.tcg.enums.OrderStatus;
  16. import com.izouma.tcg.enums.PayMethod;
  17. import com.izouma.tcg.enums.TransactionRecordType;
  18. import com.izouma.tcg.exception.BusinessException;
  19. import com.izouma.tcg.repo.MemberInfoRepo;
  20. import com.izouma.tcg.repo.card.CardBoxRepo;
  21. import com.izouma.tcg.repo.card.CardCaseRepo;
  22. import com.izouma.tcg.repo.card.JackpotRepo;
  23. import com.izouma.tcg.repo.customizeStore.StoreRepo;
  24. import com.izouma.tcg.repo.orderInfo.CaseResultRepo;
  25. import com.izouma.tcg.repo.orderInfo.OrderInfoRepo;
  26. import com.izouma.tcg.repo.orderInfo.TransactionRecordRepo;
  27. import com.izouma.tcg.service.card.CardCaseService;
  28. import com.izouma.tcg.service.delay.OrderDelayService;
  29. import com.izouma.tcg.utils.*;
  30. import lombok.AllArgsConstructor;
  31. import org.apache.commons.beanutils.ConvertUtils;
  32. import org.apache.commons.lang.RandomStringUtils;
  33. import org.springframework.beans.factory.annotation.Autowired;
  34. import org.springframework.data.domain.Page;
  35. import org.springframework.stereotype.Service;
  36. import org.springframework.util.StringUtils;
  37. import org.springframework.web.server.session.InMemoryWebSessionStore;
  38. import java.math.BigDecimal;
  39. import java.time.LocalDateTime;
  40. import java.time.format.DateTimeFormatter;
  41. import java.util.*;
  42. import java.util.stream.Collectors;
  43. @Service
  44. @AllArgsConstructor
  45. public class OrderInfoService {
  46. @Autowired
  47. private OrderInfoRepo orderInfoRepo;
  48. @Autowired
  49. private CardBoxRepo cardBoxRepo;
  50. @Autowired
  51. private CardCaseRepo cardCaseRepo;
  52. @Autowired
  53. private Cache<String, Object> caffeineCache;
  54. @Autowired
  55. private TransactionRecordRepo transactionRecordRepo;
  56. @Autowired
  57. private OrderDelayService orderDelayService;
  58. @Autowired
  59. private StoreRepo storeRepo;
  60. @Autowired
  61. private MemberInfoRepo memberInfoRepo;
  62. @Autowired
  63. private CaseResultService caseResultService;
  64. @Autowired
  65. private CaseResultRepo caseResultRepo;
  66. @Autowired
  67. private JackpotRepo jackpotRepo;
  68. public OrderInfoService() {
  69. }
  70. public Page<OrderInfo> all(PageQuery pageQuery) {
  71. return orderInfoRepo
  72. .findAll(JpaUtils.toSpecification(pageQuery, OrderInfo.class), JpaUtils.toPageRequest(pageQuery));
  73. }
  74. public OrderInfo create(String boxIdStr, Long caseId, String remark, Long userAddressId) {
  75. List<Long> boxIds = Arrays.asList((Long[]) ConvertUtils.convert(boxIdStr.split(","), Long.class));
  76. List<CardBox> cardBoxList = cardBoxRepo.findAllByIdIn(boxIds);
  77. cardBoxList.forEach(cardbox -> {
  78. if (cardbox.isSold()) {
  79. throw new BusinessException("卖完啦,本次选位已被其他用户抢先购买!");
  80. }
  81. });
  82. User user = SecurityUtils.getAuthenticatedUser();
  83. CardCase cardCase = cardCaseRepo.findById(caseId).orElseThrow(new BusinessException("无信息"));
  84. if (cardCase.isDel()) {
  85. throw new BusinessException("该卡箱已经删除,不可以购买");
  86. }
  87. if (!cardCase.getCaseStatus().equals(CaseStatus.WAIT) & !cardCase.getCaseStatus().equals(CaseStatus.PROGRESS)) {
  88. throw new BusinessException("该拼箱活动未在开箱状态中");
  89. }
  90. if (cardCase.getStartTime().compareTo(LocalDateTime.now()) < 0) {
  91. throw new BusinessException("拼箱时间已过,无法购买");
  92. }
  93. if (!checkBox(boxIdStr, caseId)) {
  94. throw new BusinessException("卡箱已被人预定,请重新购买");
  95. }
  96. OrderInfo record = new OrderInfo();
  97. record.setOrderStatus(OrderStatus.CREATED);
  98. record.setBoxesCount(cardBoxList.size());
  99. BigDecimal postage = cardCase.getPostage();
  100. if (postage == null) {
  101. postage = BigDecimal.ZERO;
  102. }
  103. record.setTotal(cardBoxList.stream().map(CardBox::getBoxPrice).reduce(BigDecimal::add).orElse(BigDecimal.ZERO)
  104. .add(postage));
  105. record.setStoreId(cardCase.getStoreId());
  106. record.setUserId(user.getId());
  107. record.setUserAddressId(userAddressId);
  108. record.setRemark(remark);
  109. record.setCaseId(caseId);
  110. record.setCardBoxStr(boxIdStr);
  111. OrderInfo saved = orderInfoRepo.save(record);
  112. cardBoxList.forEach(cardBox -> {
  113. if (cardBox.getUserId() != null & cardBox.getOrderInfoId() != null) {
  114. throw new BusinessException("该卡包已被预定,请重新选择。");
  115. }
  116. cardBox.setUserId(user.getId());
  117. cardBox.setOrderInfoId(saved.getId());
  118. cardBox.setSold(true);
  119. cardBoxRepo.save(cardBox);
  120. });
  121. OrderInfo result = orderInfoRepo.findById(saved.getId()).orElseThrow(new BusinessException("未找到"));
  122. orderDelayService.orderDelay(result.getId(), result.getCreatedAt());
  123. return result;
  124. }
  125. public boolean checkBox(String boxIdStr, Long caseId) {
  126. Long userId = SecurityUtils.getAuthenticatedUser().getId();
  127. List<Long> boxIds = Arrays.asList((Long[]) ConvertUtils.convert(boxIdStr.split(","), Long.class));
  128. List<CardBox> cardBoxList = cardBoxRepo.findAllByIdIn(boxIds);
  129. CardCase cardCase = cardCaseRepo.findById(caseId).orElseThrow(new BusinessException("无信息"));
  130. if (cardCase.isLimitOne()) {
  131. if (boxIds.size() > 1) {
  132. throw new BusinessException("本次拼箱每人限购一份");
  133. }
  134. List<OrderStatus> orderStatuses = new ArrayList<>();
  135. orderStatuses.add(OrderStatus.CANCELED);
  136. orderStatuses.add(OrderStatus.REFUNDED);
  137. Long count = orderInfoRepo.countAllByOrderStatusNotInAndUserIdAndCaseId(orderStatuses, userId, caseId);
  138. if (count > 0) {
  139. throw new BusinessException("本次拼箱每人限购一份");
  140. }
  141. }
  142. if (cardCase.isSpecial()) {
  143. Map<String, List<CardBox>> stringListMap = cardBoxList.stream()
  144. .collect(Collectors.groupingBy(CardBox::getGroupCode));
  145. List<CardBox> AList = stringListMap.get("A");
  146. List<CardBox> BList = stringListMap.get("B");
  147. if (AList != null & BList != null) {
  148. return AList.size() == BList.size();
  149. }
  150. return false;
  151. }
  152. return true;
  153. }
  154. public Map<String, Object> showPreview(String boxIdStr, Long caseId) {
  155. Long userId = SecurityUtils.getAuthenticatedUser().getId();
  156. List<Long> boxIds = Arrays.asList((Long[]) ConvertUtils.convert(boxIdStr.split(","), Long.class));
  157. List<CardBox> cardBoxList = cardBoxRepo.findAllByIdIn(boxIds);
  158. CardCase cardCase = cardCaseRepo.findById(caseId).orElseThrow(new BusinessException("无信息"));
  159. if (cardCase.isDel()) {
  160. throw new BusinessException("该卡箱已经删除,不可以购买");
  161. }
  162. if (cardCase.isLimitOne()) {
  163. if (boxIds.size() > 1) {
  164. throw new BusinessException("本次拼箱每人限购一份");
  165. }
  166. List<OrderStatus> orderStatuses = new ArrayList<>();
  167. orderStatuses.add(OrderStatus.CANCELED);
  168. orderStatuses.add(OrderStatus.REFUNDED);
  169. Long count = orderInfoRepo.countAllByOrderStatusNotInAndUserIdAndCaseId(orderStatuses, userId, caseId);
  170. if (count > 0) {
  171. throw new BusinessException("本次拼箱每人限购一份");
  172. }
  173. }
  174. Map<String, Object> resultMap = new HashMap<>();
  175. storeRepo.findById(cardCase.getStoreId()).ifPresent(store -> resultMap.put("store", store));
  176. if (cardCase.isSpecial()) {
  177. Map<String, List<CardBox>> stringListMap = cardBoxList.stream()
  178. .collect(Collectors.groupingBy(CardBox::getGroupCode));
  179. List<CardBox> AList = stringListMap.get("A");
  180. List<CardBox> BList = stringListMap.get("B");
  181. if (AList.size() != BList.size()) {
  182. resultMap.put("error", "卡箱类型需要A,B两组选择卡包数量相等。");
  183. return resultMap;
  184. }
  185. }
  186. BigDecimal postage = cardCase.getPostage();
  187. if (postage == null) {
  188. postage = BigDecimal.ZERO;
  189. }
  190. resultMap.put("selectedBoxes", cardBoxList);
  191. resultMap.put("selectedCase", cardCase);
  192. resultMap.put("total", cardBoxList.stream().map(CardBox::getBoxPrice).reduce(BigDecimal::add)
  193. .orElse(BigDecimal.ZERO)
  194. .add(postage));
  195. return resultMap;
  196. }
  197. public void pay(Long orderInfoId, String transactionId) {
  198. OrderInfo orig = orderInfoRepo.findById(orderInfoId).orElseThrow(new BusinessException("无信息"));
  199. if (!orig.getOrderStatus().equals(OrderStatus.CREATED)) {
  200. throw new BusinessException("订单未在待支付状态,无法支付");
  201. }
  202. if (org.apache.commons.lang3.StringUtils.isNotBlank(transactionId)) {
  203. orig.setTransactionId(transactionId);
  204. orig.setPayMethod(PayMethod.WECHAT);
  205. } else {
  206. orig.setTransactionId(RandomStringUtils.randomNumeric(12));
  207. orig.setPayMethod(PayMethod.BALANCE);
  208. MemberInfo memberInfo = memberInfoRepo.findAllByUserId(orig.getUserId());
  209. if (memberInfo.getMoney().compareTo(orig.getTotal()) < 0) {
  210. throw new BusinessException("余额不足");
  211. }
  212. memberInfo.setMoney(memberInfo.getMoney().subtract(orig.getTotal()));
  213. memberInfoRepo.save(memberInfo);
  214. }
  215. orig.setOrderStatus(OrderStatus.PAYED);
  216. orig.setPaidTime(LocalDateTime.now());
  217. orig.setTotal(orig.getTotal());
  218. orderInfoRepo.save(orig);
  219. Store store = storeRepo.findById(orig.getStoreId()).orElse(null);
  220. if (store != null) {
  221. MemberInfo memberInfo = memberInfoRepo.findAllByUserId(store.getUserId());
  222. memberInfo.setMoney(memberInfo.getMoney().add(orig.getTotal()));
  223. memberInfoRepo.save(memberInfo);
  224. TransactionRecord transactionRecord = new TransactionRecord();
  225. transactionRecord.setRemark(orig.getRemark());
  226. transactionRecord.setUserId(store.getUserId());
  227. transactionRecord.setStoreId(orig.getStoreId());
  228. transactionRecord.setSettleTime(LocalDateTime.now());
  229. transactionRecord.setAttach("orderInfoId" + ":" + orderInfoId);
  230. transactionRecord
  231. .setTitle(orig.getCardCase().getCollection().getName() + orig.getCardCase().getCode() + "出售");
  232. transactionRecord.setAmount(orig.getTotal());
  233. transactionRecord.setType(TransactionRecordType.SOLD);
  234. transactionRecordRepo.save(transactionRecord);
  235. }
  236. TransactionRecord transactionRecord = new TransactionRecord();
  237. transactionRecord.setRemark(orig.getRemark());
  238. transactionRecord.setUserId(orig.getUserId());
  239. transactionRecord.setStoreId(orig.getStoreId());
  240. transactionRecord.setSettleTime(LocalDateTime.now());
  241. transactionRecord.setAttach("orderInfoId" + ":" + orderInfoId);
  242. transactionRecord.setTitle(orig.getCardCase().getCollection().getName() + orig.getCardCase().getCode() + "拼箱");
  243. transactionRecord.setAmount(orig.getTotal());
  244. transactionRecord.setType(TransactionRecordType.PAY);
  245. transactionRecordRepo.save(transactionRecord);
  246. CardCase cardCase = cardCaseRepo.findById(orig.getCaseId()).orElseThrow(new BusinessException("暂无信息"));
  247. if (!cardCase.isHasLive()) {
  248. if (cardCase.isInstant()) {
  249. orig.getCardBoxList().forEach(box -> {
  250. caseResultService.genInstant(box.getId());
  251. });
  252. } else {
  253. caseResultService.genRandomResult(orig.getCaseId());
  254. }
  255. }
  256. }
  257. public void cancel(Long orderInfoId) {
  258. OrderInfo orig = orderInfoRepo.findById(orderInfoId).orElseThrow(new BusinessException("无信息"));
  259. orig.setOrderStatus(OrderStatus.CANCELED);
  260. orderInfoRepo.save(orig);
  261. List<CardBox> orderBoxes = orig.getCardBoxList();
  262. orderBoxes.forEach(cardBox -> {
  263. cardBox.setOrderInfoId(null);
  264. cardBox.setUserId(null);
  265. cardBox.setSold(false);
  266. cardBoxRepo.save(cardBox);
  267. });
  268. }
  269. public void confirm(Long orderInfoId, String remark) {
  270. OrderInfo orig = orderInfoRepo.findById(orderInfoId).orElseThrow(new BusinessException("无信息"));
  271. orig.setOrderStatus(OrderStatus.COMPETED);
  272. orig.setFinishTime(LocalDateTime.now());
  273. orig.setEvaluate(remark);
  274. orderInfoRepo.save(orig);
  275. }
  276. public void send(Long orderInfoId, String logisticNo, String type, String remark) {
  277. OrderInfo orderInfo = orderInfoRepo.findById(orderInfoId).orElseThrow(new BusinessException("暂无订单信息"));
  278. orderInfo.setOrderStatus(OrderStatus.SEND);
  279. orderInfo.setLogisticsNo(logisticNo);
  280. orderInfo.setLogisticsType(type);
  281. orderInfo.setRemark(remark);
  282. LogisticsQueryResponse result = LogisticsUtils.query(logisticNo, type);
  283. orderInfoRepo.save(orderInfo);
  284. }
  285. public Map<String, Object> checkLogistics(Long orderId) {
  286. //先从缓存取,判断是否取出
  287. caffeineCache.getIfPresent(orderId);
  288. Map<String, Object> resultMap = new HashMap<>();
  289. OrderInfo orderInfo = orderInfoRepo.findById(orderId).orElseThrow(new BusinessException("订单不存在"));
  290. LogisticsQueryResponse cacheResult = (LogisticsQueryResponse) caffeineCache.asMap().get(orderId.toString());
  291. if (!StringUtils.isEmpty(cacheResult)) {
  292. resultMap.put("logistic", cacheResult);
  293. resultMap.put("address", orderInfo.getAddress());
  294. return resultMap;
  295. }
  296. if (orderInfo.getLogisticsNo().isEmpty() || orderInfo.getLogisticsType().isEmpty()) {
  297. throw new BusinessException("未发货或发货信息错误,请联系客服");
  298. }
  299. LogisticsQueryResponse result = LogisticsUtils.query(orderInfo.getLogisticsNo(), orderInfo.getLogisticsType());
  300. List<ResultData> resultData = result.getResult().getList();
  301. List<ResultData> newList = new ArrayList<>();
  302. resultData.forEach(resultData1 -> {
  303. ResultData newOne = new ResultData();
  304. LocalDateTime localDateTime = LocalDateTime
  305. .parse(resultData1.getTime(), DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
  306. DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("MM-dd HH:mm:ss");
  307. String newTimeStr = localDateTime.format(dateTimeFormatter);
  308. newOne.setTime(newTimeStr);
  309. newOne.setStatus(resultData1.getStatus());
  310. newList.add(newOne);
  311. });
  312. Result newResult = result.getResult();
  313. newResult.setList(newList);
  314. result.setResult(newResult);
  315. caffeineCache.put(orderId.toString(), result);
  316. resultMap.put("logistic", result);
  317. resultMap.put("address", orderInfo.getAddress());
  318. return resultMap;
  319. }
  320. public List<OrderInfoDTO> showMyStoreOrders(Long userId, OrderStatus orderStatus, Long orderInfoId) {
  321. List<OrderInfo> orderInfos = new ArrayList<>();
  322. Store store = storeRepo.findFirstByUserId(userId);
  323. if (orderInfoId != null) {
  324. orderInfos = orderInfoRepo.findAllById(orderInfoId);
  325. } else {
  326. if (orderStatus.equals(OrderStatus.ALL)) {
  327. orderInfos = orderInfoRepo
  328. .findAllByStoreIdAndOrderStatusNotOrderByCreatedAtDesc(store.getId(), OrderStatus.DELETED);
  329. } else {
  330. orderInfos = orderInfoRepo
  331. .findAllByOrderStatusAndStoreIdOrderByCreatedAtDesc(orderStatus, store.getId());
  332. }
  333. }
  334. List<OrderInfoDTO> result = new ArrayList<>();
  335. orderInfos.forEach(orderInfo -> {
  336. OrderInfoDTO orderInfoDTO = new OrderInfoDTO();
  337. orderInfoDTO.setOrderInfoId(orderInfo.getId());
  338. orderInfoDTO.setCaseId(orderInfo.getCaseId());
  339. if (orderInfo.getCardCase().getCustomName() != null) {
  340. orderInfoDTO.setImage(orderInfo.getCardCase().getImages().get(0));
  341. } else {
  342. orderInfoDTO.setImage(orderInfo.getCardCase().getCollection().getImages().get(0));
  343. }
  344. orderInfoDTO.setCreateTime(orderInfo.getCreatedAt());
  345. orderInfoDTO.setRemark(orderInfo.getRemark());
  346. orderInfoDTO.setStatus(orderInfo.getOrderStatus());
  347. orderInfoDTO.setTotal(orderInfo.getTotal());
  348. orderInfoDTO.setStoreName("卓卡官方");
  349. orderInfoDTO.setUserNickName(orderInfo.getUser().getNickname());
  350. orderInfoDTO.setUserId(orderInfo.getUserId());
  351. orderInfoDTO.setAvatar(orderInfo.getUser().getAvatar());
  352. if (store != null) {
  353. orderInfoDTO.setStoreName(store.getStoreName());
  354. orderInfoDTO.setStoreId(store.getId());
  355. orderInfoDTO.setLogo(store.getLogo());
  356. orderInfoDTO.setStoreUserId(store.getUserId());
  357. }
  358. List<OrderBoxDTO> orderBoxDTOS = new ArrayList<>();
  359. if (orderInfo.getCardBoxList().size() < 1 & orderInfo.getCardBoxStr() != null) {
  360. List<Long> boxIds = Arrays
  361. .asList((Long[]) ConvertUtils.convert(orderInfo.getCardBoxStr().split(","), Long.class));
  362. List<CardBox> cardBoxList = cardBoxRepo.findAllByIdIn(boxIds);
  363. orderInfo.setCardBoxList(cardBoxList);
  364. }
  365. orderInfo.getCardBoxList().forEach(cardBox -> {
  366. OrderBoxDTO orderBoxDTO = new OrderBoxDTO();
  367. if (cardBox.getCardCase().getCustomName() != null) {
  368. orderBoxDTO.setCaseName(cardBox.getCardCase().getCustomName());
  369. } else {
  370. orderBoxDTO.setCaseName(cardBox.getCardCase().getCollection().getName());
  371. }
  372. orderBoxDTO.setBoxName(cardBox.getGroupCode() + "-" + cardBox.getBoxCode());
  373. orderBoxDTO.setMoney(cardBox.getMoney());
  374. if (orderInfo.getCardCase().getCustomName() != null) {
  375. orderBoxDTO.setImages(orderInfo.getCardCase().getImages().get(0));
  376. } else {
  377. orderBoxDTO.setImages(orderInfo.getCardCase().getCollection().getImages().get(0));
  378. }
  379. CaseResult caseResult = caseResultRepo.findFirstByBoxId(cardBox.getId());
  380. if (caseResult != null) {
  381. orderBoxDTO.setImage(Objects
  382. .requireNonNull(jackpotRepo.findById(caseResult.getJackpotId()).orElse(null)).getImage());
  383. orderBoxDTO.setHasResult(true);
  384. orderBoxDTO.setCardName(Objects
  385. .requireNonNull(jackpotRepo.findById(caseResult.getJackpotId()).orElse(null)).getName());
  386. } else {
  387. orderBoxDTO.setHasResult(false);
  388. }
  389. orderBoxDTOS.add(orderBoxDTO);
  390. });
  391. orderInfoDTO.setOrderBoxDTOS(orderBoxDTOS);
  392. result.add(orderInfoDTO);
  393. });
  394. return result;
  395. }
  396. public List<OrderInfoDTO> showMyOrderInfos(Long userId, OrderStatus orderStatus, Long orderInfoId) {
  397. List<OrderInfo> orderInfos = new ArrayList<>();
  398. if (orderInfoId != null) {
  399. orderInfos = orderInfoRepo.findAllById(orderInfoId);
  400. } else {
  401. if (orderStatus.equals(OrderStatus.ALL)) {
  402. orderInfos = orderInfoRepo
  403. .findAllByUserIdAndOrderStatusNotOrderByCreatedAtDesc(userId, OrderStatus.DELETED);
  404. } else {
  405. orderInfos = orderInfoRepo.findAllByOrderStatusAndUserIdOrderByCreatedAtDesc(orderStatus, userId);
  406. }
  407. }
  408. List<OrderInfoDTO> result = new ArrayList<>();
  409. orderInfos.forEach(orderInfo -> {
  410. OrderInfoDTO orderInfoDTO = new OrderInfoDTO();
  411. orderInfoDTO.setOrderInfoId(orderInfo.getId());
  412. orderInfoDTO.setCaseId(orderInfo.getCaseId());
  413. if (orderInfo.getCardCase().getCustomName() != null) {
  414. orderInfoDTO.setImage(orderInfo.getCardCase().getImages().get(0));
  415. } else {
  416. orderInfoDTO.setImage(orderInfo.getCardCase().getCollection().getImages().get(0));
  417. }
  418. orderInfoDTO.setCreateTime(orderInfo.getCreatedAt());
  419. orderInfoDTO.setRemark(orderInfo.getRemark());
  420. orderInfoDTO.setStatus(orderInfo.getOrderStatus());
  421. orderInfoDTO.setTotal(orderInfo.getTotal());
  422. orderInfoDTO.setStoreName("卓卡官方");
  423. orderInfoDTO.setUserNickName(orderInfo.getUser().getNickname());
  424. orderInfoDTO.setUserId(orderInfo.getUserId());
  425. orderInfoDTO.setAvatar(orderInfo.getUser().getAvatar());
  426. Store store = storeRepo.findById(orderInfo.getStoreId()).orElse(null);
  427. if (store != null) {
  428. orderInfoDTO.setStoreName(store.getStoreName());
  429. orderInfoDTO.setStoreId(store.getId());
  430. orderInfoDTO.setLogo(store.getLogo());
  431. orderInfoDTO.setStoreUserId(store.getUserId());
  432. }
  433. List<OrderBoxDTO> orderBoxDTOS = new ArrayList<>();
  434. if (orderInfo.getCardBoxList().size() < 1 & orderInfo.getCardBoxStr() != null) {
  435. List<Long> boxIds = Arrays
  436. .asList((Long[]) ConvertUtils.convert(orderInfo.getCardBoxStr().split(","), Long.class));
  437. List<CardBox> cardBoxList = cardBoxRepo.findAllByIdIn(boxIds);
  438. orderInfo.setCardBoxList(cardBoxList);
  439. }
  440. orderInfo.getCardBoxList().forEach(cardBox -> {
  441. OrderBoxDTO orderBoxDTO = new OrderBoxDTO();
  442. if (orderInfo.getCardCase().getCustomName() != null) {
  443. orderBoxDTO.setCaseName(orderInfo.getCardCase().getCustomName());
  444. } else {
  445. orderBoxDTO.setCaseName(orderInfo.getCardCase().getCollection().getName());
  446. }
  447. orderBoxDTO.setBoxName(cardBox.getGroupCode() + "-" + cardBox.getBoxCode());
  448. orderBoxDTO.setMoney(cardBox.getMoney());
  449. if (orderInfo.getCardCase().getCustomName() != null) {
  450. orderBoxDTO.setImages(orderInfo.getCardCase().getImages().get(0));
  451. } else {
  452. orderBoxDTO.setImages(orderInfo.getCardCase().getCollection().getImages().get(0));
  453. }
  454. CaseResult caseResult = caseResultRepo.findFirstByBoxId(cardBox.getId());
  455. if (caseResult != null) {
  456. orderBoxDTO.setImage(Objects
  457. .requireNonNull(jackpotRepo.findById(caseResult.getJackpotId()).orElse(null)).getImage());
  458. orderBoxDTO.setHasResult(true);
  459. orderBoxDTO.setCardName(Objects
  460. .requireNonNull(jackpotRepo.findById(caseResult.getJackpotId()).orElse(null)).getName());
  461. } else {
  462. orderBoxDTO.setHasResult(false);
  463. }
  464. orderBoxDTOS.add(orderBoxDTO);
  465. });
  466. orderInfoDTO.setOrderBoxDTOS(orderBoxDTOS);
  467. result.add(orderInfoDTO);
  468. });
  469. return result;
  470. }
  471. public void refund(Long orderInfoId, String remark) {
  472. OrderInfo orderInfo = orderInfoRepo.findById(orderInfoId).orElseThrow(new BusinessException("没有信息"));
  473. orderInfo.setOrderStatus(OrderStatus.REFUND);
  474. orderInfoRepo.save(orderInfo);
  475. }
  476. public void newAfterSale(Long orderInfoId, String remark, List<String> images) {
  477. }
  478. public void delete(Long orderInfoId) {
  479. OrderInfo orderInfo = orderInfoRepo.findById(orderInfoId).orElseThrow(new BusinessException("无信息"));
  480. orderInfo.setOrderStatus(OrderStatus.DELETED);
  481. orderInfoRepo.save(orderInfo);
  482. }
  483. public void saveLogistic(Long id, String logisticNo, String type) {
  484. OrderInfo orderInfo = orderInfoRepo.findById(id).orElseThrow(new BusinessException("无信息"));
  485. if (type.equals("SFEXPRESS")) {
  486. String phoneNumber = orderInfo.getAddress().getPhone();
  487. StringBuilder tailNum = new StringBuilder();
  488. if (phoneNumber != null) {
  489. int len = phoneNumber.length();
  490. for (int i = len - 1; i >= len - 4; i--) {
  491. tailNum.append(phoneNumber.charAt(i));
  492. }
  493. tailNum.reverse();
  494. }
  495. logisticNo = logisticNo + tailNum.toString();
  496. }
  497. orderInfo.setLogisticsType(type);
  498. orderInfo.setLogisticsNo(logisticNo);
  499. orderInfo.setOrderStatus(OrderStatus.SEND);
  500. LogisticsQueryResponse result = LogisticsUtils.query(logisticNo, type);
  501. orderInfoRepo.save(orderInfo);
  502. }
  503. public List<OrderInfoDTO> toOrderInfoDTOs(List<OrderInfo> orderInfos) {
  504. List<OrderInfoDTO> result = new ArrayList<>();
  505. orderInfos.forEach(orderInfo -> {
  506. if (!orderInfo.getCardCase().isDel()) {
  507. Store store = orderInfo.getStore();
  508. OrderInfoDTO orderInfoDTO = new OrderInfoDTO();
  509. orderInfoDTO.setOrderInfoId(orderInfo.getId());
  510. orderInfoDTO.setCaseId(orderInfo.getCaseId());
  511. if (orderInfo.getCardCase().getCustomName() != null) {
  512. orderInfoDTO.setImage(orderInfo.getCardCase().getImages().get(0));
  513. } else {
  514. orderInfoDTO.setImage(orderInfo.getCardCase().getCollection().getImages().get(0));
  515. }
  516. orderInfoDTO.setCreateTime(orderInfo.getCreatedAt());
  517. orderInfoDTO.setRemark(orderInfo.getRemark());
  518. orderInfoDTO.setStatus(orderInfo.getOrderStatus());
  519. orderInfoDTO.setTotal(orderInfo.getTotal());
  520. orderInfoDTO.setStoreName("卓卡官方");
  521. orderInfoDTO.setUserNickName(orderInfo.getUser().getNickname());
  522. orderInfoDTO.setUserId(orderInfo.getUserId());
  523. orderInfoDTO.setAvatar(orderInfo.getUser().getAvatar());
  524. orderInfoDTO.setSelectedBoxes(orderInfo.getCardBoxList().stream()
  525. .map(cardBox -> cardBox.getGroupCode() + "-" + cardBox.getBoxCode())
  526. .collect(Collectors.joining(",")));
  527. if (orderInfo.getCardCase().getCustomName() != null) {
  528. orderInfoDTO
  529. .setCaseStr(orderInfo.getCardCase().getCustomName() + orderInfo.getCardCase().getCode());
  530. } else {
  531. orderInfoDTO
  532. .setCaseStr(orderInfo.getCardCase().getCollection().getName() + "-" + orderInfo
  533. .getCardCase()
  534. .getCode());
  535. }
  536. orderInfoDTO.setStatusStr(orderInfo.getOrderStatus().getDescription());
  537. orderInfoDTO.setPaidTime(orderInfo.getPaidTime());
  538. orderInfoDTO.setTransactionId(orderInfo.getTransactionId());
  539. if (store != null) {
  540. orderInfoDTO.setStoreName(store.getStoreName());
  541. orderInfoDTO.setStoreId(store.getId());
  542. orderInfoDTO.setLogo(store.getLogo());
  543. orderInfoDTO.setStoreUserId(store.getUserId());
  544. }
  545. // List<OrderBoxDTO> orderBoxDTOS = new ArrayList<>();
  546. // if (orderInfo.getCardBoxList().size() < 1 & orderInfo.getCardBoxStr() != null) {
  547. // List<Long> boxIds = Arrays
  548. // .asList((Long[]) ConvertUtils.convert(orderInfo.getCardBoxStr().split(","), Long.class));
  549. // List<CardBox> cardBoxList = cardBoxRepo.findAllByIdIn(boxIds);
  550. // orderInfo.setCardBoxList(cardBoxList);
  551. // }
  552. // orderInfo.getCardBoxList().forEach(cardBox -> {
  553. // OrderBoxDTO orderBoxDTO = new OrderBoxDTO();
  554. // orderBoxDTO.setCaseName(cardBox.getCardCase().getCollection().getName());
  555. // orderBoxDTO.setBoxName(cardBox.getGroupCode() + "-" + cardBox.getBoxCode());
  556. // orderBoxDTO.setMoney(cardBox.getMoney());
  557. // orderBoxDTO.setImages(cardBox.getCardCase().getCollection().getImages().get(0));
  558. // orderBoxDTOS.add(orderBoxDTO);
  559. // });
  560. // orderInfoDTO.setOrderBoxDTOS(orderBoxDTOS);
  561. result.add(orderInfoDTO);
  562. }
  563. });
  564. return result;
  565. }
  566. }