搜索发现

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();// 返利到账，金币增加

      }



   }

@@ -686,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 {



                     }

                  }

               }

            }

         }

      });



   }



}