package com.ibeetl.admin.console.api;

import cn.hutool.core.date.format.FastDateFormat;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.ibeetl.admin.console.model.*;
import com.ibeetl.admin.console.service.*;
import com.ibeetl.admin.console.util.DateUtil;
import com.ibeetl.admin.console.util.DoubleUtil;
import com.ibeetl.admin.console.web.query.XzxUserRedpaperRuleQuery;
import com.ibeetl.admin.core.entity.*;
import com.ibeetl.admin.core.file.FileService;
import com.ibeetl.admin.core.service.CorePlatformService;
import com.ibeetl.admin.core.web.JsonResult;
import io.swagger.annotations.*;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.beetl.sql.core.engine.PageQuery;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.SimpleDateFormat;
import java.util.*;

@RestController
@Api(value = "红包设置规则")
public class XzxUserRedpaperRuleApi {

    private final Log log = LogFactory.getLog(this.getClass());
    private static final String MODEL = "/admin/front/xzxUserRedpaperRule";
    static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    static SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd");


    @Autowired
    XzxUserRedpaperRuleService xzxUserRedpaperRuleService;
    @Autowired
    XzxUserRedpaperInfoService xzxUserRedpaperInfoService;
    @Autowired
    XzxRebateRulePriceService xzxRebateRulePriceService;
    @Autowired
    XzxUserShareInfoService xzxUserShareInfoService;
    @Autowired
    CorePlatformService platformService;
    @Autowired
    XzxCityPartnerService cityPartnerService;





    @Autowired
    FileService fileService;
    /* 页面 */



