5f56fb2b0e1a1e519fb66bcf47375fb5e9c5934c.svn-base 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. package UIB.JHY;
  2. import java.util.ArrayList;
  3. import org.springframework.jdbc.support.rowset.SqlRowSet;
  4. import UIB.COM.XmlSqlParsersFactory;
  5. import CoreFS.SA01.CoreIComponent;
  6. import CoreFS.SA06.CoreReturnObject;
  7. /**
  8. *
  9. * @desc 按检验项目对原始数据查询
  10. * @author meiguiping
  11. * @date 2014/3/27
  12. */
  13. public class UIB100220 extends CoreIComponent
  14. {
  15. /**
  16. * qltyCD2 二级编码 即:拉力,冲击等区分
  17. * qltyCD3 三级编码 即:伸长率,屈服强度,抗拉强度等
  18. * wtbh 委托编号
  19. */
  20. public CoreReturnObject doQltyCdQuery(String qltyCD2 ,String qltyCD3 ,String wtbh ,String strArr , String strSendTP ,String qltyCD)throws Exception
  21. {
  22. //获取所有的检化验编码,如a,b,Lo,S等
  23. CoreReturnObject cro = new CoreReturnObject();
  24. String sqlOne = XmlSqlParsersFactory.getSql("UIB100220_03.SELECT");
  25. cro = this.getDao("JhyDao").ExecutequeryForRowSet(sqlOne , new Object[]{qltyCD2 });
  26. SqlRowSet srs = (SqlRowSet)cro.getResult();
  27. //获取目的SQL
  28. String repSql = ",MAX(DECODE('{2}', T1.QLTY_OPE_CD , T1.QLTY_VAL , NULL)) \"{3}\"";
  29. String temp = "";
  30. StringBuffer sBuffer = new StringBuffer(350);
  31. String qltyNm = "";
  32. while(srs.next())
  33. {
  34. temp = repSql.replaceFirst("[{]+[2]+[}]+", srs.getString(1)).replaceFirst("[{]+[3]+[}]+", srs.getString("QLTY_OPE_CFNM"));//检验项目
  35. sBuffer.append(temp);
  36. }
  37. String sqlAim = XmlSqlParsersFactory
  38. .getSql("UIB100220_04.SELECT")
  39. .replaceFirst("[{]+[1]+[}]+", sBuffer.toString());
  40. cro = this.getDao("JhyDao").ExcuteQuery(sqlAim , new Object[]{wtbh , qltyCD2 , wtbh , qltyCD2 , qltyCD3 /*,strArr , strSendTP*/ , qltyCD} );
  41. return cro;
  42. }
  43. }