diff --git a/consume/init.go b/consume/init.go
index 91c3517..39c2a14 100644
--- a/consume/init.go
+++ b/consume/init.go
@@ -73,10 +73,10 @@ func initConsumes() {
 	//jobs[consumeMd.MallAddSupplyGoodsFunName] = MallAddSupplyGoodsConsume
 
 	//////////////////////////////////////// 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 /////////////////////////////////////////////////////
 
@@ -95,7 +95,7 @@ func initConsumes() {
 	//jobs[consumeMd.ZhiosMallGreenCoinConsumeFunName] = ZhiosMallGreenCoinConsume   //绿色双链积分
 	//jobs[consumeMd.ZhiosOneCirclesCoinConsumeFunName] = ZhiosOneCirclesCoinConsume //一个圈圈虚拟币变化
 
-	jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款
+	//jobs[consumeMd.InstallmentPaymentAutoRepaidConsumeFunName] = InstallmentPaymentAutoRepaidConsume //分期付 - 自动扣款
 
 }
 
diff --git a/consume/zhios_user_visit_ip_address_consume.go b/consume/zhios_user_visit_ip_address_consume.go
index c050907..dadbdd6 100644
--- a/consume/zhios_user_visit_ip_address_consume.go
+++ b/consume/zhios_user_visit_ip_address_consume.go
@@ -88,7 +88,7 @@ func handleUserVisitIpAddress(msg []byte, geoIp2db *geoip2.DBReader) error {
 	}
 
 	//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 == "" {
 	if true {
@@ -119,8 +119,8 @@ func handleUserVisitIpAddress(msg []byte, geoIp2db *geoip2.DBReader) error {
 			//db.MasterAreaVisitsFlowsInsert(db.DataDb, )
 		}
 		//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
 }