增加业务参数

This commit is contained in:
zhangqinbin
2021-08-04 16:41:41 +08:00
parent 82de945f59
commit 0062bd7dec
8 changed files with 31 additions and 5 deletions

View File

@ -56,6 +56,8 @@ public class BizMessageConsumerController {
DescribeSiteMsgDetailVO vo = new DescribeSiteMsgDetailVO(); DescribeSiteMsgDetailVO vo = new DescribeSiteMsgDetailVO();
vo.setMsgId(source.getId()); vo.setMsgId(source.getId());
BeanUtils.copyProperties(source, vo); BeanUtils.copyProperties(source, vo);
//已读
this.service.updateStateById(source.getId());
return vo; return vo;
}).orElseGet(DescribeSiteMsgDetailVO::new); }).orElseGet(DescribeSiteMsgDetailVO::new);

View File

@ -5,4 +5,5 @@ import com.chinaunicom.mall.ebtp.extend.bizmessage.entity.BizMessageAuthorize;
public interface BizMessageAuthorizeMapper extends BaseMapper<BizMessageAuthorize> { public interface BizMessageAuthorizeMapper extends BaseMapper<BizMessageAuthorize> {
} }

View File

@ -12,4 +12,5 @@ public interface BizMessageMapper extends BaseMapper<BizMessage> {
IPage<BizMessageVo> findMessageVo(@Param("param") IPage<BizMessageVo> page, @Param("userId") String userId); IPage<BizMessageVo> findMessageVo(@Param("param") IPage<BizMessageVo> page, @Param("userId") String userId);
Boolean updateStateById(@Param("id") String id);
} }

View File

@ -19,7 +19,7 @@
</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 SELECT biz_message.*,'1' as authorizestate,null as authorizeid
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
@ -27,8 +27,8 @@
<if test="userId!=null and userId!=''"> <if test="userId!=null and userId!=''">
UNION ALL UNION ALL
SELECT a.*,IFNULL(b.state,1) as authorizestate SELECT a.*,IFNULL(b.state,1) as authorizestate,b.id as authorizeid
FROM ( SELECT biz_message.*,biz_message_template.type templatetype FROM ( SELECT biz_message.*
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 = 1) a WHERE authorize = 1) a
@ -37,4 +37,10 @@
</if> </if>
ORDER BY createtime DESC ORDER BY createtime DESC
</select> </select>
<update id="updateStateById" parameterType="java.lang.String">
update biz_message_authorize set state = 1
where id=#{id}
</update>
</mapper> </mapper>

View File

@ -5,7 +5,7 @@ import lombok.Data;
@Data @Data
public class BizMessageVo extends BizMessage{ public class BizMessageVo extends BizMessage{
private String templatetype;
private String authorizestate; private String authorizestate;
private String authorizeid;
} }

View File

@ -11,4 +11,5 @@ public interface BizMessageConsumerService {
BizMessage getDetailById(String id); BizMessage getDetailById(String id);
Boolean updateStateById(String id);
} }

View File

@ -41,7 +41,7 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService
public IBizMessagePage<DescribeSiteMsgVO> listOutline(PageDTO page) { public IBizMessagePage<DescribeSiteMsgVO> listOutline(PageDTO page) {
page = createPageCondition(page); page = createPageCondition(page);
IPage<BizMessage> pageEntity = mapper.findMessage(new Page<BizMessage>(page.getPageNo(), page.getPageSize()), IPage<BizMessageVo> pageEntity = mapper.findMessageVo(new Page<BizMessageVo>(page.getPageNo(), page.getPageSize()),
service.getCacheUser().getUserId()); service.getCacheUser().getUserId());
// DAT -> VO 转换 // DAT -> VO 转换
@ -51,6 +51,8 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService
DescribeSiteMsgVO vo = new DescribeSiteMsgVO(); DescribeSiteMsgVO vo = new DescribeSiteMsgVO();
vo.setMsgId(source.getId()); vo.setMsgId(source.getId());
vo.setServicecode(source.getServicecode()); vo.setServicecode(source.getServicecode());
vo.setAuthorizestate(source.getAuthorizestate());
vo.setAuthorizeid(source.getAuthorizeid());
BeanUtils.copyProperties(source, vo); BeanUtils.copyProperties(source, vo);
return vo; return vo;
}).collect(Collectors.toList())); }).collect(Collectors.toList()));
@ -69,6 +71,17 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService
return mapper.selectById(id); return mapper.selectById(id);
} }
/**
* 消息详情 已读修改
*
* @param id
* @return
*/
@Override
public Boolean updateStateById(String id){
return mapper.updateStateById(id);
}
/** /**
* @param page * @param page
* @return * @return

View File

@ -17,6 +17,8 @@ public class DescribeSiteMsgVO {
private String title; private String title;
private String category; private String category;
private String servicecode; private String servicecode;
private String authorizestate;
private String authorizeid;
@JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
private Timestamp createtime; private Timestamp createtime;