using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Diagnostics;
|
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;
|
using WIDESEA_Services.IRepositories;
|
using WIDESEA_Services.Repositories;
|
using WIDESEA_Services.Services;
|
using WIDESEA_WCS.WCSClient;
|
|
namespace WIDESEA_WCS.Jobs
|
{
|
/// <summary>
|
/// 辊压机上料流程逻辑
|
/// </summary>
|
public partial class EquipmentExecutor : SchedulerExecuteBase
|
{
|
private static int _readFGYUPSignalso = 0;
|
|
public static void F_GYSB_UpTask()
|
{
|
if (Interlocked.Exchange(ref _readFGYUPSignalso, 1) == 0)
|
{
|
try
|
{
|
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);
|
Ibill_pda_groupdiskRepository pdaRepository = new bill_pda_groupdiskRepository(Context);
|
Idt_agvtaskRepository agvRepository = new dt_agvtaskRepository(Context);
|
Ibill_group_stockRepository groupRepository = new bill_group_stockRepository(Context);
|
Idt_agvtask_htyRepository agvtask_HtyRepository = new dt_agvtask_htyRepository(Context);
|
// List<string> GYSBS = new List<string> { "负极3号辊压机" };
|
List<string> GYSBS = new List<string> { "负极1号辊压机", "负极2号辊压机", "负极3号辊压机" };
|
PLCClient zagvplc = WCSService.Clients.Find(v => v.PLCName == "负极1号AGV");
|
foreach (var GYSB in GYSBS)
|
{
|
WriteLog.Info($"{GYSB}上料").Write($"{GYSB}开始,时间：" + DateTime.Now + " ----------", $"{GYSB}上料");
|
PLCClient plc = WCSService.Clients.Find(v => v.PLCName == GYSB);
|
if (plc == null) { continue; }
|
var SBtask = agvRepository.FindFirst(f => f.agv_toaddress == plc.PLCDescroption);
|
if (SBtask != null) { continue; }
|
WriteLog.Info($"{GYSB}上料").Write($"SBtask：{SBtask},时间：" + DateTime.Now + " ----------", $"{GYSB}上料");
|
//启用工单
|
string IsBatchNo = plc.ReadValue(ConveyorLineInfoDBName.R_GYSB_IsWorkBatchNo.ToString(), plc.PLCDescroption).ToString();
|
if (IsBatchNo == "False") { GetEquipmentInfo(plc.PLCDescroption, "", "启用工单为：" + IsBatchNo, "", ""); continue; }
|
WriteLog.Info($"{GYSB}上料").Write($"IsBatchNo：{IsBatchNo},时间：" + DateTime.Now + " ----------", $"{GYSB}上料");
|
//读取历史任务5分钟之后在读取设备上料请求
|
var taskthy = agvtask_HtyRepository.Find(f => f.agv_toaddress == plc.PLCDescroption && f.agv_operatetype != "ManualDeletion").OrderByDescending(o => o.agv_finishedtime).First();
|
string isSBWork = "False";
|
if ((DateTime.Now - Convert.ToDateTime(taskthy.agv_finishedtime)).Minutes > 5)
|
{
|
isSBWork = plc.ReadValue(ConveyorLineInfoDBName.R_GYSB_UPrequest.ToString(), plc.PLCDescroption).ToString();
|
}
|
WriteLog.Info($"{GYSB}上料").Write($"isSBWork：{isSBWork},时间：" + DateTime.Now + " ----------", $"{GYSB}上料");
|
//读取设备的工单号
|
string batchNo = plc.ReadValue(ConveyorLineInfoDBName.R_GYSB_UPbatchNo.ToString(), plc.PLCDescroption).ToString();
|
if (batchNo == null) { GetEquipmentInfo(plc.PLCDescroption, "", batchNo, "", ""); continue; }
|
WriteLog.Info($"{GYSB}上料").Write($"batchNo：{batchNo},时间：" + DateTime.Now + " ----------", $"{GYSB}上料");
|
//工序名
|
string processName = plc.ReadValue(ConveyorLineInfoDBName.R_GYSB_GXBatchNo.ToString(), plc.PLCDescroption).ToString();
|
var route = routingRepository.FindFirst(f => f.route_end == plc.PLCDescroption);
|
var fromaddress = locRepository.FindFirst(f => f.upper_code == route.route_began || f.down_code == route.route_began);
|
var iswork = zagvplc.ReadValue(ConveyorLineInfoDBName.R_Location_iswork.ToString(), route.route_began).ToString();
|
WriteLog.Info($"{GYSB}上料").Write($"iswork：{iswork},IsBatchNo：{IsBatchNo},isSBWork：{isSBWork},batchNo：{batchNo},processName：{processName},iswork：{iswork},时间：" + DateTime.Now + " ----------", $"{GYSB}上料");
|
GetEquipmentInfo(plc.PLCDescroption, isSBWork, batchNo, processName, iswork);
|
lock (requestFJJK)
|
{
|
if (iswork == "1" && fromaddress.location_state == LocationStateEnum.LocationState_Empty.ToString())
|
{
|
WriteLog.Info("F_GYSB_UpTask").Write("F_GYSB_UpTask" + GYSB + "1", "F_GYSB_UpTask");
|
var jjktask = agvRepository.FindFirst(f => (f.agv_toaddress.Contains("JJK") && f.agv_fromaddress.Contains("FJ")) || (f.agv_fromaddress == "nou" && f.agv_toaddress.Contains("HCJ") && f.agv_toaddress.Contains("FJ")));
|
if (jjktask == null)
|
{
|
WriteLog.Info("F_GYSB_UpTask").Write("F_GYSB_UpTask" + GYSB + "2", "F_GYSB_UpTask");
|
var jjkloc = locRepository.FindFirst(f => f.down_code == "FJXL-JJK001" || f.upper_code == "FJSL-JJK001");
|
var jjkiswork = zagvplc.ReadValue(ConveyorLineInfoDBName.R_Location_iswork.ToString(), "FJXL-JJK001").ToString();
|
if (jjkloc.location_state == LocationStateEnum.LocationState_Empty.ToString() && jjkiswork == "1")
|
{
|
WriteLog.Info("F_GYSB_UpTask").Write("F_GYSB_UpTask" + GYSB + "3", "F_GYSB_UpTask");
|
//调用大及卷库出库需求接口
|
dt_agvtask agvtask = new dt_agvtask
|
{
|
agv_materbarcode = "daiding",
|
agv_barcode = "",
|
agv_code = "负极1号AGV",
|
agv_createtime = DateTime.Now,
|
agv_fromaddress = "nou",
|
agv_grade = 1,
|
agv_materielid = batchNo,
|
agv_qty = 1,
|
agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
|
agv_taskstate = "WaitStockOut",
|
agv_tasktype = "TaskType_Outbound",
|
// agv_toaddress = route.route_began,
|
agv_userid = "WCS",
|
agv_worktype = 1
|
};
|
if (bool.Parse(isSBWork) && SBtask == null)
|
{
|
agvtask.agv_toaddress = plc.PLCDescroption;
|
}
|
else
|
{
|
agvtask.agv_toaddress = route.route_began;
|
}
|
//向MES申请要料
|
MESback WMSbackresult = MESAPIInvoke.OutNeedStosk(agvtask.agv_tasknum, null, 2, batchNo, processName, plc.PLCDescroption);
|
WriteLog.Info($"{GYSB}上料").Write($"MES返回数据：{JsonConvert.SerializeObject(WMSbackresult)},时间：" + DateTime.Now + "", $"{GYSB}上料");
|
if (WMSbackresult == null)
|
{ //plc.WriteValue(ConveyorLineInfoDBName.isitem.ToString(), plc.PLCDescroption, true).ToString();
|
continue;
|
}
|
responseContent = locRepository.DbContextBeginTransaction(() =>
|
{
|
// plc.WriteValue(ConveyorLineInfoDBName.isitem.ToString(), plc.PLCDescroption, false).ToString();
|
jjkloc.location_state = LocationStateEnum.LocationState_Lock.ToString();
|
locRepository.Update(jjkloc, true);
|
if (agvtask.agv_toaddress.Contains("HCJ"))
|
{
|
fromaddress.location_state = LocationStateEnum.LocationState_Lock.ToString();
|
locRepository.Update(fromaddress, true);
|
}
|
agvRepository.Add(agvtask, true);
|
WriteLog.Info("F_GYSB_UpTask").Write("F_GYSB_UpTask" + GYSB + agvtask.agv_tasknum + DateTime.Now, "F_GYSB_UpTask");
|
return WebResponseContent.Instance.OK();
|
});
|
break;
|
}
|
}
|
}
|
}
|
if (bool.Parse(isSBWork) && SBtask == null)
|
{
|
var locstock = groupRepository.Find(f => f.location_id == fromaddress.id).OrderByDescending(o => o.created_time).First();
|
if (fromaddress.location_state == LocationStateEnum.LocationState_Stored.ToString() && locstock.MaterialType == batchNo)
|
{
|
dt_agvtask agvtask = new dt_agvtask
|
{
|
agv_materbarcode = locstock.BarCode,
|
agv_barcode = "",
|
agv_code = "负极1号AGV",
|
agv_createtime = DateTime.Now,
|
agv_fromaddress = route.route_began,
|
agv_grade = 1,
|
agv_materielid = batchNo,
|
agv_qty = 1,
|
agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
|
agv_taskstate = "Create",
|
agv_tasktype = "TaskType_Outbound",
|
agv_toaddress = plc.PLCDescroption,
|
agv_userid = "WCS",
|
agv_worktype = 1
|
};
|
//修改起点货位状态
|
agvRepository.Add(agvtask, true);
|
WriteLog.Info("F_GYSB_UpTask").Write("F_GYSB_UpTask接口调用开始" + agvtask.agv_tasknum + DateTime.Now, "F_GYSB_UpTask");
|
fromaddress.location_state = LocationStateEnum.LocationState_Lock.ToString();
|
locRepository.Update(fromaddress, true);
|
continue;
|
}
|
else
|
{
|
//zagvplc.WriteValue(ConveyorLineInfoDBName.MaterNG.ToString(), route.route_began, 1);
|
}
|
}
|
else
|
{
|
WriteLog.Info($"{GYSB}下料").Write($"{GYSB}结束, continue 时间：" + DateTime.Now + $" ----------{Environment.NewLine}", $"{GYSB}下料");
|
continue;
|
}
|
WriteLog.Info($"{GYSB}下料").Write($"{GYSB}结束,时间：" + DateTime.Now + $" ----------{Environment.NewLine}", $"{GYSB}下料");
|
}
|
}
|
catch (Exception ex)
|
{
|
WriteLog.Info("F_GYSB_UpTask").Write("F_GYSB_UpTask" + ex.Message + DateTime.Now, "F_GYSB_UpTask");
|
StackTrace stackTrace = new StackTrace();
|
StackFrame[] stackFrames = stackTrace.GetFrames();
|
string str = "";
|
foreach (var item in stackFrames)
|
{
|
str += "方法名:" + item.GetMethod().Name + ",行号:" + item.GetFileLineNumber() + ",文件名:" + item.GetFileName() + Environment.NewLine;
|
}
|
WIDESEA_Common.Tools.WriteLog.GetLog("负极辊压设备上料").Write($"错误信息：{ex.Message},{str}", "负极辊压设备上料");
|
}
|
finally
|
{
|
Interlocked.Exchange(ref _readFGYUPSignalso, 0);
|
}
|
}
|
}
|
}
|
}
|
