单纯跑历史统计

app/service/supplier_sku_statistics.go

@@ -8,10 +8,10 @@ import (
 func StatisticsSupplierSkuStatus() (err error) {
 func StatisticsSupplierSkuStatus() (err error) {
 	fmt.Println("开始统计")
 	fmt.Println("开始统计")
 	//先找出所有需要判断的供应商
 	//先找出所有需要判断的供应商
-	err = dao.StatisticsSuppliersSkuNum()
-	if err != nil {
-		return err
-	}
+	// err = dao.StatisticsSuppliersSkuNum()
+	// if err != nil {
+	// 	return err
+	// }
 
 
 	err = dao.StatisticsSuppliersHasUploadedSku()
 	err = dao.StatisticsSuppliersHasUploadedSku()
 	return err
 	return err

cmd/statistics/sku_num.go

@@ -3,8 +3,7 @@ package main
 import (
 import (
 	"flag"
 	"flag"
 	"fmt"
 	"fmt"
-
-	// "go_supplier_sever/app/service"
+	"go_supplier_sever/app/service"
 	"go_supplier_sever/boot"
 	"go_supplier_sever/boot"
 )
 )
 
 
@@ -17,11 +16,11 @@ func main() {
 	flag.StringVar(&configPath, "config", "./config/dev/", "配置文件")
 	flag.StringVar(&configPath, "config", "./config/dev/", "配置文件")
 	flag.StringVar(&logPath, "logdir", "./logs/", "日志文件存储目录")
 	flag.StringVar(&logPath, "logdir", "./logs/", "日志文件存储目录")
 	flag.Parse()
 	flag.Parse()
-	fmt.Println("测试代码")
+
 	boot.Init(configPath, logPath)
 	boot.Init(configPath, logPath)
-	// //统计供应商sku相关情况
-	// err := service.StatisticsSupplierSkuStatus()
-	// if err != nil {
-	// 	fmt.Println(err)
-	// }
+	//统计供应商sku相关情况
+	err := service.StatisticsSupplierSkuStatus()
+	if err != nil {
+		fmt.Println(err)
+	}
 }
 }