精选库商品入库及更新调整 + 9k9类商品查询取消标签查询

yujian

2019-05-29 0588d6be74335f41c79a8d8e32dbd1c3d3e47fa3

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

@@ -1,6 +1,6 @@
package com.yeshi.fanli.util;



import java.util.ArrayList;

import java.math.BigDecimal;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

@@ -15,6 +15,7 @@
import org.yeshi.utils.tencentcloud.COSManager;

import org.yeshi.utils.tencentcloud.entity.COSInitParams;



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

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

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

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

@@ -23,13 +24,19 @@
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.ThreeSaleSerivce;

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

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

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

import com.yeshi.fanli.service.inter.money.UserMoneyDebtService;

import com.yeshi.fanli.service.inter.order.OrderProcessService;

import com.yeshi.fanli.service.inter.push.IOSPushService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoOrderService;

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

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



/**

 * 系统初始化

@@ -64,6 +71,21 @@
   @Resource

   private QualityFactoryService qualityFactoryService;



   @Resource

   private UserSystemCouponService userSystemCouponService;



   @Resource

   private ThreeSaleSerivce threeSaleSerivce;



   @Resource

   private TaoBaoOrderService taoBaoOrderService;



   @Resource

   private RedisManager redisManager;



   @Resource

   private UserMoneyDebtService userMoneyDebtService;



   private static boolean isInited = false;



   public void onApplicationEvent(ContextRefreshedEvent arg0) {

@@ -90,9 +112,11 @@
         doOrderTiChengFanLi();// 处理订单提成返利

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

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

         doThreeSaleUserCouponJob();// 处理邀请队列

         doUpdateGoodsJob();

         doUserMoneyDebtJob();// 债务偿还

      } else if (!Constant.IS_TEST) {

         initScheduler();// 启动定时任务

         // doUpdateGoodsJob();

      }

   }



@@ -155,7 +179,7 @@
    */

   public void doTaoBaoOrders() {

      // 同时开启3个线程处理

      for (int i = 0; i < 3; i++) {

      for (int i = 0; i < 1; i++) {

         executor.execute(new Runnable() {

            @Override

            public void run() {

@@ -164,6 +188,13 @@
                     // 取16个订单

                     Map<String, List<TaoBaoOrder>> map = CMQManager.getInstance().consumeTaoBaoOrderMsg(16);

                     if (map != null) {

                        // 从库里面查询

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

                        while (its.hasNext()) {

                           String orderId = its.next();

                           List<TaoBaoOrder> orderList = taoBaoOrderService.getTaoBaoOrderByOrderId(orderId);

                           map.put(orderId, orderList);

                        }

                        orderProcessService.processOrder(map);

                     }

                  } catch (Exception e) {

@@ -194,7 +225,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 {

@@ -204,7 +243,7 @@
                           }

                        } catch (Exception e) {

                           try {

                              LogHelper.errorDetailInfo(e);

                              LogHelper.errorDetailInfo(e, "HongBaoV2-ID:" + map.get(handler).getId(), "");

                           } catch (Exception e1) {

                              e1.printStackTrace();

                           }

@@ -246,7 +285,7 @@
                           }

                        } catch (Exception e) {

                           try {

                              LogHelper.errorDetailInfo(e);

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

                           } catch (Exception e1) {

                              e1.printStackTrace();

                           }

@@ -346,43 +385,27 @@
      boutiqueAutoRuleService.startScheduler();

   }



	
   /**

    * 更新精选库商品

    */

   public void doUpdateGoodsJob() {



      // 采用4个线程做更新

      for (int i = 0; i < 1; i++)

         executor.execute(new Runnable() {

            @Override

            public void run() {



               while (true) {

                  try {



                     Map<String, Long> map = CMQManager.getInstance().consumeNeedUpdateTaoBaoGoodsIdMsg(16);



                     if (map != null) {



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

                        while (its.hasNext()) {



                           String key = its.next();

                           try {

                              Long goodsId = map.get(key);

                              List<Long> list = new ArrayList<>();

                              list.add(goodsId);

                              qualityFactoryService.updateGoodsFactory(list);

                              CMQManager.getInstance().deleteNeedUpdateTaoBaoGoodsIdMsg(key);

                           } catch (Exception e) {

                              try {

                                 LogHelper.errorDetailInfo(e);

                              } catch (Exception e1) {

                                 e1.printStackTrace();

                              }

                           }

                           qualityFactoryService.updateQualityGoods(map.get(its.next()));

                           CMQManager.getInstance().deleteNeedUpdateTaoBaoGoodsIdMsg(its.next());

                        }

                     }

                  } catch (Exception e) {

                     LogHelper.error("更新商品出错:" + e.getMessage());



                  }

               }

            }

@@ -402,10 +425,8 @@


               while (true) {

                  try {



                     Map<String, ThreeSale> map = ThreeSaleCMQManager.getInstance()

                           .consumeQueueMsg(ThreeSaleCMQManager.QUEUE_USER_COUPON, 16);



                     if (map != null) {



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

@@ -413,13 +434,21 @@
                           String key = its.next();

                           try {

                              ThreeSale threeSale = map.get(key);

                              if (threeSale != null)

                                 threeSale = threeSaleSerivce.selectByPrimaryKey(threeSale.getId());

                              if (threeSale != null) {

                                 if (threeSale.getState() != null && threeSale.getState() == true) {

                                    // 邀请成功

                                    // 邀请成功 - 券激活生效

                                    LogHelper.test("doThreeSaleUserCouponJob-" + threeSale.getId());



                                    // TODO 券激活生效

                                    // threeSale.getBoss().getId();

                                    Long bossId = threeSale.getBoss().getId();

                                    // 下级昵称



                                    String workerNickName = userInfoService

                                          .selectByPKey(threeSale.getWorker().getId()).getNickName();



                                    userSystemCouponService.activatedWelfareFreeCoupon(bossId,

                                          workerNickName);

                                 }

                              }

                              ThreeSaleCMQManager.getInstance()

@@ -442,4 +471,45 @@
         });



   }



   /**

    * 用户借贷处理

    */

   public void doUserMoneyDebtJob() {

      executor.execute(new Runnable() {

         @Override

         public void run() {

            while (true) {

               try {

                  Map<String, UserMoneyChangeDTO> map = UserMoneyChangeCMQManager.getInstance()

                        .consumeQueueMsg(UserMoneyChangeCMQManager.QUEUE_DEBT, 16);

                  if (map != null) {



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

                     while (its.hasNext()) {

                        String key = its.next();

                        try {

                           UserMoneyChangeDTO dto = map.get(key);

                           if (dto != null && dto.getChangeMoney().compareTo(new BigDecimal(0)) > 0) {

                              userMoneyDebtService.repayDebt(dto.getUid());

                           }

                           UserMoneyChangeCMQManager.getInstance()

                                 .deleteQueueMsg(UserMoneyChangeCMQManager.QUEUE_DEBT, key);

                        } catch (Exception e) {

                           try {

                              LogHelper.errorDetailInfo(e);

                           } catch (Exception e1) {

                              e1.printStackTrace();

                           }

                        }

                     }

                  }

               } catch (Exception e) {

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



               }

            }

         }

      });

   }

}