Skip to content

Z
zhichan
Commit e172390d by 黄静
Options

hj

parent 1a176c48
Showing with 199 additions and 18 deletions
entprofile/.idea/vcs.xml
<?xml version="1.0" encoding="UTF-8"?> <?xml version="1.0" encoding="UTF-8"?>
<project version="4"> <project version="4">
<component name="VcsDirectoryMappings"> <component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$/.." vcs="Git" />
<mapping directory="$PROJECT_DIR$/leisu_spider" vcs="Git" /> <mapping directory="$PROJECT_DIR$/leisu_spider" vcs="Git" />
</component> </component>
</project> </project>
\ No newline at end of file
entprofile/.idea/workspace.xml
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
</option> </option>
</component> </component>
<component name="Git.Settings"> <component name="Git.Settings">
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$/leisu_spider" /> <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$/.." />
</component> </component>
<component name="ProjectId" id="1abyT4R17M95kTBWh7hxBjmC0uU" /> <component name="ProjectId" id="1abyT4R17M95kTBWh7hxBjmC0uU" />
<component name="ProjectLevelVcsManager" settingsEditedManually="true" /> <component name="ProjectLevelVcsManager" settingsEditedManually="true" />
...@@ -174,6 +174,7 @@ ...@@ -174,6 +174,7 @@
<workItem from="1587433007175" duration="571000" /> <workItem from="1587433007175" duration="571000" />
<workItem from="1587437264430" duration="2651000" /> <workItem from="1587437264430" duration="2651000" />
<workItem from="1588754339665" duration="838000" /> <workItem from="1588754339665" duration="838000" />
<workItem from="1589429479087" duration="1372000" />
</task> </task>
<servers /> <servers />
</component> </component>
......
entprofile/assets/css/chunk-vendors.edfc448e.css 0 → 100644
This source diff could not be displayed because it is too large. You can view the blob instead.
entprofile/assets/js/app.fef2144c.js → entprofile/assets/js/app.f6904fcf.js
(function(e){function t(t){for(var r,o,c=t[0],i=t[1],s=t[2],l=0,f=[];l<c.length;l++)o=c[l],Object.prototype.hasOwnProperty.call(a,o)&&a[o]&&f.push(a[o][0]),a[o]=0;for(r in i)Object.prototype.hasOwnProperty.call(i,r)&&(e[r]=i[r]);p&&p(t);while(f.length)f.shift()();return u.push.apply(u,s||[]),n()}function n(){for(var e,t=0;t<u.length;t++){for(var n=u[t],r=!0,o=1;o<n.length;o++){var c=n[o];0!==a[c]&&(r=!1)}r&&(u.splice(t--,1),e=i(i.s=n[0]))}return e}var r={},o={app:0},a={app:0},u=[];function c(e){return i.p+"assets/js/"+({}[e]||e)+"."+{"chunk-15340143":"2ca419d3"}[e]+".js"}function i(t){if(r[t])return r[t].exports;var n=r[t]={i:t,l:!1,exports:{}};return e[t].call(n.exports,n,n.exports,i),n.l=!0,n.exports}i.e=function(e){var t=[],n={"chunk-15340143":1};o[e]?t.push(o[e]):0!==o[e]&&n[e]&&t.push(o[e]=new Promise((function(t,n){for(var r="assets/css/"+({}[e]||e)+"."+{"chunk-15340143":"0d644d4c"}[e]+".css",a=i.p+r,u=document.getElementsByTagName("link"),c=0;c<u.length;c++){var s=u[c],l=s.getAttribute("data-href")||s.getAttribute("href");if("stylesheet"===s.rel&&(l===r||l===a))return t()}var f=document.getElementsByTagName("style");for(c=0;c<f.length;c++){s=f[c],l=s.getAttribute("data-href");if(l===r||l===a)return t()}var p=document.createElement("link");p.rel="stylesheet",p.type="text/css",p.onload=t,p.onerror=function(t){var r=t&&t.target&&t.target.src||a,u=new Error("Loading CSS chunk "+e+" failed.\n("+r+")");u.code="CSS_CHUNK_LOAD_FAILED",u.request=r,delete o[e],p.parentNode.removeChild(p),n(u)},p.href=a;var d=document.getElementsByTagName("head")[0];d.appendChild(p)})).then((function(){o[e]=0})));var r=a[e];if(0!==r)if(r)t.push(r[2]);else{var u=new Promise((function(t,n){r=a[e]=[t,n]}));t.push(r[2]=u);var s,l=document.createElement("script");l.charset="utf-8",l.timeout=120,i.nc&&l.setAttribute("nonce",i.nc),l.src=c(e);var f=new Error;s=function(t){l.onerror=l.onload=null,clearTimeout(p);var n=a[e];if(0!==n){if(n){var r=t&&("load"===t.type?"missing":t.type),o=t&&t.target&&t.target.src;f.message="Loading chunk "+e+" failed.\n("+r+": "+o+")",f.name="ChunkLoadError",f.type=r,f.request=o,n[1](f)}a[e]=void 0}};var p=setTimeout((function(){s({type:"timeout",target:l})}),12e4);l.onerror=l.onload=s,document.head.appendChild(l)}return Promise.all(t)},i.m=e,i.c=r,i.d=function(e,t,n){i.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:n})},i.r=function(e){"undefined"!==typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},i.t=function(e,t){if(1&t&&(e=i(e)),8&t)return e;if(4&t&&"object"===typeof e&&e&&e.__esModule)return e;var n=Object.create(null);if(i.r(n),Object.defineProperty(n,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var r in e)i.d(n,r,function(t){return e[t]}.bind(null,r));return n},i.n=function(e){var t=e&&e.__esModule?function(){return e["default"]}:function(){return e};return i.d(t,"a",t),t},i.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},i.p="/",i.oe=function(e){throw console.error(e),e};var s=window["webpackJsonp"]=window["webpackJsonp"]||[],l=s.push.bind(s);s.push=t,s=s.slice();for(var f=0;f<s.length;f++)t(s[f]);var p=l;u.push([0,"chunk-vendors"]),n()})({0:function(e,t,n){e.exports=n("56d7")},"034f":function(e,t,n){"use strict";var r=n("85ec"),o=n.n(r);o.a},"56d7":function(e,t,n){"use strict";n.r(t);n("e260"),n("e6cf"),n("cca6"),n("a79d");var r=n("2b0e"),o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("div",{attrs:{id:"app"}},[n("router-view")],1)},a=[],u={name:"App",components:{}},c=u,i=(n("034f"),n("2877")),s=Object(i["a"])(c,o,a,!1,null,null,null),l=s.exports,f=(n("d3b7"),n("8c4f"));r["default"].use(f["a"]);var p=new f["a"]({routes:[{path:"/:companyName",component:function(){return n.e("chunk-15340143").then(n.bind(null,"8799"))}}]}),d=p,h=n("2f62");r["default"].use(h["a"]);var m=new h["a"].Store({state:{},mutations:{},actions:{},modules:{}}),v=n("5c96"),g=n.n(v);r["default"].use(g.a),r["default"].config.productionTip=!1,new r["default"]({router:d,store:m,render:function(e){return e(l)}}).$mount("#app")},"85ec":function(e,t,n){}}); (function(e){function t(t){for(var r,o,c=t[0],i=t[1],s=t[2],l=0,f=[];l<c.length;l++)o=c[l],Object.prototype.hasOwnProperty.call(a,o)&&a[o]&&f.push(a[o][0]),a[o]=0;for(r in i)Object.prototype.hasOwnProperty.call(i,r)&&(e[r]=i[r]);d&&d(t);while(f.length)f.shift()();return u.push.apply(u,s||[]),n()}function n(){for(var e,t=0;t<u.length;t++){for(var n=u[t],r=!0,o=1;o<n.length;o++){var c=n[o];0!==a[c]&&(r=!1)}r&&(u.splice(t--,1),e=i(i.s=n[0]))}return e}var r={},o={app:0},a={app:0},u=[];function c(e){return i.p+"assets/js/"+({}[e]||e)+"."+{"chunk-6b5d4dd2":"a7ce474c"}[e]+".js"}function i(t){if(r[t])return r[t].exports;var n=r[t]={i:t,l:!1,exports:{}};return e[t].call(n.exports,n,n.exports,i),n.l=!0,n.exports}i.e=function(e){var t=[],n={"chunk-6b5d4dd2":1};o[e]?t.push(o[e]):0!==o[e]&&n[e]&&t.push(o[e]=new Promise((function(t,n){for(var r="assets/css/"+({}[e]||e)+"."+{"chunk-6b5d4dd2":"01b1ce4f"}[e]+".css",a=i.p+r,u=document.getElementsByTagName("link"),c=0;c<u.length;c++){var s=u[c],l=s.getAttribute("data-href")||s.getAttribute("href");if("stylesheet"===s.rel&&(l===r||l===a))return t()}var f=document.getElementsByTagName("style");for(c=0;c<f.length;c++){s=f[c],l=s.getAttribute("data-href");if(l===r||l===a)return t()}var d=document.createElement("link");d.rel="stylesheet",d.type="text/css",d.onload=t,d.onerror=function(t){var r=t&&t.target&&t.target.src||a,u=new Error("Loading CSS chunk "+e+" failed.\n("+r+")");u.code="CSS_CHUNK_LOAD_FAILED",u.request=r,delete o[e],d.parentNode.removeChild(d),n(u)},d.href=a;var p=document.getElementsByTagName("head")[0];p.appendChild(d)})).then((function(){o[e]=0})));var r=a[e];if(0!==r)if(r)t.push(r[2]);else{var u=new Promise((function(t,n){r=a[e]=[t,n]}));t.push(r[2]=u);var s,l=document.createElement("script");l.charset="utf-8",l.timeout=120,i.nc&&l.setAttribute("nonce",i.nc),l.src=c(e);var f=new Error;s=function(t){l.onerror=l.onload=null,clearTimeout(d);var n=a[e];if(0!==n){if(n){var r=t&&("load"===t.type?"missing":t.type),o=t&&t.target&&t.target.src;f.message="Loading chunk "+e+" failed.\n("+r+": "+o+")",f.name="ChunkLoadError",f.type=r,f.request=o,n[1](f)}a[e]=void 0}};var d=setTimeout((function(){s({type:"timeout",target:l})}),12e4);l.onerror=l.onload=s,document.head.appendChild(l)}return Promise.all(t)},i.m=e,i.c=r,i.d=function(e,t,n){i.o(e,t)||Object.defineProperty(e,t,{enumerable:!0,get:n})},i.r=function(e){"undefined"!==typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},i.t=function(e,t){if(1&t&&(e=i(e)),8&t)return e;if(4&t&&"object"===typeof e&&e&&e.__esModule)return e;var n=Object.create(null);if(i.r(n),Object.defineProperty(n,"default",{enumerable:!0,value:e}),2&t&&"string"!=typeof e)for(var r in e)i.d(n,r,function(t){return e[t]}.bind(null,r));return n},i.n=function(e){var t=e&&e.__esModule?function(){return e["default"]}:function(){return e};return i.d(t,"a",t),t},i.o=function(e,t){return Object.prototype.hasOwnProperty.call(e,t)},i.p="/",i.oe=function(e){throw console.error(e),e};var s=window["webpackJsonp"]=window["webpackJsonp"]||[],l=s.push.bind(s);s.push=t,s=s.slice();for(var f=0;f<s.length;f++)t(s[f]);var d=l;u.push([0,"chunk-vendors"]),n()})({0:function(e,t,n){e.exports=n("56d7")},"034f":function(e,t,n){"use strict";var r=n("85ec"),o=n.n(r);o.a},"56d7":function(e,t,n){"use strict";n.r(t);n("e260"),n("e6cf"),n("cca6"),n("a79d");var r=n("2b0e"),o=function(){var e=this,t=e.$createElement,n=e._self._c||t;return n("div",{attrs:{id:"app"}},[n("router-view")],1)},a=[],u={name:"App",components:{}},c=u,i=(n("034f"),n("2877")),s=Object(i["a"])(c,o,a,!1,null,null,null),l=s.exports,f=(n("d3b7"),n("8c4f"));r["default"].use(f["a"]);var d=new f["a"]({routes:[{path:"/abc",component:function(){return n.e("chunk-6b5d4dd2").then(n.bind(null,"971e"))}}]}),p=d,h=n("2f62");r["default"].use(h["a"]);var v=new h["a"].Store({state:{},mutations:{},actions:{},modules:{}}),m=n("5c96"),b=n.n(m);n("0fae");r["default"].use(b.a),r["default"].config.productionTip=!1,new r["default"]({router:p,store:v,render:function(e){return e(l)}}).$mount("#app")},"85ec":function(e,t,n){}});
//# sourceMappingURL=app.fef2144c.js.map //# sourceMappingURL=app.f6904fcf.js.map
\ No newline at end of file \ No newline at end of file
entprofile/assets/js/chunk-15340143.2ca419d3.js deleted 100644 → 0
This source diff could not be displayed because it is too large. You can view the blob instead.
entprofile/assets/js/chunk-15340143.2ca419d3.js.map deleted 100644 → 0
This source diff could not be displayed because it is too large. You can view the blob instead.
entprofile/assets/js/chunk-6b5d4dd2.a7ce474c.js 0 → 100644
This source diff could not be displayed because it is too large. You can view the blob instead.
entprofile/assets/js/chunk-6b5d4dd2.a7ce474c.js.map 0 → 100644
This source diff could not be displayed because it is too large. You can view the blob instead.
entprofile/assets/js/chunk-vendors.a861e867.js → entprofile/assets/js/chunk-vendors.8f3145c3.js 100755 → 100644
This source diff could not be displayed because it is too large. You can view the blob instead.
entprofile/assets/js/chunk-vendors.a861e867.js.map → entprofile/assets/js/chunk-vendors.8f3145c3.js.map 100755 → 100644
This source diff could not be displayed because it is too large. You can view the blob instead.
entprofile/common/now_time.py
...@@ -4,10 +4,18 @@ ...@@ -4,10 +4,18 @@
# @Author : hj # @Author : hj
# @File : now_time.py # @File : now_time.py
# @Software: PyCharm # @Software: PyCharm
import datetime import datetime,time
def now_time(): def now_time():
now_time = datetime.datetime.now() now_time = datetime.datetime.now()
print(now_time) print(now_time)
return now_time return now_time
# now_time() # now_time()
def re_strf_Time(timestamp):
if (timestamp != None):
timeArray = time.localtime(timestamp)
otherStyleTime = time.strftime("%Y/%m/%d", timeArray) # %Y/%m/%d %H:%M:%S
else:
otherStyleTime = ''
return otherStyleTime
entprofile/dao/change_message_es.py 0 → 100644
from db.mod_db import EsBase
index = "bigdata_ic_gsb_change_1"
class ChangeMessage:
def __init__(self, es=None):
if es is None:
self.esBase = EsBase()
else:
self.esBase = es
def select_branch(self,factor):
query = {
"query":{
"term":{
factor[0]:factor[1]
}
},
"sort": [
{
"change_time": "desc"
}
],
"size":"10000"
}
return self.esBase.select(index=index,body=query)
entprofile/dao/tj_purchase_original_dao.py
...@@ -12,4 +12,4 @@ class OriginalDao: ...@@ -12,4 +12,4 @@ class OriginalDao:
def select(self,company_name): def select(self,company_name):
return self.dataBase.fetch_all("select * from `tj_standard_order` where standard_company_name = '%s' order by order_add_time desc " % company_name) return self.dataBase.fetch_all("select * from `tj_standard_order` where standard_company_name = '%s' by order_add_time desc " % company_name)
\ No newline at end of file \ No newline at end of file
entprofile/main.py
...@@ -17,11 +17,12 @@ from service.trade import selectcyle,insertcycle ...@@ -17,11 +17,12 @@ from service.trade import selectcyle,insertcycle
from service.GetImageFromSql import getImageInfo 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,nianbao
from service.talking import talking,talking_product from service.talking import talking,talking_product
from service.moneyAPI import moneyAPI from service.moneyAPI import moneyAPI
from service.company_30s import tj_30s_hx from service.company_30s import tj_30s_hx
from service.talking_name import talkingName_new from service.talking_name import talkingName_new
from service.change_message import companyChage
server = Flask(__name__,static_url_path="",static_folder="") server = Flask(__name__,static_url_path="",static_folder="")
server.config['JSON_AS_ASCII'] = False server.config['JSON_AS_ASCII'] = False
...@@ -37,11 +38,13 @@ getImageInfo(server) ...@@ -37,11 +38,13 @@ getImageInfo(server)
# getlicenceInfo(server) # getlicenceInfo(server)
gaoguan(server) gaoguan(server)
gudong(server) gudong(server)
nianbao(server)
tj_rec_status(server) tj_rec_status(server)
talking(server) talking(server)
talkingName_new(server) talkingName_new(server)
talking_product(server) talking_product(server)
tj_30s_hx(server) tj_30s_hx(server)
companyChage(server)
#基本信息 #基本信息
......
entprofile/service/change_message.py 0 → 100644
#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time : 2020/5/14 0014 11:04
# @Author : guopeng
# @File : change_message.py
# @Software: PyCharm Community Edition
from flask import request
import json
from common.re_companyName import strQ2B
from dao.change_message_es import ChangeMessage
# 内网IP
# esip = "172.16.18.110"
# esprot = "9201"
# esip = "43.247.184.94"
# esprot = "9200"
# esuser = "admines"
# espassword = "adminGSB."
# def qingxi(ustring):
# """全角转半角"""
# if ustring:
# rstring = ""
# for uchar in ustring:
# inside_code = ord(uchar)
# if inside_code == 12288: # 全角空格直接转换
# inside_code = 32
# elif (inside_code >= 65281 and inside_code <= 65374): # 全角字符（除空格）根据关系转化
# inside_code -= 65248
# rstring += chr(inside_code)
# for line in list(rstring):
# if line in ['·', '(', ')']:
# return rstring
# # if '·' or '(' or ')' in rstring:
# # return rstring
# data = re.sub('([\W,_]+)', '', rstring)
# return data
class Doelastic(object):
def SearchCompany(self,factor):
ChangeMessageInfo = ChangeMessage()
results = ChangeMessageInfo.select_branch(factor)
sp=[]
res = results["hits"]["hits"]
print(res)
for i in range(len(res)):
res[i]['_source']["num"]=i+1
if res[i]['_source']["change_item"] == None:
res[i]['_source']["change_item"]='-'
sp.append(res[i]['_source'])
return sp
def getCompnayByName(self,company_name):
factor = ['gsb_company_name.raw',company_name]
sss = self.SearchCompany(factor)
return sss
def companyChage(server):
@server.route("/api/changeAPI", methods=['POST'])
def APIChange():
try:
el = Doelastic()
mycompanyname = request.get_json().get("mycompanyname") # 得到问题
re_mycompanyname = strQ2B(mycompanyname)
r_1 = el.getCompnayByName(re_mycompanyname)
if r_1:
return json.dumps({"status": 1, "msg":"成功","data": r_1}, ensure_ascii=False)
else:
return json.dumps({"status": -1, "msg":"失败","data": 0}, ensure_ascii=False)
except:
return json.dumps({"status": -1, "msg":"调用服务出错","data": {}}, ensure_ascii=False)
#
# if __name__ == "__main__":
# el = Doelastic()
# el.getCompnayByName('青岛永创信息技术有限公司')
# if __name__ == '__main__':
# app.run(host='127.0.0.1', port=5000, debug=True)
# app.run(host=host'172.16.18.120', port=9500, debug=True)
entprofile/service/company_basic.py
...@@ -111,15 +111,24 @@ class CompanyBase: ...@@ -111,15 +111,24 @@ class CompanyBase:
for row in company_list['hits']['hits']: for row in company_list['hits']['hits']:
if row['_source']["company_name"] == company_name: if row['_source']["company_name"] == company_name:
continue continue
from_time = row['_source']["from_time"] from_time = ""
if row['_source']["from_time"] != None and row['_source']["from_time"] != "null": if row['_source']["from_time"] != None and row['_source']["from_time"] != "null" and row['_source'][
"from_time"] != 0:
from_time = self.array_time( from_time = self.array_time(
time_trans.TimestampChange(row['_source']["from_time"], 0)[0]) # 起时间 time_trans.TimestampChange(row['_source']["from_time"], 0)[0]) # 起时间
to_time = row['_source']["to_time"] # 社会统一性代码 to_time = ""
if row['_source']["to_time"] != None and row['_source']["to_time"] != "null": if row['_source']["to_time"] != None and row['_source']["to_time"] != "null" and row['_source'][
"to_time"] != 0:
to_time = self.array_time( to_time = self.array_time(
time_trans.TimestampChange(row['_source']["to_time"], 0)[0]) # 止时间 time_trans.TimestampChange(row['_source']["to_time"], 0)[0]) # 止时间
print(row['_source']["company_name"]) if row['_source']["credit_code"] == None:
row['_source']["credit_code"] = '-'
if row['_source']["legal_person"] == None:
row['_source']["legal_person"] = '-'
if row['_source']["gsb_company_cate_1"] == None:
row['_source']["gsb_company_cate_1"] = '-'
if row['_source']["company_org_type"] == None:
row['_source']["company_org_type"] = '-'
data = {"company_name":row['_source']["company_name"], "credit_code":row['_source']["credit_code"],"legal_person":str(row['_source']["legal_person"]),"time_between":str(str(from_time) + '- ' + str(to_time)),"gsb_company_cate_1":str(row['_source']["gsb_company_cate_1"]),"compamy_org_type":str(row['_source']["company_org_type"]) } data = {"company_name":row['_source']["company_name"], "credit_code":row['_source']["credit_code"],"legal_person":str(row['_source']["legal_person"]),"time_between":str(str(from_time) + '- ' + str(to_time)),"gsb_company_cate_1":str(row['_source']["gsb_company_cate_1"]),"compamy_org_type":str(row['_source']["company_org_type"]) }
namelist.append(data) namelist.append(data)
company_list_result = namelist[:3] company_list_result = namelist[:3]
......
entprofile/service/moneyAPI.py
...@@ -85,6 +85,7 @@ def moneyTest(mycompanyname): ...@@ -85,6 +85,7 @@ def moneyTest(mycompanyname):
sb_now_num = yx sb_now_num = yx
#计算不同行业的商机 #计算不同行业的商机
sb_ql_select='select trademark_num from business where gsb_company_cate_1 = "%s"'%gsb_company_cate_1 sb_ql_select='select trademark_num from business where gsb_company_cate_1 = "%s"'%gsb_company_cate_1
connection.ping(reconnect=True)
cur.execute(sb_ql_select) cur.execute(sb_ql_select)
data=cur.fetchone() data=cur.fetchone()
data=max(data) data=max(data)
...@@ -165,6 +166,7 @@ def moneyTest(mycompanyname): ...@@ -165,6 +166,7 @@ def moneyTest(mycompanyname):
zl_money = 0 zl_money = 0
zl_num=0 zl_num=0
zl_sql_select='select patent_num from business where gsb_company_cate_1 = "%s"'%gsb_company_cate_1 zl_sql_select='select patent_num from business where gsb_company_cate_1 = "%s"'%gsb_company_cate_1
connection.ping(reconnect=True)
cur.execute(zl_sql_select) cur.execute(zl_sql_select)
data1=cur.fetchone() data1=cur.fetchone()
data1=max(data1) data1=max(data1)
...@@ -310,6 +312,7 @@ def moneyTest(mycompanyname): ...@@ -310,6 +312,7 @@ def moneyTest(mycompanyname):
if ICP_status =="未办理": if ICP_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%IDC%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%IDC%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -324,6 +327,7 @@ def moneyTest(mycompanyname): ...@@ -324,6 +327,7 @@ def moneyTest(mycompanyname):
if EDI_status =="未办理": if EDI_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%EDI%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%EDI%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -339,6 +343,7 @@ def moneyTest(mycompanyname): ...@@ -339,6 +343,7 @@ def moneyTest(mycompanyname):
if IDC_status =="未办理": if IDC_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%IDC%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%IDC%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -354,6 +359,7 @@ def moneyTest(mycompanyname): ...@@ -354,6 +359,7 @@ def moneyTest(mycompanyname):
if web_status =="未办理": if web_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%网络文化经营许可证%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%网络文化经营许可证%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -369,6 +375,7 @@ def moneyTest(mycompanyname): ...@@ -369,6 +375,7 @@ def moneyTest(mycompanyname):
if game_pub_status =="未办理": if game_pub_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%网络游戏出版备案%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%网络游戏出版备案%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -384,6 +391,7 @@ def moneyTest(mycompanyname): ...@@ -384,6 +391,7 @@ def moneyTest(mycompanyname):
if game_do_status =="未办理": if game_do_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%网络游戏运营备案%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%网络游戏运营备案%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -400,6 +408,7 @@ def moneyTest(mycompanyname): ...@@ -400,6 +408,7 @@ def moneyTest(mycompanyname):
zz_importance="1" zz_importance="1"
else: else:
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%作品著作权%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%作品著作权%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -407,6 +416,7 @@ def moneyTest(mycompanyname): ...@@ -407,6 +416,7 @@ def moneyTest(mycompanyname):
zz_type="办理" zz_type="办理"
zz_money=799+zz_money zz_money=799+zz_money
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%软件著作权%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%软件著作权%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -424,6 +434,7 @@ def moneyTest(mycompanyname): ...@@ -424,6 +434,7 @@ def moneyTest(mycompanyname):
if qs_status =="未办理": if qs_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%食品生产许可证%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%食品生产许可证%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -440,6 +451,7 @@ def moneyTest(mycompanyname): ...@@ -440,6 +451,7 @@ def moneyTest(mycompanyname):
if sc_status =="未办理": if sc_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%食品生产许可证%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%食品生产许可证%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -454,6 +466,7 @@ def moneyTest(mycompanyname): ...@@ -454,6 +466,7 @@ def moneyTest(mycompanyname):
if gxqy_status =="未办理": if gxqy_status =="未办理":
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%高新企业认证%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%高新企业认证%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
...@@ -468,6 +481,7 @@ def moneyTest(mycompanyname): ...@@ -468,6 +481,7 @@ def moneyTest(mycompanyname):
#税务筹划 #税务筹划
product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%税收筹划%",mycompanyname) product_sql='SELECT * FROM tj_product_result_copy1_test_0317 where product_result like "%s" and companyname="%s"'%("%税收筹划%",mycompanyname)
connection.ping(reconnect=True)
cur.execute(product_sql) cur.execute(product_sql)
data=cur.fetchone() data=cur.fetchone()
if data: if data:
......
entprofile/service/tf_member.py
...@@ -164,6 +164,37 @@ def search_gudong(input_company_name): ...@@ -164,6 +164,37 @@ def search_gudong(input_company_name):
finall_info[j].update({'ture_subscript_type': finall_info[j].pop('paid_type')}) finall_info[j].update({'ture_subscript_type': finall_info[j].pop('paid_type')})
return finall_info # json.dumps(finall_info,ensure_ascii=False) return finall_info # json.dumps(finall_info,ensure_ascii=False)
def search_annual_report(input_company_name):
match_field_0='company_name'
field_cotent_0=input_company_name
#field_cotent1='83468156' 2914053007
annual_id = Get_Data_By_Body_Input("bigdata_ic_gsb_annualreport", match_field_0, field_cotent_0) # 返回查询结果
#print('OK--company_info->\n')
#print(annual_id[0])
finall_key={'company_id','report_year','company_name','usc_code','reg_number','phone_number','post_code', 'post_address','email','manage_state','employee_number'}
finall_info=[]
for j in range(0,len(annual_id)):
finall_info.append({key: value for key, value in annual_id[j].items() if key in finall_key})
#print('\n')
#print(finall_info[0])
report_year_unique=[]
for kk in range(0,len(finall_info)):
if finall_info[kk]['report_year'] not in report_year_unique:
report_year_unique.append(finall_info[kk]['report_year'])
report_year_unique=sorted(report_year_unique,reverse=True)
#print(report_year_unique)
finall_info_unique=[]
for ll in report_year_unique:
#print(ll)
for mm in range(0,len(finall_info)):
if finall_info[mm]['report_year']==ll:
finall_info_unique.append(finall_info[mm])
break
#print(finall_info_unique)
#print('OK--final_info->\n')
return finall_info_unique#json.dumps(finall_info_unique,ensure_ascii=False)
def gaoguan(server): def gaoguan(server):
@server.route('/api/gaoguan', methods=['POST']) @server.route('/api/gaoguan', methods=['POST'])
...@@ -172,10 +203,10 @@ def gaoguan(server): ...@@ -172,10 +203,10 @@ def gaoguan(server):
request_data = request.json request_data = request.json
inputs = request_data.get('company_name') inputs = request_data.get('company_name')
# gaoguan=getdbdata_gg(inputs) # gaoguan=getdbdata_gg(inputs)
gaoguan = search_gaoguan(inputs) annual_report = search_gaoguan(inputs)
json.dumps(gaoguan, ensure_ascii=False) # json.dumps(annual_report, ensure_ascii=False)
# outputs=record2jsion_gg(gaoguan) # outputs=record2jsion_gg(gaoguan)
return json.dumps(gaoguan, ensure_ascii=False) # gaoguan #outputs return json.dumps(annual_report, ensure_ascii=False) # gaoguan #outputs
'''def index(): '''def index():
...@@ -195,6 +226,15 @@ def gudong(server): ...@@ -195,6 +226,15 @@ def gudong(server):
gudong = search_gudong(inputs) gudong = search_gudong(inputs)
return json.dumps(gudong, ensure_ascii=False) return json.dumps(gudong, ensure_ascii=False)
def nianbao(server):
@server.route('/api/nianbao', methods=['POST'])
def indexxx():
if request.method == 'POST':
request_data = request.json
inputs = request_data.get('company_name')
gudong = search_annual_report(inputs)
return json.dumps(gudong, ensure_ascii=False)
'''def indexx(): '''def indexx():
if request.method=='POST': if request.method=='POST':
......
entprofile/templates/index.html
<!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>gsb_recomm</title><link href=/assets/css/chunk-15340143.0d644d4c.css rel=prefetch><link href=/assets/js/chunk-15340143.2ca419d3.js rel=prefetch><link href=/assets/css/app.f89c7511.css rel=preload as=style><link href=/assets/js/app.fef2144c.js rel=preload as=script><link href=/assets/js/chunk-vendors.a861e867.js rel=preload as=script><link href=/assets/css/app.f89c7511.css rel=stylesheet></head><body><noscript><strong>We're sorry but gsb_recomm doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/assets/js/chunk-vendors.a861e867.js></script><script src=/assets/js/app.fef2144c.js></script></body></html> <!DOCTYPE html><html lang=en><head><meta charset=utf-8><meta http-equiv=X-UA-Compatible content="IE=edge"><meta name=viewport content="width=device-width,initial-scale=1"><link rel=icon href=/favicon.ico><title>gsb_recomm</title><link href=/assets/css/chunk-6b5d4dd2.01b1ce4f.css rel=prefetch><link href=/assets/js/chunk-6b5d4dd2.a7ce474c.js rel=prefetch><link href=/assets/css/app.f89c7511.css rel=preload as=style><link href=/assets/css/chunk-vendors.edfc448e.css rel=preload as=style><link href=/assets/js/app.f6904fcf.js rel=preload as=script><link href=/assets/js/chunk-vendors.8f3145c3.js rel=preload as=script><link href=/assets/css/chunk-vendors.edfc448e.css rel=stylesheet><link href=/assets/css/app.f89c7511.css rel=stylesheet></head><body><noscript><strong>We're sorry but gsb_recomm doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id=app></div><script src=/assets/js/chunk-vendors.8f3145c3.js></script><script src=/assets/js/app.f6904fcf.js></script></body></html>
\ No newline at end of file \ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment