diff --git a/business/jxstore/cms/store.go b/business/jxstore/cms/store.go index 64633514d..9562e34e2 100644 --- a/business/jxstore/cms/store.go +++ b/business/jxstore/cms/store.go @@ -13,6 +13,8 @@ import ( "git.rosy.net.cn/jx-callback/business/auth2" "git.rosy.net.cn/jx-callback/business/authz" + "git.rosy.net.cn/baseapi/platformapi/autonavi" + "git.rosy.net.cn/baseapi/platformapi/baidunavi" "git.rosy.net.cn/baseapi/platformapi/dingdingapi" "git.rosy.net.cn/baseapi/platformapi/jdapi" "git.rosy.net.cn/baseapi/utils" @@ -406,29 +408,29 @@ func GetStores(ctx *jxcontext.Context, keyword string, params map[string]interfa retVal.Stores = retVal.Stores[offset : offset+pageSize] } if needConver2Baidu { - // task := tasksch.NewParallelTask("坐标转换", tasksch.NewParallelConfig().SetParallelCount(4).SetBatchSize(autonavi.MaxConvertCount), ctx, - // func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - // var coords []*autonavi.Coordinate - // for _, v := range batchItemList { - // store := v.(*StoreExt) - // coords = append(coords, &autonavi.Coordinate{ - // Lng: store.FloatLng, - // Lat: store.FloatLat, - // }) - // } - // coords, err = api.AutonaviAPI.BatchCoordinateConvert(coords, autonavi.CoordSysBaidu) - // if err == nil { - // for k, v := range batchItemList { - // store := v.(*StoreExt) - // coord := coords[k] - // store.FloatLng = coord.Lng - // store.FloatLat = coord.Lat - // } - // } - // return retVal, err - // }, retVal.Stores) - // task.Run() - // task.GetResult(0) + task := tasksch.NewParallelTask("坐标转换", tasksch.NewParallelConfig().SetParallelCount(4).SetBatchSize(autonavi.MaxConvertCount), ctx, + func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { + var coords []*baidunavi.Coordinate + for _, v := range batchItemList { + store := v.(*StoreExt) + coords = append(coords, &baidunavi.Coordinate{ + Lng: store.FloatLng, + Lat: store.FloatLat, + }) + } + coords, err = api.BaiDuNaviAPI.BatchCoordinateConvert(coords, baidunavi.CoordSysGCJ02, baidunavi.CoordSysBaiDu) + if err == nil { + for k, v := range batchItemList { + store := v.(*StoreExt) + coord := coords[k] + store.FloatLng = coord.Lng + store.FloatLat = coord.Lat + } + } + return retVal, err + }, retVal.Stores) + task.Run() + task.GetResult(0) } // if mapLimit { // retVal.TotalCount = len(retVal.Stores) diff --git a/business/jxstore/cms/user.go b/business/jxstore/cms/user.go index 79f8f490c..05fb5b8bc 100644 --- a/business/jxstore/cms/user.go +++ b/business/jxstore/cms/user.go @@ -34,7 +34,7 @@ func GetStoreUsers(ctx *jxcontext.Context, storeID int) (storeUserInfos []*dao.S WHERE t1.parentid = -1 AND t1.jxstoreid = ? GROUP BY 1,2,3,4,5,6,7; ` - globals.SugarLogger.Debug(sql) + // globals.SugarLogger.Debug(sql) if err = dao.GetRows(nil, &storeUserInfos, sql, storeID); err == nil { for _, storeUserInfo := range storeUserInfos { if storeUserInfo.MembersStr != "" { @@ -111,7 +111,7 @@ func BindMobile2Store(ctx *jxcontext.Context, mobile string, storeID int) (num i dao.Commit(db) } } else { - globals.SugarLogger.Debug(utils.Format4Output(user, false)) + // globals.SugarLogger.Debug(utils.Format4Output(user, false)) dao.WrapAddIDCULEntity(user, ctx.GetUserName()) user.ParentID = -1 if err = dao.CreateWeiXins(db, user); err == nil { diff --git a/conf/app.conf b/conf/app.conf index 6aa563bcb..c809a05f0 100644 --- a/conf/app.conf +++ b/conf/app.conf @@ -18,6 +18,9 @@ mtwmCallbackURL = "http://callback.jxc4.com" autonaviKey = "4427170f870af2110becb8852d36ab08" +baidunaviAK = "eL94zToVOdGDTkNQxV8dnEQ1ZRcB2UKb" +baidunaviSK = "ZG0OOpOsOVURUwAkkmoHQFKRCbzn0zGb" + disableElm = true disableWeimob = true diff --git a/globals/api/api.go b/globals/api/api.go index dd14840a1..c6e2f761b 100644 --- a/globals/api/api.go +++ b/globals/api/api.go @@ -5,6 +5,7 @@ import ( "git.rosy.net.cn/baseapi/platformapi" "git.rosy.net.cn/baseapi/platformapi/autonavi" + "git.rosy.net.cn/baseapi/platformapi/baidunavi" "git.rosy.net.cn/baseapi/platformapi/dadaapi" "git.rosy.net.cn/baseapi/platformapi/dingdingapi" "git.rosy.net.cn/baseapi/platformapi/ebaiapi" @@ -42,6 +43,7 @@ var ( WeixinPageAPI *weixinapi.API // 用户微信扫码登录 AutonaviAPI *autonavi.API + BaiDuNaviAPI *baidunavi.API QiniuAPI *qbox.Mac ShowAPI *showapi.API WeimobAPI *weimobapi.API @@ -138,6 +140,7 @@ func Init() { WeixinPageAPI = weixinapi.New(beego.AppConfig.String("weixinPageAppID"), beego.AppConfig.String("weixinPageSecret")) AutonaviAPI = autonavi.New(beego.AppConfig.String("autonaviKey")) + BaiDuNaviAPI = baidunavi.New(beego.AppConfig.String("baidunaviAK"), beego.AppConfig.String("baidunaviSK")) QiniuAPI = qbox.NewMac(beego.AppConfig.String("qiniuAK"), beego.AppConfig.String("qiniuSK")) ShowAPI = showapi.New(beego.AppConfig.DefaultInt("showAppID", 0), beego.AppConfig.DefaultString("showAppSecret", "")) Cacher = redis.New(beego.AppConfig.DefaultString("redisHost", "localhost"), beego.AppConfig.DefaultInt("redisPort", 0), beego.AppConfig.DefaultString("redisPassword", ""))