    @PostMapping(MODEL + "/redRuleList.json")
    @ResponseBody
    @ApiOperation(value="红包记录-红包规则", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "每页条数", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "ruleName", value = "规则名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleType", value = "规则类型（1：红包规则，2：分享分利规则 3：阶梯返利5：物品返利,7:提成规则）", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> redRuleList(@RequestBody XzxUserRedpaperRuleQuery condtion)
    {
        CoreUser user = platformService.getCurrentUser();
        XzxCityPartner partner = cityPartnerService.queryById(user.getId());

        /*if(condtion.getRuleType().equals("7")){
            if(null==partner){
              return JsonResult.failMessage("提成规则只能由合伙人设置！");
            }
        }*/
        if(null!=partner){
            condtion.setPartnerId(partner.getId()+"");
        }

        PageQuery page = condtion.getPageQuery();
        Map<String,Object> map = xzxUserRedpaperRuleService.queryByCondition(page,condtion.getRuleType());
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/add.json")
    @ResponseBody
    @ApiOperation(value="红包规则-添加红包规则", notes="test: 仅0有正确返回")
    public JsonResult add(@RequestBody XzxUserRedpaperRuleModel model)
    {
        CoreUser user = platformService.getCurrentUser();
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        if(null!=partnerIds&&partnerIds.size()>0){
            model.setPartnerId(partnerIds.get(0));
        }
        List<XzxUserRedpaperInfo> infoList = new ArrayList<>();
        List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryRedpaperListStartAndEnd(model.getStartTime(),model.getEndTime());
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("该时间段内不允许添加红包规则！");
        }
        //限制红包金额是否有符合正态分布
        if(model.getIssuanceRules().equals("0")){
            String amount = model.getAmount();
            String surplusNum = model.getRedEnvelopesNum();
            BigDecimal avg = new BigDecimal(amount).divide(new BigDecimal(surplusNum), 2, RoundingMode.HALF_UP);
            String minMoney = model.getMinMoney();
            if(minMoney!=null&&!"".equals(minMoney)){
                if(new BigDecimal(minMoney).compareTo(avg)>=0){
                    return  JsonResult.failMessage("平均金额必须大于最小金额！");
                }
            }else{
                minMoney = model.getRandomAmountAverage().split(",")[0];
                if(new BigDecimal(minMoney).compareTo(avg)>=0){
                    return  JsonResult.failMessage("平均金额必须大于最小金额！");
                }
            }
        }

        //先保存规则
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        XzxUserRedpaperRule rule = objectMapper.convertValue(model, XzxUserRedpaperRule.class);
        rule.setCreateTime(sdf.format(new Date()));
        rule.setDelFlag(0);
        rule.setRuleType("1");

        xzxUserRedpaperRuleService.save(rule);

        //通过规则关联红包
        String amount = model.getAmount();
        String redEnvelopesNum = model.getRedEnvelopesNum();
        //金额随机或者金额固定
        String issuanceRules=model.getIssuanceRules();
        String randomAmountAverage = model.getRandomAmountAverage();
        //合伙人设置红包，需要扣除合伙人的环保币余额
        String result1 = xzxUserRedpaperInfoService.subPartnerAccount(amount);
        if(null!=result1){
            return new JsonResult().failMessage(result1);
        }
        if(issuanceRules.equals("0")){
            //金额随机
            String[] random = randomAmountAverage.split(",");
            String minRadom = random[0];
            String maxRadom = random[1];
            long[] result = DoubleUtil.generate(amount, Integer.parseInt(redEnvelopesNum), maxRadom, minRadom);
            double total = 0;
            for (int i = 0; i < result.length; i++) {
                System.out.println("result[" + i + "]:" + result[i]);
                double money = (double)result[i]/100.00;
                System.out.println(money);
                total += result[i];
                if(rule.getId()!=null){
                    XzxUserRedpaperInfo info = saveRedPaperInfo(rule.getId(),amount,money);
                    info.setCreateUserId(user.getId()+"");
                    infoList.add(info);
                }
            }
            xzxUserRedpaperInfoService.batchInsertPaperInfo(infoList);
            total = total/100;
        }else if(issuanceRules.equals("1")){
            int num = Integer.parseInt(redEnvelopesNum);
            //金额固定
            for (int i = 0; i <num ; i++) {
                XzxUserRedpaperInfo info =saveRedPaperInfo(rule.getId(),amount,Double.parseDouble(randomAmountAverage));
                infoList.add(info);
            }
            xzxUserRedpaperInfoService.batchInsertPaperInfo(infoList);
        }
        //根据规则生成红包
        return new JsonResult().success();
    }

    private XzxUserRedpaperInfo saveRedPaperInfo(Integer ruleId,String total,double money){
        String code = FastDateFormat.getInstance("yyyyMMddHHmmssSSS").format(new Date());
        XzxUserRedpaperInfo info = new XzxUserRedpaperInfo();
        info.setCode(code);
        info.setCreateTime(sdf1.format(new Date()));
        info.setMoney(new BigDecimal(String.valueOf(money)));
        info.setTotalAmount(total);
        info.setRuleId(ruleId.longValue());
        info.setReceiveFlag(1);
        return info ;
    }
    @PostMapping(MODEL + "/edit.json")
    @ResponseBody
    @ApiOperation(value="红包规则-修改红包规则", notes="test: 仅0有正确返回")
    public JsonResult<String> update(@RequestBody XzxUserRedpaperRuleModel model) {
        List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryRedpaperListStartAndEnd(model.getStartTime(),model.getEndTime());
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("该时间段内不允许修改红包规则！");
        }
        XzxUserRedpaperRule ru = xzxUserRedpaperRuleService.queryById(model.getId());
        /*List<XzxUserRedpaperInfo> infoList = new ArrayList<>();
        //删除原有规则，重新创建规则生成红包
        ru.setDelFlag(1);
        boolean success = xzxUserRedpaperRuleService.update(ru);*/
        //先保存规则
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        XzxUserRedpaperRule rule = objectMapper.convertValue(model, XzxUserRedpaperRule.class);
        rule.setUpdateTime(sdf.format(new Date()));
        rule.setDelFlag(0);
        //rule.setStatus(1);
        rule.setRuleType("1");
        rule.setSharingProfitType("REDPAPER_TEXT");
        rule.setId(ru.getId());
        xzxUserRedpaperRuleService.update(rule);
        return new JsonResult().success();
        //通过规则关联红包
        /*String amount = model.getAmount();
        String redEnvelopesNum = model.getRedEnvelopesNum();
        //金额随机或者金额固定
        String issuanceRules=model.getIssuanceRules();
        String randomAmountAverage = model.getRandomAmountAverage();
        if(issuanceRules.equals("0")){
            //金额随机
            String[] random = randomAmountAverage.split(",");
            String minRadom = random[0];
            String maxRadom = random[1];
            long[] result = DoubleUtil.generate(amount, Integer.parseInt(redEnvelopesNum), maxRadom, minRadom);
            double total = 0;
            for (int i = 0; i < result.length; i++) {
                System.out.println("result[" + i + "]:" + result[i]);
                double money = (double)result[i]/100.00;
                System.out.println(money);
                total += result[i];
                if(rule.getId()!=null){
                    XzxUserRedpaperInfo info = saveRedPaperInfo(rule.getId(),amount,money);
                    infoList.add(info);
                }
            }
            total = total/100;
            xzxUserRedpaperInfoService.batchInsertPaperInfo(infoList);


        }else if(issuanceRules.equals("1")){
            int num = Integer.parseInt(redEnvelopesNum);
            //金额固定
            for (int i = 0; i <num ; i++) {
                XzxUserRedpaperInfo info =saveRedPaperInfo(rule.getId(),amount,Double.parseDouble(randomAmountAverage));
                infoList.add(info);
            }
            xzxUserRedpaperInfoService.batchInsertPaperInfo(infoList);

        }
        if (success) {
            return new JsonResult().success();
        } else {
            return JsonResult.failMessage("保存失败");
        }*/
    }

