using System.ComponentModel;
|
using Kingdee.BOS.Contracts;
|
using Kingdee.BOS;
|
using Kingdee.BOS.Core;
|
using Kingdee.BOS.ServiceHelper;
|
using System.Data;
|
|
using Newtonsoft.Json.Linq;
|
using System;
|
using Kingdee.BOS.Util;
|
using System.Linq;
|
using ZD.Cloud.WebApi;
|
using Demo.Model.Model;
|
using Demo.Model.Model.PODemandPlan;
|
|
using System.Collections.Generic;
|
using ZD.Share.Common;
|
using ZD.Cloud.Logger;
|
using System.Diagnostics;
|
using Demo.BillView.PRD;
|
|
namespace Demo.TimedTaskPlugIn.PRD
|
{
|
[Description("提料计划信息表信息同步")]
|
[HotUpdate]
|
public class TLPlanMessege : Kingdee.BOS.Contracts.IScheduleService
|
{
|
|
public Context Context;
|
public void Run(Context ctx, Schedule schedule)
|
{
|
try
|
{
|
string sql = string.Format(@"
|
/*dialect*/
|
select DISTINCT t1.FPURCHASEORGID AS FORGID,t4.FNUMBER as FORGNUMBER,t1.FSUPPLIERID,T5.FNUMBER AS FSUPPLIERNUMBER,t2.FMATERIALID ,T6.FNUMBER AS FMATERIALNUMBER from T_PUR_POORDER t1
|
join T_PUR_POORDERENTRY t2 on t1.FID = t2.FID
|
LEFT join (
|
SELECT distinct FORGID, FSUPPLIERID,FMATERIALID FROM
|
T_PRD_TLPlanConfig T1
|
JOIN T_PRD_TLPlanConfigEntry T2 ON T1.FID = T2.FID
|
)T3 ON t1.FPURCHASEORGID = T3.FORGID AND t1.FSUPPLIERID = T3.FSUPPLIERID AND t2.FMATERIALID = T3.FMATERIALID
|
JOIN T_ORG_Organizations t4 on t1.FPURCHASEORGID = t4.FORGID
|
JOIN t_BD_Supplier t5 on t1.FSUPPLIERID = t5.FSUPPLIERID
|
JOIN T_BD_MATERIAL t6 on t2.FMATERIALID = t6.FMATERIALID
|
where DATEDIFF(d,t1.FAPPROVEDATE,GETDATE())<=5
|
AND ISNULL(T3.FORGID,0) = 0
|
");
|
List<TLPlanConfigModel> TLPlanConfigModel = DBServiceHelper.ExecuteDataSet(ctx, sql).ToModelList<TLPlanConfigModel>();
|
if (TLPlanConfigModel.Count > 0)
|
{
|
var _TLPlanConfigModel = TLPlanConfigModel.GroupBy(x => new { x.FORGNUMBER }).Select((x => new TLPlanConfigModel { FORGNUMBER = x.Key.FORGNUMBER })).ToList();
|
foreach (var TLPlanConfig in _TLPlanConfigModel)
|
{
|
JObject jsonRoot = new JObject();
|
JObject model = new JObject();
|
model.Add("FORGID", new JObject() { ["Fnumber"] = TLPlanConfig.FORGNUMBER });//组织
|
var DetailModel = TLPlanConfigModel.Where(x => x.FORGNUMBER == TLPlanConfig.FORGNUMBER).ToList();
|
JArray Entry = new JArray();
|
foreach (var item in DetailModel)
|
{
|
JObject jsonEntry = new JObject();
|
jsonEntry.Add("FSUPPLIERID", new JObject() { ["Fnumber"] = item.FSUPPLIERNUMBER });
|
jsonEntry.Add("FMATERIALID", new JObject() { ["Fnumber"] = item.FMATERIALNUMBER });
|
jsonEntry.Add("FLeadtime", 2);
|
jsonEntry.Add("FLeadTtime2", 1);
|
jsonEntry.Add("FDeliveryDaysKZ", 3);
|
Entry.Add(jsonEntry);
|
}
|
model.Add("FEntity", Entry);
|
jsonRoot.Add("Model", model);
|
CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
|
var result = cloudClient.Save("BSV_TLPlanConfig", jsonRoot.ToString());
|
|
JObject saveObj = JObject.Parse(result);
|
string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
|
if (saveIsSuc != "TRUE")
|
{
|
LogService.Write(saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString());
|
}
|
}
|
|
}
|
}
|
catch (System.Exception ex)
|
{
|
LogService.Write(ex.Message.ToString()); ;
|
}
|
}
|
}
|
}
|
