diff --git a/business/jxstore/tempop/tempop.go b/business/jxstore/tempop/tempop.go index bf291f42a..77f0caba1 100644 --- a/business/jxstore/tempop/tempop.go +++ b/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 }