hj

entprofile/common/crm_change_standard.py

+#!/usr/bin/env python
+# -*- coding:utf-8 -*- 
+# Author: hj
+# softWare:pycharm
+# fileName:crm_change_standard.py
+# createTime:2020/7/10 16:11
+
+from DBUtils.PooledDB import PooledDB
+import pymysql
+
+
+MYSQL_HOST = '47.95.76.74'  # 外网地址
+PORT = 3306  # 外网端口
+USER = 'root'
+PASSWORD = 'Gongsibao2018'
+DB = 'ent_data'
+pool = PooledDB(pymysql, 8, host=MYSQL_HOST, user=USER, passwd=PASSWORD, db=DB, port=PORT)
+
+"""获取公司的标准公司名称"""
+def getStandardName(crm_company_name):
+    conn = pool.connection()
+    cursor = conn.cursor(pymysql.cursors.DictCursor)
+    sql = 'select * from tj_provide_company where crm_company_name = "%s"' % crm_company_name
+    print(sql)
+    cursor.execute(sql)
+    customer_info = cursor.fetchall()
+    for row in customer_info:
+        standard_company_name = row['standard_company_name']
+        print(standard_company_name)
+        return standard_company_name
+
+# print(getStandardName("一起住好房（北京）网络科技有限公司"))
\ No newline at end of file

entprofile/dao/tj_product_depth_dao.py

@@ -12,5 +12,5 @@ class ProductDao:
 
     def select(self, company_name):
         return self.dataBase.fetch_all(
-            "select * from `tj_product_depth_final` where company_name = '%s' order by business_opportunity_id desc limit 1" % company_name)
+            "select * from `tj_product_depth_final` where company_name = '%s' order by business_opportunity_id desc" % company_name)
 

entprofile/main.py

@@ -5,7 +5,7 @@
 # @Software: PyCharm
 
 
-
+from common.crm_change_standard import getStandardName
 from service.user_behavior import Recom
 from flask import Flask, render_template
 from flask import request
@@ -74,8 +74,8 @@ def base_info():
         if not request_data or  not request_data.get('company_name'):
             return common_result.to_result(None,300,"参数错误")
         company_name = request_data.get('company_name')
-        print(company_name)
-        base_result = companybase.companyinfo(company_name)
+        standard_company_name = getStandardName(company_name)
+        base_result = companybase.companyinfo(standard_company_name)
         return common_result.to_result(base_result)
 
 
@@ -87,7 +87,8 @@ def lable_post():
         if not request_data or  not request_data.get('company_name'):
             return common_result.to_result(None,300,"参数错误")
         company_name = request_data.get('company_name')
-        lable_result = recomm.company_label(company_name)
+        standard_company_name = getStandardName(company_name)
+        lable_result = recomm.company_label(standard_company_name)
         return common_result.to_result(lable_result)
 
 
@@ -146,8 +147,9 @@ def company_product_post():
         request_data = request.json
         if not request_data or not request_data.get('company_name'):
             return common_result.to_result(None, 300, "参数错误")
-        business_id = request_data.get('company_name')
-        business_product_result = recomm.company_product(business_id)
+        company_name = request_data.get('company_name')
+        standard_company_name = getStandardName(company_name)
+        business_product_result = recomm.company_product(standard_company_name)
         return common_result.to_result(business_product_result)
 
 
@@ -160,7 +162,8 @@ def behavior_post():
         if not request_data or  not request_data.get('company_name'):
             return common_result.to_result(None,300,"参数错误")
         company_name = request_data.get('company_name')
-        behavior_result = recomm.company_behavior(company_name)
+        standard_company_name = getStandardName(company_name)
+        behavior_result = recomm.company_behavior(standard_company_name)
         return common_result.to_result(behavior_result)
 
 #分公司
@@ -171,7 +174,8 @@ def company_branch():
         if not request_data or not request_data.get('company_name'):
             return common_result.to_result(None, 300, "参数错误")
         company_name = request_data.get('company_name')
-        company_branch_result =companybase.companybranch(company_name)
+        standard_company_name = getStandardName(company_name)
+        company_branch_result =companybase.companybranch(standard_company_name)
         return common_result.to_result(company_branch_result)
 
 #相似企业
@@ -181,10 +185,11 @@ def company_similar():
         request_data = request.json
         if not request_data or not request_data.get('company_name'):
             return common_result.to_result(None, 300, "参数错误")
