邀请码添加返回状态

yujian

2019-01-22 88b54772dbcf5ecab1e2316e4e4626ac901b8908

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

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



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

import com.yeshi.fanli.entity.admin.ReslutOrder;

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

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

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



@Service

@@ -21,6 +23,9 @@


   @Resource

   private TaoBaoOrderMapper taoBaoOrderMapper;



   @Resource

   private RedisManager redisManager;



   @Override

   public void addTaoBaoOrderList(List<TaoBaoOrder> list) {

@@ -30,7 +35,27 @@
      Iterator<String> its = map.keySet().iterator();

      while (its.hasNext()) {

         String orderId = its.next();

         String key = "addorder-" + orderId;

         // redis做频率限制

         try {

            if (Constant.IS_OUTNET) {

               if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) {

                  continue;

               }

            }



         } catch (Exception e) {



         }

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

         try {

            // 6小时内不再处理

            if (Constant.IS_OUTNET)

               redisManager.cacheCommonString(key, "1", 60 * 60 * 6);

         } catch (Exception e) {



         }



      }

   }



@@ -61,31 +86,15 @@
      }

   }





   @Override

   public List<TaoBaoOrder> getTaoBaoOrderByOrderId(String orderId) {

      return taoBaoOrderMapper.selectTaoBaoOrderByOrderId(orderId);

   }





   @Override

   public List<ReslutOrder> queryJoinHongBao (int start, int count, String key,

         String startTime,String endTime,Integer type,Integer days) throws Exception{

      return taoBaoOrderMapper.queryJoinHongBao(start, count, key, startTime, endTime, type, days);

   }

	
   @Override

   public int countQueryJoinHongBao(String key, String startTime,String endTime,Integer type,Integer days)throws Exception {

      return taoBaoOrderMapper.countQueryJoinHongBao(key, startTime, endTime, type, days);

   }

	
   @Override

   public double countEstimate(String date)throws Exception {

   public double countEstimate(String date) throws Exception {

      return taoBaoOrderMapper.countEstimate(date);

   }

	
   @Override

   public List<TaoBaoOrder> getStateByOrderIdAndPayment(String orderId, String payment )throws Exception {

      return taoBaoOrderMapper.getStateByOrderIdAndPayment(orderId, payment);

   }

	


}