| | |
| | | String key = String.format(RedisConstants.GOOD_STOCK, goods.getId()); |
| | | List<TOrder> orderList = orderService.lambdaQuery().eq(TOrder::getGoodsId, goodId) |
| | | .eq(TOrder::getDisabled, 0).list(); |
| | | int sum = orderList.stream().map(TOrder::getCount).mapToInt(Integer::intValue).sum(); |
| | | int sum = 0; |
| | | if (!orderList.isEmpty()) { |
| | | sum = orderList.stream().map(TOrder::getCount).mapToInt(Integer::intValue).sum(); |
| | | } |
| | | // 计算商品剩余可兑换数量 |
| | | int number = goods.getTotal() - sum; |
| | | if (number <= 0) { |
| | |
| | | } |
| | | // 兑换成功,生成订单信息、生成积分明细(积分明细需要远程调用rouyi-study服务) |
| | | boolean result = exchangeGood(goodExchange, recipient, number, goodId, needIntegral); |
| | | // 扣除库存 |
| | | result = result && this.lambdaUpdate().set(TGoods::getTotal, good.getTotal() - number) |
| | | .eq(TGoods::getId, good.getId()).update(); |
| | | if (!result) { |
| | | semaphore.release(number); |
| | | return R.exchangeError("商品兑换失败!"); |
| | |
| | | // 扣除用户积分 |
| | | result = result && studyClient.exchangeIntegral(needIntegral, Constants.BURDEN).getData(); |
| | | return result; |
| | | }private Boolean exchangeGoodParent(GoodExchangeDTO goodExchange, Recipient recipient, Integer number, |
| | | Integer goodId, int needIntegral) { |
| | | } |
| | | |
| | | private Boolean exchangeGoodParent(GoodExchangeDTO goodExchange, Recipient recipient, Integer number, |
| | | Integer goodId, int needIntegral) { |
| | | // 兑换成功,生成订单信息、生成积分明细(积分明细需要远程调用rouyi-study服务) |
| | | TOrder order = orderInfoParent(goodExchange, recipient, number, goodId, needIntegral); |
| | | boolean result = orderService.save(order); |
| | |
| | | return R.exchangeError("商品不存在,请稍后重试!"); |
| | | } |
| | | LoginUserParent loginUser1 = tokenService.getLoginUser1(); |
| | | if (null == loginUser1){ |
| | | if (null == loginUser1) { |
| | | return R.tokenError("登录失效"); |
| | | } |
| | | // 校验用户积分是否足够兑换 |
| | |
| | | order.setGoodsId(goodId); |
| | | order.setCount(number); |
| | | order.setState(1); |
| | | order.setRemark(goodExchange.getRemark()); |
| | | order.setIntegral(needIntegral); |
| | | order.setConsigneeName(recipient.getRecipient()); |
| | | order.setConsigneePhone(recipient.getRecipientPhone()); |
| | | order.setConsigneeAddress(recipient.getAddress()); |
| | | order.setConsigneeAddress(recipient.getProvince() + recipient.getCity() + recipient.getAddress()); |
| | | order.setDisabled(Boolean.FALSE); |
| | | return order; |
| | | } |
| | | |
| | | private TOrder orderInfoParent(GoodExchangeDTO goodExchange, Recipient recipient, Integer number, Integer goodId, int needIntegral) { |
| | | TOrder order = new TOrder(); |
| | | order.setOrderNumber(goodExchange.getOrderNumber()); |
| | |
| | | order.setGoodsId(goodId); |
| | | order.setCount(number); |
| | | order.setState(1); |
| | | order.setRemark(goodExchange.getRemark()); |
| | | order.setIntegral(needIntegral); |
| | | order.setConsigneeName(recipient.getRecipient()); |
| | | order.setConsigneePhone(recipient.getRecipientPhone()); |
| | | order.setConsigneeAddress(recipient.getAddress()); |
| | | order.setConsigneeAddress(recipient.getProvince() + recipient.getCity() + recipient.getAddress()); |
| | | order.setDisabled(Boolean.FALSE); |
| | | return order; |
| | | } |