拉新

yujian

2020-06-29 ec60e757d358636dcac1589c44a66f3e276fe58c

 fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java

@@ -11,6 +11,8 @@


import com.yeshi.fanli.entity.bus.user.cloud.UserCloudOrder;

import com.yeshi.fanli.entity.dynamic.GoodsEvaluate;

import com.yeshi.fanli.entity.dynamic.GoodsEvaluate.EvaluateEnum;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.dynamic.GoodsEvaluateService;

import com.yeshi.fanli.service.inter.user.cloud.UserCloudOrderService;

import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;

@@ -48,6 +50,7 @@
         try {

            userCloudAlipayManager.tradeQueryByOrderId(cloudOrder.getId());

         } catch (Exception e) {

            LogHelper.errorDetailInfo(e);

            e.printStackTrace();

         }

      }

@@ -57,7 +60,7 @@
    * 定时检测是否存在新的发圈

    */

   @Scheduled(cron = "0 0/20 * * * ? ")

   public void dailyCount() {

   public void fixedTimeSend() {

      if (!Constant.IS_TASK) {

         return;

      }

@@ -66,19 +69,33 @@
      Calendar nowCalendar = Calendar.getInstance();

      nowCalendar.setTimeInMillis(java.lang.System.currentTimeMillis());

      int hour = nowCalendar.get(Calendar.HOUR_OF_DAY);

      if (hour < 9 && hour > 21)

      if (hour < 9 || hour > 21)

         return;



      // 一个小时之内最新发圈

      long rand = 1000 * 60 * 60;

      long time = java.lang.System.currentTimeMillis() - rand;

      Date lastTime = new Date(time);



      List<GoodsEvaluate> list = goodsEvaluateService.listByStartTime(lastTime);

      if (list == null || list.size() == 0)

         return;



      userCloudService.fixedTimeSend(list.get(0).getId());

      // 活动列表

      List<GoodsEvaluate> listActivity = goodsEvaluateService.queryValidSortASC(1, 100, EvaluateEnum.activity, false);

      // 单品商品

      List<GoodsEvaluate> listGoods = goodsEvaluateService.queryValidSortASC(1, 5, EvaluateEnum.single, true);

      // 执行发单

      userCloudService.fixedTimeSend(listActivity, listGoods, true);

   }



	 
   /**

    * 每日22点进行深夜发圈

    */

   @Scheduled(cron = "0 0 22 * * ? ")

   public void zeroPoint() {

      if (!Constant.IS_TASK) {

         return;

      }

		
      List<GoodsEvaluate> list = goodsEvaluateService.queryValidZeroPoint(1, 50);

      if (list == null || list.size() == 0) {

         return;

      }

      // 执行发单

      userCloudService.fixedTimeSend(null, list, false);

   }

	
}