package com.boying.controller.phone;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.http.Header;
import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.boying.common.R;
import com.boying.common.SystemConfigProperties;
import com.boying.entity.*;
import com.boying.entity.vo.MonthFeePayVo;
import com.boying.service.*;
import com.boying.util.LicensePlateValidator;
import com.google.gson.Gson;
import lombok.Data;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.text.SimpleDateFormat;
import java.time.*;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;

/**
 * @author kdq
 * @version 1.0.0
 * @ClassName MonthFeePayController.java
 * @Description TODO
 * @createTime 2024年12月20日 16:14:00
 */
@RestController
@RequestMapping("ffzf/monthFeePay")
@RequiredArgsConstructor
public class MonthFeePayController {

    private final PaymentLogService paymentLogService;
    private final EnterParkService enterParkService;
    private final PayLogService payLogService;
    private final WhiteListService whiteListService;
    private final SystemConfigProperties systemConfigProperties;
    private final WXService wxService;
    private final ParkService parkService;

    @PostMapping("/pay")
    public Object pay(MonthFeePayVo vo) {
        if(!LicensePlateValidator.isValidLicensePlate(vo.getCarNo())){
            return R.failed("车牌号填写错误");
        }
        if(vo.getPhone() == null){
            return R.failed("未填写手机号");
        }
        boolean validChineseMobileNumber = isValidChineseMobileNumber(vo.getPhone());
        if(!validChineseMobileNumber){
            return R.failed("手机号有误");
        }
        QueryWrapper<WhiteList> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda()
                .eq(WhiteList::getCarNo,vo.getCarNo())
                .eq(WhiteList::getPayFlag,1);
        List<WhiteList> list = whiteListService.list(queryWrapper);
        if(list !=null && list.size()>0){
            return R.ok(list.get(0));
        }
        return R.ok(null,"未查询到月票");
    }
    @PostMapping("/findWhiteList")
    public Object findWhiteList(MonthFeePayVo vo) {
        QueryWrapper<WhiteList> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda()
                .eq(WhiteList::getCarNo,vo.getCarNo())
                .eq(WhiteList::getPhone,vo.getPhone());
        List<WhiteList> list = whiteListService.list(queryWrapper);
        if(list !=null && list.size()>0){
            return R.ok(list.get(0));
        }else {
            return R.failed("未查询到此月票");
        }
    }

    /**
     * 获取微信openid
     */
    @PostMapping("getOpenId")
    public Object park(MonthFeePayVo vo){
        String openIdByCode = wxService.getOpenIdByCode(vo.getCode());
        PaymentLog paymentLog = new PaymentLog();
        paymentLog.setType(vo.getType());
        paymentLog.setParkId(vo.getParkId());
        paymentLog.setCarNo(vo.getCarNo());
        paymentLog.setPhone(vo.getPhone());
        paymentLog.setName(vo.getName());
        paymentLog.setMoney(vo.getMoney());
        paymentLog.setStartTime(vo.getStartTime());
        paymentLog.setEndTime(vo.getEndTime());
        paymentLogService.save(paymentLog);
        return payByWX(paymentLog,openIdByCode);
    }

    /**
     * 获取阿里支付
     */
    @PostMapping("getAiLi")
    public Object getAiLi(MonthFeePayVo vo){
        PaymentLog paymentLog = new PaymentLog();
        paymentLog.setType(vo.getType());
        paymentLog.setParkId(vo.getParkId());
        paymentLog.setCarNo(vo.getCarNo());
        paymentLog.setPhone(vo.getPhone());
        paymentLog.setName(vo.getName());
        paymentLog.setMoney(vo.getMoney());
        paymentLog.setStartTime(vo.getStartTime());
        paymentLog.setEndTime(vo.getEndTime());
        paymentLogService.save(paymentLog);
        return payByAli(paymentLog);
    }

