analysisRelateProductDsOrderUnlockTimeoutQueueTimer

ms-biz/src/main/java/com/ms/api/spi/timer/AnalysisRelateProductDsOrderUnlockTimeoutQueueTimerService.java

@@ -0,0 +1,35 @@
+package com.ms.api.spi.timer;
+
+import com.jinritemai.cloud.base.api.BaseRequest;
+import com.jinritemai.cloud.base.api.BaseResponse;
+import com.jinritemai.cloud.base.api.ExtensionService;
+import com.jinritemai.cloud.base.api.ExtensionServiceHandler;
+import com.ms.api.common.R;
+import com.ms.api.common.Ret;
+import com.ms.api.common.TimerBaseService;
+import com.ms.api.consts.StatusConst;
+import com.ms.api.consts.TblConst;
+import com.ms.api.dto.ItemDTO;
+import com.ms.api.service.QueueService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+
+@ExtensionService("analysisRelateProductDsOrderUnlockTimeoutQueueTimer")
+@Slf4j
+public class AnalysisRelateProductDsOrderUnlockTimeoutQueueTimerService extends TimerBaseService implements ExtensionServiceHandler<ItemDTO, Ret> {
+
+    @Autowired
+    private QueueService queueService;
+
+    @Override
+    public BaseResponse<Ret> handle(BaseRequest<ItemDTO> req) {
+        try {
+            queueService.unlockTimeoutSolidRedisQueue(TblConst.ds_relate_product_analysis_op_order_queue, 300, null);
+            return R.ok(Ret.success());
+        } catch (Throwable e) {
+            e.printStackTrace();
+            return R.ok(Ret.fail(e.getMessage()));
+        }
+    }
+
+}