财报代码编写
This commit is contained in:
parent
11a0beaade
commit
b5f9136b7f
|
@ -3,7 +3,6 @@ package com.hzya.frame.plugin.incomeInvoiceData.plugin;
|
||||||
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.fastjson.JSONObject;
|
||||||
import com.hzya.frame.base.PluginBaseEntity;
|
import com.hzya.frame.base.PluginBaseEntity;
|
||||||
import com.hzya.frame.plugin.incomeInvoiceData.service.IIncomeInvoiceService;
|
import com.hzya.frame.plugin.incomeInvoiceData.service.IIncomeInvoiceService;
|
||||||
import com.hzya.frame.web.entity.BaseResult;
|
|
||||||
import com.hzya.frame.web.entity.JsonResultEntity;
|
import com.hzya.frame.web.entity.JsonResultEntity;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
|
@ -54,8 +53,8 @@ public class FinancialReportPluginInitializer extends PluginBaseEntity{
|
||||||
public JsonResultEntity executeBusiness(JSONObject requestJson) {
|
public JsonResultEntity executeBusiness(JSONObject requestJson) {
|
||||||
try {
|
try {
|
||||||
logger.info("======开始执行财务信息同步========");
|
logger.info("======开始执行财务信息同步========");
|
||||||
return BaseResult.getSuccessMessageEntity("数据获取成功");
|
//return BaseResult.getSuccessMessageEntity("数据获取成功");
|
||||||
//return incomeInvoiceService.sendFinancialReportPlugin(requestJson);
|
return incomeInvoiceService.sendFinancialReportPlugin(requestJson);
|
||||||
}catch (Exception e){
|
}catch (Exception e){
|
||||||
logger.info("======执行财务同步失败:{}========",e.getMessage());
|
logger.info("======执行财务同步失败:{}========",e.getMessage());
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
|
|
|
@ -269,8 +269,8 @@ public class IncomeInvoiceServiceImpl extends BaseService<IncomeInvoiceEntity, S
|
||||||
JSONObject queryParams = new JSONObject();
|
JSONObject queryParams = new JSONObject();
|
||||||
queryParams.put("page",queryCursor);
|
queryParams.put("page",queryCursor);
|
||||||
queryParams.put("size",size);
|
queryParams.put("size",size);
|
||||||
//queryParams.put("kprqq",dataTime);
|
queryParams.put("kprqq",dataTime);
|
||||||
//queryParams.put("kprqz",dataTime);
|
queryParams.put("kprqz",dataTime);
|
||||||
queryParams.put("taxNo",taxNo);
|
queryParams.put("taxNo",taxNo);
|
||||||
dayabody.put("queryParams",queryParams);
|
dayabody.put("queryParams",queryParams);
|
||||||
if(flags) {
|
if(flags) {
|
||||||
|
@ -946,6 +946,8 @@ public class IncomeInvoiceServiceImpl extends BaseService<IncomeInvoiceEntity, S
|
||||||
* @return com.hzya.frame.web.entity.JsonResultEntity
|
* @return com.hzya.frame.web.entity.JsonResultEntity
|
||||||
**/
|
**/
|
||||||
private JsonResultEntity sendFinancialReport(String ztbm ,String cjzq,String rwbm) {
|
private JsonResultEntity sendFinancialReport(String ztbm ,String cjzq,String rwbm) {
|
||||||
|
logger.error("财报数据推送入参"+ztbm+","+cjzq+","+rwbm);
|
||||||
|
|
||||||
String access_token = "";
|
String access_token = "";
|
||||||
if(flags){
|
if(flags){
|
||||||
access_token = getToken();
|
access_token = getToken();
|
||||||
|
|
|
@ -3,7 +3,7 @@ logging:
|
||||||
#日志级别 指定目录级别
|
#日志级别 指定目录级别
|
||||||
level:
|
level:
|
||||||
root: INFO
|
root: INFO
|
||||||
encodings: UTF-8
|
encodings: GBK
|
||||||
file:
|
file:
|
||||||
# 日志保存路径
|
# 日志保存路径
|
||||||
path: D:\yongansystem\serverV3\log\test
|
path: D:\yongansystem\serverV3\log\test
|
||||||
|
|
Loading…
Reference in New Issue