package com.yami.trading.api.controller.ipo;

import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.api.controller.ipo.dto.CurrentSharesDto;
import com.yami.trading.api.controller.ipo.dto.SpotStocksDataDto;
import com.yami.trading.api.controller.ipo.model.ApplyListModel;
import com.yami.trading.api.controller.ipo.model.GetTopDataModel;
import com.yami.trading.api.controller.ipo.model.SellModel;
import com.yami.trading.bean.data.domain.Realtime;
import com.yami.trading.bean.exchange.ExchangeApplyOrder;
import com.yami.trading.bean.ipo.ApplyNewSharesOrder;
import com.yami.trading.bean.ipo.UserPromiseRecord;
import com.yami.trading.bean.item.domain.Item;
import com.yami.trading.bean.model.User;
import com.yami.trading.bean.syspara.domain.Syspara;
import com.yami.trading.common.domain.BaseEntity;
import com.yami.trading.common.domain.PageRequest;
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.StringUtils;
import com.yami.trading.security.common.util.SecurityUtils;
import com.yami.trading.service.data.DataService;
import com.yami.trading.service.exchange.ExchangeApplyOrderService;
import com.yami.trading.service.ipo.ApplyNewSharesOrderService;
import com.yami.trading.service.ipo.UserPromiseRecordService;
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.user.UserService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.checkerframework.checker.units.qual.C;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.math.BigDecimal;
import java.util.*;

@RestController
@CrossOrigin
@RequestMapping("api/spotStock")
@Api(tags = "现股库存")
@Slf4j
public class ApiSpotStocksController {
    @Autowired
    ApplyNewSharesOrderService applyNewSharesOrderService;

    @Autowired
    ExchangeApplyOrderService exchangeApplyOrderService;

    @Autowired
    SysparaService sysparaService;
    @Autowired
    DataService dataService;

    @Autowired
    UserPromiseRecordService userPromiseRecordService;

    @Autowired
    UserService userService;

    @ApiOperation("获取top数据")
    @PostMapping("getTopData")
    public Result<SpotStocksDataDto> getTopData(GetTopDataModel model) {

        List<ApplyNewSharesOrder> list = new ArrayList<>();
        //1 抽签记录 2 新股库存  3 现股库存
        if (model.getType() == 1) { //抽签
            list = applyNewSharesOrderService.list(Wrappers.<ApplyNewSharesOrder>
                    query().lambda().eq(ApplyNewSharesOrder::getUserId, SecurityUtils.getUser().getUserId()));
        } else if (model.getType() == 2) {// 新股库存
            List<UserPromiseRecord> userPromiseRecords = userPromiseRecordService.list(Wrappers.<UserPromiseRecord>query()
                    .lambda().eq(UserPromiseRecord::getShowFlag, 0).eq(UserPromiseRecord::getUserId,SecurityUtils.getCurrentUserId()));
            for (UserPromiseRecord userPromiseRecord : userPromiseRecords) {
                ApplyNewSharesOrder order = new ApplyNewSharesOrder();
                ApplyNewSharesOrder applyNewSharesOrder = applyNewSharesOrderService.findByOrderNo(userPromiseRecord.getOrderNo());
                if (applyNewSharesOrder != null) {
                    order.setSymbolCode(userPromiseRecord.getProductCode());
                    order.setSubPrice(applyNewSharesOrder.getSubPrice());
                    order.setWinningNumber(applyNewSharesOrder.getWinningNumber());
                    order.setSubNumber(applyNewSharesOrder.getWinningNumber());
                    list.add(order);
                }
            }
        } else { //现股
            List<UserPromiseRecord> userPromiseRecords = userPromiseRecordService.list(Wrappers.<UserPromiseRecord>query()
                    .lambda().eq(UserPromiseRecord::getShowFlag, 0).eq(UserPromiseRecord::getUserId,SecurityUtils.getCurrentUserId()));
            for (UserPromiseRecord userPromiseRecord : userPromiseRecords) {
                ApplyNewSharesOrder order = new ApplyNewSharesOrder();
                ApplyNewSharesOrder applyNewSharesOrder = applyNewSharesOrderService.findByOrderNo(userPromiseRecord.getOrderNo());
                if (applyNewSharesOrder != null) {
                    if (applyNewSharesOrder.getSell()!=1){
                        order.setSymbolCode(userPromiseRecord.getProductCode());
                        order.setSubPrice(applyNewSharesOrder.getSubPrice());
                        order.setWinningNumber(applyNewSharesOrder.getWinningNumber());
                        order.setSubNumber(applyNewSharesOrder.getWinningNumber());
                        list.add(order);
                    }
                }
            }
        }

        SpotStocksDataDto sumSpotStockDto = new SpotStocksDataDto();
        BigDecimal marketValue = new BigDecimal(0);  //市值
        BigDecimal inventoryGainsLosses = new BigDecimal(0); //库存损益
        BigDecimal availableLimit = new BigDecimal(0); //可用额度
        for (ApplyNewSharesOrder order : list) {
            if (model.getType() == 1) {
                BigDecimal initMarketValue = order.getSubNumber().multiply(order.getSubPrice());
                marketValue = marketValue.add(initMarketValue);
                availableLimit = availableLimit.add(order.getSubNumber());
            } else {
                List<Realtime> realtimes = dataService.realtime(order.getSymbolCode());
                log.info(order.getSymbolCode()+"获取行情数据失败");
                BigDecimal initMarketValue = order.getWinningNumber().multiply(order.getSubPrice());
                if (CollectionUtil.isNotEmpty(realtimes)) {
                    Realtime realtime = realtimes.get(0);
                    BigDecimal newMarketValue = order.getWinningNumber().multiply(BigDecimal.valueOf(realtime.getClose()));
                    marketValue = marketValue.add(newMarketValue);
                    availableLimit = availableLimit.add(order.getWinningNumber());
                    inventoryGainsLosses = inventoryGainsLosses.add(newMarketValue.subtract(initMarketValue));
                } else {
                    marketValue = marketValue.add(initMarketValue);
                    availableLimit = availableLimit.add(order.getSubNumber());
                }
            }
        }

        sumSpotStockDto.setAvailableLimit(availableLimit.doubleValue());
        sumSpotStockDto.setMarketValue(marketValue.doubleValue());
        sumSpotStockDto.setInventoryGainsLosses(inventoryGainsLosses.doubleValue());
        return Result.succeed(sumSpotStockDto);
    }

    @ApiOperation("卖出")
    @PostMapping("sell")
    public Result sell(SellModel model) {
        userPromiseRecordService.sell(model.getOrderNo(), SecurityUtils.getUser().getUserId());
        return Result.succeed();
    }

}