From a17a3616fb0b59d61cda0f97c5005c18d97cdbee Mon Sep 17 00:00:00 2001 From: jyy <935090232@qq.com> Date: Mon, 22 Mar 2021 12:46:28 +0800 Subject: [PATCH] 积分商城13 --- zq-erp/src/main/java/com/matrix/system/score/entity/ScoreUseRecord.java | 2 +- zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/ScoreOrderTask.java | 28 ++++++++++++++-------------- zq-erp/src/main/java/com/matrix/system/score/entity/ScoreVipDetail.java | 2 +- zq-erp/src/main/java/com/matrix/system/score/service/ScoreVipDetailService.java | 3 ++- 4 files changed, 18 insertions(+), 17 deletions(-) diff --git a/zq-erp/src/main/java/com/matrix/system/score/entity/ScoreUseRecord.java b/zq-erp/src/main/java/com/matrix/system/score/entity/ScoreUseRecord.java index 6b2b90f..41cc47b 100644 --- a/zq-erp/src/main/java/com/matrix/system/score/entity/ScoreUseRecord.java +++ b/zq-erp/src/main/java/com/matrix/system/score/entity/ScoreUseRecord.java @@ -25,7 +25,7 @@ */ - private Integer recType; + private Integer type; /** * 数量 diff --git a/zq-erp/src/main/java/com/matrix/system/score/entity/ScoreVipDetail.java b/zq-erp/src/main/java/com/matrix/system/score/entity/ScoreVipDetail.java index 33ff3ca..8c6b859 100644 --- a/zq-erp/src/main/java/com/matrix/system/score/entity/ScoreVipDetail.java +++ b/zq-erp/src/main/java/com/matrix/system/score/entity/ScoreVipDetail.java @@ -99,7 +99,7 @@ */ - private String businessId; + private Long businessId; /** * 所属公司_id diff --git a/zq-erp/src/main/java/com/matrix/system/score/service/ScoreVipDetailService.java b/zq-erp/src/main/java/com/matrix/system/score/service/ScoreVipDetailService.java index b4c3651..b62012f 100644 --- a/zq-erp/src/main/java/com/matrix/system/score/service/ScoreVipDetailService.java +++ b/zq-erp/src/main/java/com/matrix/system/score/service/ScoreVipDetailService.java @@ -152,6 +152,7 @@ scoreVipDetail.setState(ScoreVipDetail.SCORE_STATUS_YX); scoreVipDetail.setRemainScore(score); scoreVipDetail.setUsedScore(0); + scoreVipDetail.setBusinessId(businessId); scoreVipDetail.setValiditeTime(sxys); scoreVipDetail.setOpenId(openId); scoreVipDetail.setVipId(vipId); @@ -173,7 +174,7 @@ scoreUseRecord.setScoreVipDetailId(scoreVipDetail.getId()); scoreUseRecord.setBusinessId(businessId); scoreUseRecord.setRecNum(score); - scoreUseRecord.setRecType(type); + scoreUseRecord.setType(type); scoreUseRecord.setOpenId(openId); scoreUseRecord.setVipId(vipId); scoreUseRecord.setShopId(shopId); diff --git a/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/ScoreOrderTask.java b/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/ScoreOrderTask.java index 2dfe1d5..8e21a83 100644 --- a/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/ScoreOrderTask.java +++ b/zq-erp/src/main/java/com/matrix/system/shopXcx/mqTask/ScoreOrderTask.java @@ -52,26 +52,26 @@ scoreVipDetailService.deductionScore(order.getUserId(),null,Long.parseLong(order.getStoreId()+""),order.getScorePay(),Long.parseLong(order.getId()+""), ScoreVipDetail.SCORE_VIP_TYPE_CASH); } //消费获得积分 - orderDetails.forEach(shopOrderDetail -> { - int addScore=0; + int addScore=0; + for(ShopOrderDetails shopOrderDetail : orderDetails) { if(shopOrderDetail.getPayType()==ShopOrderDetails.PAYTYPE_MICRO){ Integer xfkdScore= shopOrderDetail.getShopSku().getScore(); if(xfkdScore!=null && xfkdScore>0){ addScore+=xfkdScore; } } - if(addScore>0){ - //插入新的积分 - scoreVipDetailService.addScore( - order.getUserId(),null, - null, - Long.parseLong(order.getStoreId()+""), - addScore, - Long.parseLong(orderId+""), - ScoreVipDetail.SCORE_VIP_TYPE_CASH, - "微商城消费"); - } - }); + } + if(addScore>0){ + //插入新的积分 + scoreVipDetailService.addScore( + order.getUserId(),null, + null, + Long.parseLong(order.getStoreId()+""), + addScore, + Long.parseLong(orderId+""), + ScoreVipDetail.SCORE_VIP_TYPE_CASH, + "微商城消费"); + } } -- Gitblit v1.9.1