    @PostMapping("/paySuccess")
    public Object paySuccess(PaymentLog vo,Integer flag) {
        if(flag == null || flag == 0){
            return  R.failed("缴费失败");
        }else {
            //缴费成功，新增白名单
            WhiteList whiteList = new WhiteList();
            whiteList.setPayFlag(1);
            whiteList.setCarNo(vo.getCarNo());
            whiteList.setStartTime(vo.getStartTime());
            whiteList.setEndTime(vo.getEndTime());
            whiteList.setPhone(vo.getPhone());
            if(vo.getType()==1){
                QueryWrapper<Park> wrapper = new QueryWrapper<>();
                wrapper.lambda()
                        .select(Park::getId);
                List<Park> list = parkService.list(wrapper);
                String collect = list.stream().map(Park::getId).map(String::valueOf).collect(Collectors.joining(","));
                whiteList.setParkIds(collect);
                whiteList.setType(1);
            }else {
                whiteList.setParkIds(vo.getParkId()+"");
                whiteList.setParkId(vo.getParkId());
                whiteList.setType(1);
            }
            whiteListService.save(whiteList);
            return R.ok();
        }


    }

    /**
     * 微信缴费
     */
    @PostMapping("payByWX")
    public Object payByWX(PaymentLog paymentLog,String openId){
        System.out.println("开始支付");
        String xtyhpay = systemConfigProperties.getXTYHPAY();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
        String format = sdf.format(new Date());
        LocalDateTime date3 = LocalDateTime.now();
        Map<String,Object> map = new HashMap<>();
        map.put("encoding","UTF-8");
        map.put("signMethod","01");
        map.put("sdkAppId",systemConfigProperties.getXTYHMERID());
        map.put("txnType","1006");
        map.put("txnSubType","100603");
        map.put("txnAccType","02");
        map.put("secMerAppId",systemConfigProperties.getXTYHAPPID());
        map.put("txnSubOpenid",openId);
        map.put("txnProductId",paymentLog.getId()+"");
        map.put("aesWay","01");
        map.put("merId",systemConfigProperties.getXTYHMERID());
        map.put("merName",systemConfigProperties.getXTYHMERNAME());
        map.put("backEndUrl",systemConfigProperties.getYPRESULT());
        map.put("txnOrderId",paymentLog.getId()+""+format);
        map.put("txnOrderTime",format);
        map.put("txnOrderBody",paymentLog.getCarNo()+"月票缴费");
        map.put("txnAmt",Math.round(paymentLog.getMoney() * 100)+"");
        map.put("txnCcyType","156");

        Map<String, String> stringStringMap = wxService.addSign(map);
        map.put("certId",stringStringMap.get("certId"));
        map.put("signAture",stringStringMap.get("signAture"));
        Gson gson =new Gson();
        String str = gson.toJson(map);
        System.out.println("请求报文："+str);

        String body = HttpRequest.post(xtyhpay)
                .header(Header.CONTENT_TYPE, "application/json")
                .body(str)
                .timeout(15000)
                .execute()
                .body();
        System.out.println(paymentLog.getId()+"响应报文："+body);

        JSONObject map1 = JSON.parseObject(body);
        String respCode = (String)map1.get("respCode");
        if(respCode.equals("0000")){
            String respTxnSsn = (String)map1.get("respTxnSsn");
            String respTxnTime = (String)map1.get("respTxnTime");
            String respData = (String)map1.get("respData");
            Map map2 = gson.fromJson(respData, Map.class);
            String appId = (String)map2.get("appId");
            String timeStamp = (String)map2.get("timeStamp");
            String nonceStr = (String)map2.get("nonceStr");
            String signType = (String)map2.get("signType");
            String package1 = (String)map2.get("package");
            String paySign = (String)map2.get("paySign");
            Map<String,String> resultMap = new HashMap<>();
            resultMap.put("appId",appId);
            resultMap.put("timeStamp",timeStamp);
            resultMap.put("nonceStr",nonceStr);
            resultMap.put("signType",signType);
            resultMap.put("package",package1);
            resultMap.put("paySign",paySign);
            PayLog payLog = new PayLog();
            payLog.setOutParkId(paymentLog.getId());
            payLog.setCode2(respTxnSsn);
            payLog.setPayTime(LocalDateTime.now());
            payLog.setTxnOrderId(paymentLog.getId()+""+format);
            payLog.setTxnOrderTime(format);
            payLog.setRespTxnTime(respTxnTime);
            payLog.setType(1);
            payLogService.save(payLog);
            return R.ok(resultMap,null);
        }
        String respMsg = (String)map1.get("respMsg");
        return R.failed(respCode+":"+respMsg);
    }

