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
67c0f229
Commit
67c0f229
authored
Aug 03, 2020
by
王勇飞
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
pp
parent
635bd810
Hide whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
74 additions
and
80 deletions
+74
-80
center-manage/app/base/service/impl/auth/userSve.js
+1
-1
center-manage/app/base/service/impl/common/channelhandlers/aliCloud.js
+69
-75
center-manage/app/base/service/impl/common/channelhandlers/tencentCloud.js
+4
-4
No files found.
center-manage/app/base/service/impl/auth/userSve.js
View file @
67c0f229
...
...
@@ -725,7 +725,7 @@ module.exports = UserService;
// async function start() {
// try {
// // let result = await cacheManager["LoopDistributionUserCache"].cache("wyf", JSON.stringify({name: "test2", idx: 2}));
// let result = await cacheManager["
LoopDistributionUserCache"].getCache("LoopDistributionUserCache
");
// let result = await cacheManager["
AliCache"].getCache("8a6ce4069a8f104c70405fd1ae5be5023f62d065
");
// // let result = await cacheManager["LoopDistributionUserCache"].invalidate("LoopDistributionUserCache");
// console.log('----=-=-=-:' + JSON.stringify(result));
...
...
center-manage/app/base/service/impl/common/channelhandlers/aliCloud.js
View file @
67c0f229
...
...
@@ -64,7 +64,7 @@ class AliHandler {
var
j
=
JSON
.
parse
(
rtn
.
stdout
);
console
.
log
(
JSON
.
stringify
(
j
),
"RRRRRRRRRRRRRRR"
);
if
(
j
.
status
==
1
)
{
await
this
.
cacheManager
[
"AliCache"
].
cache
(
cachestr
,
null
,
60
0000
);
//插入redis缓存
await
this
.
cacheManager
[
"AliCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
18
0000
);
//插入redis缓存
//给业务员发信息
var
msg
=
{
"title"
:
"你有新的商机,请尽快处理"
,
...
...
@@ -123,7 +123,7 @@ class AliHandler {
var
rtn
=
await
rc
.
execPost3
(
params
,
requrl
);
var
j
=
JSON
.
parse
(
rtn
.
stdout
);
if
(
j
.
status
==
0
)
{
await
this
.
cacheManager
[
"AliCache"
].
cache
(
cachestr
,
null
,
60
0000
);
//插入缓存
await
this
.
cacheManager
[
"AliCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
18
0000
);
//插入缓存
//给业务员发信息
var
selUrl
=
this
.
icUrl
+
"/schemeCtl/findInfoByDemandCode"
;
...
...
@@ -179,16 +179,10 @@ class AliHandler {
console
.
log
(
"put in queue-----------------------------------------------------------------------------------------------------"
,
datajson
);
try
{
console
.
log
(
"交付单数据:"
+
JSON
.
stringify
(
datajson
));
// return {
// "status": 1, //1代表成功,否则失败
// "msg": "已处理成功!",
// "data": "",
// "requestId": ""
// }
var
cachestr
=
sha235
(
JSON
.
stringify
(
datajson
));
var
cacheInfo
=
await
this
.
cacheManager
[
"AliCache"
].
getCache
(
cachestr
);
if
(
cacheInfo
&&
cacheInfo
!=
'undefined'
)
{
console
.
log
(
"pushOrderDelivery 已缓存:"
+
cachestr
+
", 缓存内容: "
+
JSON
.
stringify
(
cacheInfo
));
return
{
"status"
:
1
,
//1代表成功,否则失败
"msg"
:
"已处理成功!"
,
...
...
@@ -196,75 +190,75 @@ class AliHandler {
"requestId"
:
""
}
}
else
{
var
rc
=
system
.
getObject
(
"util.execClient"
);
var
requrl
=
this
.
icUrl
+
"/deliverybillCtl/findInfoByDeliverCode"
;
var
delInfo
=
await
rc
.
execPost3
({
"d"
:
{
"deliverNumber"
:
datajson
.
actionBody
.
orderNo
}
},
requrl
);
console
.
log
(
"jdelInfo---------------------------------------------"
+
delInfo
.
stdout
);
var
jdelInfo
=
JSON
.
parse
(
delInfo
.
stdout
);
if
(
jdelInfo
.
status
==
0
)
{
return
{
"status"
:
1
,
//1代表成功,否则失败
"msg"
:
"数据已存在"
,
"data"
:
""
,
"requestId"
:
""
}
}
else
{
let
obj
=
await
this
.
actionBodyHandler
(
datajson
.
actionBody
);
//渠道名称和渠道编码
// else {
// var rc = system.getObject("util.execClient");
// var requrl = this.icUrl + "/deliverybillCtl/findInfoByDeliverCode";
// var delInfo = await rc.execPost3({ "d": { "deliverNumber": datajson.actionBody.orderNo } }, requrl);
// console.log("jdelInfo---------------------------------------------" + delInfo.stdout);
// var jdelInfo = JSON.parse(delInfo.stdout);
// if (jdelInfo.status == 0) {
// return {
// "status": 1, //1代表成功,否则失败
// "msg": "数据已存在",
// "data": "",
// "requestId": ""
// }
// }
// else {}
// }
let
rc
=
system
.
getObject
(
"util.execClient"
);
let
obj
=
await
this
.
actionBodyHandler
(
datajson
.
actionBody
);
//渠道名称和渠道编码
obj
.
channelSource
=
channelobj
.
name
;
obj
.
channelNumber
=
channelobj
.
code
;
//分配业务员
if
(
datajson
.
actionBody
.
needsolution
.
salesmanInfo
.
salesmanChannelId
)
{
//去数据库查询该业务员信息
try
{
let
resInfo
=
await
this
.
userService
.
getSalesmanInfo
(
datajson
.
actionBody
.
needsolution
.
salesmanInfo
.
salesmanChannelId
);
obj
.
salesmanOpcode
=
resInfo
.
opath
;
obj
.
salesmanName
=
resInfo
.
nickName
;
obj
.
servicerCode
=
resInfo
.
company_id
;
}
catch
(
error
)
{
console
.
log
(
"salesmanChannelId: "
+
datajson
.
actionBody
.
needsolution
.
salesmanInfo
.
salesmanChannelId
+
"获取业务员opcode失败:"
+
error
)
}
}
obj
.
channelSource
=
channelobj
.
name
;
obj
.
channelNumber
=
channelobj
.
code
;
//分配业务员
if
(
datajson
.
actionBody
.
needsolution
.
salesmanInfo
.
salesmanChannelId
)
{
//去数据库查询该业务员信息
try
{
let
resInfo
=
await
this
.
userService
.
getSalesmanInfo
(
datajson
.
actionBody
.
needsolution
.
salesmanInfo
.
salesmanChannelId
);
obj
.
salesmanOpcode
=
resInfo
.
opath
;
obj
.
salesmanName
=
resInfo
.
nickName
;
obj
.
servicerCode
=
resInfo
.
company_id
;
}
catch
(
error
)
{
console
.
log
(
"salesmanChannelId: "
+
datajson
.
actionBody
.
needsolution
.
salesmanInfo
.
salesmanChannelId
+
"获取业务员opcode失败:"
+
error
)
}
}
//分配交付员
var
ConsultTypeName
=
""
;
if
(
obj
.
businessName
&&
obj
.
businessName
!=
'undefined'
)
{
console
.
log
(
"productTypeName-----------------------------"
+
obj
.
businessName
);
ConsultTypeName
=
obj
.
businessName
;
}
try
{
var
deliveryInfo
=
await
this
.
userService
.
getBizUserForAliDelivery
(
obj
.
baseInfo
.
contactsName
,
obj
.
servicerName
,
ConsultTypeName
,
obj
.
skuCode
,
obj
.
serviceName
);
}
catch
(
error
)
{
console
.
log
(
"分配交付元失败."
);
}
//分配交付员
var
ConsultTypeName
=
""
;
if
(
obj
.
businessName
&&
obj
.
businessName
!=
'undefined'
)
{
console
.
log
(
"productTypeName-----------------------------"
+
obj
.
businessName
);
ConsultTypeName
=
obj
.
businessName
;
}
try
{
var
deliveryInfo
=
await
this
.
userService
.
getBizUserForAliDelivery
(
obj
.
baseInfo
.
contactsName
,
obj
.
servicerName
,
ConsultTypeName
,
obj
.
skuCode
,
obj
.
serviceName
);
}
catch
(
error
)
{
console
.
log
(
"分配交付元失败."
);
}
requrl
=
this
.
icUrl
+
"/deliverybillCtl/dealAliDeliveryInfo"
;
// var bizurl = this.icUrl + "/bizoptCtl/updateStatusByDemandCode";
let
requrl
=
this
.
icUrl
+
"/deliverybillCtl/dealAliDeliveryInfo"
;
// var bizurl = this.icUrl + "/bizoptCtl/updateStatusByDemandCode";
if
(
deliveryInfo
&&
deliveryInfo
!=
'undefined'
)
{
obj
.
clerkOpcode
=
deliveryInfo
.
opath
;
//交付员opcode
obj
.
clerkId
=
deliveryInfo
.
userId
;
//交付员id
obj
.
costPrice
=
deliveryInfo
.
cost
;
//成本
obj
.
clerkName
=
deliveryInfo
.
userName
;
//交付员名称
// obj.clerkPhone = deliveryInfo.mobile;//交付人员电话
// obj.servicerCode = deliveryInfo.compId;
}
if
(
deliveryInfo
&&
deliveryInfo
!=
'undefined'
)
{
obj
.
clerkOpcode
=
deliveryInfo
.
opath
;
//交付员opcode
obj
.
clerkId
=
deliveryInfo
.
userId
;
//交付员id
obj
.
costPrice
=
deliveryInfo
.
cost
;
//成本
obj
.
clerkName
=
deliveryInfo
.
userName
;
//交付员名称
// obj.clerkPhone = deliveryInfo.mobile;//交付人员电话
// obj.servicerCode = deliveryInfo.compId;
}
console
.
log
(
"推送数据oj: "
+
JSON
.
stringify
(
obj
));
var
rtn
=
await
rc
.
execPost3
({
"d"
:
obj
},
requrl
);
console
.
log
(
"pushOrderDelivery插入数据成功---------------------------------"
+
rtn
.
stdout
);
let
cacheDeliveryInfo
=
await
this
.
cacheManager
[
"AliCache"
].
cache
(
cachestr
,
null
,
1200000
);
console
.
log
(
"交付单缓存信息: "
+
JSON
.
stringify
(
cacheDeliveryInfo
));
return
{
"status"
:
1
,
//1代表成功,否则失败
"msg"
:
""
,
"data"
:
""
,
"requestId"
:
""
}
}
console
.
log
(
"推送数据oj: "
+
JSON
.
stringify
(
obj
));
var
rtn
=
await
rc
.
execPost3
({
"d"
:
obj
},
requrl
);
console
.
log
(
"pushOrderDelivery插入数据成功---------------------------------"
+
rtn
.
stdout
);
let
cacheDeliveryInfo
=
await
this
.
cacheManager
[
"AliCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
180
);
console
.
log
(
"交付单缓存信息: "
+
JSON
.
stringify
(
cacheDeliveryInfo
));
return
{
"status"
:
1
,
//1代表成功,否则失败
"msg"
:
""
,
"data"
:
""
,
"requestId"
:
""
}
}
catch
(
error
)
{
...
...
@@ -310,7 +304,7 @@ class AliHandler {
var
rtn
=
await
rc
.
execPost3
(
params
,
requrl
);
var
j
=
JSON
.
parse
(
rtn
.
stdout
);
if
(
j
.
status
==
0
)
{
await
this
.
cacheManager
[
"AliCache"
].
cache
(
cachestr
,
null
,
60000
0
);
//插入缓存
await
this
.
cacheManager
[
"AliCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
18
0
);
//插入缓存
//给业务员发信息
var
selUrl
=
this
.
icUrl
+
"/deliverybillCtl/findInfoByDeliverCode"
;
var
selpar
=
{
...
...
@@ -444,7 +438,7 @@ class AliHandler {
obj
.
baseInfo
.
contactsPhone
=
data
.
needsolution
.
customerInfo
.
publishMobile
;
}
if
(
data
.
needsolution
.
customerRemark
)
{
//备注信息
obj
.
baseInfo
.
memo
i
nfo
=
data
.
needsolution
.
customerRemark
;
obj
.
baseInfo
.
memo
I
nfo
=
data
.
needsolution
.
customerRemark
;
}
}
if
(
data
.
needsolution
.
customerMaterial
)
{
//客户上传所有材料
...
...
center-manage/app/base/service/impl/common/channelhandlers/tencentCloud.js
View file @
67c0f229
...
...
@@ -67,7 +67,7 @@ class TxHandler {
var
j
=
JSON
.
parse
(
rtn
.
stdout
);
console
.
log
(
JSON
.
stringify
(
j
),
"RRRRRRRRRRRRRRR"
);
if
(
j
.
status
==
1
)
{
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
null
,
120000
0
);
//插入redis缓存
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
18
0
);
//插入redis缓存
//给业务员发信息
var
msg
=
{
"title"
:
"你有新的商机,请尽快处理"
,
...
...
@@ -126,7 +126,7 @@ class TxHandler {
var
rtn
=
await
rc
.
execPost3
(
params
,
requrl
);
var
j
=
JSON
.
parse
(
rtn
.
stdout
);
if
(
j
.
status
==
0
)
{
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
null
,
120000
0
);
//插入缓存
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
18
0
);
//插入缓存
//给业务员发信息
var
selUrl
=
this
.
icUrl
+
"/schemeCtl/findInfoByDemandCode"
;
...
...
@@ -406,7 +406,7 @@ class TxHandler {
var
j1
=
JSON
.
parse
(
rtn
.
stdout
);
console
.
log
(
"j1---------------------------------"
+
rtn
.
stdout
);
if
(
j
.
status
==
0
&&
j1
.
status
==
0
)
{
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
null
,
120000
0
);
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
18
0
);
//给业务员发信息
var
msg
=
{
"title"
:
"你有新的交付单,请尽快处理"
,
...
...
@@ -471,7 +471,7 @@ class TxHandler {
var
rtn
=
await
rc
.
execPost3
(
params
,
requrl
);
var
j
=
JSON
.
parse
(
rtn
.
stdout
);
if
(
j
.
status
==
0
)
{
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
null
,
120000
0
);
//插入缓存
await
this
.
cacheManager
[
"TxCache"
].
cache
(
cachestr
,
JSON
.
stringify
({
cachestr
:
cachestr
}),
18
0
);
//插入缓存
//给业务员发信息
var
selUrl
=
this
.
icUrl
+
"/deliverybillCtl/findInfoByDeliverCode"
;
...
...
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