RCS / RCS_Differential_Slam_Changsha · Files

using Infrastructure;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using WebApp;
using WebRepository;

namespace WebMvc
{
    /// <summary>
	/// TBaseAgv
	/// </summary>
    [Area("acs")]
    public class TBaseAgvController : BaseController
    {
        private readonly TBaseAgvApp _app;
        private readonly IUnitWorkAcs _unitWorkAcs;

        public TBaseAgvController(IAuth authUtil, IUnitWorkAcs unitWorkAcs, TBaseAgvApp app) : base(authUtil)
        {
            _unitWorkAcs = unitWorkAcs;
            _app = app.SetLoginInfo(_loginInfo);
        }

        #region 视图功能
        /// <summary>
        /// 默认视图Action
        /// </summary>
        /// <returns></returns>
        [Authenticate]
        [ServiceFilter(typeof(OperLogFilter))]
        public ActionResult Index()
        {
            return View();
        }

        /// <summary>
        /// 默认视图Action
        /// </summary>
        /// <returns></returns>
        [Authenticate]
        [ServiceFilter(typeof(OperLogFilter))]
        public ActionResult ShutDown()
        {
            return View();
        }
        #endregion

        #region 获取数据
        /// <summary>
        /// 加载及分页查询
        /// </summary>
        /// <param name="pageRequest">表单请求信息</param>
        /// <param name="entity">请求条件实例</param>
        /// <returns></returns>
        [HttpPost]
        public string Load(PageReq pageRequest, TBaseAgv entity)
        {
            return JsonHelper.Instance.Serialize(_app.Load(pageRequest, entity));
        }

        /// <summary>
        /// 加载及分页查询
        /// </summary>
        /// <param name="pageRequest">表单请求信息</param>
        /// <param name="entity">请求条件实例</param>
        /// <returns></returns>
        [HttpPost]
        public string LoadAgvInfo(PageReq pageRequest, TBaseAgv entity)
        {
            return JsonHelper.Instance.Serialize(_app.LoadAgvInfo(entity));
        }
        
        #endregion

        #region 提交数据
        /// <summary>
        /// 新增数据
        /// </summary>
        /// <param name="Table_entity">新增实例</param>
        /// <returns></returns>
        [HttpPost]
        [ServiceFilter(typeof(OperLogFilter))]
        public string Ins(TBaseAgv Table_entity)
        {
            try
            {
                //ApiRequest apiRequest = new ApiRequest("RCS");
                //string parameter = JsonHelper.Instance.Serialize(new ChangeAGVModel
                //{
                //    AgvNo = Table_entity.StrAgvNo,
                //    Group = Table_entity.AgvGroup,
                //    AreaType = "1",
                //    ChooseStation = "",
                //    isEnable = Table_entity.IsEnable,
                //    CurrMap = Table_entity.AgvMap,
                //    type = "insert",
                //});
                //Response response = apiRequest.Post<Response>(parameter, "ChangeAGV", "RCS");
                //if (response.Code != 0)
                //{
                //    throw new Exception(response.Message);
                //}
                _app.Ins(Table_entity);
            }
            catch (Exception ex)
            {
                Result.Status = false;
                Result.Message = ex.Message;

            }
            return JsonHelper.Instance.Serialize(Result);
            
        }

        /// <summary>
        /// 修改数据
        /// </summary>
        /// <param name="Table_entity">修改实例</param>
        /// <returns></returns>
        [HttpPost]
        [ServiceFilter(typeof(OperLogFilter))]
        public string Upd(TBaseAgv Table_entity)
        {
            try
            {
                TBaseAgv baseAgv = _app.FindSingle(u => u.Id.Equals(Table_entity.Id));
                if (baseAgv == null)
                {
                    throw new Exception("要更新的数据不存在！");
                }

                ApiRequest apiRequest = new ApiRequest("RCS");
                string parameter = "";
                Response response;

                string type = "update";
                if (baseAgv.StrAgvNo != Table_entity.StrAgvNo)
                {
                    parameter = JsonHelper.Instance.Serialize(new ChangeAGVModel
                    {
                        AgvNo = baseAgv.StrAgvNo,
                        Group = baseAgv.AgvGroup,
                        AreaType = "1",
                        ChooseStation = "",
                        isEnable = Table_entity.IsEnable,
                        CurrMap = "",
                        type = "delete",
                    });
                    response = apiRequest.Post<Response>(parameter, "ChangeAGV", "RCS");
                    if (response.Code != 0)
                    {
                        throw new Exception(response.Message);
                    }
                    type = "insert";
                }
               
                parameter = JsonHelper.Instance.Serialize(new ChangeAGVModel
                {
                    AgvNo = Table_entity.StrAgvNo,
                    Group = Table_entity.AgvGroup,
                    AreaType = "1",
                    ChooseStation = "",
                    isEnable = Table_entity.IsEnable,
                    CurrMap = Table_entity.AgvMap,
                    type = type,
                });
                response = apiRequest.Post<Response>(parameter, "ChangeAGV", "RCS");
                if (response.Code != 0)
                {
                    throw new Exception(response.Message);
                }
            }
            catch (Exception ex)
            {
                Result.Status = false;
                Result.Message = ex.Message;
            }
            return JsonHelper.Instance.Serialize(Result);
        }

