11

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

@@ -136,6 +136,49 @@ public class CollectService {
		return ret;
	}
    @Get
    @Path("/wave/server/dayTime")
    public List<WaveDataItem> waveByDayTime(@JdbcConn Connection con, String[] seq, String begin,String end) 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, begin.substring(0,8) + ".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));
                            String time = wdi.getCtime();
                            if((time.compareTo(begin)>=0)&&(time.compareTo(end)<=0)) {
                                ret.add(wdi);
                            }
                        }
                        reader.close();
                    } finally {
                        if (in != null) {
                            IoUtil.close(in);
                        }
                    }
                }
            }
        }
        return ret;
    }
	@Get
	@Path("/wave/server/time")
	public List<WaveDataItem> waveByDay(@JdbcConn Connection con, String[] seq, String begin, String end) throws SQLException {