using Microsoft.CodeAnalysis;
|
using Microsoft.EntityFrameworkCore;
|
using OfficeOpenXml.FormulaParsing.Excel.Functions.Logical;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Threading;
|
using WIDESEA_Common;
|
using WIDESEA_Common.Tools;
|
using WIDESEA_Core.EFDbContext;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_Services.IRepositories;
|
using WIDESEA_Services.Repositories;
|
using WIDESEA_Services.Services;
|
using WIDESEA_WCS.JobsPart.Public;
|
using WIDESEA_WCS.WCSClient;
|
|
namespace WIDESEA_WCS
|
{
|
public partial class StackerExecutor
|
{
|
public static object requestQJ = new object();//requestZJJK
|
private static int _readQJSignalso = 0;//_readZTBUPSignalso
|
/// <summary>
|
/// 切卷自动回空
|
/// </summary>
|
/// <param name="client"></param>
|
public static void QJ_ZDHK(PLCClient client)
|
{
|
if (Interlocked.Exchange(ref _readQJSignalso, 1) == 0)
|
{
|
try
|
{
|
string[] zfqjhcj = { "ZJ-QJHCJ", "FJ-QJHCJ" };
|
foreach (var item in zfqjhcj)
|
{
|
ZFQJHLclass(item);
|
}
|
|
}
|
catch (Exception)
|
{
|
|
throw;
|
}
|
finally
|
{
|
Interlocked.Exchange(ref _readQJSignalso, 0);
|
}
|
}
|
}
|
|
public static void ZFQJHLclass(string hcjtype) {
|
VOLContext Context = new VOLContext();
|
WebResponseContent responseContent = new WebResponseContent();
|
Idt_task_numberRepository tasknumberRep = new dt_task_numberRepository(Context);
|
|
dt_task_numberService tasknumber = new dt_task_numberService(tasknumberRep);
|
Ibase_ware_locationRepository locRepository = new base_ware_locationRepository(Context);
|
|
Ibase_routing_tableRepository routingRepository = new base_routing_tableRepository(Context);
|
Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);
|
|
Idt_agvtask_htyRepository agvhtyRepository = new dt_agvtask_htyRepository(Context);
|
List<base_ware_location> base_Ware_Location = locRepository.Find(d => d.upper_code.Contains(hcjtype) && d.location_state == "LocationState_Stored" && d.gd1 == 0 && d.gd2 == 0 && d.gd3 == 0 && d.gd4 == 0 && d.tpgd == 1 && d.status == 1 && d.task == 2).ToList();
|
if (base_Ware_Location.Count > 0)
|
{
|
foreach (var item in base_Ware_Location)
|
{
|
List<base_routing_table> routing_table = routingRepository.Find(v => v.route_began == item.upper_code && v.route_end.Contains("GFHCJ")).ToList();
|
foreach (var item1 in routing_table)
|
{
|
//切卷空托盘回流到辊分下料缓存架
|
base_ware_location ware_Location = locRepository.FindFirst(d => d.upper_code == item1.route_end && d.location_state == "LocationState_Empty" && d.tpgd == 0 && d.gd1 == 0 && d.gd2 == 0 && d.gd3 == 0 && d.gd4 == 0 && d.status == 1 && d.task == 2);
|
if (ware_Location != null)
|
{
|
|
|
dt_agvtask dt_Agvtask = agvRepository.FindFirst(d => d.agv_toaddress == ware_Location.upper_code);
|
if (dt_Agvtask != null)
|
{
|
continue;
|
}
|
//延时10秒实时检测
|
int index = 0;
|
int b = 10;
|
DateTime time = DateTime.Now;
|
Double STAMP = 0;
|
do
|
{
|
DateTime time2 = DateTime.Now;
|
STAMP = (time2 - time).TotalSeconds;
|
base_ware_location DSLocation = locRepository.FindFirst(d => d.upper_code == item.upper_code
|
&& d.location_state == LocationStateEnum.LocationState_Stored.ToString() && d.tpgd == 1 && d.task == 2 && d.gd1 == 0 && d.gd2 == 0 && d.gd3 == 0 && d.gd4 == 0 && d.status == 1);
|
if (DSLocation == null)
|
{
|
index = 3;
|
break;
|
}
|
|
} while (STAMP < b);
|
if (index == 3)
|
{
|
break;
|
}
|
|
|
//dt_agvtask_hty agvtask_Hty = agvhtyRepository.Find(d => d.agv_toaddress == ware_Location1.upper_code).OrderByDescending(d => d.agv_finishedtime).FirstOrDefault();
|
|
//bool interval = (DateTime.Now - agvtask_Hty.agv_finishedtime).Value.TotalSeconds < 120;
|
//if (interval)
|
//{
|
// continue;
|
//}
|
base_ware_location ware_Location1 = locRepository.FindFirst(d => d.upper_code == item.upper_code && d.location_state == LocationStateEnum.LocationState_Stored.ToString() && d.gd1 == 0 && d.gd2 == 0 && d.gd3 == 0 && d.gd4 == 0 && d.tpgd == 1 && d.status == 1 && d.task == 2);
|
if (ware_Location1 == null)
|
{
|
continue;
|
}
|
|
dt_agvtask agvtask = new dt_agvtask();
|
agvtask.agv_id = Guid.NewGuid();
|
agvtask.agv_tasknum = "KH-" + IdenxManager.GetTaskNo();
|
agvtask.agv_fromaddress = ware_Location1.upper_code;
|
agvtask.agv_toaddress = ware_Location.upper_code;
|
agvtask.agv_code = "组装AGV调度";
|
agvtask.agv_remark = "切卷上料回空";
|
agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
|
agvtask.agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString();
|
agvtask.agv_worktype = 1;//工作类型
|
agvtask.agv_materielid = "";
|
agvtask.agv_qty = 1;
|
agvtask.agv_createtime = DateTime.Now;
|
agvtask.agv_grade = 0;//任务优先级
|
agvtask.agv_userid = "WCS";
|
|
ware_Location1.task = 1;
|
var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
|
if (entry != null)
|
{
|
entry.State = EntityState.Detached;
|
}
|
int begin = locRepository.Update(ware_Location1, d => new { d.task }, true);
|
ware_Location.task = 1;
|
var entry2 = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
|
if (entry2 != null)
|
{
|
entry2.State = EntityState.Detached;
|
}
|
int end = locRepository.Update(ware_Location, d => new { d.task }, true);
|
if (begin == 1 && end == 1)
|
{
|
WCSCommon.freeDB.Add(agvtask);
|
}
|
break;
|
}
|
}
|
|
//判断还有多余未进行回流的切卷空托盘进行回流到极库
|
base_ware_location Location = locRepository.FindFirst(d => d.upper_code == item.upper_code && d.location_state == LocationStateEnum.LocationState_Stored.ToString() && d.gd1 == 0 && d.gd2 == 0 && d.gd3 == 0 && d.gd4 == 0 && d.tpgd == 1
|
&& d.status == 1 && d.task == 2);
|
if (Location == null)
|
{
|
return;
|
}
|
//切卷空托盘回流到极库
|
List<base_routing_table> routing_table1 = routingRepository.Find(v => v.route_end == item.upper_code).ToList();
|
foreach (var item1 in routing_table1)
|
{
|
base_ware_location ware_Location = locRepository.FindFirst(d => d.upper_code == item1.route_began && d.location_state == "LocationState_Empty" && d.tpgd == 0 && d.status == 1 && d.task == 2);
|
if (ware_Location != null)
|
{
|
dt_agvtask dt_Agvtask = agvRepository.FindFirst(d => d.agv_toaddress == ware_Location.upper_code);
|
if (dt_Agvtask != null)
|
{
|
continue;
|
}
|
int index = 0;
|
int b = 10;
|
DateTime time = DateTime.Now;
|
Double STAMP = 0;
|
do
|
{
|
DateTime time2 = DateTime.Now;
|
STAMP = (time2 - time).TotalSeconds;
|
base_ware_location DSLocation = locRepository.FindFirst(d => d.upper_code == item.upper_code
|
&& d.location_state == LocationStateEnum.LocationState_Stored.ToString() && d.gd1 == 0 && d.gd2 == 0 && d.gd3 == 0 && d.gd4 == 0 && d.tpgd == 1
|
&& d.status == 1 && d.task == 2);
|
if (DSLocation == null)
|
{
|
index = 3;
|
break;
|
}
|
|
} while (STAMP < b);
|
if (index == 3)
|
{
|
break;
|
}
|
|
//切卷空托回流到极库空位架
|
base_ware_location dwLocation = locRepository.FindFirst(d => d.upper_code == item1.route_began && d.location_state == "LocationState_Empty" && d.tpgd == 0 && d.status == 1 && d.task == 2);
|
dt_agvtask_hty agvtask_Hty = agvhtyRepository.Find(d => d.agv_toaddress == dwLocation.upper_code).OrderByDescending(d => d.agv_finishedtime).FirstOrDefault();
|
if (agvtask_Hty != null)
|
{
|
bool interval = (DateTime.Now - agvtask_Hty.agv_finishedtime).Value.TotalSeconds < 60;
|
if (interval)
|
{
|
continue;
|
}
|
}
|
|
if (dwLocation == null)
|
{
|
continue;
|
}
|
|
dt_agvtask agvtask = new dt_agvtask();
|
agvtask.agv_id = Guid.NewGuid();
|
agvtask.agv_tasknum = "KH-" + IdenxManager.GetTaskNo();
|
agvtask.agv_fromaddress = Location.upper_code;
|
agvtask.agv_toaddress = dwLocation.upper_code;
|
agvtask.agv_code = "组装AGV调度";
|
agvtask.agv_remark = "切卷上料回空";
|
agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
|
agvtask.agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString();
|
agvtask.agv_worktype = 1;//工作类型
|
agvtask.agv_materielid = "";
|
agvtask.agv_qty = 1;
|
agvtask.agv_createtime = DateTime.Now;
|
agvtask.agv_grade = 0;//任务优先级
|
agvtask.agv_userid = "WCS";
|
|
|
Location.task = 1;
|
var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
|
if (entry != null)
|
{
|
entry.State = EntityState.Detached;
|
}
|
int begin = locRepository.Update(Location, d => new { d.task }, true);
|
|
dwLocation.task = 1;
|
var entry2 = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
|
if (entry2 != null)
|
{
|
entry2.State = EntityState.Detached;
|
}
|
int end = locRepository.Update(dwLocation, d => new { d.task }, true);
|
if (begin == 1 && end == 1)
|
{
|
WCSCommon.freeDB.Add(agvtask);
|
}
|
break;
|
|
|
|
}
|
|
}
|
}
|
}
|
else //从极卷库回空托到辊分下料空位缓存架
|
{
|
|
List<base_ware_location> base_Ware_GFLocation = locRepository.Find(d => d.upper_code.Contains("GFHCJ")
|
&& d.location_state == "LocationState_Empty" && d.gd1 == 0 && d.gd2 == 0 && d.gd3 == 0 && d.gd4 == 0 && d.tpgd == 0 && d.status == 1 && d.task == 2).ToList();
|
|
if (base_Ware_GFLocation.Count > 0)
|
{
|
foreach (var item in base_Ware_GFLocation)
|
{
|
|
List<base_routing_table> routing_table1 = routingRepository.Find(v => v.route_began == item.upper_code).ToList();
|
foreach (var item1 in routing_table1)
|
{
|
base_ware_location ware_Location = locRepository.FindFirst(d => d.upper_code == item1.route_end && d.location_state == "LocationState_Stored" && d.tpgd == 1 && d.geartype == "暂无" && d.status == 1 && d.task == 2);
|
if (ware_Location != null)
|
{
|
int index = 0;
|
int b = 10;
|
DateTime time = DateTime.Now;
|
Double STAMP = 0;
|
do
|
{
|
DateTime time2 = DateTime.Now;
|
STAMP = (time2 - time).TotalSeconds;
|
base_ware_location DSLocation = locRepository.FindFirst(d => d.upper_code == item.upper_code
|
&& d.location_state == "LocationState_Empty" && d.gd1 == 0 && d.gd2 == 0 && d.gd3 == 0 && d.gd4 == 0 && d.tpgd == 0 && d.status == 1 && d.task == 2);
|
if (DSLocation == null)
|
{
|
|
index = 3;
|
break;
|
}
|
|
} while (STAMP < b);
|
|
if (index == 3)
|
{
|
|
break;
|
}
|
base_ware_location dwLocation = locRepository.FindFirst(d => d.upper_code == item1.route_end && d.location_state == "LocationState_Stored" && d.tpgd == 1 && d.geartype == "暂无" && d.status == 1 && d.task == 2);
|
if (dwLocation == null)
|
{
|
continue;
|
}
|
dt_agvtask dt_Agvtask = agvRepository.FindFirst(d => d.agv_toaddress == item.upper_code);
|
if (dt_Agvtask != null)
|
{
|
continue;
|
}
|
//dt_agvtask_hty agvtask_Hty = agvhtyRepository.Find(d => d.agv_fromaddress == dwLocation.upper_code).OrderByDescending(d => d.agv_finishedtime).FirstOrDefault();
|
|
//bool interval = (DateTime.Now - agvtask_Hty.agv_finishedtime).Value.TotalSeconds < 120;
|
//if (interval)
|
//{
|
// continue;
|
//}
|
|
|
dt_agvtask agvtask = new dt_agvtask();
|
agvtask.agv_id = Guid.NewGuid();
|
agvtask.agv_tasknum = "KH-" + IdenxManager.GetTaskNo();
|
agvtask.agv_fromaddress = dwLocation.upper_code;
|
agvtask.agv_toaddress = item.upper_code;
|
agvtask.agv_code = "组装AGV调度";
|
agvtask.agv_remark = "极库空托回空";
|
agvtask.agv_taskstate = AGVTaskStateEnum.Create.ToString();
|
agvtask.agv_tasktype = AGVTaskTypeEnum.TaskType_Outbound.ToString();
|
agvtask.agv_worktype = 1;//工作类型
|
agvtask.agv_materielid = "";
|
agvtask.agv_qty = 1;
|
agvtask.agv_createtime = DateTime.Now;
|
agvtask.agv_grade = 0;//任务优先级
|
agvtask.agv_userid = "WCS";
|
item.task = 1;
|
|
var entry = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
|
if (entry != null)
|
{
|
entry.State = EntityState.Detached;
|
}
|
int begin = locRepository.Update(item, d => new { d.task }, true);
|
|
dwLocation.task = 1;
|
var entry2 = locRepository.DbContext.ChangeTracker.Entries<base_ware_location>().FirstOrDefault();
|
if (entry2 != null)
|
{
|
entry2.State = EntityState.Detached;
|
}
|
int end = locRepository.Update(dwLocation, d => new { d.task }, true);
|
if (begin == 1 && end == 1)
|
{
|
WCSCommon.freeDB.Add(agvtask);
|
}
|
break;
|
|
|
|
}
|
|
}
|
|
}
|
}
|
|
}
|
}
|
|
}
|
}
|
