WEBUI/WMS.BZServices/FJ/FJQuestDB/FJDevRunInfoService.cs

using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
using wms.sqlsugar.model.fj;
using WMS.BZModels;
using WMS.BZModels.Dto;
using WMS.BZModels.Dto.FJ.FJQuestDB;
using WMS.BZModels.Models.FJQuestDB;
using WMS.BZSqlSugar;
using WMS.Info;
using WMS.Util;

namespace WMS.BZServices.FJ.FJQuestDB
{
    public class FJDevRunInfoService
    {
        private readonly Repository<WCS_TaskOld> _wcstaskoldrepository;
        private readonly Repository<FJDevRunInfo> _fjDevRunInfoRepository;

        private static readonly List<string> SRMLists = new List<string>()
        {
          "SRM1", "SRM2" , "SRM3" , "SRM4" , "SRM5" , "SRM6" , "SRM107" , "SRM108" };

        public FJDevRunInfoService(Repository<FJDevRunInfo> fjDevRunInfoRepository, Repository<WCS_TaskOld> wcstaskoldrepository)
        {
            _fjDevRunInfoRepository = fjDevRunInfoRepository;
            _wcstaskoldrepository = wcstaskoldrepository;
        }

        public ISugarQueryable<TaskInOutDto> TaskInOutQueryable(DateTime? start, DateTime? end)
        {
            var predicate = Expressionable.Create<WCS_TaskOld>();
            predicate = predicate.And(m => m.Status == (int)BZModels.TaskStatus.Finish);
            predicate = predicate.AndIF(start.HasValue && start.Value != DateTime.MinValue, m => m.EndTime >= start.Value);
            predicate = predicate.AndIF(end.HasValue && end.Value != DateTime.MinValue, m => m.EndTime <= end.Value);
            var sugarQueryable = _wcstaskoldrepository.Queryable().With(SqlWith.NoLock).Where(predicate.ToExpression()).SplitTable(tabs => tabs.Take(3))
                 .MergeTable()//将查询结果转成一个表
                 .GroupBy(o => new { o.Type, o.Device })
                 .Select(it => new TaskInOutDto { Count = SqlFunc.AggregateCount(it.Type), Type = it.Type, BusType = it.Device });
            return sugarQueryable;

        }

        public List<FJDevRunInfoDto> GetDataList(FJDevRunInfoQueryDto queryDto)
        {
            var predicate = Expressionable.Create<FJDevRunInfo>().And(m => m.runmode != null && m.runstatus != null);
            predicate = predicate.AndIF(queryDto.BeginTime.HasValue, m => m.starttime >= queryDto.BeginTime);
            predicate = predicate.AndIF(queryDto.EndTime.HasValue, m => m.endtime <= queryDto.EndTime);
            predicate = predicate.AndIF(queryDto.DevType.HasValue, m => m.type.Equals((int)queryDto.DevType));
            var lists = _fjDevRunInfoRepository.Queryable().GroupBy(o => new { o.runmode, o.runstatus, o.code }).Where(predicate.ToExpression())
                .Select(it => new FJDevRunInfoDto
                {
                    runmode = it.runmode,
                    runstatus = it.runstatus,
                    code = it.code,
                    duration = SqlFunc.AggregateSum(it.duration),
                }).ToList();
            return lists;
        }

