From 7d9455d70e0479a521f9aeb7048e936179b23ee5 Mon Sep 17 00:00:00 2001
From: "1437892690@qq.com" <1437892690@qq.com>
Date: Fri, 2 Aug 2024 21:35:50 +0800
Subject: [PATCH 1/3] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20IT=E6=9C=8D=E5=8A=A1?=
=?UTF-8?q?-=E5=A2=9E=E5=8A=A0=E5=9F=BA=E4=BA=8E=E9=98=9F=E5=88=97?=
=?UTF-8?q?=E7=9A=84=E5=BC=82=E6=AD=A5=E4=B8=8A=E6=8A=A5=E5=B7=A5=E5=8D=95?=
=?UTF-8?q?=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
关联 #[1212437796192256]IT服务-增加基于队列的异步上报工单方式 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1212437796192256
---
...ProcessTaskAsyncCreateCrossoverMapper.java | 26 ++++
...rocessTaskAsyncCreateCrossoverService.java | 31 +++++
.../process/dto/ProcessTaskAsyncCreateVo.java | 125 ++++++++++++++++++
3 files changed, 182 insertions(+)
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverMapper.java
create mode 100644 src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
create mode 100644 src/main/java/neatlogic/framework/process/dto/ProcessTaskAsyncCreateVo.java
diff --git a/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverMapper.java b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverMapper.java
new file mode 100644
index 00000000..d1e62532
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverMapper.java
@@ -0,0 +1,26 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
+import neatlogic.framework.process.dto.ProcessTaskAsyncCreateVo;
+
+public interface IProcessTaskAsyncCreateCrossoverMapper extends ICrossoverService {
+
+ int insertProcessTaskAsyncCreate(ProcessTaskAsyncCreateVo processTaskAsyncCreateVo);
+}
diff --git a/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
new file mode 100644
index 00000000..6b04224e
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
@@ -0,0 +1,31 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.crossover;
+
+import neatlogic.framework.crossover.ICrossoverService;
+import neatlogic.framework.process.dto.ProcessTaskAsyncCreateVo;
+
+public interface IProcessTaskAsyncCreateCrossoverService extends ICrossoverService {
+
+ /**
+ * 添加新的工单信息到阻塞队列
+ * @param processTaskAsyncCreateVo
+ * @throws InterruptedException
+ */
+ void addNewProcessTaskAsyncCreate(ProcessTaskAsyncCreateVo processTaskAsyncCreateVo) throws InterruptedException;
+}
diff --git a/src/main/java/neatlogic/framework/process/dto/ProcessTaskAsyncCreateVo.java b/src/main/java/neatlogic/framework/process/dto/ProcessTaskAsyncCreateVo.java
new file mode 100644
index 00000000..98a6fc72
--- /dev/null
+++ b/src/main/java/neatlogic/framework/process/dto/ProcessTaskAsyncCreateVo.java
@@ -0,0 +1,125 @@
+/*
+ * Copyright (C) 2024 深圳极向量科技有限公司 All Rights Reserved.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program. If not, see .
+ */
+
+package neatlogic.framework.process.dto;
+
+import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.annotation.JSONField;
+import neatlogic.framework.common.dto.BaseEditorVo;
+import neatlogic.framework.util.SnowflakeUtil;
+
+public class ProcessTaskAsyncCreateVo extends BaseEditorVo {
+ private Long id;
+ private Long processTaskId;
+ private String title;
+ private String status;
+ private String error;
+ private Integer serverId;
+ private JSONObject config;
+ @JSONField(serialize = false)
+ private String configStr;
+
+ private String tenantUuid;
+
+ public ProcessTaskAsyncCreateVo() {}
+
+ public ProcessTaskAsyncCreateVo(JSONObject config) {
+ this.config = config;
+ }
+
+ public Long getId() {
+ if (id == null) {
+ id = SnowflakeUtil.uniqueLong();
+ }
+ return id;
+ }
+
+ public void setId(Long id) {
+ this.id = id;
+ }
+
+ public Long getProcessTaskId() {
+ return processTaskId;
+ }
+
+ public void setProcessTaskId(Long processTaskId) {
+ this.processTaskId = processTaskId;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+
+ public String getStatus() {
+ return status;
+ }
+
+ public void setStatus(String status) {
+ this.status = status;
+ }
+
+ public String getError() {
+ return error;
+ }
+
+ public void setError(String error) {
+ this.error = error;
+ }
+
+ public Integer getServerId() {
+ return serverId;
+ }
+
+ public void setServerId(Integer serverId) {
+ this.serverId = serverId;
+ }
+
+ public JSONObject getConfig() {
+ if (config == null && configStr != null) {
+ config = JSONObject.parseObject(configStr);
+ }
+ return config;
+ }
+
+ public void setConfig(JSONObject config) {
+ this.config = config;
+ }
+
+ public String getConfigStr() {
+ if (configStr == null && config != null) {
+ configStr = config.toJSONString();
+ }
+ return configStr;
+ }
+
+ public void setConfigStr(String configStr) {
+ this.configStr = configStr;
+ }
+
+ @Override
+ public String getTenantUuid() {
+ return tenantUuid;
+ }
+
+ public void setTenantUuid(String tenantUuid) {
+ this.tenantUuid = tenantUuid;
+ }
+}
--
Gitee
From dc2545f8c97088533259ec75c35286639669c7de Mon Sep 17 00:00:00 2001
From: "1437892690@qq.com" <1437892690@qq.com>
Date: Sat, 3 Aug 2024 01:36:49 +0800
Subject: [PATCH 2/3] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20IT=E6=9C=8D=E5=8A=A1?=
=?UTF-8?q?-=E5=A2=9E=E5=8A=A0=E5=9F=BA=E4=BA=8E=E9=98=9F=E5=88=97?=
=?UTF-8?q?=E7=9A=84=E5=BC=82=E6=AD=A5=E4=B8=8A=E6=8A=A5=E5=B7=A5=E5=8D=95?=
=?UTF-8?q?=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
关联 #[1212437796192256]IT服务-增加基于队列的异步上报工单方式 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1212437796192256
---
.../crossover/IProcessTaskAsyncCreateCrossoverService.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
index 6b04224e..f788c19a 100644
--- a/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
@@ -27,5 +27,5 @@ public interface IProcessTaskAsyncCreateCrossoverService extends ICrossoverServi
* @param processTaskAsyncCreateVo
* @throws InterruptedException
*/
- void addNewProcessTaskAsyncCreate(ProcessTaskAsyncCreateVo processTaskAsyncCreateVo) throws InterruptedException;
+ Long addNewProcessTaskAsyncCreate(ProcessTaskAsyncCreateVo processTaskAsyncCreateVo) throws InterruptedException;
}
--
Gitee
From bd7f6258faf46b1577cec9b414874bd29ec06783 Mon Sep 17 00:00:00 2001
From: "1437892690@qq.com" <1437892690@qq.com>
Date: Sat, 3 Aug 2024 18:05:46 +0800
Subject: [PATCH 3/3] =?UTF-8?q?[=E5=8A=9F=E8=83=BD]=20IT=E6=9C=8D=E5=8A=A1?=
=?UTF-8?q?-=E5=A2=9E=E5=8A=A0=E5=9F=BA=E4=BA=8E=E9=98=9F=E5=88=97?=
=?UTF-8?q?=E7=9A=84=E5=BC=82=E6=AD=A5=E4=B8=8A=E6=8A=A5=E5=B7=A5=E5=8D=95?=
=?UTF-8?q?=E6=96=B9=E5=BC=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
关联 #[1212437796192256]IT服务-增加基于队列的异步上报工单方式 http://192.168.0.96:8090/demo/rdm.html#/story-detail/939050947543040/939050947543042/1212437796192256
---
.../crossover/IProcessTaskAsyncCreateCrossoverService.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
index f788c19a..4afe0ee9 100644
--- a/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
+++ b/src/main/java/neatlogic/framework/process/crossover/IProcessTaskAsyncCreateCrossoverService.java
@@ -25,7 +25,6 @@ public interface IProcessTaskAsyncCreateCrossoverService extends ICrossoverServi
/**
* 添加新的工单信息到阻塞队列
* @param processTaskAsyncCreateVo
- * @throws InterruptedException
*/
- Long addNewProcessTaskAsyncCreate(ProcessTaskAsyncCreateVo processTaskAsyncCreateVo) throws InterruptedException;
+ Long addNewProcessTaskAsyncCreate(ProcessTaskAsyncCreateVo processTaskAsyncCreateVo);
}
--
Gitee