1202-002-gaofei
This commit is contained in:
parent
ce8adb5c7b
commit
c091208a47
|
@ -0,0 +1,2 @@
|
||||||
|
alter table [dbo].[Base_Project] add CLProjectCode bigint null
|
||||||
|
GO
|
|
@ -899,13 +899,6 @@
|
||||||
<Content Include="Scripts\jquery-3.5.1.min.js" />
|
<Content Include="Scripts\jquery-3.5.1.min.js" />
|
||||||
<Content Include="Scripts\jquery-3.5.1.slim.js" />
|
<Content Include="Scripts\jquery-3.5.1.slim.js" />
|
||||||
<Content Include="Scripts\jquery-3.5.1.slim.min.js" />
|
<Content Include="Scripts\jquery-3.5.1.slim.min.js" />
|
||||||
<None Include="Service References\CNCECHSSEService\Reference.svcmap">
|
|
||||||
<Generator>WCF Proxy Generator</Generator>
|
|
||||||
<LastGenOutput>Reference.cs</LastGenOutput>
|
|
||||||
</None>
|
|
||||||
<None Include="Service References\CNCECHSSEService\configuration.svcinfo" />
|
|
||||||
<None Include="Service References\CNCECHSSEService\configuration91.svcinfo" />
|
|
||||||
<None Include="Service References\CNCECHSSEService\HSSEService.disco" />
|
|
||||||
<None Include="Service References\MCSService\Reference.svcmap">
|
<None Include="Service References\MCSService\Reference.svcmap">
|
||||||
<Generator>WCF Proxy Generator</Generator>
|
<Generator>WCF Proxy Generator</Generator>
|
||||||
<LastGenOutput>Reference.cs</LastGenOutput>
|
<LastGenOutput>Reference.cs</LastGenOutput>
|
||||||
|
@ -913,6 +906,13 @@
|
||||||
<None Include="Service References\MCSService\configuration.svcinfo" />
|
<None Include="Service References\MCSService\configuration.svcinfo" />
|
||||||
<None Include="Service References\MCSService\configuration91.svcinfo" />
|
<None Include="Service References\MCSService\configuration91.svcinfo" />
|
||||||
<None Include="Service References\MCSService\WebService1.disco" />
|
<None Include="Service References\MCSService\WebService1.disco" />
|
||||||
|
<None Include="Service References\CNCECHSSEService\Reference.svcmap">
|
||||||
|
<Generator>WCF Proxy Generator</Generator>
|
||||||
|
<LastGenOutput>Reference.cs</LastGenOutput>
|
||||||
|
</None>
|
||||||
|
<None Include="Service References\CNCECHSSEService\configuration.svcinfo" />
|
||||||
|
<None Include="Service References\CNCECHSSEService\configuration91.svcinfo" />
|
||||||
|
<None Include="Service References\CNCECHSSEService\HSSEService.disco" />
|
||||||
</ItemGroup>
|
</ItemGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<WCFMetadataStorage Include="Service References\CNCECHSSEService\" />
|
<WCFMetadataStorage Include="Service References\CNCECHSSEService\" />
|
||||||
|
|
|
@ -2,6 +2,7 @@
|
||||||
{
|
{
|
||||||
using Newtonsoft.Json.Linq;
|
using Newtonsoft.Json.Linq;
|
||||||
using System;
|
using System;
|
||||||
|
using System.Timers;
|
||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
using System.Linq;
|
using System.Linq;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
|
@ -9,238 +10,356 @@
|
||||||
|
|
||||||
public static class MCSWebService
|
public static class MCSWebService
|
||||||
{
|
{
|
||||||
|
#region 启动监视器 系统启动5分钟
|
||||||
|
/// <summary>
|
||||||
|
/// 监视组件
|
||||||
|
/// </summary>
|
||||||
|
private static Timer messageTimer;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// 启动监视器,不一定能成功,根据系统设置决定对监视器执行的操作 系统启动5分钟
|
||||||
|
/// </summary>
|
||||||
|
public static void StartMonitor()
|
||||||
|
{
|
||||||
|
if (messageTimer != null)
|
||||||
|
{
|
||||||
|
messageTimer.Stop();
|
||||||
|
messageTimer.Dispose();
|
||||||
|
messageTimer = null;
|
||||||
|
}
|
||||||
|
messageTimer = new Timer
|
||||||
|
{
|
||||||
|
AutoReset = true
|
||||||
|
};
|
||||||
|
messageTimer.Elapsed += new ElapsedEventHandler(GetCLData);
|
||||||
|
messageTimer.Interval = 1000 * 60 * 60 * 24;// 60分钟 60000 * adTimeJ;
|
||||||
|
messageTimer.Start();
|
||||||
|
}
|
||||||
|
#endregion
|
||||||
|
|
||||||
|
private static void GetCLData(object sender, ElapsedEventArgs e)
|
||||||
|
{
|
||||||
|
getPojectInfo();
|
||||||
|
getVendor();
|
||||||
|
var projects = from x in Funs.DB.Base_Project where x.CLProjectCode != null select x;
|
||||||
|
foreach (var project in projects)
|
||||||
|
{
|
||||||
|
getPoDetails(project.CLProjectCode ?? 0);
|
||||||
|
getIssueDetails(project.CLProjectCode ?? 0);
|
||||||
|
getPartNoInfo(project.CLProjectCode ?? 0);
|
||||||
|
getShelvesNo(project.CLProjectCode ?? 0);
|
||||||
|
getSubcontractor(project.CLProjectCode ?? 0);
|
||||||
|
getReqDetails(project.CLProjectCode ?? 0);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public static void getPojectInfo()
|
||||||
|
{
|
||||||
|
try
|
||||||
|
{
|
||||||
|
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
||||||
|
var details = mscsC.getPojectInfo();
|
||||||
|
if (!string.IsNullOrEmpty(details))
|
||||||
|
{
|
||||||
|
Model.SGGLDB db = Funs.DB;
|
||||||
|
JArray arr = JArray.Parse(details);
|
||||||
|
foreach (var item in arr)
|
||||||
|
{
|
||||||
|
Model.Base_Project project = db.Base_Project.FirstOrDefault(x => x.ProjectCode == item["项目编码"].ToString());
|
||||||
|
if (project != null)
|
||||||
|
{
|
||||||
|
project.CLProjectCode = Funs.GetNewInt(item["项目ID"].ToString());
|
||||||
|
db.SubmitChanges();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrLogInfo.WriteLog(ex, "材料管理接口定时器", "MCSWebService.getPojectInfo");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public static void getPoDetails(long projectId)
|
public static void getPoDetails(long projectId)
|
||||||
{
|
{
|
||||||
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
try
|
||||||
var details = mscsC.getPoDetails(projectId);
|
|
||||||
if (!string.IsNullOrEmpty(details))
|
|
||||||
{
|
{
|
||||||
Model.SGGLDB db = Funs.DB;
|
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
||||||
var q = from x in db.CLGL_ContractQuantitySheet where x.ProjectId == projectId.ToString() select x;
|
var details = mscsC.getPoDetails(projectId);
|
||||||
if (q.Count() > 0)
|
if (!string.IsNullOrEmpty(details))
|
||||||
{
|
{
|
||||||
db.CLGL_ContractQuantitySheet.DeleteAllOnSubmit(q);
|
Model.SGGLDB db = Funs.DB;
|
||||||
db.SubmitChanges();
|
var q = from x in db.CLGL_ContractQuantitySheet where x.ProjectId == projectId.ToString() select x;
|
||||||
}
|
if (q.Count() > 0)
|
||||||
JArray arr = JArray.Parse(details);
|
{
|
||||||
foreach (var item in arr)
|
db.CLGL_ContractQuantitySheet.DeleteAllOnSubmit(q);
|
||||||
{
|
db.SubmitChanges();
|
||||||
Model.CLGL_ContractQuantitySheet contractQuantitySheet = new Model.CLGL_ContractQuantitySheet();
|
}
|
||||||
contractQuantitySheet.PPGUID = item["PPGUID"].ToString();
|
JArray arr = JArray.Parse(details);
|
||||||
contractQuantitySheet.ProjectId = projectId.ToString();
|
foreach (var item in arr)
|
||||||
contractQuantitySheet.MaterialUse = item["材料用途"].ToString();
|
{
|
||||||
contractQuantitySheet.ContractCode = item["合同号"].ToString();
|
Model.CLGL_ContractQuantitySheet contractQuantitySheet = new Model.CLGL_ContractQuantitySheet();
|
||||||
contractQuantitySheet.Major = item["专业"].ToString();
|
contractQuantitySheet.PPGUID = item["PPGUID"].ToString();
|
||||||
contractQuantitySheet.PSGUID = item["PSGUID"].ToString();
|
contractQuantitySheet.ProjectId = projectId.ToString();
|
||||||
contractQuantitySheet.RDGUID = item["RDGUID"].ToString();
|
contractQuantitySheet.MaterialUse = item["材料用途"].ToString();
|
||||||
contractQuantitySheet.MaterialCode = item["材料编码"].ToString();
|
contractQuantitySheet.ContractCode = item["合同号"].ToString();
|
||||||
contractQuantitySheet.TagNo = item["位号"].ToString();
|
contractQuantitySheet.Major = item["专业"].ToString();
|
||||||
contractQuantitySheet.BuyQuantity = item["采购量"].ToString();
|
contractQuantitySheet.PSGUID = item["PSGUID"].ToString();
|
||||||
contractQuantitySheet.Remark = item["备注"].ToString();
|
contractQuantitySheet.RDGUID = item["RDGUID"].ToString();
|
||||||
contractQuantitySheet.DeviceCode = item["装置号"].ToString();
|
contractQuantitySheet.MaterialCode = item["材料编码"].ToString();
|
||||||
contractQuantitySheet.MainItemCode = item["主项号"].ToString();
|
contractQuantitySheet.TagNo = item["位号"].ToString();
|
||||||
contractQuantitySheet.UnitName = item["企业中文名称"].ToString();
|
contractQuantitySheet.BuyQuantity = item["采购量"].ToString();
|
||||||
db.CLGL_ContractQuantitySheet.InsertOnSubmit(contractQuantitySheet);
|
contractQuantitySheet.Remark = item["备注"].ToString();
|
||||||
db.SubmitChanges();
|
contractQuantitySheet.DeviceCode = item["装置号"].ToString();
|
||||||
|
contractQuantitySheet.MainItemCode = item["主项号"].ToString();
|
||||||
|
contractQuantitySheet.UnitName = item["企业中文名称"].ToString();
|
||||||
|
db.CLGL_ContractQuantitySheet.InsertOnSubmit(contractQuantitySheet);
|
||||||
|
db.SubmitChanges();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrLogInfo.WriteLog(ex, "材料管理接口定时器", "MCSWebService.getPoDetails");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void getIssueDetails(long projectId)
|
public static void getIssueDetails(long projectId)
|
||||||
{
|
{
|
||||||
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
try
|
||||||
var details = mscsC.getIssueDetails(projectId);
|
|
||||||
if (!string.IsNullOrEmpty(details))
|
|
||||||
{
|
{
|
||||||
Model.SGGLDB db = Funs.DB;
|
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
||||||
var q = from x in db.CLGL_PickMaterialRecord where x.ProjectId == projectId.ToString() select x;
|
var details = mscsC.getIssueDetails(projectId);
|
||||||
if (q.Count() > 0)
|
if (!string.IsNullOrEmpty(details))
|
||||||
{
|
{
|
||||||
db.CLGL_PickMaterialRecord.DeleteAllOnSubmit(q);
|
Model.SGGLDB db = Funs.DB;
|
||||||
db.SubmitChanges();
|
var q = from x in db.CLGL_PickMaterialRecord where x.ProjectId == projectId.ToString() select x;
|
||||||
}
|
if (q.Count() > 0)
|
||||||
JArray arr = JArray.Parse(details);
|
{
|
||||||
foreach (var item in arr)
|
db.CLGL_PickMaterialRecord.DeleteAllOnSubmit(q);
|
||||||
{
|
db.SubmitChanges();
|
||||||
Model.CLGL_PickMaterialRecord pickMaterialRecord = new Model.CLGL_PickMaterialRecord();
|
}
|
||||||
pickMaterialRecord.IDGUID = item["IDGUID"].ToString();
|
JArray arr = JArray.Parse(details);
|
||||||
pickMaterialRecord.ProjectId = projectId.ToString();
|
foreach (var item in arr)
|
||||||
pickMaterialRecord.PickCode = item["领料单号"].ToString();
|
{
|
||||||
pickMaterialRecord.PickDate = Funs.GetNewDateTime(item["领料时间"].ToString());
|
Model.CLGL_PickMaterialRecord pickMaterialRecord = new Model.CLGL_PickMaterialRecord();
|
||||||
pickMaterialRecord.PickUnit = item["领料单位"].ToString();
|
pickMaterialRecord.IDGUID = item["IDGUID"].ToString();
|
||||||
pickMaterialRecord.PickLimitDate = Funs.GetNewDateTime(item["领料截止时间"].ToString());
|
pickMaterialRecord.ProjectId = projectId.ToString();
|
||||||
pickMaterialRecord.State = item["领料单审批状态代码"].ToString();
|
pickMaterialRecord.PickCode = item["领料单号"].ToString();
|
||||||
pickMaterialRecord.ISGUID = item["ISGUID"].ToString();
|
pickMaterialRecord.PickDate = Funs.GetNewDateTime(item["领料时间"].ToString());
|
||||||
pickMaterialRecord.PLGUID = item["PLGUID"].ToString();
|
pickMaterialRecord.PickUnit = item["领料单位"].ToString();
|
||||||
pickMaterialRecord.Major = item["专业"].ToString();
|
pickMaterialRecord.PickLimitDate = Funs.GetNewDateTime(item["领料截止时间"].ToString());
|
||||||
pickMaterialRecord.PSGUID = item["PSGUID"].ToString();
|
pickMaterialRecord.State = item["领料单审批状态代码"].ToString();
|
||||||
pickMaterialRecord.MaterialCode = item["材料编码"].ToString();
|
pickMaterialRecord.ISGUID = item["ISGUID"].ToString();
|
||||||
pickMaterialRecord.TagNo = item["位号"].ToString();
|
pickMaterialRecord.PLGUID = item["PLGUID"].ToString();
|
||||||
pickMaterialRecord.ClaimQuantity = item["申领量"].ToString();
|
pickMaterialRecord.Major = item["专业"].ToString();
|
||||||
pickMaterialRecord.ApproveQuantity = item["批准量"].ToString();
|
pickMaterialRecord.PSGUID = item["PSGUID"].ToString();
|
||||||
pickMaterialRecord.ActualQuantity = item["实发量"].ToString();
|
pickMaterialRecord.MaterialCode = item["材料编码"].ToString();
|
||||||
pickMaterialRecord.DHGUID = item["DHGUID"].ToString();
|
pickMaterialRecord.TagNo = item["位号"].ToString();
|
||||||
pickMaterialRecord.Remark = item["发料备注"].ToString();
|
pickMaterialRecord.ClaimQuantity = item["申领量"].ToString();
|
||||||
pickMaterialRecord.DeviceCode = item["装置号"].ToString();
|
pickMaterialRecord.ApproveQuantity = item["批准量"].ToString();
|
||||||
pickMaterialRecord.MainItemCode = item["主项号"].ToString();
|
pickMaterialRecord.ActualQuantity = item["实发量"].ToString();
|
||||||
db.CLGL_PickMaterialRecord.InsertOnSubmit(pickMaterialRecord);
|
pickMaterialRecord.DHGUID = item["DHGUID"].ToString();
|
||||||
db.SubmitChanges();
|
pickMaterialRecord.Remark = item["发料备注"].ToString();
|
||||||
|
pickMaterialRecord.DeviceCode = item["装置号"].ToString();
|
||||||
|
pickMaterialRecord.MainItemCode = item["主项号"].ToString();
|
||||||
|
db.CLGL_PickMaterialRecord.InsertOnSubmit(pickMaterialRecord);
|
||||||
|
db.SubmitChanges();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrLogInfo.WriteLog(ex, "材料管理接口定时器", "MCSWebService.getIssueDetails");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void getPartNoInfo(long projectId)
|
public static void getPartNoInfo(long projectId)
|
||||||
{
|
{
|
||||||
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
try
|
||||||
var details = mscsC.getPartNoInfo(projectId);
|
|
||||||
if (!string.IsNullOrEmpty(details))
|
|
||||||
{
|
{
|
||||||
Model.SGGLDB db = Funs.DB;
|
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
||||||
var q = from x in db.CLGL_Material where x.ProjectId == projectId.ToString() select x;
|
var details = mscsC.getPartNoInfo(projectId);
|
||||||
if (q.Count() > 0)
|
if (!string.IsNullOrEmpty(details))
|
||||||
{
|
{
|
||||||
db.CLGL_Material.DeleteAllOnSubmit(q);
|
Model.SGGLDB db = Funs.DB;
|
||||||
db.SubmitChanges();
|
var q = from x in db.CLGL_Material where x.ProjectId == projectId.ToString() select x;
|
||||||
}
|
if (q.Count() > 0)
|
||||||
JArray arr = JArray.Parse(details);
|
{
|
||||||
foreach (var item in arr)
|
db.CLGL_Material.DeleteAllOnSubmit(q);
|
||||||
{
|
db.SubmitChanges();
|
||||||
Model.CLGL_Material material = new Model.CLGL_Material();
|
}
|
||||||
material.Id = SQLHelper.GetNewID();
|
JArray arr = JArray.Parse(details);
|
||||||
material.ProjectId = projectId.ToString();
|
foreach (var item in arr)
|
||||||
material.MaterialCode = item["材料编码"].ToString();
|
{
|
||||||
material.TagNo = item["位号"].ToString();
|
Model.CLGL_Material material = new Model.CLGL_Material();
|
||||||
material.MaterialName = item["材料名称"].ToString();
|
material.Id = SQLHelper.GetNewID();
|
||||||
material.Def = item["规格描述"].ToString();
|
material.ProjectId = projectId.ToString();
|
||||||
material.Unit = item["计量单位"].ToString();
|
material.MaterialCode = item["材料编码"].ToString();
|
||||||
db.CLGL_Material.InsertOnSubmit(material);
|
material.TagNo = item["位号"].ToString();
|
||||||
db.SubmitChanges();
|
material.MaterialName = item["材料名称"].ToString();
|
||||||
|
material.Def = item["规格描述"].ToString();
|
||||||
|
material.Unit = item["计量单位"].ToString();
|
||||||
|
db.CLGL_Material.InsertOnSubmit(material);
|
||||||
|
db.SubmitChanges();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrLogInfo.WriteLog(ex, "材料管理接口定时器", "MCSWebService.getPartNoInfo");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void getShelvesNo(long projectId)
|
public static void getShelvesNo(long projectId)
|
||||||
{
|
{
|
||||||
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
try
|
||||||
var details = mscsC.getShelvesNo(projectId);
|
|
||||||
if (!string.IsNullOrEmpty(details))
|
|
||||||
{
|
{
|
||||||
Model.SGGLDB db = Funs.DB;
|
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
||||||
var q = from x in db.CLGL_GoodsShelves where x.ProjectId == projectId.ToString() select x;
|
var details = mscsC.getShelvesNo(projectId);
|
||||||
if (q.Count() > 0)
|
if (!string.IsNullOrEmpty(details))
|
||||||
{
|
{
|
||||||
db.CLGL_GoodsShelves.DeleteAllOnSubmit(q);
|
Model.SGGLDB db = Funs.DB;
|
||||||
db.SubmitChanges();
|
var q = from x in db.CLGL_GoodsShelves where x.ProjectId == projectId.ToString() select x;
|
||||||
}
|
if (q.Count() > 0)
|
||||||
JArray arr = JArray.Parse(details);
|
{
|
||||||
foreach (var item in arr)
|
db.CLGL_GoodsShelves.DeleteAllOnSubmit(q);
|
||||||
{
|
db.SubmitChanges();
|
||||||
Model.CLGL_GoodsShelves goodsShelves = new Model.CLGL_GoodsShelves();
|
}
|
||||||
goodsShelves.DHGUID = item["DHGUID"].ToString();
|
JArray arr = JArray.Parse(details);
|
||||||
goodsShelves.ProjectId = projectId.ToString();
|
foreach (var item in arr)
|
||||||
goodsShelves.GoodsShelvesCode = item["货架编号"].ToString();
|
{
|
||||||
goodsShelves.Def = item["货架编号描述"].ToString();
|
Model.CLGL_GoodsShelves goodsShelves = new Model.CLGL_GoodsShelves();
|
||||||
db.CLGL_GoodsShelves.InsertOnSubmit(goodsShelves);
|
goodsShelves.DHGUID = item["DHGUID"].ToString();
|
||||||
db.SubmitChanges();
|
goodsShelves.ProjectId = projectId.ToString();
|
||||||
|
goodsShelves.GoodsShelvesCode = item["货架编号"].ToString();
|
||||||
|
goodsShelves.Def = item["货架编号描述"].ToString();
|
||||||
|
db.CLGL_GoodsShelves.InsertOnSubmit(goodsShelves);
|
||||||
|
db.SubmitChanges();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrLogInfo.WriteLog(ex, "材料管理接口定时器", "MCSWebService.getPartNoInfo");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void getSubcontractor(long projectId)
|
public static void getSubcontractor(long projectId)
|
||||||
{
|
{
|
||||||
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
try
|
||||||
var details = mscsC.getSubcontractor(projectId);
|
|
||||||
if (!string.IsNullOrEmpty(details))
|
|
||||||
{
|
{
|
||||||
Model.SGGLDB db = Funs.DB;
|
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
||||||
var q = from x in db.CLGL_SubUnit where x.ProjectId == projectId.ToString() select x;
|
var details = mscsC.getSubcontractor(projectId);
|
||||||
if (q.Count() > 0)
|
if (!string.IsNullOrEmpty(details))
|
||||||
{
|
{
|
||||||
db.CLGL_SubUnit.DeleteAllOnSubmit(q);
|
Model.SGGLDB db = Funs.DB;
|
||||||
db.SubmitChanges();
|
var q = from x in db.CLGL_SubUnit where x.ProjectId == projectId.ToString() select x;
|
||||||
}
|
if (q.Count() > 0)
|
||||||
JArray arr = JArray.Parse(details);
|
{
|
||||||
foreach (var item in arr)
|
db.CLGL_SubUnit.DeleteAllOnSubmit(q);
|
||||||
{
|
db.SubmitChanges();
|
||||||
Model.CLGL_SubUnit subUnit = new Model.CLGL_SubUnit();
|
}
|
||||||
subUnit.Id = SQLHelper.GetNewID();
|
JArray arr = JArray.Parse(details);
|
||||||
subUnit.ProjectId = projectId.ToString();
|
foreach (var item in arr)
|
||||||
subUnit.SubUnitCode = item["分包商编号"].ToString();
|
{
|
||||||
subUnit.SubUnitName = item["分包商名称"].ToString();
|
Model.CLGL_SubUnit subUnit = new Model.CLGL_SubUnit();
|
||||||
db.CLGL_SubUnit.InsertOnSubmit(subUnit);
|
subUnit.Id = SQLHelper.GetNewID();
|
||||||
db.SubmitChanges();
|
subUnit.ProjectId = projectId.ToString();
|
||||||
|
subUnit.SubUnitCode = item["分包商编号"].ToString();
|
||||||
|
subUnit.SubUnitName = item["分包商名称"].ToString();
|
||||||
|
db.CLGL_SubUnit.InsertOnSubmit(subUnit);
|
||||||
|
db.SubmitChanges();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrLogInfo.WriteLog(ex, "材料管理接口定时器", "MCSWebService.getSubcontractor");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void getVendor()
|
public static void getVendor()
|
||||||
{
|
{
|
||||||
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
try
|
||||||
var details = mscsC.getVendor();
|
|
||||||
if (!string.IsNullOrEmpty(details))
|
|
||||||
{
|
{
|
||||||
Model.SGGLDB db = Funs.DB;
|
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
||||||
var q = from x in db.CLGL_Supplier select x;
|
var details = mscsC.getVendor();
|
||||||
if (q.Count() > 0)
|
if (!string.IsNullOrEmpty(details))
|
||||||
{
|
{
|
||||||
db.CLGL_Supplier.DeleteAllOnSubmit(q);
|
Model.SGGLDB db = Funs.DB;
|
||||||
db.SubmitChanges();
|
var q = from x in db.CLGL_Supplier select x;
|
||||||
}
|
if (q.Count() > 0)
|
||||||
JArray arr = JArray.Parse(details);
|
{
|
||||||
foreach (var item in arr)
|
db.CLGL_Supplier.DeleteAllOnSubmit(q);
|
||||||
{
|
db.SubmitChanges();
|
||||||
Model.CLGL_Supplier supplier = new Model.CLGL_Supplier();
|
}
|
||||||
supplier.Id = SQLHelper.GetNewID();
|
JArray arr = JArray.Parse(details);
|
||||||
supplier.SupplierName = item["企业中文名称"].ToString();
|
foreach (var item in arr)
|
||||||
supplier.SupplierCode = item["厂商企标ID"].ToString();
|
{
|
||||||
db.CLGL_Supplier.InsertOnSubmit(supplier);
|
Model.CLGL_Supplier supplier = new Model.CLGL_Supplier();
|
||||||
db.SubmitChanges();
|
supplier.Id = SQLHelper.GetNewID();
|
||||||
|
supplier.SupplierName = item["企业中文名称"].ToString();
|
||||||
|
supplier.SupplierCode = item["厂商企标ID"].ToString();
|
||||||
|
db.CLGL_Supplier.InsertOnSubmit(supplier);
|
||||||
|
db.SubmitChanges();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrLogInfo.WriteLog(ex, "材料管理接口定时器", "MCSWebService.getVendor");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void getReqDetails(long projectId)
|
public static void getReqDetails(long projectId)
|
||||||
{
|
{
|
||||||
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
try
|
||||||
var details = mscsC.getReqDetails(projectId);
|
|
||||||
if (!string.IsNullOrEmpty(details))
|
|
||||||
{
|
{
|
||||||
Model.SGGLDB db = Funs.DB;
|
MCSService.WebService1SoapClient mscsC = new MCSService.WebService1SoapClient();
|
||||||
var q = from x in db.CLGL_PurchaseRequisition where x.ProjectId == projectId.ToString() select x;
|
var details = mscsC.getReqDetails(projectId);
|
||||||
if (q.Count() > 0)
|
if (!string.IsNullOrEmpty(details))
|
||||||
{
|
{
|
||||||
db.CLGL_PurchaseRequisition.DeleteAllOnSubmit(q);
|
Model.SGGLDB db = Funs.DB;
|
||||||
db.SubmitChanges();
|
var q = from x in db.CLGL_PurchaseRequisition where x.ProjectId == projectId.ToString() select x;
|
||||||
}
|
if (q.Count() > 0)
|
||||||
JArray arr = JArray.Parse(details);
|
{
|
||||||
foreach (var item in arr)
|
db.CLGL_PurchaseRequisition.DeleteAllOnSubmit(q);
|
||||||
{
|
db.SubmitChanges();
|
||||||
Model.CLGL_PurchaseRequisition purchaseRequisition = new Model.CLGL_PurchaseRequisition();
|
}
|
||||||
purchaseRequisition.Id = SQLHelper.GetNewID();
|
JArray arr = JArray.Parse(details);
|
||||||
purchaseRequisition.RSGUID = item["RSGUID"].ToString();
|
foreach (var item in arr)
|
||||||
purchaseRequisition.ProjectId = projectId.ToString();
|
{
|
||||||
purchaseRequisition.PurchaseRequisitionCode = item["请购单号"].ToString();
|
Model.CLGL_PurchaseRequisition purchaseRequisition = new Model.CLGL_PurchaseRequisition();
|
||||||
purchaseRequisition.PurchaseRequisitionName = item["请购单名称"].ToString();
|
purchaseRequisition.Id = SQLHelper.GetNewID();
|
||||||
purchaseRequisition.SiteRequisition = item["现场请购"].ToString();
|
purchaseRequisition.RSGUID = item["RSGUID"].ToString();
|
||||||
purchaseRequisition.Major = item["专业名称"].ToString();
|
purchaseRequisition.ProjectId = projectId.ToString();
|
||||||
purchaseRequisition.RDGUID = item["RDGUID"].ToString();
|
purchaseRequisition.PurchaseRequisitionCode = item["请购单号"].ToString();
|
||||||
purchaseRequisition.MaterialClass = item["材料等级"].ToString();
|
purchaseRequisition.PurchaseRequisitionName = item["请购单名称"].ToString();
|
||||||
purchaseRequisition.MaterialCode = item["材料编码"].ToString();
|
purchaseRequisition.SiteRequisition = item["现场请购"].ToString();
|
||||||
purchaseRequisition.TagNo = item["位号"].ToString();
|
purchaseRequisition.Major = item["专业名称"].ToString();
|
||||||
purchaseRequisition.DesignQuantity = item["设计量"].ToString();
|
purchaseRequisition.RDGUID = item["RDGUID"].ToString();
|
||||||
purchaseRequisition.SurplusQuantity = item["余量"].ToString();
|
purchaseRequisition.MaterialClass = item["材料等级"].ToString();
|
||||||
purchaseRequisition.RequisitionQuantity = item["请购量"].ToString();
|
purchaseRequisition.MaterialCode = item["材料编码"].ToString();
|
||||||
purchaseRequisition.Def = item["请购说明"].ToString();
|
purchaseRequisition.TagNo = item["位号"].ToString();
|
||||||
purchaseRequisition.DeviceCode = item["装置号"].ToString();
|
purchaseRequisition.DesignQuantity = item["设计量"].ToString();
|
||||||
purchaseRequisition.MainItemCode = item["主项号"].ToString();
|
purchaseRequisition.SurplusQuantity = item["余量"].ToString();
|
||||||
purchaseRequisition.MaterialUse = item["材料用途"].ToString();
|
purchaseRequisition.RequisitionQuantity = item["请购量"].ToString();
|
||||||
purchaseRequisition.Remark = item["采购说明"].ToString();
|
purchaseRequisition.Def = item["请购说明"].ToString();
|
||||||
|
purchaseRequisition.DeviceCode = item["装置号"].ToString();
|
||||||
|
purchaseRequisition.MainItemCode = item["主项号"].ToString();
|
||||||
|
purchaseRequisition.MaterialUse = item["材料用途"].ToString();
|
||||||
|
purchaseRequisition.Remark = item["采购说明"].ToString();
|
||||||
|
|
||||||
db.CLGL_PurchaseRequisition.InsertOnSubmit(purchaseRequisition);
|
db.CLGL_PurchaseRequisition.InsertOnSubmit(purchaseRequisition);
|
||||||
db.SubmitChanges();
|
db.SubmitChanges();
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
ErrLogInfo.WriteLog(ex, "材料管理接口定时器", "MCSWebService.getVendor");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -42,6 +42,8 @@
|
||||||
{
|
{
|
||||||
BLL.RealNameMonitorService.StartMonitor();
|
BLL.RealNameMonitorService.StartMonitor();
|
||||||
}
|
}
|
||||||
|
BLL.RealNameMonitorService.StartInOutMonitor();
|
||||||
|
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue