|
|
@@ -1,8 +1,11 @@
|
|
|
package com.fdkankan.contro.mq.listener;
|
|
|
|
|
|
+import cn.hutool.core.io.FileUtil;
|
|
|
import com.alibaba.fastjson.JSON;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.fdkankan.common.util.FileUtils;
|
|
|
import com.fdkankan.fyun.face.FYunFileServiceInterface;
|
|
|
+import com.fdkankan.model.constants.ConstantFilePath;
|
|
|
import com.fdkankan.model.constants.UploadFilePath;
|
|
|
import com.rabbitmq.client.Channel;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
@@ -12,6 +15,7 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
+import java.io.File;
|
|
|
import java.nio.charset.StandardCharsets;
|
|
|
import java.util.HashMap;
|
|
|
|
|
|
@@ -43,7 +47,8 @@ public class UpdateSceneStatusListener {
|
|
|
String fileContent = fYunFileService.getFileContent(statusJsonPath);
|
|
|
JSONObject jsonObject = JSON.parseObject(fileContent);
|
|
|
jsonObject.put("status", status);
|
|
|
- fYunFileService.uploadFile(jsonObject.toJSONString().getBytes(), statusJsonPath);
|
|
|
+ FileUtil.writeUtf8String(jsonObject.toJSONString(),ConstantFilePath.SCENE_PATH + "data/data" + num + File.separator + "status.json");
|
|
|
+ fYunFileService.uploadFile(ConstantFilePath.SCENE_PATH + "data/data" + num + File.separator + "status.json", statusJsonPath);
|
|
|
}catch (Exception e){
|
|
|
log.error("更新场景的的status.json状态, content:{}", msg, e);
|
|
|
}finally {
|
