re_over_test.jsp
1.6 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
<%@ page import="com.engine.kq.wfset.util.SplitActionUtil" %>
<%@ page import="com.engine.kq.timer.KQTaskBean" %>
<%@ page import="java.util.List" %>
<%@ page import="java.util.ArrayList" %>
<%@ page import="com.engine.kq.timer.KQQueue" %>
<%@ page import="com.engine.kq.biz.KQFlowDataBiz" %>
<%@ page import="java.util.Map" %>
<%@ page import="java.util.HashMap" %>
<%@ page import="com.engine.kq.wfset.bean.SplitBean" %>
<%@ page import="com.alibaba.fastjson.JSON" %>
<%@ page language="java" contentType="text/html; charset=UTF-8" %>
<%
try {
KQFlowDataBiz kqFlowDataBiz = new KQFlowDataBiz.FlowDataParamBuilder().belongDateParam("2019-09-03").
resourceidParam("3577").build();
Map<String,Object> flowMaps = new HashMap<>();
List<SplitBean> splitBeans = kqFlowDataBiz.getOverTimeData(flowMaps);
out.print("splitBeans:"+JSON.toJSON(splitBeans)+"<br/>");
List<KQTaskBean> tasks = new ArrayList<>();
for(int i = 0 ; i < splitBeans.size();i++){
KQTaskBean taskBean = new KQTaskBean();
taskBean.setResourceId("3577");
taskBean.setTaskDate("2019-09-03");
taskBean.setSplitBean(splitBeans.get(i));
tasks.add(taskBean);
}
out.print("tasks:"+JSON.toJSON(tasks)+"<br/>");
if(!tasks.isEmpty()){
KQQueue.writeTasks(tasks);
}
out.print("queue:"+JSON.toJSON(KQQueue.queue)+"<br/>");
out.print("pollLimitList:"+JSON.toJSON(KQQueue.pollLimitList())+"<br/>");
} catch (Exception e) {
e.printStackTrace();
out.print(e.getMessage());
}
%>