StuffRecevie.cs 48 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178
  1. using System;
  2. using System.Data;
  3. using Core.Mes.ServerFrameWork;
  4. using Core.Mes.IBaseInterface;
  5. using System.Collections;
  6. namespace Core.XgMes.Server.JGKC.SteelPlateManager
  7. {
  8. /// <summary>
  9. /// StuffRecevie 的摘要说明。
  10. /// </summary>
  11. public class StuffRecevie : Core.Mes.ServerFrameWork.IComponent
  12. {
  13. public StuffRecevie()
  14. {
  15. //
  16. // TODO: 在此处添加构造函数逻辑
  17. //
  18. }
  19. public override int maxValue
  20. {
  21. get
  22. {
  23. return 100;
  24. }
  25. }
  26. public override int minValue
  27. {
  28. get
  29. {
  30. return 50;
  31. }
  32. }
  33. /// <summary>
  34. /// 获取来料信息
  35. /// </summary>
  36. /// <param name="_Where">条件</param>
  37. /// <returns></returns>
  38. public ReturnObject GetSource(string _Where,string strName,string strlx)
  39. {
  40. string strOut = "";
  41. string sql = "";
  42. if (strlx == "1")
  43. {
  44. sql = "SELECT * FROM (SELECT 'FALSE' FLAG,A.SERIALNUMBER BILLETID,'厚板线' PRODUCTLINE,A.ROLLNO ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERFORMNUMBER ORDERNO,"
  45. + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY, "
  46. + "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 "
  47. + " FROM KCH_TURNOFFSENDLIST A," +
  48. " SCM_BASE_INFO B, " +
  49. " SCM_BASE_INFO D," +
  50. " SCM_BASE_INFO G,sel_pactdetail h " +
  51. " WHERE A.ISVALID='2'" +
  52. " AND A.FACEQUALITY=B.ID_(+)" +
  53. " AND A. DETERMINANTRESULT=D.ID_(+)" +
  54. " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " +
  55. _Where +
  56. " UNION ALL "
  57. +" SELECT 'FALSE' FLAG,A.SERIALNUMBER BILLETID,'板加' PRODUCTLINE,A.ROLLNO ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERFORMNUMBER ORDERNO,"
  58. + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY, "
  59. + "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 "
  60. + " FROM KCJ_TURNOFFSENDLIST A," +
  61. " SCM_BASE_INFO B, " +
  62. " SCM_BASE_INFO D," +
  63. " SCM_BASE_INFO G,sel_pactdetail h " +
  64. " WHERE A.ISVALID='2'" +
  65. " AND A.FACEQUALITY=B.ID_(+)" +
  66. " AND A. DETERMINANTRESULT=D.ID_(+)" +
  67. " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " +
  68. _Where
  69. +"UNION ALL "
  70. + "SELECT 'FALSE' FLAG,A.SERIALNUMBER BILLETID,'中板线' PRODUCTLINE,A.ROLLNO ROLLNUMBER,A.STOVENO,A.PLANNO,A.ORDERFORMNUMBER ORDERNO,"
  71. + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY,"
  72. + "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 "
  73. + " FROM KCZ_TURNOFFSENDLIST A," +
  74. " SCM_BASE_INFO B, " +
  75. " SCM_BASE_INFO D," +
  76. " SCM_BASE_INFO G,sel_pactdetail h " +
  77. " WHERE A.ISVALID='2'" +
  78. " AND A.FACEQUALITY=B.ID_(+)" +
  79. " AND A. DETERMINANTRESULT=D.ID_(+)" +
  80. " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " +
  81. _Where+" )"
  82. + " ORDER BY BILLETID ASC ";
  83. }
  84. else
  85. {
  86. 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,"
  87. + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY,"
  88. + "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 "
  89. + " FROM KCX_TURNOFFSENDLIST A," +
  90. " SCM_BASE_INFO B, " +
  91. " SCM_BASE_INFO D," +
  92. " SCM_BASE_INFO G,sel_pactdetail h " +
  93. " WHERE A.ISVALID='2'" +
  94. " AND A.FACEQUALITY=B.ID_(+)" +
  95. " AND A. DETERMINANTRESULT=D.ID_(+)" +
  96. " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " +
  97. _Where +
  98. " UNION ALL "
  99. + "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,"
  100. + "A.PLY,A.WIDTH,A.LENGTH,A.WEIGHT THEORYWEIGHT,B.NAME_ FACEQUALITY,"
  101. + "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 "
  102. + " FROM KCJ_TURNOFFSENDLIST A," +
  103. " SCM_BASE_INFO B, " +
  104. " SCM_BASE_INFO D," +
  105. " SCM_BASE_INFO G,sel_pactdetail h " +
  106. " WHERE A.ISVALID='2'" +
  107. " AND A.FACEQUALITY=B.ID_(+)" +
  108. " AND A. DETERMINANTRESULT=D.ID_(+)" +
  109. " AND H.CHECKORG =G.ID_(+) and a.ORDERFORMNUMBER = h.ORDERNO(+) " +
  110. _Where
  111. + " )ORDER BY BILLETID ASC ";
  112. }
  113. try
  114. {
  115. DataSet ds = this.DBManager.ExecuteQuery(sql,out strOut);
  116. ds.Tables[0].TableName = "KCJ_SOURCE";
  117. return new ReturnObject(ds,strOut);
  118. }
  119. catch(Exception ex)
  120. {
  121. System.Diagnostics.Debug.WriteLine(ex.ToString());
  122. return new ReturnObject(null,ex.ToString());
  123. }
  124. }
  125. /// <summary>
  126. /// 获取已导入来料信息
  127. /// </summary>
  128. /// <param name="_Where">条件</param>
  129. /// <returns></returns>
  130. public ReturnObject GetSourceImport(string strlx)
  131. {
  132. string strOut = "";
  133. 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,"
  134. + "TO_NUMBER(A.PLY)PLY,TO_NUMBER(A.WIDTH)WIDTH,TO_NUMBER(A.LENGTH)LENGTH,TO_NUMBER(A.THEORYWEIGHT)THEORYWEIGHT,B.NAME_ FACEQUALITY, "
  135. + "D.NAME_ DETERMINANTRESULT,A.DETERMINANTCARDNUMBER,A.SOURCEID,A.PLANVEHICLEID,TO_CHAR(SYSDATE,'YYYY-MM-DD') SENDTIME,''ATTESTATIONORGAN,''ORDERBUYER,BUYERNAME,PACTNO "
  136. + "FROM KCJ_ZWIMPORT A,SCM_BASE_INFO B,SCM_BASE_INFO D WHERE A.FACEQUALITY=B.ID_(+) AND A. DETERMINANTRESULT=D.ID_(+) ";
  137. try
  138. {
  139. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  140. ds.Tables[0].TableName = "KCJ_SOURCE";
  141. return new ReturnObject(ds, strOut);
  142. }
  143. catch (Exception ex)
  144. {
  145. System.Diagnostics.Debug.WriteLine(ex.ToString());
  146. return new ReturnObject(null, ex.ToString());
  147. }
  148. }
  149. /// <summary>
  150. /// 获取订单分配信息
  151. /// </summary>
  152. /// <param name="_Where">条件</param>
  153. /// <returns></returns>
  154. public ReturnObject GetOrderNoAllicat(string _Where)
  155. {
  156. string strOut = "";
  157. string sql = "";
  158. sql = "SELECT BILLETID,ORDERNO,RECODER,TIME_ FROM KCH_STEEL_CHAGE"
  159. + _Where
  160. + " AND STLYE='订单分配' AND Old_Steel='pszx'"
  161. + " ORDER BY BILLETID ASC ";
  162. try
  163. {
  164. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  165. return new ReturnObject(ds, strOut);
  166. }
  167. catch (Exception ex)
  168. {
  169. System.Diagnostics.Debug.WriteLine(ex.ToString());
  170. return new ReturnObject(null, ex.ToString());
  171. }
  172. }
  173. /// <summary>
  174. /// 获取判定记录信息
  175. /// </summary>
  176. /// <param name="_Where">条件</param>
  177. /// <returns></returns>
  178. public ReturnObject GetJudgeRecoder(string _Where)
  179. {
  180. string strOut = "";
  181. string sql = "";
  182. sql = "SELECT BILLETID,codes2names(PDJG)PDJG,PDR,TIME_,STEELNAME FROM ( "
  183. + "SELECT SLABNO BILLETID,JUDGERESULT PDJG,RECORDER PDR,RECORDTIME TIME_,STEELNAME FROM ZJZ_COLL_JUDGE WHERE SLABNO LIKE 'Z%' "
  184. + "UNION "
  185. + "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%') "
  186. + _Where
  187. + " ORDER BY BILLETID ASC ";
  188. try
  189. {
  190. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  191. return new ReturnObject(ds, strOut);
  192. }
  193. catch (Exception ex)
  194. {
  195. System.Diagnostics.Debug.WriteLine(ex.ToString());
  196. return new ReturnObject(null, ex.ToString());
  197. }
  198. }
  199. public ReturnObject GetYLButress(string _Where)
  200. {
  201. string strOut = "";
  202. string sql = "";
  203. 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' "
  204. + _Where
  205. + " GROUP BY B.BUTTRESS,SUBSTR(a.orderno,1,LENGTH(A.ORDERNO)-3) ";
  206. try
  207. {
  208. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  209. return new ReturnObject(ds, strOut);
  210. }
  211. catch (Exception ex)
  212. {
  213. System.Diagnostics.Debug.WriteLine(ex.ToString());
  214. return new ReturnObject(null, ex.ToString());
  215. }
  216. }
  217. public ReturnObject GetYLButress_Detail(string _Where)
  218. {
  219. string strOut = "";
  220. string sql = "";
  221. 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 "
  222. + " FROM KCP_STORAGELIST A, KCJ_STORAGEBUTTRESSLIST B,SCM_BASE_INFO C ,SCM_BASE_INFO D "
  223. + " WHERE A.BILLETID = B.BILLETID AND A.DETERMINANTRESULT=C.ID_(+) AND A.PRODUCT_NAME=D.ID_(+) "
  224. + " AND A.STORAGESTATUS = '501002' "
  225. + _Where
  226. + " ORDER BY A.BILLETID ";
  227. try
  228. {
  229. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  230. return new ReturnObject(ds, strOut);
  231. }
  232. catch (Exception ex)
  233. {
  234. System.Diagnostics.Debug.WriteLine(ex.ToString());
  235. return new ReturnObject(null, ex.ToString());
  236. }
  237. }
  238. public ReturnObject GetCPButress_Detail(string _Where)
  239. {
  240. string strOut = "";
  241. string sql = "";
  242. 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 "
  243. + " FROM KCJ_TURNOFFLIST A, KCJ_TURNOFFBUTTRESSLIST B,SCM_BASE_INFO C ,SCM_BASE_INFO D "
  244. + " WHERE A.BILLETID = B.BILLETID AND A.DETERMINANTRESULT=C.ID_(+) AND A.PRODUCT_NAME=D.ID_(+) "
  245. + " AND A.STORAGESTATUS = '501602' "
  246. + _Where
  247. + " ORDER BY A.BILLETID ";
  248. try
  249. {
  250. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  251. return new ReturnObject(ds, strOut);
  252. }
  253. catch (Exception ex)
  254. {
  255. System.Diagnostics.Debug.WriteLine(ex.ToString());
  256. return new ReturnObject(null, ex.ToString());
  257. }
  258. }
  259. public ReturnObject GetCPButress(string _Where)
  260. {
  261. string strOut = "";
  262. string sql = "";
  263. 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' "
  264. + _Where
  265. + " GROUP BY B.BUTTRESS,SUBSTR(a.orderno,1,LENGTH(A.ORDERNO)-3) ";
  266. try
  267. {
  268. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  269. return new ReturnObject(ds, strOut);
  270. }
  271. catch (Exception ex)
  272. {
  273. System.Diagnostics.Debug.WriteLine(ex.ToString());
  274. return new ReturnObject(null, ex.ToString());
  275. }
  276. }
  277. public ReturnObject GetYLButress_XB(string _Where)
  278. {
  279. string strOut = "";
  280. string sql = "";
  281. 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' "
  282. + _Where
  283. + " GROUP BY B.BUTTRESS,A.PLY,A.LENGTH ";
  284. try
  285. {
  286. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  287. return new ReturnObject(ds, strOut);
  288. }
  289. catch (Exception ex)
  290. {
  291. System.Diagnostics.Debug.WriteLine(ex.ToString());
  292. return new ReturnObject(null, ex.ToString());
  293. }
  294. }
  295. public ReturnObject GetCPButress_XB(string _Where)
  296. {
  297. string strOut = "";
  298. string sql = "";
  299. 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' "
  300. + _Where
  301. + " GROUP BY B.BUTTRESS,A.PLY,A.LENGTH ";
  302. try
  303. {
  304. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  305. return new ReturnObject(ds, strOut);
  306. }
  307. catch (Exception ex)
  308. {
  309. System.Diagnostics.Debug.WriteLine(ex.ToString());
  310. return new ReturnObject(null, ex.ToString());
  311. }
  312. }
  313. /// <summary>
  314. /// 获取原料入库信息
  315. /// </summary>
  316. /// <param name=" _Where">条件</param>
  317. /// <returns></returns>
  318. public ReturnObject GetInStorage(string _Where)
  319. {
  320. string strOut = "";
  321. string sql = "";
  322. 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,"
  323. + "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,"
  324. + " (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,"
  325. + " 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 "
  326. + "FROM KCJ_STORAGELIST_ZW A, sel_pactdetail m ,SCM_BASE_INFO J ,KCJ_STORAGEBUTTRESSLIST_ZW I "
  327. + "WHERE a.orderno = m.orderno(+) AND A.BILLETID = I.BILLETID(+) AND A.STORAGESTATUS = '501002' AND A.ISVALID = '1' AND M.CHECKORG = J.ID_(+) "
  328. + " "
  329. + " "
  330. +_Where
  331. +" ORDER BY A.INTIME DESC";
  332. try
  333. {
  334. DataSet ds = this.DBManager.ExecuteQuery(sql,out strOut);
  335. ds.Tables[0].TableName = "KCJ_STORAGELIST";
  336. return new ReturnObject(ds,strOut);
  337. }
  338. catch(Exception ex)
  339. {
  340. System.Diagnostics.Debug.WriteLine(ex.ToString());
  341. return new ReturnObject(null,"数据库连接错");
  342. }
  343. }
  344. #region "获取配送中心原料入库"
  345. /// <summary>
  346. /// 获取原料入库信息
  347. /// </summary>
  348. /// <param name=" _Where">条件</param>
  349. /// <returns></returns>
  350. public ReturnObject GetInStoragePS(string _Where,string strlx,string strRole)
  351. {
  352. string strOut = "";
  353. string sql = "";
  354. if (strlx == "2")
  355. {
  356. 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,"
  357. + "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,"
  358. + " (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,"
  359. + " 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 "
  360. + "FROM KCP_STORAGELIST A, sel_pactdetail m ,SCM_BASE_INFO J ,KCJ_STORAGEBUTTRESSLIST I ,KCJ_BASEDATA K "
  361. + "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_(+) "
  362. + " AND (A.BILLETID LIKE 'Z%' OR A.BILLETID LIKE 'H%') "
  363. + " "
  364. + _Where
  365. + " ORDER BY A.INTIME DESC";
  366. }
  367. else
  368. {
  369. if (strRole == "pszxck")
  370. {
  371. 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,"
  372. + "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,"
  373. + " (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,"
  374. + " 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 "
  375. + "FROM KCP_STORAGELIST A, sel_pactdetail m ,SCM_BASE_INFO J ,KCJ_STORAGEBUTTRESSLIST I ,KCJ_BASEDATA K "
  376. + "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_(+) "
  377. + " AND (A.BILLETID LIKE 'E%' OR A.BILLETID LIKE 'Y%' OR A.BILLETID LIKE 'B%')"
  378. + " "
  379. + _Where
  380. + " ORDER BY A.INTIME DESC";
  381. }
  382. else
  383. {
  384. 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,"
  385. + "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,"
  386. + " (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,"
  387. + " 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 "
  388. + "FROM KCJ_STORAGELIST A, sel_pactdetail m ,SCM_BASE_INFO J ,KCJ_STORAGEBUTTRESSLIST I ,KCJ_BASEDATA K "
  389. + "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_(+) "
  390. + " AND (A.BILLETID LIKE 'E%' OR A.BILLETID LIKE 'Y%' OR A.BILLETID LIKE 'B%') "
  391. + " "
  392. + _Where
  393. + " ORDER BY A.INTIME DESC";
  394. }
  395. }
  396. try
  397. {
  398. DataSet ds = this.DBManager.ExecuteQuery(sql, out strOut);
  399. ds.Tables[0].TableName = "KCJ_STORAGELIST";
  400. return new ReturnObject(ds, strOut);
  401. }
  402. catch (Exception ex)
  403. {
  404. System.Diagnostics.Debug.WriteLine(ex.ToString());
  405. return new ReturnObject(null, "数据库连接错");
  406. }
  407. }
  408. #endregion
  409. #region "配送中心"
  410. /// <summary>
  411. /// 原料接收入库
  412. /// </summary>
  413. /// <param name="_BilletID ">板块序号信息</param>
  414. /// <param name="_OtherInfo ">入库信息</param>
  415. /// <returns></returns>
  416. public ReturnObject Stuff_Receive_PS(ArrayList _BilletID, ArrayList _OtherInfo,string strRole)
  417. {
  418. try
  419. {
  420. string err = "";
  421. Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  422. Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  423. Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  424. pBilletID.Direction = ParameterDirection.Input;
  425. pOtherInfo.Direction = ParameterDirection.Input;
  426. pSuccessFlag.Direction = ParameterDirection.Output;
  427. pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  428. pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  429. pBilletID.Value = _BilletID.ToArray(typeof(string));
  430. pOtherInfo.Value = _OtherInfo.ToArray(typeof(string));
  431. int[] OSizeInf = new int[_BilletID.Count];
  432. for (int i = 0; i < _BilletID.Count; i++)
  433. {
  434. OSizeInf[i] = 200;
  435. }
  436. pBilletID.Size = _BilletID.Count;
  437. pBilletID.ArrayBindSize = OSizeInf;
  438. int[] NOSizeInf = new int[_OtherInfo.Count];
  439. for (int i = 0; i < _OtherInfo.Count; i++)
  440. {
  441. NOSizeInf[i] = 200;
  442. }
  443. pOtherInfo.Size = _OtherInfo.Count;
  444. pOtherInfo.ArrayBindSize = NOSizeInf;
  445. pSuccessFlag.Size = 400;
  446. if (strRole == "pszxck")
  447. {
  448. ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.STUFF_INSTORAGE_PS", CommandType.StoredProcedure,
  449. new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err);
  450. }
  451. else
  452. {
  453. ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.STUFF_INSTORAGE", CommandType.StoredProcedure,
  454. new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err);
  455. }
  456. if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0)
  457. {
  458. return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err);
  459. }
  460. else
  461. {
  462. return new ReturnObject('1');
  463. }
  464. }
  465. catch (System.Exception ex)
  466. {
  467. System.Diagnostics.Debug.WriteLine(ex.ToString());
  468. return new ReturnObject(null, ex.ToString());
  469. }
  470. }
  471. /// <summary>
  472. /// 原料接收入库
  473. /// </summary>
  474. /// <param name="_BilletID ">板块序号信息</param>
  475. /// <param name="_OtherInfo ">入库信息</param>
  476. /// <returns></returns>
  477. public ReturnObject Stuff_Del_Recevie_PS(ArrayList _BilletID, ArrayList _OtherInfo,string strRole)
  478. {
  479. try
  480. {
  481. string err = "";
  482. Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  483. Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  484. Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  485. pBilletID.Direction = ParameterDirection.Input;
  486. pOtherInfo.Direction = ParameterDirection.Input;
  487. pSuccessFlag.Direction = ParameterDirection.Output;
  488. pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  489. pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  490. pBilletID.Value = _BilletID.ToArray(typeof(string));
  491. pOtherInfo.Value = _OtherInfo.ToArray(typeof(string));
  492. int[] OSizeInf = new int[_BilletID.Count];
  493. for (int i = 0; i < _BilletID.Count; i++)
  494. {
  495. OSizeInf[i] = 200;
  496. }
  497. pBilletID.Size = _BilletID.Count;
  498. pBilletID.ArrayBindSize = OSizeInf;
  499. int[] NOSizeInf = new int[_OtherInfo.Count];
  500. for (int i = 0; i < _OtherInfo.Count; i++)
  501. {
  502. NOSizeInf[i] = 200;
  503. }
  504. pOtherInfo.Size = _OtherInfo.Count;
  505. pOtherInfo.ArrayBindSize = NOSizeInf;
  506. pSuccessFlag.Size = 400;
  507. if (strRole == "pszxck")
  508. {
  509. ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.STUFF_DEL_INSTORAGE_PS", CommandType.StoredProcedure,
  510. new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err);
  511. }
  512. else
  513. {
  514. ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.STUFF_DEL_INSTORAGE", CommandType.StoredProcedure,
  515. new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err);
  516. }
  517. if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0)
  518. {
  519. return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err);
  520. }
  521. else
  522. {
  523. return new ReturnObject('1');
  524. }
  525. }
  526. catch (System.Exception ex)
  527. {
  528. System.Diagnostics.Debug.WriteLine(ex.ToString());
  529. return new ReturnObject(null, ex.ToString());
  530. }
  531. }
  532. #endregion
  533. /// <summary>
  534. /// 原料接收入库
  535. /// </summary>
  536. /// <param name="_BilletID ">板块序号信息</param>
  537. /// <param name="_OtherInfo ">入库信息</param>
  538. /// <returns></returns>
  539. ///
  540. public ReturnObject HB_BZ(ArrayList _BilletID, ArrayList _OtherInfo)
  541. {
  542. try
  543. {
  544. string err = "";
  545. Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  546. Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  547. Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  548. pBilletID.Direction = ParameterDirection.Input;
  549. pOtherInfo.Direction = ParameterDirection.Input;
  550. pSuccessFlag.Direction = ParameterDirection.Output;
  551. pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  552. pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  553. pBilletID.Value = _BilletID.ToArray(typeof(string));
  554. pOtherInfo.Value = _OtherInfo.ToArray(typeof(string));
  555. int[] OSizeInf = new int[_BilletID.Count];
  556. for (int i = 0; i < _BilletID.Count; i++)
  557. {
  558. OSizeInf[i] = 200;
  559. }
  560. pBilletID.Size = _BilletID.Count;
  561. pBilletID.ArrayBindSize = OSizeInf;
  562. int[] NOSizeInf = new int[_OtherInfo.Count];
  563. for (int i = 0; i < _OtherInfo.Count; i++)
  564. {
  565. NOSizeInf[i] = 200;
  566. }
  567. pOtherInfo.Size = _OtherInfo.Count;
  568. pOtherInfo.ArrayBindSize = NOSizeInf;
  569. pSuccessFlag.Size = 400;
  570. ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.HB_BZ", CommandType.StoredProcedure,
  571. new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err);
  572. if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0)
  573. {
  574. return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err);
  575. }
  576. else
  577. {
  578. return new ReturnObject('1');
  579. }
  580. }
  581. catch (System.Exception ex)
  582. {
  583. System.Diagnostics.Debug.WriteLine(ex.ToString());
  584. return new ReturnObject(null, ex.ToString());
  585. }
  586. }
  587. public ReturnObject Car_FuraceAdd(ArrayList _BilletID, ArrayList _OtherInfo)
  588. {
  589. try
  590. {
  591. string err = "";
  592. Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  593. Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  594. Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  595. pBilletID.Direction = ParameterDirection.Input;
  596. pOtherInfo.Direction = ParameterDirection.Input;
  597. pSuccessFlag.Direction = ParameterDirection.Output;
  598. pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  599. pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  600. pBilletID.Value = _BilletID.ToArray(typeof(string));
  601. pOtherInfo.Value = _OtherInfo.ToArray(typeof(string));
  602. int[] OSizeInf = new int[_BilletID.Count];
  603. for (int i = 0; i < _BilletID.Count; i++)
  604. {
  605. OSizeInf[i] = 200;
  606. }
  607. pBilletID.Size = _BilletID.Count;
  608. pBilletID.ArrayBindSize = OSizeInf;
  609. int[] NOSizeInf = new int[_OtherInfo.Count];
  610. for (int i = 0; i < _OtherInfo.Count; i++)
  611. {
  612. NOSizeInf[i] = 200;
  613. }
  614. pOtherInfo.Size = _OtherInfo.Count;
  615. pOtherInfo.ArrayBindSize = NOSizeInf;
  616. pSuccessFlag.Size = 400;
  617. ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.Car_FurcaceAdd", CommandType.StoredProcedure,
  618. new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err);
  619. if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0)
  620. {
  621. return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err);
  622. }
  623. else
  624. {
  625. return new ReturnObject('1');
  626. }
  627. }
  628. catch (System.Exception ex)
  629. {
  630. System.Diagnostics.Debug.WriteLine(ex.ToString());
  631. return new ReturnObject(null, ex.ToString());
  632. }
  633. }
  634. public ReturnObject ProductStock_Add(ArrayList _BilletID, ArrayList _OtherInfo)
  635. {
  636. try
  637. {
  638. string err = "";
  639. Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  640. Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  641. Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  642. pBilletID.Direction = ParameterDirection.Input;
  643. pOtherInfo.Direction = ParameterDirection.Input;
  644. pSuccessFlag.Direction = ParameterDirection.Output;
  645. pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  646. pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  647. pBilletID.Value = _BilletID.ToArray(typeof(string));
  648. pOtherInfo.Value = _OtherInfo.ToArray(typeof(string));
  649. int[] OSizeInf = new int[_BilletID.Count];
  650. for (int i = 0; i < _BilletID.Count; i++)
  651. {
  652. OSizeInf[i] = 200;
  653. }
  654. pBilletID.Size = _BilletID.Count;
  655. pBilletID.ArrayBindSize = OSizeInf;
  656. int[] NOSizeInf = new int[_OtherInfo.Count];
  657. for (int i = 0; i < _OtherInfo.Count; i++)
  658. {
  659. NOSizeInf[i] = 200;
  660. }
  661. pOtherInfo.Size = _OtherInfo.Count;
  662. pOtherInfo.ArrayBindSize = NOSizeInf;
  663. pSuccessFlag.Size = 400;
  664. ((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_K.ProductStock_Add", CommandType.StoredProcedure,
  665. new Oracle.DataAccess.Client.OracleParameter[] { pBilletID, pOtherInfo, pSuccessFlag }, out err);
  666. if (Common.CheckNullStr(pSuccessFlag.Value).Length > 0 | Common.CheckNullStr(err).Length > 0)
  667. {
  668. return new ReturnObject(null, 1, pSuccessFlag.Value.ToString() + err);
  669. }
  670. else
  671. {
  672. return new ReturnObject('1');
  673. }
  674. }
  675. catch (System.Exception ex)
  676. {
  677. System.Diagnostics.Debug.WriteLine(ex.ToString());
  678. return new ReturnObject(null, ex.ToString());
  679. }
  680. }
  681. public ReturnObject Stuff_Receive(ArrayList _BilletID,ArrayList _OtherInfo)
  682. {
  683. try
  684. {
  685. string err = "";
  686. Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  687. Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  688. Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  689. pBilletID.Direction = ParameterDirection.Input;
  690. pOtherInfo.Direction = ParameterDirection.Input;
  691. pSuccessFlag.Direction = ParameterDirection.Output;
  692. pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  693. pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  694. pBilletID.Value = _BilletID.ToArray(typeof(string));
  695. pOtherInfo.Value = _OtherInfo.ToArray(typeof(string));
  696. int []OSizeInf = new int[_BilletID.Count];
  697. for(int i =0;i< _BilletID.Count;i++)
  698. {
  699. OSizeInf[i ] = 200;
  700. }
  701. pBilletID.Size = _BilletID.Count;
  702. pBilletID.ArrayBindSize = OSizeInf;
  703. int []NOSizeInf = new int[_OtherInfo.Count];
  704. for(int i =0;i< _OtherInfo.Count;i++)
  705. {
  706. NOSizeInf[i ] = 200;
  707. }
  708. pOtherInfo.Size = _OtherInfo.Count;
  709. pOtherInfo.ArrayBindSize = NOSizeInf;
  710. pSuccessFlag.Size = 400;
  711. ((STMes.DBManager)DBManagerList["ODPDBZW"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_WX.STUFF_INSTORAGE", CommandType.StoredProcedure,
  712. new Oracle.DataAccess.Client.OracleParameter[]
  713. {pBilletID,pOtherInfo,pSuccessFlag}, out err);
  714. if(Common.CheckNullStr(pSuccessFlag.Value).Length>0 | Common.CheckNullStr(err).Length>0)
  715. {
  716. return new ReturnObject(null,1,pSuccessFlag.Value.ToString()+err);
  717. }
  718. else
  719. {
  720. return new ReturnObject('1');
  721. }
  722. }
  723. catch(System.Exception ex)
  724. {
  725. System.Diagnostics.Debug.WriteLine(ex.ToString());
  726. return new ReturnObject(null,ex.ToString());
  727. }
  728. }
  729. public ReturnObject Storginist_Imp(System.Data.DataTable Tab_Imp, string MakeMan)
  730. {
  731. try
  732. {
  733. string Begin_MakeNO = "0";
  734. string err = "";
  735. string MakeTime = System.DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
  736. #region"导入Excel原始数据"
  737. err = "";
  738. string sSql = "DELETE from KCJ_ZWIMPORT";
  739. this.DBManager.ExecuteQuery(sSql, out err);
  740. 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";
  741. System.Data.DataTable Tab_Commit = DealTab_Imp(Tab_Imp, MakeMan, MakeTime);
  742. this.DBManager.UpdateTable(Tab_Commit, ESql, out err);
  743. if (err.Length > 0)
  744. {
  745. return new ReturnObject(null, err);
  746. }
  747. //string strPlan = Tab_Commit.Rows[0]["MAKETIME"].ToString();
  748. #endregion
  749. #region "处理原始数据 生成坯料设计主从表"
  750. //err = "";
  751. //Oracle.DataAccess.Client.OracleParameter pMakeMan = new Oracle.DataAccess.Client.OracleParameter("vMakeMan", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  752. //Oracle.DataAccess.Client.OracleParameter pMakeTime = new Oracle.DataAccess.Client.OracleParameter("vMakeTime", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  753. //pMakeMan.Direction = ParameterDirection.Input;
  754. //pMakeTime.Direction = ParameterDirection.Input;
  755. //pMakeMan.Value = MakeMan;
  756. //pMakeTime.Value = strPlan;
  757. //((STMes.DBManager)DBManagerList["ODPDB"]).ExecuteNonQuery_NoDBSever("Train_IMP_BJ", CommandType.StoredProcedure,
  758. // new Oracle.DataAccess.Client.OracleParameter[] { pMakeMan, pMakeTime }, out err);
  759. //if (err.Length > 0)
  760. //{
  761. // return new ReturnObject(null, 1, err);
  762. //}
  763. //else
  764. //{
  765. // return new ReturnObject('1');
  766. //}
  767. return new ReturnObject('1');
  768. #endregion
  769. }
  770. catch (System.Exception ex)
  771. {
  772. return new ReturnObject(null, ex.ToString());
  773. }
  774. }
  775. #region "原料导入"
  776. private System.Data.DataTable DealTab_Imp(System.Data.DataTable Tab_Imp, string MakeMan, string MakeTime)
  777. {
  778. try
  779. {
  780. #region "临时变量"
  781. string MakeDate = System.DateTime.Now.ToString("yyyyMMdd");
  782. string ch = "";
  783. string Memo = "";
  784. #endregion
  785. #region "表架构设置"
  786. Tab_Imp.TableName = "KCJ_ZWIMPORT"; ;
  787. Tab_Imp.Columns[0].ColumnName = "BUYERNAME";
  788. Tab_Imp.Columns[1].ColumnName = "PACTNO";
  789. Tab_Imp.Columns[2].ColumnName = "ORDERNO";
  790. Tab_Imp.Columns[3].ColumnName = "SOURCEID";
  791. Tab_Imp.Columns[4].ColumnName = "ROLLNUMBER";
  792. Tab_Imp.Columns[5].ColumnName = "BILLETID";
  793. Tab_Imp.Columns[6].ColumnName = "DETERMINANTCARDNUMBER";
  794. Tab_Imp.Columns[7].ColumnName = "PLY";
  795. Tab_Imp.Columns[8].ColumnName = "WIDTH";
  796. //Tab_Imp.Columns.Add(new System.Data.DataColumn("WEIGHT", typeof(System.Double)));
  797. //Tab_Imp.Columns.Add(new System.Data.DataColumn("MONEY", typeof(System.Double)));
  798. //Tab_Imp.Columns.Add(new System.Data.DataColumn("PRICE", typeof(System.Double)));
  799. Tab_Imp.Columns[9].ColumnName = "LENGTH";
  800. Tab_Imp.Columns[10].ColumnName = "THEORYWEIGHT";
  801. Tab_Imp.Columns[11].ColumnName = "PLANNO";
  802. Tab_Imp.Columns[12].ColumnName = "FACEQUALITY";
  803. Tab_Imp.Columns[13].ColumnName = "DETERMINANTRESULT";
  804. Tab_Imp.Columns[14].ColumnName = "USE";
  805. Tab_Imp.Columns[15].ColumnName = "STANDARDNO";
  806. Tab_Imp.Columns[16].ColumnName = "DETECTMAR";
  807. Tab_Imp.Columns[17].ColumnName = "PLANVEHICLEID";
  808. Tab_Imp.Columns[18].ColumnName = "STOVENO";
  809. Tab_Imp.Columns.Add(new System.Data.DataColumn("INPUTPERSON", typeof(System.String)));
  810. Tab_Imp.Columns.Add(new System.Data.DataColumn("MAKETIME", typeof(System.String)));
  811. Tab_Imp.AcceptChanges();
  812. #endregion
  813. #region "处理数据"
  814. foreach (System.Data.DataRow row in Tab_Imp.Rows)
  815. {
  816. if (row["BILLETID"].ToString() != "")
  817. {
  818. row.BeginEdit();
  819. row["INPUTPERSON"] = MakeMan;
  820. row["MAKETIME"] = MakeDate;
  821. }
  822. row.EndEdit();
  823. }
  824. #endregion
  825. #region "删除非法记录"
  826. for (int i = Tab_Imp.Rows.Count - 1; i >= 0; i--)
  827. {
  828. if (Tab_Imp.Rows[i]["BILLETID"].GetType() == typeof(System.DBNull))
  829. {
  830. Tab_Imp.Rows[i].Delete();
  831. }
  832. }
  833. Tab_Imp.AcceptChanges();
  834. #endregion
  835. #region "生成提交数据"
  836. System.Data.DataTable Tab_Commit = Tab_Imp.Clone();
  837. foreach (System.Data.DataRow row in Tab_Imp.Rows)
  838. {
  839. System.Data.DataRow nrow = Tab_Commit.NewRow();
  840. nrow.ItemArray = row.ItemArray;
  841. Tab_Commit.Rows.Add(nrow);
  842. }
  843. #endregion
  844. return Tab_Commit;
  845. }
  846. catch (System.Exception ex)
  847. {
  848. System.Diagnostics.Debug.WriteLine(ex.ToString());
  849. return null;
  850. }
  851. }
  852. #endregion
  853. /// <summary>
  854. /// 原料接收入库
  855. /// </summary>
  856. /// <param name="_BilletID ">板块序号信息</param>
  857. /// <param name="_OtherInfo ">入库信息</param>
  858. /// <returns></returns>
  859. public ReturnObject Stuff_Del_Recevie(ArrayList _BilletID,ArrayList _OtherInfo)
  860. {
  861. try
  862. {
  863. string err = "";
  864. Oracle.DataAccess.Client.OracleParameter pBilletID = new Oracle.DataAccess.Client.OracleParameter("vBillet", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  865. Oracle.DataAccess.Client.OracleParameter pOtherInfo = new Oracle.DataAccess.Client.OracleParameter("vOtherInfo", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  866. Oracle.DataAccess.Client.OracleParameter pSuccessFlag = new Oracle.DataAccess.Client.OracleParameter("vSuccessFlag", Oracle.DataAccess.Client.OracleDbType.Varchar2);
  867. pBilletID.Direction = ParameterDirection.Input;
  868. pOtherInfo.Direction = ParameterDirection.Input;
  869. pSuccessFlag.Direction = ParameterDirection.Output;
  870. pBilletID.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  871. pOtherInfo.CollectionType = Oracle.DataAccess.Client.OracleCollectionType.PLSQLAssociativeArray;
  872. pBilletID.Value = _BilletID.ToArray(typeof(string));
  873. pOtherInfo.Value = _OtherInfo.ToArray(typeof(string));
  874. int []OSizeInf = new int[_BilletID.Count];
  875. for(int i =0;i< _BilletID.Count;i++)
  876. {
  877. OSizeInf[i ] = 200;
  878. }
  879. pBilletID.Size = _BilletID.Count;
  880. pBilletID.ArrayBindSize = OSizeInf;
  881. int []NOSizeInf = new int[_OtherInfo.Count];
  882. for(int i =0;i< _OtherInfo.Count;i++)
  883. {
  884. NOSizeInf[i ] = 200;
  885. }
  886. pOtherInfo.Size = _OtherInfo.Count;
  887. pOtherInfo.ArrayBindSize = NOSizeInf;
  888. pSuccessFlag.Size = 400;
  889. ((STMes.DBManager)DBManagerList["ODPDBZW"]).ExecuteNonQuery_NoDBSever("KCJ_STORAGEMANAGER_WX.STUFF_DEL_INSTORAGE", CommandType.StoredProcedure,
  890. new Oracle.DataAccess.Client.OracleParameter[]
  891. {pBilletID,pOtherInfo,pSuccessFlag}, out err);
  892. if(Common.CheckNullStr(pSuccessFlag.Value).Length>0 | Common.CheckNullStr(err).Length>0)
  893. {
  894. return new ReturnObject(null,1,pSuccessFlag.Value.ToString()+err);
  895. }
  896. else
  897. {
  898. return new ReturnObject('1');
  899. }
  900. }
  901. catch(System.Exception ex)
  902. {
  903. System.Diagnostics.Debug.WriteLine(ex.ToString());
  904. return new ReturnObject(null,ex.ToString());
  905. }
  906. }
  907. }
  908. }