package com.ibeetl.admin.console.service;
|
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.lang.Snowflake;
|
import cn.hutool.core.util.IdUtil;
|
import cn.hutool.json.JSON;
|
import cn.hutool.json.JSONUtil;
|
import com.ibeetl.admin.console.dao.*;
|
import com.ibeetl.admin.console.model.*;
|
import com.ibeetl.admin.console.util.DateUtil;
|
import com.ibeetl.admin.console.util.DoubleUtil;
|
import com.ibeetl.admin.core.entity.XzxCityPartner;
|
import com.ibeetl.admin.core.web.JsonResult;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.math.BigDecimal;
|
import java.text.DecimalFormat;
|
import java.text.SimpleDateFormat;
|
import java.util.*;
|
|
/**
|
* 图表数据
|
*/
|
@Service
|
@Slf4j
|
@EnableScheduling
|
@Configuration
|
public class SettlementService {
|
static SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
static SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");
|
|
@Autowired
|
private XzxUserShareInfoService service;
|
@Autowired private XzxCityPartnerDao xzxCityPartnerDao;
|
@Autowired
|
private XzxUserShareInfoDao xzxUserShareInfoDao;
|
@Autowired
|
PayConsoleDao payConsoleDao;
|
|
@Autowired
|
XzxCityPartnerService cpService;
|
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
|
@Autowired private FundManagementApiDao fundManagementApiDao;
|
@Scheduled(cron = "${ruleTime}")
|
public void index() throws Exception{
|
List<String> ruleList1 = xzxUserShareInfoDao.queryRuleOpen(null);
|
if(ruleList1.size()==0){
|
System.out.println("合伙人规则未启用==========");
|
return ;
|
}
|
|
//判断当前日期星期几
|
String time = sdf2.format(new Date());
|
String time1 = sdf1.format(new Date());
|
try {
|
String weekNum = DateUtil.dayForWeek(time);
|
int hour = DateUtil.getDayHour();
|
String timing = weekNum+","+hour;
|
List<XzxUserRedpaperRuleModel> ruleList = xzxUserShareInfoDao.queryRoyaltyByTimming(timing,time);
|
System.out.println("合伙人规则条数=========="+ruleList.size());
|
for (XzxUserRedpaperRuleModel rule:ruleList) {
|
boolean flag = false;
|
String productType = rule.getProductType();
|
//判断规则是否开启自动结算。
|
String[] typeList = productType.split(",");
|
for (String type:typeList) {
|
if(type.equals("4")){
|
flag = true;
|
}
|
}
|
if(flag){
|
updateRulePrice(rule);
|
}
|
}
|
} catch (Throwable throwable) {
|
throwable.printStackTrace();
|
}
|
}
|
|
private void updateRulePrice(XzxUserRedpaperRuleModel rule){
|
List<String> list = xzxUserShareInfoDao.queryOtherByPartnerId(null);
|
for (String receiverId:list) {
|
List<WeightItemPriceModel> royaltyList = xzxUserShareInfoDao.queryWeightItemByHsyList1(receiverId);
|
BigDecimal money = new BigDecimal("0");
|
int num =0;
|
if(royaltyList.size()>0){
|
for (WeightItemPriceModel itemModel:royaltyList) {
|
itemModel.setStatus("2");
|
num = xzxUserShareInfoDao.updateRoyaltyRule(itemModel);
|
List<WeightPriceModel> rulePrice = xzxUserShareInfoDao.queryRulePriceList(rule.getId()+"",null);
|
for (WeightPriceModel wp:rulePrice) {
|
if(itemModel.getProductType().equals(wp.getProductType())){
|
BigDecimal a = new BigDecimal(itemModel.getWeight());
|
BigDecimal rate = new BigDecimal(wp.getMoney());
|
String price = DoubleUtil.roundTwo(a.multiply(rate).toString());
|
money= money.add(new BigDecimal(price));
|
break;
|
}
|
}
|
WeightItemPriceLogModel logModel = new WeightItemPriceLogModel();
|
logModel.setItemId(itemModel.getId());
|
logModel.setSettlement("--");
|
logModel.setUnSettlement("--");
|
logModel.setReceiver(itemModel.getReceiver());
|
|
logModel.setCreateTime(sdf2.format(new Date()));
|
logModel.setTotalSettlement("--");
|
if(null!=itemModel.getPrice()&&!"".equals(itemModel.getPrice())){
|
money= money.add(new BigDecimal(itemModel.getPrice()));
|
|
}else{
|
money= money;
|
}
|
xzxUserShareInfoDao.insertRoyaltyLog(logModel);
|
}
|
|
UserAccountModel accountModel = fundManagementApiDao.getAccountByUserId(receiverId);
|
//accountModel.setMoney(DoubleUtil.add(accountModel.getMoney(),money.doubleValue()));
|
String oldAccountMoney = DoubleUtil.roundTwo(new BigDecimal(accountModel.getMoney()).toString());
|
|
XzxCityPartner partner = xzxCityPartnerDao.queryPartnerByOther(receiverId);
|
Snowflake snowflake = IdUtil.getSnowflake(0, 3);
|
String payOrderId = "ZF"+snowflake.nextIdStr();
|
|
int packageNum = service.addPartnerAccountLog(DoubleUtil.roundTwo(money.toString()),partner,payOrderId);
|
if(packageNum==0){
|
for (WeightItemPriceModel itemModel:royaltyList) {
|
if(itemModel.getStatus().equals("2")){
|
itemModel.setStatus("1");
|
//清除日志
|
xzxUserShareInfoDao.deleteBylogId(itemModel.getId());
|
}
|
xzxUserShareInfoDao.updateRoyaltyRule(itemModel);
|
}
|
continue;
|
}
|
|
BigDecimal overLimit = new BigDecimal(accountModel.getOverdraftLimit());
|
BigDecimal limit=new BigDecimal(accountModel.getFixedLimit());
|
BigDecimal ss = limit.subtract(overLimit);
|
BigDecimal flag1 = money.subtract(ss);
|
//判断额度是否可用
|
if(flag1.compareTo(BigDecimal.ZERO)==1){
|
accountModel.setMoney(flag1.doubleValue());
|
accountModel.setOverdraftLimit(DoubleUtil.roundTwo(limit.toString()));
|
}else if(flag1.compareTo(BigDecimal.ZERO)==0){
|
accountModel.setOverdraftLimit(DoubleUtil.roundTwo(limit.toString()));
|
}else{
|
accountModel.setOverdraftLimit(DoubleUtil.roundTwo(overLimit.add(money).toString()));
|
}
|
|
PayInfoModel model = new PayInfoModel();
|
model.setPayOrderId(payOrderId);
|
model.setMoney(DoubleUtil.roundTwo(money.toString()));
|
model.setCreateUserId(receiverId);
|
model.setCreateTime(sdf.format(new Date()));
|
model.setPayType("14");
|
model.setAccountId(accountModel.getAccountId());
|
model.setStatus("3");
|
model.setPayTime(sdf.format(new Date()));
|
cpService.addPayInfo1(model);
|
|
//回收员账户加钱
|
service.addOtherUserAccountLog(accountModel,money,payOrderId,oldAccountMoney);
|
String message = "您已经结算：+"+money+"元，提成单号："+payOrderId+",请注意查收.";
|
payConsoleDao.insertMessage(message,receiverId,"","1","提成",sdf.format(new Date()));
|
//写入消息列表中
|
String message1 = "您已经结算：-"+money+"元，提成单号："+payOrderId+",请注意检查.";
|
payConsoleDao.insertMessage(message1,partner.getUserId(),"","1","提成",sdf.format(new Date()));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
