From 36681e15e12aaa9135f69260472de65303cdcba3 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 26 四月 2022 19:10:45 +0800
Subject: [PATCH] 任务优化
---
app/src/main/java/com/yeshi/makemoney/app/Application.java | 35 +++++++++++++++++++++++++++++++++++
1 files changed, 35 insertions(+), 0 deletions(-)
diff --git a/app/src/main/java/com/yeshi/makemoney/app/Application.java b/app/src/main/java/com/yeshi/makemoney/app/Application.java
index 123ef3a..82da2df 100644
--- a/app/src/main/java/com/yeshi/makemoney/app/Application.java
+++ b/app/src/main/java/com/yeshi/makemoney/app/Application.java
@@ -1,5 +1,12 @@
package com.yeshi.makemoney.app;
+import com.yeshi.makemoney.app.dto.mq.GoldCornSettleMQMsg;
+import com.yeshi.makemoney.app.exception.goldcorn.GoldCornConsumeRecordException;
+import com.yeshi.makemoney.app.exception.goldcorn.GoldCornMoneyExchangeRateRecordException;
+import com.yeshi.makemoney.app.exception.money.UserMoneyRecordException;
+import com.yeshi.makemoney.app.exception.user.UserInfoException;
+import com.yeshi.makemoney.app.service.inter.goldcorn.GoldCornSettleService;
+import com.yeshi.makemoney.app.utils.mq.CMQManager;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -14,8 +21,11 @@
import org.yeshi.utils.tencentcloud.COSManager;
import org.yeshi.utils.tencentcloud.entity.COSInitParams;
+import javax.annotation.Resource;
import javax.servlet.MultipartConfigElement;
import java.io.File;
+import java.util.Iterator;
+import java.util.Map;
import java.util.Properties;
//涓嶅紩鍏ユ暟鎹簱
@@ -41,6 +51,9 @@
initCOS();
}
+ @Resource
+ private GoldCornSettleService goldCornSettleService;
+
private void initMQMsgConsumer() {
final int THREAD_NUM = 3;
@@ -49,6 +62,28 @@
new JobThreadExecutorServiceImpl().run(new Runnable() {
@Override
public void run() {
+ Map<String, GoldCornSettleMQMsg> map = CMQManager.getInstance().consumeGoldCornSettleMsg(10);
+ if (map != null) {
+ for (Iterator<String> its = map.keySet().iterator(); its.hasNext(); ) {
+ String key = its.next();
+ GoldCornSettleMQMsg msg = map.get(key);
+ try {
+ goldCornSettleService.settle(msg.getUid(), msg.getDay());
+ CMQManager.getInstance().deleteGoldCornSettleMsg(key);
+ } catch (UserInfoException e) {
+ e.printStackTrace();
+ } catch (GoldCornMoneyExchangeRateRecordException e) {
+ e.printStackTrace();
+ } catch (UserMoneyRecordException e) {
+ e.printStackTrace();
+ } catch (GoldCornConsumeRecordException e) {
+ e.printStackTrace();
+ }catch (Exception e){
+ e.printStackTrace();
+ }
+ }
+ }
+
}
});
--
Gitblit v1.8.0