diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index f4577ff35..7f321c99d 100644 --- a/business/jxstore/tempop/tempop.go +++ b/business/jxstore/tempop/tempop.go @@ -5,7 +5,6 @@ import ( "context" "fmt" "net" - "os" "regexp" "strings" "time" @@ -1946,21 +1945,22 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) { //` //weixinmsg.SmartMessageTemplateSend("oYN_usv1RPvrSxCvo1WsbwI8lZa0", weixinmsg.WX_NEWORDER_TEMPLATE_ID, "", weixinmsg.WX_MINI_TO_ORDER_PAGE_URL+fmt.Sprintf("?jxStoreId=%v&data=%v", storeID, data), nil) - server := "print.jxcs.net:8000" - tcpAddr, err := net.ResolveTCPAddr("tcp4", server) - if err != nil { - fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error()) - os.Exit(1) + var ( + db = dao.GetDB() + stores []*model.Store + ) + sql := ` + SELECT a.* + FROM store a + JOIN store_map b ON a.id =b.store_id AND b.deleted_at = '1970-01-01 00:00:00' AND b.vendor_id = 0 + WHERE a.pay_percentage > 50 + AND b.is_sync = 1 AND b.sync_status <> 0 AND price_percentage_pack = '京东一比一测试门店' + AND a.deleted_at = '1970-01-01 00:00:00' AND a.status <> -2 +` + dao.GetRows(db, &stores, sql) + for _, v := range stores { + cms.CurVendorSync.FullSyncStoresSkus(jxcontext.AdminCtx, db, []int{0}, []int{v.ID}, true, nil, true, true) } - fmt.Println("tcpaddr", utils.Format4Output(tcpAddr, true)) - conn, err := net.DialTCP("tcp", nil, tcpAddr) - if err != nil { - fmt.Println("Dial err:", err) - return - } - textChan = make(chan string, 10) - textChan <- "test" - connHandler(conn) return err }