hj

entprofile/main.py

@@ -18,7 +18,7 @@ from service.GetImageFromSql import getImageInfo
 from service.rec_status import tj_rec_status
 from service.rec_status import tj_rec_status
 from service.online_GetLicenseImage import getlicenceInfo
 from service.online_GetLicenseImage import getlicenceInfo
 from service.tf_member import gaoguan,gudong
 from service.tf_member import gaoguan,gudong
-from service.talking import talking
+from service.talking import talking,talking_product
 
 
 
 
 server = Flask(__name__)
 server = Flask(__name__)
@@ -36,6 +36,7 @@ gaoguan(server)
 gudong(server)
 gudong(server)
 tj_rec_status(server)
 tj_rec_status(server)
 talking(server)
 talking(server)
+talking_product(server)
 
 
 #画像
 #画像
 @server.route('/lable', methods=['POST'])
 @server.route('/lable', methods=['POST'])
@@ -130,4 +131,4 @@ def company_similar():
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
     server.run(debug=True,host='0.0.0.0',port=80)
     server.run(debug=True,host='0.0.0.0',port=80)
-    # server.run(debug=True, host='127.0.0.1', port=8080)
+    # server.run(debug=True, host='127.0.0.1', port=8080)
\ No newline at end of file

entprofile/service/talking.py

@@ -7,14 +7,15 @@ from flask_cors import CORS
 
 
 connection = pymysql.connect(host='47.95.76.74', port=3306, user='root', passwd='Gongsibao2018', db='ent_data')
 connection = pymysql.connect(host='47.95.76.74', port=3306, user='root', passwd='Gongsibao2018', db='ent_data')
 cur = connection.cursor()
 cur = connection.cursor()
-def talk(already_product,recommend_product):
+def talk(recommendId):
     try:
     try:
         list_test=[]
         list_test=[]
-        select_sql='select start_text,res_text,mq_text,end_text from talking where already_product="%s" and recommend_product="%s"'%(already_product,recommend_product)
-        print(select_sql,"===============select_sql")
+        update_sql='UPDATE talking t1 ,tj_recommend_do_status t2 set t1.recommendId=t2.recommend_id where t1.recommend_product=t2.product_name'
+        cur.execute(update_sql)
+        connection.commit()
+        select_sql='select start_text,res_text,mq_text,end_text from talking where recommendId="%s"'%(recommendId)
         cur.execute(select_sql)
         cur.execute(select_sql)
         s=cur.fetchone()
         s=cur.fetchone()
-        print(s,"=============api/talking")
         for i in range(0,len(s)):
         for i in range(0,len(s)):
             list_test.append(s[i])
             list_test.append(s[i])
         print(list_test)
         print(list_test)
@@ -23,25 +24,53 @@ def talk(already_product,recommend_product):
     except:
     except:
         return False,{}
         return False,{}
 
 
+def talkName(recommend_product):
+    connection = pymysql.connect(host='47.95.76.74', port=3306, user='root', passwd='Gongsibao2018', db='ent_data')
+    cur = connection.cursor()
+    try:
+        list_test=[]
+        select_sql='select start_text,res_text,mq_text,end_text from talking where recommend_product="%s"'%(recommend_product)
+        cur.execute(select_sql)
+        s=cur.fetchone()
+        for i in range(0,len(s)):
+            list_test.append(s[i])
+        print(list_test)
+        cur.close()
+        return True,list_test
+    except:
+        return False,{}
+
+
 # 服务器接口API
 # 服务器接口API
 # app = Flask(__name__)
 # app = Flask(__name__)
 def talking(server):
 def talking(server):
     @server.route('/api/talking', methods = ['POST'])
     @server.route('/api/talking', methods = ['POST'])
     def SingleLogoApi():
     def SingleLogoApi():
         try:
         try:
-            already_product = request.get_json().get("already_product")
-            recommend_product=request.get_json().get("recommend_product")
-            isSuss, talkings = talk(already_product,recommend_product)
+            recommendId = request.get_json().get("recommendId")
+            isSuss, talkings = talk(recommendId)
             if isSuss:
             if isSuss:
                 return json.dumps({"status": 0, "msg": "成功", "data": talkings}, ensure_ascii=False)
                 return json.dumps({"status": 0, "msg": "成功", "data": talkings}, ensure_ascii=False)
             else:
             else:
                 return json.dumps({"status": -1, "msg": "返回数据为空", "data": {}}, ensure_ascii=False)
                 return json.dumps({"status": -1, "msg": "返回数据为空", "data": {}}, ensure_ascii=False)
         except:
         except:
-            return json.dumps({"status": -1, "msg":"调用服务出错","data": {}}, ensure_ascii=False)
+            return json.dumps({"status": -1, "msg": "调用服务出错", "data": {}}, ensure_ascii=False)
 
 
+def talking_product(server):
+    @server.route('/api/talkingName', methods=['POST'])
+    def SingleLogoApi_name():
+        try:
+            recommend_product = request.get_json().get("recommend_product")
+            isSuss, talkings = talkName(recommend_product)
+            if isSuss:
+                return json.dumps({"status": 0, "msg": "成功", "data": talkings}, ensure_ascii=False)
+            else:
+                return json.dumps({"status": -1, "msg": "返回数据为空", "data": {}}, ensure_ascii=False)
+        except:
+            return json.dumps({"status": -1, "msg": "调用服务出错", "data": {}}, ensure_ascii=False)
 # if __name__ == '__main__':
 # if __name__ == '__main__':
 #     CORS(app, supports_credentials=True)#允许跨域
 #     CORS(app, supports_credentials=True)#允许跨域
 #     # app.run(host='172.16.18.2', port=15501, debug=True)
 #     # app.run(host='172.16.18.2', port=15501, debug=True)
 #     app.run(host='127.0.0.1', port=5000, debug=True)
 #     app.run(host='127.0.0.1', port=5000, debug=True)
 
 
-# talk("商标注册")
+# talk("商标注册")
\ No newline at end of file