using System;
|
using System.Collections.Generic;
|
using System.ComponentModel;
|
using System.Data;
|
using Kingdee.BOS.Core.DynamicForm;
|
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
|
using Kingdee.BOS.ServiceHelper;
|
using Newtonsoft.Json.Linq;
|
|
using ZD.Cloud.WebApi;
|
using Demo.Model.Model;
|
using System.Linq;
|
using Kingdee.BOS.Core.DynamicForm.PlugIn;
|
|
namespace Demo.BillView.PRD
|
{
|
/// <summary>
|
/// 生产用料清单提交 刷新日计划用料清单数据
|
/// </summary>
|
[Description("生产用料清单提交服务插件")]
|
[Kingdee.BOS.Util.HotUpdate]
|
public class Pro_PPBomSubmit : AbstractOperationServicePlugIn
|
{
|
CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
|
Dictionary<string, string> dictionary = new Dictionary<string, string>();
|
public override void OnPrepareOperationServiceOption(OnPrepareOperationServiceEventArgs e)
|
{
|
base.OnPrepareOperationServiceOption(e);
|
|
//为了在BeginOperationTransaction里检查数据抛出异常时
|
//只回滚当前单据的事务，这里设置为不支持批量事务，这样BOS会
|
//循环为每一张单据创建事务调用操作
|
e.SupportTransaction = true;
|
e.SurportBatchTransaction = false;
|
}
|
public override void OnPreparePropertys(PreparePropertysEventArgs e)
|
{
|
base.OnPreparePropertys(e);
|
e.FieldKeys.Add("FID");
|
e.FieldKeys.Add("FBillNo");
|
}
|
public override void AfterExecuteOperationTransaction(AfterExecuteOperationTransaction e)
|
{
|
base.AfterExecuteOperationTransaction(e);
|
try
|
{
|
string sql = "";
|
var fBillNo = "";
|
foreach (var select in e.SelectedRows)
|
{
|
fBillNo = select["Billno"].ToString();
|
if (dictionary.ContainsKey(fBillNo))
|
continue;
|
//变更 先去删除调整过的数据
|
sql = $"/*dialect*/ exec deleteDayPlanPpbomBillSub '{fBillNo}'";
|
DBServiceHelper.Execute(Context, sql);
|
sql = string.Format(@"
|
/*dialect*/
|
select t1.FID,t1.FSEQ FDayPlanFSEQ,t1.FEntryID,T2.FBILLNO AS FDayPlanFBILLNO,t3.FMATERIALID,T5.FNUMBER,t1.FHMASTERDATE,t1.FHQTY,t4.FMATERIALID FMATERIALID2,T6.FNUMBER FNUMBER2,T7.FNUMBER FUNITNUMBER,t4.FNumerator,t4.FDenominator,convert(decimal(18,2),(t4.FMustQty/T3.FQTY) *t1.FHQTY) FHQtyMust,T4.FUnitID,t8.FNUMBER FUNITNUMBER2,T3.FID FPPBOM,T4.FENTRYID FPPBOMENTRYID,isnull(T9.FBillNo,'')FBillNo,t10.FNUMBER FORGNUMBER,t11.FNUMBER FHSOURCENUMBER,FSCRAPRATE,t4.FFIXSCRAPQTY,T9.FID AS DayPlanFID,t2.FSCORDERNO,
|
t3.FMOENTRYID,t3.FBILLNO FPPBOMBILLNO,T4.FSEQ,tc.FOWNERTYPEID,tc.FOWNERID,tc.FEntrustPickOrgId,torg.FNUMBER as FORGNUMBER,t3.FMOID,Tc.FIssueType,t4.FMaterialType,t12.FEntryID
|
as FDayPlanPpbomFEntryId
|
FROM Sc_WorkBillSortBillSub t1
|
JOIN Sc_WorkBillSortBillMAIN t2 on t1.FID = t2.FID
|
JOIN T_PRD_PPBOM T3 on T2.FPRDMOMAINID=t3.FMOID AND T2.FPRDMOENTYID=T3.FMOENTRYID
|
JOIN T_PRD_PPBOMENTRY T4 ON T3.FID=T4.FID
|
JOIN T_PRD_PPBOMENTRY_C Tc ON T4.FENTRYID=Tc.FENTRYID
|
join T_ORG_Organizations torg ON tc.FOWNERID = torg.FORGID
|
JOIN T_BD_MATERIAL T5 ON T3.FMATERIALID=T5.FMATERIALID
|
JOIN T_BD_MATERIAL T6 ON T4.FMATERIALID=T6.FMATERIALID
|
LEFT JOIN T_BD_UNIT T7 ON T3.FUNITID = T7.FUNITID
|
LEFT JOIN T_BD_UNIT T8 ON T4.FUNITID = T8.FUNITID
|
LEFT JOIN Sc_DayPlanPPBomBillMain T9 ON T1.FEntryID=T9.FDayPlanFID
|
LEFT join Sc_DayPlanPPBomBillSub t12 on t9.FID=t12.FID and T4.FENTRYID=t12.FHPPBomEntryID
|
LEFT join T_ORG_Organizations t10 on t2.FHPRDORGID = t10.FORGID
|
LEFT join T_ENG_WORKCENTER t11 on t2.FHSOURCEID = t11.FID
|
WHERE T4.FMustQty>0
|
and T3.FBILLNO='{0}'
|
", fBillNo);
|
//LogHelper.Info("生成日计划用料清单准备数据sql:" + sql);
|
DataSet ds = DBServiceHelper.ExecuteDataSet(Context, sql);
|
DataTable dt = ds.Tables[0];
|
List<DayPlanMaterial> DayPlanMaterial = new List<DayPlanMaterial>();
|
if (dt.Rows.Count > 0)
|
{
|
foreach (DataRow dr in dt.Rows)
|
{
|
DayPlanMaterial.Add(new Demo.Model.Model.DayPlanMaterial
|
{
|
FID = dr["DayPlanFID"].ToString(),
|
FEntryID = dr["FEntryID"].ToString(),
|
FHDate = DateTime.Now.ToString(),
|
FOrgId = dr["FORGNUMBER"].ToString(),
|
FHMaterID = dr["FNUMBER"].ToString(),
|
FHWorkDate = dr["FHMASTERDATE"].ToString(),
|
FHQty = dr["FHQTY"].ToString(),
|
FHUnitID = dr["FUNITNUMBER"].ToString(),
|
FDayPlanFID = dr["FEntryID"].ToString(),
|
FHMaterSubID = dr["FNUMBER2"].ToString(),
|
FHUnitSubID = dr["FUNITNUMBER2"].ToString(),
|
FHQtyMust = dr["FHQtyMust"].ToString(),
|
FHQtySub = dr["FHQtyMust"].ToString(),
|
FHPPBomInterID = dr["FPPBOM"].ToString(),
|
FHPPBomEntryID = dr["FPPBOMENTRYID"].ToString(),
|
FHSourceID = dr["FHSOURCENUMBER"].ToString(),
|
FNumerator = dr["FNumerator"].ToString(),
|
FDenominator = dr["FDenominator"].ToString(),
|
FFIXSCRAPQTY = dr["FFIXSCRAPQTY"].ToString(),
|
FHQtyScrap = dr["FSCRAPRATE"].ToString(),
|
FMOBILLNO = dr["FSCORDERNO"].ToString(),
|
FMOENTRYID = dr["FMOENTRYID"].ToString(),
|
FPPBOMBILLNO = dr["FPPBOMBILLNO"].ToString(),
|
FPPBOMFSEQ = dr["FSEQ"].ToString(),
|
FOwnerTypeId = dr["FOWNERTYPEID"].ToString(),
|
FOwnerID = dr["FORGNUMBER"].ToString(),
|
FEntrustPickOrgId = dr["FORGNUMBER"].ToString(),
|
FMOID = dr["FMOID"].ToString(),
|
FIssueType = dr["FIssueType"].ToString(),
|
FMaterialType = dr["FMaterialType"].ToString(),
|
FDayPlanFSEQ = dr["FDayPlanFSEQ"].ToString(),
|
FDayPlanFBILLNO = dr["FDayPlanFBILLNO"].ToString(),
|
FDayPlanPpbomFEntryId = dr["FDayPlanPpbomFEntryId"].ToString(),
|
});
|
}
|
var fidList = DayPlanMaterial.Select(x => x.FEntryID).Distinct().ToList();
|
int i = 1;
|
JArray Fentity = new JArray();
|
foreach (var item in fidList)
|
{
|
var _DayPlanMaterial = DayPlanMaterial.Where(x => x.FEntryID == item).ToList();
|
JObject model = new JObject();
|
if (!string.IsNullOrEmpty(_DayPlanMaterial[0].FID))
|
model.Add("FID", _DayPlanMaterial[0].FID);
|
model.Add("FHDate", DateTime.Now);
|
model.Add("FOrgId", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FOrgId });//发料组织
|
model.Add("FHMaterID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHMaterID });//物料
|
model.Add("FHWorkDate", _DayPlanMaterial[0].FHWorkDate);//日工单日期 FHWorkDate
|
model.Add("FHQty", _DayPlanMaterial[0].FHQty);//主产品数量：FHQty
|
model.Add("FHUnitID", new JObject() { ["Fnumber"] = _DayPlanMaterial[0].FHUnitID });//单位：FHUnitID
|
model.Add("FDayPlanFID", _DayPlanMaterial[0].FDayPlanFID);//日计划工单内码
|
model.Add("FDayPlanFSEQ", _DayPlanMaterial[0].FDayPlanFSEQ);//日计划工单明细行号
|
model.Add("FDayPlanFBillNo", _DayPlanMaterial[0].FDayPlanFBILLNO);//日计划工单单据编号
|
JArray Entry = new JArray();
|
foreach (var _item in _DayPlanMaterial)
|
{
|
JObject ModelEnty = new JObject();
|
ModelEnty.Add("FHMaterSubID", new JObject() { ["Fnumber"] = _item.FHMaterSubID });//子物料FHMaterSubID
|
ModelEnty.Add("FHUnitSubID", new JObject() { ["Fnumber"] = _item.FHUnitSubID });//单位FHUnitSubID
|
ModelEnty.Add("FHQtyMust", _item.FHQtyMust);//应发数量FHQtyMust
|
ModelEnty.Add("FHQtySub", _item.FHQtySub);//数量FHQtySub
|
ModelEnty.Add("FHPPBomInterID", _item.FHPPBomInterID);//用料清单主内码FHPPBomInterID
|
ModelEnty.Add("FHPPBomEntryID", _item.FHPPBomEntryID);//用料清单子内码FHPPBomEntryID
|
ModelEnty.Add("FHSourceID", new JObject() { ["Fnumber"] = _item.FHSourceID });//生产资源FHSourceID
|
ModelEnty.Add("FNumerator", _item.FNumerator);//分母
|
ModelEnty.Add("FDenominator", _item.FDenominator);//分子
|
ModelEnty.Add("FDwyl", Convert.ToDecimal(_item.FNumerator) / Convert.ToDecimal(_item.FDenominator));//单位用料
|
ModelEnty.Add("FFIXSCRAPQTY", _item.FFIXSCRAPQTY);//固定损耗
|
ModelEnty.Add("FHQtyScrap", _item.FHQtyScrap);//变动损耗率%
|
ModelEnty.Add("FMOBILLNO", _item.FMOBILLNO);//
|
ModelEnty.Add("FMOENTRYIDINT", _item.FMOENTRYID);//
|
ModelEnty.Add("FPPBOMBILLNO", _item.FPPBOMBILLNO);//
|
ModelEnty.Add("FPPBOMFSEQINT", _item.FPPBOMFSEQ);//
|
ModelEnty.Add("FOwnerTypeId", _item.FOwnerTypeId);//
|
ModelEnty.Add("FOwnerID", new JObject() { ["Fnumber"] = _item.FOwnerID });//
|
ModelEnty.Add("FEntrustPickOrgId", new JObject() { ["Fnumber"] = _item.FEntrustPickOrgId });//
|
ModelEnty.Add("FMOID", _item.FMOID);//
|
ModelEnty.Add("FISSUETYPE", _item.FIssueType);//
|
ModelEnty.Add("FMaterialType", _item.FMaterialType);//
|
if (!string.IsNullOrEmpty(_item.FDayPlanPpbomFEntryId))
|
ModelEnty.Add("FEntryId", _item.FDayPlanPpbomFEntryId);//
|
Entry.Add(ModelEnty);
|
}
|
model.Add("FEntity", Entry);
|
|
Fentity.Add(model);
|
if ((i >= 20 || i == fidList.Count) && (i % 20 == 0 || i == fidList.Count))
|
{
|
JObject jsonRoot = new JObject()
|
{
|
["Creator"] = "",
|
["NeedUpDateFields"] = new JArray(),
|
["NeedReturnFields"] = new JArray(),
|
["SubSystemId"] = "",
|
["IsVerifyBaseDataField"] = "false",
|
["IsDeleteEntry"] = "false",
|
["Model"] = Fentity
|
};
|
CloudClient cloudClient = new CloudClient("http://localhost//k3cloud/");
|
var result = cloudClient.BatchSave("Paez_Sc_DayPlanPPBomBill", jsonRoot.ToString());
|
JObject saveObj = JObject.Parse(result);
|
string saveIsSuc = saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper();
|
if (saveIsSuc == "TRUE")
|
{
|
var Success = saveObj["Result"]["ResponseStatus"]["SuccessEntitys"].ToString().TrimStart('{').TrimEnd('}');
|
var allList = Newtonsoft.Json.JsonConvert.DeserializeObject<List<Dictionary<string, string>>>(Success);
|
List<string> ls = new List<string>();
|
foreach (var it in allList)
|
{
|
it.TryGetValue("Id", out string value);
|
ls.Add(value);
|
}
|
var resultAA = String.Join(",", ls.ToArray());
|
string resSql = string.Format(@"/*dialect*/ update Sc_WorkBillSortBillSub set Sc_WorkBillSortBillSub.FDAYPLANPPBOMBILLNO = Sc_DayPlanPPBomBillMain.FBILLNO from Sc_WorkBillSortBillSub join Sc_DayPlanPPBomBillMain on Sc_WorkBillSortBillSub.FEntryID = Sc_DayPlanPPBomBillMain.FDayPlanFID where Sc_DayPlanPPBomBillMain.FID in ({0})", resultAA);
|
DBServiceHelper.Execute(Context, resSql);
|
}
|
if (saveIsSuc != "TRUE")
|
{
|
//LogHelper.Error("日计划用料清单列表生成失败:" + jsonRoot.ToString());
|
//this.View.ShowMessage(saveObj["Result"]["ResponseStatus"]["Errors"][0]["Message"].ToString());
|
}
|
Fentity = new JArray();
|
}
|
i++;
|
}
|
}
|
}
|
foreach (var item in dictionary)
|
{
|
ResultMessage.dataError(this.OperationResult.OperateResult, item.Key, item.Value);
|
}
|
}
|
catch (Exception ex)
|
{
|
//LogHelper.Error("日计划用料清单列表生成失败:" + ex.Message.ToString());
|
}
|
}
|
|
public override void BeginOperationTransaction(BeginOperationTransactionArgs e)
|
{
|
base.BeginOperationTransaction(e);
|
try
|
{
|
var fBillNo = "";
|
var sql = "";
|
string result = "保存失败，提交后将要更新的日计划用料清单数量少于领料或调拨数量，";
|
foreach (var select in e.DataEntitys)
|
{
|
fBillNo = select["Billno"].ToString();
|
sql = string.Format(@"
|
/*dialect*/
|
select T9.FBILLNO,t12.FSEQ,t4.FMATERIALID,t6.FNUMBER ,convert(decimal(18,2),(t4.FNumerator/t4.FDenominator) *t1.FHQTY) FQty ,FPickedQty from
|
Sc_WorkBillSortBillSub t1
|
JOIN Sc_WorkBillSortBillMAIN t2 on t1.FID = t2.FID
|
JOIN T_PRD_PPBOM T3 on T2.FPRDMOMAINID=t3.FMOID AND T2.FPRDMOENTYID=T3.FMOENTRYID
|
JOIN T_PRD_PPBOMENTRY T4 ON T3.FID=T4.FID
|
JOIN T_BD_MATERIAL T6 ON T4.FMATERIALID=T6.FMATERIALID
|
LEFT JOIN Sc_DayPlanPPBomBillMain T9 ON T1.FEntryID=T9.FDayPlanFID
|
LEFT join Sc_DayPlanPPBomBillSub t12 on t9.FID=t12.FID and T4.FENTRYID=t12.FHPPBomEntryID
|
WHERE T4.FMustQty>0
|
and T3.FBILLNO='{0}'
|
and convert(decimal(18,2),(t4.FNumerator/t4.FDenominator) *t1.FHQTY)< t12.FPickedQty", fBillNo);
|
DataTable dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
|
if (dt.Rows.Count > 0)
|
{
|
e.CancelOperation = true;
|
foreach (DataRow dr in dt.Rows)
|
{
|
result += $"日计划用料清单单号：{dr["FBILLNO"].ToString()},分录行号：{dr["FSEQ"]},物料编码{dr["FNUMBER"]}";
|
}
|
dictionary.Add(fBillNo, result);
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
//LogHelper.Error("日计划用料清单列表生成失败:" + ex.Message.ToString());
|
}
|
}
|
|
public static class ResultMessage
|
{/// <summary>
|
/// 修改提示信息
|
/// </summary>
|
/// <param name="operateResult"></param>
|
/// <param name="billno"></param>
|
public static void dataError(OperateResultCollection operateResult, string billno, string message)
|
{
|
OperateResult operate = operateResult.Where(n => n.Number == billno).First();
|
operate.Message = message;
|
operate.SuccessStatus = false;
|
operate.MessageType = MessageType.FatalError;
|
}
|
}
|
}
|
}
|
