package com.yami.trading.admin.controller.future;

import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.admin.facade.FuturesParaFacade;
import com.yami.trading.bean.future.domain.FuturesPara;
import com.yami.trading.bean.future.dto.FuturesParaDTO;
import com.yami.trading.bean.future.mapstruct.TFuturesParaWrapper;
import com.yami.trading.bean.future.query.FuturesParaQuery;
import com.yami.trading.bean.item.dto.ItemDTO;
import com.yami.trading.bean.item.query.ItemQuery;
import com.yami.trading.common.domain.Result;
import com.yami.trading.common.exception.YamiShopBindException;
import com.yami.trading.common.query.QueryWrapperGenerator;
import com.yami.trading.common.util.IPHelper;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.future.FuturesParaService;
import com.yami.trading.service.item.ItemService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.validation.Valid;
import java.math.BigDecimal;


/**
 * 交割合约管理Controller
 *
 * @author lucas
 * @version 2023-04-08
 */

@Api(tags = "【管理后台】交割合约 交易参数管理")
@RestController
@RequestMapping(value = "normal/adminContractManageAction!")
public class AdminFuturesParaController {

    @Autowired
    private FuturesParaFacade futuresParaFacade;

    @Autowired
    private TFuturesParaWrapper tFuturesParaWrapper;
    @Autowired
    private ItemService itemService;

    /**
     * 获取 交易对 列表
     */
    @ApiOperation(value = "获取 交易对 列表")
    @GetMapping("list.action")
    public Result<IPage<ItemDTO>> list(ItemQuery itemQuery, Page<ItemDTO> page) throws Exception {
        QueryWrapper queryWrapper = QueryWrapperGenerator.buildQueryCondition(itemQuery, ItemQuery.class);
        IPage<ItemDTO> result = itemService.findPage(page, queryWrapper);
        return Result.ok(result);
    }

    /**
     * 交割合约管理列表数据
     */
    @ApiOperation(value = "获取交易参数列表")
    @GetMapping("listPara.action")
    public Result<IPage<FuturesPara>> list(FuturesParaQuery futuresParaQuery, Page<FuturesPara> page) throws Exception {
        QueryWrapper<FuturesPara> queryWrapper = new QueryWrapper();
        queryWrapper.eq(StrUtil.isNotBlank(futuresParaQuery.getSymbol()),"symbol", futuresParaQuery.getSymbol());
        IPage<FuturesPara> result = futuresParaFacade.getFuturesParaService().page(page, queryWrapper);
        result.getRecords().forEach(f -> {
            f.setProfitRatio(f.getProfitRatio().multiply(BigDecimal.valueOf(100)));
            f.setProfitRatioMax(f.getProfitRatioMax().multiply(BigDecimal.valueOf(100)));
            f.setUnitFee(f.getUnitFee().multiply(BigDecimal.valueOf(100)));
        });

        return Result.ok(result);
    }


    /**
     * 根据Id获取交割合约管理数据
     */
    @ApiOperation(value = "根据Id获取交割合约管理数据")
    @GetMapping("queryById.action")
    public Result<FuturesParaDTO> queryById(String id) {
        FuturesParaService futuresParaService = futuresParaFacade.getFuturesParaService();
        FuturesParaDTO body = tFuturesParaWrapper.toDTO(futuresParaService.getById(id));
        body.mutiply();
        return Result.ok(body);
    }

    /**
     * 根据Id获取交割合约管理数据
     */
    @ApiOperation(value = "新增,修改交易参数")
    @PostMapping("addFutures.action")
    public Result<String> addFutures(@Valid @RequestBody FuturesParaDTO futuresParaDTO) {
        if (futuresParaDTO.getUnitMaxAmount() == null) {
            futuresParaDTO.setUnitMaxAmount(BigDecimal.ZERO);
        }
        BigDecimal unitAmount = futuresParaDTO.getUnitAmount();
        BigDecimal unitMaxAmount = futuresParaDTO.getUnitMaxAmount();
        if (unitMaxAmount.compareTo(BigDecimal.ZERO) != 0 && unitMaxAmount.compareTo(unitAmount) < 0) {
            throw new YamiShopBindException("最高购买金额需大于最低购买金额");
        }
        futuresParaDTO.divide();
        FuturesPara futuresPara = tFuturesParaWrapper.toEntity(futuresParaDTO);
        String username = SecurityUtils.getSysUser().getUsername();
        futuresParaFacade.addFutures(futuresPara, IPHelper.getIpAddr(), username, futuresParaDTO.getLoginSafeword());
        return Result.ok("success");
    }

    /**
     * 删除 交易参数
     */
    @GetMapping("toDeleteFuturesPara.action")
    public Result<String> toDeleteFuturesPara(@RequestParam String futuresId,
                                                      @RequestParam String loginSafeword,
                                                      @RequestParam String superGoogleAuthCode
    ) {
        String username = SecurityUtils.getSysUser().getUsername();
        futuresParaFacade.deleteFuturesPara(futuresId, IPHelper.getIpAddr(), username, loginSafeword, superGoogleAuthCode);
        return Result.ok("success");

    }


}