ECS / WCS_LiuzhouZhituo · Files

using HHWCS.Model;
using MySql.Data.MySqlClient;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace HHWCS.Bill
{
    public class Bill
    {
        public static void Main(String[] args)
        {
            List<Object> a = new List<Object>();
            a.Add(1);
            a.Add(2);
            var c = a.Find(t => t == (object)3);
            Console.WriteLine(c);
            Console.Read();
        }

        #region Task
        public static BillResult<List<TaskEntity>> GetTasks(string status, string taskNo, string pallet, DateTime? beginTime, DateTime? endTime)
        {
            String sql = "select * from task where 1=1 ";
            if (!String.IsNullOrEmpty(status))
            {
                sql += " and status = '" + status + "'";
            }
            if (!String.IsNullOrEmpty(taskNo))
            {
                sql += " and id = " + taskNo;
            }
            if (!String.IsNullOrEmpty(pallet))
            {
                sql += " and containerCode = '" + pallet + "'";
            }
            if (beginTime != null)
            {
                sql += " and created>='" + beginTime.ToString() + "'";
            }
            if (endTime != null)
            {
                sql += " and created<='" + endTime.ToString() + "'";
            }


            DataSet ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);
            if (ds == null || ds.Tables.Count == 0)
            {
                return BillResultFactory.Error<List<TaskEntity>>(null, "未找到数据");
            }
            return BillResultFactory.Sucess<List<TaskEntity>>(ds.Tables[0].AsEnumerable().Select(x => new TaskEntity
            {
                Id = (int)x["id"],
                WarehouseId = Convert.ToInt32(x["warehouseId"]),
                WarehouseCode = x["warehouseCode"]?.ToString(),
                CompanyId = x["companyId"] is DBNull ? null : (int?)x["companyId"],
                Priority = Convert.ToInt32(x["priority"]),
                Type = Convert.ToInt32(x["type"]),
                Station = x["station"] is DBNull ? null : (int?)x["station"],
                ContainerId = x["containerId"] is DBNull ? null : (int?)x["containerId"],
                ContainerCode = x["containerCode"]?.ToString(),
                SourceLocation = x["sourceLocation"]?.ToString(),
                DestinationLocation = x["destinationLocation"]?.ToString(),
                Status = Convert.ToInt32(x["status"]),
                Created = x["created"] is DBNull ? null : (DateTime?)x["created"],
                CreatedBy = x["createdBy"]?.ToString(),
                BeginTime = x["beginTime"] is DBNull ? null : (DateTime?)x["beginTime"],
                EndTime = x["endTime"] is DBNull ? null : (DateTime?)x["endTime"],
                LastUpdated = x["lastUpdated"] is DBNull ? null : (DateTime?)x["lastUpdated"],
            }).OrderByDescending(t => t.Created).ToList(), "成功");
        }

        /// <summary>
        /// 创建任务
        /// </summary>
        /// <param name="palletCode"></param>
        /// <param name="station"></param>
        /// <param name="sourceLocation"></param>
        /// <param name="destinationLocation"></param>
        /// <param name="status"></param>
        /// <param name="type"></param>
        /// <param name="priority"></param>
        /// <returns>注意，任务实体没有返回</returns>
        public static BillResult<TaskEntity> creatTask(string palletCode, int station, string sourceLocation, string destinationLocation, int status, int type, int priority)
        {
            MySqlConnection mySqlConnection = new MySqlConnection(AppCommon.ConnectionString);
            MySqlTransaction tran = null;
            try
            {
                //检查参数
                if (String.IsNullOrEmpty(palletCode))
                {
                    return BillResultFactory.Error<TaskEntity>(null, "托盘号不能为空");
                }
                else
                {
                    //校验托盘，查看托盘是否存在任务未完成
                    int result = Convert.ToInt32(MySqlHelper.ExecuteScalar(AppCommon.ConnectionString, "SELECT count(*) from task where containerCode = @pallet and `status`<40 and warehouseId= @warehouseId", new MySqlParameter("@pallet", palletCode), new MySqlParameter("@warehouseId", AppCommon.WarehouseId)));
                    if (result > 0)
                    {
                        return BillResultFactory.Error<TaskEntity>(null, "托盘已存在任务");
                    }
                }
                if (type == 100 || type == 500 || type == 800)
                {
                    if (String.IsNullOrEmpty(destinationLocation))
                    {
                        return BillResultFactory.Error<TaskEntity>(null, "对于整盘入库、空盘入库和移库目标库位不能为空");
                    }
                    else
                    {
                        var temp = Bill.checkLocationForCreateTask(destinationLocation, AppCommon.WarehouseId);
                        if (!temp.Success)
                        {
                            return temp;
                        }
                    }
                }
                if (type == 200 || type == 300 || type == 400 || type == 600 || type == 700 || type == 800)
                {
                    if (String.IsNullOrEmpty(sourceLocation))
                    {
                        return BillResultFactory.Error<TaskEntity>(null, "对于补充入库、整盘出库、分拣出库、空盘出库、盘点和移库源库位不能为空");
                    }
                    else
                    {
                        //校验库位
                        var temp = Bill.checkLocationForCreateTask(sourceLocation, AppCommon.WarehouseId);
                        if (!temp.Success)
                        {
                            return temp;
                        }
                    }
                }
                mySqlConnection.Open();
                tran = mySqlConnection.BeginTransaction();
                string sql = "insert into task(containerCode,station,sourceLocation,destinationLocation,status,type,priority,warehouseId,created,createdBy) " +
                    " VALUES(@pallet, @station, @sourceLocation, @destinationLocation, @status, @type, @priority, @warehouseId,@warehouseCode, NOW(),@createdBy)";
                List<MySqlParameter> mySqlParameters = new List<MySqlParameter>();
                mySqlParameters.Add(new MySqlParameter("@pallet", palletCode));
                mySqlParameters.Add(new MySqlParameter("@station", station));
                mySqlParameters.Add(new MySqlParameter("@sourceLocation", sourceLocation));
                mySqlParameters.Add(new MySqlParameter("@destinationLocation", destinationLocation));
                mySqlParameters.Add(new MySqlParameter("@status", status));
                mySqlParameters.Add(new MySqlParameter("@type", type));
                mySqlParameters.Add(new MySqlParameter("@priority", priority));
                mySqlParameters.Add(new MySqlParameter("@warehouseId", AppCommon.WarehouseId));
                mySqlParameters.Add(new MySqlParameter("@createdBy", AppCommon.User.UserName));
                mySqlParameters.Add(new MySqlParameter("@warehouseCode", AppCommon.WarehouseCode));
                int i = MySqlHelper.ExecuteNonQuery(mySqlConnection, sql, mySqlParameters.ToArray());
                if (i == 1)
                {
                    if (type == 100 || type == 500 || type == 800)
                    {
                        var temp = Bill.updateLocationStatus(destinationLocation, AppCommon.WarehouseId, "lock", mySqlConnection);
                        if (!temp.Success)
                        {
                            tran.Rollback();
                            return BillResultFactory.Sucess<TaskEntity>(null, "创建任务失败，更新货位状态失败");
                        }
                    }
                    if (type == 200 || type == 300 || type == 400 || type == 600 || type == 700 || type == 800)
                    {
                        var temp = Bill.updateLocationStatus(sourceLocation, AppCommon.WarehouseId, "lock", mySqlConnection);
                        if (!temp.Success)
                        {
                            tran.Rollback();
                            return BillResultFactory.Sucess<TaskEntity>(null, "创建任务失败，更新货位状态失败");
                        }
                    }
                    //更新货位状态为预定
                    tran.Commit();
                    return BillResultFactory.Sucess<TaskEntity>(null, "成功");
                }
                else
                {
                    tran.Rollback();
                    return BillResultFactory.Error<TaskEntity>(null, "插入任务失败");
                }
            }
            catch (Exception ex)
            {
                tran?.Rollback();
                return BillResultFactory.Error<TaskEntity>(null, "出现异常:" + ex.ToString());
            }
            finally
            {
                mySqlConnection.Close();
                mySqlConnection.Dispose();
            }
        }

        private static BillResult<TaskEntity> checkLocationForCreateTask(String code, int warehouseId)
        {
            //校验库位
            var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, "SELECT * from location where `code` = @code and warehouseId = @warehouseId", new MySqlParameter("@code", code), new MySqlParameter("@warehouseId", AppCommon.WarehouseId));
            if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
            {
                return BillResultFactory.Error<TaskEntity>(null, "没有找到库位");
            }
            var dr = ds.Tables[0].AsEnumerable().FirstOrDefault();
            if (!String.IsNullOrEmpty(dr["containerCode"].ToString()))
            {
                return BillResultFactory.Error<TaskEntity>(null, "目标库位非空闲");
            }
            if (!String.IsNullOrEmpty(dr["containerCode"].ToString()))
            {
                return BillResultFactory.Error<TaskEntity>(null, "目标库位已有货，请不要重入");
            }
            return BillResultFactory.Sucess<TaskEntity>(null, "OK");
        }

        /// <summary>
        /// 更新货位状态
        /// </summary>
        /// <param name="locationCode"></param>
        /// <param name="warehouseId"></param>
        /// <param name="newStatus"></param>
        /// <returns></returns>
        public static BillResult<int> updateLocationStatus(String locationCode, int warehouseId, String newStatus, MySqlConnection mySqlConnection)
        {
            string sql = "update location set `status` = @status where code = @code and warehouseId = @warehouseId;";
            List<MySqlParameter> mySqlParameters = new List<MySqlParameter>();
            mySqlParameters.Add(new MySqlParameter("@status", newStatus));
            mySqlParameters.Add(new MySqlParameter("@code", locationCode));
            mySqlParameters.Add(new MySqlParameter("@warehouseId", warehouseId));
            int i = MySqlHelper.ExecuteNonQuery(mySqlConnection, sql, mySqlParameters.ToArray());
            if (i != 1)
            {
                return BillResultFactory.Error<int>(0, "失败");
            }
            else
            {
                return BillResultFactory.Sucess<int>(0, "成功");
            }

        }

        /// <summary>
        /// todo：完成任务
        /// </summary>
        /// <param name="task"></param>
        public static BillResult CompleteTask(string task)
        {
            throw new NotImplementedException();
        }
        #endregion

        #region Device

        public static BillResult<List<DeviceEntity>> GetAllDevice()
        {
            try
            {
                string sql = "select * from devicelist where enable = 1";
                var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);
                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                {
                    return BillResultFactory.Error<List<DeviceEntity>>(null, "没有数据");
                }
                var list = ds.Tables[0].AsEnumerable().Select(t => new DeviceEntity
                {
                    Id = (int)t["id"],
                    Code = t["code"].ToString(),
                    Name = t["name"].ToString(),
                    Type = (int)t["type"],
                    IP = t["ip"].ToString(),
                    S7_Connect = t["S7_Connect"].ToString(),
                    GroupName = t["groupName"].ToString(),
                    Enable = Convert.ToBoolean(t["enable"]),
                    DeviceTypeId = (int)t["deviceTypeId"],
                    Roadway = t["roadway"] is DBNull?-1:Convert.ToInt32(t["roadway"]),
                    SelfAddress = t["selfAddress"] is DBNull?-1:Convert.ToInt32(t["selfAddress"])
                }).ToList();
                return BillResultFactory.Sucess<List<DeviceEntity>>(list, "成功");

            }
            catch (Exception ex)
            {
                return BillResultFactory.Error<List<DeviceEntity>>(null, "异常:" + ex.ToString());
            }
        }

        public static BillResult<List<DeviceAddressEntity>> GetAllDeviceAddress()
        {
            try
            {
                string sql = "select * from deviceaddress where enable = 1";
                var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);
                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                {
                    return BillResultFactory.Error<List<DeviceAddressEntity>>(null, "没有数据");
                }
                var list = ds.Tables[0].AsEnumerable().Select(t => new DeviceAddressEntity
                {
                    Id = (int)t["id"],
                    DeviceId = t["deviceId"] is DBNull ? null : (int?)t["devieId"],
                    DevicePropId = t["devicePropId"] is DBNull ? null : (int?)t["devicePropId"],
                    DevicePropCode = t["devicePropCode"].ToString(),
                    ServerHandle = (int)t["serverHandle"],
                    Address = t["address"].ToString(),
                    value = t["value"].ToString(),
                    Enable = Convert.ToBoolean(t["enable"])
                }).ToList();
                return BillResultFactory.Sucess<List<DeviceAddressEntity>>(list, "成功");
            }
            catch (Exception ex)
            {
                return BillResultFactory.Error<List<DeviceAddressEntity>>(null, "异常:" + ex.ToString());
            }

        }

        public static BillResult<List<DevicePropEntity>> GetAllDeviceProp()
        {
            try
            {
                string sql = "select * from deviceprop where enable=1";
                var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);
                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                {
                    return BillResultFactory.Error<List<DevicePropEntity>>(null, "没有数据");
                }
                var list = ds.Tables[0].AsEnumerable().Select(t => new DevicePropEntity
                {
                    Id = (int)t["id"],
                    DeviceTypeId = (int)t["deviceTypeId"],
                    Code = t["code"].ToString(),
                    Name = t["name"].ToString(),
                    Type = t["type"].ToString(),
                    Description = t["description"].ToString(),
                    Enable = Convert.ToBoolean(t["enable"])
                }).ToList();
                return BillResultFactory.Sucess<List<DevicePropEntity>>(list, "成功");
            }
            catch (Exception ex)
            {
                return BillResultFactory.Error<List<DevicePropEntity>>(null, "异常:" + ex.ToString());
            }
        }

        public static BillResult<List<DeviceTypeEntity>> GetAllDeviceType()
        {
            try
            {
                string sql = "select * from devicetype where enable=1";
                var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);
                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                {
                    return BillResultFactory.Error<List<DeviceTypeEntity>>(null, "没有数据");
                }
                var list = ds.Tables[0].AsEnumerable().Select(t => new DeviceTypeEntity
                {
                    Id = (int)t["id"],
                    Code = t["code"].ToString(),
                    Name = t["name"].ToString(),
                    Description = t["description"].ToString(),
                    Enable = Convert.ToBoolean(t["enable"])
                }).ToList();
                return BillResultFactory.Sucess<List<DeviceTypeEntity>>(list, "成功");
            }
            catch (Exception ex)
            {
                return BillResultFactory.Error<List<DeviceTypeEntity>>(null, "异常:" + ex.ToString());
            }
        }

        #endregion

        #region location

        public static BillResult<List<LocationEntity>> GetAllLocations(String containerCode, string row, string column, string layer, string roadway, string status)
        {
            try
            {
                string sql = "select * from location where 1=1 ";
                if (!String.IsNullOrEmpty(containerCode))
                {
                    sql += " and containerCode = '" + containerCode + "'";
                }
                if (!String.IsNullOrEmpty(row))
                {
                    sql += " and row =" + row;
                }
                if (!String.IsNullOrEmpty(column))
                {
                    sql += " and column =" + column;
                }
                if (!String.IsNullOrEmpty(layer))
                {
                    sql += " and layer =" + layer;
                }
                if (!String.IsNullOrEmpty(roadway))
                {
                    sql += " and roadway =" + roadway;
                }
                if (!String.IsNullOrEmpty(status))
                {
                    sql += " and status = '" + status + "'";
                }

                var ds = MySqlHelper.ExecuteDataset(AppCommon.ConnectionString, sql);
                if (ds == null || ds.Tables.Count == 0 || ds.Tables[0].Rows.Count == 0)
                {
                    return BillResultFactory.Error<List<LocationEntity>>(null, "没有数据");
                }

                var list = ds.Tables[0].AsEnumerable().Select(t => new LocationEntity
                {
                    Id = (int)t["id"],
                    Code = t["code"].ToString(),
                    WarehouseCode = t["warehouseCode"].ToString(),
                    Row = (int)t["row"],
                    Column = (int)t["column"],
                    Layer = (int)t["layer"],
                    Grid = t["grid"] is DBNull?0:Convert.ToInt32(t["grid"]),
                    Roadway = (int)t["roadway"],
                    ContainerCode = t["containerCode"].ToString(),
                    Status = t["status"].ToString()
                }).ToList();
                return BillResultFactory.Sucess<List<LocationEntity>>(list, "成功");
            }
            catch (Exception ex)
            {
                return BillResultFactory.Error<List<LocationEntity>>(null, "访问异常：" + ex.ToString());
            }
        }

        #endregion
    }
}