liuchang/biz_service_ebtp_extend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加业务参数

Browse Source
This commit is contained in:
zhangqinbin
2021-08-10 13:56:20 +08:00
parent 164210d1c8
commit 045546b340
2 changed files with 12 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/dao/BizMessageMapper.java
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);
IPage<BizMessageVo> findMessageVoList(@Param("param") IPage<BizMessageVo> page,BizMessageVo vo); List<BizMessageVo> findMessageVoList(BizMessageVo vo);
} }

21
src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageConsumerServiceImpl.java
View File

@ -15,6 +15,7 @@ import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.Optional; import java.util.Optional;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@ -109,17 +110,19 @@ public class BizMessageConsumerServiceImpl implements BizMessageConsumerService
if(vo.getAuthorizestate()==null||"".equals(vo.getAuthorizestate())){ if(vo.getAuthorizestate()==null||"".equals(vo.getAuthorizestate())){
vo.setAuthorizestate("0"); vo.setAuthorizestate("0");
} }
PageDTO page = new PageDTO();
page.setPageSize(vo.getSize());
IPage<BizMessageVo> pageEntity = mapper.findMessageVoList(new Page<BizMessageVo>(page.getPageNo(), page.getPageSize()),vo); List<BizMessageVo> list = mapper.findMessageVoList(vo);
List<BizMessageVo> list = pageEntity.getRecords(); List<BizMessageVo> rList = new ArrayList<>();
list.forEach(l->{ for(int i = 0 ; i < list.size();i++){
l.setDatanum(pageEntity.getTotal()); if(i<vo.getSize()){
}); BizMessageVo message = list.get(i);
message.setDatanum(Long.valueOf(list.size()));
return list; rList.add(message);
}
}
return rList;
} }
} }