|
|
@@ -14,6 +14,7 @@ import com.fdkankan.contro.entity.Scene3dNum;
|
|
|
import com.fdkankan.contro.enums.CameraTypeEnum;
|
|
|
import com.fdkankan.contro.mapper.IScene3dNumMapper;
|
|
|
import com.fdkankan.contro.service.ICameraTypeService;
|
|
|
+import com.fdkankan.contro.service.ICommonService;
|
|
|
import com.fdkankan.contro.service.IScene3dNumService;
|
|
|
import com.fdkankan.dingtalk.DingTalkSendUtils;
|
|
|
import com.fdkankan.redis.constant.RedisKey;
|
|
|
@@ -72,13 +73,17 @@ public class Scene3dNumServiceImpl extends ServiceImpl<IScene3dNumMapper, Scene3
|
|
|
private DingTalkSendUtils dingTalkSendUtils;
|
|
|
@Autowired
|
|
|
private ICameraTypeService cameraTypeService;
|
|
|
+ @Autowired
|
|
|
+ private ICommonService commonService;
|
|
|
|
|
|
@Override
|
|
|
public String generateSceneNum(Integer cameraType, JSONObject dataFdage) throws Exception {
|
|
|
// 从缓存中获取
|
|
|
String sceneNum = redisUtil.lLeftPop(RedisKey.FDKANKAN_SCENE_NUMS);
|
|
|
+ //获取插件前缀
|
|
|
+ String pluginPrefix = commonService.getPluginPrefix(dataFdage);
|
|
|
if(Objects.nonNull(sceneNum)){
|
|
|
- return addPrefix(sceneNum,cameraType, null);
|
|
|
+ return addPrefix(sceneNum,cameraType, pluginPrefix);
|
|
|
}
|
|
|
//为了防止场景量暴增导致定时任务来还不急处理,如果上面redis获取不到,需要调用一下生成场景码方法
|
|
|
log.warn("定时任务没有生成足够的场景码,此处实时调用批量生成场景码程序");
|
|
|
@@ -91,7 +96,7 @@ public class Scene3dNumServiceImpl extends ServiceImpl<IScene3dNumMapper, Scene3
|
|
|
dingTalkSendUtils.sendActioncardMsgToDingRobot(content, "场景码穷尽告警");
|
|
|
throw new Exception("场景计算获取场景码失败");
|
|
|
}
|
|
|
- return addPrefix(sceneNum,cameraType,null);
|
|
|
+ return addPrefix(sceneNum,cameraType,pluginPrefix);
|
|
|
}
|
|
|
|
|
|
@Override
|