From 0e46e316bbe6628e4fce162813f89703fef6075c Mon Sep 17 00:00:00 2001
From: 77 <77@77.com>
Date: Sun, 24 Mar 2024 19:07:50 +0800
Subject: [PATCH] init

---
 .../mq/handle/CalculateSalesNotifyHandle.java | 26 +++++++++++++++++++
 1 file changed, 26 insertions(+)
 create mode 100644 ruoyi-xq/src/main/java/com/ruoyi/xq/mq/handle/CalculateSalesNotifyHandle.java

diff --git a/ruoyi-xq/src/main/java/com/ruoyi/xq/mq/handle/CalculateSalesNotifyHandle.java b/ruoyi-xq/src/main/java/com/ruoyi/xq/mq/handle/CalculateSalesNotifyHandle.java
new file mode 100644
index 0000000..4e86041
--- /dev/null
+++ b/ruoyi-xq/src/main/java/com/ruoyi/xq/mq/handle/CalculateSalesNotifyHandle.java
@@ -0,0 +1,26 @@
+package com.ruoyi.xq.mq.handle;
+
+import com.alibaba.fastjson2.JSON;
+import com.ruoyi.xq.mq.CommonConsumerEnum;
+import com.ruoyi.xq.mq.handle.dto.CalculateSalesHandleDTO;
+import com.ruoyi.xq.service.ConsumeLogService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+@Component
+public class CalculateSalesNotifyHandle implements IHandle{
+
+    @Autowired
+    private ConsumeLogService consumeLogService;
+
+    @Override
+    public void run(String message) {
+        CalculateSalesHandleDTO calculateSalesHandle = JSON.parseObject(message, CalculateSalesHandleDTO.class);
+        consumeLogService.dealFenxiao(calculateSalesHandle.getConsumerLogId(),true);
+    }
+
+    @Override
+    public CommonConsumerEnum getType() {
+        return CommonConsumerEnum.CALCULATE_SALES;
+    }
+}