test-version22
/
MeterSphere
mirror of https://gitee.com/fit2cloud-feizhiyun/MeterSphere.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix(接口测试): 修复场景后置脚本设置环境变量失败的缺陷 

--bug=1026136 --user=王孝刚 【接口测试】场景后置脚本设置环境变量失败#24364也提了同类问题获取list失败
https://www.tapd.cn/55049933/s/1371292
This commit is contained in:
wxg0103 2023-05-15 18:44:53 +08:00 committed by fit2-zhao
parent 738c01ecd4
commit d559f5c489
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
api-test/backend/src/main/java/io/metersphere/api/jmeter/KafkaListenerTask.java
View File

@ -45,6 +45,9 @@ public class KafkaListenerTask implements Runnable {
}}; }};
public static final String ENV = "ENV";
@Override @Override
public void run() { public void run() {
try { try {
@ -58,7 +61,9 @@ public class KafkaListenerTask implements Runnable {
// 分三类存储 // 分三类存储
Map<String, List<ResultDTO>> assortMap = new LinkedHashMap<>(); Map<String, List<ResultDTO>> assortMap = new LinkedHashMap<>();
// 携带结果 // 携带结果
if (CollectionUtils.isNotEmpty(dto.getRequestResults())) { if (CollectionUtils.isNotEmpty(dto.getRequestResults()) ||
(MapUtils.isNotEmpty(dto.getArbitraryData()) &&
dto.getArbitraryData().containsKey(ENV))) {
String key = RUN_MODE_MAP.get(dto.getRunMode()); String key = RUN_MODE_MAP.get(dto.getRunMode());
if (assortMap.containsKey(key)) { if (assortMap.containsKey(key)) {
assortMap.get(key).add(dto); assortMap.get(key).add(dto);
@ -68,7 +73,6 @@ public class KafkaListenerTask implements Runnable {
}}); }});
} }
} }
if (MapUtils.isNotEmpty(assortMap)) { if (MapUtils.isNotEmpty(assortMap)) {
testResultService.batchSaveResults(assortMap); testResultService.batchSaveResults(assortMap);
} }