From 99c409e5ce4e1e5c69d04a67cdbd0073cd9ec8e4 Mon Sep 17 00:00:00 2001 From: xudawei Date: Fri, 9 Aug 2024 11:13:09 +0800 Subject: [PATCH 1/4] =?UTF-8?q?[REQ-2348]=20=E5=88=9B=E5=BB=BA=E5=B7=A5?= =?UTF-8?q?=E7=A8=8B=E7=9B=91=E6=8E=A7MQ=E5=8A=A0=E4=B8=8A=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/event/workspace/CreateEngineeringProjectHandler.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/workspace/CreateEngineeringProjectHandler.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/workspace/CreateEngineeringProjectHandler.java index 8fe4860f..a925e8e9 100644 --- a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/workspace/CreateEngineeringProjectHandler.java +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/workspace/CreateEngineeringProjectHandler.java @@ -31,9 +31,11 @@ public class CreateEngineeringProjectHandler implements EventHandler, Initializi log.info("CreateEngineeringProjectHandler-start mq,eventModule:{},eventName:{}, event:{}", event.getEventCode().getModule(), event.getEventCode().getName(), JSON.toJSONString(event)); //解析数据 String data = (String)event.getData(); + log.info("CreateEngineeringProjectHandler replace before data,data:{}", data); if (data.contains("\\\"")) { data = data.replaceAll("\\\\\"", "\\\""); } + log.info("CreateEngineeringProjectHandler replace after data,data:{}", data); CreateProjectMsgVO createProjectMsgVO1 = JSON.parseObject(JSON.toJSONString(data), CreateProjectMsgVO.class); // CreateProjectMsgVO createProjectMsgVO = event.normalizedData(CreateProjectMsgVO.class); From e4089381c20b01a62177beb67940720dfb0e8a3e Mon Sep 17 00:00:00 2001 From: xudawei Date: Fri, 9 Aug 2024 11:50:39 +0800 Subject: [PATCH 2/4] =?UTF-8?q?[REQ-2348]=20=E5=88=9B=E5=BB=BA=E5=B7=A5?= =?UTF-8?q?=E7=A8=8B=E7=9B=91=E6=8E=A7MQ=E5=8A=A0=E4=B8=8A=E6=97=A5?= =?UTF-8?q?=E5=BF=97=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../event/workspace/CreateEngineeringProjectHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/workspace/CreateEngineeringProjectHandler.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/workspace/CreateEngineeringProjectHandler.java index a925e8e9..d5ad8a24 100644 --- a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/workspace/CreateEngineeringProjectHandler.java +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/workspace/CreateEngineeringProjectHandler.java @@ -36,7 +36,7 @@ public class CreateEngineeringProjectHandler implements EventHandler, Initializi data = data.replaceAll("\\\\\"", "\\\""); } log.info("CreateEngineeringProjectHandler replace after data,data:{}", data); - CreateProjectMsgVO createProjectMsgVO1 = JSON.parseObject(JSON.toJSONString(data), CreateProjectMsgVO.class); + CreateProjectMsgVO createProjectMsgVO1 = JSON.parseObject(data, CreateProjectMsgVO.class); // CreateProjectMsgVO createProjectMsgVO = event.normalizedData(CreateProjectMsgVO.class); log.info("CreateEngineeringProjectHandler,createProjectMsgVO:{}", JSON.toJSONString(createProjectMsgVO1)); @@ -50,11 +50,11 @@ public class CreateEngineeringProjectHandler implements EventHandler, Initializi } public static void main(String[] args) { - String str = "{\\\"categoryCode\\\":\\\"1000000000\\\",\\\"projectId\\\":722,\\\"projectName\\\":\\\"4\\\",\\\"saasTenantId\\\":174,\\\"singleCodes\\\":[\\\"1010000000\\\"],\\\"workspaceId\\\":442}"; + String str = "{\"categoryCode\":\"1000000000\",\"projectId\":731,\"projectName\":\"6\",\"saasTenantId\":174,\"singleCodes\":[\"1010000000\"],\"workspaceId\":442}"; if (str.contains("\\\"")) { str = str.replaceAll("\\\\\"", "\\\""); } - JSONObject evenJSON = JSONObject.parseObject(str); + CreateProjectMsgVO evenJSON = JSONObject.parseObject(str,CreateProjectMsgVO.class); System.out.println("evenJSON = " + evenJSON); } } From bc7d11ce77fc3ef66701e54e7fe3e2670e56a712 Mon Sep 17 00:00:00 2001 From: chenwenjian Date: Fri, 9 Aug 2024 17:19:36 +0800 Subject: [PATCH 3/4] =?UTF-8?q?feat(REQ-2348):=20=E5=88=9B=E5=BB=BA?= =?UTF-8?q?=E6=96=BD=E5=B7=A5=E5=8C=BA=E5=9F=9F=E5=92=8C=E4=B8=8A=E4=BC=A0?= =?UTF-8?q?=E4=BA=A4=E5=BA=95=E6=93=8D=E4=BD=9C=E7=8A=B6=E6=80=81=E5=8F=98?= =?UTF-8?q?=E6=9B=B4=E7=9B=91=E5=90=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../config/RocketMQEventConfiguration.java | 47 ++++++++++++- .../GuideTenantProcedureStatusUpdateReq.java | 6 ++ .../server/enums/GuideProcedureEnum.java | 70 +++++++++++++++++++ .../AbstractTenantProcedureStatusHandler.java | 37 ++++++++++ .../event/apollo/ConstructionAreaHandler.java | 44 ++++++++++++ .../data_collection/DisclosureHandler.java | 43 ++++++++++++ .../server/event/enums/MQEventEnum.java | 4 ++ .../payload/ConstructionAreaPayload.java | 30 ++++++++ .../event/payload/DisclosurePayload.java | 49 +++++++++++++ ...GuideTenantProcedureStatusServiceImpl.java | 7 +- 10 files changed, 334 insertions(+), 3 deletions(-) create mode 100644 op/op-server/src/main/java/cn/axzo/nanopart/server/enums/GuideProcedureEnum.java create mode 100644 op/op-server/src/main/java/cn/axzo/nanopart/server/event/AbstractTenantProcedureStatusHandler.java create mode 100644 op/op-server/src/main/java/cn/axzo/nanopart/server/event/apollo/ConstructionAreaHandler.java create mode 100644 op/op-server/src/main/java/cn/axzo/nanopart/server/event/data_collection/DisclosureHandler.java create mode 100644 op/op-server/src/main/java/cn/axzo/nanopart/server/event/payload/ConstructionAreaPayload.java create mode 100644 op/op-server/src/main/java/cn/axzo/nanopart/server/event/payload/DisclosurePayload.java diff --git a/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java b/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java index ca40d03a..6a9beccc 100644 --- a/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java +++ b/nanopart-server/src/main/java/cn/axzo/nanopart/config/RocketMQEventConfiguration.java @@ -6,7 +6,6 @@ import cn.axzo.framework.rocketmq.EventConsumer; import cn.axzo.framework.rocketmq.EventHandlerRepository; import cn.axzo.framework.rocketmq.EventProducer; import cn.axzo.framework.rocketmq.RocketMQEventProducer; -import cn.axzo.nanopart.server.event.workspace.WorkerJoinWorkspaceHandler; import com.alibaba.fastjson.JSON; import lombok.extern.slf4j.Slf4j; import org.apache.rocketmq.common.message.MessageExt; @@ -36,9 +35,10 @@ public class RocketMQEventConfiguration { private String topic; @Bean - public RocketMQTemplate ser(){ + public RocketMQTemplate ser() { return new RocketMQTemplate(); } + @Bean EventProducer eventProducer(RocketMQTemplate rocketMQTemplate) { return new RocketMQEventProducer(rocketMQTemplate, @@ -177,4 +177,47 @@ public class RocketMQEventConfiguration { super.onEvent(message, eventConsumer); } } + + /** + * 创建施工区域 + */ + @Slf4j + @Component + @RocketMQMessageListener(topic = "topic_construction_area_${spring.profiles.active]", + consumerGroup = "GID_construction_area_${spring.application.name}_${spring.profiles.active}", + consumeMode = ConsumeMode.ORDERLY, + nameServer = "${rocketmq.name-server}") + public static class ConstructionAreaListener extends BaseListener implements RocketMQListener { + + @Autowired + private EventConsumer eventConsumer; + + @Override + public void onMessage(MessageExt message) { + log.info("ConstructionAreaListener onMessage nanopart, message:{}", JSON.toJSONString(message)); + super.onEvent(message, eventConsumer); + } + } + + /** + * 上传交底 + */ + @Slf4j + @Component + @RocketMQMessageListener(topic = "topic_disclosure_${spring.profiles.active}", + consumerGroup = "GID_disclosure_${spring.application.name}_${spring.profiles.active}", + consumeMode = ConsumeMode.ORDERLY, + nameServer = "${rocketmq.name-server}" + ) + public static class DisclosureListener extends BaseListener implements RocketMQListener { + + @Autowired + private EventConsumer eventConsumer; + + @Override + public void onMessage(MessageExt message) { + log.info("DisclosureListener onMessage nanopart, message:{}", JSON.toJSONString(message)); + super.onEvent(message, eventConsumer); + } + } } diff --git a/op/op-api/src/main/java/cn/axzo/op/api/request/GuideTenantProcedureStatusUpdateReq.java b/op/op-api/src/main/java/cn/axzo/op/api/request/GuideTenantProcedureStatusUpdateReq.java index f5052bef..7aae3203 100644 --- a/op/op-api/src/main/java/cn/axzo/op/api/request/GuideTenantProcedureStatusUpdateReq.java +++ b/op/op-api/src/main/java/cn/axzo/op/api/request/GuideTenantProcedureStatusUpdateReq.java @@ -40,4 +40,10 @@ public class GuideTenantProcedureStatusUpdateReq { private GuideProcedureStatus status; private Long updateBy; + + /** + * 来源：1-用户操作，2-系统监听MQ处理 + * 该字段仅用于区分系统监听MQ处理，正常使用可不管该字段 + */ + private Integer from; } diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/enums/GuideProcedureEnum.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/enums/GuideProcedureEnum.java new file mode 100644 index 00000000..3bc7a278 --- /dev/null +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/enums/GuideProcedureEnum.java @@ -0,0 +1,70 @@ +package cn.axzo.nanopart.server.enums; + +import cn.axzo.basics.common.util.NumberUtil; +import cn.axzo.nanopart.server.domain.GuideProcedureTemplate; +import cn.axzo.op.api.enums.GuideProcedureTypeEnum; +import lombok.Getter; + +/** + * 操作步骤模板枚举 + *

