智云MES后端API代码
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yangle
2022-11-17 720ad806c65ac92647730e64dd90ee62da627d1e 
 WebAPI/Controllers/POStockInBillController.cs


@@ -411,6 +411,55 @@


        }














        [Route("Kf_QCStockInCheckBill_Fast/BarCode_Json")]


        [HttpGet]


        public object BarCode_Json(string HBarCode)


        {


            try


            {


                SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();


                ds = oCN.RunProcReturn("select * from h_v_QCStockInCheckBill_Json where  条码编号 ='" + HBarCode.ToString() + "'" , "h_v_QCStockInCheckBill_Json");


                if (ds == null || ds.Tables[0].Rows.Count <= 0)


                {




                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "没有返回任何记录！";


                    objJsonResult.data = null;


                    return objJsonResult;


                    //DBUtility.ClsPub.MessageBeep((int)DBUtility.ClsPub.BeepType.Warning);


                }


                else


                {


                    objJsonResult.code = "0";


                    objJsonResult.count = 1;


                    objJsonResult.Message = "获取信息成功！";


                    objJsonResult.data = ds.Tables[0];


                    return objJsonResult;


                }


            }


            catch (Exception e)


            {




                objJsonResult.code = "0";


                objJsonResult.count = 0;


                objJsonResult.Message = "没有返回任何记录！" + e.ToString();


                objJsonResult.data = null;


                return objJsonResult;


            }


        }


















        /// <summary>


        /// 返回出入库条码临时表     


        /// </summary>


@@ -1474,8 +1523,25 @@


                DAL.ClsCg_POInStockBill oBill = new DAL.ClsCg_POInStockBill();


                var hinterID = list[0].HInterID;


                var FID = list[0].FID;




                #region 校验是否扫描条码


                var HInterID = list[0].HInterID;


                string jysql = string.Format(@"select * from KF_PonderationBillMain_Temp where HSourceInterID = {0}", HInterID);


                DataTable jyDt =oCn.RunProcReturn(jysql, "jysql").Tables[0];


                if (jyDt.Rows.Count == 0 || jyDt == null)


                {


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "请扫描条码";


                    objJsonResult.data = null;


                    return objJsonResult;


                }


                #endregion


                #region 金蝶审核后会重新同步单据到mes 故不需要更新mes的收料通知单 


                /*


                oCn.BeginTran();


                string sql = string.Empty;




                foreach (var item in list)


                {


                    if (item.HSQty == 0)


@@ -1484,6 +1550,15 @@


                    oCn.RunProc(sql);


                }


                oCn.RunProc("exec h_p_Cg_UpDatePOOrderRelation_Del " + hinterID);//删除关联关系


                sql = string.Format(@"update Cg_POInStockBillMain set 


HBillStatus = 2 ,


HCheckDate   = getdate()


where HInterID in ({0})", HInterID);


                oCn.RunProc(sql);//更新mes状态  


                //更新成功后 同步更新金蝶


                oCn.Commit();


                **/


                #endregion




                JObject jsonRoot = new JObject();


                jsonRoot.Add("Creator", "");


@@ -1496,17 +1571,16 @@


                JObject jsonModel = new JObject();


                jsonModel.Add("FID", FID);


                JArray Entry = new JArray();




                foreach (var item in list)


                {


                    if (item.HSQty == 0)


                        continue;


                    JObject jsonFPOOrderEntry = new JObject();


                    jsonFPOOrderEntry.Add("FEntryID", item.FEntryID);


                    jsonFPOOrderEntry.Add("FHQty ", item.HSQty); ;


                    jsonFPOOrderEntry.Add("FActReceiveQty ", item.HSQty); ;


                    Entry.Add(jsonFPOOrderEntry);


                }


                jsonModel.Add("FEntity", Entry);


                jsonModel.Add("FDetailEntity", Entry);


                jsonRoot.Add("Model", jsonModel);


                var loginRet = InvokeHelper.Login();


                var isSuccess = JObject.Parse(loginRet)["LoginResultType"].Value<int>();


