#!/bin/bash ############################################################## # システム名 ：eo顧客基幹システム # # サブシステム名：料金管理 # # シェル名 ：設備卸契約情報抽出 # # 機能 ：設備卸契約情報を抽出し、設備卸契約情報を作成する。 # 設備卸契約情報から卸先事業者別集計ファイルを作成する。 # # # コマンド形式 ：EO31N0120J0.sh # # 実行環境 ：.../app/shl # # 終了ステータス：ゼロ以外異常 # # 特記事項 ：特になし # # 変更履歴 ：変更日 変更者 障害／仕様変更No. # v37.00.00 2018/4/2 FJ)鈴木 ANK-3366-00-00 新規作成 ｅｏ光設備卸対応 # v37.01.00 2018/5/8 FJ)鈴木 IT2-2018-0000037 インセンティブ料金情報の新規申込件数集計エラー # v39.00.00 2018/9/25 FJ)原田 ANK-3478-00-00 ｅｏ光設備卸対応(サービス開始対応) # v39.00.01 2018/10/2 FJ)原田 ANK-3478-00-00 ｅｏ光設備卸対応(サービス開始対応) 卸TVの地デジ・BSコース除外 # v39.00.02 2018/11/7 FJ)原田 ANK-3478-01-00 eo光設備卸（サービス開始対応）【12月末商用リリース分】 インセンティブ処理データ管理 ############################################################## ############################################################## # 環境変数定義 ############################################################## # #---ツール格納場所 # G_TOOLSH=. # #---環境変数定義Shell呼び出し # . EOK010110J0.sh # #---ＪＯＢ名 # JOBNAME=`basename $0 | sed -e "s/\.sh//g"` # #---サービス（業務プロセス） # SVC=$JOBNAME # #---OPD # OPD=$1 # # #---業務で必要な変数定義 # #--- マッチングツール定義ファイル # マッチングツール定義ファイル(お客様（アンロードデータ）-サービス契約（アンロードデータ）-卸先事業者契約異動通知（アンロードデータ）) MATCHDEFFILE1=${G_TOOLSH}/util/def/AC_CM_0137.def MATCHDEFFILE2=${G_TOOLSH}/util/def/AC_CM_0139.def # v39.00.01 ADD START MATCHDEFFILE3=${G_TOOLSH}/util/def/AC_CM_0152.def # v39.00.01 ADD END # v39.00.02 ADD START MATCHDEFFILE4=${G_TOOLSH}/util/def/AC_CM_0156.def # v39.00.02 ADD END # #--- ファイル定義 # # 入力ファイル #　お客様共通アンロード #ANK-3478-00-00 MOD START #INFILE1=${MID_DIR_CC}/CCIFM001001.csv INFILE1=${MID_DIR_CC}/CCIFM019002.csv #ANK-3478-00-00 MOD END #　サービス契約共通アンロード #ANK-3478-00-00 MOD START #INFILE2=${MID_DIR_CC}/CCIFM018002.csv INFILE2=${MID_DIR_CC}/CCIFM020002.csv #ANK-3478-00-00 MOD END # 卸先事業者契約異動通知アンロード INFILE3=${MID_DIR_AC}/ACIFM297001.csv # v39.00.02 ADD START # 卸先事業者インセンティブ実績管理アンロード INFILE4=${MID_DIR_AC}/ACIFM321001.csv # v39.00.02 ADD END # 一時ファイル #ANK-3478-00-00 MOD START #CUST_ALD_CP=${MID_DIR_AC}/CCIFM001001_cp_EO31N0120J0.csv #SVC_KEI_CP=${MID_DIR_AC}/CCIFM018002_cp_EO31N0120J0.csv #CUST_ALD_SORT=${MID_DIR_AC}/CCIFM001001_sort_EO31N0120J0.csv #SVC_KEI_EDIT=${MID_DIR_AC}/CCIFM018002_edit_EO31N0120J0.csv #CUST_ALD_EDIT=${MID_DIR_AC}/CCIFM001001_edit_EO31N0120J0.csv CUST_ALD_CP=${MID_DIR_AC}/CCIFM019002_cp_EO31N0120J0.csv SVC_KEI_CP=${MID_DIR_AC}/CCIFM020002_cp_EO31N0120J0.csv CUST_ALD_SORT=${MID_DIR_AC}/CCIFM019002_sort_EO31N0120J0.csv SVC_KEI_EDIT=${MID_DIR_AC}/CCIFM020002_edit_EO31N0120J0.csv CUST_ALD_EDIT=${MID_DIR_AC}/CCIFM019002_edit_EO31N0120J0.csv #ANK-3478-00-00 MOD END # マッチング結果ファイル MATCHING_FILE1=${MID_DIR_AC}/ACIFM298001_match1.csv STBORS_KEI_INFO=${MID_DIR_AC}/ACIFM298001.csv # v39.00.01 ADD START STBORS_KEI_ALL_INFO=${MID_DIR_AC}/ACIFM298001_ALL.csv STBORS_KEI_BF_EXCLUDE=${MID_DIR_AC}/ACIFM298001_BF_EXCLUDE.csv # v39.00.01 ADD END STBORS_WORK_FILE=${MID_DIR_AC}/ACIFM298001_edit_EO31N0120J0.csv # 設備卸契約情報 STBORS_CUNT_FILE=${MID_DIR_AC}/ACIFM298001_cunt_EO31N0120J0.csv # 設備卸契約集計ファイル SUMMARYFILE=${MID_DIR_AC}/ACIFM298001_summary_EO31N0120J0.csv # v39.00.02 ADD START STBORS_KEI_BF_EXCLUDE_2=${MID_DIR_AC}/ACIFM298001_BF_EXCLUDE_2.csv STBORS_KEI_BF_EXCLUDE_3=${MID_DIR_AC}/ACIFM298001_BF_EXCLUDE_3.csv ORSINV_JSK_KNRI_CP=${MID_DIR_AC}/ACIFM321001_cp_EO31N0120J0.csv ORSINV_JSK_KNRI_NEW_MSKM=${MID_DIR_AC}/ACIFM321001_new_mskm.csv # v39.00.02 ADD END # v39.00.01 ADD START #--- アンロードSQL定義ファイル # 卸先事業者契約異動通知アンロードSQL定義ファイル ULDSQL_KK3141=${SQL_DIR}/KK_U_KK3141_04.sql ULDFILE_KK3141_WK=${MID_DIR_CH}/KK_U_KK3141_04_WK.csv # v39.00.01 ADD END # 出力ファイル # 卸先事業者集計情報 OUTFILE=${MID_DIR_AC}/ACIFM299001.csv # v39.00.01 ADD START # #--- アンロード関数 # p1：出力ファイル名 # p2：クエリファイル名 # p3：バインド変数置換文字 EXEC_UNLOAD() { local _OTF=$1 local _SQL_FILE=$2 local _BIND_VAL=$3 local _SQL_WORK_FILE=${ULD_WORK_DIR}/${JOBNAME}.W_ULD.sql # SQLクエリファイル初期化 cat /dev/null > ${_SQL_WORK_FILE} # SQL定義ファイルが存在しない場合エラー if [ ! -r ${_SQL_FILE} ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " File is nonexist(${_SQL_FILE}) " echo $JOBNAME " File is nonexist(${_SQL_FILE}) " exit ${G_RTN_ERROR} fi cat ${_SQL_FILE} > ${_SQL_WORK_FILE} # バインド変数を置き換える if [ "${_BIND_VAL}" != "" ] then for bind in ${_BIND_VAL} do sed -i -e 0,/?/s/?/"'"$bind"'"/ ${_SQL_WORK_FILE} done fi # 出力ファイルの初期化 cat /dev/null > ${_OTF} # アンロード sh ${G_TOOLSH}/EOKULD02.sh ${_SQL_WORK_FILE} ${_OTF} rc=$? if [ $rc -ne 0 ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " unload error(${_SQL_FILE}:rc=$rc) " echo $JOBNAME " unload error(${_SQL_FILE}:rc=$rc) " exit ${G_RTN_ERROR} fi # 一時ファイル削除 rm -f ${_SQL_WORK_FILE} } # v39.00.01 ADD END ############################################################## # 共通関数 ############################################################## # #--- マッチング処理 # p1：出力ファイルパス # p2：マッチングクエリファイルパス EXEC_MATCHING() { local _OUTFILE=$1 local _MATCHING_FILE=$2 # マッチングクエリファイルの存在チェック if [ ! -r ${_MATCHING_FILE} ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " File is nonexist(${_MATCHING_FILE}) " echo $JOBNAME " File is nonexist(${_MATCHING_FILE}) " exit ${G_RTN_ERROR} fi # 出力ファイルの初期化 cat /dev/null > ${_OUTFILE} # マッチング実行 export ZTLOUTFILE=${_OUTFILE} ${G_TOOLSH}/util/bin/ZTLMAT01 ${_MATCHING_FILE} rc=$? if [ $rc -ne 0 ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " matching error($2:rc=$rc) " echo $JOBNAME " matching error($2:rc=$rc) " exit ${G_RTN_ERROR} fi } # #--- bsortexコマンド実行時のエラー処理 # p1：bsortexコマンドの終了コード # p2：bsortexコマンドの入力ファイル BSORT_ERROR() { sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " bsortex error(input file=$2:rc=$1) " echo $JOBNAME " bsortex error(input file=$2:rc=$1) " exit ${G_RTN_ERROR} } # #xxx=xxxxxxx ############################################################## # 業務処理 ############################################################## sh ${G_TOOLSH}/EOK010210J0.sh CS00025I $JOBNAME # #---運用日付取得 # if [ "${OPD}" = "" ]; then . EOK010310J0.sh "BDATE" else RSLT_OPEDATE="${OPD}" fi #---前月末日を取得 NOW_MONTH_ONEDAY=`date -d "${RSLT_OPEDATE}" +'%Y%m'`01 PREV_MONTH_LASTDAY=`date -d "-1 day ${NOW_MONTH_ONEDAY}" +'%Y%m%d'` #---前月1日を取得 PREV_MONTH_ONEDAY=`date -d "-1 month ${RSLT_OPEDATE}" +'%Y%m'`01 #---翌月1日を取得 NEXT_MONTH_ONEDAY=`date -d "1 month ${RSLT_OPEDATE}" +'%Y%m'`01 #---請求年月を取得 SEIKY_YM=`echo ${PREV_MONTH_ONEDAY} | cut -c 1-6` # #--- お客様共通アンロードファイルの複製 # # ファイルの存在チェック if [ ! -r ${INFILE1} ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " File is nonexist(${INFILE1}) " echo $JOBNAME " File is nonexist(${INFILE1}) " exit ${G_RTN_ERROR} fi cp -fp ${INFILE1} ${CUST_ALD_CP} # #--- サービス契約共通アンロードファイルの複製 # # ファイルの存在チェック if [ ! -r ${INFILE2} ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " File is nonexist(${INFILE2}) " echo $JOBNAME " File is nonexist(${INFILE2}) " exit ${G_RTN_ERROR} fi cp -fp ${INFILE2} ${SVC_KEI_CP} # v39.00.02 ADD START # #--- 卸先事業者インセンティブ実績管理アンロードファイルの複製 # # ファイルの存在チェック if [ ! -r ${INFILE4} ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " File is nonexist(${INFILE4}) " echo $JOBNAME " File is nonexist(${INFILE4}) " exit ${G_RTN_ERROR} fi cp -fp ${INFILE4} ${ORSINV_JSK_KNRI_CP} # #--- 卸先事業者インセンティブ実績管理アンロード複製ファイルから #--- インセンティブ計算区分が”1：新規申込料金”であるデータを取得する。 # bsortex -sort key=1.10asc -record recform=txtcsv \ -input file=${ORSINV_JSK_KNRI_CP} reclen=55 \ include="3.1ascn.eq.'1'" \ -output file=${ORSINV_JSK_KNRI_NEW_MSKM} \ reconst="1.10" # v39.00.02 ADD END # v39.00.01 ADD START # #---1. 卸先事業者アンロード処理 # EXEC_UNLOAD ${ULDFILE_KK3141_WK} ${ULDSQL_KK3141} ${RSLT_OPEDATE} # v39.00.01 ADD END # #--- 1.お客様共通アンロードファイルの抽出・ソート #　抽出条件 # 卸先事業者コード≠null # # 0.10　SYSID # 1.17　世代年月日時分秒 # 8.2　卸先事業者コード #ANK-3478-00-00 MOD START #bsortex -sort key=0.10asc,1.17asc,8.2asc -record recform=txtcsv \ # -input file=${CUST_ALD_CP} reclen=321 \ # include="8.2ascn.gt.' '" \ # -output file=${CUST_ALD_SORT} \ # reconst="0.10,8.2,1.17" bsortex -sort key=0.10asc,1.17asc,8.2asc -record recform=txtcsv \ -input file=${CUST_ALD_CP} reclen=${ULD2_REC_LEN_CK0011} \ include="33.2ascn.gt.' '" \ -output file=${CUST_ALD_SORT} \ reconst="0.10,33.2,1.17" #ANK-3478-00-00 MOD END rc=$? if [ $rc -ne 0 ] then BSORT_ERROR ${rc} ${CUST_ALD_SORT} fi # #--- マージ（各キー項目毎のカレントレコードのみを残す） # 世代年月日時分秒が最大のレコードを取得する bsortex -merge key=0.17asc -record recform=txtcsv \ -input file=${CUST_ALD_SORT} reclen=321 -summary suppress last \ -output file=${CUST_ALD_EDIT} \ reconst="0.10,1.2" rc=$? if [ $rc -ne 0 ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " MERGE Error($SVC merge:rc=$rc) " echo $JOBNAME " MERGE Error($SVC merge:rc=$rc) " exit ${G_RTN_ERROR} fi # #--- 2.サービス契約共通アンロードファイルの抽出・ソート #　抽出条件 # サービス開始年月日≦運用日の前月末日 # # 0.10　サービス契約番号 # 1.17　世代年月日時分秒 # 3.10　SYSID # 4.2　サービスコード # 19.8　サービス開始年月日 # v39.00.02 MOD START ##ANK-3478-00-00 MOD START ##bsortex -sort key=0.10asc,1.17asc,3.10asc,4.2asc -record recform=txtcsv \ ## -input file=${SVC_KEI_CP} reclen=397 \ ## include="19.8asc.ge.'${PREV_MONTH_ONEDAY}'.and.19.8asc.le.'${PREV_MONTH_LASTDAY}'" \ ## -output file=${SVC_KEI_EDIT} \ ## reconst="0.10,3.10,4.2" #bsortex -sort key=0.10asc,1.17asc,3.10asc,4.2asc -record recform=txtcsv \ # -input file=${SVC_KEI_CP} reclen=${ULD2_REC_LEN_KK0081} \ # include="22.8asc.ge.'${PREV_MONTH_ONEDAY}'.and.22.8asc.le.'${PREV_MONTH_LASTDAY}'" \ # -output file=${SVC_KEI_EDIT} \ # reconst="0.10,3.10,4.2" ##ANK-3478-00-00 MOD END bsortex -sort key=0.10asc,1.17asc,3.10asc,4.2asc -record recform=txtcsv \ -input file=${SVC_KEI_CP} reclen=${ULD2_REC_LEN_KK0081} \ include="22.8asc.gt.' '.and.22.8asc.le.'${PREV_MONTH_LASTDAY}'" \ -output file=${SVC_KEI_EDIT} \ reconst="0.10,3.10,4.2" # v39.00.02 MOD END rc=$? if [ $rc -ne 0 ] then BSORT_ERROR ${rc} ${SVC_KEI_EDIT} fi # # --- 3.マッチング１ # # お客様共通アンロード抽出ファイル、サービス契約アンロード抽出ファイルをマッチング # SYSID export CUST_ALD_EDIT export SVC_KEI_EDIT EXEC_MATCHING ${MATCHING_FILE1} ${MATCHDEFFILE1} # # --- 4.マッチング２ # # マッチングファイル１、卸先事業者契約異動通知アンロードファイルをマッチング # 卸先事業者コード、サービス契約コード export INFILE3 export MATCHING_FILE1 # v39.00.01 MOD START #EXEC_MATCHING ${STBORS_KEI_INFO} ${MATCHDEFFILE2} EXEC_MATCHING ${STBORS_KEI_ALL_INFO} ${MATCHDEFFILE2} # v39.00.01 MOD END # v39.00.01 ADD START # ここでマッチングして除外対象をあぶりだす。 # STBORS_KEI_ALL_INFO と ULDFILE_KK3141_WK のマッチング（卸事業者コードとサービス契約番号のLEFT JOIN） # STBORS_KEI_BF_EXCLUDE に出力 # # --- 4.マッチング３ # マッチング２で出力したレコードの内、出力対象外のレコードをマッチング処理にて特定する export STBORS_KEI_ALL_INFO export ULDFILE_KK3141_WK EXEC_MATCHING ${STBORS_KEI_BF_EXCLUDE} ${MATCHDEFFILE3} # STBORS_KEI_BF_EXCLUDE で印のつけたレコードを # 除外して STBORS_KEI_INFO に出力 # v39.00.02 MOD START #bsortex -sort key=0.2asc,1.10asc -record recform=txtcsv \ # -input file=${STBORS_KEI_BF_EXCLUDE} reclen=35 \ # include="3.10asc.lt.' '" \ # -output file=${STBORS_KEI_INFO} \ # reconst="0.2,1.10,2.2" # bsortex -sort key=0.2asc,1.10asc -record recform=txtcsv \ -input file=${STBORS_KEI_BF_EXCLUDE} reclen=35 \ include="3.10asc.lt.' '" \ -output file=${STBORS_KEI_BF_EXCLUDE_2} \ reconst="0.2,1.10,2.2" # v39.00.02 MOD END rc=$? if [ $rc -ne 0 ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " SORT Error($SVC sort:rc=$rc) " echo $JOBNAME " SORT Error($SVC sort:rc=$rc) " exit ${G_RTN_ERROR} fi # v39.00.01 ADD END # v39.00.02 ADD START # # --- 4.マッチング４ # マッチング３で出力したレコードの内、出力対象外のレコードをマッチング処理にて特定する # （卸先事業者インセンティブ実績管理に登録してるサービス契約番号と一致するデータを除外対象とする。） export STBORS_KEI_BF_EXCLUDE_2 export ORSINV_JSK_KNRI_NEW_MSKM EXEC_MATCHING ${STBORS_KEI_BF_EXCLUDE_3} ${MATCHDEFFILE4} # STBORS_KEI_BF_EXCLUDE_3 で印のつけたレコードを # 除外して STBORS_KEI_INFO に出力 bsortex -sort key=0.2asc,1.10asc -record recform=txtcsv \ -input file=${STBORS_KEI_BF_EXCLUDE_3} reclen=35 \ include="3.10asc.lt.' '" \ -output file=${STBORS_KEI_INFO} \ reconst="0.2,1.10,2.2" # v39.00.02 ADD END # ダブルクォートを削除 # cat ${STBORS_KEI_INFO} | sed -e 's/"//g' > ${STBORS_WORK_FILE} # # --- 5.ファイル編集 # --- 件数「1」を設定する # ソートキー：卸先事業者コード、サービスコード # bsortex -sort key=0.2asc,2.2asc -record recform=txtcsv \ -input file=${STBORS_WORK_FILE} reclen=23 \ -output file=${STBORS_CUNT_FILE} \ reconst="0.2,1.10,2.2,'1'.1asc" rc=$? if [ $rc -ne 0 ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " SORT Error($SVC sort:rc=$rc) " echo $JOBNAME " SORT Error($SVC sort:rc=$rc) " exit ${G_RTN_ERROR} fi # # --- サマリー処理 # ソートキー：卸先事業者コード、サービスコード # ソートキー毎に件数の合計値を集計する。 # #IT2-2018-0000037 MOD START #bsortex -sort key=0.2asc,2.2asc \ # -record recform=txtcsv -summary field=3.1ascud \ # -input file=${STBORS_CUNT_FILE} reclen=30 \ # -output file=${SUMMARYFILE} \ # reconst="0.2,2.2,3.1" # #rc=$? #if [ $rc -ne 0 ] #then # sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " SORT Error($SVC sort:rc=$rc) " # echo $JOBNAME " SORT Error($SVC sort:rc=$rc) " # exit ${G_RTN_ERROR} #fi bsortex -sort key=0.2asc,2.2asc \ -record recform=txtcsv -summary field=3.10ascud \ -input file=${STBORS_CUNT_FILE} reclen=30 \ -output file=${SUMMARYFILE} \ reconst="0.2,2.2,3.10" rc=$? if [ $rc -ne 0 ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " SORT Error($SVC sort:rc=$rc) " echo $JOBNAME " SORT Error($SVC sort:rc=$rc) " exit ${G_RTN_ERROR} fi #IT2-2018-0000037 MOD END # #---ダブルクォート付与（すでにダブルクォートが付いている場合は何もしない） # nkf -d ${SUMMARYFILE} |sed -e "s/^\"*/\"/" |sed -e "s/\"*$/\"/" |sed -e "s/,/\",\"/g" > ${OUTFILE} rc=$? if [ $rc -ne 0 ] then sh ${G_TOOLSH}/EOK010210J0.sh CS00002E $JOBNAME " SED Error($SVC sed:rc=$rc) " echo $JOBNAME " SED Error($SVC sed:rc=$rc) " exit ${G_RTN_ERROR} fi # #--- 不要ファイルの削除を行う # rm -f ${CUST_ALD_CP} rm -f ${SVC_KEI_CP} rm -f ${CUST_ALD_SORT} rm -f ${CUST_ALD_EDIT} rm -f ${SVC_KEI_EDIT} # v39.00.01 DEL START # rm -f ${STBORS_KEI_INFO} # v39.00.01 DEL END rm -f ${MATCHING_FILE1} rm -f ${STBORS_WORK_FILE} rm -f ${STBORS_CUNT_FILE} rm -f ${SUMMARYFILE} # v39.00.01 ADD START rm -f ${STBORS_KEI_ALL_INFO} rm -f ${STBORS_KEI_BF_EXCLUDE} rm -f ${ULDFILE_KK3141_WK} # v39.00.01 ADD END # v39.00.02 ADD START rm -f ${ORSINV_JSK_KNRI_CP} rm -f ${ORSINV_JSK_KNRI_NEW_MSKM} rm -f ${STBORS_KEI_BF_EXCLUDE_2} rm -f ${STBORS_KEI_BF_EXCLUDE_3} # v39.00.02 ADD END # #--- ジョブの終了メッセージを出力する # sh ${G_TOOLSH}/EOK010210J0.sh CS00028I $JOBNAME sh ${G_TOOLSH}/EOK010210J0.sh CS00026I $JOBNAME exit ${G_RTN_NORMAL}