package com.ibeetl.admin.console.api;

import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
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.core.entity.*;
import com.ibeetl.admin.core.service.CorePlatformService;
import com.ibeetl.admin.core.web.JsonResult;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.bind.annotation.RestController;

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

/**
 * 售后服务类
 */
@RestController
@Api(value = "合伙人接口")
public class CityPartnerApi {

private static final String MODEL = "/admin/front/cityPartner";
    private final Logger log = LoggerFactory.getLogger(this.getClass());
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    @Autowired
    XzxCityPartnerService service;
    @Autowired
    XzxPartnerFenceService pfService;
    @Autowired
    CorePlatformService platformService;
    @Autowired
    XzxPartnerBankService bankService;
    @Autowired
    XzxPayRequestInfoService payRequestInfoService;
    @Autowired
    CuserConsoleService userService;
    Snowflake snowflake = IdUtil.getSnowflake(0, 3);

    @PostMapping(MODEL + "/getCityPartnerName.json")
    @ResponseBody
    @ApiOperation(value="生成合伙人账号", notes="test: 仅0有正确返回")
    public JsonResult<String> getCityPartnerName(){
        String id="ZH"+snowflake.nextIdStr();
        return JsonResult.success(id);
    }

    private String checkSamePartnerName(XzxCityPartnerModel model,List<AreaModel> areaModelList,String mobile){
        String key = model.getPartnerKeys();
        if(model.getPartnerType().equals("1")){
            if(null==key&&"".equals(model.getPartnerKeys())){
                return " 添加失败，合伙人key不能为空！";
            }
        }
        if(model.getPartnerType().equals("1")) {
            if(null==areaModelList&&areaModelList.size()==0){
                return " 添加失败，合伙人地区不能为空！";
            }
        }
        //判断是否有该合伙人手机号
        if(null!=mobile&&!"".equals(mobile)){
            List<XzxCityPartner> list = service.queryPartnerByMobile(model);
            if(null!=list&&list.size()>0){
                return " 添加失败，手机号码、合伙人或打包站名称不能重复！";
            }
        }
        return null;
    }
    @PostMapping(MODEL + "/addCityPartner.json")
    @ResponseBody
    @ApiOperation(value="添加合伙人", notes="test: 仅0有正确返回")
    public JsonResult<String> addCityPartner(@RequestBody XzxCityPartnerModel model){
        //判断是否有分配key
        List<String> partnerIds1 = service.queryPartnerByCurrent();
        if(null!=partnerIds1&&partnerIds1.size()>0){
            if(model.getPartnerType().equals("1")){
                return JsonResult.failMessage("不允许新建下级合伙人！");

            }
        }
        //不能添加重复区域的合伙人
        if(model.getPartnerType().equals("1")){
            int num = service.queryPartnerGaode(model.getAreaList());
            if(num>0){
                return JsonResult.failMessage("该区域已经存在合伙人！");

            }
        }
           List<AreaModel> areaModelList = model.getAreaList();
           String mobile = model.getMobilePhone();
           String res = checkSamePartnerName(model,areaModelList,mobile);
           if(null!=res){
               return JsonResult.failMessage(res);
           }
        model.setDelFlag(0);
        model.setCreateTime(sdf.format(new Date()));
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        XzxCityPartner info = objectMapper.convertValue(model, XzxCityPartner.class);
        info.setDelFlag(0);
        Snowflake snowflake1 = IdUtil.getSnowflake(1, 3);
        String userId = "USER"+snowflake1.nextIdStr();
        info.setUserId(userId);
        if(model.getPartnerType().equals("1")){
            if(null==info.getOrgId()){
                info.setOrgId(Long.parseLong("9"));
            }
            info.setState("S1");
        }else{
            if(null==info.getOrgId()){
                info.setOrgId(Long.parseLong("16"));
            }
            info.setState("S1");
            //判断是否合伙人登陆
            List<String> partnerIds = service.queryPartnerByCurrent();
            if(null!=partnerIds&&partnerIds.size()>0){
                info.setPackingStation(partnerIds.get(0));
            }else{
                //根据区域查询合伙人Id
                String townName = model.getTownName();
                String townIdPackage = service.queryAreaTownList(townName);
                String packingStation = service.queryGaodeByTownId(townIdPackage);
                info.setPackingStation(packingStation);
            }
        }
        if(service.save(info)){
            //创建服务
            if(model.getPartnerType().equals("1")){
                String result = service.createServiceByKey(info);
                String partnerId = service.queryCityPartnerByPhone(mobile);
                insertGaodeTown(areaModelList,partnerId,model.getPartnerKeys());
                info.setId(Long.parseLong(partnerId));
                insertUserOther(info,userId);
                pfService.addAccountInfo(info.getMobilePhone(),userId,model.getAccountNo(),info.getId(),model.getRoleId(),info.getOrgId());

            }else{
                areaModelList = new ArrayList<>();
                String cityPackage = model.getCityName();
                String cityIdPackage = service.queryAreaCityList(cityPackage);
                AreaModel areaModel = new AreaModel();
                areaModel.setCityId(Long.parseLong(cityIdPackage));
                areaModel.setCityName(cityPackage);
                areaModel.setProvinceName(model.getProvinceName());
                areaModel.setTownName(model.getTownName());
                areaModelList.add(areaModel);
                insertGaodeTown(areaModelList,info.getId()+"",info.getId()+"");
                insertUserOtherPackage(info,userId,cityPackage,cityIdPackage);
                pfService.addAccountByPackage(info.getMobilePhone(),userId,model.getAccountNo(),info.getId(),model.getRoleId());
            }
             return JsonResult.success("添加成功！");
        }else{
            return JsonResult.failMessage("添加合伙人失败！");
        }
    }

