增加业务参数

This commit is contained in:
zhangqinbin
2021-08-10 08:56:49 +08:00
parent bae2583d4c
commit fa2df9fcf3
4 changed files with 18 additions and 8 deletions

View File

@ -16,6 +16,6 @@ public interface BizMessageMapper extends BaseMapper<BizMessage> {
Boolean updateState(@Param("userId") String userId,@Param("messageId") String messageId); Boolean updateState(@Param("userId") String userId,@Param("messageId") String messageId);
List<BizMessageVo> findMessageVoList(BizMessageVo vo); IPage<BizMessageVo> findMessageVoList(@Param("param") IPage<BizMessageVo> page,BizMessageVo vo);
} }

View File

@ -19,13 +19,13 @@
</select> </select>
<select id="findMessageVo" resultType="com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageVo"> <select id="findMessageVo" resultType="com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageVo">
SELECT biz_message.*,biz_message_template.type as templatetype,'1' as authorizestate,count(a.*) as datanum SELECT biz_message.*,biz_message_template.type as templatetype,'1' as authorizestate
FROM biz_message FROM biz_message
left join biz_message_template on biz_message.templatecode = biz_message_template.code left join biz_message_template on biz_message.templatecode = biz_message_template.code
WHERE authorize = 0 WHERE authorize = 0
<if test="userId!=null and userId!=''"> <if test="userId!=null and userId!=''">
UNION ALL UNION ALL
SELECT a.*,IFNULL(b.state,1) as authorizestate,count(a.*) as datanum SELECT a.*,IFNULL(b.state,1) as authorizestate
FROM ( SELECT biz_message.*,biz_message_template.type as templatetype FROM ( SELECT biz_message.*,biz_message_template.type as templatetype
FROM biz_message FROM biz_message
left join biz_message_template on biz_message.templatecode = biz_message_template.code left join biz_message_template on biz_message.templatecode = biz_message_template.code
@ -47,8 +47,7 @@
SELECT SELECT
biz_message.*, biz_message.*,
biz_message_authorize.state as authorizestate, biz_message_authorize.state as authorizestate,
biz_message_template.type AS templatetype, biz_message_template.type AS templatetype
count(biz_message.*) as datanum
FROM FROM
biz_message biz_message
LEFT JOIN biz_message_template ON biz_message.templatecode = biz_message_template.CODE LEFT JOIN biz_message_template ON biz_message.templatecode = biz_message_template.CODE
@ -62,6 +61,7 @@
and biz_message_template.type = #{templatetype} and biz_message_template.type = #{templatetype}
</if> </if>
ORDER BY createtime DESC ORDER BY createtime DESC
LIMIT #{size}
</select> </select>
</mapper> </mapper>

View File

@ -8,6 +8,7 @@ public class BizMessageVo extends BizMessage{
private String authorizestate; private String authorizestate;
private String templatetype; private String templatetype;
private String userId; private String userId;
private Integer datanum; private Long datanum;
private Integer size;
} }

View File

@ -104,12 +104,21 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService
*/ */
@Override @Override
public List<BizMessageVo> selectMsgListByType(BizMessageVo vo) { public List<BizMessageVo> selectMsgListByType(BizMessageVo vo) {
vo.setSize(vo.getSize()!=null?vo.getSize():5);
vo.setUserId(service.getCacheUser().getUserId()); vo.setUserId(service.getCacheUser().getUserId());
if(vo.getAuthorizestate()==null||"".equals(vo.getAuthorizestate())){ if(vo.getAuthorizestate()==null||"".equals(vo.getAuthorizestate())){
vo.setAuthorizestate("0"); vo.setAuthorizestate("0");
} }
List<BizMessageVo> list = mapper.findMessageVoList(vo); PageDTO page = new PageDTO();
page.setPageSize(vo.getSize());
IPage<BizMessageVo> pageEntity = mapper.findMessageVoList(new Page<BizMessageVo>(page.getPageNo(), page.getPageSize()),vo);
List<BizMessageVo> list = pageEntity.getRecords();
list.forEach(l->{
l.setDatanum(pageEntity.getCurrent());
});
return list; return list;
} }