优化活动统计

special/activity_statistics/main.go

@@ -51,7 +51,7 @@ func initLog() {
 	logger.Init()
 	logger.Init()
 }
 }
 
 
-//初始化数据库
+// 初始化数据库
 func initDB() {
 func initDB() {
 	dsn := util.Configs.Liexin_databases.Dns
 	dsn := util.Configs.Liexin_databases.Dns
 	orderDsn := util.Configs.Liexin_databases.Dns
 	orderDsn := util.Configs.Liexin_databases.Dns
@@ -83,7 +83,7 @@ func OrderDB() gorose.IOrm {
 	return orderEngine.NewOrm()
 	return orderEngine.NewOrm()
 }
 }
 
 
-//有货提醒
+// 有货提醒
 func main() {
 func main() {
 	//先去遍历数据库,全部过一遍
 	//先去遍历数据库,全部过一遍
 	db := DB()
 	db := DB()
@@ -221,7 +221,7 @@ func main() {
 		fmt.Println(err.Error())
 		fmt.Println(err.Error())
 	}
 	}
 	for _, activity := range priceActivityList {
 	for _, activity := range priceActivityList {
-		orderNum, _ := orderDb.Reset().Table("lie_order_activity_count").Where("activity_id", activity.Id).Count("order_id")
+		orderNum, _ := orderDb.Reset().Table("lie_order_activity_count").Where("activity_id", activity.Id).GroupBy("order_id").Count("order_id")
 		//先找出这个活动对应的所有用户(根据user_id)去重
 		//先找出这个活动对应的所有用户(根据user_id)去重
 		orderActivityUserIds, _ := orderDb.Reset().Table("lie_order_activity_count").
 		orderActivityUserIds, _ := orderDb.Reset().Table("lie_order_activity_count").
 			Where("lie_order_activity_count.activity_id", activity.Id).
 			Where("lie_order_activity_count.activity_id", activity.Id).