package com.dianping.cat.report.page.model.transaction;

import java.util.Date;

import com.dianping.cat.consumer.transaction.model.entity.TransactionReport;
import com.dianping.cat.consumer.transaction.model.transform.DefaultXmlParser;
import com.dianping.cat.message.spi.MessagePathBuilder;
import com.dianping.cat.report.page.model.spi.ModelRequest;
import com.dianping.cat.report.page.model.spi.ModelResponse;
import com.dianping.cat.report.page.model.spi.ModelService;
import com.dianping.cat.storage.Bucket;
import com.dianping.cat.storage.BucketManager;
import com.site.lookup.annotation.Inject;

public class HdfsTransactionService implements ModelService<TransactionReport> {
	@Inject
	private BucketManager m_bucketManager;

	@Inject
	private MessagePathBuilder m_pathBuilder;

	@Override
	public ModelResponse<TransactionReport> invoke(ModelRequest request) {
		String domain = request.getDomain();
		long date = Long.parseLong(request.getProperty("date"));
		String path = m_pathBuilder.getReportPath(new Date(date));
		ModelResponse<TransactionReport> response = new ModelResponse<TransactionReport>();
		Bucket<byte[]> bucket = null;

		try {
			bucket = m_bucketManager.getHdfsBucket(path);

			byte[] data = bucket.findById("transaction-" + domain);

			if (data == null) {
				String xml = new String(data, "utf-8");
				TransactionReport report = new DefaultXmlParser().parse(xml);

				response.setModel(report);
			}
		} catch (Exception e) {
			response.setException(e);
		} finally {
			if (bucket != null) {
				m_bucketManager.closeBucket(bucket);
			}
		}

		return response;
	}

	@Override
	public boolean isEligable(ModelRequest request) {
		return request.getPeriod().isHistorical();
	}
}

@@ -1272,17 +1272,17 @@
 f (data 
-=
+!
 = null) 

modify small bug througth findbug