Skip to content

Z
zhichan
Commit b1c9cf23 by 宋毅
Options

fh0323

parent 326307d7
Showing with 36 additions and 16 deletions
rpt_result/main.py
...@@ -7,7 +7,7 @@ ...@@ -7,7 +7,7 @@
from getcompanyinfofromES import GetComanyinfoFromES from getcompanyinfofromES import GetComanyinfoFromES
from GetFIinfoFromJson import GetFIinfoFromJson from GetFIinfoFromJson import GetFIinfoFromJson
from GetRiskinfoFromJson import Riskinfo from GetRiskinfo import Riskinfo
import time,requests,oss2,sys,os,json import time,requests,oss2,sys,os,json
from flask import Flask ,request from flask import Flask ,request
from docxtpl import DocxTemplate,InlineImage from docxtpl import DocxTemplate,InlineImage
...@@ -45,10 +45,30 @@ def charts(datalist, charttype, pngpath): ...@@ -45,10 +45,30 @@ def charts(datalist, charttype, pngpath):
print("ExceptionExceptionExceptionExceptionExceptionException>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>ExceptionExceptionExceptionException") print("ExceptionExceptionExceptionExceptionExceptionException>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>ExceptionExceptionExceptionException")
return False return False
#传入风险描述信息list,表格分条显示
def in_Write_list(Risk_list):
sources = []
n = 1
for r in Risk_list:
if Risk_list==["贵公司提供的检测数据不能支撑此风险项检测，您可以尝试按季度或年度检测"]:
source = {"desc": "贵公司提供的检测数据不能支撑此风险项检测，您可以尝试按季度或年度检测",
"no": ""}
sources.append(source)
else:
source = {"desc": r,
"no": str(n)+"."}
n += 1
sources.append(source)
if sources == []:
source = {"desc": "根据贵公司提供的数据检测得出，贵公司暂无此项风险",
"no": ""}
sources.append(source)
return sources
#生成报告(es工商、财务信息、风险监测（仪表盘图）) #生成报告(es工商、财务信息、风险监测（仪表盘图）)
def WriteReport(Else_info,Companyinfo,Fi_dict,Risk_info): def WriteReport(Else_info,Companyinfo,Fi_dict,Risk_info):
tpl = DocxTemplate('tax_word_model.docx') tpl = DocxTemplate('tax_word_model_v2.docx')
context={} context={}
#其他传入参数 #其他传入参数
context['CreatTime']=Else_info['CreatTime'] context['CreatTime']=Else_info['CreatTime']
...@@ -137,19 +157,19 @@ def WriteReport(Else_info,Companyinfo,Fi_dict,Risk_info): ...@@ -137,19 +157,19 @@ def WriteReport(Else_info,Companyinfo,Fi_dict,Risk_info):
context["ARisk_desc"] = Risk_info["ARisk"]["describe"] context["ARisk_desc"] = Risk_info["ARisk"]["describe"]
context["describe_info"] = Risk_info["info"]["describe"] context["describe_info"] = Risk_info["info"]["describe"]
#细分风险项 #细分风险项
context["IT_YCSR_Risk_desc"] = str(Risk_info["Risk_IT_YCSR"]["describe"]).replace("['","").replace("']","").replace("'","") context['IT_YCSR_Risk_descs'] = in_Write_list(Risk_info["Risk_IT_YCSR"])
context["IT_XZFY_Risk_desc"] = str(Risk_info["Risk_IT_XZFY"]["describe"]).replace("['","").replace("']","").replace("'","") context["IT_XZFY_Risk_descs"] = in_Write_list(Risk_info["Risk_IT_XZFY"])
context["IT_XZCB_Risk_desc"] = str(Risk_info["Risk_IT_XZCB"]["describe"]).replace("['","").replace("']","").replace("'","") context["IT_XZCB_Risk_descs"] = in_Write_list(Risk_info["Risk_IT_XZCB"])
context["VAT_XKFP_Risk_desc"] = str(Risk_info["Risk_VAT_XKFP"]["describe"]).replace("['","").replace("']","").replace("'","") context["VAT_XKFP_Risk_descs"] = in_Write_list(Risk_info["Risk_VAT_XKFP"])
context["VAT_YCXX_Risk_desc"] = str(Risk_info["Risk_VAT_YCXX"]["describe"]).replace("['","").replace("']","").replace("'","") context["VAT_YCXX_Risk_descs"] = in_Write_list(Risk_info["Risk_VAT_YCXX"])
context["VAT_XZJX_Risk_desc"] = str(Risk_info["Risk_VAT_XZJX"]["describe"]).replace("['","").replace("']","").replace("'","") context["VAT_XZJX_Risk_descs"] = in_Write_list(Risk_info["Risk_VAT_XZJX"])
context["CT_FX_Risk_desc"] = str(Risk_info["Risk_CT_FX"]["describe"]).replace("['","").replace("']","").replace("'","") context["CT_FX_Risk_descs"] = in_Write_list(Risk_info["Risk_CT_FX"])
context["ALLT_FX_Risk_desc"] = str(Risk_info["Risk_ALLT_FX"]["describe"]).replace("['","").replace("']","").replace("'","") context["ALLT_FX_Risk_descs"] = in_Write_list(Risk_info["Risk_ALLT_FX"])
print("ddddddddddddddddddddddddddddddddddd"); print("ddddddddddddddddddddddddddddddddddd")
tpl.render(context) tpl.render(context)
addr = "/tmp/TaxRiskReport.docx" addr = "/tmp/TaxRiskReport.docx"
# addr = "G://TaxRiskReport26.docx" # addr = "G://TaxRiskReport32.docx"
print("ddddddddddddddddddddddddddddddddddd"); print("ddddddddddddddddddddddddddddddddddd")
tpl.save(addr) tpl.save(addr)
print(addr,"+++++++++") print(addr,"+++++++++")
return addr return addr
...@@ -204,7 +224,7 @@ def report(): ...@@ -204,7 +224,7 @@ def report():
# print(data) # print(data)
# print("ccccccccccccccccccccccccccccc") # print("ccccccccccccccccccccccccccccc")
# json_str = json.dumps(data) # json_str = json.dumps(data)
# print(json_str); # print(json_str)
GetAllinfo = json.loads(data) GetAllinfo = json.loads(data)
companyname=GetAllinfo["company_name"] #获取监测企业名称 companyname=GetAllinfo["company_name"] #获取监测企业名称
batchid=GetAllinfo["Task_Num"] #获取任务号 batchid=GetAllinfo["Task_Num"] #获取任务号
...@@ -218,7 +238,6 @@ def report(): ...@@ -218,7 +238,6 @@ def report():
report = WriteReport(Else_info,Companyinfo,Fi_dict,Risk_info) #将工商、财务、风险三部分内容写入word中 report = WriteReport(Else_info,Companyinfo,Fi_dict,Risk_info) #将工商、财务、风险三部分内容写入word中
except Exception as e: except Exception as e:
print(e) print(e)
rptUrl = put2oss(report) # 上传文件到oss上 rptUrl = put2oss(report) # 上传文件到oss上
print("报告已生成",rptUrl) print("报告已生成",rptUrl)
result=UpdateTaskRptUrl(batchid, rptUrl)# 完成后调用接口，通知服务已完成 result=UpdateTaskRptUrl(batchid, rptUrl)# 完成后调用接口，通知服务已完成
...@@ -227,4 +246,4 @@ def report(): ...@@ -227,4 +246,4 @@ def report():
return "请输入检测公司名称" return "请输入检测公司名称"
server.run(host='0.0.0.0', port=80, debug=False) server.run(host='0.0.0.0', port=80, debug=False)
\ 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