fix20221226

apps/view_index/view.py

@@ -2,11 +2,13 @@ import json
 import os
 import sys
 
+import requests
 from aliyunsdkcore.client import AcsClient
 from aliyunsdkcore.acs_exception.exceptions import ClientException
 from aliyunsdkcore.acs_exception.exceptions import ServerException
 from aliyunsdkvod.request.v20170321.GetPlayInfoRequest import GetPlayInfoRequest
 from flask import request, jsonify, session, current_app
+from lxml import etree
 from sqlalchemy import func, desc, or_
 from apps.models import *
 from apps.view_index import api_attract
@@ -18,6 +20,48 @@ from apps import db, constants, redis_store
 from apps.util import verify_token
 
 
+# 数据通报
+@api_attract.route("/DataNotification", methods=["GET"])
+def data_notification():
+    page_html_list = [
+        "index.shtml",  # 首页
+        "index_1.shtml",  # 第2页
+        "index_2.shtml",  # 第3页
+        "index_3.shtml",  # 第4页
+        "index_4.shtml",  # 第5页
+        "index_5.shtml",  # 第6页
+        "index_6.shtml",  # 第7页
+    ]
+    data_list1 = []
+    for page_index in page_html_list:
+        url = "http://zsj.jcgov.gov.cn/sjtb/sjtb/{}".format(page_index)
+
+    headers = {
+        'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/108.0.0.0 Safari/537.36 Edg/108.0.1462.54'}
+    try:
+        respose = requests.get(url, headers=headers)
+        respose.encoding = 'utf-8'
+        if respose.status_code == 200:
+            html_etree = etree.HTML(respose.text)
+        # handeled_html_str = etree.tostring(html_etree).decode()
+        # print(handeled_html_str)
+        data_list = []
+        content_name_list = html_etree.xpath('//div[@class="newslist newslistdixx"]//span[@class="list_newstitle"]/a/text()')
+        content_url_list = html_etree.xpath('//div[@class="newslist newslistdixx"]//span[@class="list_newstitle"]/a/@href')
+
+        i = 0
+        for content_name in content_name_list:
+            data_dic = {"content_name": content_name, "content_url": content_url_list[i].replace('./', 'http://zsj.jcgov.gov.cn/sjtb/sjtb/')}
+            data_list.append(data_dic)
+            i += 1
+            data_list1 = data_list + data_list1
+            continue
+        return jsonify(code=RET.OK, msg="获取成功", data=data_list1)
+    except Exception as e:
+        current_app.logger.error(e)
+        return jsonify(code=RET.DBERR, msg="数据库错误")
+
+
 def get_jjzb(district, year):
     '''经济指标数据'''
     year1 = datetime.now().year - 1
@@ -67,11 +111,6 @@ def get_jjzb(district, year):
         return jsonify(code=RET.DBERR, msg="数据库错误")
 
 
-@api_attract.route("/view_index", methods=["GET"])
-def index():
-    return '德旭，你好！'
-
-
 # 左上角企业数量各资质统计、左上角获取经济指标数据、产业机构分布饼状图数据统计
 @api_attract.route("/menu", methods=["POST"])
 def menu():