admin
2020-06-10 271ae63c20fcbe28d29c47f1881138ff6551a2a1
fanli/src/main/java/com/yeshi/fanli/job/order/vipshop/UpdateVipShopOrderJob.java
@@ -13,6 +13,7 @@
import com.yeshi.fanli.dto.vipshop.VipShopQueryOrderResultDTO;
import com.yeshi.fanli.entity.vipshop.VipShopOrder;
import com.yeshi.fanli.exception.vipshop.VipShopOrderException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.order.vipshop.VipShopOrderService;
import com.yeshi.fanli.util.RedisKeyEnum;
import com.yeshi.fanli.util.RedisManager;
@@ -45,12 +46,16 @@
            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.VIPShopOrder, order.getOrderSn() + "");
            String result = redisManager.getCommonString(key);
            // 判断
            if (StringUtil.isNullOrEmpty(result)) {
//            if (StringUtil.isNullOrEmpty(result)) {
               VipShopOrderCMQManager.getInstance().addVipShopOrder(order.getOrderSn() + "");
               redisManager.cacheCommonString(key, "1", 60 * 60 * 2);// 2小时内不再更新
            }
               LogHelper.test("唯品会订单消息发送成功");
//            }else{
//               LogHelper.test("唯品会订单频率限制");
//            }
         } catch (VipShopOrderException e) {
            e.printStackTrace();
            LogHelper.errorDetailInfo(e);
         }
      }
   }
@@ -60,6 +65,7 @@
    */
   @XxlJob("updateVipShopOrderHandler")
   public ReturnT<String> updateVipShopSoonOrder(String param) throws Exception {
      LogHelper.test("updateVipShopOrderHandler:"+param);
      long endTime = System.currentTimeMillis();
      if ("1hour".equalsIgnoreCase(param)) {// 更新1小时内的订单
         updateByOrderTime(endTime - 1000 * 60 * 60 * 1L, endTime);