hj

entprofile/.idea/workspace.xml

@@ -158,6 +158,18 @@
       </list>
     </recent_temporary>
   </component>
+  <component name="ServiceViewManager">
+    <option name="viewStates">
+      <list>
+        <serviceView>
+          <treeState>
+            <expand />
+            <select />
+          </treeState>
+        </serviceView>
+      </list>
+    </option>
+  </component>
   <component name="SvnConfiguration">
     <configuration />
   </component>
@@ -173,6 +185,8 @@
       <workItem from="1587352427758" duration="7427000" />
       <workItem from="1587433007175" duration="571000" />
       <workItem from="1587437264430" duration="2651000" />
+      <workItem from="1588728490707" duration="79000" />
+      <workItem from="1588728913571" duration="5000" />
     </task>
     <servers />
   </component>
@@ -294,10 +308,10 @@
     </breakpoint-manager>
   </component>
   <component name="com.intellij.coverage.CoverageDataManagerImpl">
-    <SUITE FILE_PATH="coverage/recommendation$mod_db.coverage" NAME="mod_db Coverage Results" MODIFIED="1587358120537" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$/db" />
     <SUITE FILE_PATH="coverage/recommendation$main.coverage" NAME="main Coverage Results" MODIFIED="1587437271477" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$" />
-    <SUITE FILE_PATH="coverage/recommendation$company_basic.coverage" NAME="company_basic Coverage Results" MODIFIED="1587363152092" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$/service" />
     <SUITE FILE_PATH="coverage/recommendation$company_es.coverage" NAME="company_es Coverage Results" MODIFIED="1587358210574" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$/dao" />
+    <SUITE FILE_PATH="coverage/recommendation$company_basic.coverage" NAME="company_basic Coverage Results" MODIFIED="1587363152092" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$/service" />
     <SUITE FILE_PATH="coverage/recommendation$user_behavior.coverage" NAME="user_behavior Coverage Results" MODIFIED="1587456914187" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$/user_behavior" />
+    <SUITE FILE_PATH="coverage/recommendation$mod_db.coverage" NAME="mod_db Coverage Results" MODIFIED="1587358120537" SOURCE_PROVIDER="com.intellij.coverage.DefaultCoverageFileProvider" RUNNER="coverage.py" COVERAGE_BY_TEST_ENABLED="true" COVERAGE_TRACING_ENABLED="false" WORKING_DIRECTORY="$PROJECT_DIR$/db" />
   </component>
 </project>
\ No newline at end of file

entprofile/dao/tj_provide_company.py

@@ -13,7 +13,7 @@ class ProvideDao:
 
     def select(self):
         return self.dataBase.fetch_all(
-            "select * from `tj_provide_company` where provide_status is null")
+            "select * from `tj_provide_company` where provide_status is null limit 100")
 
     def update_status(self,company_list):
         # print(" update tj_provide_company set provide_status = 1 where id in (%s)" % to_sql_in(company_list))

entprofile/main.py

@@ -20,7 +20,7 @@ from service.online_GetLicenseImage import getlicenceInfo
 from service.tf_member import gaoguan,gudong
 from service.talking import talking,talking_product
 from service.moneyAPI import moneyAPI
-
+from service.company_30s import tj_30s_hx
 
 server = Flask(__name__,static_url_path="",static_folder="")
 server.config['JSON_AS_ASCII'] = False
@@ -39,9 +39,10 @@ gudong(server)
 tj_rec_status(server)
 talking(server)
 talking_product(server)
+tj_30s_hx(server)
 
 #画像
-@server.route('/lable', methods=['POST'])
+@server.route('/label', methods=['POST'])
 def lable_post():
     if request.method == 'POST':
         request_data = request.json
@@ -76,7 +77,7 @@ def business_post():
 def business_product_post():
     if request.method == 'POST':
         request_data = request.json
-        if not request_data or not request_data.get('bussines_id'):
+        if not request_data or not request_data.get('credit_code'):
             return common_result.to_result(None, 300, "参数错误")
         business_id = request_data.get('bussines_id')
         business_product_result = recomm.business_product(business_id)

entprofile/service/company_30s.py

