package com.yami.trading.api.controller;

import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.api.dto.FutureOpenAction;
import com.yami.trading.bean.future.domain.FuturesLock;
import com.yami.trading.bean.future.domain.FuturesOrder;
import com.yami.trading.bean.future.domain.FuturesPara;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.model.User;
import com.yami.trading.bean.model.Wallet;
import com.yami.trading.bean.syspara.domain.Syspara;
import com.yami.trading.common.domain.Result;
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.StringUtils;
import com.yami.trading.common.util.ThreadUtils;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.MarketOpenChecker;
import com.yami.trading.service.SessionTokenService;
import com.yami.trading.service.WalletService;
import com.yami.trading.service.future.FuturesOrderService;
import com.yami.trading.service.future.FuturesParaService;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.system.TipService;
import com.yami.trading.service.user.UserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import javax.validation.constraints.NotEmpty;
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;

/**
 * 交割合约订单
 */
@Api(tags = "【h5】交割合约订单")
@RestController
@CrossOrigin
@Slf4j
public class ApiFuturesOrderController {
    public final static String action = "/api/futuresOrder!";
    @Autowired
    SessionTokenService sessionTokenService;
    @Autowired
    WalletService walletService;
    @Autowired
    UserService partyService;
    @Autowired
    ItemService itemService;
    @Autowired
    FuturesOrderService futuresOrderService;
    @Autowired
    FuturesParaService futuresParaService;
    @Autowired
    SysparaService sysparaService;
    @Autowired
    TipService tipService;
//    @Autowired
//    private ExchangeRateService exchangeRateService;

    /**
     * 开仓页面参数
     * <p>
     * symbol 币种
     */
    @GetMapping(action + "openview.action")
    @ApiOperation(value = "开仓页面参数")
    public Result<Map<String, Object>> openview(@RequestParam @NotEmpty String symbol) {
        Map<String, Object> data = new HashMap<>();
        Item bySymbol = itemService.findBySymbol(symbol);
        if (bySymbol == null) {
            throw new YamiShopBindException("当前币对不存在");
        }

        Date now = new Date();
        List<Map<String, Object>> futuresParas = new ArrayList<>();
        for (FuturesPara para : this.futuresParaService.getBySymbolSort(symbol)) {
            Map<String, Object> map = new HashMap<String, Object>();
            map.put("para_id", para.getUuid());
            map.put("symbol", para.getSymbol());
            map.put("time_num", para.getTimenum());
            map.put("time_unit", para.getTimeunit());
            map.put("entityVersion", 0);
            map.put("timeUnitCn", para.getTimeunit());
            map.put("timestamp", para.getCreateTimeTs());
            map.put("now_time", now);
            DecimalFormat df = new DecimalFormat("#");
            if (para.getProfitRatio().doubleValue() < 0.01 || para.getProfitRatioMax().doubleValue() < 0.01) {
                df = new DecimalFormat("#.#");
            }
            // TMX start voaex
//		map.put("profit_ratio", df.format(Arith.mul(para.getProfit_ratio(), 100)));
            // TMX end
//		if(para.getProfit_ratio() != para.getProfit_ratio_max()) {
            map.put("profit_ratio", df.format(Arith.mul(para.getProfitRatio().doubleValue(), 100)) + "~"
                    + df.format(Arith.mul(para.getProfitRatioMax().doubleValue(), 100)));
//		}
            map.put("buy_min", para.getUnitAmount());
            map.put("unit_fee", para.getUnitFee());
            map.put("buy_max", para.getUnitMaxAmount().compareTo(BigDecimal.ZERO) <= 0 ? null : para.getUnitMaxAmount());
            futuresParas.add(map);
        }
        data.put("para", futuresParas);

        String partyId = SecurityUtils.getCurrentUserId();
        if (StrUtil.isNotBlank(partyId) && futuresParas != null) {
            Wallet wallet = this.walletService.findByUserId(partyId);
            // 账户剩余资金
            String session_token = this.sessionTokenService.savePut(partyId);
            data.put("session_token", session_token);
//            data.put("amount", exchangeRateService.getCurrencyByType(wallet.getMoney(), bySymbol.getType()).doubleValue());
            data.put("amount", wallet.getMoney());
        } else {
            data.put("amount", 0);
        }
        data.put("open", MarketOpenChecker.isMarketOpenByItemCloseType(bySymbol.getOpenCloseType()));
        return Result.succeed(data);
    }