    @PostMapping(MODEL + "/delete.json")
    @ResponseBody
    @ApiOperation(value="红包记录-删除红包规则(分享分利规则)", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "id", value = "规则Id", required = true, dataType = "Integer")
    })
    public JsonResult delete(@RequestBody XzxUserRedpaperRuleModel model) {
        //查询未领取的红包
        String redMoney = xzxUserRedpaperInfoService.queryMoneyByRuleId(model.getId()+"");
        if(redMoney.equals("0")){
            XzxUserRedpaperRule ru = xzxUserRedpaperRuleService.queryById(model.getId());
            //删除原有规则，重新创建规则生成红包
            ru.setDelFlag(1);
            boolean success = xzxUserRedpaperRuleService.update(ru);
            if (success) {
                return new JsonResult().success();
            } else {
                return JsonResult.failMessage("删除失败");
            }
        }else{
            return JsonResult.failMessage("该规则有未领取的红包，不能删除规则。请返回该红包金额后再删除！");
        }

    }

    @PostMapping(MODEL + "/isStart.json")
    @ResponseBody
    @ApiOperation(value="红包记录-红包规则（是否启用 通用）", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "id", value = "规则Id", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "status", value = "开关0：关闭，1：正常", required = true, dataType = "Integer")

    })
    public JsonResult isStart(@RequestBody XzxUserRedpaperRuleModel model) {
        XzxUserRedpaperRule ru = xzxUserRedpaperRuleService.queryById(model.getId());
        ru.setStatus(model.getStatus());
        boolean success = xzxUserRedpaperRuleService.update(ru);
        if (success) {
            return new JsonResult().success();
        } else {
            return JsonResult.failMessage("修改失败");
        }
    }

    @PostMapping(MODEL + "/queryRebateList.do")
    @ResponseBody
    @ApiOperation(value="阶梯返利(查询列表)", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "每页条数", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "mobilePhone", value = "手机号(昵称)", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryRebateList(@RequestBody XzxPlatformCapitalInfoModel model)
    {
        Map<String,Object> map =xzxUserRedpaperRuleService.queryRebateList(model);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/addRebateRule.json")
    @ResponseBody
    @ApiOperation(value="阶梯返利-阶梯返利添加", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "rulePriceList", value = "阶梯价格列表", required = true, dataType = "List<XzxRebateRulePrice>"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "有效开始时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "有效结束时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "status", value = "开关0：关闭，1：正常", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "conversionPerUnit", value = "每台家电折算重量", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "conversionPerUnitFlag", value = "每台家电折算重量是否启用（0:不启用，1：启用）", required = true, dataType = "String")

    })
    public JsonResult addRebateRule(@RequestBody XzxUserRebateRuleModel model){
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        if(null!=partnerIds&&partnerIds.size()>0){
            model.setPartnerId(partnerIds.get(0));
        }
        List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryRebateRuleList(model);
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("只能添加一个阶梯规则");
        }

        List<XzxRebateRulePrice> rulePriceList = model.getRulePriceList();
        List<String> priceList = new ArrayList<>();
        for (int i = 0; i <rulePriceList.size() ; i++) {
            priceList.add(rulePriceList.get(i).getRate());
        }
        boolean bool = DateUtil.isSorted(priceList,priceList.size());
        if(!bool){
            return JsonResult.failMessage("阶梯价格必须按顺序排列");
        }
        XzxUserRedpaperRule rule = new XzxUserRedpaperRule();
        rule.setConversionPerUnit(model.getConversionPerUnit());
        rule.setStartTime(model.getStartTime());
        rule.setEndTime(model.getEndTime());
        rule.setRuleName("阶梯价格规则");
        rule.setCreateTime(sdf.format(new Date()));
        rule.setDelFlag(0);
        rule.setRuleType("3");
        rule.setStatus(model.getStatus());
        rule.setApplicableObject("1");
        rule.setConversionPerUnitFlag(model.getConversionPerUnitFlag());
        xzxUserRedpaperRuleService.save(rule);
        if(rule.getId()!=null){
            for (int i = 0; i <rulePriceList.size() ; i++) {
                XzxRebateRulePrice rulePrice = rulePriceList.get(i);
                rulePrice.setCreateTime(sdf1.format(new Date()));
                rulePrice.setRuleId(rule.getId());
                rulePrice.setSort(String.valueOf(i+1));
                xzxRebateRulePriceService.save(rulePrice);
            }
        }
        return new JsonResult().success();
    }


    @PostMapping(MODEL + "/updateRebateRule.json")
    @ResponseBody
    @ApiOperation(value="阶梯返利-阶梯返利修改(重量规则修改)", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "ruleName", value = "规则名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "rulePriceList", value = "阶梯价格列表", required = true, dataType = "List<XzxRebateRulePrice>"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "有效开始时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "有效结束时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "status", value = "开关0：关闭，1：正常", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "conversionPerUnit", value = "每台家电折算重量", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "conversionPerUnitFlag", value = "每台家电折算重量是否启用（0:不启用，1：启用）", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "id", value = "规则ID", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleType", value = "规则类型", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "weightRateList", value = "重量规则", required = true, dataType = "String")
    })
    public JsonResult updateRebateRule(@RequestBody XzxUserRedpaperRuleModel model){
        //判断时间段内是否相交
        XzxUserRedpaperRule rule = xzxUserRedpaperRuleService.queryById(model.getId());

        List<XzxRebateRulePrice> rulePriceList = model.getRulePriceList();
        if(rule.getRuleType().equals("5")){
            rulePriceList  = model.getWeightRateList();
        }
        List<String> priceList = new ArrayList<>();
        for (int i = 0; i <rulePriceList.size() ; i++) {
            priceList.add(rulePriceList.get(i).getRate());
        }
        boolean bool = DateUtil.isSorted(priceList,priceList.size());
        if(!bool){
            return JsonResult.failMessage("阶梯价格必须按顺序排列");
        }
        rule.setConversionPerUnit(model.getConversionPerUnit());
        rule.setStartTime(model.getStartTime());
        rule.setEndTime(model.getEndTime());
        if(rule.getRuleType().equals("5")){
            rule.setRuleName("重量规则返利");
            rule.setRuleType("5");
            if(null!=model.getProductType()&&!"".equals(model.getProductType())){
                rule.setProductType(model.getProductType());
            }

        }else{
            rule.setRuleName("阶梯价格规则");
            rule.setRuleType("3");
        }
        rule.setCreateTime(sdf.format(new Date()));
        rule.setDelFlag(0);
        rule.setStatus(model.getStatus());
        rule.setConversionPerUnitFlag(model.getConversionPerUnitFlag());
        xzxUserRedpaperRuleService.update(rule);

        if(rule.getId()!=null){
            //删除原有阶梯
            xzxUserRedpaperRuleService.deleteByRuleId(rule.getId());
            for (int i = 0; i <rulePriceList.size() ; i++) {
                XzxRebateRulePrice rulePrice = rulePriceList.get(i);
                rulePrice.setCreateTime(sdf1.format(new Date()));
                rulePrice.setRuleId(rule.getId());
                rulePrice.setSort(String.valueOf(i+1));
                xzxRebateRulePriceService.save(rulePrice);
            }
        }
        return new JsonResult().success();
    }

    @PostMapping(MODEL + "/queryShareInfoList.do")
    @ResponseBody
    @ApiOperation(value="分享分利", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "每页条数", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "name", value = "邀请人", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "mobilePhone", value = "邀请人手机号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "registerName", value = "被邀请人", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "registerMobilePhone", value = "被邀请人手机号", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryShareInfoList(@RequestBody XzxUserShareInfoModel model)
    {
        Map<String,Object> map =xzxUserShareInfoService.queryShareInfoList(model);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/queryShareOrderList.json")
    @ResponseBody
    @ApiOperation(value="分享分利-下单详情", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "每页条数", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "shareId", value = "分享ID", required = true, dataType = "String"),
    })
    public JsonResult<Map<String,Object>> queryShareOrderList(@RequestBody XzxPlatformCapitalInfoModel model)
    {
        Map<String,Object> map =xzxUserShareInfoService.queryShareOrderList(model);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/addShareRule.json")
    @ResponseBody
    @ApiOperation(value="分享分利-分享分利添加", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "startTime", value = "有效开始时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "有效结束时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "status", value = "开关0：关闭，1：正常", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "sharingProfitType", value = "分享分利规则文案（SHARE_RATIO对应第一个文案，COMMISSION_FOR_INVITEES：第二个，DESIGNATED_USER：第三个，多个用逗号分割）", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "shareRatio", value = "分享利益百分比", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleName", value = "规则名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "applicableObject", value = "指定用户1：全部用户，2：指定用户", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "designatedWeight", value = "指定用户规则(回收累计重量)", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "issuanceRules", value = "发放规则（0：金额随机，1：金额固定）", required = true, dataType = "String")
            })
    public JsonResult addShareRule(@RequestBody XzxUserRedpaperRuleModel model){
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        if(null!=partnerIds&&partnerIds.size()>0){
            model.setPartnerId(partnerIds.get(0));
        }
        List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryShareListByTime(model.getStartTime(),model.getEndTime());
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("该时间段内不允许添加分享分利规则！");
        }

        XzxUserRedpaperRule rule = getRedpaperRule(model);
        boolean success = xzxUserRedpaperRuleService.save(rule);
        if (success) {
            return new JsonResult().success();
        } else {
            return JsonResult.failMessage("添加失败");
        }
    }

    @PostMapping(MODEL + "/updateShareRule.json")
    @ResponseBody
    @ApiOperation(value="分享分利-分享分利修改", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "startTime", value = "有效开始时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "有效结束时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "status", value = "开关0：关闭，1：正常", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "sharingProfitType", value = "分享分利规则文案（SHARE_RATIO对应第一个文案，COMMISSION_FOR_INVITEES：第二个，DESIGNATED_USER：第三个，多个用逗号分割）", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "shareRatio", value = "分享利益百分比", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleName", value = "规则名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "applicableObject", value = "指定用户1：全部用户，2：指定用户", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "designatedWeight", value = "指定用户规则(回收累计重量)", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "id", value = "id", required = true, dataType = "String")

    })
    public JsonResult updateShareRule(@RequestBody XzxUserRedpaperRuleModel model){
        List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryShareListByTime(model.getStartTime(),model.getEndTime());
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("该时间段内不允许修改分享分利规则！");
        }
        XzxUserRedpaperRule rule = new XzxUserRedpaperRule();
        rule = xzxUserRedpaperRuleService.queryById(model.getId());
        if(rule!=null){
            rule = getRedpaperRule(model);
            rule.setId(model.getId());
        }else{
            return JsonResult.failMessage("修改失败");
        }
        boolean success = xzxUserRedpaperRuleService.update(rule);
        if (success) {
            return new JsonResult().success();
        } else {
            return JsonResult.failMessage("修改失败");
        }
    }

    private XzxUserRedpaperRule getRedpaperRule(XzxUserRedpaperRuleModel model){
        XzxUserRedpaperRule rule = new XzxUserRedpaperRule();
        rule.setId(model.getId());
        rule.setStartTime(model.getStartTime());
        rule.setEndTime(model.getEndTime());
        rule.setRuleName(model.getRuleName());
        if(model.getId()!=null){
            rule.setUpdateTime(sdf.format(new Date()));
        }else{
            rule.setCreateTime(sdf.format(new Date()));
        }
        rule.setDelFlag(0);
        if(null!=model.getRuleType()&&!"".equals(model.getRuleType())){
            rule.setRuleType(model.getRuleType());
        }else{
            rule.setRuleType("2");
        }

        rule.setSharingProfitType(model.getSharingProfitType());
        rule.setShareRatio(model.getShareRatio());
        rule.setStatus(model.getStatus());
        rule.setRuleName(model.getRuleName());
        rule.setApplicableObject(model.getApplicableObject());
        rule.setDesignatedWeight(model.getDesignatedWeight());
        rule.setIssuanceRules(model.getIssuanceRules());
        return rule;

    }


    @PostMapping(MODEL + "/addWeightRule.json")
    @ResponseBody
    @ApiOperation(value="重量返利规则-重量返利规则添加", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "weightRateList", value = "阶梯重量列表（用户返利，合伙人，回收员的返利用逗号隔开）", required = true, dataType = "List<XzxRebateRulePrice>"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "有效开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "有效结束时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "status", value = "开关0：关闭，1：正常", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "productType", value = "适用物品类型（1：废纸，2：杂纸（多选用逗号隔开））", required = true, dataType = "String")

    })
    public JsonResult addWeightRule(@RequestBody XzxUserRebateRuleModel model){
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        if(null!=partnerIds&&partnerIds.size()>0){
            model.setPartnerId(partnerIds.get(0));
        }
        List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryWeightRuleList(model);
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("只能添加一个重量返利规则");
        }

        List<XzxRebateRulePrice> rulePriceList = model.getWeightRateList();
        List<String> priceList = new ArrayList<>();
        for (int i = 0; i <rulePriceList.size() ; i++) {
            priceList.add(rulePriceList.get(i).getWeight());
        }
        boolean bool = DateUtil.isSorted(priceList,priceList.size());
        if(!bool){
            return JsonResult.failMessage("重量必须按顺序排列");
        }
        XzxUserRedpaperRule rule = new XzxUserRedpaperRule();
        rule.setStartTime(model.getStartTime());
        rule.setEndTime(model.getEndTime());
        rule.setRuleName("按重量返利规则");
        rule.setCreateTime(sdf.format(new Date()));
        rule.setDelFlag(0);
        rule.setRuleType("5");
        rule.setStatus(model.getStatus());
        rule.setApplicableObject("1");
        rule.setProductType(model.getProductType());
        xzxUserRedpaperRuleService.save(rule);
        if(rule.getId()!=null){
            for (int i = 0; i <rulePriceList.size() ; i++) {
                XzxRebateRulePrice rulePrice = rulePriceList.get(i);
                rulePrice.setCreateTime(sdf1.format(new Date()));
                rulePrice.setRuleId(rule.getId());
                rulePrice.setSort(String.valueOf(i+1));
                xzxRebateRulePriceService.save(rulePrice);
            }
        }
        return new JsonResult().success();
    }

    @PostMapping(MODEL + "/queryWeightOrderList.json")
    @ResponseBody
    @ApiOperation(value="重量返利-下单详情", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "每页条数", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "nickName", value = "用户昵称或手机号", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryWeightOrderList(@RequestBody WeightOrderModel model)
    {
        Map<String,Object> map =xzxUserShareInfoService.queryWeightOrderList(model);
        return JsonResult.success(map);
    }


    @PostMapping(MODEL + "/addRoyaltyRule.json")
    @ResponseBody
    @ApiOperation(value="添加(修改)提成规则", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "royaltyRuleList", value = "提成规则", required = true, dataType = "List<RebateWeightPriceModel>"),
            @ApiImplicitParam(paramType="query", name = "packageId", value = "打包员Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleName", value = "规则名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "productType", value = "3：人工审核,4：自动审核", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "timing", value = "定时执行时间(比如星期一 2点 格式为 1,2)", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleName", value = "规则名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "id", value = "规则主键", required = true, dataType = "String")
    })
    public JsonResult<String> addRoyaltyRule(@RequestBody XzxUserRebateRuleModel model)
    {

        CoreUser user = platformService.getCurrentUser();
        XzxCityPartner partner = cityPartnerService.queryById(user.getId());
        List<XzxUserRedpaperRule> queryList =new ArrayList<>();

        if(null!=partner){
            queryList = xzxUserRedpaperRuleService.queryRoyalRuleList(user.getId()+"",model.getPackageId());
        }else{
            queryList = xzxUserRedpaperRuleService.queryRoyalRuleList(null,model.getPackageId());
        }
        if(queryList!=null&&queryList.size()>0){
            if(null!=model.getId()){


            XzxUserRedpaperRule oldRule = queryList.get(0);

            List<RebateWeightPriceModel> oldItemList = xzxUserShareInfoService.queryOldItemList(oldRule.getId()+"");
            for (RebateWeightPriceModel oldWp:oldItemList) {
                oldWp.setStartTime(oldRule.getStartTime());
                oldWp.setEndTime(model.getStartTime());
            }
            xzxUserShareInfoService.insertPriceHistory(oldItemList);
            xzxUserShareInfoService.deleteByRuleId(oldRule.getId()+"");
            //将老的规则写入历史数据
            XzxUserRedpaperRule rule = new XzxUserRedpaperRule();
            rule.setStartTime(model.getStartTime());
            rule.setEndTime(model.getEndTime());
            rule.setRuleName(model.getRuleName());
            rule.setCreateTime(sdf.format(new Date()));
            rule.setDelFlag(0);
            rule.setRuleType("7");
            rule.setStatus(model.getStatus());
            rule.setApplicableObject("1");
            rule.setProductType(model.getProductType());
            rule.setPackageId(model.getPackageId());
            rule.setPartnerId(user.getId()+"");
            rule.setId(model.getId());
            rule.setTiming(model.getTiming());
            xzxUserRedpaperRuleService.update(rule);
            List<RebateWeightPriceModel> royaltyRuleList = model.getRoyaltyRuleList();
            for (RebateWeightPriceModel model1:royaltyRuleList) {
                model1.setRuleId(oldRule.getId()+"");
                model1.setPackageId(model.getPackageId());
                int count =xzxUserShareInfoService.addRoyaltyRule(model1);
            }
                return JsonResult.success("修改成功！");
            }else {
                return JsonResult.failMessage("不能新增多条规则！");
            }
        }else{
            XzxUserRedpaperRule rule = new XzxUserRedpaperRule();
            rule.setStartTime(model.getStartTime());
            rule.setEndTime(model.getEndTime());
            rule.setRuleName(model.getRuleName());
            rule.setCreateTime(sdf.format(new Date()));
            rule.setDelFlag(0);
            rule.setRuleType("7");
            rule.setStatus(model.getStatus());
            rule.setApplicableObject("1");
            rule.setProductType(model.getProductType());
            rule.setPackageId(model.getPackageId());
            rule.setPartnerId(user.getId()+"");
            rule.setTiming(model.getTiming());
            xzxUserRedpaperRuleService.save(rule);
            List<RebateWeightPriceModel> royaltyRuleList = model.getRoyaltyRuleList();
            for (RebateWeightPriceModel model1:royaltyRuleList) {
                model1.setRuleId(rule.getId()+"");
                model1.setPackageId(model.getPackageId());
                int count =xzxUserShareInfoService.addRoyaltyRule(model1);
            }
            return JsonResult.success("添加成功！");
        }

    }

    @PostMapping(MODEL + "/queryRuleManage.json")
    @ResponseBody
    @ApiOperation(value="提成管理", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "每页条数", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "name", value = "姓名或手机号", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryRoyaltyManage(@RequestBody SettlementModel model)
    {
        Map<String,Object> map =xzxUserShareInfoService.queryRoyaltyManage(model);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/updateRoyaltyRule.json")
    @ResponseBody
    @ApiOperation(value="提成明细批量审核", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "royaltyList", value = "传入id, status 审核状态(1:未审核，2：已审核 3：异常),price审核金额", required = true, dataType = "List<WeightItemPriceModel>"),
            @ApiImplicitParam(paramType="query", name = "royaltyMoney", value = "未结算提成", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "settlementMoney", value = "已结算提成", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "receiver", value = "回收员Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "flag", value = "是否可以人工审核（true,false）", required = true, dataType = "boolean")
    })
    public JsonResult<String> updateRoyaltyRule(@RequestBody SettlementModel model) {
        //判断是否有开启规则
        List<String> rule = xzxUserShareInfoService.queryRuleOpen();
        if(rule.size()==0){
            return JsonResult.failMessage("规则未生效，请重新设置启用后才能结算.");
        }
        int num = xzxUserShareInfoService.updateRoyaltyRule(model);
        if(num>0){
            return JsonResult.success("结算成功！");

        }else if(num==-1){
            return JsonResult.failMessage("合伙人余额不足，结算失败！");
        }else{
            return JsonResult.failMessage("结算失败！");
        }
    }

    @PostMapping(MODEL + "/queryPackageType.json")
    @ResponseBody
    @ApiOperation(value="查询打包站纸类别", notes="test: 仅0有正确返回")
    public JsonResult<Map<String,Object>> queryPackageType() {
        Map<String,Object> map = xzxUserShareInfoService.queryPackageType();
        return JsonResult.success(map);
    }


    @PostMapping(MODEL + "/addCommissionRule.json")
    @ResponseBody
    @ApiOperation(value="提佣规则添加", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "startTime", value = "有效开始时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "有效结束时间", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "status", value = "开关0：关闭，1：正常", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "shareRatio", value = "每笔订单回收流水百分比", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleName", value = "规则名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "applicableObject", value = "指定用户1：全部合伙人", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "issuanceRules", value = "3:系统自动提佣", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleType", value = "规则类型：1：红包规则，2：分享分利规则，3：阶梯返利，5重量返利,7:提成规则，8：提佣规则", required = true, dataType = "String"),
    })
    public JsonResult addCommissionRule(@RequestBody XzxUserRedpaperRuleModel model){
        /*List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryCommissioList();
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("只能添加一个提佣规则");
        }*/
        List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryCommListByTime(model.getStartTime(),model.getEndTime(),null);
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("该时间段内不允许添加提佣规则！");
        }
        BigDecimal shareRatio = new BigDecimal(model.getShareRatio());
        BigDecimal aa = shareRatio.divide(new BigDecimal("100"));
        model.setShareRatio(aa.toString());
        XzxUserRedpaperRule rule = getRedpaperRule(model);
        boolean success = xzxUserRedpaperRuleService.save(rule);
        if (success) {
            return new JsonResult().success();
        } else {
            return JsonResult.failMessage("添加失败");
        }
    }
    @PostMapping(MODEL + "/updateCommissionRule.json")
    @ResponseBody
    @ApiOperation(value="提佣规则修改", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "id", value = "规则Id", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "有效开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "有效结束时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "status", value = "开关0：关闭，1：正常", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "shareRatio", value = "每笔订单回收流水百分比", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleName", value = "规则名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "applicableObject", value = "指定用户1：全部合伙人", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "issuanceRules", value = "3:系统自动提佣", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "ruleType", value = "规则类型：1：红包规则，2：分享分利规则，3：阶梯返利，5重量返利,7:提成规则，8：提佣规则", required = true, dataType = "String"),
    })
    public JsonResult updateCommissionRule(@RequestBody XzxUserRedpaperRuleModel model){
        //List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryCommissioList();
        List<XzxUserRedpaperRule> queryList = xzxUserRedpaperRuleService.queryCommListByTime(model.getStartTime(),model.getEndTime(),model.getId()+"");
        if(queryList!=null&&queryList.size()>0){
            return  JsonResult.failMessage("该时间段内不允许修改提佣规则！");
        }
        XzxUserRedpaperRule oldRule = xzxUserRedpaperRuleService.queryById(model.getId());
        BigDecimal shareRatio = new BigDecimal(model.getShareRatio());
        BigDecimal aa = shareRatio.divide(new BigDecimal("100"));
        model.setShareRatio(aa.toString());
        XzxUserRedpaperRule rule = getRedpaperRule(model);
        boolean success = xzxUserRedpaperRuleService.update(rule);
        if (success) {
            return new JsonResult().success();
        } else {
            return JsonResult.failMessage("添加失败");
        }
    }

    @PostMapping(MODEL + "/queryAccountList.json")
    @ResponseBody
    @ApiOperation(value="提佣规则数据列表", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "条数", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerName", value = "城市合伙人姓名/手机号", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryAccountList(@RequestBody CommissionModel model) {

        Map<String,Object> result = xzxUserRedpaperRuleService.queryAccountList(model);
        return JsonResult.success(result);
    }

    public JsonResult deleteCommissionRule(@RequestBody XzxUserRedpaperRuleModel model) {
        XzxUserRedpaperRule ru = xzxUserRedpaperRuleService.queryById(model.getId());
        //删除原有规则，重新创建规则生成红包
        ru.setDelFlag(1);
        boolean success = xzxUserRedpaperRuleService.update(ru);
        if (success) {
            return new JsonResult().success();
        } else {
            return JsonResult.failMessage("删除失败");
        }
    }
}