d1141cf715e43916f7913aa4647b30f179b124e9.svn-base 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781
  1. package xin.glue.ui.H.H02;
  2. import java.sql.CallableStatement;
  3. import java.sql.SQLException;
  4. import java.util.ArrayList;
  5. import java.util.HashMap;
  6. import java.util.List;
  7. import java.util.Map;
  8. import xin.glue.ui.common.ProduceFactory;
  9. import com.posdata.glue.PosException;
  10. import com.posdata.glue.biz.activity.PosActivity;
  11. import com.posdata.glue.biz.constants.PosBizControlConstants;
  12. import com.posdata.glue.component.layout.PosMessageLayoutIF;
  13. import com.posdata.glue.context.PosContext;
  14. import com.posdata.glue.dao.vo.PosParameter;
  15. import com.posdata.glue.dao.vo.PosRow;
  16. import com.posdata.glue.dao.vo.PosRowSet;
  17. import com.posdata.glue.msg.PosMESMessageImpl;
  18. import com.posdata.glue.msg.PosMessageAttributeDefinition;
  19. import com.posdata.glue.msg.PosMessageDefinition;
  20. import com.posdata.glue.util.log.PosLog;
  21. import com.posdata.glue.util.log.PosLogFactory;
  22. /************
  23. * 唐亮添加,为了处理电文发送错误的情况。比如实际没有轧回加回,二级给出电文。或者轧回加回电文给反了
  24. * 这里只是把钢卷拉到出炉待机的情况,具体是轧回还是加回还是轧制完成由操作人员在界面上完成。
  25. * ***************/
  26. public class PosCoilReturn extends PosActivity{
  27. public String runActivity(PosContext context) {
  28. String[] OLD_SAMPL_NO = (String[])context.get("OLD_SAMPL_NO");
  29. String[] REG_ID = (String[])context.get("REG_ID");
  30. //这里必须判断此卷是否判定、下计划、发货。出于这些状态的卷是不能回拉的
  31. PosParameter param1 = new PosParameter();
  32. param1.setWhereClauseParameter(0, OLD_SAMPL_NO[0]);
  33. PosRowSet curVo = getDao("mesdao").find("UIH020220_02.select", param1);
  34. String CUR_PROG_CD = null;
  35. String slab_no = null;
  36. String coil_no = null;
  37. String coil_stat = null;
  38. String MISSNO_CLF_CD = null;
  39. if(curVo.hasNext()){
  40. PosRow curRow = curVo.next();
  41. CUR_PROG_CD = (String) curRow.getAttribute("CUR_PROG_CD");
  42. slab_no = (String) curRow.getAttribute("SLAB_NO");
  43. coil_no = (String) curRow.getAttribute("COIL_NO");
  44. coil_stat = (String) curRow.getAttribute("COIL_STAT");
  45. MISSNO_CLF_CD = (String) curRow.getAttribute("MISSNO_CLF_CD");
  46. //此方法用来传送异动点数据
  47. ProduceFactory PD= new ProduceFactory();
  48. PD.ErpDataCover("HSLAB",slab_no,"41A","0","O","轧制电文回退","热轧轧制");
  49. //做一步非空判断
  50. if(CUR_PROG_CD == null){
  51. //这里必须判断是炉前取消还是炉后加回以及轧回,并进行相应的处理
  52. PosParameter param2 = new PosParameter();
  53. param2.setWhereClauseParameter(0, slab_no);
  54. param2.setWhereClauseParameter(1, coil_no);
  55. PosRowSet missnoVo = getDao("mesdao").find("UIH020220_03.select", param2);
  56. String MISSNO_CLF = null;
  57. if(missnoVo.hasNext()){
  58. PosRow missnoRow = missnoVo.next();
  59. MISSNO_CLF = (String) missnoRow.getAttribute("MISSNO_CLF");
  60. if(MISSNO_CLF.equals("1")){
  61. //炉前加回
  62. logger.logDebug("PosCoilReturn 炉前取消处理。"+MISSNO_CLF);
  63. //这里需要清空轧制吊销表
  64. PosParameter param3 = new PosParameter();
  65. param3.setWhereClauseParameter(0, slab_no);
  66. param3.setWhereClauseParameter(1, coil_no);
  67. getDao("mesdao").update("UIH020220_01.delete", param3);
  68. //入炉出炉表
  69. PosParameter param4 = new PosParameter();
  70. param4.setWhereClauseParameter(0, "1");
  71. param4.setWhereClauseParameter(1, slab_no);
  72. param4.setWhereClauseParameter(2, coil_no);
  73. getDao("mesdao").update("UIH020220_01.update", param4);
  74. //这里板坯公共表不动,吊销的时候只是写入原因代码
  75. //钢卷公共表,这里要记录修改人和修改时间
  76. PosParameter param5 = new PosParameter();
  77. param5.setWhereClauseParameter(0, "0");
  78. param5.setWhereClauseParameter(1, REG_ID[0]);
  79. param5.setWhereClauseParameter(2, slab_no);
  80. param5.setWhereClauseParameter(3, coil_no);
  81. getDao("mesdao").update("UIH020220_02.update", param5);
  82. //更新轧制计划表
  83. PosParameter param33 = new PosParameter();
  84. param33.setWhereClauseParameter(0,slab_no);
  85. param33.setWhereClauseParameter(1,coil_no);
  86. PosRowSet specMillVo = getDao("mesdao").find("NIH020020_SPEC_MILL.select", param33);
  87. if (specMillVo.hasNext()) {
  88. PosRow specMillROW = specMillVo.next();
  89. Number SLAB_EDT_SEQ = (Number)specMillROW.getAttribute("SLAB_EDT_SEQ");
  90. PosParameter param55 = new PosParameter();
  91. param55.setWhereClauseParameter(0, "B" );
  92. param55.setWhereClauseParameter(1, slab_no );
  93. param55.setWhereClauseParameter(2, coil_no );
  94. getDao("mesdao").update("NIH020020_SPEC_MILL.update", param55);
  95. PosParameter param6 = new PosParameter();
  96. param6.setWhereClauseParameter(0, "B" );
  97. param6.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  98. getDao("mesdao").update("NIH020020_SPEC_MILL_D.update", param6);
  99. PosParameter param7 = new PosParameter();
  100. param7.setWhereClauseParameter(0, "B" );
  101. param7.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  102. getDao("mesdao").update("NIH020020_MILL_IDX.update", param7);
  103. }
  104. //回退电文,需要调用品质的存储过程
  105. logger.logInfo("PosCoilReturn---> NIB027010 TC sql call" );
  106. CallableStatement PlRtn = getDao("mesdao").getCallableStatement("UIH020220_NIB02701X");
  107. logger.logInfo("PosCoilReturn---> NIB027010 TC try" );
  108. try {
  109. if(PlRtn != null) {
  110. PlRtn.setString(1,coil_no);
  111. //新增加一个字段,为了废弃的时候使用
  112. PlRtn.setString(2,"T");
  113. PlRtn.registerOutParameter(3, java.sql.Types.VARCHAR);
  114. PlRtn.registerOutParameter(4, java.sql.Types.VARCHAR);
  115. PlRtn.execute();
  116. String sRetCode = PlRtn.getString(3);
  117. String sRetMsg = PlRtn.getString(4);
  118. logger.logInfo("PosCoilReturn---> NIB027010 TC PlRtn1:["+sRetCode+"]:"+ sRetMsg);
  119. } else {
  120. logger.logInfo("PosCoilReturn---> NIB027010 PlRtn2:"+PlRtn );
  121. }
  122. } catch (SQLException e) {
  123. throw new PosException(e.getMessage());
  124. }finally
  125. {
  126. if (PlRtn != null)
  127. {
  128. try
  129. {
  130. PlRtn.close();
  131. }
  132. catch (SQLException e)
  133. {
  134. logger.logWarn(e.getMessage(), e);
  135. logger.logInfo("PosCoilReturn---> NIB027010 SQLException:"+e );
  136. }
  137. }
  138. }
  139. }else if(MISSNO_CLF.equals("2")){
  140. //炉后加回
  141. logger.logDebug("PosCoilReturn 炉后加回处理。"+MISSNO_CLF);
  142. //这里需要清空轧制吊销表
  143. PosParameter param3 = new PosParameter();
  144. param3.setWhereClauseParameter(0, slab_no);
  145. param3.setWhereClauseParameter(1, coil_no);
  146. getDao("mesdao").update("UIH020220_01.delete", param3);
  147. //入炉出炉表
  148. PosParameter param4 = new PosParameter();
  149. param4.setWhereClauseParameter(0, "2");
  150. param4.setWhereClauseParameter(1, slab_no);
  151. param4.setWhereClauseParameter(2, coil_no);
  152. getDao("mesdao").update("UIH020220_01.update", param4);
  153. //这里板坯公共表不动,吊销的时候只是写入原因代码
  154. //钢卷公共表,这里要记录修改人和修改时间
  155. PosParameter param5 = new PosParameter();
  156. param5.setWhereClauseParameter(0, "1");
  157. param5.setWhereClauseParameter(1, REG_ID[0]);
  158. param5.setWhereClauseParameter(2, slab_no);
  159. param5.setWhereClauseParameter(3, coil_no);
  160. getDao("mesdao").update("UIH020220_02.update", param5);
  161. //更新轧制计划表
  162. PosParameter param33 = new PosParameter();
  163. param33.setWhereClauseParameter(0,slab_no);
  164. param33.setWhereClauseParameter(1,coil_no);
  165. PosRowSet specMillVo = getDao("mesdao").find("NIH020020_SPEC_MILL.select", param33);
  166. if (specMillVo.hasNext()) {
  167. PosRow specMillROW = specMillVo.next();
  168. Number SLAB_EDT_SEQ = (Number)specMillROW.getAttribute("SLAB_EDT_SEQ");
  169. PosParameter param55 = new PosParameter();
  170. param55.setWhereClauseParameter(0, "B" );
  171. param55.setWhereClauseParameter(1, slab_no );
  172. param55.setWhereClauseParameter(2, coil_no );
  173. getDao("mesdao").update("NIH020020_SPEC_MILL.update", param55);
  174. PosParameter param6 = new PosParameter();
  175. param6.setWhereClauseParameter(0, "B" );
  176. param6.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  177. getDao("mesdao").update("NIH020020_SPEC_MILL_D.update", param6);
  178. PosParameter param7 = new PosParameter();
  179. param7.setWhereClauseParameter(0, "B" );
  180. param7.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  181. getDao("mesdao").update("NIH020020_MILL_IDX.update", param7);
  182. }
  183. //回退电文,需要调用品质的存储过程
  184. logger.logInfo("PosCoilReturn---> NIB027010 TC sql call" );
  185. CallableStatement PlRtn = getDao("mesdao").getCallableStatement("UIH020220_NIB02701X");
  186. logger.logInfo("PosCoilReturn---> NIB027010 TC try" );
  187. try {
  188. if(PlRtn != null) {
  189. PlRtn.setString(1,coil_no);
  190. //新增加一个字段,为了废弃的时候使用
  191. PlRtn.setString(2,"T");
  192. PlRtn.registerOutParameter(3, java.sql.Types.VARCHAR);
  193. PlRtn.registerOutParameter(4, java.sql.Types.VARCHAR);
  194. PlRtn.execute();
  195. String sRetCode = PlRtn.getString(3);
  196. String sRetMsg = PlRtn.getString(4);
  197. logger.logInfo("PosCoilReturn---> NIB027010 TC PlRtn1:["+sRetCode+"]:"+ sRetMsg);
  198. } else {
  199. logger.logInfo("PosCoilReturn---> NIB027010 PlRtn2:"+PlRtn );
  200. }
  201. } catch (SQLException e) {
  202. throw new PosException(e.getMessage());
  203. }finally
  204. {
  205. if (PlRtn != null)
  206. {
  207. try
  208. {
  209. PlRtn.close();
  210. }
  211. catch (SQLException e)
  212. {
  213. logger.logWarn(e.getMessage(), e);
  214. logger.logInfo("PosCoilReturn---> NIB027010 SQLException:"+e );
  215. }
  216. }
  217. }
  218. }else if(MISSNO_CLF.equals("3")){
  219. //轧回
  220. logger.logDebug("PosCoilReturn 轧回处理。"+MISSNO_CLF);
  221. //这里需要清空轧制吊销表
  222. PosParameter param3 = new PosParameter();
  223. param3.setWhereClauseParameter(0, slab_no);
  224. param3.setWhereClauseParameter(1, coil_no);
  225. getDao("mesdao").update("UIH020220_01.delete", param3);
  226. //入炉出炉表
  227. PosParameter param4 = new PosParameter();
  228. param4.setWhereClauseParameter(0, "2");
  229. param4.setWhereClauseParameter(1, slab_no);
  230. param4.setWhereClauseParameter(2, coil_no);
  231. getDao("mesdao").update("UIH020220_01.update", param4);
  232. //这里板坯公共表不动,吊销的时候只是写入原因代码
  233. //钢卷公共表,这里要记录修改人和修改时间
  234. PosParameter param5 = new PosParameter();
  235. param5.setWhereClauseParameter(0, "1");
  236. param5.setWhereClauseParameter(1, REG_ID[0]);
  237. param5.setWhereClauseParameter(2, slab_no);
  238. param5.setWhereClauseParameter(3, coil_no);
  239. getDao("mesdao").update("UIH020220_02.update", param5);
  240. //更新轧制计划表
  241. PosParameter param33 = new PosParameter();
  242. param33.setWhereClauseParameter(0,slab_no);
  243. param33.setWhereClauseParameter(1,coil_no);
  244. PosRowSet specMillVo = getDao("mesdao").find("NIH020020_SPEC_MILL.select", param33);
  245. if (specMillVo.hasNext()) {
  246. PosRow specMillROW = specMillVo.next();
  247. Number SLAB_EDT_SEQ = (Number)specMillROW.getAttribute("SLAB_EDT_SEQ");
  248. PosParameter param55 = new PosParameter();
  249. param55.setWhereClauseParameter(0, "B" );
  250. param55.setWhereClauseParameter(1, slab_no );
  251. param55.setWhereClauseParameter(2, coil_no );
  252. getDao("mesdao").update("NIH020020_SPEC_MILL.update", param55);
  253. PosParameter param6 = new PosParameter();
  254. param6.setWhereClauseParameter(0, "B" );
  255. param6.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  256. getDao("mesdao").update("NIH020020_SPEC_MILL_D.update", param6);
  257. PosParameter param7 = new PosParameter();
  258. param7.setWhereClauseParameter(0, "B" );
  259. param7.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  260. getDao("mesdao").update("NIH020020_MILL_IDX.update", param7);
  261. }
  262. //回退电文,需要调用品质的存储过程
  263. logger.logInfo("PosCoilReturn---> NIB027010 TC sql call" );
  264. CallableStatement PlRtn = getDao("mesdao").getCallableStatement("UIH020220_NIB02701X");
  265. logger.logInfo("PosCoilReturn---> NIB027010 TC try" );
  266. try {
  267. if(PlRtn != null) {
  268. PlRtn.setString(1,coil_no);
  269. //新增加一个字段,为了废弃的时候使用
  270. PlRtn.setString(2,"T");
  271. PlRtn.registerOutParameter(3, java.sql.Types.VARCHAR);
  272. PlRtn.registerOutParameter(4, java.sql.Types.VARCHAR);
  273. PlRtn.execute();
  274. String sRetCode = PlRtn.getString(3);
  275. String sRetMsg = PlRtn.getString(4);
  276. logger.logInfo("PosCoilReturn---> NIB027010 TC PlRtn1:["+sRetCode+"]:"+ sRetMsg);
  277. } else {
  278. logger.logInfo("PosCoilReturn---> NIB027010 PlRtn2:"+PlRtn );
  279. }
  280. } catch (SQLException e) {
  281. throw new PosException(e.getMessage());
  282. }finally
  283. {
  284. if (PlRtn != null)
  285. {
  286. try
  287. {
  288. PlRtn.close();
  289. }
  290. catch (SQLException e)
  291. {
  292. logger.logWarn(e.getMessage(), e);
  293. logger.logInfo("PosCoilReturn---> NIB027010 SQLException:"+e );
  294. }
  295. }
  296. }
  297. }else{
  298. //轧废
  299. logger.logDebug("PosCoilReturn 轧废处理。"+MISSNO_CLF);
  300. //这里需要清空轧制吊销表
  301. PosParameter param3 = new PosParameter();
  302. param3.setWhereClauseParameter(0, slab_no);
  303. param3.setWhereClauseParameter(1, coil_no);
  304. getDao("mesdao").update("UIH020220_01.delete", param3);
  305. //入炉出炉表
  306. PosParameter param4 = new PosParameter();
  307. param4.setWhereClauseParameter(0, "2");
  308. param4.setWhereClauseParameter(1, slab_no);
  309. param4.setWhereClauseParameter(2, coil_no);
  310. getDao("mesdao").update("UIH020220_01.update", param4);
  311. //这里板坯公共表不动,吊销的时候只是写入原因代码
  312. //钢卷公共表,这里要记录修改人和修改时间
  313. PosParameter param5 = new PosParameter();
  314. param5.setWhereClauseParameter(0, "1");
  315. param5.setWhereClauseParameter(1, REG_ID[0]);
  316. param5.setWhereClauseParameter(2, slab_no);
  317. param5.setWhereClauseParameter(3, coil_no);
  318. getDao("mesdao").update("UIH020220_02.update", param5);
  319. //更新轧制计划表
  320. PosParameter param33 = new PosParameter();
  321. param33.setWhereClauseParameter(0,slab_no);
  322. param33.setWhereClauseParameter(1,coil_no);
  323. PosRowSet specMillVo = getDao("mesdao").find("NIH020020_SPEC_MILL.select", param33);
  324. if (specMillVo.hasNext()) {
  325. PosRow specMillROW = specMillVo.next();
  326. Number SLAB_EDT_SEQ = (Number)specMillROW.getAttribute("SLAB_EDT_SEQ");
  327. PosParameter param55 = new PosParameter();
  328. param55.setWhereClauseParameter(0, "B" );
  329. param55.setWhereClauseParameter(1, slab_no );
  330. param55.setWhereClauseParameter(2, coil_no );
  331. getDao("mesdao").update("NIH020020_SPEC_MILL.update", param55);
  332. PosParameter param6 = new PosParameter();
  333. param6.setWhereClauseParameter(0, "B" );
  334. param6.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  335. getDao("mesdao").update("NIH020020_SPEC_MILL_D.update", param6);
  336. PosParameter param7 = new PosParameter();
  337. param7.setWhereClauseParameter(0, "B" );
  338. param7.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  339. getDao("mesdao").update("NIH020020_MILL_IDX.update", param7);
  340. }
  341. // 这里还要更新轧制实际表的废弃宽度、厚度、重量信息
  342. PosParameter param8 = new PosParameter();
  343. param8.setWhereClauseParameter(0, slab_no);
  344. param8.setWhereClauseParameter(1, coil_no);
  345. getDao("mesdao").update("UIH020220_03.update", param8);
  346. //回退电文,需要调用品质的存储过程
  347. logger.logInfo("PosCoilReturn---> NIB027010 TC sql call" );
  348. CallableStatement PlRtn = getDao("mesdao").getCallableStatement("UIH020220_NIB02701X");
  349. logger.logInfo("PosCoilReturn---> NIB027010 TC try" );
  350. try {
  351. if(PlRtn != null) {
  352. PlRtn.setString(1,coil_no);
  353. //新增加一个字段,为了废弃的时候使用
  354. PlRtn.setString(2,"T");
  355. PlRtn.registerOutParameter(3, java.sql.Types.VARCHAR);
  356. PlRtn.registerOutParameter(4, java.sql.Types.VARCHAR);
  357. PlRtn.execute();
  358. String sRetCode = PlRtn.getString(3);
  359. String sRetMsg = PlRtn.getString(4);
  360. logger.logInfo("PosCoilReturn---> NIB027010 TC PlRtn1:["+sRetCode+"]:"+ sRetMsg);
  361. } else {
  362. logger.logInfo("PosCoilReturn---> NIB027010 PlRtn2:"+PlRtn );
  363. }
  364. } catch (SQLException e) {
  365. throw new PosException(e.getMessage());
  366. }finally
  367. {
  368. if (PlRtn != null)
  369. {
  370. try
  371. {
  372. PlRtn.close();
  373. }
  374. catch (SQLException e)
  375. {
  376. logger.logWarn(e.getMessage(), e);
  377. logger.logInfo("PosCoilReturn---> NIB027010 SQLException:"+e );
  378. }
  379. }
  380. }
  381. }
  382. }else{
  383. //轧废或者中板的情况,在没有收到实际的情况下。进行相应的回退操作
  384. if(MISSNO_CLF_CD != null){
  385. //轧废,需要清除轧废的宽度、厚度、重量、时间等信息
  386. //这里在轧制实际表中
  387. logger.logDebug("PosCoilReturn 轧废处理,这里进程代码为SED.废弃代码存在");
  388. //这里需要清空轧制吊销表
  389. // PosParameter param3 = new PosParameter();
  390. //
  391. // param3.setWhereClauseParameter(0, slab_no);
  392. // param3.setWhereClauseParameter(1, coil_no);
  393. //
  394. // getDao("mesdao").update("UIH020220_01.delete", param3);
  395. //入炉出炉表
  396. PosParameter param4 = new PosParameter();
  397. param4.setWhereClauseParameter(0, "2");
  398. param4.setWhereClauseParameter(1, slab_no);
  399. param4.setWhereClauseParameter(2, coil_no);
  400. getDao("mesdao").update("UIH020220_01.update", param4);
  401. //这里板坯公共表不动,吊销的时候只是写入原因代码
  402. //钢卷公共表,这里要记录修改人和修改时间
  403. PosParameter param5 = new PosParameter();
  404. param5.setWhereClauseParameter(0, "1");
  405. param5.setWhereClauseParameter(1, REG_ID[0]);
  406. param5.setWhereClauseParameter(2, slab_no);
  407. param5.setWhereClauseParameter(3, coil_no);
  408. getDao("mesdao").update("UIH020220_02.update", param5);
  409. //更新轧制计划表
  410. PosParameter param33 = new PosParameter();
  411. param33.setWhereClauseParameter(0,slab_no);
  412. param33.setWhereClauseParameter(1,coil_no);
  413. PosRowSet specMillVo = getDao("mesdao").find("NIH020020_SPEC_MILL.select", param33);
  414. if (specMillVo.hasNext()) {
  415. PosRow specMillROW = specMillVo.next();
  416. Number SLAB_EDT_SEQ = (Number)specMillROW.getAttribute("SLAB_EDT_SEQ");
  417. PosParameter param55 = new PosParameter();
  418. param55.setWhereClauseParameter(0, "B" );
  419. param55.setWhereClauseParameter(1, slab_no );
  420. param55.setWhereClauseParameter(2, coil_no );
  421. getDao("mesdao").update("NIH020020_SPEC_MILL.update", param55);
  422. PosParameter param6 = new PosParameter();
  423. param6.setWhereClauseParameter(0, "B" );
  424. param6.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  425. getDao("mesdao").update("NIH020020_SPEC_MILL_D.update", param6);
  426. PosParameter param7 = new PosParameter();
  427. param7.setWhereClauseParameter(0, "B" );
  428. param7.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  429. getDao("mesdao").update("NIH020020_MILL_IDX.update", param7);
  430. }
  431. //这里还要更新轧制实际表的废弃宽度、厚度、重量信息
  432. PosParameter param8 = new PosParameter();
  433. param8.setWhereClauseParameter(0, slab_no);
  434. param8.setWhereClauseParameter(1, coil_no);
  435. getDao("mesdao").update("UIH020220_03.update", param8);
  436. //回退电文,需要调用品质的存储过程
  437. logger.logInfo("PosCoilReturn---> NIB027010 TC sql call" );
  438. CallableStatement PlRtn = getDao("mesdao").getCallableStatement("UIH020220_NIB02701X");
  439. logger.logInfo("PosCoilReturn---> NIB027010 TC try" );
  440. try {
  441. if(PlRtn != null) {
  442. PlRtn.setString(1,coil_no);
  443. //新增加一个字段,为了废弃的时候使用
  444. PlRtn.setString(2,"T");
  445. PlRtn.registerOutParameter(3, java.sql.Types.VARCHAR);
  446. PlRtn.registerOutParameter(4, java.sql.Types.VARCHAR);
  447. PlRtn.execute();
  448. String sRetCode = PlRtn.getString(3);
  449. String sRetMsg = PlRtn.getString(4);
  450. logger.logInfo("PosCoilReturn---> NIB027010 TC PlRtn1:["+sRetCode+"]:"+ sRetMsg);
  451. } else {
  452. logger.logInfo("PosCoilReturn---> NIB027010 PlRtn2:"+PlRtn );
  453. }
  454. } catch (SQLException e) {
  455. throw new PosException(e.getMessage());
  456. }finally
  457. {
  458. if (PlRtn != null)
  459. {
  460. try
  461. {
  462. PlRtn.close();
  463. }
  464. catch (SQLException e)
  465. {
  466. logger.logWarn(e.getMessage(), e);
  467. logger.logInfo("PosCoilReturn---> NIB027010 SQLException:"+e );
  468. }
  469. }
  470. }
  471. }else{
  472. //已经收到轧制实际的情况下,不能进行回退操作。
  473. logger.logDebug("PosCoilReturn 钢卷状态存在.不能进行回退操作。"+CUR_PROG_CD);
  474. String vtemp="CUR_PROG_CD";
  475. context.put("rs", vtemp);
  476. }
  477. }
  478. }else{
  479. if(CUR_PROG_CD.equals("SED") && MISSNO_CLF_CD != null){
  480. //轧废,需要清除轧废的宽度、厚度、重量、时间等信息
  481. //这里在轧制实际表中
  482. logger.logDebug("PosCoilReturn 轧废处理,这里进程代码为SED.废弃代码存在");
  483. //这里需要清空轧制吊销表
  484. PosParameter param3 = new PosParameter();
  485. param3.setWhereClauseParameter(0, slab_no);
  486. param3.setWhereClauseParameter(1, coil_no);
  487. getDao("mesdao").update("UIH020220_01.delete", param3);
  488. //入炉出炉表
  489. PosParameter param4 = new PosParameter();
  490. param4.setWhereClauseParameter(0, "2");
  491. param4.setWhereClauseParameter(1, slab_no);
  492. param4.setWhereClauseParameter(2, coil_no);
  493. getDao("mesdao").update("UIH020220_01.update", param4);
  494. //这里板坯公共表不动,吊销的时候只是写入原因代码
  495. //钢卷公共表,这里要记录修改人和修改时间
  496. PosParameter param5 = new PosParameter();
  497. param5.setWhereClauseParameter(0, "1");
  498. param5.setWhereClauseParameter(1, REG_ID[0]);
  499. param5.setWhereClauseParameter(2, slab_no);
  500. param5.setWhereClauseParameter(3, coil_no);
  501. getDao("mesdao").update("UIH020220_02.update", param5);
  502. //更新轧制计划表
  503. PosParameter param33 = new PosParameter();
  504. param33.setWhereClauseParameter(0,slab_no);
  505. param33.setWhereClauseParameter(1,coil_no);
  506. PosRowSet specMillVo = getDao("mesdao").find("NIH020020_SPEC_MILL.select", param33);
  507. if (specMillVo.hasNext()) {
  508. PosRow specMillROW = specMillVo.next();
  509. Number SLAB_EDT_SEQ = (Number)specMillROW.getAttribute("SLAB_EDT_SEQ");
  510. PosParameter param55 = new PosParameter();
  511. param55.setWhereClauseParameter(0, "B" );
  512. param55.setWhereClauseParameter(1, slab_no );
  513. param55.setWhereClauseParameter(2, coil_no );
  514. getDao("mesdao").update("NIH020020_SPEC_MILL.update", param55);
  515. PosParameter param6 = new PosParameter();
  516. param6.setWhereClauseParameter(0, "B" );
  517. param6.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  518. getDao("mesdao").update("NIH020020_SPEC_MILL_D.update", param6);
  519. PosParameter param7 = new PosParameter();
  520. param7.setWhereClauseParameter(0, "B" );
  521. param7.setWhereClauseParameter(1, SLAB_EDT_SEQ );
  522. getDao("mesdao").update("NIH020020_MILL_IDX.update", param7);
  523. }
  524. //这里还要更新轧制实际表的废弃宽度、厚度、重量信息
  525. PosParameter param8 = new PosParameter();
  526. param8.setWhereClauseParameter(0, slab_no);
  527. param8.setWhereClauseParameter(1, coil_no);
  528. getDao("mesdao").update("UIH020220_03.update", param8);
  529. //回退电文,需要调用品质的存储过程
  530. logger.logInfo("PosCoilReturn---> NIB027010 TC sql call" );
  531. CallableStatement PlRtn = getDao("mesdao").getCallableStatement("UIH020220_NIB02701X");
  532. logger.logInfo("PosCoilReturn---> NIB027010 TC try" );
  533. try {
  534. if(PlRtn != null) {
  535. PlRtn.setString(1,coil_no);
  536. //新增加一个字段,为了废弃的时候使用
  537. PlRtn.setString(2,"T");
  538. PlRtn.registerOutParameter(3, java.sql.Types.VARCHAR);
  539. PlRtn.registerOutParameter(4, java.sql.Types.VARCHAR);
  540. PlRtn.execute();
  541. String sRetCode = PlRtn.getString(3);
  542. String sRetMsg = PlRtn.getString(4);
  543. logger.logInfo("PosCoilReturn---> NIB027010 TC PlRtn1:["+sRetCode+"]:"+ sRetMsg);
  544. } else {
  545. logger.logInfo("PosCoilReturn---> NIB027010 PlRtn2:"+PlRtn );
  546. }
  547. } catch (SQLException e) {
  548. throw new PosException(e.getMessage());
  549. }finally
  550. {
  551. if (PlRtn != null)
  552. {
  553. try
  554. {
  555. PlRtn.close();
  556. }
  557. catch (SQLException e)
  558. {
  559. logger.logWarn(e.getMessage(), e);
  560. logger.logInfo("PosCoilReturn---> NIB027010 SQLException:"+e );
  561. }
  562. }
  563. }
  564. }else{
  565. //已经收到轧制实际的情况下,不能进行回退操作。
  566. logger.logDebug("PosCoilReturn 钢卷状态存在.不能进行回退操作。"+CUR_PROG_CD);
  567. String vtemp="CUR_PROG_CD";
  568. context.put("rs", vtemp);
  569. }
  570. }
  571. }else{
  572. // 钢卷信息不存在
  573. logger.logDebug("PosCoilReturn 钢卷号在公共表中不存在。"+OLD_SAMPL_NO[0]);
  574. String vtemp="OLD_SAMPL_NO";
  575. context.put("rs", vtemp);
  576. }
  577. return PosBizControlConstants.SUCCESS;
  578. }
  579. }