Merge remote-tracking branch 'origin/master'

admin

2019-04-04 3a6e476b2f498e876ff10f1328455f58e63ee85a

 fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoOrderServiceImpl.java

@@ -11,7 +11,9 @@
import org.springframework.transaction.annotation.Transactional;



import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderMapper;

import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoOrderTradeMapMapper;

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

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

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

@@ -26,6 +28,9 @@


   @Resource

   private RedisManager redisManager;



   @Resource

   private TaoBaoOrderTradeMapMapper taoBaoOrderTradeMapMapper;



   @Override

   public void addTaoBaoOrderList(List<TaoBaoOrder> list) {

@@ -47,7 +52,7 @@
         } catch (Exception e) {



         }

			


         addTaoBaoOrder(orderId, map.get(orderId));

         try {

            // 6小时内不再处理

@@ -56,8 +61,20 @@
         } catch (Exception e) {



         }



      }

   }



   @Transactional

   private void addTaoBaoOrderTradeMap(TaoBaoOrder order) {

      if (order == null || StringUtil.isNullOrEmpty(order.getTradeId()))

         return;

      TaoBaoOrderTradeMap map = new TaoBaoOrderTradeMap();

      map.setCreateTime(new Date());

      map.setTaoBaoOrder(order);

      map.setTradeId(order.getTradeId());

      TaoBaoOrderTradeMap oldMap = taoBaoOrderTradeMapMapper.selectByTradeId(order.getTradeId());

      if (oldMap == null)

         taoBaoOrderTradeMapMapper.insertSelective(map);

   }



   @Transactional

@@ -68,6 +85,7 @@
         for (TaoBaoOrder taoBaoOrder : list) {

            taoBaoOrder.setLatestUpdateTime(new Date());

            taoBaoOrderMapper.insertSelective(taoBaoOrder);

            addTaoBaoOrderTradeMap(taoBaoOrder);

         }

      } else {

         if (StringUtil.isNullOrEmpty(oldOrderList.get(0).getTradeId())) {

@@ -75,6 +93,7 @@
            for (TaoBaoOrder taoBaoOrder : list) {

               taoBaoOrder.setLatestUpdateTime(new Date());

               taoBaoOrderMapper.insertSelective(taoBaoOrder);

               addTaoBaoOrderTradeMap(taoBaoOrder);

            }

         } else {

            // 按tradeId更新

@@ -83,12 +102,14 @@
               if (order == null) {

                  taoBaoOrder.setLatestUpdateTime(new Date());

                  taoBaoOrderMapper.insertSelective(taoBaoOrder);

                  addTaoBaoOrderTradeMap(taoBaoOrder);

               } else {

                  taoBaoOrder.setId(order.getId());

                  taoBaoOrder.setRelationId(order.getRelationId());

                  taoBaoOrder.setSpecialId(order.getSpecialId());

                  taoBaoOrder.setLatestUpdateTime(new Date());

                  taoBaoOrderMapper.updateByPrimaryKeySelective(taoBaoOrder);

                  addTaoBaoOrderTradeMap(taoBaoOrder);

               }

            }

         }