4aedac80e65dda70423b9b765221f9ce40763eb3.svn-base 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550
  1. package UIF.UIF04;
  2. import java.sql.SQLException;
  3. import java.util.ArrayList;
  4. import UIB.COM.XmlSqlParsersFactory;
  5. import CoreFS.SA01.CoreIComponent;
  6. import CoreFS.SA06.CoreReturnObject;
  7. public class UIF042010 extends CoreIComponent {
  8. public CoreReturnObject query01() throws SQLException
  9. {
  10. CoreReturnObject cro=new CoreReturnObject();
  11. StringBuffer str = new StringBuffer();
  12. str.append("SELECT \n");
  13. str.append(" '' WTH_GRP_CD --轧制单元号 \n");
  14. str.append(" ,0 WTH_MINI --单元内序号 \n");
  15. str.append(" ,0 WTH_MAXI --轧制序号 \n");
  16. str.append(" ,SUM(DECODE(THK_GRP_CD,'T01',MINI,0)) T01_CNT \n");
  17. str.append(" ,SUM(DECODE(THK_GRP_CD,'T01',MAXI,0)) T01_WGT \n");
  18. str.append(" ,SUM(DECODE(THK_GRP_CD,'T02',MINI,0)) T02_CNT \n");
  19. str.append(" ,SUM(DECODE(THK_GRP_CD,'T02',MAXI,0)) T02_WGT \n");
  20. str.append(" ,SUM(DECODE(THK_GRP_CD,'T03',MINI,0)) T03_CNT \n");
  21. str.append(" ,SUM(DECODE(THK_GRP_CD,'T03',MAXI,0)) T03_WGT \n");
  22. str.append(" ,SUM(DECODE(THK_GRP_CD,'T04',MINI,0)) T04_CNT \n");
  23. str.append(" ,SUM(DECODE(THK_GRP_CD,'T04',MAXI,0)) T04_WGT \n");
  24. str.append(" ,SUM(DECODE(THK_GRP_CD,'T05',MINI,0)) T05_CNT \n");
  25. str.append(" ,SUM(DECODE(THK_GRP_CD,'T05',MAXI,0)) T05_WGT \n");
  26. str.append(" ,SUM(DECODE(THK_GRP_CD,'T06',MINI,0)) T06_CNT \n");
  27. str.append(" ,SUM(DECODE(THK_GRP_CD,'T06',MAXI,0)) T06_WGT \n");
  28. str.append(" ,SUM(DECODE(THK_GRP_CD,'T07',MINI,0)) T07_CNT \n");
  29. str.append(" ,SUM(DECODE(THK_GRP_CD,'T07',MAXI,0)) T07_WGT \n");
  30. str.append(" ,SUM(DECODE(THK_GRP_CD,'T08',MINI,0)) T08_CNT \n");
  31. str.append(" ,SUM(DECODE(THK_GRP_CD,'T08',MAXI,0)) T08_WGT \n");
  32. str.append(" ,SUM(DECODE(THK_GRP_CD,'T09',MINI,0)) T09_CNT \n");
  33. str.append(" ,SUM(DECODE(THK_GRP_CD,'T09',MAXI,0)) T09_WGT \n");
  34. str.append(" ,0 MINI \n");
  35. str.append(" ,0 MAXI \n");
  36. str.append("FROM TBF02_ROLL_THK_GRP \n");
  37. str.append("WHERE PLT = 'C' \n");
  38. str.append("UNION ALL \n");
  39. str.append(" \n");
  40. str.append(" \n");
  41. str.append("SELECT C.WTH_GRP_CD, --宽度组 \n");
  42. str.append(" C.MINI WTH_MINI, --宽度组下限 \n");
  43. str.append(" C.MAXI WTH_MAXI, --宽度组上限 \n");
  44. str.append(" A.T01_CNT, --已编制板坯数量 \n");
  45. str.append(" A.T01_WGT, --已编制板坯质量 \n");
  46. str.append(" A.T02_CNT, --已编制板坯数量 \n");
  47. str.append(" A.T02_WGT, --已编制板坯质量 \n");
  48. str.append(" A.T03_CNT, --已编制板坯数量 \n");
  49. str.append(" A.T03_WGT, --已编制板坯质量 \n");
  50. str.append(" A.T04_CNT, --已编制板坯数量 \n");
  51. str.append(" A.T04_WGT, --已编制板坯质量 \n");
  52. str.append(" A.T05_CNT, --已编制板坯数量 \n");
  53. str.append(" A.T05_WGT, --已编制板坯质量 \n");
  54. str.append(" A.T06_CNT, --已编制板坯数量 \n");
  55. str.append(" A.T06_WGT, --已编制板坯质量 \n");
  56. str.append(" A.T07_CNT, --已编制板坯数量 \n");
  57. str.append(" A.T07_WGT, --已编制板坯质量 \n");
  58. str.append(" A.T08_CNT, --已编制板坯数量 \n");
  59. str.append(" A.T08_WGT, --已编制板坯质量 \n");
  60. str.append(" A.T09_CNT, --已编制板坯数量 \n");
  61. str.append(" A.T09_WGT, --已编制板坯质量 \n");
  62. str.append(" --A.MILL_LEN, --轧制长度 \n");
  63. str.append(" D.MINI, --编制量下限 \n");
  64. str.append(" D.MAXI --编制量上限 \n");
  65. str.append(" -- A.ROLL_DTIME, --注册时间 \n");
  66. str.append(" -- C.WTH_GRP_CD CD_SEQ --宽度组排序序号 \n");
  67. str.append("FROM (SELECT DISTINCT WTH_GRP_CD \n");
  68. str.append(" ,sum(DECODE(THK_GRP_CD , 'T01',ROLL_COIL_CNT,0)) T01_CNT \n");
  69. str.append(" ,sum(DECODE(THK_GRP_CD , 'T01',ROLL_COIL_WGT,0)) T01_WGT \n");
  70. str.append(" ,sum(DECODE(THK_GRP_CD , 'T02',ROLL_COIL_CNT,0)) T02_CNT \n");
  71. str.append(" ,sum(DECODE(THK_GRP_CD , 'T02',ROLL_COIL_WGT,0)) T02_WGT \n");
  72. str.append(" ,sum(DECODE(THK_GRP_CD , 'T03',ROLL_COIL_CNT,0)) T03_CNT \n");
  73. str.append(" ,sum(DECODE(THK_GRP_CD , 'T03',ROLL_COIL_WGT,0)) T03_WGT \n");
  74. str.append(" ,sum(DECODE(THK_GRP_CD , 'T04',ROLL_COIL_CNT,0)) T04_CNT \n");
  75. str.append(" ,sum(DECODE(THK_GRP_CD , 'T04',ROLL_COIL_WGT,0)) T04_WGT \n");
  76. str.append(" ,sum(DECODE(THK_GRP_CD , 'T05',ROLL_COIL_CNT,0)) T05_CNT \n");
  77. str.append(" ,sum(DECODE(THK_GRP_CD , 'T05',ROLL_COIL_WGT,0)) T05_WGT \n");
  78. str.append(" ,sum(DECODE(THK_GRP_CD , 'T06',ROLL_COIL_CNT,0)) T06_CNT \n");
  79. str.append(" ,sum(DECODE(THK_GRP_CD , 'T06',ROLL_COIL_WGT,0)) T06_WGT \n");
  80. str.append(" ,sum(DECODE(THK_GRP_CD , 'T07',ROLL_COIL_CNT,0)) T07_CNT \n");
  81. str.append(" ,sum(DECODE(THK_GRP_CD , 'T07',ROLL_COIL_WGT,0)) T07_WGT \n");
  82. str.append(" ,sum(DECODE(THK_GRP_CD , 'T08',ROLL_COIL_CNT,0)) T08_CNT \n");
  83. str.append(" ,sum(DECODE(THK_GRP_CD , 'T08',ROLL_COIL_WGT,0)) T08_WGT \n");
  84. str.append(" ,sum(DECODE(THK_GRP_CD , 'T09',ROLL_COIL_CNT,0)) T09_CNT \n");
  85. str.append(" ,sum(DECODE(THK_GRP_CD , 'T09',ROLL_COIL_WGT,0)) T09_WGT \n");
  86. str.append(" FROM C_TBF03_SCH_ROLL \n");
  87. str.append(" group by wth_grp_cd \n");
  88. str.append(" order by wth_grp_cd) A , \n");
  89. str.append(" TBF02_ROLL_WTH_GRP C , \n");
  90. str.append(" TBF02_ROLL_WTH D \n");
  91. str.append("WHERE '1' = '1' \n");
  92. str.append(" AND C.PLT = 'C' \n");
  93. str.append(" AND C.WTH_GRP_CD = A.WTH_GRP_CD(+) \n");
  94. str.append(" AND C.WTH_GRP_CD = D.WTH_GRP_CD(+) \n");
  95. str.append(" ORDER BY WTH_GRP_CD \n");
  96. String sql = str.toString();
  97. cro=this.getDao("KgDao").ExcuteQuery(sql);
  98. System.out.println(cro);
  99. return cro;
  100. }
  101. public CoreReturnObject query02(String curLoc,String ordNO,String ordSeq,String entryTime
  102. ,String exshapeGrd,String stlGrd,String prodLine,String thkMin
  103. ,String thkMax,String wthMin,String wthMax) throws SQLException
  104. {
  105. CoreReturnObject cro=new CoreReturnObject();
  106. ArrayList<String> paramArray = new ArrayList<String>();
  107. StringBuffer str = new StringBuffer();
  108. str.append("select A.COIL_NO --基料卷号 \n");
  109. str.append(" ,D.H_SPEC_STL_GRD --基料卷牌号 \n");
  110. str.append(" ,D.C_SPEC_STL_GRD --酸轧卷牌号 \n");
  111. str.append(" ,A.ORD_NO --合同号 \n");
  112. str.append(" ,A.ORD_SEQ --订单号 \n");
  113. str.append(" ,A.COIL_THK --基料卷厚度 \n");
  114. str.append(" ,A.COIL_WTH --基料卷宽度 \n");
  115. str.append(" ,A.COIL_LEN --基料卷长度 \n");
  116. str.append(" ,A.ACT_WGT --基料卷重量 \n");
  117. str.append(" ,A.INSTR_COIL_THK --订单厚度 \n");
  118. str.append(" ,A.INSTR_COIL_WTH --订单宽度 \n");
  119. str.append(" ,B.ORD_LEN --订单长度 \n");
  120. str.append(" ,B.ORD_WGT --订单重量 \n");
  121. str.append(" ,A.CUR_LOAD_LOC --堆放位置 \n");
  122. str.append(" ,A.YARD_ENTRY_DTIME --入库时间 \n");
  123. str.append(" ,A.EXTSHAPE_DEC_GRD --表面等级 \n");
  124. str.append(" ,DECODE(B.DIVID_YN,1,'N','Y') DIVID_YN --是否分卷 \n");
  125. str.append(" ,D.DEL_TO_DATE --交货期 \n");
  126. str.append(" ,NVL(D.EMGMTR_NMG_CLF,'N') EMGMTR_NMG_CLF --紧急材代码 \n");
  127. str.append(" ,D.PROD_LINE --产线 \n");
  128. str.append("from c_tbk02_coil_comm a \n");
  129. str.append(" ,(select coil_no,count(1) divid_yn,sum(ord_len) ord_len,sum(ord_wgt) ord_wgt \n");
  130. str.append(" from c_tbk02_coil_comm_d group by coil_no) b \n");
  131. str.append(" --,tbb01_ord_prod c 待确认 \n");
  132. str.append(" ,tbe02_ord_prc d \n");
  133. str.append("where a.coil_no = b.coil_no \n");
  134. str.append("and a.ord_no = d.ord_no \n");
  135. str.append("and a.ord_seq = d.ord_seq \n");
  136. str.append("AND A.CUR_PROG_CD = 'PCA' \n");
  137. str.append("AND A.COIL_STAT = '2' \n");
  138. str.append("AND A.ORD_FL = '1' \n");
  139. str.append("and A.COIL_NO NOT IN (SELECT COIL_NO FROM C_TBF03_SCH_MILL) \n");
  140. if(!curLoc.equals("")){
  141. paramArray.add(curLoc);
  142. str.append("and a.cur_load_loc||'&' like :1||'%' \n");
  143. }
  144. if(!ordNO.equals("")){
  145. paramArray.add(ordNO);
  146. str.append("and a.ord_no = nvl(:2,a.ord_no) \n");
  147. }
  148. if(!ordSeq.equals("")){
  149. paramArray.add(ordSeq);
  150. str.append("and a.ord_seq = nvl(:3,a.ord_seq) \n");
  151. }
  152. if(!entryTime.equals("")){
  153. paramArray.add(entryTime);
  154. str.append("and a.yard_entry_dtime >= :4 \n");
  155. }
  156. if(!exshapeGrd.equals("")){
  157. paramArray.add(curLoc);
  158. str.append("and a.extshape_dec_grd = nvl(:5,a.extshape_dec_grd) \n");
  159. }
  160. if(!stlGrd.equals("")){
  161. paramArray.add(stlGrd);
  162. str.append("and d.h_stl_grd = nvl(:6,d.h_stl_grd) \n");
  163. }
  164. if(!prodLine.equals("")){
  165. paramArray.add(prodLine);
  166. str.append("and d.prod_line = nvl(:7,d.prod_line) \n");
  167. }
  168. paramArray.add(thkMin);
  169. paramArray.add(thkMax);
  170. paramArray.add(wthMin);
  171. paramArray.add(wthMax);
  172. str.append("and a.INSTR_COIL_THK >= :8 \n");
  173. str.append("and a.INSTR_COIL_THK < :9 \n");
  174. str.append("and a.INSTR_COIL_WTH >= :10 \n");
  175. str.append("and a.INSTR_COIL_WTH < :11 \n");
  176. String sql = str.toString();
  177. System.out.println(thkMin);
  178. cro=this.getDao("KgDao").ExcuteQuery(sql,paramArray.toArray());
  179. System.out.println(cro);
  180. return cro;
  181. }
  182. public CoreReturnObject query03(String thkGrpCD,String WthGrpCD) throws SQLException
  183. {
  184. CoreReturnObject cro=new CoreReturnObject();
  185. StringBuffer str = new StringBuffer();
  186. str.append("select a.COIL_NO \n");
  187. str.append(" ,c.H_SPEC_STL_GRD \n");
  188. str.append(" ,c.C_SPEC_STL_GRD \n");
  189. str.append(" ,a.ORD_NO \n");
  190. str.append(" ,a.ORD_SEQ \n");
  191. str.append(" ,a.COIL_THK \n");
  192. str.append(" ,a.COIL_WTH \n");
  193. str.append(" ,a.COIL_LEN \n");
  194. str.append(" ,a.COIL_WGT \n");
  195. str.append(" ,a.ORD_THK \n");
  196. str.append(" ,a.ORD_WGT \n");
  197. str.append(" ,b.CUR_LOAD_LOC \n");
  198. str.append(" ,b.YARD_ENTRY_DTIME \n");
  199. str.append(" ,b.EXTSHAPE_DEC_GRD \n");
  200. str.append(" ,a.DIVID_YN \n");
  201. str.append(" ,c.DEL_TO_DATE \n");
  202. str.append(" ,c.EMGMTR_NMG_CLF \n");
  203. str.append(" ,c.PROD_LINE \n");
  204. str.append("from c_tbf03_sch_mill a \n");
  205. str.append(" ,c_tbk02_coil_comm b \n");
  206. str.append(" ,tbe02_ord_prc c \n");
  207. str.append("where a.COIL_NO = b.COIL_NO \n");
  208. str.append("and a.ORD_NO = c.ORD_NO \n");
  209. str.append("and a.ORD_SEQ = c.ORD_SEQ \n");
  210. str.append("and a.THK_GRP_CD = :1 \n");
  211. str.append("and a.WTH_GRP_CD = :2 \n");
  212. String sql = str.toString();
  213. cro=this.getDao("KgDao").ExcuteQuery(sql,new Object[]{thkGrpCD,WthGrpCD});
  214. System.out.println(cro);
  215. return cro;
  216. }
  217. public CoreReturnObject update01(ArrayList<String> paramArray,String thk_grp_cd,String wth_grp_cd) throws Exception
  218. {
  219. ArrayList<String> coilNo = paramArray;
  220. CoreReturnObject cro=new CoreReturnObject();
  221. String sql = "";
  222. StringBuffer str = new StringBuffer();
  223. str.append("insert into c_tbf03_sch_mill ( \n");
  224. str.append(" COIL_EDT_SEQ --编制顺序号 \n");
  225. str.append(" ,COIL_NO --基料卷号 \n");
  226. str.append(" ,C_COIL_NO --酸轧卷号 \n");
  227. str.append(" ,ROLL_NO --轧制单元号 \n");
  228. str.append(" ,ROLL_COIL_SEQ --轧制单元内顺序号 \n");
  229. str.append(" ,PRODNM_CD --产品代码 \n");
  230. str.append(" ,STL_GRD --基料卷牌号 \n");
  231. str.append(" ,STL_GRP_CD --牌号组 \n");
  232. str.append(" ,COIL_THK --基料卷厚度 \n");
  233. str.append(" ,COIL_WTH --基料卷宽度 \n");
  234. str.append(" ,COIL_LEN --基料卷长度 \n");
  235. str.append(" ,COIL_WGT --基料卷重量 \n");
  236. str.append(" ,THK_GRP_CD --产品宽度组 \n");
  237. str.append(" ,WTH_GRP_CD --产品厚度组 \n");
  238. str.append(" ,THK_AIM --产品目标厚度 \n");
  239. str.append(" ,THK_MIN --产品最小厚度 \n");
  240. str.append(" ,THK_MAX --产品最大厚度 \n");
  241. str.append(" ,WTH_AIM --产品目标宽度 \n");
  242. str.append(" ,WTH_MIN --产品最小宽度 \n");
  243. str.append(" ,WTH_MAX --产品最大宽度 \n");
  244. str.append(" \n");
  245. str.append(" ,ORD_NO --合同号 \n");
  246. str.append(" ,ORD_SEQ --订单号 \n");
  247. str.append(" ,ORD_USEAGE_CD --订单用途代码 \n");
  248. str.append(" ,SPEC_ABBSYM --标准号 \n");
  249. str.append(" ,ORD_CUST_CD --客户代码 \n");
  250. str.append(" ,CUST_CD --客户代码 \n");
  251. str.append(" ,DEST_CD --目的地代码 \n");
  252. str.append(" ,DELV_REQ_DATE --交货期 \n");
  253. str.append(" ,PROD_LINE --去向 \n");
  254. str.append(" \n");
  255. str.append(" ,ORD_THK --订单厚度 \n");
  256. str.append(" ,ORD_WTH --订单宽度 \n");
  257. str.append(" ,ORD_WGT --订单重量 \n");
  258. str.append(" ,ORD_WGT_MIN --订单单重下限 \n");
  259. str.append(" ,ORD_WGT_MAX --订单单重上限 \n");
  260. str.append(" ,ORD_INDIA --订单内径 \n");
  261. str.append(" ,ORD_OUTDIA --订单外径 \n");
  262. str.append(" \n");
  263. str.append(" ,PACK_METHOD --包装方法 \n");
  264. str.append(" ,PATH_MILL_CD --轧制工艺流程 \n");
  265. str.append(" ,DIVID_YN --是否分卷 \n");
  266. str.append(" ,COIL_CUT_CNT --分卷数 \n");
  267. str.append(" ,STATUS_CD --状态 \n");
  268. str.append(" ,FL --编制区分 \n");
  269. str.append(" ) \n");
  270. str.append(" select (SELECT NVL(MAX(ROLL_COIL_SEQ),0) + 1 FROM C_TBF03_SCH_MILL ) COIL_EDT_SEQ \n");
  271. str.append(" ,a.COIL_NO \n");
  272. str.append(" ,'' c_coil_no \n");
  273. str.append(" ,'A0001' \n");
  274. str.append(" ,(SELECT NVL(MAX(ROLL_COIL_SEQ),0) + 1 FROM C_TBF03_SCH_MILL ) ROLL_COIL_SEQ \n");
  275. str.append(" ,A.PRODNM_CD \n");
  276. str.append(" ,A.H_SPEC_STL_GRD STL_GRD \n");
  277. str.append(" ,'' STL_GRP_CD --牌号组 \n");
  278. str.append(" ,A.COIL_THK \n");
  279. str.append(" ,A.COIL_WTH \n");
  280. str.append(" ,A.COIL_LEN \n");
  281. str.append(" ,A.ACT_WGT \n");
  282. str.append(" ,:1 THK_GRP_CD --产品宽度组 \n");
  283. str.append(" ,:2 WTH_GRP_CD --产品厚度组 \n");
  284. str.append(" ,'' THK_AIM --产品目标厚度 \n");
  285. str.append(" ,'' THK_MIN --产品最小厚度 \n");
  286. str.append(" ,'' THK_MAX --产品最大厚度 \n");
  287. str.append(" ,'' WTH_AIM --产品目标宽度 \n");
  288. str.append(" ,'' WTH_MIN --产品最小宽度 \n");
  289. str.append(" ,'' WTH_MAX --产品最大宽度 \n");
  290. str.append(" \n");
  291. str.append(" \n");
  292. str.append(" ,A.ORD_NO \n");
  293. str.append(" ,A.ORD_SEQ \n");
  294. str.append(" ,A.ORD_USE_CD \n");
  295. str.append(" ,A.SPEC_ABBSYM \n");
  296. str.append(" ,'' --客户代码 \n");
  297. str.append(" ,A.CUST_CD \n");
  298. str.append(" ,A.DEST_CD \n");
  299. str.append(" ,C.DEL_TO_DATE \n");
  300. str.append(" ,C.PROD_LINE \n");
  301. str.append(" ,C.ORD_THK \n");
  302. str.append(" ,C.ORD_WTH \n");
  303. str.append(" ,C.ORD_WGT \n");
  304. str.append(" ,'' ORD_WGT_MIN \n");
  305. str.append(" ,'' ORD_WGT_MAX \n");
  306. str.append(" ,C.ORD_INDIA \n");
  307. str.append(" ,C.ORD_OUTDIA \n");
  308. str.append(" \n");
  309. str.append(" ,C.PACK_METHOD \n");
  310. str.append(" ,'' PATH_MILL_CD --轧制工艺流程 \n");
  311. str.append(" ,'' DIVID_YN --是否分卷 \n");
  312. str.append(" ,'' COIL_CUT_CNT --分卷数 \n");
  313. str.append(" ,'' STATUS_CD --状态 \n");
  314. str.append(" ,'' FL --编制区分 \n");
  315. str.append(" from c_tbk02_coil_comm a \n");
  316. str.append(" ,C_TBK02_COIL_COMM_D B \n");
  317. str.append(" ,TBE02_ORD_PRC C \n");
  318. str.append(" WHERE A.COIL_NO = :3 \n");
  319. str.append(" AND A.COIL_NO = B.COIL_NO \n");
  320. str.append(" AND A.ORD_NO = C.ORD_NO \n");
  321. str.append(" AND A.ORD_SEQ = C.ORD_SEQ \n");
  322. str.append(" AND A.CUR_PROG_CD = 'PCA' \n");
  323. str.append(" AND A.COIL_STAT = '2' \n");
  324. str.append(" AND A.ORD_FL = '1' \n");
  325. sql = str.toString();
  326. for(int i = 0 ; i < coilNo.size();i++){
  327. cro=this.getDao("KgDao").ExcuteNonQuery(sql,new Object[]{thk_grp_cd,wth_grp_cd,coilNo.get(i)});
  328. }
  329. System.out.println(cro);
  330. str = new StringBuffer();
  331. str.append("INSERT INTO C_TBF03_SCH_MILL_D ( \n");
  332. str.append(" COIL_EDT_SEQ \n");
  333. str.append(" ,COIL_CUT_SEQ \n");
  334. str.append(" ,ORD_THK \n");
  335. str.append(" ,ORD_WTH \n");
  336. str.append(" ,ORD_LEN \n");
  337. str.append(" ,ORD_WGT \n");
  338. str.append(" ,ORD_WGT_MIN \n");
  339. str.append(" ,ORD_WGT_MAX \n");
  340. str.append(" ,ORD_INDIA \n");
  341. str.append(" ,ORD_OUTDIA \n");
  342. str.append(" ,ORD_NO \n");
  343. str.append(" ,ORD_SEQ \n");
  344. str.append(" ,ORD_FL \n");
  345. str.append(")( \n");
  346. str.append(" SELECT B.COIL_EDT_SEQ \n");
  347. str.append(" ,A.CUT_SEQ \n");
  348. str.append(" ,A.ORD_THK \n");
  349. str.append(" ,A.ORD_WTH \n");
  350. str.append(" ,A.ORD_LEN \n");
  351. str.append(" ,A.ORD_WGT \n");
  352. str.append(" ,A.ORD_WGT_MIN \n");
  353. str.append(" ,A.ORD_WGT_MAX \n");
  354. str.append(" ,A.ORD_INDIA \n");
  355. str.append(" ,A.ORD_OUTDIA \n");
  356. str.append(" ,A.ORD_NO \n");
  357. str.append(" ,A.ORD_SEQ \n");
  358. str.append(" ,A.ORD_FL \n");
  359. str.append(" FROM C_TBK02_COIL_COMM_D A, \n");
  360. str.append(" (SELECT T.COIL_NO,T.COIL_EDT_SEQ \n");
  361. str.append(" FROM C_TBF03_SCH_MILL T \n");
  362. str.append(" WHERE T.COIL_EDT_SEQ IN \n");
  363. str.append(" (SELECT COIL_EDT_SEQ \n");
  364. str.append(" FROM C_TBF03_SCH_MILL \n");
  365. str.append(" WHERE COIL_EDT_SEQ NOT IN \n");
  366. str.append(" (SELECT COIL_EDT_SEQ FROM C_TBF03_SCH_MILL_D))) B, \n");
  367. str.append(" C_TBK02_COIL_COMM C \n");
  368. str.append(" WHERE '1' = '1' \n");
  369. str.append(" AND A.COIL_NO = C.COIL_NO \n");
  370. str.append(" AND A.COIL_NO = B.COIL_NO \n");
  371. str.append(" ) \n");
  372. sql = str.toString();
  373. cro=this.getDao("KgDao").ExcuteNonQuery(sql);
  374. sql = " delete from c_tbf03_sch_roll ";
  375. cro=this.getDao("KgDao").ExcuteNonQuery(sql);
  376. str = new StringBuffer();
  377. str.append("INSERT INTO C_TBF03_SCH_ROLL \n");
  378. str.append(" ( ROLL_NO \n");
  379. str.append(" ,WTH_GRP_CD \n");
  380. str.append(" ,WTH_MINI \n");
  381. str.append(" ,WTH_MAXI \n");
  382. str.append(" ,THK_GRP_CD \n");
  383. str.append(" ,THK_MINI \n");
  384. str.append(" ,THK_MAXI \n");
  385. str.append(" ,STL_GRD \n");
  386. str.append(" ,ROLL_COIL_CNT \n");
  387. str.append(" ,ROLL_COIL_WGT \n");
  388. str.append(" ,MILL_LEN \n");
  389. str.append(" ,ROLL_DTIME \n");
  390. str.append(" ,FL \n");
  391. str.append(" ) \n");
  392. str.append(" (SELECT A.ROLL_NO \n");
  393. str.append(" ,A.WTH_GRP_CD \n");
  394. str.append(" ,C.MINI \n");
  395. str.append(" ,C.MAXI \n");
  396. str.append(" ,A.THK_GRP_CD \n");
  397. str.append(" ,D.MINI \n");
  398. str.append(" ,D.MAXI \n");
  399. str.append(" ,'' \n");
  400. str.append(" ,COUNT(A.COIL_EDT_SEQ) \n");
  401. str.append(" ,SUM(A.COIL_WGT) \n");
  402. str.append(" ,SUM(B.ORD_LEN) \n");
  403. str.append(" ,TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS') \n");
  404. str.append(" ,'' \n");
  405. str.append(" FROM C_TBF03_SCH_MILL A \n");
  406. str.append(" ,(SELECT COIL_NO,SUM(ORD_LEN) ORD_LEN \n");
  407. str.append(" FROM C_TBK02_COIL_COMM_D \n");
  408. str.append(" GROUP BY COIL_NO)B \n");
  409. str.append(" ,TBF02_ROLL_WTH_GRP C \n");
  410. str.append(" ,TBF02_ROLL_THK_GRP D \n");
  411. str.append(" WHERE A.COIL_NO = B.COIL_NO \n");
  412. str.append(" AND A.WTH_GRP_CD = C.WTH_GRP_CD \n");
  413. str.append(" AND A.THK_GRP_CD = D.THK_GRP_CD \n");
  414. str.append(" AND C.PLT = 'C' \n");
  415. str.append(" AND D.PLT = 'C' \n");
  416. str.append(" GROUP BY (A.ROLL_NO,A.WTH_GRP_CD,C.MINI,C.MAXI,A.THK_GRP_CD,D.MINI,D.MAXI) \n");
  417. str.append(" \n");
  418. str.append(" \n");
  419. str.append(" ) \n");
  420. sql = str.toString();
  421. cro=this.getDao("KgDao").ExcuteNonQuery(sql);
  422. return cro;
  423. }
  424. public CoreReturnObject update02(ArrayList<String> paramArray,String thk_grp_cd,String wth_grp_cd) throws Exception
  425. {
  426. ArrayList<String> coilNo = paramArray;
  427. CoreReturnObject cro=new CoreReturnObject();
  428. String sql = "delete from c_tbf03_sch_mill where coil_no = :1";
  429. for(int i = 0 ; i < coilNo.size();i++){
  430. cro=this.getDao("KgDao").ExcuteNonQuery(sql,new Object[]{coilNo.get(i)});
  431. }
  432. sql = "delete from c_tbf03_sch_mill_d where coil_edt_seq not in (select coil_edt_seq from c_tbf03_sch_mill )";
  433. cro=this.getDao("KgDao").ExcuteNonQuery(sql);
  434. sql = " delete from c_tbf03_sch_roll ";
  435. cro=this.getDao("KgDao").ExcuteNonQuery(sql);
  436. return cro;
  437. }
  438. public CoreReturnObject update03() throws Exception
  439. {
  440. String sql = "delete from c_tbf03_sch_mill where coil_no = :1";
  441. String name = "{call C_PKG_NIF043010.PLTCM_INDICATION(?,?)}";
  442. CoreReturnObject cro=new CoreReturnObject();
  443. cro=this.getDao("KgDao").ExcuteNonQuery(sql);
  444. return cro;
  445. }
  446. //根据条件得到待轧辊制定的基料卷信息
  447. public CoreReturnObject Query_HCoil_Info(String _Condition)
  448. {
  449. try
  450. {
  451. CoreReturnObject rtnobj=new CoreReturnObject();
  452. String Sql = XmlSqlParsersFactory.getSql("UIF041011.Query_HCoil_List");
  453. Sql = Sql + "AND A.FL='0' " + _Condition ;
  454. rtnobj=this.getDao("KgDao").ExcuteQuery(Sql);
  455. return rtnobj;
  456. }
  457. catch(Exception ex)
  458. {
  459. CoreReturnObject err = new CoreReturnObject();
  460. err.SetErrInfo(ex.toString());
  461. return err;
  462. }
  463. }
  464. //根据条件得到已制定的轧制计划明细信息
  465. public CoreReturnObject Query_RollPlan_List()
  466. {
  467. try
  468. {
  469. CoreReturnObject rtnobj=new CoreReturnObject();
  470. String Sql = XmlSqlParsersFactory.getSql("UIF042010.Query_RollPlan_List");
  471. rtnobj=this.getDao("KgDao").ExcuteQuery(Sql);
  472. return rtnobj;
  473. }
  474. catch(Exception ex)
  475. {
  476. CoreReturnObject err = new CoreReturnObject();
  477. err.SetErrInfo(ex.toString());
  478. return err;
  479. }
  480. }
  481. //根据条件得到已制定的轧制计划汇总信息
  482. public CoreReturnObject Query_RollPlan_Info()
  483. {
  484. try
  485. {
  486. CoreReturnObject rtnobj=new CoreReturnObject();
  487. String Sql = XmlSqlParsersFactory.getSql("UIF042010.Query_RollPlan_Info");
  488. rtnobj=this.getDao("KgDao").ExcuteQuery(Sql);
  489. return rtnobj;
  490. }
  491. catch(Exception ex)
  492. {
  493. CoreReturnObject err = new CoreReturnObject();
  494. err.SetErrInfo(ex.toString());
  495. return err;
  496. }
  497. }
  498. //新增轧制计划制定信息
  499. public CoreReturnObject Add_RollPlan_List(String CoilNOS,int Coil_NUM,String User)
  500. {
  501. try
  502. {
  503. //CoreReturnObject rtnobj=new CoreReturnObject();
  504. //rtnobj=this.getDao("KgDao").ExcuteProcedure(name, sqltypes, sqlparams);
  505. return null;
  506. }
  507. catch(Exception ex)
  508. {
  509. CoreReturnObject err = new CoreReturnObject();
  510. err.SetErrInfo(ex.toString());
  511. return err;
  512. }
  513. }
  514. }