using Cksoft.Data;
using Cksoft.Data.Repository;
using Cksoft.Unity;
using Cksoft.Unity.Log4NetConfig;
using DllEapEntity;
using DllEapEntity.Dtos;
using DllEapEntity.OFILM;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Logging;
using Newtonsoft.Json;
using SharpCifs.Util.Sharpen;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net.Http;
using System.Text;
using System.Threading.Tasks;

namespace DllEapDal.OFILM
{
    public class SamplePara
    {
        /// <summary>
        /// 获取DA所有稼动机台的X，Y，T，MDP参数
        /// </summary>
        public IConfiguration Configuration { get; set; }
        private ILogger<SamplePara> myloger = null;
        /// <summary>
        /// 将数据获取结果写入日志
        /// </summary>
        public void Get()
        {
            SetTypeAsync();
        }

        private async Task SetTypeAsync()
        {
            Parallel.Invoke(
                () =>
                    {
                        var t1 = GetparaAsync();
                        LogHelper<SamplePara>.LogInfo(JsonConvert.SerializeObject(t1.Result), null, null);
                    },
                () =>
                    {
                        var t2 =  GetLHAPara();
                        LogHelper<SamplePara>.LogInfo(JsonConvert.SerializeObject(t2.Result), null, null);
                    },
                () =>
                    {
                        var t3 =  GetAAPara();
                        LogHelper<SamplePara>.LogInfo(JsonConvert.SerializeObject(t3.Result), null, null);
                    });
        }

        /// <summary>
        /// 获取所有稼动的DA机台的相关参数
        /// </summary>
        /// <returns></returns>
        private async Task<List<object>> GetparaAsync()
        {
            IDatabase db = DbFactory.Base("eap");
            DaSampleDal dal = new DaSampleDal(db);
            List<MacInfo> data = GetMachine("DA");
            List<string> li = new List<string>() {"19","560", "561", "562", "1070","1060" };
            /*MacInfo m = new MacInfo() { parameters = li };*/
            List<object > list = new List<object>();
            foreach (var item in data)
            {
                item.parameters = li;
                var result = await dal.GetParams(item);
                list.Add("机台编号：" + item.EquipmentID + "结果为：" + result);
            }
          
            return list;
        }
        private async Task<List<object>> GetLHAPara()
        {
            Parameter dal = new Parameter();
            List<MacInfo> data = GetMachine("LHA");
            List<string> li = new List<string>() { "19", "1071", "1101", "1090", "1060" };
            List<object> list = new List<object>();
            foreach (var item in data)
            {
                item.Pcode = "LHA";
                item.parameters = li;
                var result = await dal.GetParams(item);
                list.Add("机台编号：" + item.EquipmentID + "结果为：" + result);
            }

            return list;
        }

        

        private List<MacInfo> GetMachine(string str)
        {
            using (IDatabase db = DbFactory.Base("eapslave")) {
                string sql = " select ID MacId,FCode EquipmentID from   machine  ";
                return db.FindList<MacInfo>(sql).ToList().Where(c => c.EquipmentID.StartsWith(str))?.ToList();
            }
        }

        private async Task<List<object>> GetAAPara()
        {
            Parameter dal = new Parameter();
            List<MacInfo> data = GetMachine("AA");
            List<string> li = new List<string>() { "19", "4002", "4102", "4202", "4302" };
            List<object> list = new List<object>();
            foreach (var item in data)
            {
                item.Pcode = "AA";
                item.parameters = li;
                var result = await dal.GetParams(item);
                list.Add("机台编号：" + item.EquipmentID + "结果为：" + result);
            }
            return list;
        }

    }
}