AnalysisHandler.py 958 B

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. from handlers.HandlerBase import BaseHandler
  2. from model.DataBaseUtils import MysqlUtils
  3. import json
  4. import requests
  5. from data_manage.analysis_select import *
  6. from model.DataBaseUtils import MysqlUtils
  7. db = MysqlUtils()
  8. class ChannelAnalysisHandler(BaseHandler):
  9. APP_MAP = {
  10. "channel_order_track": channel_analysis_select,
  11. "channel_order_track_daily": channel_analysis_select_daily,
  12. }
  13. def post(self):
  14. arg = self.get_args()
  15. print(arg)
  16. try:
  17. data = self.run(arg)
  18. print(data)
  19. self.write_json(data=data.get("data"),total=data.get('total',1),total_data=data.get('total_data',{}))
  20. except Exception as e:
  21. print(e)
  22. self.write_fail()
  23. def run(self, arg):
  24. app = self.request.full_url().split('/')[-1]
  25. return self.run_function(self.APP_MAP[app], arg)
  26. def run_function(self, func, arg):
  27. return func(arg)