|
@@ -146,7 +146,7 @@ public class KGraphTaskServiceImpl extends BaseServiceImpl<KGraphTaskMapper, KGr
|
|
|
}
|
|
|
String result;
|
|
|
JSONObject jsonObject;
|
|
|
- ExtraKGraphTaskVo extraKGraphTaskVo = new ExtraKGraphTaskVo();
|
|
|
+ ExtraKGraphTaskVo extraGraphTaskVo = new ExtraKGraphTaskVo();
|
|
|
switch (kGraphTaskBo.getTaskType()) {
|
|
|
case "0":
|
|
|
updateStatus(kGraphTaskBo, kGraphTaskVo.getVersion(), GraphStatus.STATUS_1.getCode());
|
|
@@ -166,9 +166,9 @@ public class KGraphTaskServiceImpl extends BaseServiceImpl<KGraphTaskMapper, KGr
|
|
|
KGraphClauseBo kGraphClauseBo = new KGraphClauseBo();
|
|
|
kGraphClauseBo.setTaskId(kGraphTaskBo.getId());
|
|
|
List<KGraphClauseVo> graphClauseVos = kGraphClauseService.selectList(kGraphClauseBo);
|
|
|
- extraKGraphTaskVo.setTaskId(kGraphTaskBo.getId());
|
|
|
- extraKGraphTaskVo.setGraphClauseList(graphClauseVos);
|
|
|
- result = HttpUtils.postJson(extractUrl, extraKGraphTaskVo);
|
|
|
+ extraGraphTaskVo.setTaskId(kGraphTaskBo.getId());
|
|
|
+ extraGraphTaskVo.setGraphClauseList(graphClauseVos);
|
|
|
+ result = HttpUtils.postJson(extractUrl, extraGraphTaskVo);
|
|
|
jsonObject = JSONUtil.parseObj(result);
|
|
|
if (!StrUtil.equals("200", jsonObject.getStr("code"))) {
|
|
|
throw new BusinessException(jsonObject.getStr("msg"));
|
|
@@ -180,10 +180,10 @@ public class KGraphTaskServiceImpl extends BaseServiceImpl<KGraphTaskMapper, KGr
|
|
|
updateStatus(kGraphTaskBo, kGraphTaskVo.getVersion(), GraphStatus.STATUS_5.getCode());
|
|
|
// 知识图谱入库
|
|
|
List<KGraphEntityVo> graphEntityVos = kGraphEntityService.selectListByTaskId(kGraphTaskBo.getId());
|
|
|
- extraKGraphTaskVo.setTaskId(kGraphTaskBo.getId());
|
|
|
- extraKGraphTaskVo.setOssId(ossId);
|
|
|
- extraKGraphTaskVo.setGraphEntityList(graphEntityVos);
|
|
|
- result = HttpUtils.postJson(storageUrl, extraKGraphTaskVo);
|
|
|
+ extraGraphTaskVo.setTaskId(kGraphTaskBo.getId());
|
|
|
+ extraGraphTaskVo.setOssId(ossId);
|
|
|
+ extraGraphTaskVo.setGraphEntityList(graphEntityVos);
|
|
|
+ result = HttpUtils.postJson(storageUrl, extraGraphTaskVo);
|
|
|
jsonObject = JSONUtil.parseObj(result);
|
|
|
if (!StrUtil.equals("200", jsonObject.getStr("code"))) {
|
|
|
throw new BusinessException(jsonObject.getStr("msg"));
|