package com.doumee.service.system.impl;

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Utils;
import com.doumee.dao.system.SystemLoginLogMapper;
import com.doumee.dao.system.dto.QuerySystemLoginLogDTO;
import com.doumee.dao.system.model.SystemLoginLog;
import com.doumee.dao.system.model.SystemTraceLog;
import com.doumee.service.system.SystemLoginLogService;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.List;

/**
 * 登录日志Service实现
 * @author Eva.Caesar Liu
 * @since 2025/03/31 16:44
 */
@Service
public class SystemLoginLogServiceImpl implements SystemLoginLogService {

    @Autowired
    private SystemLoginLogMapper systemLoginLogMapper;

    @Override
    public Integer create(SystemLoginLog systemLoginLog) {
        systemLoginLogMapper.insert(systemLoginLog);
        return systemLoginLog.getId();
    }

    @Override
    public void deleteById(Integer id) {
        systemLoginLogMapper.deleteById(id);
    }

    @Override
    public void delete(SystemLoginLog systemLoginLog) {
        UpdateWrapper<SystemLoginLog> deleteWrapper = new UpdateWrapper<>(systemLoginLog);
        systemLoginLogMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) return;
        systemLoginLogMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(SystemLoginLog systemLoginLog) {
        systemLoginLogMapper.updateById(systemLoginLog);
    }

    @Override
    public void updateByIdInBatch(List<SystemLoginLog> systemLoginLogs) {
        if (CollectionUtils.isEmpty(systemLoginLogs)) return;
        for (SystemLoginLog systemLoginLog: systemLoginLogs) {
            this.updateById(systemLoginLog);
        }
    }

    @Override
    public SystemLoginLog findById(Integer id) {
        return systemLoginLogMapper.selectById(id);
    }

    @Override
    public SystemLoginLog findOne(SystemLoginLog systemLoginLog) {
        Wrapper<SystemLoginLog> wrapper = new QueryWrapper<>(systemLoginLog);
        return systemLoginLogMapper.selectOne(wrapper);
    }

    @Override
    public List<SystemLoginLog> findList(SystemLoginLog systemLoginLog) {
        Wrapper<SystemLoginLog> wrapper = new QueryWrapper<>(systemLoginLog);
        return systemLoginLogMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<SystemLoginLog> findPage(PageWrap<QuerySystemLoginLogDTO> pageWrap) {
        IPage<SystemLoginLog> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<SystemLoginLog> queryWrapper = new QueryWrapper<>();

        // 登录用户名
        if (StringUtils.isNotBlank(pageWrap.getModel().getLoginUsername())) {
            queryWrapper.lambda().like(SystemLoginLog::getLoginUsername, pageWrap.getModel().getLoginUsername());
        }
        // 登录IP
        if (StringUtils.isNotBlank(pageWrap.getModel().getIp())) {
            queryWrapper.lambda().eq(SystemLoginLog::getIp, pageWrap.getModel().getIp());
        }
        // 服务器IP
        if (StringUtils.isNotBlank(pageWrap.getModel().getServerIp())) {
            queryWrapper.lambda().eq(SystemLoginLog::getServerIp, pageWrap.getModel().getServerIp());
        }
        // 登录状态
        if (pageWrap.getModel().getSuccess() != null) {
            queryWrapper.lambda().eq(SystemLoginLog::getSuccess, pageWrap.getModel().getSuccess());
        }
        // 登录开始时间
        if (pageWrap.getModel().getStartTime() != null) {
            queryWrapper.lambda().ge(SystemLoginLog::getLoginTime, pageWrap.getModel().getStartTime());
        }
        // 登录结束时间
        if (pageWrap.getModel().getStartTime() != null) {
            queryWrapper.lambda().lt(SystemLoginLog::getLoginTime, pageWrap.getModel().getEndTime());
        }
        // 字段排序
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase("DESC")) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        return PageData.from(systemLoginLogMapper.selectPage(page, queryWrapper));
    }

    @Override
    public long count(SystemLoginLog systemLoginLog) {
        Wrapper<SystemLoginLog> wrapper = new QueryWrapper<>(systemLoginLog);
        return systemLoginLogMapper.selectCount(wrapper);
    }
}