package com.xzx.gc.pay.controller;


import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.convert.Convert;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.lang.Validator;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.StrUtil;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.xzx.gc.common.Result;
import com.xzx.gc.common.constant.CommonEnum;
import com.xzx.gc.common.constant.Constants;
import com.xzx.gc.common.constant.OrderEnum;
import com.xzx.gc.common.constant.PayEnum;
import com.xzx.gc.common.dto.CommonDto;
import com.xzx.gc.common.dto.SimplePage;
import com.xzx.gc.common.dto.log.OperationAppLog;
import com.xzx.gc.common.request.BaseController;
import com.xzx.gc.common.utils.BusinessUtil;
import com.xzx.gc.entity.*;
import com.xzx.gc.model.JsonResult;
import com.xzx.gc.model.admin.*;
import com.xzx.gc.model.pay.MoneyAuditDto;
import com.xzx.gc.model.pay.RkLimitDto;
import com.xzx.gc.model.pay.RkWalletDto;
import com.xzx.gc.pay.dto.SelectByAreaDto;
import com.xzx.gc.pay.mapper.CoreUserMapper;
import com.xzx.gc.pay.mapper.OrderStorageInfoMapper;
import com.xzx.gc.pay.mapper.PayRequestMapper;
import com.xzx.gc.pay.service.*;
import com.xzx.gc.util.SessionUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import tk.mybatis.mapper.entity.Example;

import javax.servlet.http.HttpServletRequest;
import java.math.BigDecimal;
import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@Api(tags = "充值等审核管理")
@RestController
@Validated
@Slf4j
public class PayRequestController extends BaseController {

    @Autowired
    private PayRequestMapper payRequestMapper;

    @Autowired
    private UserService userService;

    @Autowired
    private SessionUtil sessionUtil;

    @Autowired
    private OtherUserService otherUserService;

    @Autowired
    private PayRequestService payRequestService;

    @Autowired
    private CityPartnerService cityPartnerService;

    @Autowired
    private CoreUserMapper coreUserMapper;

    @Autowired
    private AccountService accountService;

    @Autowired
    private BusinessUtil businessUtil;

    @Autowired
    private OrderStorageInfoMapper orderStorageInfoMapper;

    @ApiOperation(value = "根据类型查看")
    @PostMapping("/payRequest/limit/find")
    public Result limitAdd(HttpServletRequest request,@RequestBody CommonDto commonDto){
        Result result=new Result();
        String extra = commonDto.getExtra();
        Validator.validateNotEmpty(extra,"申请类型不能为空");
        PayRequestInfo payRequestInfo=new PayRequestInfo();
        payRequestInfo.setCreateUserId(getUserId(request));
        payRequestInfo.setPayType(extra);
        List<PayRequestInfo> list = payRequestMapper.select(payRequestInfo);
        if(CollUtil.isNotEmpty(list)){
            List<PayRequestInfo> list2 = list.stream().sorted(Comparator.comparing(PayRequestInfo::getCreateTime).reversed()).collect(Collectors.toList());
            PayRequestInfo select=list2.get(0);
            if(PayEnum.待审核.getValue().equals(select.getStatus())){
                result.setCode(-4);
                result.setMsg("您还有待审核的申请");
            }else if(PayEnum.审核不通过.getValue().equals(select.getStatus())){
                result.setCode(-5);
                result.setMsg(select.getUnpassReason());
            }
        }
        return result;
    }


    @ApiOperation(value = "分页查询某个地区的用户的提现列表",notes = "查询市下面的用户则只需要传cityId")
    @PostMapping("/payRequest/selectByArea")
    public Result<PageInfo<UserInfo>> selectByArea(HttpServletRequest request,@RequestBody SelectByAreaDto selectByAreaDto){

        if(StrUtil.isNotBlank(selectByAreaDto.getStartDate())){
            selectByAreaDto.setStartDate(selectByAreaDto.getStartDate()+" 00:00:00");
        }
        if(StrUtil.isNotBlank(selectByAreaDto.getEndDate())){
            selectByAreaDto.setEndDate(selectByAreaDto.getEndDate()+" 00:00:00");
        }

        PageHelper.startPage(selectByAreaDto.getPageNo(),selectByAreaDto.getPageSize());
        List<UserInfo> list = payRequestMapper.selectByArea(selectByAreaDto);
        PageInfo<UserInfo> pageInfo=new PageInfo<>(list);
        return Result.success(pageInfo);
    }

