package com.cntytz;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import weaver.conn.RecordSet;
import weaver.interfaces.schedule.BaseCronJob;

import java.text.SimpleDateFormat;
import java.util.Calendar;

public class BZHKSchedule extends BaseCronJob {
    private final Log logger = LogFactory.getLog(this.getClass().getName());
    @Override
    public void execute() {
        logger.info("开始运行");
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
        Calendar calendar = Calendar.getInstance();
        calendar.add(Calendar.YEAR, -2);
        String twoyearsago = sdf.format(calendar.getTime());
        calendar.add(Calendar.YEAR, -1);
        String threeyearsago = sdf.format(calendar.getTime());

        RecordSet rs = new RecordSet();
        String sql;

        //（1）从标准发布日期到当前截止时间小于等于2年，为“正常使用”状态；
        sql = "update uf_bzhk set bzzt='0' where bzfbrq>='" + twoyearsago + "'";
        logger.info(sql);
        rs.execute(sql);

        //（2）从标准发布日期到当前截止时间大于2年且小于等于3年，为“预警”状态；
        sql = "update uf_bzhk set bzzt='1' where bzfbrq>='" + threeyearsago + "' and bzfbrq<'" + twoyearsago + "'";
        logger.info(sql);
        rs.execute(sql);

        //（3）从标准发布日期到当前截止时间大于3年，为“废止”状态；
        sql = "update uf_bzhk set bzzt='2' where bzfbrq<'" + threeyearsago + "'";
        logger.info(sql);
        rs.execute(sql);
        logger.info("结束运行");
    }

}