Skip to content

A
amos-boot-biz
Commit f75162ab authored by chenzhao's avatar chenzhao
Browse files
Options

屏蔽原有健康指数算法输出的日志文件 过于占内存

parent 0bd4732c
Show whitespace changes
Inline Side-by-side
Showing with 84 additions and 84 deletions
amos-boot-system-jxiop/amos-boot-module-jxiop-analyse-biz/src/main/java/com/yeejoin/amos/boot/module/jxiop/biz/service/impl/CommonServiceImpl.java
View file @ f75162ab
......@@ -2008,16 +2008,16 @@ public class CommonServiceImpl {
requestMap.put("centerValue", centerValueList);
requestMap.put("analysisVariableId", analysisVariableIdList);
Table healthData = Table.create("healthData");
healthData.addColumns(DoubleColumn.create("analysisVariable", analysisVariable),
DoubleColumn.create("stdDev", stdDev), DoubleColumn.create("centerValue", centerValue),
StringColumn.create("ProcessPoint1Id", ProcessPoint1Id),
DoubleColumn.create("ProcessPoint1", ProcessPoint1),
StringColumn.create("ProcessPoint2Id", ProcessPoint2Id),
DoubleColumn.create("ProcessPoint2", ProcessPoint2),
StringColumn.create("ProcessPoint3Id", ProcessPoint3Id),
DoubleColumn.create("ProcessPoint3", ProcessPoint3),
StringColumn.create("analysisVariableId", analysisVariableIds));
// Table healthData = Table.create("healthData");
// healthData.addColumns(DoubleColumn.create("analysisVariable", analysisVariable),
// DoubleColumn.create("stdDev", stdDev), DoubleColumn.create("centerValue", centerValue),
// StringColumn.create("ProcessPoint1Id", ProcessPoint1Id),
// DoubleColumn.create("ProcessPoint1", ProcessPoint1),
// StringColumn.create("ProcessPoint2Id", ProcessPoint2Id),
// DoubleColumn.create("ProcessPoint2", ProcessPoint2),
// StringColumn.create("ProcessPoint3Id", ProcessPoint3Id),
// DoubleColumn.create("ProcessPoint3", ProcessPoint3),
// StringColumn.create("analysisVariableId", analysisVariableIds));
logger.info(
"------------------------------------------开始调用风机健康指数计算算法开始----------------------------------------");
logger.info("------------------------------------------调用地址:" + baseUrlZSFX);
......@@ -2031,14 +2031,14 @@ public class CommonServiceImpl {
JSONArray analysisVariableIdArray = jsonObject.getJSONArray("analysisVariableId");
List<String> jsonArrayToStringList = JSONObject.parseArray(analysisVariableIdArray.toJSONString(),
String.class);
List<Double> scoreValue = JSONObject.parseArray(scoreValueArray.toJSONString(), Double.class);
List<Double> indexValue = JSONObject.parseArray(indexValueArray.toJSONString(), Double.class);
// List<Double> scoreValue = JSONObject.parseArray(scoreValueArray.toJSONString(), Double.class);
// List<Double> indexValue = JSONObject.parseArray(indexValueArray.toJSONString(), Double.class);
// Table resultTable = Table.create("healthData");
healthData.addColumns(StringColumn.create("analysisVariableIdResult", jsonArrayToStringList),
DoubleColumn.create("indexValue", indexValue), DoubleColumn.create("scoreValue", scoreValue));
System.out.println(healthData.print());
// healthData.addColumns(StringColumn.create("analysisVariableIdResult", jsonArrayToStringList),
// DoubleColumn.create("indexValue", indexValue), DoubleColumn.create("scoreValue", scoreValue));
// System.out.println(healthData.print());
try {
healthData.write().csv(new Date().getTime() + "fj.csv");
// healthData.write().csv(new Date().getTime() + "fj.csv");
} catch (Exception e) {
e.printStackTrace();
......@@ -2306,17 +2306,17 @@ public class CommonServiceImpl {
requestMap.put("stdDev", stdDevList);
requestMap.put("centerValue", centerValueList);
requestMap.put("analysisVariableId", analysisVariableIdList);
Table healthData = Table.create("healthData");
healthData.addColumns(DoubleColumn.create("analysisVariable", analysisVariable),
DoubleColumn.create("stdDev", stdDev), DoubleColumn.create("centerValue", centerValue),
StringColumn.create("ProcessPoint1Id", ProcessPoint1Id),
DoubleColumn.create("ProcessPoint1", ProcessPoint1),
StringColumn.create("ProcessPoint2Id", ProcessPoint2Id),
DoubleColumn.create("ProcessPoint2", ProcessPoint2),
StringColumn.create("ProcessPoint3Id", ProcessPoint3Id),
DoubleColumn.create("ProcessPoint3", ProcessPoint3),
StringColumn.create("analysisVariableId", analysisVariableIds));
//
// Table healthData = Table.create("healthData");
// healthData.addColumns(DoubleColumn.create("analysisVariable", analysisVariable),
// DoubleColumn.create("stdDev", stdDev), DoubleColumn.create("centerValue", centerValue),
// StringColumn.create("ProcessPoint1Id", ProcessPoint1Id),
// DoubleColumn.create("ProcessPoint1", ProcessPoint1),
// StringColumn.create("ProcessPoint2Id", ProcessPoint2Id),
// DoubleColumn.create("ProcessPoint2", ProcessPoint2),
// StringColumn.create("ProcessPoint3Id", ProcessPoint3Id),
// DoubleColumn.create("ProcessPoint3", ProcessPoint3),
// StringColumn.create("analysisVariableId", analysisVariableIds));
logger.info(
"------------------------------------------开始调用风机健康指数计算算法开始----------------------------------------");
logger.info("------------------------------------------调用地址:" + baseUrlZSFX);
......@@ -2330,18 +2330,18 @@ public class CommonServiceImpl {
JSONArray analysisVariableIdArray = jsonObject.getJSONArray("analysisVariableId");
List<String> jsonArrayToStringList = JSONObject.parseArray(analysisVariableIdArray.toJSONString(),
String.class);
List<Double> scoreValue = JSONObject.parseArray(scoreValueArray.toJSONString(), Double.class);
List<Double> indexValue = JSONObject.parseArray(indexValueArray.toJSONString(), Double.class);
// Table resultTable = Table.create("healthData");
healthData.addColumns(StringColumn.create("analysisVariableIdResult", jsonArrayToStringList),
DoubleColumn.create("indexValue", indexValue), DoubleColumn.create("scoreValue", scoreValue));
System.out.println(healthData.print());
try {
healthData.write().csv(new Date().getTime() + "fj.csv");
} catch (Exception e) {
e.printStackTrace();
}
// List<Double> scoreValue = JSONObject.parseArray(scoreValueArray.toJSONString(), Double.class);
// List<Double> indexValue = JSONObject.parseArray(indexValueArray.toJSONString(), Double.class);
// // Table resultTable = Table.create("healthData");
// healthData.addColumns(StringColumn.create("analysisVariableIdResult", jsonArrayToStringList),
// DoubleColumn.create("indexValue", indexValue), DoubleColumn.create("scoreValue", scoreValue));
// System.out.println(healthData.print());
// try {
// healthData.write().csv(new Date().getTime() + "fj.csv");
//
// } catch (Exception e) {
// e.printStackTrace();
// }
LambdaQueryWrapper<IdxBizFanPointProcessVariableClassification> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.in(IdxBizFanPointProcessVariableClassification::getSequenceNbr, jsonArrayToStringList);
......@@ -2613,16 +2613,16 @@ public class CommonServiceImpl {
requestMap.put("centerValue", centerValueList);
requestMap.put("analysisVariableId", analysisVariableIdList);
Table healthData = Table.create("healthData");
healthData.addColumns(DoubleColumn.create("analysisVariable", analysisVariable),
DoubleColumn.create("stdDev", stdDev), DoubleColumn.create("centerValue", centerValue),
StringColumn.create("ProcessPoint1Id", ProcessPoint1Id),
DoubleColumn.create("ProcessPoint1", ProcessPoint1),
StringColumn.create("ProcessPoint2Id", ProcessPoint2Id),
DoubleColumn.create("ProcessPoint2", ProcessPoint2),
StringColumn.create("ProcessPoint3Id", ProcessPoint3Id),
DoubleColumn.create("ProcessPoint3", ProcessPoint3),
StringColumn.create("analysisVariableId", analysisVariableIds));
// Table healthData = Table.create("healthData");
// healthData.addColumns(DoubleColumn.create("analysisVariable", analysisVariable),
// DoubleColumn.create("stdDev", stdDev), DoubleColumn.create("centerValue", centerValue),
// StringColumn.create("ProcessPoint1Id", ProcessPoint1Id),
// DoubleColumn.create("ProcessPoint1", ProcessPoint1),
// StringColumn.create("ProcessPoint2Id", ProcessPoint2Id),
// DoubleColumn.create("ProcessPoint2", ProcessPoint2),
// StringColumn.create("ProcessPoint3Id", ProcessPoint3Id),
// DoubleColumn.create("ProcessPoint3", ProcessPoint3),
// StringColumn.create("analysisVariableId", analysisVariableIds));
logger.info(
"------------------------------------------开始调用光伏健康指数计算算法开始----------------------------------------");
logger.info("------------------------------------------调用地址:" + baseUrlZSFX);
......@@ -2635,18 +2635,18 @@ public class CommonServiceImpl {
JSONArray analysisVariableIdArray = jsonObject.getJSONArray("analysisVariableId");
List<String> jsonArrayToStringList = JSONObject.parseArray(analysisVariableIdArray.toJSONString(),
String.class);
List<Double> scoreValue = JSONObject.parseArray(scoreValueArray.toJSONString(), Double.class);
List<Double> indexValue = JSONObject.parseArray(indexValueArray.toJSONString(), Double.class);
// Table resultTable = Table.create("healthData");
healthData.addColumns(StringColumn.create("analysisVariableIdResult", jsonArrayToStringList),
DoubleColumn.create("indexValue", indexValue), DoubleColumn.create("scoreValue", scoreValue));
System.out.println(healthData.print());
try {
healthData.write().csv(new Date().getTime() + "gf.csv");
} catch (Exception e) {
e.printStackTrace();
}
// List<Double> scoreValue = JSONObject.parseArray(scoreValueArray.toJSONString(), Double.class);
// List<Double> indexValue = JSONObject.parseArray(indexValueArray.toJSONString(), Double.class);
// // Table resultTable = Table.create("healthData");
// healthData.addColumns(StringColumn.create("analysisVariableIdResult", jsonArrayToStringList),
// DoubleColumn.create("indexValue", indexValue), DoubleColumn.create("scoreValue", scoreValue));
// System.out.println(healthData.print());
// try {
// healthData.write().csv(new Date().getTime() + "gf.csv");
//
// } catch (Exception e) {
// e.printStackTrace();
// }
LambdaQueryWrapper<IdxBizPvPointProcessVariableClassification> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.in(IdxBizPvPointProcessVariableClassification::getSequenceNbr, jsonArrayToStringList);
......@@ -2876,17 +2876,17 @@ public class CommonServiceImpl {
requestMap.put("stdDev", stdDevList);
requestMap.put("centerValue", centerValueList);
requestMap.put("analysisVariableId", analysisVariableIdList);
Table healthData = Table.create("healthData");
healthData.addColumns(DoubleColumn.create("analysisVariable", analysisVariable),
DoubleColumn.create("stdDev", stdDev), DoubleColumn.create("centerValue", centerValue),
StringColumn.create("ProcessPoint1Id", ProcessPoint1Id),
DoubleColumn.create("ProcessPoint1", ProcessPoint1),
StringColumn.create("ProcessPoint2Id", ProcessPoint2Id),
DoubleColumn.create("ProcessPoint2", ProcessPoint2),
StringColumn.create("ProcessPoint3Id", ProcessPoint3Id),
DoubleColumn.create("ProcessPoint3", ProcessPoint3),
StringColumn.create("analysisVariableId", analysisVariableIds));
//
// Table healthData = Table.create("healthData");
// healthData.addColumns(DoubleColumn.create("analysisVariable", analysisVariable),
// DoubleColumn.create("stdDev", stdDev), DoubleColumn.create("centerValue", centerValue),
// StringColumn.create("ProcessPoint1Id", ProcessPoint1Id),
// DoubleColumn.create("ProcessPoint1", ProcessPoint1),
// StringColumn.create("ProcessPoint2Id", ProcessPoint2Id),
// DoubleColumn.create("ProcessPoint2", ProcessPoint2),
// StringColumn.create("ProcessPoint3Id", ProcessPoint3Id),
// DoubleColumn.create("ProcessPoint3", ProcessPoint3),
// StringColumn.create("analysisVariableId", analysisVariableIds));
logger.info(
"------------------------------------------开始调用光伏健康指数计算算法开始----------------------------------------");
logger.info("------------------------------------------调用地址:" + baseUrlZSFX);
......@@ -2899,18 +2899,18 @@ public class CommonServiceImpl {
JSONArray analysisVariableIdArray = jsonObject.getJSONArray("analysisVariableId");
List<String> jsonArrayToStringList = JSONObject.parseArray(analysisVariableIdArray.toJSONString(),
String.class);
List<Double> scoreValue = JSONObject.parseArray(scoreValueArray.toJSONString(), Double.class);
List<Double> indexValue = JSONObject.parseArray(indexValueArray.toJSONString(), Double.class);
// Table resultTable = Table.create("healthData");
healthData.addColumns(StringColumn.create("analysisVariableIdResult", jsonArrayToStringList),
DoubleColumn.create("indexValue", indexValue), DoubleColumn.create("scoreValue", scoreValue));
System.out.println(healthData.print());
try {
healthData.write().csv(new Date().getTime() + "gf.csv");
} catch (Exception e) {
e.printStackTrace();
}
// List<Double> scoreValue = JSONObject.parseArray(scoreValueArray.toJSONString(), Double.class);
// List<Double> indexValue = JSONObject.parseArray(indexValueArray.toJSONString(), Double.class);
// // Table resultTable = Table.create("healthData");
// healthData.addColumns(StringColumn.create("analysisVariableIdResult", jsonArrayToStringList),
// DoubleColumn.create("indexValue", indexValue), DoubleColumn.create("scoreValue", scoreValue));
// System.out.println(healthData.print());
// try {
// healthData.write().csv(new Date().getTime() + "gf.csv");
//
// } catch (Exception e) {
// e.printStackTrace();
// }
LambdaQueryWrapper<IdxBizPvPointProcessVariableClassification> queryWrapper = new LambdaQueryWrapper<>();
queryWrapper.in(IdxBizPvPointProcessVariableClassification::getSequenceNbr, jsonArrayToStringList);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment