|
@@ -14,6 +14,7 @@ import org.springframework.amqp.core.Message;
|
|
|
import org.springframework.amqp.rabbit.annotation.Queue;
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
import java.io.File;
|
|
@@ -28,6 +29,8 @@ public class UpdateSceneStatusListener {
|
|
|
private FYunFileServiceInterface fYunFileService;
|
|
|
@Autowired
|
|
|
private ICommonService commonService;
|
|
|
+ @Value("${env:gn}")
|
|
|
+ private String env;
|
|
|
|
|
|
/**
|
|
|
* 更新场景status.json状态
|
|
@@ -51,7 +54,7 @@ public class UpdateSceneStatusListener {
|
|
|
jsonObject.put("status", status);
|
|
|
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);
|
|
|
- if(status == 1){
|
|
|
+ if("eur".equals(env) && status == 1){
|
|
|
commonService.sendEmail(num, "standar");
|
|
|
}
|
|
|
}catch (Exception e){
|