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

import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
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.google.common.collect.Lists;
import com.yami.trading.admin.controller.service.SysUserOperService;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.item.dto.ItemConfig;
import com.yami.trading.bean.item.dto.ItemDTO;
import com.yami.trading.bean.item.mapstruct.ItemWrapper;
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.common.util.StringUtils;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.item.ItemService;
import com.yami.trading.service.user.UserService;
import com.yami.trading.sys.model.SysUser;
import com.yami.trading.sys.service.SysUserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

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


/**
 * 产品Controller
 *
 * @author lucas
 * @version 2023-03-10
 */

@Api(tags = "永续合约管理和行情品种")
@RestController
@CrossOrigin
@RequestMapping(value = "normal/adminItemAction!")
public class AdminItemController {

    @Autowired
    private ItemService itemService;

    @Autowired
    private ItemWrapper itemWrapper;
    @Autowired
    private UserService userService;

    @Autowired
    SysUserService sysUserService;
    @Autowired
    private SysUserOperService sysUserOperService;

    /**
     * 产品列表数据
     */
    @ApiOperation(value = "永续合约列表，配置列表")
    @GetMapping("list")
    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("setShowStatus")
    public Result<String> setShowStatus(String symbol, String showStatus) throws Exception {
        Item bySymbol = itemService.getOne(new LambdaQueryWrapper<Item>().eq(Item::getSymbol, symbol));
        if (bySymbol == null) {
            throw new YamiShopBindException(symbol + "不存在");
        }
//		Item update = new Item();
//		update.setUuid(bySymbol.getUuid());
//		update.setShowStatus(showStatus);
        bySymbol.setShowStatus(showStatus);
        itemService.updateById(bySymbol);
        SysUser secUser = sysUserService.getByUserName(SecurityUtils.getSysUser().getUsername());
        sysUserOperService.saveLog(secUser, secUser.getUsername(), StrUtil.format("将 {}前端显示状态修改为 {}", symbol, showStatus));
        return Result.ok(showStatus);
    }

    @ApiOperation(value = "设置交易状态, 返回修改后的状态")
    @GetMapping("setTradeStatus")
    public Result<String> setTradeStatus(String symbol, String tradeStatus) throws Exception {
        Item bySymbol = itemService.getOne(new LambdaQueryWrapper<Item>().eq(Item::getSymbol, symbol));
        if (bySymbol == null) {
            throw new YamiShopBindException(symbol + "不存在");
        }
//		Item update = new Item();
//		update.setUuid(bySymbol.getUuid());
//		update.setTradeStatus(tradeStatus);
        bySymbol.setTradeStatus(tradeStatus);
        itemService.updateById(bySymbol);
        SysUser secUser = sysUserService.getByUserName(SecurityUtils.getSysUser().getUsername());
        sysUserOperService.saveLog(secUser, secUser.getUsername(), StrUtil.format("将 {}交易状态显示修改为 {}", symbol, tradeStatus));
        return Result.ok(tradeStatus);
    }

    /**
     * 根据Id获取产品数据
     */
    @ApiOperation(value = "根据Id获取产品数据")
    @GetMapping("queryById")
    public Result<ItemDTO> queryById(String id) {
        return Result.ok(itemService.findById(id));
    }

    /**
     * 保存产品
     */
    @ApiOperation(value = "保存产品")
    @PostMapping("save")
    public Result<String> save(@Valid @RequestBody Item item) {
        //新增或编辑表单保存
        if (StrUtil.isBlank(item.getSorted())) {
            item.setSorted("999999");
        }
        try {
            item.setSorted(item.getSorted().trim());
            Integer.parseInt(item.getSorted());
        } catch (Exception e) {
            throw new YamiShopBindException("排序值不正确");
        }

        itemService.saveOrUpdate(item);
        return Result.ok("保存产品成功");
    }

    /**
     * 保存产品
     */
    @ApiOperation(value = "保存配置")
    @PostMapping("addConfig.action")
    public Result<String> addConfig(@Valid @RequestBody ItemConfig itemConfig) {
        //userService.checkLoginSafeword(SecurityUtils.getSysUser().getUserId().toString(), itemConfig.getLoginSafeword());
        if (StrUtil.isNotBlank(itemConfig.getUuid())) {
            throw new YamiShopBindException("新增配置不要传入uuid");
        }
        Item bySymbol = itemService.findBySymbol(itemConfig.getSymbol());
        if (bySymbol != null) {
            throw new YamiShopBindException("代码已经存在");
        }
        Item item = itemWrapper.toEntity(itemConfig);
        //新增或编辑表单保存
        itemService.save(item);
        SysUser secUser = sysUserService.getByUserName(SecurityUtils.getSysUser().getUsername());
        sysUserOperService.saveLog(secUser, secUser.getUsername(), StrUtil.format("更新了 {} 行情品种配置", itemConfig.getSymbol()));
        // todo log
        return Result.ok("保存行情品种成功");
    }


