订单新消息修改

This commit is contained in:
苏尹岚
2020-05-25 10:32:57 +08:00
parent 509ade1871
commit 4b53553a10

View File

@@ -1498,7 +1498,7 @@ func addSku(outSkuId string, cagtegoryId int, shopCategories []int64, brandId in
}
func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// db := dao.GetDB()
db := dao.GetDB()
// result1, _ := api.JdShopAPI.GetProvince()
// for _, v := range result1 {
// place1, _ := dao.GetPlaceByName(db, v.AreaName, 1, 0)
@@ -1583,18 +1583,31 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// }
// }
// var stores []*model.StoreMap
// sql := `
// SELECT a.*
// FROM store_map a, store b
// WHERE a.store_id = b.id
// AND a.vendor_store_id = '' AND a.vendor_id = 5 AND a.deleted_at = ?
// AND b.deleted_at = ?
// `
// sqlParams := []interface{}{utils.DefaultTimeValue, utils.DefaultTimeValue}
// err = dao.GetRows(db, &stores, sql, sqlParams)
// for _, v := range stores {
// api.JdShopAPI.GetCity(parentID)
// }
var stores []*model.StoreMap
sql := `
SELECT a.*
FROM store_map a, store b
WHERE a.store_id = b.id
AND a.vendor_store_id = '' AND a.vendor_id = 5 AND a.deleted_at = ?
AND b.deleted_at = ?
`
sqlParams := []interface{}{utils.DefaultTimeValue, utils.DefaultTimeValue}
err = dao.GetRows(db, &stores, sql, sqlParams)
result1, _ := api.JdShopAPI.GetProvince()
for _, v := range stores {
for _, vv := range result1 {
result2, _ := api.JdShopAPI.GetCity(vv.AreaID)
for _, vvv := range result2 {
result3, _ := api.JdShopAPI.GetCounty(vvv.AreaID)
for _, vvvv := range result3 {
if vvvv.AreaName == v.JdsStreetName {
v.JdsStreetCode = vvvv.AreaID
dao.UpdateEntity(db, v, "JdsStreetCode")
}
break
}
}
}
}
return err
}