using HslCommunication;
|
using System;
|
using System.Collections.Generic;
|
using System.Text;
|
using WIDESEA_Common;
|
using WIDESEA_Common.LogEnum;
|
using WIDESEA_Core.Utilities;
|
using WIDESEA_Entity.DomainModels;
|
using WIDESEA_Services;
|
using WIDESEA_Services.Repositories;
|
using WIDESEA_WCS.WCSClient;
|
|
namespace WIDESEA_WCS.Jobs.ConveyorLine
|
{
|
public class WeighingLogic
|
{
|
|
/// <summary>
|
/// 获取重量，不管是空托还是实托，都需要有重量记录
|
/// </summary>
|
/// <param name="taskWCSinfoRepository"></param>
|
/// <param name="station"></param>
|
/// <param name="client"></param>
|
public static void DealWithWeighingLogic(Dt_TaskWCSinfoRepository taskWCSinfoRepository, Dt_StationManager station, PLCClient client)
|
{
|
OperateResult<Int16> weightingResult = (OperateResult<Int16>)client.ReadValue(CLineInfoDBName.R_Line_Weighting.ToString(), station.sm_stationNo);
|
OperateResult<UInt32> rfidResult = (OperateResult<UInt32>)client.ReadValue(CLineInfoDBName.R_Line_Barcode.ToString(), station.sm_stationNo);
|
OperateResult<UInt32> taskRes = (OperateResult<UInt32>)client.ReadValue(CLineInfoDBName.R_Line_TaskNumber.ToString(), station.sm_stationNo);
|
if (weightingResult.IsSuccess && rfidResult.IsSuccess && taskRes.IsSuccess)
|
{
|
UInt32 rfidValue = rfidResult.Content; //托盘码
|
int weighting = weightingResult.Content; //1 = 称重中 2= 称重完成
|
UInt32 taskNum = taskRes.Content;
|
|
//找到正在进行称重的任务
|
Dt_TaskWCSinfo wcsInfo = taskWCSinfoRepository.FindFirst(x =>
|
x.wcstask_barcode == rfidValue.ToString() &&
|
x.wcstask_taskNumber == taskNum &&
|
(x.wcstask_type == TaskType.TaskType_Box_Pallet_Inbound.ToString() ||
|
x.wcstask_type == TaskType.TaskType_Empty_Pallet_Inbound.ToString())&&
|
(x.wcstask_state == TaskState.TaskState_ConveyorLineExecuting.ToString() ||
|
x.wcstask_state == TaskState.TaskState_Weighing.ToString()));
|
if (wcsInfo != null)
|
{
|
//1 = 表示在称重中
|
if (weighting == 1)
|
{
|
LogRecord.WriteLog(LogEnum.InBound,$"任务号：【{taskNum}】,托盘号：【{rfidValue}】对应的任务达到【20201】站台，并且处于【称重中...】状态");
|
//在此更新任务状态、上报WMS任务状态
|
WebResponseContent content = WMSApi.PostTaskStateToWMS(rfidValue.ToString(), TaskState.TaskState_Weighing.ToString());
|
if (content.Status)
|
{
|
wcsInfo.wcstask_state = TaskState.TaskState_Weighing.ToString();
|
wcsInfo.wcstask_dispatcherTime = DateTime.Now;
|
taskWCSinfoRepository.Update(wcsInfo, true);
|
Console.WriteLine($"{DateTime.Now}=>Success=> 上报WMS更新任务状态成功【TaskState_Weighing】，任务号：【{wcsInfo.wcstask_taskNumber}】");
|
|
LogRecord.WriteLog(LogEnum.InBound, $"任务号：【{taskNum}】,托盘号：【{rfidValue}】上报WMS更新任务状态成功【TaskState_Weighing】");
|
}
|
else
|
{
|
Console.WriteLine($"{DateTime.Now}=>Failed=> 上报WMS更新任务状态出错【TaskState_Weighing】，任务号：【{wcsInfo.wcstask_taskNumber}】，原因：{content.Message}");
|
|
LogRecord.WriteLog(LogEnum.InBound, $"::Error::=> 任务号：【{taskNum}】,托盘号：【{rfidValue}】上报WMS更新任务状态失败【TaskState_Weighing】，原因：{content.Message}");
|
}
|
}
|
else if (weighting == 2)
|
{
|
OperateResult<UInt32> weightResult = (OperateResult<UInt32>)client.ReadValue(CLineInfoDBName.R_Line_Weight.ToString(), station.sm_stationNo);
|
if (weightResult.IsSuccess)
|
{
|
UInt32 weightValue = weightResult.Content;
|
|
LogRecord.WriteLog(LogEnum.InBound, $" 任务号：【{taskNum}】,托盘号：【{rfidValue}】读取到称重值：【{weightValue}】");
|
|
//向WMS上报读取到的重量值和对应的RFID值
|
WebResponseContent content = WMSApi.TellWmsWeightResult(rfidValue.ToString(), weightValue.ToString());
|
if (content.Status)
|
{
|
Console.WriteLine($"{DateTime.Now}=>上报WMS称重结果完成，托盘号：【{rfidValue}】，重量值：【{weightValue}】");
|
LogRecord.WriteLog(LogEnum.InBound, $" 任务号：【{taskNum}】,托盘号：【{rfidValue}】上报WMS称重值：【{weightValue}】成功");
|
//上报重量结果后，在此通知线体继续任务，该为了人工手动
|
bool goonTask = client.WriteValue(CLineInfoDBName.W_Line_Weight_OK.ToString(), true);
|
if (goonTask)
|
{
|
LogRecord.WriteLog(LogEnum.InBound, $" 任务号：【{taskNum}】,托盘号：【{rfidValue}】上报WMS称重值后，发送继续任务指令给线体");
|
Console.WriteLine($"{DateTime.Now}=>Success=> 称重完成后继续任务，任务号：【{wcsInfo.wcstask_taskNumber}】");
|
//称重完成后，在此更新任务状态、上报WMS任务状态
|
content = WMSApi.PostTaskStateToWMS(rfidValue.ToString(), TaskState.TaskState_ConveyorLineExecuting.ToString());
|
if (content.Status)
|
{
|
wcsInfo.wcstask_state = TaskState.TaskState_ConveyorLineExecuting.ToString();
|
wcsInfo.wcstask_dispatcherTime = DateTime.Now;
|
taskWCSinfoRepository.Update(wcsInfo, true);
|
Console.WriteLine($"{DateTime.Now}=>Success=> 上报WMS更新任务状态成功【TaskState_ConveyorLineExecuting】，任务号：【{wcsInfo.wcstask_taskNumber}】");
|
|
LogRecord.WriteLog(LogEnum.InBound, $"任务号：【{taskNum}】,托盘号：【{rfidValue}】上报WMS更新任务状态成功【TaskState_ConveyorLineExecuting】，称重后上报");
|
}
|
else
|
{
|
Console.WriteLine($"{DateTime.Now}=>Failed=> 上报WMS更新任务状态出错【TaskState_ConveyorLineExecuting】，任务号：【{wcsInfo.wcstask_taskNumber}】，原因：{content.Message}");
|
|
LogRecord.WriteLog(LogEnum.InBound, $"::Error::=> 任务号：【{taskNum}】,托盘号：【{rfidValue}】上报WMS更新任务状态失败【TaskState_ConveyorLineExecuting】，称重后上报，原因：{content.Message}");
|
}
|
}
|
else
|
{
|
Console.WriteLine($"{DateTime.Now}=>Failed=> 称重完成后写如继续任务失败，任务号：【{wcsInfo.wcstask_taskNumber}】");
|
}
|
}
|
else
|
{
|
Console.WriteLine($"::Error::=> 上报WMS称重结果失败，托盘号：【{rfidValue}】，重量值：【{weightValue}】");
|
|
LogRecord.WriteLog(LogEnum.InBound, $"::Error::=> 任务号：【{taskNum}】,托盘号：【{rfidValue}】上报WMS称重结果失败，原因：{content.Message}");
|
}
|
}
|
else
|
{
|
LogRecord.WriteLog(LogEnum.InBound, $"::Error::=> 任务号：【{taskNum}】,托盘号：【{rfidValue}】读取重量值失败");
|
}
|
}
|
|
}
|
else
|
{
|
//Console.WriteLine("当前没有需要进行的称重任务");
|
}
|
}
|
}
|
}
|
}
|
