wcs_server_kate_suzhou/WcsMain/DataBase/Dao/AppTcpDao.cs

using WcsMain.Common;
using WcsMain.DataBase.TableEntity;
using WcsMain.WcsAttribute.AutoFacAttribute;

namespace WcsMain.DataBase.Dao;

[Component]
public class AppTcpDao
{

    /// <summary>
    /// 查询所有socket数据
    /// </summary>
    /// <returns></returns>
    public List<AppTcp>? Query() => Query(new AppTcp());

    /// <summary>
    /// 条件查询
    /// </summary>
    /// <param name="socket"></param>
    /// <returns></returns>
    public List<AppTcp>? Query(AppTcp socket)
    {
        try
        {
            var sqlFuc = CommonTool.DbServe.Queryable<AppTcp>()
                .WhereIF(socket.TcpId != default, w => w.TcpId == socket.TcpId)
                .WhereIF(socket.TcpIp != default, w => w.TcpIp == socket.TcpIp)
                .WhereIF(socket.TcpPort != default, w => w.TcpPort == socket.TcpPort)
                .WhereIF(socket.TcpType != default, w => w.TcpType == socket.TcpType)
                .WhereIF(socket.TcpStatus != default, w => w.TcpStatus == socket.TcpStatus)
                .WhereIF(socket.DisplayName != default, w => w.DisplayName == socket.DisplayName)
                .WhereIF(socket.Remark != default, w => w.Remark == socket.Remark);
            return sqlFuc.ToList();

        }
        catch (Exception ex)
        {
            _ = ex;
        }
        return default;
    }

    /// <summary>
    /// 插入一条记录
    /// </summary>
    /// <param name="socket"></param>
    /// <returns></returns>
    public int Insert(AppTcp socket)
    {
        try
        {
            int insertRows = CommonTool.DbServe.Insertable(socket).ExecuteCommand();
            return insertRows;
        }
        catch (Exception ex)
        {
            _ = ex;
            return 0;
        }
    }

    /// <summary>
    /// 根据主键更新记录，忽略 null 
    /// </summary>
    /// <param name="socket"></param>
    /// <returns></returns>
    public int Update(AppTcp socket)
    {
        try
        {
            int insertRows = CommonTool.DbServe.Updateable(socket).IgnoreColumns(ignoreAllNullColumns: true)
                .ExecuteCommand();
            return insertRows;
        }
        catch (Exception ex)
        {
            _ = ex;
            return 0;
        }
    }

    /// <summary>
    /// 删除一条记录 ---- 根据主键
    /// </summary>
    /// <param name="socket"></param>
    /// <returns></returns>
    public int Delete(AppTcp socket)
    {
        try
        {
            int insertRows = CommonTool.DbServe.Deleteable(socket).ExecuteCommand();
            return insertRows;
        }
        catch (Exception ex)
        {
            _ = ex;
            return 0;
        }
    }

    /// <summary>
    /// 根据状态查询 socket 数据
    /// </summary>
    /// <param name="status"></param>
    /// <returns></returns>
    public List<AppTcp>? GetNeedUseSocket(int status)
    {
        try
        {
            List<AppTcp> sockets = CommonTool.DbServe.Queryable<AppTcp>().Where(w => w.TcpStatus == status).ToList();
            return sockets;

        }
        catch (Exception ex)
        {
            _ = ex;
        }
        return default;
    }
}