using System;
|
using System.Collections.Generic;
|
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.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 _readZTSJSignalso = 0;
|
/// <summary>
|
/// 正极提升机口有下料请求
|
/// </summary>
|
/// <returns></returns>
|
public static void Z_TSJ_DownTask()
|
{
|
if (Interlocked.Exchange(ref _readZTSJSignalso, 1) == 0)
|
{
|
try
|
{
|
VOLContext Context = new VOLContext();
|
|
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);
|
|
PLCClient plc = WCSService.Clients.Find(v => v.PLCName == "正极提升机");
|
if (plc == null)
|
return;
|
//获取三楼正极上料请求 DB1002.693.0
|
string isZWork = plc.ReadValue(ConveyorLineInfoDBName.R_ZTSJ_Downrequest.ToString(), plc.PLCDescroption).ToString();
|
//获取三楼负极上料请求
|
string isFWork = plc.ReadValue(ConveyorLineInfoDBName.R_FTSJ_Downrequest.ToString(), plc.PLCDescroption).ToString();
|
WriteLog.Info("提升机请求").Write("Z_TSJ_DownTask,正极：" + isZWork+"负极：" + isFWork + DateTime.Now, "提升机请求");
|
if (bool.Parse(isZWork))
|
{
|
string newBarcode = "";
|
string fromAdd = "ZJXL-WLX002";
|
//查询是否有任务存在
|
var task = agvRepository.FindFirst(v => v.agv_fromaddress == fromAdd);
|
if (task != null)
|
return;
|
//读取物料条码
|
//BarCode = plc.ReadValue(ConveyorLineInfoDBName.R_ZTSJ_Barcode.ToString(), plc.PLCDescroption).ToString();
|
//当AGV完成时，并且任务是去三楼的，则将任务条码保存在数据库中，三楼下料时，每次取前两个条码，并删除前两个条码
|
var barcodelist = tasknumberRep.FindFirst(v => v.taskno == 1);
|
string[] BarCodelist = barcodelist.numtype.Split(";");
|
if (BarCodelist.Length <= 2 && (string.IsNullOrEmpty(BarCodelist[1]) || string.IsNullOrEmpty(BarCodelist[0])))
|
{
|
if (string.IsNullOrEmpty(BarCodelist[0]) )
|
{
|
barcodelist.numtype = barcodelist.numtype.Substring(1, barcodelist.numtype.Length-1);
|
tasknumberRep.Update(barcodelist, true);
|
}
|
return;
|
}
|
var hxtask = agvRepository.FindFirst(f => f.agv_materbarcode.Contains(BarCodelist[0]));
|
if (hxtask != null)
|
{
|
var agvtaskold= agvRepository.FindFirst(v => v.agv_fromaddress == "错误展示");
|
agvtaskold.agv_realesstime = DateTime.Now;
|
agvtaskold.ErrMsg = "提升机有下料请求，但当前条码已经存在任务";
|
agvRepository.Update(agvtaskold,true);
|
throw new Exception(string.Format("正极提升机有下料请求，但当前条码已经存在任务{0}", BarCodelist[0]));
|
}
|
//查找库存
|
var stock = groupRepository.FindFirst(v => v.BarCode == BarCodelist[0]);
|
if (stock == null)
|
{
|
var agvtaskold = agvRepository.FindFirst(v => v.agv_fromaddress == "错误展示");
|
agvtaskold.ErrMsg = "正极提升机有下料请求，但请求条码未查询到库存信息";
|
agvtaskold.agv_realesstime = DateTime.Now;
|
agvRepository.Update(agvtaskold, true);
|
WriteLog.Info("Z_TSJ_DownTask").Write("提升机有下料请求，但请求条码未查询到库存信息，条码是" + BarCodelist[0] + DateTime.Now, "Z_TSJ_DownTask");
|
return;
|
}
|
string BarCode = BarCodelist[0] + ";" + BarCodelist[1];
|
WriteLog.Info("正极提升机下料时的两个烘箱条码").Write(BarCode +"\t"+ DateTime.Now, "正极提升机下料时的两个烘箱条码");
|
for (int i = 2; i < BarCodelist.Length; i++)
|
{
|
if (!string.IsNullOrEmpty(BarCodelist[i]))
|
{
|
newBarcode = newBarcode + BarCodelist[i] + ";";
|
}
|
}
|
barcodelist.numtype = newBarcode;
|
tasknumberRep.Update(barcodelist, true);
|
|
dt_agvtask agvtask = new dt_agvtask
|
{
|
agv_materbarcode = BarCode,
|
agv_barcode = "",
|
agv_code = "负极2号AGV",
|
agv_createtime = DateTime.Now,
|
agv_fromaddress = fromAdd,
|
agv_grade = 1,
|
agv_materielid = stock.BarCode,
|
agv_qty = 1,
|
agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
|
agv_taskstate = "Create",
|
agv_tasktype = "TaskType_Outbound",
|
agv_toaddress = stock.Remark1,
|
agv_userid = "WCS",
|
agv_worktype = 1
|
};
|
agvRepository.Add(agvtask, true);
|
WriteLog.Info("Z_TSJ_DownTask").Write("Z_TSJ_DownTask" + agvtask.agv_tasknum + DateTime.Now, "Z_TSJ_DownTask");
|
}
|
if (bool.Parse(isFWork))
|
{
|
string newBarcode = "";
|
string fromAdd = "FJXL-WLX002";
|
//查询是否有任务存在
|
var task = agvRepository.FindFirst(v => v.agv_fromaddress == fromAdd);
|
if (task != null)
|
return;
|
//BarCode = plc.ReadValue(ConveyorLineInfoDBName.R_FTSJ_Barcode.ToString(), plc.PLCDescroption).ToString();
|
//当AGV完成时，并且任务是去三楼的，则将任务条码保存在数据库中，三楼下料时，每次取前两个条码，并删除前两个条码
|
var barcodelist = tasknumberRep.FindFirst(v => v.taskno == 2);
|
string[] BarCodelist = barcodelist.numtype.Split(";");
|
if (BarCodelist.Length <= 2 && (string.IsNullOrEmpty(BarCodelist[1])|| string.IsNullOrEmpty(BarCodelist[0])))
|
{
|
if (string.IsNullOrEmpty(BarCodelist[0]))
|
{
|
barcodelist.numtype = barcodelist.numtype.Substring(1, barcodelist.numtype.Length - 1);
|
tasknumberRep.Update(barcodelist, true);
|
}
|
return;
|
}
|
var hxtask = agvRepository.FindFirst(f => f.agv_materbarcode.Contains(BarCodelist[0]));
|
if (hxtask != null)
|
{
|
var agvtaskold = agvRepository.FindFirst(v => v.agv_fromaddress == "错误展示");
|
agvtaskold.ErrMsg = "负极提升机有下料请求，但当前条码已经存在任务";
|
agvtaskold.agv_realesstime = DateTime.Now;
|
agvRepository.Update(agvtaskold, true);
|
throw new Exception(string.Format("提升机有下料请求，但当前条码已经存在任务{0}", BarCodelist[0]));
|
}
|
//查找库存
|
var stock = groupRepository.FindFirst(v => v.BarCode == BarCodelist[0]);
|
if (stock == null)
|
{
|
var agvtaskold = agvRepository.FindFirst(v => v.agv_fromaddress == "错误展示");
|
agvtaskold.ErrMsg = "负极提升机有下料请求，但请求条码未查询到库存信息";
|
agvtaskold.agv_realesstime = DateTime.Now;
|
agvRepository.Update(agvtaskold, true);
|
WriteLog.Info("Z_TSJ_DownTask").Write("提升机有下料请求，但请求条码未查询到库存信息，条码是" + BarCodelist[0] + DateTime.Now, "Z_TSJ_DownTask");
|
return;
|
}
|
string BarCode = BarCodelist[0] + ";" + BarCodelist[1];
|
WriteLog.Info("负极提升机下料时的两个烘箱条码").Write(BarCode + "\t" + DateTime.Now, "负极提升机下料时的两个烘箱条码");
|
for (int i = 2; i < BarCodelist.Length; i++)
|
{
|
if (!string.IsNullOrEmpty(BarCodelist[i]))
|
{
|
newBarcode = newBarcode + BarCodelist[i] + ";";
|
}
|
}
|
barcodelist.numtype = newBarcode;
|
tasknumberRep.Update(barcodelist, true);
|
|
dt_agvtask agvtask = new dt_agvtask
|
{
|
agv_materbarcode = BarCode,
|
agv_barcode = "",
|
agv_code = "负极2号AGV",
|
agv_createtime = DateTime.Now,
|
agv_fromaddress = fromAdd,
|
agv_grade = 1,
|
agv_materielid = stock.BarCode,
|
agv_qty = 1,
|
agv_tasknum = "KH-" + tasknumber.GetTaskNumber(tasknumberRep),
|
agv_taskstate = "Create",
|
agv_tasktype = "TaskType_Outbound",
|
agv_toaddress = stock.Remark1,
|
agv_userid = "WCS",
|
agv_worktype = 1
|
};
|
agvRepository.Add(agvtask, true);
|
WriteLog.Info("Z_TSJ_DownTask").Write("Z_TSJ_DownTask" + agvtask.agv_tasknum + stock.BarCode + DateTime.Now, "Z_TSJ_DownTask");
|
}
|
}
|
catch (Exception ex)
|
{
|
WriteLog.Info("Z_TSJ_DownTask").Write("Z_TSJ_DownTask" + ex.Message + DateTime.Now, "Z_TSJ_DownTask");
|
}
|
finally
|
{
|
Interlocked.Exchange(ref _readZTSJSignalso, 0);
|
}
|
}
|
}
|
}
|
}
|
