|
@@ -1208,7 +1208,7 @@ func SocializeSummaryAddOrUpdate(tx *sql.Tx, groupId, myPositionId, yourPosition
|
|
|
ok_my := true
|
|
|
ok_your := true
|
|
|
//发送方
|
|
|
- if r := IC.BaseMysql.SelectBySql(fmt.Sprintf(`select id,unread from %s where my_position_id =? and your_position_id =? limit 1`, util.SOCIALIZE_SUMMARY), yourPositionId, myPositionId); r != nil && len(*r) > 0 { //存在更新
|
|
|
+ if r := IC.BaseMysql.SelectBySql(fmt.Sprintf(`select id,unread from %s where my_position_id =? and your_position_id =? limit 1`, util.SOCIALIZE_SUMMARY), myPositionId, yourPositionId); r != nil && len(*r) > 0 { //存在更新
|
|
|
updateMap := map[string]interface{}{
|
|
|
"message_id": messageId,
|
|
|
"timestamp": timestamp,
|