72724e1ca3d53080c26b1788c57e1c510de085b2.svn-base 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. package com.chinacreator.process.dao;
  2. import com.chinacreator.process.util.DataSource;
  3. import com.frameworkset.common.poolman.SQLExecutor;
  4. import oracle.sql.CLOB;
  5. import org.springframework.stereotype.Component;
  6. import java.io.BufferedReader;
  7. import java.io.IOException;
  8. import java.io.Reader;
  9. import java.sql.SQLException;
  10. import java.text.SimpleDateFormat;
  11. import java.util.Calendar;
  12. import java.util.Date;
  13. import java.util.HashMap;
  14. import java.util.List;
  15. @Component
  16. public class EverySmsDao {
  17. public List<HashMap> getData(String datetm) throws SQLException {
  18. String sql = " SELECT id,count,datetm FROM TD_FLOWRUNOUT_REC A WHERE A.STATUS = '1' and datetm = ?";
  19. return SQLExecutor.queryListWithDBName(HashMap.class, DataSource.NET3G, sql, datetm);
  20. }
  21. //已处理数据
  22. public List<HashMap> gethasdealData(String datetm) throws SQLException {
  23. String sql = " SELECT id,count,datetm FROM TD_FLOWRUNOUT_REC A WHERE A.STATUS = '0' and datetm = ?";
  24. return SQLExecutor.queryListWithDBName(HashMap.class, DataSource.NET3G, sql, datetm);
  25. }
  26. //统计数据到表
  27. public void statistics(String datetm) throws SQLException {
  28. String sql = "insert into TD_FLOWRUNOUT_REC(id,count,datetm) values(TO_CHAR(SYSDATE,'yyyyMMddhh24miss')||SEQ_COMMON6.nextval," +
  29. "(select count(*) from TL_SMSALARM_LOG t1,TB_FLOWLIMIT_ALERT_CONF t2 where to_char(t1.inserttime,'yyyy-MM-dd')=? " +
  30. "and t1.alertid = t2.id and t2.alertval = '0' and t1.resultcode = '0'),?)";
  31. SQLExecutor.insertWithDBName(DataSource.NET3G, sql, datetm, datetm);
  32. }
  33. /**
  34. * 更新状态为已完成
  35. *
  36. * @return
  37. */
  38. public void upResult(String id, String resultcode, String resultinfo) throws SQLException {
  39. String sql = "UPDATE TD_FLOWRUNOUT_REC SET STATUS = '0',RESULTCODE=?,RESULTINFO=? WHERE id=?";
  40. SQLExecutor.updateWithDBName(DataSource.NET3G, sql, resultcode, resultinfo, id);
  41. }
  42. public static void main(String[] args) {
  43. SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  44. Calendar c = Calendar.getInstance();
  45. c.setTime(new Date());
  46. c.add(Calendar.DAY_OF_MONTH, -1);
  47. Date yesterday = c.getTime();//这是昨天
  48. String date = sdf.format(yesterday);
  49. System.out.println(date);
  50. }
  51. }