|
@@ -63,14 +63,8 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
private String bucket;
|
|
private String bucket;
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
- private ISceneService sceneService;
|
|
|
|
- @Autowired
|
|
|
|
private ISceneFileBuildService sceneFileBuildService;
|
|
private ISceneFileBuildService sceneFileBuildService;
|
|
@Autowired
|
|
@Autowired
|
|
- private ISceneProService sceneProService;
|
|
|
|
- @Autowired
|
|
|
|
- private ISceneProExtService sceneProExtService;
|
|
|
|
- @Autowired
|
|
|
|
private ICameraDetailService cameraDetailService;
|
|
private ICameraDetailService cameraDetailService;
|
|
@Autowired
|
|
@Autowired
|
|
private ISceneEditInfoService sceneEditInfoService;
|
|
private ISceneEditInfoService sceneEditInfoService;
|
|
@@ -109,11 +103,6 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
try {
|
|
try {
|
|
if(!buildSuccess){//建模失败,修改状态为失败状态
|
|
if(!buildSuccess){//建模失败,修改状态为失败状态
|
|
log.info("建模失败,修改状态为失败状态");
|
|
log.info("建模失败,修改状态为失败状态");
|
|
- // TODO: 2022/3/21 plus版本稳定后删除------------------------start
|
|
|
|
- sceneService.updateStatus(sceneCode, SceneStatus.FAILD.code());
|
|
|
|
- sceneProService.updateStatus(sceneCode, SceneStatus.FAILD.code());
|
|
|
|
- // TODO: 2022/3/21 plus版本稳定后删除------------------------send
|
|
|
|
-
|
|
|
|
scenePlusService.update(
|
|
scenePlusService.update(
|
|
new LambdaUpdateWrapper<ScenePlus>()
|
|
new LambdaUpdateWrapper<ScenePlus>()
|
|
.set(ScenePlus::getSceneStatus, SceneStatus.FAILD.code())
|
|
.set(ScenePlus::getSceneStatus, SceneStatus.FAILD.code())
|
|
@@ -134,10 +123,6 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
long space = this.calUseSpace(uploadFiles);
|
|
long space = this.calUseSpace(uploadFiles);
|
|
|
|
|
|
if(cameraType < 3){
|
|
if(cameraType < 3){
|
|
- // TODO: 2022/3/21 plus版本稳定后删除------------------------start
|
|
|
|
- sceneService.updateTime(sceneCode, space, payStatus);
|
|
|
|
- // TODO: 2022/3/21 plus版本稳定后删除------------------------send
|
|
|
|
-
|
|
|
|
this.updateDb4Sm(sceneCode, space);
|
|
this.updateDb4Sm(sceneCode, space);
|
|
|
|
|
|
uploadToOssUtil.uploadMulFiles(uploadFiles);
|
|
uploadToOssUtil.uploadMulFiles(uploadFiles);
|
|
@@ -148,20 +133,16 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
JSONObject videosJson = this.getVideosJson(path, videoVersion, sceneCode, cameraType);
|
|
JSONObject videosJson = this.getVideosJson(path, videoVersion, sceneCode, cameraType);
|
|
|
|
|
|
//写入数据库
|
|
//写入数据库
|
|
- // TODO: 2022/3/21 plus版本稳定后删除------------------------start
|
|
|
|
- ScenePro scenePro = this.updateDbPro(sceneCode, space, payStatus, videosJson.toJSONString(), computeTime, fileId);
|
|
|
|
- SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
|
|
|
|
- // TODO: 2022/3/21 plus版本稳定后删除------------------------send
|
|
|
|
ScenePlus scenePlus = this.updateDbPlus(sceneCode, space, payStatus, videosJson.toJSONString(), computeTime, fileId);
|
|
ScenePlus scenePlus = this.updateDbPlus(sceneCode, space, payStatus, videosJson.toJSONString(), computeTime, fileId);
|
|
ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
|
|
ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
|
|
|
|
|
|
//变更容量,arrearCap为true时,代表容量不足
|
|
//变更容量,arrearCap为true时,代表容量不足
|
|
- boolean arrearCap = this.updateSpace(scenePlus.getCameraId(), space, scenePlus.getId(), scenePro.getId());
|
|
|
|
|
|
+ boolean arrearCap = this.updateSpace(scenePlus.getCameraId(), space);
|
|
|
|
|
|
//如果相机容量不足,需要把场景的paystatus改为容量不足状态
|
|
//如果相机容量不足,需要把场景的paystatus改为容量不足状态
|
|
- this.sealScene(arrearCap, scenePlus.getId(), scenePro.getId());
|
|
|
|
|
|
+ this.sealScene(arrearCap, scenePlus.getId(), scenePlus.getId());
|
|
|
|
|
|
- Object[] editInfoArr = this.updateEditInfo(scenePro, scenePlus);
|
|
|
|
|
|
+ Object[] editInfoArr = this.updateEditInfo(scenePlus);
|
|
SceneEditInfo sceneEditInfo = (SceneEditInfo)editInfoArr[0];
|
|
SceneEditInfo sceneEditInfo = (SceneEditInfo)editInfoArr[0];
|
|
SceneEditInfoExt sceneEditInfoExt = (SceneEditInfoExt)editInfoArr[1];
|
|
SceneEditInfoExt sceneEditInfoExt = (SceneEditInfoExt)editInfoArr[1];
|
|
SceneEditControls sceneEditControls = (SceneEditControls)editInfoArr[2];
|
|
SceneEditControls sceneEditControls = (SceneEditControls)editInfoArr[2];
|
|
@@ -206,7 +187,7 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
sceneEditInfo, sceneEditInfoExt, sceneEditControls, scenePlus, scenePlusExt, arrearCap);
|
|
sceneEditInfo, sceneEditInfoExt, sceneEditControls, scenePlus, scenePlusExt, arrearCap);
|
|
|
|
|
|
//计算成功,发短信
|
|
//计算成功,发短信
|
|
- this.sendSms(pushChannel,pushToken, cameraType, scenePro.getSceneName(), scenePro.getWebSite());
|
|
|
|
|
|
+ this.sendSms(pushChannel,pushToken, cameraType, scenePlus.getTitle(), scenePlusExt.getWebSite());
|
|
|
|
|
|
log.info("场景计算结果处理结束,场景码:{}", message.getSceneCode());
|
|
log.info("场景计算结果处理结束,场景码:{}", message.getSceneCode());
|
|
|
|
|
|
@@ -496,14 +477,6 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
new LambdaUpdateWrapper<ScenePlus>()
|
|
new LambdaUpdateWrapper<ScenePlus>()
|
|
.set(ScenePlus::getPayStatus, PayStatus.NO_CAPACITY.code())
|
|
.set(ScenePlus::getPayStatus, PayStatus.NO_CAPACITY.code())
|
|
.eq(ScenePlus::getId, scenePlusId));
|
|
.eq(ScenePlus::getId, scenePlusId));
|
|
-
|
|
|
|
-
|
|
|
|
- // TODO: 2022/3/22 plus版本稳定后删除---------------------------start
|
|
|
|
- sceneProService.update(
|
|
|
|
- new LambdaUpdateWrapper<ScenePro>()
|
|
|
|
- .set(ScenePro::getPayStatus, PayStatus.NO_CAPACITY.code())
|
|
|
|
- .eq(ScenePro::getId, sceneProId));
|
|
|
|
- // TODO: 2022/3/22 plus版本稳定后删除---------------------------end
|
|
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -540,44 +513,6 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
.set(ScenePlusExt::getSpace, space));
|
|
.set(ScenePlusExt::getSpace, space));
|
|
}
|
|
}
|
|
|
|
|
|
- private ScenePro updateDbPro(String sceneCode, Long space, Integer payStatus, String videosJson, Long computeTime, String fileId) throws Exception{
|
|
|
|
- ScenePro scenePro = sceneProService.findBySceneNum(sceneCode);
|
|
|
|
-
|
|
|
|
- sceneProService.updateTime(sceneCode, space, payStatus, videosJson, computeTime);
|
|
|
|
- SceneFileBuild sceneFileBuild = sceneFileBuildService.findByFileId(fileId);
|
|
|
|
- if(sceneFileBuild != null){
|
|
|
|
- sceneFileBuild.setBuildStatus(BuildStatus.success.code());
|
|
|
|
- sceneFileBuildService.updateById(sceneFileBuild);
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- if(Objects.nonNull(scenePro)){
|
|
|
|
- SceneProExt sceneProExt = sceneProExtService.findBySceneProId(scenePro.getId());
|
|
|
|
- SceneSource sceneSource = SceneSource.get(sceneProExt.getSceneSource());
|
|
|
|
- switch (sceneSource){
|
|
|
|
- case BM:
|
|
|
|
- sceneProExt.setSceneResolution(SceneResolution.TILES_2K.code());
|
|
|
|
- sceneProExt.setSceneFrom(SceneFrom.PRO.code());
|
|
|
|
- break;
|
|
|
|
- case SM:
|
|
|
|
- sceneProExt.setSceneResolution(SceneResolution.TILES_1K.code());
|
|
|
|
- sceneProExt.setSceneFrom(SceneFrom.LITE.code());
|
|
|
|
- break;
|
|
|
|
- case ZT:
|
|
|
|
- sceneProExt.setSceneResolution(SceneResolution.TILES_4K.code());
|
|
|
|
- sceneProExt.setSceneFrom(SceneFrom.MINION.code());
|
|
|
|
- break;
|
|
|
|
- case JG:
|
|
|
|
- sceneProExt.setSceneResolution(SceneResolution.TILES_4K.code());
|
|
|
|
- sceneProExt.setSceneFrom(SceneFrom.LASER.code());
|
|
|
|
- break;
|
|
|
|
- }
|
|
|
|
- sceneProExtService.updateById(sceneProExt);
|
|
|
|
-
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
- return scenePro;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
private ScenePlus updateDbPlus(String num, Long space, Integer payStatus, String videosJson, Long computeTime, String fileId) throws Exception{
|
|
private ScenePlus updateDbPlus(String num, Long space, Integer payStatus, String videosJson, Long computeTime, String fileId) throws Exception{
|
|
ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
|
|
ScenePlus scenePlus = scenePlusService.getScenePlusByNum(num);
|
|
ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
|
|
ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
|
|
@@ -636,7 +571,7 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
return scenePlus;
|
|
return scenePlus;
|
|
}
|
|
}
|
|
|
|
|
|
- private boolean updateSpace(Long cameraId, Long space, Long scenePlusId, Long sceneProId) throws Exception{
|
|
|
|
|
|
+ private boolean updateSpace(Long cameraId, Long space) throws Exception{
|
|
//更新相机使用用量
|
|
//更新相机使用用量
|
|
CameraDetail cameraDetail = cameraDetailService.updateCameraDetailByCameraIdAndSpace(cameraId, space);
|
|
CameraDetail cameraDetail = cameraDetailService.updateCameraDetailByCameraIdAndSpace(cameraId, space);
|
|
UserIncrement userIncrement = userIncrementService.getByCameraId(cameraId);
|
|
UserIncrement userIncrement = userIncrementService.getByCameraId(cameraId);
|
|
@@ -649,14 +584,13 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
return false;
|
|
return false;
|
|
}
|
|
}
|
|
|
|
|
|
- private Object[] updateEditInfo(ScenePro scenePro, ScenePlus scenePlus){
|
|
|
|
|
|
+ private Object[] updateEditInfo(ScenePlus scenePlus){
|
|
SceneEditInfo sceneEditInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
|
|
SceneEditInfo sceneEditInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
|
|
SceneEditControls sceneEditControls = null;
|
|
SceneEditControls sceneEditControls = null;
|
|
SceneEditInfoExt sceneEditInfoExt = null;
|
|
SceneEditInfoExt sceneEditInfoExt = null;
|
|
if(sceneEditInfo == null){
|
|
if(sceneEditInfo == null){
|
|
sceneEditInfo = new SceneEditInfo();
|
|
sceneEditInfo = new SceneEditInfo();
|
|
sceneEditInfo.setScenePlusId(scenePlus.getId());
|
|
sceneEditInfo.setScenePlusId(scenePlus.getId());
|
|
- sceneEditInfo.setSceneProId(scenePro.getId());
|
|
|
|
sceneEditInfo.setDescription(scenePlus.getDescription());
|
|
sceneEditInfo.setDescription(scenePlus.getDescription());
|
|
sceneEditInfo.setTitle(scenePlus.getTitle());
|
|
sceneEditInfo.setTitle(scenePlus.getTitle());
|
|
sceneEditInfoService.save(sceneEditInfo);
|
|
sceneEditInfoService.save(sceneEditInfo);
|
|
@@ -675,7 +609,6 @@ public class BuildScenePostServiceImpl implements IBuildScenePostService {
|
|
if(sceneEditInfoExt == null){
|
|
if(sceneEditInfoExt == null){
|
|
sceneEditInfoExt = new SceneEditInfoExt();
|
|
sceneEditInfoExt = new SceneEditInfoExt();
|
|
sceneEditInfoExt.setScenePlusId(scenePlus.getId());
|
|
sceneEditInfoExt.setScenePlusId(scenePlus.getId());
|
|
- sceneEditInfoExt.setSceneProId(scenePro.getId());
|
|
|
|
sceneEditInfoExt.setEditInfoId(sceneEditInfo.getId());
|
|
sceneEditInfoExt.setEditInfoId(sceneEditInfo.getId());
|
|
sceneEditInfoExtService.save(sceneEditInfoExt);
|
|
sceneEditInfoExtService.save(sceneEditInfoExt);
|
|
}
|
|
}
|