        [HttpPost]
        [ServiceFilter(typeof(OperLogFilter))]
        public string DelByIds(int[] ids)
        {
            try
            {
                foreach (var item in ids)
                {
                    TBaseAgv baseAgv = _app.FindSingle(u => u.Id == item);
                    ApiRequest apiRequest = new ApiRequest("RCS");
                    string parameter = JsonHelper.Instance.Serialize(new ChangeAGVModel
                    {
                        AgvNo = baseAgv.StrAgvNo,
                        Group = baseAgv.AgvGroup,
                        AreaType = "1",
                        ChooseStation = "",
                        isEnable = baseAgv.IsEnable,
                        CurrMap = "",
                        type = "delete",
                    });
                    Response response = apiRequest.Post<Response>(parameter, "ChangeAGV", "RCS");
                    if (response.Code != 0)
                    {
                        throw new Exception(response.Message);
                    }
                }
            }
            catch (Exception ex)
            {
                Result.Status = false;
                Result.Message = ex.Message;
            }
            return JsonHelper.Instance.Serialize(Result);
        }
        #endregion

        #region 导出数据
        /// <summary>
        /// 导出数据
        /// </summary>
        /// <param name="entity">请求条件实例</param>
        /// <returns></returns>
        [HttpPost]
        public string Export(TBaseAgv entity)
        {
            return JsonHelper.Instance.Serialize(_app.ExportData(entity));
        }
        #endregion

        #region 导出模板
        /// <summary>
        /// 导出模板
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public string GetTemplate()
        {
            var result = new TableData();
            List<TBaseAgv> listTBaseAgv = new List<TBaseAgv>();
            TBaseAgv entity = _app.FindSingle(u => u.Id > 0);
            if (entity != null)
            {
                listTBaseAgv.Add(entity);
            }
            else
            {
                listTBaseAgv.Add(new TBaseAgv());
            }
 
            result.data = listTBaseAgv;
            result.count = listTBaseAgv.Count;

            return JsonHelper.Instance.Serialize(result);
        }
        #endregion

        #region 导入数据
        /// <summary>
        /// 导入数据
        /// </summary>
        /// <param name="excelfile">表单提交的文件信息</param>
        /// <returns></returns>
        [HttpPost]
        public string Import(IFormFile excelfile)
        {
            try
            {
                Response result = _app.ImportIn(excelfile);
                if (!result.Status)
                {
                    Result.Status = false;
                    Result.Message = result.Message;
                }
            }
            catch (Exception ex)
            {
                Result.Status = false;
                Result.Message = ex.Message;
            }
            return JsonHelper.Instance.Serialize(Result);
        }
        #endregion

        #region 自定义方法
        /// <summary>
        /// 整体关机
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        [ServiceFilter(typeof(OperLogFilter))]
        public string CloseAgvAll()
        {
            try
            {
                ApiRequest apiRequest = new ApiRequest("RCS");
                string parameter = JsonHelper.Instance.Serialize(new CloseAgvModel
                {
                    offType = 1,
                });
                Response response = apiRequest.Post<Response>(parameter, "CloseAgv", "RCS");
                if (response.Code != 0)
                {
                    throw new Exception(response.Message);
                }
               
            }
            catch (Exception ex)
            {
                Result.Code = 500;
                Result.Message = ex.Message;
            }
            return JsonHelper.Instance.Serialize(Result);
        }

        /// <summary>
        /// 指定AGV关机
        /// </summary>
        /// <param name="ids">小车Id</param>
        /// <returns></returns>
        [HttpPost]
        [ServiceFilter(typeof(OperLogFilter))]
        public string CloseAgv(int[] ids)
        {
            try
            {
                foreach (var item in ids)
                {
                    TBaseAgv baseAgv = _app.FindSingle(u => u.Id == item);
                    ApiRequest apiRequest = new ApiRequest("RCS");
                    string parameter = JsonHelper.Instance.Serialize(new CloseAgvModel
                    {
                        offType = 2,
                        agvNo = baseAgv.StrAgvNo,
                    });
                    Response response = apiRequest.Post<Response>(parameter, "CloseAgv", "RCS");
                    if (response.Code != 0)
                    {
                        throw new Exception(response.Message);
                    }
                }
            }
            catch (Exception ex)
            {
                Result.Code = 500;
                Result.Message = ex.Message;
            }
            return JsonHelper.Instance.Serialize(Result);
        }

        /// <summary>
        /// 获取AGV信息
        /// </summary>
        /// <returns></returns>
        public string GetAgvInfo()
        {
            return JsonHelper.Instance.Serialize(_app.GetAgvInfo());
        }

        /// <summary>
        /// 获取启用AGV信息
        /// </summary>
        /// <returns></returns>
        public string GetEnableAgvInfo()
        {
            return JsonHelper.Instance.Serialize(_app.GetEnableAgvInfo());
        }

        /// <summary>
        /// 获取AGV任务路径
        /// </summary>
        /// <param name="AgvNo">Agv编号</param>
        /// <returns></returns>
        [HttpPost]
        public string GetAgvTaskPath(string AgvNo)
        {
            TableData tableData = new TableData();
            try
            {
                TTask task = _unitWorkAcs.FindSingle<TTask>(u => u.StrTaskAgv.Equals(AgvNo));
                if (task != null)
                {
                    tableData = _app.GetTaskPathPoint(task.StrTaskNo);
                }
            }
            catch (Exception ex)
            {
                tableData.code = 500;
                tableData.msg = ex.Message;
            }

            return JsonHelper.Instance.Serialize(tableData);
        }
        #endregion
    }
}