订单处理逻辑变更（不处理6小时内处理过的订单）

Administrator

2018-10-31 e3819aca2480fda8fe90640569b42b882de57a49

订单处理逻辑变更（不处理6小时内处理过的订单）

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

@@ -14,6 +14,8 @@
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.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,24 @@
        Iterator<String> its = map.keySet().iterator();

        while (its.hasNext()) {

            String orderId = its.next();

            String key = "doorder-" + orderId;

            // redis做频率限制

            try {

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

                    continue;

                }



            } catch (Exception e) {



            }

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

            try {

                // 6小时内不再处理

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

            } catch (Exception e) {



            }



        }

    }



@@ -61,20 +83,20 @@
        }

    }





    @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{

    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 {

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

            throws Exception {

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

    }

    


 fanli/src/main/resource/uml/¶©µ¥´¦ÀíÂß¼­£¨Ð£©.acd

@@ -102,8 +102,8 @@
                  <constraint>
                    <height>-1</height>
                    <width>-1</width>
                    <x>219</x>
                    <y>240</y>
                    <x>220</x>
                    <y>325</y>
                  </constraint>
                  <sourceConnections>
                    <net.java.amateras.uml.activitydiagram.model.FlowModel>
@@ -136,7 +136,7 @@
                          <height>-1</height>
                          <width>-1</width>
                          <x>256</x>
                          <y>307</y>
                          <y>416</y>
                        </constraint>
                        <sourceConnections/>
                        <targetConnections>
@@ -613,8 +613,8 @@
                        <constraint>
                          <height>39</height>
                          <width>124</width>
                          <x>81</x>
                          <y>241</y>
                          <x>82</x>
                          <y>373</y>
                        </constraint>
                        <sourceConnections>
                          <net.java.amateras.uml.model.AnchorModel reference="../../.."/>