package com.ibeetl.admin.console.api;

import com.ibeetl.admin.console.model.ItemModel;
import com.ibeetl.admin.console.model.MoneyModel;
import com.ibeetl.admin.console.model.UserAccountModel;
import com.ibeetl.admin.console.model.UserModel;
import com.ibeetl.admin.console.service.CuserConsoleService;
import com.ibeetl.admin.console.service.FunctionConsoleService;
import com.ibeetl.admin.console.service.MoneyConsoleService;
import com.ibeetl.admin.console.service.SettingConsoleService;
import com.ibeetl.admin.console.service.pay.PayService;
import com.ibeetl.admin.console.service.pay.utils.WechatpayUtil;
import com.ibeetl.admin.console.service.pay.utils.entity.ResultEntity;
import com.ibeetl.admin.console.service.pay.utils.entity.TransfersDto;
import com.ibeetl.admin.console.util.PreventManyCommit;
import com.ibeetl.admin.console.util.UserLock;
import com.ibeetl.admin.core.annotation.Function;
import com.ibeetl.admin.core.gen.MavenProjectTarget;
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.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.servlet.ModelAndView;

import java.sql.SQLOutput;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * 微信提现
 */
@RestController
@Configuration
@Api(value = "微信提现接口类")
public class PayApi {

    private static final String MODEL = "/admin/wx/pay";
    private final Logger log = LoggerFactory.getLogger(this.getClass());
    @Autowired
    CuserConsoleService service;
    @Autowired
    MoneyConsoleService moneyConsoleService;
    @Autowired
    CuserConsoleService cuserConsoleService;
    @Autowired
    PayService payService;
    @Autowired
    SettingConsoleService settingConsoleService;
    @Autowired
    FunctionConsoleService functionConsoleService;

    @Value("${wx.app.url}")
    String TRANS_URL;
    @Value("${wx.app.key}")
    String APP_KEY;
    @Value("${wx.path}")
    String CERT_PATH;
    @Value("${wx.appid}")
    String APP_ID;
    @Value("${wx.mchid}")
    String MCH_ID;
    @Value("${wx.name}")
    String MCH_NAME;
    @Value("${wx.create.ip}")
    String CREATE_IP;
    @Value("${wx.appid.app}")
    String APP_ID_APP;
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

