dianliang/oil-station
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
zhaohengkun 2024-10-24 10:10:25 +08:00
parent 9eceda0858
commit 51bc0851f9
1 changed files with 55 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

99
fuintBackend/fuint-application/src/main/java/com/fuint/business/integral/service/impl/IntegralOrdersServiceImpl.java
View File

@ -483,57 +483,68 @@ public class IntegralOrdersServiceImpl implements IntegralOrdersService {
String lockKey = "IntegralOrders" + orderNo; String lockKey = "IntegralOrders" + orderNo;
Boolean isLock = redisLock.tryLock(lockKey, 5000, TimeUnit.MILLISECONDS); Boolean isLock = redisLock.tryLock(lockKey, 5000, TimeUnit.MILLISECONDS);
if (isLock && "paid".equals(listByOrderNo.get(0).getStatus()) && "0".equals(listByOrderNo.get(0).getProcessingStatus())) { if (isLock && "paid".equals(listByOrderNo.get(0).getStatus()) && "0".equals(listByOrderNo.get(0).getProcessingStatus())) {
// 查询用户信息 try {
LJUserVo ljUserVos = ljUserMapper.selectAllInfoById2(listByOrderNo.get(0).getUserId(), listByOrderNo.get(0).getChainStoreId());
// 查询用户信息
BigDecimal totalPoints = new BigDecimal(0);
for (IntegralOrders integralOrders : listByOrderNo) { // 查询用户信息
// 查询员工信息 LJUserVo ljUserVos = ljUserMapper.selectAllInfoById2(listByOrderNo.get(0).getUserId(), listByOrderNo.get(0).getChainStoreId());
LJStaff ljStaff = ljStaffMapper.selectById(integralOrders.getStaffId()); // 查询用户信息
if (ObjectUtil.isEmpty(integralOrders.getIntegral())) integralOrders.setIntegral(0.0); BigDecimal totalPoints = new BigDecimal(0);
totalPoints = totalPoints.add(new BigDecimal(integralOrders.getIntegral()));
// 加兑换卷和优惠券判断
IntegralGift integralGift = integralGiftService.queryById(integralOrders.getGiftId());
if (integralGift.getGiftType().equals("电子券")) {
CardCoupon cardCoupon = cardCouponService.selectOneBuId(integralGift.getCouponId()); for (IntegralOrders integralOrders : listByOrderNo) {
ResponseObject responseObject = cardCouponService.sendCoupon2(new CardCouponUser()); // 查询员工信息
LJStaff ljStaff = ljStaffMapper.selectById(integralOrders.getStaffId());
if (ObjectUtil.isEmpty(integralOrders.getIntegral())) integralOrders.setIntegral(0.0);
totalPoints = totalPoints.add(new BigDecimal(integralOrders.getIntegral()));
// 加兑换卷和优惠券判断
IntegralGift integralGift = integralGiftService.queryById(integralOrders.getGiftId());
if (integralGift.getGiftType().equals("电子券")) {
for (int i = 0; i <integralOrders.getExchangeQuantity() ; i++) {
CardCouponUser cardCouponUser = new CardCouponUser();
cardCouponUser.setMtUserId(ljUserVos.getId());
cardCouponUser.setStoreId(integralOrders.getStoreId());
cardCouponUser.setCardCouponId(integralGift.getCouponId());
ResponseObject responseObject = cardCouponService.sendCoupon2(cardCouponUser);
}
} else if (integralGift.getGiftType().equals("实物商品")) {
// 修改商品库存并增加记录
LJGoodsDto goods = new LJGoodsDto();
goods.setId(integralGift.getGoodsId());
goods.setDocument("积分兑换");
goods.setNumberOfChanges(-integralOrders.getExchangeQuantity());
goods.setGoodsNo(integralOrders.getOrderNumber());
ljGoodsService.editGoodsInventory(goods);
}
// 处理积分库存
integralGiftService.updateInventoryByLock(integralOrders.getGiftId(), integralOrders.getExchangeQuantity());
} else if (integralGift.getGiftType().equals("实物商品")) {
// 修改商品库存并增加记录
LJGoodsDto goods = new LJGoodsDto();
goods.setId(integralGift.getGoodsId());
goods.setDocument("积分兑换");
goods.setNumberOfChanges(-integralOrders.getExchangeQuantity());
goods.setGoodsNo(integralOrders.getOrderNumber());
ljGoodsService.editGoodsInventory(goods);
} }
// 处理积分库存 // 用户积分余额变动
integralGiftService.updateInventoryByLock(integralOrders.getGiftId(), integralOrders.getExchangeQuantity()); if (totalPoints.doubleValue() > 0) {
UserBalance userBalance = balanceCalculation(ljUserVos, totalPoints.doubleValue());
userBalance.setChainStoreId(listByOrderNo.get(0).getChainStoreId());
userBalanceService.updateUserBalance(userBalance);
}
// 积分表变动
if (totalPoints.doubleValue() > 0) {
IntegralDetail integralDetail = changesInPoints(totalPoints.doubleValue(), ljUserVos);
integralDetail.setStoreId(listByOrderNo.get(0).getStoreId());
integralDetail.setChainStoreId(listByOrderNo.get(0).getChainStoreId());
integralDetailService.insert2(integralDetail);
}
// 批量修改该
integralOrdersDao.updatePaymentType(orderNo);
redisLock.unlock(lockKey);
} catch (Exception e) {
redisLock.unlock(lockKey);
e.printStackTrace();
} }
// 用户积分余额变动
if (totalPoints.doubleValue() > 0) {
UserBalance userBalance = balanceCalculation(ljUserVos, totalPoints.doubleValue());
userBalance.setChainStoreId(listByOrderNo.get(0).getChainStoreId());
userBalanceService.updateUserBalance(userBalance);
}
// 积分表变动
if (totalPoints.doubleValue() > 0) {
IntegralDetail integralDetail = changesInPoints(totalPoints.doubleValue(), ljUserVos);
integralDetail.setStoreId(listByOrderNo.get(0).getStoreId());
integralDetail.setChainStoreId(listByOrderNo.get(0).getChainStoreId());
integralDetailService.insert2(integralDetail);
}
// 批量修改该
integralOrdersDao.updatePaymentType(orderNo);
redisLock.unlock(lockKey);
} else { } else {
redisLock.unlock(lockKey); redisLock.unlock(lockKey);