    private void insertGaodeTown(List<AreaModel> areaModelList,String partnerId,String key){
        List<PartnerGaodeModel>  townCodeList = new ArrayList<>();

        for (AreaModel area:areaModelList) {
            String city = area.getCityName();
            String cityId = service.queryAreaCityList(city);
                String cityPackage = area.getCityName();
                String cityIdPackage = service.queryAreaCityList(cityPackage);
                String provinceName = area.getProvinceName();
                String townName = area.getTownName();
                String townIdPackage = service.queryAreaTownList(townName);
                PartnerGaodeModel gaodeModel = new PartnerGaodeModel();
                gaodeModel.setCityId(cityIdPackage);
                if(null!=townName&&!"".equals(townName)){
                    gaodeModel.setAddressArea(provinceName+","+cityPackage+","+townName);
                }else{
                    gaodeModel.setAddressArea(provinceName+","+cityPackage);

                }
                gaodeModel.setTownId(townIdPackage);
                gaodeModel.setCityId(cityId);
                gaodeModel.setCreateTime(sdf.format(new Date()));
                gaodeModel.setPartnerId(partnerId);
                gaodeModel.setPartnerKey(key);
                gaodeModel.setDelFlag("0");
                townCodeList.add(gaodeModel);
        }
            service.insertGaodeInfo(townCodeList);

    }

    private void insertUserOtherPackage(XzxCityPartner info,String userId,String city,String cityId){
        UserModel otherInfo = new UserModel();
        otherInfo.setName(info.getPartnerName());
        otherInfo.setDelFlag("0");
        otherInfo.setMobilePhone(info.getMobilePhone());
        otherInfo.setLoginAccount(userId);
        otherInfo.setRoleIds("6");
        otherInfo.setUserType("7");
        otherInfo.setCityId(cityId);
        otherInfo.setUserId(userId);
        String salt = DateUtil.getRandomNickname(16);
        otherInfo.setSalt(salt);
        String pass = DateUtil.encrypt(salt,"888888");
        otherInfo.setPassword(pass);
        otherInfo.setRegistTime(sdf.format(new Date()));
        otherInfo.setIsProhibit("0");
       /* if(null!=info.getPackingStation()&&!"".equals(info.getPackingStation())){
            otherInfo.setPartnerId(info.getPackingStation());

        }else{*/
            otherInfo.setPartnerId(info.getId()+"");
        //}

        otherInfo.setAvatar("https://res.cnxzx.com/resource/static/img/icon-loadlogo.png");
        userService.insertUserOtherInfo(otherInfo);

    }
    private void insertUserOther(XzxCityPartner info,String userId){
        UserModel otherInfo = new UserModel();
        otherInfo.setName(info.getPartnerName());
        otherInfo.setDelFlag("0");
        otherInfo.setMobilePhone(info.getMobilePhone());
        otherInfo.setLoginAccount(userId);
        otherInfo.setRoleIds("3");
        otherInfo.setUserType("5");
        otherInfo.setUserId(userId);
        String salt = DateUtil.getRandomNickname(16);
        otherInfo.setSalt(salt);
        String pass = DateUtil.encrypt(salt,info.getPassword());
        otherInfo.setPassword(pass);
        otherInfo.setRegistTime(sdf.format(new Date()));
        otherInfo.setIsProhibit("0");
        otherInfo.setPartnerId(info.getId()+"");
        userService.insertUserOtherInfo(otherInfo);
    }

