using HH.WCS.JingyuNongfu.util;
using SqlSugar;
using System;
using System.Collections.Generic;

namespace HH.WCS.JingyuNongfu.wms
{
    /// <summary>
    /// 涉及到设备任务调度的，例如提升机、堆垛机、输送线相关表的读写
    /// </summary>
    public class WCSHelper
    {
        static WCSHelper() {
        }

      
       
        internal static bool AddElevatorTaskInfo(ElevatorTaskInfo info) {
            var db = new SqlHelper<ElevatorTaskInfo>().GetInstance();
            return db.Insertable(info).ExecuteCommand() > 0;
        }
        /// <summary>
        /// 获取一个执行中的电梯任务
        /// </summary>
        /// <returns></returns>
        internal static ElevatorTaskInfo GetOneWorkingElevatorTask() {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<ElevatorTaskInfo>().Where(a => a.state > 0).First();

        }
        /// <summary>
        /// 获取一个已经分配电梯缓存位的任务
        /// </summary>
        /// <returns></returns>
        internal static ElevatorTaskInfo GetOneAssignedElevatorTask() {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<ElevatorTaskInfo>().Where(a => !string.IsNullOrEmpty(a.elevatorCacheBit.Trim())).First();

        }
        /// <summary>
        /// 获取一个待处理的电梯任务
        /// </summary>
        /// <returns></returns>
        internal static ElevatorTaskInfo GetOnePendingElevatorTask() {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<ElevatorTaskInfo>().Where(a => a.state == 0 && string.IsNullOrEmpty(a.elevatorCacheBit.Trim())).First();

        }
        internal static ElevatorTaskInfo GetElevatorTaskByBit(string bit) {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<ElevatorTaskInfo>().Where(a => a.elevatorCacheBit.Trim() == bit.Trim()).First();

        }
        /// <summary>
        /// 获取同类型的电梯任务
        /// </summary>
        /// <param name="taskNo"></param>
        /// <param name="actionType"></param>
        /// <returns></returns>
        internal static List<ElevatorTaskInfo> GetOtherElevatorTask(string taskNo, int actionType) {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<ElevatorTaskInfo>().Where(a => a.actionType == actionType && a.sourceNo.Trim() != taskNo.Trim()).ToList();
        }
        internal static ElevatorTaskInfo GetElevatorTask(string taskNo) {
            var db = new SqlHelper<object>().GetInstance();
            return db.Queryable<ElevatorTaskInfo>().Where(a =>  a.sourceNo.Trim() != taskNo.Trim()).First();
        }
        internal static bool UpdateElevatorTask(string bit, int currState, int state) {
            var result = false;
            var db = new SqlHelper<ElevatorTaskInfo>().GetInstance();
            var model = db.Queryable<ElevatorTaskInfo>().Where(a => a.elevatorCacheBit == bit && a.state == currState).First();
            if (model != null) {
                model.state = state;
                result = db.Updateable(model).UpdateColumns(it => new { it.state }).ExecuteCommand() > 0;
            }
            return result;

        }
        internal static bool UpdateElevatorTask(ElevatorTaskInfo model, string cacheBit, int state) {
            var result = false;
            var db = new SqlHelper<ElevatorTaskInfo>().GetInstance();
            model.elevatorCacheBit = cacheBit;
            model.state = state;
            result = db.Updateable(model).UpdateColumns(it => new { it.elevatorCacheBit, it.state }).ExecuteCommand() > 0;
            return result;

        }
        internal static bool UpdateElevatorTask(string taskNo, int state) {
            var result = false;
            var db = new SqlHelper<ElevatorTaskInfo>().GetInstance();
            var model = db.Queryable<ElevatorTaskInfo>().Where(a => a.sourceNo.Trim()==taskNo).First();
            if (model != null) {
                model.state = state;
                result = db.Updateable(model).UpdateColumns(it => new { it.state }).ExecuteCommand() > 0;
            }
            return result;

        }
        internal static bool DeleteElevatorTaskByState(int state) {
            var db = new SqlHelper<object>().GetInstance();
            return db.Deleteable<ElevatorTaskInfo>().Where(a => a.state == state).ExecuteCommand() > 0;

        }
        internal static bool DeleteElevatorTask(ElevatorTaskInfo taskInfo) {
            var db = new SqlHelper<object>().GetInstance();
            return db.Deleteable<ElevatorTaskInfo>().Where(a => a.S_ID == taskInfo.S_ID).ExecuteCommand() > 0;

        }
        internal static bool DeleteElevatorTask(string no) {
            var db = new SqlHelper<object>().GetInstance();
            return db.Deleteable<ElevatorTaskInfo>().Where(a => a.sourceNo.Trim() == no).ExecuteCommand() > 0;

        }
       

    }
}