package com.szpg.db.dao.impl;

import com.szpg.db.dao.PgConRemoveDao;
import com.szpg.db.data.PgConRemoveMsg;
import com.szpg.db.util.ConnectionManager;
import org.apache.commons.dbutils.DbUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import org.apache.log4j.Logger;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class PgConRemoveDaoImp implements PgConRemoveDao {

    private org.apache.log4j.Logger logger = Logger.getLogger(this.getClass().getName());

    @Override
    public void addConRemove(List<PgConRemoveMsg> pgConRemoveMsgList){
        Connection conn = null;

        String insertStr = "INSERT INTO PG_CON_REMOVE_MSG " +
                "(XD_DATE, XD_END_TIME, XD_SUPERVISOR,XD_FIELD_SITUATION,XD_REMARKS,XD_APPROVER,XD_APPROVER_TIME,LOG_DATE)" +
                "VALUES (?,?,?,?,?,?,?,?)";

        List<Object[]> paramObjectList=new ArrayList<>();
        for(PgConRemoveMsg pgConRemoveMsg:pgConRemoveMsgList){

            Object[] params = new Object[34];
            params[0] = pgConRemoveMsg.getXD_DATE();
            params[1] = pgConRemoveMsg.getXD_END_TIME();
            params[2] = pgConRemoveMsg.getXD_SUPERVISOR();
            params[3] = pgConRemoveMsg.getXD_FIELD_SITUATION();
            params[4] = pgConRemoveMsg.getXD_REMARKS();
            params[5] = pgConRemoveMsg.getXD_APPROVER();
            params[6] = pgConRemoveMsg.getXD_APPROVER_TIME();
            params[7] = pgConRemoveMsg.getLOG_DATE();

            paramObjectList.add(params);
        }
        try {
            conn = ConnectionManager.getConnectionFromC3P0();
            conn.setAutoCommit(false);

            QueryRunner runner = new QueryRunner();
            for (Object[] params:paramObjectList) {
                int count = runner.update(conn, insertStr, params);
                if (count > 0)
                    logger.info("施工消点数据同步成功" + pgConRemoveMsgList.toString());
                else
                    logger.info("施工消点数据同步失败！");
            }

        } catch (Exception ex) {
            logger.info("施工作业数据同步异常", ex);
        } finally {
            try {
                DbUtils.commitAndClose(conn);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    @Override
    public String findLastRecordTime(){
        Connection conn = null;

        String queryStr = "SELECT * FROM PG_CON_REMOVE_MSG ORDER BY LOG_DATE DESC";
        try {
            conn = ConnectionManager.getConnectionFromC3P0();
            conn.setAutoCommit(false);

            QueryRunner runner = new QueryRunner();
            List<PgConRemoveMsg> pgConRemoveMsgList = (List<PgConRemoveMsg>) runner.query(conn,
                    queryStr, new BeanListHandler<PgConRemoveMsg>(PgConRemoveMsg.class));

            if (null != pgConRemoveMsgList && pgConRemoveMsgList.isEmpty() == false) {
                logger.debug("获取最新施工消点记录成功[" + pgConRemoveMsgList + "]");
                return pgConRemoveMsgList.get(0).getLOG_DATE();
            }
            else
                return null;
        } catch (Exception ex) {
            logger.error("获取最新施工消点记录异常", ex);
        } finally {
            try {
                DbUtils.commitAndClose(conn);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        return null;
    }

}