hj

entprofile/service/talking.py

@@ -5,8 +5,39 @@ import json
 from flask import Flask, render_template, request
 from flask_cors import CORS
 
+def getName(recommendId):
+    connection = pymysql.connect(host='47.95.76.74', port=3306, user='root', passwd='Gongsibao2018', db='ent_data')
+    cur = connection.cursor()
+    sql='select company_name from tj_recommend_do_status where recommend_id = "%s"' %recommendId
+    cur.execute(sql)
+    s=cur.fetchone()
+    print(s)
+    cur.close()
+    connection.close()
+    return s
+
+def getSource(name):
+    connection = pymysql.connect(host='47.95.76.74', port=3306, user='root', passwd='Gongsibao2018', db='ent_data')
+    cur = connection.cursor()
+
+    sql='select preference_label from tj_label_depth where company_name = "%s"'%name
+    print(name)
+    cur.execute(sql)
+    s=cur.fetchall()
+    x= ''
+    for ss in s:
+        aa=ss[0]
+        aaa=aa.replace(']','').replace('[','')
+        x=json.loads(aaa)['来源偏好']
+
+    print(x)
+    cur.close()
+    connection.close()
+    return x
+
+
 
-def talk(recommendId):
+def talk(recommendId,source):
     connection = pymysql.connect(host='47.95.76.74', port=3306, user='root', passwd='Gongsibao2018', db='ent_data')
     cur = connection.cursor()
     try:
@@ -16,19 +47,49 @@ def talk(recommendId):
         cur.execute(select_name_sql)
         name=cur.fetchone()
         print(name)
+        name=name[0]
+        print(name)
         #connection.commit()
-        select_sql='select start_text,res_text,mq_text,end_text from tj_talking where recommend_product="%s"'%(name)
-        cur.execute(select_sql)
-        s=cur.fetchone()
-        for i in range(0,len(s)):
-            list_test.append(s[i])
-        print(list_test)
-        # if s:
-        #     for i in range(0,len(s)):
-        #         list_test.append(s[i])
-        #     print(list_test)
-        # else:
-        #     list_test.append('暂无话术，感谢您')
+        print(source ,'------------------')
+        sa=list(source)
+        print(sa)
+        if source != '钉钉' and  sa [0]!='阿' and sa[1] != '里' :
+            print('1')
+            select_sql='select start_text,res_text,mq_text,end_text from tj_talking where recommend_product="%s" and id>6000'%(name)
+            # select_sql='select mq_text from tj_talking where  id>6000'
+            cur.execute(select_sql)
+            print(select_sql)
+            s=cur.fetchone()
+            if s:
+                for i in range(0,len(s)):
+                    list_test.append(s[i])
+                print(list_test)
+            else:
+                start_text="老板，您好，我是公司宝XXX"
+                list_test.append(start_text)
+                res_text="我们公司宝主体是汉唐信通（北京）咨询股份有限公司拥有13年丰富企服行业经验致力于企业全生命周期的一站式服务平台。"
+                list_test.append(res_text)
+                list_test.append('暂无话术，敬请期待')
+                end_text="好的，老板，公司宝有公司注册、财税代理、知识产权、行业资质认证、薪 税服务、公司交易多达三百余项产品，贵公司在业务开展过程中，如果有其他上述的服务需求，随时欢迎找我们。感谢您的支持。（也可以继续推荐其他套餐）"
+                list_test.append(end_text)
+        else:
+            print('2')
+            select_sql='select start_text,res_text,mq_text,end_text from tj_talking where recommend_product="%s"'%name
+            cur.execute(select_sql)
+            print(select_sql)
+            s=cur.fetchone()
+            if s:
+                for i in range(0,len(s)):
+                    list_test.append(s[i])
+                print(list_test)
+            else:
+                start_text="老板，您好，我是公司宝XXX"
+                list_test.append(start_text)
+                res_text="我们公司宝主体是汉唐信通（北京）咨询股份有限公司拥有13年丰富企服行业经验致力于企业全生命周期的一站式服务平台。"
+                list_test.append(res_text)
+                list_test.append('暂无话术，敬请期待')
+                end_text="好的，老板，公司宝有公司注册、财税代理、知识产权、行业资质认证、薪 税服务、公司交易多达三百余项产品，贵公司在业务开展过程中，如果有其他上述的服务需求，随时欢迎找我们。感谢您的支持。（也可以继续推荐其他套餐）"
+                list_test.append(end_text)
         cur.close()
         connection.close()
         return True,list_test
@@ -63,13 +124,15 @@ def talking(server):
     def SingleLogoApi1():
         try:
             recommendId = request.get_json().get("recommendId")
-            isSuss, talkings = talk(recommendId)
+            name = getName(recommendId)
+            source = getSource(name)
+            isSuss, talkings = talk(recommendId, source)
             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)
+            return json.dumps({"status": -1, "msg": "调用服务出错", "data": {}}, ensure_ascii=False)