    @PostMapping(MODEL + "/queryCityPartnerForOtherUser.json")
    @ResponseBody
    @ApiOperation(value="查询合伙人所有回收员和推广员接口", notes="test: 仅0有正确返回")
    public JsonResult<Map<String, Object>> queryCityPartnerForOtherUser(){
        Map<String, Object> map =  service.queryCityPartnerForOtherUser();
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/queryCityPartner.do")
    @ResponseBody
    @ApiOperation(value="查询合伙人列表(打包站列表 参数看partnerType)", 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 = "prohibit", value = "是否禁用（1：禁用，0：启用）", required = true, dataType = "Integer"),
            @ApiImplicitParam(paramType="query", name = "partnerType", value = "合伙类型（1：合伙人。2：打包站）", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "packingStation", value = "打包站名称", required = true, dataType = "String")

    })
    public JsonResult<Map<String, Object>> queryCityPartner(@RequestBody XzxCityPartnerModel model){
        Map<String, Object> map =  service.queryCityPartner(model);
        return JsonResult.success(map);
    }
    @PostMapping(MODEL + "/queryPartnerAccount.json")
    @ResponseBody
    @ApiOperation(value="查询合伙人账户余额", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "id", value = "合伙人ID(如果不传，需要合伙人登陆)", required = true, dataType = "String"),
    })
    public JsonResult<Map<String,Object>> queryPartnerAccount(@RequestBody XzxCityPartnerModel model){
          Map<String,Object> map = new HashMap<>();

          if(null!=model){
              if(null!=model.getId()&&!"".equals(model.getId())){
                  map=service.queryPartnerAccount(model.getId());
              }else{
                  CoreUser user = platformService.getCurrentUser();
                  if(user.getId()==1){
                      return JsonResult.success(map);
                  }else{
                      CoreUser user1 = service.queryPartnerAdmin(user.getId());
                      if(user1!=null){
                          return JsonResult.success(map);
                      }
                  }
                  XzxCityPartner partner = service.queryById(user.getId());
                  if(null!=partner){
                      map=service.queryPartnerAccount(partner.getUserId());
                  }else{
                      return JsonResult.success(map);
                  }

              }
          }else{
              CoreUser user = platformService.getCurrentUser();
              if(user.getId()==1){
                  return JsonResult.success(map);
              }else{
                  user = service.queryPartnerAdmin(user.getId());
                  if(user!=null){
                      return JsonResult.success(map);
                  }
              }
              map=service.queryPartnerAccount(user.getId().toString());
          }
          return JsonResult.success(map);
    }


    @PostMapping(MODEL + "/updateCityPartner.json")
    @ResponseBody
    @ApiOperation(value="修改合伙人", notes="test: 仅0有正确返回")
    public JsonResult<String> updateCityPartner(@RequestBody XzxCityPartnerModel model){
        //判断是否有分配key
        String key = model.getPartnerKeys();
        if(model.getPartnerType().equals("1")){
            if(null==key&&"".equals(model.getPartnerKeys())){
                return JsonResult.failMessage(" 修改失败，合伙人key不能为空！");
            }
        }

        List<AreaModel> areaModelList = model.getAreaList();
        if(model.getPartnerType().equals("1")) {
            if(null==areaModelList&&areaModelList.size()==0){
                return JsonResult.failMessage(" 添加失败，合伙人地区不能为空！");
            }
        }

        model.setDelFlag(0);
        model.setCreateTime(sdf.format(new Date()));
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        XzxCityPartner info = objectMapper.convertValue(model, XzxCityPartner.class);
        info.setPartnerKey(key);
        if(model.getPartnerType().equals("1")){
            if(null==info.getOrgId()){
                info.setOrgId(Long.parseLong("9"));
            }
            info.setState("S1");
        }else{
            if(null==info.getOrgId()){
                info.setOrgId(Long.parseLong("16"));
            }
            info.setState("S1");
        }
        if(service.update(info)){
            //删除合伙人原有区域
            service.deletePartnerTownCode(info.getId()+"");
            if(info.getPartnerType().equals("1")){
                String result = service.createServiceByKey(info);
            }
            insertGaodeTown(areaModelList,info.getId()+"",model.getPartnerKeys());
            return JsonResult.success("修改成功！");
        }else{
            return JsonResult.failMessage("修改合伙人失败！");
        }
    }

    @PostMapping(MODEL + "/queryAllPartnerList.do")
    @ResponseBody
    @ApiOperation(value="查询合伙人和打包站列表", notes="test: 仅0有正确返回")
    public JsonResult<List<XzxCityPartner>> queryAllPartnerList(){
        CoreUser user = platformService.getCurrentUser();
        List<XzxCityPartner> cityPartners = new ArrayList<>();
        if(user.getId()==1){
            cityPartners = service.queryAllCityPartnerList(null);
        }else{
            CoreUser user1 = service.queryPartnerAdmin(user.getId());
            if(user1!=null){
                cityPartners = service.queryAllCityPartnerList(null);
            }else{
                cityPartners = service.queryAllCityPartnerList(user.getId()+"");
                /*XzxCityPartner partner = service.queryById(user.getId());
                cityPartners.add(partner);*/
            }
        }
        return JsonResult.success(cityPartners);
    }


    @PostMapping(MODEL + "/queryDetailsPresentation.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 = "payType", value = "费用类型(1:充值,2:环保金支出,3环保金收入,4提现5现金收入 6现金支出 10分享返利 11阶梯返利 12红包)", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "payStatus", value = "状态(1为待支付,2为已支付,3为已审核,4为已提现）", required = true, dataType = "Integer")
    })
    public JsonResult<Map<String, Object>> queryDetailsPresentation(@RequestBody PartnerPayMsgModel model){
        CoreUser user = platformService.getCurrentUser();
        if(user.getId()==1){
            //return JsonResult.success(new HashMap<>());
        }else{
            CoreUser user1 = service.queryPartnerAdmin(user.getId());
            if(user1!=null){

            }else{
                XzxCityPartner partner = service.queryById(user.getId());
                if(null!=partner){
                    model.setUserId(partner.getUserId());
                }
            }
        }

        Map<String, Object> map =  service.queryDetailsPresentation(model);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/queryAreaLongiLati.json")
    @ResponseBody
    @ApiOperation(value="根据地区名称查询经纬度", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="name", value = "地区名称", required = true, dataType = "String")
    })
    public JsonResult<AreaModel> queryAreaLongiLati(@RequestBody AreaModel model){
        AreaModel map = service.queryAreaLongiLati(model);
        return JsonResult.success(map);
    }


    @PostMapping(MODEL + "/addPayInfoImg.json")
    @ResponseBody
    @ApiOperation(value="添加合伙人充值汇款凭证接口", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
             @ApiImplicitParam(paramType="query", name ="payImg", value = "凭证图片路径", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "money", value = "汇款金额", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "payType", value = "汇款用途（1）", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "payTime", value = "充值时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "rechargeName", value = "汇款人姓名", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "rechargePhone", value = "汇款人手机号码", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "company", value = "收款单位", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "companyAccount", value = "收款账号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "bankName", value = "收款单位开户行", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerType", value = "角色类型（1：合伙人。2：打包站）", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "status", value = "0：保存，5：上传审核", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerId", value = "合伙人，打包站Id", required = true, dataType = "String")

    })
    public JsonResult<String> addPayInfoImg(@RequestBody PayInfoModel model){
        CoreUser user = platformService.getCurrentUser();
        String result = service.addPayInfoImg(model);
        if(result.equals("0")){
            return JsonResult.failMessage("添加汇款记录失败!");
        }else{
            return JsonResult.success(result);
        }
    }

    @PostMapping(MODEL + "/updatePayInfoPass.json")
    @ResponseBody
    @ApiOperation(value="后台合伙人充值审核接口", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="payOrderId", value = "充值Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "createUserId", value = "充值用户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "status", value = "支付状态(1为待支付,2为已支付,3为已审核,4为已提现，5待审核,6为审核不通过)", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "unpassReason", value = "审核不通过原因", required = true, dataType = "String")
    })
    public JsonResult<String> updatePayInfoPass(@RequestBody PayInfoModel model){
            String result = service.updatePayInfoPass(model);
            return JsonResult.success(result);
    }

    private String checkPackageProhibit(XzxCityPartnerModel model){
        //判断是否合伙人身份
        CoreUser user = platformService.getCurrentUser();
        XzxCityPartner partner = service.queryById(user.getId());
        if(null!=partner){
               //查询打包站账户余额是否为0
               String hbb = service.queryAccountByPartnerId(partner.getUserId());
               BigDecimal m = new BigDecimal(hbb);
               if(m.compareTo(BigDecimal.ZERO)==1){
                   return "打包站账户余额不为零，无法关闭打包站！";
               }
        }
        return null;
    }
    @PostMapping(MODEL + "/updatePartnerProhibit.json")
    @ResponseBody
    @ApiOperation(value="后台合伙人是否启用接口", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="id", value = "合伙人Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "prohibit", value = "是否启用", required = true, dataType = "String")
    })
    public JsonResult<String> updatePartnerProhibit(@RequestBody XzxCityPartnerModel model){
        XzxCityPartner info=service.queryById(model.getId());
        String msg = checkPackageProhibit(model);
        if(null!=msg){
            return JsonResult.failMessage(msg);
        }
        info.setProhibit(model.getProhibit());
        info.setUpdateTime(sdf.format(new Date()));
        service.update(info);
        userService.updateOtherUserById(info.getId()+"");
        return JsonResult.success("修改成功");
    }

    @PostMapping(MODEL + "/queryPartnerFenceList.do")
    @ResponseBody
    @ApiOperation(value="新增合伙人-查询所有未绑定的电子围栏", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="id", value = "合伙人Id", required = true, dataType = "String")
    })
    public JsonResult<List<XzxElectronicFenceModel>> queryPartnerFenceList(@RequestBody XzxCityPartnerModel model){
        List<XzxElectronicFenceModel> list =  service.queryPartnerFenceList(model);
        return JsonResult.success(list);
    }

    @PostMapping(MODEL + "/queryPartnerFenceListByUser.do")
    @ResponseBody
    @ApiOperation(value="回收员绑定的电子围栏", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="id", value = "合伙人Id", required = true, dataType = "String")
    })
    public JsonResult<List<XzxElectronicFenceModel>> queryPartnerFenceListByUser(@RequestBody XzxCityPartnerModel model){
        List<XzxElectronicFenceModel> list =  service.queryPartnerFenceListByUser(model);
        return JsonResult.success(list);
    }


    @PostMapping(MODEL + "/deleteBankCard.json")
    @ResponseBody
    @ApiOperation(value="删除合伙人银行账户信息", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="id", value = "银行卡Id主键", required = true, dataType = "int")
    })
    public JsonResult<String> deleteBankCard(@RequestBody XzxPartnerBankModel model){
        CoreUser user = platformService.getCurrentUser();
        if(user.getId()==1){
            return JsonResult.failMessage("超管不能删除合伙人银行账户信息！");
        }
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        XzxPartnerBank bank = objectMapper.convertValue(model, XzxPartnerBank.class);
        bank = bankService.queryById(bank.getId());
        bank.setDelFlag("1");
        bank.setUpdateTime(sdf.format(new Date()));

            if(!bankService.update(bank)){
                return JsonResult.failMessage("删除失败");
            }else{
                return  JsonResult.success("删除成功");
            }

    }

    @PostMapping(MODEL + "/updateBankCard.json")
    @ResponseBody
    @ApiOperation(value="修改合伙人银行账户信息", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="id", value = "银行卡Id主键", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name ="bankNo", value = "银行账号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "bankName", value = "银行名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "openName", value = "开户人名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "idCard", value = "证件号码", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "mobilePhone", value = "预留手机号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerId", value = "合伙人Id", required = true, dataType = "String")
    })
    public JsonResult<String> updateBankCard(@RequestBody XzxPartnerBankModel model){
        CoreUser user = platformService.getCurrentUser();
        if(user.getId()==1){
            return JsonResult.failMessage("超管不能修改合伙人银行账户信息！");
        }
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        XzxPartnerBank bank = objectMapper.convertValue(model, XzxPartnerBank.class);
        bank.setDelFlag("0");
        bank.setUpdateTime(sdf.format(new Date()));
        //CoreUser user = platformService.getCurrentUser();
        bank.setPartnerId(user.getId()+"");
        //银行账号相同，直接返回失败
        String oldBankNo =bankService.queryByBankNo(bank.getBankNo(),model.getId()+"");
        if(null!=oldBankNo&&!"".equals(oldBankNo)){
            return JsonResult.failMessage("银行账号不能相同！");
        }else{
            if(!bankService.update(bank)){
                return JsonResult.failMessage("修改失败");
            }else{
                return  JsonResult.success("修改成功");
            }
        }
    }

    @PostMapping(MODEL + "/addBankCard.json")
    @ResponseBody
    @ApiOperation(value="添加合伙人银行账户信息", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="bankNo", value = "银行账号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "bankName", value = "银行名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "openName", value = "开户人名称", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "idCard", value = "证件号码", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "mobilePhone", value = "预留手机号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerId", value = "合伙人Id", required = true, dataType = "String")
    })
    public JsonResult<String> addBankCard(@RequestBody XzxPartnerBankModel model){
        CoreUser user = platformService.getCurrentUser();
        if(user.getId()==1){
            return JsonResult.failMessage("超管不能添加合伙人银行账户信息！");
        }
        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
        XzxPartnerBank bank = objectMapper.convertValue(model, XzxPartnerBank.class);
        bank.setDelFlag("0");
        bank.setCreateTime(sdf.format(new Date()));
        //CoreUser user = platformService.getCurrentUser();
        bank.setPartnerId(user.getId()+"");
        //银行账号相同，直接返回失败
        String oldBankNo =bankService.queryByBankNo(bank.getBankNo(),null);
        if(null!=oldBankNo&&!"".equals(oldBankNo)){
            return JsonResult.failMessage("银行账号不能相同！");
        }else{
            if(!bankService.save(bank)){
                return JsonResult.failMessage("保存失败");
            }else{
                return  JsonResult.success("保存成功");
            }
        }
    }

    @PostMapping(MODEL + "/addPayRequestInfo.json")
    @ResponseBody
    @ApiOperation(value="添加合伙人提现申请", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="money", value = "提现金额", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name ="bankAccountId", value = "银行账号Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name ="accountMoney", value = "账户余额", required = true, dataType = "String")
    })
    public JsonResult<String> addPayRequestInfo(@RequestBody PayRequestInfoModel model){
        CoreUser user = platformService.getCurrentUser();
        if(user.getId()==1){
            return JsonResult.failMessage("超管不能添加合伙人提现申请！");
        }
        BigDecimal decimal = new BigDecimal("0");
        decimal = new BigDecimal(model.getMoney()).subtract(new BigDecimal(model.getAccountMoney()));
        if(decimal.compareTo(BigDecimal.ZERO)==1){
            return JsonResult.failMessage("账号余额不能小于提现金额");
        }else{
            //单笔限额小于1万元
            BigDecimal flagAmount = new BigDecimal(model.getMoney()).subtract(new BigDecimal("10000"));
            if(flagAmount.compareTo(BigDecimal.ZERO)==1){
                return JsonResult.failMessage("单笔提现额度必须小于1万元");
            }
            //CoreUser user = platformService.getCurrentUser();
            XzxCityPartner partner = service.queryById(user.getId());

            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
            XzxPayRequestInfo info = objectMapper.convertValue(model, XzxPayRequestInfo.class);
            //UserAccountModel accountModel=service.queryPartnerAccountByUserId(partner.getUserId());
            info.setAccountId(model.getBankAccountId());
            info.setAccountBindId(Long.parseLong(model.getBankAccountId()));
            info.setCreateTime(sdf.format(new Date()));
            info.setCreateUserId(partner.getUserId());
            info.setPayType("4");
            info.setStatus("1");
            info.setPayFlag(1);
            Snowflake snowflake = IdUtil.getSnowflake(0, 3);
            String payOrderId = "ZF"+snowflake.nextIdStr();
            info.setPayOrderId(payOrderId);
            if(payRequestInfoService.insertPayRequestInfo(info)>0){
                return JsonResult.success("保存成功");
            }else{
                return JsonResult.failMessage("保存失败");
            }

        }
    }

    @PostMapping(MODEL + "/queryBankCard.json")
    @ResponseBody
    @ApiOperation(value="查询银行账户信息", notes="test: 仅0有正确返回")
    public JsonResult<List<XzxPartnerBankModel>> queryBankCard(@RequestBody XzxPartnerBankModel model){
        List<XzxPartnerBankModel> list = bankService.queryByBankList();
        return JsonResult.success(list);
    }

    @PostMapping(MODEL + "/queryBankCardById.json")
    @ResponseBody
    @ApiOperation(value="查询审批信息", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="payOrderId", value = "提现申请id", required = true, dataType = "String")
    })
    public JsonResult<XzxPartnerBankModel> queryBankCardById(@RequestBody XzxPartnerBankModel model){
        XzxPartnerBankModel obj = bankService.queryBankCardById(model);
        return JsonResult.success(obj);
    }

    @PostMapping(MODEL + "/queryGaodeByUserId.json")
    @ResponseBody
    @ApiOperation(value="查询轨迹接口", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="userId", value = "用户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name ="orderId", value = "订单Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name ="dayTime", value = "日期", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name ="dateTime", value = "时间段", required = true, dataType = "String")

    })
    public JsonResult<List<Map<String,Object>>> queryGaodeByUserId(@RequestBody XzxCityPartnerModel model){

        List<Map<String,Object>> list =  service.queryGaodeByUserId(model);
        return JsonResult.success(list);
    }


    @PostMapping(MODEL + "/queryOrderByHsy.json")
    @ResponseBody
    @ApiOperation(value="查询回收员所有订单", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="userId", value = "用户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name ="dayTime", value = "日期", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String")
    })
    public JsonResult<List<Map<String,String>>> queryOrderByHsy(@RequestBody XzxCityPartnerModel model){

        List<Map<String,String>> list =  service.queryOrderByHsy(model);
        return JsonResult.success(list);
    }

    @PostMapping(MODEL + "/queryPartnerAccountLog.json")
    @ResponseBody
    @ApiOperation(value="后台账户资金流转接口", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="approverStatus", value = "审核状态(1为待审核,2为已审核,3为审核不通过)", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "数量", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "type", value = "类型", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "startTime", value = "开始时间", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "endTime", value = "结束时间", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryPartnerAccountLog(@RequestBody PartnerAccountLogModel model){
        Map<String,Object> map = service.queryPartnerAccountLog(model);
        return JsonResult.success(map);
    }


    @PostMapping(MODEL + "/queryUserAccountLog.json")
    @ResponseBody
    @ApiOperation(value="账户管理优化", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="szType", value = "收支类型（空为全部，1：收2：支出）", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "page", value = "页码", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "limit", value = "数量", required = true, dataType = "int"),
            @ApiImplicitParam(paramType="query", name = "channelType", value = "操作渠道1：充值 2：提现 3：回收 4入库 5红包 6分享返利 7重量达标返利8额度申请 9 额度恢复 10 推广返利 11垫付合伙人", 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 = "userName", value = "姓名手机号", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "roleType", value = "角色类型", required = true, dataType = "int")

    })
    public JsonResult<Map<String,Object>> queryUserAccountLog(@RequestBody AccountLogModel model){
        Map<String,Object> map = service.queryUserAccountLog(model);
        return JsonResult.success(map);
    }
    @PostMapping(MODEL + "/queryPartnerCityById.json")
    @ResponseBody
    @ApiOperation(value="账户管理优化（查询回收人所属城市）", notes="test: 仅0有正确返回")
    public JsonResult<Map<String,Object>> queryPartnerCityById(){
        CoreUser currentUser = platformService.getCurrentUser();
        XzxCityPartner partner = service.queryById(currentUser.getId());
        List<Map<String,String>> list = service.queryPartnerCityById(partner);
        Map<String,Object> map = new HashMap<>();
        map.put("data",list);
        map.put("code",0);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/queryAreaObj.json")
    @ResponseBody
    @ApiOperation(value="账户管理优化（查询回收人所属城市）", notes="test: 仅0有正确返回")
    public JsonResult<Map<String,Object>> queryAreaObj(){
        CoreUser currentUser = platformService.getCurrentUser();
        XzxCityPartner partner = service.queryById(currentUser.getId());
        List<Map<String,Object>> list = service.queryAreaObj(partner);
        Map<String,Object> map = new HashMap<>();
        map.put("data",list);
        map.put("code",0);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/queryPartnerName.json")
    @ResponseBody
    @ApiOperation(value="查询合伙人姓名", notes="test: 仅0有正确返回")
    public JsonResult<Map<String,Object>> queryPartnerName(){
        List<String> partnerIds = service.queryPartnerByCurrent();
        List<XzxCityPartner> list = service.queryPartnerName(partnerIds);
        Map<String,Object> map = new HashMap<>();
        map.put("data",list);
        map.put("code",0);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/queryAccountMoney.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 = "isProhibit", value = "冻结状态", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "roleType", value = "角色Type", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "partnerId", value = "合伙人ID", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "userName", value = "姓名手机号", required = true, dataType = "String")
    })
    public JsonResult<Map<String,Object>> queryAccountMoney(@RequestBody AccountMoneyModel model){

        List<String> partnerIds = service.queryPartnerByCurrent();
        if(null!=model.getPartnerId()&&!"".equals(model.getPartnerId())){
            if(null==partnerIds){
                partnerIds= new ArrayList<>();
            }
            partnerIds.add(model.getPartnerId());
        }
        List<UserModel> userIds = new ArrayList<>();
        List<String> allUserIds = new ArrayList<>();
        if(null!=partnerIds&&!"".equals(partnerIds)){
            //查询合伙人所有打包站的Id
            if(null!=model.getRoleType()&&!"".equals(model.getRoleType())){
                if(model.getRoleType().equals("1")){
                    List<String> townIds = service.queryTownIdsByPartnerId(partnerIds.get(0));
                    model.setTownIds(townIds);
                     userIds = service.queryUserNormal(model);
                }else{
                    List<String> packageStationList = service.queryPackageIdList(partnerIds.get(0));
                    userIds = service.queryOtherUserByPid(partnerIds.get(0),model,packageStationList);
                }
            }else{
                List<String> packageStationList = service.queryPackageIdList(partnerIds.get(0));
                userIds = service.queryOtherUserByPid(partnerIds.get(0),model,packageStationList);
                //查询合伙人区域列表
                List<String> townIds = service.queryTownIdsByPartnerId(partnerIds.get(0));
                model.setTownIds(townIds);
                List<UserModel> nomalUserIds = service.queryUserNormal(model);
                userIds.addAll(nomalUserIds);
            }

        }else{
            if(null!=model.getRoleType()&&!"".equals(model.getRoleType())){
                if(model.getRoleType().equals("1")){
                    userIds = service.queryUserNormal(model);
                }else{
                    userIds = service.queryOtherUserByPid(null,model,null);
                }
            }else{
                if(null!=model.getUserName()&&!"".equals(model.getUserName())){
                    userIds = service.queryUserNormal(model);
                }
            }
        }

        List<String> uid = new ArrayList<>();
        if(null!=userIds&&userIds.size()>0){
            for (UserModel mm:userIds) {
                uid.add(mm.getUserId());
            }
        }else{
            if(model.getRoleType().equals("8")){
                uid.add("0");
            }else{
                uid = null;
            }

        }

        model.setUserIds(uid);

        List<AccountMoneyModel> list = service.queryAccountByUserIds(model);
        Map<String,Object> map = new HashMap<>();
        map.put("data",list);
        map.put("count",service.queryAccountByUserIdsCount(model));
        map.put("code",0);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/updateAccountLimit.json")
    @ResponseBody
    @ApiOperation(value="调整额度", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="accountId", value = "账户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "fixedLimit", value = "固定额度", required = true, dataType = "int")
    })
    public JsonResult<String> updateAccountLimit(@RequestBody AccountMoneyModel model){
        int num = service.updateAccountLimit(model);
        if(num>0){
            return JsonResult.success("修改成功！");
        }else if(num==-1) {
            return JsonResult.failMessage("可用额度不足，调额失败！");
        }else{
                return JsonResult.failMessage("额度必须由合伙人修改，所以修改失败！");
        }


    }

    @PostMapping(MODEL + "/queryPackageByPartner.json")
    @ResponseBody
    @ApiOperation(value="查询打包站", notes="test: 仅0有正确返回")
    public JsonResult<Map<String,Object>> queryPackageByPartner(){
        List<String> partnerIds = service.queryPartnerByCurrent();
        List<XzxCityPartner> list = service.queryPackageByPartner(partnerIds);
        Map<String,Object> map = new HashMap<>();
        map.put("data",list);
        map.put("code",0);
        return JsonResult.success(map);
    }

    @PostMapping(MODEL + "/updateAccountType.json")
    @ResponseBody
    @ApiOperation(value="修改账户冻结状态", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name ="accountId", value = "账户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "isProhibit", value = "冻结状态 0：未冻结，1：冻结", required = true, dataType = "int")
    })
    public JsonResult<String> updateAccountType(@RequestBody AccountMoneyModel model){
        int num = service.updateAccountType(model);
        if(num>0){
            return JsonResult.success("修改成功");
        }else{
            return JsonResult.success("修改失败");
        }
    }
}