BuildSceneServiceImpl.java 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861
  1. package com.fdkankan.contro.mq.service.impl;
  2. import cn.hutool.core.bean.BeanUtil;
  3. import cn.hutool.core.collection.CollUtil;
  4. import cn.hutool.core.io.FileUtil;
  5. import cn.hutool.core.io.file.FileNameUtil;
  6. import cn.hutool.core.util.StrUtil;
  7. import cn.hutool.core.util.ZipUtil;
  8. import cn.hutool.extra.qrcode.QrCodeUtil;
  9. import cn.hutool.extra.qrcode.QrConfig;
  10. import cn.hutool.http.HttpUtil;
  11. import com.alibaba.fastjson.JSON;
  12. import com.alibaba.fastjson.JSONArray;
  13. import com.alibaba.fastjson.JSONObject;
  14. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  15. import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
  16. import com.fdkankan.common.constant.*;
  17. import com.fdkankan.common.util.FileUtils;
  18. import com.fdkankan.contro.bean.SceneJsonBean;
  19. import com.fdkankan.contro.entity.*;
  20. import com.fdkankan.contro.mq.service.IBuildSceneService;
  21. import com.fdkankan.contro.service.*;
  22. import com.fdkankan.contro.vo.SceneEditControlsVO;
  23. import com.fdkankan.fyun.config.FYunFileConfig;
  24. import com.fdkankan.fyun.constant.FYunTypeEnum;
  25. import com.fdkankan.fyun.face.FYunFileServiceInterface;
  26. import com.fdkankan.model.constants.ConstantFileName;
  27. import com.fdkankan.model.constants.ConstantFilePath;
  28. import com.fdkankan.model.constants.UploadFilePath;
  29. import com.fdkankan.model.enums.ModelTypeEnums;
  30. import com.fdkankan.model.utils.CreateHouseJsonUtil;
  31. import com.fdkankan.model.utils.CreateObjUtil;
  32. import com.fdkankan.model.utils.SceneUtil;
  33. import com.fdkankan.push.config.PushMessageConfig;
  34. import com.fdkankan.push.utils.PushMsgUtil;
  35. import com.fdkankan.rabbitmq.bean.BuildSceneCallMessage;
  36. import com.fdkankan.rabbitmq.bean.BuildSceneResultMqMessage;
  37. import com.fdkankan.rabbitmq.util.RabbitMqProducer;
  38. import com.fdkankan.redis.constant.RedisKey;
  39. import com.fdkankan.redis.util.RedisUtil;
  40. import lombok.extern.slf4j.Slf4j;
  41. import org.apache.commons.lang3.ObjectUtils;
  42. import org.apache.commons.lang3.StringUtils;
  43. import org.springframework.beans.factory.annotation.Autowired;
  44. import org.springframework.beans.factory.annotation.Value;
  45. import org.springframework.stereotype.Service;
  46. import java.io.File;
  47. import java.io.IOException;
  48. import java.util.*;
  49. import java.util.Map.Entry;
  50. import java.util.stream.Collectors;
  51. /**
  52. * <p>
  53. * TODO
  54. * </p>
  55. *
  56. * @author dengsixing
  57. * @since 2022/4/20
  58. **/
  59. @Slf4j
  60. @Service
  61. public class BuildSceneServiceImpl implements IBuildSceneService {
  62. @Value("${queue.modeling.modeling-call}")
  63. private String queueModelingCall;
  64. @Value("${queue.modeling.single.modeling-call}")
  65. private String singleModelingCall;
  66. @Value("${model.type:#{null}}")
  67. private String modelType;
  68. @Autowired
  69. private RabbitMqProducer mqProducer;
  70. @Autowired
  71. private FYunFileServiceInterface fYunFileService;
  72. @Autowired
  73. private ICameraDetailService cameraDetailService;
  74. @Autowired
  75. private ISceneEditInfoService sceneEditInfoService;
  76. @Autowired
  77. private ISceneEditControlsService sceneEditControlsService;
  78. @Autowired
  79. private FYunFileConfig fYunFileConfig;
  80. @Autowired
  81. private RedisUtil redisUtil;
  82. @Autowired
  83. private IScenePlusService scenePlusService;
  84. @Autowired
  85. private IScenePlusExtService scenePlusExtService;
  86. @Autowired
  87. private ISceneEditInfoExtService sceneEditInfoExtService;
  88. @Autowired
  89. private IUserIncrementService userIncrementService;
  90. @Autowired
  91. private IFdkkLaserService fdkkLaserService;
  92. @Autowired
  93. private IBuildSceneDTService buildSceneDTService;
  94. @Autowired
  95. private IIncrementTypeService incrementTypeService;
  96. @Autowired
  97. private ICompanyService companyService;
  98. @Override
  99. public void buildScenePre(BuildSceneCallMessage message) {
  100. boolean success = false;
  101. try {
  102. //重新计算时需要删除文件夹,否知使用缓存
  103. if(new File(message.getPath() + File.separator + "results").exists()){
  104. FileUtils.deleteDirectory(message.getPath() + File.separator + "results");
  105. }
  106. //根据相机类型,组装资源路径
  107. //下载资源到本地
  108. this.downLoadSource(message, message.getPath());
  109. JSONObject fdageJson = JSONObject.parseObject(FileUtils.readFile(message.getPath().concat("/capture/data.fdage")));
  110. boolean rewrite = false;
  111. // 兼容旧的数据,防止OnlyExportMeshObj标志未删除掉
  112. if (fdageJson.containsKey("OnlyExportMeshObj")) {
  113. log.info("data.fdage 包含 OnlyExportMeshObj,进行去除!");
  114. // 写入data.fdage 防止重算
  115. fdageJson.remove("OnlyExportMeshObj");
  116. String ossPath = getOssPath(message.getPath());
  117. fYunFileService.uploadFile(fdageJson.toJSONString().getBytes(), ossPath + "data.fdage");
  118. rewrite = true;
  119. }
  120. if (!ObjectUtils.isEmpty(modelType)) {
  121. // 修改dataFdage文件
  122. fdageJson.put("modelType", modelType);
  123. rewrite = true;
  124. }
  125. if (rewrite) {
  126. FileUtils.writeFile(message.getPath().concat("/capture/data.fdage"), fdageJson.toJSONString());
  127. }
  128. message.getBuildContext().put("cameraType",message.getCameraType());
  129. // 判断企业是否配置了弹性伸缩
  130. if (message.getFlexibility() == 0) {
  131. //发送mq,就进行计算
  132. mqProducer.sendByWorkQueue(queueModelingCall, message);
  133. } else {
  134. //发送mq,就进行计算
  135. mqProducer.sendByWorkQueue(singleModelingCall, message);
  136. }
  137. success = true;
  138. log.info("场景计算资源准备结束,场景码:{}", message.getSceneNum());
  139. }catch (Exception e){
  140. log.error("场景计算前置处理出错", e);
  141. }finally {
  142. //如果前置处理失败,发送钉钉消息
  143. if(!success){
  144. buildSceneDTService.handBaseFail("场景计算资源准备异常!", message.getPath(), message.getSceneNum(), "计算控制服务器");
  145. }
  146. }
  147. }
  148. private String getOssPath(String path) {
  149. String ossPath = ConstantFilePath.OSS_PREFIX
  150. + path.replace(ConstantFilePath.BUILD_MODEL_PATH, "")
  151. .replace(ConstantFilePath.BUILD_MODEL_LASER_PATH, "");
  152. if (!ossPath.endsWith("/")) {
  153. ossPath = ossPath.concat("/");
  154. }
  155. return ossPath;
  156. }
  157. @Override
  158. public void downLoadSource(BuildSceneCallMessage buildSceneMqMessage,String path){
  159. String ossPath = getOssPath(path);
  160. fYunFileService.downloadFileByCommand(path + File.separator + "capture", ossPath);
  161. }
  162. @Override
  163. public void buildScenePost(BuildSceneResultMqMessage message) throws Exception {
  164. String sceneCode = message.getBuildContext().get("sceneNum").toString();
  165. String path = message.getPath();
  166. try {
  167. // 上传计算日志
  168. //如果是重复计算,没有走到计算逻辑,不需要上传日志文件
  169. log.info("开始上传计算日志");
  170. String buildLogPath = String.format(UploadFilePath.BUILD_LOG_PATH, sceneCode);
  171. fYunFileService.uploadFile(path + File.separator + "console.log", buildLogPath + "console.log");
  172. log.info("计算日志上传完成");
  173. if (!message.getBuildSuccess()) {
  174. log.error("建模失败,修改状态为失败状态");
  175. scenePlusService.update(new LambdaUpdateWrapper<ScenePlus>()
  176. .set(ScenePlus::getSceneStatus, SceneStatus.FAILD.code())
  177. .eq(ScenePlus::getNum, sceneCode));
  178. // 发送钉钉消息,计算失败
  179. buildSceneDTService.handModelFail("计算失败", message.getPath(), sceneCode, message.getHostName());
  180. return;
  181. }
  182. JSONObject fdageData = getFdageData(path + File.separator + "capture" +File.separator+"data.fdage");
  183. ScenePlus scenePlus = scenePlusService.getScenePlusByNum(sceneCode);
  184. Integer cameraType = Integer.parseInt(message.getBuildContext().get("cameraType").toString());
  185. Map<String, String> uploadFiles = getUploadFiles(scenePlus,path,cameraType,fdageData);
  186. //计算场景消耗磁盘空间
  187. long space = this.calUseSpace(uploadFiles);
  188. scenePlus.setPayStatus(PayStatus.PAY.code());
  189. //如果相机容量不足,需要把场景的paystatus改为容量不足状态
  190. if (cameraType != 14) {
  191. scenePlus.setPayStatus(this.getPayStatus(scenePlus.getCameraId(), space));
  192. }
  193. scenePlus.setUpdateTime(new Date());
  194. scenePlus.setSceneStatus(SceneStatus.NO_DISPLAY.code());
  195. scenePlusService.updateById(scenePlus);
  196. Integer videoVersion = fdageData.getInteger("videoVersion");
  197. //读取计算结果文件生成videosJson
  198. JSONObject videosJson = this.getVideosJson(path, videoVersion, sceneCode, cameraType);
  199. ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
  200. boolean isObj = fdageData.containsKey("exportMeshObj") && fdageData.getIntValue("exportMeshObj") == 1;
  201. //写入数据库
  202. this.updateDbPlus(scenePlus.getSceneSource(), space, videosJson.toJSONString(), message.getComputeTime(),isObj,scenePlusExt);
  203. Object[] editInfoArr = this.updateEditInfo(scenePlus);
  204. SceneEditInfo sceneEditInfo = (SceneEditInfo)editInfoArr[0];
  205. SceneEditInfoExt sceneEditInfoExt = (SceneEditInfoExt)editInfoArr[1];
  206. SceneEditControls sceneEditControls = (SceneEditControls)editInfoArr[2];
  207. //上传全景图俯视图
  208. this.uploadFloorCad(path, sceneCode, uploadFiles);
  209. //上传文件
  210. log.info("开始上传场景计算结果数据,num:{}", sceneCode);
  211. fYunFileService.uploadMulFiles(uploadFiles);
  212. Map<String,String> damFileHeaders = new HashMap<>();
  213. damFileHeaders.put("Content-Encoding","gzip");
  214. if (!fYunFileService.getFyunType().equals(FYunTypeEnum.LOCAL.code())) {
  215. // dam 文件设置请求头
  216. uploadFiles.entrySet().stream().filter(entry -> FileNameUtil.extName(entry.getKey()).equals("dam"))
  217. .forEach(entry -> {
  218. if (!new File(entry.getKey()).exists()) {
  219. log.error("文件不存在,不予gzip压缩,文件路径:{}", entry.getKey());
  220. return;
  221. }
  222. // gzip压缩
  223. FileUtil.writeBytes(ZipUtil.gzip(new File(entry.getKey())), entry.getKey() + ".gzip");
  224. // 重命名
  225. FileUtil.rename(new File(entry.getKey() + ".gzip"), entry.getKey(), true);
  226. fYunFileService.uploadFile(entry.getKey(), entry.getValue(), damFileHeaders);
  227. });
  228. }
  229. //拷贝部分文件到编辑目录,用于用户编辑
  230. this.copyToEditDir(sceneCode);
  231. //计算完毕后,同步全景图到缓存目录
  232. this.cachePanorama(path, sceneCode);
  233. //生成houseTypejson并上传
  234. uploadFiles.entrySet().stream().filter(entry-> FileNameUtil.getName(entry.getKey()).equals("floorplan_cad.json"))
  235. .forEach(entry-> uploadHouseTypeJson(sceneCode,entry.getKey()));
  236. //写scene.json
  237. log.info("生成scene.json上传oss并设置缓存,num:{}", sceneCode);
  238. CameraDetail cameraDetail = cameraDetailService.getByCameraId(scenePlus.getCameraId());
  239. Company company = !ObjectUtils.isEmpty(cameraDetail.getCompanyId()) ? companyService.getById(cameraDetail.getCompanyId()) : null;
  240. if (cameraType == 14) {
  241. //计算成功 激光转台相机 同步 请求
  242. fdkkLaserService.syncBuildResult(scenePlus.getNum(), scenePlusExt.getDataSource(),scenePlus.getCreateTime());
  243. sceneEditControlsService.update(new LambdaUpdateWrapper<SceneEditControls>().set(SceneEditControls::getShowMap,0)
  244. .eq(SceneEditControls::getEditInfoId,sceneEditInfo.getId()));
  245. sceneEditControls.setShowMap(0);
  246. }
  247. this.writeSceneJson(sceneCode, videosJson,sceneEditInfo, sceneEditInfoExt, sceneEditControls, scenePlus,scenePlusExt,company);
  248. String qrLogo = !ObjectUtils.isEmpty(company) && !ObjectUtils.isEmpty(company.getQrLogo()) ? company.getQrLogo() : null;
  249. qrLogo = ObjectUtils.isEmpty(qrLogo) && !ObjectUtils.isEmpty(sceneEditInfoExt.getShareLogoImg()) ? fYunFileConfig.getHost().concat(sceneEditInfoExt.getShareLogoImg()) : null;
  250. createQrCode(sceneCode, scenePlusExt, qrLogo);
  251. //计算成功,通知APP
  252. Integer pushChannel = fdageData.getInteger("pushChannel");
  253. String pushToken = fdageData.getString("pushToken");
  254. this.pushMsgToApp(pushChannel,pushToken, cameraType, scenePlus.getTitle(), scenePlusExt.getWebSite());
  255. CreateObjUtil.deleteFile(path.replace(ConstantFilePath.BUILD_MODEL_PATH, "/") + "/capture");
  256. log.info("场景计算结果处理结束,场景码:{}", sceneCode);
  257. }catch (Exception e){
  258. e.printStackTrace();
  259. buildSceneDTService.handBaseFail("场景计算结果处理出错!", message.getPath(), sceneCode, "计算控制服务器");
  260. }
  261. }
  262. private void cachePanorama(String dataSource, String num){
  263. String cachedImagesPath = String.format(ConstantFilePath.SCENE_CACHE_IMAGES, num);
  264. //将全景图缓存到缓存目录
  265. List<String> imagesList = FileUtil.listFileNames(dataSource + "/caches/images");
  266. //先清除旧的全景图
  267. cn.hutool.core.io.FileUtil.del(cachedImagesPath);
  268. String visionPath = dataSource + "/results/vision.txt";
  269. List<String> panoramaImageList = SceneUtil.getPanoramaImageList(visionPath);
  270. imagesList.stream().forEach(fileName -> {
  271. if (panoramaImageList.contains(fileName)) {
  272. String srcPath = dataSource + "/caches/images/" + fileName;
  273. String targetPath = cachedImagesPath + fileName;
  274. log.info("源文件:{}, 目标文件:{}", srcPath, targetPath);
  275. cn.hutool.core.io.FileUtil.copy(srcPath, targetPath, true);
  276. }
  277. });
  278. }
  279. private Map<String, String> getUploadFiles(ScenePlus scenePlus,String path,Integer cameraType,JSONObject fdageData) throws Exception {
  280. if (ObjectUtils.isEmpty(scenePlus)) {
  281. throw new Exception("未找到场景信息:" + path);
  282. }
  283. String projectNum = scenePlus.getNum();
  284. String dataViewPath = String.format(UploadFilePath.DATA_VIEW_PATH, projectNum);
  285. String imagesPath = String.format(UploadFilePath.IMG_VIEW_PATH, projectNum);
  286. String videoPath = String.format(UploadFilePath.VIDEOS_VIEW_PATH, projectNum);
  287. String resultsPath = path + File.separator + "results" + File.separator;
  288. String uploadData = FileUtils.readFile(resultsPath + "upload.json");
  289. JSONArray array = JSONObject.parseObject(uploadData).getJSONArray("upload");
  290. JSONObject fileJson = null;
  291. String fileName = "";
  292. Map<String, String> map = new HashMap();
  293. for (int i = 0; i < array.size(); ++i) {
  294. fileJson = array.getJSONObject(i);
  295. fileName = fileJson.getString("file");
  296. String filePath = resultsPath + fileName;
  297. if (!(new File(filePath)).exists()) {
  298. throw new Exception(filePath + "文件不存在");
  299. }
  300. if ("vision2.txt".equals(fileName)) {
  301. CreateObjUtil.convertTxtToVisionmodeldata(resultsPath + "vision2.txt", resultsPath + "vision2.modeldata");
  302. map.put(resultsPath + "vision2.modeldata", imagesPath + "vision2.modeldata");
  303. map.put(resultsPath + "vision2.txt", imagesPath + "vision2.txt");
  304. }
  305. if (fileJson.getIntValue("clazz") == 2) {
  306. map.put(filePath, imagesPath + ConstantFileName.modelUUID + "_50k_texture_jpg_high1/" + fileName.replace("tex/", ""));
  307. } else if (fileJson.getIntValue("clazz") == 3) {
  308. map.put(filePath, imagesPath + "pan/high/" + fileName.replace("high/", ""));
  309. } else if (fileJson.getIntValue("clazz") == 4) {
  310. map.put(filePath, imagesPath + "pan/low/" + fileName.replace("low/", ""));
  311. } else if (fileJson.getIntValue("clazz") == 5) {
  312. map.put(filePath, imagesPath + fileName);
  313. } else if (fileJson.getIntValue("clazz") == 7) {
  314. map.put(filePath, imagesPath + fileName);
  315. } else if (fileJson.getIntValue("clazz") == 10) {
  316. String updown = FileUtils.readFile(filePath);
  317. JSONObject updownJson = JSONObject.parseObject(updown);
  318. String mappingOssPath = String.format("scene_edit_data/%s/data/", projectNum) + fileName.replace("updown", "mapping");
  319. map.put(filePath, mappingOssPath);
  320. } else {
  321. if (fileJson.getIntValue("clazz") == 11 || fileJson.getIntValue("clazz") == 12) {
  322. map.put(filePath, videoPath + fileName.replace("videos/", ""));
  323. if (fileName.contains(".mp4")) {
  324. map.put(resultsPath + fileName.replace("mp4", "flv"), videoPath + fileName.replace("videos/", "").replace("mp4", "flv"));
  325. }
  326. }
  327. if (fileJson.getIntValue("clazz") == 16) {
  328. map.put(filePath, dataViewPath + fileName);
  329. }
  330. if (fileJson.getIntValue("clazz") == 18) {
  331. map.put(filePath, imagesPath + fileName);
  332. }
  333. }
  334. }
  335. if ((fdageData.containsKey("exportMeshObj") && fdageData.getIntValue("exportMeshObj") == 1)
  336. || (!ObjectUtils.isEmpty(cameraType) && (!cameraType.equals(14)))) {
  337. CreateObjUtil.convertTxtToDam(path + File.separator + "results" + File.separator + "tex" + File.separator + "modeldata.txt", path + File.separator + "results" + File.separator + ConstantFileName.modelUUID + "_50k.dam");
  338. CreateObjUtil.convertDamToLzma(path + File.separator + "results/");
  339. CreateObjUtil.convertTxtToDam(path + File.separator + "results" + File.separator + "tex" + File.separator + "modeldata.txt", path + File.separator + "results" + File.separator + ConstantFileName.modelUUID + "_50k.dam");
  340. map.put(path + File.separator + "results" + File.separator + ConstantFileName.modelUUID + "_50k.dam.lzma", imagesPath + ConstantFileName.modelUUID + "_50k.dam.lzma");
  341. map.put(path + File.separator + "results" + File.separator + ConstantFileName.modelUUID + "_50k.dam", imagesPath + ConstantFileName.modelUUID + "_50k.dam");
  342. }
  343. CreateObjUtil.convertTxtToVisionmodeldata(resultsPath + "vision.txt", resultsPath + "vision.modeldata");
  344. map.put(resultsPath + "vision.txt", imagesPath + "vision.txt");
  345. map.put(resultsPath + "vision.modeldata", imagesPath + "vision.modeldata");
  346. log.info("数据转换完成:" + projectNum);
  347. if(!new File("/mnt/4Dkankan/scene/data" + File.separator + "data" + projectNum).exists()){
  348. FileUtil.mkdir("/mnt/4Dkankan/scene/data" + File.separator + "data" + projectNum);
  349. }
  350. map.put(resultsPath + "floorplan.json", dataViewPath + "floor.json");
  351. map.put(resultsPath + "floorplan_cad.json", dataViewPath + "floorplan_cad.json");
  352. map.put(path + File.separator + "capture/stitch_params.txt", dataViewPath + "stitch_params.txt");
  353. map.put(path + File.separator + "capture/Up.xml", dataViewPath + "Up.xml");
  354. map.put(path + File.separator + "capture/Up2.xml", dataViewPath + "Up2.xml");
  355. map.put(path + File.separator + "capture/Up.txt", dataViewPath + "Up.txt");
  356. map.put(path + File.separator + "capture/Up2.txt", dataViewPath + "Up2.txt");
  357. return map;
  358. }
  359. private JSONObject getFdageData(String dataFdagePath) {
  360. log.info("dataFdagePath 文件路径 :{}", dataFdagePath);
  361. String data = FileUtils.readFile(dataFdagePath);
  362. //获取data.fdage的内容
  363. JSONObject dataJson = new JSONObject();
  364. if(data!=null){
  365. dataJson = JSONObject.parseObject(data);
  366. }
  367. return dataJson;
  368. }
  369. private void uploadFloorCad(String path, String num, Map<String, String> uploadFiles){
  370. //户型图上传
  371. String userEditPath = UploadFilePath.USER_EDIT_PATH + "floor-cad-%s.%s";
  372. String userViewPath = UploadFilePath.USER_VIEW_PATH + "floor-cad-%s.%s";
  373. String floorCadPath = path + "/results/floorplan_cad";
  374. List<String> floorCadList = FileUtils.getFileList(floorCadPath);
  375. if(CollUtil.isNotEmpty(floorCadList)){
  376. floorCadList.stream().forEach(str->{
  377. String substring = str.substring(str.lastIndexOf(File.separator) + 1);
  378. String[] arr = substring.split("floor");
  379. String[] arr2 = arr[1].split("\\.");
  380. uploadFiles.put(str, String.format(userEditPath, num, arr2[0], arr2[1]));
  381. uploadFiles.put(str, String.format(userViewPath, num, arr2[0], arr2[1]));
  382. });
  383. }
  384. }
  385. private void writeSceneJson(String num, JSONObject videosJson, SceneEditInfo sceneEditInfo, SceneEditInfoExt sceneEditInfoExt,
  386. SceneEditControls sceneEditControls, ScenePlus scenePlus, ScenePlusExt scenePlusExt,Company company){
  387. String dataViewPath = String.format(UploadFilePath.DATA_VIEW_PATH, num);
  388. SceneJsonBean sceneJson = new SceneJsonBean();
  389. BeanUtil.copyProperties(sceneEditInfoExt, sceneJson);
  390. BeanUtil.copyProperties(sceneEditInfo, sceneJson);
  391. SceneEditControlsVO sceneEditControlsVO = BeanUtil.copyProperties(sceneEditControls, SceneEditControlsVO.class);
  392. sceneJson.setControls(sceneEditControlsVO);
  393. sceneJson.setNum(num);
  394. sceneJson.setCreateTime(scenePlus.getCreateTime());
  395. sceneJson.setSceneResolution(scenePlusExt.getSceneResolution());
  396. sceneJson.setVersion(sceneEditInfo.getVersion());
  397. sceneJson.setImgVersion(sceneEditInfo.getImgVersion());
  398. sceneJson.setSceneFrom(scenePlusExt.getSceneFrom());
  399. sceneJson.setSceneKind(scenePlusExt.getSceneKind());
  400. sceneJson.setVideos(JSON.toJSONString(videosJson));
  401. sceneJson.setPayStatus(scenePlus.getPayStatus());
  402. if(!ObjectUtils.isEmpty(company)){
  403. String userViewPath = String.format(UploadFilePath.USER_VIEW_PATH, num);
  404. String userEditPath = String.format(UploadFilePath.USER_EDIT_PATH, num);
  405. String localLogoPath = null;
  406. if (StrUtil.isNotEmpty(company.getTopLogo())) {
  407. localLogoPath = ConstantFilePath.AGENT_PATH + company.getTopLogo().substring(company.getTopLogo().lastIndexOf("//") + 1);
  408. HttpUtil.downloadFile(company.getTopLogo(), localLogoPath);
  409. fYunFileService.uploadFile(localLogoPath, userViewPath + "loadingLogo-user.png");
  410. fYunFileService.uploadFile(localLogoPath, userEditPath + "loadingLogo-user.png");
  411. sceneJson.setLoadingLogo("user");
  412. sceneJson.setLoadingLogoFile("loadingLogo-user.png");
  413. sceneEditInfo.setLoadingLogo("user");
  414. sceneEditInfo.setLoadingLogoFile("loadingLogo-user.png");
  415. }
  416. if (StrUtil.isNotEmpty(company.getFloorLogo())) {
  417. localLogoPath = ConstantFilePath.AGENT_PATH + company.getFloorLogo().substring(company.getFloorLogo().lastIndexOf("//") + 1);
  418. HttpUtil.downloadFile(company.getFloorLogo(), localLogoPath);
  419. fYunFileService.uploadFile(localLogoPath, userViewPath + "floorLogo-user.png");
  420. fYunFileService.uploadFile(localLogoPath, userEditPath + "floorLogo-user.png");
  421. sceneJson.setFloorLogo("user");
  422. sceneJson.setFloorLogoFile("floorLogo-user.png");
  423. sceneEditInfo.setFloorLogo("user");
  424. sceneEditInfo.setFloorLogoFile("floorLogo-user.png");
  425. }
  426. if(!ObjectUtils.isEmpty(localLogoPath)){
  427. sceneEditInfoService.updateById(sceneEditInfo);
  428. FileUtils.deleteFile(localLogoPath);
  429. }
  430. }
  431. String sceneJsonStr = JSON.toJSONString(sceneJson);
  432. //上传sceneJson文件
  433. fYunFileService.uploadFile(sceneJsonStr.getBytes(), dataViewPath + "scene.json");
  434. //scenejson写入缓存
  435. redisUtil.set(String.format(RedisKey.SCENE_JSON, num), sceneJsonStr);
  436. // 上传status JSON.
  437. JSONObject statusJson = new JSONObject();
  438. //临时将-2改成1,app还没完全更新
  439. statusJson.put("status", 1);
  440. statusJson.put("webSite", scenePlusExt.getWebSite());
  441. statusJson.put("sceneNum", num);
  442. statusJson.put("thumb", scenePlusExt.getThumb());
  443. statusJson.put("payStatus", scenePlus.getPayStatus());
  444. statusJson.put("sceneScheme", scenePlusExt.getSceneScheme());
  445. FileUtils.writeFile(ConstantFilePath.SCENE_PATH + "data/data" + num + File.separator + "status.json", statusJson.toString());
  446. fYunFileService.uploadFile(ConstantFilePath.SCENE_PATH + "data/data" + num + File.separator + "status.json",
  447. dataViewPath + "status.json");
  448. }
  449. private void createQrCode(String num, ScenePlusExt scenePlusExt, String qrLogo) {
  450. String localLogoPath = null;
  451. if (!ObjectUtils.isEmpty(qrLogo)) {
  452. try {
  453. localLogoPath = ConstantFilePath.AGENT_PATH + qrLogo.substring(qrLogo.lastIndexOf("//") + 1);
  454. HttpUtil.downloadFile(qrLogo, localLogoPath);
  455. } catch (Exception e) {
  456. log.error("公司logo下载失败:{}", qrLogo);
  457. localLogoPath = null;
  458. }
  459. }
  460. //生成二维码
  461. String outPathZh = ConstantFilePath.BASE_PATH + File.separator + "sceneQRcode/"+ num +".png";
  462. String outPathEn = ConstantFilePath.BASE_PATH + File.separator + "sceneQRcode/"+ num +"_en.png";
  463. QrConfig qrConfig = QrConfig.create();
  464. if(!ObjectUtils.isEmpty(localLogoPath)){
  465. qrConfig.setImg(localLogoPath);
  466. }
  467. QrCodeUtil.generate(scenePlusExt.getWebSite(), qrConfig, FileUtil.file(outPathZh));
  468. QrCodeUtil.generate(scenePlusExt.getWebSite() + "&lang=en", qrConfig, FileUtil.file(outPathEn));
  469. //上传二维码
  470. fYunFileService.uploadFile(outPathZh, String.format(UploadFilePath.DOWNLOADS_QRCODE, num) + num + ".png");
  471. fYunFileService.uploadFile(outPathEn, String.format(UploadFilePath.DOWNLOADS_QRCODE, num) + num + "_en.png");
  472. if(!ObjectUtils.isEmpty(localLogoPath)){
  473. FileUtils.deleteFile(localLogoPath);
  474. }
  475. }
  476. private void pushMsgToApp(Integer pushChannel, String pushToken, int cameraType, String sceneName, String webSite){
  477. log.info("推送消息,渠道是 {}, 手机token是 {}", pushChannel, pushToken);
  478. if(Objects.isNull(pushChannel) && StrUtil.isBlank(pushToken)){
  479. return;
  480. }
  481. String title = sceneName + "计算完成";
  482. String body = "您上传的" + sceneName + "计算完成,点击查看";
  483. try{
  484. if(FYunTypeEnum.AWS.code().equals(fYunFileService.getFyunType())){
  485. PushMsgUtil.googlePushMsg(ConstantFilePath.BASE_PATH + "/refreshToken.json", pushToken,
  486. title, body , webSite);
  487. return;
  488. }
  489. PushMessageConfig pushConfig = null;
  490. if(pushChannel == 0){
  491. if(cameraType == 10 || cameraType == 13){
  492. //ios
  493. pushConfig = new PushMessageConfig(PushMessageConfig.IOS_KEY_Z, PushMessageConfig.IOS_SECRET_Z);
  494. pushConfig.sendIOSUnicast(pushToken, "四维看看Minion",title, body, webSite);
  495. }else {
  496. //ios
  497. pushConfig = new PushMessageConfig(PushMessageConfig.IOS_KEY, PushMessageConfig.IOS_SECRET);
  498. pushConfig.sendIOSUnicast(pushToken, "四维看看Pro",title, body, webSite);
  499. }
  500. }else {
  501. if(cameraType == 10 || cameraType == 13){
  502. //ios
  503. //安卓
  504. pushConfig = new PushMessageConfig(PushMessageConfig.ANDROID_KEY_Z, PushMessageConfig.ANDROID_SECRET_Z);
  505. pushConfig.sendAndroidUnicast2(pushToken, "四维看看Minion",title, body, webSite);
  506. }else {
  507. //安卓
  508. pushConfig = new PushMessageConfig(PushMessageConfig.ANDROID_KEY, PushMessageConfig.ANDROID_SECRET);
  509. pushConfig.sendAndroidUnicast(pushToken, "四维看看Pro",title, body, webSite);
  510. }
  511. }
  512. log.info("消息推送结束!");
  513. }catch (Exception e){
  514. log.error("推送消息失败:", e);
  515. }
  516. }
  517. private void copyToEditDir(String num) throws IOException {
  518. String editImagesPath = String.format(UploadFilePath.IMG_EDIT_PATH, num);
  519. String viewImagesPath = String.format(UploadFilePath.IMG_VIEW_PATH, num);
  520. String editDataPath = String.format(UploadFilePath.DATA_EDIT_PATH, num);
  521. String viewDataPath = String.format(UploadFilePath.DATA_VIEW_PATH, num);
  522. Map<String, String> map = new HashMap<>();
  523. map.put(editImagesPath + "vision.modeldata", viewImagesPath + "vision.modeldata");
  524. map.put(editImagesPath + "vision2.modeldata", viewImagesPath + "vision2.modeldata");
  525. map.put(editDataPath + "floorplan_cad.json", viewDataPath + "floorplan_cad.json");
  526. for (Entry<String, String> entry : map.entrySet()) {
  527. fYunFileService.copyFileInBucket(entry.getValue(), entry.getKey());
  528. }
  529. }
  530. private JSONObject getVideosJson(String path, Integer videoVersion, String projectNum, int cameraType) throws Exception {
  531. //读取videos_hdr_param.json, 保存点位视频的value
  532. Map<String, Object> videoMap = new HashMap<>();
  533. String videosHdr = FileUtils.readFile(path + File.separator + "results/videos/videos_hdr_param.json");
  534. JSONArray videoArray = null;
  535. if(StringUtils.isNotEmpty(videosHdr)){
  536. videoArray = JSONObject.parseObject(videosHdr).getJSONArray("hdr_param");
  537. }
  538. if(videoArray != null){
  539. for(int i = 0, len = videoArray.size(); i < len; i++) {
  540. videoMap.put(videoArray.getJSONObject(i).getString("name"), videoArray.getJSONObject(i).getString("value"));
  541. if(videoArray.getJSONObject(i).containsKey("fov")){
  542. videoMap.put(videoArray.getJSONObject(i).getString("name") + "_fov", videoArray.getJSONObject(i).getString("fov"));
  543. }
  544. }
  545. }
  546. //获取upload中的video视频名称
  547. String uploadData = FileUtils.readFile(path + File.separator + "results" +File.separator+"upload.json");
  548. JSONObject uploadJson = null;
  549. JSONArray array = null;
  550. if(uploadData!=null) {
  551. uploadJson = JSONObject.parseObject(uploadData);
  552. array = uploadJson.getJSONArray("upload");
  553. }
  554. JSONObject fileJson = null;
  555. String fileName = "";
  556. //计算ts文件的大小,并拼接成json格式
  557. JSONArray jsonArray = new JSONArray();
  558. JSONObject videoJson = null;
  559. JSONObject videosJson = new JSONObject();
  560. long videoSize = 0L;
  561. for(int i = 0, len = array.size(); i < len; i++) {
  562. fileJson = array.getJSONObject(i);
  563. fileName = fileJson.getString("file");
  564. if(fileJson.getIntValue("clazz") == 11 && fileName.contains(".mp4") && !fileName.contains("-ios.mp4")){
  565. videoJson = new JSONObject();
  566. videoJson.put("id", fileName.substring(
  567. 0, fileName.lastIndexOf(".")).replace("videos/", ""));
  568. //如果ts文件存在,就计算ts大小
  569. if(new File(path + File.separator + "results" +File.separator+ fileName.replace(".mp4", ".ts")).exists()){
  570. videoSize = new File(path + File.separator + "results" +File.separator+ fileName.replace(".mp4", ".ts")).length();
  571. videoJson.put("tsSize", videoSize);
  572. }
  573. if(videoMap.containsKey(videoJson.get("id"))){
  574. videoJson.put("value", videoMap.get(videoJson.get("id")));
  575. }
  576. if(videoMap.containsKey(videoJson.get("id") + "_fov")){
  577. videoJson.put("blend_fov", videoMap.get(videoJson.get("id") + "_fov"));
  578. }else {
  579. videoJson.put("blend_fov", 7);
  580. }
  581. jsonArray.add(videoJson);
  582. }
  583. }
  584. videosJson.put("data", jsonArray);
  585. if(Objects.nonNull(videoVersion) && videoVersion >= 4){
  586. videosJson.put("version", 3);
  587. videosJson.put("upPath", fYunFileConfig.getHost() + String.format(UploadFilePath.DATA_VIEW_PATH, projectNum) + "Up.xml");
  588. if(cameraType == 13){
  589. //转台相机
  590. videosJson.put("upPath", videosJson.getString("upPath").replace(".xml", ".txt"));
  591. }
  592. }else {
  593. videosJson.put("version", 1);
  594. videosJson.put("upPath", fYunFileConfig.getHost() + String.format(UploadFilePath.DATA_VIEW_PATH, projectNum) + "Up2.xml");
  595. if(cameraType == 13){
  596. //转台相机
  597. videosJson.put("upPath", videosJson.getString("upPath").replace(".xml", ".txt"));
  598. }
  599. }
  600. if(cameraType == 5 || cameraType == 6){
  601. videosJson.put("version", 1);
  602. videosJson.put("upPath", fYunFileConfig.getHost() + String.format(UploadFilePath.DATA_VIEW_PATH, projectNum) + "stitch_params.txt");
  603. }
  604. return videosJson;
  605. }
  606. private Long calUseSpace(Map<String, String> uploadFile) {
  607. return uploadFile.keySet().stream().map(File::new).filter(File::exists).mapToLong(File::length).sum();
  608. }
  609. private void sealScene(Long scenePlusId){
  610. scenePlusService.update(
  611. new LambdaUpdateWrapper<ScenePlus>()
  612. .set(ScenePlus::getPayStatus, PayStatus.NO_CAPACITY.code())
  613. .eq(ScenePlus::getId, scenePlusId));
  614. }
  615. /**
  616. * <p>
  617. 双目场景更新数据库
  618. * </p>
  619. * @author dengsixing
  620. * @date 2022/3/21
  621. * @param num
  622. * @param space
  623. **/
  624. private void updateDb4Sm(String num, long space){
  625. List<ScenePlus> ScenePlusList = scenePlusService.list(
  626. new LambdaQueryWrapper<ScenePlus>().select(ScenePlus::getId).eq(ScenePlus::getNum, num));
  627. if(CollUtil.isEmpty(ScenePlusList)){
  628. return ;
  629. }
  630. List<Long> sceneIds = ScenePlusList.stream().map(ScenePlus::getId).collect(Collectors.toList());
  631. //更新场景创建时间
  632. scenePlusService.update(new LambdaUpdateWrapper<ScenePlus>().in(ScenePlus::getId, sceneIds)
  633. .set(ScenePlus::getSceneStatus, SceneStatus.NO_DISPLAY.code()));
  634. //更新使用容量
  635. scenePlusExtService.update(new LambdaUpdateWrapper<ScenePlusExt>().in(ScenePlusExt::getPlusId, sceneIds)
  636. .set(ScenePlusExt::getSpace, space)
  637. .set(ScenePlusExt::getAlgorithmTime, Calendar.getInstance().getTime()));
  638. }
  639. private void updateDbPlus(int sceneSource,Long space,String videosJson, Long computeTime,boolean isObj,ScenePlusExt scenePlusExt){
  640. scenePlusExt.setSpace(space);
  641. scenePlusExt.setComputeTime(computeTime.toString());
  642. scenePlusExt.setAlgorithmTime(new Date());
  643. scenePlusExt.setVideos(videosJson);
  644. scenePlusExt.setIsObj(isObj ? 1 : 0);
  645. if(ModelTypeEnums.TILE_CODE.equals(modelType)){
  646. scenePlusExt.setSceneScheme(3);
  647. }
  648. switch (SceneSource.get(sceneSource)){
  649. case BM:
  650. scenePlusExt.setSceneResolution(SceneResolution.two_K.code());
  651. scenePlusExt.setSceneFrom(SceneFrom.PRO.code());
  652. break;
  653. case SM:
  654. scenePlusExt.setSceneResolution(SceneResolution.one_k.code());
  655. scenePlusExt.setSceneFrom(SceneFrom.LITE.code());
  656. break;
  657. case ZT:
  658. scenePlusExt.setSceneResolution(SceneResolution.four_K.code());
  659. scenePlusExt.setSceneFrom(SceneFrom.MINION.code());
  660. break;
  661. case JG:
  662. scenePlusExt.setSceneResolution(SceneResolution.four_K.code());
  663. scenePlusExt.setSceneFrom(SceneFrom.LASER.code());
  664. break;
  665. }
  666. String sceneKind = scenePlusExt.getSceneScheme() == 3 ? SceneKind.FACE.code():SceneKind.TILES.code();
  667. scenePlusExt.setSceneKind(sceneKind);
  668. scenePlusExtService.updateById(scenePlusExt);
  669. }
  670. private int getPayStatus(Long cameraId, Long space){
  671. //更新相机使用用量
  672. CameraDetail cameraDetail = cameraDetailService.updateCameraDetailByCameraIdAndSpace(cameraId, space);
  673. Long totalSpace = cameraDetail.getTotalSpace();
  674. UserIncrement userIncrement = userIncrementService.getByCameraId(cameraId);
  675. if(!ObjectUtils.isEmpty(userIncrement) && userIncrement.getIsExpired().equals(ExpiredStatus.NOT_EXPIRED.code())){
  676. IncrementType type = incrementTypeService.getById(userIncrement.getIncrementTypeId());
  677. if(type != null){
  678. Integer cameraCapacity = type.getCameraCapacity();
  679. if(cameraCapacity == -1){ //无限容量权益
  680. return PayStatus.PAY.code();
  681. }else {
  682. totalSpace = cameraCapacity *1024 * 1024 * 1024L; //权益设置容量
  683. }
  684. }
  685. }
  686. return totalSpace.compareTo(cameraDetail.getUsedSpace()) == -1 ? PayStatus.NO_CAPACITY.code() : PayStatus.PAY.code();
  687. }
  688. private Object[] updateEditInfo(ScenePlus scenePlus){
  689. SceneEditInfo sceneEditInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
  690. SceneEditControls sceneEditControls = null;
  691. SceneEditInfoExt sceneEditInfoExt = null;
  692. if(sceneEditInfo == null){
  693. sceneEditInfo = new SceneEditInfo();
  694. sceneEditInfo.setScenePlusId(scenePlus.getId());
  695. sceneEditInfo.setDescription(scenePlus.getDescription());
  696. sceneEditInfo.setTitle(scenePlus.getTitle());
  697. sceneEditInfoService.save(sceneEditInfo);
  698. }else{
  699. sceneEditControls = sceneEditControlsService.getBySceneEditId(sceneEditInfo.getId());
  700. sceneEditInfoExt = sceneEditInfoExtService.getByEditInfoId(sceneEditInfo.getId());
  701. sceneEditInfo.setVersion(sceneEditInfo.getVersion() + 1);
  702. sceneEditInfo.setImgVersion(sceneEditInfo.getImgVersion() + 1);
  703. sceneEditInfoService.updateById(sceneEditInfo);
  704. }
  705. if(sceneEditControls == null){
  706. sceneEditControls = new SceneEditControls();
  707. sceneEditControls.setEditInfoId(sceneEditInfo.getId());
  708. sceneEditControlsService.save(sceneEditControls);
  709. }
  710. if(sceneEditInfoExt == null){
  711. sceneEditInfoExt = new SceneEditInfoExt();
  712. sceneEditInfoExt.setScenePlusId(scenePlus.getId());
  713. sceneEditInfoExt.setEditInfoId(sceneEditInfo.getId());
  714. sceneEditInfoExtService.save(sceneEditInfoExt);
  715. }
  716. return new Object[]{sceneEditInfo, sceneEditInfoExt, sceneEditControls};
  717. }
  718. public void uploadHouseTypeJson(String num, String floorPlanCardFilePath) {
  719. if (!new File(floorPlanCardFilePath).exists()) {
  720. log.error("floorplan_cad.json 文件不存在,文件路径:{}", floorPlanCardFilePath);
  721. return;
  722. }
  723. JSONObject json = CreateHouseJsonUtil.createHouseTypeJsonByCad(floorPlanCardFilePath);
  724. String hourseTypeJsonPath = String.format(UploadFilePath.DATA_VIEW_PATH, num) + "houseType.json";
  725. fYunFileService.uploadFile(json.toJSONString().getBytes(), hourseTypeJsonPath);
  726. hourseTypeJsonPath = String.format(UploadFilePath.DATA_EDIT_PATH, num) + "houseType.json";
  727. fYunFileService.uploadFile(json.toJSONString().getBytes(), hourseTypeJsonPath);
  728. }
  729. }