AcsTaskController.cs 8.29 KB
using Infrastructure;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using System;
using System.Collections.Generic;
using WebApp;
using WebRepository;

namespace WebMvc
{
    /// <summary>
	/// 任务表
	/// </summary>
    [Area("agv")]
    public class AcsTaskController : BaseController
    {
        private readonly AcsTaskApp _app;
        private readonly AcsTaskHisApp _appHis;

        public AcsTaskController(IAuth authUtil, AcsTaskApp app, AcsTaskHisApp appHis) : base(authUtil)
        {
            _app = app.SetLoginInfo(_loginInfo);
            _appHis = appHis.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 TaskFinish()
        {
            return View();
        }
        #endregion

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

        #region 提交数据
        /// <summary>
        /// 新增数据
        /// </summary>
        /// <param name="Table_entity">新增实例</param>
        /// <returns></returns>
        [HttpPost]
        [ServiceFilter(typeof(OperLogFilter))]
        public string Ins(AcsTask Table_entity)
        {
            try
            {
                _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(AcsTask Table_entity)
        {
            try
            {
                _app.Upd(Table_entity);
            }
            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
            {
                _app.DelByIds(ids);
            }
            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(AcsTask entity)
        {
            return JsonHelper.Instance.Serialize(_app.ExportData(entity));
        }
        #endregion

        #region 导出模板
        /// <summary>
        /// 导出模板
        /// </summary>
        /// <returns></returns>
        [HttpPost]
        public string GetTemplate()
        {
            var result = new TableData();
            List<AcsTask> listAcsTask = new List<AcsTask>();
            AcsTask entity = _app.FindSingle(u => u.Id > 0);
            if (entity != null)
            {
                listAcsTask.Add(entity);
            }
            else
            {
                listAcsTask.Add(new AcsTask());
            }
 
            result.data = listAcsTask;
            result.count = listAcsTask.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>
        /// <param name="ids">任务Id</param>
        /// <returns></returns>
        [HttpPost]
        [ServiceFilter(typeof(OperLogFilter))]
        public string Cancel(int[] ids)
        {
            try
            {
                foreach (int item in ids)
                {
                    AcsTask task = _app.FindSingle(u => u.Id.Equals(item) && u.Status.Equals(0));
                    if (task != null)
                    {
                        if (!string.IsNullOrEmpty(task.StartStation) && !string.IsNullOrEmpty(task.EndStation))
                        {
                            ApiRequest apiRequest = new ApiRequest("RCS");
                            string parameter = JsonHelper.Instance.Serialize(new TaskChangeModel
                            {
                                taskNo = task.TaskNo,
                                taskState = "Cancel",
                            });
                            Response response = apiRequest.Post<Response>(parameter, "TaskChange", "RCS");
                            if (response.Code != 0)
                            {
                                throw new Exception(response.Message);
                            }
                        }

                        task.Status = 98;
                        _app.Upd(task);
                        AcsTaskHis acsTaskHis = task.CopyTo<AcsTaskHis>();
                        acsTaskHis.Id = null;
                        _appHis.Ins(acsTaskHis);
                        _app.DelByIds(new int[] { task.Id.Value });
                    }
                }
            }
            catch (Exception ex)
            {
                Result.Status = false;
                Result.Message = ex.Message;
            }
            return JsonHelper.Instance.Serialize(Result);
        }

        /// <summary>
        /// 人工确认完成
        /// </summary>
        /// <param name="cuStNo">当前站台</param>
        /// <returns></returns>
        [HttpPost]
        [ServiceFilter(typeof(OperLogFilter))]
        public string TaskFinish(string cuStNo)
        {
            try
            {
                ApiRequest apiRequest = new ApiRequest("RCS");
                string parameter = JsonHelper.Instance.Serialize(new TaskFinishModel
                {
                    stName = cuStNo,
                    stState = 99,
                });
                Response response = apiRequest.Post<Response>(parameter, "TaskFinish", "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]
        //public string Init()
        //{
        //    return JsonHelper.Instance.Serialize(_app.Init());
        //}

        //[HttpPost]
        //public string Init1()
        //{
        //    return JsonHelper.Instance.Serialize(_app.Init1());
        //}
        #endregion
    }
}