update codes

lib/shell/hive2csv.sh

@@ -15,6 +15,8 @@ timestamp=`date +"%Y%m%d%H%M%S"`
 tmp_file_name="/data/bi-report/tmp/tmp_"$timestamp".sql"
 result_file_name="/data/bi-report/result/"$1"_"$partition_date".csv"
 
+[ $? -eq 0 ] || exit 1
+
 #输入的账期为空，则取T+1默认账期
 if [ -z ${V_DATE} ];then
     V_DATE=`date --date="-1 day" +%Y-%m-%d`
@@ -53,6 +55,8 @@ sed -i "s/\$V_7DAYMD_AGO/$V_7DAYMD_AGO/g" $tmp_file_name
 sed -i "s/\$V_1DAY_M_D_AGO/$V_1DAY_M_D_AGO/g" $tmp_file_name
 sed -i "s/\$V_7DAY_M_D_AGO/$V_7DAY_M_D_AGO/g" $tmp_file_name
 
+[ $? -eq 0 ] || exit 1
+
 # 新标签与新标签对应集合类型 的对应关系
 /opt/hive/hive-1.1.0-cdh5.16.1/bin/beeline -u jdbc:hive2://bj-gm-prod-cos-datacenter004:10000 -n data --outputformat=csv2 --showHeader=true -e "`cat $tmp_file_name`" > $result_file_name
 rm -rf $tmp_file_name

lib/shell/hive2hive.sh

@@ -13,6 +13,8 @@ V_DATE=$2
 timestamp=`date +"%Y%m%d%H%M%S"`
 tmp_file_name="/data/bi-report/tmp/tmp_"$timestamp".sql"
 
+[ $? -eq 0 ] || exit 1
+
 #输入的账期为空，则取T+1默认账期
 if [ -z ${V_DATE} ];then
     V_DATE=`date --date="-1 day" +%Y-%m-%d`
@@ -51,6 +53,8 @@ sed -i "s/\$V_7DAYMD_AGO/$V_7DAYMD_AGO/g" $tmp_file_name
 sed -i "s/\$V_1DAY_M_D_AGO/$V_1DAY_M_D_AGO/g" $tmp_file_name
 sed -i "s/\$V_7DAY_M_D_AGO/$V_7DAY_M_D_AGO/g" $tmp_file_name
 
+[ $? -eq 0 ] || exit 1
+
 # 新标签与新标签对应集合类型 的对应关系
 /opt/hive/hive-1.1.0-cdh5.16.1/bin/beeline -u jdbc:hive2://bj-gm-prod-cos-datacenter004:10000 -n data -e "`cat $tmp_file_name`"
 rm -rf $tmp_file_name

lib/shell/sparksql2csv.sh

@@ -50,6 +50,8 @@ sed -i "s/\$V_7DAYMD_AGO/$V_7DAYMD_AGO/g" tmp.sql
 sed -i "s/\$V_1DAY_M_D_AGO/$V_1DAY_M_D_AGO/g" tmp.sql
 sed -i "s/\$V_7DAY_M_D_AGO/$V_7DAY_M_D_AGO/g" tmp.sql
 
+[ $? -eq 0 ] || exit 1
+
 # 新标签与新标签对应集合类型 的对应关系
 /opt/spark/spark-2.4.5-bin-hadoop2.7/bin/beeline -u jdbc:hive2://bj-gm-prod-cos-datacenter003:10010/online -n data --outputformat=csv2 --showHeader=true -e "`cat tmp.sql`">$2
 rm -rf tmp.sql

lib/shell/sparksql2email.sh

@@ -15,6 +15,8 @@ timestamp=`date +"%Y%m%d%H%M%S"`
 tmp_file_name="/data/bi-report/tmp/tmp_"$timestamp".sql"
 result_file_name="/data/bi-report/result/"$1"_"$partition_date".csv"
 
+[ $? -eq 0 ] || exit 1
+
 #输入的账期为空，则取T+1默认账期
 if [ -z ${V_DATE} ];then
     V_DATE=`date --date="-1 day" +%Y-%m-%d`
@@ -53,11 +55,17 @@ sed -i "s/\$V_7DAYMD_AGO/$V_7DAYMD_AGO/g" $tmp_file_name
 sed -i "s/\$V_1DAY_M_D_AGO/$V_1DAY_M_D_AGO/g" $tmp_file_name
 sed -i "s/\$V_7DAY_M_D_AGO/$V_7DAY_M_D_AGO/g" $tmp_file_name
 
+[ $? -eq 0 ] || exit 1
+
 # 新标签与新标签对应集合类型 的对应关系
 
 /opt/spark/spark-2.4.5-bin-hadoop2.7/bin/beeline -u jdbc:hive2://bj-gm-prod-cos-datacenter003:10010/online -n data --outputformat=csv2 --showHeader=true -e "`cat $tmp_file_name`"> $result_file_name
+[ $? -eq 0 ] || exit 1
+
 rm -rf $tmp_file_name
 
+[ $? -eq 0 ] || exit 1
+
 to=$2
 cc=$3
 echo "to: "$to

lib/shell/waitsuccess.sh

@@ -17,6 +17,8 @@ export DB=$2
 export TABLE=$3
 export PARTITIONS=$yesterday_date
 
+[ $? -eq 0 ] || exit 1
+
 /bin/bash /srv/apps/data-ready-checker/client/bin/checker.sh
 
 exit $?
\ No newline at end of file