打印

special/activity_statistics/main.go

@@ -91,6 +91,7 @@ func main() {
 	err = specialDb.Reset().Table(&giftActivityList).Fields("id,start_time,end_time").Where("status", "!=", -1).
 	err = specialDb.Reset().Table(&giftActivityList).Fields("id,start_time,end_time").Where("status", "!=", -1).
 		Where("end_time", ">", updateTime).Select()
 		Where("end_time", ">", updateTime).Select()
 	if err != nil {
 	if err != nil {
+		fmt.Println(err.Error())
 		logger.Error(err.Error())
 		logger.Error(err.Error())
 	}
 	}
 	fmt.Println(len(giftActivityList))
 	fmt.Println(len(giftActivityList))
@@ -127,6 +128,7 @@ func main() {
 		var orderGifts []model.OrderGift
 		var orderGifts []model.OrderGift
 		err = db.Reset().Table(&orderGifts).Where("activity_id", activity.Id).Where("status", "!=", -1).Select()
 		err = db.Reset().Table(&orderGifts).Where("activity_id", activity.Id).Where("status", "!=", -1).Select()
 		if err != nil {
 		if err != nil {
+			fmt.Println(err.Error())
 			logger.Error(err.Error())
 			logger.Error(err.Error())
 		}
 		}
 		for _, orderGif := range orderGifts {
 		for _, orderGif := range orderGifts {
@@ -167,6 +169,7 @@ func main() {
 				}
 				}
 				err = mongoConn.DB("ichunt").C("gift_activity_detail").Insert(&data)
 				err = mongoConn.DB("ichunt").C("gift_activity_detail").Insert(&data)
 				if err != nil {
 				if err != nil {
+					fmt.Println(err.Error())
 					logger.Error(err.Error())
 					logger.Error(err.Error())
 				}
 				}
 			}
 			}
@@ -178,6 +181,7 @@ func main() {
 	err = specialDb.Reset().Table(&priceActivityList).Fields("id,start_time,end_time").Where("status", "!=", -1).
 	err = specialDb.Reset().Table(&priceActivityList).Fields("id,start_time,end_time").Where("status", "!=", -1).
 		Where("end_time", ">", updateTime).Select()
 		Where("end_time", ">", updateTime).Select()
 	if err != nil {
 	if err != nil {
+		fmt.Println(err.Error())
 		logger.Error(err.Error())
 		logger.Error(err.Error())
 	}
 	}
 	for _, activity := range priceActivityList {
 	for _, activity := range priceActivityList {
@@ -197,12 +201,14 @@ func main() {
 		if count > 0 {
 		if count > 0 {
 			_, err = specialDb.Reset().Table("lie_activity_statistics").Where("activity_id", activity.Id).Data(data).Update()
 			_, err = specialDb.Reset().Table("lie_activity_statistics").Where("activity_id", activity.Id).Data(data).Update()
 			if err != nil {
 			if err != nil {
+				fmt.Println(err.Error())
 				logger.Error(err.Error())
 				logger.Error(err.Error())
 			}
 			}
 		} else {
 		} else {
 			data["create_time"] = time.Now().Unix()
 			data["create_time"] = time.Now().Unix()
 			_, err = specialDb.Reset().Table("lie_activity_statistics").Data(data).Insert()
 			_, err = specialDb.Reset().Table("lie_activity_statistics").Data(data).Insert()
 			if err != nil {
 			if err != nil {
+				fmt.Println(err.Error())
 				logger.Error(err.Error())
 				logger.Error(err.Error())
 			}
 			}
 		}
 		}
@@ -225,6 +231,7 @@ func main() {
 				Find(bson.M{"order_id": gjson.Get(result, "order_id").Int(), "activity_id": gjson.Get(result, "activity_id").Int()}).
 				Find(bson.M{"order_id": gjson.Get(result, "order_id").Int(), "activity_id": gjson.Get(result, "activity_id").Int()}).
 				One(&priceActivityMongo)
 				One(&priceActivityMongo)
 			if err != nil && err != mgo.ErrNotFound {
 			if err != nil && err != mgo.ErrNotFound {
+				fmt.Println(err.Error())
 				logger.Error(err.Error())
 				logger.Error(err.Error())
 			}
 			}
 			//存在跳过,不存在才插入
 			//存在跳过,不存在才插入
@@ -237,6 +244,7 @@ func main() {
 				priceActivityMongo.Pf = gjson.Get(result, "create_device").Int()
 				priceActivityMongo.Pf = gjson.Get(result, "create_device").Int()
 				err = mongoConn.DB("ichunt").C("price_activity_statistics").Insert(&priceActivityMongo)
 				err = mongoConn.DB("ichunt").C("price_activity_statistics").Insert(&priceActivityMongo)
 				if err != nil {
 				if err != nil {
+					fmt.Println(err.Error())
 					logger.Error(err.Error())
 					logger.Error(err.Error())
 				}
 				}
 			}
 			}