单独跑任务

app/dao/supplier.go

@@ -2,12 +2,13 @@ package dao
 
 
 import (
 import (
 	"fmt"
 	"fmt"
-	"github.com/ichunt2019/cfg/lib"
-	"github.com/imroc/req"
-	"github.com/tidwall/gjson"
 	"go_supplier_sever/app/model"
 	"go_supplier_sever/app/model"
 	"strconv"
 	"strconv"
 	"time"
 	"time"
+
+	"github.com/ichunt2019/cfg/lib"
+	"github.com/imroc/req"
+	"github.com/tidwall/gjson"
 )
 )
 
 
 func StatisticsSuppliersSkuNum() (err error) {
 func StatisticsSuppliersSkuNum() (err error) {
@@ -48,6 +49,7 @@ func StatisticsSuppliersSkuNum() (err error) {
 
 
 //统计供应商是否上传过sku
 //统计供应商是否上传过sku
 func StatisticsSuppliersHasUploadedSku() (err error) {
 func StatisticsSuppliersHasUploadedSku() (err error) {
+	fmt.Println("开始统计历史上传SKU")
 	supplier := new(model.Supplier)
 	supplier := new(model.Supplier)
 	//先去根据供应商内部编码找出对应的supplierId
 	//先去根据供应商内部编码找出对应的supplierId
 	rows, err := Dao.GetDb("supplier").Table("lie_supplier_channel").Where("is_type = ?", 0).OrderBy("supplier_id desc").Rows(supplier)
 	rows, err := Dao.GetDb("supplier").Table("lie_supplier_channel").Where("is_type = ?", 0).OrderBy("supplier_id desc").Rows(supplier)

app/service/supplier_sku_statistics.go

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