package com.ibeetl.admin.console.service;


import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import com.ibeetl.admin.console.dao.FundManagementApiDao;
import com.ibeetl.admin.console.dao.XzxUserRedpaperInfoDao;
import com.ibeetl.admin.console.model.PartnerAccountModel;
import com.ibeetl.admin.console.model.PlatformAccountLogModel;
import com.ibeetl.admin.console.model.UserAccountModel;
import com.ibeetl.admin.console.model.XzxUserRedpaperInfoModel;
import com.ibeetl.admin.console.util.DoubleUtil;
import com.ibeetl.admin.core.entity.CoreUser;
import com.ibeetl.admin.core.entity.XzxCityPartner;
import com.ibeetl.admin.core.entity.XzxUserRedpaperInfo;
import com.ibeetl.admin.core.entity.XzxUserRedpaperRule;
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.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.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


/**
 * XzxUserRedpaperInfo Service
 */

@Service
@Transactional
public class XzxUserRedpaperInfoService extends CoreBaseService<XzxUserRedpaperInfo>{

    @Autowired private XzxUserRedpaperInfoDao xzxUserRedpaperInfoDao;
    @Autowired
    XzxCityPartnerService service;
    SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");
    @Autowired
    XzxCityPartnerService cityPartnerService;
    @Autowired
    CorePlatformService platformService;
    @Autowired private FundManagementApiDao fundManagementApiDao;
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    final Base64 base64 = new Base64();
    public PageQuery<XzxUserRedpaperInfo>queryByCondition(PageQuery query){
        PageQuery ret =  xzxUserRedpaperInfoDao.queryByCondition(query);
        queryListAfter(ret.getList());
        return ret;
    }

    public void batchDelXzxUserRedpaperInfo(List<Long> ids){
        try {
            xzxUserRedpaperInfoDao.batchDelXzxUserRedpaperInfoByIds(ids);
        } catch (Exception e) {
            throw new PlatformException("批量删除XzxUserRedpaperInfo失败", e);
        }
    }

