kazelee
1 天以前 6ed44f32c96a17fd10601a24c3c36ca1229bc89b
core/WCSCore.cs
@@ -14,8 +14,9 @@
namespace HH.WCS.Mobox3.AnGang.core
{
    internal class WCSCore
    {
    internal class WCSCore {
        public static string AgvState = string.Empty;
        public static ReturnResult OperateAgvTaskStatus(AgvTaskState model) {
            var result = new ReturnResult();
            try {
@@ -103,6 +104,7 @@
                    break;
                case 2: // 完成
                    WCSHelper.End(TN_Task); // 任务状态改成结束
                    break;
                case 7: // 异常
                    TaskProcess.OperateStatus(TN_Task, 7); // 异常处理
@@ -126,9 +128,8 @@
                    return;
                }
                if (db.Updateable<TN_Loc_Container>()
                    .SetColumns(d => d.S_IMG_URL == filepath)
                    .Where(d => d.S_CNTR_CODE == model.S_CNTR_CODE).ExecuteCommand() <= 0) {
                if (db.Updateable<TN_Loc_Container>().SetColumns(d => d.S_IMG_URL == filepath).Where(d => d.S_CNTR_CODE == model.S_CNTR_CODE).ExecuteCommand() <= 0 &&
                    db.Updateable<TN_CG_Detail>().SetColumns(d => d.S_EXT_ATTR5 == filepath).Where(d => d.S_CNTR_CODE == model.S_CNTR_CODE).ExecuteCommand() <= 0) { // FIX: SNAP
                    LogHelper.Info($"图片URL '{filepath}' 写入数据库失败");
                    return;
@@ -367,22 +368,18 @@
        /// <summary>
        /// 任务分发,根据调度类型发给不同的调度系统
        /// </summary>
        internal static void Dispatch()
        {
        internal static void Dispatch() {
            //查询任务
            //获取所有等待的任务
            var list = WCSHelper.GetWaitingTaskList();
            LogHelper.Info("等待任务信息" + JsonConvert.SerializeObject(list), "API");
            if (list.Count > 0)
            {
                list.ForEach(task =>
                {
            if (list.Count > 0) {
                list.ForEach(task => {
                    //使用自定义任务推送
                    TaskProcess.SendTask(task);//调度NDC或杭奥或国自设备
                });
            }
            else
            {
            else {
                LogHelper.Info("暂无任务");
            }
        }
@@ -396,5 +393,23 @@
            // 目前该项目没有站台安全交互的功能
            return gzResult;
        }
        public static string agvRealtimeStateReport(agvRealtimeStateReportInfo model) {
            var res = string.Empty;
            switch (model.agvStatusID) {
                case 1: res = "in_system"; break;
                case 2: res = "out_system"; break;
                case 3: res = "online"; break;
                case 4: res = "offline"; break;
                case 5: res = "ready"; break;
                case 6: res = "not_ready"; break;
                case 7: res = "in_dispatch"; break;
                case 8: res = "out_dispatch"; break;
                case 9: res = "running"; break;
                case 10: res = "not_running"; break;
            }
            AgvState = res;
            return res;
        }
    }
}