admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

特邀发言官代码编写

Browse Source
This commit is contained in:
lxu75
2025-06-06 16:51:13 +08:00
parent bf43b9647f
commit 32f9659bd3
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/SpokesManService.java
View File

@@ -7,7 +7,6 @@ import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.huaweicloud.sdk.eg.v1.model.CloudEvents; import com.huaweicloud.sdk.eg.v1.model.CloudEvents;
import com.volvo.ai.analytic.center.dto.req.DiFyReq; import com.volvo.ai.analytic.center.dto.req.DiFyReq;
import com.volvo.ai.analytic.center.dto.req.DifyCommunityTargetDTO;
import com.volvo.ai.analytic.center.dto.req.DifyImageWorkFlow; import com.volvo.ai.analytic.center.dto.req.DifyImageWorkFlow;
import com.volvo.ai.analytic.center.dto.req.SpokesManDTO; import com.volvo.ai.analytic.center.dto.req.SpokesManDTO;
import com.volvo.ai.analytic.center.entity.AiAnalysisErrors; import com.volvo.ai.analytic.center.entity.AiAnalysisErrors;
@@ -53,8 +52,11 @@ public class SpokesManService {
@Value("${dify.spokesMan.token}") @Value("${dify.spokesMan.token}")
private String spokesManToken; private String spokesManToken;
@Value("${dify.spokesMan.channel}") @Value("${huawei.cloud.EG.spokesMan.channelId}")
private String channel; private String channelId;
@Value("${huawei.cloud.EG.spokesMan.sourceId}")
private String sourceId;
/** /**
* 处理社区特邀发言官回调请求 * 处理社区特邀发言官回调请求
@@ -123,7 +125,11 @@ public class SpokesManService {
//发送事件网格 //发送事件网格
CloudEvents cloudEvents = new CloudEvents(); CloudEvents cloudEvents = new CloudEvents();
cloudEvents.setData(difSpokesManResult); cloudEvents.setData(difSpokesManResult);
huaWeiEGService.sendEvent(cloudEvents, channel); cloudEvents.setSource(sourceId);
cloudEvents.setSpecversion("3.1.51");
cloudEvents.setType("ai-analytic-center");
cloudEvents.setId(aiAnalysisRequestId);
huaWeiEGService.sendEvent(cloudEvents, channelId);
//异步更新dify响应日志 //异步更新dify响应日志
syncUpdateDiFyResponse(difSpokesManResult, aiAnalysisRequestId); syncUpdateDiFyResponse(difSpokesManResult, aiAnalysisRequestId);
} catch (Exception e) { } catch (Exception e) {