更新任务状态逻辑及文档布局调整

huangxiaoqiang

8 小时以前 510a2ae8b46e792a67080f99d7f66b07189c6682

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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
using HslCommunication;
using Quartz;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEAWCS_Common.TaskEnum;
using WIDESEAWCS_ITaskInfoRepository;
using WIDESEAWCS_ITaskInfoService;
using WIDESEAWCS_QuartzJob;
using WIDESEAWCS_Tasks.ConveyorLineJob;
using WIDESEAWCS_Tasks.ElevatorJob;
 
namespace WIDESEAWCS_Tasks
{
    [DisallowConcurrentExecution]
    public class CommonAGVJob : JobBase, IJob
    {
        private readonly ITaskRepository _taskRepository;
        private readonly ITaskService _taskService;
        public CommonAGVJob(ITaskRepository taskRepository,ITaskService taskService) 
        {
            _taskRepository = taskRepository;
            _taskService = taskService;
        }
 
        public Task Execute(IJobExecutionContext context)
        {
            #region AGV跨楼层任务
            var AcrossFloorTask = _taskRepository.QueryFirst(x => x.TaskState == (int)TaskAcrossFloorStatusEnum.CarryNew);
            if (AcrossFloorTask != null)
            {
                var task = _taskRepository.QueryFirst(x => x.TaskState > (int)TaskAcrossFloorStatusEnum.CarryNew && x.TaskState < (int)TaskAcrossFloorStatusEnum.EndAddressExecuting);
                if(task == null)
                {
                    CommonElevator? elevator = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "TSJ1") as CommonElevator;
                    if (elevator != null)
                    {
                        if (elevator.GetValue<ElevatorDBName, short>(ElevatorDBName.Model) == 1)
                        {
                            if (AcrossFloorTask.Floor == "1F")
                            {
                                elevator.SetValue(ElevatorDBName.FlagBit, Convert.ToInt16(1));
                                elevator.SetValue(ElevatorDBName.StartFloor, Convert.ToInt16(1));
                                elevator.SetValue(ElevatorDBName.EdnFloor, Convert.ToInt16(2));
                                Thread.Sleep(1000);
                                elevator.SetValue(ElevatorDBName.StartCommand, Convert.ToInt16(1));
 
                                _taskService.SendAgvTask("AAA", AcrossFloorTask.TaskNum);
                                AcrossFloorTask.TaskState = (int)TaskAcrossFloorStatusEnum.FirstCarry;
                                _taskRepository.UpdateData(AcrossFloorTask);
                            }
                            else
                            {
                                elevator.SetValue(ElevatorDBName.FlagBit, Convert.ToInt16(1));
                                elevator.SetValue(ElevatorDBName.StartFloor, Convert.ToInt16(2));
                                elevator.SetValue(ElevatorDBName.EdnFloor, Convert.ToInt16(1));
                                Thread.Sleep(1000);
                                elevator.SetValue(ElevatorDBName.StartCommand, Convert.ToInt16(1));
 
                                _taskService.SendAgvTask("DDD", AcrossFloorTask.TaskNum);
                                AcrossFloorTask.TaskState = (int)TaskAcrossFloorStatusEnum.FirstCarry;
                                _taskRepository.UpdateData(AcrossFloorTask);
                            }
                        }
                    }
                }
            }
            #endregion
 
            #region AGV同层搬运任务
            var Carry = _taskRepository.QueryFirst(x => x.TaskState == (int)TaskAGVCarryStatusEnum.CarryNew);
 
            if (Carry != null)
            {
                if (Carry.SourceAddress.Contains("XB001") || Carry.TargetAddress.Contains("XB001"))
                {
                    _taskService.SendAgvTask("cattleCarry1", Carry.TaskNum);
                    Carry.TaskState = (int)TaskAGVCarryStatusEnum.AGV_CarryExecuting;
                    _taskRepository.UpdateData(Carry);
                }
                else if (Carry.Floor == "1F")
                {
                    _taskService.SendAgvTask("forkAutoTemplate1", Carry.TaskNum);
                    Carry.TaskState = (int)TaskAGVCarryStatusEnum.AGV_CarryExecuting;
                    _taskRepository.UpdateData(Carry);
                }
                else
                {
                    _taskService.SendAgvTask("cattleCarry1", Carry.TaskNum);
                    Carry.TaskState = (int)TaskAGVCarryStatusEnum.AGV_CarryExecuting;
                    _taskRepository.UpdateData(Carry);
                }
            }
            #endregion
 
            #region 1楼AGV入库任务
            var InTask = _taskRepository.QueryFirst(x => x.TaskState == (int)TaskInStatusEnum.InNew);
            if (InTask != null)
            {
                var OutTask = _taskRepository.QueryFirst(x => x.TaskState >= (int)TaskOutStatusEnum.OutNew && x.TaskState <(int)TaskOutStatusEnum.AGV_OutExecuting);
                var task = _taskRepository.QueryFirst(x => x.TaskState > (int)TaskInStatusEnum.InNew && x.TaskState < (int)TaskInStatusEnum.SC_InExecuting);
                if (OutTask == null && task == null)
                {
                    CommonConveyorLine? conveyorLine = Storage.Devices.FirstOrDefault(x => x.DeviceCode == "1001") as CommonConveyorLine;
                    if (conveyorLine != null)
                    {
                        bool IsWrite = false;
                        short InteractiveSignal = conveyorLine.GetValue<ConveyorLineDBName, short>(ConveyorLineDBName.InteractiveSignal, "LK001");
                        var structs = BitConverter.GetBytes(InteractiveSignal).Reverse().ToArray().ToBoolArray();
                        if (structs[0])
                        {
                            IsWrite = conveyorLine.Communicator.WriteNoRead("DB100.0", 0);
                            Thread.Sleep(1000);
                            IsWrite = conveyorLine.Communicator.WriteNoRead("DB100.0", 9999);
                            if (!IsWrite)
                            {
                                return Task.CompletedTask;
                            }
 
                            _taskService.SendAgvTask("LIFANG", InTask.TaskNum);
 
                            _taskService.UpdateTaskStatusToNext(InTask.TaskNum);
                        }
                    }
                }
            }
 
            #endregion
 
            return Task.CompletedTask;
        }
    }
}