券推送插入

yujian

2019-04-22 b6c37e4bc38db88a360d0f2c6099183f9bb75bdc

 fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java

@@ -76,6 +76,9 @@
   @Resource

   private TaoBaoOrderService taoBaoOrderService;



   @Resource

   private RedisManager redisManager;



   private static boolean isInited = false;



   public void onApplicationEvent(ContextRefreshedEvent arg0) {

@@ -215,7 +218,15 @@
                     while (its.hasNext()) {

                        String handler = its.next();

                        try {

                           orderProcessService.fanli(map.get(handler));

                           HongBaoV2 hongbao = map.get(handler);

                           if (hongbao != null) {

                              String key = "hongbao-fanli-" + hongbao.getId();

                              if (StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {

                                 // 处理之后要隔2小时再次进行处理

                                 redisManager.cacheCommonString(key, "1", 60 * 60 * 2);

                                 orderProcessService.fanli(map.get(handler));

                              }

                           }

                           CMQManager.getInstance().deleteFanLiMsgNew(handler);

                        } catch (TaoBaoWeiQuanException e) {

                           try {