package com.muyu.system.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.common.core.domain.Result;
import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.common.system.domain.LoginUser;
import com.muyu.common.system.domain.SysUser;
import com.muyu.system.domain.Connector;
import com.muyu.system.domain.ConnectorLog;
import com.muyu.system.domain.ConnectorUser;
import com.muyu.system.mapper.BuyMapper;
import com.muyu.system.service.BuyService;
import org.apache.catalina.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * @Author：chaiyapeng
 * @Package：com.muyu.system.service.impl
 * @Project：cloud-system
 * @name：BuyServiceImpl
 * @Date：2024/9/1 14:40
 * 购买接口
 */
@Service
public class BuyServiceImpl extends ServiceImpl<BuyMapper, Connector> implements BuyService {
    @Resource
    private BuyMapper buyMapper;
    @Override
    public Result doBuyInterface(ConnectorUser connectorUser) {
//        //获取当前用户名
//        String username = SecurityUtils.getUsername();
        //获取当前用户ID
        Long userId = SecurityUtils.getUserId();
//        //获取当前的用户信息
//        LoginUser loginUser = SecurityUtils.getLoginUser();
        connectorUser.setUserId(userId);
        SysUser user = buyMapper.selectUser(userId);
        if (user.getUserBalance()<connectorUser.getConnectorFrequency()*connectorUser.getConnectorPrice()){
            return Result.error("余额不足");
        }
        Integer i = buyMapper.doBuyInterface(connectorUser);
        if (i>0){
            user.setUserBalance(user.getUserBalance()-connectorUser.getConnectorFrequency()*connectorUser.getConnectorPrice());
            buyMapper.buyPrice(user);
            buyMapper.doBuyInterface(connectorUser);
            ConnectorLog connectorLog = new ConnectorLog();
            connectorLog.setDataName(connectorUser.getConnectorName());
            connectorLog.setAmount(connectorUser.getConnectorPrice());
            // 插入购买记录
            buyMapper.insertPurchaseRecord(connectorLog);
            return Result.success(i,"购买成功");
        }
        ConnectorUser connectorUser1 = buyMapper.selectConnectorUser(connectorUser);
        if (connectorUser1==null){
            Integer i1 = buyMapper.addConnectorUser(connectorUser);
            if (i1>0){
                user.setUserBalance(user.getUserBalance()-connectorUser.getConnectorFrequency()*connectorUser.getConnectorPrice());
                buyMapper.buyPrice(user);
                buyMapper.doBuyInterface(connectorUser);
                ConnectorLog connectorLog = new ConnectorLog();
                connectorLog.setDataName(connectorUser.getConnectorName());
                connectorLog.setAmount(connectorUser.getConnectorPrice());
                // 插入购买记录
                buyMapper.insertPurchaseRecord(connectorLog);
                return Result.success(i,"购买成功");
            }
        }
        return Result.error("购买失败");
    }
}