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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
package cn.wisenergy.chnmuseum.party.service.impl;
import cn.wisenergy.chnmuseum.party.common.util.CurrencyMathUtil;
import cn.wisenergy.chnmuseum.party.common.util.DateUtil;
import cn.wisenergy.chnmuseum.party.common.util.RedisUtil;
import cn.wisenergy.chnmuseum.party.core.annotations.RedisLock;
import cn.wisenergy.chnmuseum.party.model.*;
import cn.wisenergy.chnmuseum.party.mapper.TBoardStatisticMapper;
import cn.wisenergy.chnmuseum.party.service.TAreaService;
import cn.wisenergy.chnmuseum.party.service.TBoardStatisticService;
import cn.wisenergy.chnmuseum.party.service.TUserService;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.beans.factory.annotation.Autowired;
import javax.annotation.Resource;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;
/**
* <pre>
* 展板统计信息表 服务实现类
* </pre>
*
* @author Danny Lee
* @since 2021-03-25
*/
@Slf4j
@Service
public class TBoardStatisticServiceImpl extends ServiceImpl<TBoardStatisticMapper, TBoardStatistic> implements TBoardStatisticService {
@Resource
private TBoardStatisticMapper boardStatisticMapper;
@Autowired
private TUserService userService;
@Autowired
private TAreaService areaService;
@Autowired
private RedisUtil redisUtil;
@Autowired
private RedisTemplate<String, ? extends Object> redisTemplate;
private static String STATISTIC_BOARD_INFO_KEY = "STATISTIC_BOARD_INFO_KEY"; // 展板统计信息key
@Override
@RedisLock(value = "boardLock", timeLock = 20, required = true, timeOut = 1100000)
public Object boardStatisticInfo(TBoardStatistic tBoardStatistic, boolean autoUpdate) {
if (tBoardStatistic != null) {
// 根据用户id获取用户信息
TUser user = userService.selectById(tBoardStatistic.getUserId());
tBoardStatistic.setOrganId(user.getOrgId()); // 用户所属机构
tBoardStatistic.setAreaId(Integer.parseInt(user.getAreaId()));// 用户所属地区
if (StringUtils.isEmpty(tBoardStatistic.getPlayDate())) {
// 获取当前日期
tBoardStatistic.setPlayDate(DateUtil.getCurrentDate("yyyyMMdd"));
}
if (null == tBoardStatistic.getPlayNumber()) {
// 获取当前日期
tBoardStatistic.setPlayNumber(1);
}
}
List<TBoardStatistic> statisticList = new ArrayList<>();
String redisKey = STATISTIC_BOARD_INFO_KEY;
// 获取统计信息缓存数据
String businessJsonArray = (String) redisUtil.get(redisKey);
// 缓存数据不为空，转换数据
if (StringUtils.isNotEmpty(businessJsonArray)) {
statisticList = JSONObject.parseArray(businessJsonArray, TBoardStatistic.class);
}
if (tBoardStatistic != null) {
statisticList.add(tBoardStatistic);
}
redisUtil.set(redisKey, JSON.toJSON(statisticList).toString());
// 统计记录数等于100 时，或者需要自动更新时 汇总统计数据
if (statisticList.size() >= 100 || (autoUpdate && statisticList.size() > 0)) {
// 更新展板统计信息
updateBoardStatisticInfo(statisticList, redisKey);
}
return true;
}
@Override
public Page<TBoardPlayRank> getBoardRankPageList(Page<TBoardPlayRank> page, TBoardPlayRank rank) {
page.setRecords(boardStatisticMapper.getBoardRankPageList(page, rank));
return page;
}
@Override
public Page<TBoardPlayTrend> getBoardTrendPageList(Page<TBoardPlayTrend> page, TBoardPlayTrend trend) {
page.setRecords(boardStatisticMapper.getBoardTrendPageList(page, trend));
return page;
}
@Override
public Page<TDistrictBoardStatistic> getBoardDistrictPageList(Page<TDistrictBoardStatistic> page, TDistrictBoardStatistic district) {
List<TDistrictBoardStatistic> list = boardStatisticMapper.getBoardDistrictPageList(page, district);
page.setRecords(list);
return page;
}
@Override
public TBoardSurvey getBoardSurvey(TBoardSurvey survey) {
// 获取展板播放量
survey.setPlayCnt(boardStatisticMapper.getBoardPlayTotal(survey));
// 获取展板总数
survey.setBoardCnt(boardStatisticMapper.getBoardTotal(survey));
// 获取播放展板的机构总数
survey.setOrgCnt(boardStatisticMapper.getOrganTotal(survey));
// 获取互动总数
survey.setInteractionCnt(boardStatisticMapper.getInteractionTotal(survey));
return survey;
}
@Override
public Page getInteractionFrequency(Page page, String frequencyDate, String orgCode) {
page.setRecords(boardStatisticMapper.getInteractionFrequency(page, frequencyDate, orgCode));
return page;
}
@Override
public List getBoardProvincePlayTotalList(String organId, String orgCode) {
// 获取省份信息
QueryWrapper qw = new QueryWrapper();
qw.eq("type", "P");
List<TArea> provlist = areaService.list(qw);
provlist.stream().forEach(l -> l.setName(l.getName().replace("省", "").replace("市", "").
replace("自治区", "").replace("特别行政区", "").replace("壮族", "").replace("回族", "").replace("维吾尔", "")));
// 遍历省份，统计各省播放量
TBoardSurvey survey = new TBoardSurvey();
String dateStr = DateUtil.getCurrentDate("yyyyMM");
survey.setStatisticDate(dateStr);
survey.setOrganId(organId);
survey.setOrganCode(orgCode);
List list = new ArrayList();
// 根据省份查询播放量
for (TArea prov : provlist) {
Map map = new HashMap();
survey.setAreaId(prov.getId().toString().substring(0, 2));
Integer cnt = boardStatisticMapper.getBoardPlayTotal(survey);
map.put("name", prov.getName());
map.put("value", cnt == null ? 0 : cnt);
list.add(map);
}
return list;
}
@Override
public Page<TBoardPlayTrend> getBoardPageList(Page<TBoardPlayTrend> page, TBoardPlayTrend trend) {
HashMap<String, Integer> map = new HashMap<>();
List<TBoardPlayTrend> board = boardStatisticMapper.getBoardPageList(page, trend);
for (TBoardPlayTrend tBoardPlayTrend : board) {
map.put(tBoardPlayTrend.getPlayDate(),tBoardPlayTrend.getPlayNumber());
}
SimpleDateFormat sim = new SimpleDateFormat("yyyyMM");
Date begin = null;
Date end = null;
try {
begin = sim.parse(trend.getBeginDate());
end = sim.parse(trend.getEndDate());
} catch (ParseException e) {
e.printStackTrace();
}
long l = (end.getTime() - begin.getTime()) / 1000 / 3600 / 24 / 30;
ArrayList<TBoardPlayTrend> list = new ArrayList<>();
Calendar rightNow = Calendar.getInstance();
rightNow.setTime(begin);
for (int i = 0; i <= l; i++) {
TBoardPlayTrend tBoardPlayTrend = new TBoardPlayTrend();
String date = sim.format(rightNow.getTime());
tBoardPlayTrend.setPlayDate(date);
if (map.get(date)!=null){
tBoardPlayTrend.setPlayNumber(map.get(date));
}else {
tBoardPlayTrend.setPlayNumber(0);
}
list.add(tBoardPlayTrend);
rightNow.add(Calendar.MONTH, 1);
}
page.setRecords(list);
return page;
}
/**
* 更新展板统计信息
*/
@Override
public void updateBoardStatisticInfo(List<TBoardStatistic> statisticList, String redisKey) {
Map<String, TBoardStatistic> map = new HashMap<>();
statisticList.stream().forEach(s -> {
String key = s.getBoardId() + "_" + s.getOrganId() + "_" + s.getPlayDate();
// 如果有对应的展板记录，累计播放量
if (map.containsKey(key)) {
TBoardStatistic boardStatistic = map.get(key);
boardStatistic.setPlayNumber(Integer.parseInt(CurrencyMathUtil.add(boardStatistic.getPlayNumber(), s.getPlayNumber())));
map.put(key, boardStatistic);
} else {
// 如果无对应的展板记录，插入到map中
map.put(key, s);
}
});
// 更新数据库展板统计信息
for (String key : map.keySet()) {
TBoardStatistic bs = map.get(key);
// 查询数据库是否有对应的记录
QueryWrapper<TBoardStatistic> qw = new QueryWrapper<>();
qw.eq("board_id", bs.getBoardId());
qw.eq("organ_id", bs.getOrganId());
qw.eq("play_date", bs.getPlayDate());
TBoardStatistic tbDB = this.getOne(qw);
// 如果数据库存在统计记录，则累计统计数量
if (tbDB != null) {
tbDB.setPlayNumber(Integer.parseInt(CurrencyMathUtil.add(bs.getPlayNumber(), tbDB.getPlayNumber())));
this.updateById(tbDB);
map.put(key, tbDB);
} else {
// 如果数据库不存在统计记录，则增加统计数据
this.save(bs);
}
}
// 清空redis
redisUtil.del(redisKey);
}
}