From 02aea9b1a44461c5f4f79d458670b2212e505a86 Mon Sep 17 00:00:00 2001
From: yangle <admin@YINMOU>
Date: 星期四, 09 三月 2023 13:26:29 +0800
Subject: [PATCH] 末道工序同步

---
 WebAPI/Controllers/ReportController.cs |  257 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 256 insertions(+), 1 deletions(-)

diff --git a/WebAPI/Controllers/ReportController.cs b/WebAPI/Controllers/ReportController.cs
index a60ca4b..1c27082 100644
--- a/WebAPI/Controllers/ReportController.cs
+++ b/WebAPI/Controllers/ReportController.cs
@@ -1,4 +1,5 @@
-锘縰sing Newtonsoft.Json.Linq;
+锘縰sing Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
 using Pub_Class;
 using System;
 using System.Collections;
@@ -115,5 +116,259 @@
         }
 
         //
+
+        #region 鏈亾宸ュ簭姹囨姤鍏ュ簱
+        /// <summary>
+        /// 鏈亾宸ュ簭姹囨姤鍏ュ簱鍒楄〃
+        /// </summary>
+        /// <param name="sWhere"></param>
+        /// <param name="user"></param>
+        /// <returns></returns>
+        [Route("Sc_ProcessMangement/Sc_ProcessReportList_Last")]
+        [HttpGet]
+        public object Sc_ProcessReportList_Last(string sWhere, string user)
+        {
+            try
+            {
+                string sql1 = "select * from h_v_Sc_ProcessReportList_Last where 1 = 1  and HLastProc='鏄�'";
+                string sql = sql1 + sWhere + "  order by hmainid desc";
+                ds = oCN.RunProcReturn(sql, "h_v_Sc_ProcessReportList_Last");
+
+                objJsonResult.code = "1";
+                objJsonResult.count = 1;
+                objJsonResult.Message = "Sucess锛�";
+                objJsonResult.data = ds.Tables[0];
+                return objJsonResult;
+
+            }
+            catch (Exception e)
+            {
+                objJsonResult.code = "0";
+                objJsonResult.count = 0;
+                objJsonResult.Message = "Exception锛�" + e.ToString();
+                objJsonResult.data = null;
+                return objJsonResult;
+            }
+        }
+        #endregion
+
+        #region 鏂帿灏� 鏈亾宸ュ簭姹囨姤鍒楄〃  姹囨姤 鍏ュ簱
+        /// <summary>
+        /// 鐢熸垚 鐢熶骇姹囨姤鍗�  
+        /// 鍚屾閲戣澏浜� 宸ュ簭姹囨姤鍏ュ簱鍗� 鍏ュ簱
+        /// </summary>
+        /// <param name="InterID"></param>
+        /// <param name="user"></param>
+        /// <param name="BillNo"></param>
+        /// <param name="OrganizationID"></param>
+        /// <returns></returns>
+        [Route("Sc_ProcessMangement/SRM_SaveICMOReportBill")]
+        [HttpGet]
+        public object SRM_SaveICMOReportBill(string InterID, string user, string BillNo, string OrganizationID)
+        {
+            try
+            {
+                //鑾峰彇鐢熶骇姹囨姤鍗曟渶澶nterID鍜屽崟鎹彿
+                Int64 HInterID = DBUtility.ClsPub.CreateBillID("3711", ref DBUtility.ClsPub.sExeReturnInfo);
+                string HBillNo = DBUtility.ClsPub.CreateBillCode("3711", ref DBUtility.ClsPub.sExeReturnInfo, true);
+                HBillNo = "9010-" + HBillNo;
+                //鑾峰彇缁勭粐浠g爜
+                string OrganizationNUM = oCN.RunProcReturn("select HNumber from Xt_ORGANIZATIONS where HItemID=" + OrganizationID, "Xt_ORGANIZATIONS").Tables[0].Rows[0]["HNumber"].ToString();
+                //鏍规嵁宸ュ簭姹囨姤鍗曚富ID鑾峰彇宸ュ簭姹囨姤鍏ュ簱鍗曠殑鏁版嵁
+                DataSet ds = oCN.RunProcReturn("select * from h_v_MES_StationOutBillList_LastProc where HInterID=" + InterID, "h_v_MES_StationOutBillList_LastProc");
+                DataRow dr = ds.Tables[0].Rows[0];
+
+                //淇濆瓨
+                oCN.BeginTran();
+                DataSet DsTable = oCN.RunProcReturn($"select * from Sc_ICMOReportBillMain where HBillNo='{HBillNo}'", "Sc_ICMOReportBillMain");
+                if (DsTable.Tables[0].Rows.Count > 0)
+                {
+                    objJsonResult.code = "0";
+                    objJsonResult.count = 0;
+                    objJsonResult.Message = "宸插叆搴�,璇蜂笉瑕侀噸澶嶅叆搴�";
+                    objJsonResult.data = null;
+                    return objJsonResult;
+                }
+                //鐢熶骇姹囨姤鍗曚富琛�
+                oCN.RunProc("Insert Into Sc_ICMOReportBillMain   " +
+            "(HBillType,HBillSubType,HInterID,HBillNo,HDate,HMaker,HMakeDate,HBillStatus,HChecker,HCheckDate" +
+            ",HYear,HPeriod,HRemark,HEmpID,HEmpNumber" +
+            ",HGroupID,HDeptID,HDeptNumber" +
+            ",HMainSourceBillNo,HMainSourceInterID,HMainSourceEntryID,HMainSourceBillType" +
+            ") " +
+            " values('3711','3711'," + HInterID.ToString() + ",'" + HBillNo + "',getdate(),'" + user + "',getdate(),2,'" + user + "',getdate()" +
+            ",DATENAME(YEAR,GETDATE()),"+DateTime.Now.Month+",'','" + dr["HEmpID"].ToString() + "','" + dr["鎿嶄綔鍛樹唬鐮�"].ToString() +
+            "','" + dr["HGroupID"].ToString() + "',0,''" +
+            ",'" + BillNo.ToString() + "'," + InterID.ToString() + ", 0,'3791'" +
+            ") ");
+                //鐢熶骇姹囨姤鍗曞瓙琛�
+                oCN.RunProc("Insert into Sc_ICMOReportBillSub " +
+                      " (HInterID,HEntryID,HMaterID,HMaterNumber" +
+                      ",HQty,HUnitID,HUnitNumber,HTimes,HSourceID" +
+                      ",HQtyMust,HWorkerID,HWorkerNumber,HBadCount,HWasterQty," +
+                      "HCloseMan,HCloseType,HRemark," +
+                      "HSourceInterID,HSourceEntryID,HSourceBillNo,HSourceBillType,HRelationQty,HRelationMoney" +
+                      ",HSeOrderInterID,HSeOrderEntryID,HSeOrderBillNo" +
+                      ",HICMOInterID,HICMOBillNo,HBarCode" +
+                      ") values("
+                      + HInterID.ToString() + ",1," + dr["HMaterID"].ToString() + ",'" + dr["浜у搧浠g爜"].ToString() + "'" +
+                      "," + dr["鍚堟牸鏁伴噺"].ToString() + ",0,'',0,0" +
+                      "," + dr["鎺ユ敹鏁伴噺"].ToString() + "," + dr["HEmpID"].ToString() + ",'" + dr["鎿嶄綔鍛樹唬鐮�"].ToString() + "'," + dr["涓嶈壇鏁伴噺"].ToString() + "," + dr["鎶ュ簾鏁伴噺"].ToString() +
+                      ",'',0,''" +
+                      "," + InterID.ToString() + ",0,'" + BillNo.ToString() + "','3791',0,0" +
+                      ",0,0,''" +
+                      "," + dr["HICMOInterID"].ToString() + ",'" + dr["浠诲姟鍗�"].ToString() + "',''" +
+                      ") ");
+                //鍚屾閲戣澏
+                //璁块棶閲戣澏
+                var loginRet = InvokeHelper.Login();
+                var isSuccess = JObject.Parse(loginRet)["LoginResultType"].Value<int>();
+                if (isSuccess == 0)
+                {
+                    objJsonResult.code = "0";
+                    objJsonResult.count = 0;
+                    objJsonResult.Message = "鎿嶄綔澶辫触,閲戣澏璐﹀彿鐧诲綍寮傚父銆�" + loginRet;
+                    objJsonResult.data = null;
+                    return objJsonResult;
+                }
+
+                //鏍规嵁浠诲姟鍗曟煡鎵惧埌閲戣澏鐨勭敓浜ц鍗�
+                DataSet ds1 = oCN.RunProcReturn("select * from  h_v_TOERP_StationOutBillList_LastProc_SMR where 鍗曟嵁鍙�='" + dr["鍗曟嵁鍙�"].ToString()+"'" , "h_v_TOERP_StationOutBillList_LastProc_SMR");
+
+                if (ds1.Tables[0].Rows.Count == 0)
+                {
+                    objJsonResult.code = "0";
+                    objJsonResult.count = 0;
+                    objJsonResult.Message = "鎿嶄綔澶辫触,閫氳繃鍑虹珯鍗曟煡涓嶅埌鐢熶骇璁㈠崟鏁版嵁";
+                    objJsonResult.data = null;
+                    return objJsonResult;
+                }
+                DataRow dr1 = ds1.Tables[0].Rows[0];
+
+                JObject model = new JObject();
+                model.Add("FBillType", new JObject() { ["Fnumber"] = "SCHBD01_SYS" }); //鍗曟嵁绫诲瀷鐢熶骇姹囨姤鈥淪CHBD02_SYS鈥� 鍏ュ簱姹囨姤SCHBD01_SYS
+                model.Add("FPrdOrgId", new JObject() { ["Fnumber"] = dr1["FPrdOrgNUMBER"].ToString() }); //鐢熶骇缁勭粐1
+                model.Add("FDate", DateTime.Now.ToString("yyyy-MM-dd")); //鍗曟嵁鏃ユ湡1
+                model.Add("FBillNo", HBillNo);
+                model.Add("F_RCZU_LZKH", dr1["宸ュ簭娴佽浆鍗″彿"].ToString());
+
+                JArray Fentity = new JArray();
+
+                foreach (DataRow item in ds.Tables[0].Rows)
+                {
+                    JObject FentityModel = new JObject();
+                    FentityModel.Add("FIsNew", false);//  婧愬崟绫诲瀷 
+                    FentityModel.Add("FReportType", new JObject() { ["Fnumber"] = dr1["FREPORTTYPENUMBER"].ToString() });//鐢熶骇姹囨姤绫诲瀷
+                    FentityModel.Add("FSrcBillType", "PRD_MO");//  婧愬崟绫诲瀷 
+                    FentityModel.Add("FProductType", "1");//  浜у搧绫诲瀷 
+                    FentityModel.Add("FSrcBillNo", item["浠诲姟鍗�"].ToString());//  婧愬崟缂栧彿 
+                    FentityModel.Add("FSrcInterId", dr1["FMOID"].ToString());//  婧愬崟鍐呯爜 
+                    FentityModel.Add("FSrcEntryId", dr1["FMOENTRYID"].ToString());//  婧愬崟鍒嗗綍鍐呯爜銆�
+                    FentityModel.Add("FSRCENTRYSEQ", dr1["FMOENTRYSEQ"].ToString());//  婧愬崟鍒嗗綍琛屽彿
+                    FentityModel.Add("FUNITID", new JObject() { ["Fnumber"] = dr1["FUNITNUMBER"].ToString() });//鍗曚綅
+                    FentityModel.Add("FTimeUnitId", "1");//鏃堕棿鍗曚綅
+                    FentityModel.Add("FWorkshipId", new JObject() { ["Fnumber"] = dr1["FWorkShopNUM"].ToString() }); //  鐢熶骇杞﹂棿
+                    FentityModel.Add("FStandHourUnitId", "3600"); // 鍗曚綅鏍囧噯宸ユ椂鍗曚綅 
+                    FentityModel.Add("FMaterialId", new JObject() { ["Fnumber"] = dr1["FMaterialNUM"].ToString() }); // 鐗╂枡缂栫爜 
+                    FentityModel.Add("FMoEntrySeq", dr1["FMOENTRYSEQ"].ToString());//鐢熶骇璁㈠崟琛屽彿
+                    FentityModel.Add("FMoId", dr1["HICMOInterID"].ToString());//鐢熶骇璁㈠崟鍐呯爜
+                    FentityModel.Add("FFinishQty", item["鎺ユ敹鏁伴噺"].ToString());//瀹屾垚鏁伴噺1
+                    FentityModel.Add("FQuaQty", item["鍚堟牸鏁伴噺"].ToString());//鍚堟牸鏁伴噺1FFailQty
+                    FentityModel.Add("FFailQty", item["涓嶈壇鏁伴噺"].ToString());//涓嶅悎鏍兼暟閲�
+                    FentityModel.Add("FStockInOrgId ", new JObject() { ["Fnumber"] = OrganizationNUM });// 鍏ュ簱缁勭粐 
+                    FentityModel.Add("FStockId", new JObject() { ["Fnumber"] = dr1["FStockNUM"].ToString() }); // 浠撳簱 
+                    FentityModel.Add("FMOBILLNO", dr1["FMOBILLNO"].ToString());//  
+                    FentityModel.Add("FMOENTRYID", dr1["FMOENTRYID"].ToString());//  
+                    FentityModel.Add("FOwnerTypeId", dr1["FOWNERTYPEID"].ToString()); //璐т富绫诲瀷锛欶OwnerTypeId(蹇呭~椤�)
+                    FentityModel.Add("FOwnerId", new JObject() { ["Fnumber"] = dr1["FOwnerNumber"].ToString() }); //璐т富锛欶OwnerId(蹇呭~椤�)
+                    FentityModel.Add("FBomId", new JObject() { ["F    number"] = dr1["FBOMNUM"].ToString() }); //BOM鐗堟湰锛欶BomId(蹇呭~椤�)
+                    FentityModel.Add("FCostRate", dr1["FCostRate"].ToString());// 鎴愭湰鏉冮噸
+                    FentityModel.Add("FISBACKFLUSH", dr1["FISBACKFLUSH"].ToString() == "1" ? true : false);// 鍊掑啿棰嗘枡
+                    FentityModel.Add("FMOMAINENTRYID", dr1["FMOENTRYID"].ToString());//
+                    FentityModel.Add("FLot", new JObject() { ["FNumber"] = dr1["FBATCHNO"].ToString() }); //鎵瑰彿
+                    //FentityModel.Add("F_RCZU_LZKH", dr1["宸ュ簭娴佽浆鍗″彿"].ToString());//  宸ュ簭娴佽浆鍗� 
+                    JArray Fentity2 = new JArray();
+                    JObject FentityModel2 = new JObject();
+                    FentityModel2.Add("FEntity_Link_FFlowId", "f6e6eec3-5267-4f02-8593-b633da508a72");
+                    FentityModel2.Add("FEntity_Link_FFlowLineId", "PRD_MO2MORPT");
+                    FentityModel2.Add("FEntity_Link_FRuleId", "3");
+                    FentityModel2.Add("FEntity_Link_FSTableId", "0");
+                    FentityModel2.Add("FEntity_Link_FSTableName", "T_PRD_MOENTRY");
+                    FentityModel2.Add("FEntity_Link_FSBillId", dr1["FMOID"].ToString());
+                    FentityModel2.Add("FEntity_Link_FSId", dr1["FMOENTRYID"].ToString());
+                    FentityModel2.Add("FEntity_Link_FBaseQuaQtyOld", item["鍚堟牸鏁伴噺"].ToString());
+                    FentityModel2.Add("FEntity_Link_FBaseQuaQty", item["鍚堟牸鏁伴噺"].ToString());
+                    Fentity2.Add(FentityModel2);
+                    FentityModel.Add("FEntity_Link", Fentity2);
+                    Fentity.Add(FentityModel);
+                }
+                model.Add("FEntity", Fentity); //鏄庣粏淇℃伅                       
+                JObject jsonRoot = new JObject()
+                {
+                    ["Creator"] = "",
+                    ["NeedUpDateFields"] = new JArray(),
+                    ["NeedReturnFields"] = new JArray(),
+                    ["IsDeleteEntry"] = "false",
+                    ["SubSystemId"] = "",
+                    ["IsVerifyBaseDataField"] = "false",
+                    //["IsAutoSubmitAndAudit"] = true,//鑷姩璋冪敤鎻愪氦鍜屽鏍稿姛鑳�
+                    ["Model"] = model
+                };
+
+                string result = InvokeHelper.Save("PRD_MORPT", JsonConvert.SerializeObject(jsonRoot));//淇濆瓨
+                //鍒ゆ柇淇濆瓨鏄惁鎴愬姛
+                if (JObject.Parse(result)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")
+                {
+                    LogService.Write("宸ュ簭姹囨姤鍗曞叆搴撻敊璇痡sonRoot:" + jsonRoot);
+                    oCN.RollBack();
+                    objJsonResult.code = "0";
+                    objJsonResult.count = 0;
+                    objJsonResult.Message = $"鐢熶骇姹囨姤鍏ュ簱鍗曞悓姝ラ噾铦朵簯澶辫触锛佸崟鍙�:{dr["鍗曟嵁鍙�"].ToString()}" + result;
+                    objJsonResult.data = null;
+                    return objJsonResult;
+                }
+                //鎻愪氦瀹℃牳
+                string result1 = string.Empty;
+                string result2 = string.Empty;
+                var fID = JObject.Parse(result)["Result"]["Id"].ToString();
+                var fBillNo = JObject.Parse(result)["Result"]["Number"].ToString();
+                var json = new
+                {
+                    Ids = fID,
+                };
+                result1 = InvokeHelper.Submit("PRD_MORPT", JsonConvert.SerializeObject(json));//鎻愪氦
+                result2 = InvokeHelper.Audit("PRD_MORPT", JsonConvert.SerializeObject(json));//鎻愪氦
+                if (JObject.Parse(result1)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")
+                {
+                    oCN.RollBack();
+                    objJsonResult.code = "0";
+                    objJsonResult.count = 0;
+                    objJsonResult.Message = $"鐢熶骇姹囨姤鍗曞崟鍙凤細{fBillNo}锛屾彁浜ゅけ璐�" + result;
+                    objJsonResult.data = null;
+                    return objJsonResult;
+                }
+
+                oCN.RunProc("update Sc_StationOutBillMain set HRelationQty=1 where  HBillNo='" + BillNo + "'");
+
+                oCN.Commit();
+                objJsonResult.code = "0";
+                objJsonResult.count = 1;
+                objJsonResult.Message = "淇濆瓨鎴愬姛锛�";
+                objJsonResult.data = 1;
+                return objJsonResult;
+            }
+            catch (Exception e)
+            {
+                oCN.RollBack();
+                objJsonResult.code = "0";
+                objJsonResult.count = 0;
+                objJsonResult.Message = "Exception锛�" + e.ToString();
+                objJsonResult.data = null;
+                return objJsonResult;
+            }
+        }
+        #endregion
+
+
     }
 }
\ No newline at end of file

--
Gitblit v1.9.1