hj

entprofile/dao/consultation_record_dao.py

+#!/usr/bin/env python
+# -*- coding:utf-8 -*- 
+# Author: hj
+# softWare:pycharm
+# fileName:consultation_record_dao.py
+# createTime:2020/7/6 14:51
+
+from db.mod_db import DataBase
+
+
+class consultation_Dao:
+    def __init__(self, db=None):
+        if db is None:
+            self.dataBase = DataBase()
+        else:
+            self.dataBase = db
+    def select_sql(self,standard_company_name):
+        return self.dataBase.fetch_all('SELECT DATE_FORMAT(create_time, "%%Y-%%m-%%d %%T") as create_time, source, consult_product, address FROM `consulting_customer_fq` WHERE standard_company_name = "%s" ORDER BY create_time DESC'%(standard_company_name))
+
+

entprofile/main.py

@@ -29,6 +29,7 @@ from service.select_es_result import hx_company_dict,hx_company_list
 from service.hxResult import businessApi
 from service.assigned_opportunity import assigned_opportunity
 from service.potential import app_website
+from service.consultation_record import consultingInfo
 
 server = Flask(__name__,static_url_path="",static_folder="")
 server.config['JSON_AS_ASCII'] = False
@@ -61,6 +62,8 @@ hx_company_list(server)
 businessApi(server)
 assigned_opportunity(server)
 app_website(server)
+consultingInfo(server)
+
 
 #基本信息
 @server.route('/base_info', methods=['POST'])
@@ -117,6 +120,7 @@ def business_product_post():
         business_id = request_data.get('bussines_id')
         business_type = request_data.get('businessType')
         business_product_result, reason,relational_reason = recomm.business_product(business_id, business_type)
+        print(business_product_result, reason,relational_reason)
         if business_type != "智能监测" and business_type != "关联推荐":
             return common_result.to_result(business_product_result)
         elif business_type == "关联推荐":

entprofile/service/assigned_opportunity.py

@@ -37,8 +37,8 @@ def assigned_opportunity(server):
             assigned_oportunity = request.json
             pagesize = assigned_oportunity.get('pagesize')
             currentpage = assigned_oportunity.get('currentpage')
-            # try:
-            company_dict_list,total_nu = selectAssigned(pagesize,currentpage)
-            return {"status": 200, "msg": "成功", "data": company_dict_list,"total":total_nu}
-            # except:
-            #     return {"status": 404, "msg": "失败", "data": []}
\ No newline at end of file
+            try:
+                company_dict_list,total_nu = selectAssigned(pagesize,currentpage)
+                return {"status": 200, "msg": "成功", "data": company_dict_list,"total":total_nu}
+            except:
+                return {"status": 404, "msg": "失败", "data": []}
\ No newline at end of file

entprofile/service/consultation_record.py

+#!/usr/bin/env python
+# -*- coding:utf-8 -*- 
+# Author: hj
+# softWare:pycharm
+# fileName:consultation_record.py
+# createTime:2020/7/6 14:50
+
+# 读表获取咨询记录
+import datetime,ast
+
+from flask import request
+
+from common.re_companyName import strQ2B
+from dao.consultation_record_dao import consultation_Dao
+
+consultation_sql = consultation_Dao()
+
+def consultingRecord(company_name):
+    consultation_list = []
+    consultation_info = consultation_sql.select_sql(company_name)
+    # for row in consultation_info:
+    #     consultation_dict['channel'] = row['source']
+    #     consult_product = ast.literal_eval(row['consult_product'])
+    #     consult_product_list = []
+    #     for consult_product_item in consult_product:
+    #         consult_product = consult_product_item['product_name']
+    #         re_consult_product = strQ2B(consult_product)
+    #         consult_product_list.append(re_consult_product)
+    #     str1 = ";".join(map(str, consult_product_list))
+    #     consultation_dict['consult_product'] = str1
+    #     consultation_dict['customer_address'] = row['address']
+    #     consult_time_info = row['create_time']
+    #     consultation_dict['consult_time'] = str(consult_time_info)
+    #     consultation_list.append(consultation_dict)
+    for row in consultation_info:
+        consult_product = ast.literal_eval(row['consult_product'])
+        for consult_product_item in consult_product:
+            consultation_dict = {}
+            consult_product = consult_product_item['product_name']
+            re_consult_product = strQ2B(consult_product)
+            # consultation_dict['product_price'] = consult_product_item['product_price']
+            if re_consult_product:
+                consultation_dict['channel'] = row['source']
+                consultation_dict['consult_product'] = re_consult_product
+                consultation_dict['customer_address'] = row['address']
+                consult_time_info = row['create_time']
+                consultation_dict['consult_time'] = str(consult_time_info)
+                consultation_list.append(consultation_dict)
+    print(consultation_list)
+    return consultation_list
+# consultingRecord('北京爱诺斯科技有限公司')
+#
+def consultingInfo(server):
+    @server.route('/gsb/api/consultingRecord', methods=['POST'])
+    def consultMain():
+        if request.method == 'POST':
+            consultParams = request.json
+            company_name = consultParams.get('company_name')
+            try:
+                consultation_list = consultingRecord(company_name)
+                return {"status": 200, "msg": "成功", "data": consultation_list}
+            except Exception as e:
+                print('咨询记录错误',e)
+                return {"status": 404, "msg": "失败", "data": ""}
+
+     
\ No newline at end of file