    @ApiOperation(value = "分页查询某个用户的提现明细",notes = "id传用户id")
    @PostMapping("/payRequest/selectDetailByUser")
    public Result<PageInfo<PayRequestInfo>> selectDetailByUser(HttpServletRequest request,@RequestBody SimplePage simplePage){
        String userId = simplePage.getId();
        PageHelper.startPage(simplePage.getPageNo(),simplePage.getPageSize());
        Example example=new Example(PayRequestInfo.class);
        Example.Criteria criteria = example.createCriteria();
        criteria.andEqualTo("createUserId",userId);
        criteria.andEqualTo("status",PayEnum.已审核完成.getValue());
        criteria.andEqualTo("payType",PayEnum.提现.getValue());
        example.setOrderByClause("create_time desc");
        List<PayRequestInfo> list = payRequestMapper.selectByExample(example);
        if(CollUtil.isNotEmpty(list)){
            for (PayRequestInfo payRequestInfo : list) {
                String createUserId = payRequestInfo.getCreateUserId();
                UserInfo byId = userService.findById(createUserId);
                if(byId!=null){
                    payRequestInfo.setMobilePhone(byId.getMobilePhone());
                    payRequestInfo.setUserName(byId.getNickName());
                    payRequestInfo.setUserType("1");
                }else{
                    //
                    OtherUserInfo byId1 = otherUserService.findById(createUserId);
                    if(byId1!=null){
                        payRequestInfo.setUserType("2");
                        payRequestInfo.setMobilePhone(byId1.getMobilePhone());
                        payRequestInfo.setUserName(byId1.getName());
                    }

                }
            }
        }
        PageInfo<PayRequestInfo> pageInfo=new PageInfo<>(list);
        return Result.success(pageInfo);
    }


