package com.happy.dao.impl;

import com.happy.Model.Consume;
import com.happy.Model.Recharge;
import com.happy.Model.Recharge_elc;
import com.happy.dao.ConsumeDao;
import com.happy.dao.RechargeDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.stereotype.Repository;

import java.util.List;

@Repository("RechargeDao")
public class RechargeDaoImpl implements RechargeDao {

    @Autowired
    private NamedParameterJdbcTemplate namedParameterJdbcTemplate;

    public NamedParameterJdbcTemplate getNamedParameterJdbcTemplate() {
        return namedParameterJdbcTemplate;
    }

    public void setNamedParameterJdbcTemplate(
            NamedParameterJdbcTemplate namedParameterJdbcTemplate) {
        this.namedParameterJdbcTemplate = namedParameterJdbcTemplate;
    }

    public List<Recharge> queryByStu(String stu_number, String re_time){
        String sql="select * from `recharge` where `pay_state`=2 and stu_number=:stu_number and re_time like '" + re_time + "%' order by id desc";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("stu_number", stu_number);
        List<Recharge> list=namedParameterJdbcTemplate.query(sql, sps,new BeanPropertyRowMapper<Recharge>(Recharge.class));
        if(list != null && list.size() >0){
            return list;
        }
        return null;
    }

    public int insertRecharge(Recharge recharge){
        String sql = "insert into recharge(order_num, card_number, user_name, account, re_time, state, stu_number) values(:order_num, :card_number, :user_name, :account, :re_time, :state, :stu_number)";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("order_num", recharge.getOrder_num());
        sps.addValue("card_number", recharge.getCard_number());
        sps.addValue("user_name", recharge.getUser_name());
        sps.addValue("account", recharge.getAccount());
        sps.addValue("re_time", recharge.getRe_time());
        sps.addValue("state", recharge.getState());
        sps.addValue("stu_number", recharge.getStu_number());
        int num = 0;
        try{
            num = namedParameterJdbcTemplate.update(sql, sps);
        }
        catch(Exception e){
            e.printStackTrace();
        }
        return num;
    }

    // 修改水费为已支付
    public int updatePay(String orderNo){
        String sql = "update `recharge` set pay_state=1 where order_num=:order_num";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("order_num", orderNo);
        int num = 0;
        try{
            num = namedParameterJdbcTemplate.update(sql, sps);
        }
        catch(Exception e){
            e.printStackTrace();
        }
        return num;
    }

    // 修改水费为已到账
    public int updateMoney(String orderNo){
        String sql = "update `recharge` set pay_state=2 where order_num=:order_num";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("order_num", orderNo);
        int num = 0;
        try{
            num = namedParameterJdbcTemplate.update(sql, sps);
        }
        catch(Exception e){
            e.printStackTrace();
        }
        return num;
    }

    // 插入充值电费记录
    public int insertRecharge2(Recharge_elc recharge){
        String sql = "insert into `recharge_elc`(order_num, card_number, user_name, account, re_time, state, stu_number, school, build, room,day_time,pointid) values(:order_num, :card_number, :user_name, :account, :re_time, :state, :stu_number, :school, :build, :room,:day_time,:pointid)";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("order_num", recharge.getOrder_num());
        sps.addValue("card_number", recharge.getCard_number());
        sps.addValue("user_name", recharge.getUser_name());
        sps.addValue("account", recharge.getAccount());
        sps.addValue("re_time", recharge.getRe_time());
        sps.addValue("state", recharge.getState());
        sps.addValue("stu_number", recharge.getStu_number());
        sps.addValue("school", recharge.getSchool());
        sps.addValue("build", recharge.getBuild());
        sps.addValue("room", recharge.getRoom());
        sps.addValue("day_time", recharge.getDay_time());
        sps.addValue("pointid", recharge.getPointid());
        int num = 0;
        try{
            num = namedParameterJdbcTemplate.update(sql, sps);
        }
        catch(Exception e){
            e.printStackTrace();
        }
        return num;
    }

    // 修改电费支付状态为已支付
    public int succRecharge2(String orderNo){
        String sql = "update `recharge_elc` set state=1 where order_num=:order_num";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("order_num", orderNo);
        int num = 0;
        try{
            num = namedParameterJdbcTemplate.update(sql, sps);
        }
        catch(Exception e){
            e.printStackTrace();
        }
        return num;
    }

    // 修改电费支付状态为已到账
    public int succRecharge3(String order_num){
        String sql = "update `recharge_elc` set `state`=2 where order_num=:order_num";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("order_num", order_num);
        int num = 0;
        try{
            num = namedParameterJdbcTemplate.update(sql, sps);
        }
        catch(Exception e){
            e.printStackTrace();
        }
        return num;
    }

    //根据订单号查找支付记录信息
    public Recharge findPayByNo(String order_num) {
        String sql = "select * from recharge where `pay_state`=2 and order_num=:order_num";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("order_num", order_num);
        Recharge recharge = null;
        try{
            recharge = namedParameterJdbcTemplate.queryForObject(sql, sps, new BeanPropertyRowMapper<Recharge>(Recharge.class));
        }
        catch(Exception e){
            recharge = null;
        }
        return recharge;
    }

    //根据订单号查找电费支付记录信息，未支付成功
    public Recharge_elc findPayElByNo(String order_num) {
        String sql = "select * from recharge_elc where order_num=:order_num ";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("order_num", order_num);
        Recharge_elc recharge = null;
        try{
            recharge = namedParameterJdbcTemplate.queryForObject(sql, sps, new BeanPropertyRowMapper<Recharge_elc>(Recharge_elc.class));
        }
        catch(Exception e){
            recharge = null;
        }
        return recharge;
    }

    public List<Recharge_elc> queryRecordByStu(String stu_number, String re_time){
        String sql="select * from recharge_elc where `stu_number`=:stu_number and `state`=2 and `re_time` like '"+ re_time +"%' order by id desc";
        MapSqlParameterSource sps = new MapSqlParameterSource();
        sps.addValue("stu_number", stu_number);
        List<Recharge_elc> list=namedParameterJdbcTemplate.query(sql, sps,new BeanPropertyRowMapper<Recharge_elc>(Recharge_elc.class));
        if(list != null && list.size() >0){
            return list;
        }
        return null;
    }



}