2 changed files with 8 additions and 8 deletions
Unified View
Diff Options
+ 5
- 5
consume/init.go
View File
| @@ -73,10 +73,10 @@ func initConsumes() { | |||||
| //jobs[consumeMd.MallAddSupplyGoodsFunName] = MallAddSupplyGoodsConsume | //jobs[consumeMd.MallAddSupplyGoodsFunName] = MallAddSupplyGoodsConsume | ||||
| //////////////////////////////////////// bigData ///////////////////////////////////////////////////// | //////////////////////////////////////// bigData ///////////////////////////////////////////////////// | ||||
| //jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume | |||||
| //jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume | |||||
| //jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume | |||||
| //jobs[consumeMd.CanalUserVirtualCcoinFlowFunName] = CanalUserVirtualCoinFlowConsume | |||||
| jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume | |||||
| jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume | |||||
| jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume | |||||
| jobs[consumeMd.CanalUserVirtualCcoinFlowFunName] = CanalUserVirtualCoinFlowConsume | |||||
| //////////////////////////////////////// oneCircles ///////////////////////////////////////////////////// | //////////////////////////////////////// oneCircles ///////////////////////////////////////////////////// | ||||
| @@ -95,7 +95,7 @@ func initConsumes() { | |||||
| //jobs[consumeMd.ZhiosMallGreenCoinConsumeFunName] = ZhiosMallGreenCoinConsume //绿色双链积分 | //jobs[consumeMd.ZhiosMallGreenCoinConsumeFunName] = ZhiosMallGreenCoinConsume //绿色双链积分 | ||||
| //jobs[consumeMd.ZhiosOneCirclesCoinConsumeFunName] = ZhiosOneCirclesCoinConsume //一个圈圈虚拟币变化 | //jobs[consumeMd.ZhiosOneCirclesCoinConsumeFunName] = ZhiosOneCirclesCoinConsume //一个圈圈虚拟币变化 | ||||
| jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款 | |||||
| //jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款 | |||||
| } | } | ||||
+ 3
- 3
consume/zhios_user_visit_ip_address_consume.go
View File
| @@ -88,7 +88,7 @@ func handleUserVisitIpAddress(msg []byte, geoIp2db *geoip2.DBReader) 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) | //get, _ := cache.HGetString(cacheKey, msgStruct.Ip) | ||||
| //if get == "" { | //if get == "" { | ||||
| if true { | if true { | ||||
| @@ -119,8 +119,8 @@ func handleUserVisitIpAddress(msg []byte, geoIp2db *geoip2.DBReader) error { | |||||
| //db.MasterAreaVisitsFlowsInsert(db.DataDb, ) | //db.MasterAreaVisitsFlowsInsert(db.DataDb, ) | ||||
| } | } | ||||
| //4、加入到缓存map中 | //4、加入到缓存map中 | ||||
| cache.HSet(cacheKey, msgStruct.Ip, msgStruct.MasterId) | |||||
| cache.Expire(cacheKey, md.ZhiOsUserVisitIpAddressHashMapCacheTime) | |||||
| //cache.HSet(cacheKey, msgStruct.Ip, msgStruct.MasterId) | |||||
| //cache.Expire(cacheKey, md.ZhiOsUserVisitIpAddressHashMapCacheTime) | |||||
| } | } | ||||
| return nil | return nil | ||||
| } | } | ||||