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

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

@@ -1,23 +1,67 @@
package com.ekexiu.project.bridge.collect;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.Writer;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import org.jfw.apt.annotation.Autowrie;
import org.jfw.apt.web.annotation.Path;
import org.jfw.apt.web.annotation.operate.Get;
import org.jfw.apt.web.annotation.param.JdbcConn;
import org.jfw.util.ConstData;
import org.jfw.util.DateUtil;
import org.jfw.util.ListUtil;
import org.jfw.util.io.IoUtil;
import org.jfw.util.jdbc.JdbcUtil;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;
import com.ekexiu.project.bridge.resource.dao.BridgeServerDao;
import com.ekexiu.project.bridge.resource.po.BridgeServer;
@Path("/collect")
public class CollectService {
	private Map<String, List<WaveDataItem>> waveCache;
	private File backupPath;
	@Autowrie
	private CollectDao collectDao;
	private BridgeServerDao bridgeServerDao;
	public CollectService(){
		try{
			this.backupPath = new File("/bridge/wave_backup");
		}catch(Exception e){}
		
	}
	
	public BridgeServerDao getBridgeServerDao() {
		return bridgeServerDao;
	}
	public void setBridgeServerDao(BridgeServerDao bridgeServerDao) {
		this.bridgeServerDao = bridgeServerDao;
	}
	public File getBackupPath() {
		return backupPath;
	}
	public void setBackupPath(File backupPath) {
		this.backupPath = backupPath;
	}
	public CollectDao getCollectDao() {
		return collectDao;
@@ -47,8 +91,42 @@ public class CollectService {
	
	@Get
	@Path("/wave/server/day")
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con,String[] seq,String day)throws SQLException{
		return this.collectDao.query(con, seq, day+"000000", day+"235959");
	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()){
					InputStream in = null;
					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);
							}
							WaveDataItem wdi = new WaveDataItem();
							wdi.setSeq(s);
							wdi.setHvalue(Integer.parseInt(ls.get(0)));
							wdi.setLvalue(Integer.parseInt(ls.get(1)));
							wdi.setCid(Integer.parseInt(ls.get(2)));
							wdi.setDid(Integer.parseInt(ls.get(3)));
							wdi.setCtime(ls.get(4));
							ret.add(wdi);
						}
						reader.close();
					}finally{
						if(in != null){
							IoUtil.close(in);
						}
					}
				}
			}
		}
		return ret;
	}
	
	@Get
@@ -68,5 +146,80 @@ public class CollectService {
	}
	
	
	@Get
	@Path("/wave/backup")
	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);
		
		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;
				}
			}
			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;
				}
			}
			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 {
						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(ps);
					}
					write.flush();
					write.close();
					fos.flush();
				}finally{
					fos.close();
				}
			}catch(IOException e){
				continue;
			}
		}
		for(BridgeServer srv:srvs){
			JdbcUtil.execute(con,"DELETE FROM WAVE_ITEM_DATA WHERE SEQ='"+srv.getSeq()+"' AND CTIME LIKE '"+yyd+"%'");
		}
	}
}

src/main/java/com/ekexiu/project/bridge/resource/dao/BridgeServerDao.java

@@ -79,6 +79,10 @@ public interface BridgeServerDao {
    @SelectList
    List<BridgeServer> queryByCode(Connection con, @Nullable Boolean active, @Nullable @Like String code) throws SQLException;
    
    @SelectList
    @Exclude( { "createTime","modifyTime","creator","modifier","remark" })
    List<BridgeServer> queryAll(Connection con) throws SQLException;
}