|
@@ -65,8 +65,9 @@ func handleUserVisitIpAddress(msg []byte) error { |
|
|
|
|
|
|
|
|
//1、判断ip是否已统计 |
|
|
//1、判断ip是否已统计 |
|
|
cacheKey := fmt.Sprintf(md.ZhiOsUserVisitIpAddressHashMapCacheKey, msgStruct.MasterId, today) |
|
|
cacheKey := fmt.Sprintf(md.ZhiOsUserVisitIpAddressHashMapCacheKey, msgStruct.MasterId, today) |
|
|
get, _ := cache.HGetString(cacheKey, msgStruct.Ip) |
|
|
|
|
|
if get == "" { |
|
|
|
|
|
|
|
|
//get, _ := cache.HGetString(cacheKey, msgStruct.Ip) |
|
|
|
|
|
//if get == "" { |
|
|
|
|
|
if true { |
|
|
//2、分析ip归属地 |
|
|
//2、分析ip归属地 |
|
|
countryName, provinceId, cityId, provinceName, cityName := getIpAddress(db.DBs[msgStruct.MasterId], msgStruct) |
|
|
countryName, provinceId, cityId, provinceName, cityName := getIpAddress(db.DBs[msgStruct.MasterId], msgStruct) |
|
|
if provinceId != "" || cityId != "" || countryName != "" || provinceName != "" || cityName != "" { |
|
|
if provinceId != "" || cityId != "" || countryName != "" || provinceName != "" || cityName != "" { |
|
|