红包统计剔除 赠送退回统计

yujian

2019-08-29 9c9911225e32b308520afe3fe8bc20aa5ffa5094

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

@@ -29,6 +29,7 @@
import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;

import com.yeshi.fanli.exception.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.jd.JDOrderService;

import com.yeshi.fanli.service.inter.lable.BoutiqueAutoRuleService;

@@ -42,6 +43,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;

@@ -101,6 +103,9 @@


   @Resource

   private PDDOrderService pddOrderService;



   @Resource

   private HongBaoV2Service hongBaoV2Service;



   private static boolean isInited = false;



@@ -205,6 +210,7 @@
            public void run() {

               while (true) {

                  try {



                     // 取16个订单

                     List<String> orderIds = CMQManager.getInstance().consumeTaoBaoOrderMsg(16);

                     if (orderIds != null) {

@@ -569,7 +575,6 @@
                  }

               } catch (Exception e) {

                  LogHelper.error("还款出错:" + e.getMessage());



               }

            }

         }

@@ -634,17 +639,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 +691,53 @@


   }



   /**

    * 红包到账后的金币获取

    */

   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) {

                           if (hongBaoV2.getType() == HongBaoV2.TYPE_ZIGOU) {// 自购

                              // TODO 添加加金币事件

                           } else if (hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_GOODS) {// 分享赚

                              // TODO 添加加金币事件

                           } else if (hongBaoV2.getType() == HongBaoV2.TYPE_YIJI

                                 || hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_YIJI) {// 一级邀请赚

                              // TODO 添加加金币事件

                           } else if (hongBaoV2.getType() == HongBaoV2.TYPE_ERJI

                                 || hongBaoV2.getType() == HongBaoV2.TYPE_SHARE_ERJI) {// 二级邀请赚

                              // TODO 添加加金币事件

                           }

                        }

                        HongBaoRecieveCMQManager.getInstance()

                              .deleteQueueMsg(HongBaoRecieveCMQManager.QUEUE_INTEGRAL, key);

                     } catch (Exception e) {

                        try {

                           LogHelper.errorDetailInfo(e);

                        } catch (Exception e1) {

                           e1.printStackTrace();

                        }

                     } finally {



                     }

                  }

               }

            }

         }

      });



   }



}