WEBUI/WMS.BZCore/ServiceCore/WCSManager/WcsDatablockService.cs

using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WMS.Core.APPBLL;
using WMS.Info;
using WMS.Util;

namespace WMS.Core.ServiceCore
{
    public class WcsDatablockService
    {
        /// <summary>
        /// 获取分页数据
        /// <summary>
        /// <returns></returns>
        public IEnumerable<dynamic> GetPageList(Pagination pagination, string queryJson)
        {
            SqlSugarClient client = null;
            try
            {
                client = WCSDbCore.GetDbCtx();
                int count = 0;
                var queryParam = queryJson.ToJObject();
                var db = client.Queryable<WcsDatablockEntity>();
                if (!queryParam["keyword"].IsEmpty())
                {
                    string kw = queryParam["keyword"].ToString();
                    db.Where(ord => ord.Code.Contains(kw));
                }
                if (!queryParam["Name"].IsEmpty())
                {
                    string name = queryParam["Name"].ToString();
                    db.Where(o => o.Name.Contains(name));
                }
                if (!queryParam["Plccode"].IsEmpty())
                {
                    string Plccode = queryParam["Plccode"].ToString();
                    db.Where(o => o.Plccode.Equals(Plccode));
                }
                
                //if (!queryParam["IP"].IsEmpty())
                //{
                //    string ip = queryParam["IP"].ToString();
                //    db.Where(o => o.Ip.Contains(ip));
                //}
                //if (!queryParam["PORT"].IsEmpty())
                //{
                //    string port = queryParam["PORT"].ToString();
                //    db.Where(o => o.Port.ToString().Contains(port));
                //}
                if (pagination.sord.ToUpper() != "ASC")
                {
                    pagination.sidx = pagination.sidx + " DESC";
                }

                var list = db.OrderBy(pagination.sidx).Select<dynamic>(@"*").ToPageList(pagination.page, pagination.rows, ref count);
                pagination.records = count;
                return list;
            }
            catch (Exception ex)
            {
                throw ex;
            }
            finally
            {
                client.Dispose();
            }
        }

        public IEnumerable<dynamic> GetSelectDBNameList() 
        { 
            var client = WCSDbCore.GetDbCtx();
            var db = client.Queryable<WcsDatablockEntity>().Where(o => o.Enabled).Select<dynamic>(" CODE as id, CONCAT(NAME ,'-' ,PLCCODE) as text");
            return db.ToList();

        }

        public IEnumerable<dynamic> GetDBNameByPlcCode(string plccode)
        {
            var client = WCSDbCore.GetDbCtx();
            var db = client.Queryable<WcsDatablockEntity>().Where(o => o.Enabled && o.Plccode==plccode).Select<dynamic>(" CODE as id, NAME as text");
            return db.ToList();

        }

        /// <summary>
        /// 获取实体数据
        /// <param name="keyValue">主键</param>
        /// <summary>
        /// <returns></returns>
        public WcsDatablockEntity GetEntity(string keyValue)
        {
            try
            {
                return WCSDbCore.GetDbCtx().Queryable<WcsDatablockEntity>().Where(it => it.Code == keyValue).First();
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        /// <summary>
        /// 删除实体数据
        /// <param name="keyValue">主键</param>
        /// <summary>
        /// <returns></returns>
        public void DeleteEntity(string keyValue)
        {
            try
            {
                //SysDbCore.GetDbCtx().Deleteable<BASE_WAREHOUSE>().Where(it => it.F_NO == keyValue).ExecuteCommand();
                WCSDbCore.GetDbCtx().Deleteable<WcsDatablockEntity>().Where(it => it.Code == keyValue).ExecuteCommand();
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 保存实体数据（新增、修改）
        /// <param name="keyValue">主键</param>
        /// <summary>
        /// <returns></returns>
        public void SaveEntity(LoginUserInfo loginUserInfo, string keyValue, WcsDatablockEntity entity)
        {
            if (entity == null)
            {
                throw SysExCore.ThrowFailException("输入数据为空。");
            }
            if (string.IsNullOrWhiteSpace(entity.Code))
            {
                throw SysExCore.ThrowFailException("编码为空。");
            }
            if (string.IsNullOrWhiteSpace(entity.Name))
            {
                throw SysExCore.ThrowFailException("名称为空。");
            }
            entity.Updatetime = DateTime.Now;
            entity.Updateuser = loginUserInfo.UserNo;
            if (string.IsNullOrEmpty(keyValue))
            {
                using (var ctx = WCSDbCore.GetDbCtx())
                {
                    var item = ctx.Queryable<WcsDatablockEntity>().First(o => o.Code == keyValue);
                    if (item != null)
                    {
                        throw SysExCore.ThrowFailException("添加PLC Datablock时，PLC Datablock编号不能重复。");
                    }
                    entity.Updatetime = DateTime.Now;
                    entity.Updateuser = loginUserInfo.UserNo;
                    entity.Enabled = true;
                    ctx.Insertable(entity).ExecuteCommand();
                }
            }
            else
            {
                WCSDbCore.GetDbCtx().Updateable(entity).IgnoreColumns(it => new { it.Noupdate }).Where(it => it.Code == keyValue).ExecuteCommand();
            }
        }
    }
}