package com.gkhy.exam.pay.service.impl;

import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.gkhy.exam.pay.entity.CoalPayStudent;
import com.gkhy.exam.pay.entity.NonCoalPayStudent;
import com.gkhy.exam.pay.mapper.CoalPayStudentMapper;
import com.gkhy.exam.pay.mapper.NonCoalPayStudentMapper;
import com.gkhy.exam.pay.service.PaymentService;
import com.gkhy.exam.pay.utils.CaiZhengConstans;
import com.gkhy.exam.pay.utils.PayUtils;
import jar.org.apache.commons.codec.binary.Base64;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Date;
import java.util.List;

import static com.ruoyi.common.utils.Threads.sleep;

@Service
@Slf4j
public class PaymentServiceImpl implements PaymentService {

    @Autowired
    private PayUtils payUtils;
    @Resource
    private NonCoalPayStudentMapper nonCoalPayStudentMapper;
    @Resource
    private CoalPayStudentMapper coalPayStudentMapper;

    @Override
    public void notifyConfirm(String orderNo) {
        try {
            payUtils.affirmPost(orderNo);
        } catch (Exception e) {
            e.printStackTrace();
        }

        String reqdatastr1 = "{\"orderNo\": \"" + orderNo + "\"}";
        String mac1 = getMD5("A1749891493E4CDDBFE4506357B1F0AB||" + getBase64(reqdatastr1));
        JSONObject jsonObject1 = new JSONObject();
        jsonObject1.put("appid", "A1749891493E4CDDBFE4506357B1F0AB");
        jsonObject1.put("mac", mac1);
        jsonObject1.put("reqdata", getBase64(reqdatastr1));
        String resultStr1 = HttpUtil.post("http://finpt.xjcz.gov.cn/fs-service/fs-pay/notifyConfirm.do", jsonObject1);
        System.out.println("通知确定入参===" + jsonObject1);
        JSONObject result1 = JSONObject.parseObject(resultStr1);
        System.out.println("通知确定回参===" + result1);


    }


    public String getMD5(String input) {
        try {
            MessageDigest md = MessageDigest.getInstance("MD5");
            byte[] messageDigest = md.digest(input.getBytes());
            StringBuilder hexString = new StringBuilder();
            for (byte b : messageDigest) {
                hexString.append(String.format("%02x", new Object[]{Byte.valueOf(b)}));
            }
            return hexString.toString();
        } catch (NoSuchAlgorithmException e) {
            throw new RuntimeException(e);
        }
    }

    public String getBase64(String str) {
        String encodedStr = Base64.encodeBase64String(str.getBytes());
        return encodedStr;
    }

    @Override
    public void paySuccess(String orderNo, Date payTime) {

        if (orderNo.startsWith("NC")) {
            //非煤
            nonCoalPayStudentMapper.update(null, Wrappers.<NonCoalPayStudent>lambdaUpdate()
                    .set(NonCoalPayStudent::getPayStatus, 1)
                    .set(NonCoalPayStudent::getPayTime, payTime)
                    .eq(NonCoalPayStudent::getOrderNo, orderNo).eq(NonCoalPayStudent::getDelFlag, 0)
                    .eq(NonCoalPayStudent::getPayStatus, 0));
        } else {
            coalPayStudentMapper.update(null, Wrappers.<CoalPayStudent>lambdaUpdate()
                    .set(CoalPayStudent::getPayStatus, 1)
                    .set(CoalPayStudent::getPayTime, payTime)
                    .eq(CoalPayStudent::getOrderNo, orderNo).eq(CoalPayStudent::getDelFlag, 0)
                    .eq(CoalPayStudent::getPayStatus, 0));
        }
        notifyConfirm(orderNo);

    }

    @Override
    public void schedulePayment() {
        List<NonCoalPayStudent> nonCoalPayStudents = nonCoalPayStudentMapper.getsch();

        if (nonCoalPayStudents != null) {
            for (NonCoalPayStudent nonCoalPayStudent : nonCoalPayStudents) {
                sleep(5000);
                if (nonCoalPayStudent.getGovPayStatus() == 2 && nonCoalPayStudent.getPayStatus() == 0) {
                    try {
                        JSONObject result = payUtils.query(nonCoalPayStudent.getOrderNo());
                        log.info("查询财政订单返回结果：" + result);
                        String respcode = result.getString("respcode");
                        if (CaiZhengConstans.CAI_ZHENG_SUCCESS.equals(respcode)) {
                            JSONObject respdata = result.getJSONObject("respdata");
                            if (respdata != null && "1".equals(respdata.getString("status"))) {
                                nonCoalPayStudentMapper.update(null, Wrappers.<NonCoalPayStudent>lambdaUpdate()
                                        .set(NonCoalPayStudent::getPayStatus, 1)
                                        .set(NonCoalPayStudent::getPayTime, respdata.getDate("payTime"))
                                        .eq(NonCoalPayStudent::getOrderNo, nonCoalPayStudent.getOrderNo()).eq(NonCoalPayStudent::getDelFlag, 0)
                                        .eq(NonCoalPayStudent::getPayStatus, 0));
                                // 回调确认支付
                                nonCoalPayStudent.setPayStatus(1L);
                                payUtils.affirmPost(nonCoalPayStudent.getOrderNo());
                            } else {
                                log.error("查询财政订单失败：" + result.getString("respmsg") + "，错误编码：" + result.getString("respcode"));
                            }

                        }
                    } catch (Exception e) {
                        log.error("查询财政订单失败：" + e.getMessage());

                    }
                }
            }
        }

    }


}