|
|
|
|
|
package com.anjiplus.template.gaea.business.modules.dataset.service.impl;
|
|
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
import com.alibaba.fastjson.JSONArray;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import com.anji.plus.gaea.constant.Enabled;
|
...
|
...
|
@@ -41,10 +42,10 @@ import java.util.Map; |
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
* @desc DataSet 数据集服务实现
|
|
|
* @author Raod
|
|
|
* @date 2021-03-18 12:11:31.150755900
|
|
|
**/
|
|
|
* @desc DataSet 数据集服务实现
|
|
|
* @author Raod
|
|
|
* @date 2021-03-18 12:11:31.150755900
|
|
|
**/
|
|
|
@Service
|
|
|
//@RequiredArgsConstructor
|
|
|
@Slf4j
|
...
|
...
|
@@ -64,7 +65,7 @@ public class DataSetServiceImpl implements DataSetService { |
|
|
|
|
|
@Override
|
|
|
public GaeaBaseMapper<DataSet> getMapper() {
|
|
|
return dataSetMapper;
|
|
|
return dataSetMapper;
|
|
|
}
|
|
|
|
|
|
/**
|
...
|
...
|
@@ -115,9 +116,9 @@ public class DataSetServiceImpl implements DataSetService { |
|
|
|
|
|
List<DataSetTransform> dataSetTransformList = dataSetTransformService.list(
|
|
|
new QueryWrapper<DataSetTransform>()
|
|
|
.lambda()
|
|
|
.eq(DataSetTransform::getSetCode, setCode)
|
|
|
.orderByAsc(DataSetTransform::getOrderNum)
|
|
|
.lambda()
|
|
|
.eq(DataSetTransform::getSetCode, setCode)
|
|
|
.orderByAsc(DataSetTransform::getOrderNum)
|
|
|
);
|
|
|
List<DataSetTransformDto> dataSetTransformDtoList = new ArrayList<>();
|
|
|
dataSetTransformList.forEach(dataSetTransform -> {
|
...
|
...
|
@@ -129,8 +130,23 @@ public class DataSetServiceImpl implements DataSetService { |
|
|
|
|
|
if (StringUtils.isNotBlank(dto.getCaseResult())) {
|
|
|
try {
|
|
|
JSONArray jsonArray = JSONArray.parseArray(dto.getCaseResult());
|
|
|
JSONObject jsonObject = jsonArray.getJSONObject(0);
|
|
|
String caseResult = dto.getCaseResult();
|
|
|
boolean isObj = JSONUtil.isJsonObj(caseResult);
|
|
|
JSONArray jsonArray = null;
|
|
|
JSONObject jsonObject = null;
|
|
|
if(isObj){
|
|
|
JSONObject result = JSONObject.parseObject(caseResult);
|
|
|
Object data = result.get("data");
|
|
|
if (data instanceof JSONObject) {
|
|
|
jsonObject = (JSONObject)data;
|
|
|
} else {
|
|
|
jsonArray = jsonObject.getJSONArray("data");
|
|
|
jsonObject = jsonArray.getJSONObject(0);
|
|
|
}
|
|
|
} else {
|
|
|
jsonArray = JSONArray.parseArray(caseResult);
|
|
|
jsonObject = jsonArray.getJSONObject(0);
|
|
|
}
|
|
|
dto.setSetParamList(jsonObject.keySet());
|
|
|
} catch (Exception e) {
|
|
|
log.error("error",e);
|
...
|
...
|
@@ -299,7 +315,7 @@ public class DataSetServiceImpl implements DataSetService { |
|
|
}
|
|
|
|
|
|
}else {
|
|
|
dataSource = dataSourceService.selectOne("source_code", sourceCode);
|
|
|
dataSource = dataSourceService.selectOne("source_code", sourceCode);
|
|
|
}
|
|
|
|
|
|
//3.参数替换
|
...
|
...
|
|