Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
Z
zhichan
Overview
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
蒋勇
zhichan
Commits
8803fdb1
Commit
8803fdb1
authored
Sep 18, 2020
by
Sxy
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
fix: 更改请求融易算地址
parent
87a6f402
Show whitespace changes
Inline
Side-by-side
Showing
6 changed files
with
51 additions
and
50 deletions
+51
-50
tx-fi-tax/app/base/controller/impl/bizchance/bizoptCtl.js
+16
-16
tx-fi-tax/app/base/controller/impl/bizchance/deliverybillCtl.js
+24
-23
tx-fi-tax/app/base/controller/impl/bizchance/fitaxschemeCtl.js
+6
-6
tx-fi-tax/app/base/utils/toFtClient.js
+2
-2
tx-fi-tax/app/config/routes/api.js
+2
-2
tx-fi-tax/app/config/settings.js
+1
-1
No files found.
tx-fi-tax/app/base/controller/impl/bizchance/bizoptCtl.js
View file @
8803fdb1
...
@@ -121,9 +121,9 @@ class BizOptCtl extends CtlBase {
...
@@ -121,9 +121,9 @@ class BizOptCtl extends CtlBase {
}
}
*/
*/
async
closeBizopt
(
mobj
,
qobj
,
req
)
{
async
closeBizopt
(
mobj
,
qobj
,
req
)
{
console
.
log
(
"bizoptCtl:closeBizopt:mobj-----------------"
,
JSON
.
stringify
(
mobj
));
console
.
log
(
"bizoptCtl:closeBizopt:mobj-----------------"
,
JSON
.
stringify
(
mobj
));
let
pobj
=
mobj
.
d
;
let
pobj
=
mobj
.
d
;
console
.
log
(
"bizoptCtl:closeBizopt:pobj-----------------"
,
JSON
.
stringify
(
pobj
));
console
.
log
(
"bizoptCtl:closeBizopt:pobj-----------------"
,
JSON
.
stringify
(
pobj
));
pobj
.
business_status
=
"isClosed"
;
pobj
.
business_status
=
"isClosed"
;
if
(
!
pobj
.
demand_code
||
!
pobj
.
close_reason
)
{
if
(
!
pobj
.
demand_code
||
!
pobj
.
close_reason
)
{
return
system
.
getResultError
(
"缺少必要参数."
);
return
system
.
getResultError
(
"缺少必要参数."
);
...
@@ -131,7 +131,7 @@ class BizOptCtl extends CtlBase {
...
@@ -131,7 +131,7 @@ class BizOptCtl extends CtlBase {
//根据需求编号去更新该条需求的状态为已关闭
//根据需求编号去更新该条需求的状态为已关闭
try
{
try
{
let
res
=
await
this
.
service
.
updateStatusByDemandCode
(
pobj
);
let
res
=
await
this
.
service
.
updateStatusByDemandCode
(
pobj
);
console
.
log
(
"bizoptCtl:closeBizopt:res-----------------"
,
JSON
.
stringify
(
res
));
console
.
log
(
"bizoptCtl:closeBizopt:res-----------------"
,
JSON
.
stringify
(
res
));
//添加到记录表
//添加到记录表
pobj
.
operator
=
{
pobj
.
operator
=
{
...
@@ -144,7 +144,7 @@ class BizOptCtl extends CtlBase {
...
@@ -144,7 +144,7 @@ class BizOptCtl extends CtlBase {
remarks
:
pobj
.
remarks
remarks
:
pobj
.
remarks
}
}
let
recordRes
=
await
this
.
operationrecordSve
.
insertInfo
(
pobj
);
let
recordRes
=
await
this
.
operationrecordSve
.
insertInfo
(
pobj
);
console
.
log
(
"bizoptCtl:operationrecordSve-----------------"
,
JSON
.
stringify
(
recordRes
));
console
.
log
(
"bizoptCtl:operationrecordSve-----------------"
,
JSON
.
stringify
(
recordRes
));
//异步将该需求关闭信息同步到其他系统(走队列,融易算接口文档2.3)
//异步将该需求关闭信息同步到其他系统(走队列,融易算接口文档2.3)
//构造参数,添加判断(有方案信息的才走队列同步到融易算,没有的直接关闭)
//构造参数,添加判断(有方案信息的才走队列同步到融易算,没有的直接关闭)
let
schemeRes
=
await
this
.
schemeSve
.
findInfo
(
pobj
);
let
schemeRes
=
await
this
.
schemeSve
.
findInfo
(
pobj
);
...
@@ -157,16 +157,16 @@ class BizOptCtl extends CtlBase {
...
@@ -157,16 +157,16 @@ class BizOptCtl extends CtlBase {
console
.
log
(
"bizoptCtl:closeBizopt-----------------关闭需求成功"
);
console
.
log
(
"bizoptCtl:closeBizopt-----------------关闭需求成功"
);
return
system
.
getResult
(
"关闭需求成功!"
);
return
system
.
getResult
(
"关闭需求成功!"
);
}
catch
(
error
)
{
}
catch
(
error
)
{
console
.
log
(
"bizoptCtl/closeBizopt 关闭需求出错------------------"
,
error
);
console
.
log
(
"bizoptCtl/closeBizopt 关闭需求出错------------------"
,
error
);
return
system
.
getResultError
(
"bizoptCtl/closeBizopt 关闭需求出错!"
);
return
system
.
getResultError
(
"bizoptCtl/closeBizopt 关闭需求出错!"
);
}
}
}
}
async
testCloseProposal
(
obj
){
async
testCloseProposal
(
obj
)
{
console
.
log
(
"testCloseProposal-------------------"
);
console
.
log
(
"testCloseProposal-------------------"
);
return
{
return
{
"requestId"
:
"d51aa427-738f-4bed-b48d-282da0a74432"
,
"requestId"
:
"d51aa427-738f-4bed-b48d-282da0a74432"
,
"status"
:
1
,
"status"
:
1
,
"success"
:
true
,
"success"
:
true
,
"errorCode"
:
0
,
"errorCode"
:
0
,
"errorMsg"
:
"ok"
,
"errorMsg"
:
"ok"
,
...
@@ -177,8 +177,8 @@ class BizOptCtl extends CtlBase {
...
@@ -177,8 +177,8 @@ class BizOptCtl extends CtlBase {
}
}
buildObj
(
pobj
,
schemeRes
)
{
buildObj
(
pobj
,
schemeRes
)
{
//let pushUrl = this.rysUrl + "
leads/proposal/close";
let
pushUrl
=
this
.
rysUrl
+
"/
leads/proposal/close"
;
let
pushUrl
=
this
.
rysUrl
+
"/web/bizchance/bizoptCtl/testCloseProposal"
;
//
let pushUrl = this.rysUrl + "/web/bizchance/bizoptCtl/testCloseProposal";
let
solutionBizId
;
let
solutionBizId
;
if
(
schemeRes
.
solution_bizid
)
{
if
(
schemeRes
.
solution_bizid
)
{
solutionBizId
=
schemeRes
.
solution_bizid
.
replace
(
/_book/g
,
""
);
solutionBizId
=
schemeRes
.
solution_bizid
.
replace
(
/_book/g
,
""
);
...
@@ -248,7 +248,7 @@ class BizOptCtl extends CtlBase {
...
@@ -248,7 +248,7 @@ class BizOptCtl extends CtlBase {
var
followUpinfos
=
await
this
.
operationrecordSve
.
findAllInfo
(
pobj
);
//线索记录
var
followUpinfos
=
await
this
.
operationrecordSve
.
findAllInfo
(
pobj
);
//线索记录
var
rtn
=
{
bizoptInfo
:
bizoptInfo
,
companyInfo
:
companyInfo
,
schemeInfo
:
schemeInfo
,
followUpinfos
:
followUpinfos
};
var
rtn
=
{
bizoptInfo
:
bizoptInfo
,
companyInfo
:
companyInfo
,
schemeInfo
:
schemeInfo
,
followUpinfos
:
followUpinfos
};
console
.
log
(
"获取记录详情页所有信息-------------------"
,
JSON
.
stringify
(
rtn
));
console
.
log
(
"获取记录详情页所有信息-------------------"
,
JSON
.
stringify
(
rtn
));
return
system
.
getResult
(
rtn
);
return
system
.
getResult
(
rtn
);
}
catch
(
error
)
{
}
catch
(
error
)
{
...
@@ -410,7 +410,7 @@ class BizOptCtl extends CtlBase {
...
@@ -410,7 +410,7 @@ class BizOptCtl extends CtlBase {
/*插入数据信息 */
/*插入数据信息 */
async
insertInfo
(
nobj
,
qobj
,
req
)
{
async
insertInfo
(
nobj
,
qobj
,
req
)
{
console
.
log
(
"融易算需求插入参数-------------------------------------------"
,
JSON
.
stringify
(
nobj
));
console
.
log
(
"融易算需求插入参数-------------------------------------------"
,
JSON
.
stringify
(
nobj
));
var
pobj
=
nobj
.
actionBody
;
var
pobj
=
nobj
.
actionBody
;
if
(
pobj
.
intentionBizId
&&
pobj
.
intentionBizId
!=
'undefined'
)
{
if
(
pobj
.
intentionBizId
&&
pobj
.
intentionBizId
!=
'undefined'
)
{
try
{
try
{
...
@@ -434,7 +434,7 @@ class BizOptCtl extends CtlBase {
...
@@ -434,7 +434,7 @@ class BizOptCtl extends CtlBase {
//插入操作
//插入操作
var
buInfo
=
await
this
.
service
.
insertInfo
(
pobj
);
var
buInfo
=
await
this
.
service
.
insertInfo
(
pobj
);
console
.
log
(
"融易算需求插入结果-----------------------------------------"
,
JSON
.
stringify
(
buInfo
));
console
.
log
(
"融易算需求插入结果-----------------------------------------"
,
JSON
.
stringify
(
buInfo
));
if
(
buInfo
)
{
if
(
buInfo
)
{
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
180
);
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
180
);
//日志
//日志
...
@@ -457,7 +457,7 @@ class BizOptCtl extends CtlBase {
...
@@ -457,7 +457,7 @@ class BizOptCtl extends CtlBase {
}
}
}
catch
(
error
)
{
}
catch
(
error
)
{
//异常处理
//异常处理
console
.
log
(
"融易算需求插入异常-------------------------"
,
error
);
console
.
log
(
"融易算需求插入异常-------------------------"
,
error
);
return
system
.
getResultError
(
error
);
return
system
.
getResultError
(
error
);
}
}
}
else
{
}
else
{
...
@@ -469,7 +469,7 @@ class BizOptCtl extends CtlBase {
...
@@ -469,7 +469,7 @@ class BizOptCtl extends CtlBase {
/*根据需求编号更新需求状态*/
/*根据需求编号更新需求状态*/
async
updatepayStatusByDemandCode
(
mobj
,
qobj
,
req
)
{
async
updatepayStatusByDemandCode
(
mobj
,
qobj
,
req
)
{
console
.
log
(
"融易算更新需求状态参数-----------------------"
,
JSON
.
stringify
(
mobj
));
console
.
log
(
"融易算更新需求状态参数-----------------------"
,
JSON
.
stringify
(
mobj
));
var
pobj
=
mobj
.
actionBody
;
var
pobj
=
mobj
.
actionBody
;
if
(
pobj
.
solutionBizId
&&
pobj
.
solutionBizId
!=
'undefined'
)
{
if
(
pobj
.
solutionBizId
&&
pobj
.
solutionBizId
!=
'undefined'
)
{
try
{
try
{
...
@@ -478,7 +478,7 @@ class BizOptCtl extends CtlBase {
...
@@ -478,7 +478,7 @@ class BizOptCtl extends CtlBase {
pobj
.
business_status
=
'isFinished'
;
pobj
.
business_status
=
'isFinished'
;
}
}
var
res
=
await
this
.
service
.
findInfoByDemandCode
(
pobj
);
var
res
=
await
this
.
service
.
findInfoByDemandCode
(
pobj
);
console
.
log
(
"融易算更新需求返回结果-----------------------"
,
JSON
.
stringify
(
res
));
console
.
log
(
"融易算更新需求返回结果-----------------------"
,
JSON
.
stringify
(
res
));
if
(
res
)
{
if
(
res
)
{
Object
.
assign
(
res
.
business_info
,
{
"payStatus"
:
"已支付"
})
Object
.
assign
(
res
.
business_info
,
{
"payStatus"
:
"已支付"
})
await
res
.
update
({
business_info
:
res
.
business_info
})
await
res
.
update
({
business_info
:
res
.
business_info
})
...
@@ -488,7 +488,7 @@ class BizOptCtl extends CtlBase {
...
@@ -488,7 +488,7 @@ class BizOptCtl extends CtlBase {
return
system
.
getResultError
(
"更新需求状态出错"
);
return
system
.
getResultError
(
"更新需求状态出错"
);
}
}
}
catch
(
error
)
{
}
catch
(
error
)
{
console
.
log
(
"融易算更新需求返回error-----------------------"
,
error
);
console
.
log
(
"融易算更新需求返回error-----------------------"
,
error
);
return
system
.
getResultError
(
error
);
return
system
.
getResultError
(
error
);
}
}
}
else
{
}
else
{
...
...
tx-fi-tax/app/base/controller/impl/bizchance/deliverybillCtl.js
View file @
8803fdb1
...
@@ -17,6 +17,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -17,6 +17,7 @@ class DeliverybillCtl extends CtlBase {
this
.
cacheManager
=
system
.
getObject
(
"db.common.cacheManager"
);
this
.
cacheManager
=
system
.
getObject
(
"db.common.cacheManager"
);
this
.
fitaxschemeService
=
system
.
getObject
(
"service.bizchance.fitaxschemeSve"
);
this
.
fitaxschemeService
=
system
.
getObject
(
"service.bizchance.fitaxschemeSve"
);
this
.
bizoptService
=
system
.
getObject
(
"service.bizchance.bizoptSve"
);
this
.
bizoptService
=
system
.
getObject
(
"service.bizchance.bizoptSve"
);
this
.
rysUrl
=
settings
.
rysUrl
();
}
}
/**
/**
...
@@ -77,11 +78,11 @@ class DeliverybillCtl extends CtlBase {
...
@@ -77,11 +78,11 @@ class DeliverybillCtl extends CtlBase {
}
}
}
}
const
rs
=
await
this
.
service
.
updateOrderStatus
(
pobj
);
const
rs
=
await
this
.
service
.
updateOrderStatus
(
pobj
);
console
.
log
(
"updateOrderStatus--------------rs"
,
JSON
.
stringify
(
rs
));
console
.
log
(
"updateOrderStatus--------------rs"
,
JSON
.
stringify
(
rs
));
return
system
.
getResult
(
rs
);
return
system
.
getResult
(
rs
);
}
catch
(
err
)
{
}
catch
(
err
)
{
console
.
log
(
"updateOrderStatus--------------error"
,
err
);
console
.
log
(
"updateOrderStatus--------------error"
,
err
);
console
.
log
(
"updateOrderStatus:err.message--------------error"
,
err
.
message
);
console
.
log
(
"updateOrderStatus:err.message--------------error"
,
err
.
message
);
return
system
.
getResult
(
null
,
err
.
message
)
return
system
.
getResult
(
null
,
err
.
message
)
}
}
}
}
...
@@ -93,7 +94,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -93,7 +94,7 @@ class DeliverybillCtl extends CtlBase {
* @param {*} req
* @param {*} req
*/
*/
async
setupBill
(
pobj
,
qobj
,
req
)
{
async
setupBill
(
pobj
,
qobj
,
req
)
{
console
.
log
(
"deliveryCtl:setupBill:pobj--------------------------------"
+
JSON
.
stringify
(
pobj
));
console
.
log
(
"deliveryCtl:setupBill:pobj--------------------------------"
+
JSON
.
stringify
(
pobj
));
try
{
try
{
if
(
!
pobj
.
deliverId
)
{
if
(
!
pobj
.
deliverId
)
{
throw
new
Error
(
"deliverId 不能为空"
);
throw
new
Error
(
"deliverId 不能为空"
);
...
@@ -102,10 +103,10 @@ class DeliverybillCtl extends CtlBase {
...
@@ -102,10 +103,10 @@ class DeliverybillCtl extends CtlBase {
throw
new
Error
(
"参数不能为空"
);
throw
new
Error
(
"参数不能为空"
);
}
}
const
rs
=
await
this
.
service
.
setupBill
(
pobj
);
const
rs
=
await
this
.
service
.
setupBill
(
pobj
);
console
.
log
(
"deliveryCtl:setupBill:rs--------------------------------"
+
JSON
.
stringify
(
rs
));
console
.
log
(
"deliveryCtl:setupBill:rs--------------------------------"
+
JSON
.
stringify
(
rs
));
return
system
.
getResult
(
rs
);
return
system
.
getResult
(
rs
);
}
catch
(
err
)
{
}
catch
(
err
)
{
console
.
log
(
"deliveryCtl:setupBill:err--------------------------------"
+
err
);
console
.
log
(
"deliveryCtl:setupBill:err--------------------------------"
+
err
);
return
system
.
getResult
(
null
,
err
.
message
)
return
system
.
getResult
(
null
,
err
.
message
)
}
}
}
}
...
@@ -174,7 +175,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -174,7 +175,7 @@ class DeliverybillCtl extends CtlBase {
}
}
}));
}));
}
catch
(
err
)
{
}
catch
(
err
)
{
console
.
log
(
"delivergCtr:getChannelCompany:err-------------------------------------------"
+
err
);
console
.
log
(
"delivergCtr:getChannelCompany:err-------------------------------------------"
+
err
);
return
system
.
getResult
(
null
,
err
.
message
)
return
system
.
getResult
(
null
,
err
.
message
)
}
}
}
}
...
@@ -199,7 +200,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -199,7 +200,7 @@ class DeliverybillCtl extends CtlBase {
obj
.
delivery_code
=
pobj
.
orderId
+
"_book"
;
obj
.
delivery_code
=
pobj
.
orderId
+
"_book"
;
obj
.
source_number
=
"tx"
;
obj
.
source_number
=
"tx"
;
if
(
pobj
.
solutionBizId
)
{
if
(
pobj
.
solutionBizId
)
{
obj
.
scheme_number
=
pobj
.
solutionBizId
+
"_book"
;
obj
.
scheme_number
=
pobj
.
solutionBizId
+
"_book"
;
var
scheme
=
await
this
.
fitaxschemeService
.
findInfoByBizid
({
"bizId"
:
pobj
.
solutionBizId
});
var
scheme
=
await
this
.
fitaxschemeService
.
findInfoByBizid
({
"bizId"
:
pobj
.
solutionBizId
});
if
(
scheme
)
{
if
(
scheme
)
{
obj
.
demand_code
=
scheme
.
demand_code
;
obj
.
demand_code
=
scheme
.
demand_code
;
...
@@ -260,7 +261,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -260,7 +261,7 @@ class DeliverybillCtl extends CtlBase {
//更新融易算服务实例
//更新融易算服务实例
async
updateServer
(
mobj
,
qobj
,
req
)
{
async
updateServer
(
mobj
,
qobj
,
req
)
{
console
.
log
(
"更新融易算服务实例参数--------------------------"
,
JSON
.
stringify
(
mobj
));
console
.
log
(
"更新融易算服务实例参数--------------------------"
,
JSON
.
stringify
(
mobj
));
try
{
try
{
var
pobj
=
mobj
.
actionBody
;
var
pobj
=
mobj
.
actionBody
;
var
cachestr
=
sha235
(
JSON
.
stringify
(
pobj
));
var
cachestr
=
sha235
(
JSON
.
stringify
(
pobj
));
...
@@ -298,7 +299,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -298,7 +299,7 @@ class DeliverybillCtl extends CtlBase {
"biz_id"
:
pobj
.
bizId
"biz_id"
:
pobj
.
bizId
};
};
const
rs
=
await
this
.
service
.
updateServer
(
obj
);
const
rs
=
await
this
.
service
.
updateServer
(
obj
);
console
.
log
(
"更新融易算服务返回结果--------------------------"
,
JSON
.
stringify
(
rs
));
console
.
log
(
"更新融易算服务返回结果--------------------------"
,
JSON
.
stringify
(
rs
));
if
(
rs
)
{
if
(
rs
)
{
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
180
);
//插入redis缓存
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
180
);
//插入redis缓存
return
{
return
{
...
@@ -314,7 +315,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -314,7 +315,7 @@ class DeliverybillCtl extends CtlBase {
}
}
}
}
catch
(
err
)
{
catch
(
err
)
{
console
.
log
(
"更新融易算服务返回错误结果--------------------------"
,
error
);
console
.
log
(
"更新融易算服务返回错误结果--------------------------"
,
error
);
return
system
.
getResult
(
null
,
err
.
message
)
return
system
.
getResult
(
null
,
err
.
message
)
}
}
}
}
...
@@ -337,7 +338,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -337,7 +338,7 @@ class DeliverybillCtl extends CtlBase {
//服务状态变更通知
//服务状态变更通知
async
notifyServiceStatusChange
(
pobj
,
qobj
,
req
)
{
async
notifyServiceStatusChange
(
pobj
,
qobj
,
req
)
{
console
.
log
(
"融易算服务状态变更通知参数--------------------------"
,
JSON
.
stringify
(
pobj
));
console
.
log
(
"融易算服务状态变更通知参数--------------------------"
,
JSON
.
stringify
(
pobj
));
let
ab
=
pobj
.
actionBody
;
let
ab
=
pobj
.
actionBody
;
if
(
!
ab
.
requestId
||
ab
.
requestId
==
"undefined"
)
{
if
(
!
ab
.
requestId
||
ab
.
requestId
==
"undefined"
)
{
return
system
.
getResultFail
(
-
1
,
"请求id不能为空"
);
return
system
.
getResultFail
(
-
1
,
"请求id不能为空"
);
...
@@ -363,7 +364,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -363,7 +364,7 @@ class DeliverybillCtl extends CtlBase {
// 变更服务状态
// 变更服务状态
let
whereObj
=
{
biz_id
:
ab
.
bizId
};
let
whereObj
=
{
biz_id
:
ab
.
bizId
};
let
rtn
=
await
this
.
service
.
findOne
(
whereObj
);
let
rtn
=
await
this
.
service
.
findOne
(
whereObj
);
console
.
log
(
"融易算服务状态变更通知返回结果--------------------------"
,
JSON
.
stringify
(
rtn
));
console
.
log
(
"融易算服务状态变更通知返回结果--------------------------"
,
JSON
.
stringify
(
rtn
));
if
(
!
rtn
)
{
if
(
!
rtn
)
{
return
system
.
getResultFail
(
-
1
,
"未知服务信息"
);
return
system
.
getResultFail
(
-
1
,
"未知服务信息"
);
}
}
...
@@ -388,14 +389,14 @@ class DeliverybillCtl extends CtlBase {
...
@@ -388,14 +389,14 @@ class DeliverybillCtl extends CtlBase {
}
}
}
}
catch
(
err
)
{
catch
(
err
)
{
console
.
log
(
"融易算服务状态变更通知返回错误结果--------------------------"
,
error
);
console
.
log
(
"融易算服务状态变更通知返回错误结果--------------------------"
,
error
);
return
system
.
getResultError
(
err
);
return
system
.
getResultError
(
err
);
}
}
}
}
//接收票据快递单号
//接收票据快递单号
async
receivePaperPost
(
pobj
,
qobj
,
req
)
{
async
receivePaperPost
(
pobj
,
qobj
,
req
)
{
console
.
log
(
"融易算接收票据快递单号参数--------------------------"
,
JSON
.
stringify
(
pobj
));
console
.
log
(
"融易算接收票据快递单号参数--------------------------"
,
JSON
.
stringify
(
pobj
));
var
deliverInfo
=
await
this
.
service
.
getInfo
({
"bizId"
:
pobj
.
bizNo
});
var
deliverInfo
=
await
this
.
service
.
getInfo
({
"bizId"
:
pobj
.
bizNo
});
if
(
deliverInfo
)
{
if
(
deliverInfo
)
{
var
param
=
{
var
param
=
{
...
@@ -411,7 +412,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -411,7 +412,7 @@ class DeliverybillCtl extends CtlBase {
var
reqUrl
=
settings
.
ftConfig
.
url
+
"/customerReceiveBill/addCusReceiveBill"
;
var
reqUrl
=
settings
.
ftConfig
.
url
+
"/customerReceiveBill/addCusReceiveBill"
;
var
result
=
await
rc
.
execPost
(
param
,
reqUrl
);
var
result
=
await
rc
.
execPost
(
param
,
reqUrl
);
var
j
=
JSON
.
parse
(
result
.
stdout
);
var
j
=
JSON
.
parse
(
result
.
stdout
);
console
.
log
(
"融易算接收票据快递单号返回结果--------------------------"
,
JSON
.
stringify
(
j
));
console
.
log
(
"融易算接收票据快递单号返回结果--------------------------"
,
JSON
.
stringify
(
j
));
if
(
j
.
status
==
1
)
{
if
(
j
.
status
==
1
)
{
return
system
.
getResult
(
result
);
return
system
.
getResult
(
result
);
}
}
...
@@ -430,11 +431,11 @@ class DeliverybillCtl extends CtlBase {
...
@@ -430,11 +431,11 @@ class DeliverybillCtl extends CtlBase {
}
}
async
testPaperPostConfirm
(
obj
){
async
testPaperPostConfirm
(
obj
)
{
console
.
log
(
"testCloseProposal-------------------"
);
console
.
log
(
"testCloseProposal-------------------"
);
return
{
return
{
"requestId"
:
"d51aa427-738f-4bed-b48d-282da0a74432"
,
"requestId"
:
"d51aa427-738f-4bed-b48d-282da0a74432"
,
"status"
:
1
,
"status"
:
1
,
"success"
:
true
,
"success"
:
true
,
"errorCode"
:
0
,
"errorCode"
:
0
,
"errorMsg"
:
"ok"
,
"errorMsg"
:
"ok"
,
...
@@ -445,7 +446,7 @@ class DeliverybillCtl extends CtlBase {
...
@@ -445,7 +446,7 @@ class DeliverybillCtl extends CtlBase {
//票据快递情况反馈
//票据快递情况反馈
async
confirmPaperPost
(
pobj
,
qobj
,
req
)
{
async
confirmPaperPost
(
pobj
,
qobj
,
req
)
{
console
.
log
(
"融易算接收票据快递情况反馈参数--------------------------"
,
JSON
.
stringify
(
pobj
));
console
.
log
(
"融易算接收票据快递情况反馈参数--------------------------"
,
JSON
.
stringify
(
pobj
));
var
deliverInfo
=
await
this
.
service
.
findByClientId
({
"vftClientId"
:
pobj
.
customer_id
});
var
deliverInfo
=
await
this
.
service
.
findByClientId
({
"vftClientId"
:
pobj
.
customer_id
});
if
(
deliverInfo
)
{
if
(
deliverInfo
)
{
var
param
=
{
var
param
=
{
...
@@ -461,8 +462,8 @@ class DeliverybillCtl extends CtlBase {
...
@@ -461,8 +462,8 @@ class DeliverybillCtl extends CtlBase {
}
}
}
}
var
pushObj
=
{
var
pushObj
=
{
//"pushUrl": this.rysUrl + "
service/paperPost/confirm",
"pushUrl"
:
this
.
rysUrl
+
"/
service/paperPost/confirm"
,
"pushUrl"
:
this
.
rysUrl
+
"/web/bizchance/deliverybillCtl/testPaperPostConfirm"
,
//
"pushUrl": this.rysUrl + "/web/bizchance/deliverybillCtl/testPaperPostConfirm",
"actionType"
:
"confirm"
,
"actionType"
:
"confirm"
,
"messageBody"
:
param
,
"messageBody"
:
param
,
"headData"
:
{
"headData"
:
{
...
@@ -480,11 +481,11 @@ class DeliverybillCtl extends CtlBase {
...
@@ -480,11 +481,11 @@ class DeliverybillCtl extends CtlBase {
}
}
}
}
async
testfeedback
(
obj
){
async
testfeedback
(
obj
)
{
console
.
log
(
"testfeedback-------------------"
);
console
.
log
(
"testfeedback-------------------"
);
return
{
return
{
"requestId"
:
"d51aa427-738f-4bed-b48d-282da0a74432"
,
"requestId"
:
"d51aa427-738f-4bed-b48d-282da0a74432"
,
"status"
:
1
,
"status"
:
1
,
"success"
:
true
,
"success"
:
true
,
"errorCode"
:
0
,
"errorCode"
:
0
,
"errorMsg"
:
"ok"
,
"errorMsg"
:
"ok"
,
...
...
tx-fi-tax/app/base/controller/impl/bizchance/fitaxschemeCtl.js
View file @
8803fdb1
...
@@ -26,7 +26,7 @@ class FitaxschemeCtl extends CtlBase {
...
@@ -26,7 +26,7 @@ class FitaxschemeCtl extends CtlBase {
//构造参数
//构造参数
let
pushObj
=
this
.
buildObj
(
pobj
);
let
pushObj
=
this
.
buildObj
(
pobj
);
system
.
queueOper
(
pushObj
);
system
.
queueOper
(
pushObj
);
console
.
log
(
"fitasschemeCtl:insertInfo:queueOper--------------------新建方案成功"
);
console
.
log
(
"fitasschemeCtl:insertInfo:queueOper--------------------新建方案成功"
);
return
system
.
getResult
(
"新建方案成功!"
);
return
system
.
getResult
(
"新建方案成功!"
);
}
catch
(
error
)
{
}
catch
(
error
)
{
console
.
log
(
"fitaxschemeCtl/insertInfo---------------------------------------------------------------- "
+
error
);
console
.
log
(
"fitaxschemeCtl/insertInfo---------------------------------------------------------------- "
+
error
);
...
@@ -40,7 +40,7 @@ class FitaxschemeCtl extends CtlBase {
...
@@ -40,7 +40,7 @@ class FitaxschemeCtl extends CtlBase {
* @param {*} req
* @param {*} req
*/
*/
async
updateInfo
(
pobj
,
qobj
,
req
)
{
async
updateInfo
(
pobj
,
qobj
,
req
)
{
console
.
log
(
"fitaxscjemeCtl:updateInfo:pobj--------------------"
,
JSON
.
stringify
(
pobj
));
console
.
log
(
"fitaxscjemeCtl:updateInfo:pobj--------------------"
,
JSON
.
stringify
(
pobj
));
let
obj
=
{};
let
obj
=
{};
if
(
pobj
.
actionBody
.
messageBody
.
IntentionBizId
)
{
//需求编号
if
(
pobj
.
actionBody
.
messageBody
.
IntentionBizId
)
{
//需求编号
obj
.
demand_code
=
pobj
.
actionBody
.
messageBody
.
IntentionBizId
+
"_book"
;
obj
.
demand_code
=
pobj
.
actionBody
.
messageBody
.
IntentionBizId
+
"_book"
;
...
@@ -78,11 +78,11 @@ class FitaxschemeCtl extends CtlBase {
...
@@ -78,11 +78,11 @@ class FitaxschemeCtl extends CtlBase {
}
}
}
}
async
testCreateProposal
(
pobj
){
async
testCreateProposal
(
pobj
)
{
console
.
log
(
"testCreateProposal-------------------"
);
console
.
log
(
"testCreateProposal-------------------"
);
return
{
return
{
"requestId"
:
"d51aa427-738f-4bed-b48d-282da0a74432"
,
"requestId"
:
"d51aa427-738f-4bed-b48d-282da0a74432"
,
"status"
:
1
,
"status"
:
1
,
"success"
:
true
,
"success"
:
true
,
"errorCode"
:
0
,
"errorCode"
:
0
,
"errorMsg"
:
"ok"
,
"errorMsg"
:
"ok"
,
...
@@ -94,8 +94,8 @@ class FitaxschemeCtl extends CtlBase {
...
@@ -94,8 +94,8 @@ class FitaxschemeCtl extends CtlBase {
}
}
buildObj
(
pobj
)
{
buildObj
(
pobj
)
{
//let pushUrl = this.rysUrl + "
leads/proposal/create";
let
pushUrl
=
this
.
rysUrl
+
"/
leads/proposal/create"
;
let
pushUrl
=
this
.
rysUrl
+
"/web/bizchance/fitaxschemeCtl/testCreateProposal"
;
//
let pushUrl = this.rysUrl + "/web/bizchance/fitaxschemeCtl/testCreateProposal";
let
notifyUrl
=
this
.
bookUrl
+
"/web/bizchance/fitaxschemeCtl/updateInfo"
;
let
notifyUrl
=
this
.
bookUrl
+
"/web/bizchance/fitaxschemeCtl/updateInfo"
;
let
companyType
,
sreaCode
,
quantity
,
taxQualify
;
let
companyType
,
sreaCode
,
quantity
,
taxQualify
;
if
(
pobj
.
company_type
)
{
//公司类型
if
(
pobj
.
company_type
)
{
//公司类型
...
...
tx-fi-tax/app/base/utils/toFtClient.js
View file @
8803fdb1
...
@@ -141,8 +141,8 @@ const feedbackToRys = async (data) => {
...
@@ -141,8 +141,8 @@ const feedbackToRys = async (data) => {
}
}
}
}
let
resData
=
await
system
.
queueOper
({
let
resData
=
await
system
.
queueOper
({
//pushUrl: this.rysUrl + "
service/feedback",
pushUrl
:
settings
.
rysUrl
()
+
"/
service/feedback"
,
pushUrl
:
settings
.
rysUrl
()
+
"/web/bizchance/deliverybillCtl/testfeedback"
,
//
pushUrl: settings.rysUrl() + "/web/bizchance/deliverybillCtl/testfeedback",
actionType
:
"feedback"
,
actionType
:
"feedback"
,
messageBody
:
reqData
,
messageBody
:
reqData
,
headData
:
{
headData
:
{
...
...
tx-fi-tax/app/config/routes/api.js
View file @
8803fdb1
...
@@ -61,13 +61,13 @@ module.exports = function (app) {
...
@@ -61,13 +61,13 @@ module.exports = function (app) {
console
.
log
(
JSON
.
stringify
(
req
.
body
));
console
.
log
(
JSON
.
stringify
(
req
.
body
));
await
deliverService
.
fromFtToRys
(
JSON
.
parse
(
req
.
body
.
info
));
await
deliverService
.
fromFtToRys
(
JSON
.
parse
(
req
.
body
.
info
));
res
.
json
({
res
.
json
({
status
:
0
,
code
:
1
,
msg
:
"SUCCESS"
,
msg
:
"SUCCESS"
,
data
:
"SUCCESS"
,
data
:
"SUCCESS"
,
});
});
}
catch
(
err
)
{
}
catch
(
err
)
{
res
.
json
({
res
.
json
({
status
:
-
1
,
status
:
0
,
msg
:
err
.
message
,
msg
:
err
.
message
,
data
:
null
,
data
:
null
,
});
});
...
...
tx-fi-tax/app/config/settings.js
View file @
8803fdb1
...
@@ -63,7 +63,7 @@ var settings = {
...
@@ -63,7 +63,7 @@ var settings = {
if
(
this
.
env
==
"localhost"
)
{
if
(
this
.
env
==
"localhost"
)
{
return
"http://192.168.1.6:8889"
;
return
"http://192.168.1.6:8889"
;
}
else
{
}
else
{
return
"http://
bookdeliver-service
"
;
return
"http://
abk.tencentyun.com
"
;
}
}
},
},
bookUrl
:
function
()
{
bookUrl
:
function
()
{
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment