diff --git a/doc/db/tables_xxl_job.sql b/doc/db/tables_xxl_job.sql index 9a045a41..7cb49429 100644 --- a/doc/db/tables_xxl_job.sql +++ b/doc/db/tables_xxl_job.sql @@ -145,13 +145,22 @@ INSERT INTO `xxl_job_info`(`id`, `job_group`, `job_desc`, `add_time`, `update_ti `child_jobid`) VALUES (1, 1, '示例任务01', now(), now(), 'XXL', '', 'CRON', '0 0 0 * * ? *', 'DO_NOTHING', 'FIRST', 'demoJobHandler', '', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', - '2018-11-03 22:21:31', ''), - (2, 2, 'Ollama示例任务01', now(), now(), 'XXL', '', 'CRON', '0 0 0 * * ? *', + now(), ''), + (2, 2, 'Ollama示例任务01', now(), now(), 'XXL', '', 'NONE', '', 'DO_NOTHING', 'FIRST', 'ollamaJobHandler', '{ "input": "慢SQL问题分析思路", "prompt": "你是一个研发工程师,擅长解决技术类问题。" }', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', - '2018-11-03 22:21:31', ''); + now(), ''), + (3, 2, 'Dify示例任务', now(), now(), 'XXL', '', 'NONE', '', + 'DO_NOTHING', 'FIRST', 'difyWorkflowJobHandler', '{ + "inputs":{ + "input":"查询班级各学科前三名" + }, + "user": "xxl-job" +}', 'SERIAL_EXECUTION', 0, 0, 'BEAN', '', 'GLUE代码初始化', + now(), '') + ; INSERT INTO `xxl_job_user`(`id`, `username`, `password`, `role`, `permission`) VALUES (1, 'admin', 'e10adc3949ba59abbe56e057f20f883e', 1, NULL); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot-ai/src/main/java/com/xxl/job/executor/jobhandler/AIXxlJob.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot-ai/src/main/java/com/xxl/job/executor/jobhandler/AIXxlJob.java index 115b2266..aadb7a8f 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot-ai/src/main/java/com/xxl/job/executor/jobhandler/AIXxlJob.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot-ai/src/main/java/com/xxl/job/executor/jobhandler/AIXxlJob.java @@ -64,7 +64,7 @@ public class AIXxlJob { return; } } catch (Exception e) { - XxlJobHelper.log(e); + XxlJobHelper.log(new RuntimeException("OllamaParam parse error", e)); XxlJobHelper.handleFail(); return; } @@ -144,7 +144,7 @@ public class AIXxlJob { difyParam.setUser("xxl-job"); } } catch (Exception e) { - XxlJobHelper.log(e); + XxlJobHelper.log(new RuntimeException("DifyParam parse error", e)); XxlJobHelper.handleFail(); return; }