|
|
|
@ -0,0 +1,104 @@ |
|
|
|
using ICSSoft.FromERP.Model; |
|
|
|
using Newtonsoft.Json; |
|
|
|
using Quartz; |
|
|
|
using System; |
|
|
|
using System.Collections.Generic; |
|
|
|
using System.Data; |
|
|
|
using System.Linq; |
|
|
|
using System.Text; |
|
|
|
using System.Threading.Tasks; |
|
|
|
|
|
|
|
namespace ICSSoft.FromERP |
|
|
|
{ |
|
|
|
/// <summary>
|
|
|
|
/// 数采上传(金杨)
|
|
|
|
/// </summary>
|
|
|
|
public class SyncCas_Jinyang : IJob |
|
|
|
{ |
|
|
|
private static object key = new object(); |
|
|
|
private static log4net.ILog log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); |
|
|
|
public void Execute(IJobExecutionContext context) |
|
|
|
{ |
|
|
|
try |
|
|
|
{ |
|
|
|
lock (key) |
|
|
|
{ |
|
|
|
log.Info("开始……………………………………………………………………"); |
|
|
|
Execute(); |
|
|
|
log.Info("结束……………………………………………………………………"); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) |
|
|
|
{ |
|
|
|
log.Error(ex.ToString()); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public void Execute() |
|
|
|
{ |
|
|
|
try |
|
|
|
{ |
|
|
|
string conStr = ICSHelper.GetConnectString(); |
|
|
|
string Namespace = this.GetType().Namespace; |
|
|
|
//string Class = this.GetType().Name;
|
|
|
|
DataTable dt = ICSHelper.GetERPDB(conStr); |
|
|
|
foreach (DataRow dr in dt.Rows) |
|
|
|
{ |
|
|
|
var dtNowBegin = new DateTime(2000, 1, 1, 0, 0, 0);//默认开始时间
|
|
|
|
var dtNow = DateTime.Now; |
|
|
|
string erpName = ICSHelper.GetConfigString()["ERPDB"]; |
|
|
|
string TenantId = dr["TenantId"].ToString();//mes 组织
|
|
|
|
string TenantCode = dr["TenantCode"].ToString(); |
|
|
|
string ErpId = dr["ErpID"].ToString(); //erpID
|
|
|
|
string Class = this.GetType().Name + TenantCode; |
|
|
|
erpName = string.Format(erpName, TenantId); |
|
|
|
|
|
|
|
string sql0 = " SELECT top 1 ModifyDate FROM ICSERPTime where ClassName='" + Class + "'"; |
|
|
|
var lastDate = ICSHelper.ExecuteScalar(conStr, sql0).ToDateOrNull(); |
|
|
|
if (!lastDate.HasValue) |
|
|
|
{ |
|
|
|
lastDate = dtNowBegin; |
|
|
|
} |
|
|
|
|
|
|
|
string sql = @" select '" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "' as MTIME into #TempVendor "; |
|
|
|
sql = ICSHelper.Time(Namespace, Class, TenantId, sql, "#TempVendor"); |
|
|
|
sql += "DROP TABLE #TempVendor"; |
|
|
|
ICSHelper.ExecuteDate(conStr, sql); |
|
|
|
|
|
|
|
|
|
|
|
var input = new CapInputDto(); |
|
|
|
input.WorkshopID = ""; |
|
|
|
input.EquipmentID = ""; |
|
|
|
input.ProductNo = ""; |
|
|
|
input.LotNo = ""; |
|
|
|
input.CollectionTime = ""; |
|
|
|
input.ParamValue_Resistance = 12; |
|
|
|
input.ParamValue_Height = 12; |
|
|
|
input.Msg = ""; |
|
|
|
|
|
|
|
var inputObj = JsonConvert.SerializeObject(input); |
|
|
|
string url = ICSHelper.GetConfigString()["WeiMasErpUrl"] + @"/BasicAssistingService/FromWeMec/APIVenderToMES"; |
|
|
|
|
|
|
|
var result = HttpHelper.HttpClientPost<ResponseInfoDto>(url, inputObj).Result; |
|
|
|
if (result.Result == "OK") |
|
|
|
{ |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// insertSql += "DROP TABLE #tempFromErp4Vendor";
|
|
|
|
//ICSHelper.ExecuteDate(conStr, insertSql);
|
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
|
throw new Exception(result.Result); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
catch (Exception ex) |
|
|
|
{ |
|
|
|
log.Error(ex.ToString()); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
xusc
3 weeks ago