package com.ibeetl.admin.console.service;


import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
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.*;
import com.ibeetl.admin.core.service.CoreBaseService;
import com.ibeetl.admin.core.service.CorePlatformService;
import com.ibeetl.admin.core.util.PlatformException;
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 java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;


/**
 * XzxUserShareInfo Service
 */

@Service
@Transactional
public class XzxUserShareInfoService extends CoreBaseService<XzxUserShareInfo>{

    @Autowired
    private XzxUserShareInfoDao xzxUserShareInfoDao;
    @Autowired
    private XzxUserRedpaperRuleDao xzxUserRedpaperRuleDao;
    @Autowired private FundManagementApiDao fundManagementApiDao;
    @Autowired private XzxCityPartnerDao xzxCityPartnerDao;
    @Autowired
    CorePlatformService platformService;
    @Autowired
    PayConsoleDao payConsoleDao;
    @Autowired
    PayConsoleService payLogService;
    @Autowired
    XzxCityPartnerService cityPartnerService;
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    final Base64 base64 = new Base64();



    public PageQuery<XzxUserShareInfo>queryByCondition(PageQuery query){
        PageQuery ret =  xzxUserShareInfoDao.queryByCondition(query);
        queryListAfter(ret.getList());
        return ret;
    }

    public void batchDelXzxUserShareInfo(List<Long> ids){
        try {
            xzxUserShareInfoDao.batchDelXzxUserShareInfoByIds(ids);
        } catch (Exception e) {
            throw new PlatformException("批量删除XzxUserShareInfo失败", e);
        }
    }

    public Map<String,Object> queryShareInfoList(XzxUserShareInfoModel 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);
        if(!StringUtils.isEmpty(model.getName())){
            model.setName(new String(Base64.encodeBase64(model.getName().getBytes())));
        }
        if(!StringUtils.isEmpty(model.getRegisterName())){
            model.setRegisterName(new String(Base64.encodeBase64(model.getRegisterName().getBytes())));
        }
        List<XzxUserShareInfoModel> list = xzxUserShareInfoDao.queryShareInfoList(model);
        for (XzxUserShareInfoModel info:list) {
            //转昵称
            String name = info.getName();
            String registName = info.getRegisterName();
            if(name!=null&&!"".equals(name)){
                try {
                    name =new String(base64.decode(name), "UTF-8");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }
            if(registName!=null&&!"".equals(registName)){
                try {
                    registName =new String(base64.decode(registName), "UTF-8");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }
            info.setName(name);
            info.setRegisterName(registName);
            //查询用户此单之前的累计重量
            String totalMoney = "0" ;
            String userId = info.getUserId();
            String invitedUserId = info.getInvitedUserId();
            String completeTime = null;
            List<String> orderIds = new ArrayList<>();
            if(invitedUserId!=null&&!"".equals(invitedUserId)){
                orderIds = xzxUserRedpaperRuleDao.queryUserOrderIds(completeTime,invitedUserId);
            }
            if(orderIds!=null&&orderIds.size()>0){
                totalMoney = xzxUserRedpaperRuleDao.queryTotalOrderMoney(orderIds);
                info.setStatus("0");
            }else{
                info.setStatus("1");
            }
            info.setTotalMoney(DoubleUtil.roundTwo(totalMoney));
        }
        String totalAmount =xzxUserShareInfoDao.totalAmount(model);
        int num = xzxUserShareInfoDao.queryShareInfoCount(model);
        map.put("totalAmount",DoubleUtil.roundTwo(totalAmount));
        map.put("data",list);
        map.put("count",num);
        map.put("personNum",num);
        return map;
    }
    public int addRoyaltyRule(RebateWeightPriceModel model) {
        int num = xzxUserShareInfoDao.addRoyaltyRule(model);
        return num;
    }
    public void deleteByRuleId(String ruleId){
        int num = xzxUserShareInfoDao.deleteByRuleId(ruleId);
    }
    public void insertPriceHistory(List<RebateWeightPriceModel> list){
        xzxUserShareInfoDao.insertPriceHistory(list);
    }
    public List<RebateWeightPriceModel> queryOldItemList(String ruleId){
        return xzxUserShareInfoDao.queryOldItemList(ruleId);
    }
    public Map<String,Object> queryWeightOrderList(WeightOrderModel model) {
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        List<String> fenceIds = xzxUserShareInfoDao.queryFenceByPartnerIds(partnerIds);
        model.setFenceIds(fenceIds);
        int p = (model.getPage() - 1) * model.getLimit();
        model.setPage(p);
        if(null!=model.getStartTime()&&!"".equals(model.getStartTime())){
            model.setStartTime(model.getStartTime()+" 00:00:00");
        }
        if(null!=model.getEndTime()&&!"".equals(model.getEndTime())){
            model.setEndTime(model.getEndTime()+" 23:59:59");
        }
        if(null!=model.getNickName()&&!"".equals(model.getNickName())){
            model.setMobilePhone(model.getNickName());
            model.setNickName(new String(Base64.encodeBase64(model.getNickName().getBytes())));
        }
        if(null!=model.getMobilePhone()&&!"".equals(model.getMobilePhone())){
            model.setNickName(new String(Base64.encodeBase64(model.getMobilePhone().getBytes())));
        }
        Map<String,Object> map = new HashMap<>();
        map.put("code",0);
        List<WeightOrderModel> list = xzxUserShareInfoDao.queryWeightOrderList(model);
        String totalMoney = xzxUserShareInfoDao.queryTotalRoyaltyMoney(fenceIds);
        for (WeightOrderModel model1:list) {
            String royaltMoney = DoubleUtil.roundTwo(model1.getRoyaltyMoney());
            String partnerMoney = DoubleUtil.roundTwo(model1.getPartnerMoney());
            BigDecimal t = new BigDecimal(royaltMoney);
            BigDecimal pa = new BigDecimal(partnerMoney);
            model1.setHsyMoney(DoubleUtil.roundTwo(t.subtract(pa).toString()));
            model1.setRoyaltyMoney(royaltMoney);
            model1.setPartnerMoney(partnerMoney);
            model1.setDesignatedWeight(DoubleUtil.roundThree(model1.getDesignatedWeight()));
            model1.setOrderMoney(DoubleUtil.roundTwo(model1.getOrderMoney()));
            if(DateUtil.isBase64(model1.getNickName())){
                try {
                    model1.setNickName(new String(base64.decode(model1.getNickName()), "UTF-8"));
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }
        }
        map.put("data",list);
        int num = xzxUserShareInfoDao.queryWeightOrderCount(model);
        map.put("count",num);
        map.put("flNum",num);
        if(null!=totalMoney&&!"".equals(totalMoney)){
            map.put("totalMoney",DoubleUtil.roundTwo(totalMoney));
        }else{
            map.put("totalMoney","0");
        }
        return map;
    }
    public Map<String,Object> queryShareOrderList(XzxPlatformCapitalInfoModel model) {
        Map<String, Object> map = new HashMap<>();
        int p = model.getPage();
        p = (p - 1) * model.getLimit();
        model.setPage(p);
        List<XzxPlatformCapitalInfoModel> list = xzxUserShareInfoDao.queryShareOrderList(model.getShareId(),model.getPage(),model.getLimit());
        map.put("data",list);
        map.put("count",xzxUserShareInfoDao.queryShareOrderCount(model.getShareId()));
        map.put("code",0);
        return map;
    }

   public List<String> queryRuleOpen(){
       CoreUser user = platformService.getCurrentUser();
       XzxCityPartner partner = cityPartnerService.queryById(user.getId());
       List<String> list = new ArrayList<>();
       if(null!=partner){
            list = xzxUserShareInfoDao.queryRuleOpen(partner.getId()+"");
       }else{
           list = xzxUserShareInfoDao.queryRuleOpen(null);
       }
       return list;
   }
   public int updateRoyaltyRule(SettlementModel model){
       int num = 0 ;
        if(model.isFlag()){
            List<WeightItemPriceModel> weightList = model.getRoyaltyList();
            BigDecimal settlementMoney = new BigDecimal(model.getSettlementMoney());
            BigDecimal royaltyMoney = new BigDecimal(model.getRoyaltyMoney());
            BigDecimal money = new BigDecimal("0");
            for (WeightItemPriceModel itemModel:weightList) {

                if(itemModel.getStatus().equals("2")){
                    WeightItemPriceLogModel logModel = new WeightItemPriceLogModel();
                    logModel.setItemId(itemModel.getId());
                    logModel.setSettlement(settlementMoney.toString());
                    logModel.setUnSettlement(royaltyMoney.toString());
                    logModel.setReceiver(model.getReceiver());
                    logModel.setCreateTime(sdf.format(new Date()));
                    settlementMoney =settlementMoney.add(new BigDecimal(itemModel.getPrice()));
                    royaltyMoney = royaltyMoney.subtract(new BigDecimal(itemModel.getPrice()));
                    money= money.add(new BigDecimal(itemModel.getPrice()));
                    logModel.setTotalSettlement(DoubleUtil.roundTwo(settlementMoney.toString()));
                    xzxUserShareInfoDao.insertRoyaltyLog(logModel);
                }
                num =  xzxUserShareInfoDao.updateRoyaltyRule(itemModel);
            }
            UserAccountModel accountModel = fundManagementApiDao.getAccountByUserId(model.getReceiver());
            //accountModel.setMoney(DoubleUtil.add(accountModel.getMoney(),money.doubleValue()));
             String ssAccountMoney = new BigDecimal(accountModel.getMoney()).toString();
            XzxCityPartner partner = xzxCityPartnerDao.queryPartnerByOther(model.getReceiver());
            Snowflake snowflake = IdUtil.getSnowflake(0, 3);
            String payOrderId = "ZF"+snowflake.nextIdStr();
            //扣合伙人环保币  更新账号余额 写日志
            int packageNum = addPartnerAccountLog(DoubleUtil.roundTwo(money.toString()),partner,payOrderId);
            //是否扣款成功
            if(packageNum==0){
                for (WeightItemPriceModel itemModel:weightList) {
                    if(itemModel.getStatus().equals("2")){
                        itemModel.setStatus("1");
                        //清除日志
                        xzxUserShareInfoDao.deleteBylogId(itemModel.getId());
                    }
                    xzxUserShareInfoDao.updateRoyaltyRule(itemModel);
                }
                return -1;
            }
            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()));
            }
            //回收员账户加钱
            addOtherUserAccountLog(accountModel,money,payOrderId,ssAccountMoney);

            PayInfoModel model1 = new PayInfoModel();
            model1.setPayOrderId(payOrderId);
            model1.setMoney(DoubleUtil.roundTwo(money.toString()));
            model1.setCreateUserId(model.getReceiver());
            model1.setCreateTime(sdf.format(new Date()));
            model1.setPayType("14");
            model1.setAccountId(accountModel.getAccountId());
            model1.setStatus("3");
            model1.setPayTime(sdf.format(new Date()));
            cityPartnerService.addPayInfo1(model1);
//写入消息列表中
            String message = "您已经结算：+"+money+"元，提成单号："+payOrderId+",请注意查收.";
            payConsoleDao.insertMessage(message,model.getReceiver(),"","1","提成",sdf.format(new Date()));
//写入消息列表中
            String message1 = "您已经结算：-"+money+"元，提成单号："+payOrderId+",请注意检查.";
            payConsoleDao.insertMessage(message1,partner.getUserId(),"","1","提成",sdf.format(new Date()));

        }
       return num;
   }
    public void addOtherUserAccountLog1(UserAccountModel accountModel,String type,BigDecimal money,String payOrderId){
        BigDecimal newMon = new BigDecimal(accountModel.getMoney()).add(money);

        xzxUserShareInfoDao.updateUserAccount(accountModel.getAccountId(),DoubleUtil.roundTwo(accountModel.getMoney()+""),accountModel.getOverdraftLimit());
        //写入日志
        AccountLogModel log = new AccountLogModel();
        log.setAccountId(accountModel.getAccountId());
        log.setChannelType(type);
        log.setCreateTime(sdf.format(new Date()));
        log.setCreateUserId(accountModel.getUserId());
        BigDecimal oldFixedLimit = new BigDecimal(String.valueOf(accountModel.getFixedLimit()));
        BigDecimal oldLimit = new BigDecimal(String.valueOf(accountModel.getOverdraftLimit()));
        BigDecimal oldMoney = new BigDecimal(accountModel.getMoney());
        log.setNewFixedLimit(accountModel.getFixedLimit());
        log.setNewLimit(accountModel.getLimit()+"");
        log.setNewMoney(DoubleUtil.roundTwo(newMon.toString()));
        log.setOldFixedLimit(accountModel.getFixedLimit());
        log.setOldLimit(accountModel.getLimit()+"");
        log.setOldMoney(DoubleUtil.roundTwo(accountModel.getMoney()+""));
        log.setOrderId(payOrderId);
        //model.setOrderId(payOrderId);
        payLogService.insertAccountLog(log);
    }
   public void addOtherUserAccountLog(UserAccountModel accountModel,BigDecimal money,String payOrderId,String accountMoney){
        BigDecimal oldMon = new BigDecimal(accountModel.getMoney()).subtract(money);
       //accountModel.setMoney(DoubleUtil.add(accountModel.getMoney(),money.doubleValue()));
       BigDecimal newAccountMoney= new BigDecimal(accountMoney).add(new BigDecimal(accountModel.getMoney()));
       System.out.println("修改后账户的金额===="+accountModel.getMoney()+"======增加的钱====="+money);
       xzxUserShareInfoDao.updateUserAccount(accountModel.getAccountId(),DoubleUtil.roundTwo(newAccountMoney.toString()),accountModel.getOverdraftLimit());
       //写入日志
       AccountLogModel log = new AccountLogModel();
       log.setAccountId(accountModel.getAccountId());
       log.setChannelType("12");
       log.setCreateTime(sdf.format(new Date()));
       log.setCreateUserId(accountModel.getUserId());
       BigDecimal oldFixedLimit = new BigDecimal(String.valueOf(accountModel.getFixedLimit()));
       BigDecimal oldLimit = new BigDecimal(String.valueOf(accountModel.getOverdraftLimit()));
       BigDecimal oldMoney = new BigDecimal(accountMoney);
       log.setNewFixedLimit(accountModel.getFixedLimit());
       log.setNewLimit(accountModel.getLimit()+"");
       log.setNewMoney(DoubleUtil.roundTwo(newAccountMoney.toString()));
       log.setOldFixedLimit(accountModel.getFixedLimit());
       log.setOldLimit(accountModel.getLimit()+"");
       log.setOldMoney(DoubleUtil.roundTwo(oldMoney.toString()));
       log.setOrderId(payOrderId);
       //model.setOrderId(payOrderId);
       payLogService.insertAccountLog(log);
   }
   public int addPartnerAccountLog(String money,XzxCityPartner partner,String payOrderId){
       String accountInfoMoney = xzxCityPartnerDao.queryAccountByPartnerId(partner.getUserId());
       BigDecimal newMoney = new BigDecimal(accountInfoMoney).subtract(new BigDecimal(money));

       PartnerAccountModel partnerAccountModel = fundManagementApiDao.getPartnerAccountByUserId(partner.getUserId());
       BigDecimal hbb = new BigDecimal(partnerAccountModel.getHbb());
       hbb = hbb.subtract(new BigDecimal(money));
       if(hbb.compareTo(BigDecimal.ZERO)==-1){
           return 0;
       }
       fundManagementApiDao.updateParterAccount(DoubleUtil.roundTwo(hbb.toString()),partnerAccountModel.getAccount());


       //写入日志
       AccountLogModel log1 = new AccountLogModel();
       log1.setAccountId(partner.getAccountNo());
       log1.setChannelType("12");
       log1.setCreateTime(sdf.format(new Date()));
       log1.setCreateUserId(partner.getUserId());
       log1.setOldMoney(accountInfoMoney);
       log1.setOrderId(payOrderId);
       log1.setNewMoney(newMoney.toString());
       payLogService.insertAccountLog(log1);
       PayLog newPl = new PayLog();
       newPl.setAccountId(partner.getAccountNo());
       newPl.setMoney(newMoney.doubleValue());

       payConsoleDao.updateAccountMoneyDouble(newPl);
      /* PartnerAccountModel partnerAccountModel = fundManagementApiDao.getPartnerAccountByUserId(partner.getUserId());
       BigDecimal hbb = new BigDecimal(partnerAccountModel.getHbb());
       hbb = hbb.subtract(new BigDecimal(money));
       fundManagementApiDao.updateParterAccount(DoubleUtil.roundTwo(hbb.toString()),partnerAccountModel.getAccount());
*/

       PartnerAccountLogModel log = new  PartnerAccountLogModel();
       log.setFlowNo(payOrderId);
       log.setCreateTime(sdf.format(new Date()));
       log.setApproverStatus("1");
       log.setMoney(money);
       log.setHbb(money);
       log.setDelFlag(0);
       log.setAccountId(partner.getAccountNo());
       log.setUserName(partner.getPartnerName());
       log.setType("1");
       log.setUserPhone(partner.getMobilePhone());
       log.setRoleName("城市合伙人");
       xzxCityPartnerDao.addPartnerAccountLog(log);
       return 1;
   }
    public Map<String,Object> queryPackageType(){
        List<Map<String,Object>> list = xzxUserShareInfoDao.queryPackageGoods();
        for (Map<String,Object> map1 :list) {
            map1.put("configTypeName",map1.get("title"));
            map1.put("configTypeCode",map1.get("itemtype"));
        }
        Map<String,Object> map = new HashMap<>();
        map.put("data",list);
        map.put("code",0);
        return map;
    }
   public Map<String,Object> queryRoyaltyManage(SettlementModel model){
       int p = (model.getPage() - 1) * model.getLimit();
       model.setPage(p);
       Map<String,Object> map = new HashMap<>();
       List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
       model.setPartnerIds(partnerIds);
       List<SettlementModel> list = xzxUserShareInfoDao.queryRoyaltyManage(model);
       List<XzxUserRedpaperRuleModel> ruleList = xzxUserShareInfoDao.queryRoyalty(partnerIds);
       boolean flag = false;
       int count=0;
       if(null!=ruleList&&ruleList.size()>0){
           XzxUserRedpaperRuleModel rule = ruleList.get(0);
           String productType = rule.getProductType();
           String[] typeList = productType.split(",");
           for (String type:typeList) {
               if(type.equals("3")){
                   flag = true;
               }
           }

           for (SettlementModel seModel:list) {
               List<WeightItemPriceModel> royaltyList = xzxUserShareInfoDao.queryWeightItemList(seModel.getReceiver());
               BigDecimal royaltyMoney= new BigDecimal("0");
               BigDecimal settlementMoney = new BigDecimal("0");
               for (WeightItemPriceModel pModel:royaltyList) {
                   String time = pModel.getCreateTime();
                  /* if(pModel.getProductType().equals("1")){

                   }*/
                   String title = xzxUserShareInfoDao.queryGoodsById(pModel.getProductType());
                   pModel.setProductName(title);

                   if(null!=rule){
                       List<WeightPriceModel> rulePrice = xzxUserShareInfoDao.queryRulePriceList(rule.getId()+"",time);
                       if(rulePrice.size()>0){
                       }else{
                           rulePrice = xzxUserShareInfoDao.queryRoyaltyHistory(rule.getId()+"",time);
                       }
                       if(pModel.getStatus().equals("1")){
                           for (WeightPriceModel rp:rulePrice) {
                               BigDecimal a = new BigDecimal(pModel.getWeight());
                               BigDecimal rate = new BigDecimal(rp.getMoney());
                               if(rp.getProductType().equals(pModel.getProductType())){
                                   pModel.setPrice(DoubleUtil.roundTwo(a.multiply(rate).toString()));
                                   royaltyMoney= royaltyMoney.add(new BigDecimal(pModel.getPrice()));
                                   break;
                               }
                           }
                       }else if(pModel.getStatus().equals("2")){
                           for (WeightPriceModel rp:rulePrice) {
                               BigDecimal a = new BigDecimal(pModel.getWeight());
                               BigDecimal rate = new BigDecimal(rp.getMoney());
                               if(rp.getProductType().equals(pModel.getProductType())){
                                   pModel.setPrice(DoubleUtil.roundTwo(a.multiply(rate).toString()));
                                   settlementMoney = settlementMoney.add(new BigDecimal(pModel.getPrice()));
                                   break;
                               }
                           }
                       }

                   }else{
                       return null;
                   }

               }
               seModel.setRoyaltyMoney(DoubleUtil.roundTwo(royaltyMoney.toString()));
               seModel.setSettlementMoney(DoubleUtil.roundTwo(settlementMoney.toString()));
               seModel.setRoyaltyList(royaltyList);
               seModel.setFlag(flag);
           }

       }

       String num =xzxUserShareInfoDao.queryRoyaltyManageCount(model);
       if(null!=num&&!"".equals(num)){
           count = Integer.parseInt(num);
       }
       map.put("flag",flag);
       map.put("data",list);
       map.put("count",count);
       map.put("code",0);
       return map;
   }



}