using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.ServiceModel;
|
using System.Text;
|
using System.Threading.Tasks;
|
using WIDESEA.Common;
|
using WIDESEA.Core.Utilities;
|
using WIDESEA.Entity.DomainModels;
|
using WIDESEA.Services.Repositories;
|
using WIDESEA.Services.Services.ToMes;
|
using WIDESEA_Common.LogEnum;
|
using WIDESEA_Services;
|
|
namespace WIDESEA.Services.Services.ToMeasureDevice
|
{
|
public class ToMeasureDeviceService
|
{
|
|
/// <summary>
|
/// 测量设备调用该接口，获取测量需要的数据
|
/// </summary>
|
/// <returns></returns>
|
public static Dictionary<string, object> GetGoodsInformation()
|
{
|
Dictionary<string, object> resultDic = new Dictionary<string, object>();
|
//string state = "成功";
|
try
|
{
|
Dictionary<string, object> dataDic = new Dictionary<string, object>();
|
|
Dt_taskinfo taskinfo = Dt_taskinfoRepository.Instance.FindFirst(x => x.task_state == TaskState.TaskState_Measureing.ToString());
|
//Dt_taskinfo taskinfo = Dt_taskinfoRepository.Instance.FindFirst(x => x.task_type == TaskType.TaskType_Box_Pallet_Measure_Out.ToString());
|
if (taskinfo != null)
|
{
|
VV_ContainerInfo containerInfo = VV_ContainerInfoRepository.Instance.FindFirst(x => x.containerhead_barcode == taskinfo.task_barcode);
|
if (containerInfo != null)
|
{
|
dataDic.Add("operator", containerInfo.containerdtl_operator);
|
dataDic.Add("identifierNo", containerInfo.containerdtl_goodsCode);
|
dataDic.Add("inboundUnit", containerInfo.containerdtl_inboundUnit);
|
dataDic.Add("inboundDate", containerInfo.containerhead_createtime);
|
string standard = containerInfo.containerdtl_standard.Contains("0") ? "新品" : "检修";
|
dataDic.Add("standard", standard);
|
// dataDic.Add("standard", "新品");
|
dataDic.Add("carType", containerInfo.containerdtl_carType);
|
//dataDic.Add("carType", "CRH2A");
|
dataDic.Add("type", containerInfo.containerdtl_type);
|
//dataDic.Add("type", "F-80781112TAROL130/240-B-TVP");
|
dataDic.Add("barcode", containerInfo.containerhead_barcode);
|
dataDic.Add("madeUnit", containerInfo.containerdtl_madeUnit);
|
dataDic.Add("madeDate", containerInfo.containerdtl_madeDate);
|
dataDic.Add("number", containerInfo.containerdtl_number);
|
resultDic.Add("status", true);
|
resultDic.Add("message", "Success");
|
resultDic.Add("data", dataDic);
|
|
LogRecord.WriteLog((int)LogEnum.MeasureResult, $"===发送===>发送给测量设备的信息数据：{JsonConvert.SerializeObject(dataDic)}");
|
}
|
else
|
throw new Exception("没有找到测量信息");
|
}
|
else
|
throw new Exception("当前没有正在进行的测量任务");
|
}
|
catch (Exception ex)
|
{
|
resultDic.Add("status", false);
|
resultDic.Add("message", ex.Message);
|
resultDic.Add("data", null);
|
//state = "失败";
|
LogRecord.WriteLog((int)LogEnum.MeasureResult, $"===发送===>发送给测量设备的信息数据失败：{JsonConvert.SerializeObject(resultDic)}");
|
}
|
//CommonFunction.AddInterfaceLogAction(null, resultDic, state, "GetGoodsInformation");
|
return resultDic;
|
}
|
|
|
/// <summary>
|
/// 测量设备对轴承测量完毕后，调用该接口向WMS上报测量结果
|
/// </summary>
|
/// <returns></returns>
|
public static Dictionary<string, object> PostGoodsData(Dictionary<string, object> data)
|
{
|
Dictionary<string, object> resultDic = new Dictionary<string, object>();
|
//string state = "成功";
|
try
|
{
|
LogRecord.WriteLog((int)LogEnum.MeasureResult, $"===接收===>接收到测量设备的测量结果：{JsonConvert.SerializeObject(data)}");
|
|
//获取轴承识别号，找到对应的测量记录，将测量数据填充
|
string identitfierId = data["ID"].ToString();
|
//
|
Dt_container_size_info container_Size_Info = Dt_container_size_infoRepository.Instance.FindFirst(x => x.csize_barcode == identitfierId);
|
//Dt_container_size_info container_Size_Info = Dt_container_size_infoRepository.Instance.FindFirst(x => true);
|
if (container_Size_Info != null)
|
{
|
container_Size_Info.csize_in_1 = data["BearingInnerDiameter11"].ToString();
|
container_Size_Info.csize_in_2 = data["BearingInnerDiameter12"].ToString();
|
container_Size_Info.csize_in_3 = data["BearingInnerDiameter13"].ToString();
|
container_Size_Info.csize_in_4 = data["BearingInnerDiameter14"].ToString() + "_" + data["BearingInnerDiameter1Avg"].ToString();
|
|
container_Size_Info.csize_in_5 = data["BearingInnerDiameter21"].ToString();
|
container_Size_Info.csize_in_6 = data["BearingInnerDiameter22"].ToString();
|
container_Size_Info.csize_in_7 = data["BearingInnerDiameter23"].ToString();
|
container_Size_Info.csize_in_8 = data["BearingInnerDiameter24"].ToString() + "_" + data["BearingInnerDiameter2Avg"].ToString();
|
|
container_Size_Info.csize_in_9 = data["BearingInnerDiameter31"].ToString();
|
container_Size_Info.csize_in_10 = data["BearingInnerDiameter32"].ToString();
|
container_Size_Info.csize_in_11 = data["BearingInnerDiameter33"].ToString();
|
container_Size_Info.csize_in_12 = data["BearingInnerDiameter34"].ToString() + "_" + data["BearingInnerDiameter3Avg"].ToString();
|
|
container_Size_Info.csize_in_13 = data["BearingInnerDiameter41"].ToString();
|
container_Size_Info.csize_in_14 = data["BearingInnerDiameter42"].ToString();
|
container_Size_Info.csize_in_15 = data["BearingInnerDiameter43"].ToString();
|
container_Size_Info.csize_in_16 = data["BearingInnerDiameter44"].ToString() + "_" + data["BearingInnerDiameter4Avg"].ToString();
|
//轴承内径平均值
|
container_Size_Info.csize_in_value = data["BearingInnerDiameterAvg"].ToString();
|
//轴承内径合格否
|
container_Size_Info.csize_in_result = data["BearingInnerDiameterQualified"].ToString();
|
|
|
container_Size_Info.csize_out_1 = data["BearingOuterDiameter11"].ToString();
|
container_Size_Info.csize_out_2 = data["BearingOuterDiameter12"].ToString();
|
container_Size_Info.csize_out_3 = data["BearingOuterDiameter13"].ToString();
|
container_Size_Info.csize_out_4 = data["BearingOuterDiameter14"].ToString() + "_" + data["BearingOuterDiameter1Avg"].ToString();
|
|
container_Size_Info.csize_out_5 = data["BearingOuterDiameter21"].ToString();
|
container_Size_Info.csize_out_6 = data["BearingOuterDiameter22"].ToString();
|
container_Size_Info.csize_out_7 = data["BearingOuterDiameter23"].ToString();
|
container_Size_Info.csize_out_8 = data["BearingOuterDiameter24"].ToString() + "_" + data["BearingOuterDiameter2Avg"].ToString();
|
|
container_Size_Info.csize_out_9 = data["BearingOuterDiameter31"].ToString();
|
container_Size_Info.csize_out_10 = data["BearingOuterDiameter32"].ToString();
|
container_Size_Info.csize_out_11 = data["BearingOuterDiameter33"].ToString();
|
container_Size_Info.csize_out_12 = data["BearingOuterDiameter34"].ToString() + "_" + data["BearingOuterDiameter3Avg"].ToString();
|
|
container_Size_Info.csize_out_13 = data["BearingOuterDiameter41"].ToString();
|
container_Size_Info.csize_out_14 = data["BearingOuterDiameter42"].ToString();
|
container_Size_Info.csize_out_15 = data["BearingOuterDiameter43"].ToString();
|
container_Size_Info.csize_out_16 = data["BearingOuterDiameter44"].ToString() + "_" + data["BearingOuterDiameter4Avg"].ToString();
|
//轴承外径平均值
|
container_Size_Info.csize_out_value = data["BearingOuterDiameterAvg"].ToString();
|
//轴承外径合格否
|
container_Size_Info.csize_out_result = data["BearingOuterDiameterQualified"].ToString();
|
|
|
container_Size_Info.csize_three_1 = data["BearingOilGearDiameter1"].ToString();
|
container_Size_Info.csize_three_2 = data["BearingOilGearDiameter2"].ToString();
|
//挡油内径平均值
|
container_Size_Info.csize_three_3 = data["BearingOilGearDiameterAvg"].ToString();
|
//挡油内径合格否
|
container_Size_Info.csize_three_result = data["BearingOilGearDiameterQualified"].ToString();
|
|
container_Size_Info.csize_four_1 = data["BearingTailgateDiameter1"].ToString();
|
container_Size_Info.csize_four_2 = data["BearingTailgateDiameter2"].ToString();
|
//后挡内径平均值
|
container_Size_Info.csize_four_3 = data["BearingTailgateDiameterAvg"].ToString();
|
//后挡内径合格否
|
container_Size_Info.csize_four_result = data["BearingTailgateDiameterQualified"].ToString();
|
|
Dt_container_size_infoRepository.Instance.Update(container_Size_Info, true);
|
|
Guid id = Guid.Parse(container_Size_Info.csize_container_detail_id);
|
Dt_container_detail detail = Dt_container_detailRepository.Instance.FindFirst(r => r.containerdtl_id == id);
|
if (null != detail)
|
{
|
detail.containerdtl_text1 = "已测量";
|
detail.containerdtl_text2 = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
data.Add("weight", detail.containerdtl_goodsWeight);
|
string uploadStatus = "未上传";
|
string result = "合格";
|
if ("不合格".Equals(container_Size_Info.csize_in_result) || "不合格".Equals(container_Size_Info.csize_out_result)
|
|| "不合格".Equals(container_Size_Info.csize_three_result) || "不合格".Equals(container_Size_Info.csize_four_result))
|
result = "不合格";
|
else
|
{
|
string resultString = string.Empty;
|
try
|
{
|
EndpointAddress address = new EndpointAddress(ToMesService.POSTURL);
|
ErpWebService.Service_EQPSoapClient client = new ErpWebService.Service_EQPSoapClient(new BasicHttpBinding(), address);
|
Task<ErpWebService.ReportToSCEResponse> res = client.ReportToSCEAsync(detail.containerdtl_number, JsonConvert.SerializeObject(data));
|
resultString = res.Result.Body.ReportToSCEResult;
|
uploadStatus = "已上传";
|
}
|
catch
|
{
|
|
}
|
finally
|
{
|
LogRecord.WriteLog((int)LogEnum.Mes, $"测量上传MES参数:{JsonConvert.SerializeObject(data)},结果：{resultString}");
|
}
|
}
|
detail.containerdtl_text3 = result;
|
Dt_container_detailRepository.Instance.Update(detail, x => new { x.containerdtl_text1, x.containerdtl_text2, x.containerdtl_text3 }, true);
|
|
Dt_container_head head = Dt_container_headRepository.Instance.FindFirst(r => r.containerhead_id == Guid.Parse(detail.containerdtl_headid));
|
Dt_taskinfo task = Dt_taskinfoRepository.Instance.FindFirst(r => r.task_barcode == head.containerhead_barcode);
|
if (null == task)
|
task = new Dt_taskinfo() { task_creator = "手动上传." };
|
|
dt_measureRecord record = new dt_measureRecord()
|
{
|
measure_barcode = head.containerhead_barcode,
|
measure_createTime = DateTime.Now,
|
measure_fcbAVG = string.IsNullOrEmpty(container_Size_Info.csize_four_3) ? 0 : decimal.Parse(container_Size_Info.csize_four_3),
|
measure_fcbAVG_result = container_Size_Info.csize_four_result,
|
measure_id = Guid.NewGuid(),
|
measure_locationId = task.task_fromlocationid,
|
measure_madeUnit = detail.containerdtl_madeUnit,
|
measure_materielId = detail.containerdtl_materielid,
|
measure_materielNumber = detail.containerdtl_goodsCode,
|
measure_materielType = detail.containerdtl_type,
|
measure_standa = detail.containerdtl_standard,
|
measure_userName = task.task_creator,
|
measure_weight = string.IsNullOrEmpty(detail.containerdtl_goodsWeight) ? 0 : decimal.Parse(detail.containerdtl_goodsWeight),
|
measure_ydAVG = string.IsNullOrEmpty(container_Size_Info.csize_three_3) ? 0 : decimal.Parse(container_Size_Info.csize_three_3),
|
measure_ydAVG_result = container_Size_Info.csize_three_result,
|
measure_zjAVG = string.IsNullOrEmpty(container_Size_Info.csize_in_value) ? 0 : decimal.Parse(container_Size_Info.csize_in_value),
|
measure_zjAVG_result = container_Size_Info.csize_in_result,
|
measure_result = result,
|
measure_wjAVG = string.IsNullOrEmpty(container_Size_Info.csize_out_value) ? 0 : decimal.Parse(container_Size_Info.csize_out_value),
|
measure_wj_result = container_Size_Info.csize_out_result,
|
};
|
if (result.Equals("合格"))
|
{
|
record.measure_uploadData = JsonConvert.SerializeObject(data);
|
record.measure_uploadResult = uploadStatus;
|
record.measure_uploadTime = DateTime.Now;
|
record.measure_uploadUser = "system";
|
}
|
dt_measureRecordRepository.Instance.Add(record, true);
|
}
|
resultDic.Add("status", "1");
|
resultDic.Add("message", "Success");
|
resultDic.Add("data", null);
|
}
|
else
|
{
|
resultDic.Add("status", "-1");
|
resultDic.Add("message", $"没有找到对应ID的轴承记录：【{identitfierId}】");
|
resultDic.Add("data", null);
|
//state = "失败";
|
}
|
}
|
catch (Exception ex)
|
{
|
resultDic.Add("status", "-1");
|
resultDic.Add("message", ex.Message);
|
resultDic.Add("data", null);
|
// state = "失败";
|
}
|
|
//CommonFunction.AddInterfaceLogAction(data, resultDic, state, "PostGoodsData");
|
return resultDic;
|
}
|
|
|
|
/// <summary>
|
/// 测量设备调用此接口上报设备状态，同时作为心跳检测接口确保与WMS的连接
|
/// </summary>
|
/// <param name="data"></param>
|
/// <returns></returns>
|
public static Dictionary<string, object> PostDeviceStatus(Dictionary<string, object> data)
|
{
|
|
Dictionary<string, object> resultDic = new Dictionary<string, object>();
|
try
|
{
|
//设备编号
|
string EquipmentNumber = data["EquipmentNumber"].ToString();
|
//设备状态
|
//0=正常进行
|
//1=设备异常报警
|
//2=测量数据异常报警
|
//3=暂停
|
//4=停止
|
string EquipmentStatus = data["EquipmentStatus"].ToString();
|
//设备状态具体信息、报警状态详细信息
|
string StatusInformation = data["StatusInformation"].ToString();
|
//上报时间
|
string OperationTime = data["OperationTime"].ToString();
|
|
string heartStatus = "onLine";
|
|
LogRecord.WriteLog((int)LogEnum.MeasureHeart, $"接收到测量设备的状态上报数据：{JsonConvert.SerializeObject(data)}");
|
|
Dt_general_info general_Info = Dt_general_infoRepository.Instance.FindFirst(x => true);
|
general_Info.general_measure_device_status = EquipmentStatus;
|
general_Info.general_measure_device_heart = heartStatus;
|
|
Dt_general_infoRepository.Instance.Update(general_Info, true);
|
|
resultDic.Add("status", "1");
|
resultDic.Add("message", "Success");
|
resultDic.Add("data", null);
|
|
}
|
catch (Exception ex)
|
{
|
resultDic.Add("status", "-1");
|
resultDic.Add("message", ex.Message);
|
resultDic.Add("data", null);
|
}
|
//CommonFunction.AddInterfaceLogAction(data, resultDic, state, "PostDeviceStatus");
|
return resultDic;
|
|
}
|
|
}
|
}
|
