e9dcaea6124037156d3ee1d84c1b929e3a07d306.svn-base 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. package UIM.UIM07;
  2. import java.sql.PreparedStatement;
  3. import java.sql.ResultSet;
  4. import java.sql.SQLException;
  5. import java.sql.CallableStatement;
  6. import java.sql.Connection;
  7. import java.util.ArrayList;
  8. import java.util.Map;
  9. import UIB.COM.XmlSqlParsersFactory;
  10. import CoreFS.SA01.CoreIComponent;
  11. import CoreFS.SA06.CoreReturnObject;
  12. /**
  13. * 酸轧上料管理
  14. *
  15. * @author zsx
  16. * @date 2017-7-26
  17. */
  18. public class UIM070020 extends CoreIComponent {
  19. public CoreReturnObject deleteyard(ArrayList<String[]> list)
  20. throws SQLException {
  21. CoreReturnObject cro = new CoreReturnObject();
  22. StringBuffer sqlBuffer = null;
  23. Map result = this.getDao("KgDao").CoreBeginTranscation();
  24. try {
  25. for (int i = 0; i < list.size(); i++) {
  26. // 判断是否全部选择的标志位
  27. boolean flag = true;
  28. String[] param = list.get(i);
  29. // 查询钢卷公共表中的SHIP_PROG_CD状态
  30. sqlBuffer = new StringBuffer();
  31. // 更新钢卷公共表中的车辆号,排车顺序号
  32. sqlBuffer = new StringBuffer();
  33. sqlBuffer.append(" UPDATE MATAL_DETAIL_inACCOUNTING\n");
  34. sqlBuffer.append(" SET \n");
  35. sqlBuffer.append(" staus = 'D'\n");
  36. sqlBuffer.append(" WHERE PRIGUID =?\n");
  37. this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(),
  38. new Object[] { param[0]});
  39. sqlBuffer = new StringBuffer();
  40. sqlBuffer.append(" UPDATE MATAL_DETAIL_OUTACCOUNTING\n");
  41. sqlBuffer.append(" SET \n");
  42. sqlBuffer.append(" staus = 'D'\n");
  43. sqlBuffer.append(" WHERE PRIGUID =?\n");
  44. this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(),
  45. new Object[] { param[0]});
  46. }
  47. this.getDao("KgDao").CoreCommit(result);
  48. } catch (Exception ex) {
  49. this.getDao("KgDao").CoreRollBack(result);
  50. cro.setV_errCode(-1);
  51. cro.setV_errMsg("删除交易失败!");
  52. }
  53. return cro;
  54. }
  55. public CoreReturnObject returnyard(ArrayList<String[]> list)
  56. throws SQLException {
  57. CoreReturnObject cro = new CoreReturnObject();
  58. StringBuffer sqlBuffer = null;
  59. Map result = this.getDao("KgDao").CoreBeginTranscation();
  60. try {
  61. for (int i = 0; i < list.size(); i++) {
  62. // 判断是否全部选择的标志位
  63. boolean flag = true;
  64. String[] param = list.get(i);
  65. // 查询钢卷公共表中的SHIP_PROG_CD状态
  66. sqlBuffer = new StringBuffer();
  67. // 更新钢卷公共表中的车辆号,排车顺序号
  68. sqlBuffer = new StringBuffer();
  69. sqlBuffer.append(" UPDATE MATAL_DETAIL_inACCOUNTING\n");
  70. sqlBuffer.append(" SET \n");
  71. sqlBuffer.append(" staus = 'N'\n");
  72. sqlBuffer.append(" WHERE PRIGUID =?\n");
  73. this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(),
  74. new Object[] { param[0]});
  75. sqlBuffer = new StringBuffer();
  76. sqlBuffer.append(" UPDATE MATAL_DETAIL_OUTACCOUNTING\n");
  77. sqlBuffer.append(" SET \n");
  78. sqlBuffer.append(" staus = 'N'\n");
  79. sqlBuffer.append(" WHERE PRIGUID =?\n");
  80. this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(),
  81. new Object[] { param[0]});
  82. }
  83. this.getDao("KgDao").CoreCommit(result);
  84. } catch (Exception ex) {
  85. this.getDao("KgDao").CoreRollBack(result);
  86. cro.setV_errCode(-1);
  87. cro.setV_errMsg("回退交易失败!");
  88. }
  89. return cro;
  90. }
  91. }