liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-10-13 09:40:18 +08:00
parent 9a065f0d92
commit 20db1887e9
2 changed files with 26 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
business/jxstore/cms/store_sku.go
View File

@@ -862,8 +862,6 @@ func GetStoresSkusNew(ctx *jxcontext.Context, storeIDs, skuIDs []int, upcs []str
} }
var tmpList []*tGetStoresSkusInfo var tmpList []*tGetStoresSkusInfo
beginTime := time.Now() beginTime := time.Now()
fmt.Println(sql)
fmt.Println(sqlParams)
if err = dao.GetRowsTx(txDB, &tmpList, sql, sqlParams...); err != nil { if err = dao.GetRowsTx(txDB, &tmpList, sql, sqlParams...); err != nil {
dao.Rollback(db, txDB) dao.Rollback(db, txDB)
return nil, err return nil, err

41
business/jxstore/tempop/tempop.go
View File

@@ -4,7 +4,6 @@ import (
"bytes" "bytes"
"context" "context"
"fmt" "fmt"
"git.rosy.net.cn/jx-callback/business/jxstore/act"
"net" "net"
"regexp" "regexp"
"strconv" "strconv"
@@ -1973,20 +1972,32 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// } // }
// } // }
//} //}
//for i := 1; i < 3; i++ { //act.RrefreshMtwmVendorAct(jxcontext.AdminCtx)
// server := "print.jxcs.net:8000" var (
// tcpAddr, err := net.ResolveTCPAddr("tcp4", server) db = dao.GetDB()
// if err != nil { skuNames []*model.SkuName
// os.Exit(1) )
// return err sql := `
// } SELECT * FROM sku_name WHERE upc <> ''
// conn, err := net.DialTCP("tcp", nil, tcpAddr) `
// if err != nil { dao.GetRows(db, &skuNames, sql)
// return err task := tasksch.NewParallelTask("aaa", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
// } func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// go connHandler(conn, "1e000f02000151323032313036313530303030313"+utils.Int2Str(i)+"00000033") skuName := batchItemList[0].(*model.SkuName)
//} if data, _, err := jxutils.DownloadFileByURL(skuName.Img); err != nil || data == nil {
act.RrefreshMtwmVendorAct(jxcontext.AdminCtx) 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 return err
} }