From 612258efc012b91bbb2e35ecb3f3ef5b1f5b4487 Mon Sep 17 00:00:00 2001
From: 王 垚 <1402714037@qq.com>
Date: 星期二, 29 十二月 2020 11:12:08 +0800
Subject: [PATCH] 重复导入问题
---
src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs | 67 +++++++++++++++------------------
1 files changed, 30 insertions(+), 37 deletions(-)
diff --git a/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs b/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs
index 2c1bd2c..eef07d7 100644
--- a/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs
+++ b/src/BLL/Demo.BillView/PRD/Pro_ScDayImport.cs
@@ -27,6 +27,7 @@
[HotUpdate]
public class Pro_ScDayImport : AbstractDynamicFormPlugIn
{
+ CloudClient cloudClient = new CloudClient("http://localhost/K3Cloud/");
private string fileFullPath = string.Empty;
//public override void BarItemClick(Kingdee.BOS.Core.DynamicForm.PlugIn.Args.BarItemClickEventArgs e)
//{
@@ -139,8 +140,8 @@
DataTable dayPlanDt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
if (dayPlanDt.Rows.Count > 0)
{
- fDayPlanID = _dt.Rows[0]["FID"].ToString();
- fDayPlanBillNo = _dt.Rows[0]["FBILLNO"].ToString();
+ fDayPlanID = dayPlanDt.Rows[0]["FID"].ToString();
+ fDayPlanBillNo = dayPlanDt.Rows[0]["FBILLNO"].ToString();
}
//DynamicObject row = new DynamicObject(entity.DynamicObjectType);
this.Model.CreateNewEntryRow("FEntity");
@@ -225,14 +226,25 @@
try
{
LogService.WriteAsync("娴嬭瘯");
-
string sql;
DateTime date = Convert.ToDateTime(this.Model.GetValue("F_Paez_Date"));
//鑾峰彇鍗曟嵁浣撲俊鎭�
Entity entity = this.View.BillBusinessInfo.GetEntity("FEntity");
//鍗曟嵁浣撲俊鎭浆鎹负鍒楄〃闆嗗悎
DynamicObjectCollection entityDataObjoct = this.View.Model.GetEntityDataObject(entity);
-
+ List<string> sqlList = new List<string>();
+ foreach (DynamicObject current in entityDataObjoct)
+ {
+ if (Convert.ToString(current["FDayPlanID"]) == "0")
+ continue;
+ for (int i = 0; i <= 60; i++)
+ {
+ JObject jsonFPOOrderEntry = new JObject();
+ sql = string.Format($"update SC_WORKBILLSORTBILLSub set FHQTY ='{Convert.ToString(current["FT" + "" + i + ""])}' where FID ={Convert.ToString(current["FDayPlanID"])} and FHMASTERDATE ={date.AddDays(i).ToShortDateString()} and FHLOCKEDSUB = 0");
+ sqlList.Add(sql);
+ }
+ }
+ int res = DBServiceHelper.ExecuteBatch(Context, sqlList);
string _result = "";
foreach (DynamicObject current in entityDataObjoct)
{
@@ -251,24 +263,20 @@
this.View.ShowErrMessage(_result);
return;
}
-
foreach (DynamicObject current in entityDataObjoct)
{
if (Convert.ToInt32(current["FNoScheduled"]) < 0)
_result += "搴忓彿锛�" + Convert.ToString(current["SEQ"]) + ",鏃ヨ鍒掓�绘暟閲忚秴鍑虹敓浜ц鍗曟暟閲�";
-
}
if (_result != "")
{
this.View.ShowErrMessage(_result);
return;
}
-
foreach (DynamicObject current in entityDataObjoct)
{
if (string.IsNullOrEmpty(Convert.ToString(current["FSalOrderNo"])) || string.IsNullOrEmpty(Convert.ToString(current["FSCOrderNo"])))
continue;
-
//鏍规嵁鐢熶骇璁㈠崟鍙峰拰鐗╂枡鏌ヨ鏄惁瀛樺湪鏄庣粏
sql = string.Format(@"/*dialect*/SELECT T1.FBILLNO,T2.* FROM T_PRD_MO T1
LEFT JOIN T_PRD_MOENTRY T2 ON T1.FID = T2.FID
@@ -277,13 +285,11 @@
dt = DBServiceHelper.ExecuteDataSet(Context, sql).Tables[0];
if (dt.Rows.Count == 0)
continue;
-
string FID = "";//FID 婧愬崟涓诲唴鐮�
string FENTRYID = "";//FENTRYID 婧愬崟瀛愬唴鐮�
string FLOT = "";//FLOT 鎵规
string FQTY = "";//FQTY 鐢熶骇璁㈠崟鏁伴噺
string FBILLNO = "";//FBILLNO 鍘熷崟鍙�
-
if (dt.Rows.Count > 0)
{
FID = dt.Rows[0]["FID"].ToString();
@@ -296,10 +302,9 @@
jsonRoot.Add("Creator", "");
jsonRoot.Add("NeedUpDateFields", new JArray());
jsonRoot.Add("NeedReturnFields", new JArray());
- jsonRoot.Add("IsDeleteEntry", "true");
+ jsonRoot.Add("IsDeleteEntry", "false");
jsonRoot.Add("SubSystemId", "");
jsonRoot.Add("IsVerifyBaseDataField", "");
-
JObject jsonModel = new JObject();
jsonModel.Add("FPreparatDate", date.ToString());//缂栧埗鏃ユ湡
jsonModel.Add("FSCOrderNo", current["FSCOrderNo"].ToString()); //鐢熶骇璁㈠崟鍙稦SCOrderNo
@@ -313,18 +318,12 @@
jsonModel.Add("FPrdBillNo", FBILLNO); ;//婧愬崟缂栧彿
jsonModel.Add("FPRDMOMAINID", FID); ;//婧愬崟涓诲唴鐮�
jsonModel.Add("FPRDMOENTYID", FENTRYID); ;//婧愬崟瀛愬唴鐮�
-
jsonModel.Add("FOrderQuantity", current["FOrderQuantity"].ToString()); ;//鐢熶骇璁㈠崟鏁伴噺
jsonModel.Add("FDayPlanQuantity", current["FDayPlanQuantity"].ToString()); ;//鏃ヨ鍒掓暟閲�
jsonModel.Add("FNoScheduled", current["FNoScheduled"].ToString()); ;//鏈帓鏁伴噺
-
-
-
-
JObject jsonFHMaterID = new JObject();
jsonFHMaterID.Add("FNumber", (current["FMatrailId"] as DynamicObject)["Number"].ToString());
jsonModel.Add("FHMaterID", jsonFHMaterID);//FHMaterID 鐗╂枡
-
if (Convert.ToString(current["FORGID_Id"]) != "0")
{
JObject jsonFHPRDORGID = new JObject();
@@ -338,7 +337,6 @@
jsonFProductWorkShopId.Add("FNumber", (current["FResourcesId"] as DynamicObject)["Number"].ToString());
jsonModel.Add("FHSourceID", jsonFProductWorkShopId);//FHSourceID 鐢熶骇杞﹂棿
}
-
if (Convert.ToString(current["FProductWorkShopId_Id"]) != "0")
{
JObject jsonFResourcesId = new JObject();
@@ -346,21 +344,21 @@
jsonModel.Add("FHWorkShopID", jsonFResourcesId);//FHWorkShopID 鐢熶骇璧勬簮
}
JArray Entry = new JArray();
- for (int i = 0; i <= 60; i++)
+ if (Convert.ToString(current["FDayPlanID"]) != "0")
{
- JObject jsonFPOOrderEntry = new JObject();
-
- jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//涓绘棩鏈�
- jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//鏃ヨ鍒掓暟閲�
- jsonFPOOrderEntry.Add("FColumn", "FT" + "" + i + ""); ;//瀵瑰簲鐨勫垪澶�
- //jsonFPOOrderEntry.Add("FHMainSourceBillType ", "鐢熶骇璁㈠崟"); ;//婧愬崟绫诲瀷
- //jsonFPOOrderEntry.Add("FHMainSourceBillNo", FBILLNO); ;//婧愬崟缂栧彿
- //jsonFPOOrderEntry.Add("FHMainSourceInterID", FID); ;//婧愬崟涓诲唴鐮�
- //jsonFPOOrderEntry.Add("FHMainSourceEntryID", FENTRYID); ;//婧愬崟瀛愬唴鐮�
-
- Entry.Add(jsonFPOOrderEntry);
+ sql = $"select max(FHMASTERDATE)FHMASTERDATE from SC_WORKBILLSORTBILLSub where FID={Convert.ToString(current["FDayPlanID"])} ";
+ DateTime EndDate = DBServiceHelper.ExecuteScalar<DateTime>(Context, sql, DateTime.Now);
+ for (int i = 0; i <= 60; i++)
+ {
+ if (EndDate >= date.AddDays(i))
+ continue;
+ JObject jsonFPOOrderEntry = new JObject();
+ jsonFPOOrderEntry.Add("FHMasterDate", date.AddDays(i).ToShortDateString()); ;//涓绘棩鏈�
+ jsonFPOOrderEntry.Add("FHQty ", Convert.ToString(current["FT" + "" + i + ""])); ;//鏃ヨ鍒掓暟閲�
+ jsonFPOOrderEntry.Add("FColumn", "FT" + "" + i + ""); ;//瀵瑰簲鐨勫垪澶�
+ Entry.Add(jsonFPOOrderEntry);
+ }
}
-
jsonModel.Add("FEntity", Entry);
//鏃ヨ鍒掑伐鍗曚笉涓虹┖鏃秛pdate
if (Convert.ToString(current["FDayPlanID"]) != "0")
@@ -403,8 +401,6 @@
this.Model.SetValue("FDayPlanBillNo", FDayPlanBillNo, Convert.ToInt32(current["SEQ"]) - 1);//
this.Model.SetValue("FDayPlanID", FDayPlanID, Convert.ToInt32(current["SEQ"]) - 1);//
-
-
this.View.ShowMessage("瀵煎叆鎴愬姛");
}
@@ -419,10 +415,7 @@
}
}
-
this.View.UpdateView();
-
-
}
}
catch (Exception ex)
--
Gitblit v1.9.1