yujian
2019-09-09 0d9ac58dc11f54351e5e18dba8e950717d78019f
fanli/src/main/java/com/yeshi/fanli/util/SpringContext.java
@@ -27,9 +27,11 @@
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;
import com.yeshi.fanli.exception.TaoBaoWeiQuanException;
import com.yeshi.fanli.exception.order.TaoBaoWeiQuanException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service;
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
import com.yeshi.fanli.service.inter.integral.IntegralGetService;
import com.yeshi.fanli.service.inter.jd.JDOrderService;
import com.yeshi.fanli.service.inter.lable.BoutiqueAutoRuleService;
import com.yeshi.fanli.service.inter.lable.LabelService;
@@ -42,6 +44,7 @@
import com.yeshi.fanli.service.inter.user.ExtractService;
import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
import com.yeshi.fanli.util.cmq.HongBaoRecieveCMQManager;
import com.yeshi.fanli.util.cmq.JDOrderCMQManager;
import com.yeshi.fanli.util.cmq.PDDOrderCMQManager;
import com.yeshi.fanli.util.cmq.ThreeSaleCMQManager;
@@ -102,6 +105,12 @@
   @Resource
   private PDDOrderService pddOrderService;
   @Resource
   private HongBaoV2Service hongBaoV2Service;
   @Resource
   private IntegralGetService integralGetService;
   private static boolean isInited = false;
   public void onApplicationEvent(ContextRefreshedEvent arg0) {
@@ -136,6 +145,7 @@
         doJDOrderJob();// 京东订单处理
         doPDDOrderJob();// 拼多多订单处理
         doImportantTaoBaoGoodsUpdateJob();// 淘宝重要商品的信息更新
         doHongBaoRecieveIntegralGetJob();// 返利到账,金币增加
      }
   }
@@ -205,6 +215,7 @@
            public void run() {
               while (true) {
                  try {
                     // 取16个订单
                     List<String> orderIds = CMQManager.getInstance().consumeTaoBaoOrderMsg(16);
                     if (orderIds != null) {
@@ -569,7 +580,6 @@
                  }
               } catch (Exception e) {
                  LogHelper.error("还款出错:" + e.getMessage());
               }
            }
         }
@@ -634,17 +644,12 @@
                           }
                           PDDOrderCMQManager.getInstance().deletePDDOrder(key);
                        } catch (Exception e) {
                           try {
                              LogHelper.errorDetailInfo(e);
                           } catch (Exception e1) {
                              e1.printStackTrace();
                           }
                           LogHelper.errorDetailInfo(e);
                        }
                     }
                  }
               } catch (Exception e) {
                  LogHelper.error("拼多多订单:" + e.getMessage());
               }
            }
         }
@@ -691,4 +696,54 @@
   }
   /**
    * 红包到账后的金币获取
    */
   public void doHongBaoRecieveIntegralGetJob() {
      executor.execute(new Runnable() {
         @Override
         public void run() {
            while (true) {
               Map<String, Long> map = HongBaoRecieveCMQManager.getInstance()
                     .consumeQueueMsg(HongBaoRecieveCMQManager.QUEUE_INTEGRAL, 16);
               if (map != null) {
                  Iterator<String> its = map.keySet().iterator();
                  while (its.hasNext()) {
                     String key = its.next();
                     Long hongBaoId = map.get(key);
                     try {
                        HongBaoV2 hongBaoV2 = hongBaoV2Service.selectByPrimaryKey(hongBaoId);
                        if (hongBaoV2 != null && hongBaoV2.getState() == HongBaoV2.STATE_YILINGQU
                              && hongBaoV2.getMoney().compareTo(new BigDecimal(0)) > 0) {
                           if (hongBaoV2.getType() == HongBaoV2.TYPE_ZIGOU) {// 自购
                              integralGetService.addRebateOrder(hongBaoV2.getUserInfo().getId());
                           } else if (hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_GOODS) {// 分享赚
                              integralGetService.addShareOrder(hongBaoV2.getUserInfo().getId());
                           } else if (hongBaoV2.getType() == HongBaoV2.TYPE_YIJI
                                 || hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_YIJI) {// 一级邀请赚
                              integralGetService.addInviteOrderLevelOne(hongBaoV2.getUserInfo().getId());
                           } else if (hongBaoV2.getType() == HongBaoV2.TYPE_ERJI
                                 || hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_ERJI) {// 二级邀请赚
                              integralGetService.addInviteOrderLevelOne(hongBaoV2.getUserInfo().getId());
                           }
                        }
                        HongBaoRecieveCMQManager.getInstance()
                              .deleteQueueMsg(HongBaoRecieveCMQManager.QUEUE_INTEGRAL, key);
                     } catch (Exception e) {
                        try {
                           LogHelper.errorDetailInfo(e);
                        } catch (Exception e1) {
                           e1.printStackTrace();
                        }
                     } finally {
                     }
                  }
               }
            }
         }
      });
   }
}