5467b02ffb1c25f42f51ca928ca5e2d29f25fdc8.svn-base 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package UIM;
  2. import java.sql.ResultSet;
  3. import java.sql.SQLException;
  4. import java.util.ArrayList;
  5. import UIB.COM.XmlSqlParsersFactory;
  6. import CoreFS.SA01.CoreIComponent;
  7. import CoreFS.SA06.CoreReturnObject;
  8. import CoreFS.SA06.CoreSqlType;
  9. public class UIM010330 extends CoreIComponent{
  10. public CoreReturnObject query(String coilNo,String fromTime,String toTime) throws SQLException{
  11. CoreReturnObject cro = new CoreReturnObject();
  12. String sql = XmlSqlParsersFactory.getSql("UIM010330_01.SELECT");
  13. cro = this.getDao("KgDao").ExcuteQuery(sql,new Object[]{coilNo,fromTime,toTime});
  14. return cro;
  15. }
  16. public CoreReturnObject doOut(String coilNo, String regId,
  17. String trnfShift, String trnfGroup, String trnfTime) throws SQLException{
  18. CoreReturnObject cro = new CoreReturnObject();
  19. // 根据钢卷号查询垛位编号
  20. String sql1 = "select clf_no from c_tbk08_coil_yard where coil_no = '"
  21. + coilNo + "'";
  22. ResultSet rs = this.getDao("KgDao").ExceuteQueryForResultSet(sql1);
  23. long yardNo = 0;
  24. // 如果钢卷在原料库中,查询出相应的垛位编号
  25. if (rs.next()) {
  26. yardNo = Long.parseLong(rs.getObject("clf_no").toString());
  27. }
  28. //20131014系统连接异常优化
  29. this.getDao("KgDao").closeRs(rs);
  30. // 根据垛位编号清除钢卷信息
  31. String sql2 = "update c_tbk08_coil_yard set coil_no = '' where clf_no= ?";
  32. this.getDao("KgDao").ExcuteNonQuery(sql2, new Object[] { yardNo });
  33. // 修改原料公共表钢卷操作信息
  34. String sql3 = XmlSqlParsersFactory.getSql("UIM010330_01.UPDATE");
  35. this.getDao("KgDao").ExcuteNonQuery(
  36. sql3,
  37. new Object[] { regId, trnfShift, trnfGroup, trnfTime,
  38. coilNo });
  39. return cro;
  40. }
  41. }