|
@ -48,22 +48,18 @@ public class IotMessageService extends BaseJpaService<IotMessageDO, IotMessageD
|
|
|
*/
|
|
|
public MixEnvelop<IotMessageDO, IotMessageDO> findAll(Integer page, Integer size) throws ParseException {
|
|
|
|
|
|
String sqlunRead="SELECT * FROM iot_message WHERE read_msg=0 ORDER BY create_time DESC;";
|
|
|
String sqlRead="SELECT * FROM iot_message WHERE read_msg=1 ORDER BY create_time DESC;";
|
|
|
StringBuffer sql= new StringBuffer("SELECT * FROM iot_message");
|
|
|
|
|
|
List<IotMessageDO> unlist = jdbcTemplate.query(sqlunRead, new BeanPropertyRowMapper<>(IotMessageDO.class));
|
|
|
List<IotMessageDO> list = jdbcTemplate.query(sqlRead, new BeanPropertyRowMapper<>(IotMessageDO.class));
|
|
|
sql.append(sql).append(" ORDER BY read_msg, create_time DESC LIMIT ").append((page-1)*size).append(",").append(size);
|
|
|
|
|
|
Map<String, List> listMap = new HashMap<>();
|
|
|
listMap.put("unread",unlist);
|
|
|
listMap.put("read",list);
|
|
|
List<IotMessageDO> list = jdbcTemplate.query(sql.toString(), new BeanPropertyRowMapper<>(IotMessageDO.class));
|
|
|
|
|
|
long size2 = unlist.size();
|
|
|
long size1 = list.size();
|
|
|
long count = list.size();
|
|
|
|
|
|
long count =size1+size2;
|
|
|
|
|
|
return MixEnvelop.getSuccessMapWithPage(IotRequestMapping.Company.message_success_find_functions,listMap, page, size,count);
|
|
|
|
|
|
|
|
|
return MixEnvelop.getSuccessListWithPage(IotRequestMapping.Company.message_success_find_functions,list, page, size,count);
|
|
|
}
|
|
|
|
|
|
/**
|