base.py 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175
  1. #!/usr/bin/env python
  2. # -*- coding: utf-8 -*-
  3. from flask import request
  4. import json
  5. import jimit as ji
  6. from models import Rules
  7. __author__ = 'James Iter'
  8. __date__ = '2017/5/28'
  9. __contact__ = 'james.iter.cn@gmail.com'
  10. __copyright__ = '(c) 2017 by James Iter.'
  11. class Base(object):
  12. def __init__(self, the_class=None, the_blueprint=None, the_blueprints=None):
  13. self.the_class = the_class
  14. self.the_blueprint = the_blueprint
  15. self.the_blueprints = the_blueprints
  16. def get_by_filter(self):
  17. page = str(request.args.get('page', 1))
  18. page_size = str(request.args.get('page_size', 50))
  19. args_rules = [
  20. Rules.PAGE.value,
  21. Rules.PAGE_SIZE.value
  22. ]
  23. try:
  24. ji.Check.previewing(args_rules, {'page': page, 'page_size': page_size})
  25. except ji.PreviewingError, e:
  26. return json.loads(e.message)
  27. page = int(page)
  28. page_size = int(page_size)
  29. # 把page和page_size换算成offset和limit
  30. offset = (page - 1) * page_size
  31. # offset, limit将覆盖page及page_size的影响
  32. offset = str(request.args.get('offset', offset))
  33. limit = str(request.args.get('limit', page_size))
  34. order_by = request.args.get('order_by', 'id')
  35. order = request.args.get('order', 'asc')
  36. filter_str = request.args.get('filter', '')
  37. args_rules = [
  38. Rules.OFFSET.value,
  39. Rules.LIMIT.value,
  40. Rules.ORDER_BY.value,
  41. Rules.ORDER.value
  42. ]
  43. try:
  44. ji.Check.previewing(args_rules, {'offset': offset, 'limit': limit, 'order_by': order_by, 'order': order})
  45. offset = int(offset)
  46. limit = int(limit)
  47. ret = dict()
  48. ret['state'] = ji.Common.exchange_state(20000)
  49. ret['data'] = list()
  50. ret['paging'] = {'total': 0, 'offset': offset, 'limit': limit, 'page': page, 'page_size': page_size,
  51. 'next': '', 'prev': '', 'first': '', 'last': ''}
  52. ret['data'], ret['paging']['total'] = self.the_class.get_by_filter(
  53. offset=offset, limit=limit,order_by=order_by, order=order, filter_str=filter_str)
  54. host_url = request.host_url.rstrip('/')
  55. other_str = '&filter=' + filter_str + '&order=' + order + '&order_by=' + order_by
  56. last_pagination = (ret['paging']['total'] + page_size - 1) / page_size
  57. if page <= 1:
  58. ret['paging']['prev'] = host_url + self.the_blueprints.url_prefix + '?page=1&page_size=' + \
  59. page_size.__str__() + other_str
  60. else:
  61. ret['paging']['prev'] = host_url + self.the_blueprints.url_prefix + '?page=' + str(page - 1) + \
  62. '&page_size=' + page_size.__str__() + other_str
  63. if page >= last_pagination:
  64. ret['paging']['next'] = host_url + self.the_blueprints.url_prefix + '?page=' + \
  65. last_pagination.__str__() + '&page_size=' + page_size.__str__() + other_str
  66. else:
  67. ret['paging']['next'] = host_url + self.the_blueprints.url_prefix + '?page=' + str(page + 1) + \
  68. '&page_size=' + page_size.__str__() + other_str
  69. ret['paging']['first'] = host_url + self.the_blueprints.url_prefix + '?page=1&page_size=' + \
  70. page_size.__str__() + other_str
  71. ret['paging']['last'] = \
  72. host_url + self.the_blueprints.url_prefix + '?page=' + last_pagination.__str__() + '&page_size=' + \
  73. page_size.__str__() + other_str
  74. return ret
  75. except ji.PreviewingError, e:
  76. return json.loads(e.message)
  77. def content_search(self):
  78. page = str(request.args.get('page', 1))
  79. page_size = str(request.args.get('page_size', 50))
  80. args_rules = [
  81. Rules.PAGE.value,
  82. Rules.PAGE_SIZE.value
  83. ]
  84. try:
  85. ji.Check.previewing(args_rules, {'page': page, 'page_size': page_size})
  86. except ji.PreviewingError, e:
  87. return json.loads(e.message)
  88. page = int(page)
  89. page_size = int(page_size)
  90. # 把page和page_size换算成offset和limit
  91. offset = (page - 1) * page_size
  92. # offset, limit将覆盖page及page_size的影响
  93. offset = str(request.args.get('offset', offset))
  94. limit = str(request.args.get('limit', page_size))
  95. order_by = request.args.get('order_by', 'id')
  96. order = request.args.get('order', 'asc')
  97. keyword = request.args.get('keyword', '')
  98. args_rules = [
  99. Rules.OFFSET.value,
  100. Rules.LIMIT.value,
  101. Rules.ORDER_BY.value,
  102. Rules.ORDER.value,
  103. Rules.KEYWORD.value
  104. ]
  105. try:
  106. ji.Check.previewing(args_rules, {'offset': offset, 'limit': limit, 'order_by': order_by, 'order': order,
  107. 'keyword': keyword})
  108. offset = int(offset)
  109. limit = int(limit)
  110. ret = dict()
  111. ret['state'] = ji.Common.exchange_state(20000)
  112. ret['data'] = list()
  113. ret['paging'] = {'total': 0, 'offset': offset, 'limit': limit, 'page': page, 'page_size': page_size}
  114. ret['data'], ret['paging']['total'] = self.the_class.content_search(
  115. offset=offset, limit=limit, order_by=order_by, order=order, keyword=keyword)
  116. host_url = request.host_url.rstrip('/')
  117. other_str = '&keyword=' + keyword + '&order=' + order + '&order_by=' + order_by
  118. last_pagination = (ret['paging']['total'] + page_size - 1) / page_size
  119. if page <= 1:
  120. ret['paging']['prev'] = host_url + self.the_blueprints.url_prefix + '/_search?page=1&page_size=' + \
  121. page_size.__str__() + other_str
  122. else:
  123. ret['paging']['prev'] = host_url + self.the_blueprints.url_prefix + '/_search?page=' + str(page - 1) + \
  124. '&page_size=' + page_size.__str__() + other_str
  125. if page >= last_pagination:
  126. ret['paging'][
  127. 'next'] = host_url + self.the_blueprints.url_prefix + '/_search?page=' + last_pagination.__str__() + \
  128. '&page_size=' + page_size.__str__() + other_str
  129. else:
  130. ret['paging']['next'] = host_url + self.the_blueprints.url_prefix + '/_search?page=' + str(page + 1) + \
  131. '&page_size=' + page_size.__str__() + other_str
  132. ret['paging']['first'] = host_url + self.the_blueprints.url_prefix + '/_search?page=1&page_size=' + \
  133. page_size.__str__() + other_str
  134. ret['paging']['last'] = \
  135. host_url + self.the_blueprints.url_prefix + '/_search?page=' + last_pagination.__str__() + \
  136. '&page_size=' + page_size.__str__() + other_str
  137. return ret
  138. except ji.PreviewingError, e:
  139. return json.loads(e.message)