Authored by mlge

gatewayAccess事件检测

... ... @@ -25,4 +25,9 @@ public interface TaskSheduleMapper {
int selectCount();
int updateLastTime(int id);
int selectGatewayCount();
List<TaskModel> selectPageforGateway(PageBean page);
}
... ...
... ... @@ -57,6 +57,24 @@
where id = #{id,jdbcType=INTEGER}
</delete>
<select id="selectGatewayCount" resultType="java.lang.Integer">
select
count(1)
from task_shedule
where inf_database = 'yoho_event'
</select>
<select id="selectPageforGateway" resultMap="BaseResultMap">
select
*
from task_shedule
where inf_database = 'yoho_event'
order by id
limit #{startIndex},#{pageSize}
</select>
<update id="updateByid" parameterType="com.model.TaskModel">
update task_shedule
set alarm_interval = #{interval,jdbcType=INTEGER},
... ...
... ... @@ -103,4 +103,37 @@ public class TaskConfigureCtrl {
}
}
@RequestMapping("/getGatewayConfigure")
@ResponseBody
public BaseResponse<PageResponse<TaskModel>> getGateWayTaskConfigure(@RequestBody PageRequest request) {
try {
// 组装分页对象
PageBean page = PageBean.initPageInfo(request.getCurrentPage(),
request.getPageSize(), request);
// 先查询符合条件的总数量
int total = taskSheduleMapper.selectGatewayCount();
// 数量为0 直接返回
if (total == 0) {
// 返回初始page对象
return null;
}
// 获取列表
List<TaskModel> taskModels = taskSheduleMapper.selectPageforGateway(page);
if (CollectionUtils.isEmpty(taskModels)) {
return null;
}
PageResponse<TaskModel> response = new PageResponse<TaskModel>();
response.setCurrentPage(request.getCurrentPage());
response.setPageSize(request.getPageSize());
response.setTotal(total);
response.setRows(taskModels);
return new BaseResponse<PageResponse<TaskModel>>(response);
} catch (Exception e) {
log.error("getTaskConfigure error", e);
return new BaseResponse<>(e.getMessage());
}
}
}
... ...