qinglong/shell/task.sh

#!/usr/bin/env bash

## 导入通用变量与函数
dir_shell=/ql/shell
. $dir_shell/share.sh
. $dir_shell/api.sh

## 选择python3还是node
define_program() {
    local p1=$1
    if [[ $p1 == *.js ]]; then
        which_program="node"
    elif [[ $p1 == *.py ]]; then
        which_program="python3"
    elif [[ $p1 == *.sh ]]; then
        which_program="bash"
    elif [[ $p1 == *.ts ]]; then
        which_program="ts-node-transpile-only"
    else
        which_program=""
    fi
}

random_delay() {
    local random_delay_max=$RandomDelay
    if [[ $random_delay_max ]] && [[ $random_delay_max -gt 0 ]]; then
        local current_min=$(date "+%-M")
        if [[ $current_min -ne 0 ]] && [[ $current_min -ne 30 ]]; then
            delay_second=$(($(gen_random_num $random_delay_max) + 1))
            echo -e "\n命令未添加 \"now\"，随机延迟 $delay_second 秒后再执行任务，如需立即终止，请按 CTRL+C...\n"
            sleep $delay_second
        fi
    fi
}

## scripts目录下所有可运行脚本数组
gen_array_scripts() {
    local dir_current=$(pwd)
    local i="-1"
    cd $dir_scripts
    for file in $(ls); do
        if [ -f $file ] && [[ $file == *.js && $file != sendNotify.js ]]; then
            let i++
            array_scripts[i]=$(echo "$file" | perl -pe "s|$dir_scripts/||g")
            array_scripts_name[i]=$(grep "new Env" $file | awk -F "'|\"" '{print $2}' | head -1)
            [[ -z ${array_scripts_name[i]} ]] && array_scripts_name[i]="<未识别出活动名称>"
        fi
    done
    cd $dir_current
}