+ * 对应 数据库表 guide_procedure_template，为减少整体枚举值的数量， + * 只记录需要进行异步状态更新的操作步骤，前端上报状态变更的操作步骤不进行枚举 + * + * @author chenwenjian + * @version 1.0 + * @date 2024/8/9 16:38 + * @see GuideProcedureTemplate + */ +@Getter +public enum GuideProcedureEnum { + + ADD_NODE_USR(2L, GuideProcedureTypeEnum.ENT, "添加人员"), + + CREATE_PROJECT(3L, GuideProcedureTypeEnum.ENT, "创建项目"), + + CREATE_ENGINEERING_ENT(4L, GuideProcedureTypeEnum.ENT, "创建工程"), + + CREATE_ENGINEERING_PROJECT(5L, GuideProcedureTypeEnum.PROJECT, "创建工程"), + + INVITE_TEAM(6L, GuideProcedureTypeEnum.PROJECT, "邀请参建单位&班组"), + + INVITE_PARTICIPANT(7L, GuideProcedureTypeEnum.PROJECT, "邀请从业人员"), + + CREATE_CONSTRUCTION_AREA(8L, GuideProcedureTypeEnum.PROJECT, "创建施工区"), + + DISCLOSURE(10L, GuideProcedureTypeEnum.PROJECT, "上传交底"); + + /** + * 对应步骤模板的id + */ + private final Long code; + + /** + * 对应步骤模板的type + */ + private final GuideProcedureTypeEnum type; + + /** + * 对应步骤模板的name + */ + private final String desc; + + GuideProcedureEnum(Long code, GuideProcedureTypeEnum type, String desc) { + this.code = code; + this.type = type; + this.desc = desc; + } + + public static GuideProcedureEnum getByCode(Long code) { + if (NumberUtil.isPositiveNumber(code)) { + return null; + } + for (GuideProcedureEnum value : GuideProcedureEnum.values()) { + if (value.getCode().equals(code)) { + return value; + } + } + return null; + } +} diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/AbstractTenantProcedureStatusHandler.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/AbstractTenantProcedureStatusHandler.java new file mode 100644 index 00000000..5bf70b7f --- /dev/null +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/AbstractTenantProcedureStatusHandler.java @@ -0,0 +1,37 @@ +package cn.axzo.nanopart.server.event; + +import cn.axzo.nanopart.server.enums.GuideProcedureEnum; +import cn.axzo.nanopart.server.service.GuideTenantProcedureStatusService; +import cn.axzo.op.api.enums.GuideProcedureStatus; +import cn.axzo.op.api.request.GuideTenantProcedureStatusUpdateReq; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * @author chenwenjian + * @version 1.0 + * @date 2024/8/9 16:52 + */ +@Slf4j +@Component +public class AbstractTenantProcedureStatusHandler { + + @Autowired + private GuideTenantProcedureStatusService guideTenantProcedureService; + + /** + * 更新步骤状态 + * + * @param workspaceId 租户id + * @param procedure 操作步骤id + */ + protected void updateTenantStatus(Long workspaceId, GuideProcedureEnum procedure) { + GuideTenantProcedureStatusUpdateReq updateReq = new GuideTenantProcedureStatusUpdateReq(); + updateReq.setWorkspaceId(workspaceId); + updateReq.setProcedureId(procedure.getCode()); + updateReq.setStatus(GuideProcedureStatus.FINISHED); + updateReq.setFrom(2); + guideTenantProcedureService.updateStatus(updateReq); + } +} diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/apollo/ConstructionAreaHandler.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/apollo/ConstructionAreaHandler.java new file mode 100644 index 00000000..213cb971 --- /dev/null +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/apollo/ConstructionAreaHandler.java @@ -0,0 +1,44 @@ +package cn.axzo.nanopart.server.event.apollo; + +import cn.axzo.framework.rocketmq.Event; +import cn.axzo.framework.rocketmq.EventConsumer; +import cn.axzo.framework.rocketmq.EventHandler; +import cn.axzo.nanopart.server.enums.GuideProcedureEnum; +import cn.axzo.nanopart.server.event.AbstractTenantProcedureStatusHandler; +import cn.axzo.nanopart.server.event.enums.MQEventEnum; +import cn.axzo.nanopart.server.event.payload.ConstructionAreaPayload; +import cn.hutool.json.JSONUtil; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.InitializingBean; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * @author chenwenjian + * @version 1.0 + * @date 2024/8/9 15:16 + */ +@Slf4j +@Component +public class ConstructionAreaHandler extends AbstractTenantProcedureStatusHandler implements EventHandler, InitializingBean { + + @Autowired + private EventConsumer eventConsumer; + + + @Override + public void onEvent(Event event, EventConsumer.Context context) { + log.info("ConstructionAreaHandler onEvent, event: {}", JSONUtil.toJsonStr(event)); + // 解析数据 + ConstructionAreaPayload constructionAreaPayload = event.normalizedData(ConstructionAreaPayload.class); + log.info("ConstructionAreaHandler onEvent, payload: {}", JSONUtil.toJsonStr(constructionAreaPayload)); + // 业务处理：更新对应workspaceId下创建施工区域操作的完成状态 + updateTenantStatus(constructionAreaPayload.getWorkspaceId(), GuideProcedureEnum.CREATE_CONSTRUCTION_AREA); + } + + @Override + public void afterPropertiesSet() throws Exception { + Event.EventCode eventCode = new Event.EventCode(MQEventEnum.CONSTRUCTION_AREA.getModel(), MQEventEnum.CONSTRUCTION_AREA.getTag()); + eventConsumer.registerHandler(eventCode, this); + } +} diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/data_collection/DisclosureHandler.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/data_collection/DisclosureHandler.java new file mode 100644 index 00000000..a34545e6 --- /dev/null +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/data_collection/DisclosureHandler.java @@ -0,0 +1,43 @@ +package cn.axzo.nanopart.server.event.data_collection; + +import cn.axzo.framework.rocketmq.Event; +import cn.axzo.framework.rocketmq.EventConsumer; +import cn.axzo.framework.rocketmq.EventHandler; +import cn.axzo.nanopart.server.enums.GuideProcedureEnum; +import cn.axzo.nanopart.server.event.AbstractTenantProcedureStatusHandler; +import cn.axzo.nanopart.server.event.enums.MQEventEnum; +import cn.axzo.nanopart.server.event.payload.DisclosurePayload; +import cn.hutool.json.JSONUtil; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.InitializingBean; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * @author chenwenjian + * @version 1.0 + * @date 2024/8/9 16:05 + */ +@Slf4j +@Component +public class DisclosureHandler extends AbstractTenantProcedureStatusHandler implements EventHandler, InitializingBean { + + @Autowired + private EventConsumer eventConsumer; + + @Override + public void onEvent(Event event, EventConsumer.Context context) { + log.info("DisclosureHandler onEvent, event: {}", JSONUtil.toJsonStr(event)); + // 解析数据 + DisclosurePayload disclosurePayload = event.normalizedData(DisclosurePayload.class); + log.info("DisclosureHandler onEvent, payload: {}", JSONUtil.toJsonStr(disclosurePayload)); + // 业务处理：更新对应workspaceId下上传交底操作的完成状态 + updateTenantStatus(disclosurePayload.getWorkspaceId(), GuideProcedureEnum.DISCLOSURE); + } + + @Override + public void afterPropertiesSet() throws Exception { + Event.EventCode eventCode = new Event.EventCode(MQEventEnum.DISCLOSURE.getModel(), MQEventEnum.DISCLOSURE.getTag()); + eventConsumer.registerHandler(eventCode, this); + } +} diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/enums/MQEventEnum.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/enums/MQEventEnum.java index 95348606..6e3d216a 100644 --- a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/enums/MQEventEnum.java +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/enums/MQEventEnum.java @@ -36,6 +36,10 @@ public enum MQEventEnum { WORKSPACE("WORKSPACE", "WORKSPACE", "WORKSPACE"), LABOUR("LABOUR", "LABOUR", "LABOUR"), + CONSTRUCTION_AREA("construction_area", "construction_area", "创建施工区域"), + + DISCLOSURE("disclosure", "disclosure", "上传交底"), + ; private final String model; private final String tag; diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/payload/ConstructionAreaPayload.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/payload/ConstructionAreaPayload.java new file mode 100644 index 00000000..b739b8a7 --- /dev/null +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/payload/ConstructionAreaPayload.java @@ -0,0 +1,30 @@ +package cn.axzo.nanopart.server.event.payload; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.Accessors; + +/** + * 施工区域消息体 + * + * @author chenwenjian + * @version 1.0 + * @date 2024/8/9 15:18 + */ +@Data +@Accessors(chain = true) +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class ConstructionAreaPayload { + + private Long id; + + private String name; + + private Long workspaceId; + + private Long projectId; +} diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/payload/DisclosurePayload.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/payload/DisclosurePayload.java new file mode 100644 index 00000000..d24c970f --- /dev/null +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/payload/DisclosurePayload.java @@ -0,0 +1,49 @@ +package cn.axzo.nanopart.server.event.payload; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.Accessors; + +/** + * @author chenwenjian + * @version 1.0 + * @date 2024/8/9 15:21 + */ +@Data +@Accessors(chain = true) +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class DisclosurePayload { + + private Long workspaceId; + + private Long templateId; + + /** + *任务项编码 + */ + private String taskContentCode; + + /** + * 交底编码 + */ + private Long code; + + /** + * 区域名称 + */ + private String name; + + /** + * 分类，1：分项交底，2：作业交底 + */ + private Integer category; + + /** + * 类别，1：技术，2：安全 + */ + private Integer type; +} diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/service/impl/GuideTenantProcedureStatusServiceImpl.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/service/impl/GuideTenantProcedureStatusServiceImpl.java index d30de7d6..a5cb522c 100644 --- a/op/op-server/src/main/java/cn/axzo/nanopart/server/service/impl/GuideTenantProcedureStatusServiceImpl.java +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/service/impl/GuideTenantProcedureStatusServiceImpl.java @@ -113,7 +113,8 @@ public class GuideTenantProcedureStatusServiceImpl extends ServiceImpl Date: Fri, 9 Aug 2024 17:22:46 +0800 Subject: [PATCH 4/4] =?UTF-8?q?feat(REQ-2348):=20=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E6=89=93=E5=8D=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/event/AbstractTenantProcedureStatusHandler.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/AbstractTenantProcedureStatusHandler.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/AbstractTenantProcedureStatusHandler.java index 5bf70b7f..6b7ea5ad 100644 --- a/op/op-server/src/main/java/cn/axzo/nanopart/server/event/AbstractTenantProcedureStatusHandler.java +++ b/op/op-server/src/main/java/cn/axzo/nanopart/server/event/AbstractTenantProcedureStatusHandler.java @@ -4,6 +4,7 @@ import cn.axzo.nanopart.server.enums.GuideProcedureEnum; import cn.axzo.nanopart.server.service.GuideTenantProcedureStatusService; import cn.axzo.op.api.enums.GuideProcedureStatus; import cn.axzo.op.api.request.GuideTenantProcedureStatusUpdateReq; +import cn.hutool.json.JSONUtil; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -32,6 +33,7 @@ public class AbstractTenantProcedureStatusHandler { updateReq.setProcedureId(procedure.getCode()); updateReq.setStatus(GuideProcedureStatus.FINISHED); updateReq.setFrom(2); + log.info("系统监听MQ处理更新操作状态：{}", JSONUtil.toJsonStr(updateReq)); guideTenantProcedureService.updateStatus(updateReq); } }