    @PostMapping(MODEL + "/wxPay.do")
    @ResponseBody
    @ApiOperation(value = "微信提现接口", notes = "test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType = "query", name = "userId", value = "用户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType = "query", name = "payOrderId", value = "提现申请订单Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType = "query", name = "otherUserId", value = "非普通用户Id", required = true, dataType = "String")
    })
    public JsonResult<String> wxPay(@RequestBody TransfersDto dto) {
        Map<String,Object> result = new HashMap<>();
        MoneyModel moneyModel = new MoneyModel();
        String payOrderId = dto.getPayOrderId();
        if (StringUtils.isEmpty(dto.getPayOrderId())) {

            return JsonResult.fail("payOrderId不能为空");
        } else {
            moneyModel = getMoneyModel(dto.getPayOrderId());
            String desc ="";
            if(null!=dto.getOtherUserId()&&!"".equals(dto.getOtherUserId())){
                desc =  checkMoneyModel(moneyModel, dto.getOtherUserId());
            }else{
                desc = checkMoneyModel(moneyModel, dto.getUserId());
            }
            if (!"0".equals(desc)) {
                return JsonResult.fail(desc);
            }
        }

        //查询用户openId
        String openId = "";
        UserModel userModel = new UserModel();
        UserModel userModelAccount = new UserModel();
        if(null!=dto.getOtherUserId()&&!"".equals(dto.getOtherUserId())){
            //if(dto.getOtherUserId().equals(dto.getUserId())){
                dto.setMch_appid(APP_ID_APP);
            //}
            userModelAccount = service.queryUserOtherInfoById(dto.getOtherUserId());
            userModel = service.queryUserOtherInfoById(dto.getOtherUserId());
            System.out.println("============otherUserId="+dto.getOtherUserId());
        }else{
            userModel = service.queryUserById(dto.getUserId());
            dto.setMch_appid(APP_ID);
        }
        System.out.println("APPID========="+APP_ID);
        log.info("appid==="+APP_ID);
        if (userModel == null) {
            moneyModel.setUnpassReason("用户不存在");
            moneyConsoleService.updateMoney(moneyModel);
            return JsonResult.fail( "用户不存在");
        }
        //查询用户账户是否能提现
        UserAccountModel userAccount = new UserAccountModel();
        if(null!=dto.getOtherUserId()&&!"".equals(dto.getOtherUserId())){
            userAccount = getUserAccount(moneyModel, userModelAccount);

        }else{
            userAccount = getUserAccount(moneyModel, userModel);

        }
        String oldMoney = String.valueOf(userAccount.getMoney());

        if (null != userAccount.getErrorType() && !"".equals(userAccount.getErrorType())) {
            return JsonResult.fail(userAccount.getErrorType());
        } else {
            // 审核通过
            moneyModel.setStatus("2");
            moneyModel.setPayFlag("0");
            moneyConsoleService.updateMoney(moneyModel);
        }
        openId = userModel.getOpenId();
        String mobilePhone = userModel.getMobilePhone();
        if (!"".equals(openId)) {
            dto.setOpenid(openId);
            dto.setMchid(MCH_ID);
            dto.setAppkey(APP_KEY);
            dto.setSpbill_create_ip(CREATE_IP);
            dto.setMch_name("湖南小棕熊环保科技有限责任公司");
            dto.setDesc("企业付款到零钱");
            if(null!=dto.getOtherUserId()&&!"".equals(dto.getOtherUserId())){
                dto.setUserId(dto.getOtherUserId());

            }
            //自动转为以分为单位
            dto.setAmount(Double.parseDouble(moneyModel.getMoney()));
            dto.setPayOrderId(payOrderId);
            result = payService.sendWxPay(TRANS_URL, CERT_PATH, dto, userAccount,mobilePhone,oldMoney);
        }
        if("0".equals(result.get("code").toString())){
            return JsonResult.success(result.get("data").toString());

        }else{
            return  JsonResult.fail(result.get("data").toString());

        }
    }

    /**
     * 查询提现申请记录
     *
     * @param payOrderId
     * @return
     */
    private MoneyModel getMoneyModel(String payOrderId) {
        MoneyModel moneyModel = new MoneyModel();
        moneyModel.setPayOrderId(payOrderId);
        moneyModel = moneyConsoleService.queryMoney(moneyModel);
        moneyModel.setStatus("3");
        moneyModel.setPayFlag("3");
        moneyModel.setExamineTime(sdf.format(new Date()));
        return moneyModel;
    }

    /**
     * @param model
     * @return
     */
    private String checkMoneyModel(MoneyModel model, String userId) {
        if (!model.getCreateUserId().equals(userId)) {
            model.setUnpassReason("userId和支付订单里面的userId不一致");
            moneyConsoleService.updateMoney(model);
            return "userId和支付订单里面的userId不一致";
        }
        if (StringUtils.isEmpty(model.getCreateUserId())) {
            model.setUnpassReason("用户ID不能为空");
            moneyConsoleService.updateMoney(model);
            return "用户ID不能为空";
        }
        if (StringUtils.isEmpty(model.getMoney())) {
            model.setUnpassReason("金钱不能为空");
            moneyConsoleService.updateMoney(model);
            return "金钱不能为空";
        }
        if (Double.parseDouble(model.getMoney()) <=0.3) {
            model.setUnpassReason("金额不能等于或小于0.3");
            moneyConsoleService.updateMoney(model);
            return "金额不能等于或小于1";
        }
        return "0";
    }

    private UserAccountModel getUserAccount(MoneyModel moneyModel, UserModel userModel) {
        UserAccountModel model = new UserAccountModel();

        // 查询用户账号表
        UserAccountModel userAccountModel = cuserConsoleService.queryAccountInfo(userModel.getUserId(), userModel.getMobilePhone());
        if (userAccountModel == null) {
            moneyModel.setUnpassReason("此用户未查询到账户信息");
            moneyConsoleService.updateMoney(moneyModel);
            model.setErrorType("此用户未查询到账户信息");
            return model;
        }
        if (userAccountModel.getDelFlag().equals("1")) {
            moneyModel.setUnpassReason("账户信息已删除");
            moneyConsoleService.updateMoney(moneyModel);
            model.setErrorType("账户信息已删除");
            return model;
        }
        if (userAccountModel.getMoney() < Double.parseDouble(moneyModel.getMoney())) {
            moneyModel.setUnpassReason("可提现金额不足");
            moneyConsoleService.updateMoney(moneyModel);
            model.setErrorType("可提现金额不足");
            return model;
        }
        if (!userModel.getOpenId().equals(moneyModel.getOpenId())) {
            moneyModel.setUnpassReason("用户和支付的openId不一致");
            moneyConsoleService.updateMoney(moneyModel);
            model.setErrorType("用户和支付的openId不一致");
            return model;
        }
        return userAccountModel;
    }

    @PostMapping(MODEL + "/queryPayInfoDetail.json")
    @ResponseBody
    Map<String, Object> queryPayInfoDetail(String payOrderId){
        return payService.queryPayInfoDetail(payOrderId);
    }

    // 回收员类别页面
    @GetMapping(MODEL + "/queryPayInfo.do")
    ModelAndView queryPayInfo(String payOrderId) {
        ModelAndView view = new ModelAndView("/admin/money/payInfoDetail.html");
        view.addObject("payOrderId", payOrderId);
        return view;
    }

    /**
     * 更新
     * @param payOrderId
     * @param userId
     * @param unpassReason
     * @return
     */
    @PostMapping(MODEL + "/addReason.json")
    @ResponseBody
    int addReason(String payOrderId,String userId,String unpassReason){

        return payService.addReason(payOrderId,userId,unpassReason);
    }



    @PostMapping(MODEL + "/quotaList.json")
    @ResponseBody
    Map<String, Object> quotaList(MoneyModel moneyModel,String page,String limit){
        moneyModel.setPayType("7");
        return moneyConsoleService.queryMoneyList(moneyModel,page,limit);
    }

    @PostMapping(MODEL + "/quota.json")
    @ResponseBody
    public JsonResult<String> quota(TransfersDto dto) {
        Map<String, Object> result = new HashMap<>();
        MoneyModel moneyModel = new MoneyModel();
        moneyModel.setPayOrderId(dto.getPayOrderId());
        moneyModel = moneyConsoleService.queryMoney(moneyModel);
        //
        UserModel userModel = service.queryRecoveryById(dto.getUserId(),"2");
        if(null!=userModel){
            UserAccountModel userAccountModel = cuserConsoleService.queryAccountInfo(moneyModel.getCreateUserId(), userModel.getMobilePhone());
            if (userAccountModel == null) {
                return JsonResult.success("此用户未查询到账户信息");
            }else{
                settingConsoleService.updateOverdrawPriceByUserId(userAccountModel.getAccountId(),moneyModel.getMoney());
                //修改申请状态
                moneyModel.setStatus("2");
                moneyModel.setUnpassReason("审核通过");
                moneyConsoleService.updateMoney(moneyModel);
                return JsonResult.success("完成审核");
            }
        }else{
            return JsonResult.success("查不到对应的回收员");
        }
    }

    @PostMapping(MODEL + "/wxPayCancel.json")
    @ResponseBody
    @ApiOperation(value="资金管理-提现申请(拒绝)", notes="test: 仅0有正确返回")
    @ApiImplicitParams({
            @ApiImplicitParam(paramType="query", name = "payOrderId", value = "提现申请Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "userId", value = "用户Id", required = true, dataType = "String"),
            @ApiImplicitParam(paramType="query", name = "unpassReason", value = "未通过原因", required = true, dataType = "String")

    })
    public JsonResult<String> wxPayCancel(@RequestBody TransfersDto dto) {
        Map<String, Object> result = new HashMap<>();
        MoneyModel moneyModel = new MoneyModel();
        moneyModel.setPayOrderId(dto.getPayOrderId());
        moneyModel = moneyConsoleService.queryMoney(moneyModel);
        moneyModel.setStatus("3");
        moneyModel.setUnpassReason(dto.getUnpassReason());
        functionConsoleService.updateMoney(moneyModel);
        return JsonResult.success("完成审核");
    }


}