数据修正

src/main/java/com/zhiwei/manage/bean/Data.java

@@ -9,6 +9,7 @@ import org.springframework.data.mongodb.core.mapping.Document;
 import org.springframework.stereotype.Component;
 
 @Component
+@Document(collection="Data")
 public class Data implements Serializable{
 
 	@Id

src/main/java/com/zhiwei/manage/dao/DataDaoImpl.java

@@ -81,7 +81,7 @@ public class DataDaoImpl implements DataDao {
 	@Override
 	public void insert(Data data) {
 		Data d = null;
-		if (data != null) {
+		if (data.getTempName() != null) {
 			d = mongo.findOne(Query.query(Criteria.where("time").is(data.getTime())
 					.andOperator(Criteria.where("tempName").is(data.getTempName()))), Data.class);
 		} else {

src/main/java/com/zhiwei/manage/handle/MainThread.java

@@ -171,19 +171,6 @@ public class MainThread extends Thread {
 				int count = 0;
 				List<Channel> channel = serverService.findDisChannel();
 				for (Channel chan : channel) {
-					// if(chan.getPt().equals("微信全量")){
-					// try {
-					// Data data = new Data();
-					// data.setCount(632514);
-					// data.setPt(chan.getPt());
-					// data.setTime(d);
-					// dataService.insert(data);
-					// log.info(TimeUtil.yearToDay(start.getTime()) + "|" + chan.getPt() + "|入库");
-					// } catch (Exception e) {
-					// log.error(chan.getPt() + "入库出错，错误信息{}", e);
-					// }
-					// continue;
-					// }
 					try {
 						count = (int) dataService.finCountByDayData(start.getTime(), end.getTime(), chan.getPt());
 						Data data = new Data();