aa

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
 }