    public String cancelRedPaper(XzxCityPartner partner){
        String day = sdf.format(new Date());
        Snowflake snowflake = IdUtil.getSnowflake(0, 3);
        String payOrderId = "ZF"+snowflake.nextIdStr();
        if(null!=partner){
            //合伙人退还红包
            //判断红包有效时间是否已经截止
            XzxUserRedpaperRule rule = xzxUserRedpaperInfoDao.queryRuleByDay(partner.getId(),day);
            if(null!=rule){
                //查询规则未领完的红包金额
                String redMoney = queryMoneyByRuleId(rule.getId()+"");
                BigDecimal rd = new BigDecimal(redMoney);
                if(rd.compareTo(BigDecimal.ZERO)==0){
                    return "合伙人的红包已经领完，不能退还！";
                }else{
                   PartnerAccountModel partnerAccountModel = cityPartnerService.queryAccountIdByUserId(partner.getUserId());
                   UserAccountModel userAccountModel1 = cityPartnerService.queryPartnerAccountByUserId(partner.getUserId());
                   BigDecimal hbb = new BigDecimal(partnerAccountModel.getHbb()).add(new BigDecimal(redMoney));
                   //先写日志 UserAccountModel accountModel, String type, BigDecimal money, String payOrderId
                   cityPartnerService.insertAccountLogByPartner(userAccountModel1,"5",new BigDecimal(redMoney),payOrderId);
                   cityPartnerService.insertPartnerLogByPartner(partnerAccountModel,"8",redMoney,payOrderId,partner,DoubleUtil.roundTwo(hbb.toString()));
                   //修改合伙人环保币
                   partnerAccountModel.setHbb(DoubleUtil.roundTwo(hbb.toString()));
                   cityPartnerService.updatePartnerAccount(partnerAccountModel);
                   UserAccountModel userAccountModel = new UserAccountModel();
                   userAccountModel.setUserId(partner.getUserId());
                   userAccountModel.setMoney(Double.valueOf(DoubleUtil.roundTwo(hbb.toString())));
                   cityPartnerService.updateAccountPartner(userAccountModel);
                }
            }else{
                 rule = xzxUserRedpaperInfoDao.queryRuleByDay(partner.getId(),null);
                    String endTime =rule.getEndTime();
                    if(null!=endTime&&!"".equals(endTime)){
                        String[] times = endTime.split("-");
                        return "请在红包结束时间"+times[0]+"年"+times[1]+"月"+times[2]+"日之后进行操作";
                    }else{
                        return "没有规则，无法退红包！";
                    }
            }
        }else{
            //平台管理员退还红包
            XzxUserRedpaperRule rule = xzxUserRedpaperInfoDao.queryRuleByDay(null,day);
            if(null!=rule){
                String redMoney = queryMoneyByRuleId(rule.getId()+"");
                BigDecimal rd = new BigDecimal(redMoney);
                if(rd.compareTo(BigDecimal.ZERO)==0){
                    return "平台的红包已经领完，不能退还！";
                }else{
                    String acc = cityPartnerService.queryAccountByAdminId();
                    String[] accArr = acc.split(",");
                    String oldMoney = accArr[1];
                    String oldHbb = accArr[2];
                    BigDecimal newMoney = new BigDecimal(oldMoney).add(new BigDecimal(redMoney));
                    updateAdminAccount(redMoney,"0",oldHbb,oldMoney,oldHbb,DoubleUtil.roundTwo(newMoney.toString()),null,payOrderId);
                    cityPartnerService.updatePlatformMoney(DoubleUtil.roundTwo(newMoney.toString()));
                }
            }else{
                rule = xzxUserRedpaperInfoDao.queryRuleByDay(null,null);
                String endTime =rule.getEndTime();
                if(null!=endTime&&!"".equals(endTime)){
                    String[] times = endTime.split("-");
                    return "请在红包结束时间"+times[0]+"年"+times[1]+"月"+times[2]+"日之后进行操作";
                }else{
                    return "没有规则，无法退红包！";
                }
            }
        }
        return null;
    }
    public String queryMoneyByRuleId(String ruleId){
        return xzxUserRedpaperInfoDao.queryMoneyByRuleId(ruleId);
    }
    private void updateAdminAccount(String money,String hbb,String oldHbb,String oldMoney,String newHbb,String newMoney,XzxCityPartner partner,String payOrderId){
        CoreUser user = platformService.getCurrentUser();
        PlatformAccountLogModel platformAccountLogModel = new PlatformAccountLogModel();
        platformAccountLogModel.setCreateTime(sdf.format(new Date()));
        platformAccountLogModel.setCreateUserId(user.getId()+"");
        platformAccountLogModel.setMoney(money);
        platformAccountLogModel.setHbb(hbb);
        platformAccountLogModel.setOldHbb(oldHbb);
        platformAccountLogModel.setOldMoney(oldMoney);
        platformAccountLogModel.setNewHbb(newHbb);
        platformAccountLogModel.setNewMoney(newMoney);
        if(null!=partner){
            platformAccountLogModel.setCreateUserName(partner.getPartnerName());
            platformAccountLogModel.setCreateUserMobile(partner.getMobilePhone());
        }else{
            platformAccountLogModel.setCreateUserName(user.getName());
            platformAccountLogModel.setCreateUserMobile("-");
        }
        platformAccountLogModel.setCreateUserType("2");
        platformAccountLogModel.setFlowNo(payOrderId);
        fundManagementApiDao.insertPlatFormLog(platformAccountLogModel);
    }
    public Map<String,Object> redPaperList(XzxUserRedpaperInfoModel 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);
        List<XzxUserRedpaperInfoModel> list = xzxUserRedpaperInfoDao.redPaperList(model);
        for (XzxUserRedpaperInfoModel resultModel:list) {
            String name = resultModel.getName();
            if(name!=null&&!"".equals(name)){
                try {
                    name =new String(base64.decode(name), "UTF-8");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }
            resultModel.setName(name);
        }
        Map<String,Object> totalmap = xzxUserRedpaperInfoDao.redPaperTotal(model);
        map.put("data",list);
        map.put("count",xzxUserRedpaperInfoDao.redPaperCount(model));
        map.put("code",0);
        map.put("redPaperTotalNum",totalmap.get("count"));
        if(totalmap.get("money")!=null){
            map.put("redPaperTotalMoney",totalmap.get("money"));
        }else{
            map.put("redPaperTotalMoney","0");
        }
        return map;
    }

