using System; using System.Data; using Core.Mes.ServerFrameWork; using Core.Mes.IBaseInterface; using System.Collections; namespace Core.XgMes.Server.JGKC.SteelPlateManager { /// /// StuffRecevie 的摘要说明。 /// public class StuffRecevie : Core.Mes.ServerFrameWork.IComponent { public StuffRecevie() { // // TODO: 在此处添加构造函数逻辑 // } public override int maxValue { get { return 100; } } public override int minValue { get { return 50; } } /// /// 获取来料信息 /// /// 条件 /// public ReturnObject GetSource(string _Where,string strName,string strlx) { string strOut = ""; string sql = ""; if (strlx == "1") { sql = "SELECT * FROM (SELECT 'FALSE' FLAG,A.SERIALNUMBER BILLETID,'厚板线' PRODUCTLINE,A.ROLLNO ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERFORMNUMBER ORDERNO," + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY, " + "D.NAME_ DETERMINANTRESULT,A.STEELTYPE DETERMINANTCARDNUMBER,A.LISTNUMBER SOURCEID,A.PLANVEHICLEID,TO_CHAR(A.PICKSTORAGETIME,'YYYY-MM-DD') SENDTIME,G.NAME_ ATTESTATIONORGAN,A.ORDERBUYER,H.BUYERCODE BUYERNAME,H.PACTNO " + " FROM KCH_TURNOFFSENDLIST A," + " SCM_BASE_INFO B, " + " SCM_BASE_INFO D," + " SCM_BASE_INFO G,sel_pactdetail h " + " WHERE A.ISVALID='2'" + " AND A.FACEQUALITY=B.ID_(+)" + " AND A. DETERMINANTRESULT=D.ID_(+)" + " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " + _Where + " UNION ALL " +" SELECT 'FALSE' FLAG,A.SERIALNUMBER BILLETID,'板加' PRODUCTLINE,A.ROLLNO ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERFORMNUMBER ORDERNO," + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY, " + "D.NAME_ DETERMINANTRESULT,A.STEELTYPE DETERMINANTCARDNUMBER,A.LISTNUMBER SOURCEID,A.PLANVEHICLEID,TO_CHAR(A.PICKSTORAGETIME,'YYYY-MM-DD') SENDTIME,G.NAME_ ATTESTATIONORGAN,A.ORDERBUYER,H.BUYERCODE BUYERNAME,H.PACTNO " + " FROM KCJ_TURNOFFSENDLIST A," + " SCM_BASE_INFO B, " + " SCM_BASE_INFO D," + " SCM_BASE_INFO G,sel_pactdetail h " + " WHERE A.ISVALID='2'" + " AND A.FACEQUALITY=B.ID_(+)" + " AND A. DETERMINANTRESULT=D.ID_(+)" + " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " + _Where +"UNION ALL " + "SELECT 'FALSE' FLAG,A.SERIALNUMBER BILLETID,'中板线' PRODUCTLINE,A.ROLLNO ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERFORMNUMBER ORDERNO," + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY," + "D.NAME_ DETERMINANTRESULT,A.STEELTYPE DETERMINANTCARDNUMBER,A.LISTNUMBER SOURCEID,A.PLANVEHICLEID,TO_CHAR(A.PICKSTORAGETIME,'YYYY-MM-DD') SENDTIME,G.NAME_ ATTESTATIONORGAN,A.ORDERBUYER,H.BUYERCODE BUYERNAME,H.PACTNO " + " FROM KCZ_TURNOFFSENDLIST A," + " SCM_BASE_INFO B, " + " SCM_BASE_INFO D," + " SCM_BASE_INFO G,sel_pactdetail h " + " WHERE A.ISVALID='2'" + " AND A.FACEQUALITY=B.ID_(+)" + " AND A. DETERMINANTRESULT=D.ID_(+)" + " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " + _Where+" )" + " ORDER BY BILLETID ASC "; } else { sql = "SELECT * FROM (SELECT 'FALSE' FLAG,A.SERIALNUMBER BILLETID,CASE WHEN SUBSTR(A.SERIALNUMBER,1,1)='E' THEN '二线厂' WHEN SUBSTR(A.SERIALNUMBER,1,1)='Y' THEN '高棒厂' WHEN SUBSTR(A.SERIALNUMBER,1,1)='B' THEN '普棒厂' END PRODUCTLINE,A.ROLLNO ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERFORMNUMBER ORDERNO," + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY," + "D.NAME_ DETERMINANTRESULT,A.STEELTYPE DETERMINANTCARDNUMBER,A.LISTNUMBER SOURCEID,A.PLANVEHICLEID,TO_CHAR(A.PICKSTORAGETIME,'YYYY-MM-DD') SENDTIME,G.NAME_ ATTESTATIONORGAN,'' ORDERBUYER,H.BUYERCODE BUYERNAME,H.PACTNO " + " FROM KCX_TURNOFFSENDLIST A," + " SCM_BASE_INFO B, " + " SCM_BASE_INFO D," + " SCM_BASE_INFO G,sel_pactdetail h " + " WHERE A.ISVALID='2'" + " AND A.FACEQUALITY=B.ID_(+)" + " AND A. DETERMINANTRESULT=D.ID_(+)" + " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " + _Where + " UNION ALL " + "SELECT 'FALSE' FLAG,A.SERIALNUMBER BILLETID,CASE WHEN SUBSTR(A.SERIALNUMBER,1,1)='E' THEN '二线厂' WHEN SUBSTR(A.SERIALNUMBER,1,1)='Y' THEN '高棒厂' WHEN SUBSTR(A.SERIALNUMBER,1,1)='B' THEN '普棒厂' END PRODUCTLINE,A.ROLLNO ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERFORMNUMBER ORDERNO," + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY," + "D.NAME_ DETERMINANTRESULT,A.STEELTYPE DETERMINANTCARDNUMBER,A.LISTNUMBER SOURCEID,A.PLANVEHICLEID,TO_CHAR(A.PICKSTORAGETIME,'YYYY-MM-DD') SENDTIME,G.NAME_ ATTESTATIONORGAN,'' ORDERBUYER ,H.BUYERCODE BUYERNAME,H.PACTNO " + " FROM KCJ_TURNOFFSENDLIST A," + " SCM_BASE_INFO B, " + " SCM_BASE_INFO D," + " SCM_BASE_INFO G,sel_pactdetail h " + " WHERE A.ISVALID='2'" + " AND A.FACEQUALITY=B.ID_(+)" + " AND A. DETERMINANTRESULT=D.ID_(+)" + " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " + _Where + " )ORDER BY BILLETID ASC "; } try { DataSet ds = this.DBManager.ExecuteQuery(sql,out strOut); ds.Tables[0].TableName = "KCJ_SOURCE"; return new ReturnObject(ds,strOut); } catch(Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null,ex.ToString()); } } /// /// 获取已导入来料信息 /// /// 条件 /// public ReturnObject GetSourceImport(string strlx) { string strOut = ""; string sql = "SELECT 'FALSE' FLAG,A.BILLETID,CASE WHEN SUBSTR(A.BILLETID,1,1)='H'THEN '厚板线' WHEN SUBSTR(A.BILLETID,1,1)='Z'THEN '中板线' WHEN SUBSTR(A.BILLETID,1,1)='B'THEN '棒材线' WHEN SUBSTR(A.BILLETID,1,1)='E'THEN '二线厂' WHEN SUBSTR(A.BILLETID,1,1)='Y'THEN '高棒厂' END PRODUCTLINE,A.ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERNO," + "TO_NUMBER(A.PLY)PLY,TO_NUMBER(A.WIDTH)WIDTH,TO_NUMBER(A.LENGTH)LENGTH,TO_NUMBER(A.THEORYWEIGHT)THEORYWEIGHT,B.NAME_ FACEQUALITY, " + "D.NAME_ DETERMINANTRESULT,A.DETERMINANTCARDNUMBER,A.SOURCEID,A.PLANVEHICLEID,TO_CHAR(SYSDATE,'YYYY-MM-DD') SENDTIME,''ATTESTATIONORGAN,''ORDERBUYER,BUYERNAME,PACTNO " + "FROM KCJ_ZWIMPORT A,SCM_BASE_INFO B,SCM_BASE_INFO D WHERE A.FACEQUALITY=B.ID_(+) AND A. DETERMINANTRESULT=D.ID_(+) "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); ds.Tables[0].TableName = "KCJ_SOURCE"; return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } /// /// 获取订单分配信息 /// /// 条件 /// public ReturnObject GetOrderNoAllicat(string _Where) { string strOut = ""; string sql = ""; sql = "SELECT BILLETID,ORDERNO,RECODER,TIME_ FROM KCH_STEEL_CHAGE" + _Where + " AND STLYE='订单分配' AND Old_Steel='pszx'" + " ORDER BY BILLETID ASC "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } /// /// 获取判定记录信息 /// /// 条件 /// public ReturnObject GetJudgeRecoder(string _Where) { string strOut = ""; string sql = ""; sql = "SELECT BILLETID,codes2names(PDJG)PDJG,PDR,TIME_,STEELNAME FROM ( " + "SELECT SLABNO BILLETID,JUDGERESULT PDJG,RECORDER PDR,RECORDTIME TIME_,STEELNAME FROM ZJZ_COLL_JUDGE WHERE SLABNO LIKE 'Z%' " + "UNION " + "SELECT P_MB_CB_ID BILLETID,COLLRESULT PDJG,JUDGER PDR,JUDGETIME TIME_ ,JUDGESTEELNAME STEELNAME FROM ZJH_COLL_JUDGE WHERE P_MB_CB_ID LIKE 'H%') " + _Where + " ORDER BY BILLETID ASC "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject GetYLButress(string _Where) { string strOut = ""; string sql = ""; sql = "select B.BUTTRESS,SUBSTR(a.orderno,1,LENGTH(A.ORDERNO)-3)ORDERNO,COUNT(A.BILLETID)NUMBER1,SUM(A.THEORYWEIGHT)WEIGHT from KCP_STORAGELIST A,KCJ_STORAGEBUTTRESSLIST B WHERE A.BILLETID=B.BILLETID AND A.STORAGESTATUS='501002' " + _Where + " GROUP BY B.BUTTRESS,SUBSTR(a.orderno,1,LENGTH(A.ORDERNO)-3) "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject GetYLButress_Detail(string _Where) { string strOut = ""; string sql = ""; sql = "SELECT B.BUTTRESS, A.BILLETID,A.THEORYWEIGHT,A.DETERMINANTCARDNUMBER,A.PLY,A.WIDTH,A.LENGTH,A.ORDERNO,C.NAME_ DETERMINANTRESULT,D.NAME_ PRODUCT_NAME " + " FROM KCP_STORAGELIST A, KCJ_STORAGEBUTTRESSLIST B,SCM_BASE_INFO C ,SCM_BASE_INFO D " + " WHERE A.BILLETID = B.BILLETID AND A.DETERMINANTRESULT=C.ID_(+) AND A.PRODUCT_NAME=D.ID_(+) " + " AND A.STORAGESTATUS = '501002' " + _Where + " ORDER BY A.BILLETID "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject GetCPButress_Detail(string _Where) { string strOut = ""; string sql = ""; sql = "SELECT B.BUTTRESS, A.BILLETID,A.THEORYWEIGHT,A.DETERMINANTCARDNUMBER,A.PLY,A.WIDTH,A.LENGTH,A.ORDERNO,C.NAME_ DETERMINANTRESULT,D.NAME_ PRODUCT_NAME " + " FROM KCJ_TURNOFFLIST A, KCJ_TURNOFFBUTTRESSLIST B,SCM_BASE_INFO C ,SCM_BASE_INFO D " + " WHERE A.BILLETID = B.BILLETID AND A.DETERMINANTRESULT=C.ID_(+) AND A.PRODUCT_NAME=D.ID_(+) " + " AND A.STORAGESTATUS = '501602' " + _Where + " ORDER BY A.BILLETID "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject GetCPButress(string _Where) { string strOut = ""; string sql = ""; sql = "select B.BUTTRESS,SUBSTR(a.orderno,1,LENGTH(A.ORDERNO)-3)ORDERNO,COUNT(A.BILLETID)NUMBER1,SUM(A.THEORYWEIGHT)WEIGHT from KCJ_TURNOFFLIST A,KCJ_TURNOFFBUTTRESSLIST B WHERE A.BILLETID=B.BILLETID AND A.STORAGESTATUS='501602' " + _Where + " GROUP BY B.BUTTRESS,SUBSTR(a.orderno,1,LENGTH(A.ORDERNO)-3) "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject GetYLButress_XB(string _Where) { string strOut = ""; string sql = ""; sql = "select B.BUTTRESS,A.PLY,A.LENGTH,COUNT(A.BILLETID)NUMBER1,SUM(A.THEORYWEIGHT)WEIGHT from KCP_STORAGELIST A,KCJ_STORAGEBUTTRESSLIST B WHERE A.BILLETID=B.BILLETID AND A.STORAGESTATUS='501002' " + _Where + " GROUP BY B.BUTTRESS,A.PLY,A.LENGTH "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject GetCPButress_XB(string _Where) { string strOut = ""; string sql = ""; sql = "select B.BUTTRESS,A.PLY,A.LENGTH,COUNT(A.BILLETID)NUMBER1,SUM(A.THEORYWEIGHT)WEIGHT from KCJ_TURNOFFLIST A,KCJ_TURNOFFBUTTRESSLIST B WHERE A.BILLETID=B.BILLETID AND A.STORAGESTATUS='501602' " + _Where + " GROUP BY B.BUTTRESS,A.PLY,A.LENGTH "; try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } /// /// 获取原料入库信息 /// /// 条件 /// public ReturnObject GetInStorage(string _Where) { string strOut = ""; string sql = ""; sql = "SELECT A.BILLETID ,(SELECT NAME_ FROM SCM_BASE_INFO F WHERE A.PRODUCTLINE = F.ID_)PRODUCTLINE,A.ROLLNUMBER,A.MOTHERBOARDNUMBER,A.STOVENO,A.PLANNO,A.ORDERNO,A.YPLANNO,A.YORDERNO,J.NAME_ ATTESTATIONORGAN," + "A.PLY,A.WIDTH,A.LENGTH,A.THEORYWEIGHT,(SELECT NAME_ FROM SCM_BASE_INFO B WHERE A.FACEQUALITY = B.ID_)FACEQUALITY,(SELECT NAME_ FROM SCM_BASE_INFO C WHERE A.BUGREASON = C.ID_)BUGREASON,A.DETERMINANTCARDNUMBER,(SELECT NAME_ FROM SCM_BASE_INFO D WHERE A.CLIPTYPEPROCESS = D.ID_)CLIPTYPEPROCESS, TO_CHAR(m.sendbegindate, 'YYYY-MM-DD') SENDBEGINDATE," + " (SELECT NAME_ FROM SCM_BASE_INFO E WHERE A.DETERMINANTRESULT = E.ID_)DETERMINANTRESULT,A.SOURCEID,TO_CHAR(A.INTIME,'YYYY-MM-DD HH24:MI:SS') INTIME,A.CONDOLENUMBER," + " A.CHECKOPERATOR,A.IN_MAN,(SELECT NAME_ FROM SCM_BASE_INFO G WHERE A.INCLASSORDER = G.ID_)INCLASSORDER,(SELECT NAME_ FROM SCM_BASE_INFO H WHERE A.INCLASSTEAM = H.ID_)INCLASSTEAM, I.BUTTRESS,A.REMARK,A.ORDERBUYER,a.BUYERNAME,a.PACTNO " + "FROM KCJ_STORAGELIST_ZW A, sel_pactdetail m ,SCM_BASE_INFO J ,KCJ_STORAGEBUTTRESSLIST_ZW I " + "WHERE a.orderno = m.orderno(+) AND A.BILLETID = I.BILLETID(+) AND A.STORAGESTATUS = '501002' AND A.ISVALID = '1' AND M.CHECKORG = J.ID_(+) " + " " + " " +_Where +" ORDER BY A.INTIME DESC"; try { DataSet ds = this.DBManager.ExecuteQuery(sql,out strOut); ds.Tables[0].TableName = "KCJ_STORAGELIST"; return new ReturnObject(ds,strOut); } catch(Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null,"数据库连接错"); } } #region "获取配送中心原料入库" /// /// 获取原料入库信息 /// /// 条件 /// public ReturnObject GetInStoragePS(string _Where,string strlx,string strRole) { string strOut = ""; string sql = ""; if (strlx == "2") { sql = "SELECT A.BILLETID ,(SELECT NAME_ FROM SCM_BASE_INFO F WHERE A.PRODUCTLINE = F.ID_)PRODUCTLINE,A.ROLLNUMBER,A.MOTHERBOARDNUMBER,A.STOVENO,A.PLANNO,A.ORDERNO,A.YPLANNO,A.YORDERNO,J.NAME_ ATTESTATIONORGAN," + "A.PLY,A.WIDTH,A.LENGTH,A.THEORYWEIGHT,(SELECT NAME_ FROM SCM_BASE_INFO B WHERE A.FACEQUALITY = B.ID_)FACEQUALITY,(SELECT NAME_ FROM SCM_BASE_INFO C WHERE A.BUGREASON = C.ID_)BUGREASON,A.DETERMINANTCARDNUMBER,(SELECT NAME_ FROM SCM_BASE_INFO D WHERE A.CLIPTYPEPROCESS = D.ID_)CLIPTYPEPROCESS, TO_CHAR(m.sendbegindate, 'YYYY-MM-DD') SENDBEGINDATE," + " (SELECT NAME_ FROM SCM_BASE_INFO E WHERE A.DETERMINANTRESULT = E.ID_)DETERMINANTRESULT,A.SOURCEID,TO_CHAR(A.INTIME,'YYYY-MM-DD HH24:MI:SS') INTIME,A.CONDOLENUMBER," + " A.CHECKOPERATOR,A.IN_MAN,(SELECT NAME_ FROM SCM_BASE_INFO G WHERE A.INCLASSORDER = G.ID_)INCLASSORDER,(SELECT NAME_ FROM SCM_BASE_INFO H WHERE A.INCLASSTEAM = H.ID_)INCLASSTEAM, I.BUTTRESS,A.REMARK,A.ORDERBUYER,K.NAME_ BUSINESS_CATEGORY " + "FROM KCP_STORAGELIST A, sel_pactdetail m ,SCM_BASE_INFO J ,KCJ_STORAGEBUTTRESSLIST I ,KCJ_BASEDATA K " + "WHERE a.orderno = m.orderno(+) AND A.BILLETID = I.BILLETID(+) AND A.STORAGESTATUS = '501002' AND A.ISVALID = '1' AND M.CHECKORG = J.ID_(+) AND A.BUSINESS_CATEGORY = K.ID_(+) " + " AND (A.BILLETID LIKE 'Z%' OR A.BILLETID LIKE 'H%') " + " " + _Where + " ORDER BY A.INTIME DESC"; } else { if (strRole == "pszxck") { sql = "SELECT A.BILLETID ,(SELECT NAME_ FROM SCM_BASE_INFO F WHERE A.PRODUCTLINE = F.ID_)PRODUCTLINE,A.ROLLNUMBER,A.MOTHERBOARDNUMBER,A.STOVENO,A.PLANNO,A.ORDERNO,A.YPLANNO,A.YORDERNO,J.NAME_ ATTESTATIONORGAN," + "A.PLY,A.WIDTH,A.LENGTH,A.THEORYWEIGHT,(SELECT NAME_ FROM SCM_BASE_INFO B WHERE A.FACEQUALITY = B.ID_)FACEQUALITY,(SELECT NAME_ FROM SCM_BASE_INFO C WHERE A.BUGREASON = C.ID_)BUGREASON,A.DETERMINANTCARDNUMBER,(SELECT NAME_ FROM SCM_BASE_INFO D WHERE A.CLIPTYPEPROCESS = D.ID_)CLIPTYPEPROCESS, TO_CHAR(m.sendbegindate, 'YYYY-MM-DD') SENDBEGINDATE," + " (SELECT NAME_ FROM SCM_BASE_INFO E WHERE A.DETERMINANTRESULT = E.ID_)DETERMINANTRESULT,A.SOURCEID,TO_CHAR(A.INTIME,'YYYY-MM-DD HH24:MI:SS') INTIME,A.CONDOLENUMBER," + " A.CHECKOPERATOR,A.IN_MAN,(SELECT NAME_ FROM SCM_BASE_INFO G WHERE A.INCLASSORDER = G.ID_)INCLASSORDER,(SELECT NAME_ FROM SCM_BASE_INFO H WHERE A.INCLASSTEAM = H.ID_)INCLASSTEAM, I.BUTTRESS,A.REMARK,A.ORDERBUYER,K.NAME_ BUSINESS_CATEGORY " + "FROM KCP_STORAGELIST A, sel_pactdetail m ,SCM_BASE_INFO J ,KCJ_STORAGEBUTTRESSLIST I ,KCJ_BASEDATA K " + "WHERE a.orderno = m.orderno(+) AND A.BILLETID = I.BILLETID(+) AND A.STORAGESTATUS = '501002' AND A.ISVALID = '1' AND M.CHECKORG = J.ID_(+) AND A.BUSINESS_CATEGORY = K.ID_(+) " + " AND (A.BILLETID LIKE 'E%' OR A.BILLETID LIKE 'Y%' OR A.BILLETID LIKE 'B%')" + " " + _Where + " ORDER BY A.INTIME DESC"; } else { sql = "SELECT A.BILLETID ,(SELECT NAME_ FROM SCM_BASE_INFO F WHERE A.PRODUCTLINE = F.ID_)PRODUCTLINE,A.ROLLNUMBER,A.MOTHERBOARDNUMBER,A.STOVENO,A.PLANNO,A.ORDERNO,A.YPLANNO,A.YORDERNO,J.NAME_ ATTESTATIONORGAN," + "A.PLY,A.WIDTH,A.LENGTH,A.THEORYWEIGHT,(SELECT NAME_ FROM SCM_BASE_INFO B WHERE A.FACEQUALITY = B.ID_)FACEQUALITY,(SELECT NAME_ FROM SCM_BASE_INFO C WHERE A.BUGREASON = C.ID_)BUGREASON,A.DETERMINANTCARDNUMBER,(SELECT NAME_ FROM SCM_BASE_INFO D WHERE A.CLIPTYPEPROCESS = D.ID_)CLIPTYPEPROCESS, TO_CHAR(m.sendbegindate, 'YYYY-MM-DD') SENDBEGINDATE," + " (SELECT NAME_ FROM SCM_BASE_INFO E WHERE A.DETERMINANTRESULT = E.ID_)DETERMINANTRESULT,A.SOURCEID,TO_CHAR(A.INTIME,'YYYY-MM-DD HH24:MI:SS') INTIME,A.CONDOLENUMBER," + " A.CHECKOPERATOR,A.IN_MAN,(SELECT NAME_ FROM SCM_BASE_INFO G WHERE A.INCLASSORDER = G.ID_)INCLASSORDER,(SELECT NAME_ FROM SCM_BASE_INFO H WHERE A.INCLASSTEAM = H.ID_)INCLASSTEAM, I.BUTTRESS,A.REMARK,A.ORDERBUYER,K.NAME_ BUSINESS_CATEGORY " + "FROM KCJ_STORAGELIST A, sel_pactdetail m ,SCM_BASE_INFO J ,KCJ_STORAGEBUTTRESSLIST I ,KCJ_BASEDATA K " + "WHERE a.orderno = m.orderno(+) AND A.BILLETID = I.BILLETID(+) AND A.STORAGESTATUS = '501002' AND A.ISVALID = '1' AND M.CHECKORG = J.ID_(+) AND A.BUSINESS_CATEGORY = K.ID_(+) " + " AND (A.BILLETID LIKE 'E%' OR A.BILLETID LIKE 'Y%' OR A.BILLETID LIKE 'B%') " + " " + _Where + " ORDER BY A.INTIME DESC"; } } try { DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut); ds.Tables[0].TableName = "KCJ_STORAGELIST"; return new ReturnObject(ds, strOut); } catch (Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, "数据库连接错"); } } #endregion #region "配送中心" /// /// 原料接收入库 /// /// 板块序号信息 /// 入库信息 /// public ReturnObject Stuff_Receive_PS(ArrayList _BilletID, ArrayList _OtherInfo,string strRole) { try { string err = ""; Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2); pBilletID.Direction = ParameterDirection.Input; pOtherInfo.Direction = ParameterDirection.Input; pSuccessFlag.Direction = ParameterDirection.Output; pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pBilletID.Value = _BilletID.ToArray(typeof(string)); pOtherInfo.Value = _OtherInfo.ToArray(typeof(string)); int[] OSizeInf = new int[_BilletID.Count]; for (int i = 0; i < _BilletID.Count; i++) { OSizeInf[i] = 200; } pBilletID.Size = _BilletID.Count; pBilletID.ArrayBindSize = OSizeInf; int[] NOSizeInf = new int[_OtherInfo.Count]; for (int i = 0; i < _OtherInfo.Count; i++) { NOSizeInf[i] = 200; } pOtherInfo.Size = _OtherInfo.Count; pOtherInfo.ArrayBindSize = NOSizeInf; pSuccessFlag.Size = 400; if (strRole == "pszxck") { ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.STUFF_INSTORAGE_PS", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err); } else { ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.STUFF_INSTORAGE", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err); } if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0) { return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err); } else { return new ReturnObject('1'); } } catch (System.Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } /// /// 原料接收入库 /// /// 板块序号信息 /// 入库信息 /// public ReturnObject Stuff_Del_Recevie_PS(ArrayList _BilletID, ArrayList _OtherInfo,string strRole) { try { string err = ""; Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2); pBilletID.Direction = ParameterDirection.Input; pOtherInfo.Direction = ParameterDirection.Input; pSuccessFlag.Direction = ParameterDirection.Output; pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pBilletID.Value = _BilletID.ToArray(typeof(string)); pOtherInfo.Value = _OtherInfo.ToArray(typeof(string)); int[] OSizeInf = new int[_BilletID.Count]; for (int i = 0; i < _BilletID.Count; i++) { OSizeInf[i] = 200; } pBilletID.Size = _BilletID.Count; pBilletID.ArrayBindSize = OSizeInf; int[] NOSizeInf = new int[_OtherInfo.Count]; for (int i = 0; i < _OtherInfo.Count; i++) { NOSizeInf[i] = 200; } pOtherInfo.Size = _OtherInfo.Count; pOtherInfo.ArrayBindSize = NOSizeInf; pSuccessFlag.Size = 400; if (strRole == "pszxck") { ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.STUFF_DEL_INSTORAGE_PS", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err); } else { ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.STUFF_DEL_INSTORAGE", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err); } if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0) { return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err); } else { return new ReturnObject('1'); } } catch (System.Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } #endregion /// /// 原料接收入库 /// /// 板块序号信息 /// 入库信息 /// /// public ReturnObject HB_BZ(ArrayList _BilletID, ArrayList _OtherInfo) { try { string err = ""; Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2); pBilletID.Direction = ParameterDirection.Input; pOtherInfo.Direction = ParameterDirection.Input; pSuccessFlag.Direction = ParameterDirection.Output; pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pBilletID.Value = _BilletID.ToArray(typeof(string)); pOtherInfo.Value = _OtherInfo.ToArray(typeof(string)); int[] OSizeInf = new int[_BilletID.Count]; for (int i = 0; i < _BilletID.Count; i++) { OSizeInf[i] = 200; } pBilletID.Size = _BilletID.Count; pBilletID.ArrayBindSize = OSizeInf; int[] NOSizeInf = new int[_OtherInfo.Count]; for (int i = 0; i < _OtherInfo.Count; i++) { NOSizeInf[i] = 200; } pOtherInfo.Size = _OtherInfo.Count; pOtherInfo.ArrayBindSize = NOSizeInf; pSuccessFlag.Size = 400; ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.HB_BZ", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err); if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0) { return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err); } else { return new ReturnObject('1'); } } catch (System.Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject Car_FuraceAdd(ArrayList _BilletID, ArrayList _OtherInfo) { try { string err = ""; Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2); pBilletID.Direction = ParameterDirection.Input; pOtherInfo.Direction = ParameterDirection.Input; pSuccessFlag.Direction = ParameterDirection.Output; pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pBilletID.Value = _BilletID.ToArray(typeof(string)); pOtherInfo.Value = _OtherInfo.ToArray(typeof(string)); int[] OSizeInf = new int[_BilletID.Count]; for (int i = 0; i < _BilletID.Count; i++) { OSizeInf[i] = 200; } pBilletID.Size = _BilletID.Count; pBilletID.ArrayBindSize = OSizeInf; int[] NOSizeInf = new int[_OtherInfo.Count]; for (int i = 0; i < _OtherInfo.Count; i++) { NOSizeInf[i] = 200; } pOtherInfo.Size = _OtherInfo.Count; pOtherInfo.ArrayBindSize = NOSizeInf; pSuccessFlag.Size = 400; ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.Car_FurcaceAdd", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err); if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0) { return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err); } else { return new ReturnObject('1'); } } catch (System.Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject ProductStock_Add(ArrayList _BilletID, ArrayList _OtherInfo) { try { string err = ""; Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2); pBilletID.Direction = ParameterDirection.Input; pOtherInfo.Direction = ParameterDirection.Input; pSuccessFlag.Direction = ParameterDirection.Output; pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pBilletID.Value = _BilletID.ToArray(typeof(string)); pOtherInfo.Value = _OtherInfo.ToArray(typeof(string)); int[] OSizeInf = new int[_BilletID.Count]; for (int i = 0; i < _BilletID.Count; i++) { OSizeInf[i] = 200; } pBilletID.Size = _BilletID.Count; pBilletID.ArrayBindSize = OSizeInf; int[] NOSizeInf = new int[_OtherInfo.Count]; for (int i = 0; i < _OtherInfo.Count; i++) { NOSizeInf[i] = 200; } pOtherInfo.Size = _OtherInfo.Count; pOtherInfo.ArrayBindSize = NOSizeInf; pSuccessFlag.Size = 400; ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.ProductStock_Add", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err); if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0) { return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err); } else { return new ReturnObject('1'); } } catch (System.Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null, ex.ToString()); } } public ReturnObject Stuff_Receive(ArrayList _BilletID,ArrayList _OtherInfo) { try { string err = ""; Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2); pBilletID.Direction = ParameterDirection.Input; pOtherInfo.Direction = ParameterDirection.Input; pSuccessFlag.Direction = ParameterDirection.Output; pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pBilletID.Value = _BilletID.ToArray(typeof(string)); pOtherInfo.Value = _OtherInfo.ToArray(typeof(string)); int []OSizeInf = new int[_BilletID.Count]; for(int i =0;i< _BilletID.Count;i++) { OSizeInf[i ] = 200; } pBilletID.Size = _BilletID.Count; pBilletID.ArrayBindSize = OSizeInf; int []NOSizeInf = new int[_OtherInfo.Count]; for(int i =0;i< _OtherInfo.Count;i++) { NOSizeInf[i ] = 200; } pOtherInfo.Size = _OtherInfo.Count; pOtherInfo.ArrayBindSize = NOSizeInf; pSuccessFlag.Size = 400; ((STMes.DBManager)DBManagerList["ODPDBZW"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_WX.STUFF_INSTORAGE", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] {pBilletID,pOtherInfo,pSuccessFlag}, out err); if(Common.CheckNullStr(pSuccessFlag.Value).Length>0 | Common.CheckNullStr(err).Length>0) { return new ReturnObject(null,1,pSuccessFlag.Value.ToString()+err); } else { return new ReturnObject('1'); } } catch(System.Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null,ex.ToString()); } } public ReturnObject Storginist_Imp(System.Data.DataTable Tab_Imp, string MakeMan) { try { string Begin_MakeNO = "0"; string err = ""; string MakeTime = System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"); #region"导入Excel原始数据" err = ""; string sSql = "DELETE from KCJ_ZWIMPORT"; this.DBManager.ExecuteQuery(sSql, out err); string ESql = "SELECT BUYERNAME,PACTNO,ORDERNO,SOURCEID,ROLLNUMBER,BILLETID,DETERMINANTCARDNUMBER,PLY,WIDTH,LENGTH,THEORYWEIGHT,PLANNO,FACEQUALITY,DETERMINANTRESULT,USE,STANDARDNO,DETECTMAR,PLANVEHICLEID,STOVENO FROM KCJ_ZWIMPORT"; System.Data.DataTable Tab_Commit = DealTab_Imp(Tab_Imp, MakeMan, MakeTime); this.DBManager.UpdateTable(Tab_Commit, ESql, out err); if (err.Length > 0) { return new ReturnObject(null, err); } //string strPlan = Tab_Commit.Rows[0]["MAKETIME"].ToString(); #endregion #region "处理原始数据 生成坯料设计主从表" //err = ""; //Oracle.DataAccess.Client.OracleParameter pMakeMan = new Oracle.DataAccess.Client.OracleParameter("vMakeMan", Oracle.DataAccess.Client.OracleDbType.Varchar2); //Oracle.DataAccess.Client.OracleParameter pMakeTime = new Oracle.DataAccess.Client.OracleParameter("vMakeTime", Oracle.DataAccess.Client.OracleDbType.Varchar2); //pMakeMan.Direction = ParameterDirection.Input; //pMakeTime.Direction = ParameterDirection.Input; //pMakeMan.Value = MakeMan; //pMakeTime.Value = strPlan; //((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("Train_IMP_BJ", CommandType.StoredProcedure, // new Oracle.DataAccess.Client.OracleParameter[] { pMakeMan, pMakeTime }, out err); //if (err.Length > 0) //{ // return new ReturnObject(null, 1, err); //} //else //{ // return new ReturnObject('1'); //} return new ReturnObject('1'); #endregion } catch (System.Exception ex) { return new ReturnObject(null, ex.ToString()); } } #region "原料导入" private System.Data.DataTable DealTab_Imp(System.Data.DataTable Tab_Imp, string MakeMan, string MakeTime) { try { #region "临时变量" string MakeDate = System.DateTime.Now.ToString("yyyyMMdd"); string ch = ""; string Memo = ""; #endregion #region "表架构设置" Tab_Imp.TableName = "KCJ_ZWIMPORT"; ; Tab_Imp.Columns[0].ColumnName = "BUYERNAME"; Tab_Imp.Columns[1].ColumnName = "PACTNO"; Tab_Imp.Columns[2].ColumnName = "ORDERNO"; Tab_Imp.Columns[3].ColumnName = "SOURCEID"; Tab_Imp.Columns[4].ColumnName = "ROLLNUMBER"; Tab_Imp.Columns[5].ColumnName = "BILLETID"; Tab_Imp.Columns[6].ColumnName = "DETERMINANTCARDNUMBER"; Tab_Imp.Columns[7].ColumnName = "PLY"; Tab_Imp.Columns[8].ColumnName = "WIDTH"; //Tab_Imp.Columns.Add(new System.Data.DataColumn("WEIGHT", typeof(System.Double))); //Tab_Imp.Columns.Add(new System.Data.DataColumn("MONEY", typeof(System.Double))); //Tab_Imp.Columns.Add(new System.Data.DataColumn("PRICE", typeof(System.Double))); Tab_Imp.Columns[9].ColumnName = "LENGTH"; Tab_Imp.Columns[10].ColumnName = "THEORYWEIGHT"; Tab_Imp.Columns[11].ColumnName = "PLANNO"; Tab_Imp.Columns[12].ColumnName = "FACEQUALITY"; Tab_Imp.Columns[13].ColumnName = "DETERMINANTRESULT"; Tab_Imp.Columns[14].ColumnName = "USE"; Tab_Imp.Columns[15].ColumnName = "STANDARDNO"; Tab_Imp.Columns[16].ColumnName = "DETECTMAR"; Tab_Imp.Columns[17].ColumnName = "PLANVEHICLEID"; Tab_Imp.Columns[18].ColumnName = "STOVENO"; Tab_Imp.Columns.Add(new System.Data.DataColumn("INPUTPERSON", typeof(System.String))); Tab_Imp.Columns.Add(new System.Data.DataColumn("MAKETIME", typeof(System.String))); Tab_Imp.AcceptChanges(); #endregion #region "处理数据" foreach (System.Data.DataRow row in Tab_Imp.Rows) { if (row["BILLETID"].ToString() != "") { row.BeginEdit(); row["INPUTPERSON"] = MakeMan; row["MAKETIME"] = MakeDate; } row.EndEdit(); } #endregion #region "删除非法记录" for (int i = Tab_Imp.Rows.Count - 1; i >= 0; i--) { if (Tab_Imp.Rows[i]["BILLETID"].GetType() == typeof(System.DBNull)) { Tab_Imp.Rows[i].Delete(); } } Tab_Imp.AcceptChanges(); #endregion #region "生成提交数据" System.Data.DataTable Tab_Commit = Tab_Imp.Clone(); foreach (System.Data.DataRow row in Tab_Imp.Rows) { System.Data.DataRow nrow = Tab_Commit.NewRow(); nrow.ItemArray = row.ItemArray; Tab_Commit.Rows.Add(nrow); } #endregion return Tab_Commit; } catch (System.Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return null; } } #endregion /// /// 原料接收入库 /// /// 板块序号信息 /// 入库信息 /// public ReturnObject Stuff_Del_Recevie(ArrayList _BilletID,ArrayList _OtherInfo) { try { string err = ""; Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2); Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2); pBilletID.Direction = ParameterDirection.Input; pOtherInfo.Direction = ParameterDirection.Input; pSuccessFlag.Direction = ParameterDirection.Output; pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray; pBilletID.Value = _BilletID.ToArray(typeof(string)); pOtherInfo.Value = _OtherInfo.ToArray(typeof(string)); int []OSizeInf = new int[_BilletID.Count]; for(int i =0;i< _BilletID.Count;i++) { OSizeInf[i ] = 200; } pBilletID.Size = _BilletID.Count; pBilletID.ArrayBindSize = OSizeInf; int []NOSizeInf = new int[_OtherInfo.Count]; for(int i =0;i< _OtherInfo.Count;i++) { NOSizeInf[i ] = 200; } pOtherInfo.Size = _OtherInfo.Count; pOtherInfo.ArrayBindSize = NOSizeInf; pSuccessFlag.Size = 400; ((STMes.DBManager)DBManagerList["ODPDBZW"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_WX.STUFF_DEL_INSTORAGE", CommandType.StoredProcedure, new Oracle.DataAccess.Client.OracleParameter[] {pBilletID,pOtherInfo,pSuccessFlag}, out err); if(Common.CheckNullStr(pSuccessFlag.Value).Length>0 | Common.CheckNullStr(err).Length>0) { return new ReturnObject(null,1,pSuccessFlag.Value.ToString()+err); } else { return new ReturnObject('1'); } } catch(System.Exception ex) { System.Diagnostics.Debug.WriteLine(ex.ToString()); return new ReturnObject(null,ex.ToString()); } } } }