package com.yami.trading.service.c2c.impl;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.yami.trading.bean.c2c.C2cAdvert;
import com.yami.trading.bean.c2c.C2cOrder;
import com.yami.trading.bean.c2c.C2cUser;
import com.yami.trading.bean.model.C2cPaymentMethod;
import com.yami.trading.bean.model.HighLevelAuthRecord;
import com.yami.trading.bean.model.Log;
import com.yami.trading.bean.model.MoneyLog;
import com.yami.trading.bean.model.RealNameAuthRecord;
import com.yami.trading.bean.model.RechargeBlockchainOrder;
import com.yami.trading.bean.model.User;
import com.yami.trading.bean.model.Wallet;
import com.yami.trading.bean.model.WalletExtend;
import com.yami.trading.bean.model.WalletLog;
import com.yami.trading.common.constants.Constants;
import com.yami.trading.common.constants.RedisKeys;
import com.yami.trading.common.constants.TipConstants;
import com.yami.trading.common.exception.BusinessException;
import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.common.util.Arith;
import com.yami.trading.common.util.C2cAdvertLock;
import com.yami.trading.common.util.C2cLock;
import com.yami.trading.common.util.DateUtil;
import com.yami.trading.common.util.DateUtils;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.dao.c2c.C2cOrderMapper;
import com.yami.trading.service.AwsS3OSSFileService;
import com.yami.trading.service.HighLevelAuthRecordService;
import com.yami.trading.service.MoneyLogService;
import com.yami.trading.service.RealNameAuthRecordService;
import com.yami.trading.service.RechargeBlockchainOrderService;
import com.yami.trading.service.WalletService;
import com.yami.trading.service.c2c.C2cAdvertService;
import com.yami.trading.service.c2c.C2cOrderService;
import com.yami.trading.service.c2c.C2cPaymentMethodService;
import com.yami.trading.service.c2c.C2cUserService;
import com.yami.trading.service.data.DataService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.system.LogService;
import com.yami.trading.service.system.TipService;
import com.yami.trading.service.user.UserDataService;
import com.yami.trading.service.user.UserService;
import com.yami.trading.service.user.WalletLogService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.math.BigDecimal;
import java.text.DecimalFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

@Service
@Slf4j
public class C2cOrderServiceImpl extends ServiceImpl<C2cOrderMapper, C2cOrder> implements C2cOrderService {

    @Autowired
    WalletService walletService;

    @Autowired
    C2cPaymentMethodService c2cPaymentMethodService;

    @Autowired
    RechargeBlockchainOrderService rechargeBlockchainOrderService;

    @Autowired
    SysparaService sysparaService;

    @Autowired
    RedisTemplate redisTemplate;

    @Autowired
    MoneyLogService moneyLogService;

    @Autowired
    TipService tipService;

    @Autowired
    UserService userService;

    @Autowired
    WalletLogService walletLogService;

    @Autowired
    C2cAdvertService c2cAdvertService;

    @Autowired
    LogService logService;

    @Autowired
    C2cUserService c2cUserService;

    @Autowired
    UserDataService userDataService;


    @Autowired
    AwsS3OSSFileService awsS3OSSFileService;

    @Autowired
    ItemService itemService;

    @Autowired
    DataService dataService;

    @Autowired
    RealNameAuthRecordService realNameAuthRecordService;

    @Autowired
    HighLevelAuthRecordService highLevelAuthRecordService;

    @Override
    public long getTodayCancelOrderCount(String userId) {

        return count(Wrappers.<C2cOrder>query().lambda().eq(C2cOrder::getPartyId, userId).eq(C2cOrder::getState, 4));
    }

    @Override
    /*
     * 查询未完结订单数量，根据广告ID
     */
    public Long findNoEndingOrdersCountByAdvertId(String c2cAdvertId) {
        return count(Wrappers.<C2cOrder>query().lambda().eq(C2cOrder::getC2cAdvertId, c2cAdvertId).in(C2cOrder::getState, "0", "1", "2", "5"));
    }

