|
@@ -109,13 +109,11 @@ func (l *MsgDistributorLogic) MsgDistributor(in *bxsubscribe.MsgDistributorReq)
|
|
|
for _, staff := range staffs {
|
|
|
//today
|
|
|
redis.Del("pushcache_2_b", fmt.Sprintf("entnichepush_%s", staff))
|
|
|
-
|
|
|
//all
|
|
|
redis.Del("pushcache_2_a", fmt.Sprintf("all_entnichepush_%s", staff))
|
|
|
redis.Del("pushcache_2_a", fmt.Sprintf("all_entnichepush_vip_%s", staff))
|
|
|
redis.Del("pushcache_2_a", fmt.Sprintf("all_entnichepush_member_%s", staff))
|
|
|
}
|
|
|
-
|
|
|
if !ok {
|
|
|
return &bxsubscribe.StatusResp{ErrorCode: -1, ErrorMsg: "数据分发异常"}, nil
|
|
|
}
|