From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 25 二月 2025 16:41:22 +0800 Subject: [PATCH] 淘宝转链接口更新 --- fanli/src/main/java/com/yeshi/fanli/lijin/manager/UserLijinMnager.java | 94 ++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 80 insertions(+), 14 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/lijin/manager/UserLijinMnager.java b/fanli/src/main/java/com/yeshi/fanli/lijin/manager/UserLijinMnager.java index ca25690..e734f08 100644 --- a/fanli/src/main/java/com/yeshi/fanli/lijin/manager/UserLijinMnager.java +++ b/fanli/src/main/java/com/yeshi/fanli/lijin/manager/UserLijinMnager.java @@ -3,6 +3,7 @@ import com.ks.lijin.service.LiJinExpendRecordService; import com.ks.lijin.service.LiJinLinkService; import com.ks.lijin.service.LijinCreateService; +import com.ks.vip.exception.LijinBalanceException; import com.ks.vip.exception.OrderPayException; import com.ks.vip.exception.VipOrderException; import com.ks.vip.pojo.DO.*; @@ -12,10 +13,14 @@ import com.ks.vip.pojo.Enums.VIPEnum; import com.ks.vip.service.*; import com.yeshi.fanli.entity.SystemEnum; +import com.yeshi.fanli.entity.config.SystemConfigKeyEnum; import com.yeshi.fanli.entity.system.ConfigKeyEnum; import com.yeshi.fanli.lijin.dto.TodayLijinCreatedInfo; import com.yeshi.fanli.lijin.vo.UserLijinLevelInfoVO; import com.yeshi.fanli.service.inter.config.ConfigService; +import com.yeshi.fanli.service.inter.config.SystemConfigService; +import com.yeshi.fanli.service.inter.user.UserInfoService; +import com.yeshi.fanli.util.account.UserUtil; import org.apache.dubbo.config.annotation.Reference; import org.springframework.stereotype.Component; import org.yeshi.utils.TimeUtil; @@ -29,55 +34,71 @@ @Component public class UserLijinMnager { - //@Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20904/com.ks.lijin.service.LijinCreateService") - @Reference(version = "1.0", check = false) - private LijinCreateService lijinCreateService; +// @Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20904/com.ks.lijin.service.LijinCreateService") +// @Reference(version = "1.0", check = false, timeout = 30000) +// private LijinCreateService lijinCreateService; - //@Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20902/com.ks.vip.service.VipCenterService") +// @Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20902/com.ks.vip.service.VipCenterService") @Reference(version = "1.0", check = false) private VipCenterService vipCenterService; - //@Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipCenterRecordService") +// @Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipCenterRecordService") @Reference(version = "1.0", check = false) private VipCenterRecordService vipCenterRecordService; - //@Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20902/com.ks.vip.service.VipGradePotenceService") +// @Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20902/com.ks.vip.service.VipGradePotenceService") @Reference(version = "1.0", check = false) private VipGradePotenceService vipGradePotenceService; - //@Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20902/com.ks.vip.service.VipGradeService") +// @Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20902/com.ks.vip.service.VipGradeService") @Reference(version = "1.0", check = false) private VipGradeService vipGradeService; - //@Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipComboService") +// @Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipComboService") @Reference(version = "1.0", check = false) private VipComboService vipComboService; - //@Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20904/com.ks.lijin.service.LiJinLinkService") +// @Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20904/com.ks.lijin.service.LiJinLinkService") @Reference(version = "1.0", check = false) private LiJinLinkService liJinLinkService; - //@Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20904/com.ks.lijin.service.LiJinExpendRecordService") +// @Reference(version = "1.0", check = false, url = "dubbo://193.112.35.168:20904/com.ks.lijin.service.LiJinExpendRecordService") @Reference(version = "1.0", check = false) private LiJinExpendRecordService liJinExpendRecordService; - //@Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipOrederService") +// @Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipOrederService") @Reference(version = "1.0", check = false) private VipOrederService vipOrederService; - //@Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipOrederPayService") +// @Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipOrederPayService") @Reference(version = "1.0", check = false) private VipOrederPayService vipOrederPayService; +// @Reference(version = "1.0", check = false,url="dubbo://193.112.35.168:20902/com.ks.vip.service.VipOrederPayService") + @Reference(version = "1.0", check = false) + private LijinBalanceService lijinBalanceService; + @Reference(version = "1.0", check = false) + private LijinRecordService lijinRecordService; + @Resource private ConfigService configService; + + @Resource + private SystemConfigService systemConfigService; + + @Resource + private UserInfoService userInfoService; private String getUid(Long uid) { if (uid == null) return null; - return "tejia-" + uid; + + SystemEnum system = userInfoService.getUserSystem(uid); + if (system == null) + return null; + return systemConfigService.getValueCache(SystemConfigKeyEnum.thirdAppUidPrefix, system) + uid; } public VIPEnum getVIPRank(Long uid) { @@ -158,7 +179,7 @@ * @return */ public UserLijinLevelInfoVO getUserLevelInfo(Long uid, SystemEnum system) { - if (system == SystemEnum.yhqjx) { + if (system == SystemEnum.yhqjx || system == SystemEnum.hsb) { VIPEnum rank = getVIPRank(uid); UserLijinLevelInfoVO vo = new UserLijinLevelInfoVO(); vo.setUserLevel(getVIPRank(uid).name()); @@ -288,5 +309,50 @@ return vipOrederPayService.getAlipayPaySuccessOutOrderNo(params); } + public void addLijin(Long uid, BigDecimal money, String title, String category) throws LijinBalanceException { + lijinBalanceService.addLijin(getUid(uid), money, title, category, null); + } + + public List<UserLijinRecord> getLijinRecord(Long uid, Integer type, int page, int pageSize) { + return lijinRecordService.listRecord(getUid(uid), type, page, pageSize); + } + + public long countLijinRecord(Long uid, Integer type) { + return lijinRecordService.countRecord(getUid(uid), type); + } + + public UserLijinRecord getLijinRecord(Long uid, Integer type, String category) { + return lijinRecordService.getRecord(getUid(uid), type, category, null); + } + + /** + * 鑾峰彇绀奸噾浣欓 + * + * @param uid + * @return + */ + public BigDecimal getLijinBalance(Long uid) { + return lijinBalanceService.getBalance(getUid(uid)); + } + + /** + * 鑾峰彇浣跨敤涓殑绀奸噾 + * + * @param uid + * @return + */ + public BigDecimal getUsingLijin(Long uid) { + return lijinBalanceService.getUsingLijin(getUid(uid)); + } + + /** + * 鍒濆鍖栦綑棰� + * + * @param uid + */ + public void initBalance(Long uid) { + lijinBalanceService.init(getUid(uid)); + } + } -- Gitblit v1.8.0