修改积分交易

p-honggang.li

2025-09-03 7307fad287994fce2567bf4a7bdd4b7d3f06ea83

修改积分交易

 src/main/java/com/webmanage/dto/DeductUserPointsDTO.java

@@ -38,4 +38,7 @@

    @ApiModelProperty("数据类型")
    private Integer dataType = 1; // 1表示消耗

    @ApiModelProperty("提供者")
    private String providerId;
}

 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);