@@ -1518,20 +1592,49 @@


                    objJsonResult.data = null;


                    return objJsonResult;


                }


                //LogService.Write("jsonRoot:" + jsonRoot.ToString());


                var result = InvokeHelper.Save("PUR_ReceiveBill", jsonRoot.ToString());


                //LogService.Write(result);


                if (JObject.Parse(result)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() == "TRUE")


                if (JObject.Parse(result)["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")


                {


                    LogService.Write("收料通知单修改失败jsonRoot:" + jsonRoot.ToString());


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "金蝶收料通知单更新失败" + result;


                    objJsonResult.data = null;


                    return objJsonResult;


                }


                var json = new


                {


                    Ids = FID,


                };


                //提交


                var _result = InvokeHelper.Submit("PUR_ReceiveBill", JsonConvert.SerializeObject(json));


                var _saveObj = JObject.Parse(_result);


                if (_saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")


                {


                    LogService.Write("收料通知单提交失败jsonRoot:" + jsonRoot.ToString());


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "金蝶收料通知单提交失败" + _result;


                    objJsonResult.data = null;


                    return objJsonResult;




                //更新成功后 同步更新金蝶


                oCn.Commit();


                }


                //审核


                _result = InvokeHelper.Audit("PUR_ReceiveBill", JsonConvert.SerializeObject(json));


                _saveObj = JObject.Parse(_result);


                if (_saveObj["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToUpper() != "TRUE")


                {


                    LogService.Write("收料通知单审核失败jsonRoot:" + jsonRoot.ToString());


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "金蝶收料通知单审核失败jsonRoot" + _result;


                    objJsonResult.data = null;


                    return objJsonResult;




                }






                objJsonResult.code = "1";


                objJsonResult.count = 1;


                objJsonResult.Message = "操作成功！";


@@ -1540,7 +1643,7 @@


            }


            catch (Exception e)


            {


                oCn.RollBack();


                //oCn.RollBack();


                objJsonResult.code = "0";


                objJsonResult.count = 0;


                objJsonResult.Message = "异常！" + e.ToString();


@@ -1562,8 +1665,9 @@


        {


            try


            {


                //var code = HBarcode.Split('#')[0];


                //校验条码是否存在


                string sql = $"select* from  Gy_BarCodeBill where HSourceInterID ={HInterID} and HBarCode = '{HBarcode}'";


                string sql = $"select HItemID,HSourceBillNo from  Gy_BarCodeBill where HSourceInterID ={HInterID} and HBarCode = '{HBarcode.Split('#')[0]}' and HQty = {HBarcode.Split('#')[1]}";


                DataSet ds = oCn.RunProcReturn(sql, "H_v_SRM_POOrderBillList");


                if (ds.Tables[0].Rows.Count == 0)


                {


@@ -1573,6 +1677,29 @@


                    objJsonResult.data = ds.Tables[0];


                    return objJsonResult;


                }


                else


                {


                    //存入条码临时表


                    sql = $"delete from KF_PonderationBillMain_Temp Where HBillNo='{ds.Tables[0].Rows[0]["HSourceBillNo"]}' ";


                    oCn.RunProc(sql);


                    sql = string.Format(@"Insert into KF_PonderationBillMain_Temp 


   (HInterID,HBillNo,HBillType,HMaterID,HProcID,HWhID,HSCWHID


   ,HStockPlaceID,HOutStockPlaceID,HGroupID,HQty,HQtyMust,HPieceQty


   ,HAuxPropID,HBatchNo,HBarCode,HAddr,HMaker,HMakeDate


   ,HSourceInterID,HSourceEntryID,HSourceBillType,HSourceBillNo,HMTONo


   ,HSTOCKORGID,HOWNERID,HExpressNumber,HSubBillType


   ,HRelationInterID,HRelationEntryID,HRelationBillNo,HRedBlueFlag


   ,HCusID)


   select HInterID,HSourceBillNo,HBillType,HMaterID,0,0,0


   ,0,0,0,HQty,HQty,0


   ,HAuxPropID,HBatchNo,'','','System',getdate()


   ,HSourceInterID,HSourceEntryID,HSourceBillType,HSourceBillNo,HMTONo


   ,HSTOCKORGID,HOWNERID,'',HBillType


   ,0,0,'',0


   ,0 from Gy_BarCodeBill  


   where HItemID = {0}", ds.Tables[0].Rows[0]["HItemID"]);


                    oCn.RunProc(sql);


                }




                objJsonResult.code = "1";


                objJsonResult.count = 1;