package project.monitor.pledgegalaxy.internal;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.Arith;
|
import kernel.util.DateUtils;
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import kernel.web.Page;
|
import kernel.web.PagedQueryDao;
|
import project.Constants;
|
import project.log.MoneyLog;
|
import project.log.MoneyLogService;
|
import project.monitor.AdminPledgeGalaxyProfitService;
|
import project.monitor.pledgegalaxy.PledgeGalaxyOrder;
|
import project.monitor.pledgegalaxy.PledgeGalaxyOrderService;
|
import project.monitor.pledgegalaxy.PledgeGalaxyProfit;
|
import project.monitor.pledgegalaxy.PledgeGalaxyProfitService;
|
import project.monitor.pledgegalaxy.PledgeGalaxyStatusConstants;
|
import project.party.recom.UserRecomService;
|
import project.wallet.Wallet;
|
import project.wallet.WalletService;
|
|
public class AdminPledgeGalaxyProfitServiceImpl implements AdminPledgeGalaxyProfitService {
|
|
private PagedQueryDao pagedQueryDao;
|
|
private WalletService walletService;
|
|
private MoneyLogService moneyLogService;
|
|
private UserRecomService userRecomService;
|
|
private PledgeGalaxyOrderService pledgeGalaxyOrderService;
|
|
private PledgeGalaxyProfitService pledgeGalaxyProfitService;
|
|
@Override
|
public Page pagedQuery(int pageNo, int pageSize, String order_no, String relation_order_no, String start_time, String end_time, String name, String rolename, Integer status, String loginPartyId) {
|
|
StringBuffer queryString = new StringBuffer();
|
|
queryString.append("SELECT ");
|
|
queryString.append(" party.USERNAME username, party.ROLENAME rolename, party.USERCODE usercode, party_parent.USERNAME username_parent, ");
|
|
queryString.append(" pledge_galaxy_profit.UUID uuid, pledge_galaxy_profit.AMOUNT amount, pledge_galaxy_profit.TYPE type, "
|
+ " pledge_galaxy_profit.STATUS 'status', pledge_galaxy_profit.AUDIT_TIME audit_time, "
|
+ " pledge_galaxy_profit.EXPIRE_TIME expire_time, pledge_galaxy_profit.CREATE_TIME create_time, "
|
+ " pledge_galaxy_profit.RELATION_ORDER_NO relation_order_no ");
|
|
queryString.append(" FROM ");
|
|
queryString.append(" T_AUTO_MONITOR_PLEDGE_GALAXY_PROFIT pledge_galaxy_profit "
|
+ " LEFT JOIN PAT_PARTY party ON pledge_galaxy_profit.PARTY_ID = party.UUID "
|
+ " LEFT JOIN PAT_USER_RECOM user ON user.PARTY_ID = party.UUID "
|
+ " LEFT JOIN PAT_PARTY party_parent ON user.RECO_ID = party_parent.UUID ");
|
|
queryString.append(" WHERE 1=1 ");
|
|
Map<String, Object> parameters = new HashMap<String, Object>();
|
|
if (!StringUtils.isNullOrEmpty(loginPartyId)) {
|
List<String> children = this.userRecomService.findChildren(loginPartyId);
|
if (children.size() == 0) {
|
return new Page();
|
}
|
queryString.append(" and pledge_galaxy_profit.PARTY_ID in (:children) ");
|
parameters.put("children", children);
|
}
|
|
if (!StringUtils.isNullOrEmpty(order_no)) {
|
queryString.append(" and pledge_galaxy_profit.UUID =:uuid");
|
parameters.put("uuid", order_no);
|
}
|
|
if (!StringUtils.isNullOrEmpty(relation_order_no)) {
|
queryString.append(" and pledge_galaxy_profit.RELATION_ORDER_NO =:relation_order_no");
|
parameters.put("relation_order_no", relation_order_no);
|
}
|
|
if (!StringUtils.isNullOrEmpty(start_time)) {
|
queryString.append(" AND DATE(pledge_galaxy_profit.CREATE_TIME) >= DATE('" + start_time + " 00:00:00') ");
|
}
|
if (!StringUtils.isNullOrEmpty(end_time)) {
|
queryString.append(" AND DATE(pledge_galaxy_profit.CREATE_TIME) <= DATE('" + end_time + " 23:59:59') ");
|
}
|
|
if (!StringUtils.isNullOrEmpty(name)) {
|
queryString.append(" and (party.USERNAME like :name_para or party.USERCODE =:usercode) ");
|
parameters.put("name_para", "%" + name + "%");
|
parameters.put("usercode", name);
|
}
|
|
if (!StringUtils.isNullOrEmpty(name)) {
|
queryString.append("AND (party.USERNAME like:username OR party.USERCODE like:username ) ");
|
parameters.put("username", "%" + name + "%");
|
}
|
|
if (!StringUtils.isNullOrEmpty(rolename)) {
|
queryString.append(" and party.ROLENAME =:rolename");
|
parameters.put("rolename", rolename);
|
}
|
|
if (null != status) {
|
queryString.append(" and pledge_galaxy_profit.STATUS = :status ");
|
parameters.put("status", status);
|
}
|
|
queryString.append(" order by pledge_galaxy_profit.CREATE_TIME desc ");
|
|
Page page = this.pagedQueryDao.pagedQuerySQL(pageNo, pageSize, queryString.toString(), parameters);
|
|
return page;
|
}
|
|
/**
|
* 收益记录审核
|
*/
|
@Override
|
public void saveReceiveApply(String id, String msg, boolean isPassed) {
|
PledgeGalaxyProfit profit = get(id);
|
if (PledgeGalaxyStatusConstants.PROFIT_AUTID != profit.getStatus()) {
|
throw new BusinessException("收益订单状态异常");
|
}
|
|
// 不通过
|
if (!isPassed) {
|
profit.setStatus(PledgeGalaxyStatusConstants.PROFIT_FAIL);
|
profit.setAuditTime(new Date());
|
profit.setMsg(msg);
|
pledgeGalaxyProfitService.update(profit);
|
return;
|
}
|
|
String partyId = profit.getPartyId();
|
double amount = profit.getAmount();
|
Wallet wallet = this.walletService.saveWalletByPartyId(partyId);
|
double amount_before = wallet.getMoney();
|
this.walletService.update(partyId, amount);
|
|
// 保存资金日志
|
MoneyLog moneylog = new MoneyLog();
|
moneylog.setCategory(Constants.MONEYLOG_CATEGORY_GALAXY);
|
moneylog.setAmount_before(amount_before);
|
moneylog.setAmount(amount);
|
moneylog.setAmount_after(Arith.add(amount_before, amount));
|
// 动静收益
|
if (profit.getType() != 3) {
|
moneylog.setLog("质押2.0收益，订单号[" + profit.getRelationOrderNo() + "]");
|
moneylog.setContent_type(Constants.MONEYLOG_CONTENT_GALAXY_PROFIT);
|
PledgeGalaxyOrder order = pledgeGalaxyOrderService.findById(profit.getRelationOrderNo());
|
// 记息日期
|
order.setSettleTime(new Date());
|
order.setProfit(Arith.add(order.getProfit(), amount));
|
|
pledgeGalaxyOrderService.update(order);
|
}
|
// 团队收益
|
else {
|
moneylog.setLog("质押2.0团队收益下发");
|
moneylog.setContent_type(Constants.MONEYLOG_CONTENT_GALAXY_RECOM_PROFIT);
|
}
|
moneylog.setPartyId(partyId);
|
moneylog.setWallettype(Constants.WALLET);
|
moneylog.setCreateTime(new Date());
|
moneyLogService.save(moneylog);
|
|
profit.setStatus(PledgeGalaxyStatusConstants.PROFIT_PASSED);
|
profit.setAuditTime(new Date());
|
profit.setMsg(msg);
|
pledgeGalaxyProfitService.update(profit);
|
}
|
|
public PledgeGalaxyProfit get(String id) {
|
return ApplicationUtil.executeGet(id,PledgeGalaxyProfit.class);
|
}
|
|
/**
|
* 根据关联订单号获取收益记录
|
*/
|
@Override
|
public List<PledgeGalaxyProfit> findByRelationOrderNo(String relationOrderNo) {
|
return ApplicationUtil.executeSelect(PledgeGalaxyProfit.class,"WHERE RELATION_ORDER_NO=?",new Object[] {relationOrderNo});
|
}
|
|
/**
|
* 删除质押收益记录
|
*/
|
@Override
|
public void delete(PledgeGalaxyProfit profit) {
|
ApplicationUtil.executeDelete(profit);
|
}
|
|
/**
|
* 人工补静态及助力收益
|
*/
|
public void saveProfit(String time) {
|
Date startTime = DateUtils.toDate(time, DateUtils.NORMAL_DATE_FORMAT);
|
Date now = new Date();
|
Date dayStart = DateUtils.getDayStart(now);
|
int status = PledgeGalaxyStatusConstants.PLEDGE_APPLY;
|
// 补收益时间当天开始
|
Date startTimeDayStart = DateUtils.getDayStart(startTime);
|
// 补收益时间当天结束
|
Date startTimeDayEnd = DateUtils.getDayEnd(startTime);
|
Date startTimeDay = DateUtils.toDate(DateUtils.format(startTime, "yyyy-MM-dd"));
|
List<PledgeGalaxyOrder> list = pledgeGalaxyOrderService.findByStatusCrateTime(status, startTimeDayEnd);
|
if (list.size() <= 0) {
|
return;
|
}
|
for (PledgeGalaxyOrder order : list) {
|
List<PledgeGalaxyProfit> profits = pledgeGalaxyProfitService.findByRelationOrderNo(String.valueOf(order.getId()), startTimeDay);
|
// 当天无收益记录
|
if (profits.size() <= 0) {
|
// 29
|
if (order.getSettleTime().before(startTimeDayStart)) {
|
// 补4次
|
continue;
|
}
|
// 30 0:40
|
else {
|
// 判断订单的创建日期
|
int orderHour = DateUtils.getHour(order.getSettleTime());
|
System.out.println("判断订单的创建日期 小时" + orderHour);
|
if (orderHour < 6) {
|
// 补三次
|
continue;
|
} else if (orderHour >= 6 && orderHour < 12) {
|
// 补两次
|
continue;
|
} else if (orderHour >= 12 && orderHour < 18) {
|
// 补一次
|
continue;
|
}
|
}
|
}
|
// 当天有收益记录
|
else {
|
if (profits.size() >= 4) {
|
// 不补
|
continue;
|
}
|
|
List<Integer> profitHours = new ArrayList<Integer>();
|
for (PledgeGalaxyProfit profit : profits) {
|
int profitHour = DateUtils.getHour(profit.getCreateTime());
|
profitHours.add(profitHour);
|
}
|
// 29
|
if (order.getSettleTime().before(startTimeDayStart)) {
|
|
if (!profitHours.contains(0)) {
|
// 补0点
|
}
|
if (!profitHours.contains(6)) {
|
// 补6点
|
}
|
if (!profitHours.contains(12)) {
|
// 补12点
|
}
|
if (!profitHours.contains(18)) {
|
// 补18点
|
}
|
continue;
|
}
|
else {
|
// 判断订单的创建日期
|
int orderHour = DateUtils.getHour(order.getSettleTime());
|
System.out.println("判断订单的创建日期 小时" + orderHour);
|
|
// 如果 今天 以前
|
if (startTime.before(dayStart)) {
|
if (orderHour < 6) {
|
if (!profitHours.contains(6)) {
|
// 补6点
|
}
|
if (!profitHours.contains(12)) {
|
// 补12点
|
}
|
if (!profitHours.contains(18)) {
|
// 补18点
|
}
|
continue;
|
} else if (orderHour >= 6 && orderHour < 12) {
|
if (!profitHours.contains(12)) {
|
// 补12点
|
}
|
if (!profitHours.contains(18)) {
|
// 补18点
|
}
|
continue;
|
} else if (orderHour >= 12 && orderHour < 18) {
|
if (!profitHours.contains(18)) {
|
// 补18点
|
}
|
continue;
|
}
|
|
} else {
|
int nowHour = DateUtils.getHour(now);
|
if (orderHour < 6) {
|
if (!profitHours.contains(6) && nowHour >= 6) {
|
// 补6点
|
}
|
if (!profitHours.contains(12) && nowHour >= 12) {
|
// 补12点
|
}
|
if (!profitHours.contains(18) && nowHour >= 18) {
|
// 补18点
|
}
|
continue;
|
} else if (orderHour >= 6 && orderHour < 12) {
|
if (!profitHours.contains(12) && nowHour >= 12) {
|
// 补12点
|
}
|
if (!profitHours.contains(18) && nowHour >= 18) {
|
// 补18点
|
}
|
continue;
|
} else if (orderHour >= 12 && orderHour < 18) {
|
if (!profitHours.contains(18) && nowHour >= 18) {
|
// 补18点
|
}
|
}
|
}
|
}
|
}
|
}
|
}
|
|
public void setPagedQueryDao(PagedQueryDao pagedQueryDao) {
|
this.pagedQueryDao = pagedQueryDao;
|
}
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setMoneyLogService(MoneyLogService moneyLogService) {
|
this.moneyLogService = moneyLogService;
|
}
|
|
public void setPledgeGalaxyOrderService(PledgeGalaxyOrderService pledgeGalaxyOrderService) {
|
this.pledgeGalaxyOrderService = pledgeGalaxyOrderService;
|
}
|
|
public void setPledgeGalaxyProfitService(PledgeGalaxyProfitService pledgeGalaxyProfitService) {
|
this.pledgeGalaxyProfitService = pledgeGalaxyProfitService;
|
}
|
|
@Override
|
public void saveTeamProfit(String time) {
|
// TODO Auto-generated method stub
|
}
|
}
|
