/******************************************************************************* * All Rights reserved,Copyright (c) K-Opticom ******************************************************************************** *＜プログラム内容＞ * システム名：eo顧客基幹システム * モジュール名：JSYejbECR0341B010TPDA * ソースファイル名：JSYejbECR0341B010TPDA.java * 作成者：EK909496 * 日付：2011年08月15日 *＜機能概要＞ * SQLFacility * テンプレートDBアクセス部品です。 *＜修正履歴＞ * バージョン修正日修正者修正内容 * ｖ1.00.00 * ｖ6.00.00 2013/10/09 FJ)日野【OM-2013-0003328】0件表示対応 * v29.00.00 2017/03/01 FJ)クウン ANK-2923-00-00_(客B) 担当者モニタへの担当者検索条件追加 * ********************************************************************************/ package eo.ejb.cbs.sqlf; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import com.fujitsu.futurity.model.base.CAANJDBCUtil; import com.fujitsu.futurity.model.base.CAANMsg; import com.fujitsu.futurity.model.base.CAANRuntimeException; import com.fujitsu.futurity.model.base.CAANSQLFacility; import com.fujitsu.futurity.model.ejb.common.JSYejbConnection; import com.fujitsu.futurity.model.ejb.common.JSYejbLog; import com.fujitsu.futurity.model.ejb.common.StatusCodes; import com.fujitsu.futurity.model.ejb.common.fw.AgentDispatchContext; import com.fujitsu.futurity.model.ejb.common.fw.TemplateDBAccessHandler; import eo.common.constant.JCRStrConst; import eo.common.constant.JPCModelConstant; import eo.common.util.JKKStringUtil; import eo.ejb.cbm.entity.CR0341ETMsg; import eo.ejb.cbs.cbsmsg.ECR0341B010CBSMsg; import eo.ejb.cbs.cbsmsg.ECR0341B010CBSMsg1List; /** * * テンプレートDBアクセス部品　ECR0341B010_SQLF
* 入力された項目からSQL文を動的に組み立て、
* 検索結果をCBSMsgにセットします。
*/ public class JSYejbECR0341B010TPDA extends CAANSQLFacility implements TemplateDBAccessHandler{ /** * コンストラクタ */ public JSYejbECR0341B010TPDA() { } /** * ECR0341B010_SQLF
* @param inMsg 入力値の格納されたCBSMsg
* @return void */ public void invoke(CAANMsg inMsg,AgentDispatchContext inContext){ // コネクション Connection con1 = null; // プリペアステートメント PreparedStatement pstmt = null; // リザルトセット ResultSet rsltQuery = null; //--------------------------------修正Start----------------------------------------------- // ソート指定項目 String sortShiteiKmk = inMsg.getString(ECR0341B010CBSMsg.KEY_SORT_SHITEI_KMK); // 全件出力フラグ String allOutputFlg = inMsg.getString(ECR0341B010CBSMsg.ALL_OUTPUT_FLG); /******************** * SQL文の作成 ********************/ try{ //コネクション取得 con1 = JSYejbConnection.getConnection(CR0341ETMsg.getTableName()); // SQL文_基本部1 StringBuffer sql_Buff = new StringBuffer(); sql_Buff.append(" SELECT UTM1.USER_ID, ") .append(" UTM1.USER_NM, ") .append(" SUM(UTM1.NEW_SAKSEI_SHUK_CNT) AS NEW_SAKSEI_SHUK_CNT, ") .append(" SUM(UTM1.CLOSE_SHUK_CNT) AS CLOSE_SHUK_CNT, ") .append(" SUM(UTM1.NG_WORD_SHUK_CNT) AS NG_WORD_SHUK_CNT ") .append(" FROM "); // 全件表示フラグ0のとき各集計件数が全て0のレコードは表示しない // ユーザー別問合せモニタに登録されているレコードからのみデータ取得 if(JCRStrConst.ALL_OUTPUT_FLG_OFF.equals(allOutputFlg)) { sql_Buff.append(" CR_T_USER_TOIAWSMNT UTM1 ") .append(" WHERE UTM1.WKKBT_ORG_CD IN( ") .append(inMsg.getString(ECR0341B010CBSMsg.KEY_WKKBT_ORG_CD)) .append(" ) ") .append(" AND (UTM1.HASSEI_YMD >= ? AND UTM1.HASSEI_YMD <= ?) ") .append(" AND (UTM1.NEW_SAKSEI_SHUK_CNT > 0 OR UTM1.CLOSE_SHUK_CNT > 0 OR UTM1.NG_WORD_SHUK_CNT > 0) ") .append(" AND UTM1.MK_FLG = '0' "); //---------v29.00.00 追加開始---------// //従業員番号が「null」、空白以外の場合、下記の処理を実施する if ((!JKKStringUtil.isNullBlank(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID))) && (!JKKStringUtil.isNullSpace(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID)))){ sql_Buff.append(" AND UTM1.USER_ID in ('") .append(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID)) .append("') "); }; //---------v29.00.00 追加終了---------// } // v6.00.00追加全件表示フラグ0以外は、該当する全てのユーザーを表示する // ワークグループに所属するユーザーを洗い出しユーザー別問合せモニタと結合してレコード取得 else { sql_Buff.append(" (SELECT ") .append(" USR_TMP.USER_ID, ") .append(" USR_TMP.USER_NM, ") .append(" NVL(UTM_TEMP.NEW_SAKSEI_SHUK_CNT,0) AS NEW_SAKSEI_SHUK_CNT, ") .append(" NVL(UTM_TEMP.CLOSE_SHUK_CNT,0) AS CLOSE_SHUK_CNT, ") .append(" NVL(UTM_TEMP.NG_WORD_SHUK_CNT,0) AS NG_WORD_SHUK_CNT ") .append(" FROM ") .append(" (SELECT ") .append(" HTG.USER_ID, ") //---------v29.00.00 変更開始---------// .append(" (SELECT USR.USER_NM FROM ZM_M_USER USR WHERE HTG.USER_ID = USR.USER_ID"); //従業員番号が「null」、空白以外の場合、下記の処理を実施する if ((!JKKStringUtil.isNullBlank(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID))) && (!JKKStringUtil.isNullSpace(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID)))){ sql_Buff.append(" AND HTG.USER_ID IN ( '") .append(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID)) .append("')"); } sql_Buff.append(" ) AS USER_NM ") //---------v29.00.00 変更終了---------// .append(" FROM ") .append(" ZM_M_USER_HTG_KGGRP HTG ") .append(" WHERE ") .append(" EXISTS (SELECT ") .append(" * ") .append(" FROM ") .append(" ZM_M_AUTHORITY_GRP GRP ") .append(" WHERE ") .append(" GRP.WKKBT_ORG_CD IN( ") .append(inMsg.getString(ECR0341B010CBSMsg.KEY_WKKBT_ORG_CD)) .append(" ) ") .append(" AND HTG.KGGRP_CD = GRP.KGGRP_CD ") .append(" AND GRP.MK_FLG = '0') ") //---------v29.00.00 変更開始---------// .append(" AND HTG.MK_FLG = '0' "); if ((!JKKStringUtil.isNullBlank(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID))) && (!JKKStringUtil.isNullSpace(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID)))){ sql_Buff.append(" AND HTG.USER_ID IN ( '") .append(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID)) .append("')"); } sql_Buff.append(" GROUP BY ") //---------v29.00.00 変更終了---------// .append(" HTG.USER_ID ") .append(" ) USR_TMP ") .append(" LEFT OUTER JOIN CR_T_USER_TOIAWSMNT UTM_TEMP ON ") .append(" UTM_TEMP.WKKBT_ORG_CD IN( ") .append(inMsg.getString(ECR0341B010CBSMsg.KEY_WKKBT_ORG_CD)) .append(" ) ") .append(" AND (UTM_TEMP.HASSEI_YMD >= ? AND UTM_TEMP.HASSEI_YMD <= ?) ") .append(" AND USR_TMP.USER_ID = UTM_TEMP.USER_ID ") //---------v29.00.00 変更開始---------// .append(" AND UTM_TEMP.MK_FLG = '0' "); if ((!JKKStringUtil.isNullBlank(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID))) && (!JKKStringUtil.isNullSpace(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID)))){ sql_Buff.append(" AND USR_TMP.USER_ID IN ( '") .append(inMsg.getString(ECR0341B010CBSMsg.KEY_USER_ID)) .append("')"); } sql_Buff.append(" ) UTM1 "); //---------v29.00.00 変更終了---------// } sql_Buff.append(" GROUP BY UTM1.USER_ID, UTM1.USER_NM "); // 機能コード1のとき(昇順) if(JPCModelConstant.FUNC_CD_1.equals(inMsg.getString(ECR0341B010CBSMsg.FUNC_CODE))) { // ユーザー名 if(JCRStrConst.USER_NM.equals(sortShiteiKmk)) { sql_Buff.append(" ORDER BY UTM1.USER_NM ASC"); } // 新規作成集計件数 else if(JCRStrConst.NEW_SAKSEI_SHUK_CNT.equals(sortShiteiKmk)) { sql_Buff.append(" ORDER BY NEW_SAKSEI_SHUK_CNT ASC"); } // クローズ集計件数 else if(JCRStrConst.CLOSE_SHUK_CNT.equals(sortShiteiKmk)) { sql_Buff.append(" ORDER BY CLOSE_SHUK_CNT ASC"); } // NGワード集計件数 else if(JCRStrConst.NG_WORD_SHUK_CNT.equals(sortShiteiKmk)) { sql_Buff.append(" ORDER BY NG_WORD_SHUK_CNT ASC"); } } // 機能コード2のとき(降順) else if(JPCModelConstant.FUNC_CD_2.equals(inMsg.getString(ECR0341B010CBSMsg.FUNC_CODE))) { // ユーザー名 if(JCRStrConst.USER_NM.equals(sortShiteiKmk)) { sql_Buff.append(" ORDER BY UTM1.USER_NM DESC"); } // 新規作成集計件数 else if(JCRStrConst.NEW_SAKSEI_SHUK_CNT.equals(sortShiteiKmk)) { sql_Buff.append(" ORDER BY NEW_SAKSEI_SHUK_CNT DESC"); } // クローズ集計件数 else if(JCRStrConst.CLOSE_SHUK_CNT.equals(sortShiteiKmk)) { sql_Buff.append(" ORDER BY CLOSE_SHUK_CNT DESC"); } // NGワード集計件数 else if(JCRStrConst.NG_WORD_SHUK_CNT.equals(sortShiteiKmk)) { sql_Buff.append(" ORDER BY NG_WORD_SHUK_CNT DESC"); } } //prepareStatementにSQL文をセット pstmt = con1.prepareStatement(sql_Buff.toString()); //ログ出力(SQL文の出力) JSYejbLog.outlog(inContext, JSYejbLog.DBACCESS, this.getClass(), sql_Buff); // PreparedStatementの指定されたパラメータカラムに指定された値を設定 // パラメータの設定(ＫＥＹ＿発生年月日（自）を指定) CAANJDBCUtil.setParam(pstmt, 1, inMsg.getObject(ECR0341B010CBSMsg.KEY_HASSEI_YMD_STAT)); // パラメータの設定(ＫＥＹ＿発生年月日（至）を指定) CAANJDBCUtil.setParam(pstmt, 2, inMsg.getObject(ECR0341B010CBSMsg.KEY_HASSEI_YMD_END)); // ResultSetの取得 rsltQuery = pstmt.executeQuery(); // ECR0341B010CBSMsgの明細にセットする項目 String[] msgKeyList1 = { ECR0341B010CBSMsg1List.USER_ID , ECR0341B010CBSMsg1List.USER_NM , ECR0341B010CBSMsg1List.NEW_SAKSEI_SHUK_CNT , ECR0341B010CBSMsg1List.CLOSE_SHUK_CNT , ECR0341B010CBSMsg1List.NG_WORD_SHUK_CNT }; // 明細に処理結果(ResultSet)をマッピング CAANMsg[] outMsg1 = mapMessageList(rsltQuery,msgKeyList1,"eo.ejb.cbs.cbsmsg.ECR0341B010CBSMsg1List",0); // inMsg(CBSMsg)に明細をセット inMsg.set("ECR0341B010CBSMsg1List", outMsg1); if (outMsg1.length == 0) { // 検索結果が0件の場合、検索エラーフラグに1をセット inMsg.set(ECR0341B010CBSMsg.SEARCH_ERR_FLG, JPCModelConstant.SEARCH_ERR_FLG_ZERO); } // 総検索件数セット inMsg.set(ECR0341B010CBSMsg.TOTAL_SEARCH_NUM,String.valueOf(outMsg1.length)); //--------------------------------修正end----------------------------------------------- } catch(SQLException e) { inMsg.set(ECR0341B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } finally { // 資源の解放 try{ if(rsltQuery != null){ rsltQuery.close(); } if(pstmt != null){ pstmt.close(); } if(con1 != null){ closeConnection(con1); } }catch(SQLException e){ inMsg.set(ECR0341B010CBSMsg.STATUS, StatusCodes.FIND_DB_ERR); throw new CAANRuntimeException(e); } } } }