Skip to content

Z
zhichan
Commit 81b06da3 by gxfeng
Options

fgx

parent 2f7c5dfc
Showing with 637 additions and 605 deletions
center-manage/app/base/service/impl/common/channelhandlers/tx.js
...@@ -3,643 +3,676 @@ const sha235 = require("sha256"); ...@@ -3,643 +3,676 @@ const sha235 = require("sha256");
var settings = require("../../../../../config/settings"); var settings = require("../../../../../config/settings");
class TxHandler { 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.msgService = system.getObject("service.msg.msgSve")
this.cacheManager = system.getObject("db.common.cacheManager"); this.cacheManager = system.getObject("db.common.cacheManager");
this.queueUrl = settings.bpushUrl(); this.queueUrl = settings.bpushUrl();
this.bookUrl = settings.bookUrl() + "/web/bizchance"; this.bookUrl = settings.bookUrl() + "/web/bizchance";
} }
/** /**
* 需要调用生成者接口，把数据丢入队列 * 需要调用生成者接口，把数据丢入队列
* 组装生产者需要的数据结构 * 组装生产者需要的数据结构
* @param {*} datajson * @param {*} datajson
*/ */
//新商机处理 //新商机处理
async addChance(datajson) { async addChance(datajson) {
console.log("put in queue", datajson); console.log("put in queue", datajson);
try { try {
var cachestr = sha235(JSON.stringify(datajson)); var cachestr = sha235(JSON.stringify(datajson));
var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr); var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr);
if (cacheInfo && cacheInfo != 'undefined') { if (cacheInfo && cacheInfo != 'undefined') {
return { return {
"status": 1, //1代表成功，否则失败 "status": 1, //1代表成功，否则失败
"msg": "已处理成功!", "msg": "已处理成功!",
"data": "", "data": "",
"requestId": "" "requestId": ""
} }
} else {
//获取分配的业务员信息
var ConsultTypeName = datajson.actionBody.ConsultTypeName.split("/")[2];
var salesmanInfo = await this.userService.getBizUserForBizChance(datajson.actionBody.ContactsMobile, datajson.actionBody.ServicerName, ConsultTypeName, datajson.actionBody.RegionName);
console.log("salesman ------- ");
console.log(salesmanInfo);
var rc = system.getObject("util.execClient");
var requrl = this.icUrl + "/bizoptCtl/insertInfo";
var params = {
"businessMode": datajson.actionBody.NeedNum,
"servicerName": datajson.actionBody.ServicerName,
"serviceCode": datajson.actionBody.RegionId,
"serviceName": datajson.actionBody.RegionName,
"contactsName": datajson.actionBody.ContactsName,
"contactsPhone": datajson.actionBody.ContactsMobile,
"businessType": datajson.actionBody.ConsultType,
"businessName": datajson.actionBody.ConsultTypeName,
"currentStatus": "beforeSubmission",
"channelSource": "tencentCloud", //渠道
"channelNumber": "tx"
}
if (datajson.actionBody.Notes && datajson.actionBody.Notes != 'undefined') {
params.memoInfo = datajson.actionBody.Notes;
}
if (datajson.actionBody.CompanyName && datajson.actionBody.CompanyName != 'undefined') {
params.companyName = datajson.actionBody.CompanyName;
}
if (datajson.actionBody.UserName && datajson.actionBody.UserName != 'undefined') {
params.UserName = datajson.actionBody.UserName;
}
if (salesmanInfo.comInfo) {
params.servicerCode = salesmanInfo.comInfo.compId
}
if (salesmanInfo.userInfo && salesmanInfo.userInfo != 'undefined') {
params.salesmanOpcode = salesmanInfo.userInfo.opath;
params.salesmanId = salesmanInfo.userInfo.userId;
params.clerkName = salesmanInfo.userInfo.userName;
params.clerkPhone = system.encryptStr(salesmanInfo.userInfo.mobile);
}
var rtn = await rc.execPost3({ "d": params }, requrl);
var j = JSON.parse(rtn.stdout);
console.log(JSON.stringify(j), "RRRRRRRRRRRRRRR");
if (j.status == 1) {
await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180); //插入redis缓存
//给业务员发信息
if (params.salesmanId) {
var msg = {
"title": "你有新的商机，请尽快处理",
"content": "商机编号" + params.businessMode + ",商机类型是" + params.businessName + ",服务地区是" + params.serviceName,
"sender": "管理员",
"sender_id": 0,
"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 { } else {
//获取分配的业务员信息 msg.app_key = "42d814c1-4daa-4643-88b2-f5dd3ec853f3";
var ConsultTypeName = datajson.actionBody.ConsultTypeName.split("/")[2]; msg.jump_address = "myChance"
var salesmanInfo = await this.userService.getBizUserForBizChance(datajson.actionBody.ContactsMobile, datajson.actionBody.ServicerName, ConsultTypeName, datajson.actionBody.RegionName);
console.log("salesman ------- ");
console.log(salesmanInfo);
var rc = system.getObject("util.execClient");
var requrl = this.icUrl + "/bizoptCtl/insertInfo";
var params = {
"businessMode": datajson.actionBody.NeedNum,
"servicerName": datajson.actionBody.ServicerName,
"serviceCode": datajson.actionBody.RegionId,
"serviceName": datajson.actionBody.RegionName,
"contactsName": datajson.actionBody.ContactsName,
"contactsPhone": datajson.actionBody.ContactsMobile,
"businessType": datajson.actionBody.ConsultType,
"businessName": datajson.actionBody.ConsultTypeName,
"currentStatus": "beforeSubmission",
"channelSource": "tencentCloud", //渠道
"channelNumber": "tx"
}
if (datajson.actionBody.Notes && datajson.actionBody.Notes != 'undefined') {
params.memoInfo = datajson.actionBody.Notes;
}
if (datajson.actionBody.CompanyName && datajson.actionBody.CompanyName != 'undefined') {
params.companyName = datajson.actionBody.CompanyName;
}
if (datajson.actionBody.UserName && datajson.actionBody.UserName != 'undefined') {
params.UserName = datajson.actionBody.UserName;
}
if (salesmanInfo.comInfo) {
params.servicerCode = salesmanInfo.comInfo.compId
}
if (salesmanInfo.userInfo && salesmanInfo.userInfo != 'undefined') {
params.salesmanOpcode = salesmanInfo.userInfo.opath;
params.salesmanId = salesmanInfo.userInfo.userId;
params.clerkName = salesmanInfo.userInfo.userName;
params.clerkPhone = system.encryptStr(salesmanInfo.userInfo.mobile);
}
var rtn = await rc.execPost3({ "d": params }, requrl);
var j = JSON.parse(rtn.stdout);
console.log(JSON.stringify(j), "RRRRRRRRRRRRRRR");
if (j.status == 1) {
await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180); //插入redis缓存
//给业务员发信息
if (params.salesmanId) {
var msg = {
"title": "你有新的商机，请尽快处理",
"content": "商机编号" + params.businessMode + ",商机类型是" + params.businessName + ",服务地区是" + params.serviceName,
"sender": "管理员",
"sender_id": 0,
"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"
}
this.msgService.create(msg);
}
}
return j;
} }
} catch (error) { this.msgService.create(msg);
console.log("TTTTTTTTTTTTTT"); }
console.log(error);
return system.getResultError(error);
} }
return j;
}
} catch (error) {
console.log("TTTTTTTTTTTTTT");
console.log(error);
return system.getResultError(error);
} }
//退回商机处理 }
async needClose(datajson) {
console.log("put in queue" + JSON.stringify(datajson) + "DDDDDDDDDDDDDDDDDDDDDDDDDDDDDDD");
try {
var cachestr = sha235(JSON.stringify(datajson));
var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr);
if (cacheInfo && cacheInfo != 'undefined') {
return {
"status": 1, //1代表成功，否则失败
"msg": "已处理成功!",
"data": "",
"requestId": ""
}
} else {
var rc = system.getObject("util.execClient");
var requrl = this.icUrl + "/schemeCtl/updateStatusByDemandCode";
var params = {
"d": {
"businessMode": datajson.actionBody.NeedNum,
"schemeNumber": datajson.actionBody.SolutionNum,
"currentStatus": "isReject",
"statusReason": datajson.actionBody.RefusalContent
}
}
var rtn = await rc.execPost3(params, requrl);
var j = JSON.parse(rtn.stdout);
if (j.status == 0) {
await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180); //插入缓存
//给业务员发信息 //退回商机处理
var selUrl = this.icUrl + "/schemeCtl/findInfoByDemandCode"; async needClose(datajson) {
var selpar = { console.log("put in queue" + JSON.stringify(datajson) + "DDDDDDDDDDDDDDDDDDDDDDDDDDDDDDD");
"d": { try {
"businessMode": datajson.actionBody.NeedNum var cachestr = sha235(JSON.stringify(datajson));
} var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr);
} if (cacheInfo && cacheInfo != 'undefined') {
rtn = await rc.execPost3(selpar, selUrl); return {
var jj = JSON.parse(rtn.stdout); "status": 1, //1代表成功，否则失败
console.log("jj------------------------------" + rtn.stdout); "msg": "已处理成功!",
if (jj.status == 0 && jj.data) { "data": "",
if (jj.data.clerkId) { "requestId": ""
var msg = { }
"title": "你有退回的商机，请尽快处理", } else {
"content": "商机编号" + jj.data.businessMode + ",商机类型是" + jj.data.businessName, var rc = system.getObject("util.execClient");
"sender": "管理员", var requrl = this.icUrl + "/schemeCtl/updateStatusByDemandCode";
"sender_id": 0, var params = {
"msgType": "single", "d": {
"target": { "id": jj.data.clerkId, "name": jj.data.clerkName }, "businessMode": datajson.actionBody.NeedNum,
} "schemeNumber": datajson.actionBody.SolutionNum,
if (jj.data.businessType == "ICP" || jj.data.businessType == "EDI" || jj.data.businessType == "ICPANNUALREPORT" || jj.data.businessType == "EDIANNUALREPORT") { "currentStatus": "isReject",
msg.app_key = "5ae2da88-0ced-4b7a-98ea-60d5e1ff7e2e"; "statusReason": datajson.actionBody.RefusalContent
msg.jump_address = "allDispose" }
} else { }
msg.app_key = "42d814c1-4daa-4643-88b2-f5dd3ec853f3"; var rtn = await rc.execPost3(params, requrl);
msg.jump_address = "myChance" var j = JSON.parse(rtn.stdout);
} if (j.status == 0) {
this.msgService.create(msg); await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180); //插入缓存
}
}
return { //给业务员发信息
"status": 1, //1代表成功，否则失败 var selUrl = this.icUrl + "/schemeCtl/findInfoByDemandCode";
"msg": "成功", var selpar = {
"data": "", "d": {
"requestId": "" "businessMode": datajson.actionBody.NeedNum
}
} else {
return j;
}
} }
} catch (error) { }
return system.getResultError(error); rtn = await rc.execPost3(selpar, selUrl);
} var jj = JSON.parse(rtn.stdout);
console.log("jj------------------------------" + rtn.stdout);
if (jj.status == 0 && jj.data) {
if (jj.data.clerkId) {
var msg = {
"title": "你有退回的商机，请尽快处理",
"content": "商机编号" + jj.data.businessMode + ",商机类型是" + jj.data.businessName,
"sender": "管理员",
"sender_id": 0,
"msgType": "single",
"target": { "id": jj.data.clerkId, "name": jj.data.clerkName },
}
if (jj.data.businessType == "ICP" || jj.data.businessType == "EDI" || jj.data.businessType == "ICPANNUALREPORT" || jj.data.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"
}
this.msgService.create(msg);
}
}
return {
"status": 1, //1代表成功，否则失败
"msg": "成功",
"data": "",
"requestId": ""
}
} else {
return j;
}
}
} catch (error) {
return system.getResultError(error);
} }
//交付单处理 }
async orderSubmit(datajson) {
console.log("put in queue-----------------------------------------------------------------------------------------------------", datajson);
try {
var cachestr = sha235(JSON.stringify(datajson));
var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr);
if (cacheInfo && cacheInfo != 'undefined') {
return {
"status": 1, //1代表成功，否则失败
"msg": "已处理成功!",
"data": "",
"requestId": ""
}
} else {
var rc = system.getObject("util.execClient");
var requrl = this.icUrl + "/deliverybillCtl/findInfoByDeliverCode";
var delInfo = await rc.execPost3({ "d": { "deliverNumber": datajson.actionBody.orderNum } }, requrl);
console.log("jdelInfo---------------------------------------------" + delInfo.stdout);
var jdelInfo = JSON.parse(delInfo.stdout);
if (jdelInfo.status == 0) {
return {
"status": 1, //1代表成功，否则失败
"msg": "数据已存在",
"data": "",
"requestId": ""
}
} else {
//获取分配的业务员信息
var ConsultTypeName = "";
console.log("productTypeName-----------------------------" + datajson.actionBody.productTypeName);
if (datajson.actionBody.productTypeName && datajson.actionBody.productTypeName != 'undefined') {
ConsultTypeName = datajson.actionBody.productTypeName.split("/")[2];
}
console.log("ConsultTypeName-----------------------------" + ConsultTypeName);
var salesmanInfo = await this.userService.getBizUserForDelivery(datajson.actionBody.orderSnapshot.contactsPhone, datajson.actionBody.servicerName, ConsultTypeName, datajson.actionBody.txPriceCode, datajson.actionBody.regionName);
requrl = this.icUrl + "/deliverybillCtl/insertInfo";
var bizurl = this.icUrl + "/bizoptCtl/updateStatusByDemandCode";
var params = {
"channelSource": "tencentCloud", //渠道
"channelNumber": "tx",
"deliverNumber": datajson.actionBody.orderNum,
"servicerName": datajson.actionBody.servicerName,
"serviceCode": datajson.actionBody.regionId,
"serviceName": datajson.actionBody.regionName,
"businessType": datajson.actionBody.productType,
"businessName": ConsultTypeName,
"skuCode": datajson.actionBody.txPriceCode,
"txOrderNum": datajson.actionBody.txOrderNum,
"deliverStatus": "received",
"baseInfo": {
"txOrderNum": datajson.actionBody.txOrderNum,
"isAdviser": "已分配", //是否分配顾问
"contactsName": datajson.actionBody.orderSnapshot.contactsName,
"contactsPhone": datajson.actionBody.orderSnapshot.contactsPhone,
"payStatus": "待交付"
},
"companyInfo": {},
"registeredInfo": {},
"positionInfo": {},
"regInfo": {},
"express_info": {}
}
if (salesmanInfo.comInfo) {
params.costPrice = salesmanInfo.comInfo.cost;
params.servicerCode = salesmanInfo.comInfo.compId;
}
//设置成本 tocheck
let costprice = await this.userService.findCostBySkuCode(datajson.actionBody.txPriceCode)
params.costPrice = costprice
if (salesmanInfo.userInfo && salesmanInfo.userInfo != 'undefined') { //交付单处理
params.clerkOpcode = salesmanInfo.userInfo.opath; async orderSubmit(datajson) {
params.clerkId = salesmanInfo.userInfo.userId; console.log("put in queue-----------------------------------------------------------------------------------------------------", datajson);
params.clerkName = salesmanInfo.userInfo.userName; try {
//params.clerkPhone = salesmanInfo.userInfo.mobile; var cachestr = sha235(JSON.stringify(datajson));
params.baseInfo.clerkName = salesmanInfo.userInfo.userName; var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr);
// params.baseInfo.clerkPhone = salesmanInfo.userInfo.mobile if (cacheInfo && cacheInfo != 'undefined') {
} return {
// if (!params.servicerCode || params.servicerCode == 'undefined') { "status": 1, //1代表成功，否则失败
// if (datajson.actionBody.orderSnapshot.servicerCode && datajson.actionBody.orderSnapshot.servicerCode != 'undefined') { "msg": "已处理成功!",
// params.servicerCode = datajson.actionBody.orderSnapshot.servicerCode;//fuwushang id "data": "",
// } "requestId": ""
// } }
if (datajson.actionBody.orderSnapshot.needNum && datajson.actionBody.orderSnapshot.needNum != 'undefined') { } else {
params.businessMode = datajson.actionBody.orderSnapshot.needNum; //商机编号 var rc = system.getObject("util.execClient");
} var requrl = this.icUrl + "/deliverybillCtl/findInfoByDeliverCode";
if (datajson.actionBody.realTotalCost && datajson.actionBody.realTotalCost != 'undefined') { var delInfo = await rc.execPost3({ "d": { "deliverNumber": datajson.actionBody.orderNum } }, requrl);
params.sellingPrice = datajson.actionBody.realTotalCost; //价格 console.log("jdelInfo---------------------------------------------" + delInfo.stdout);
} var jdelInfo = JSON.parse(delInfo.stdout);
// if (datajson.actionBody.orderSnapshot.channelSource && datajson.actionBody.orderSnapshot.channelSource != 'undefined') { if (jdelInfo.status == 0) {
// params.channelSource = datajson.actionBody.orderSnapshot.channelSource;//渠道名称 return {
// } "status": 1, //1代表成功，否则失败
// if (datajson.actionBody.orderSnapshot.channelNumber && datajson.actionBody.orderSnapshot.channelNumber != 'undefined') { "msg": "数据已存在",
// params.channelNumber = datajson.actionBody.orderSnapshot.channelNumber;//渠道编码 "data": "",
// } "requestId": ""
if (datajson.actionBody.orderSnapshot.hasOwnProperty("isWhether")) { }
if (datajson.actionBody.orderSnapshot.isWhether === true || datajson.actionBody.orderSnapshot.isWhether === "yes") { } else {
params.baseInfo.isWhether = "yes"; //是否刻章 //获取分配的业务员信息
} else { var ConsultTypeName = "";
params.baseInfo.isWhether = "no"; //是否刻章 console.log("productTypeName-----------------------------" + datajson.actionBody.productTypeName);
} if (datajson.actionBody.productTypeName && datajson.actionBody.productTypeName != 'undefined') {
} else { ConsultTypeName = datajson.actionBody.productTypeName.split("/")[2];
if (datajson.actionBody.contextOrderCount && datajson.actionBody.contextOrderCount != 'undefined' && datajson.actionBody.contextOrderCount > 1) { }
params.baseInfo.isWhether = "yes"; console.log("ConsultTypeName-----------------------------" + ConsultTypeName);
} else { var salesmanInfo = await this.userService.getBizUserForDelivery(datajson.actionBody.orderSnapshot.contactsPhone, datajson.actionBody.servicerName, ConsultTypeName, datajson.actionBody.txPriceCode, datajson.actionBody.regionName);
params.baseInfo.isWhether = "no"; requrl = this.icUrl + "/deliverybillCtl/insertInfo";
} var bizurl = this.icUrl + "/bizoptCtl/updateStatusByDemandCode";
} var params = {
if (datajson.actionBody.orderSnapshot.hasOwnProperty("financial")) { "channelSource": "tencentCloud", //渠道
if (datajson.actionBody.orderSnapshot.financial === true || datajson.actionBody.orderSnapshot.financial === "yes") { "channelNumber": "tx",
params.baseInfo.financial = "yes"; "deliverNumber": datajson.actionBody.orderNum,
} else { "servicerName": datajson.actionBody.servicerName,
params.baseInfo.financial = "no"; "serviceCode": datajson.actionBody.regionId,
} "serviceName": datajson.actionBody.regionName,
} else { "businessType": datajson.actionBody.productType,
if (datajson.actionBody.contextOrderCount && datajson.actionBody.contextOrderCount != 'undefined' && datajson.actionBody.contextOrderCount > 1) { "businessName": ConsultTypeName,
params.baseInfo.financial = "yes"; "skuCode": datajson.actionBody.txPriceCode,
} else { "txOrderNum": datajson.actionBody.txOrderNum,
params.baseInfo.financial = "no"; "deliverStatus": "received",
} "baseInfo": {
} "txOrderNum": datajson.actionBody.txOrderNum,
if (datajson.actionBody.orderSnapshot.officialSeal && datajson.actionBody.orderSnapshot.officialSeal != 'undefined') { "isAdviser": "已分配", //是否分配顾问
params.baseInfo.officialSeal = datajson.actionBody.orderSnapshot.officialSeal; //公章扫描件 "contactsName": datajson.actionBody.orderSnapshot.contactsName,
} "contactsPhone": datajson.actionBody.orderSnapshot.contactsPhone,
if (datajson.actionBody.orderSnapshot.businessLicense && datajson.actionBody.orderSnapshot.businessLicense != 'undefined') { "payStatus": "待交付"
params.baseInfo.businessLicense = datajson.actionBody.orderSnapshot.businessLicense; //营业执照扫描件 },
} "companyInfo": {},
if (datajson.actionBody.orderSnapshot.taxpayerName && datajson.actionBody.orderSnapshot.taxpayerName != 'undefined') { "registeredInfo": {},
params.baseInfo.taxpayerName = datajson.actionBody.orderSnapshot.taxpayerName; //纳税人类型名称 "positionInfo": {},
} else if (datajson.actionBody.orderSnapshot.taxpayerType && datajson.actionBody.orderSnapshot.taxpayerType != 'undefined') { "regInfo": {},
params.baseInfo.taxpayerName = datajson.actionBody.orderSnapshot.taxpayerType; //纳税人类型名称 "express_info": {}
} }
if (datajson.actionBody.orderSnapshot.buyDuration && datajson.actionBody.orderSnapshot.buyDuration != 'undefined') { if (salesmanInfo.comInfo) {
params.baseInfo.buyDuration = datajson.actionBody.orderSnapshot.buyDuration; //购买时长 params.costPrice = salesmanInfo.comInfo.cost;
} else if (datajson.actionBody.orderSnapshot.timeSpan && datajson.actionBody.orderSnapshot.timeSpan != 'undefined') { params.servicerCode = salesmanInfo.comInfo.compId;
params.baseInfo.buyDuration = datajson.actionBody.orderSnapshot.timeSpan + "年"; //购买时长 }
} //设置成本 tocheck
if (datajson.actionBody.orderSnapshot.buyTime && datajson.actionBody.orderSnapshot.buyTime != 'undefined') { let costprice = await this.userService.findCostBySkuCode(datajson.actionBody.txPriceCode)
params.baseInfo.buyTime = datajson.actionBody.orderSnapshot.buyTime; //购买时间 params.costPrice = costprice
}
if (datajson.actionBody.orderSnapshot.isRenew && datajson.actionBody.orderSnapshot.isRenew != 'undefined') {
params.baseInfo.isRenew = datajson.actionBody.orderSnapshot.isRenew; //是否自动续费
}
if (datajson.actionBody.orderSnapshot.memoInfo && datajson.actionBody.orderSnapshot.memoInfo != 'undefined') {
params.baseInfo.memoInfo = datajson.actionBody.orderSnapshot.memoInfo;
} else if (datajson.actionBody.orderSnapshot.businessContent && datajson.actionBody.orderSnapshot.businessContent != 'undefined') {
params.baseInfo.memoInfo = datajson.actionBody.orderSnapshot.businessContent;
}
if (datajson.actionBody.orderSnapshot.whetherType && datajson.actionBody.orderSnapshot.whetherType != 'undefined') {
params.baseInfo.whetherType = datajson.actionBody.orderSnapshot.whetherType; //刻章类型
}
if (datajson.actionBody.orderSnapshot.hasOwnProperty("annualReport")) { //年报信息
params.baseInfo.annualReport = datajson.actionBody.orderSnapshot.annualReport;
} else {
if (datajson.actionBody.orderSnapshot.annual_report && datajson.actionBody.orderSnapshot.annual_report != 'undefined') {
params.baseInfo.annualReport = true; //shifouxuyaonianbao
} else {
params.baseInfo.annualReport = false;
}
}
if (datajson.actionBody.orderSnapshot.hasOwnProperty("addressType")) { //注册地址类型
if (datajson.actionBody.orderSnapshot.addressType === true || datajson.actionBody.orderSnapshot.addressType === "practical") {
params.baseInfo.addressType = "practical";
} else {
params.baseInfo.addressType = "virtual";
}
}
if (datajson.actionBody.orderSnapshot.subjectType && datajson.actionBody.orderSnapshot.subjectType != 'undefined') {
params.baseInfo.subjectType = datajson.actionBody.orderSnapshot.subjectType; //代理记账主体类型
}
if (datajson.actionBody.orderSnapshot.companyName && datajson.actionBody.orderSnapshot.companyName != 'undefined') {
params.baseInfo.companyName = datajson.actionBody.orderSnapshot.companyName; //公司名称
params.companyInfo.companyName = datajson.actionBody.orderSnapshot.companyName;
} else if (datajson.actionBody.orderSnapshot.company && datajson.actionBody.orderSnapshot.company != 'undefined') {
params.baseInfo.companyName = datajson.actionBody.orderSnapshot.company; //公司名称
params.companyInfo.companyName = datajson.actionBody.orderSnapshot.company;
}
if (datajson.actionBody.orderSnapshot.companyProperties && datajson.actionBody.orderSnapshot.companyProperties != 'undefined') {
params.companyInfo.companyPropertiesName = datajson.actionBody.orderSnapshot.companyProperties; //公司性质名称
} else if (datajson.actionBody.orderSnapshot.companyType && datajson.actionBody.orderSnapshot.companyType != 'undefined') {
params.companyInfo.companyPropertiesName = datajson.actionBody.orderSnapshot.companyType; //公司性质名称
} else if (datajson.actionBody.orderSnapshot.registeredName && datajson.actionBody.orderSnapshot.registeredName != 'undefined') {
params.companyInfo.companyPropertiesName = datajson.actionBody.orderSnapshot.registeredName; //公司性质名称
}
if (datajson.actionBody.orderSnapshot.fullAddress && datajson.actionBody.orderSnapshot.fullAddress != 'undefined') {
params.companyInfo.fullAddress = datajson.actionBody.orderSnapshot.fullAddress; //详细地址
} else if (datajson.actionBody.orderSnapshot.residenceAddress && datajson.actionBody.orderSnapshot.residenceAddress != 'undefined') {
params.companyInfo.fullAddress = datajson.actionBody.orderSnapshot.residenceAddress; //详细地址
}
if (datajson.actionBody.orderSnapshot.virtualPrice && datajson.actionBody.orderSnapshot.virtualPrice != 'undefined') {
params.companyInfo.virtualPrice = datajson.actionBody.orderSnapshot.virtualPrice; //虚拟地址价格
params.baseInfo.virtualPrice = datajson.actionBody.orderSnapshot.virtualPrice; //虚拟地址价格
}
if (datajson.actionBody.orderSnapshot.residenceAddress && datajson.actionBody.orderSnapshot.residenceAddress != 'undefined') {
params.companyInfo.residenceAddress = datajson.actionBody.orderSnapshot.residenceAddress; //zhusuo
}
if (datajson.actionBody.orderSnapshot.engagedIndustry && datajson.actionBody.orderSnapshot.engagedIndustry != 'undefined') {
params.companyInfo.engagedIndName = datajson.actionBody.orderSnapshot.engagedIndustry; //从事行业名称
}
if (datajson.actionBody.orderSnapshot.businessScope && datajson.actionBody.orderSnapshot.businessScope != 'undefined') {
params.companyInfo.businessScope = datajson.actionBody.orderSnapshot.businessScope; //经营范围
}
if (datajson.actionBody.orderSnapshot.operatingPeriod && datajson.actionBody.orderSnapshot.operatingPeriod != 'undefined') {
params.companyInfo.operatingPeriod = datajson.actionBody.orderSnapshot.operatingPeriod; //经营期限
}
if (datajson.actionBody.orderSnapshot.businessTerm && datajson.actionBody.orderSnapshot.businessTerm != 'undefined') {
params.companyInfo.businessTerm = datajson.actionBody.orderSnapshot.businessTerm; //经营期限
}
if (datajson.actionBody.orderSnapshot.registeredCapital && datajson.actionBody.orderSnapshot.registeredCapital != 'undefined') {
params.companyInfo.registeredCapital = datajson.actionBody.orderSnapshot.registeredCapital; //注册资本
}
if (datajson.actionBody.orderSnapshot.creditCode && datajson.actionBody.orderSnapshot.creditCode != 'undefined') {
params.companyInfo.creditCode = datajson.actionBody.orderSnapshot.creditCode; //统一社会信用代码
}
if (datajson.actionBody.orderSnapshot.establishedTime && datajson.actionBody.orderSnapshot.establishedTime != 'undefined') {
params.companyInfo.establishedTime = datajson.actionBody.orderSnapshot.establishedTime; //成立时间
}
if (datajson.actionBody.orderSnapshot.shareholderName && datajson.actionBody.orderSnapshot.shareholderName != 'undefined') {
params.companyInfo.shareholderName = datajson.actionBody.orderSnapshot.shareholderName; //法人代表
}
if (salesmanInfo.userInfo && salesmanInfo.userInfo != 'undefined') {
params.clerkOpcode = salesmanInfo.userInfo.opath;
params.clerkId = salesmanInfo.userInfo.userId;
params.clerkName = salesmanInfo.userInfo.userName;
//params.clerkPhone = salesmanInfo.userInfo.mobile;
params.baseInfo.clerkName = salesmanInfo.userInfo.userName;
// params.baseInfo.clerkPhone = salesmanInfo.userInfo.mobile
}
// if (!params.servicerCode || params.servicerCode == 'undefined') {
// if (datajson.actionBody.orderSnapshot.servicerCode && datajson.actionBody.orderSnapshot.servicerCode != 'undefined') {
// params.servicerCode = datajson.actionBody.orderSnapshot.servicerCode;//fuwushang id
// }
// }
if (datajson.actionBody.orderSnapshot.needNum && datajson.actionBody.orderSnapshot.needNum != 'undefined') {
params.businessMode = datajson.actionBody.orderSnapshot.needNum; //商机编号
}
if (datajson.actionBody.realTotalCost && datajson.actionBody.realTotalCost != 'undefined') {
params.sellingPrice = datajson.actionBody.realTotalCost; //价格
}
// if (datajson.actionBody.orderSnapshot.channelSource && datajson.actionBody.orderSnapshot.channelSource != 'undefined') {
// params.channelSource = datajson.actionBody.orderSnapshot.channelSource;//渠道名称
// }
// if (datajson.actionBody.orderSnapshot.channelNumber && datajson.actionBody.orderSnapshot.channelNumber != 'undefined') {
// params.channelNumber = datajson.actionBody.orderSnapshot.channelNumber;//渠道编码
// }
if (datajson.actionBody.orderSnapshot.hasOwnProperty("isWhether")) {
if (datajson.actionBody.orderSnapshot.isWhether === true || datajson.actionBody.orderSnapshot.isWhether === "yes") {
params.baseInfo.isWhether = "yes"; //是否刻章
} else {
params.baseInfo.isWhether = "no"; //是否刻章
}
} else {
if (datajson.actionBody.contextOrderCount && datajson.actionBody.contextOrderCount != 'undefined' && datajson.actionBody.contextOrderCount > 1) {
params.baseInfo.isWhether = "yes";
} else {
params.baseInfo.isWhether = "no";
}
}
if (datajson.actionBody.orderSnapshot.hasOwnProperty("financial")) {
if (datajson.actionBody.orderSnapshot.financial === true || datajson.actionBody.orderSnapshot.financial === "yes") {
params.baseInfo.financial = "yes";
} else {
params.baseInfo.financial = "no";
}
} else {
if (datajson.actionBody.contextOrderCount && datajson.actionBody.contextOrderCount != 'undefined' && datajson.actionBody.contextOrderCount > 1) {
params.baseInfo.financial = "yes";
} else {
params.baseInfo.financial = "no";
}
}
if (datajson.actionBody.orderSnapshot.officialSeal && datajson.actionBody.orderSnapshot.officialSeal != 'undefined') {
params.baseInfo.officialSeal = datajson.actionBody.orderSnapshot.officialSeal; //公章扫描件
}
if (datajson.actionBody.orderSnapshot.businessLicense && datajson.actionBody.orderSnapshot.businessLicense != 'undefined') {
params.baseInfo.businessLicense = datajson.actionBody.orderSnapshot.businessLicense; //营业执照扫描件
}
if (datajson.actionBody.orderSnapshot.taxpayerName && datajson.actionBody.orderSnapshot.taxpayerName != 'undefined') {
params.baseInfo.taxpayerName = datajson.actionBody.orderSnapshot.taxpayerName; //纳税人类型名称
} else if (datajson.actionBody.orderSnapshot.taxpayerType && datajson.actionBody.orderSnapshot.taxpayerType != 'undefined') {
params.baseInfo.taxpayerName = datajson.actionBody.orderSnapshot.taxpayerType; //纳税人类型名称
}
if (datajson.actionBody.orderSnapshot.buyDuration && datajson.actionBody.orderSnapshot.buyDuration != 'undefined') {
params.baseInfo.buyDuration = datajson.actionBody.orderSnapshot.buyDuration; //购买时长
} else if (datajson.actionBody.orderSnapshot.timeSpan && datajson.actionBody.orderSnapshot.timeSpan != 'undefined') {
params.baseInfo.buyDuration = datajson.actionBody.orderSnapshot.timeSpan + "年"; //购买时长
}
if (datajson.actionBody.orderSnapshot.buyTime && datajson.actionBody.orderSnapshot.buyTime != 'undefined') {
params.baseInfo.buyTime = datajson.actionBody.orderSnapshot.buyTime; //购买时间
}
if (datajson.actionBody.orderSnapshot.isRenew && datajson.actionBody.orderSnapshot.isRenew != 'undefined') {
params.baseInfo.isRenew = datajson.actionBody.orderSnapshot.isRenew; //是否自动续费
}
if (datajson.actionBody.orderSnapshot.memoInfo && datajson.actionBody.orderSnapshot.memoInfo != 'undefined') {
params.baseInfo.memoInfo = datajson.actionBody.orderSnapshot.memoInfo;
} else if (datajson.actionBody.orderSnapshot.businessContent && datajson.actionBody.orderSnapshot.businessContent != 'undefined') {
params.baseInfo.memoInfo = datajson.actionBody.orderSnapshot.businessContent;
}
if (datajson.actionBody.orderSnapshot.whetherType && datajson.actionBody.orderSnapshot.whetherType != 'undefined') {
params.baseInfo.whetherType = datajson.actionBody.orderSnapshot.whetherType; //刻章类型
}
if (datajson.actionBody.orderSnapshot.hasOwnProperty("annualReport")) { //年报信息
params.baseInfo.annualReport = datajson.actionBody.orderSnapshot.annualReport;
} else {
if (datajson.actionBody.orderSnapshot.annual_report && datajson.actionBody.orderSnapshot.annual_report != 'undefined') {
params.baseInfo.annualReport = true; //shifouxuyaonianbao
} else {
params.baseInfo.annualReport = false;
}
}
if (datajson.actionBody.orderSnapshot.hasOwnProperty("addressType")) { //注册地址类型
if (datajson.actionBody.orderSnapshot.addressType === true || datajson.actionBody.orderSnapshot.addressType === "practical") {
params.baseInfo.addressType = "practical";
} else {
params.baseInfo.addressType = "virtual";
}
}
if (datajson.actionBody.orderSnapshot.subjectType && datajson.actionBody.orderSnapshot.subjectType != 'undefined') {
params.baseInfo.subjectType = datajson.actionBody.orderSnapshot.subjectType; //代理记账主体类型
}
if (datajson.actionBody.orderSnapshot.companyName && datajson.actionBody.orderSnapshot.companyName != 'undefined') {
params.baseInfo.companyName = datajson.actionBody.orderSnapshot.companyName; //公司名称
params.companyInfo.companyName = datajson.actionBody.orderSnapshot.companyName;
} else if (datajson.actionBody.orderSnapshot.company && datajson.actionBody.orderSnapshot.company != 'undefined') {
params.baseInfo.companyName = datajson.actionBody.orderSnapshot.company; //公司名称
params.companyInfo.companyName = datajson.actionBody.orderSnapshot.company;
}
if (datajson.actionBody.orderSnapshot.companyProperties && datajson.actionBody.orderSnapshot.companyProperties != 'undefined') {
params.companyInfo.companyPropertiesName = datajson.actionBody.orderSnapshot.companyProperties; //公司性质名称
} else if (datajson.actionBody.orderSnapshot.companyType && datajson.actionBody.orderSnapshot.companyType != 'undefined') {
params.companyInfo.companyPropertiesName = datajson.actionBody.orderSnapshot.companyType; //公司性质名称
} else if (datajson.actionBody.orderSnapshot.registeredName && datajson.actionBody.orderSnapshot.registeredName != 'undefined') {
params.companyInfo.companyPropertiesName = datajson.actionBody.orderSnapshot.registeredName; //公司性质名称
}
if (datajson.actionBody.orderSnapshot.fullAddress && datajson.actionBody.orderSnapshot.fullAddress != 'undefined') {
params.companyInfo.fullAddress = datajson.actionBody.orderSnapshot.fullAddress; //详细地址
} else if (datajson.actionBody.orderSnapshot.residenceAddress && datajson.actionBody.orderSnapshot.residenceAddress != 'undefined') {
params.companyInfo.fullAddress = datajson.actionBody.orderSnapshot.residenceAddress; //详细地址
}
if (datajson.actionBody.orderSnapshot.virtualPrice && datajson.actionBody.orderSnapshot.virtualPrice != 'undefined') {
params.companyInfo.virtualPrice = datajson.actionBody.orderSnapshot.virtualPrice; //虚拟地址价格
params.baseInfo.virtualPrice = datajson.actionBody.orderSnapshot.virtualPrice; //虚拟地址价格
}
if (datajson.actionBody.orderSnapshot.residenceAddress && datajson.actionBody.orderSnapshot.residenceAddress != 'undefined') {
params.companyInfo.residenceAddress = datajson.actionBody.orderSnapshot.residenceAddress; //zhusuo
}
if (datajson.actionBody.orderSnapshot.engagedIndustry && datajson.actionBody.orderSnapshot.engagedIndustry != 'undefined') {
params.companyInfo.engagedIndName = datajson.actionBody.orderSnapshot.engagedIndustry; //从事行业名称
}
if (datajson.actionBody.orderSnapshot.businessScope && datajson.actionBody.orderSnapshot.businessScope != 'undefined') {
params.companyInfo.businessScope = datajson.actionBody.orderSnapshot.businessScope; //经营范围
}
if (datajson.actionBody.orderSnapshot.operatingPeriod && datajson.actionBody.orderSnapshot.operatingPeriod != 'undefined') {
params.companyInfo.operatingPeriod = datajson.actionBody.orderSnapshot.operatingPeriod; //经营期限
}
if (datajson.actionBody.orderSnapshot.businessTerm && datajson.actionBody.orderSnapshot.businessTerm != 'undefined') {
params.companyInfo.businessTerm = datajson.actionBody.orderSnapshot.businessTerm; //经营期限
}
if (datajson.actionBody.orderSnapshot.registeredCapital && datajson.actionBody.orderSnapshot.registeredCapital != 'undefined') {
params.companyInfo.registeredCapital = datajson.actionBody.orderSnapshot.registeredCapital; //注册资本
}
if (datajson.actionBody.orderSnapshot.creditCode && datajson.actionBody.orderSnapshot.creditCode != 'undefined') {
params.companyInfo.creditCode = datajson.actionBody.orderSnapshot.creditCode; //统一社会信用代码
}
if (datajson.actionBody.orderSnapshot.establishedTime && datajson.actionBody.orderSnapshot.establishedTime != 'undefined') {
params.companyInfo.establishedTime = datajson.actionBody.orderSnapshot.establishedTime; //成立时间
}
if (datajson.actionBody.orderSnapshot.shareholderName && datajson.actionBody.orderSnapshot.shareholderName != 'undefined') {
params.companyInfo.shareholderName = datajson.actionBody.orderSnapshot.shareholderName; //法人代表
}
var rtn = await rc.execPost3({ "d": params }, requrl);
var j = JSON.parse(rtn.stdout);
console.log("j---------------------------------" + rtn.stdout);
var j1 = 0;
if (params.businessMode && params.businessMode != 'undefined') {
var stau = {
"businessMode": params.businessMode,
"currentStatus": "isFinished",
"statusReason": ""
}
rtn = await rc.execPost3({ "d": stau }, bizurl); //更新商机状态为已完成
j1 = JSON.parse(rtn.stdout);
console.log("j1---------------------------------" + rtn.stdout);
} var rtn = await rc.execPost3({ "d": params }, requrl);
if (j.status == 0 && j1.status == 0) { var j = JSON.parse(rtn.stdout);
await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180); console.log("j---------------------------------" + rtn.stdout);
//给业务员发信息 var j1 = 0;
var msg = { if (params.businessMode && params.businessMode != 'undefined') {
"title": "你有新的交付单，请尽快处理", var stau = {
"content": "交付单编号" + params.deliverNumber + ",产品类型是" + params.businessName + ",服务地区是" + params.serviceName, "businessMode": params.businessMode,
"sender": "管理员", "currentStatus": "isFinished",
"sender_id": 0, "statusReason": ""
"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"
}
this.msgService.create(msg);
return {
"status": 1, //1代表成功，否则失败
"msg": "",
"data": "",
"requestId": ""
}
} else {
return j;
}
}
} }
} catch (error) { rtn = await rc.execPost3({ "d": stau }, bizurl); //更新商机状态为已完成
console.log("error-------------------------------------" + error); j1 = JSON.parse(rtn.stdout);
return system.getResultError(error); console.log("j1---------------------------------" + rtn.stdout);
}
}
//关闭交付单处理 }
async orderClose(datajson) { if (j.status == 0 && j1.status == 0) {
console.log("put in queue", datajson); await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180);
try { //给业务员发信息
var cachestr = sha235(JSON.stringify(datajson)); var msg = {
var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr); "title": "你有新的交付单，请尽快处理",
if (cacheInfo && cacheInfo != 'undefined') { "content": "交付单编号" + params.deliverNumber + ",产品类型是" + params.businessName + ",服务地区是" + params.serviceName,
return { "sender": "管理员",
"status": 1, //1代表成功，否则失败 "sender_id": 0,
"msg": "已处理成功!", "msgType": "single",
"data": "", "target": { "id": params.clerkId, "name": params.clerkName },
"requestId": "" }
} 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 { } else {
var rc = system.getObject("util.execClient"); msg.app_key = "42d814c1-4daa-4643-88b2-f5dd3ec853f3";
var requrl = this.icUrl + "/deliverybillCtl/updateStatusByDeliverCode"; msg.jump_address = "myDeliver"
var params = { }
"d": { this.msgService.create(msg);
"deliverNumber": datajson.actionBody.orderNum, return {
"deliverStatus": "closed", "status": 1, //1代表成功，否则失败
"statusReason": datajson.actionBody.refusalContent "msg": "",
} "data": "",
} "requestId": ""
var rtn = await rc.execPost3(params, requrl);
var j = JSON.parse(rtn.stdout);
if (j.status == 0) {
await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180); //插入缓存
//给业务员发信息
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);
console.log("jj-------------------------" + rtn.stdout);
if (jj.status == 0 && jj.data) {
var msg = {
"title": "你有关闭的交付单，请尽快处理",
"content": "交付单编号" + jj.data.delivery_code + ",产品类型是" + jj.data.product_name,
"sender": "管理员",
"sender_id": 0,
"msgType": "single",
"target": { "id": jj.data.delivery_man_id, "name": jj.data.delivery_man_name },
}
if (jj.data.product_code == "ICP" || jj.data.product_code == "EDI" || jj.data.product_code == "ICPANNUALREPORT" || jj.data.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"
}
this.msgService.create(msg);
}
return {
"status": 1, //1代表成功，否则失败
"msg": "",
"data": "",
"requestId": ""
}
} else {
return j;
}
} }
} catch (error) { } else {
return system.getResultError(error); return j;
}
} }
}
} catch (error) {
console.log("error-------------------------------------" + error);
return system.getResultError(error);
} }
}
async ServiceCreate(datajson) { //获取融易算服务实例到队列 //关闭交付单处理
try { async orderClose(datajson) {
var rc = system.getObject("util.execClient"); console.log("put in queue", datajson);
var requrl = this.queueUrl; try {
var params = { var cachestr = sha235(JSON.stringify(datajson));
"actionType": "produceData", var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr);
"actionBody": { if (cacheInfo && cacheInfo != 'undefined') {
"pushUrl": this.bookUrl + "/deliverybillCtl", return {
"actionType": "insertInfo", "status": 1, //1代表成功，否则失败
"identifyCode": "book-manage", "msg": "已处理成功!",
"messageBody": datajson, "data": "",
"headData": { "requestId": ""
'Authorization': 'Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJvcnpaWmhXRXBKNVVFZzRZUU5uUmlyVEJXa1FQbnZ6UyIsImlhdCI6MTU5MjcwOTYzNn0.TWk_F6Tz3fRMqspoG24VSt5RiC4ldFembFYcLcAbowE', }
'XAPPKEY': '647a68c9-da01-40d3-9763-1ffa0f64cf3f' } else {
} var rc = system.getObject("util.execClient");
} var requrl = this.icUrl + "/deliverybillCtl/updateStatusByDeliverCode";
} var params = {
var rtn = await rc.execPost(params, requrl); "d": {
var j = JSON.parse(rtn.stdout); "deliverNumber": datajson.actionBody.orderNum,
if (j.status == 1) { "deliverStatus": "closed",
return { "statusReason": datajson.actionBody.refusalContent
"requestId": datajson.requestId, }
"success": true, }
"errorCode": 0, var rtn = await rc.execPost3(params, requrl);
"errorMsg": "ok", var j = JSON.parse(rtn.stdout);
"data": null if (j.status == 0) {
} await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180); //插入缓存
} else {
return {
"requestId": datajson.requestId,
"success": false,
"errorCode": -1,
"errorMsg": rtn.stderr,
"data": null
}
}
} catch (error) { //给业务员发信息
return { var selUrl = this.icUrl + "/deliverybillCtl/findInfoByDeliverCode";
"requestId": datajson.requestId, var selpar = {
"success": false, "d": {
"errorCode": -1, "deliverNumber": datajson.actionBody.orderNum
"errorMsg": error, }
"data": null }
} rtn = await rc.execPost3(selpar, selUrl);
var jj = JSON.parse(rtn.stdout);
console.log("jj-------------------------" + rtn.stdout);
if (jj.status == 0 && jj.data) {
var msg = {
"title": "你有关闭的交付单，请尽快处理",
"content": "交付单编号" + jj.data.delivery_code + ",产品类型是" + jj.data.product_name,
"sender": "管理员",
"sender_id": 0,
"msgType": "single",
"target": { "id": jj.data.delivery_man_id, "name": jj.data.delivery_man_name },
} }
if (jj.data.product_code == "ICP" || jj.data.product_code == "EDI" || jj.data.product_code == "ICPANNUALREPORT" || jj.data.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"
}
this.msgService.create(msg);
}
return {
"status": 1, //1代表成功，否则失败
"msg": "",
"data": "",
"requestId": ""
}
} else {
return j;
} }
// async createLeads(datajson) {//财税需求处理 }
// try { } catch (error) {
// var cachestr = sha235(JSON.stringify(datajson)); return system.getResultError(error);
// var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr); }
// if (cacheInfo && cacheInfo != 'undefined') {
// return {
// "status": 1, //1代表成功，否则失败
// "msg": "已处理成功!",
// "data": "",
// "requestId": ""
// }
// }
// else {
// var rc = system.getObject("util.execClient");
// var requrl = this.icUrl + "/bizoptCtl/insertInfo";//这个地方要改
// var params = {
// "businessMode": datajson.actionBody.NeedNum,//需求编号
// "servicerName": datajson.actionBody.ServicerName,//服务商编码
// "serviceCode": datajson.actionBody.RegionId,//服务地区编码
// "serviceName": datajson.actionBody.RegionName,//服务地区名字,需要转换
// //"contactsName": datajson.actionBody.ContactsName,
// "contactsPhone": datajson.actionBody.ContactsMobile,//联系人电话
// "businessType": datajson.actionBody.ConsultType,//需求类型
// "businessName": datajson.actionBody.ConsultTypeName,//需求名称
// "currentStatus": "beforeSubmission",
// "channelSource": "tencentCloud",//渠道
// "channelNumber": "tx"
// }
// } }
// }
// catch (error) {
// return system.getResultError(error);
// }
// } async ServiceCreate(datajson) { //获取融易算服务实例到队列
async LeadsCreate(datajson) { try {
try { var rc = system.getObject("util.execClient");
var rc = system.getObject("util.execClient"); var requrl = this.queueUrl;
var requrl = this.queueUrl //改队列 var params = {
var params = { "actionType": "produceData",
"actionType":   "produceData", "actionBody": {
"actionBody":  {           "pushUrl": this.bookUrl + "/deliverybillCtl",
"pushUrl":  this.icUrl  +  "/bizOptCtl", "actionType": "insertInfo",
"actionType":   "insertInfo", "identifyCode": "book-manage",
"identifyCode":   "book-manage", "messageBody": datajson,
"messageBody":  datajson, "headData": {
"headData": null // 'Authorization': 'Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJvcnpaWmhXRXBKNVVFZzRZUU5uUmlyVEJXa1FQbnZ6UyIsImlhdCI6MTU5MjcwOTYzNn0.TWk_F6Tz3fRMqspoG24VSt5RiC4ldFembFYcLcAbowE',
}, 'XAPPKEY': '647a68c9-da01-40d3-9763-1ffa0f64cf3f'
"requestId": datajson.requestId }
} }
var  rtn  =  await  rc.execPost(params,  requrl);       }
var  j  =  JSON.parse(rtn.stdout);       var rtn = await rc.execPost(params, requrl);
if  (j.status  ==  1)  {         var j = JSON.parse(rtn.stdout);
return  system.getResult("获取数据成功！");       if (j.status == 1) {
}       return {
else  {         "requestId": datajson.requestId,
return  system.getResultError("获取数据失败！");       "success": true,
} "errorCode": 0,
} catch (error) { "errorMsg": "ok",
return system.getResultError(error) "data": null
}
} else {
return {
"requestId": datajson.requestId,
"success": false,
"errorCode": -1,
"errorMsg": rtn.stderr,
"data": null
}
}
} catch (error) {
return {
"requestId": datajson.requestId,
"success": false,
"errorCode": -1,
"errorMsg": error,
"data": null
}
}
}
//获取融易算服务实例到队列 进行数据更新
async ServiceUpdate(datajson) {
try {
var rc = system.getObject("util.execClient");
var requrl = this.queueUrl;
var params = {
"actionType": "produceData",
"actionBody": {
"pushUrl": this.bookUrl + "/deliverybillCtl",
"actionType": "updateServer",
"identifyCode": "book-manage",
"messageBody": datajson,
"headData": {
'Authorization': 'Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJvcnpaWmhXRXBKNVVFZzRZUU5uUmlyVEJXa1FQbnZ6UyIsImlhdCI6MTU5MjcwOTYzNn0.TWk_F6Tz3fRMqspoG24VSt5RiC4ldFembFYcLcAbowE',
'XAPPKEY': '647a68c9-da01-40d3-9763-1ffa0f64cf3f'
}
}
}
var rtn = await rc.execPost(params, requrl);
var j = JSON.parse(rtn.stdout);
if (j.status == 1) {
return {
"requestId": datajson.requestId,
"success": true,
"errorCode": 0,
"errorMsg": "ok",
"data": null
} }
} else {
return {
"requestId": datajson.requestId,
"success": false,
"errorCode": -1,
"errorMsg": rtn.stderr,
"data": null
}
}
} catch (error) {
return {
"requestId": datajson.requestId,
"success": false,
"errorCode": -1,
"errorMsg": error,
"data": null
}
} }
}
async LeadsCreate(datajson) {
try {
var rc = system.getObject("util.execClient");
var requrl = this.queueUrl //改队列
var params = {
"actionType": "produceData",
"actionBody": {
"pushUrl": this.icUrl + "/bizOptCtl",
"actionType": "insertInfo",
"identifyCode": "book-manage",
"messageBody": datajson,
"headData": null //
},
"requestId": datajson.requestId
}
var rtn = await rc.execPost(params, requrl);
var j = JSON.parse(rtn.stdout);
if (j.status == 1) {
return system.getResult("获取数据成功！");
}
else {
return system.getResultError("获取数据失败！");
}
} catch (error) {
return system.getResultError(error)
}
}
} }
module.exports = new TxHandler(); module.exports = new TxHandler();
// var task = new TxHandler();
// var obj = {
// "requestId": "825da0a74432-738f-4bed-b48d-d51aa808",
// "bizId": "5892748825",
// "contactsPhone": "18510669321",
// "userId": "10973452443103825",
// "orderId": "341184456620496_book",
// "areatype": "city",
// "area": "100010",
// "topOrgCode": "rong_yi_suan",
// "taxpayerType": 1,
// "product_code": "bookkeeping",
// "product_name": "代账服务",
// "service_address": "110100",
// "delivery_status": "waituserconfirm",
// "facilitator_id": "10"
// }
// task.ServiceCreate(obj, {}, {}).then(d => {
// console.log(JSON.stringify(d));
// })
// (async () => { // (async () => {
// var task = new TxHandler(); // var task = new TxHandler();
// var obj = { // var obj = {
...@@ -657,4 +690,4 @@ module.exports = new TxHandler(); ...@@ -657,4 +690,4 @@ module.exports = new TxHandler();
// console.log("ddddddddddddd"); // console.log("ddddddddddddd");
// console.log(JSON.stringify(d)); // console.log(JSON.stringify(d));
// console.log("dddddddddddddd"); // console.log("dddddddddddddd");
// })() // })()
\ No newline at end of file
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