addOrUpdateMap = new HashMap<>();
int i = 0;
for (JSONObject jsonObject : data) {
jsonObject.put("createTime", Calendar.getInstance().getTimeInMillis() + i++);
addOrUpdateMap.put(jsonObject.getString("sid"), JSON.toJSONString(jsonObject));
}
this.syncBillboardsFromFileToRedis(num);
//处理新增和修改数据
this.addOrUpdateBillboardsHandler(num, addOrUpdateMap);
}
/**
*
保证指示牌数据安全性，当redis宕机导致热点数据丢失时，可以从文件中读取，恢复到redis
*
* @author dengsixing
* @date 2022/3/3
**/
private void syncBillboardsFromFileToRedis(String num) throws Exception{
String key = String.format(RedisKey.SCENE_BILLBOARDS, num);
boolean exist = redisUtil.hasKey(key);
if(exist){
return;
}
String lockKey = String.format(RedisLockKey.LOCK_BILLBOARDS_SYNC, num);
String lockVal = cn.hutool.core.lang.UUID.randomUUID().toString();
boolean lock = redisLockUtil.lock(lockKey, lockVal, RedisKey.EXPIRE_TIME_1_MINUTE);
if(!lock){
throw new BusinessException(ErrorCode.SYSTEM_BUSY);
}
try{
exist = redisUtil.hasKey(key);
if(exist){
return;
}
String billboardsFilePath = String.format(ConstantFilePath.SCENE_USER_PATH_V4, num) + "billboards.json";
String billboardsData = FileUtils.readUtf8String(billboardsFilePath);
if(StrUtil.isEmpty(billboardsData)){
return;
}
JSONArray tagsArr = JSON.parseArray(billboardsData);
if(CollUtil.isEmpty(tagsArr)){
return;
}
Map map = new HashMap<>();
for (Object o : tagsArr) {
JSONObject jo = (JSONObject)o;
map.put(jo.getString("sid"), jo.toJSONString());
}
redisUtil.hmset(key, map);
}finally {
redisLockUtil.unlockLua(lockKey, lockVal);
}
}
private void addOrUpdateBillboardsHandler(String num, Map addOrUpdateMap){
if(CollUtil.isEmpty(addOrUpdateMap))
return;
//批量写入缓存
String key = String.format(RedisKey.SCENE_BILLBOARDS, num);
redisUtil.hmset(key, addOrUpdateMap);
//写入本地文件，作为备份
this.writeBillboardJson(num);
}
/**
*
热点数据保存
*
* @author dengsixing
* @date 2022/3/3
*
**/
private void writeBillboardJson(String num){
String lockKey = String.format(RedisLockKey.LOCK_BILLBOARDS_SYNC, num);
String lockVal = cn.hutool.core.lang.UUID.randomUUID().toString();
boolean lock = redisLockUtil.lock(lockKey, lockVal, RedisKey.EXPIRE_TIME_1_MINUTE);
if(!lock){
return;
}
try{
String dataKey = String.format(RedisKey.SCENE_BILLBOARDS, num);
String hotJsonPath = String.format(ConstantFilePath.SCENE_USER_PATH_V4, num) + "billboards.json";
if(!redisUtil.hasKey(dataKey)){
FileUtil.del(hotJsonPath);
return;
}
Map billboardMap = redisUtil.hmget(dataKey);
List billboardList = billboardMap.entrySet().stream().map(entry->JSON.parseObject(entry.getValue())).collect(Collectors.toList());
FileUtil.writeUtf8String(JSON.toJSONString(billboardList), hotJsonPath);
}finally {
redisLockUtil.unlockLua(lockKey, lockVal);
}
}
private void writeBillboardStylesJson(String num){
String lockKey = String.format(RedisLockKey.LOCK_BILLBOARDS_STYLES_SYNC, num);
String lockVal = cn.hutool.core.lang.UUID.randomUUID().toString();
boolean lock = redisLockUtil.lock(lockKey, lockVal, RedisKey.EXPIRE_TIME_1_MINUTE);
if(!lock){
return;
}
try{
String dataKey = String.format(RedisKey.SCENE_BILLBOARDS_STYLES, num);
String stylesPath = String.format(ConstantFilePath.SCENE_USER_PATH_V4, num) + "billboards-styles.json";
if(!redisUtil.hasKey(dataKey)){
FileUtil.del(stylesPath);
return;
}
Map billboardStylesMap = redisUtil.hmget(dataKey);
List billboardStyleList = billboardStylesMap.entrySet().stream().map(entry->JSON.parseObject(entry.getValue())).collect(Collectors.toList());
FileUtil.writeUtf8String(JSON.toJSONString(billboardStyleList), stylesPath);
}finally {
redisLockUtil.unlockLua(lockKey, lockVal);
}
}
private void updateBillboards(String num, SceneEditInfoExt sceneEditInfoExt){
//查询缓存是否包含热点数据
String key = String.format(RedisKey.SCENE_BILLBOARDS, num);
Map billboardsMap = redisUtil.hmget(key);
boolean hashBillboards= false;
for (Map.Entry tagMap : billboardsMap.entrySet()) {
if(StrUtil.isEmpty(tagMap.getValue())){
continue;
}
hashBillboards = true;
break;
}
//更改热点状态
sceneEditInfoExt.setBillboards(hashBillboards ? CommonStatus.YES.code().intValue() : CommonStatus.NO.code().intValue());
this.updateById(sceneEditInfoExt);
}
@Override
public ResultData deleteBillboardsStyles(DeleteStylesParamVO param) throws Exception {
ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
if (scenePlus == null)
throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
List sidList = param.getSidList();
this.syncBillboardsStylesFromFileToRedis(param.getNum());
String key = String.format(RedisKey.SCENE_BILLBOARDS_STYLES, param.getNum());
List deleteList = redisUtil.hMultiGet(key, sidList);
redisUtil.hdel(key, sidList.toArray());
//写入本地文件，作为备份
this.writeBillboardStylesJson(param.getNum());
//删除oss文件
List deleteFileList = deleteList.stream().map(str -> {
JSONObject parse = JSON.parseObject(str);
return parse.getString("url");
}).collect(Collectors.toList());
sceneUploadService.delete(
DeleteFileParamVO.builder()
.num(param.getNum())
.fileNames(deleteFileList)
.bizType(FileBizType.BILLBOARD_ICON.code()).build());
return ResultData.ok();
}
}