03595bf2578696deebdffc95e8eab936757dbbd1.svn-base 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918
  1. package UIK.UIK02;
  2. import java.sql.CallableStatement;
  3. import java.sql.Connection;
  4. import java.sql.PreparedStatement;
  5. import java.sql.ResultSet;
  6. import java.sql.SQLException;
  7. import java.sql.Statement;
  8. import java.sql.Types;
  9. import java.util.ArrayList;
  10. import java.util.HashMap;
  11. import java.util.Hashtable;
  12. import java.util.Iterator;
  13. import java.util.List;
  14. import java.util.Map;
  15. import UIB.COM.ProduceFactory;
  16. import UIB.COM.XmlSqlParsersFactory;
  17. import CoreFS.SA01.CoreIComponent;
  18. import CoreFS.SA06.CoreReturnObject;
  19. /**
  20. * 酸轧作业管理
  21. *
  22. * @author siy
  23. * @date 2010-9-17
  24. */
  25. public class UIK020020 extends CoreIComponent {
  26. /**
  27. * 查询酸轧作业实绩
  28. *
  29. * @return
  30. * @throws SQLException
  31. */
  32. public CoreReturnObject queryAcidRollingResult(String cCoilNo,String hCoilNo)
  33. throws SQLException {
  34. CoreReturnObject cro = new CoreReturnObject();
  35. StringBuffer sqlBuffer = new StringBuffer();
  36. sqlBuffer.append(XmlSqlParsersFactory.getSql("UIK020020_01.SELECT"));
  37. // if(null == cCoilNo || "".equals(cCoilNo)){
  38. // sqlBuffer.append(" and r.mill_dtime = (select max(mill_dtime) from
  39. // c_tbl02_pltcm_result)");
  40. // }
  41. // else{
  42. // sqlBuffer.append(" and r.l_coil_no = '" + cCoilNo + "'");
  43. // }
  44. cro = this.getDao("KgDao").ExcuteQuery(sqlBuffer.toString(),
  45. new Object[] { cCoilNo,hCoilNo });
  46. return cro;
  47. }
  48. public CoreReturnObject queryOriCoil(String cCoilNo )
  49. throws SQLException {
  50. CoreReturnObject cro = new CoreReturnObject();
  51. StringBuffer sqlBuffer = new StringBuffer();
  52. sqlBuffer.append(XmlSqlParsersFactory.getSql("UIK020020_11.SELECT"));
  53. cro = this.getDao("KgDao").ExcuteQuery(sqlBuffer.toString(),
  54. new Object[] { cCoilNo });
  55. return cro;
  56. }
  57. /**
  58. * 查询冷轧卷是否存在
  59. *
  60. * @param coilNo
  61. * @return
  62. * @throws SQLException
  63. */
  64. public CoreReturnObject queryCoilExist(String coilNo) throws SQLException {
  65. CoreReturnObject cro = new CoreReturnObject();
  66. // 查询钢卷是否存在于实绩表
  67. String sql = XmlSqlParsersFactory.getSql("UIK020020_03.SELECT");
  68. List list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  69. new Object[] { coilNo });
  70. Iterator it = list.iterator();
  71. int count = 0;
  72. try {
  73. while (it.hasNext()) {
  74. Map map = (Map) it.next();
  75. count = Integer.parseInt(map.get("COUNT").toString());
  76. }
  77. } catch (Exception ex) {
  78. }
  79. if (count == 0 && !coilNo.endsWith("0")) {
  80. String pCoilNo = coilNo.substring(0, coilNo.length() - 2) + "0";
  81. CoreReturnObject cro1 = this.queryCoilExist(pCoilNo);
  82. count = Integer.parseInt(cro1.getResult().toString());
  83. }
  84. cro.setResult(count);
  85. return cro;
  86. }
  87. /**
  88. * 新增酸轧实绩
  89. *
  90. * @param listParam
  91. * @param regID
  92. * @return
  93. * @throws SQLException
  94. */
  95. public CoreReturnObject addAcidRollingResult(ArrayList listParam,String regID)
  96. throws SQLException {
  97. CoreReturnObject cro = new CoreReturnObject();
  98. String[] lCoilInfo = (String[]) listParam.get(0);
  99. ArrayList hCoilInfo = (ArrayList) listParam.get(1);
  100. ArrayList defectInfo = (ArrayList) listParam.get(2);
  101. String sqlEntry = "select t.OLD_SAMPL_NO from c_tbl02_coil_comm t where (t.DLIV_DIRNO is not null or t.FL = '1') and t.OLD_SAMPL_NO = ?";
  102. List listEntry = this.getDao("KgDao").ExcuteQueryReturnList(sqlEntry,
  103. new Object[] { lCoilInfo[0].substring(0, 11)+"0" });
  104. if (listEntry.size() > 0) {
  105. cro.setV_errCode(new Integer(1));
  106. cro.setV_errMsg("物料对应的母卷"+lCoilInfo[0].substring(0, 11)+"0"+"已发货或已连退,禁止分卷!");
  107. return cro;
  108. }
  109. // 查询钢卷是否存在于钢卷公共表
  110. String sql = XmlSqlParsersFactory.getSql("UIK020020_02.SELECT");
  111. List list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  112. new Object[] { lCoilInfo[0] });
  113. Iterator it = list.iterator();
  114. int count = 0;
  115. try {
  116. while (it.hasNext()) {
  117. Map map = (Map) it.next();
  118. count = Integer.parseInt(map.get("COUNT").toString());
  119. }
  120. } catch (Exception ex) {
  121. }
  122. //根据真实钢卷号判断是否存在此卷
  123. String sqln = XmlSqlParsersFactory.getSql("UIK020020_10.SELECT");
  124. List listN = this.getDao("KgDao").ExcuteQueryReturnList(sqln,
  125. new Object[] { lCoilInfo[0] });
  126. Iterator itn = listN.iterator();
  127. int countn = 0;
  128. try {
  129. while (itn.hasNext()) {
  130. Map mapn = (Map) itn.next();
  131. countn = Integer.parseInt(mapn.get("COUNT").toString());
  132. }
  133. } catch (Exception ex) {
  134. }
  135. //判断母卷-10是否存在
  136. List listMU = this.getDao("KgDao").ExcuteQueryReturnList(sqln,
  137. new Object[] { lCoilInfo[0].substring(0, 11)+"0" });
  138. Iterator itMU = listMU.iterator();
  139. int countMU = 0;
  140. try {
  141. while (itMU.hasNext()) {
  142. Map mapMU = (Map) itMU.next();
  143. countMU = Integer.parseInt(mapMU.get("COUNT").toString());
  144. }
  145. } catch (Exception ex) {
  146. }
  147. Map result = this.getDao("KgDao").CoreBeginTranscation();
  148. try {
  149. List<Object> param = new ArrayList<Object>();
  150. param.add(lCoilInfo[0]);
  151. param.add(lCoilInfo[0]);
  152. param.add(lCoilInfo[1]);
  153. param.add(lCoilInfo[3]);
  154. param.add(lCoilInfo[6]);
  155. param.add(lCoilInfo[7]);
  156. param.add(lCoilInfo[2]);
  157. param.add(lCoilInfo[8]);
  158. param.add("");// lock_coil
  159. param.add(lCoilInfo[9]);
  160. for (int i = 0; i < hCoilInfo.size(); i++) {
  161. String[] hCoil = (String[]) hCoilInfo.get(i);
  162. for (int j = 0; j < hCoil.length - 1; j++) {
  163. param.add(hCoil[j]);
  164. }
  165. }
  166. param.add(lCoilInfo[10]);
  167. for (int i = 0; i < defectInfo.size(); i++) {
  168. String[] defect = (String[]) defectInfo.get(i);
  169. for (int j = 0; j < defect.length; j++) {
  170. param.add(defect[j]);
  171. }
  172. }
  173. // 新增实绩
  174. sql = XmlSqlParsersFactory.getSql("UIK020020_01.INSERT");
  175. this.getDao("KgDao").ExcuteNonQuery(sql, param.toArray());
  176. // 查询订单信息
  177. sql = XmlSqlParsersFactory.getSql("UIK020020_04.SELECT");
  178. list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  179. new Object[] { lCoilInfo[0] });
  180. it = list.iterator();
  181. Map ordMap = new HashMap();
  182. if (it.hasNext()) {
  183. ordMap = (Map) it.next();
  184. }
  185. param = new ArrayList<Object>();
  186. param.add(lCoilInfo[0]);
  187. String coilLen = lCoilInfo[3];
  188. try {
  189. if (coilLen == null || coilLen.equals("")
  190. || Integer.parseInt(coilLen) == 0) {
  191. coilLen = String.valueOf(Math.round(Double
  192. .parseDouble(lCoilInfo[2])
  193. * 1000
  194. / (Double.parseDouble(lCoilInfo[4])
  195. * Double.parseDouble(lCoilInfo[5]) * 7.85)
  196. * 1000));
  197. }
  198. } catch (Exception ex) {
  199. }
  200. param.add(coilLen);
  201. param.add(lCoilInfo[6]);
  202. param.add(lCoilInfo[7]);
  203. param.add(lCoilInfo[5]);
  204. param.add(lCoilInfo[4]);
  205. param.add(""); //param.add(lCoilInfo[2]);重量屏蔽
  206. param.add(ordMap.get("STL_GRD") != null ? ordMap.get("STL_GRD")
  207. .toString() : "");// stl_grd
  208. param.add(lCoilInfo[1]);
  209. param.add(lCoilInfo[0]);
  210. if (((String[]) hCoilInfo.get(0))[0].length() > 3) {
  211. param.add(((String[]) hCoilInfo.get(0))[0].substring(0,
  212. ((String[]) hCoilInfo.get(0))[0].length() - 3));// ord_no
  213. param
  214. .add(((String[]) hCoilInfo.get(0))[0]
  215. .substring(((String[]) hCoilInfo.get(0))[0]
  216. .length() - 3));// ord_seq
  217. param.add(1);
  218. } else {
  219. String ordNo = ordMap.get("ORD_NO") != null ? ordMap.get(
  220. "ORD_NO").toString() : "";
  221. String ordSeq = ordMap.get("ORD_SEQ") != null ? ordMap.get(
  222. "ORD_SEQ").toString() : "";
  223. String ordFl = ordNo.equals("") ? "2" : "1";
  224. param.add(ordNo);// ord_no
  225. param.add(ordSeq);// ord_seq
  226. param.add(ordFl);
  227. }
  228. // for (int i = 0; i < 5; i++) {
  229. // param.add(((String[]) defectInfo.get(i))[1]);// defect_type
  230. // }
  231. String slabNo = "";
  232. sql = "select k.slab_no from c_tbk02_coil_comm k where k.coil_no = ?";
  233. list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  234. new Object[] { ((String[]) hCoilInfo.get(0))[29] });// h_coil_no1
  235. it = list.iterator();
  236. if (it.hasNext()) {
  237. Map map = (Map) it.next();
  238. slabNo = map.get("SLAB_NO").toString();
  239. }
  240. param.add(slabNo);// slab_no
  241. String []hCoils = new String[3];
  242. for (int i = 0; i < 3; i++) {
  243. hCoils[i] = ((String[]) hCoilInfo.get(i))[29];
  244. param.add(((String[]) hCoilInfo.get(i))[29]);// h_coil_no
  245. param.add(((String[]) hCoilInfo.get(i))[2]);// h_coil_len
  246. }
  247. param.add(ordMap.get("ORD_THK") != null ? ordMap.get("ORD_THK")
  248. .toString() : "");
  249. param.add(ordMap.get("ORD_WTH") != null ? ordMap.get("ORD_WTH")
  250. .toString() : "");
  251. param.add(ordMap.get("ORD_LEN") != null ? ordMap.get("ORD_LEN")
  252. .toString() : "");
  253. param.add(ordMap.get("ORD_WGT") != null ? ordMap.get("ORD_WGT")
  254. .toString() : "");
  255. param.add(ordMap.get("ORD_INDIA") != null ? ordMap.get("ORD_INDIA")
  256. .toString() : "");
  257. param.add(ordMap.get("ORD_OUTDIA") != null ? ordMap.get(
  258. "ORD_OUTDIA").toString() : "");
  259. param.add(ordMap.get("DEL_TO_DATE") != null ? ordMap.get(
  260. "DEL_TO_DATE").toString() : "");
  261. param.add(ordMap.get("DEST_CD") != null ? ordMap.get("DEST_CD")
  262. .toString() : "");
  263. param.add(ordMap.get("ORDCUST_CD") != null ? ordMap.get("ORDCUST_CD")
  264. .toString() : "");
  265. //param.add("");// cust_cd
  266. param.add(ordMap.get("CUST_CD") != null ? ordMap.get("CUST_CD")
  267. .toString() : "");
  268. param.add(ordMap.get("SPEC_STL_GRD") != null ? ordMap.get(
  269. "SPEC_STL_GRD").toString() : "");
  270. // param.add(ordMap.get("STL_GRD") != null ? ordMap.get("STL_GRD")
  271. // .toString() : "");
  272. param.add(ordMap.get("PRODNM_CD") != null ? ordMap.get("PRODNM_CD")
  273. .toString() : "");
  274. param.add(ordMap.get("C_ORD_USEAGE_CD") != null ? ordMap.get(
  275. "C_ORD_USEAGE_CD").toString() : "");
  276. param.add(ordMap.get("C_SPEC_ABBSYM") != null ? ordMap.get(
  277. "C_SPEC_ABBSYM").toString() : "");
  278. param.add(regID);
  279. param.add(ordMap.get("SPEC_STL_GRD") != null ? ordMap.get(
  280. "SPEC_STL_GRD").toString() : "");
  281. if (count <= 0) {// 新增钢卷
  282. sql = XmlSqlParsersFactory.getSql("UIK020020_02.INSERT");
  283. this.getDao("KgDao").ExcuteNonQuery(sql, param.toArray());
  284. if(countMU>0) {
  285. //调用存货异动点存储过程
  286. ProduceFactory PD= new ProduceFactory();
  287. PD.ErpDataCover("CCOIL",lCoilInfo[0].substring(0, 11)+"0","11AD","0","O",regID,"酸轧分卷母卷");
  288. PD.ErpDataCoverFJ("CCOIL",lCoilInfo[0],"11AD","0","N","N","",lCoilInfo[0].substring(0, 11)+"0",regID,"酸轧分卷子卷");
  289. }
  290. else{
  291. ProduceFactory PD= new ProduceFactory();
  292. PD.ErpDataCover("CORICOIL",((String[]) hCoilInfo.get(0))[29],"41A","0","O",regID,"酸轧轧制"); //((String[]) hCoilInfo.get(i))[29]
  293. PD.ErpDataCoverFJ("CCOIL",lCoilInfo[0],"11A","0","N","N","",((String[]) hCoilInfo.get(0))[29],regID,"酸轧分卷子卷");
  294. }
  295. // 修改母卷
  296. sql = XmlSqlParsersFactory.getSql("UIK020020_07.UPDATE");
  297. this.getDao("KgDao").ExcuteNonQuery(sql,new Object[] { lCoilInfo[0].substring(0, 11)+"0" });
  298. sql = XmlSqlParsersFactory.getSql("UIK020020_08.UPDATE");
  299. this.getDao("KgDao").ExcuteNonQuery(sql,new Object[] { lCoilInfo[0].substring(0, 11)+"0" });
  300. } else {// 修改钢卷
  301. sql = XmlSqlParsersFactory.getSql("UIK020020_02.UPDATE");
  302. param.remove(0);
  303. param.add(lCoilInfo[0]);
  304. this.getDao("KgDao").ExcuteNonQuery(sql, param.toArray());
  305. if(countn<=0)//人工补录实绩时抛送异动点
  306. {
  307. ProduceFactory PD= new ProduceFactory();
  308. PD.ErpDataCover("CCOIL",lCoilInfo[0],"11A","0","O",regID,"酸轧补录产出"); //
  309. PD.ErpDataCover("CORICOIL",((String[]) hCoilInfo.get(0))[29],"41A","0","O",regID,"酸轧轧制"); //((String[]) hCoilInfo.get(i))[29]
  310. }
  311. }
  312. //更改原料卷状态
  313. sql = XmlSqlParsersFactory.getSql("UIK020020_06.UPDATE");
  314. this.getDao("KgDao").ExcuteNonQuery(sql, hCoils);
  315. // 写入钢卷公共表_D
  316. if (!(ordMap.get("ORD_NO") != null ? ordMap.get("ORD_NO")
  317. .toString() : "").equals("")) {
  318. sql = XmlSqlParsersFactory.getSql("UIK020020_06.SELECT");
  319. list = this.getDao("KgDao")
  320. .ExcuteQueryReturnList(
  321. sql,
  322. new Object[] { lCoilInfo[0], lCoilInfo[0],
  323. lCoilInfo[0] });
  324. it = list.iterator();
  325. Map ordMapD = new HashMap();
  326. if (it.hasNext()) {
  327. ordMapD = (Map) it.next();
  328. }
  329. String cutSeq = ordMapD.get("CUT_SEQ") != null ? ordMapD.get(
  330. "CUT_SEQ").toString() : "";
  331. String ordThk = ordMapD.get("ORD_THK") != null ? ordMapD.get(
  332. "ORD_THK").toString() : "";
  333. String ordWth = ordMapD.get("ORD_WTH") != null ? ordMapD.get(
  334. "ORD_WTH").toString() : "";
  335. String ordLen = ordMapD.get("ORD_LEN") != null ? ordMapD.get(
  336. "ORD_LEN").toString() : "";
  337. String ordWgt = ordMapD.get("ORD_WGT") != null ? ordMapD.get(
  338. "ORD_WGT").toString() : "";
  339. String ordWgtMin = ordMapD.get("ORD_WGT_MIN") != null ? ordMapD
  340. .get("ORD_WGT_MIN").toString() : "";
  341. String ordWgtMax = ordMapD.get("ORD_WGT_MAX") != null ? ordMapD
  342. .get("ORD_WGT_MAX").toString() : "";
  343. String ordIndia = ordMapD.get("ORD_INDIA") != null ? ordMapD
  344. .get("ORD_INDIA").toString() : "";
  345. String ordOutdia = ordMapD.get("ORD_OUTDIA") != null ? ordMapD
  346. .get("ORD_OUTDIA").toString() : "";
  347. String ordNo = ordMapD.get("ORD_NO") != null ? ordMapD.get(
  348. "ORD_NO").toString() : "";
  349. String ordSeq = ordMapD.get("ORD_SEQ") != null ? ordMapD.get(
  350. "ORD_SEQ").toString() : "";
  351. String ordFl = ordMapD.get("ORD_FL") != null ? ordMapD.get(
  352. "ORD_FL").toString() : "";
  353. sql = XmlSqlParsersFactory.getSql("UIK020020_07.SELECT");
  354. list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  355. new Object[] { lCoilInfo[0], cutSeq });
  356. it = list.iterator();
  357. Map ordMapCount = new HashMap();
  358. if (it.hasNext()) {
  359. ordMapCount = (Map) it.next();
  360. }
  361. int ordCount = Integer
  362. .parseInt(ordMapCount.get("COUNT") != null ? ordMapCount
  363. .get("COUNT").toString().trim()
  364. : "0");
  365. if (ordCount > 0) {
  366. sql = XmlSqlParsersFactory.getSql("UIK020020_05.UPDATE");
  367. this.getDao("KgDao")
  368. .ExcuteNonQuery(
  369. sql,
  370. new Object[] { ordThk, ordWth, ordLen,
  371. ordWgt, ordWgtMin, ordWgtMax,
  372. ordIndia, ordOutdia, ordNo, ordSeq,
  373. ordFl, lCoilInfo[0], cutSeq });
  374. } else {
  375. sql = XmlSqlParsersFactory.getSql("UIK020020_03.INSERT");
  376. this.getDao("KgDao").ExcuteNonQuery(
  377. sql,
  378. new Object[] { lCoilInfo[0], cutSeq, ordThk,
  379. ordWth, ordLen, ordWgt, ordWgtMin,
  380. ordWgtMax, ordIndia, ordOutdia, ordNo,
  381. ordSeq, ordFl });
  382. }
  383. }
  384. // 修改钢卷轧制状态
  385. sql = XmlSqlParsersFactory.getSql("UIK020020_03.UPDATE");
  386. this.getDao("KgDao").ExcuteNonQuery(sql,
  387. new Object[] { lCoilInfo[0] });
  388. // 修改轧辊单元轧制状态
  389. sql = XmlSqlParsersFactory.getSql("UIK020020_04.UPDATE");
  390. this.getDao("KgDao").ExcuteNonQuery(sql,
  391. new Object[] { lCoilInfo[0], lCoilInfo[0], lCoilInfo[0] });
  392. this.getDao("KgDao").CoreCommit(result);
  393. Connection conn = this.getDao("KgDao").getConnection();
  394. try {
  395. conn.setAutoCommit(false);
  396. // this.takeOverPltcmCoilLable(conn, lCoilInfo[0], Double
  397. // .parseDouble(lCoilInfo[2]), Double
  398. // .parseDouble(lCoilInfo[5]), lCoilInfo[1]);
  399. // 酸轧实绩补录成功后进行尺寸及重量判定
  400. this.dscCoilWgtSize(conn, lCoilInfo[0]);
  401. //添加操作记录
  402. this.CallHistory(conn, lCoilInfo[0] , regID);
  403. // 分卷后重新取样
  404. if ("123456789".contains(lCoilInfo[0].substring(lCoilInfo[0]
  405. .length() - 1))) {
  406. this.cutCoilLost(conn, lCoilInfo[0]);
  407. }
  408. conn.commit();
  409. } catch (Exception e) {
  410. e.printStackTrace();
  411. conn.rollback();
  412. } finally {
  413. if (conn != null && !conn.isClosed()) {
  414. conn.close();
  415. }
  416. }
  417. } catch (Exception ex) {
  418. ex.printStackTrace();
  419. this.getDao("KgDao").CoreRollBack(result);
  420. cro.setV_errCode(-1);
  421. cro.setV_errMsg("实绩新增失败!");
  422. }
  423. return cro;
  424. }
  425. /**
  426. * 新增酸轧实绩
  427. *
  428. * @param listParam
  429. * @param regID
  430. * @return
  431. * @throws SQLException
  432. */
  433. public CoreReturnObject addAcidResultSaunXi(ArrayList listParam,String regID)
  434. throws SQLException {
  435. CoreReturnObject cro = new CoreReturnObject();
  436. String[] lCoilInfo = (String[]) listParam.get(0);
  437. ArrayList hCoilInfo = (ArrayList) listParam.get(1);
  438. ArrayList defectInfo = (ArrayList) listParam.get(2);
  439. // 查询钢卷是否存在于钢卷公共表
  440. String sql = XmlSqlParsersFactory.getSql("UIK020020_02.SELECT");
  441. List list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  442. new Object[] { lCoilInfo[0] });
  443. Iterator it = list.iterator();
  444. int count = 0;
  445. try {
  446. while (it.hasNext()) {
  447. Map map = (Map) it.next();
  448. count = Integer.parseInt(map.get("COUNT").toString());
  449. }
  450. } catch (Exception ex) {
  451. }
  452. Map result = this.getDao("KgDao").CoreBeginTranscation();
  453. try {
  454. List<Object> param = new ArrayList<Object>();
  455. param.add(lCoilInfo[0]);
  456. param.add(lCoilInfo[0]);
  457. param.add(lCoilInfo[1]);
  458. param.add(lCoilInfo[3]);
  459. param.add(lCoilInfo[6]);
  460. param.add(lCoilInfo[7]);
  461. param.add(lCoilInfo[2]);
  462. param.add(lCoilInfo[8]);
  463. param.add("");// lock_coil
  464. param.add(lCoilInfo[9]);
  465. for (int i = 0; i < hCoilInfo.size(); i++) {
  466. String[] hCoil = (String[]) hCoilInfo.get(i);
  467. for (int j = 0; j < hCoil.length - 1; j++) {
  468. param.add(hCoil[j]);
  469. }
  470. }
  471. param.add(lCoilInfo[10]);
  472. for (int i = 0; i < defectInfo.size(); i++) {
  473. String[] defect = (String[]) defectInfo.get(i);
  474. for (int j = 0; j < defect.length; j++) {
  475. param.add(defect[j]);
  476. }
  477. }
  478. // 新增实绩
  479. sql = XmlSqlParsersFactory.getSql("UIK020020_01.INSERT");
  480. this.getDao("KgDao").ExcuteNonQuery(sql, param.toArray());
  481. // 查询订单信息
  482. sql = XmlSqlParsersFactory.getSql("UIK020020_08.SELECT");
  483. list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  484. new Object[] { lCoilInfo[0] });
  485. it = list.iterator();
  486. Map ordMap = new HashMap();
  487. if (it.hasNext()) {
  488. ordMap = (Map) it.next();
  489. }
  490. param = new ArrayList<Object>();
  491. param.add(lCoilInfo[0]);
  492. String coilLen = lCoilInfo[3];
  493. try {
  494. if (coilLen == null || coilLen.equals("")
  495. || Integer.parseInt(coilLen) == 0) {
  496. coilLen = String.valueOf(Math.round(Double
  497. .parseDouble(lCoilInfo[2])
  498. * 1000
  499. / (Double.parseDouble(lCoilInfo[4])
  500. * Double.parseDouble(lCoilInfo[5]) * 7.85)
  501. * 1000));
  502. }
  503. } catch (Exception ex) {
  504. }
  505. param.add(coilLen);
  506. param.add(lCoilInfo[6]);
  507. param.add(lCoilInfo[7]);
  508. param.add(lCoilInfo[5]);
  509. param.add(lCoilInfo[4]);
  510. param.add("");//param.add(lCoilInfo[2]);
  511. param.add(ordMap.get("STL_GRD") != null ? ordMap.get("STL_GRD")
  512. .toString() : "");// stl_grd
  513. param.add(lCoilInfo[1]);
  514. param.add(lCoilInfo[0]);
  515. if (((String[]) hCoilInfo.get(0))[0].length() > 3) {
  516. param.add(((String[]) hCoilInfo.get(0))[0].substring(0,
  517. ((String[]) hCoilInfo.get(0))[0].length() - 3));// ord_no
  518. param
  519. .add(((String[]) hCoilInfo.get(0))[0]
  520. .substring(((String[]) hCoilInfo.get(0))[0]
  521. .length() - 3));// ord_seq
  522. param.add(1);
  523. } else {
  524. String ordNo = ordMap.get("ORD_NO") != null ? ordMap.get(
  525. "ORD_NO").toString() : "";
  526. String ordSeq = ordMap.get("ORD_SEQ") != null ? ordMap.get(
  527. "ORD_SEQ").toString() : "";
  528. String ordFl = ordNo.equals("") ? "2" : "1";
  529. param.add(ordNo);// ord_no
  530. param.add(ordSeq);// ord_seq
  531. param.add(ordFl);
  532. }
  533. // for (int i = 0; i < 5; i++) {
  534. // param.add(((String[]) defectInfo.get(i))[1]);// defect_type
  535. // }
  536. String slabNo = "";
  537. String smp_no = "";
  538. String smp_cut_loc = "";
  539. String matlqlty_dec_grd = "0";
  540. sql = "select k.SMP_NO, k.SMP_CUT_LOC,k.MATLQLTY_DEC_GRD,k.slab_no from c_tbk02_coil_comm k where k.coil_no = ?";
  541. list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  542. new Object[] { ((String[]) hCoilInfo.get(0))[29] });// h_coil_no1
  543. it = list.iterator();
  544. if (it.hasNext()) {
  545. Map map = (Map) it.next();
  546. slabNo = map.get("SLAB_NO").toString();
  547. // smp_no = map.get("SMP_NO").toString();
  548. smp_no = map.get("SMP_NO") != null ? map.get(
  549. "SMP_NO").toString() : "";
  550. smp_cut_loc = map.get("SMP_CUT_LOC") != null ? map.get(
  551. "SMP_CUT_LOC").toString() : "";
  552. //smp_cut_loc = map.get("SMP_CUT_LOC").toString();
  553. matlqlty_dec_grd = map.get("MATLQLTY_DEC_GRD").toString();
  554. }
  555. param.add(slabNo);// slab_no
  556. param.add(smp_no);
  557. param.add(smp_cut_loc);
  558. param.add(matlqlty_dec_grd);
  559. /*
  560. param.add("188888");
  561. param.add("k");
  562. param.add("1");
  563. */
  564. String []hCoils = new String[3];
  565. for (int i = 0; i < 3; i++) {
  566. hCoils[i] = ((String[]) hCoilInfo.get(i))[29];
  567. param.add(((String[]) hCoilInfo.get(i))[29]);// h_coil_no
  568. param.add(((String[]) hCoilInfo.get(i))[2]);// h_coil_len
  569. }
  570. param.add(ordMap.get("ORD_THK") != null ? ordMap.get("ORD_THK")
  571. .toString() : "");
  572. param.add(ordMap.get("ORD_WTH") != null ? ordMap.get("ORD_WTH")
  573. .toString() : "");
  574. param.add(ordMap.get("ORD_LEN") != null ? ordMap.get("ORD_LEN")
  575. .toString() : "");
  576. param.add(ordMap.get("ORD_WGT") != null ? ordMap.get("ORD_WGT")
  577. .toString() : "");
  578. param.add(ordMap.get("ORD_INDIA") != null ? ordMap.get("ORD_INDIA")
  579. .toString() : "");
  580. param.add(ordMap.get("ORD_OUTDIA") != null ? ordMap.get(
  581. "ORD_OUTDIA").toString() : "");
  582. param.add(ordMap.get("DEL_TO_DATE") != null ? ordMap.get(
  583. "DEL_TO_DATE").toString() : "");
  584. param.add(ordMap.get("DEST_CD") != null ? ordMap.get("DEST_CD")
  585. .toString() : "");
  586. param.add(ordMap.get("ORDCUST_CD") != null ? ordMap.get("ORDCUST_CD")
  587. .toString() : "");
  588. //param.add("");// cust_cd
  589. param.add(ordMap.get("CUST_CD") != null ? ordMap.get("CUST_CD")
  590. .toString() : "");
  591. param.add(ordMap.get("SPEC_STL_GRD") != null ? ordMap.get(
  592. "SPEC_STL_GRD").toString() : "");
  593. // param.add(ordMap.get("STL_GRD") != null ? ordMap.get("STL_GRD")
  594. // .toString() : "");
  595. param.add(ordMap.get("PRODNM_CD") != null ? ordMap.get("PRODNM_CD")
  596. .toString() : "");
  597. param.add(ordMap.get("C_ORD_USEAGE_CD") != null ? ordMap.get(
  598. "C_ORD_USEAGE_CD").toString() : "");
  599. param.add(ordMap.get("C_SPEC_ABBSYM") != null ? ordMap.get(
  600. "C_SPEC_ABBSYM").toString() : "");
  601. param.add(regID);
  602. param.add(ordMap.get("SPEC_STL_GRD") != null ? ordMap.get(
  603. "SPEC_STL_GRD").toString() : "");
  604. if (count <= 0) {// 新增钢卷
  605. sql = XmlSqlParsersFactory.getSql("UIK020020_04.INSERT");
  606. this.getDao("KgDao").ExcuteNonQuery(sql, param.toArray());
  607. // 修改母卷
  608. sql = XmlSqlParsersFactory.getSql("UIK020020_07.UPDATE");
  609. this.getDao("KgDao").ExcuteNonQuery(sql,new Object[] { lCoilInfo[0].substring(0, 11)+"0" });
  610. sql = XmlSqlParsersFactory.getSql("UIK020020_08.UPDATE");
  611. this.getDao("KgDao").ExcuteNonQuery(sql,new Object[] { lCoilInfo[0].substring(0, 11)+"0" });
  612. } else {// 修改钢卷
  613. sql = XmlSqlParsersFactory.getSql("UIK020020_02.UPDATE");
  614. param.remove(0);
  615. param.add(lCoilInfo[0]);
  616. this.getDao("KgDao").ExcuteNonQuery(sql, param.toArray());
  617. }
  618. //更改原料卷状态
  619. sql = XmlSqlParsersFactory.getSql("UIK020020_06.UPDATE");
  620. this.getDao("KgDao").ExcuteNonQuery(sql, hCoils);
  621. // 写入钢卷公共表_D
  622. if (!(ordMap.get("ORD_NO") != null ? ordMap.get("ORD_NO")
  623. .toString() : "").equals("")) {
  624. sql = XmlSqlParsersFactory.getSql("UIK020020_09.SELECT");
  625. list = this.getDao("KgDao")
  626. .ExcuteQueryReturnList(
  627. sql,
  628. new Object[] { lCoilInfo[0], lCoilInfo[0],
  629. lCoilInfo[0] });
  630. it = list.iterator();
  631. Map ordMapD = new HashMap();
  632. if (it.hasNext()) {
  633. ordMapD = (Map) it.next();
  634. }
  635. String cutSeq = ordMapD.get("CUT_SEQ") != null ? ordMapD.get(
  636. "CUT_SEQ").toString() : "";
  637. String ordThk = ordMapD.get("ORD_THK") != null ? ordMapD.get(
  638. "ORD_THK").toString() : "";
  639. String ordWth = ordMapD.get("ORD_WTH") != null ? ordMapD.get(
  640. "ORD_WTH").toString() : "";
  641. String ordLen = ordMapD.get("ORD_LEN") != null ? ordMapD.get(
  642. "ORD_LEN").toString() : "";
  643. String ordWgt = ordMapD.get("ORD_WGT") != null ? ordMapD.get(
  644. "ORD_WGT").toString() : "";
  645. String ordWgtMin = ordMapD.get("ORD_WGT_MIN") != null ? ordMapD
  646. .get("ORD_WGT_MIN").toString() : "";
  647. String ordWgtMax = ordMapD.get("ORD_WGT_MAX") != null ? ordMapD
  648. .get("ORD_WGT_MAX").toString() : "";
  649. String ordIndia = ordMapD.get("ORD_INDIA") != null ? ordMapD
  650. .get("ORD_INDIA").toString() : "";
  651. String ordOutdia = ordMapD.get("ORD_OUTDIA") != null ? ordMapD
  652. .get("ORD_OUTDIA").toString() : "";
  653. String ordNo = ordMapD.get("ORD_NO") != null ? ordMapD.get(
  654. "ORD_NO").toString() : "";
  655. String ordSeq = ordMapD.get("ORD_SEQ") != null ? ordMapD.get(
  656. "ORD_SEQ").toString() : "";
  657. String ordFl = ordMapD.get("ORD_FL") != null ? ordMapD.get(
  658. "ORD_FL").toString() : "";
  659. sql = XmlSqlParsersFactory.getSql("UIK020020_07.SELECT");
  660. list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
  661. new Object[] { lCoilInfo[0], cutSeq });
  662. it = list.iterator();
  663. Map ordMapCount = new HashMap();
  664. if (it.hasNext()) {
  665. ordMapCount = (Map) it.next();
  666. }
  667. int ordCount = Integer
  668. .parseInt(ordMapCount.get("COUNT") != null ? ordMapCount
  669. .get("COUNT").toString().trim()
  670. : "0");
  671. if (ordCount > 0) {
  672. sql = XmlSqlParsersFactory.getSql("UIK020020_05.UPDATE");
  673. this.getDao("KgDao")
  674. .ExcuteNonQuery(
  675. sql,
  676. new Object[] { ordThk, ordWth, ordLen,
  677. ordWgt, ordWgtMin, ordWgtMax,
  678. ordIndia, ordOutdia, ordNo, ordSeq,
  679. ordFl, lCoilInfo[0], cutSeq });
  680. } else {
  681. sql = XmlSqlParsersFactory.getSql("UIK020020_03.INSERT");
  682. this.getDao("KgDao").ExcuteNonQuery(
  683. sql,
  684. new Object[] { lCoilInfo[0], cutSeq, ordThk,
  685. ordWth, ordLen, ordWgt, ordWgtMin,
  686. ordWgtMax, ordIndia, ordOutdia, ordNo,
  687. ordSeq, ordFl });
  688. }
  689. }
  690. // 修改钢卷轧制状态
  691. sql = XmlSqlParsersFactory.getSql("UIK020020_11.UPDATE");
  692. this.getDao("KgDao").ExcuteNonQuery(sql,
  693. new Object[] { lCoilInfo[0] });
  694. // 修改轧辊单元轧制状态
  695. sql = XmlSqlParsersFactory.getSql("UIK020020_12.UPDATE");
  696. this.getDao("KgDao").ExcuteNonQuery(sql,
  697. new Object[] { lCoilInfo[0], lCoilInfo[0], lCoilInfo[0] });
  698. this.getDao("KgDao").CoreCommit(result);
  699. Connection conn = this.getDao("KgDao").getConnection();
  700. try {
  701. conn.setAutoCommit(false);
  702. // this.takeOverPltcmCoilLable(conn, lCoilInfo[0], Double
  703. // .parseDouble(lCoilInfo[2]), Double
  704. // .parseDouble(lCoilInfo[5]), lCoilInfo[1]);
  705. // 酸轧实绩补录成功后进行尺寸及重量判定
  706. this.dscCoilWgtSize(conn, lCoilInfo[0]);
  707. //添加操作记录
  708. this.CallHistory(conn, lCoilInfo[0] , regID);
  709. // 分卷后重新取样 20190409 注释
  710. /*
  711. if ("123456789".contains(lCoilInfo[0].substring(lCoilInfo[0]
  712. .length() - 1))) {
  713. this.cutCoilLost(conn, lCoilInfo[0]);
  714. }
  715. */
  716. conn.commit();
  717. } catch (Exception e) {
  718. e.printStackTrace();
  719. conn.rollback();
  720. } finally {
  721. if (conn != null && !conn.isClosed()) {
  722. conn.close();
  723. }
  724. }
  725. } catch (Exception ex) {
  726. ex.printStackTrace();
  727. this.getDao("KgDao").CoreRollBack(result);
  728. cro.setV_errCode(-1);
  729. cro.setV_errMsg("实绩新增失败!");
  730. }
  731. return cro;
  732. }
  733. /**
  734. * 修改酸轧实绩
  735. *
  736. * @param coilNo
  737. * @param coilWgt
  738. * @param coilLen
  739. * @param coilWth
  740. * @param CoilThk
  741. * @param coilInida
  742. * @param coilOutdia
  743. * @return
  744. * @throws SQLException
  745. */
  746. public CoreReturnObject updateAcidRollingResult(String coilNo,
  747. String coilWgt, String coilLen, String coilWth, String coilThk,
  748. String coilIndia, String coilOutdia, String regId)
  749. throws SQLException {
  750. CoreReturnObject cro = new CoreReturnObject();
  751. String sql = XmlSqlParsersFactory.getSql("UIK020020_01.UPDATE");
  752. this.getDao("KgDao").ExcuteNonQuery(
  753. sql,
  754. new Object[] { coilLen, coilWth, coilThk, coilIndia,
  755. coilOutdia, regId, coilNo });
  756. String sql0 = XmlSqlParsersFactory.getSql("UIK020020_10.UPDATE");
  757. this.getDao("KgDao").ExcuteNonQuery(
  758. sql0,
  759. new Object[] { coilNo, coilLen, coilIndia,
  760. coilOutdia,coilThk, coilWth, coilWgt,regId });
  761. return cro;
  762. }
  763. /**
  764. * 查询酸轧轧制最后20卷
  765. *
  766. * @return
  767. * @throws SQLException
  768. */
  769. public CoreReturnObject queryLastCoilNos() throws SQLException {
  770. CoreReturnObject cro = new CoreReturnObject();
  771. String sql = XmlSqlParsersFactory.getSql("UIK020020_05.SELECT");
  772. PreparedStatement pSta = this.getDao("KgDao").getPreparedStatement(sql);
  773. ResultSet rs = pSta.executeQuery();
  774. ArrayList<String> list = new ArrayList<String>();
  775. String param = "";
  776. while (rs.next()) {
  777. param = rs.getString("COIL_NO");
  778. list.add(param);
  779. }
  780. cro.setResult(list);
  781. rs.close();
  782. Connection con = pSta.getConnection();
  783. pSta.close();
  784. con.close();
  785. return cro;
  786. }
  787. /**
  788. * 酸轧重量及尺寸判定
  789. *
  790. * @param conn
  791. * @param coilNo
  792. * @return
  793. * @throws SQLException
  794. */
  795. private String dscCoilWgtSize(Connection conn, String coilNo)
  796. throws SQLException {
  797. // ZL_SUAN_DCS01.DCS_COIL_WGTSIZE(v_rec.EXIT_COIL_ID,P_RETURN_MSG);
  798. String retMsg = "";
  799. String sql = XmlSqlParsersFactory.getSql("UIK020020_01.CALL");
  800. CallableStatement cstm = conn.prepareCall(sql);
  801. cstm.setString(1, coilNo);
  802. cstm.registerOutParameter(2, java.sql.Types.VARCHAR);
  803. cstm.execute();
  804. retMsg = cstm.getString(2);
  805. cstm.close();
  806. return retMsg;
  807. }
  808. /**
  809. * 分卷后重新生成取样信息
  810. *
  811. * @param conn
  812. * @param coilNo
  813. * @return
  814. * @throws SQLException
  815. */
  816. private String cutCoilLost(Connection conn, String coilNo)
  817. throws SQLException {
  818. String retMsg = "";
  819. String sql = XmlSqlParsersFactory.getSql("UIK020020_02.CALL");
  820. CallableStatement cstm = conn.prepareCall(sql);
  821. cstm.setString(1, coilNo);
  822. cstm.registerOutParameter(2, java.sql.Types.VARCHAR);
  823. cstm.execute();
  824. retMsg = cstm.getString(2);
  825. cstm.close();
  826. return retMsg;
  827. }
  828. /**
  829. * 补录实绩后调用标签打印
  830. *
  831. * @param conn
  832. * @param coilNo
  833. * @return
  834. * @throws SQLException
  835. */
  836. private void takeOverPltcmCoilLable(Connection conn, String coilNo,
  837. double coilWgt, double coilThk, String millDtime)
  838. throws SQLException {
  839. String sql = XmlSqlParsersFactory.getSql("UIK020020_03.CALL");
  840. CallableStatement cstm = conn.prepareCall(sql);
  841. cstm.setString(1, coilNo);
  842. cstm.setDouble(2, coilWgt);
  843. cstm.setDouble(3, coilThk);
  844. cstm.setString(4, millDtime);
  845. cstm.execute();
  846. cstm.close();
  847. }
  848. public void CallHistory(Connection conn,String coilNo,String regid){
  849. try{
  850. String sql = XmlSqlParsersFactory.getSql("UIL010020_02_CALL.CALL");
  851. CallableStatement cstm = conn.prepareCall(sql);
  852. cstm.setString(1,"S");
  853. cstm.setString(2,coilNo);
  854. cstm.setString(3,regid);
  855. cstm.setString(4,"酸轧实绩修改");
  856. cstm.setString(5,"UIK020020");
  857. cstm.setString(6,"修改后");
  858. cstm.registerOutParameter(7,Types.VARCHAR);
  859. cstm.execute();
  860. cstm.close();
  861. }catch(Exception j){
  862. j.getMessage();
  863. }
  864. }
  865. }