package com.yami.trading.service.user.impl;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.google.common.reflect.TypeToken;
|
import com.google.gson.Gson;
|
import com.yami.trading.bean.contract.domain.ContractOrder;
|
import com.yami.trading.bean.data.domain.Realtime;
|
import com.yami.trading.bean.exchange.ExchangeApplyOrder;
|
import com.yami.trading.bean.future.domain.FuturesOrder;
|
import com.yami.trading.bean.model.User;
|
import com.yami.trading.bean.model.UserData;
|
import com.yami.trading.bean.model.UserDataSum;
|
import com.yami.trading.bean.model.UserRecom;
|
import com.yami.trading.bean.user.dto.ChildrenLever;
|
import com.yami.trading.bean.user.dto.UserBenefitsDto;
|
import com.yami.trading.common.constants.Constants;
|
import com.yami.trading.common.exception.YamiShopBindException;
|
import com.yami.trading.common.util.Arith;
|
import com.yami.trading.common.util.DateUtil;
|
import com.yami.trading.common.util.DateUtils;
|
import com.yami.trading.dao.user.UserDataMapper;
|
import com.yami.trading.service.data.DataService;
|
import com.yami.trading.service.user.UserDataService;
|
import com.yami.trading.service.user.UserDataSumService;
|
import com.yami.trading.service.user.UserRecomService;
|
import com.yami.trading.service.user.UserService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import java.io.Serializable;
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.util.*;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
@Service
|
@Slf4j
|
public class UserDataServiceImpl extends ServiceImpl<UserDataMapper, UserData> implements UserDataService {
|
/**
|
* 缓存时间
|
*/
|
private final int CACHE_TIME = 60 * 60 * 25;
|
private final String CACHE_KEY_START = "usercode:";
|
@Autowired
|
UserService userService;
|
@Autowired
|
UserRecomService userRecomService;
|
@Autowired
|
UserDataSumService userDataSumService;
|
|
@Autowired
|
private DataService dataService;
|
|
@Autowired
|
private RedisTemplate<String, Object> redisTemplate;
|
private String REDIS_KEY = "userdata:";
|
|
private UserData findBydate(String userId, Date date) {
|
|
Date startDate = DateUtil.minDate(date);
|
;
|
Date endDate = DateUtil.maxDate(date);
|
return getOne(Wrappers.<UserData>query().lambda().between(UserData::getCreateTime, startDate, endDate)
|
.eq(UserData::getUserId, userId));
|
}
|
|
public Map<String, UserData> cacheByPartyId(String partyId) {
|
|
Object obj = redisTemplate.opsForValue().get(REDIS_KEY + partyId);
|
if (obj == null) {
|
return null;
|
}
|
return null;
|
// return new Gson().fromJson(obj.toString(), new TypeToken<HashMap<String, UserData>>() {
|
// }.getType());
|
}
|
|
@Override
|
public Page listUserGenefits(Page page, Date startTime, Date endTime, String userName,
|
List<String> children) {
|
|
baseMapper.listUserGenefits(page, startTime, endTime, userName,children);
|
compute(page.getRecords());
|
return page;
|
|
|
|
}
|
|
/**
|
* 获取今日充值的人数
|
*
|
* @return
|
*/
|
@Override
|
public long countTodayRechargeUser() {
|
|
Date now = new Date();
|
return count(Wrappers.<UserData>query().lambda().between(UserData::getCreateTime, DateUtil.minDate(now),
|
DateUtil.maxDate(now)).gt(UserData::getRecharge, 0));
|
}
|
|
@Override
|
public UserBenefitsDto daySumData(Date startTime, Date endTime, List<String> userIds) {
|
|
return baseMapper.daySumData(startTime, endTime, userIds);
|
}
|
|
|
/**
|
* 矿机利息
|
*/
|
@Override
|
public void saveGiftMoneyHandle(String partyId, double amount) {
|
User user =userService.getById(partyId);
|
boolean guest = false;
|
if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName())) {
|
guest = true;
|
}
|
|
if (guest) {
|
return;
|
}
|
|
UserData userData = new UserData();
|
userData.setRolename(user.getRoleName());
|
userData.setCreateTime(new Date());
|
userData.setUserId(user.getUserId());
|
userData.setGiftMoney(amount);
|
saveUserData(userData);
|
|
}
|
|
@Override
|
public List<Map<String, UserData>> cacheByPartyIds(List<String> partyIds) {
|
|
if (CollectionUtils.isEmpty(partyIds)) return new LinkedList<Map<String, UserData>>();
|
List<Map<String, UserData>> result = new LinkedList<Map<String, UserData>>();
|
for (String id : partyIds) {
|
result.add(cacheByPartyId(id));
|
}
|
return result;
|
}
|
|
@Override
|
public void saveRegister(String userId) {
|
|
User user = userService.getById(userId);
|
boolean guest = false;
|
if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName())) {
|
guest = true;
|
}
|
if (guest) {
|
return;
|
}
|
UserRecom userRecom = userRecomService.findByPartyId(userId);
|
if (userRecom == null) {
|
return;
|
}
|
List<UserRecom> parents = this.userRecomService.getParents(userId);
|
int loop = 4;
|
for (int i = 0; i < parents.size(); i++) {
|
User party_parent = userService.getById(parents.get(i).getRecomUserId());
|
if (Constants.SECURITY_ROLE_MEMBER.equals(party_parent.getRoleName()) && loop > 0) {
|
UserData userData_reco = new UserData();
|
userData_reco.setRolename(party_parent.getRoleName());
|
userData_reco.setCreateTime(new Date());
|
userData_reco.setUserId(parents.get(i).getRecomUserId());
|
userData_reco.setRecoNum(1);
|
save(userData_reco);
|
UserDataSum userDataSum = saveBySum(parents.get(i).getRecomUserId());
|
userDataSum.setRecoNum(userDataSum.getRecoNum() + 1);
|
userDataSumService.updateById(userDataSum);
|
loop--;
|
}
|
// if (Constants.SECURITY_ROLE_AGENT.equals(party_parent.getRoleName())) {
|
// List<UserDataSum> userDataSums = userDataSumService.getByUserId(parents.get(i).getRecomUserId().toString());
|
// UserDataSum userDataSum = new UserDataSum();
|
// if (userDataSums.size() > 0) {
|
// userDataSum = userDataSums.get(0);
|
// }
|
// userDataSum.setRecoNum(userDataSum.getRecoNum() + 1);
|
// userDataSumService.saveOrUpdate(userDataSum);
|
// }
|
}
|
}
|
|
/**
|
* 根据partyId获取UserDataSum
|
*/
|
public UserDataSum saveBySum(String partyId) {
|
|
List list = userDataSumService.getByUserId(partyId);
|
if (list.size() > 0) {
|
return (UserDataSum) list.get(0);
|
}
|
UserDataSum userDataSum = new UserDataSum();
|
userDataSum.setUserId(partyId);
|
userDataSumService.save(userDataSum);
|
return userDataSum;
|
}
|
|
@Override
|
public Page userAll(Page page, Date startTime, Date endTime) {
|
|
Page page1 = baseMapper.userAll(page, startTime, endTime);
|
compute(page1.getRecords(), false);
|
return page1;
|
}
|
|
@Override
|
public Map sumAll(Date startTime, Date endTime) {
|
|
Map map = baseMapper.sumAll(startTime, endTime);
|
List<Map> maps = new ArrayList<>();
|
maps.add(map);
|
compute(maps, true);
|
return maps.get(0);
|
}
|
|
/**
|
* 统计的数据存在空时，不统计总额
|
*
|
* @param data
|
* @return
|
*/
|
private boolean dataExistNull(Map<String, Object> data) {
|
|
if (null == data.get("recharge_withdrawal_fee")) return false;
|
if (null == data.get("order_income")) return false;
|
if (null == data.get("fee")) return false;
|
if (null == data.get("finance_income")) return false;
|
if (null == data.get("exchange_fee")) return false;
|
if (null == data.get("exchange_income")) return false;
|
if (null == data.get("furtures_fee")) return false;
|
if (null == data.get("furtures_income")) return false;
|
return true;
|
}
|
|
|
private void compute(List<Map<String,Object>> datas) {
|
if(org.apache.commons.collections.CollectionUtils.isEmpty(datas)) return;
|
Double totle_income=0d;
|
Double totle_fee = 0d;
|
Double business_profit = 0d;//交易盈亏
|
Double fin_miner_amount = 0d;//理财 矿机 交易额
|
Double fin_miner_income = 0d;//理财 矿机 收益
|
for(Map<String,Object> data:datas) {
|
totle_income=0d;
|
totle_fee = 0d;
|
business_profit = 0d;
|
fin_miner_amount = 0d;
|
fin_miner_income = 0d;
|
if(null==data.get("reco_num")) {
|
data.put("reco_num", 0);
|
}
|
|
// if(null!=data.get("rolename")) {
|
// data.put("rolename", Constants.ROLE_MAP.get(data.get("rolename").toString()));
|
// }
|
if(null != data.get("order_income"))
|
data.put("order_income", Arith.sub(0, new Double(data.get("order_income").toString())));//订单收益负数
|
if(null != data.get("finance_income"))
|
data.put("finance_income", Arith.sub(0, new Double(data.get("finance_income").toString())));//理财收益负数
|
if(null != data.get("exchange_income"))
|
// data.put("exchange_income", Arith.sub(0, new Double(data.get("exchange_income").toString())));//币币收益负数
|
data.put("exchange_income", 0);//币币收益负数
|
if(null != data.get("furtures_income"))
|
data.put("furtures_income", Arith.sub(0, new Double(data.get("furtures_income").toString())));//交割收益负数
|
if (null != data.get("miner_income"))
|
data.put("miner_income", Arith.sub(0, new Double(data.get("miner_income").toString())));// 矿机收益负数
|
if (null != data.get("exchange_lever_order_income"))
|
data.put("exchange_lever_order_income", Arith.sub(0, new Double(data.get("exchange_lever_order_income").toString())));// 币币收益负数
|
|
if(!dataExistNull(data)) continue;
|
totle_income = Arith.add(totle_income,new Double(data.get("recharge_withdrawal_fee").toString()));
|
totle_income = Arith.add(totle_income,new Double(data.get("order_income").toString()));
|
totle_income = Arith.add(totle_income,new Double(data.get("fee").toString()));
|
totle_income = Arith.add(totle_income,new Double(data.get("finance_income").toString()));
|
totle_income = Arith.add(totle_income,new Double(data.get("exchange_fee").toString()));
|
totle_income = Arith.add(totle_income,new Double(0));
|
// totle_income = Arith.add(totle_income,new Double(data.get("exchange_income").toString()));
|
totle_income = Arith.add(totle_income,new Double(data.get("furtures_fee").toString()));
|
totle_income = Arith.add(totle_income,new Double(data.get("furtures_income").toString()));
|
totle_income = Arith.add(totle_income,new Double(data.get("miner_income").toString()));
|
totle_income = Arith.add(totle_income,new Double(data.get("exchange_lever_order_income").toString()));
|
data.put("totle_income", totle_income);
|
|
totle_fee = Arith.add(totle_fee, new Double(data.get("recharge_withdrawal_fee").toString()));
|
totle_fee = Arith.add(totle_fee, new Double(data.get("fee").toString()));
|
totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_fee").toString()));
|
totle_fee = Arith.add(totle_fee, new Double(data.get("furtures_fee").toString()));
|
totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_lever_fee").toString()));
|
data.put("totle_fee", totle_fee);
|
|
business_profit = Arith.add(business_profit, new Double(data.get("order_income").toString()));
|
business_profit = Arith.add(business_profit, new Double(data.get("exchange_income").toString()));
|
business_profit = Arith.add(business_profit, new Double(data.get("furtures_income").toString()));
|
business_profit = Arith.add(business_profit, new Double(data.get("exchange_lever_order_income").toString()));
|
data.put("business_profit", business_profit);
|
|
fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("finance_amount").toString()));
|
fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("miner_amount").toString()));
|
data.put("fin_miner_amount", fin_miner_amount);
|
|
fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("finance_income").toString()));
|
fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("miner_income").toString()));
|
data.put("fin_miner_income", fin_miner_income);
|
}
|
}
|
|
|
/**
|
* 计算 统计时
|
*
|
* @param datas
|
* @param isSum
|
*/
|
private void compute(List<Map> datas, boolean isSum) {
|
|
if (org.apache.commons.collections.CollectionUtils.isEmpty(datas)) return;
|
Double totle_income = 0d;
|
Double totle_fee = 0d;
|
Double business_profit = 0d;//交易盈亏
|
Double fin_miner_amount = 0d;//理财 矿机 交易额
|
Double fin_miner_income = 0d;//理财 矿机 收益
|
for (Map<String, Object> data : datas) {
|
totle_income = 0d;
|
totle_fee = 0d;
|
business_profit = 0d;
|
fin_miner_amount = 0d;
|
fin_miner_income = 0d;
|
if (null != data.get("order_income"))
|
data.put("order_income", Arith.sub(0, new Double(data.get("order_income").toString())));//订单收益负数
|
if (null != data.get("finance_income"))
|
data.put("finance_income", Arith.sub(0, new Double(data.get("finance_income").toString())));//理财收益负数
|
if (null != data.get("exchange_income"))
|
// data.put("exchange_income", Arith.sub(0, new Double(data.get("exchange_income").toString())));//币币收益负数
|
data.put("exchange_income", 0);//币币收益负数
|
if (null != data.get("furtures_income"))
|
data.put("furtures_income", Arith.sub(0, new Double(data.get("furtures_income").toString())));//交割收益负数
|
if (null != data.get("miner_income"))
|
data.put("miner_income", Arith.sub(0, new Double(data.get("miner_income").toString())));// 矿机收益负数
|
if (null != data.get("exchange_lever_order_income"))
|
data.put("exchange_lever_order_income", Arith.sub(0, new Double(data.get("exchange_lever_order_income").toString())));// 币币收益负数
|
if (!dataExistNull(data)) continue;
|
totle_income = Arith.add(totle_income, new Double(data.get("recharge_withdrawal_fee").toString()));
|
totle_income = Arith.add(totle_income, new Double(data.get("order_income").toString()));
|
totle_income = Arith.add(totle_income, new Double(data.get("fee").toString()));
|
totle_income = Arith.add(totle_income, new Double(data.get("finance_income").toString()));
|
totle_income = Arith.add(totle_income, new Double(data.get("exchange_fee").toString()));
|
totle_income = Arith.add(totle_income, new Double(0));
|
// totle_income = Arith.add(totle_income,new Double(data.get("exchange_income").toString()));
|
totle_income = Arith.add(totle_income, new Double(data.get("furtures_fee").toString()));
|
totle_income = Arith.add(totle_income, new Double(data.get("furtures_income").toString()));
|
totle_income = Arith.add(totle_income, new Double(data.get("miner_income").toString()));
|
totle_income = Arith.add(totle_income, new Double(data.get("exchange_lever_order_income").toString()));
|
data.put("totle_income", totle_income);
|
totle_fee = Arith.add(totle_fee, new Double(data.get("recharge_withdrawal_fee").toString()));
|
totle_fee = Arith.add(totle_fee, new Double(data.get("fee").toString()));
|
totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_fee").toString()));
|
totle_fee = Arith.add(totle_fee, new Double(data.get("furtures_fee").toString()));
|
totle_fee = Arith.add(totle_fee, new Double(data.get("exchange_lever_fee").toString()));
|
data.put("totle_fee", totle_fee);
|
business_profit = Arith.add(business_profit, new Double(data.get("order_income").toString()));
|
business_profit = Arith.add(business_profit, new Double(data.get("exchange_income").toString()));
|
business_profit = Arith.add(business_profit, new Double(data.get("furtures_income").toString()));
|
business_profit = Arith.add(business_profit, new Double(data.get("exchange_lever_order_income").toString()));
|
data.put("business_profit", business_profit);
|
fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("finance_amount").toString()));
|
fin_miner_amount = Arith.add(fin_miner_amount, new Double(data.get("miner_amount").toString()));
|
data.put("fin_miner_amount", fin_miner_amount);
|
fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("finance_income").toString()));
|
fin_miner_income = Arith.add(fin_miner_income, new Double(data.get("miner_income").toString()));
|
data.put("fin_miner_income", fin_miner_income);
|
data.put("recharge_btc", new BigDecimal(data.get("recharge_btc").toString()).setScale(8, RoundingMode.FLOOR).toPlainString());//订单收益负数
|
}
|
}
|
|
@Override
|
public void saveUserData(UserData entity) {
|
|
try {
|
UserData db = findBydate(entity.getUserId(), entity.getCreateTime());
|
if (db != null) {
|
db.setRechargeDapp(Arith.add(db.getRechargeDapp(), entity.getRechargeDapp()));
|
db.setWithdrawDapp(Arith.add(db.getWithdrawDapp(), entity.getWithdrawDapp()));
|
db.setRecharge(Arith.add(db.getRecharge(), entity.getRecharge()));
|
db.setRechargeEth(Arith.add(db.getRechargeEth(), entity.getRechargeEth()));
|
db.setRechargeUsdt(Arith.add(db.getRechargeUsdt(), entity.getRechargeUsdt()));
|
db.setRechargeBtc(Arith.add(db.getRechargeBtc(), entity.getRechargeBtc()));
|
db.setRechargeHt(Arith.add(db.getRechargeHt(), entity.getRechargeHt()));
|
db.setRechargeLtc(Arith.add(db.getRechargeLtc(), entity.getRechargeLtc()));
|
// 充值返佣
|
db.setRechargeRecom(Arith.add(db.getRechargeRecom(), entity.getRechargeRecom()));
|
db.setWithdrawAll(Arith.add(db.getWithdrawAll(), entity.getWithdrawAll()));
|
db.setWithdraw(Arith.add(db.getWithdraw(), entity.getWithdraw()));
|
db.setWithdrawEth(Arith.add(db.getWithdrawEth(), entity.getWithdrawEth()));
|
db.setWithdrawBtc(Arith.add(db.getWithdrawBtc(), entity.getWithdrawBtc()));
|
db.setAmount(Arith.add(db.getAmount(), entity.getAmount()));
|
db.setFee(Arith.add(db.getFee(), entity.getFee()));
|
db.setOrderIncome(Arith.add(db.getOrderIncome(), entity.getOrderIncome()));
|
db.setFinanceAmount(Arith.add(db.getFinanceAmount(), entity.getFinanceAmount()));
|
db.setFinanceIncome(Arith.add(db.getFinanceIncome(), entity.getFinanceIncome()));
|
db.setExchangeAmount(Arith.add(db.getExchangeAmount(), entity.getExchangeAmount()));
|
db.setExchangeFee(Arith.add(db.getExchangeFee(), entity.getExchangeFee()));
|
db.setExchangeIncome(Arith.add(db.getExchangeIncome(), entity.getExchangeIncome()));
|
db.setCoinIncome(Arith.add(db.getCoinIncome(), entity.getCoinIncome()));
|
db.setFurturesAmount(Arith.add(db.getFurturesAmount(), entity.getFurturesAmount()));
|
db.setFurturesFee(Arith.add(db.getFurturesFee(), entity.getFurturesFee()));
|
db.setFurturesIncome(Arith.add(db.getFurturesIncome(), entity.getFurturesIncome()));
|
db.setRecoNum(db.getRecoNum() + entity.getRecoNum());
|
db.setRechargeWithdrawalFee(
|
Arith.add(db.getRechargeWithdrawalFee(), entity.getRechargeWithdrawalFee()));
|
db.setGiftMoney(Arith.add(db.getGiftMoney(), entity.getGiftMoney()));
|
db.setMinerAmount(Arith.add(db.getMinerAmount(), entity.getMinerAmount()));
|
db.setMinerIncome(Arith.add(db.getMinerIncome(), entity.getMinerIncome()));
|
// 质押2.0
|
db.setGalaxyAmount(Arith.add(db.getGalaxyAmount(), entity.getGalaxyAmount()));
|
db.setGalaxyIncome(Arith.add(db.getGalaxyIncome(), entity.getGalaxyIncome()));
|
db.setThirdRechargeAmount(Arith.add(db.getThirdRechargeAmount(), entity.getThirdRechargeAmount()));
|
db.setHoldingMoney(Arith.add(db.getHoldingMoney(), entity.getHoldingMoney()));
|
db.setTransferInMoney(Arith.add(db.getTransferInMoney(), entity.getTransferInMoney()));
|
db.setTransferOutMoney(Arith.add(db.getTransferOutMoney(), entity.getTransferOutMoney()));
|
db.setExchangeLeverAmount(Arith.add(db.getExchangeLeverAmount(), entity.getExchangeLeverAmount()));
|
db.setExchangeLeverFee(Arith.add(db.getExchangeLeverFee(), entity.getExchangeLeverFee()));
|
db.setExchangeLeverOrderIncome(Arith.add(db.getExchangeLeverOrderIncome(), entity.getExchangeLeverOrderIncome()));
|
updateById(db);
|
setCache(db);
|
} else {
|
save(entity);
|
setCache(entity);
|
}
|
} catch (Exception e) {
|
log.error("saveUserData 异常", e);
|
}
|
}
|
|
public void setCache(UserData userData) {
|
// Map<String, UserData> map_party = cacheByPartyId(userData.getUserId());
|
// if (map_party == null) {
|
// map_party = new ConcurrentHashMap<String, UserData>();
|
// }
|
// map_party.put(DateUtils.format(userData.getCreateTime(), DateUtils.DEFAULT_DATE_FORMAT), userData);
|
// put(userData.getUserId(), map_party);
|
}
|
|
public void put(String userId, Map<String, UserData> map_party) {
|
|
redisTemplate.opsForValue().set(REDIS_KEY + userId, map_party);
|
}
|
|
@Override
|
public List<Map<String, UserData>> findByPartyIds(List<String> children) {
|
List<UserData> users= list(Wrappers.<UserData>query().lambda().in(UserData::getUserId,children));
|
List<Map<String, UserData>> mapList=new ArrayList<>();
|
for (UserData userData:users){
|
Map<String, UserData> map=new HashMap<>();
|
map.put(userData.getUserId(),userData);
|
mapList.add(map);
|
}
|
return mapList;
|
}
|
|
/**
|
* 资金盘定制化需求，等盘口下架可以删除
|
*/
|
|
@Override
|
public List<Map<String, Object>> getChildrenLevelPagedForGalaxy(int pageNo, int pageSize, String partyId, Integer levelNum) {
|
|
List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
|
ChildrenLever children = cacheChildrenLever4(partyId);
|
// 获取子代partyId
|
List<String> level = new ArrayList<String>();
|
if (levelNum == 1) {
|
level = children.getLever1();
|
}
|
if (levelNum == 2) {
|
level = children.getLever2();
|
}
|
if (levelNum == 3) {
|
level = children.getLever3();
|
}
|
// if (levelNum == 4) {
|
// level = children.getLever4();
|
// }
|
if (level == null || level.isEmpty()) {
|
return list;
|
}
|
Page<User> page = new Page(pageNo, pageSize);
|
userService.page(page, Wrappers.<User>query().lambda().in(User::getUserId, level));
|
Map<String, Object> element_map = new HashMap<String, Object>();
|
for (int i = 0; i < page.getRecords().size(); i++) {
|
User user = page.getRecords().get(i);
|
element_map.put("username", user.getUserName());
|
element_map.put("partyId", user.getUserId());
|
String childrenPartyId = element_map.get("partyId").toString();
|
ChildrenLever childrenLever = cacheChildrenLever4(childrenPartyId);
|
// 获取子代partyId
|
List<String> level_children = new ArrayList<String>();
|
if (levelNum == 1) {
|
level_children = childrenLever.getLever1();
|
}
|
if (levelNum == 2) {
|
level_children = childrenLever.getLever2();
|
}
|
if (levelNum == 3) {
|
level_children = childrenLever.getLever3();
|
}
|
// if (levelNum == 4) {
|
// level_children = childrenLever.getLever4();
|
// }
|
element_map.put("reco_sum", level_children.size());
|
// list里面的总业绩
|
Map<String, UserData> map = cacheByPartyId(childrenPartyId);
|
double sum = 0;
|
if (null != map && map.size() > 0) {
|
for (UserData userData : map.values()) {
|
sum += userData.getGalaxyIncome();
|
}
|
}
|
element_map.put("recharge_sum", sum);
|
list.add(element_map);
|
}
|
return list;
|
}
|
|
@Override
|
public ChildrenLever cacheChildrenLever4(String partyId) {
|
|
ChildrenLever childrenLever = new ChildrenLever();
|
/**
|
* lever1
|
*/
|
List<UserRecom> userrecom_lever1 = userRecomService.findRecoms(partyId);
|
for (int i = 0; i < userrecom_lever1.size(); i++) {
|
childrenLever.getLever1().add(userrecom_lever1.get(i).getUserId().toString());
|
}
|
/**
|
* lever2
|
*/
|
if (childrenLever.getLever1().size() == 0) {
|
return childrenLever;
|
}
|
for (int i = 0; i < childrenLever.getLever1().size(); i++) {
|
List<UserRecom> userrecom_lever2 = userRecomService.findRecoms(childrenLever.getLever1().get(i));
|
for (int j = 0; j < userrecom_lever2.size(); j++) {
|
childrenLever.getLever2().add(userrecom_lever2.get(j).getUserId().toString());
|
}
|
}
|
/**
|
* lever3
|
*/
|
if (childrenLever.getLever2().size() == 0) {
|
return childrenLever;
|
}
|
for (int i = 0; i < childrenLever.getLever2().size(); i++) {
|
List<UserRecom> userrecom_lever3 = userRecomService.findRecoms(childrenLever.getLever2().get(i));
|
for (int j = 0; j < userrecom_lever3.size(); j++) {
|
childrenLever.getLever3().add(userrecom_lever3.get(j).getUserId().toString());
|
}
|
}
|
// /**
|
// * lever4
|
// */
|
// if (childrenLever.getLever3().size() == 0) {
|
// return childrenLever;
|
// }
|
// for (int i = 0; i < childrenLever.getLever3().size(); i++) {
|
// List<UserRecom> userrecom_lever4 = userRecomService.findRecoms(childrenLever.getLever3().get(i));
|
// for (int j = 0; j < userrecom_lever4.size(); j++) {
|
// childrenLever.getLever4().add(userrecom_lever4.get(j).getPartyId().toString());
|
// }
|
//
|
// }
|
return childrenLever;
|
}
|
|
public void saveWithdrawHandle(String partyId, double amount, double amount_fee, String symbol) {
|
|
System.out.println("saveWithdrawHandle -> partyId:" + partyId);
|
User user = userService.getById(partyId);
|
boolean guest = false;
|
if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName())) {
|
guest = true;
|
}
|
if (guest) {
|
return;
|
}
|
UserData userData = new UserData();
|
userData.setRolename(user.getRoleName());
|
userData.setCreateTime(new Date());
|
userData.setUserId(partyId);
|
if (StringUtils.isEmpty(symbol) || "usdt".equals(symbol)) {
|
userData.setWithdraw(amount);
|
userData.setRechargeWithdrawalFee(amount_fee);
|
userData.setWithdrawAll(amount);
|
} else {
|
// TODO: 2023/4/21 = this.dataService.realtime(symbol);
|
List<Realtime> realtime_list = dataService.realtime(symbol);
|
Realtime realtime = null;
|
if (realtime_list.size() > 0) {
|
realtime = realtime_list.get(0);
|
} else {
|
throw new YamiShopBindException("系统错误，请稍后重试");
|
}
|
if ("btc".equals(symbol)) {
|
userData.setRechargeWithdrawalFee(Arith.mul(amount_fee, realtime.getClose().doubleValue()));
|
userData.setWithdrawBtc(amount);
|
userData.setWithdrawAll(Arith.mul(amount, realtime.getClose().doubleValue()));
|
}
|
if ("eth".equals(symbol)) {
|
userData.setRechargeWithdrawalFee(Arith.mul(amount_fee, realtime.getClose().doubleValue()));
|
userData.setWithdrawEth(amount);
|
userData.setWithdrawAll(Arith.mul(amount, realtime.getClose().doubleValue()));
|
}
|
}
|
saveUserData(userData);
|
}
|
|
@Override
|
public void saveRechargeHandle(String partyId, double amount, String symbol) {
|
|
User party = userService.getById(partyId);
|
if ("USDT_DAPP".equals(symbol)) {
|
UserData userData = new UserData();
|
userData.setRolename(party.getRoleName());
|
userData.setCreateTime(new Date());
|
userData.setUserId(partyId);
|
userData.setRechargeDapp(amount);
|
save(userData);
|
return;
|
}
|
boolean guest = false;
|
if (Constants.SECURITY_ROLE_GUEST.equals(party.getRoleName())) {
|
guest = true;
|
}
|
if (guest) {
|
return;
|
}
|
UserData userData = new UserData();
|
userData.setRolename(party.getRoleName());
|
userData.setCreateTime(new Date());
|
userData.setUserId(partyId);
|
if ("usdt".equals(symbol)) {
|
userData.setRecharge(amount);
|
userData.setRechargeUsdt(amount);
|
} else {
|
List<Realtime> realtime_list = this.dataService.realtime(symbol);
|
Realtime realtime = null;
|
if (realtime_list.size() > 0) {
|
realtime = realtime_list.get(0);
|
} else {
|
throw new YamiShopBindException("系统错误，请稍后重试");
|
}
|
if ("btc".equals(symbol)) {
|
userData.setRecharge(Arith.mul(amount, realtime.getClose().doubleValue()));
|
userData.setRechargeBtc(amount);
|
}
|
if ("eth".equals(symbol)) {
|
userData.setRecharge(Arith.mul(amount, realtime.getClose().doubleValue()));
|
userData.setRechargeEth(amount);
|
}
|
if ("ht".equals(symbol)) {
|
userData.setRecharge(Arith.mul(amount, realtime.getClose().doubleValue()));
|
userData.setRechargeHt(amount);
|
}
|
if ("ltc".equals(symbol)) {
|
userData.setRecharge(Arith.mul(amount, realtime.getClose().doubleValue()));
|
userData.setRechargeLtc(amount);
|
}
|
}
|
saveUserData(userData);
|
}
|
|
public void saveClose(ContractOrder order) {
|
|
User user = userService.getById(order.getPartyId());
|
boolean guest = false;
|
if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName()) || Constants.SECURITY_ROLE_TEST.equals(user.getRoleName())) {
|
guest = true;
|
}
|
if (guest) {
|
return;
|
}
|
UserData userData = new UserData();
|
userData.setRolename(userData.getRolename());
|
userData.setCreateTime(new Date());
|
userData.setUserId(order.getPartyId());
|
userData.setAmount(order.getDepositOpen().doubleValue());
|
if(order.getAmountClose() == null){
|
order.setAmountClose(BigDecimal.ZERO);
|
}
|
if(order.getAmountClose().compareTo(BigDecimal.ZERO) <0) {
|
order.setAmountClose(BigDecimal.ZERO);
|
}
|
userData.setFee(order.getFee().doubleValue());
|
userData.setOrderIncome(order.getAmountClose().subtract(order.getDepositOpen()).doubleValue());
|
saveUserData(userData);
|
}
|
|
@Override
|
public void saveSell(ExchangeApplyOrder order) {
|
|
User user = userService.getById(order.getPartyId());
|
boolean guest = false;
|
if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName()) || Constants.SECURITY_ROLE_TEST.equals(user.getRoleName())) {
|
guest = true;
|
}
|
if (guest) {
|
return;
|
}
|
List<Realtime> realtime_list = this.dataService.realtime(order.getSymbol());
|
Realtime realtime = null;
|
if (realtime_list.size() > 0) {
|
realtime = realtime_list.get(0);
|
} else {
|
throw new YamiShopBindException("系统错误，请稍后重试");
|
}
|
UserData userData = new UserData();
|
userData.setRolename(user.getRoleName());
|
userData.setCreateTime(new Date());
|
userData.setUserId(order.getPartyId());
|
userData.setExchangeAmount(Arith.mul(realtime.getClose().doubleValue(), order.getVolume()));
|
userData.setExchangeFee(Arith.mul(realtime.getClose().doubleValue(), order.getFee()));
|
userData.setExchangeIncome(0);
|
saveUserData(userData);
|
}
|
|
@Override
|
public void saveBuy(ExchangeApplyOrder order) {
|
|
User user = userService.getById(order.getPartyId());
|
boolean guest = false;
|
if (Constants.SECURITY_ROLE_GUEST.equals(user.getRoleName()) || Constants.SECURITY_ROLE_TEST.equals(user.getRoleName())) {
|
guest = true;
|
}
|
if (guest) {
|
return;
|
}
|
List<Realtime> realtime_list = this.dataService.realtime(order.getSymbol());
|
Realtime realtime = null;
|
if (realtime_list.size() > 0) {
|
realtime = realtime_list.get(0);
|
} else {
|
throw new YamiShopBindException("系统错误，请稍后重试");
|
}
|
UserData userData = new UserData();
|
userData.setRolename(user.getRoleName());
|
userData.setCreateTime(new Date());
|
userData.setUserId(order.getPartyId());
|
userData.setExchangeAmount(order.getVolume());
|
userData.setExchangeFee(0);
|
saveUserData(userData);
|
}
|
|
/**
|
* 交割合约平仓
|
*/
|
@Override
|
public void saveFuturesClose(FuturesOrder order) {
|
|
User user = userService.getById(order.getPartyId());
|
String roleName = user.getRoleName();
|
boolean guest = false;
|
if (Constants.SECURITY_ROLE_GUEST.equals(roleName) || Constants.SECURITY_ROLE_TEST.equals(roleName)) {
|
guest = true;
|
}
|
if (guest) {
|
return;
|
}
|
User party = userService.getById(order.getPartyId());
|
UserData userData = new UserData();
|
userData.setRolename(party.getRealName());
|
userData.setCreateTime(new Date());
|
userData.setUserId(order.getPartyId());
|
userData.setFurturesAmount(order.getVolume());
|
userData.setFurturesFee(order.getFee());
|
userData.setFurturesIncome(order.getProfit());
|
saveUserData(userData);
|
// UserRecom userRecom = this.userRecomService.findByPartyId(order.getPartyId());
|
// if (userRecom == null) {
|
// return;
|
// }
|
// List<UserRecom> parents = this.userRecomService.getParents(userRecom.getPartyId());
|
//
|
// for (int i = 0; i < parents.size(); i++) {
|
// Party party_parent = partyService.cachePartyBy(parents.get(i).getReco_id());
|
//
|
// if (Constants.SECURITY_ROLE_AGENT.equals(party_parent.getRolename())) {
|
// UserData userData_reco = new UserData();
|
// userData_reco.setRolename(party_parent.getRolename());
|
// userData_reco.setCreateTime(new Date());
|
// userData_reco.setPartyId(parents.get(i).getReco_id());
|
// userData_reco.setFurtures_amount(order.getVolume());
|
// userData_reco.setFurtures_fee(order.getFee());
|
// userData_reco.setFurtures_income(order.getProfit());
|
// save(userData_reco);
|
// }
|
}
|
|
}
|
