using HH.WCS.Mobox3.HD.device;
using HH.WCS.Mobox3.HD.process;
using HH.WCS.Mobox3.HD.util;
using HH.WCS.Mobox3.HD.wms;
using Newtonsoft.Json;
using System;
using System.Web.Http;
using static HH.WCS.Mobox3.HD.api.ApiHelper;
using static HH.WCS.Mobox3.HD.api.ApiModel;
using static HH.WCS.Mobox3.HD.api.OtherModel;
using static HH.WCS.Mobox3.HD.core.MQTTCore;
using static HH.WCS.Mobox3.HD.device.S7Helper;
using SqlSugar;
using System.Reflection;

namespace HH.WCS.Mobox3.HD.api {
    /// <summary>
    /// 测试用，如果项目中要和设备对接，前期设备无法测试，用接口模拟
    /// </summary>
    [RoutePrefix("api")]
    public class DebugController : System.Web.Http.ApiController {


        [HttpPost]
        [Route("s7SetInt")]
        public SimpleResult s7SetInt(DBWModel model) {
            S7Helper.s7SetInt(model);
            return new SimpleResult();

        }

        [HttpPost]
        [Route("s7SetDint")]
        public SimpleResult s7SetDint(DBWModel model)
        {
            S7Helper.s7SetDint(model);
            return new SimpleResult();

        }


        [HttpPost]
        [Route("s7SetBit")]
        public SimpleResult s7SetBit(DBXModel model) {
            S7Helper.s7SetBit(model);
            return new SimpleResult();
        }

        [HttpPost]
        [Route("s7SetString")]
        public SimpleResult s7SetString(DBBModel model) {
            S7Helper.s7SetStr(model);
            return new SimpleResult();

        }

        [HttpPost]
        [Route("mqttsTest")]
        public SimpleResult mqttsTest(string locCode)
        {
            try
            {
                Location loc = LocationHelper.GetLoc(locCode);
                MqttClientService mqttClientService = new MqttClientService();
                LogHelper.Info("获取MQTT服务......", "MQTTS");
                mqqtClients.TryGetValue("数字孪生", out mqttClientService);

                LogHelper.Info("mqtts开始推送消息", "MQTTS");
                mqttClientService.Publish("locationChange", JsonConvert.SerializeObject(new AreaLocStatusData()
                {
                    areaCode = loc.S_AREA_CODE,
                    locCode = locCode,
                    status = 1
                }));
                LogHelper.Info("mqtts推送消息完成", "MQTTS");
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                LogHelper.Info("mqtts测试错误，错误原因：" + e.Message,"MQTTS");
            }
            return new SimpleResult();
        }

        [HttpPost]
        [Route("ddjTaskTest")]
        public SimpleResult ddjTaskTest(TaskParam model)
        {
            var startLoc = LocationHelper.GetLoc(model.startLoc);
            var endLoc = LocationHelper.GetLoc(model.endLoc);

            WCSTask wcsTask = new WCSTask
            {
                S_CODE = WCSHelper.GenerateTaskNo(),
                S_TYPE = "堆垛机"+ model.taskType + "测试任务",
                S_START_LOC = startLoc.S_CODE,
                S_START_AREA = startLoc.S_AREA_CODE,
                S_END_LOC = endLoc.S_CODE,
                S_END_AREA = endLoc.S_AREA_CODE,
                S_CNTR_CODE = model.trayCode,
                N_CNTR_COUNT = 1,
                S_SCHEDULE_TYPE = "RB",
                S_EQ_NO = model.eqCode,
            };
            if (WCSHelper.CreateTask(wcsTask))
            {
                // 对开始货位、接驳货位、终点货位进行加锁
                LocationHelper.LockLoc(startLoc.S_CODE, 2);
                LocationHelper.LockLoc(endLoc.S_CODE, 1);
            }
            return new SimpleResult();

        }

        [HttpPost]
        [Route("Test1")]
        public SimpleResult Test1() {
            var db = new SqlHelper<object>().GetInstance();
            var data = db.Queryable<Location>()
                     .LeftJoin<FunctionArea>((a, b) => a.S_CODE == b.S_FA_CODE && b.N_FA_TYPE == 1)
                     .LeftJoin<WCSTask>((a, b, c) => a.S_CODE == c.S_END_LOC && c.N_B_STATE < 3)
                     .Where((a, b, c) => a.S_AREA_CODE == "LTK02-JB" && a.N_ROADWAY == 1 && b.N_TYPE == 11)
                     .GroupBy((a, b, c) => new { a.S_CODE })
                     .Select((a, b, c) => new {
                         count = SqlFunc.AggregateCount(c.S_END_LOC),
                         name = a.S_CODE
                     })
                    .MergeTable()//需要加MergeTable才能排序统计过的列
                    .OrderBy(it => it.count)
                    .ToList();
            return new SimpleResult() { result = data };
        }

        [HttpPost]
        [Route("ExecutionMethod")]
        public void ExecutionMethod()
        {
            // 假设你已经获取到了类名和方法名
            string className = "HH.WCS.Mobox3.HD.api.DebugController";
            string methodName = "mqttsTest";
            string locCode = "11111";

            // 获取类型
            Type type = Type.GetType(className);
            if (type == null)
            {
                Console.WriteLine("Class not found");
                return;
            }

            // 创建实例
            object instance = Activator.CreateInstance(type);

            // 获取方法信息
            MethodInfo methodInfo = type.GetMethod(methodName);
            if (methodInfo == null)
            {
                Console.WriteLine("Method not found");
                return;
            }

            // 调用方法
            methodInfo.Invoke(instance, new object[] { locCode });
        }

        [HttpPost]
        [Route("DeleteMouldByCntr")]
        public void DeleteMouldByCntr(string cntrCode) 
        {
            MouldHelper.deleteMouldByCntr(cntrCode);
        }

        public class TaskParam{
            public string taskType { get; set; }
            public string startLoc { get; set; }
            public string endLoc { get; set; }
            public string trayCode { get; set; }
            public string eqCode { get; set; } // 设备号
        }
    }
}