aa

business/jxstore/tempop/tempop.go

@@ -1865,25 +1865,22 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
 	// 	}, storeMaps)
 	// tasksch.HandleTask(task, nil, true).Run()
 	// _, err = task.GetResult(0)
-	var (
-		storeMaps []*model.StoreMap
-		db        = dao.GetDB()
-		stores    []int
-	)
-	sql := `
-		SELECT * FROM store_map WHERE deleted_at = ? AND vendor_org_code = ? AND vendor_id = ? 
-	`
-	sqlParams := []interface{}{
-		utils.DefaultTimeValue, "2", model.VendorIDJDShop,
-	}
-	dao.GetRows(db, &storeMaps, sql, sqlParams)
-	for _, v := range storeMaps {
-		err = api.JdShop2API.CreateGisFence(utils.Str2Int(v.VendorStoreID), "1")
-		if err != nil {
-			stores = append(stores, v.StoreID)
+	stores := []int{}
+	for i := 1; i < 26; i++ {
+		result, _ := api.JdShop2API.ShopList(i)
+		for _, v := range result.List {
+			if v.Kilometres == "" {
+				if err = api.JdShop2API.CreateGisFence(v.StoreID, "1"); err != nil {
+					if err2 := api.JdShop2API.CreateGisFence(utils.Str2Int(err.Error()), "1"); err2 == nil {
+						if err3 := api.JdShop2API.CreateGisFence(v.StoreID, "1"); err3 != nil {
+							stores = append(stores, v.StoreID)
+						}
+					}
+				}
+			}
 		}
 	}
-	fmt.Println("resultstores55", stores)
+	fmt.Println("resultstores112", stores)
 	return err
 }