#!/bin/bash
source ~/.bash_profile
source ~/.bashrc
conda activate tf2 

cd /data/OffLineRec

#1. download data
nowday=`date  +"%Y%m%d" -d -0days`
last7day=`date  +"%Y%m%d" -d -15days`
echo ${nowday} 
echo ${last7day}
mkdir -p ./data/
mkdir -p ./logs/
#conda activate py36

nowhour=`date  +"%Y%m%d%H" -d -0days`
nowstart=$nowday'000000'
nowhour=${nowhour}'0000'
#nowhour='20230601140000'
echo $nowhour
echo ${nowstart}
echo ${last7day}

#python extract_cur_share_log.py ${nowstart} ${nowhour}
#if [ $? -ne 0 ];
#then
   # msg = "[ERROR] simrecall extract_share_log"
   # sh sendmsg.sh  $nowday  $msg
   # echo "[ERROR] echo 'extract_share_log"
   # exit 255
#fi


python extract_share_log.py ${last7day} ${nowday}
if [ $? -ne 0 ];
then
    msg = "[ERROR] simrecall extract_share_log"
    #sh sendmsg.sh  $nowday  $msg
    echo "[ERROR] echo 'extract_share_log"
    exit 255
fi

python filter_video.py ./data/user_item_share_${nowday} ./data/user_item_share_filter_${nowday}


exit
#nowday='20230505'
#2. cal i2i result
#python calI2I2.py ${nowday}  ${nowhour}
if [ $? -ne 0 ];
then
    msg = "[ERROR] simrecall calI2I.py"
    #sh sendmsg.sh $nowday $msg
    echo $msg
    exit -1
fi

#3.import res
#python import_redist.py "./data/rec_result3_"${nowhour}".json"  "./data/redis_cls_"${nowhour}".json"
if [ $? -ne 0 ];
then
    msg = "[ERROR] simhot recall import_redist.py"
    sh sendmsg.sh  $nowday  $msg
    echo $msg
    exit -1
fi
echo 'finish sorted'