Admin
5 天以前 bd6818fc9d40f343547bafca0743658f3c0379dc
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
using HslCommunication;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using WIDESEA_Common;
using WIDESEA_Common.Tools;
using WIDESEA_Core.Utilities;
using WIDESEA_Entity.DomainModels;
using WIDESEA_Services;
using WIDESEA_Services.IRepositories;
using WIDESEA_Services.Repositories;
using WIDESEA_Services.Services;
using WIDESEA_WCS.WCSClient;
 
namespace WIDESEA_WCS.Jobs.ConveyorLine.OutboundArea
{
    public partial class OutboundAreaDispatch
    {
        public static string[] endStationNo = new string[] { "70101", "70103", "70104", "70106", "70109", "70110", "70113", "70114" };
        /// <summary>
        /// 出库任务完成
        /// </summary>
        /// <param name="taskWCSinfoRepository"></param>
        /// <param name="client"></param>
        public static void OutboundCompleteAction(IDt_TaskWCSinfoRepository taskWCSinfoRepository, PLCClient client)
        {
            foreach (var item in endStationNo)
            {
                try
                {
                    string barcode = client.ReadValue(CLineInfoDBName.R_Line_Barcode.ToString(), item).ToString();
                    //查找任务表中的 轴承出库任务
                    Dt_TaskWCSinfo emptyOutWcsInfo = taskWCSinfoRepository.FindFirst(x => ((x.wcstask_type == TaskType.TaskType_Box_Pallet_Outbound.ToString() &&
                    x.wcstask_state == TaskState.TaskState_Box_Out_Line_Executing.ToString()) ||
                    (x.wcstask_type == TaskType.TaskType_Empty_Pallet_Outbound.ToString() && x.wcstask_state == TaskState.TaskState_Empty_Out_Line_Executing.ToString()))
                        && x.wcstask_barcode == barcode);
                    if (null != emptyOutWcsInfo)
                    {
                        //在此完成该空托出库任务
                        WebResponseContent content = taskWCSinfoRepository.DbContextBeginTransaction(() =>
                        {
                            //上报WMS任务完成
                            content = WMSApi.TellWmsTaskFinished(emptyOutWcsInfo.wcstask_barcode);
                            if (content.Status)
                            {
                                //移动任务到历史表
                                Dt_TaskWCSinfo_HtyRepository taskWCSinfo_HtyRepository = new Dt_TaskWCSinfo_HtyRepository(taskWCSinfoRepository.DbContext);
                                emptyOutWcsInfo.wcstask_state = TaskState.TaskState_Finished.ToString();
                                CommonFunction.AddWcsTaskToHistory(emptyOutWcsInfo, taskWCSinfoRepository, taskWCSinfo_HtyRepository);
                            }
                            else
                                throw new Exception($"{ DateTime.Now }上报WMS任务完成出错,原因:【{content.Message}】");
 
                            return content;
                        });
                        string str = string.Empty;
                        if (content.Status)
                            str = $" { DateTime.Now }上报WMS出库完成成功【TaskState_ConveyorLineExecuting】,托盘号:{emptyOutWcsInfo.wcstask_barcode},任务号:{ emptyOutWcsInfo.wcstask_taskNumber}";
                        else
                            str = $" { DateTime.Now }上报WMS出库完成失败【TaskState_ConveyorLineExecuting】,托盘号:{emptyOutWcsInfo.wcstask_barcode},任务号:{ emptyOutWcsInfo.wcstask_taskNumber}";
 
                        WriteLog.Info(item).Write(str, item);
                    }
                }
                catch (Exception ex)
                {
 
                    WriteLog.Info(item).Write($"{ DateTime.Now }上报WMS出库完成任务失败:{ex.Message}", item);
                }
            }
 
        }
    }
}