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

yujian

2019-05-29 0588d6be74335f41c79a8d8e32dbd1c3d3e47fa3

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

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



import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Iterator;

import java.util.List;

import java.util.Map;

@@ -118,7 +117,6 @@
         doUserMoneyDebtJob();// 债务偿还

      } else if (!Constant.IS_TEST) {

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

         //

      }

   }



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

   }



   public void doUpdateGoodsJob() {



      // 采用4个线程做更新

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

   /**

    * 更新精选库商品

    */

   public void doUpdateGoodsJob() {

      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());



                  }

               }

            }