    /**
     * 阿里缴费
     */
    @PostMapping("payByAli")
    public Object payByAli(PaymentLog paymentLog){
        String xtyhpay = systemConfigProperties.getXTYHPAY();
        LocalDateTime date3 = LocalDateTime.now();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
        String format = sdf.format(new Date());
        Map<String,Object> map = new HashMap<>();
        map.put("encoding","UTF-8");
        map.put("signMethod","01");
        map.put("sdkAppId",systemConfigProperties.getXTYHMERID());
        map.put("txnType","1007");
        map.put("txnSubType","100702");
        map.put("txnAccType","03");
        map.put("aesWay","01");
        map.put("merId",systemConfigProperties.getXTYHMERID());
        map.put("merName",systemConfigProperties.getXTYHMERNAME());
        map.put("backEndUrl",systemConfigProperties.getXTYHRESULT());
        map.put("txnOrderId",paymentLog.getId()+""+format);
        map.put("txnOrderTime",format);
        map.put("txnOrderBody",paymentLog.getCarNo()+"月票缴费");
        map.put("txnAmt",Math.round(paymentLog.getMoney() * 100)+"");
        map.put("txnCcyType","156");

        Map<String, String> stringStringMap = wxService.addSign(map);
        map.put("certId",stringStringMap.get("certId"));
        map.put("signAture",stringStringMap.get("signAture"));
        Gson gson =new Gson();
        String str = gson.toJson(map);
        System.out.println("请求报文："+str);
        String body = HttpRequest.post(xtyhpay)
                .header(Header.CONTENT_TYPE, "application/json")
                .body(str)
                .timeout(15000)
                .execute()
                .body();
        System.out.println(paymentLog.getId()+"响应报文："+body);

        JSONObject map1 = JSON.parseObject(body);
        String respCode = (String)map1.get("respCode");
        if(respCode.equals("0000")){
            String respTxnSsn = (String)map1.get("respTxnSsn");
            String respData = (String)map1.get("respData");
            String respTxnTime = (String)map1.get("respTxnTime");
            Map map2 = gson.fromJson(respData, Map.class);
            String qrCode = (String)map2.get("qrCode");
            PayLog payLog = new PayLog();
            payLog.setOutParkId(paymentLog.getId());
            payLog.setCode2(respTxnSsn);
            payLog.setQrCode(qrCode);
            payLog.setPayTime(LocalDateTime.now());
            payLog.setTxnOrderId(paymentLog.getId()+""+format);
            payLog.setTxnOrderTime(format);
            payLog.setRespTxnTime(respTxnTime);
            payLog.setType(1);
            payLogService.save(payLog);
            return R.ok(null,qrCode);
        }
        String respMsg = (String)map1.get("respMsg");
        return R.failed(respCode+":"+respMsg);
    }

    /**
     * 邢台银行支付回调接口
     * @param
     * @return
     */
    @PostMapping("/getResult")
    public Object getResult(HttpServletRequest request){
        System.out.println("getResult收到访问");
        String respCode = request.getParameter("respCode");
        String respTxnSsn = request.getParameter("respTxnSsn");
        System.out.println(respCode+":"+respTxnSsn);
        if(respCode != null){
            if(respCode.equals("0000")){
                //交易成功,根据流水号查询出场记录
                PayLog payLog = payLogService.findByPayCode(respTxnSsn);
                if(payLog == null){
                    return R.failed("未查询到流水记录");
                }else {
                    PaymentLog byPayCode = paymentLogService.getById(payLog.getOutParkId());
                    if(byPayCode == null){
                        return R.failed("未查询到流水");
                    }else {
                        if(byPayCode.getStatus() == 1){
                            return R.ok(null,"月票已支付");
                        }else {
                           byPayCode.setStatus(1);
                            paySuccess(byPayCode,1);
                            return R.ok(null,"回调成功");
                        }
                    }
                }
            }else if(respCode.equals("0002") || respCode.equals("0003") || respCode.equals("0003") || respCode.equals("0012")){
                //交易成功，超时，未明，稍后发起查询
            }else if(respCode.equals("0011")){
                //交易
            }
        }else {
            return R.failed("未接收到入参");
        }
        return R.failed(null,"请求失败");
    }

    //判断手机号
    public static boolean isValidChineseMobileNumber(String number) {
        // 正则表达式
        String regex = "^(13[0-9]|14[57]|15[0-35-9]|17[0-9]|18[0-9])\\d{8}$";
        // 编译正则表达式
        Pattern pattern = Pattern.compile(regex);
        // 匹配
        Matcher matcher = pattern.matcher(number);
        // 返回是否匹配结果
        return matcher.matches();
    }
}