    /**
     * 开仓
     * symbol 币种
     * direction "buy":多 "sell":空
     * amount 委托数量(张)
     * para_id 交割合约参数
     */
    @GetMapping(action + "open.action")
    @ApiOperation(value = "开仓")
    public Result<Map<String, String>> open(FutureOpenAction futureOpenAction) {
        Item bySymbol = itemService.findBySymbol(futureOpenAction.getSymbol());
        if (bySymbol == null) {
            throw new YamiShopBindException("当前币对不存在");
        }
        boolean isOpen = MarketOpenChecker.isMarketOpenByItemCloseType(bySymbol.getOpenCloseType());
        if (!isOpen) {
            throw new YamiShopBindException("当前已经休市");
        }

        String partyId = SecurityUtils.getUser().getUserId();
        boolean lock = false;
        try {
            Map<String, String> data = new HashMap<>();

            if (!FuturesLock.add(partyId)) {
                throw new YamiShopBindException("请稍后再试");
            }

            lock = true;
            String session_token = futureOpenAction.getSession_token();
            Object object = this.sessionTokenService.cacheGet(session_token);
            this.sessionTokenService.del(session_token);
            User party = this.partyService.findUserByUserCode(partyId);
            if (!party.isEnabled()) {
                throw new YamiShopBindException("用户已锁定");
            }
            if (null == object || !party.getUserId().equals((String) object)) {
                throw new BusinessException("请稍后再试");
            }
            Syspara syspara = sysparaService.find("stop_user_internet");
            String stopUserInternet = syspara.getSvalue();
            if (org.apache.commons.lang3.StringUtils.isNotEmpty(stopUserInternet)) {
                String[] stopUsers = stopUserInternet.split(",");
                if (Arrays.asList(stopUsers).contains(party.getUserName())) {
                    throw new YamiShopBindException("无网络");
                }
            }

            Date now = new Date();
            FuturesOrder order = new FuturesOrder();
            order.setPartyId(partyId);
            order.setSymbol(futureOpenAction.getSymbol());
            order.setDirection(futureOpenAction.getDirection());
            order.setVolume(futureOpenAction.getAmount().doubleValue());
            order.setCreateTime(now);
            order.setCreateTimeTs(now.getTime() / 1000L);
            order.setUpdateTime(now);
            order.setUpdateTimeTs(now.getTime() / 1000L);

            order = this.futuresOrderService.saveOpen(order, futureOpenAction.getPara_id());
            data.put("order_no", order.getOrderNo());
            data.put("open_price", order.getTradeAvgPrice().toString());
            return Result.succeed(data);
        } catch (Exception e) {
            log.error("开仓异常", e);
            throw new YamiShopBindException(e.getMessage());
        } finally {
            if (lock) {
                ThreadUtils.sleep(100);
                FuturesLock.remove(partyId);
            }
        }
    }

    /**
     * 查询交割持仓列表
     * <p>
     * page_no 页码
     * symbol 币种
     * type 开仓页面订单类型
     */
    @RequestMapping(action + "list.action")
    @ApiOperation("查询交割持仓列表,实时价格，通过价格接口取")
    public Result<List<Map<String, Object>>> list(@RequestParam(required = false) String symbol,
                                                  @RequestParam(required = false) String type,
                                                  @RequestParam(required = false) String page_no
            , @RequestParam(required = false) String date,
                                                  @RequestParam(required = false) String startTime,
                                                  @RequestParam(required = false) String endTime,
                                                  @RequestParam(required = false) String symbolType) {
        IPage<FuturesOrder> page = new Page<>();
        if (StringUtils.isEmptyString(page_no)) {
            page.setCurrent(1);
        } else {
            page.setCurrent(Long.parseLong(page_no));
            ;
        }
        String loginPartyId = SecurityUtils.getUser().getUserId();
        IPage<FuturesOrder> paged = this.futuresOrderService.getPaged(page, loginPartyId, symbol, type, date, startTime, endTime, symbolType);
        List<FuturesOrder> list = paged.getRecords();
        Result<List<Map<String, Object>>> succeed = Result.succeed(futuresOrderService.bulidData(list));
        succeed.setTotal(paged.getTotal());
        return succeed;
    }

    /**
     * 查询交割持仓详情
     * <p>
     * order_no 订单号
     */
    @RequestMapping(action + "get.action")
    public Result<Map<String, Object>> get(@RequestParam @NotEmpty String order_no) {
        FuturesOrder order = this.futuresOrderService.cacheByOrderNo(order_no);
        if (null == order) {
            log.info("futuresOrder!get order_no:" + order_no + ", order null");
            throw new YamiShopBindException("订单不存在");
        }
        return Result.succeed(this.futuresOrderService.bulidOne(order));
    }

}