package com.net.quartz;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.List;

import org.apache.log4j.Logger;

import org.springframework.beans.factory.annotation.Autowired;

import com.net.entity.record.CountRecord;

import com.net.entity.user.Users;

import com.net.service.CountRecordService;

import com.net.service.UserService;

/**

 * 每日刷新会员分享数额作业

 * 每日刷新会员有效天数

 * @author zhangdi

 *

 */

public class RefreshCountRecord {

    private Logger log = Logger.getLogger(RefreshCountRecord.class);

    @Autowired

    private CountRecordService cRecordService;//权限服务

    @Autowired

    private UserService userService;//用户会员天数更新以及用户会员降级操作

    //调用的方法

    public void execute(){

        Date d = new Date();

        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        String dateNowStr = sdf.format(d);

        //需要做的事情

        /*

         * *************************************************

         * *************************************************

         * **这里执行会员降级与会员有效天数减一操作**

         * *************************************************

         * *************************************************

         */

        log.info("=========***update userLevel by vipDay START***===============");

        //将vip天数为0的用户的用户等级降为0

        boolean updateUserLeverToNormal = userService.updateUserLevelByVipDays(0, 0);

        log.info(dateNowStr+"=========update userLevel to 0 by vipDay===============>"+updateUserLeverToNormal);

        log.info(dateNowStr+"=========***update userLevel by vipDay END***===============");

        log.info(dateNowStr+"=========***VIP vipDay-1 START***===============");

        List<Users> userLevelOne = userService.findUserByUserLevel(1);

        List<Users> userLevelTwo = userService.findUserByUserLevel(2);

        List<Users> userLevelThree = userService.findUserByUserLevel(3);

        //开始执行vip天数减一

        reduceVipDay(userLevelOne);

        reduceVipDay(userLevelTwo);

        reduceVipDay(userLevelThree);

        log.info(dateNowStr+"=========***VIP vipDay-1 END***===============");

        /*

         * *************************************************

         * *************************************************

         * ****这里执行会员记录操作，执行在会员降级之后

         * *************************************************

         * *************************************************

         */

        //设置是否刷新成功

        boolean isRefresh = false;

        //查询出所有会员的限制记录1代表会员0代表非会员

        List<CountRecord> countRecords = cRecordService.findCountRecordsByIsVip(1);

        if(countRecords.size()==0){

            log.info("============="+dateNowStr+"===>not found vip record!!!==========");

            System.out.println(dateNowStr+"发现没有会员记录");

        }else{

            for (CountRecord c : countRecords) {

                c.setAdverCount(200);

                c.setContactsCount(200);

                c.setShareCount(200);

                c.setIsVip(1);

                isRefresh = cRecordService.updateCountRecordByUserId(c);

            }

            log.info("============="+dateNowStr+"===>refresh vip count to 200=================>"+isRefresh);

            System.out.println(dateNowStr+"刷新会员权限数额为200=================>"+isRefresh);

        }

    }

    /**

     * 执行用户vip天数减一

     * @param list

     */

    private void reduceVipDay(List<Users> list){

        int oldVipDays = 0;

        int nowVipDays = 0;

        for (Users users : list) {

            oldVipDays = users.getVipDays();

            nowVipDays = oldVipDays-1;

            boolean isSuccess =userService.updateVipDaysById(users.getId(), nowVipDays);

            log.info("=========update=="+users.getUserName()+"vipDays=======>"+isSuccess);

        }

    }

}

    <!--  使用quartz框架做简单的作业调度（定时器）-->

    <!--要调度的对象-->

    <!-- 刷新数据库中会员每日添加记录的上限 -->

    <bean id="jobBean" class="com.net.quartz.RefreshCountRecord" />

     <!-- 定义调用对象和调用对象的方法 -->

    <bean id="jobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">

        <property name="targetObject" ref="jobBean" />

        <property name="targetMethod" value="execute" />

        <!--将并发设置为false-->

        <property name="concurrent" value="false" />

    </bean>

    <!-- 定义触发时间 -->

    <bean id="trigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">

            <property name="jobDetail" ref="jobDetail" />

                    <!--表达式，我的是每天凌晨1点执行一次-->

                   <property name="cronExpression" value="0 0 1 * * ?" />

                   <!-- <property name="cronExpression" value="0/10 * * * * ?" /> -->

    </bean>

    <!--  总管理类如果将lazy-init='false'那么容器启动就会执行调度程序   -->

    <bean id="startQuertz" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" lazy-init="false" >

            <property name="triggers">

                <list>

                    <!--作业调度器,list下可加入其他的调度器-->

                <ref bean="trigger" />

                </list>

        </property>

    </bean>