#! /bin/bash

. /opt/app/bi-app/energy/dayTask/config.sh

if [ -n "$2" ] ;then
    echo "如果是输入的日期按照取输入日期"
    do_date=$2
else
    echo "====没有输入数据的日期,取当前时间的前一天===="
    do_date=`date -d yesterday +"%Y-%m-%d"`
fi

echo $do_date

host=$MYSQL_HOST
username=$MYSQL_USER
password=$MYSQL_PASSWORD
database=saga_dev

del_energy_15_min="delete from energy_15_min where dt = '$do_date';"
del_energy_15_min_fjd="delete from energy_15_min_fjd where dt = '$do_date';"

#del_energy_15_min="truncate table energy_15_min;"
#del_energy_5_min="truncate table energy_5_min;"
#del_energy_15_min_fjd="truncate table energy_15_min_fjd;"
#del_energy_5_min_fjd="truncate table energy_5_min_fjd;"

## 历史数据一次性导入后,需要删除 mysql 中的冗余数据
clean_energy_15(){
mysql -h${host}  -P3306  -u${username} -p${password} ${database} -e "${del_energy_15_min}"
}

clean_energy_5(){
mysql -h${host}  -P3306  -u${username} -p${password} ${database} -e "${del_energy_5_min}"
}

clean_energy_15_fjd(){
mysql -h${host}  -P3306  -u${username} -p${password} ${database} -e "${del_energy_15_min_fjd}"
}

clean_energy_5_fjd(){
mysql -h${host}  -P3306  -u${username} -p${password} ${database} -e "${del_energy_5_min_fjd}"
}

case $1 in
"all")
    clean_energy_15
    clean_energy_15_fjd
    clean_energy_5
    clean_energy_5_fjd
  ;;
"clean_15")
    clean_energy_15
    clean_energy_15_fjd
  ;;
"clean_5")
    clean_energy_5
    clean_energy_5_fjd
  ;;
"clean_energy_15")
    clean_energy_15
  ;;
"clean_energy_15_fjd")
    clean_energy_15_fjd
  ;;
"clean_energy_5")
    clean_energy_5
  ;;
"clean_energy_5_fjd")
    clean_energy_5_fjd
  ;;
esac