|
@@ -2,6 +2,7 @@ package com.fdkankan.contro.mq.service.impl;
|
|
|
|
|
|
import cn.hutool.core.exceptions.ExceptionUtil;
|
|
import cn.hutool.core.exceptions.ExceptionUtil;
|
|
import cn.hutool.core.collection.CollUtil;
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
|
+import cn.hutool.core.io.FileUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
import cn.hutool.core.util.StrUtil;
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
@@ -122,9 +123,13 @@ public class BuildObjServiceImpl implements IBuildSceneService {
|
|
log.error("data.fdage文件不存在");
|
|
log.error("data.fdage文件不存在");
|
|
return ;
|
|
return ;
|
|
}
|
|
}
|
|
|
|
+ //下载资源到本地
|
|
|
|
+ this.downLoadSource(message, laserObjFilePath);
|
|
|
|
+
|
|
if (!jsonObject.containsKey("exportMeshObj") || jsonObject.getIntValue("exportMeshObj") != 1) {
|
|
if (!jsonObject.containsKey("exportMeshObj") || jsonObject.getIntValue("exportMeshObj") != 1) {
|
|
// 写入data.fdage 防止重算
|
|
// 写入data.fdage 防止重算
|
|
jsonObject.put("exportMeshObj", 1);
|
|
jsonObject.put("exportMeshObj", 1);
|
|
|
|
+ FileUtil.writeUtf8String(jsonObject.toJSONString(), laserObjFilePath + File.separator + "capture" + File.separator + "data.fdage");
|
|
fYunFileService.uploadFile(laserObjFilePath + File.separator + "capture" + File.separator + "data.fdage",
|
|
fYunFileService.uploadFile(laserObjFilePath + File.separator + "capture" + File.separator + "data.fdage",
|
|
ConstantFilePath.OSS_PREFIX + path.replace(ConstantFilePath.BUILD_MODEL_LASER_PATH, "") + "/data.fdage");
|
|
ConstantFilePath.OSS_PREFIX + path.replace(ConstantFilePath.BUILD_MODEL_LASER_PATH, "") + "/data.fdage");
|
|
}
|
|
}
|
|
@@ -138,9 +143,6 @@ public class BuildObjServiceImpl implements IBuildSceneService {
|
|
message.setPath(laserObjFilePath);
|
|
message.setPath(laserObjFilePath);
|
|
message.setResultReceiverMqName(queueObjModelingPost);
|
|
message.setResultReceiverMqName(queueObjModelingPost);
|
|
|
|
|
|
- //下载资源到本地
|
|
|
|
- this.downLoadSource(message, laserObjFilePath);
|
|
|
|
-
|
|
|
|
//发送mq,就进行计算
|
|
//发送mq,就进行计算
|
|
mqProducer.sendByWorkQueue(queueModelingCall, message);
|
|
mqProducer.sendByWorkQueue(queueModelingCall, message);
|
|
|
|
|