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
983babc4
Commit
983babc4
authored
Aug 20, 2020
by
王勇飞
Browse files
Options
Browse Files
Download
Plain Diff
pp
parents
418b3029
0b0b8162
Show whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
81 additions
and
108 deletions
+81
-108
tx-fi-tax/app/base/controller/impl/bizchance/bizoptCtl.js
+54
-65
tx-fi-tax/app/base/db/impl/bizchance/bizoptDao.js
+27
-43
No files found.
tx-fi-tax/app/base/controller/impl/bizchance/bizoptCtl.js
View file @
983babc4
...
...
@@ -9,9 +9,9 @@ class BizOptCtl extends CtlBase {
constructor
()
{
super
(
"bizchance"
,
CtlBase
.
getServiceName
(
BizOptCtl
));
this
.
schemeService
=
system
.
getObject
(
"service.bizchance.schemeSve"
);
this
.
schemeSve
=
system
.
getObject
(
"service.bizchance.fitaxschemeSve"
);
//财税-方案信息
this
.
fitaxcompanySve
=
system
.
getObject
(
"service.bizchance.fitaxcompanySve"
);
//财税-企业信息
this
.
operationrecordSve
=
system
.
getObject
(
"service.bizchance.operationrecordSve"
);
//财税-需求分配记录
this
.
schemeSve
=
system
.
getObject
(
"service.bizchance.fitaxschemeSve"
);
//财税-方案信息
this
.
fitaxcompanySve
=
system
.
getObject
(
"service.bizchance.fitaxcompanySve"
);
//财税-企业信息
this
.
operationrecordSve
=
system
.
getObject
(
"service.bizchance.operationrecordSve"
);
//财税-需求分配记录
this
.
logService
=
system
.
getObject
(
"service.bizchance.statuslogSve"
);
this
.
shisService
=
system
.
getObject
(
"service.bizchance.salesmanhisSve"
);
this
.
receiveUrl
=
settings
.
receiveUrl
();
...
...
@@ -40,22 +40,21 @@ class BizOptCtl extends CtlBase {
let
results
=
rs
.
results
.
rows
;
results
.
forEach
(
element
=>
{
let
robj
=
{};
robj
.
id
=
element
.
id
;
//数据的id
robj
.
demand_code
=
element
.
demand_code
;
//商机编号
robj
.
v_cophone
=
system
.
decryptStr
(
element
.
v_cophone
);
//联系电话-shousuo
robj
.
business_status
=
element
.
business_status
;
//商机当前状态
robj
.
id
=
element
.
id
;
//数据的id
robj
.
demand_code
=
element
.
demand_code
;
//商机编号
robj
.
v_cophone
=
system
.
decryptStr
(
element
.
v_cophone
);
//联系电话-shousuo
robj
.
business_status
=
element
.
business_status
;
//商机当前状态
if
(
element
.
business_info
.
serviceName
&&
element
.
business_info
.
serviceName
!=
'undefined'
)
{
robj
.
address
=
element
.
business_info
.
serviceName
;
//服务地区
}
else
{
robj
.
address
=
element
.
business_info
.
serviceName
;
//服务地区
}
else
{
robj
.
address
=
""
;
}
// robj.updated_at = this.timeFormat(element.updated_at);//商机当前状态日期
robj
.
updated_at
=
element
.
updated_at
;
//商机当前状态日期
robj
.
business_type
=
element
.
business_type
;
//商机类型
robj
.
v_coname
=
element
.
v_coname
;
//联系人-shousuo
robj
.
source_name
=
element
.
source_name
;
//渠道来源--前端服务
robj
.
servicerName
=
element
.
facilitator_name
;
//服务商名称
robj
.
updated_at
=
element
.
updated_at
;
//商机当前状态日期
robj
.
business_type
=
element
.
business_type
;
//商机类型
robj
.
v_coname
=
element
.
v_coname
;
//联系人-shousuo
robj
.
source_name
=
element
.
source_name
;
//渠道来源--前端服务
robj
.
servicerName
=
element
.
facilitator_name
;
//服务商名称
// robj.facilitator_name = element.facilitator_name;//服务商名称
// robj.sourceName = element.source_name;//渠道来源
...
...
@@ -154,10 +153,10 @@ class BizOptCtl extends CtlBase {
var
pobj
=
mobj
.
d
;
if
(
pobj
.
demand_code
&&
pobj
.
demand_code
!=
'undefined'
)
{
try
{
var
bizoptInfo
=
await
this
.
service
.
findInfoByDemandCode
(
pobj
);
//需求信息
var
companyInfo
=
await
this
.
fitaxcompanySve
.
findInfo
(
pobj
);
//企业信息
var
schemeInfo
=
await
this
.
schemeSve
.
findInfo
(
pobj
);
//方案详情
var
followUpinfos
=
await
this
.
operationrecordSve
.
findAllInfo
(
pobj
);
//线索记录
var
bizoptInfo
=
await
this
.
service
.
findInfoByDemandCode
(
pobj
);
//需求信息
var
companyInfo
=
await
this
.
fitaxcompanySve
.
findInfo
(
pobj
);
//企业信息
var
schemeInfo
=
await
this
.
schemeSve
.
findInfo
(
pobj
);
//方案详情
var
followUpinfos
=
await
this
.
operationrecordSve
.
findAllInfo
(
pobj
);
//线索记录
return
system
.
getResult
({
bizoptInfo
:
bizoptInfo
,
companyInfo
:
companyInfo
,
schemeInfo
:
schemeInfo
,
followUpinfos
:
followUpinfos
});
}
catch
(
error
)
{
...
...
@@ -178,27 +177,26 @@ class BizOptCtl extends CtlBase {
var
ms
=
await
this
.
schemeService
.
findInfoByDemandCode
(
pobj
);
var
rarr
=
{}
if
(
rs
)
{
var
statusInfo
=
{
"currentStatus"
:
rs
.
business_status
};
//商机状态
var
statusInfo
=
{
"currentStatus"
:
rs
.
business_status
};
//商机状态
var
businessInfo
=
{};
businessInfo
.
demand_code
=
rs
.
demand_code
;
//商机编号
businessInfo
.
channelSource
=
appconfig
.
pdict
.
source
[
rs
.
source_name
];
///渠道来源
businessInfo
.
demand_code
=
rs
.
demand_code
;
//商机编号
businessInfo
.
channelSource
=
appconfig
.
pdict
.
source
[
rs
.
source_name
];
///渠道来源
// businessInfo.businessType = rs.business_type;//商机类型代码
businessInfo
.
businessType
=
appconfig
.
pdict
.
businessType
[
rs
.
business_type
];
//商机类型名称
businessInfo
.
businessType
=
appconfig
.
pdict
.
businessType
[
rs
.
business_type
];
//商机类型名称
// businessInfo.serviceArea = rs.service_address;//服务地区
if
(
businessInfo
.
businessName
==
"云上园区注册"
)
{
businessInfo
.
serviceArea
=
appconfig
.
pdict
.
registeredParkDict
[
rs
.
service_address
];
//服务地区名称
}
else
{
businessInfo
.
serviceArea
=
appconfig
.
pdict
.
registeredAreaDict
[
rs
.
service_address
];
//服务地区名称
businessInfo
.
serviceArea
=
appconfig
.
pdict
.
registeredParkDict
[
rs
.
service_address
];
//服务地区名称
}
else
{
businessInfo
.
serviceArea
=
appconfig
.
pdict
.
registeredAreaDict
[
rs
.
service_address
];
//服务地区名称
}
if
(
businessInfo
.
businessName
==
"注册地址"
)
{
businessInfo
.
registeredAddress
=
appconfig
.
pdict
.
registeredAreaDict
[
rs
.
service_address
];
//注册地址名称
businessInfo
.
registeredAddress
=
appconfig
.
pdict
.
registeredAreaDict
[
rs
.
service_address
];
//注册地址名称
}
businessInfo
.
statusReason
=
rs
.
close_reason
;
//商机关闭原因
businessInfo
.
memoInfo
=
rs
.
business_info
.
memoInfo
;
//备注信息
businessInfo
.
contactsName
=
rs
.
business_info
.
contactsName
;
//联系人名称
businessInfo
.
contactsPhone
=
system
.
decryptStr
(
rs
.
business_info
.
contactsPhone
);
//联系人联系方式
businessInfo
.
createdTime
=
this
.
timeFormat
(
rs
.
created_at
);
//商机创建时间
businessInfo
.
statusReason
=
rs
.
close_reason
;
//商机关闭原因
businessInfo
.
memoInfo
=
rs
.
business_info
.
memoInfo
;
//备注信息
businessInfo
.
contactsName
=
rs
.
business_info
.
contactsName
;
//联系人名称
businessInfo
.
contactsPhone
=
system
.
decryptStr
(
rs
.
business_info
.
contactsPhone
);
//联系人联系方式
businessInfo
.
createdTime
=
this
.
timeFormat
(
rs
.
created_at
);
//商机创建时间
rarr
.
statusInfo
=
statusInfo
;
rarr
.
businessInfo
=
businessInfo
;
}
...
...
@@ -208,22 +206,19 @@ class BizOptCtl extends CtlBase {
planInfo
.
currentStatus
=
ms
.
scheme_status
;
if
(
ms
.
scheme_status
&&
ms
.
scheme_status
==
"isReject"
)
{
planInfo
.
currentStatus
=
"已退回"
;
}
else
{
}
else
{
planInfo
.
currentStatus
=
ms
.
scheme_status
;
}
planInfo
.
statusReason
=
ms
.
reject_reason
;
rarr
.
planInfo
=
planInfo
;
}
return
system
.
getResult
(
rarr
);
}
catch
(
error
)
{
}
catch
(
error
)
{
console
.
log
(
"eeeeeeeeeeeeeeeeeeeeee"
);
console
.
log
(
error
);
return
system
.
getResultError
(
error
);
}
}
else
{
}
else
{
return
system
.
getResultError
(
"参数错误!"
);
}
}
...
...
@@ -254,20 +249,17 @@ class BizOptCtl extends CtlBase {
"newFacilitatorName"
:
pobj
.
facilitatorName
}
}
await
this
.
shisService
.
insertInfo
(
sInfo
);
//之前业务员转历史
await
this
.
service
.
updateSalesmanInfoByDemandCode
(
pobj
);
//更新业务员信息
await
this
.
shisService
.
insertInfo
(
sInfo
);
//之前业务员转历史
await
this
.
service
.
updateSalesmanInfoByDemandCode
(
pobj
);
//更新业务员信息
return
system
.
getResult
(
"操作成功!"
);
}
else
{
}
else
{
return
system
.
getResultError
(
"未找到相关数据"
);
}
}
catch
(
error
)
{
}
catch
(
error
)
{
return
system
.
getResultError
(
error
);
}
}
else
{
}
else
{
return
system
.
getResultError
(
"参数错误!"
);
}
}
...
...
@@ -277,7 +269,7 @@ class BizOptCtl extends CtlBase {
if
(
pobj
.
businessMode
&&
pobj
.
businessMode
!=
'undefined'
&&
pobj
.
currentStatus
&&
pobj
.
currentStatus
!=
'undefined'
)
{
try
{
await
this
.
service
.
updateStatusByDemandCode
(
pobj
);
await
this
.
schemeService
.
updateStatusByDemandCode
(
pobj
);
//同时更新方案的状态
await
this
.
schemeService
.
updateStatusByDemandCode
(
pobj
);
//同时更新方案的状态
var
res
=
await
this
.
service
.
findInfoByDemandCode
(
pobj
);
if
(
res
&&
res
!=
'undefined'
)
{
var
logInfo
=
{
...
...
@@ -288,7 +280,7 @@ class BizOptCtl extends CtlBase {
"clerkName"
:
res
.
salesman_name
,
"clerkId"
:
res
.
salesman_id
}
await
this
.
logService
.
insertInfo
(
logInfo
);
//插入状态日志表
await
this
.
logService
.
insertInfo
(
logInfo
);
//插入状态日志表
}
if
(
pobj
.
currentStatus
==
"isClosed"
)
{
//关闭需求时调用
...
...
@@ -310,20 +302,16 @@ class BizOptCtl extends CtlBase {
var
j
=
JSON
.
parse
(
rtn
.
stdout
);
if
(
j
.
status
==
1
)
{
return
system
.
getResult
(
"操作成功!"
);
}
else
{
}
else
{
return
system
.
getResultError
(
"更新方案状态出错!"
);
}
}
else
{
}
else
{
return
system
.
getResult
(
"操作成功!"
);
}
}
catch
(
error
)
{
}
catch
(
error
)
{
return
system
.
getResultError
(
error
);
}
}
else
{
}
else
{
return
system
.
getResultError
(
"参数错误!"
);
}
}
...
...
@@ -336,30 +324,31 @@ class BizOptCtl extends CtlBase {
//pobj.currentStatus = "beforeSubmission";//加上当前状态为待提交方案
// pobj.channelSource = "tencentCloud";//目前渠道只有腾讯
// pobj.sourceNumber = "1111111";
pobj
.
businessType
=
appconfig
.
pdict
.
dyDict
[
pobj
.
businessType
];
//
pobj.businessType = appconfig.pdict.dyDict[pobj.businessType];
var
buInfo
=
await
this
.
service
.
insertInfo
(
pobj
);
var
logInfo
=
{
"flowType"
:
"BIZ"
,
"flowId"
:
buInfo
.
id
,
"statusCode"
:
pobj
.
current
Status
,
"clerkName"
:
pobj
.
clerk
Name
,
"statusCode"
:
pobj
.
bussiness
Status
,
"clerkName"
:
pobj
.
salesman
Name
,
"clerkId"
:
pobj
.
salesmanId
}
await
this
.
logService
.
insertInfo
(
logInfo
);
//插入状态日至表
await
this
.
logService
.
insertInfo
(
logInfo
);
//插入状态日至表
return
{
"status"
:
1
,
//1代表成功,否则失败
"message"
:
"操作成功"
,
"data"
:
""
,
"requestId"
:
""
};
}
catch
(
error
)
{
}
catch
(
error
)
{
console
.
log
(
"TTTTTTTTTTTTTTTTTTTTTTT"
);
console
.
log
(
error
);
return
system
.
getResultError
(
error
);
}
}
else
{
}
else
{
return
system
.
getResultError
(
"参数错误!"
);
}
}
...
...
tx-fi-tax/app/base/db/impl/bizchance/bizoptDao.js
View file @
983babc4
...
...
@@ -19,8 +19,7 @@ class BizoptDao extends Dao {
*/
if
(
!
qobj
.
opath
)
{
// 管理员 不做处理
}
else
if
(
qobj
.
isPrincipal
)
{
// 销售主管 查询为空和自己组织结构下的
filters
.
push
({
$or
:
[
qw
[
"$or"
]
=
[
{
salesman_opcode
:
{
$eq
:
null
...
...
@@ -29,11 +28,8 @@ class BizoptDao extends Dao {
salesman_opcode
:
{
$like
:
`%
${
qobj
.
opath
}
%`
}
}
]
});
}
else
{
// 销售 查询自己的
filters
.
push
({
salesman_opcode
:
{
$like
:
`%
${
qobj
.
opath
}
%`
}
});
qw
[
"salesman_opcode"
]
=
{
$like
:
`%
${
qobj
.
opath
}
%`
}
}
//不是来自平台前端查询
if
(
qobj
.
bizpath
&&
qobj
.
bizpath
.
indexOf
(
"pmx"
)
<
0
)
{
...
...
@@ -75,8 +71,7 @@ class BizoptDao extends Dao {
var
setobj
=
{
"business_status"
:
qobj
.
business_status
};
if
(
qobj
.
close_reason
&&
qobj
.
close_reason
!=
'undefined'
)
{
setobj
[
"close_reason"
]
=
qobj
.
close_reason
;
}
else
{
}
else
{
setobj
[
"close_reason"
]
=
""
;
}
var
whereobj
=
{
"demand_code"
:
qobj
.
demand_code
};
...
...
@@ -113,47 +108,35 @@ class BizoptDao extends Dao {
var
obj
=
{
"demand_code"
:
qobj
.
businessMode
,
"business_type"
:
qobj
.
businessType
,
"business_status"
:
qobj
.
currentStatus
,
"business_info"
:
{}
"business_status"
:
qobj
.
bussinessStatus
,
"business_info"
:
{},
"source_number"
:
qobj
.
sourceNumber
,
"service_address"
:
qobj
.
serviceAddress
,
"facilitator_id"
:
qobj
.
favilitatorID
,
"facilitator_name"
:
qobj
.
favilitatorName
,
"source_name"
:
qobj
.
sourceName
,
};
if
(
qobj
.
channelSource
&&
qobj
.
channelSource
!=
'undefined'
)
{
obj
.
source_name
=
qobj
.
channelSource
;
}
if
(
qobj
.
sourceNumber
&&
qobj
.
sourceNumber
!=
'undefined'
)
{
obj
.
source_number
=
qobj
.
sourceNumber
;
//business_info START
if
(
qobj
.
topOrgCode
&&
qobj
.
topOrgCode
!=
'undefined'
)
{
obj
.
business_info
.
topOrgCode
=
qobj
.
topOrgCode
}
if
(
qobj
.
serviceCode
&&
qobj
.
serviceCode
!=
'undefined'
)
{
obj
.
service_address
=
qobj
.
serviceCode
;
if
(
qobj
.
intentionBizId
&&
qobj
.
intentionBizId
!=
'undefined'
)
{
obj
.
business_info
.
intentionBizId
=
qobj
.
intentionBizId
;
}
if
(
qobj
.
memoInfo
&&
qobj
.
memoInfo
!=
'undefined'
)
{
obj
.
business_info
.
memoInfo
=
qobj
.
memoInfo
;
}
if
(
qobj
.
statusReason
&&
qobj
.
statusReason
!=
'undefined'
)
{
obj
.
close_reason
=
qobj
.
statusReason
;
if
(
qobj
.
contactsPhone
&&
qobj
.
contactsPhone
!=
'undefined'
)
{
obj
.
business_info
.
contactsPhone
=
qobj
.
contactsPhone
;
//已经加密
}
if
(
qobj
.
contactsName
&&
qobj
.
contactsName
!=
'undefined'
)
{
obj
.
business_info
.
contactsName
=
qobj
.
contactsName
;
}
if
(
qobj
.
contactsPhone
&&
qobj
.
contactsPhone
!=
'undefined'
)
{
obj
.
business_info
.
contactsPhone
=
qobj
.
contactsPhone
;
//已经加密
}
if
(
qobj
.
serviceName
&&
qobj
.
serviceName
!=
'undefined'
)
{
obj
.
business_info
.
serviceName
=
qobj
.
serviceName
;
}
if
(
qobj
.
businessName
&&
qobj
.
businessName
!=
'undefined'
)
{
obj
.
business_info
.
businessName
=
qobj
.
businessName
;
}
if
(
qobj
.
UserName
&&
qobj
.
UserName
!=
'undefined'
)
{
obj
.
business_info
.
userName
=
qobj
.
UserNames
;
}
if
(
qobj
.
companyName
&&
qobj
.
companyName
!=
'undefined'
)
{
obj
.
business_info
.
companyName
=
qobj
.
companyName
;
}
if
(
qobj
.
servicerCode
&&
qobj
.
servicerCode
!=
'undefined'
)
{
obj
.
facilitator_id
=
qobj
.
servicerCode
;
}
if
(
qobj
.
servicerName
&&
qobj
.
servicerName
!=
'undefined'
)
{
obj
.
facilitator_name
=
qobj
.
servicerName
;
//bussiness_info END
//other
if
(
qobj
.
closeReason
&&
qobj
.
closeReason
!=
'undefined'
)
{
obj
.
close_reason
=
qobj
.
closeReason
;
}
if
(
qobj
.
salesmanOpcode
&&
qobj
.
salesmanOpcode
!=
'undefined'
)
{
obj
.
salesman_opcode
=
qobj
.
salesmanOpcode
;
...
...
@@ -161,12 +144,13 @@ class BizoptDao extends Dao {
if
(
qobj
.
salesmanId
&&
qobj
.
salesmanId
!=
'undefined'
)
{
obj
.
salesman_id
=
qobj
.
salesmanId
;
}
if
(
qobj
.
clerkName
&&
qobj
.
clerk
Name
!=
'undefined'
)
{
obj
.
salesman_name
=
qobj
.
clerk
Name
;
if
(
qobj
.
salesmanName
&&
qobj
.
salesman
Name
!=
'undefined'
)
{
obj
.
salesman_name
=
qobj
.
salesman
Name
;
}
if
(
qobj
.
clerkPhone
&&
qobj
.
clerk
Phone
!=
'undefined'
)
{
obj
.
salesman_phone
=
qobj
.
clerk
Phone
;
if
(
qobj
.
salesmanPhone
&&
qobj
.
salesman
Phone
!=
'undefined'
)
{
obj
.
salesman_phone
=
qobj
.
salesman
Phone
;
}
return
await
this
.
create
(
obj
,
t
);
}
...
...
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