From 20db1887e9523d0a8a6fa80be73ee49852afdeb8 Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Wed, 13 Oct 2021 09:40:18 +0800
Subject: [PATCH] aa

---
 business/jxstore/cms/store_sku.go |  2 --
 business/jxstore/tempop/tempop.go | 41 ++++++++++++++++++++-----------
 2 files changed, 26 insertions(+), 17 deletions(-)

diff --git a/business/jxstore/cms/store_sku.go b/business/jxstore/cms/store_sku.go
index 1cacd3272..db1da3e2f 100644
--- a/business/jxstore/cms/store_sku.go
+++ b/business/jxstore/cms/store_sku.go
@@ -862,8 +862,6 @@ func GetStoresSkusNew(ctx *jxcontext.Context, storeIDs, skuIDs []int, upcs []str
 	}
 	var tmpList []*tGetStoresSkusInfo
 	beginTime := time.Now()
-	fmt.Println(sql)
-	fmt.Println(sqlParams)
 	if err = dao.GetRowsTx(txDB, &tmpList, sql, sqlParams...); err != nil {
 		dao.Rollback(db, txDB)
 		return nil, err
diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go
index 6c8a7e60d..da1d5c4aa 100644
--- a/business/jxstore/tempop/tempop.go
+++ b/business/jxstore/tempop/tempop.go
@@ -4,7 +4,6 @@ import (
 	"bytes"
 	"context"
 	"fmt"
-	"git.rosy.net.cn/jx-callback/business/jxstore/act"
 	"net"
 	"regexp"
 	"strconv"
@@ -1973,20 +1972,32 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	//		}
 	//	}
 	//}
-	//for i := 1; i < 3; i++ {
-	//	server := "print.jxcs.net:8000"
-	//	tcpAddr, err := net.ResolveTCPAddr("tcp4", server)
-	//	if err != nil {
-	//		os.Exit(1)
-	//		return err
-	//	}
-	//	conn, err := net.DialTCP("tcp", nil, tcpAddr)
-	//	if err != nil {
-	//		return err
-	//	}
-	//	go connHandler(conn, "1e000f02000151323032313036313530303030313"+utils.Int2Str(i)+"00000033")
-	//}
-	act.RrefreshMtwmVendorAct(jxcontext.AdminCtx)
+	//act.RrefreshMtwmVendorAct(jxcontext.AdminCtx)
+	var (
+		db       = dao.GetDB()
+		skuNames []*model.SkuName
+	)
+	sql := `
+		SELECT * FROM sku_name WHERE upc <> ''
+	`
+	dao.GetRows(db, &skuNames, sql)
+	task := tasksch.NewParallelTask("aaa", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
+		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
+			skuName := batchItemList[0].(*model.SkuName)
+			if data, _, err := jxutils.DownloadFileByURL(skuName.Img); err != nil || data == nil {
+				skuList, _ := dao.GetSkus(db, nil, []int{skuName.ID}, nil, nil, nil)
+				orderSku := &model.OrderSku{}
+				sql := `
+					SELECT * FROM order_sku WHERE order_created_at > '2021-09-13' AND sku_id = ?
+				`
+				sqlParams := []int{skuList[0].ID}
+				if err = dao.GetRow(db, &orderSku, sql, sqlParams); err == nil && orderSku == nil {
+					fmt.Println("exeNoImg, sku_id : ", skuList[0].ID)
+				}
+			}
+			return retVal, err
+		}, skuNames)
+	task.GetResult(0)
 	return err
 }