-    company_name = request_data.get('company_name')
-    company_info = companybase.companyinfo(company_name)
-    similar_company_list = companybase.similar_company(company_info,company_name)
-    return common_result.to_result(similar_company_list)
+        company_name = request_data.get('company_name')
+        standard_company_name = getStandardName(company_name)
+        company_info = companybase.companyinfo(standard_company_name)
+        similar_company_list = companybase.similar_company(company_info,company_name)
+        return common_result.to_result(similar_company_list)
 
 @server.route('/')
 def index_page():

entprofile/service/GetImageFromSql.py

@@ -10,6 +10,7 @@
 #读取数据库，获取画像标签
 from flask import request,jsonify
 from dao.GetImageFromSql_dao import Lable_Product_Dao
+from common.crm_change_standard import getStandardName
 from db.mod_db import DataBase
 from common import re_companyName
 
@@ -76,9 +77,10 @@ def getImageInfo(server):
                 requestdata = request.json
                 print(requestdata)
                 companyname = requestdata.get('companyname')
-                companyname = re_companyName.strQ2B(companyname)
-                Image_result = GetImageFromSql(companyname)
-                product_result = GetProductFromSql(companyname)
+                standard_company_name = getStandardName(companyname)
+                standard_company_name1 = re_companyName.strQ2B(standard_company_name)
+                Image_result = GetImageFromSql(standard_company_name1)
+                product_result = GetProductFromSql(standard_company_name1)
                 result = {"status":200,"msg":"操作成功","image": Image_result,"product": product_result}
         except:
             result = {"status":404,"msg":"操作失败","image": "-","product": "-"}

entprofile/service/Image_status.py

@@ -5,6 +5,7 @@
 # @File    : Image_status.py
 # @Software: PyCharm
 
+from common.crm_change_standard import getStandardName
 from dao.Image_status_dao import Image_status_Dao
 from db.mod_db import DataBase
 from flask import request,jsonify
@@ -152,7 +153,8 @@ def imageInfo(server):
                 pageSize = requestdata.get('pageSize')
                 # 公司名称
                 companyName = requestdata.get('companyName')
-                companyName = re_companyName.strQ2B(companyName)
+                standard_company = getStandardName(companyName)
+                companyName = re_companyName.strQ2B(standard_company)
                 # 提交日期
                 currdate = requestdata.get('currdate')
                 # 根据公司名称查询画像标签库、画像状态

entprofile/service/assigned_opportunity.py

@@ -7,6 +7,8 @@
 """已分配商机"""
 from flask import request
 from service.select_es_result import hx
+from common.crm_change_standard import getStandardName
+
 import json
 from dao.business_job_dao import hxDao
 from service.company_basic import CompanyBase
@@ -23,7 +25,8 @@ def selectAssigned(pagesize,currentpage):
     company_dict_list = []
     for row in assigned_opportunity:
         company_name = row['company_name']
-        company_name_list.append(company_name)
+        standard_company_name = getStandardName(company_name)
+        company_name_list.append(standard_company_name)
     for company_name in company_name_list:
         company_dict = company_base.companyinfo(company_name)
         company_dict['logo'] = hx.select_url(company_name)

entprofile/service/change_message.py

@@ -9,6 +9,8 @@ from flask import request
 import json
 from common.re_companyName import strQ2B
 from dao.change_message_es import ChangeMessage
+from common.crm_change_standard import getStandardName
+
 
 # 内网IP
 # esip = "172.16.18.110"
@@ -61,8 +63,11 @@ def companyChage(server):
         try:
             el = Doelastic()
             mycompanyname = request.get_json().get("mycompanyname")  # 得到问题
-            re_mycompanyname = strQ2B(mycompanyname)
-            r_1 = el.getCompnayByName(re_mycompanyname)
+            # re_mycompanyname = strQ2B(mycompanyname)
+            print('re_mycompanyname',mycompanyname)
+            standard_company_name = getStandardName(mycompanyname)
+            print('standard_company_name',standard_company_name)
+            r_1 = el.getCompnayByName(standard_company_name)
             if r_1:
                 return json.dumps({"status": 1, "msg":"成功","data": r_1}, ensure_ascii=False)
             else:

entprofile/service/company_30s.py

 import pymysql,ast
 from flask import request
 from DBUtils.PooledDB import PooledDB
+from common.crm_change_standard import getStandardName
+
 
 MYSQL_HOST = '47.95.76.74'  # 外网地址
 PORT = 3306  # 外网端口
@@ -122,8 +124,9 @@ def tj_30s_hx(server):
                 requestdata = request.json
                 print(requestdata)
                 companyName = requestdata.get('company_name')
