소스 검색

feat:新增定时任务,定时同步对话记录

lihao16 4 달 전
부모
커밋
366788e828
1개의 변경된 파일30개의 추가작업 그리고 0개의 파일을 삭제
  1. 30 0
      smsb-modules/smsb-job/src/main/java/org/dromara/job/snailjob/SyncChatRecordExecutor.java

+ 30 - 0
smsb-modules/smsb-job/src/main/java/org/dromara/job/snailjob/SyncChatRecordExecutor.java

@@ -0,0 +1,30 @@
+package org.dromara.job.snailjob;
+
+import com.aizuda.snailjob.client.job.core.annotation.JobExecutor;
+import com.aizuda.snailjob.client.model.ExecuteResult;
+import com.aizuda.snailjob.common.log.SnailJobLog;
+import com.inspur.device.service.ISmsbDeviceChatRecordService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+
+/**
+ * 同步dify平台对话内容
+ *
+ * @author lihao16
+ */
+@Component
+@JobExecutor(name = "SyncChatRecord")
+public class SyncChatRecordExecutor {
+
+    @Autowired
+    private ISmsbDeviceChatRecordService smsbDeviceChatRecordService;
+
+    public ExecuteResult jobExecute() {
+        SnailJobLog.REMOTE.info("syncChatRecord job start...");
+        boolean syncResult = smsbDeviceChatRecordService.syncRecordFromDify();
+        SnailJobLog.REMOTE.info("syncChatRecord job end... syncResult = " + syncResult);
+        return ExecuteResult.success("syncChatRecord job execute success");
+    }
+
+}