模型bugfix
This commit is contained in:
@@ -81,7 +81,8 @@ public class ModelsServiceImpl extends ServiceImpl<MachineLearningModelsMapper,
|
|||||||
String key = RedisUtils.getPrimaryKey(TableEnum.T_MACHINE_LEARNING_MODELS, id);
|
String key = RedisUtils.getPrimaryKey(TableEnum.T_MACHINE_LEARNING_MODELS, id);
|
||||||
machineLearningModels = redisManager.getByPrimaryKey(key, MachineLearningModels.class);
|
machineLearningModels = redisManager.getByPrimaryKey(key, MachineLearningModels.class);
|
||||||
} else {
|
} else {
|
||||||
machineLearningModels = this.selectById(id);
|
// machineLearningModels = this.selectById(id);
|
||||||
|
machineLearningModels = machineLearningModelsMapper.selectById(id);
|
||||||
}
|
}
|
||||||
|
|
||||||
return machineLearningModels;
|
return machineLearningModels;
|
||||||
|
|||||||
@@ -82,6 +82,7 @@ public class ModelNode implements EngineRunnerNode {
|
|||||||
|
|
||||||
Map<String, Object> input = new HashMap<>();
|
Map<String, Object> input = new HashMap<>();
|
||||||
String[] modelFieldArr = models.getModelField().split(",");
|
String[] modelFieldArr = models.getModelField().split(",");
|
||||||
|
// TODO mappingFieldArr 是 字段id t_field.id ,需要根据 id 取出 field_en
|
||||||
String[] mappingFieldArr = models.getMappingField().split(",");
|
String[] mappingFieldArr = models.getMappingField().split(",");
|
||||||
for (int i = 0; i < modelFieldArr.length; i++) {
|
for (int i = 0; i < modelFieldArr.length; i++) {
|
||||||
input.put(modelFieldArr[i], inputParam.get(mappingFieldArr[i]));
|
input.put(modelFieldArr[i], inputParam.get(mappingFieldArr[i]));
|
||||||
@@ -91,7 +92,7 @@ public class ModelNode implements EngineRunnerNode {
|
|||||||
try {
|
try {
|
||||||
modelResult =pmmlExecutor.predict(evaluator, input);
|
modelResult =pmmlExecutor.predict(evaluator, input);
|
||||||
}catch (Exception e){
|
}catch (Exception e){
|
||||||
logger.error("模型节点执行异常,node:{}",engineNode);
|
logger.error("模型节点执行异常,node:{}",engineNode,e);
|
||||||
}
|
}
|
||||||
JSONObject jsonObject = new JSONObject();
|
JSONObject jsonObject = new JSONObject();
|
||||||
jsonObject.put("nodeId", engineNode.getNodeId());
|
jsonObject.put("nodeId", engineNode.getNodeId());
|
||||||
|
|||||||
@@ -1 +1,64 @@
|
|||||||
spring.profiles.active=dev
|
# spring.profiles.active=dev
|
||||||
|
|
||||||
|
server.port=8071
|
||||||
|
|
||||||
|
logging.config=classpath:logging-config.xml
|
||||||
|
|
||||||
|
# mysql
|
||||||
|
spring.datasource.druid.url=jdbc:mysql://120.27.225.67:9609/riskmanage?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=utf-8&allowMultiQueries=true
|
||||||
|
spring.datasource.druid.username=riskmanage
|
||||||
|
spring.datasource.druid.password=riskmanage@Farben2023
|
||||||
|
spring.datasource.druid.driver-class-name=com.mysql.cj.jdbc.Driver
|
||||||
|
spring.datasource.druid.initialSize=20
|
||||||
|
spring.datasource.druid.minIdle=20
|
||||||
|
spring.datasource.druid.maxActive=100
|
||||||
|
spring.datasource.druid.maxWait=60000
|
||||||
|
spring.datasource.druid.timeBetweenEvictionRunsMillis=60000
|
||||||
|
spring.datasource.druid.minEvictableIdleTimeMillis=300000
|
||||||
|
spring.datasource.druid.testWhileIdle=true
|
||||||
|
spring.datasource.druid.testOnBorrow=true
|
||||||
|
spring.datasource.druid.testOnReturn=false
|
||||||
|
spring.datasource.druid.poolPreparedStatements=true
|
||||||
|
spring.datasource.druid.maxOpenPreparedStatements=20
|
||||||
|
spring.datasource.druid.validationQuery=SELECT 1
|
||||||
|
spring.datasource.druid.validation-query-timeout=500
|
||||||
|
spring.datasource.druid.filters=stat
|
||||||
|
|
||||||
|
# redis
|
||||||
|
redis.host=127.0.0.1
|
||||||
|
redis.port=6379
|
||||||
|
redis.db=0
|
||||||
|
redis.password=
|
||||||
|
redis.pool.maxTotal=3000
|
||||||
|
redis.pool.maxIdle=100
|
||||||
|
redis.pool.maxWait=1000
|
||||||
|
redis.pool.timeout=100000
|
||||||
|
|
||||||
|
# mail
|
||||||
|
spring.mail.host=smtp.exmail.qq.com
|
||||||
|
spring.mail.username=xxx
|
||||||
|
spring.mail.password=xxx
|
||||||
|
spring.mail.port=465
|
||||||
|
spring.mail.properties.mail.smtp.auth=true
|
||||||
|
spring.mail.properties.mail.smtp.timeout=50000
|
||||||
|
spring.mail.properties.mail.smtp.starttls.enable=true
|
||||||
|
spring.mail.properties.mail.smtp.socketFactory.port=465
|
||||||
|
spring.mail.properties.mail.smtp.socketFactory.class=javax.net.ssl.SSLSocketFactory
|
||||||
|
spring.mail.properties.mail.smtp.socketFactory.fallback=false
|
||||||
|
|
||||||
|
# hbase no use
|
||||||
|
spring.data.hbase.quorum:127.0.0.1
|
||||||
|
spring.data.hbase.rootDir: /usr/local/hbase/datatest
|
||||||
|
spring.data.hbase.nodeParent: /hbase
|
||||||
|
|
||||||
|
# canal
|
||||||
|
switch.use.cache=off
|
||||||
|
switch.canal.cache=off
|
||||||
|
canal.hostname=127.0.0.1
|
||||||
|
canal.port=11111
|
||||||
|
|
||||||
|
# monitor
|
||||||
|
monitor.data.storage.type=mysql
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user