package com.nq.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.nq.common.ServerResponse;
import com.nq.dao.SiteVipRobMapper;
import com.nq.dao.StockMapper;
import com.nq.pojo.SiteVipRob;
import com.nq.pojo.Stock;
import com.nq.pojo.UserPurchaseApplication;
import com.nq.service.ISiteVipRobService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.util.Date;
import java.util.List;

@Service("iSiteVipRobService")
public class SiteVipRobServiceImpl extends ServiceImpl<SiteVipRobMapper, SiteVipRob> implements ISiteVipRobService {
    private static final Logger log = LoggerFactory.getLogger(SiteVipRobServiceImpl.class);

    @Autowired
    SiteVipRobMapper siteVipRobMapper;
    @Autowired
    StockMapper stockMapper;

    @Override
    public ServerResponse insert(SiteVipRob siteVipRob) {
        // 构造查询条件
        LambdaQueryWrapper<SiteVipRob> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(SiteVipRob::getStockCode, siteVipRob.getStockCode());
        if(siteVipRob.getStockChg().compareTo(new BigDecimal(0)) < 0 || siteVipRob.getStockChg().compareTo(new BigDecimal(100)) >= 0){
            return ServerResponse.createByErrorMsg("涨跌幅在0~100之间");
        }
        // 查询是否存在相同的股票代码设置
        List<SiteVipRob> list = list(wrapper);
        if (!list.isEmpty()) {
            return ServerResponse.createByErrorMsg("该股票代码设置已存在");
        }
        Stock stock = stockMapper.findStockByCode(siteVipRob.getStockCode());
        if(null == stock){
            return ServerResponse.createByErrorMsg("股票代码不存在");
        }
        // 设置创建时间
        siteVipRob.setCreateTime(new Date());

        // 执行保存操作
        if (save(siteVipRob)) {
            return ServerResponse.createBySuccessMsg("添加成功");
        } else {
            return ServerResponse.createByErrorMsg("添加失败");
        }
    }


    @Override
    public ServerResponse modify(SiteVipRob siteVipRob) {
        // 构造查询条件
        LambdaQueryWrapper<SiteVipRob> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(SiteVipRob::getStockCode, siteVipRob.getStockCode())
                .ne(SiteVipRob::getId, siteVipRob.getId());
        if(siteVipRob.getStockChg().compareTo(new BigDecimal(0)) < 0 || siteVipRob.getStockChg().compareTo(new BigDecimal(100)) >= 0){
            return ServerResponse.createByErrorMsg("涨跌幅在0~100之间");
        }
        // 查询是否存在相同的股票代码设置
        List<SiteVipRob> list = list(wrapper);
        if (!list.isEmpty()) {
            return ServerResponse.createByErrorMsg("该股票代码设置已存在");
        }
        Stock stock = stockMapper.findStockByCode(siteVipRob.getStockCode());
        if(null == stock){
            return ServerResponse.createByErrorMsg("股票代码不存在");
        }
        // 更新修改时间
        siteVipRob.setUpdateTime(new Date());

        // 执行更新操作
        if (updateById(siteVipRob)) {
            return ServerResponse.createBySuccessMsg("修改成功");
        } else {
            return ServerResponse.createByErrorMsg("修改失败");
        }
    }


    @Override
    public ServerResponse list(String keyword, Integer status, int pageNum, int pageSize) {
        // 创建分页对象
        Page<SiteVipRob> page = new Page<>(pageNum, pageSize);

        // 构造查询条件
        LambdaQueryWrapper<SiteVipRob> wrapper = new LambdaQueryWrapper<>();
        wrapper.and(q -> q.like(SiteVipRob::getStockCode, keyword).or().like(SiteVipRob::getName, keyword));
        if (status != null) {
            wrapper.eq(SiteVipRob::getStatus, status);
        }
        wrapper.orderByDesc(SiteVipRob::getCreateTime);
        // 执行分页查询
        IPage<SiteVipRob> resultPage = page(page, wrapper);

        // 返回分页结果
        return ServerResponse.createBySuccess(resultPage);
    }


    @Override
    public SiteVipRob getByStockCode(String stockCode) {
        LambdaQueryWrapper<SiteVipRob> wrapper = new LambdaQueryWrapper<SiteVipRob>().eq(SiteVipRob::getStockCode, stockCode);
        return siteVipRobMapper.selectOne(wrapper);
    }

    @Override
    public ServerResponse updateStatus(Integer id,Integer status) {
        SiteVipRob siteVipRob = siteVipRobMapper.selectById(id);
        siteVipRob.setStatus(status);
        siteVipRob.setUpdateTime(new Date());
        // 执行更新操作
        if (updateById(siteVipRob)) {
            return ServerResponse.createBySuccessMsg("修改成功");
        } else {
            return ServerResponse.createByErrorMsg("修改失败");
        }
    }

}