label_number.py 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263
  1. from configs.connections import connect_graph
  2. import logging
  3. logger = logging.getLogger(__name__)
  4. from flask import current_app
  5. def job_label(skip_count,page_size):
  6. try:
  7. cql = f"""
  8. MATCH (n:jobLabel)
  9. with n.name as name
  10. ORDER BY id(n) desc
  11. SKIP {skip_count}
  12. LIMIT {page_size}
  13. return collect(name) as label_list
  14. """
  15. label_list = connect_graph.run(cql).evaluate()
  16. total_query = f"MATCH (n:jobLabel) RETURN COUNT(n) AS total"
  17. total_result = connect_graph.run(total_query).evaluate()
  18. return label_list,total_result
  19. except Exception as e:
  20. current_app.logger.error(f'job_label error:{e}')
  21. return ""
  22. def enterprise_label(skip_count,page_size):
  23. try:
  24. cql = f"""
  25. MATCH (n:enterpriseLabel)
  26. with n.name as name
  27. ORDER BY id(n) desc
  28. SKIP {skip_count}
  29. LIMIT {page_size}
  30. return collect(name) as label_list
  31. """
  32. label_list = connect_graph.run(cql).evaluate()
  33. total_query = f"MATCH (n:enterpriseLabel) RETURN COUNT(n) AS total"
  34. total_result = connect_graph.run(total_query).evaluate()
  35. return label_list, total_result
  36. except Exception as e:
  37. current_app.logger.error(f'enterprise_label error:{e}')
  38. return ""
  39. def seeker_label(skip_count,page_size):
  40. try:
  41. cql = f"""
  42. MATCH (n:seekerLabel)
  43. with n.name as name
  44. ORDER BY id(n) desc
  45. SKIP {skip_count}
  46. LIMIT {page_size}
  47. return collect(name) as label_list
  48. """
  49. label_list = connect_graph.run(cql).evaluate()
  50. total_query = f"MATCH (n:seekerLabel) RETURN COUNT(n) AS total"
  51. total_result = connect_graph.run(total_query).evaluate()
  52. return label_list, total_result
  53. except Exception as e:
  54. current_app.logger.error(f'seeker_label error:{e}')
  55. return ""