    @PostMapping("/admin/front/payRequest/addPayInfoImg.json")
    @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, HttpServletRequest request){
        String result = payRequestService.addPayInfoImg(model);
        if(result.equals("0")){
            return JsonResult.failMessage("添加汇款记录失败!");
        }else{
            OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                    .methodName(Constants.ORDER_MODUL_NAME).operateAction("添加合伙人充值汇款凭证-"+model.getPartnerId()).build();
            mqUtil.sendApp(build);
            return JsonResult.success(result);
        }
    }

    @PostMapping("/admin/front/payRequest/updatePayInfoPass.json")
    @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,HttpServletRequest request){
        payRequestService.updatePayInfoPass(model);
        OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                .methodName(Constants.ORDER_MODUL_NAME).operateAction("后台合伙人充值审核-"+model.getPayOrderId()).build();
        mqUtil.sendApp(build);
        return JsonResult.success("1");
    }

    @PostMapping( "/admin/front/payRequest/addPayRequestInfo.json")
    @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, HttpServletRequest request){
        CoreUser user = sessionUtil.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万元");
            }
            CityPartner partner = cityPartnerService.queryById(user.getId().toString());

            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
            PayRequestInfo info = objectMapper.convertValue(model, PayRequestInfo.class);
            info.setAccountId(model.getBankAccountId());
            info.setAccountBindId(Long.parseLong(model.getBankAccountId()));
            info.setCreateTime(DateUtil.now());
            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(payRequestService.insertPayRequestInfo(info)>0){
                OperationAppLog build = OperationAppLog.builder().appPrograme(CommonEnum.后台.getValue()).opreateName(getAdminName(request))
                        .methodName(Constants.ORDER_MODUL_NAME).operateAction("添加合伙人提现申请-"+model.getBankAccountId()).build();
                mqUtil.sendApp(build);
                return JsonResult.success("保存成功");
            }else{
                return JsonResult.failMessage("保存失败");
            }

        }
    }

    @PostMapping( "/admin/front/payRequest/queryDetailsPresentation.do")
    @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 = sessionUtil.getCurrentUser();
        if(user.getId()==1){
            //return JsonResult.success(new HashMap<>());
        }else{
            CoreUser user1 = coreUserMapper.queryPartnerAdmin(user.getId());
            if(user1!=null){

            }else{
                CityPartner partner = cityPartnerService.queryById(user.getId().toString());
                if(null!=partner){
                    model.setUserId(partner.getUserId());
                }
            }
        }

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

    @PostMapping("/payRequest/rk/limit/list")
    @ApiOperation(value = "入库员额度明细列表")
    public Result<PageInfo<RkLimitDto>> rkwalletList(HttpServletRequest request, @RequestBody SimplePage simplePage) {
        Result result = new Result();
        String userId = getUserId(request);
        PageInfo<RkLimitDto> rkLimitDtoPageInfo = payRequestService.rkMessage(userId, simplePage);
        result.setData(rkLimitDtoPageInfo);
        return result;
    }

    @PostMapping("/payRequest/rk/limit/recovery")
    @ApiOperation(value = "入库员额度恢复请求")
    public Result rkwalletRecovery(HttpServletRequest request) {
        Result result = payRequestService.quotaRestore(getUserId(request));
        if(result.getCode()==0){
            String mobilePhone = userService.findOtherByUserId(getUserId(request),1);
            OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
                    .methodName(Constants.PAY_MODUL_NAME).operateAction("入库员额度恢复请求-"+getUserId(request)).build();
            mqUtil.sendApp(build);
        }
        return result;
    }

    @ApiOperation(value = "入库员或打包站额度申请或额度恢复审核", notes = "id是流水号 ，extra是驳回原因")
    @PostMapping("/payRequest/rk/limit/audit")
    public Result audit(HttpServletRequest request, @RequestBody MoneyAuditDto moneyAuditDto) {
        String payOrderId = moneyAuditDto.getId();
        String extra = moneyAuditDto.getExtra();
        payRequestService.audit(getUserId(request), payOrderId, extra, moneyAuditDto.getPayType(), moneyAuditDto.getAuditUserId(), moneyAuditDto.getMoney(),moneyAuditDto.getAuditUserType());


        String mobilePhone = userService.findOtherByUserId(getUserId(request),1);
        OperationAppLog build = OperationAppLog.builder().appPrograme(getFrontClient(request)).opreateName(mobilePhone)
                .methodName(Constants.ORDER_MODUL_NAME).operateAction("入库员或打包站额度申请或额度恢复审核-"+payOrderId).build();
        mqUtil.sendApp(build);
        return Result.success();
    }

    @PostMapping("/payRequest/rk/wallet")
    @ApiOperation(value = "入库员钱包额度")
    public Result<RkWalletDto> rkwallet(HttpServletRequest request) {
        Result result = new Result();
        String userId = getUserId(request);
        //一共的额度
        AccountInfo accountInfo1 = accountService.findByUserIdForbidden(userId);
        //可用的额度
        BigDecimal overdraftLimit = Convert.toBigDecimal(accountInfo1.getOverdraftLimit(), Constants.MONEY_INIT);
        BigDecimal fixedLimit = Convert.toBigDecimal(accountInfo1.getFixedLimit(), Constants.MONEY_INIT);
        RkWalletDto rkWalletDto = new RkWalletDto();
        rkWalletDto.setAvailableLimit(businessUtil.changeMoney(overdraftLimit));
        rkWalletDto.setUsedLimit(businessUtil.changeMoney(NumberUtil.sub(fixedLimit, overdraftLimit)));
        //一共支出
        OrderStorageInfo orderStorageInfo = new OrderStorageInfo();
        orderStorageInfo.setStorageStatus(Convert.toShort(OrderEnum.已入库.getValue()));
        orderStorageInfo.setStorageUserId(userId);
        List<OrderStorageInfo> select = orderStorageInfoMapper.select(orderStorageInfo);
        if (CollUtil.isNotEmpty(select)) {
            double sum = select.stream().mapToDouble(x -> Convert.toDouble(x.getStorageMoney())).sum();
            rkWalletDto.setAllPay(businessUtil.changeMoney(Convert.toBigDecimal(sum, Constants.MONEY_INIT)));
        } else {
            rkWalletDto.setAllPay(Constants.MONEY_INIT.toString());
        }
        result.setData(rkWalletDto);
        return result;
    }


    @PostMapping( "/admin/front/payRequest/queryStorageMoneyApi.do")
    @ApiOperation(value = "资金管理-支出明细", notes = "test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = false, dataType = "int"),
            @ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = false, dataType = "int"),
            @ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = false, dataType = "String"),
            @ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = false, dataType = "String"),
            @ApiImplicitParam(paramType = "query", name = "storageUserName", value = "入库员", required = false, dataType = "String"),
            @ApiImplicitParam(paramType = "query", name = "storageUserPhone", value = "入库员手机号", required = false, dataType = "String")
    })
    public JsonResult<Map<String, Object>> queryStorageMoneyApi(@RequestBody PayStorageModel model) {
        Map<String, Object> map = payRequestService.queryStorageMoneyApi(model);
        return JsonResult.success(map);
    }

    @PostMapping( "/admin/front/payRequest/queryStorageMoneyDetailApi.json")
    @ApiOperation(value = "资金管理-支出明细详情", notes = "test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = false, dataType = "int"),
            @ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = false, dataType = "int"),
            @ApiImplicitParam(paramType = "query", name = "storageId", value = "入库Id", required = false, dataType = "String"),
    })
    public JsonResult<Map<String, Object>> queryStorageMoneyDetailApi(@RequestBody PayStorageModel model) {
        Map<String, Object> map = payRequestService.queryStorageMoneyDetailApi(model);
        return JsonResult.success(map);
    }

    @PostMapping( "/admin/front/payRequest/quotaDetail.json")
    @ApiOperation(value = "资金管理-额度申请(详情)", notes = "test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "query", name = "page", value = "页码", required = false, dataType = "int"),
            @ApiImplicitParam(paramType = "query", name = "limit", value = "每页条数", required = false, dataType = "int"),
            @ApiImplicitParam(paramType = "query", name = "startTime", value = "开始时间", required = false, dataType = "String"),
            @ApiImplicitParam(paramType = "query", name = "endTime", value = "结束时间", required = false, dataType = "String"),
            @ApiImplicitParam(paramType = "query", name = "userId", value = "回收员Id", required = false, dataType = "String")
    })
    public JsonResult<Map<String, Object>> quotaDetail(@RequestBody StorageUserModel storageUserModel) {
        Map<String, Object> map = payRequestService.quotaDetail(storageUserModel);
        return JsonResult.success(map);
    }
}