package com.dsh.course.util.midtrans;

import com.dsh.guns.modular.system.util.ResultUtil;
import com.midtrans.Config;
import com.midtrans.Midtrans;
import com.midtrans.httpclient.IrisApi;
import org.json.JSONArray;
import org.json.JSONObject;

import java.util.*;

/**
 * 付款工具类
 * @author zhibing.pu
 * @date 2023/5/4 19:22
 */
public class Payouts {

    private static String sandbox_merchant_id = "G118246934";

    private static String sandbox_serverKey = "IRIS-330198f0-e49d-493f-baae-585cfded355d";

//    private static String sandbox_serverKey = "SB-Mid-server-qR4Xy4kbpyxND_7f6c1_knb9";

    private static String sandbox_clientKey = "SB-Mid-client-xhRbIV8lsbu7bKCE";

    private static String merchant_id = "G118246934";

    private static String serverKey = "Mid-server-w1ATM2ldDpd0c4Q0s9sNfeNN";

    private static String clientKey = "Mid-client-X22yMA1Wvs0v1vfO";


    /**
     * 添加转账账户信息
     * @param beneficiary_name
     * @param beneficiary_account
     * @param beneficiary_bank
     * @param beneficiary_email
     * @return
     */
    public static ResultUtil addBeneficiaries(String beneficiary_name, String alias_name, String beneficiary_account, String beneficiary_bank, String beneficiary_email){
        try {
            //沙箱环境
            Midtrans.serverKey = sandbox_serverKey;
            Midtrans.clientKey = sandbox_clientKey;
            Midtrans.isProduction = false;

            //生产环境
//        Midtrans.serverKey = serverKey;
//        Midtrans.clientKey = clientKey;
//        Midtrans.isProduction = true;
            Map<String, String> requestBody = new HashMap<>();
            requestBody.put("name", beneficiary_name);
            requestBody.put("account", beneficiary_account);
            requestBody.put("bank", beneficiary_bank);
            requestBody.put("alias_name", alias_name);
            requestBody.put("email", beneficiary_email);
            JSONObject beneficiaries = IrisApi.createBeneficiaries(requestBody, Config.getGlobalConfig());
            String status = beneficiaries.getString("status");
            if("created".equals(status)){
                return ResultUtil.success();
            }
        }catch (Exception e){
            e.printStackTrace();
        }
        return ResultUtil.error("失败");
    }


    /**
     * 更新转账用户数据
     * @param beneficiary_name
     * @param beneficiary_account
     * @param beneficiary_bank
     * @param beneficiary_email
     * @return
     */
    public static ResultUtil editBeneficiaries(String beneficiary_name, String alias_name, String beneficiary_account, String beneficiary_bank, String beneficiary_email){
        try {
            //沙箱环境
            Midtrans.serverKey = sandbox_serverKey;
            Midtrans.clientKey = sandbox_clientKey;
            Midtrans.isProduction = false;

            //生产环境
//        Midtrans.serverKey = serverKey;
//        Midtrans.clientKey = clientKey;
//        Midtrans.isProduction = true;
            Map<String, String> requestBody = new HashMap<>();
            requestBody.put("name", beneficiary_name);
            requestBody.put("account", beneficiary_account);
            requestBody.put("bank", beneficiary_bank);
            requestBody.put("alias_name", alias_name);
            requestBody.put("email", beneficiary_email);
            JSONObject beneficiaries = IrisApi.updateBeneficiaries(alias_name, requestBody, Config.getGlobalConfig());
            String status = beneficiaries.getString("status");
            if("updated".equals(status)){
                return ResultUtil.success();
            }
        }catch (Exception e){
            e.printStackTrace();
        }
        return ResultUtil.error("失败");
    }


