|
|
@@ -3,6 +3,7 @@ using System;
|
|
|
using System.ServiceModel;
|
|
|
using System.ServiceModel.Activation;
|
|
|
using Curtain.Core;
|
|
|
+using Dongke.IBOSS.PRD.Service.BPMDataService;
|
|
|
using Dongke.IBOSS.PRD.Service.SAPHegiiDataService;
|
|
|
using Dongke.IBOSS.PRD.Service.WMSDataService;
|
|
|
using Dongke.IBOSS.PRD.WCF.Contracts;
|
|
|
@@ -33,6 +34,7 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
#region Hegii
|
|
|
if ("Hegii" == cre.NameSpace)
|
|
|
{
|
|
|
+ #region SAP相关
|
|
|
// 获取同步最后一次同步成功的日期
|
|
|
if ("GetLastDateByCode" == cre.Name)
|
|
|
{
|
|
|
@@ -42,7 +44,7 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
return result;
|
|
|
}
|
|
|
// 获取成品交接同步数据
|
|
|
- if ("GetWorkData60" == cre.Name)
|
|
|
+ else if ("GetWorkData60" == cre.Name)
|
|
|
{
|
|
|
DateTime date = (DateTime)cre.Request;
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
@@ -50,7 +52,7 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
return result;
|
|
|
}
|
|
|
// 同步成品交接数据
|
|
|
- if ("SetWorkData60" == cre.Name)
|
|
|
+ else if ("SetWorkData60" == cre.Name)
|
|
|
{
|
|
|
DateTime date = (DateTime)cre.Request;
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
@@ -58,29 +60,29 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
return result;
|
|
|
}
|
|
|
// 查询同步日志
|
|
|
- if ("GetDataLog" == cre.Name)
|
|
|
+ else if ("GetDataLog" == cre.Name)
|
|
|
{
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetDataLog(cre));
|
|
|
return result;
|
|
|
}
|
|
|
// 查询产量同步明细
|
|
|
- if ("GetWorkDataByDataLog" == cre.Name)
|
|
|
+ else if ("GetWorkDataByDataLog" == cre.Name)
|
|
|
{
|
|
|
int logid = Convert.ToInt32(cre.Request);
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetWorkDataByDataLog(logid));
|
|
|
return result;
|
|
|
- }
|
|
|
- // 查询
|
|
|
- if ("GetWorkDataSPSumByDate" == cre.Name)
|
|
|
- {
|
|
|
- ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.GetWorkDataSPSumByDate(cre));
|
|
|
- return result;
|
|
|
- }
|
|
|
- // 查询成品条码同步明细
|
|
|
- if ("GetFinishedProductByDataLog" == cre.Name)
|
|
|
+ }
|
|
|
+ // 查询
|
|
|
+ else if ("GetWorkDataSPSumByDate" == cre.Name)
|
|
|
+ {
|
|
|
+ ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
+ () => SAPDataLogic.GetWorkDataSPSumByDate(cre));
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ // 查询成品条码同步明细
|
|
|
+ else if ("GetFinishedProductByDataLog" == cre.Name)
|
|
|
{
|
|
|
int logid = Convert.ToInt32(cre.Request);
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
@@ -88,7 +90,7 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
return result;
|
|
|
}
|
|
|
// 获取数据并同步产量数据
|
|
|
- if ("SetWorkData10_50" == cre.Name)
|
|
|
+ else if ("SetWorkData10_50" == cre.Name)
|
|
|
{
|
|
|
DateTime date = (DateTime)cre.Request;
|
|
|
string datacode = cre.Properties["datacode"] + "";
|
|
|
@@ -97,7 +99,7 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
return result;
|
|
|
}
|
|
|
// 同步产量数据
|
|
|
- if ("SyncSap" == cre.Name)
|
|
|
+ else if ("SyncSap" == cre.Name)
|
|
|
{
|
|
|
DateTime date = (DateTime)cre.Request;
|
|
|
string datacode = cre.Properties["datacode"] + "";
|
|
|
@@ -107,21 +109,21 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
return result;
|
|
|
}
|
|
|
// 同步成品条码明细数据
|
|
|
- if ("SetFP6001" == cre.Name)
|
|
|
- {
|
|
|
- // DateTime date = (DateTime)cre.Request;
|
|
|
- // //if (date.Year < 2018)
|
|
|
- // //{
|
|
|
- // // ServiceResultEntity result1 = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- // // () => SAPDataLogic.SetFP6001_1(date, SUserInfo.UserID));
|
|
|
- // // return result1;
|
|
|
- // //}
|
|
|
- // ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- //() => SAPDataLogic.SetFP6001(date, SUserInfo.UserID));
|
|
|
- return new ServiceResultEntity();
|
|
|
- }
|
|
|
+ else if ("SetFP6001" == cre.Name)
|
|
|
+ {
|
|
|
+ // DateTime date = (DateTime)cre.Request;
|
|
|
+ // //if (date.Year < 2018)
|
|
|
+ // //{
|
|
|
+ // // ServiceResultEntity result1 = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
+ // // () => SAPDataLogic.SetFP6001_1(date, SUserInfo.UserID));
|
|
|
+ // // return result1;
|
|
|
+ // //}
|
|
|
+ // ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
+ //() => SAPDataLogic.SetFP6001(date, SUserInfo.UserID));
|
|
|
+ return new ServiceResultEntity();
|
|
|
+ }
|
|
|
// 同步成品条码明细数据
|
|
|
- if ("SetFP6002" == cre.Name)
|
|
|
+ else if ("SetFP6002" == cre.Name)
|
|
|
{
|
|
|
//DateTime date = (DateTime)cre.Request;
|
|
|
//ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
@@ -129,36 +131,23 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
return new ServiceResultEntity();
|
|
|
}
|
|
|
// 临时同步
|
|
|
- if ("SetFP60_T" == cre.Name)
|
|
|
+ else if ("SetFP60_T" == cre.Name)
|
|
|
{
|
|
|
//DateTime date = DateTime.Now;//(DateTime)cre.Request;
|
|
|
//ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
// () => SAPDataLogic.SetFP60_T(date, SUserInfo.UserID));
|
|
|
return new ServiceResultEntity();
|
|
|
}
|
|
|
- // 查询WMS同步日志
|
|
|
- if ("GetWMSDataLog" == cre.Name)
|
|
|
- {
|
|
|
- ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => WMSDataLogic.GetWMSDataLog(cre, SUserInfo));
|
|
|
- return result;
|
|
|
- }
|
|
|
- // 同步WMS同步日志
|
|
|
- if ("SyncWMSDataLog" == cre.Name)
|
|
|
- {
|
|
|
- ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => WMSDataLogic.SyncWMSDataLog(cre, SUserInfo));
|
|
|
- return result;
|
|
|
- }
|
|
|
+
|
|
|
//查询跨车间作业同步汇总
|
|
|
- if ("GetDataLog_kczzy" == cre.Name)
|
|
|
+ else if ("GetDataLog_kczzy" == cre.Name)
|
|
|
{
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetDataLog_kczzy(cre));
|
|
|
return result;
|
|
|
}
|
|
|
// 查询跨车间作业同步明细
|
|
|
- if ("GetWorkData_kczzy" == cre.Name)
|
|
|
+ else if ("GetWorkData_kczzy" == cre.Name)
|
|
|
{
|
|
|
//int logid = Convert.ToInt32(cre.Request);
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
@@ -166,141 +155,163 @@ namespace Dongke.IBOSS.PRD.WCF.Services
|
|
|
return result;
|
|
|
}
|
|
|
// 查询报工移库日志
|
|
|
- if ("GetDataLog_BGYK" == cre.Name)
|
|
|
+ else if ("GetDataLog_BGYK" == cre.Name)
|
|
|
{
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetDataLog_BGYK(cre));
|
|
|
return result;
|
|
|
}
|
|
|
// 查询报工移库日志明细
|
|
|
- if ("GetWorkData_BGYK" == cre.Name)
|
|
|
+ else if ("GetWorkData_BGYK" == cre.Name)
|
|
|
{
|
|
|
//update xiacm 2022-10-21
|
|
|
- // int logid = Convert.ToInt32(cre.Request);
|
|
|
+ // int logid = Convert.ToInt32(cre.Request);
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetWorkData_BGYK(cre));
|
|
|
return result;
|
|
|
}
|
|
|
// 查询报工日志
|
|
|
- if ("GetDataLog_BG" == cre.Name)
|
|
|
+ else if ("GetDataLog_BG" == cre.Name)
|
|
|
{
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetDataLog_BG(cre));
|
|
|
return result;
|
|
|
}
|
|
|
// 查询报工日志明细
|
|
|
- if ("GetWorkData_BG" == cre.Name)
|
|
|
+ else if ("GetWorkData_BG" == cre.Name)
|
|
|
{
|
|
|
- // int logid = Convert.ToInt32(cre.Request);
|
|
|
+ // int logid = Convert.ToInt32(cre.Request);
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetWorkData_BG(cre));
|
|
|
return result;
|
|
|
}
|
|
|
// 查询报工汇总 add xiacm 2022-10-12
|
|
|
- if("GetDataLogTotal_BG" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("GetDataLogTotal_BG" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetDataLogTotal_BG(cre));
|
|
|
return result;
|
|
|
}
|
|
|
// 查询半成品库存 add xiacm 2022-11-09
|
|
|
- if("GetDataIVITotal_BC" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("GetDataIVITotal_BC" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
() => SAPDataLogic.GetDataIVITotal_BC(cre));
|
|
|
return result;
|
|
|
}
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region WMS相关
|
|
|
+ // 查询WMS同步日志
|
|
|
+ else if ("GetWMSDataLog" == cre.Name)
|
|
|
+ {
|
|
|
+ ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
+ () => WMSDataLogic.GetWMSDataLog(cre, SUserInfo));
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ // 同步WMS同步日志
|
|
|
+ else if ("SyncWMSDataLog" == cre.Name)
|
|
|
+ {
|
|
|
+ ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
+ () => WMSDataLogic.SyncWMSDataLog(cre, SUserInfo));
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+ #endregion
|
|
|
+
|
|
|
+ #region BPM相关
|
|
|
// 查询组件报损数据
|
|
|
- if("GetDataBARCODEIDNRKSCRAP" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("GetDataBARCODEIDNRKSCRAP" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.GetDataBARCODEIDNRKSCRAP(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.GetDataBARCODEIDNRKSCRAP(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
// 确认组件报损
|
|
|
- if("SaveConfirmIdnrkScrap" ==cre.Name)
|
|
|
- {
|
|
|
+ else if ("SaveConfirmIdnrkScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.SaveConfirmIdnrkScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.SaveConfirmIdnrkScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
// 撤销确认组件报损
|
|
|
- if("SaveUNConfirmIdnrkScrap" ==cre.Name)
|
|
|
- {
|
|
|
+ else if ("SaveUNConfirmIdnrkScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.SaveUNConfirmIdnrkScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.SaveUNConfirmIdnrkScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//同步bpm组件报损
|
|
|
- if("SynIdnrkScrap" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("SynIdnrkScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.SynIdnrkScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.SynIdnrkScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//撤销bpm组件报损
|
|
|
- if("CancelSynIdnrkScrap" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("CancelSynIdnrkScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.CancelSynIdnrkScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.CancelSynIdnrkScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//查询成本中心
|
|
|
- if("GetCostCenter" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("GetCostCenter" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.GetCostCenter(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.GetCostCenter(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//设置成本中心
|
|
|
- if("SaveCostCenter" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("SaveCostCenter" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.SaveCostCenter(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.SaveCostCenter(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//确认bpm 同一流程实例报损履历是否全部选中
|
|
|
- if("CheckScrap" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("CheckScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.CheckScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.CheckScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//删除报损履历
|
|
|
- if("DeleteIDNRKScrap" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("DeleteIDNRKScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.DeleteIDNRKScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.DeleteIDNRKScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//新建报损履历
|
|
|
- if("AddIDNRKScrap" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("AddIDNRKScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.AddIDNRKScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.AddIDNRKScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//获取报损履历信息
|
|
|
- if("GetIDNRKScrap" ==cre.Name)
|
|
|
- {
|
|
|
+ else if ("GetIDNRKScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.GetIDNRKScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.GetIDNRKScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//
|
|
|
- if("GetIdnrkCode" ==cre.Name)
|
|
|
- {
|
|
|
+ else if ("GetIdnrkCode" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.GetIdnrkCode(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.GetIdnrkCode(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
//编辑报损履历
|
|
|
- if("UpdateIDNRKScrap" == cre.Name)
|
|
|
- {
|
|
|
+ else if ("UpdateIDNRKScrap" == cre.Name)
|
|
|
+ {
|
|
|
ServiceResultEntity result = ServiceInvoker.Invoke<ServiceResultEntity>(this,
|
|
|
- () => SAPDataLogic.UpdateIDNRKScrap(cre, SUserInfo));
|
|
|
+ () => BPMDataLogic.UpdateIDNRKScrap(cre, SUserInfo));
|
|
|
return result;
|
|
|
}
|
|
|
+ #endregion
|
|
|
+
|
|
|
return null;
|
|
|
}
|
|
|
#endregion
|