统一修改包

zt-module-qms/pom.xml

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>dsc-qms</artifactId>
+        <groupId>com.zt.plat</groupId>
+        <version>${revision}</version>
+    </parent>
+    <modules>
+        <module>zt-module-qms-api</module>
+        <module>zt-module-qms-server</module>
+    </modules>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>cloud-module-qms</artifactId>
+    <packaging>pom</packaging>
+
+    <name>${project.artifactId}</name>
+    <description>
+        JyBusiness 模块。
+    </description>
+
+</project>

zt-module-qms/zt-module-qms-api/pom.xml

@@ -0,0 +1,46 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>cloud-module-qms</artifactId>
+        <groupId>com.zt.plat</groupId>
+        <version>${revision}</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>cloud-module-qms-api</artifactId>
+    <packaging>jar</packaging>
+
+    <name>${project.artifactId}</name>
+    <description>
+        暴露给其它模块调用
+    </description>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.zt.plat</groupId>
+            <artifactId>cloud-common</artifactId>
+        </dependency>
+        <!-- Web 相关 -->
+        <dependency>
+            <groupId>org.springdoc</groupId> <!-- 接口文档：使用最新版本的 Swagger 模型 -->
+            <artifactId>springdoc-openapi-starter-webmvc-api</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+        <!-- 参数校验 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+            <optional>true</optional>
+        </dependency>
+
+        <!-- RPC 远程调用相关 -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-openfeign</artifactId>
+            <optional>true</optional>
+        </dependency>
+    </dependencies>
+
+</project>

zt-module-qms/zt-module-qms-api/src/main/java/com/zt/plat/module/qms/api/task/QmsApi.java

@@ -0,0 +1,24 @@
+package com.zt.plat.module.qms.api.task;
+
+import com.zt.plat.framework.common.pojo.CommonResult;
+import com.zt.plat.module.qms.api.task.dto.QmsBpmDTO;
+import com.zt.plat.module.qms.enums.ApiConstants;
+import com.alibaba.fastjson.JSONObject;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.validation.Valid;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+@FeignClient(name = ApiConstants.NAME, fallbackFactory = QmsApiFallback.class)
+@Tag(name = "RPC 服务 - 检验检测")
+public interface QmsApi {
+
+    String PREFIX = ApiConstants.PREFIX + "/process-instance";
+
+    @PostMapping(PREFIX + "/updateQmdDataByWf")
+    @Operation(summary = "流程节点触发业务数据改变")
+    CommonResult<JSONObject> bpmCallback(@Valid @RequestBody QmsBpmDTO reqDTO);
+
+}

zt-module-qms/zt-module-qms-api/src/main/java/com/zt/plat/module/qms/api/task/QmsApiFallback.java

@@ -0,0 +1,18 @@
+package com.zt.plat.module.qms.api.task;
+
+import lombok.Setter;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.cloud.openfeign.FallbackFactory;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class QmsApiFallback implements FallbackFactory<QmsApi> {
+
+    @Setter private Throwable cause;
+    @Override
+    public QmsApi create(Throwable cause) {
+        log.error("QMS微服务接口调用失败：{}", cause.getMessage());
+        return null;
+    }
+}

zt-module-qms/zt-module-qms-api/src/main/java/com/zt/plat/module/qms/api/task/dto/QmsBpmDTO.java

@@ -0,0 +1,35 @@
+package com.zt.plat.module.qms.api.task.dto;
+
+import com.alibaba.fastjson.JSONObject;
+import io.swagger.v3.oas.annotations.media.Schema;
+import jakarta.validation.constraints.NotEmpty;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Schema(description = "RPC 服务 - 流程回调 Request DTO")
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class QmsBpmDTO {
+    @Schema(description = "流程实例ID", requiredMode = Schema.RequiredMode.REQUIRED)
+    @NotEmpty(message = "流程实例ID不能为空")
+    private String processInstanceId;
+
+    @Schema(description = "业务的唯一标识")
+    private String businessKey;
+
+    @Schema(description = "传入数据", requiredMode = Schema.RequiredMode.REQUIRED)
+    private JSONObject variables;
+
+    @Schema(description = "状态")
+    private String state;
+
+    /* variables，传入业务类型
+    {
+     "beanName": "dataFormService"
+
+    }
+    * */
+
+}

zt-module-qms/zt-module-qms-api/src/main/java/com/zt/plat/module/qms/enums/ApiConstants.java

@@ -0,0 +1,23 @@
+package com.zt.plat.module.qms.enums;
+
+import com.zt.plat.framework.common.enums.RpcConstants;
+
+/**
+ * API 相关的枚举
+ *
+ * @author ZT
+ */
+public class ApiConstants {
+
+    /**
+     * 服务名
+     *
+     * 注意，需要保证和 spring.application.name 保持一致
+     */
+    public static final String NAME = "qms-server";
+
+    public static final String PREFIX = RpcConstants.RPC_API_PREFIX + "/qms";
+
+    public static final String VERSION = "1.0.0";
+
+}

zt-module-qms/zt-module-qms-server/src/main/java/com/zt/plat/module/qms/QmsServerApplication.java

@@ -0,0 +1,16 @@
+package com.zt.plat.module.qms;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * 项目的启动类
+ */
+@SpringBootApplication
+public class QmsServerApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(QmsServerApplication.class, args);
+    }
+
+}