饿了么绘图，添加口碑

admin

2020-05-19 744594ef1a2f530fc3e86ea9dc48b62247f79420

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

@@ -21,7 +21,6 @@
import com.yeshi.fanli.dto.ad.DouYinDeviceActiveQueueDTO;

import com.yeshi.fanli.dto.money.UserMoneyChangeDTO;

import com.yeshi.fanli.dto.mq.UidDateDTO;

import com.yeshi.fanli.dto.order.dividents.UserDividentsDayDTO;

import com.yeshi.fanli.entity.ad.DouYinClickEvent;

import com.yeshi.fanli.entity.bus.user.AlipayTransferResultInfo;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;

@@ -38,6 +37,7 @@
import com.yeshi.fanli.entity.taobao.TaoBaoOrder;

import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;

import com.yeshi.fanli.exception.order.TaoBaoWeiQuanException;

import com.yeshi.fanli.exception.order.dividents.TeamDividentsRecordException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.ad.DouYinClickEventService;

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

@@ -59,14 +59,16 @@
import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;

import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.manger.money.TeamEincomeManager;

import com.yeshi.fanli.service.manger.order.TeamDividentsManager;

import com.yeshi.fanli.util.ad.DouYinAdUtil;

import com.yeshi.fanli.util.cmq.DouYinDeviceActiveCMQManager;

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.PlaceOrderCMQManager;

import com.yeshi.fanli.util.cmq.UserMoneyChangeCMQManager;

import com.yeshi.fanli.util.cmq.order.JDOrderCMQManager;

import com.yeshi.fanli.util.cmq.order.PDDOrderCMQManager;

import com.yeshi.fanli.util.cmq.order.PlaceOrderCMQManager;

import com.yeshi.fanli.util.cmq.order.TeamOrderCMQManager;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;



/**

@@ -144,6 +146,9 @@
   @Resource

   private TeamDividentsManager teamDividentsManager;



   @Resource

   private TeamEincomeManager teamEincomeManager;



   private static boolean isInited = false;



   public void onApplicationEvent(ContextRefreshedEvent arg0) {

@@ -168,7 +173,7 @@
         doTaoBaoOrders();// 处理淘宝订单

         doTaoBaoNewOrders();// 处理淘宝订单（刚刚产生的）

         doOrderFanLiNew();// 新版返利

         doOrderTeamIncomeFanLi();// 处理订单提成返利



         doOrderShareFanLi();

         doWeiQuanOrder();// 处理维权订单

         doPushIOS();// 处理发送IOS消息

@@ -181,9 +186,11 @@
         doHongBaoRecieveIntegralGetJob();// 返利到账，金币增加

         // doPlaceOrderIntegralJob();// 下单赠送金币任务

         // doDouYinDeviceActiveJob();// 抖音设备激活广告监测

         doOrderTeamIncomePreFanLi();// 处理订单提成返利

         doDividentsPreJob();



         doOrderTeamIncomeFanLi();

         doDividentsJob();



      }

   }



@@ -373,13 +380,14 @@
   /**

    * 处理团队订单返利

    */

   public void doOrderTeamIncomeFanLi() {

   public void doOrderTeamIncomePreFanLi() {

      executor.execute(new Runnable() {

         @Override

         public void run() {

            while (true) {

               try {

                  Map<String, UidDateDTO> map = CMQManager.getInstance().consumeFanLiTeamIncomeMsg(16);

                  Map<String, UidDateDTO> map = TeamOrderCMQManager.getInstance()

                        .consumeFanLiTeamIncomePreMsg(16);

                  if (map != null) {

                     Iterator<String> its = map.keySet().iterator();

                     while (its.hasNext()) {

@@ -387,7 +395,42 @@
                        try {

                           UidDateDTO dto = map.get(handler);

                           orderProcessService.fanliPreInvaite(dto.getUid(), dto.getDate());

                           CMQManager.getInstance().deleteTeamIncomeMsg(handler);

                           TeamOrderCMQManager.getInstance().deleteTeamIncomePreMsg(handler);

                        } catch (Exception e) {

                           try {

                              LogHelper.errorDetailInfo(e, map.get(handler).toString(), "");

                           } catch (Exception e1) {

                              e1.printStackTrace();

                           }

                        }

                     }

                  }

               } catch (Exception e) {



               }

            }

         }

      });

   }



   /**

    * 处理团队订单返利

    */

   public void doOrderTeamIncomeFanLi() {

      executor.execute(new Runnable() {

         @Override

         public void run() {

            while (true) {

               try {

                  Map<String, UidDateDTO> map = TeamOrderCMQManager.getInstance().consumeFanLiTeamIncomeMsg(16);

                  if (map != null) {

                     Iterator<String> its = map.keySet().iterator();

                     while (its.hasNext()) {

                        String handler = its.next();

                        try {

                           UidDateDTO dto = map.get(handler);

                           teamEincomeManager.addTeamIncomeTOUserAccount(dto.getDate(), dto.getUid());

                           TeamOrderCMQManager.getInstance().deleteTeamIncomeMsg(handler);

                        } catch (Exception e) {

                           try {

                              LogHelper.errorDetailInfo(e, map.get(handler).toString(), "");

@@ -1106,19 +1149,63 @@
   }



   // 分红

   public void doDividentsPreJob() {

      executor.execute(new Runnable() {

         @Override

         public void run() {

            while (true) {

               Map<String, UidDateDTO> map = TeamOrderCMQManager.getInstance().consumeTeamDividentsPreMsg(16);

               if (map != null) {

                  Iterator<String> its = map.keySet().iterator();

                  while (its.hasNext()) {

                     String key = its.next();

                     UidDateDTO dto = map.get(key);

                     try {

                        teamDividentsManager.addToTeamEincome(dto.getUid(), dto.getDate());

                        TeamOrderCMQManager.getInstance().deleteTeamDividentsPreMsg(key);

                     } catch (TeamDividentsRecordException e1) {

                        if (e1.getCode() == TeamDividentsRecordException.CODE_EXIST) {

                           TeamOrderCMQManager.getInstance().deleteTeamDividentsPreMsg(key);

                        } else {

                           try {

                              LogHelper.errorDetailInfo(e1);

                           } catch (Exception e2) {

                              e2.printStackTrace();

                           }

                        }

                     }



                     catch (Exception e) {

                        try {

                           LogHelper.errorDetailInfo(e);

                        } catch (Exception e1) {

                           e1.printStackTrace();

                        }

                     } finally {



                     }

                  }

               }

            }

         }

      });

   }



   // 分红

   public void doDividentsJob() {

      executor.execute(new Runnable() {

         @Override

         public void run() {

            while (true) {

               Map<String, UserDividentsDayDTO> map = CMQManager.getInstance().consumeTeamDividentsMsg(16);

               Map<String, UidDateDTO> map = TeamOrderCMQManager.getInstance().consumeTeamDividentsMsg(16);

               if (map != null) {

                  Iterator<String> its = map.keySet().iterator();

                  while (its.hasNext()) {

                     String key = its.next();

                     UserDividentsDayDTO dto = map.get(key);

                     UidDateDTO dto = map.get(key);

                     try {

                        teamDividentsManager.addToTeamEincome(dto.getUid(), dto.getPreGetTime());

                        teamEincomeManager.addTeamDividentsTOUserAccount(dto.getDate(), dto.getUid());

                        TeamOrderCMQManager.getInstance().deleteTeamDividentsMsg(key);

                     } catch (Exception e) {

                        try {

                           LogHelper.errorDetailInfo(e);