using Admin.NET.Application;
|
using Admin.NET.Core.EnterWareHouseModule;
|
using Admin.NET.Core.EnterWareHouseModule.Enum;
|
using iWareCC.Common.Helper;
|
using iWareCC.ConveyorService;
|
using iWareCommon.Common.Globle;
|
using iWareCommon.Utils;
|
using iWareModel;
|
using iWareSql.DataAccess;
|
using iWareSql.DbOrm;
|
using iWareSql.Orm;
|
using Newtonsoft.Json;
|
using Newtonsoft.Json.Linq;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading;
|
using System.Threading.Tasks;
|
using System.Windows.Forms;
|
using XiGang.Core.Model;
|
|
namespace iWareCC
|
{
|
public class ScanContainerCode
|
{
|
public static LogType currentLogType = LogType.ScanContainerCode;
|
|
public static string host = ConfigHelper.GetConfigString("WMSHost");
|
public static string addWarehouseEstablishment = ConfigHelper.GetConfigString("addWarehouseEstablishment");
|
public static string addEnterEmptyWare = ConfigHelper.GetConfigString("addEnterEmptyWare");
|
public static string getOrderNo = ConfigHelper.GetConfigString("getOrderNo");
|
public static string fronttask = ConfigHelper.GetConfigString("fronttask");
|
|
/// <summary>
|
///读码线程
|
/// </summary>
|
public static void HandlerMainTaskScanCode1()
|
{
|
Log4NetHelper.WriteInfoLog(currentLogType, "101扫码线程启动");
|
while (true)
|
{
|
try
|
{
|
string str = "";
|
if (SystemValue.isStartedModel)
|
{
|
var vs = new ConveyerServiceClient();
|
//if (FormCC.conveyerView.R_Scan1_Success)
|
if (vs.ReadAddress("2304|800.0") == true)
|
{
|
//string currentCodeScan101 = FormCC.conveyerView.R_Scan1_Value;
|
//short height = FormCC.conveyerView.R_Shape;
|
string currentCodeScan101 = vs.ReadStr("2304|804");
|
short height = vs.ReadShort("2304|802");
|
|
SystemWarningMsg._lbl_ScanHandle101 = "接受到请求，条码:" + currentCodeScan101 + "高度:" + height;
|
Log4NetHelper.WriteInfoLog(currentLogType, "接受到请求，条码:" + currentCodeScan101 + "高度:" + height);
|
|
if (string.IsNullOrWhiteSpace(currentCodeScan101))
|
{
|
Thread.Sleep(1000);
|
continue;
|
}
|
short convertH = 0;
|
|
switch (height)
|
{
|
case 14:
|
convertH = 4;
|
break;
|
case 21:
|
convertH = 3;
|
break;
|
case 23:
|
convertH = 2;
|
break;
|
case 26:
|
convertH = 1;
|
break;
|
}
|
|
//校验堆垛机任务的状态
|
using (DbOrm dbOrm = new DbOrm())
|
{
|
//var task = dbOrm.ware_task_sub.Where(u => u.ContainerCode == currentCodeScan101 && u.DeviceId == (int)EDevice.堆垛机).FirstOrDefault();
|
//查询当前执行中的升降机任务
|
var task = dbOrm.ware_task_sub.Where(u => u.TaskState == 1 && u.DeviceId == 3 && u.ContainerCode == "等待识别").FirstOrDefault();
|
if (task != null)
|
{
|
//查询AGV和堆垛机任务
|
var tasks = dbOrm.ware_task_sub.Where(u => u.TaskId == task.TaskId && (u.DeviceId == 1099 || u.DeviceId == 1)).ToList();
|
|
|
//获取托盘类型
|
var container = dbOrm.wms_container.AsNoTracking().Where(u => u.ContainerCode == currentCodeScan101).FirstOrDefault();
|
if (container == null)
|
{
|
SystemWarningMsg._lbl_ScanHandle101 = $"小车{currentCodeScan101}没有配置基础信息";
|
Thread.Sleep(1000);
|
continue;
|
}
|
if (string.IsNullOrEmpty(container.RealLocationCode))
|
{
|
SystemWarningMsg._lbl_ScanHandle101 = $"小车{currentCodeScan101}没有绑定库位";
|
Thread.Sleep(1000);
|
continue;
|
}
|
var containerType = dbOrm.wms_container_type.AsNoTracking().Where(u => u.WareContainerTypeCode == container.ContainerTypeCode).FirstOrDefault();
|
if (containerType == null)
|
{
|
SystemWarningMsg._lbl_ScanHandle101 = $"小车{currentCodeScan101}没有配置类型信息";
|
Thread.Sleep(1000);
|
continue;
|
}
|
|
if (containerType.PLCTypeId <= convertH && convertH != 0)
|
{
|
task.ContainerCode = currentCodeScan101;
|
task.ContainerType = containerType.PLCTypeId;
|
|
var sdaResult = vs.WriteReceiveScan((int)EDevice.输送线, "101", true);
|
if (!sdaResult.result)
|
{
|
Log4NetHelper.WriteErrorLog(currentLogType, $"{currentCodeScan101} 号扫码器接受完成写入失败，" + sdaResult.resMsg);
|
}
|
else
|
{
|
Log4NetHelper.WriteInfoLog(currentLogType, $"{currentCodeScan101} 号扫码器接受完成写入成功");
|
foreach (var item in tasks)
|
{
|
item.ContainerCode = currentCodeScan101;
|
item.ContainerType = containerType.PLCTypeId;
|
if (item.DeviceId == 1)
|
{
|
item.ToPlace = container.RealLocationCode;
|
item.TaskState = (int)SubTaskStateEnum.未开始;
|
}
|
}
|
var maintask = dbOrm.ware_task.Where(u => u.Id == task.TaskId).FirstOrDefault();
|
if (maintask != null)
|
{
|
//查询绑定的零件号
|
var partCode = dbOrm.wms_part.AsNoTracking().Where(u => u.MaterialCode == currentCodeScan101).FirstOrDefault();
|
maintask.ToLocationCode = container.RealLocationCode;
|
maintask.ContainerCode = currentCodeScan101;
|
maintask.PartCode = partCode?.PartCode;
|
}
|
}
|
|
}
|
|
|
//if (task.ContainerType <= convertH)
|
//{
|
// var sdaResult = vs.WriteReceiveScan((int)EDevice.输送线, "101", true);
|
// if (!sdaResult.result)
|
// {
|
// Log4NetHelper.WriteErrorLog(currentLogType, "1号扫码器接受完成写入失败，" + sdaResult.resMsg);
|
// }
|
// else
|
// {
|
// Log4NetHelper.WriteInfoLog(currentLogType, "1号扫码器接受完成写入成功");
|
// if (task.TaskState == (int)SubTaskStateEnum.等待下发)
|
// {
|
// task.TaskState = (int)SubTaskStateEnum.未开始;
|
// }
|
// }
|
//}
|
else
|
{
|
SystemWarningMsg._lbl_ScanHandle101 = "接受到请求，条码" + currentCodeScan101 + "的高度：" + height + "与配置" + GetHeight(containerType.PLCTypeId) + " 不一致";
|
}
|
}
|
else
|
{
|
var task1 = dbOrm.ware_task_sub.Where(u => u.ContainerCode == currentCodeScan101 && u.DeviceId == (int)EDevice.堆垛机).FirstOrDefault();
|
if (task1 != null)
|
{
|
if (task1.ContainerType <= convertH && convertH != 0)
|
{
|
var sdaResult = vs.WriteReceiveScan((int)EDevice.输送线, "101", true);
|
if (!sdaResult.result)
|
{
|
Log4NetHelper.WriteErrorLog(currentLogType, $"{currentCodeScan101} 1号扫码器接受完成写入失败，" + sdaResult.resMsg);
|
}
|
else
|
{
|
Log4NetHelper.WriteInfoLog(currentLogType, $"{currentCodeScan101} 1号扫码器接受完成写入成功");
|
if (task1.TaskState == (int)SubTaskStateEnum.等待下发)
|
{
|
task1.TaskState = (int)SubTaskStateEnum.未开始;
|
}
|
}
|
}
|
else
|
{
|
SystemWarningMsg._lbl_ScanHandle101 = "接受到请求，条码: " + currentCodeScan101 + "高度: " + height + " 与配置高度" + GetHeight(task1.ContainerType) + "不一致";
|
}
|
}
|
else
|
{
|
SystemWarningMsg._lbl_ScanHandle101 = "没有任务应答请求";
|
}
|
}
|
//else
|
//{
|
// var sdaResult = new ConveyorService.ConveyerServiceClient().WriteReceiveScan((int)EDevice.输送线, "101", true);
|
// if (!sdaResult.result)
|
// {
|
// Log4NetHelper.WriteErrorLog(currentLogType, "1号扫码器接受完成写入失败，" + sdaResult.resMsg);
|
// }
|
// else
|
// {
|
// Log4NetHelper.WriteInfoLog(currentLogType, "1号扫码器接受完成写入成功");
|
// }
|
//}
|
dbOrm.SaveChanges();
|
}
|
}
|
else
|
{
|
//if (FormCC.conveyerView.W_Scan1_ReceiveFinish)
|
if (vs.ReadAddress("2304|300.0") == true)
|
{
|
var sdaResult = vs.WriteReceiveScan((int)EDevice.输送线, "101", false);
|
if (!sdaResult.result)
|
{
|
Log4NetHelper.WriteErrorLog(currentLogType, $"1号扫码器取消接受完成写入失败，{sdaResult.resMsg}");
|
}
|
}
|
SystemWarningMsg._lbl_ScanHandle101 = "当前没有请求";
|
}
|
vs.Close();
|
}
|
}
|
catch (Exception ex)
|
{
|
SystemWarningMsg._lbl_ScanHandle101 = $"1分解线程出现异常:{ex.Message}";
|
Log4NetHelper.WriteErrorLog(currentLogType, $"扫码处理出现异常：{ex.Message}", ex);
|
}
|
Thread.Sleep(1000);//休眠2秒
|
}
|
}
|
|
public static CommonResponse ExeCreateFrontTask(string containercode, string sitecode, ref string msg)
|
{
|
FrontTaskInput front = new FrontTaskInput() { sitecode = sitecode, containercode = containercode };
|
//var wmsResults = new HTTPService(host).postContent<FrontTaskInput, CommonResponse>(fronttask, front, Guid.NewGuid(), 30);
|
var wmsResult = HttpHelper.GetHttpResponse<FrontTaskInput, CommonResponse>(host + fronttask, front, 10000);
|
if (wmsResult.code == 200)
|
{
|
Log4NetHelper.WriteInfoLog(currentLogType, $"站台：{sitecode}，托盘：{containercode}，生成前置输送线任务成功");
|
msg = $"站台{sitecode}，托盘：{containercode}，生成前置输送线任务成功";
|
}
|
else
|
{
|
Log4NetHelper.WriteErrorLog(currentLogType, $"站台：{sitecode}，托盘：{containercode}，生成前置输送线任务失败，{wmsResult.message}");
|
msg = $"站台：{sitecode}，托盘：{containercode}，生成前置输送线任务失败，{wmsResult.message}";
|
}
|
return wmsResult;
|
}
|
|
public static string GetHeight(int? heigh)
|
{
|
switch (heigh)
|
{
|
case 1:
|
return "26";
|
case 2:
|
return "23";
|
case 3:
|
return "21";
|
case 4:
|
return "14";
|
default:
|
return " ";
|
}
|
}
|
}
|
}
|
