liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
苏尹岚
2021-04-07 14:48:12 +08:00
parent 07a6fd04fd
commit 66a56c2a61
2 changed files with 56 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

96
business/jxstore/tempop/tempop.go
View File

@@ -1839,60 +1839,60 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
// }, storeMaps) // }, storeMaps)
// tasksch.HandleTask(task, nil, true).Run() // tasksch.HandleTask(task, nil, true).Run()
// task.GetID() // task.GetID()
//删除京东会员价 //删京东会员价
// var (
// db = dao.GetDB()
// vendorThingIDs []int64
// )
// storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406")
// things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"})
// thingIDmap := make(map[int64]string)
// for _, v := range things {
// if v.VendorThingID != "" {
// vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID))
// thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID)
// }
// }
// task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
// func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// storeMap := batchItemList[0].(*model.StoreMap)
// FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) {
// api := jd.GetAPI("320406")
// priceInfo, _ := api.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
// var list []*jdapi.SkuIdEntity
// for _, vv := range priceInfo {
// if vv.VipPrice != 0 {
// list = append(list, &jdapi.SkuIdEntity{
// OutSkuId: thingIDmap[vv.SkuID],
// })
// }
// }
// if len(list) > 0 {
// err = api.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
// }
// return result, 0, err
// }, ctx, task, vendorThingIDs, 50, true)
// return retVal, err
// }, storeMaps)
// tasksch.HandleTask(task, nil, true).Run()
// _, err = task.GetResult(0)
//京东账号更新
var ( var (
db = dao.GetDB() db = dao.GetDB()
vendorThingIDs []int64
) )
if configs, err := dao.QueryConfigs(dao.GetDB(), "jdConfigCookie", model.ConfigTypeCookie, ""); err == nil { storeMaps, _ := dao.GetStoresMapList(db, []int{model.VendorIDJD}, nil, nil, model.StoreStatusAll, model.StoreIsSyncAll, "", "", "320406")
api.JdAPI.SetCookieWithStr(configs[0].Value) things, _ := dao.GetThingMapList(db, model.ThingTypeSku, []int{model.VendorIDJD}, nil, []string{"320406"})
result, _ := api.JdAPI.GetJdAppInfo() thingIDmap := make(map[int64]string)
if result != nil {
if vocs, _ := dao.GetVendorOrgCode(db, model.VendorIDJD, result.OrgCode, model.VendorOrgTypePlatform); len(vocs) > 0 { for _, v := range things {
vocs[0].AppKey = result.AppKey if v.VendorThingID != "" {
vocs[0].AppSecret = result.AppSecret vendorThingIDs = append(vendorThingIDs, utils.Str2Int64(v.VendorThingID))
dao.UpdateEntity(db, vocs[0], "AppKey", "AppSecret") thingIDmap[utils.Str2Int64(v.VendorThingID)] = utils.Int64ToStr(v.ThingID)
} }
} }
task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeMap := batchItemList[0].(*model.StoreMap)
FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) {
api := jd.GetAPI("320406")
priceInfo, _ := api.GetStationInfoList(storeMap.VendorStoreID, batchedStoreSkuList)
var list []*jdapi.SkuIdEntity
for _, vv := range priceInfo {
if vv.VipPrice != 0 {
list = append(list, &jdapi.SkuIdEntity{
OutSkuId: thingIDmap[vv.SkuID],
})
} }
}
if len(list) > 0 {
err = api.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
}
return result, 0, err
}, ctx, task, vendorThingIDs, 50, true)
return retVal, err
}, storeMaps)
tasksch.HandleTask(task, nil, true).Run()
_, err = task.GetResult(0)
//京东账号更新
// var (
// db = dao.GetDB()
// )
// if configs, err := dao.QueryConfigs(dao.GetDB(), "jdConfigCookie", model.ConfigTypeCookie, ""); err == nil {
// api.JdAPI.SetCookieWithStr(configs[0].Value)
// result, _ := api.JdAPI.GetJdAppInfo()
// if result != nil {
// if vocs, _ := dao.GetVendorOrgCode(db, model.VendorIDJD, result.OrgCode, model.VendorOrgTypePlatform); len(vocs) > 0 {
// vocs[0].AppKey = result.AppKey
// vocs[0].AppSecret = result.AppSecret
// dao.UpdateEntity(db, vocs[0], "AppKey", "AppSecret")
// }
// }
// }
// var ( // var (
// db = dao.GetDB() // db = dao.GetDB()
// users []*model.User // users []*model.User

7
business/partner/purchase/jd/jd.go
View File

@@ -162,7 +162,12 @@ func OnTokenChange(values url.Values) {
if err := dao.GetRow(db, &voc, sql, sqlParams); err == nil && voc != nil { if err := dao.GetRow(db, &voc, sql, sqlParams); err == nil && voc != nil {
if result, _ := dao.GetVendorOrgCode(db, model.VendorIDJD, voc.VendorOrgCode, model.VendorOrgTypePlatform); len(result) > 0 { if result, _ := dao.GetVendorOrgCode(db, model.VendorIDJD, voc.VendorOrgCode, model.VendorOrgTypePlatform); len(result) > 0 {
result[0].Token = tokenInfo.Token result[0].Token = tokenInfo.Token
dao.UpdateEntity(db, result[0], "Token") if _, err = dao.UpdateEntity(db, result[0], "Token"); err == nil {
result2, _ := api.JdAPI.GetJdAppInfo()
result[0].AppKey = result2.AppKey
result[0].AppSecret = result2.AppSecret
dao.UpdateEntity(db, result[0], "AppKey", "AppSecret")
}
} else { } else {
globals.SugarLogger.Debugf("OnTokenChange， 发token，但是库里没这个账号") globals.SugarLogger.Debugf("OnTokenChange， 发token，但是库里没这个账号")
} }