        public PagedInfo<RunListModel> GetSRMPageList(Pagination pagination, FJDevRunInfoQueryDto queryDto)
        {
            var tasklists = TaskInOutQueryable(queryDto.BeginTime, queryDto.EndTime).ToList();

            var lists = GetDataList(queryDto);

            var RunListModellists = new List<RunListModel>();
            foreach (var srmcode in SRMLists)
            {
                var runListModel = new RunListModel() { Code = srmcode };
                runListModel.OutDepot = tasklists.FirstOrDefault(o => o.BusType == srmcode && o.Type == 2)?.Count ?? 0;
                runListModel.EnterDepot = tasklists.FirstOrDefault(o => o.BusType == srmcode && o.Type == 1)?.Count ?? 0;
                runListModel.TransferDepot = tasklists.FirstOrDefault(o => o.BusType == srmcode && o.Type == 3)?.Count ?? 0;

                var totalduration = lists.Where(o => o.code == srmcode).Sum(o => o.duration);

                var Free = lists.Where(o => o.runstatus == "空闲" && o.code == srmcode).Sum(o => o.duration);
                runListModel.Free = TimeSpan.FromMilliseconds(Free).TotalMinutes;
                runListModel.State[0] = totalduration > 0 ? Math.Round(Free / (decimal)totalduration * 100, 2) : 0;

                var Manual = lists.Where(o => o.runmode == "手动" && o.code == srmcode).Sum(o => o.duration);
                runListModel.Manual = TimeSpan.FromMilliseconds(Manual).TotalMinutes;
                runListModel.State[1] = totalduration > 0 ? Math.Round(Manual / (decimal)totalduration * 100, 2) : 0;

                var Automatic = lists.Where(o => o.runmode == "自动" && o.code == srmcode).Sum(o => o.duration);
                runListModel.Automatic = TimeSpan.FromMilliseconds(Automatic).TotalMinutes;
                runListModel.State[2] = totalduration > 0 ? Math.Round(Automatic / (decimal)totalduration * 100, 2) : 0;

                var Alarm = lists.Where(o => o.runmode == "报警" && o.code == srmcode).Sum(o => o.duration);
                runListModel.Alarm = TimeSpan.FromMilliseconds(Alarm).TotalMinutes;
                runListModel.State[3] = totalduration > 0 ? Math.Round(Alarm / (decimal)totalduration * 100, 2) : 0;

                var Working = lists.Where(o => o.runmode == "自动" && !new string[] { "手动", "半自动", "自动", "报警", "空闲", "维护" }.Contains(o.runstatus) && o.code == srmcode).Sum(o => o.duration);
                runListModel.Working = TimeSpan.FromMilliseconds(Working).TotalMinutes;
                runListModel.State[4] = totalduration > 0 ? Math.Round(Working / (decimal)totalduration * 100, 2) : 0;

                RunListModellists.Add(runListModel);
            }

            PagedInfo<RunListModel> resultlists = new PagedInfo<RunListModel>()
            {
                Result = RunListModellists
            };

            if (!pagination.sidx.IsEmpty())
            {
                pagination.sidx = pagination.sidx.Replace("DESC", "").Replace("ASC", "");
                if (pagination.sidx != "No")
                {
                    resultlists.Result.Sort(
                    delegate (RunListModel info1, RunListModel info2)
                    {
                        Type t = typeof(RunListModel);
                        PropertyInfo pro = t.GetProperty(pagination.sidx);
                        if (pagination.sidx == "Code")
                        {
                            return pagination.sord.ToLower().Contains("asc") ?
                                                          pro.GetValue(info1, null).ToString().CompareTo(pro.GetValue(info2, null).ToString()) :
                                                          pro.GetValue(info2, null).ToString().CompareTo(pro.GetValue(info1, null).ToString());
                        }
                        else
                            return pagination.sord.ToLower().Contains("asc") ?
                                 pro.GetValue(info1, null).ToDouble().CompareTo(pro.GetValue(info2, null).ToDouble()) :
                                 pro.GetValue(info2, null).ToDouble().CompareTo(pro.GetValue(info1, null).ToDouble());

                    });
                }
            }
            resultlists.PageIndex = 1;
            resultlists.PageSize = resultlists.Result.Count;
            resultlists.TotalNum = resultlists.Result.Count;
            var total = lists.Sum(o => o.duration);
            resultlists.Extra.Add("total", total / 1000.0 / 60.0);
            return resultlists;
        }