    /**
     * 订单放行
     */
    public void saveOrderPass(C2cOrder c2cOrder) {

        DecimalFormat df = new DecimalFormat("#.########");
        C2cAdvert c2cAdvert = this.c2cAdvertService.getById(c2cOrder.getC2cAdvertId());
        if (null == c2cAdvert) {
            throw new YamiShopBindException("广告不存在");
        }
//		double symbolClose = symbolClose(c2cOrder.getSymbol());
        double symbolClose = c2cAdvert.getSymbolClose();
        if (C2cOrder.DIRECTION_BUY.equals(c2cOrder.getDirection())) {
            // 买币
            // 给用户账户添加相应的币种数量
            double amountBefore = 0d;
            double amountAfter = 0d;
            if ("usdt".equalsIgnoreCase(c2cOrder.getSymbol())) {
                Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
                amountBefore = wallet.getMoney().doubleValue();
                amountAfter = Double.valueOf(df.format(Arith.add(wallet.getMoney().doubleValue(), c2cOrder.getCoinAmount()))).doubleValue();
                this.walletService.update(c2cOrder.getPartyId().toString(), c2cOrder.getCoinAmount());
            } else {
                WalletExtend walletExtend = this.walletService.saveExtendByPara(c2cOrder.getPartyId(), c2cOrder.getSymbol());
                amountBefore = walletExtend.getAmount();
                amountAfter = Double.valueOf(df.format(Arith.add(walletExtend.getAmount(), c2cOrder.getCoinAmount()))).doubleValue();
                this.walletService.updateExtend(c2cOrder.getPartyId().toString(), c2cOrder.getSymbol(), c2cOrder.getCoinAmount());
            }
            // 保存资金日志
            MoneyLog moneyLog = new MoneyLog();
            moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
            moneyLog.setAmountBefore(new BigDecimal(amountBefore));
            moneyLog.setAmount(new BigDecimal(c2cOrder.getCoinAmount()));
            moneyLog.setAmountAfter(new BigDecimal(amountAfter));
            moneyLog.setLog("c2c订单购买放行，订单号[" + c2cOrder.getOrderNo() + "]");
            moneyLog.setUserId(c2cOrder.getPartyId());
            moneyLog.setWalletType(c2cOrder.getSymbol());
            moneyLog.setSymbol(c2cOrder.getSymbol());
            moneyLog.setContentType(Constants.MONEYLOG_CONTENT_OTC_BUY);
            moneyLogService.save(moneyLog);
            // usdt价值=币种数量*行情价
            if ("usdt".equalsIgnoreCase(c2cOrder.getSymbol())) {
                userDataService.saveRechargeHandle(c2cOrder.getPartyId(), c2cOrder.getCoinAmount(), c2cOrder.getSymbol());
            } else {
                this.userDataService.saveRechargeHandle(c2cOrder.getPartyId(), c2cOrder.getCoinAmount(), c2cOrder.getSymbol());
            }
        } else if (C2cOrder.DIRECTION_SELL.equals(c2cOrder.getDirection())) {
            // 卖币
            if (C2cAdvertLock.add(c2cOrder.getC2cAdvertId())) {
                c2cAdvert.setCoinAmount(Double.valueOf(df.format(Arith.add(c2cAdvert.getCoinAmount(), c2cOrder.getCoinAmount()))).doubleValue());
                c2cAdvert.setDeposit(Double.valueOf(df.format(Arith.add(c2cAdvert.getDeposit(), c2cOrder.getAmountUsdt()))).doubleValue());
                this.c2cAdvertService.updateById(c2cAdvert);
            }
            // usdt价值=币种数量*行情价
            if ("usdt".equalsIgnoreCase(c2cOrder.getSymbol())) {
                this.userDataService.saveWithdrawHandle(c2cOrder.getPartyId(), c2cOrder.getCoinAmount(), 0d, "usdt");
            } else {
                this.userDataService.saveWithdrawHandle(c2cOrder.getPartyId(), Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), symbolClose))).doubleValue(), 0d, c2cOrder.getSymbol());
            }
        }
        // 订单完成
        c2cOrder.setState("3");
        c2cOrder.setHandleTime(new Date());
        updateById(c2cOrder);
        this.updateNofinishOrderCount(c2cOrder);
        C2cUser c2cUser = this.c2cUserService.getById(c2cOrder.getC2cUserId());
        if (null == c2cUser) {
            throw new YamiShopBindException("承兑商不存在");
        }
        if (C2cOrder.DIRECTION_BUY.equals(c2cOrder.getDirection())) {
            // 买币
            c2cUser.setBuyAmount(c2cUser.getBuyAmount() + c2cOrder.getAmountUsdt());
            c2cUser.setBuySuccessOrders(c2cUser.getBuySuccessOrders() + 1);
        } else if (C2cOrder.DIRECTION_SELL.equals(c2cOrder.getDirection())) {
            // 卖币
            c2cUser.setSellAmount(c2cUser.getSellAmount() + c2cOrder.getAmountUsdt());
            c2cUser.setSellSuccessOrders(c2cUser.getSellSuccessOrders() + 1);
        }
        c2cUser.setTotalAmount(c2cUser.getTotalAmount() + c2cOrder.getAmountUsdt());
        c2cUser.setTotalSuccessOrders(c2cUser.getTotalSuccessOrders() + 1);
        if (C2cOrder.DIRECTION_SELL.equals(c2cOrder.getDirection())) {
            // 卖币
            // 用户出售承兑商付款 相当于给承兑商账户充值了保证金
            c2cUser.setDepositOpen(Double.valueOf(df.format(Arith.add(c2cUser.getDepositOpen(), c2cOrder.getAmountUsdt()))).doubleValue());
        }
        this.c2cUserService.updateById(c2cUser);
        this.tipService.deleteTip(c2cOrder.getUuid().toString());
        //this.c2cSendMessageByState(c2cOrder, "3");
    }

    @Override
    public void savePass(C2cOrder c2cOrder, String safeword, String operator_username) {

        if ("3".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("订单已完成，无法放行");
        }
        if ("4".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("订单已取消，无法放行");
        }
        saveOrderPass(c2cOrder);
        User order_user = userService.getById(c2cOrder.getPartyId());
        this.saveLog(order_user.getUserName(), operator_username, "C2C订单放行", c2cOrder.getPartyId().toString());
    }

    @Override
    public Map<String, Object> detail(C2cOrder order) {

        Map<String, String> pmtMap = this.c2cAdvertService
                .getC2cSyspara("c2c_payment_method_type");
        Map<String, Object> result = new HashMap<String, Object>();
        result.put("id", order.getUuid());
        result.put("party_id", order.getPartyId());
        result.put("c2c_user_id", order.getC2cUserId());
        result.put("c2c_advert_id", order.getC2cAdvertId());
        result.put("payment_method_id", order.getPaymentMethodId());
        result.put("order_type", order.getOrderType());
        result.put("order_no", order.getOrderNo());
        result.put("state", order.getState());
        result.put("c2c_user_type", order.getC2cUserType());
        result.put("c2c_user_code", order.getC2cUserCode());
        result.put("c2c_user_nick_name", order.getC2cUserNickName());
        result.put("c2c_user_party_id", order.getC2cUserPartyId());
        result.put("c2c_user_party_code", order.getC2cUserPartyCode());
        result.put("c2c_user_party_name", order.getC2cUserPartyName());
        result.put("direction", order.getDirection());
        result.put("currency", order.getCurrency());
        result.put("symbol", order.getSymbol().toUpperCase());
        result.put("pay_rate", order.getPayRate());
        result.put("symbol_value", order.getSymbolValue());
        result.put("coin_amount", order.getCoinAmount());
        result.put("expire_time", order.getExpireTime());
        result.put("amount", order.getAmount());
        result.put("method_type", order.getMethodType());
        String methodType = String.valueOf(order.getMethodType());
        result.put("method_type_name", pmtMap.containsKey(methodType) ? pmtMap.get(methodType) : methodType);
        result.put("method_name", order.getMethodName());
        result.put("method_img", awsS3OSSFileService.getUrl(order.getMethodImg()));
        result.put("real_name", order.getRealName());
        result.put("param_name1", order.getParamName1());
        result.put("param_value1", order.getParamValue1());
        result.put("param_name2", order.getParamName2());
        result.put("param_value2", order.getParamValue2());
        result.put("param_name3", order.getParamName3());
        result.put("param_value3", order.getParamValue3());
        result.put("param_name4", order.getParamName4());
        result.put("param_value4", order.getParamValue4());
        result.put("param_name5", order.getParamName5());
        result.put("param_value5", order.getParamValue5());
        result.put("param_name6", order.getParamName6());
        result.put("param_value6", order.getParamValue6());
        result.put("param_name7", order.getParamName7());
        result.put("param_value7", order.getParamValue7());
        result.put("param_name8", order.getParamName8());
        result.put("param_value8", order.getParamValue8());
        result.put("param_name9", order.getParamName9());
        result.put("param_value9", order.getParamValue9());
        result.put("param_name10", order.getParamName10());
        result.put("param_value10", order.getParamValue10());
        result.put("param_name11", order.getParamName11());
        result.put("param_value11", order.getParamValue11());
        result.put("param_name12", order.getParamName12());
        result.put("param_value12", order.getParamValue12());
        result.put("param_name13", order.getParamName13());
        result.put("param_value13", order.getParamValue13());
        result.put("param_name14", order.getParamName14());
        result.put("param_value14", order.getParamValue14());
        result.put("param_name15", order.getParamName15());
        result.put("param_value15", order.getParamValue15());
        result.put("qrcode", order.getQrcode());
        result.put("remark", order.getRemark());
        result.put("img", awsS3OSSFileService.getUrl(order.getImg()));

        result.put("create_time", DateUtils.format(order.getCreateTime(), DateUtils.DF_yyyyMMddHHmmss));
        result.put("handle_time", DateUtils.format(order.getHandleTime(), DateUtils.DF_yyyyMMddHHmmss));
        result.put("close_time", DateUtils.format(order.getCloseTime(), DateUtils.DF_yyyyMMddHHmmss));
        result.put("pay_time", DateUtils.format(order.getPayTime(), DateUtils.DF_yyyyMMddHHmmss));
        result.put("cancel_time", DateUtils.format(order.getCancelTime(), DateUtils.DF_yyyyMMddHHmmss));
        return result;
    }

    @Override
    public void saveOpenQuickApply(C2cOrder c2cOrder) {

        C2cPaymentMethod method = this.c2cPaymentMethodService.get(c2cOrder.getPaymentMethodId());
        if (null == method) {
            throw new BusinessException("支付方式不存在");
        }

        C2cAdvert c2cAdvert = this.c2cAdvertService.getById(c2cOrder.getC2cAdvertId());
        if (null == c2cAdvert) {
            throw new BusinessException("广告不存在");
        }

        c2cOrder.setC2cUserId(c2cAdvert.getC2cUserId());

        if (C2cAdvert.DIRECTION_BUY.equals(c2cAdvert.getDirection())) {
            // 买币 订单存承兑商支付方式

            C2cUser c2cUser = this.c2cUserService.getById(c2cAdvert.getC2cUserId());
            if (null == c2cUser) {
                throw new BusinessException("承兑商不存在");
            }

            Map<String, C2cPaymentMethod> methodMap = this.c2cPaymentMethodService.getByPartyId(c2cUser.getC2cUserPartyId());
            if (null == methodMap) {
                throw new BusinessException("承兑商支付方式不存在");
            }

            boolean found = false;
            for (String id : methodMap.keySet()) {
                C2cPaymentMethod cpm = methodMap.get(id);
                if (null != cpm && cpm.getMethodConfigId().equals(method.getMethodConfigId())) {
                    c2cOrder.setPaymentMethodId(method.getUuid().toString());
                    found = true;
                    break;
                }
            }
            if (!found) {
                throw new BusinessException("承兑商支付方式不存在");
            }

        } else if (C2cAdvert.DIRECTION_SELL.equals(c2cAdvert.getDirection())) {
            // 卖币 订单存用户支付方式
        } else {
            throw new BusinessException("买卖方式不正确");
        }

        boolean lock = false;
        String partyId = c2cOrder.getPartyId();
        try {

            if (!C2cLock.add(partyId)) {
                throw new BusinessException("Please try again later");
            }
            lock = true;

            //  if (C2cAdvertLock.add(c2cOrder.getC2cAdvertId())) {
            this.saveOpen(c2cOrder, "");
            //}

        } catch (BusinessException e) {
            throw e;
        } catch (Throwable t) {
            throw t;
        } finally {
            if (lock) {
                C2cLock.remove(partyId);
            }
        }
    }


    /**
     * 订单取消
     *
     * @param role: user/用户；manager/承兑商管理员、root和admin；timer/订单自动取消定时器；
     */
    public void saveC2COrderCancel(C2cOrder c2cOrder, String role) {

        DecimalFormat df = new DecimalFormat("#.########");
        if ("4".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("该订单已取消");
        }
        if ("3".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("该订单已完成");
        }
        if ("recharge".equals(c2cOrder.getDirection())) {
            // 充值
        } else if ("withdraw".equals(c2cOrder.getDirection())) {
            // 提现
            // 用户钱包退还
            Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
            double amountBefore = wallet.getMoney().doubleValue();
            double amountAfter = Double.valueOf(df.format(Arith.add(wallet.getMoney().doubleValue(), c2cOrder.getCoinAmount()))).doubleValue();
            this.walletService.update(c2cOrder.getPartyId().toString(), c2cOrder.getCoinAmount());
            // 保存 资金日志
            MoneyLog moneyLog = new MoneyLog();
            moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
            moneyLog.setAmountBefore(new BigDecimal(amountBefore));
            moneyLog.setAmount(new BigDecimal(c2cOrder.getCoinAmount()));
            moneyLog.setAmountAfter(new BigDecimal(amountAfter));
            moneyLog.setLog("银行卡订单取消，订单号[" + c2cOrder.getOrderNo() + "]");
            moneyLog.setUserId(c2cOrder.getPartyId());
            moneyLog.setWalletType(c2cOrder.getSymbol());
            moneyLog.setSymbol(c2cOrder.getSymbol());


            moneyLog.setContentType(Constants.MONEYLOG_CONTENT_OTC_CANCEL);
            this.moneyLogService.save(moneyLog);
            // 保存 充提记录
            WalletLog walletLog = new WalletLog();
            walletLog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
            walletLog.setPartyId(c2cOrder.getPartyId());
            walletLog.setOrderNo(c2cOrder.getOrderNo());
            walletLog.setStatus(Integer.valueOf(c2cOrder.getState()).intValue());
            walletLog.setAmount(c2cOrder.getCoinAmount());
            walletLog.setWallettype(c2cOrder.getSymbol());
            moneyLog.setSymbol(c2cOrder.getSymbol());
            this.walletLogService.save(walletLog);
        }
        c2cOrder.setState("4");
        c2cOrder.setCancelTime(new Date());
        updateById(c2cOrder);
        this.updateNofinishOrderCount(c2cOrder);
        this.tipService.deleteTip(c2cOrder.getUuid().toString());
        // 取消次数加1
        String partyIdCancel = "";
        if ("user".equals(role)) {
            partyIdCancel = c2cOrder.getPartyId();
        }
        if (!"".equals(partyIdCancel)) {
            Map<String, Integer> map = (Map<String, Integer>) redisTemplate.opsForValue().get(RedisKeys.C2C_ORDER_CANCEL_DAY_TIMES);
            if (null == map) {
                map = new ConcurrentHashMap<String, Integer>();
            }
            if (null == map.get(partyIdCancel)) {
                map.put(partyIdCancel, 1);
            } else {
                map.put(partyIdCancel, map.get(partyIdCancel) + 1);
            }
            redisTemplate.opsForValue().set(RedisKeys.C2C_ORDER_CANCEL_DAY_TIMES, map);
        }
    }


    /**
     * 订单取消
     *
     * @param role: user/用户；manager/承兑商管理员、root和admin；timer/订单自动取消定时器；
     */
    public void saveOrderCancel(C2cOrder c2cOrder, String role) {

        DecimalFormat df = new DecimalFormat("#.########");
        if ("4".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("该订单已取消");
        }
        if ("3".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("该订单已完成");
        }
        if ("recharge".equals(c2cOrder.getDirection())) {
            // 充值
        } else if ("withdraw".equals(c2cOrder.getDirection())) {
            // 提现
            // 用户钱包退还
            Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
            double amountBefore = wallet.getMoney().doubleValue();
            double amountAfter = Double.valueOf(df.format(Arith.add(wallet.getMoney().doubleValue(), c2cOrder.getCoinAmount()))).doubleValue();
            this.walletService.update(c2cOrder.getPartyId().toString(), c2cOrder.getCoinAmount());
            // 保存 资金日志
            MoneyLog moneyLog = new MoneyLog();
            moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
            moneyLog.setAmountBefore(new BigDecimal(amountBefore));
            moneyLog.setAmount(new BigDecimal(c2cOrder.getCoinAmount()));
            moneyLog.setAmountAfter(new BigDecimal(amountAfter));
            moneyLog.setLog("银行卡订单取消，订单号[" + c2cOrder.getOrderNo() + "]");
            moneyLog.setUserId(c2cOrder.getPartyId());
            moneyLog.setWalletType(c2cOrder.getSymbol());
            moneyLog.setSymbol(c2cOrder.getSymbol());
            moneyLog.setContentType(Constants.MONEYLOG_CONTENT_BANK_CARD_ORDER_CANCEL);
            moneyLog.setCreateTime(new Date());
            this.moneyLogService.save(moneyLog);
            // 保存 充提记录
            WalletLog walletLog = new WalletLog();
            walletLog.setCategory(Constants.MONEYLOG_CATEGORY_BANK_CARD_WITHDRAW);
            walletLog.setPartyId(c2cOrder.getPartyId());
            walletLog.setOrderNo(c2cOrder.getOrderNo());
            walletLog.setStatus(Integer.valueOf(c2cOrder.getState()).intValue());
            walletLog.setAmount(c2cOrder.getCoinAmount());
            walletLog.setWallettype(c2cOrder.getSymbol());
            moneyLog.setSymbol(c2cOrder.getSymbol());
            this.walletLogService.save(walletLog);
        }
        c2cOrder.setState("4");
        c2cOrder.setCancelTime(new Date());
        updateById(c2cOrder);
        this.updateNofinishOrderCount(c2cOrder);
        this.tipService.deleteTip(c2cOrder.getUuid().toString());
        // 取消次数加1
        String partyIdCancel = "";
        if ("user".equals(role)) {
            partyIdCancel = c2cOrder.getPartyId();
        }
        if (!"".equals(partyIdCancel)) {
            Map<String, Integer> map = (Map<String, Integer>) redisTemplate.opsForValue().get(RedisKeys.C2C_ORDER_CANCEL_DAY_TIMES);
            if (null == map) {
                map = new ConcurrentHashMap<String, Integer>();
            }
            if (null == map.get(partyIdCancel)) {
                map.put(partyIdCancel, 1);
            } else {
                map.put(partyIdCancel, map.get(partyIdCancel) + 1);
            }
            redisTemplate.opsForValue().set(RedisKeys.C2C_ORDER_CANCEL_DAY_TIMES, map);
        }
    }

    /*
     * 用户未结束订单数量（0未付款）减1
     */
    public void updateNofinishOrderCount(C2cOrder entity) {

        Map<String, Long> ocMap = (Map<String, Long>) redisTemplate.opsForValue().get(RedisKeys.C2C_NOFINISH_ORDER_COUNT);
        if (null == ocMap) {
            ocMap = new ConcurrentHashMap<String, Long>();
        }
        Long count = ocMap.get(entity.getPartyId());
        if (null == count) {
            ocMap.put(entity.getPartyId(), 0L);
        } else {
            ocMap.put(entity.getPartyId(), count - 1 <= 0 ? 0 : count - 1);
        }
        redisTemplate.opsForValue().set(RedisKeys.C2C_NOFINISH_ORDER_COUNT, ocMap);
    }

    /**
     * 手动放行
     */
    @Override
    @Transactional
    public void manualRelease(C2cOrder c2cOrder, String operator_username) {
        if ("3".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("订单已完成，无法放行");
        }
        if ("4".equals(c2cOrder.getState())) {
            throw new YamiShopBindException("订单已取消，无法放行");
        }

        DecimalFormat df = new DecimalFormat("#.########");
        String logStr = "银行卡订单充值放行，订单号[" + c2cOrder.getOrderNo() + "]";
        ;
        if ("recharge".equals(c2cOrder.getDirection())) {
            // 充值

            // 给用户账户添加相应的币种数量
            Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
            double amountBefore = wallet.getMoney().doubleValue();
            double amountAfter = Double.valueOf(df.format(Arith.add(wallet.getMoney().doubleValue(), c2cOrder.getCoinAmount()))).doubleValue();
            this.walletService.update(c2cOrder.getPartyId().toString(), c2cOrder.getCoinAmount());

            // 保存 资金日志
            MoneyLog moneyLog = new MoneyLog();
            moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
            moneyLog.setAmountBefore(new BigDecimal(amountBefore));
            moneyLog.setAmount(new BigDecimal(c2cOrder.getCoinAmount()));
            moneyLog.setAmountAfter(new BigDecimal(amountAfter));
            moneyLog.setLog("银行卡订单充值放行，订单号[" + c2cOrder.getOrderNo() + "]");
            moneyLog.setUserId(c2cOrder.getPartyId());
            moneyLog.setWalletType(c2cOrder.getSymbol());
            moneyLog.setContentType(Constants.MONEYLOG_CONTENT_BANK_CARD_RECHARGE);
            moneyLog.setCreateTime(new Date());
            moneyLog.setUpdateTime(new Date());
            this.moneyLogService.save(moneyLog);

            // 保存 充提记录
            WalletLog walletLog = new WalletLog();
            walletLog.setCategory(Constants.MONEYLOG_CATEGORY_BANK_CARD_RECHARGE);
            walletLog.setPartyId(c2cOrder.getPartyId());
            walletLog.setOrderNo(c2cOrder.getOrderNo());
            walletLog.setStatus(Integer.valueOf(c2cOrder.getState()).intValue());
            walletLog.setAmount(c2cOrder.getCoinAmount());
            walletLog.setWallettype(c2cOrder.getSymbol());
            walletLog.setCreateTime(new Date());
            this.walletLogService.save(walletLog);

            this.userDataService.saveRechargeHandle(c2cOrder.getPartyId(), c2cOrder.getCoinAmount(), c2cOrder.getSymbol().toLowerCase());
        } else if ("withdraw".equals(c2cOrder.getDirection())) {
            // 提现

            this.userDataService.saveWithdrawHandle(c2cOrder.getPartyId(), c2cOrder.getCoinAmount(), 0d, "usdt");
            logStr = "银行卡订单提现放行，订单号[" + c2cOrder.getOrderNo() + "]";
        }

        // 订单完成
        c2cOrder.setState("3");
        c2cOrder.setHandleTime(new Date());
        updateById(c2cOrder);
        this.updateNofinishOrderCount(c2cOrder);

        this.tipService.deleteTip(c2cOrder.getUuid().toString());

        User order_user = userService.getById(c2cOrder.getPartyId());
        //  this.saveLog(order_user.getUserName(), operator_username, "订单放行", c2cOrder.getPartyId().toString());
        Log log = new Log();
        log.setCategory(Constants.LOG_CATEGORY_BANK_CARD_RW);
        log.setUsername(operator_username);
        log.setUserId(c2cOrder.getPartyId());
        log.setOperator(operator_username);
        log.setLog(logStr);
        log.setCreateTime(new Date());
        logService.save(log);
    }

    /**
     * 取消订单
     *
     * @param id
     * @param reason
     */
    @Override
    public void orderCancel(String id, String reason) {
//        C2cOrder c2cOrder= getById(id);
//        if (c2cOrder==null){
//            throw  new YamiShopBindException("参数错误!");
//        }
//        if (c2cOrder.getStatus()!=0){
//            throw  new YamiShopBindException("订单已操作过了!");
//        }
//        Date now=new Date();
//        c2cOrder.setStatus(4);
//        c2cOrder.setReason(reason);
//        c2cOrder.setHandleTime(now);
//        c2cOrder.setUpdateTime(now);
//        updateById(c2cOrder);
    }

    @Override
    public Page pagedQuery(int pageNo, int pageSize, List<String> direction, String state, String loginPartyId, boolean isC2cUser) {
        Page page = new Page(pageNo, pageSize);
        baseMapper.pagedQueryC2c(page, direction, state, loginPartyId, isC2cUser);
        // 金额默认保留2位
        DecimalFormat df = new DecimalFormat("#.##");
        // 币种默认保留8位
        DecimalFormat dfCoin = new DecimalFormat("#.########");
        for (Map<String, Object> data : (List<Map<String, Object>>) page.getRecords()) {
            data.put("symbol_value", df.format(data.get("symbol_value")));
            data.put("coin_amount", dfCoin.format(data.get("coin_amount")));
            data.put("symbol", data.get("symbol").toString().toUpperCase());
        }

        return page;
    }

    @Override
    public Page pagedQuery(long pageNo, long pageSize, String status, String orderNo, String userCode, String rolename,
                           String c2cUserCode, String c2cUserType, String c2cUserPartyCode, List<String> direction, List<String> children) {
        Page page = new Page(pageNo, pageSize);
        return baseMapper.pagedC2cQuery(page, status, orderNo, userCode, rolename, c2cUserCode, c2cUserType, c2cUserPartyCode, direction, children);
    }


    public void saveOpen(C2cOrder c2cOrder, String remark) {
        log.error("saveOpen start:" + remark);
        C2cAdvert c2cAdvert = this.c2cAdvertService.getById(c2cOrder.getC2cAdvertId());
        if (null == c2cAdvert) {
            throw new YamiShopBindException("广告不存在");
        }

        if (1 != c2cAdvert.getOnSale()) {
            throw new YamiShopBindException("广告已下架");
        }

        User party = userService.getById(c2cOrder.getPartyId());
        if (null == party) {
            throw new YamiShopBindException("用户信息不存在");
        }

        C2cUser c2cUser = this.c2cUserService.getById(c2cAdvert.getC2cUserId());
        if (null == c2cUser) {
            throw new YamiShopBindException("承兑商不存在");
        }
        User c2cParty = userService.getById(c2cUser.getC2cUserPartyId());

        if (null == c2cParty) {
            throw new YamiShopBindException("承兑商的用户信息不存在");
        }

        C2cPaymentMethod method = this.c2cPaymentMethodService.get(c2cOrder.getPaymentMethodId());
        if (null == method) {
            throw new YamiShopBindException("支付方式不存在");
        }

        if (C2cAdvert.DIRECTION_SELL.equals(c2cAdvert.getDirection())) {

//            if (!party.isWithdrawAuthority()) {
//                throw new YamiShopBindException( "无权限");
//            }

            this.checkSellAuth(c2cOrder.getPartyId());
            this.checkSellNum(c2cOrder.getPartyId());

            if (!method.getPartyId().equals(c2cOrder.getPartyId())) {
                throw new YamiShopBindException("支付方式不匹配该用户");
            }
        } else {

//            if (!method.getPartyId().equals(c2cUser.getC2cUserPartyId())) {
//                throw new YamiShopBindException("支付方式不匹配该承兑商");
//            }
        }

        c2cOrder.setC2cUserType(c2cUser.getC2cUserType());
        c2cOrder.setC2cUserCode(c2cUser.getC2cUserCode());
        c2cOrder.setC2cUserNickName(c2cUser.getNickName());
        c2cOrder.setC2cUserHeadImg(c2cUser.getHeadImg());
        c2cOrder.setC2cUserPartyId(c2cUser.getC2cUserPartyId());
        c2cOrder.setC2cUserPartyCode(c2cParty.getUserCode());
        c2cOrder.setC2cUserPartyName(c2cParty.getUserName());
        c2cOrder.setDirection(c2cAdvert.getDirection());
        c2cOrder.setCurrency(c2cAdvert.getCurrency());
        c2cOrder.setSymbol(c2cAdvert.getSymbol());
        c2cOrder.setPayRate(c2cAdvert.getPayRate());
        c2cOrder.setSymbolValue(c2cAdvert.getSymbolValue());
        c2cOrder.setExpireTime(c2cAdvert.getExpireTime());
        c2cOrder.setMethodType(method.getMethodType());
        c2cOrder.setMethodName(method.getMethodName());
        c2cOrder.setMethodImg(method.getMethodImg());
        c2cOrder.setRealName(method.getRealName());
        c2cOrder.setParamName1(method.getParamName1());
        c2cOrder.setParamValue1(method.getParamValue1());
        c2cOrder.setParamName2(method.getParamName2());
        c2cOrder.setParamValue2(method.getParamValue2());
        c2cOrder.setParamName3(method.getParamName3());
        c2cOrder.setParamValue3(method.getParamValue3());
        c2cOrder.setParamName4(method.getParamName4());
        c2cOrder.setParamValue4(method.getParamValue4());
        c2cOrder.setParamName5(method.getParamName5());
        c2cOrder.setParamValue5(method.getParamValue5());
        c2cOrder.setParamName6(method.getParamName6());
        c2cOrder.setParamValue6(method.getParamValue6());
        c2cOrder.setParamName7(method.getParamName7());
        c2cOrder.setParamValue7(method.getParamValue7());
        c2cOrder.setParamName8(method.getParamName8());
        c2cOrder.setParamValue8(method.getParamValue8());
        c2cOrder.setParamName9(method.getParamName9());
        c2cOrder.setParamValue9(method.getParamValue9());
        c2cOrder.setParamName10(method.getParamName10());
        c2cOrder.setParamValue10(method.getParamValue10());
        c2cOrder.setParamName11(method.getParamName11());
        c2cOrder.setParamValue11(method.getParamValue11());
        c2cOrder.setParamName12(method.getParamName12());
        c2cOrder.setParamValue12(method.getParamValue12());
        c2cOrder.setParamName13(method.getParamName13());
        c2cOrder.setParamValue13(method.getParamValue13());
        c2cOrder.setParamName14(method.getParamName14());
        c2cOrder.setParamValue14(method.getParamValue14());
        c2cOrder.setParamName15(method.getParamName15());
        c2cOrder.setParamValue15(method.getParamValue15());
        c2cOrder.setQrcode(method.getQrcode());
        c2cOrder.setCreateTime(new Date());
        c2cOrder.setHandleTime(null);
        c2cOrder.setCloseTime(DateUtils.addMinute(c2cOrder.getCreateTime(), c2cOrder.getExpireTime()));
        c2cOrder.setPayTime(null);
        c2cOrder.setCancelTime(null);

        // 币种单价
        double symbolValue = c2cAdvert.getSymbolValue();
        if (C2cAdvert.DIRECTION_BUY.equals(c2cAdvert.getDirection())) {
            // 买币
            this.saveBuy(c2cOrder, c2cAdvert, symbolValue, remark);
        } else if (C2cAdvert.DIRECTION_SELL.equals(c2cAdvert.getDirection())) {
            // 卖币
            this.saveSell(c2cOrder, c2cAdvert, symbolValue, remark);
        } else {
            throw new YamiShopBindException("买卖方式不正确");
        }

        this.tipService.saveTip(c2cOrder.getUuid().toString(), TipConstants.C2C_ORDER, c2cOrder.getPartyId());
        //  this.c2cSendMessageByState(c2cOrder, "0");
        log.error("saveOpen end:" + remark);
    }


    /**
     * 检测用户可卖币次数
     */
    public void checkSellNum(String partyId) {
        // 当日提现次数是否超过
        Object obj = this.sysparaService.find("c2c_sell_limit_num");
        if (null != obj) {
            double c2c_sell_limit_num = Double.valueOf(this.sysparaService.find("c2c_sell_limit_num").getSvalue());
            List<C2cOrder> c2cOrders = this.findByPartyIdAndToday(partyId, C2cAdvert.DIRECTION_SELL, null);

            if (c2c_sell_limit_num > 0 && c2cOrders != null) {
                if (c2cOrders.size() >= c2c_sell_limit_num) {
                    throw new BusinessException(1, "当日可提现次数不足");
                }
            }
        }
    }

    /**
     * 检测用户可卖币权限
     */
    public void checkSellAuth(String partyId) {
        RealNameAuthRecord party_kyc = realNameAuthRecordService.getByUserId(partyId);
        Object objKyc = this.sysparaService.find("c2c_sell_by_kyc");
        if (null != objKyc) {
            if (party_kyc == null) {
                party_kyc = new RealNameAuthRecord();
            }
            if (!(party_kyc.getStatus() == 2) && "true".equals(this.sysparaService.find("c2c_sell_by_kyc").getSvalue())) {
                throw new BusinessException(401, "无权限");
            }
        }
        HighLevelAuthRecord party_kycHighLevel = highLevelAuthRecordService.findByUserId(partyId);
        Object objKycHigh = this.sysparaService.find("c2c_sell_by_high_kyc");
        if (null != objKycHigh) {
            if (party_kycHighLevel == null) {
                party_kycHighLevel = new HighLevelAuthRecord();
            }
            if (!(party_kycHighLevel.getStatus() == 2) && "true".equals(this.sysparaService.find("c2c_sell_by_high_kyc").getSvalue())) {
                throw new BusinessException(1, "请先通过高级认证");
            }
        }
    }

    private void saveSell(C2cOrder c2cOrder, C2cAdvert c2cAdvert, double symbol_value, String remark) {
        log.error("saveSell start::" + remark);
        DecimalFormat df = new DecimalFormat("#.########");

        if (C2cOrder.ORDER_TYPE_BY_AMOUNT.equals(c2cOrder.getOrderType())) {
            // 按支付金额支付

            // 币种数量 = 支付金额/币种单价
            double coin_amount = Double.valueOf(df.format(Arith.div(c2cOrder.getAmount(), symbol_value, 10)));
            c2cOrder.setCoinAmount(coin_amount);
            c2cOrder.setAmountUsdt(Double.valueOf(df.format(Arith.mul(coin_amount, c2cAdvert.getSymbolClose(), 10))).doubleValue());
        } else {
            // 按币种数量支付
            c2cOrder.setAmount(Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), symbol_value))));
            c2cOrder.setAmountUsdt(Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), c2cAdvert.getSymbolClose(), 10))).doubleValue());
        }
        log.error("sell save start::" + remark);
        this.save(c2cOrder);
        log.error("save save end::" + remark);
        // 买入金额需要在区间内
        if (c2cOrder.getAmount() > c2cAdvert.getInvestmentMax() || c2cOrder.getAmount() < c2cAdvert.getInvestmentMin()) {
            throw new YamiShopBindException("金额不在购买区间");
        }

        double amountBefore = 0d;
        double amountAfter = 0d;

        if ("usdt".equalsIgnoreCase(c2cAdvert.getSymbol())) {

            Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
            if (c2cOrder.getCoinAmount() > wallet.getMoney().doubleValue()) {
                throw new YamiShopBindException("用户剩余数量不足");
            }

            amountBefore = wallet.getMoney().doubleValue();
            amountAfter = Double.valueOf(df.format(Arith.sub(wallet.getMoney().doubleValue(), c2cOrder.getCoinAmount()))).doubleValue();
            this.walletService.update(c2cOrder.getPartyId(), Arith.sub(0, c2cOrder.getCoinAmount()));
        } else {

            WalletExtend walletExtend = this.walletService.saveExtendByPara(c2cOrder.getPartyId(), c2cOrder.getSymbol());

            if (c2cOrder.getCoinAmount() > walletExtend.getAmount()) {
                throw new YamiShopBindException("用户剩余数量不足");
            }

            amountBefore = walletExtend.getAmount();
            amountAfter = Double.valueOf(df.format(Arith.sub(walletExtend.getAmount(), c2cOrder.getCoinAmount()))).doubleValue();
            this.walletService.updateExtend(c2cOrder.getPartyId(), c2cOrder.getSymbol(), Arith.sub(0, c2cOrder.getCoinAmount()));
        }

        // 保存资金日志
        MoneyLog moneylog = new MoneyLog();
        moneylog.setCategory(Constants.MONEYLOG_CATEGORY_C2C);
        moneylog.setAmountBefore(new BigDecimal(amountBefore));
        moneylog.setAmount(new BigDecimal(Arith.sub(0, c2cOrder.getCoinAmount())));
        moneylog.setAmountAfter(new BigDecimal(amountAfter));
        moneylog.setLog("c2c卖币，币种[" + c2cOrder.getSymbol() + "]，订单号[" + c2cOrder.getOrderNo() + "]");
        moneylog.setUserId(c2cOrder.getPartyId());
        moneylog.setWalletType(c2cOrder.getSymbol());
        moneylog.setContentType(Constants.MONEYLOG_CONTENT_C2C_SELL);
        moneyLogService.save(moneylog);

        c2cAdvert.setSortIndex(0);
        this.c2cAdvertService.updateById(c2cAdvert);
        log.error("saveSell end::" + remark);
    }

    private void saveBuy(C2cOrder c2cOrder, C2cAdvert c2cAdvert, double symbol_value, String remark) {
        log.error("saveBuy start:" + remark);
        DecimalFormat df = new DecimalFormat("#.########");

        if (C2cOrder.ORDER_TYPE_BY_AMOUNT.equals(c2cOrder.getOrderType())) {
            // 按支付金额支付

            // 币种数量 = 支付金额/币种单价
            double coin_amount = Double.valueOf(df.format(Arith.div(c2cOrder.getAmount(), symbol_value, 8))).doubleValue();

            if (coin_amount > c2cAdvert.getCoinAmount()) {
                throw new YamiShopBindException("该广告剩余数量不足");
            }

            c2cOrder.setCoinAmount(coin_amount);
            c2cOrder.setAmountUsdt(Double.valueOf(df.format(Arith.mul(coin_amount, c2cAdvert.getSymbolClose()))).doubleValue());
            c2cAdvert.setCoinAmount(Double.valueOf(df.format(Arith.sub(c2cAdvert.getCoinAmount(), coin_amount))).doubleValue());
            c2cAdvert.setDeposit(Double.valueOf(df.format(Arith.sub(c2cAdvert.getDeposit(), c2cOrder.getAmountUsdt()))).doubleValue());
        } else {
            // 按币种数量支付

            if (c2cOrder.getCoinAmount() > c2cAdvert.getCoinAmount()) {
                throw new YamiShopBindException("该广告剩余数量不足");
            }

            c2cOrder.setAmount(Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), symbol_value))).doubleValue());
            c2cOrder.setAmountUsdt(Double.valueOf(df.format(Arith.mul(c2cOrder.getCoinAmount(), c2cAdvert.getSymbolClose()))).doubleValue());
            c2cAdvert.setCoinAmount(Double.valueOf(df.format(Arith.sub(c2cAdvert.getCoinAmount(), c2cOrder.getCoinAmount()))).doubleValue());
            c2cAdvert.setDeposit(Double.valueOf(df.format(Arith.sub(c2cAdvert.getDeposit(), c2cOrder.getAmountUsdt()))).doubleValue());
        }
        log.error("buy save start:" + remark);
        this.save(c2cOrder);
        log.error("buy save end:" + remark);
        // 买入金额需要在区间内https://enjdhdg.site/api/api/
        if (c2cOrder.getAmount() > c2cAdvert.getInvestmentMax() || c2cOrder.getAmount() < c2cAdvert.getInvestmentMin()) {
            throw new YamiShopBindException("金额不在购买区间");
        }

        c2cAdvert.setSortIndex(0);
        this.c2cAdvertService.updateById(c2cAdvert);
        log.error("saveBuy end:" + remark);
    }


    @Override
    public Page pagedBankCardOrderQuery(Page page, List<String> direction, String state, String userCode, String roleName, String orderNo, List<String> userIds) {
        return baseMapper.pagedBankCardOrderQuery(page, direction, state, userCode, roleName,
                orderNo, userIds);
    }

    @Override
    public Page pagedQuery(int pageNo, int pageSize, List<String> direction, String state, String loginPartyId) {
        Page page = new Page(pageNo, pageSize);
        baseMapper.pagedQuery(page, direction, state, loginPartyId);
        // 金额默认保留2位
        DecimalFormat df = new DecimalFormat("#.##");
        // 币种默认保留8位
        DecimalFormat dfCoin = new DecimalFormat("#.########");
        for (Map<String, Object> data : (List<Map<String, Object>>) page.getRecords()) {
            data.put("symbol_value", df.format(data.get("symbol_value")));
            data.put("coin_amount", dfCoin.format(data.get("coin_amount")));
            data.put("amount", dfCoin.format(data.get("amount")));
        }

        return page;
    }

    public List<C2cOrder> findByPartyIdAndToday(String partyId, String direction, String state) {

        Date now = new Date();
        if (StringUtils.isEmptyString(state)) {
            List<C2cOrder> list = list(Wrappers.<C2cOrder>query().lambda().eq(C2cOrder::getPartyId, partyId).eq(C2cOrder::getDirection, direction)
                    .between(C2cOrder::getCreateTime, DateUtil.minDate(now), DateUtil.maxDate(now)));
            return list;
        } else {
            List<C2cOrder> list = list(Wrappers.<C2cOrder>query().lambda().eq(C2cOrder::getPartyId, partyId).eq(C2cOrder::getDirection, direction)
                    .between(C2cOrder::getCreateTime, DateUtil.minDate(now), DateUtil.maxDate(now)).eq(C2cOrder::getState, state));
            return list;
        }
    }

    @Override
    public C2cOrder get(String order_no) {
        List<C2cOrder> list = list(Wrappers.<C2cOrder>query().lambda().eq(C2cOrder::getOrderNo, order_no));
        if (list.size() > 0) {
            return (C2cOrder) list.get(0);
        }
        return null;
    }

    public List<C2cPaymentMethod> getOrderPayments(String order_no, boolean c2cOrderFlag) {

        C2cOrder c2cOrder = get(order_no);
        if (null == c2cOrder) {
            throw new YamiShopBindException("订单不存在");
        }
        List<String> typeList = new ArrayList<>();
        if (c2cOrderFlag) {
            C2cAdvert c2cAdvert = c2cAdvertService.getById(c2cOrder.getC2cAdvertId());
            if (null == c2cAdvert) {
                throw new YamiShopBindException("广告不存在");
            }
            String[] types = c2cAdvert.getPayType().split(",");
            typeList = Arrays.asList(types);

        }

        List<C2cPaymentMethod> list = new ArrayList<C2cPaymentMethod>();
        Map<String, C2cPaymentMethod> methodMap = null;
        if (c2cOrderFlag) {
            methodMap = this.c2cPaymentMethodService.getByC2CPartyId(c2cOrder.getPartyId());

        } else {
            methodMap = this.c2cPaymentMethodService.getByBankCardPartyId(c2cOrder.getPartyId());
        }
        for (String key : methodMap.keySet()) {
            C2cPaymentMethod method = methodMap.get(key);
            if (null != method) {
                list.add(method);
            }
        }
        C2cPaymentMethod cpm = this.c2cPaymentMethodService.get(c2cOrder.getPaymentMethodId());
        List<C2cPaymentMethod> listRet = new ArrayList<C2cPaymentMethod>();
        // 先添加订单记录的支付方式
        for (C2cPaymentMethod pay : list) {
            if (c2cOrder.getPaymentMethodId().equals(pay.getUuid())) {
                listRet.add(pay);
            }
        }
        // 再添加与订单记录的支付方式类型相同的支付方式
        for (C2cPaymentMethod pay : list) {
            if (!c2cOrder.getPaymentMethodId().equals(pay.getUuid())) {
                if (cpm.getMethodConfigId().equals(pay.getMethodConfigId())) {
                    listRet.add(pay);
                }
            }
        }
        if (!c2cOrderFlag) {
            // 最后添加与广告匹配的支付方式
            for (C2cPaymentMethod pay : list) {
                if (!c2cOrder.getPaymentMethodId().equals(pay.getUuid()) && !cpm.getMethodConfigId().equals(pay.getMethodConfigId())) {
                    if (typeList.contains(pay.getMethodConfigId())) {
                        listRet.add(pay);
                    }
                }
            }
        }
        for (int i = 0; i < listRet.size(); i++) {
            C2cPaymentMethod method = listRet.get(i);
            String methodType = String.valueOf(method.getMethodType());
            Map<String, String> pmtMap = this.c2cAdvertService.getC2cSyspara("c2c_payment_method_type");
            method.setMethodTypeName(pmtMap.containsKey(methodType) ? pmtMap.get(methodType) : methodType);
        }
        return listRet;
    }

    @Override
    public void saveOrderPay(String order_no, String safeword, String operator_username, String payment_method_id_order_pay) {

        C2cOrder c2cOrder = get(order_no);
        if (null == c2cOrder) {
            throw new YamiShopBindException("订单不存在");
        }
        if (!Arrays.asList("0", "2").contains(c2cOrder.getState())) {
            throw new YamiShopBindException("订单不处于待支付或申诉中状态，无法转账");
        }
        C2cPaymentMethod method = this.c2cPaymentMethodService.get(payment_method_id_order_pay);
        // 更新最终的支付方式
        c2cOrder.setPaymentMethodId(method.getUuid());
        c2cOrder.setMethodType(method.getMethodType());
        c2cOrder.setMethodName(method.getMethodName());
        c2cOrder.setMethodImg(method.getMethodImg());
        c2cOrder.setRealName(method.getRealName());
        c2cOrder.setParamName1(method.getParamName1());
        c2cOrder.setParamValue1(method.getParamValue1());
        c2cOrder.setParamName2(method.getParamName2());
        c2cOrder.setParamValue2(method.getParamValue2());
        c2cOrder.setParamName3(method.getParamName3());
        c2cOrder.setParamValue3(method.getParamValue3());
        c2cOrder.setParamName4(method.getParamName4());
        c2cOrder.setParamValue4(method.getParamValue4());
        c2cOrder.setParamName5(method.getParamName5());
        c2cOrder.setParamValue5(method.getParamValue5());
        c2cOrder.setParamName6(method.getParamName6());
        c2cOrder.setParamValue6(method.getParamValue6());
        c2cOrder.setParamName7(method.getParamName7());
        c2cOrder.setParamValue7(method.getParamValue7());
        c2cOrder.setParamName8(method.getParamName8());
        c2cOrder.setParamValue8(method.getParamValue8());
        c2cOrder.setParamName9(method.getParamName9());
        c2cOrder.setParamValue9(method.getParamValue9());
        c2cOrder.setParamName10(method.getParamName10());
        c2cOrder.setParamValue10(method.getParamValue10());
        c2cOrder.setParamName11(method.getParamName11());
        c2cOrder.setParamValue11(method.getParamValue11());
        c2cOrder.setParamName12(method.getParamName12());
        c2cOrder.setParamValue12(method.getParamValue12());
        c2cOrder.setParamName13(method.getParamName13());
        c2cOrder.setParamValue13(method.getParamValue13());
        c2cOrder.setParamName14(method.getParamName14());
        c2cOrder.setParamValue14(method.getParamValue14());
        c2cOrder.setParamName15(method.getParamName15());
        c2cOrder.setParamValue15(method.getParamValue15());
        c2cOrder.setQrcode(method.getQrcode());
        c2cOrder.setState("1");
        c2cOrder.setPayTime(new Date());
        updateById(c2cOrder);

        this.tipService.deleteTip(c2cOrder.getUuid());
    }

    public void saveLog(String order_username, String operator, String context, String orderPartyId) {

        Log log = new Log();
        log.setCategory(Constants.LOG_CATEGORY_C2C);
        log.setUsername(order_username);
        log.setUserId(orderPartyId);
        log.setOperator(operator);
        log.setLog(context);
        log.setCreateTime(new Date());
        logService.save(log);
    }

    public void saveOpen(C2cOrder c2cOrder, User party) {
        //部分盘口无需充值方式
        if ("recharge".equals(c2cOrder.getDirection()) && StringUtils.isEmptyString(c2cOrder.getPaymentMethodId())) {
            Integer expireTime = c2cOrder.getExpireTime();
            if (expireTime == null || expireTime <= 0) {
                expireTime = 120;
            }
            Object obj = this.sysparaService.find("bank_card_expire_time");
            if (null != obj) {
                expireTime = Integer.valueOf(this.sysparaService.find("bank_card_expire_time").getSvalue()).intValue();
            }
            c2cOrder.setExpireTime(expireTime);
            c2cOrder.setMethodType(0);
            c2cOrder.setPaymentMethodId("");
            this.saveRecharge(c2cOrder, party);
            return;
        }

        C2cPaymentMethod method = c2cPaymentMethodService.get(c2cOrder.getPaymentMethodId());
        if (null == method) {
            throw new YamiShopBindException("支付方式不存在");
        }
        if ("withdraw".equals(c2cOrder.getDirection())) {
            String partyId = party.getUserId();
            if (!method.getPartyId().equals(partyId)) {
                throw new YamiShopBindException("支付方式不匹配该用户");
            }
            List<C2cOrder> allNotCompleteList = this.findAllNotComplete("withdraw", c2cOrder.getPartyId(), 0);
            if (!CollectionUtils.isEmpty(allNotCompleteList)) {
                throw new YamiShopBindException("当前有待处理提现订单，请稍后提现！");
            }

        } else {
//            if (!method.getPartyId().equals("2c948a8282920a9f01829270bcac0000")) {
//                throw new YamiShopBindException("支付方式不匹配官方");
            //  }
        }
        int expireTime = 45;
        Object obj = this.sysparaService.find("bank_card_expire_time");
        if (null != obj) {
            expireTime = Integer.valueOf(this.sysparaService.find("bank_card_expire_time").getSvalue()).intValue();
        }
        c2cOrder.setExpireTime(expireTime);
        c2cOrder.setMethodType(method.getMethodType());
        c2cOrder.setMethodName(method.getMethodName());
        c2cOrder.setMethodImg(method.getMethodImg());
        c2cOrder.setRealName(method.getRealName());
        c2cOrder.setParamName1(method.getParamName1());
        c2cOrder.setParamValue1(method.getParamValue1());
        c2cOrder.setParamName2(method.getParamName2());
        c2cOrder.setParamValue2(method.getParamValue2());
        c2cOrder.setParamName3(method.getParamName3());
        c2cOrder.setParamValue3(method.getParamValue3());
        c2cOrder.setParamName4(method.getParamName4());
        c2cOrder.setParamValue4(method.getParamValue4());
        c2cOrder.setParamName5(method.getParamName5());
        c2cOrder.setParamValue5(method.getParamValue5());
        c2cOrder.setParamName6(method.getParamName6());
        c2cOrder.setParamValue6(method.getParamValue6());
        c2cOrder.setParamName7(method.getParamName7());
        c2cOrder.setParamValue7(method.getParamValue7());
        c2cOrder.setParamName8(method.getParamName8());
        c2cOrder.setParamValue8(method.getParamValue8());
        c2cOrder.setParamName9(method.getParamName9());
        c2cOrder.setParamValue9(method.getParamValue9());
        c2cOrder.setParamName10(method.getParamName10());
        c2cOrder.setParamValue10(method.getParamValue10());
        c2cOrder.setParamName11(method.getParamName11());
        c2cOrder.setParamValue11(method.getParamValue11());
        c2cOrder.setParamName12(method.getParamName12());
        c2cOrder.setParamValue12(method.getParamValue12());
        c2cOrder.setParamName13(method.getParamName13());
        c2cOrder.setParamValue13(method.getParamValue13());
        c2cOrder.setParamName14(method.getParamName14());
        c2cOrder.setParamValue14(method.getParamValue14());
        c2cOrder.setParamName15(method.getParamName15());
        c2cOrder.setParamValue15(method.getParamValue15());
        c2cOrder.setQrcode(method.getQrcode());
        if ("recharge".equals(c2cOrder.getDirection())) {
            // 充值
            this.saveRecharge(c2cOrder, party);
        } else if ("withdraw".equals(c2cOrder.getDirection())) {
            // 提现
            this.saveWithdraw(c2cOrder);
        } else {
            throw new YamiShopBindException("充值或提现不正确");
        }
    }

    public List<C2cOrder> findAllNotComplete(String direction, String userId, Integer status) {
        return list(
                Wrappers.<C2cOrder>query().lambda()
                        .eq(C2cOrder::getDirection, direction)
                        .eq(C2cOrder::getPartyId, userId)
                        .eq(C2cOrder::getState, status));
    }

    private void saveWithdraw(C2cOrder c2cOrder) {

        DecimalFormat df = new DecimalFormat("#.########");
        Wallet wallet = this.walletService.saveWalletByPartyId(c2cOrder.getPartyId());
        if (c2cOrder.getCoinAmount() > wallet.getMoney().doubleValue()) {
            throw new YamiShopBindException("余额不足");
        }
        double amountBefore = wallet.getMoney().doubleValue();
        double amountAfter = Double.valueOf(df.format(Arith.sub(wallet.getMoney().doubleValue(), c2cOrder.getCoinAmount()))).doubleValue();
        this.walletService.update(c2cOrder.getPartyId(), Arith.sub(0, c2cOrder.getCoinAmount()));
        this.save(c2cOrder);
        this.tipService.saveTip(c2cOrder.getUuid(), TipConstants.BANK_CARD_ORDER, c2cOrder.getPartyId());
        // 保存 资金日志
        MoneyLog moneylog = new MoneyLog();
        moneylog.setCategory(Constants.MONEYLOG_CATEGORY_COIN);
        moneylog.setAmountBefore(new BigDecimal(amountBefore));
        moneylog.setAmount(new BigDecimal(Arith.sub(0, c2cOrder.getCoinAmount())));
        moneylog.setAmountAfter(new BigDecimal(amountAfter));
        moneylog.setLog("银行卡提现，币种[" + c2cOrder.getSymbol() + "]，订单号[" + c2cOrder.getOrderNo() + "]");
        moneylog.setUserId(c2cOrder.getPartyId());
        moneylog.setWalletType(c2cOrder.getSymbol());
        moneylog.setSymbol(c2cOrder.getSymbol());
        moneylog.setCreateTime(new Date());

        moneylog.setContentType(Constants.MONEYLOG_CONTENT_BANK_CARD_WITHDRAW);
        moneyLogService.save(moneylog);
        // 保存 充提记录
        WalletLog walletLog = new WalletLog();
        walletLog.setCategory(Constants.MONEYLOG_CATEGORY_BANK_CARD_WITHDRAW);
        walletLog.setPartyId(c2cOrder.getPartyId());
        walletLog.setOrderNo(c2cOrder.getOrderNo());
        walletLog.setStatus(Integer.valueOf(c2cOrder.getState()).intValue());
        walletLog.setAmount(c2cOrder.getCoinAmount());
        walletLog.setWallettype(c2cOrder.getSymbol());
        moneylog.setSymbol(c2cOrder.getSymbol());

        walletLogService.save(walletLog);
    }

    private void saveRecharge(C2cOrder c2cOrder, User party) {
        // 充值申请中的订单是否只能唯一：1唯一，2不限制
        double recharge_only_one = Double.valueOf(this.sysparaService.find("recharge_only_one").getSvalue());
        // 用户未完成USDT订单
        List<RechargeBlockchainOrder> orders = rechargeBlockchainOrderService.findByPartyIdAndSucceeded(party.getUserId(), 0);
        if (null != orders && 1 == recharge_only_one) {
            throw new YamiShopBindException("提交失败，当前有未处理USDT订单");
        }
        // 用户未结束银行卡订单数量
        Long nofinishOrderCount = this.getNofinishOrderCount(c2cOrder.getPartyId());
        if (null != nofinishOrderCount && 0 != nofinishOrderCount.longValue() && 1 == recharge_only_one) {
            throw new YamiShopBindException("提交失败，当前有未处理银行卡订单");
        }
        double recharge_limit_min = Double.valueOf(this.sysparaService.find("recharge_limit_min").getSvalue());
        double recharge_limit_max = Double.valueOf(this.sysparaService.find("recharge_limit_max").getSvalue());
        if (c2cOrder.getCoinAmount() < recharge_limit_min) {
            throw new YamiShopBindException("充值数量不得小于最小限额");
        }
        if (c2cOrder.getCoinAmount() > recharge_limit_max) {
            throw new YamiShopBindException("充值数量不得大于最大限额");
        }
        this.save(c2cOrder);
        this.tipService.saveTip(c2cOrder.getUuid().toString(), TipConstants.BANK_CARD_ORDER, c2cOrder.getPartyId());
    }


    public List<C2cOrder> getByPayId(String payId) {
        return list(Wrappers.<C2cOrder>query().lambda().eq(C2cOrder::getPaymentMethodId, payId).in(C2cOrder::getState, 0, 1));
    }

    @Override
    public C2cOrder findOrderNo(String orderNo) {
        return getOne(Wrappers.<C2cOrder>query().lambda().eq(C2cOrder::getOrderNo, orderNo));

    }

    /*
     * 获取 用户未结束订单数量
     */
    @Override
    public Long getNofinishOrderCount(String partyId) {

        Map<String, Long> ocMap = (Map<String, Long>) redisTemplate.opsForValue().get(RedisKeys.C2C_NOFINISH_ORDER_COUNT);
        if (null == ocMap) {
            return 0L;
        }
        Long count = ocMap.get(partyId);
        if (null == count) {
            return 0L;
        } else {
            return count;
        }
    }

    /*
     * 获取 用户未结束订单数量
     */
    public Long getNofinishOrderCount(String partyId, String direction) {
        List<C2cOrder> c2cOrderList = list(Wrappers.<C2cOrder>query().lambda()
                .eq(C2cOrder::getPartyId, partyId).eq(C2cOrder::getDirection, direction)
                .in(C2cOrder::getState,
                        1, 2));
        if (ObjectUtils.isNotEmpty(c2cOrderList)) {
            return (long) c2cOrderList.size();
        }
        return 0l;
    }

}