Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div

yujian

2019-08-27 d8359ddb48dab5cc797a9d552e11fde571f4920c

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

@@ -5,9 +5,16 @@
import java.util.List;

import java.util.Scanner;



import javax.annotation.Resource;



import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;



import com.yeshi.fanli.entity.push.PushGoods;

import com.yeshi.fanli.entity.push.PushInfo;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.push.PushGoodsService;

import com.yeshi.fanli.service.inter.push.PushInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.factory.IOSPushFactory;

import com.yeshi.fanli.util.push.IOSPushUtil;

@@ -16,7 +23,14 @@


@Component

public class PushJob {



	
   @Resource

   private PushInfoService pushInfoService;

	
   @Resource

   private PushGoodsService pushGoodsService;

	
	
   /**

    * 推送老版本IOS(每晚8点推送)

    */

@@ -49,4 +63,51 @@
      }

   }



	
	
   /**

    *  定时消息推送任务 每个30秒爬取

    */

   @Scheduled(cron = "30 * * * * ? ")

   public void pushInfo() {

      if (!Constant.IS_TASK) {

         return;

      }

		
      // 站内信、网页、百川

      try {

         List<PushInfo> listTask = pushInfoService.listTask();

         if (listTask != null && listTask.size() > 0) {

            for (PushInfo pushInfo: listTask) {

               pushInfoService.taskPush(pushInfo);

            }

         }

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

      }

		
      //   今日推荐

      try {

         List<PushGoods> listTask = pushGoodsService.listTask();

         if (listTask != null && listTask.size() > 0) {

            for (PushGoods pushGoods: listTask) {

               pushGoodsService.taskPush(pushGoods);

            }

         }

      } catch (Exception e) {

         try {

            LogHelper.errorDetailInfo(e);

         } catch (Exception e1) {

            e1.printStackTrace();

         }

      }

		
   }

	
	
	
}