|
@@ -742,27 +742,29 @@ func (s *subscribePush) SetRead(newUserId, id int64, userId, entUserId, entId st
|
|
|
IC.BaseServiceMysql.UpdateOrDeleteBySql(fmt.Sprintf("update %s set isvisit=1 where userid=? and id=?", aboutDbMsg[s.ModuleFlag].MysqlTable), newUserId, id)
|
|
|
}
|
|
|
}
|
|
|
- todaySubPush, err := s.GetTodayCache(userId)
|
|
|
- //当天数据处理
|
|
|
- if err == nil && todaySubPush != nil {
|
|
|
- for _, v := range todaySubPush.Datas {
|
|
|
- if v.CaIndex == id {
|
|
|
- v.CaIsvisit = 1
|
|
|
- break
|
|
|
+ if !isEnt {
|
|
|
+ todaySubPush, err := s.GetTodayCache(userId)
|
|
|
+ //当天数据处理
|
|
|
+ if err == nil && todaySubPush != nil {
|
|
|
+ for _, v := range todaySubPush.Datas {
|
|
|
+ if v.CaIndex == id {
|
|
|
+ v.CaIsvisit = 1
|
|
|
+ break
|
|
|
+ }
|
|
|
}
|
|
|
- }
|
|
|
- s.PutTodayCache(userId, todaySubPush)
|
|
|
- }
|
|
|
- //全部数据处理
|
|
|
- allSubPush, err := s.GetAllCache(userId)
|
|
|
- if err == nil && allSubPush != nil {
|
|
|
- for _, v := range allSubPush.Datas {
|
|
|
- if v.CaIndex == id {
|
|
|
- v.CaIsvisit = 1
|
|
|
- break
|
|
|
+ s.PutTodayCache(userId, todaySubPush)
|
|
|
+ }
|
|
|
+ //全部数据处理
|
|
|
+ allSubPush, err := s.GetAllCache(userId)
|
|
|
+ if err == nil && allSubPush != nil {
|
|
|
+ for _, v := range allSubPush.Datas {
|
|
|
+ if v.CaIndex == id {
|
|
|
+ v.CaIsvisit = 1
|
|
|
+ break
|
|
|
+ }
|
|
|
}
|
|
|
+ s.PutAllCache(userId, allSubPush)
|
|
|
}
|
|
|
- s.PutAllCache(userId, allSubPush)
|
|
|
}
|
|
|
return nil
|
|
|
}
|