+import pymysql,json
+from flask import request
+from DBUtils.PooledDB import PooledDB
+
+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 industry_select(companyName):
+    company_industry = ''
+    conn = pool.connection()
+    cursor = conn.cursor()
+    sql = 'SELECT * FROM `tj_standard_order` WHERE standard_company_name = "%s" limit 1' % companyName
+    cursor.execute(sql)
+    standard_order_info = cursor.fetchall()
+    for row in standard_order_info:
+        company_industry = row[4]
+    return company_industry
+# print(industry_select('云选家网络科技(广东)有限公司'))
+# 根据公司名称获取产品标签两个。知识产权信息；3个（商标、著作权、专利）；资产标签2个及分公司情况
+def hx_30s(companyName):
+    conn = pool.connection()
+    cursor = conn.cursor()
+    sql = 'SELECT * FROM `tj_label_depth` WHERE company_name = "%s"' % companyName
+    cursor.execute(sql)
+    company_hx_info = cursor.fetchall()
+    hx_info_dict ={}
+    for row in company_hx_info:
+        hx_info_dict['company_base']  = row[1]
+        hx_info_dict['knowledge_info'] =  row[3]
+        hx_info_dict['product'] = row[5]
+    return hx_info_dict
+
+# 组装成输出的样子
+'''
+{
+  "code": 200,
+  "data": [
+    {
+      "lable_data": [
+        "大型企业",
+        "有限责任公司",
+        "青年公司",
+        "华北地区",
+        "一枝独秀"
+      ],
+      "lable_type": "基本标签"
+    }
+  ],
+  "message": "操作成功"
+}
+'''
+def final_hx (company_industry,hx_info_dict):
+    data = []
+    productData_dict ={}
+    industryData_dict ={}
+    knowledgeData_dict ={}
+    branchLable_dict ={}
+
+    industryData_dict['label_data'] = company_industry
+    industryData_dict['label_type'] = '行业标签'
+    data.append(industryData_dict)
+
+    productData = hx_info_dict['product'].replace('[','').replace(']','').replace("'",'').replace(" ",'').split(',')
+    if len(productData)>2:
+        lable_data =  productData[0:2]
+    else:
+        lable_data = productData
+    productData_dict['label_data'] = lable_data
+    productData_dict['label_type'] = '产品标签'
+    data.append(productData_dict)
+
+    knowledgeData = hx_info_dict['knowledge_info'].replace('[','').replace(']','').replace("'",'').replace(" ",'').split(',')
+    print(knowledgeData,"knowledgeData=====")
+    knowledgeData_list =[]
+    for knowledgeItem in knowledgeData:
+        knowledgeItem = eval(knowledgeItem)
+        for k,v in knowledgeItem.items():
+            knowledgeData_list.append(v)
+    knowledgeData_dict['label_data'] = knowledgeData_list
+    knowledgeData_dict['label_type'] = '资产标签'
+    data.append(knowledgeData_dict)
+
+    baseData = hx_info_dict['company_base'].replace('[', '').replace(']', '').replace("'", '').replace(" ",'').split(',')
+    for base_item in baseData:
+        base_item = eval(base_item)
+        if '分公司数量' in base_item.keys():
+            branchLable_dict['label_data'] = base_item['分公司数量']
+            branchLable_dict['label_type'] = '分公司标签'
+    data.append(branchLable_dict)
+    return data
+
+
+
+
+
+# 获取公司名称及获取30s画像
+def tj_30s_hx(server):
+    @server.route('/gsb/api/company_hx', methods=['POST'])
+    def company_30s_main():
+        if request.method == 'POST':
+            try:
+                requestdata = request.json
+                print(requestdata)
+                companyName = requestdata.get('company_name')
+                industryLable = industry_select(companyName)
+                hx_info_dict = hx_30s(companyName)
+                print(hx_info_dict, "hx_info_dict===")
+                data = final_hx(industryLable, hx_info_dict)
+                hx_30s_result = {"status": 0, "msg": "成功", "data": data}
+            except  Exception as error:
+                hx_30s_result = {"status": -1, "msg": "失败", "data": error}
+            return hx_30s_result
\ No newline at end of file

entprofile/service/user_behavior.py

@@ -173,12 +173,14 @@ class Recom:
             print(item)
             company_list.append(item['id'])
             business_data_dict = {}
-            company_name = item['company_name']
-            company_id = item['company_id']
+            crm_company_name = item['crm_company_name']
+            standard_company_name = item['standard_company_name']
+            company_id = item['credit_code']
             bussinessid = item['serial_number']
             create_time = str(item['create_time'])[:10]
             business_data_dict['companyId'] = company_id
-            business_data_dict['companyName'] = company_name
+            business_data_dict['crm_company_name'] = crm_company_name
+            business_data_dict['standard_company_name'] = standard_company_name
             business_data_dict['businessId'] = bussinessid
             business_data_dict['createTime'] = create_time
             print(business_data_dict)