package com.ks.app.service.manager;
|
|
import com.ks.goldcorn.exception.GoldAppException;
|
import com.ks.goldcorn.exception.GoldTradeException;
|
import com.ks.goldcorn.exception.GoldUserException;
|
import com.ks.goldcorn.pojo.DO.GoldCornGetSource;
|
import com.ks.goldcorn.pojo.DO.GoldCornRecord;
|
import com.ks.goldcorn.pojo.DO.GoldCornRecordCountMap;
|
import com.ks.goldcorn.pojo.Query.GoldCornRecordQuery;
|
import com.ks.goldcorn.service.remote.GoldCornBalanceService;
|
import com.ks.goldcorn.service.remote.GoldCornGetSourceService;
|
import com.ks.goldcorn.service.remote.GoldCornRecordService;
|
import com.ks.goldcorn.service.remote.GoldCornTradeService;
|
import com.ks.app.entity.vip.OrderRecord;
|
import com.ks.app.entity.vip.OrderType;
|
import com.ks.app.exception.goldcorn.GoldCornException;
|
import com.ks.app.service.inter.config.SystemConfigService;
|
import org.apache.dubbo.config.annotation.Reference;
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.StringUtil;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author hxh
|
* @title: GoldCornManager
|
* @description: TODO
|
* @date 2021/11/17 14:54
|
*/
|
@Component
|
public class GoldCornManager {
|
|
|
@Resource
|
private SystemConfigService systemConfigService;
|
|
// @Reference(version = "1.0", check = false)
|
private GoldCornTradeService goldCornTradeService;
|
|
// @Reference(version = "1.0", check = false)
|
private GoldCornRecordService goldCornRecordService;
|
|
// @Reference(version = "1.0", check = false)
|
private GoldCornBalanceService goldCornBalanceService;
|
|
// @Reference(version = "1.0", check = false)
|
private GoldCornGetSourceService goldCornGetSourceService;
|
|
|
public void init(Long uid) throws Exception {
|
goldCornBalanceService.init(getAppCode(), getUid(uid));
|
}
|
|
|
/**
|
* 获取金币系统的用户ID
|
*
|
* @param uid
|
* @return
|
* @throws Exception
|
*/
|
public String getUid(Long uid) throws Exception {
|
String prefix = "";//systemConfigService.getValueCache(SystemEnum.location,"thirdUidPrefix");
|
if (StringUtil.isNullOrEmpty(prefix)) {
|
throw new Exception("用户ID前缀获取出错");
|
}
|
return prefix + uid;
|
}
|
|
public String getAppCode() {
|
String appCode = "XXXX";
|
//TODO 获取appcode
|
return appCode;
|
}
|
|
public long getBalance(Long uid) {
|
if (uid == null) {
|
return 0;
|
}
|
try {
|
Long count = goldCornBalanceService.getBalance(getAppCode(), getUid(uid));
|
if (count == null) {
|
init(uid);
|
}
|
return count == null ? 0 : count;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return 0;
|
}
|
|
|
/**
|
* 金币消耗
|
*
|
* @param record
|
* @param goldCornCount 金币数量
|
* @throws GoldCornException
|
* @throws Exception
|
*/
|
public void consumeGoldCorn(OrderRecord record, int goldCornCount) throws GoldCornException, Exception {
|
String tuid = getUid(record.getUid());
|
String appCode = getAppCode();
|
String sourceCode = "";
|
String title = "";
|
String desc = "";
|
if (record.getOrderType() == OrderType.vip) {
|
sourceCode = "buyVIP";
|
title = "购买VIP";
|
}
|
consumeGoldCorn(appCode, tuid, sourceCode, goldCornCount, title, desc);
|
}
|
|
|
/**
|
* 添加金币
|
*
|
* @param uid
|
* @param source
|
* @param goldCorn
|
* @param title
|
* @param desc
|
* @throws GoldUserException
|
* @throws GoldAppException
|
* @throws GoldTradeException
|
* @throws Exception
|
*/
|
// public void addGoldCorn(String uid, CodeCornGetSourceType source, Integer goldCorn, String title, String desc) throws GoldUserException, GoldAppException, GoldTradeException, Exception {
|
// addGoldCorn(getAppCode(), getUid(uid), source.name(), goldCorn, title, desc);
|
// }
|
//
|
// public GoldCornGetSource getGoldCornGetSource(CodeCornGetSourceType source) throws GoldAppException {
|
// return goldCornGetSourceService.selectByAppAndCode(getAppCode(), source.name());
|
// }
|
|
/**
|
* 返回影视豆
|
*
|
* @param record
|
* @throws GoldCornException
|
* @throws Exception
|
*/
|
public void drawbackGoldCorn(OrderRecord record) throws GoldCornException, Exception {
|
String tuid = getUid(record.getUid());
|
String appCode = getAppCode();
|
String sourceCode = "";
|
String title = "";
|
String desc = "";
|
if (record.getOrderType() == OrderType.vip) {
|
sourceCode = "buyVIP";
|
title = "购买VIP退款";
|
}
|
addGoldCorn(appCode, tuid, sourceCode, record.getGoldCorn(), title, desc);
|
}
|
|
public List<GoldCornRecord> getRecordList(GoldCornRecordQuery query, Long uid) throws Exception {
|
query.setAppCode(getAppCode());
|
query.setUid(getUid(uid));
|
return goldCornRecordService.listUserRecord(query);
|
}
|
|
|
public long getRecordCount(GoldCornRecordQuery query, Long uid) throws Exception {
|
query.setAppCode(getAppCode());
|
query.setUid(getUid(uid));
|
return goldCornRecordService.countUserRecord(query);
|
}
|
|
private void addGoldCorn(String appCode, String uid, String sourceCode, Integer goldCornCount, String title, String desc) throws GoldUserException, GoldAppException, GoldTradeException {
|
goldCornTradeService.addGoldCorn(appCode, uid, sourceCode, goldCornCount, title, desc);
|
}
|
|
|
private void consumeGoldCorn(String appCode, String uid, String sourceCode, Integer goldCornCount, String title, String desc) throws GoldUserException, GoldAppException, GoldTradeException {
|
goldCornTradeService.consumeGoldCorn(appCode, uid, sourceCode, goldCornCount, title, desc);
|
}
|
|
|
public List<GoldCornGetSource> listGetCornSource(int page, int pageSize) throws GoldAppException {
|
return goldCornGetSourceService.listShow(getAppCode(), page, pageSize);
|
}
|
|
public List<GoldCornRecordCountMap> countRecordByGetSource(Long uid, List<String> sourceCodes, Date minCreateTime, Date maxCreateTime) throws Exception {
|
if (uid == null) {
|
return new ArrayList<>();
|
}
|
GoldCornRecordQuery query = new GoldCornRecordQuery();
|
query.setUid(getUid(uid));
|
query.setAppCode(getAppCode());
|
query.setSourceCodes(sourceCodes);
|
query.setMinCreateTime(minCreateTime);
|
query.setMaxCreateTime(maxCreateTime);
|
query.setType(GoldCornRecord.TYPE_GET);
|
return goldCornRecordService.countUserRecordBySource(query);
|
}
|
|
}
|
