using SqlSugar;
using SHJX.Service.Common.ReadXML;
using SHJX.Service.Model.Dao;
using System.Collections.Generic;

namespace SHJX.Service.Dao
{
    public class OperateDataManager : DataManagerImp
    {
        public OperateDataManager(ReadConfigUtil config)
        {
            InitData(config);
        }

        public List<EquipmentTask> GetTaskByWaveKey(string waveKey, string level,string taskType)
        {
            var tasks = Db.Queryable<EquipmentTask>().Where(item => item.TaskType.Equals(taskType) && item.WaveKey.Equals(waveKey)&&item.SampleConcentration.Equals(level)).ToList();
            return tasks.Count < 1 ? null : tasks;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        /// <![CDATA[
        /// SELECT * FROM equipment_task WHERE wavekey=(
        /// SELECT wavekey FROM equipment_task 
        /// where TaskType='标定' GROUP BY wavekey 
        /// ORDER BY CreateTime desc 
        /// LIMIT 1
        /// )
        /// ]]>
        public List<EquipmentTask> GetLastOtherTaskByWaveKey(string taskType, string level)
        {
            var task = Db.Queryable<EquipmentTask>()
                   .Where(item => item.TaskType.Equals(taskType) 
                   && item.Status.Equals(TaskState.Finished)
                   &&item.SampleConcentration.Equals(level))
                   .GroupBy(item => new { item.WaveKey })
                   .OrderBy(item => item.CreateTime, OrderByType.Desc)
                   .First();
            var waveKey = task?.WaveKey;
            var tasks = Db.Queryable<EquipmentTask>()
                .Where(item => item.WaveKey.Equals(waveKey))
                .Where(item => item.TaskType.Equals(taskType))
                .ToList();
            return tasks.Count < 1 ? null : tasks;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="data"></param>
        /// <returns></returns>
        public List<EquipmentTask> GetIsHaveEquipment(EquipmentTask data) =>
            Db.Queryable<EquipmentTask>()
                .Where(item => item.RouteType.Equals(data.RouteType))
                .Where(item => item.RouteId.Equals(data.RouteId))
                .Where(item => item.RouteStepId.Equals(data.RouteStepId))
                .Where(item => item.Status.Equals(TaskState.Doing))
                .ToList();

        public bool GetTaskIsDoingOrNew() =>
                Db.Queryable<EquipmentTask>()
                    .Where(item => item.Status.Equals(TaskState.Doing) || item.Status.Equals(TaskState.New))
                    .Any();

        public bool GetEquipmentTasksBD(string wavekey) =>
                Db.Queryable<EquipmentTask>()
                    .Where(item => item.WaveKey == wavekey && item.TaskType == "标定" && !item.Status.Equals(TaskState.Finished))
                     .Any();


        public List<EquipmentTask> QueryHeatingTaskbyState(string opType) => Db.Queryable<EquipmentTask>()
            .Where(item => item.RouteStep.Equals(opType)
            && item.Status.Equals(TaskState.Doing)).ToList();

        public DropLiquid QueryLiquid(string pumpName) => Db.Queryable<DropLiquid>().First(item => item.LiquidName.Equals(pumpName));

        public PID GetPid(string type) => Db.Queryable<PID>().First(item => item.TypeName.Equals(type));
    }
}