        public PagedInfo<RunListModel> GetRobotPageList(Pagination pagination, FJDevRunInfoQueryDto queryDto)
        {
            var tasklists = TaskInOutQueryable(queryDto.BeginTime, queryDto.EndTime).ToList();

            var lists = GetDataList(queryDto);
            var RunListModellists = new List<RunListModel>();
            foreach (var robotcode in new string[] { "Robot1", "Robot2" })
            {
                var runListModel = new RunListModel() { Code = robotcode };
                runListModel.OutDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 2)?.Count ?? 0;
                //runListModel.EnterDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 1)?.Count ?? 0;
                //runListModel.TransferDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 3)?.Count ?? 0;

                var totalduration = lists.Where(o => o.code == robotcode).Sum(o => o.duration);

                var Free = lists.Where(o => o.runstatus == "空闲" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Free = TimeSpan.FromMilliseconds(Free).TotalMinutes;
                runListModel.State[0] = totalduration > 0 ? Math.Round(Free / (decimal)totalduration * 100, 2) : 0;

                var Manual = lists.Where(o => o.runmode == "手动" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Manual = TimeSpan.FromMilliseconds(Manual).TotalMinutes;
                runListModel.State[1] = totalduration > 0 ? Math.Round(Manual / (decimal)totalduration * 100, 2) : 0;

                var Automatic = lists.Where(o => o.runmode == "自动" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Automatic = TimeSpan.FromMilliseconds(Automatic).TotalMinutes;
                runListModel.State[2] = totalduration > 0 ? Math.Round(Automatic / (decimal)totalduration * 100, 2) : 0;

                var Alarm = lists.Where(o => o.runmode == "报警" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Alarm = TimeSpan.FromMilliseconds(Alarm).TotalMinutes;
                runListModel.State[3] = totalduration > 0 ? Math.Round(Alarm / (decimal)totalduration * 100, 2) : 0;

                var Working = lists.Where(o => o.runmode == "自动" && !new string[] { "手动", "半自动", "自动", "报警", "空闲", "维护" }.Contains(o.runstatus) && o.code == robotcode).Sum(o => o.duration);
                runListModel.Working = TimeSpan.FromMilliseconds(Working).TotalMinutes;
                runListModel.State[4] = totalduration > 0 ? Math.Round(Working / (decimal)totalduration * 100, 2) : 0;

                RunListModellists.Add(runListModel);
            }

            PagedInfo<RunListModel> resultlists = new PagedInfo<RunListModel>()
            {
                Result = RunListModellists
            };

            if (!pagination.sidx.IsEmpty())
            {
                pagination.sidx = pagination.sidx.Replace("DESC", "").Replace("ASC", "");
                if (pagination.sidx != "No")
                {
                    resultlists.Result.Sort(
                    delegate (RunListModel info1, RunListModel info2)
                    {
                        Type t = typeof(RunListModel);
                        PropertyInfo pro = t.GetProperty(pagination.sidx);
                        if (pagination.sidx == "Code")
                        {
                            return pagination.sord.ToLower().Contains("asc") ?
                                                          pro.GetValue(info1, null).ToString().CompareTo(pro.GetValue(info2, null).ToString()) :
                                                          pro.GetValue(info2, null).ToString().CompareTo(pro.GetValue(info1, null).ToString());
                        }
                        else
                            return pagination.sord.ToLower().Contains("asc") ?
                                 pro.GetValue(info1, null).ToDouble().CompareTo(pro.GetValue(info2, null).ToDouble()) :
                                 pro.GetValue(info2, null).ToDouble().CompareTo(pro.GetValue(info1, null).ToDouble());

                    });
                }
            }
            resultlists.PageIndex = 1;
            resultlists.PageSize = resultlists.Result.Count;
            resultlists.TotalNum = resultlists.Result.Count;
            var total = lists.Sum(o => o.duration);
            resultlists.Extra.Add("total", total / 1000.0 / 60.0);
            return resultlists;
        }

        public PagedInfo<RunListModel> GetRgvPageList(Pagination pagination, FJDevRunInfoQueryDto queryDto)
        {
            var tasklists = TaskInOutQueryable(queryDto.BeginTime, queryDto.EndTime).ToList();

            var lists = GetDataList(queryDto);
            var RunListModellists = new List<RunListModel>();
            foreach (var robotcode in new string[] { "Robot1", "Robot2" })
            {
                var runListModel = new RunListModel() { Code = robotcode };
                runListModel.OutDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 2)?.Count ?? 0;
                //runListModel.EnterDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 1)?.Count ?? 0;
                //runListModel.TransferDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 3)?.Count ?? 0;

                var totalduration = lists.Where(o => o.code == robotcode).Sum(o => o.duration);

                var Free = lists.Where(o => o.runstatus == "空闲" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Free = TimeSpan.FromMilliseconds(Free).TotalMinutes;
                runListModel.State[0] = totalduration > 0 ? Math.Round(Free / (decimal)totalduration * 100, 2) : 0;

                var Manual = lists.Where(o => o.runmode == "手动" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Manual = TimeSpan.FromMilliseconds(Manual).TotalMinutes;
                runListModel.State[1] = totalduration > 0 ? Math.Round(Manual / (decimal)totalduration * 100, 2) : 0;

                var Automatic = lists.Where(o => o.runmode == "自动" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Automatic = TimeSpan.FromMilliseconds(Automatic).TotalMinutes;
                runListModel.State[2] = totalduration > 0 ? Math.Round(Automatic / (decimal)totalduration * 100, 2) : 0;

                var Alarm = lists.Where(o => o.runmode == "报警" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Alarm = TimeSpan.FromMilliseconds(Alarm).TotalMinutes;
                runListModel.State[3] = totalduration > 0 ? Math.Round(Alarm / (decimal)totalduration * 100, 2) : 0;

                var Working = lists.Where(o => o.runmode == "自动" && !new string[] { "手动", "半自动", "自动", "报警", "空闲", "维护" }.Contains(o.runstatus) && o.code == robotcode).Sum(o => o.duration);
                runListModel.Working = TimeSpan.FromMilliseconds(Working).TotalMinutes;
                runListModel.State[4] = totalduration > 0 ? Math.Round(Working / (decimal)totalduration * 100, 2) : 0;

                RunListModellists.Add(runListModel);
            }

            PagedInfo<RunListModel> resultlists = new PagedInfo<RunListModel>()
            {
                Result = RunListModellists
            };

            if (!pagination.sidx.IsEmpty())
            {
                pagination.sidx = pagination.sidx.Replace("DESC", "").Replace("ASC", "");
                if (pagination.sidx != "No")
                {
                    resultlists.Result.Sort(
                    delegate (RunListModel info1, RunListModel info2)
                    {
                        Type t = typeof(RunListModel);
                        PropertyInfo pro = t.GetProperty(pagination.sidx);
                        if (pagination.sidx == "Code")
                        {
                            return pagination.sord.ToLower().Contains("asc") ?
                                                          pro.GetValue(info1, null).ToString().CompareTo(pro.GetValue(info2, null).ToString()) :
                                                          pro.GetValue(info2, null).ToString().CompareTo(pro.GetValue(info1, null).ToString());
                        }
                        else
                            return pagination.sord.ToLower().Contains("asc") ?
                                 pro.GetValue(info1, null).ToDouble().CompareTo(pro.GetValue(info2, null).ToDouble()) :
                                 pro.GetValue(info2, null).ToDouble().CompareTo(pro.GetValue(info1, null).ToDouble());

                    });
                }
            }
            resultlists.PageIndex = 1;
            resultlists.PageSize = resultlists.Result.Count;
            resultlists.TotalNum = resultlists.Result.Count;
            var total = lists.Sum(o => o.duration);
            resultlists.Extra.Add("total", total / 1000.0 / 60.0);
            return resultlists;
        }

        public PagedInfo<RunListModel> GetHJPageList(Pagination pagination, FJDevRunInfoQueryDto queryDto)
        {
            var tasklists = TaskInOutQueryable(queryDto.BeginTime, queryDto.EndTime).ToList();

            var lists = GetDataList(queryDto);
            var RunListModellists = new List<RunListModel>();
            foreach (var robotcode in new string[] { "Robot1", "Robot2" })
            {
                var runListModel = new RunListModel() { Code = robotcode };
                runListModel.OutDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 2)?.Count ?? 0;
                //runListModel.EnterDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 1)?.Count ?? 0;
                //runListModel.TransferDepot = tasklists.FirstOrDefault(o => o.BusType == robotcode && o.Type == 3)?.Count ?? 0;

                var totalduration = lists.Where(o => o.code == robotcode).Sum(o => o.duration);

                var Free = lists.Where(o => o.runstatus == "空闲" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Free = TimeSpan.FromMilliseconds(Free).TotalMinutes;
                runListModel.State[0] = totalduration > 0 ? Math.Round(Free / (decimal)totalduration * 100, 2) : 0;

                var Manual = lists.Where(o => o.runmode == "手动" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Manual = TimeSpan.FromMilliseconds(Manual).TotalMinutes;
                runListModel.State[1] = totalduration > 0 ? Math.Round(Manual / (decimal)totalduration * 100, 2) : 0;

                var Automatic = lists.Where(o => o.runmode == "自动" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Automatic = TimeSpan.FromMilliseconds(Automatic).TotalMinutes;
                runListModel.State[2] = totalduration > 0 ? Math.Round(Automatic / (decimal)totalduration * 100, 2) : 0;

                var Alarm = lists.Where(o => o.runmode == "报警" && o.code == robotcode).Sum(o => o.duration);
                runListModel.Alarm = TimeSpan.FromMilliseconds(Alarm).TotalMinutes;
                runListModel.State[3] = totalduration > 0 ? Math.Round(Alarm / (decimal)totalduration * 100, 2) : 0;

                var Working = lists.Where(o => o.runmode == "自动" && !new string[] { "手动", "半自动", "自动", "报警", "空闲", "维护" }.Contains(o.runstatus) && o.code == robotcode).Sum(o => o.duration);
                runListModel.Working = TimeSpan.FromMilliseconds(Working).TotalMinutes;
                runListModel.State[4] = totalduration > 0 ? Math.Round(Working / (decimal)totalduration * 100, 2) : 0;

                RunListModellists.Add(runListModel);
            }

            PagedInfo<RunListModel> resultlists = new PagedInfo<RunListModel>()
            {
                Result = RunListModellists
            };

            if (!pagination.sidx.IsEmpty())
            {
                pagination.sidx = pagination.sidx.Replace("DESC", "").Replace("ASC", "");
                if (pagination.sidx != "No")
                {
                    resultlists.Result.Sort(
                    delegate (RunListModel info1, RunListModel info2)
                    {
                        Type t = typeof(RunListModel);
                        PropertyInfo pro = t.GetProperty(pagination.sidx);
                        if (pagination.sidx == "Code")
                        {
                            return pagination.sord.ToLower().Contains("asc") ?
                                                          pro.GetValue(info1, null).ToString().CompareTo(pro.GetValue(info2, null).ToString()) :
                                                          pro.GetValue(info2, null).ToString().CompareTo(pro.GetValue(info1, null).ToString());
                        }
                        else
                            return pagination.sord.ToLower().Contains("asc") ?
                                 pro.GetValue(info1, null).ToDouble().CompareTo(pro.GetValue(info2, null).ToDouble()) :
                                 pro.GetValue(info2, null).ToDouble().CompareTo(pro.GetValue(info1, null).ToDouble());

                    });
                }
            }
            resultlists.PageIndex = 1;
            resultlists.PageSize = resultlists.Result.Count;
            resultlists.TotalNum = resultlists.Result.Count;
            var total = lists.Sum(o => o.duration);
            resultlists.Extra.Add("total", total / 1000.0 / 60.0);
            return resultlists;
        }
    }
}