|
@@ -851,11 +851,11 @@ func (s *subscribePush) listManager(spqp *SubPushQueryParam, list []map[string]i
|
|
|
id := int64(0)
|
|
id := int64(0)
|
|
|
switch s.ModuleFlag {
|
|
switch s.ModuleFlag {
|
|
|
case "eType":
|
|
case "eType":
|
|
|
- id, _ = spqp.BaseServiceMysql.InsertIgnoreBatch(aboutDbMsg[s.ModuleFlag].MysqlTable, ennicheInsertCollKey, pushInsert)
|
|
|
|
|
|
|
+ _, id = spqp.BaseServiceMysql.InsertIgnoreBatch(aboutDbMsg[s.ModuleFlag].MysqlTable, ennicheInsertCollKey, pushInsert)
|
|
|
case "mType":
|
|
case "mType":
|
|
|
- id, _ = spqp.BaseServiceMysql.InsertIgnoreBatch(aboutDbMsg[s.ModuleFlag].MysqlTable, memberInsertCollKey, pushInsert)
|
|
|
|
|
|
|
+ _, id = spqp.BaseServiceMysql.InsertIgnoreBatch(aboutDbMsg[s.ModuleFlag].MysqlTable, memberInsertCollKey, pushInsert)
|
|
|
default:
|
|
default:
|
|
|
- id, _ = spqp.BaseServiceMysql.InsertIgnoreBatch(aboutDbMsg[s.ModuleFlag].MysqlTable, subscribeInsertCollKey, pushInsert)
|
|
|
|
|
|
|
+ _, id = spqp.BaseServiceMysql.InsertIgnoreBatch(aboutDbMsg[s.ModuleFlag].MysqlTable, subscribeInsertCollKey, pushInsert)
|
|
|
}
|
|
}
|
|
|
for i := 0; i < len(resultList); i++ {
|
|
for i := 0; i < len(resultList); i++ {
|
|
|
resultList[i].Index = id
|
|
resultList[i].Index = id
|
