Skip to content

Z
zhichan
Commit edbeb796 by 王勇飞
Options

gyq

parent 51187059
Showing with 104 additions and 16 deletions
center-manage/app/base/service/impl/common/channelhandlers/tx.js
...@@ -5,6 +5,7 @@ class TxHandler { ...@@ -5,6 +5,7 @@ class TxHandler {
constructor() { constructor() {
this.icUrl = settings.icUrl() + "/web/bizchance"; this.icUrl = settings.icUrl() + "/web/bizchance";
this.userService = system.getObject("service.auth.userSve"); this.userService = system.getObject("service.auth.userSve");
this.msgService = system.getObject("service.msg.msgSve")
this.cacheManager = system.getObject("db.common.cacheManager"); this.cacheManager = system.getObject("db.common.cacheManager");
} }
/** /**
...@@ -56,14 +57,31 @@ class TxHandler { ...@@ -56,14 +57,31 @@ class TxHandler {
params.salesmanOpcode = salesmanInfo.opath; params.salesmanOpcode = salesmanInfo.opath;
params.salesmanId = salesmanInfo.userId; params.salesmanId = salesmanInfo.userId;
params.clerkName = salesmanInfo.userName; params.clerkName = salesmanInfo.userName;
params.clerkPhone = salesmanInfo.mobile, params.clerkPhone = salesmanInfo.mobile;
params.servicerCode = salesmanInfo.compId params.servicerCode = salesmanInfo.compId
} }
var rtn = await rc.execPost3({ "d": params }, requrl); var rtn = await rc.execPost3({ "d": params }, requrl);
var j = JSON.parse(rtn.stdout); var j = JSON.parse(rtn.stdout);
console.log(JSON.stringify(j), "RRRRRRRRRRRRRRR"); console.log(JSON.stringify(j), "RRRRRRRRRRRRRRR");
if (j.status == 1) {//插入redis缓存 if (j.status == 1) {
await this.cacheManager["TxCache"].cache(cachestr, null, 1200000); await this.cacheManager["TxCache"].cache(cachestr, null, 1200000);//插入redis缓存
//给业务员发信息
var msg = {
"title": "你有新的商机，请尽快处理",
"content": "商机编号" + params.businessMode + ",商机类型是" + params.businessName + ",服务地区是" + params.serviceName,
"sender": "管理员",
"msgType": "single",
"target": { "id": params.salesmanId, "name": params.clerkName },
}
if (params.businessType == "/qcfw/icp/" || params.businessType == "/qcfw/edi/" || params.businessType == "/qcfw/icpannals/" || params.businessType == "/qcfw/ediannals/") {
msg.app_key = "5ae2da88-0ced-4b7a-98ea-60d5e1ff7e2e";
msg.jump_address = "allDispose"
}
else {
msg.app_key = "42d814c1-4daa-4643-88b2-f5dd3ec853f3";
msg.jump_address = "myChance"
}
await this.msgService.create(msg);
} }
return j; return j;
} }
...@@ -104,7 +122,34 @@ class TxHandler { ...@@ -104,7 +122,34 @@ class TxHandler {
var rtn = await rc.execPost3(params, requrl); var rtn = await rc.execPost3(params, requrl);
var j = JSON.parse(rtn.stdout); var j = JSON.parse(rtn.stdout);
if (j.status == 0) { if (j.status == 0) {
await this.cacheManager["TxCache"].cache(cachestr, null, 1200000); await this.cacheManager["TxCache"].cache(cachestr, null, 1200000);//插入缓存
//给业务员发信息
var selUrl = this.icUrl + "/schemeCtl/findInfoByDemandCode";
var selpar = {
"d": {
"businessMode": datajson.actionBody.NeedNum
}
}
rtn = await rc.execPost3(selpar, selUrl);
var jj = JSON.parse(rtn.stdout);
var msg = {
"title": "你有退回的商机，请尽快处理",
"content": "商机编号" + jj.businessMode + ",商机类型是" + jj.businessName,
"sender": "管理员",
"msgType": "single",
"target": { "id": jj.clerkId, "name": jj.clerkName },
}
if (jj.businessType == "ICP" || params.businessType == "EDI" || params.businessType == "ICPANNUALREPORT" || params.businessType == "EDIANNUALREPORT") {
msg.app_key = "5ae2da88-0ced-4b7a-98ea-60d5e1ff7e2e";
msg.jump_address = "allDispose"
}
else {
msg.app_key = "42d814c1-4daa-4643-88b2-f5dd3ec853f3";
msg.jump_address = "myChance"
}
await this.msgService.create(msg);
return { return {
"status": 1, //1代表成功，否则失败 "status": 1, //1代表成功，否则失败
"msg": "成功", "msg": "成功",
...@@ -185,14 +230,14 @@ class TxHandler { ...@@ -185,14 +230,14 @@ class TxHandler {
"express_info": {} "express_info": {}
} }
if (salesmanInfo && salesmanInfo != 'undefined') { if (salesmanInfo && salesmanInfo != 'undefined') {
params.clerkOpcode = salesmanInfo.opath, params.clerkOpcode = salesmanInfo.opath;
params.clerkId = salesmanInfo.userId, params.clerkId = salesmanInfo.userId;
params.clerkName = salesmanInfo.userName, params.clerkName = salesmanInfo.userName;
params.clerkPhone = salesmanInfo.mobile, params.clerkPhone = salesmanInfo.mobile;
params.costPrice = salesmanInfo.cost, params.costPrice = salesmanInfo.cost;
params.servicerCode = salesmanInfo.compId, params.servicerCode = salesmanInfo.compId;
params.baseInfo.clerkName = salesmanInfo.userName, params.baseInfo.clerkName = salesmanInfo.userName;
params.baseInfo.clerkPhone = salesmanInfo.mobile params.baseInfo.clerkPhone = salesmanInfo.mobile
} }
if (!params.serviceCode || params.serviceCode == 'undefined') { if (!params.serviceCode || params.serviceCode == 'undefined') {
if (datajson.actionBody.orderSnapshot.servicerCode && datajson.actionBody.orderSnapshot.servicerCode != 'undefined') { if (datajson.actionBody.orderSnapshot.servicerCode && datajson.actionBody.orderSnapshot.servicerCode != 'undefined') {
...@@ -220,7 +265,7 @@ class TxHandler { ...@@ -220,7 +265,7 @@ class TxHandler {
} }
} }
if (datajson.actionBody.orderSnapshot.hasOwnProperty("financial")) { if (datajson.actionBody.orderSnapshot.hasOwnProperty("financial")) {
if (datajson.actionBody.orderSnapshot.financial === true || datajson.actionBody.orderSnapshot.financial === "yes") { if (datajson.actionBody.orderSnapshot.financial === true || datajson.actionBody.orderSnapshot.financial === "yes") {
params.baseInfo.financial = "yes"; params.baseInfo.financial = "yes";
} }
else { else {
...@@ -325,7 +370,7 @@ class TxHandler { ...@@ -325,7 +370,7 @@ class TxHandler {
if (datajson.actionBody.orderSnapshot.annual_report && datajson.actionBody.orderSnapshot.annual_report != 'undefined') { if (datajson.actionBody.orderSnapshot.annual_report && datajson.actionBody.orderSnapshot.annual_report != 'undefined') {
params.baseInfo.annualReport = true;//shifouxuyaonianbao params.baseInfo.annualReport = true;//shifouxuyaonianbao
} }
else{ else {
params.baseInfo.annualReport = false; params.baseInfo.annualReport = false;
} }
...@@ -342,6 +387,23 @@ class TxHandler { ...@@ -342,6 +387,23 @@ class TxHandler {
console.log("j1---------------------------------" + rtn.stdout); console.log("j1---------------------------------" + rtn.stdout);
if (j.status == 0 && j1.status == 0) { if (j.status == 0 && j1.status == 0) {
await this.cacheManager["TxCache"].cache(cachestr, null, 1200000); await this.cacheManager["TxCache"].cache(cachestr, null, 1200000);
//给业务员发信息
var msg = {
"title": "你有新的交付单，请尽快处理",
"content": "交付单编号" + params.deliverNumber + ",产品类型是" + params.businessName + ",服务地区是" + params.serviceName,
"sender": "管理员",
"msgType": "single",
"target": { "id": params.clerkId, "name": params.clerkName },
}
if (params.businessType == "/qcfw/icp/" || params.businessType == "/qcfw/edi/" || params.businessType == "/qcfw/icpannals/" || params.businessType == "/qcfw/ediannals/") {
msg.app_key = "5ae2da88-0ced-4b7a-98ea-60d5e1ff7e2e";
msg.jump_address = "deliveryAll"
}
else {
msg.app_key = "42d814c1-4daa-4643-88b2-f5dd3ec853f3";
msg.jump_address = "myDeliver"
}
await this.msgService.create(msg);
return { return {
"status": 1, //1代表成功，否则失败 "status": 1, //1代表成功，否则失败
"msg": "", "msg": "",
...@@ -388,7 +450,33 @@ class TxHandler { ...@@ -388,7 +450,33 @@ class TxHandler {
var rtn = await rc.execPost3(params, requrl); var rtn = await rc.execPost3(params, requrl);
var j = JSON.parse(rtn.stdout); var j = JSON.parse(rtn.stdout);
if (j.status == 0) { if (j.status == 0) {
await this.cacheManager["TxCache"].cache(cachestr, null, 1200000); await this.cacheManager["TxCache"].cache(cachestr, null, 1200000);//插入缓存
//给业务员发信息
var selUrl = this.icUrl + "/deliverybillCtl/findInfoByDeliverCode";
var selpar = {
"d":{
"deliverNumber":datajson.actionBody.orderNum
}
}
rtn = await rc.execPost3(selpar, selUrl);
var jj = JSON.parse(rtn.stdout);
var msg = {
"title": "你有关闭的交付单，请尽快处理",
"content": "交付单编号" + jj.delivery_code + ",产品类型是" + jj.product_name,
"sender": "管理员",
"msgType": "single",
"target": { "id": jj.salesman_id, "name": jj.salesman_name },
}
if (jj.product_code == "ICP" || jj.product_code == "EDI" || jj.product_code == "ICPANNUALREPORT" || jj.product_code == "EDIANNUALREPORT") {
msg.app_key = "5ae2da88-0ced-4b7a-98ea-60d5e1ff7e2e";
msg.jump_address = "deliveryAll"
}
else {
msg.app_key = "42d814c1-4daa-4643-88b2-f5dd3ec853f3";
msg.jump_address = "myDeliver"
}
await this.msgService.create(msg);
return { return {
"status": 1, //1代表成功，否则失败 "status": 1, //1代表成功，否则失败
"msg": "", "msg": "",
......
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