-                industryLable = industry_select(companyName)
-                hx_info_dict = hx_30s(companyName)
+                standard_company_name = getStandardName(companyName)
+                industryLable = industry_select(standard_company_name)
+                hx_info_dict = hx_30s(standard_company_name)
                 print(hx_info_dict, "hx_info_dict===")
                 data = final_hx(industryLable, hx_info_dict)
                 hx_30s_result = {"status": 0, "msg": "成功", "data": data}

entprofile/service/consultation_record.py

@@ -9,6 +9,7 @@
 import datetime,ast
 
 from flask import request
+from common.crm_change_standard import getStandardName
 
 from common.re_companyName import strQ2B
 from dao.consultation_record_dao import consultation_Dao
@@ -60,10 +61,11 @@ def consultingInfo(server):
         if request.method == 'POST':
             consultParams = request.json
             company_name = consultParams.get('company_name')
-            re_company_name = strQ2B(company_name)
-            # try:
-            consultation_list = consultingRecord(re_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
+            # re_company_name = strQ2B(company_name)
+            standard_company_name = getStandardName(company_name)
+            try:
+                consultation_list = consultingRecord(standard_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

entprofile/service/moneyAPI.py

@@ -2,6 +2,7 @@
 # !/usr/bin/python
 from elasticsearch import Elasticsearch
 from flask import Flask, render_template, request
+from common.crm_change_standard import getStandardName
 import json
 import pymysql
 
@@ -511,10 +512,10 @@ def moneyAPI(server):
     def APImoney():
         try:
             mycompanyname = request.get_json().get("mycompanyname")  # 得到问题
-            r_1 = moneyTest(strQ2B(mycompanyname))
+            standard_company_name = getStandardName(mycompanyname)
+            r_1 = moneyTest(strQ2B(standard_company_name))
             if r_1:
                 return r_1
-
             else:
                 return json.dumps({"status": -1, "msg":"失败","data": 0}, ensure_ascii=False)
         except:

entprofile/service/online_GetLicenseImage.py

@@ -6,6 +6,7 @@
 # @Software: PyCharm
 
 from dao.online_GetlicenseImage_es import online_Getlicense_Es
+from common.crm_change_standard import getStandardName
 from flask import request,jsonify
 from common import re_companyName
 
@@ -140,8 +141,9 @@ def getlicenceInfo(server):
             requestdata = request.json
             print(requestdata)
             companyname = requestdata.get('companyname')
+            standard_company_name = getStandardName(companyname)
             print('证照companyname',companyname)
-            companyname = re_companyName.strQ2B(companyname)
+            companyname = re_companyName.strQ2B(standard_company_name)
             LicenseInfo1= GetGXLicensesFromES(companyname)
             LicenseInfo2 = GetgameLicensesFromES(companyname)
             LicenseInfo3 = GetICPLicensesFromES(companyname)

entprofile/service/potential.py

@@ -12,6 +12,8 @@ from flask_cors import *
 import sys,os,flask,pymysql
 from DBUtils.PooledDB import PooledDB
 from flask import render_template,url_for
+from common.crm_change_standard import getStandardName
+
 
 interface_path = os.path.dirname(__file__)
 sys.path.insert(0, interface_path)  # 将当前文件的父目录加入临时系统变量
@@ -82,9 +84,10 @@ def websiteInfo(company_name):
 def app_website(server):
     @server.route('/app-website/<companyName>')
     def generate_html(companyName):
-        companyName = strQ2B(companyName)
-        app_info = appInfo(companyName)
-        website_info = websiteInfo(companyName)
+        # companyName = strQ2B(companyName)
+        standard_company_name = getStandardName(companyName)
+        app_info = appInfo(standard_company_name)
+        website_info = websiteInfo(standard_company_name)
         return render_template('potential_business.html',**locals())
 #
 # if __name__ == "__main__":

entprofile/service/rec_status.py

@@ -11,7 +11,6 @@ from db.mod_db import DataBase
 from flask import request
 
 
-
 #更新状态表的结果
 def WriteRecStatusToSql(recommend_id,status_name):
     # json写入数据库

entprofile/service/select_es_result.py

@@ -11,6 +11,8 @@ from elasticsearch import Elasticsearch
 from service.company_basic import CompanyBase
 from dao.select_hx_logo import hx_logo_Dao
 from db.mod_db import DataBase
+from common.crm_change_standard import getStandardName
+
 
 
 companybase = CompanyBase()
@@ -274,10 +276,11 @@ def hx_company_dict(server):
         if request.method == 'POST':
             requestdata = request.json
             company_name = requestdata.get('company_name')
+            standard_company_name = getStandardName(company_name)
             print(type(company_name), 0000)
             try:
-                base_result = companybase.companyinfo(company_name)
-                logo_url = hx.select_url(company_name)
+                base_result = companybase.companyinfo(standard_company_name)
+                logo_url = hx.select_url(standard_company_name)
                 if base_result:
                     base_result['logo'] = logo_url
                 else:

entprofile/service/talking.py

@@ -121,7 +121,9 @@ def talking(server):
     def SingleLogoApi1():
         try:
             recommendId = request.get_json().get("recommendId")
+            print('recommendId',recommendId)
             name = getName(recommendId)
+            print('name',name)
             # name = 'tttt'
             source = getSource(name)
             print('source',source)

entprofile/service/tf_member.py

@@ -3,6 +3,7 @@ import json
 from dao.tf_member_dao import tf_member_Dao
 from dao.tf_member_es import tf_member_Es
 from db.mod_db import DataBase
+from common.crm_change_standard import getStandardName
 
 def getdbdata_gg(input_name):
     tf_memberInfo = tf_member_Dao()
@@ -202,8 +203,9 @@ def gaoguan(server):
         if request.method == 'POST':
             request_data = request.json
             inputs = request_data.get('company_name')
+            standard_company_name = getStandardName(inputs)
             # gaoguan=getdbdata_gg(inputs)
-            annual_report = search_gaoguan(inputs)
+            annual_report = search_gaoguan(standard_company_name)
             # json.dumps(annual_report, ensure_ascii=False)
             # outputs=record2jsion_gg(gaoguan)
             return json.dumps(annual_report, ensure_ascii=False)  # gaoguan #outputs
@@ -223,7 +225,8 @@ def gudong(server):
         if request.method == 'POST':
             request_data = request.json
             inputs = request_data.get('company_name')
-            gudong = search_gudong(inputs)
+            standard_company_name = getStandardName(inputs)
+            gudong = search_gudong(standard_company_name)
             return json.dumps(gudong, ensure_ascii=False)
 
 def nianbao(server):
@@ -232,7 +235,8 @@ def nianbao(server):
         if request.method == 'POST':
             request_data = request.json
             inputs = request_data.get('company_name')
-            gudong = search_annual_report(inputs)
+            standard_company_name = getStandardName(inputs)
+            gudong = search_annual_report(standard_company_name)
             return json.dumps(gudong, ensure_ascii=False)
 
 

entprofile/service/trade.py

 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
 from flask import request
+from common.crm_change_standard import getStandardName
 import json
 from service.Dataoper import Datao
 from dao.trade_es import trade_Es
 
 
+
 def selectcyle(server):
     @server.route("/api/selectcycle",methods = ['POST'])
     def getCompanyTrade():
         try:
             companyNames=request.get_json().get("company_name")
             trade_Info = trade_Es()
-            searched = trade_Info.Get_Data_By_Body(companyNames)
+            standard_company_name = getStandardName(companyNames)
+            searched = trade_Info.Get_Data_By_Body(standard_company_name)
             if searched["hits"]["total"]:
                 company_cate_1 = searched["hits"]["hits"][0]['_source']["gsb_company_cate_1"]  # 行业第一大类
                 company_cate_2 = searched["hits"]["hits"][0]['_source']["gsb_company_cate_2"]  # 行业第二大类

entprofile/service/user_behavior.py

@@ -262,6 +262,7 @@ class Recom:
         product_list = []
         product = ProductDao()
         product_result = product.select(company_name)
+        print('product_result',len(product_result))
         for data in product_result:
             print(data,"======推荐产品")
             if data['relational_product_old']:
@@ -289,6 +290,7 @@ class Recom:
                     crossitem['typeName'] = "交叉推荐"
                     product_list.append(crossitem)
             if data['survey_product_old']:
+                print('111',data['survey_product_old'])
                 survey = eval(data['survey_product_old'])
                 for surveyitem in survey:
                     surveyitem['typeCate'] = surveyitem['typeName']
@@ -304,13 +306,6 @@ class Recom:
                     potentialitem['typeName'] = "潜在商机"
                     product_list.append(potentialitem)
 
-            if data['relational_product_old']:
-                relational = eval(data['relational_product_old'])
-                for relationalitem in relational:
-                    relationalitem['typeCate'] = relationalitem['typeName']
-                    relationalitem['productName'] = relationalitem['commodityName']
-                    relationalitem['typeName'] = "关联推荐"
-                    product_list.append(relationalitem)
 
             if data['seas_product_old']:
                 seas = eval(data['seas_product_old'])