Commit 6301c95b by 蒋勇

d

parent 06f681e1
...@@ -35,6 +35,7 @@ class RptTypeService extends ServiceBase{ ...@@ -35,6 +35,7 @@ class RptTypeService extends ServiceBase{
await self.db.models.rpthistory.bulkCreate(hisarray,{transaction:t}); await self.db.models.rpthistory.bulkCreate(hisarray,{transaction:t});
//每保存一次历史数据,就是处理完成一个任务中的一个报表 //每保存一次历史数据,就是处理完成一个任务中的一个报表
var currentval= await self.redisClient.decr("batch"+batchid); var currentval= await self.redisClient.decr("batch"+batchid);
console.log(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>"+currentval);
if(currentval==0){ if(currentval==0){
await self.redisClient.rpush("riskmq",JSON.stringify({ await self.redisClient.rpush("riskmq",JSON.stringify({
key:new Date().toLocaleString(), key:new Date().toLocaleString(),
...@@ -44,6 +45,7 @@ class RptTypeService extends ServiceBase{ ...@@ -44,6 +45,7 @@ class RptTypeService extends ServiceBase{
accountTypeCode:batch.accountstandardcode, accountTypeCode:batch.accountstandardcode,
taxCode:batch.companycode taxCode:batch.companycode
} }
console.log(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>sended...........");
})); }));
self.redisClient.delete("batch"+batchid); self.redisClient.delete("batch"+batchid);
//改变批的状态为解析完毕 //改变批的状态为解析完毕
...@@ -68,14 +70,19 @@ class RptTypeService extends ServiceBase{ ...@@ -68,14 +70,19 @@ class RptTypeService extends ServiceBase{
tmp[item.indexName]=Number(item.status); tmp[item.indexName]=Number(item.status);
})); }));
var rptdata=await this.apiCallWithoutAk("http://fkrptresult-service/gsb/api/report",tmp); var rptdata=await this.apiCallWithoutAk("http://fkrptresult-service/gsb/api/report",tmp);
var rtn={ if(rptdata){
var rtn={
batchdate:batch.batchdate, batchdate:batch.batchdate,
rptdate:batch.updated_at, rptdate:batch.updated_at,
companyName:batch.companyname, companyName:batch.companyname,
taxCode:batch.companycode, taxCode:batch.companycode,
results:rptdata, results:rptdata,
}; };
return rtn; return rtn;
}else{
return null;
}
} }
async saveRpt(upinfo){ async saveRpt(upinfo){
return this.db.transaction(async t=>{ return this.db.transaction(async t=>{
......
...@@ -142,3 +142,40 @@ console.log(t2.apiDoc); ...@@ -142,3 +142,40 @@ console.log(t2.apiDoc);
具有良好的沟通表达能力和团队协作能力。 具有良好的沟通表达能力和团队协作能力。
对标白兔 继续
1,目前没使用 2,很少使用,3,使用中
最后上传日期 2019.7.19
功能迁移到IGIRL,未产品化
计税宝 注册用户 业务支持使用中
效果好,争取到了项目
使用中,对外展示用
稳定 交易
流量接入 效果不错
尹亚亭
数据库设计
整合和运维各子系统
老系统商标导入蜂擎
申洪蝉
知产接入
对接方案设计
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