From 7307fad287994fce2567bf4a7bdd4b7d3f06ea83 Mon Sep 17 00:00:00 2001
From: p-honggang.li <p-honggang.li@pcitc.com>
Date: 星期三, 03 九月 2025 18:30:53 +0800
Subject: [PATCH] 修改积分交易
---
src/main/java/com/webmanage/service/impl/PointsFlowServiceImpl.java | 13 ++++++++++++-
src/main/java/com/webmanage/dto/DeductUserPointsDTO.java | 3 +++
2 files changed, 15 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/webmanage/dto/DeductUserPointsDTO.java b/src/main/java/com/webmanage/dto/DeductUserPointsDTO.java
index a3eed51..7d1ad4a 100644
--- a/src/main/java/com/webmanage/dto/DeductUserPointsDTO.java
+++ b/src/main/java/com/webmanage/dto/DeductUserPointsDTO.java
@@ -38,4 +38,7 @@
@ApiModelProperty("鏁版嵁绫诲瀷")
private Integer dataType = 1; // 1琛ㄧず娑堣��
+
+ @ApiModelProperty("鎻愪緵鑰�")
+ private String providerId;
}
diff --git a/src/main/java/com/webmanage/service/impl/PointsFlowServiceImpl.java b/src/main/java/com/webmanage/service/impl/PointsFlowServiceImpl.java
index fd44187..14fd125 100644
--- a/src/main/java/com/webmanage/service/impl/PointsFlowServiceImpl.java
+++ b/src/main/java/com/webmanage/service/impl/PointsFlowServiceImpl.java
@@ -17,6 +17,7 @@
import com.webmanage.mapper.UserPointsMapper;
import com.webmanage.mapper.PointsTransactionMapper;
import com.webmanage.entity.PointsTransaction;
+import com.webmanage.service.OrderInfoService;
import com.webmanage.service.PointsFlowService;
import com.webmanage.service.PointsRuleService;
import lombok.extern.slf4j.Slf4j;
@@ -45,6 +46,7 @@
@Resource
private PointsTransactionMapper pointsTransactionMapper;
+
@Override
public PageResult<PointsFlow> getPersonalPointsFlowPage(PointsFlowQueryDTO queryDTO) {
@@ -571,6 +573,7 @@
public boolean deductUserPoints(DeductUserPointsDTO deductDTO) {
try {
String userId = deductDTO.getUserId();
+ String providerId = deductDTO.getProviderId();
String unitId = deductDTO.getUnitId();
Integer points = deductDTO.getPoints();
String orderId = deductDTO.getOrderId();
@@ -632,7 +635,15 @@
if (inserted <= 0 || trans.getId() == null) {
throw new BusinessException("淇濆瓨绉垎浜ゆ槗璁板綍澶辫触");
}
-
+ // 涓烘彁渚涜�呮柊澧炵Н鍒�
+ AddPointsFlowDTO addPointsFlowDTO = new AddPointsFlowDTO();
+ addPointsFlowDTO.setCategory("璧勬簮浜ゆ槗");
+ addPointsFlowDTO.setCount(1);
+ addPointsFlowDTO.setProviderId(providerId);
+ addPointsFlowDTO.setRuleType(0);
+ addPointsFlowDTO.setRuleNameCode("digital_product_transaction");
+ addPointsFlowDTO.setDescription("浜у搧浜ゆ槗");
+ addPointsFlowByRule(addPointsFlowDTO);
return true;
} catch (Exception e) {
log.error("鎵ｅ噺鐢ㄦ埛绉垎澶辫触", e);
--
Gitblit v1.8.0