czg_team/wx-cashier-service
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

积分模块相关代码

Browse Source
This commit is contained in:
谭凯凯
2024-11-01 17:25:40 +08:00
committed by Tankaikai
parent 02a756d32d
commit 0b86ed1459
1 changed files with 14 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/com/chaozhanggui/system/cashierservice/service/impl/TbPointsExchangeRecordServiceImpl.java
View File

@@ -141,7 +141,7 @@ public class TbPointsExchangeRecordServiceImpl extends ServiceImpl<TbPointsExcha
} }
private void verify(TbPointsExchangeRecord record, TbPointsBasicSetting basic, TbPointsGoodsSetting goods, TbMemberPoints memberPoints) { private Object[] verify(TbPointsExchangeRecord record) {
try { try {
Assert.notNull(record.getShopId(), "{}({})不能为空", "店铺id", "shopId"); Assert.notNull(record.getShopId(), "{}({})不能为空", "店铺id", "shopId");
Assert.notNull(record.getPointsGoodsId(), "{}({})不能为空", "积分商品id", "pointsGoodsId"); Assert.notNull(record.getPointsGoodsId(), "{}({})不能为空", "积分商品id", "pointsGoodsId");
@@ -152,14 +152,14 @@ public class TbPointsExchangeRecordServiceImpl extends ServiceImpl<TbPointsExcha
} catch (IllegalArgumentException e) { } catch (IllegalArgumentException e) {
throw new MsgException(e.getMessage()); throw new MsgException(e.getMessage());
} }
basic = tbPointsBasicSettingMapper.selectOne(Wrappers.<TbPointsBasicSetting>lambdaQuery().eq(TbPointsBasicSetting::getShopId, record.getShopId())); TbPointsBasicSetting basic = tbPointsBasicSettingMapper.selectOne(Wrappers.<TbPointsBasicSetting>lambdaQuery().eq(TbPointsBasicSetting::getShopId, record.getShopId()));
if (basic == null) { if (basic == null) {
throw new MsgException("商家未配置积分锁客基本设置"); throw new MsgException("商家未配置积分锁客基本设置");
} }
if (basic.getEnablePointsMall() != 1) { if (basic.getEnablePointsMall() != 1) {
throw new MsgException("积分商城未开启"); throw new MsgException("积分商城未开启");
} }
goods = tbPointsGoodsSettingMapper.selectById(record.getPointsGoodsId()); TbPointsGoodsSetting goods = tbPointsGoodsSettingMapper.selectById(record.getPointsGoodsId());
if (goods == null) { if (goods == null) {
throw new MsgException("兑换的商品信息不存在"); throw new MsgException("兑换的商品信息不存在");
} }
@@ -177,7 +177,7 @@ public class TbPointsExchangeRecordServiceImpl extends ServiceImpl<TbPointsExcha
if (quantity <= 0) { if (quantity <= 0) {
throw new MsgException("兑换的商品库存不足"); throw new MsgException("兑换的商品库存不足");
} }
memberPoints = tbMemberPointsMapper.selectOne(Wrappers.<TbMemberPoints>lambdaQuery().eq(TbMemberPoints::getMemberId, record.getMemberId())); TbMemberPoints memberPoints = tbMemberPointsMapper.selectOne(Wrappers.<TbMemberPoints>lambdaQuery().eq(TbMemberPoints::getMemberId, record.getMemberId()));
if (memberPoints == null) { if (memberPoints == null) {
throw new MsgException("会员积分不足无法兑换此商品"); throw new MsgException("会员积分不足无法兑换此商品");
} }
@@ -186,14 +186,15 @@ public class TbPointsExchangeRecordServiceImpl extends ServiceImpl<TbPointsExcha
if (accountPoints < requiredPoints) { if (accountPoints < requiredPoints) {
throw new MsgException("会员积分不足无法兑换此商品"); throw new MsgException("会员积分不足无法兑换此商品");
} }
return new Object[]{basic, goods, memberPoints};
} }
@Override @Override
public TbPointsExchangeRecord create(TbPointsExchangeRecord record) { public TbPointsExchangeRecord create(TbPointsExchangeRecord record) {
TbPointsBasicSetting basic = null; Object[] verify = verify(record);
TbPointsGoodsSetting goods = null; TbPointsBasicSetting basic = (TbPointsBasicSetting) verify[0];
TbMemberPoints memberPoints = null; TbPointsGoodsSetting goods = (TbPointsGoodsSetting) verify[1];
verify(record, basic, goods, memberPoints); TbMemberPoints memberPoints = (TbMemberPoints) verify[2];
record.setExtraPaymentAmount(goods.getExtraPrice()); record.setExtraPaymentAmount(goods.getExtraPrice());
record.setSpendPoints(goods.getRequiredPoints()); record.setSpendPoints(goods.getRequiredPoints());
Snowflake seqNo = IdUtil.getSnowflake(0, 0); Snowflake seqNo = IdUtil.getSnowflake(0, 0);
@@ -220,7 +221,10 @@ public class TbPointsExchangeRecordServiceImpl extends ServiceImpl<TbPointsExcha
TbPointsGoodsSetting goods = null; TbPointsGoodsSetting goods = null;
TbMemberPoints memberPoints = null; TbMemberPoints memberPoints = null;
try { try {
verify(entity, basic, goods, memberPoints); Object[] verify = verify(record);
basic = (TbPointsBasicSetting) verify[0];
goods = (TbPointsGoodsSetting) verify[1];
memberPoints = (TbMemberPoints) verify[2];
} catch (Exception e) { } catch (Exception e) {
throw new MsgException(e.getMessage().concat("，请您取消订单")); throw new MsgException(e.getMessage().concat("，请您取消订单"));
} }
@@ -481,7 +485,7 @@ public class TbPointsExchangeRecordServiceImpl extends ServiceImpl<TbPointsExcha
} }
OrderReturnResp returnResp = publicResp.getObjData(); OrderReturnResp returnResp = publicResp.getObjData();
if (!"SUCCESS".equals(returnResp.getState())) { if (!"SUCCESS".equals(returnResp.getState())) {
throw new MsgException(StrUtil.format("退款失败原因：{}",returnResp.getState())); throw new MsgException(StrUtil.format("退款失败原因：{}", returnResp.getState()));
} }
} }