    /**
     * 保存永续合约
     */
    @ApiOperation(value = "保存永续合约")
    @PostMapping("add.action")
    public Result<String> addConfig(@Valid @RequestBody ItemDTO itemDTO) {
        //userService.checkLoginSafeword(SecurityUtils.getSysUser().getUserId().toString(), itemDTO.getLoginSafeword());
        if (StrUtil.isNotBlank(itemDTO.getUuid())) {
            throw new YamiShopBindException("新增配置不要传入uuid");
        }
        Item bySymbol = itemService.findBySymbol(itemDTO.getSymbol());
        if (bySymbol != null) {
            throw new YamiShopBindException("代码已经存在");
        }
        Item item = itemWrapper.toEntity(itemDTO);
        //新增或编辑表单保存
        itemService.save(item);
        SysUser secUser = sysUserService.getByUserName(SecurityUtils.getSysUser().getUsername());
        sysUserOperService.saveLog(secUser, secUser.getUsername(), StrUtil.format("新增{}的永续合约成功 ", itemDTO.getSymbol()));
        // todo log
        return Result.ok("保存永续合约成功");
    }

    /**
     * 保存产品
     */
    @ApiOperation(value = "更新产品/修改交易对/修改状态")
    @PostMapping("update.action")
    public Result<String> updateConfig(@Valid @RequestBody ItemDTO itemDTO) {
        //	userService.checkLoginSafeword(SecurityUtils.getSysUser().getUserId().toString(), itemDTO.getLoginSafeword());
        if (StrUtil.isBlank(itemDTO.getUuid())) {
            throw new YamiShopBindException("更新数据时候uuid不能为空");
        }
        Item byId = itemService.getById(itemDTO.getUuid());
        if (byId == null) {
            throw new YamiShopBindException("更新永续合约不存在");
        }
        String symbol = itemDTO.getSymbol();

        // 新老代码不等
        if (!byId.getSymbol().equalsIgnoreCase(symbol)) {
            // 且老的名称已经存在
            Item bySymbol = itemService.findBySymbol(symbol);
            if (bySymbol != null) {
                throw new YamiShopBindException("被更新的永续合约已经存在");
            }
        }

        sysUserService.checkSafeWord(itemDTO.getLoginSafeword());
        Integer decimals = itemDTO.getDecimals();
        if (decimals != null) {
            byId.setDecimals(decimals);
        }
        BigDecimal pips = itemDTO.getPips();
        if (pips != null) {
            byId.setPips(pips.doubleValue());
        }
        BigDecimal pipsAmount = itemDTO.getPipsAmount();
        if (pipsAmount != null) {
            byId.setPipsAmount(pipsAmount.doubleValue());
        }
        BigDecimal unitAmount = itemDTO.getUnitAmount();
        if (unitAmount != null) {
            byId.setUnitAmount(unitAmount.doubleValue());
        }
        Double unitFee = itemDTO.getUnitFee();
        if (unitFee != null) {
            byId.setUnitFee(unitFee);
        }
        BigDecimal unitPercentage = itemDTO.getUnitPercentage();
        if (unitPercentage != null) {
            byId.setUnitPercentage(unitPercentage.doubleValue());
        }
        BigDecimal borrowingRate = itemDTO.getBorrowingRate();
        if (borrowingRate != null) {
            byId.setBorrowingRate(borrowingRate.doubleValue());
        }
        BigDecimal multiple = itemDTO.getMultiple();
        if (multiple != null) {
            byId.setMultiple(multiple.doubleValue());
        }
        String name = itemDTO.getName();
        if (StringUtils.isNotEmpty(name)) {
            byId.setName(name);
        }
        String canBuyAtMarketPrice = itemDTO.getCanBuyAtMarketPrice();
        if (StringUtils.isNotEmpty(canBuyAtMarketPrice)) {
            byId.setCanBuyAtMarketPrice(canBuyAtMarketPrice);
        }
        String canSellAtMarketPrice = itemDTO.getCanSellAtMarketPrice();
        if (StringUtils.isNotEmpty(canSellAtMarketPrice)) {
            byId.setCanSellAtMarketPrice(canSellAtMarketPrice);
        }
        String enable = itemDTO.getEnable();
        if (StringUtils.isNotEmpty(enable)) {
            byId.setEnable(enable);
        }
        String enName = itemDTO.getEnName();
        if (StringUtils.isNotEmpty(enName)) {
            byId.setEnName(enName);
        }
        String limitCanBuy = itemDTO.getLimitCanBuy();
        if (StringUtils.isNotEmpty(limitCanBuy)) {
            byId.setLimitCanBuy(limitCanBuy);
        }
        String limitCanSell = itemDTO.getLimitCanSell();
        if (StringUtils.isNotEmpty(limitCanSell)) {
            byId.setLimitCanSell(limitCanSell);
        }
        String quoteCurrency = itemDTO.getQuoteCurrency();
        if (StringUtils.isNotEmpty(quoteCurrency)) {
            byId.setQuoteCurrency(quoteCurrency);
        }
        String showStatus = itemDTO.getShowStatus();
        if (StringUtils.isNotEmpty(showStatus)) {
            byId.setShowStatus(showStatus);
        }
        String sorted = itemDTO.getSorted();
        if (StringUtils.isNotEmpty(sorted)) {
            byId.setSorted(sorted);
        }
        String symbolData = itemDTO.getSymbolData();
        if (StringUtils.isNotEmpty(symbolData)) {
            byId.setSymbolData(symbolData);
        }
        String symbolFullName = itemDTO.getSymbolFullName();
        if (StringUtils.isNotEmpty(symbolFullName)) {
            byId.setSymbolFullName(symbolFullName);
        }
        String tradeStatus = itemDTO.getTradeStatus();
        if (StringUtils.isNotEmpty(tradeStatus)) {
            byId.setTradeStatus(tradeStatus);
        }
        //新增或编辑表单保存
        itemService.saveOrUpdate(byId);

        String log = MessageFormat.format("ip:" + IPHelper.getIpAddr() +
                        ",永续合约配置进行了修改,id:{0}, 原名称:{1},原保留精度:{2},原金额:{3},原合约手续费:{4},原手续费:{5},原最小变动单位:{6},原最小变动单位的单位盈亏{7}," +
                        "原名称:{8},原保留精度:{9},新金额:{10},新合约手续费:{11},新手续费:{12},新最小变动单位:{13},新最小变动单位的单位盈亏{14}",
                byId.getUuid(), byId.getName(), byId.getDecimals(), byId.getUnitAmount(), byId.getUnitPercentage(), byId.getUnitFee(), byId.getPips(), byId.getPipsAmount(),
                name, decimals, unitAmount, unitPercentage, unitFee, pips, pipsAmount);

        SysUser secUser = sysUserService.getByUserName(SecurityUtils.getSysUser().getUsername());
        sysUserOperService.saveLog(secUser, secUser.getUsername(), log);
        return Result.ok("保存行情永续合约成功");
    }

