|
@@ -67,7 +67,7 @@ func (l *MsgDistributorLogic) MsgDistributor(in *bxsubscribe.MsgDistributorReq)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
//查询分发信息内容
|
|
//查询分发信息内容
|
|
- msgRes := IC.BaseServiceMysql.SelectBySql("SELECT p.* FROM pushentniche p,(SELECT infoid,MIN(id) as id FROM pushentniche WHERE infoid in ('5f4f603fc01454407374b7d2','5f4f1860c014544073748bbe') GROUP BY infoid) b WHERE p.id=b.id", strings.Join(infoIds, "','"))
|
|
|
|
|
|
+ msgRes := IC.BaseServiceMysql.SelectBySql("SELECT p.* FROM pushentniche p,(SELECT infoid,MIN(id) as id FROM pushentniche WHERE infoid in ('?') GROUP BY infoid) b WHERE p.id=b.id", strings.Join(infoIds, "','"))
|
|
if msgRes == nil || len(*msgRes) == 0 {
|
|
if msgRes == nil || len(*msgRes) == 0 {
|
|
return &bxsubscribe.StatusResp{ErrorCode: -1, ErrorMsg: "获取分发信息内容异常"}, nil
|
|
return &bxsubscribe.StatusResp{ErrorCode: -1, ErrorMsg: "获取分发信息内容异常"}, nil
|
|
}
|
|
}
|