package com.gunshi.project.xyt.service;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.gunshi.project.xyt.model.BzProtocolInfo;
import com.gunshi.project.xyt.model.BzProtocolInfoAutoDao;
import com.gunshi.project.xyt.so.BzProtocolInfoSo;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 类描述
 *
 * @author lyf
 * @version 1.0.0
 * @since 2024-01-23
 */
@Service
public class ProtocolInfoService {
    @Autowired
    private BzProtocolInfoAutoDao dao;


    public Page<BzProtocolInfo> page(BzProtocolInfoSo so) {
        if (StringUtils.isNotEmpty(so.getId())) {
            BzProtocolInfo entity = dao.getById(so.getId());
            if (entity == null) {
                return null;
            }
            List<BzProtocolInfo> records = List.of(entity);
            return new Page<BzProtocolInfo>(1, 1, 1).setRecords(records);
        }

        LambdaQueryWrapper<BzProtocolInfo> query = new LambdaQueryWrapper<>();
        if (StringUtils.isNotEmpty(so.getName())) {
            query.like(StringUtils.isNotEmpty(so.getName()), BzProtocolInfo::getName, so.getName());
        }
        if (StringUtils.isNotEmpty(so.getIp())) {
            query.like(BzProtocolInfo::getIp, so.getIp());
        }
        if (so.getPort() != null) {
            query.eq(BzProtocolInfo::getPort, so.getPort());
        }
        if (StringUtils.isNotEmpty(so.getStd())) {
            query.like(BzProtocolInfo::getStd, so.getStd());
        }
        if (StringUtils.isNotEmpty(so.getTrans())) {
            query.like(BzProtocolInfo::getTrans, so.getTrans());
        }
        if (so.getEnable() != null) {
            query.eq(BzProtocolInfo::getEnable, so.getEnable());
        }
        query.orderByDesc(BzProtocolInfo::getCreateTm);

        return dao.page(so.getPageSo().toPage(), query);
    }
}