Skip to content

Z
zhichan
Commit 37b0861b by 王勇飞
Options

gyq

parent 50bf868d
Showing with 100 additions and 78 deletions
center-manage/app/base/service/impl/common/channelhandlers/tx.js
var system = require("../../../../system"); var system = require("../../../../system");
const sha235 = require("sha256"); const sha235 = require("sha256");
var settings = require("../../../../../config/settings");
class TxHandler { class TxHandler {
constructor() { constructor() {
this.icUrl = "http://ic.com:8000/web/bizchance"; this.icUrl = settings.icUrl() + "/web/bizchance";
this.userService = system.getObject("service.auth.userSve"); this.userService = system.getObject("service.auth.userSve");
this.cacheManager = system.getObject("db.common.cacheManager"); this.cacheManager = system.getObject("db.common.cacheManager");
} }
...@@ -48,7 +49,7 @@ class TxHandler { ...@@ -48,7 +49,7 @@ class TxHandler {
if (datajson.actionBody.CompanyName && datajson.actionBody.CompanyName != 'undefined') { if (datajson.actionBody.CompanyName && datajson.actionBody.CompanyName != 'undefined') {
params.companyName = datajson.actionBody.CompanyName; params.companyName = datajson.actionBody.CompanyName;
} }
if (datajson.actionBody.UserName && datajson.actionBody.UserName != 'undefined'){ if (datajson.actionBody.UserName && datajson.actionBody.UserName != 'undefined') {
params.UserName = datajson.actionBody.UserName; params.UserName = datajson.actionBody.UserName;
} }
if (salesmanInfo && salesmanInfo != 'undefined') { if (salesmanInfo && salesmanInfo != 'undefined') {
...@@ -56,7 +57,7 @@ class TxHandler { ...@@ -56,7 +57,7 @@ class TxHandler {
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);
...@@ -154,12 +155,13 @@ class TxHandler { ...@@ -154,12 +155,13 @@ class TxHandler {
//获取分配的业务员信息 //获取分配的业务员信息
var ConsultTypeName = ""; var ConsultTypeName = "";
console.log("productTypeName-----------------------------" + datajson.actionBody.productTypeName); console.log("productTypeName-----------------------------" + datajson.actionBody.productTypeName);
if (datajson.actionBody.productTypeName && datajson.actionBody.productTypeName != 'undefined'){ if (datajson.actionBody.productTypeName && datajson.actionBody.productTypeName != 'undefined') {
ConsultTypeName = datajson.actionBody.productTypeName.split("/")[2]; ConsultTypeName = datajson.actionBody.productTypeName.split("/")[2];
} }
console.log("ConsultTypeName-----------------------------" + ConsultTypeName); console.log("ConsultTypeName-----------------------------" + ConsultTypeName);
var salesmanInfo = await this.userService.getBizUserForDelivery(datajson.actionBody.orderSnapshot.contactsPhone, datajson.actionBody.servicerName, ConsultTypeName, datajson.actionBody.txPriceCode, datajson.actionBody.regionName); 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"; requrl = this.icUrl + "/deliverybillCtl/insertInfo";
var bizurl = this.icUrl + "/bizoptCtl/updateStatusByDemandCode";
var params = { var params = {
"deliverNumber": datajson.actionBody.orderNum, "deliverNumber": datajson.actionBody.orderNum,
"servicerName": datajson.actionBody.servicerName, "servicerName": datajson.actionBody.servicerName,
...@@ -168,7 +170,7 @@ class TxHandler { ...@@ -168,7 +170,7 @@ class TxHandler {
"businessType": datajson.actionBody.productType, "businessType": datajson.actionBody.productType,
"businessName": ConsultTypeName, "businessName": ConsultTypeName,
"skuCode": datajson.actionBody.txPriceCode, "skuCode": datajson.actionBody.txPriceCode,
"txOrderNum":datajson.actionBody.txOrderNum, "txOrderNum": datajson.actionBody.txOrderNum,
"baseInfo": { "baseInfo": {
"txOrderNum": datajson.actionBody.txOrderNum, "txOrderNum": datajson.actionBody.txOrderNum,
"isAdviser": "已分配",//是否分配顾问 "isAdviser": "已分配",//是否分配顾问
...@@ -184,13 +186,18 @@ class TxHandler { ...@@ -184,13 +186,18 @@ class TxHandler {
} }
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 (datajson.actionBody.orderSnapshot.servicerCode && datajson.actionBody.orderSnapshot.servicerCode != 'undefined') {
params.serviceCode = datajson.actionBody.orderSnapshot.servicerCode;//fuwushang id
}
} }
if (datajson.actionBody.orderSnapshot.needNum && datajson.actionBody.orderSnapshot.needNum != 'undefined') { if (datajson.actionBody.orderSnapshot.needNum && datajson.actionBody.orderSnapshot.needNum != 'undefined') {
params.businessMode = datajson.actionBody.orderSnapshot.needNum;//商机编号 params.businessMode = datajson.actionBody.orderSnapshot.needNum;//商机编号
...@@ -244,7 +251,7 @@ class TxHandler { ...@@ -244,7 +251,7 @@ class TxHandler {
if (datajson.actionBody.orderSnapshot.whetherType && datajson.actionBody.orderSnapshot.whetherType != 'undefined') { if (datajson.actionBody.orderSnapshot.whetherType && datajson.actionBody.orderSnapshot.whetherType != 'undefined') {
params.baseInfo.whetherType = datajson.actionBody.orderSnapshot.whetherType;//刻章类型 params.baseInfo.whetherType = datajson.actionBody.orderSnapshot.whetherType;//刻章类型
} }
if (datajson.actionBody.orderSnapshot.hasOwnProperty("annualReport")){//年报信息 if (datajson.actionBody.orderSnapshot.hasOwnProperty("annualReport")) {//年报信息
params.baseInfo.annualReport = datajson.actionBody.orderSnapshot.annualReport; params.baseInfo.annualReport = datajson.actionBody.orderSnapshot.annualReport;
} }
if (datajson.actionBody.orderSnapshot.hasOwnProperty("addressType")) {//注册地址类型 if (datajson.actionBody.orderSnapshot.hasOwnProperty("addressType")) {//注册地址类型
...@@ -272,7 +279,7 @@ class TxHandler { ...@@ -272,7 +279,7 @@ class TxHandler {
params.companyInfo.fullAddress = datajson.actionBody.orderSnapshot.fullAddress;//详细地址 params.companyInfo.fullAddress = datajson.actionBody.orderSnapshot.fullAddress;//详细地址
} }
if (datajson.actionBody.orderSnapshot.residenceAddress && datajson.actionBody.orderSnapshot.residenceAddress != 'undefined') { if (datajson.actionBody.orderSnapshot.residenceAddress && datajson.actionBody.orderSnapshot.residenceAddress != 'undefined') {
params.companyInfo.fullAddress = datajson.actionBody.orderSnapshot.residenceAddress;//详细地址 params.companyInfo.residenceAddress = datajson.actionBody.orderSnapshot.residenceAddress;//zhusuo
} }
if (datajson.actionBody.orderSnapshot.engagedIndustry && datajson.actionBody.orderSnapshot.engagedIndustry != 'undefined') { if (datajson.actionBody.orderSnapshot.engagedIndustry && datajson.actionBody.orderSnapshot.engagedIndustry != 'undefined') {
params.companyInfo.engagedIndName = datajson.actionBody.orderSnapshot.engagedIndustry;//从事行业名称 params.companyInfo.engagedIndName = datajson.actionBody.orderSnapshot.engagedIndustry;//从事行业名称
...@@ -284,7 +291,7 @@ class TxHandler { ...@@ -284,7 +291,7 @@ class TxHandler {
params.companyInfo.operatingPeriod = datajson.actionBody.orderSnapshot.operatingPeriod;//经营期限 params.companyInfo.operatingPeriod = datajson.actionBody.orderSnapshot.operatingPeriod;//经营期限
} }
if (datajson.actionBody.orderSnapshot.businessTerm && datajson.actionBody.orderSnapshot.businessTerm != 'undefined') { if (datajson.actionBody.orderSnapshot.businessTerm && datajson.actionBody.orderSnapshot.businessTerm != 'undefined') {
params.companyInfo.operatingPeriod = datajson.actionBody.orderSnapshot.businessTerm;//经营期限 params.companyInfo.businessTerm = datajson.actionBody.orderSnapshot.businessTerm;//经营期限
} }
if (datajson.actionBody.orderSnapshot.registeredCapital && datajson.actionBody.orderSnapshot.registeredCapital != 'undefined') { if (datajson.actionBody.orderSnapshot.registeredCapital && datajson.actionBody.orderSnapshot.registeredCapital != 'undefined') {
params.companyInfo.registeredCapital = datajson.actionBody.orderSnapshot.registeredCapital;//注册资本 params.companyInfo.registeredCapital = datajson.actionBody.orderSnapshot.registeredCapital;//注册资本
...@@ -301,8 +308,16 @@ class TxHandler { ...@@ -301,8 +308,16 @@ class TxHandler {
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("rtn---------------------------------" + rtn.stdout); console.log("j---------------------------------" + rtn.stdout);
if (j.status == 0) { var stau = {
"businessMode": params.businessMode,
"currentStatus": "isFinished",
"statusReason": ""
}
rtn = await rc.execPost3({ "d": stau }, bizurl);//更新商机状态为已完成
var j1 = SON.parse(rtn.stdout);
console.log("j1---------------------------------" + rtn.stdout);
if (j.status == 0 && j1.status == 0) {
await this.cacheManager["TxCache"].cache(cachestr, null, 1200000); await this.cacheManager["TxCache"].cache(cachestr, null, 1200000);
return { return {
"status": 1, //1代表成功，否则失败 "status": 1, //1代表成功，否则失败
......
center-manage/app/config/settings.js
var path = require('path'); var path = require('path');
var localsettings=require("./localsettings"); var localsettings = require("./localsettings");
var ENVINPUT={ var ENVINPUT = {
KONG_ADMIAN:process.env.KONG_ADMIAN, KONG_ADMIAN: process.env.KONG_ADMIAN,
DB_HOST:process.env.DB_HOST, DB_HOST: process.env.DB_HOST,
DB_PORT:process.env.DB_PORT, DB_PORT: process.env.DB_PORT,
DB_USER:process.env.DB_USER, DB_USER: process.env.DB_USER,
DB_PWD:process.env.DB_PWD, DB_PWD: process.env.DB_PWD,
DB_NAME:process.env.PAAS_DB_NAME, DB_NAME: process.env.PAAS_DB_NAME,
REDIS_HOST:process.env.REDIS_HOST, REDIS_HOST: process.env.REDIS_HOST,
REDIS_PORT:process.env.REDIS_PORT, REDIS_PORT: process.env.REDIS_PORT,
REDIS_PWD:process.env.REDIS_PWD, REDIS_PWD: process.env.REDIS_PWD,
REDIS_DB:process.env.PAAS_REDIS_DB, REDIS_DB: process.env.PAAS_REDIS_DB,
APP_ENV:process.env.APP_ENV?process.env.APP_ENV:"dev" APP_ENV: process.env.APP_ENV ? process.env.APP_ENV : "dev"
}; };
var settings = { var settings = {
env:ENVINPUT.APP_ENV, env: ENVINPUT.APP_ENV,
salt: "%iatpD1gcxz7iF#B", salt: "%iatpD1gcxz7iF#B",
defaultpwd:"gsb2020", defaultpwd: "gsb2020",
basepath : path.normalize(path.join(__dirname, '../..')), basepath: path.normalize(path.join(__dirname, '../..')),
port : process.env.NODE_PORT || 80, port: process.env.NODE_PORT || 80,
kongurl : function(){ kongurl: function () {
if(this.env=="dev"){ if (this.env == "dev") {
return localsettings.kongurl; return localsettings.kongurl;
}else { } else {
return ENVINPUT.KONG_ADMIAN; return ENVINPUT.KONG_ADMIAN;
} }
}, },
pmappname:"center-app", icUrl: function () {
pmappid:1, if (this.env == "dev") {
pmcompanyid:1, return "http://ic.com:8000";
pmroleid:{"ta":1,"pr":2}, } else {
redis:function(){ return "http://icdeliver-service";
if(this.env=="dev"){ }
},
pmappname: "center-app",
pmappid: 1,
pmcompanyid: 1,
pmroleid: { "ta": 1, "pr": 2 },
redis: function () {
if (this.env == "dev") {
return localsettings.redis; return localsettings.redis;
}else { } else {
return { return {
host:ENVINPUT.REDIS_HOST, host: ENVINPUT.REDIS_HOST,
port:ENVINPUT.REDIS_PORT, port: ENVINPUT.REDIS_PORT,
password:ENVINPUT.REDIS_PWD, password: ENVINPUT.REDIS_PWD,
db:ENVINPUT.REDIS_DB, db: ENVINPUT.REDIS_DB,
}; };
} }
}, },
database:function(){ database: function () {
if(this.env=="dev"){ if (this.env == "dev") {
var localsettings=require("./localsettings"); var localsettings = require("./localsettings");
return localsettings.database; return localsettings.database;
}else{ } else {
return { return {
dbname : ENVINPUT.DB_NAME, dbname: ENVINPUT.DB_NAME,
user : ENVINPUT.DB_USER, user: ENVINPUT.DB_USER,
password : ENVINPUT.DB_PWD, password: ENVINPUT.DB_PWD,
config : { config: {
host: ENVINPUT.DB_HOST, host: ENVINPUT.DB_HOST,
dialect: 'mysql', dialect: 'mysql',
operatorsAliases: false, operatorsAliases: false,
pool: { pool: {
max: 5, max: 5,
min: 0, min: 0,
acquire: 90000000, acquire: 90000000,
idle: 1000000 idle: 1000000
}, },
debug:false, debug: false,
timezone:'+08:00', timezone: '+08:00',
dialectOptions:{ dialectOptions: {
requestTimeout: 999999, requestTimeout: 999999,
// instanceName:'DEV' // instanceName:'DEV'
} //设置MSSQL超时时间 } //设置MSSQL超时时间
}, },
}; };
} }
} }
}; };
settings.ENVINPUT=ENVINPUT; settings.ENVINPUT = ENVINPUT;
module.exports = settings; module.exports = settings;
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