From c30a9a85c9d69e16c28fe67ba9ebe827e892ac22 Mon Sep 17 00:00:00 2001 From: shihxuancheng Date: Wed, 30 Oct 2019 17:59:54 +0800 Subject: [PATCH] daily commit --- back_end/bot_app/__init__.py | 1 + back_end/bot_app/fulfillment/controllers.py | 5 +- back_end/bot_app/fulfillment/whl_report.py | 97 +++++++++++++++++++++ 3 files changed, 102 insertions(+), 1 deletion(-) create mode 100644 back_end/bot_app/fulfillment/whl_report.py diff --git a/back_end/bot_app/__init__.py b/back_end/bot_app/__init__.py index b61364e..2e13294 100644 --- a/back_end/bot_app/__init__.py +++ b/back_end/bot_app/__init__.py @@ -1,4 +1,5 @@ from flask import Flask +import bot_app.fulfillment.utility as util import bot_app.fulfillment.controllers as controller app = Flask(__name__) diff --git a/back_end/bot_app/fulfillment/controllers.py b/back_end/bot_app/fulfillment/controllers.py index a5fbc01..3038355 100644 --- a/back_end/bot_app/fulfillment/controllers.py +++ b/back_end/bot_app/fulfillment/controllers.py @@ -3,6 +3,7 @@ import bot_app.fulfillment.utility as util import bot_app.fulfillment.buying_drink as buying_drink import bot_app.fulfillment.system_pic as system_pic import bot_app.fulfillment.whl_family as whl_family +import bot_app.fulfillment.whl_report as whl_report from flask import Blueprint, Flask, jsonify, request, json import threading import time @@ -25,7 +26,8 @@ def index(): return eval(handleName + '(jsonObj)') except Exception as e: print(str(e)) - return util.simple_response(str(e)) + return util.simple_response(fulfillmentObj=util.reset_all_contexts(fulfillmentObj=jsonObj)) + # return util.simple_response(str(e)) @fulfillment.route("/short_call", methods=['GET', 'POST']) @@ -60,4 +62,5 @@ def init_app(app): util.init_app(app) buying_drink.init_app(app) system_pic.init_app(app) + whl_report.init_app(app) whl_family.init_app(app) \ No newline at end of file diff --git a/back_end/bot_app/fulfillment/whl_report.py b/back_end/bot_app/fulfillment/whl_report.py new file mode 100644 index 0000000..04d1ad0 --- /dev/null +++ b/back_end/bot_app/fulfillment/whl_report.py @@ -0,0 +1,97 @@ +import bot_app.fulfillment.utility as util + +def init_app(app): + pass + +#表列rs +def list_rs(fulfillment): + office_code = fulfillment.get('queryResult').get('parameters').get('office_code') + rs_code = fulfillment.get('queryResult').get('parameters').get('rs_code') + + if rs_code == '': + rs_url='%' + else: + rs_url= rs_code.upper() + '.WANHAI.COM:80%' + + strsql = ''' + select a.rs_url, + a.is_internet, + decode(b.is_active, 0, 'Active', 'InActive') as status + from was5005 a, was5011 b + where a.office_code = :office_code + and upper(a.rs_url) like :rs_url + and a.rs_id = b.rs_id + ''' + + with util.get_db_conn() as conn: + res = conn.execute(strsql,office_code=office_code,rs_url=rs_url) + res = res.fetchall() + if len(res) == 0: + strRes = '無法取得Office: ' + office_code + 'Report Server資訊，請重新查詢!' + return util.simple_response(fulfillmentObj={ + 'fulfillmentText':strRes, + 'outputContexts': fulfillment.get('queryResult').get('outputContexts') + }) + else: + strRes = 'Office: ' + office_code + " Report Server資訊如下:\n" + for row in res: + strRes += row[0]+'(isInternet: '+row[1]+', Status: ' + row[2] + '), ' + + return util.simple_response(text_content=strRes) + +#取得rs資訊 +def get_rs_info(fulfillment): + office_code = fulfillment.get('queryResult').get('parameters').get('office_code') + rs_code = fulfillment.get('queryResult').get('parameters').get('rs_code') + rs_url = rs_code.upper() + '.WANHAI.COM:80%' + strsql='''select a.office_code,a.rs_url,a.is_internet,decode(b.is_active,0,'Active','InActive') as status from was5005 a,was5011 b where upper(a.rs_url)=:rs_url and a.rs_id=b.rs_id''' + + with util.get_db_conn() as conn: + res = conn.execute(strsql,rs_url=rs_url) + res = res.fetchall() + + if len(res) == 0: + strRes = '無法取得' + rs_code + '資訊，請重新查詢!' + return util.simple_response(fulfillmentObj={ + 'fulfillmentText':strRes, + 'outputContexts': fulfillment.get('queryResult').get('outputContexts') + }) + elif len(res)>1: + return util.simple_response(fulfillmentObj={ + 'followupEventInput': { + 'name': 'list_rs_by_office', + 'languageCode': 'zh-TW', + 'parameters': fulfillment.get('queryResult').get('parameters') + } + }) + else: + strRes = 'Report Server: '+ rs_code +'資訊如下:\n' + for row in res: + strRes += row[1]+'(office: ' + row[0] + ', isInternet: '+row[2]+', Status: ' + row[3] + ') ' + return util.simple_response(text_content=strRes) + + +#開啟/關閉rs +def switch_on_off(fulfillment): + office_code = fulfillment.get('queryResult').get('parameters').get('office_code') + switch_action = fulfillment.get('queryResult').get('parameters').get('switch_action') + rs_code = fulfillment.get('queryResult').get('parameters').get('rs_code') + rs_url = rs_code.upper() + '.WANHAI.COM:80' + action_code = '0' if switch_action=='ON' else '1' + + strsql = '''update was5011 set is_active=:action_code where rs_id in (select rs_id from was5005 where office_code=:office_code and upper(rs_url)=:rs_url)''' + + with util.get_db_conn() as conn: + res = conn.execute(strsql,action_code=action_code,office_code=office_code,rs_url=rs_url) + + # if len(res) == 0: + # strRes = '無法取得' + rs_code + '資訊，請重新查詢!' + # else: + # strRes = '已更新' + str(len(res)) + '筆資料' + strRes = '資料已更新' + return util.simple_response(text_content=strRes) + # return util.simple_response(fulfillmentObj={ + # 'fulfillmentText':strRes, + # 'outputContexts': fulfillment.get('queryResult').get('outputContexts') + # }) +