From c95812b953a54e60c916c8ca375101376f58de57 Mon Sep 17 00:00:00 2001 From: Administrator <1101184511@qq.com> Date: 星期日, 20 四月 2025 17:24:09 +0800 Subject: [PATCH] 基础功能的单元测试完成 --- src/main/java/com/taoke/autopay/manager/UserCreditManager.java | 54 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 54 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/taoke/autopay/manager/UserCreditManager.java b/src/main/java/com/taoke/autopay/manager/UserCreditManager.java index d72b1ff..d095cfe 100644 --- a/src/main/java/com/taoke/autopay/manager/UserCreditManager.java +++ b/src/main/java/com/taoke/autopay/manager/UserCreditManager.java @@ -1,14 +1,19 @@ package com.taoke.autopay.manager; +import com.taoke.autopay.entity.credit.CreditSetting; import com.taoke.autopay.entity.credit.UserCreditBalance; import com.taoke.autopay.entity.credit.UserCreditRecord; +import com.taoke.autopay.exception.UserCreditException; +import com.taoke.autopay.service.credit.CreditSettingService; import com.taoke.autopay.service.credit.UserCreditBalanceService; import com.taoke.autopay.service.credit.UserCreditRecordService; +import com.taoke.autopay.utils.TimeUtil; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; import java.math.BigDecimal; +import java.util.Date; @Component public class UserCreditManager { @@ -18,6 +23,9 @@ @Resource private UserCreditRecordService userCreditRecordService; + + @Resource + private CreditSettingService creditSettingService; /** @@ -54,4 +62,50 @@ // 澧炲姞绉垎璁板綍 userCreditRecordService.addCreditRecord(creditRecord); } + + /** + * 鎶栭煶璁㈠崟鏀粯璁板綍 + * @param uid + */ + @Transactional(rollbackFor = Exception.class) + public void addDYOrderPayRecord(Long uid,String keyId) throws UserCreditException { + CreditSetting setting = creditSettingService.getSettingCacheByType(CreditSetting.CreditSettingType.DOUYIN_PAYMENT_SUCCESS_CREDITS,new Date(TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(System.currentTimeMillis(),"yyyyMMddHHmm"),"yyyyMMddHHmm"))); + if(setting==null){ + throw new UserCreditException("鏈厤缃姈闊虫敮浠樻垚鍔熺Н鍒�"); + } + UserCreditRecord record = UserCreditRecord.builder() + .creditAmount(Integer.parseInt(setting.getValue())) + .acquisitionMethod(UserCreditRecord.AcquisitionMethod.COMMAND_PAYMENT) + .direction(UserCreditRecord.DIRECTION_GAIN) + .identifierId(keyId) + .uid(uid) + .description("鎶栭煶浠d粯") + .build(); + increaseCredit(record); + } + + + /** + * 蹇墜璁㈠崟鏀粯鎴愬姛澧炲姞绉垎 + * @param uid + * @param keyId + * @throws UserCreditException + */ + @Transactional(rollbackFor = Exception.class) + public void addKSOrderPayRecord(Long uid,String keyId) throws UserCreditException { + CreditSetting setting = creditSettingService.getSettingCacheByType(CreditSetting.CreditSettingType.KUAISHOU_PAYMENT_SUCCESS_CREDITS,new Date(TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(System.currentTimeMillis(),"yyyyMMddHHmm"),"yyyyMMddHHmm"))); + if(setting==null){ + throw new UserCreditException("鏈厤缃揩鎵嬫敮浠樻垚鍔熺Н鍒�"); + } + UserCreditRecord record = UserCreditRecord.builder() + .creditAmount(Integer.parseInt(setting.getValue())) + .acquisitionMethod(UserCreditRecord.AcquisitionMethod.COMMAND_PAYMENT) + .direction(UserCreditRecord.DIRECTION_GAIN) + .identifierId(keyId) + .uid(uid) + .description("蹇墜浠d粯") + .build(); + increaseCredit(record); + } + } \ No newline at end of file -- Gitblit v1.8.0