using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.ServiceModel;
|
using System.Text;
|
using System.Threading.Tasks;
|
using System.Xml;
|
using WIDESEA.Common;
|
using WIDESEA.Core.ManageUser;
|
using WIDESEA.Core.Utilities;
|
using WIDESEA.Entity.DomainModels;
|
using WIDESEA.Services.IServices;
|
using WIDESEA.Services.Repositories;
|
using WIDESEA_Common.LogEnum;
|
|
namespace WIDESEA.Services.Services.ToMes
|
{
|
public class ToMesService
|
{
|
//http://172.21.1.117/barcode/Webservice/WebService_ZY/WebServiceZY.asmx;
|
public static string POSTURL = "http://172.21.1.117/barcode/Webservice/WebService_ZY/Service_EQP.asmx";
|
/// <summary>
|
/// 获取轴承信息接口
|
/// </summary>
|
/// <param name="saveModel">轴承条码</param>
|
/// <returns></returns>
|
public static WebResponseContent Mes_GetBearingInfo(SaveModel saveModel)
|
{
|
getInfoByBearingXMLEntity xmlEntity = null;
|
string resultString = string.Empty;
|
WebResponseContent content = new WebResponseContent();
|
Idt_rulerService rulerService = dt_rulerService.Instance;
|
//WebResponseContent result = new WebResponseContent();
|
try
|
{
|
string barcode = saveModel.MainData["barcode"].ToString();
|
//2695-2022-05-1815
|
EndpointAddress address = new EndpointAddress(POSTURL);
|
ErpWebService.Service_EQPSoapClient client = new ErpWebService.Service_EQPSoapClient(new BasicHttpBinding(), address);
|
Task<ErpWebService.getInfoByBearingResponse> res = client.getInfoByBearingAsync(barcode);
|
resultString = res.Result.Body.getInfoByBearingResult;
|
//result.OK(data: resultString);
|
// resultString = File.ReadAllText(@"D://xml.txt");
|
if (string.IsNullOrEmpty(resultString))
|
throw new Exception("获取轴承信息失败.");
|
|
|
xmlEntity = XMLSerializationTool.DeserializeXmlToObject<getInfoByBearingXMLEntity>(resultString);
|
WebResponseContent responseContent = rulerService.GetDateTimeByRule(xmlEntity.TRAINTYPE, xmlEntity.MANUFACTOR, xmlEntity.MAINFREQ, barcode);
|
if(responseContent.Status)
|
{
|
xmlEntity.ProductDate = responseContent.Data.ToString();
|
}
|
|
content.OK(data: xmlEntity);
|
}
|
catch (Exception ex)
|
{
|
content.Error("获取轴承信息失败.异常:" + ex.Message);
|
}
|
finally
|
{
|
LogRecord.WriteLog((int)LogEnum.Mes, $"组盘查询轴承信息结果：{resultString}");
|
}
|
return content;
|
}
|
|
|
/// <summary>
|
/// 获取轴颈尺寸接口（扫描轮对条码，获取轴颈数据）
|
/// </summary>
|
/// <param name="saveModel">轮对条码</param>
|
/// <returns></returns>
|
public static WebResponseContent Mes_GetBearingNeckSizeInfo(SaveModel saveModel)
|
{
|
WebResponseContent content = new WebResponseContent();
|
//WebResponseContent result = new WebResponseContent();
|
string resultString = string.Empty;
|
getInfoByJournalXMLEntity xmlEntity = null;
|
string barcode = string.Empty;
|
QueryZCInfo queryZCInfo = new QueryZCInfo();
|
try
|
{
|
barcode = saveModel.MainData["barcode"].ToString();
|
EndpointAddress address = new EndpointAddress(POSTURL);
|
ErpWebService.Service_EQPSoapClient client = new ErpWebService.Service_EQPSoapClient(new BasicHttpBinding(), address);
|
Task<ErpWebService.getInfoByJournalResponse> res = client.getInfoByJournalAsync(barcode);
|
resultString = res.Result.Body.getInfoByJournalResult;
|
// result.OK(data: resultString);
|
// resultString = File.ReadAllText(@"D://xml.txt");
|
xmlEntity = XMLSerializationTool.DeserializeXmlToObject<getInfoByJournalXMLEntity>(resultString);
|
if (xmlEntity.FLAG == "S")
|
{
|
Data zzjAVG = xmlEntity.Datas.Data.Where(r => r.name == "左轴颈平均值").OrderByDescending(r => r.time).FirstOrDefault();
|
if (null != zzjAVG) queryZCInfo.zzjAVG = decimal.Parse(zzjAVG.value).ToString("N3");
|
|
Data yzjAVG = xmlEntity.Datas.Data.Where(r => r.name == "右轴颈平均值").OrderByDescending(r => r.time).FirstOrDefault();
|
if (null != yzjAVG) queryZCInfo.yzjAVG = decimal.Parse(yzjAVG.value).ToString("N3");
|
|
Data zfcbAVG = xmlEntity.Datas.Data.Where(r => r.name == "左防尘板座平均值").OrderByDescending(r => r.time).FirstOrDefault();
|
if (null != zfcbAVG) queryZCInfo.zfcbAVG = decimal.Parse(zfcbAVG.value).ToString("N3");
|
|
Data yfcbAVG = xmlEntity.Datas.Data.Where(r => r.name == "右防尘板座平均值").OrderByDescending(r => r.time).FirstOrDefault();
|
if (null != yfcbAVG) queryZCInfo.yfcbAVG = decimal.Parse(yfcbAVG.value).ToString("N3");
|
|
Data zydAVG = xmlEntity.Datas.Data.Where(r => r.name == "左油档平均值").OrderByDescending(r => r.time).FirstOrDefault();
|
if (null != zydAVG) queryZCInfo.zydAVG = decimal.Parse(zydAVG.value).ToString("N3");
|
|
Data yydAVG = xmlEntity.Datas.Data.Where(r => r.name == "右油档平均值").OrderByDescending(r => r.time).FirstOrDefault();
|
if (null != yydAVG) queryZCInfo.yydAVG = decimal.Parse(yydAVG.value).ToString("N3");
|
|
Data materiel = xmlEntity.Datas.Data.Where(r => r.name == "车型").OrderByDescending(r => r.time).FirstOrDefault();
|
if (null != materiel) queryZCInfo.materiel = materiel.value;
|
|
Data ldcode = xmlEntity.Datas.Data.Where(r => r.name == "轮对号").OrderByDescending(r => r.time).FirstOrDefault();
|
if (null != ldcode) queryZCInfo.ldCode = ldcode.value;
|
|
queryZCInfo.ortherData = "";
|
List<Dt_materielinfo> materielinfo = Dt_materielinfoRepository.Instance.Find(r => r.materiel_suitMateriel.Contains(queryZCInfo.materiel));
|
if (null != materielinfo && materielinfo.Count > 0)
|
{
|
string[] listMaterielId = materielinfo.Select(r => r.materiel_id).ToArray();
|
List<Dt_selection_standards> standards = Dt_selection_standardsRepository.Instance.Find(r => listMaterielId.Contains(r.selection_carId));
|
if (null != standards && standards.Count > 0)
|
{
|
queryZCInfo.manufacturerArray = standards.Select(r => r.selection_zc_manufacturer).ToArray().Distinct().ToArray();
|
queryZCInfo.neworold = standards.Select(r => r.selection_zc_type).ToArray().Distinct().ToArray();
|
}
|
}
|
}
|
content.OK(data: queryZCInfo);
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
finally
|
{
|
LogRecord.WriteLog((int)LogEnum.Mes, $"{barcode},轴承出库查询轴承选配结果：{resultString},返回App信息:{JsonConvert.SerializeObject(queryZCInfo)}");
|
// Services.CommonFunction.AddInterfaceLogAction(saveModel, result, "Mes_GetBearingNeckSizeInfo");
|
}
|
return content;
|
}
|
|
|
|
/// <summary>
|
/// 轴承扫码选配接口
|
/// </summary>
|
/// <param name="saveModel"></param>
|
/// <returns></returns>
|
public WebResponseContent Mes_WheelsetMatch(SaveModel saveModel)
|
{
|
//WebResponseContent content = new WebResponseContent();
|
//try
|
//{
|
// //轮对条码
|
// string barcode = saveModel.MainData["barcode"].ToString();
|
// //轴承条码
|
// string barcodePart = saveModel.MainData["barcodePart"].ToString();
|
// //部件类型
|
// string barcodeType = saveModel.MainData["barcodeType"].ToString();
|
//}
|
//catch (Exception ex)
|
//{
|
// content.Error(ex.Message);
|
//}
|
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
EndpointAddress address = new EndpointAddress("http://172.21.1.117/barcode/Webservice/WebService_ZY/Service_EQP.asmx");
|
//EndpointAddress address = new EndpointAddress(" http://172.21.1.117/barcode/Webservice/WebService_ZY/WebServiceZY.asmx");
|
ErpWebService.Service_EQPSoapClient client = new ErpWebService.Service_EQPSoapClient(new BasicHttpBinding(), address);
|
Task<ErpWebService.WheelsetMatchResponse> res = client.WheelsetMatchAsync("", "", "");
|
string resultString = res.Result.Body.WheelsetMatchResult;
|
Console.WriteLine(resultString);
|
}
|
catch (Exception ex)
|
{
|
content.Error(ex.Message);
|
}
|
finally
|
{
|
//Services.CommonFunction.AddInterfaceLogAction("", content, "Mes_WheelsetMatch");
|
}
|
return content;
|
}
|
/// <summary>
|
/// 查询测量数据结果
|
/// </summary>
|
/// <param name="materielNumber"></param>
|
/// <returns></returns>
|
public string Mes_QueryMeasureInfo(object materielNumber)
|
{
|
MeasureInfo result = new MeasureInfo();
|
try
|
{
|
Dt_container_size_info info = Dt_container_size_infoRepository.Instance.FindFirst(x => x.csize_barcode == materielNumber.ToString());
|
if (null != info)
|
{
|
if (string.IsNullOrEmpty(info.csize_in_1))
|
throw new Exception("暂无测量值");
|
object obj = new
|
{
|
BearingInnerDiameter11 = info.csize_in_1,
|
BearingInnerDiameter12 = info.csize_in_2,
|
BearingInnerDiameter13 = info.csize_in_3,
|
BearingInnerDiameter14 = info.csize_in_4.Split('_')[0],
|
BearingInnerDiameter1Avg = info.csize_in_4.Split('_')[1],
|
|
BearingInnerDiameter21 = info.csize_in_5,
|
BearingInnerDiameter22 = info.csize_in_6,
|
BearingInnerDiameter23 = info.csize_in_7,
|
BearingInnerDiameter24 = info.csize_in_8.Split('_')[0],
|
BearingInnerDiameter2Avg = info.csize_in_8.Split('_')[1],
|
|
|
BearingInnerDiameter31 = info.csize_in_9,
|
BearingInnerDiameter32 = info.csize_in_10,
|
BearingInnerDiameter33 = info.csize_in_11,
|
BearingInnerDiameter34 = info.csize_in_12.Split('_')[0],
|
BearingInnerDiameter3Avg = info.csize_in_12.Split('_')[1],
|
|
BearingInnerDiameter41 = info.csize_in_13,
|
BearingInnerDiameter42 = info.csize_in_14,
|
BearingInnerDiameter43 = info.csize_in_15,
|
BearingInnerDiameter44 = info.csize_in_16.Split('_')[0],
|
BearingInnerDiameter4Avg = info.csize_in_16.Split('_')[1],
|
|
|
BearingInnerDiameterAvg = info.csize_in_value,
|
BearingInnerDiameterQualified = info.csize_in_result,
|
|
|
BearingOuterDiameter11 = info.csize_out_1,
|
BearingOuterDiameter12 = info.csize_out_2,
|
BearingOuterDiameter13 = info.csize_out_3,
|
BearingOuterDiameter14 = info.csize_out_4.Split('_')[0],
|
BearingOuterDiameter1Avg = info.csize_out_4.Split('_')[1],
|
|
|
BearingOuterDiameter21 = info.csize_out_5,
|
BearingOuterDiameter22 = info.csize_out_6,
|
BearingOuterDiameter23 = info.csize_out_7,
|
BearingOuterDiameter24 = info.csize_out_8.Split('_')[0],
|
BearingOuterDiameter2Avg = info.csize_out_8.Split('_')[1],
|
|
BearingOuterDiameter31 = info.csize_out_9,
|
BearingOuterDiameter32 = info.csize_out_10,
|
BearingOuterDiameter33 = info.csize_out_11,
|
BearingOuterDiameter34 = info.csize_out_12.Split('_')[0],
|
BearingOuterDiameter3Avg = info.csize_out_12.Split('_')[1],
|
|
BearingOuterDiameter41 = info.csize_out_13,
|
BearingOuterDiameter42 = info.csize_out_14,
|
BearingOuterDiameter43 = info.csize_out_15,
|
BearingOuterDiameter44 = info.csize_out_16.Split('_')[0],
|
BearingOuterDiameter4Avg = info.csize_out_16.Split('_')[1],
|
|
|
BearingOuterDiameterAvg = info.csize_out_value,
|
BearingOuterDiameterQualified = info.csize_out_result,
|
|
BearingOilGearDiameter1 = info.csize_three_1,
|
BearingOilGearDiameter2 = info.csize_three_2,
|
BearingOilGearDiameterAvg = info.csize_three_3,
|
BearingOilGearDiameterQualified = info.csize_three_result,
|
|
|
BearingTailgateDiameter1 = info.csize_four_1,
|
BearingTailgateDiameter2 = info.csize_four_2,
|
BearingTailgateDiameterAvg = info.csize_four_3,
|
BearingTailgateDiameterQualified = info.csize_four_result,
|
};
|
result.code = 1;
|
result.data = obj;
|
}
|
else
|
{
|
result.code = 0;
|
result.message = "未找到轴承信息.";
|
}
|
}
|
catch (Exception ex)
|
{
|
result.code = 0;
|
result.message = ex.Message;
|
}
|
return JsonConvert.SerializeObject(result);
|
}
|
|
public WebResponseContent UploadMES(SaveModel saveModel)
|
{
|
WebResponseContent content = new WebResponseContent();
|
try
|
{
|
foreach (var item in saveModel.DelKeys)
|
{
|
string resultString = string.Empty;
|
string recordData = string.Empty;
|
try
|
{
|
dt_measureRecord record = dt_measureRecordRepository.Instance.FindFirst(r => r.measure_id == Guid.Parse(item.ToString()));
|
if (null == record)
|
return content.Error("未找到测量记录.");
|
if (!record.measure_result.Equals("合格"))
|
return content.Error("只能上传测量合格的数据.");
|
if (string.IsNullOrEmpty(record.measure_uploadData))
|
return content.Error("当前没有上传的数据,请重新测量.");
|
recordData = record.measure_uploadData;
|
EndpointAddress address = new EndpointAddress(ToMesService.POSTURL);
|
ErpWebService.Service_EQPSoapClient client = new ErpWebService.Service_EQPSoapClient(new BasicHttpBinding(), address);
|
Task<ErpWebService.ReportToSCEResponse> res = client.ReportToSCEAsync(record.measure_materielNumber, record.measure_uploadData);
|
resultString = res.Result.Body.ReportToSCEResult;
|
|
|
record.measure_uploadResult = "已上传";
|
record.measure_uploadTime = DateTime.Now;
|
record.measure_uploadUser = UserContext.Current.UserTrueName;
|
dt_measureRecordRepository.Instance.Update(record, x => new { x.measure_uploadResult, x.measure_uploadTime, x.measure_uploadUser }, true);
|
}
|
catch
|
{
|
|
}
|
finally
|
{
|
LogRecord.WriteLog((int)LogEnum.Mes, $"{UserContext.Current.UserTrueName}上传MES参数:{recordData},结果：{resultString}");
|
}
|
}
|
content.OK();
|
}
|
catch (Exception ex)
|
{
|
content.Error("上传失败:" + ex.Message);
|
}
|
finally
|
{
|
|
}
|
return content;
|
}
|
}
|
public class MeasureInfo
|
{
|
public int code { get; set; }
|
public object data { get; set; }
|
|
public string message { get; set; }
|
}
|
}
|