## 使用说明
usage() {
    define_cmd
    gen_array_scripts
    echo -e "task命令运行本程序自动添加进crontab的脚本，需要输入脚本的绝对路径或去掉 “$dir_scripts/” 目录后的相对路径（定时任务中请写作相对路径），用法为："
    echo -e "1.$cmd_task <file_name>                  # 依次执行，如果设置了随机延迟，将随机延迟一定秒数"
    echo -e "2.$cmd_task <file_name> now              # 依次执行，无论是否设置了随机延迟，均立即运行，前台会输出日志，同时记录在日志文件中"
    echo -e "3.$cmd_task <file_name> conc <环境变量名>  # 并发执行，无论是否设置了随机延迟，均立即运行，前台不产生日志，直接记录在日志文件中"
    if [[ ${#array_scripts[*]} -gt 0 ]]; then
        echo -e "\n当前有以下脚本可以运行:"
        for ((i = 0; i < ${#array_scripts[*]}; i++)); do
            echo -e "$(($i + 1)). ${array_scripts_name[i]}：${array_scripts[i]}"
        done
    else
        echo -e "\n暂无脚本可以执行"
    fi
}

## run nohup，$1：文件名，不含路径，带后缀
run_nohup() {
    local file_name=$1
    nohup node $file_name &>$log_path &
}

## 正常运行单个脚本，$1：传入参数
run_normal() {
    local p1=$1
    cd $dir_scripts
    define_program "$p1"
    if [[ $p1 == *.js ]]; then
        if [[ $# -eq 1 ]]; then
            random_delay
        fi
    fi
    log_time=$(date "+%Y-%m-%d-%H-%M-%S")
    log_dir_tmp="${p1##*/}"
    log_dir="$dir_log/${log_dir_tmp%%.*}"
    log_path="$log_dir/$log_time.log"
    make_dir "$log_dir"

    local id=$(cat $list_crontab_user | grep -E "$cmd_task $p1" | perl -pe "s|.*ID=(.*) $cmd_task $p1\.*|\1|" | head -1 | awk -F " " '{print $1}')
    local begin_time=$(date '+%Y-%m-%d %H:%M:%S')
    echo -e "## 开始执行... $begin_time\n" | tee --output-error=warn  -a $log_path
    [[ $id ]] && update_cron "\"$id\"" "0" "$$" "$log_path"
    if [[ ! $(. $file_task_before) ]]; then
        . $file_task_before
    else
        echo -e "## task_before执行失败，自行检查\n" | tee --output-error=warn  -a $log_path
    fi

    timeout $command_timeout_time $which_program $p1 2>&1 | tee --output-error=warn  -a $log_path

    if [[ ! $(. $file_task_after) ]]; then
        . $file_task_after
    else
        echo -e "## task_after执行失败，自行检查\n" | tee --output-error=warn  -a $log_path
    fi
    [[ $id ]] && update_cron "\"$id\"" "1" "" "$log_path"
    local end_time=$(date '+%Y-%m-%d %H:%M:%S')
    local diff_time=$(($(date +%s -d "$end_time") - $(date +%s -d "$begin_time")))
    echo -e "\n## 执行结束... $end_time  耗时 $diff_time 秒" | tee --output-error=warn  -a $log_path
}

## 并发执行时，设定的 RandomDelay 不会生效，即所有任务立即执行
run_concurrent() {
    local p1=$1
    local p3=$3
    if [[ ! $p3 ]]; then
        echo -e "\n 缺少并发运行的环境变量参数"
        exit 1
    fi

    local envs=$(eval echo "\$${p3}")
    local array=($(echo $envs | sed 's/&/ /g'))
    cd $dir_scripts
    define_program "$p1"
    log_time=$(date "+%Y-%m-%d-%H-%M-%S")
    log_dir_tmp="${p1##*/}"
    log_dir="$dir_log/${log_dir_tmp%%.*}"
    log_path="$log_dir/$log_time.log"
    make_dir $log_dir

    local id=$(cat $list_crontab_user | grep -E "$cmd_task $p1" | perl -pe "s|.*ID=(.*) $cmd_task $p1\.*|\1|" | head -1 | awk -F " " '{print $1}')
    local begin_time=$(date '+%Y-%m-%d %H:%M:%S')
    echo -e "## 开始执行... $begin_time\n" | tee --output-error=warn  -a $log_path
    [[ $id ]] && update_cron "\"$id\"" "0" "$$" "$log_path"
    if [[ ! $(. $file_task_before) ]]; then
        . $file_task_before
    else
        echo -e "## task_before执行失败，自行检查\n" | tee --output-error=warn  -a $log_path
    fi
    echo -e "\n各账号间已经在后台开始并发执行，前台不输入日志，日志直接写入文件中。\n" | tee --output-error=warn  -a $log_path

    single_log_time=$(date "+%Y-%m-%d-%H-%M-%S.%N")
    for i in "${!array[@]}"; do
        export ${p3}=${array[i]}
        single_log_path="$log_dir/${single_log_time}_$((i+1)).log"
        timeout $command_timeout_time $which_program $p1 &>$single_log_path &
    done

    if [[ ! $(. $file_task_after) ]]; then
        . $file_task_after
    else
        echo -e "## task_after执行失败，自行检查\n" | tee --output-error=warn  -a $log_path
    fi
    [[ $id ]] && update_cron "\"$id\"" "1" "" "$log_path"
    local end_time=$(date '+%Y-%m-%d %H:%M:%S')
    local diff_time=$(($(date +%s -d "$end_time") - $(date +%s -d "$begin_time")))
    echo -e "\n## 执行结束... $end_time  耗时 $diff_time 秒" | tee --output-error=warn  -a $log_path
}

## 运行其他命令
run_else() {
    local log_time=$(date "+%Y-%m-%d-%H-%M-%S")
    local log_dir_tmp="${1##*/}"
    local log_dir="$dir_log/${log_dir_tmp%%.*}"
    log_path="$log_dir/$log_time.log"
    make_dir "$log_dir"

    local id=$(cat $list_crontab_user | grep -E "$cmd_task $p1" | perl -pe "s|.*ID=(.*) $cmd_task $p1\.*|\1|" | head -1 | awk -F " " '{print $1}')
    local begin_time=$(date '+%Y-%m-%d %H:%M:%S')
    echo -e "## 开始执行... $begin_time\n" | tee --output-error=warn  -a $log_path
    [[ $id ]] && update_cron "\"$id\"" "0" "$$" "$log_path"
    if [[ ! $(. $file_task_before) ]]; then
        . $file_task_before
    else
        echo -e "## task_before执行失败，自行检查\n" | tee --output-error=warn  -a $log_path
    fi

    timeout $command_timeout_time "$@" 2>&1 | tee --output-error=warn  -a $log_path

    if [[ ! $(. $file_task_after) ]]; then
        . $file_task_after
    else
        echo -e "## task_after执行失败，自行检查\n" | tee --output-error=warn  -a $log_path
    fi
    [[ $id ]] && update_cron "\"$id\"" "1" "" "$log_path"
    local end_time=$(date '+%Y-%m-%d %H:%M:%S')
    local diff_time=$(($(date +%s -d "$end_time") - $(date +%s -d "$begin_time")))
    echo -e "\n## 执行结束... $end_time  耗时 $diff_time 秒" | tee --output-error=warn  -a $log_path
}

## 命令检测
main() {
    case $# in
    0)
        echo
        usage
        ;;
    1)
        run_normal $1
        ;;
    2|3)
        case $2 in
        now)
            run_normal $1 $2
            ;;
        conc)
            run_concurrent $1 $2 $3
            ;;
        *)
            run_else "$@"
            ;;
        esac
        ;;
    *)
        run_else "$@"
        ;;
    esac
}

main "$@"

exit 0