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.ResponseCode;
import com.nq.common.ServerResponse;
import com.nq.dao.SiteTaskLogMapper;
import com.nq.dao.StockMapper;
import com.nq.dao.UserPurchaseApplicationMapper;
import com.nq.pojo.*;
import com.nq.service.IUserPositionService;
import com.nq.service.IUserPurchaseApplicationService;
import com.nq.utils.timeutil.DateTimeUtil;
import com.nq.utils.translate.GoogleTranslateUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.servlet.http.HttpServletRequest;
import java.util.Date;

@Service("purchaseApplicationService")
public class UserPurchaseApplicationServiceImpl extends ServiceImpl<UserPurchaseApplicationMapper, UserPurchaseApplication> implements IUserPurchaseApplicationService {

    @Autowired
    private UserPurchaseApplicationMapper purchaseApplicationMapper;
    @Autowired
    private SiteTaskLogMapper siteTaskLogMapper;
    @Autowired
    private IUserPositionService userPositionService;
    @Autowired
    private StockMapper stockMapper;

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

        // 构造查询条件
        LambdaQueryWrapper<UserPurchaseApplication> wrapper = new LambdaQueryWrapper<>();
        wrapper.and(q -> q.like(UserPurchaseApplication::getStockCode, keyword).or().like(UserPurchaseApplication::getUserId, keyword));
        if (status != null) {
            wrapper.eq(UserPurchaseApplication::getStatus, status);
        }
        wrapper.orderByDesc(UserPurchaseApplication::getAddTime);

        // 执行分页查询
        IPage<UserPurchaseApplication> resultPage = page(page, wrapper);

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

    @Override
    @Transactional
    public ServerResponse examine(Integer id, HttpServletRequest request) {

        try{
            UserPurchaseApplication purchaseApplication = getById(id);
            if(null != purchaseApplication && purchaseApplication.getStatus() != 0){
                return ServerResponse.createByErrorMsg("当前状态无法操作");
            }
            purchaseApplication.setStatus(1);
            SiteTaskLog siteTaskLog = new SiteTaskLog();
            siteTaskLog.setTaskType("涨停板购买审核");
            String tasktarget = "此次买入id：" + purchaseApplication.getId();
            siteTaskLog.setTaskTarget(tasktarget);
            siteTaskLog.setAddTime(new Date());
            siteTaskLog.setIsSuccess(0);
            siteTaskLog.setErrorMsg("");

            //购买
            Stock stock = stockMapper.findStockByCode(purchaseApplication.getStockCode());
            ServerResponse serverResponse = userPositionService.buy(stock.getId(),purchaseApplication.getBuyNum(),
                    purchaseApplication.getBuyType(),purchaseApplication.getLever(),purchaseApplication.getProfitTarget(),purchaseApplication.getStopTarget(), request,purchaseApplication.getUserId());
            if(serverResponse.getStatus() == ResponseCode.SUCCESS.getCode()){
                this.purchaseApplicationMapper.updateById(purchaseApplication);
                this.siteTaskLogMapper.insert(siteTaskLog);
                return ServerResponse.createBySuccessMsg("审核成功，已转持仓");
            }else {
                return ServerResponse.createByErrorMsg(serverResponse.getMsg(),"en","zh");
            }

        }catch (Exception e){
            log.error("挂单失败");
        }
        return ServerResponse.createByErrorMsg("操作失败");
    }
}