    /**
     * 获取转账用户
     * @param account
     * @return
     */
    public static Beneficiaries getBeneficiaries(String account){
        try {
            //沙箱环境
            Midtrans.serverKey = sandbox_serverKey;
            Midtrans.clientKey = sandbox_clientKey;
            Midtrans.isProduction = false;

            //生产环境
//        Midtrans.serverKey = serverKey;
//        Midtrans.clientKey = clientKey;
//        Midtrans.isProduction = true;
            JSONArray beneficiaries = IrisApi.getBeneficiaries(Config.getGlobalConfig());
            for (int i = 0; i < beneficiaries.length(); i++) {
                JSONObject jsonObject = beneficiaries.getJSONObject(i);
                String account1 = jsonObject.getString("account");
                if(account.equals(account1)){
                    Beneficiaries beneficiaries1 = new Beneficiaries();
                    beneficiaries1.setName(jsonObject.getString("name"));
                    beneficiaries1.setAccount(jsonObject.getString("account"));
                    beneficiaries1.setAlias_name(jsonObject.getString("alias_name"));
                    beneficiaries1.setBank(jsonObject.getString("bank"));
                    beneficiaries1.setEmail(jsonObject.getString("email"));
                    return beneficiaries1;
                }
            }
        }catch (Exception e){
            e.printStackTrace();
        }
        return null;
    }



    /**
     * 单笔转账
     * @param beneficiary_name      转账用户名称
     * @param alias_name            用户别名
     * @param beneficiary_account   转账用户账号
     * @param beneficiary_bank      转账银行
     * @param beneficiary_email     邮箱
     * @param amount                金额
     * @param notes                 备注
     * @return
     */
    public static ResultUtil<String> payout(String beneficiary_name, String alias_name, String beneficiary_account, String beneficiary_bank, String beneficiary_email, Double amount, String notes){
        try {
            //沙箱环境
            Midtrans.serverKey = sandbox_serverKey;
            Midtrans.clientKey = sandbox_clientKey;
            Midtrans.isProduction = false;

            //生产环境
//        Midtrans.serverKey = serverKey;
//        Midtrans.clientKey = clientKey;
//        Midtrans.isProduction = true;
            Beneficiaries beneficiaries = getBeneficiaries(beneficiary_account);
            if(null == beneficiaries){
                ResultUtil resultUtil = addBeneficiaries(beneficiary_name, alias_name, beneficiary_account, beneficiary_bank, beneficiary_email);
                if(resultUtil.getCode() != 200){
                    System.err.println(resultUtil.getMsg());
                    return resultUtil;
                }
            }else{
                ResultUtil resultUtil = editBeneficiaries(beneficiary_name, alias_name, beneficiary_account, beneficiary_bank, beneficiary_email);
                if(resultUtil.getCode() != 200){
                    return resultUtil;
                }
            }

            List<Map<String, Object>> list = new ArrayList<>();
            Map<String, Object> map = new HashMap<>();
            map.put("beneficiary_name", beneficiary_name);
            map.put("beneficiary_account", beneficiary_account);
            map.put("beneficiary_bank", beneficiary_bank);
            map.put("beneficiary_email", beneficiary_email);
            map.put("amount", amount.toString());
            map.put("notes", notes);
            list.add(map);

            Map<String, Object> requestBody = new HashMap<>();
            requestBody.put("payouts", list);
            JSONObject jsonObject = IrisApi.createPayouts(requestBody, Config.getGlobalConfig());
            JSONArray payouts = jsonObject.getJSONArray("payouts");
            JSONObject jsonObject1 = payouts.getJSONObject(0);
            String status = jsonObject1.getString("status");//状态(queued：付款正在等待执行，processed：付款请求已发送到银行并完成，completed：付款请求将发送到银行并通过收款人帐户接收，failed：付款未通过)
            String reference_no = jsonObject1.getString("reference_no");//流水号
            if("queued".equals(status)){
                return ResultUtil.success("付款正在等待执行", reference_no, "0");
            }
            if("processed".equals(status)){
                return ResultUtil.success("付款请求已发送到银行并完成", reference_no, "1");
            }
            if("completed".equals(status)){
                return ResultUtil.success("付款请求将发送到银行并通过收款人帐户接收", reference_no, "1");
            }
            if("failed".equals(status)){
                return ResultUtil.error("付款未通过");
            }
        }catch (Exception e){
            e.printStackTrace();
            return ResultUtil.runErr();
        }
        return ResultUtil.error("未知错误");
    }