    public void batchInsertPaperInfo(List<XzxUserRedpaperInfo> list){
        xzxUserRedpaperInfoDao.batchInsertPaperInfo(list);
    }
    public String subPartnerAccount(String amount){
        List<String> partnerIds = service.queryPartnerByCurrent();
        Snowflake snowflake = IdUtil.getSnowflake(0, 3);
        String payOrderId = "ZF"+snowflake.nextIdStr();
        if(null!=partnerIds&&partnerIds.size()>0){
            PartnerAccountModel partnerAccount = new PartnerAccountModel();
            XzxCityPartner partner = service.queryById(partnerIds.get(0));
            partnerAccount = service.queryAccountIdByUserId(partner.getUserId());
            BigDecimal pHbb = new BigDecimal(partnerAccount.getHbb());
            BigDecimal subHbb = pHbb.subtract(new BigDecimal(amount));
            if(subHbb.compareTo(BigDecimal.ZERO)==-1){
                return "合伙人的余额为："+partnerAccount.getHbb()+",不足以发红包金额："+amount+",请充值环保币！";
            }
            UserAccountModel userAccount = service.queryPartnerAccountByUserId(partner.getUserId());
            cityPartnerService.insertPartnerAccountLog(userAccount,"5",new BigDecimal(amount),payOrderId,"8");
            userAccount.setMoney(Double.valueOf(DoubleUtil.roundTwo(subHbb.toString())));
            cityPartnerService.updateAccountPartner(userAccount);
            partnerAccount.setHbb(DoubleUtil.roundTwo(subHbb.toString()));
            cityPartnerService.updatePartnerAccount(partnerAccount);
        }else{
            String acc = service.queryAccountByAdminId();
            String[] accArr = acc.split(",");
            String adminMoney = accArr[1];
            String adminhbb = accArr[2];
            //平台
            BigDecimal oldAdminMoney = new BigDecimal(adminMoney);
            BigDecimal oldAdminhbb = new BigDecimal(adminhbb);
            //平台账户处理红包
            BigDecimal newAdminhbb = oldAdminhbb.subtract(new BigDecimal(amount));
            service.updatePlatformHbb(DoubleUtil.roundTwo(newAdminhbb.toString()));
            PlatformAccountLogModel platformAccountLogModel = new PlatformAccountLogModel();
            platformAccountLogModel.setCreateTime(sdf.format(new Date()));
            platformAccountLogModel.setCreateUserId("1");
            platformAccountLogModel.setMoney(DoubleUtil.roundTwo("0"));
            platformAccountLogModel.setHbb("-" + DoubleUtil.roundTwo(amount));
            platformAccountLogModel.setOldHbb(DoubleUtil.roundTwo(adminhbb));
            platformAccountLogModel.setOldMoney(DoubleUtil.roundTwo(adminMoney));
            platformAccountLogModel.setNewHbb(DoubleUtil.roundTwo(newAdminhbb.toString()));
            platformAccountLogModel.setNewMoney(DoubleUtil.roundTwo(adminMoney));
            platformAccountLogModel.setCreateUserName("平台管理员");
            platformAccountLogModel.setCreateUserType("2");
            platformAccountLogModel.setCreateUserMobile("--");
            platformAccountLogModel.setFlowNo(payOrderId);
            service.insertPlatFormLog(platformAccountLogModel);
        }
        return null;
    }

}