package com.nq.controller.smart;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.nq.common.ServerResponse;
import com.nq.dao.IntradayOrderMapper;
import com.nq.dao.StockMapper;
import com.nq.dao.UserAssetsMapper;
import com.nq.enums.EStockType;
import com.nq.enums.EUserAssets;
import com.nq.pojo.*;
import com.nq.service.IUserAssetsServices;
import com.nq.service.IUserService;
import com.nq.service.impl.IntradayOrderSerivceImpl;
import com.nq.service.impl.SmartIntradaySerivceImpl;
import com.nq.service.impl.StockServiceImpl;
import com.nq.utils.ConverterUtil;
import com.nq.vo.smart.IntradayOrderVo;
import com.nq.vo.smart.SmartIntradayVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.validation.Valid;
import java.math.BigDecimal;
import java.util.Collections;
import java.util.List;

/**
 * @program: dabaogp
 * @description:
 * @create: 2025-07-15 14:27
 **/
@Controller
@RequestMapping({"/api/intraday/"})
public class IntradayOrderController {

    @Autowired
    private IntradayOrderSerivceImpl intradayOrderSerivce;

    @Autowired
    private SmartIntradaySerivceImpl smartIntradaySerivce;

    @Autowired
    private StockMapper stockMapper;

    @Autowired
    private IUserService userService;

    @Autowired
    private IUserAssetsServices iUserAssetsServices;

    @Autowired
    private UserAssetsMapper userAssetsMapper;

    @Autowired
    private IntradayOrderMapper intradayOrderMapper;



    /**
     * 智能日内列表
     */
    @RequestMapping(value = {"listSmart.do"}, method = {RequestMethod.POST})
    @ResponseBody
    public ServerResponse listSmart() {

        // 创建查询条件
        LambdaQueryWrapper<SmartIntraday> wrapper = new LambdaQueryWrapper<>();

        wrapper.eq(SmartIntraday::getStatus,1);
        // 按创建时间倒序
        wrapper.orderByDesc(SmartIntraday::getCreatedAt);
        // 执行分页查询
        List<SmartIntraday>list = smartIntradaySerivce.list( wrapper);
        return ServerResponse.createBySuccess(list);
    }

    /**
     * 下单智能日内
     * @param vo
     * @return
     */
    @RequestMapping(value = {"addIntraday.do"}, method = {RequestMethod.POST})
    @ResponseBody
    public ServerResponse addIntraday(@Valid IntradayOrderVo vo,HttpServletRequest request) {
        SmartIntraday smartIntraday = smartIntradaySerivce.getById(vo.getSmartId());
        if(ObjectUtil.isEmpty(smartIntraday)){
            return ServerResponse.createBySuccess("产品已下架！",request);
        }
        User user = userService.getCurrentRefreshUser(request);
        UserAssets userAssets = iUserAssetsServices.assetsByTypeAndUserId(EStockType.JP.getCode(), user.getId());
        BigDecimal orderAmount = vo.getOrderAmount();
        if(userAssets.getAvailableBalance().compareTo(orderAmount)<0){
            return ServerResponse.createByErrorMsg("余额不足",request);
        }

        userAssets.setAvailableBalance(userAssets.getAvailableBalance().subtract(orderAmount));
        userAssetsMapper.updateById(userAssets);

        IntradayOrder intradayOrder = ConverterUtil.convert(vo, IntradayOrder.class);
        intradayOrder.setUserId(user.getId());
        intradayOrder.setSmartId(smartIntraday.getId());
        intradayOrder.setStockType(EStockType.JP.getCode());
        intradayOrderSerivce.save(intradayOrder);
        return ServerResponse.createBySuccess("下单成功",request);
    }

    /**
     * 智能日内订单列表
     */
    @RequestMapping(value = {"listIntraday.do"}, method = {RequestMethod.POST})
    @ResponseBody
    public ServerResponse listIntraday(@RequestParam(value = "status" , required = false) Integer status,HttpServletRequest request) {
        User user = userService.getCurrentRefreshUser(request);
        List<IntradayOrder> intradayOrderList = intradayOrderMapper.selectList(new LambdaQueryWrapper<>(IntradayOrder.class)
                .eq(IntradayOrder::getAuditStatus,status)
                .eq(IntradayOrder::getUserId,user.getId())
        );
        return ServerResponse.createBySuccess(intradayOrderList);
    }
}