package com.ibeetl.admin.console.service;
|
import com.ibeetl.admin.console.dao.FundManagementApiDao;
|
import com.ibeetl.admin.console.dao.XzxUserRedpaperRuleDao;
|
import com.ibeetl.admin.console.dao.XzxUserShareInfoDao;
|
import com.ibeetl.admin.console.model.CommissionModel;
|
import com.ibeetl.admin.console.model.RebateWeightPriceModel;
|
import com.ibeetl.admin.console.model.XzxPlatformCapitalInfoModel;
|
import com.ibeetl.admin.console.model.XzxUserRedpaperPriceModel;
|
import com.ibeetl.admin.console.util.DoubleUtil;
|
import com.ibeetl.admin.core.entity.XzxCityPartner;
|
import com.ibeetl.admin.core.entity.XzxRebateRulePrice;
|
import com.ibeetl.admin.core.entity.XzxUserRedpaperRule;
|
import com.ibeetl.admin.core.service.CoreBaseService;
|
import com.ibeetl.admin.core.util.PlatformException;
|
import io.swagger.annotations.ApiModelProperty;
|
import org.apache.commons.codec.binary.Base64;
|
import org.apache.commons.lang3.StringUtils;
|
import org.beetl.sql.core.engine.PageQuery;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
import com.ibeetl.admin.console.model.XzxUserRebateRuleModel;
|
import java.io.UnsupportedEncodingException;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
@Transactional
|
public class XzxUserRedpaperRuleService extends CoreBaseService<XzxUserRedpaperRule>{
|
|
@Autowired private XzxUserRedpaperRuleDao xzxUserRedpaperRuleDao;
|
@Autowired private FundManagementApiDao fundManagementApiDao;
|
@Autowired
|
private XzxUserShareInfoDao xzxUserShareInfoDao;
|
@Autowired
|
XzxUserShareInfoService xzxUserShareInfoService;
|
@Autowired
|
XzxCityPartnerService cityPartnerService;
|
final Base64 base64 = new Base64();
|
|
public Map<String,Object> queryByCondition(PageQuery query, String ruleType){
|
PageQuery ret = xzxUserRedpaperRuleDao.queryByCondition(query);
|
List<XzxUserRedpaperPriceModel> priceList = new ArrayList<>();
|
List<XzxUserRedpaperRule> list = ret.getList();
|
|
if(ruleType.equals("3")){
|
for (XzxUserRedpaperRule rule:list) {
|
XzxUserRedpaperPriceModel model = new XzxUserRedpaperPriceModel(rule);
|
List<XzxRebateRulePrice> rulePriceList =xzxUserRedpaperRuleDao.queryRebateRulePriceList(String.valueOf(rule.getId()));
|
model.setRulePriceList(rulePriceList);
|
model.setApplicableObject(rule.getApplicableObject());
|
//文案文字返回
|
String sharingProfitType = rule.getSharingProfitType();
|
if(sharingProfitType!=null){
|
String[] types = sharingProfitType.split(",");
|
StringBuffer typeDesc = new StringBuffer();
|
String aa="";
|
String demo="";
|
for (String type:types) {
|
String desc =fundManagementApiDao.queryTypeDesc(type);
|
int a=1;
|
for (XzxRebateRulePrice p:rulePriceList) {
|
if(typeDesc.toString()!=null&&!"".equals(typeDesc.toString())){
|
if(type.equals("REBATE_TWO")){
|
if(a>=2){
|
typeDesc.append(";").append(a+"、"+demo).append(p.getWeight()).append("kg,").append(desc).append(p.getRate()).append("%");
|
}else{
|
typeDesc.append(desc).append(p.getRate()).append("%");
|
}
|
|
}else if(type.equals("REBATE_THREE")){
|
aa=desc;
|
}
|
a=a+1;
|
}else{
|
demo=desc;
|
typeDesc.append(a+"、"+desc).append(p.getWeight()).append("kg,");
|
}
|
|
//break;
|
}
|
|
}
|
|
typeDesc.append(",").append((rulePriceList.size()+1)+"、").append(aa).append(model.getConversionPerUnit()).append("kg");
|
model.setTypeDesc(typeDesc.toString());
|
|
}
|
priceList.add(model);
|
|
}
|
}else if(ruleType.equals("8")){
|
for (XzxUserRedpaperRule rule:list) {
|
XzxUserRedpaperPriceModel model = new XzxUserRedpaperPriceModel(rule);
|
|
StringBuffer typeDesc = new StringBuffer();
|
BigDecimal radio = new BigDecimal(rule.getShareRatio());
|
BigDecimal showRadio = radio.multiply(new BigDecimal("100"));
|
typeDesc.append("城市合伙人每笔订单成交，总部收取每笔订单回收流水的").append(DoubleUtil.subZeroAndDot(showRadio.toString()));
|
typeDesc.append("%，做为平台服务费。");
|
model.setTypeDesc(typeDesc.toString());
|
model.setShareRatio(showRadio.toString());
|
priceList.add(model);
|
|
}
|
}else{
|
for (XzxUserRedpaperRule rule:list) {
|
XzxUserRedpaperPriceModel model = new XzxUserRedpaperPriceModel(rule);
|
//文案文字返回
|
String sharingProfitType = rule.getSharingProfitType();
|
model.setApplicableObject(rule.getApplicableObject());
|
if(ruleType.equals("2")){
|
if(sharingProfitType!=null){
|
String[] types = sharingProfitType.split(",");
|
StringBuffer typeDesc = new StringBuffer();
|
for (String type:types) {
|
String desc =fundManagementApiDao.queryTypeDesc(type);
|
if(typeDesc.toString()!=null&&!"".equals(typeDesc.toString())){
|
typeDesc.append(",").append(desc);
|
}else{
|
if(type.equals("SHARE_RATIO")){
|
typeDesc.append(desc).append(model.getShareRatio()).append("%");
|
}else{
|
typeDesc.append(desc);
|
}
|
}
|
}
|
model.setTypeDesc(typeDesc.toString());
|
}
|
}else{
|
if(ruleType.equals("5")){
|
StringBuffer str = new StringBuffer();
|
String productType="";
|
String rate="";
|
List<XzxRebateRulePrice> wl = fundManagementApiDao.queryWtList(rule.getId()+"");
|
model.setProductType(rule.getProductType());
|
String[] types = rule.getProductType().split(",");
|
List<XzxRebateRulePrice> rulePriceList = new ArrayList<>();
|
for (int i=0;i<wl.size();i++) {
|
XzxRebateRulePrice ww = wl.get(i);
|
rulePriceList.add(ww);
|
str.append(i+1).append("、用户每次下单超过").append(ww.getWeight()).append("kg,返利").append(ww.getRate().split(",")[0]+"%;");
|
}
|
model.setRulePriceList(rulePriceList);
|
str.append((wl.size()+1));
|
str.append("、适用物品包括：");
|
for (String t:types) {
|
if(t.equals("1")){
|
str.append("废纸").append(",");
|
}else if(t.equals("2")){
|
str.append("杂纸").append(",");
|
}
|
}
|
model.setTypeDesc(str.toString());
|
}else if(ruleType.equals("7")){
|
StringBuffer str = new StringBuffer();
|
String packageId = rule.getPackageId();
|
XzxCityPartner partner =cityPartnerService.queryById(packageId);
|
str.append(partner.getPartnerName()).append("的发放规则");
|
str.append("1、回收员每次成交，合伙人给回收员发放提成，提成为");
|
List<RebateWeightPriceModel> itemList = xzxUserShareInfoService.queryOldItemList(rule.getId()+"");
|
for (RebateWeightPriceModel mm:itemList) {
|
String title = xzxUserShareInfoDao.queryGoodsById(mm.getProductType());
|
mm.setProductName(title);
|
str.append(title).append("：").append(mm.getMoney()).append("元/公斤，");
|
|
}
|
model.setRoyaltyRuleList(itemList);
|
String rType = rule.getProductType();
|
if(null!=rType){
|
String[] itemType = rType.split(",");
|
if(itemType[0].equals("3")){
|
str.append("2、可以人工结算提成；");
|
}
|
if(itemType[0].equals("4")){
|
String timming = rule.getTiming();
|
String[] trs = timming.split(",");
|
str.append("3、每周").append(trs[0]).append(" ").append(trs[1]).append("点系统自动结算提成");
|
}
|
}
|
model.setTypeDesc(str.toString());
|
}else{
|
StringBuffer str = new StringBuffer();
|
if(model.getIssuanceRules().equals("0")){
|
double totald = Double.parseDouble(model.getAmount())*100;
|
long total =new Double(totald).longValue();
|
int count = Integer.parseInt(model.getRedEnvelopesNum());
|
long average = total / count;
|
String[] pri = model.getRandomAmountAverage().split(",");
|
str.append("1、发放金额随机，金额范围为").append(model.getRandomAmountAverage()).append("元；平均为").append(average).append("元");
|
str.append("总额为").append(model.getAmount()).append("元,随机分配；最高").append(pri[1]).append("元/个");
|
}else{
|
str.append("发放固定金额，红包为").append(model.getRandomAmountAverage()).append(",总额为").append(model.getAmount());
|
}
|
model.setTypeDesc(str.toString());
|
}
|
|
}
|
priceList.add(model);
|
|
}
|
}
|
Map<String,Object> map = new HashMap<>();
|
map.put("data",priceList);
|
map.put("pageNumber",ret.getPageNumber());
|
map.put("pageSize",ret.getPageSize());
|
map.put("totalPage",ret.getTotalPage());
|
map.put("count",ret.getTotalRow());
|
//queryListAfter(priceList);
|
|
return map;
|
}
|
|
public void batchDelXzxUserRedpaperRule(List<Long> ids){
|
try {
|
xzxUserRedpaperRuleDao.batchDelXzxUserRedpaperRuleByIds(ids);
|
} catch (Exception e) {
|
throw new PlatformException("批量删除XzxUserRedpaperRule失败", e);
|
}
|
}
|
public void deleteByRuleId(Integer ruleId){
|
xzxUserRedpaperRuleDao.deleteByRuleId(ruleId);
|
}
|
public Map<String,Object> queryRebateList(XzxPlatformCapitalInfoModel model){
|
|
List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
|
model.setPartnerIds(partnerIds);
|
Map<String,Object> map = new HashMap<>();
|
int p = model.getPage();
|
p = (p - 1) * model.getLimit();
|
model.setPage(p);
|
String mobilePhone = model.getMobilePhone();
|
if(!StringUtils.isEmpty(model.getMobilePhone())){
|
model.setMobilePhone(mobilePhone);
|
model.setNickName(new String(Base64.encodeBase64(mobilePhone.getBytes())));
|
|
}
|
List<XzxPlatformCapitalInfoModel> list = xzxUserRedpaperRuleDao.queryRebateList(model);
|
for (XzxPlatformCapitalInfoModel info:list) {
|
if(info.getUserId()!=null&&!"".equals(info.getUserId())){
|
//转昵称
|
String nickName = info.getNickName();
|
if(nickName!=null&&!"".equals(nickName)){
|
try {
|
nickName =new String(base64.decode(nickName), "UTF-8");
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
}
|
info.setNickName(nickName);
|
//查询用户此单之前的累计重量
|
String afterWeight = "0" ;
|
String userId = info.getUserId();
|
String completeTime = info.getCreateTime();
|
List<String> orderIds = xzxUserRedpaperRuleDao.queryUserOrderIds(completeTime,userId);
|
if(orderIds!=null&&orderIds.size()>0){
|
afterWeight = xzxUserRedpaperRuleDao.queryAfterWeightByOrderIds(orderIds);
|
}
|
info.setAfterWeight(DoubleUtil.roundThree(afterWeight));
|
info.setDesignatedWeight(DoubleUtil.roundThree(info.getDesignatedWeight()));
|
}
|
|
}
|
//如果没有用户Id，则不显示返利列表
|
if(list.size()==0){
|
list = new ArrayList<>();
|
}
|
int count = xzxUserRedpaperRuleDao.queryRebateCount(model);
|
String totalAmount =xzxUserRedpaperRuleDao.queryTotalAmountByParam(model);
|
|
map.put("data",list);
|
map.put("count",count);
|
map.put("code",0);
|
map.put("orderNum",count);
|
if(null!=totalAmount&&!"".equals(totalAmount)){
|
map.put("totalAmount",DoubleUtil.roundTwo(totalAmount));
|
|
}else{
|
map.put("totalAmount","0");
|
}
|
return map;
|
}
|
|
public List<XzxUserRedpaperRule> queryRedpaperList(String startTime){
|
return xzxUserRedpaperRuleDao.queryRedpaperList(startTime);
|
}
|
public List<XzxUserRedpaperRule> queryRedpaperListStartAndEnd(String startTime,String endTime){
|
return xzxUserRedpaperRuleDao.queryRedpaperListStartAndEnd(startTime,endTime);
|
}
|
|
public List<XzxUserRedpaperRule> queryShareListByTime(String startTime,String endTime){
|
return xzxUserRedpaperRuleDao.queryShareListByTime(startTime,endTime);
|
}
|
public List<XzxUserRedpaperRule> queryCommListByTime(String startTime,String endTime,String id){
|
return xzxUserRedpaperRuleDao.queryCommListByTime(startTime,endTime,id);
|
}
|
public Map<String,Object> queryAccountList(CommissionModel model){
|
Map<String,Object> map = new HashMap<>();
|
int p = model.getPage();
|
p = (p - 1) * model.getLimit();
|
model.setPage(p);
|
String partnerName = model.getPartnerName();
|
if(!StringUtils.isEmpty(partnerName)){
|
model.setPartnerName(partnerName);
|
model.setMobile(partnerName);
|
}
|
int count = 0;
|
String c = xzxUserRedpaperRuleDao.queryAccountListCount(model);
|
List<CommissionModel> list = xzxUserRedpaperRuleDao.queryAccountList(model);
|
if(null!=c&&!"".equals(c)){
|
count = Integer.parseInt(c);
|
}
|
//已提佣次数
|
map.put("commissionNum",count);
|
//总提佣金额
|
String totalMoney =xzxUserRedpaperRuleDao.queryTotalCommissionMoney(model);
|
if(null!=totalMoney&&!"".equals(totalMoney)){
|
map.put("totalMoney",DoubleUtil.roundTwo(totalMoney));
|
}else{
|
map.put("totalMoney","0.00");
|
}
|
map.put("code",0);
|
map.put("data",list);
|
map.put("count",count);
|
return map;
|
}
|
public List<XzxUserRedpaperRule> queryRebateRuleList(XzxUserRebateRuleModel model){
|
return xzxUserRedpaperRuleDao.queryRebateRuleList(model);
|
}
|
public List<XzxUserRedpaperRule> queryCommissioList(){
|
return xzxUserRedpaperRuleDao.queryCommissioList();
|
}
|
|
public List<XzxUserRedpaperRule> queryWeightRuleList(XzxUserRebateRuleModel model){
|
return xzxUserRedpaperRuleDao.queryWeightRuleList(model);
|
}
|
|
public List<XzxUserRedpaperRule> queryRoyalRuleList(String partnerId,String packageId){
|
return xzxUserRedpaperRuleDao.queryRoyalRuleList(partnerId,packageId);
|
}
|
|
}
|