    /**
     * 保存产品
     */
    @ApiOperation(value = "更新配置")
    @PostMapping("updateConfig.action")
    public Result<String> updateConfig(@Valid @RequestBody ItemConfig itemConfig) {
        //userService.checkLoginSafeword(SecurityUtils.getSysUser().getUserId().toString(), itemConfig.getLoginSafeword());
        if (StrUtil.isBlank(itemConfig.getUuid())) {
            throw new YamiShopBindException("更新数据时候uuid不能为空");
        }
        Item byId = itemService.getById(itemConfig.getUuid());
        String symbol = itemConfig.getSymbol();
        if (byId == null) {
            throw new YamiShopBindException("更新品种不存在");
        }
        // 新老代码不等
        if (!byId.getSymbol().equalsIgnoreCase(symbol)) {
            // 且老的名称已经存在
            Item bySymbol = itemService.findBySymbol(symbol);
            if (bySymbol != null) {
                throw new YamiShopBindException("被更新的品种已经存在");
            }
        }
        Double borrowingRate = itemConfig.getBorrowingRate();
        if (borrowingRate != null) {
            byId.setBorrowingRate(borrowingRate);
        }
        Integer decimals = itemConfig.getDecimals();
        if (decimals != null) {
            byId.setDecimals(decimals);
        }
        Double multiple = itemConfig.getMultiple();
        if (multiple != null) {
            byId.setMultiple(multiple);
        }
        String name = itemConfig.getName();
        if (StringUtils.isNotEmpty(name)) {
            byId.setName(name);
        }
        String symbolData = itemConfig.getSymbolData();
        if (StringUtils.isNotEmpty(symbolData)) {
            byId.setSymbolData(symbolData);
        }

        //新增或编辑表单保存
        itemService.saveOrUpdate(byId);
        SysUser secUser = sysUserService.getByUserName(SecurityUtils.getSysUser().getUsername());
        sysUserOperService.saveLog(secUser, secUser.getUsername(), StrUtil.format("对{}行情品种配置进行了修改", symbol));
        // todo log
        return Result.ok("保存行情品种成功");
    }

    /**
     * 删除产品
     */
    @ApiOperation(value = "删除产品")
    @DeleteMapping("delete")
    public Result<String> delete(String ids) {
        String idArray[] = ids.split(",");
        itemService.removeByIds(Lists.newArrayList(idArray));
        return Result.ok("删除产品成功");
    }

}