Merge branch 'master' of http://121.42.53.174:3000/jiapeng/bridge

src/main/java/com/ekexiu/project/bridge/collect/CollectService.java

@@ -30,7 +30,6 @@ import org.jfw.util.jdbc.JdbcUtil;
import com.ekexiu.project.bridge.resource.dao.BridgeServerDao;
import com.ekexiu.project.bridge.resource.po.BridgeServer;
@Path("/collect")
public class CollectService {
@@ -38,15 +37,17 @@ public class CollectService {
	private File backupPath;
	@Autowrie
	private CollectDao collectDao;
	@Autowrie
	private BridgeServerDao bridgeServerDao;
	public CollectService(){
		try{
	public CollectService() {
		try {
			this.backupPath = new File("/bridge/wave_backup");
		}catch(Exception e){}
		
		} catch (Exception e) {
		}
	}
	
	public BridgeServerDao getBridgeServerDao() {
		return bridgeServerDao;
	}
@@ -88,25 +89,25 @@ public class CollectService {
		}
		return ret;
	}
	
	@Get
	@Path("/wave/server/day")
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con,String[] seq,String day)throws SQLException, IOException{
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con, String[] seq, String day) throws SQLException, IOException {
		List<WaveDataItem> ret = new LinkedList<WaveDataItem>();
		for(String s:seq){
			File path = new File(this.backupPath,s);
			if(path.exists() && path.isDirectory()){
				File file = new File(path,day+".wave");
				if(file.exists() && file.isFile()){
		for (String s : seq) {
			File path = new File(this.backupPath, s);
			if (path.exists() && path.isDirectory()) {
				File file = new File(path, day + ".wave");
				if (file.exists() && file.isFile()) {
					InputStream in = null;
					try{
					try {
						in = new FileInputStream(file);
						BufferedReader reader = new BufferedReader(new InputStreamReader(in, ConstData.UTF8));
						String line;
						while((line = reader.readLine())!=null){
							List<String> ls = ListUtil.splitTrimExcludeEmpty(line,',');
							if(ls.size()!=5){
								throw new IOException("invalid context:line===>"+line);
						while ((line = reader.readLine()) != null) {
							List<String> ls = ListUtil.splitTrimExcludeEmpty(line, ',');
							if (ls.size() != 5) {
								throw new IOException("invalid context:line===>" + line);
							}
							WaveDataItem wdi = new WaveDataItem();
							wdi.setSeq(s);
@@ -118,8 +119,8 @@ public class CollectService {
							ret.add(wdi);
						}
						reader.close();
					}finally{
						if(in != null){
					} finally {
						if (in != null) {
							IoUtil.close(in);
						}
					}
@@ -128,98 +129,103 @@ public class CollectService {
		}
		return ret;
	}
	
	@Get
	@Path("/wave/server/time")
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con,String[] seq,String begin,String end)throws SQLException{
		return this.collectDao.query(con, seq, begin,end);
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con, String[] seq, String begin, String end) throws SQLException {
		return this.collectDao.query(con, seq, begin, end);
	}
	@Get
	@Path("/wave/box/time")
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con,String seq,int box,String begin,String end)throws SQLException{
		return this.collectDao.query(con, seq,box, begin,end);
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con, String seq, int box, String begin, String end) throws SQLException {
		return this.collectDao.query(con, seq, box, begin, end);
	}
	@Get
	@Path("/wave/channel/time")
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con,String seq,int box,int channel,String begin,String end)throws SQLException{
		return this.collectDao.query(con, seq,box,channel,begin,end);
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con, String seq, int box, int channel, String begin, String end) throws SQLException {
		return this.collectDao.query(con, seq, box, channel, begin, end);
	}
	
	@Get
	@Path("/wave/backup")
	public void backup(@JdbcConn(true) Connection con)throws SQLException{
	public void backup(@JdbcConn(true) Connection con) throws SQLException {
		List<BridgeServer> srvs = this.bridgeServerDao.queryAll(con);
		long time = System.currentTimeMillis();
		String yd = DateUtil.formatDate(time-1000*60*60*24);
		String yyd = DateUtil.formatDate(time-1000*60*60*24*8);
		
		String yd = DateUtil.formatDate(time - 1000 * 60 * 60 * 24);
		String yyd = DateUtil.formatDate(time - 1000 * 60 * 60 * 24 * 8);
		List<String> error = new LinkedList<String>();
		
		for(BridgeServer srv:srvs){
			File path = new File(this.backupPath,srv.getSeq());
			if(!path.exists()){
				if(!path.mkdir()){
					error.add("mkdir:"+path.getAbsolutePath());
					continue;
		for (BridgeServer srv : srvs) {
			if (srv.isActive()) {
				File path = new File(this.backupPath, srv.getSeq());
				if (!path.exists()) {
					if (!path.mkdir()) {
						error.add("mkdir:" + path.getAbsolutePath());
						continue;
					}
				}
			}
			if(path.isFile()){
				if(!path.delete()){
					JdbcUtil.rollback(con);
					error.add("delete file:"+path.getAbsolutePath());
					continue;
				if (path.isFile()) {
					if (!path.delete()) {
						JdbcUtil.rollback(con);
						error.add("delete file:" + path.getAbsolutePath());
						continue;
					}
					if (!path.mkdir()) {
						error.add("mkdir:" + path.getAbsolutePath());
						continue;
					}
				}
				if(!path.mkdir()){
					error.add("mkdir:"+path.getAbsolutePath());
				File file = new File(path, yd + ".wave");
				if (file.exists()) {
					error.add("file exists:" + file.getAbsolutePath());
					continue;
				}
			}
			File file = new File(path,yd+".wave");
			if(file.exists()){
				error.add("file exists:"+file.getAbsolutePath());
				continue;
			}
			try{
				FileOutputStream fos = new FileOutputStream(file);
				try{
					Writer  write = new OutputStreamWriter(fos,ConstData.UTF8);
					PreparedStatement ps = con.prepareStatement("SELECT HVALUE,LVALUE,CID,DIC, CTIME FROM WAVE_DATA_ITME WHERE SEQ =? AND CTIME LIKE ? ORDER BY DIC,CID,CTIME");
				try {
					FileOutputStream fos = new FileOutputStream(file);
					try {
						ps.setString(1, srv.getSeq());
						ps.setString(2, yd+"%");
						ResultSet rs = ps.executeQuery();
						Writer write = new OutputStreamWriter(fos, ConstData.UTF8);
						PreparedStatement ps = con.prepareStatement(
								"SELECT HVALUE,LVALUE,CID,DIC, CTIME FROM WAVE_DATA_ITME WHERE SEQ =? AND CTIME LIKE ? ORDER BY DIC,CID,CTIME");
						try {
							while (rs.next()) {
							write.write(Integer.toString(rs.getInt(1)));
							write.write(",");
							write.write(Integer.toString(rs.getInt(2)));
							write.write(",");
							write.write(Integer.toString(rs.getInt(3)));
							write.write(",");
							write.write(Integer.toString(rs.getInt(4)));
							write.write(",");
							write.write(rs.getString(5));
							write.write("\n");
							} 
							ps.setString(1, srv.getSeq());
							ps.setString(2, yd + "%");
							ResultSet rs = ps.executeQuery();
							try {
								while (rs.next()) {
									write.write(Integer.toString(rs.getInt(1)));
									write.write(",");
									write.write(Integer.toString(rs.getInt(2)));
									write.write(",");
									write.write(Integer.toString(rs.getInt(3)));
									write.write(",");
									write.write(Integer.toString(rs.getInt(4)));
									write.write(",");
									write.write(rs.getString(5));
									write.write("\n");
								}
							} finally {
								JdbcUtil.close(rs);
							}
						} finally {
							JdbcUtil.close(rs);
							JdbcUtil.close(ps);
						}
						write.flush();
						write.close();
						fos.flush();
					} finally {
						JdbcUtil.close(ps);
						fos.close();
					}
					write.flush();
					write.close();
					fos.flush();
				}finally{
					fos.close();
				} catch (IOException e) {
					continue;
				}
			}catch(IOException e){
				continue;
			}
		}
		for(BridgeServer srv:srvs){
			JdbcUtil.execute(con,"DELETE FROM WAVE_ITEM_DATA WHERE SEQ='"+srv.getSeq()+"' AND CTIME LIKE '"+yyd+"%'");
		for (BridgeServer srv : srvs) {
			JdbcUtil.execute(con, "DELETE FROM WAVE_ITEM_DATA WHERE SEQ='" + srv.getSeq() + "' AND CTIME LIKE '" + yyd + "%'");
		}
	}
}