ScheduleBuffer.java
2.12 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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
package com.bsth.service.realcontrol.buffer;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.bsth.entity.realcontrol.ScheduleRealInfo;
import com.google.common.collect.ArrayListMultimap;
/**
*
* @ClassName: ScheduleRealInfoBuffer
* @Description: TODO(当天实际排班缓存)
* @author PanZhao
* @date 2016年6月14日 上午9:40:38
*
*/
public class ScheduleBuffer {
static Logger logger = LoggerFactory.getLogger(ScheduleBuffer.class);
/**
* 当天实际排班
* K 线路编码 V 按时间升序的班次
*/
public static ArrayListMultimap<String, ScheduleRealInfo> schedulListMap;
/**
* K: 车辆自编号 V: 班次链表
*/
public static Map<String, LinkedList<ScheduleRealInfo>> vehLinkedMap;
/**
* 主键 和 排班映射
*/
public static Map<Long, ScheduleRealInfo> pkSchedulMap;
/**
* 需要持久化的排班
*/
public static LinkedList<ScheduleRealInfo> persistentList;
static{
schedulListMap = ArrayListMultimap.create();
pkSchedulMap = new HashMap<>();
persistentList = new LinkedList<>();
vehLinkedMap = new HashMap<>();
}
public static int init(List<ScheduleRealInfo> list){
try{
//发车时间排序
Collections.sort(list, new Comparator<ScheduleRealInfo>() {
@Override
public int compare(ScheduleRealInfo o1, ScheduleRealInfo o2) {
return (int) (o1.getFcsjT() - o2.getFcsjT());
}
});
String zbh;
for(ScheduleRealInfo schedul : list){
schedulListMap.put(schedul.getXlBm(), schedul);
pkSchedulMap.put(schedul.getId(), schedul);
//初始化车辆和班次列表对照
zbh = schedul.getClZbh();
if(!vehLinkedMap.containsKey(zbh))
vehLinkedMap.put(zbh, new LinkedList<ScheduleRealInfo>());
vehLinkedMap.get(zbh).add(schedul);
}
}catch(Exception e){
logger.error("缓存排班数据失败...", e);
return -1;
}
return 0;
}
}