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.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
{
public partial class EquipmentExecutor : SchedulerExecuteBase
{
private static int _readZFINOUTSignalso = 0;
public static object requestJJK = new object();
///
/// 正极和负极大及卷库出入库逻辑
///
///
public static void ZF_InOut_Djjk()
{
if (Interlocked.Exchange(ref _readZFINOUTSignalso, 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);
List HCJnos = new List {"ZJSL-FQHCJ001","ZJSL-TBHCJ007","ZJSL-TBHCJ008","ZJSL-TBHCJ009","ZJSL-TBHCJ010","ZJSL-TBHCJ011","ZJSL-TBHCJ012",
"ZJSL-TBHCJ001","ZJSL-TBHCJ002","ZJSL-TBHCJ003","ZJSL-TBHCJ004","ZJSL-TBHCJ005","ZJSL-TBHCJ006",
"ZJSL-QXHCJ001","ZJSL-QXHCJ002", "ZJSL-GYHCJ001", "ZJSL-GYHCJ002", "ZJSL-GYHCJ003","ZJSL-FQHCJ002"};
PLCClient plc = null;
string toadd = "";
var task = agvRepository.FindFirst(f=>(f.agv_toaddress.Contains("JJK")&&f.agv_fromaddress.Contains("ZJ"))||(f.agv_fromaddress=="nou"&&f.agv_toaddress.Contains("HCJ")&& f.agv_toaddress.Contains("ZJ")));
if (task!=null)
{
WriteLog.Info("ZF_InOut_Djjk").Write("正极大极卷库有正在执行的任务" + DateTime.Now, "ZF_InOut_Djjk");
return;
}
foreach (var hcj in HCJnos)
{
toadd = "ZJXL-JJK001";
plc = WCSService.Clients.Find(v => v.PLCName == "正极1号AGV");
if (plc == null)
continue;
var iswork = plc.ReadValue(ConveyorLineInfoDBName.R_Location_iswork.ToString(), toadd).ToString();
if (iswork == "2")
continue;
//读取有货无货信号
var isemptyorwork = plc.ReadValue(ConveyorLineInfoDBName.R_Location_iswork.ToString(), hcj).ToString();
GetEquipmentInfo(toadd, hcj + "的货位状态是" + isemptyorwork, "", "", iswork);
if (isemptyorwork == "1")
continue;
var location = locRepository.FindFirst(v => v.upper_code == hcj);
var stock = groupRepository.Find(v => v.location_id == location.id).OrderByDescending(v=>v.created_time).FirstOrDefault();
var loc = locRepository.FindFirst(f => f.upper_code == "ZJSL-JJK001" && f.down_code == "ZJXL-JJK001");
if (stock == null)
continue;
//判断当前状态是否有更新
if (hcj.Contains("QX") && hcj.Contains("ZJ"))
{
if (string.IsNullOrEmpty(stock.TB_Status))
{
continue;
}
}
else if (hcj.Contains("TB") && hcj.Contains("ZJ"))
{
if (string.IsNullOrEmpty(stock.TB_Status))
{
continue;
}
}
else if (hcj.Contains("FQ") && hcj.Contains("ZJ"))
{
if (string.IsNullOrEmpty(stock.GY_Status))
{
continue;
}
}
else if (hcj.Contains("GY") && hcj.Contains("ZJ"))
{
if (string.IsNullOrEmpty(stock.QX_Status))
{
continue;
}
}
lock (requestJJK)
{
if (loc.location_state == LocationStateEnum.LocationState_Empty.ToString() && location.location_state == LocationStateEnum.LocationState_Stored.ToString() && stock.BarCode != null && stock.MaterialStatus != null)
{
responseContent = locRepository.DbContextBeginTransaction(() =>
{
MESback WMSbackresult = MESAPIInvoke.PreTask(1);
if (WMSbackresult == null) { return WebResponseContent.Instance.Error("正极大极卷库不通过入库申请"); }
dt_agvtask agvtask = new dt_agvtask
{
agv_materbarcode = stock.BarCode,
agv_barcode = "",
agv_code = plc.PLCName,
agv_createtime = DateTime.Now,
agv_fromaddress = hcj,
agv_grade = 1,
agv_materielid = stock.MaterialType,
agv_qty = 1,
agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
agv_taskstate = "Create",
agv_tasktype = "TaskType_Outbound",
agv_toaddress = toadd,
agv_userid = "WCS",
agv_worktype = 1
};
agvRepository.Add(agvtask, true);
WriteLog.Info("ZF_InOut_Djjk").Write("ZF_InOut_Djjk" + agvtask.agv_tasknum + stock.BarCode + DateTime.Now, "ZF_InOut_Djjk");
location.location_state = LocationStateEnum.LocationState_Lock.ToString();
loc.location_state = LocationStateEnum.LocationState_Lock.ToString();
locRepository.Update(loc, true);
locRepository.Update(location, true);
return WebResponseContent.Instance.OK();
});
}
}
}
}
catch (Exception ex)
{
WriteLog.Info("ZF_InOut_Djjk").Write("ZF_InOut_Djjk" + ex.Message + DateTime.Now, "ZF_InOut_Djjk");
}
finally
{
Interlocked.Exchange(ref _readZFINOUTSignalso, 0);
}
}
}
}
}