    /**
     * 确认转账付款操作
     * @param reference_no  转账流水号
     * @param otp           谷歌身份验证OTP（QR码将在合作伙伴注册期间发送到审批者的电子邮件）
     * @return
     */
    public static ResultUtil approve(String reference_no, String otp){
        try {
            //沙箱环境
            Midtrans.serverKey = sandbox_serverKey;
            Midtrans.clientKey = sandbox_clientKey;
            Midtrans.isProduction = false;

            //生产环境
//        Midtrans.serverKey = serverKey;
//        Midtrans.clientKey = clientKey;
//        Midtrans.isProduction = true;

            List<String> list = new ArrayList<>();
            list.add(reference_no);

            Map<String, Object> requestBody = new HashMap<>();
            requestBody.put("reference_nos", list);
            requestBody.put("otp", otp);
            JSONObject jsonObject = IrisApi.approvePayouts(requestBody, Config.getGlobalConfig());
            String status = jsonObject.getString("status");
            if("ok".equals(status)){
                return ResultUtil.success();
            }
        }catch (Exception e){
            e.printStackTrace();
            return ResultUtil.runErr(e.getMessage());
        }
        return ResultUtil.error("未知错误");
    }


    /**
     * 拒绝转账付款操作
     * @param reference_no      转账流水号
     * @param reject_reason     拒绝付款的原因
     * @return
     */
    public static ResultUtil reject(String reference_no, String reject_reason){
        try {
            //沙箱环境
            Midtrans.serverKey = sandbox_serverKey;
            Midtrans.clientKey = sandbox_clientKey;
            Midtrans.isProduction = false;

            //生产环境
//        Midtrans.serverKey = serverKey;
//        Midtrans.clientKey = clientKey;
//        Midtrans.isProduction = true;

            List<String> list = new ArrayList<>();
            list.add(reference_no);

            Map<String, Object> requestBody = new HashMap<>();
            requestBody.put("reference_nos", list);
            requestBody.put("reject_reason", reject_reason);
            JSONObject jsonObject = IrisApi.rejectPayouts(requestBody, Config.getGlobalConfig());
            String status = jsonObject.getString("status");
            if("ok".equals(status)){
                return ResultUtil.success();
            }
        }catch (Exception e){
            e.printStackTrace();
            return ResultUtil.runErr(e.getMessage());
        }
        return ResultUtil.error("未知错误");
    }


    /**
     * 获取转账付款详情
     * @param reference_no
     * @return
     */
    public static ResultUtil<Integer> getPayout(String reference_no){
        /**
         * {
         *   "amount": "200000.00",                                 已处理的付款金额
         *   "beneficiary_name": "Ryan Renolds",                    收款人姓名
         *   "beneficiary_account": "33287352",                     收款人的收款账号
         *   "bank": "Bank Central Asia ( BCA )",                   收款人使用的银行名称
         *   "reference_no": "83hgf882",                            付款流水号reference_no
         *   "notes": "Payout June 17",                             备注
         *   "beneficiary_email": "beneficiary@example.com",        邮箱
         *   "status": "queued",                                    状态
         *   "created_by": "John Doe",                              由制造商创建的付款
         *   "created_at": "2017-01-11T00:00:00Z",
         *   "updated_at": "2017-01-11T00:00:00Z"
         * }
         */
        try {
            //沙箱环境
            Midtrans.serverKey = sandbox_serverKey;
            Midtrans.clientKey = sandbox_clientKey;
            Midtrans.isProduction = false;

            //生产环境
//        Midtrans.serverKey = serverKey;
//        Midtrans.clientKey = clientKey;
//        Midtrans.isProduction = true;

            JSONObject jsonObject = IrisApi.getPayoutDetails(reference_no, Config.getGlobalConfig());
            String status = jsonObject.getString("status");
            if("queued".equals(status)){
                return ResultUtil.success("付款正在等待执行", 0);
            }
            if("processed".equals(status)){
                return ResultUtil.success("付款请求已发送到银行并完成", 1);
            }
            if("completed".equals(status)){
                return ResultUtil.success("付款请求将发送到银行并通过收款人帐户接收", 1);
            }
            if("failed".equals(status)){
                return ResultUtil.error("付款未通过");
            }
        }catch (Exception e){
            e.printStackTrace();
            return ResultUtil.runErr();
        }
        return ResultUtil.error("未知错误");
    }



}