From 15bedcc619b1edb6eb987f9288db7670e5b38c46 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期六, 07 五月 2022 19:42:23 +0800 Subject: [PATCH] bug修复 --- app/src/main/java/com/yeshi/makemoney/app/Application.java | 51 +++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 51 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 bfd01d7..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,17 +1,31 @@ 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; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.boot.web.servlet.MultipartConfigFactory; import org.springframework.context.ApplicationListener; +import org.springframework.context.annotation.Bean; import org.springframework.context.event.ContextRefreshedEvent; import org.springframework.transaction.annotation.EnableTransactionManagement; import org.yeshi.utils.mq.JobThreadExecutorServiceImpl; 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; //涓嶅紩鍏ユ暟鎹簱 @@ -37,6 +51,9 @@ initCOS(); } + @Resource + private GoldCornSettleService goldCornSettleService; + private void initMQMsgConsumer() { final int THREAD_NUM = 3; @@ -45,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(); + } + } + } + } }); @@ -69,4 +108,16 @@ COSManager.getInstance().init(params); } + @Bean + MultipartConfigElement multipartConfigElement() { + MultipartConfigFactory factory = new MultipartConfigFactory(); + String location = System.getProperty("user.dir") + "/data/tmp"; + File tmpFile = new File(location); + if (!tmpFile.exists()) { + tmpFile.mkdirs(); + } + factory.setLocation(location); + return factory.createMultipartConfig(); + } + } -- Gitblit v1.8.0