Skip to content

Z
zhichan
Commit 851c1106 by 王勇飞
Options

gyq

parent 9a557a21
Showing with 129 additions and 14 deletions
center-manage/app/base/db/cache/aliCache.js 0 → 100644
const CacheBase = require("../cache.base");
const system = require("../../system");
const settings = require("../../../config/settings");
class AliCache extends CacheBase {
constructor() {
super();
//this.userDao = system.getObject("db.auth.userDao");
}
isdebug() {
return settings.env == "dev";
}
desc() {
return "缓存缓存腾讯队列信息";
}
prefix() {
return "g_aliInfo_cm:"
}
async buildCacheVal(cachekey, inputkey, val, ex, ...items) {
if (val) {
return val;
}
return null;
}
}
module.exports = AliCache;
\ No newline at end of file
center-manage/app/base/service/impl/common/channelhandlers/ali.js
...@@ -64,13 +64,13 @@ class AliHandler { ...@@ -64,13 +64,13 @@ class AliHandler {
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) { if (j.status == 1) {
await this.cacheManager["AliCache"].cache(cachestr, null, 1200000);//插入redis缓存 await this.cacheManager["AliCache"].cache(cachestr, null, 600000);//插入redis缓存
//给业务员发信息 //给业务员发信息
var msg = { var msg = {
"title": "你有新的商机，请尽快处理", "title": "你有新的商机，请尽快处理",
"content": "商机编号" + params.businessMode + ",商机类型是" + params.businessName + ",服务地区是" + params.serviceName, "content": "商机编号" + params.businessMode + ",商机类型是" + params.businessName + ",服务地区是" + params.serviceName,
"sender": "管理员", "sender": "管理员",
"sender_id":0, "sender_id": 0,
"msgType": "single", "msgType": "single",
"target": { "id": params.salesmanId, "name": params.clerkName }, "target": { "id": params.salesmanId, "name": params.clerkName },
} }
...@@ -123,7 +123,7 @@ class AliHandler { ...@@ -123,7 +123,7 @@ class AliHandler {
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["AliCache"].cache(cachestr, null, 1200000);//插入缓存 await this.cacheManager["AliCache"].cache(cachestr, null, 600000);//插入缓存
//给业务员发信息 //给业务员发信息
var selUrl = this.icUrl + "/schemeCtl/findInfoByDemandCode"; var selUrl = this.icUrl + "/schemeCtl/findInfoByDemandCode";
...@@ -135,12 +135,12 @@ class AliHandler { ...@@ -135,12 +135,12 @@ class AliHandler {
rtn = await rc.execPost3(selpar, selUrl); rtn = await rc.execPost3(selpar, selUrl);
var jj = JSON.parse(rtn.stdout); var jj = JSON.parse(rtn.stdout);
console.log("jj------------------------------" + rtn.stdout); console.log("jj------------------------------" + rtn.stdout);
if (jj.status == 0 && jj.data){ if (jj.status == 0 && jj.data) {
var msg = { var msg = {
"title": "你有退回的商机，请尽快处理", "title": "你有退回的商机，请尽快处理",
"content": "商机编号" + jj.data.businessMode + ",商机类型是" + jj.data.businessName, "content": "商机编号" + jj.data.businessMode + ",商机类型是" + jj.data.businessName,
"sender": "管理员", "sender": "管理员",
"sender_id":0, "sender_id": 0,
"msgType": "single", "msgType": "single",
"target": { "id": jj.data.clerkId, "name": jj.data.clerkName }, "target": { "id": jj.data.clerkId, "name": jj.data.clerkName },
} }
...@@ -314,7 +314,7 @@ class AliHandler { ...@@ -314,7 +314,7 @@ class AliHandler {
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;
} }
else{ else {
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
} }
...@@ -400,13 +400,13 @@ class AliHandler { ...@@ -400,13 +400,13 @@ class AliHandler {
var j1 = JSON.parse(rtn.stdout); var j1 = JSON.parse(rtn.stdout);
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["AliCache"].cache(cachestr, null, 1200000); await this.cacheManager["AliCache"].cache(cachestr, null, 600000);
//给业务员发信息 //给业务员发信息
var msg = { var msg = {
"title": "你有新的交付单，请尽快处理", "title": "你有新的交付单，请尽快处理",
"content": "交付单编号" + params.deliverNumber + ",产品类型是" + params.businessName + ",服务地区是" + params.serviceName, "content": "交付单编号" + params.deliverNumber + ",产品类型是" + params.businessName + ",服务地区是" + params.serviceName,
"sender": "管理员", "sender": "管理员",
"sender_id":0, "sender_id": 0,
"msgType": "single", "msgType": "single",
"target": { "id": params.clerkId, "name": params.clerkName }, "target": { "id": params.clerkId, "name": params.clerkName },
} }
...@@ -465,24 +465,24 @@ class AliHandler { ...@@ -465,24 +465,24 @@ class AliHandler {
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["AliCache"].cache(cachestr, null, 1200000);//插入缓存 await this.cacheManager["AliCache"].cache(cachestr, null, 600000);//插入缓存
//给业务员发信息 //给业务员发信息
var selUrl = this.icUrl + "/deliverybillCtl/findInfoByDeliverCode"; var selUrl = this.icUrl + "/deliverybillCtl/findInfoByDeliverCode";
var selpar = { var selpar = {
"d":{ "d": {
"deliverNumber":datajson.actionBody.orderNum "deliverNumber": datajson.actionBody.orderNum
} }
} }
rtn = await rc.execPost3(selpar, selUrl); rtn = await rc.execPost3(selpar, selUrl);
var jj = JSON.parse(rtn.stdout); var jj = JSON.parse(rtn.stdout);
console.log("jj-------------------------" + rtn.stdout); console.log("jj-------------------------" + rtn.stdout);
if (jj.status ==0 && jj.data){ if (jj.status == 0 && jj.data) {
var msg = { var msg = {
"title": "你有关闭的交付单，请尽快处理", "title": "你有关闭的交付单，请尽快处理",
"content": "交付单编号" + jj.data.delivery_code + ",产品类型是" + jj.data.product_name, "content": "交付单编号" + jj.data.delivery_code + ",产品类型是" + jj.data.product_name,
"sender": "管理员", "sender": "管理员",
"sender_id":0, "sender_id": 0,
"msgType": "single", "msgType": "single",
"target": { "id": jj.data.salesman_id, "name": jj.data.salesman_name }, "target": { "id": jj.data.salesman_id, "name": jj.data.salesman_name },
} }
...@@ -496,7 +496,7 @@ class AliHandler { ...@@ -496,7 +496,7 @@ class AliHandler {
} }
await this.msgService.create(msg); await this.msgService.create(msg);
} }
return { return {
"status": 1, //1代表成功，否则失败 "status": 1, //1代表成功，否则失败
"msg": "", "msg": "",
...@@ -514,8 +514,97 @@ class AliHandler { ...@@ -514,8 +514,97 @@ class AliHandler {
} }
} }
//客户状态处理
async deliveryNotify(dtajson) {
try {
var cachestr = sha235(JSON.stringify(datajson));
var cacheInfo = await this.cacheManager["AliCache"].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/updateFileAndStatusByDelivertCode";
var params = {
"d": {
"deliverNumber": datajson.actionBody.orderNum,
"baseInfo": {}
// "deliverStatus": "closed",
// "statusReason": datajson.actionBody.refusalContent
}
}
title = "";
if (datajson.actionBody.status == "USER_CONFIRMED") {//用户已确认递交文件
title = "用户已确认递交文件";
params.d.deliverStatus = "userConfirmationResolve";
params.d.customerMaterial = datajson.actionBody.customerMaterial;
}
else if (datajson.actionBody.status == "CLOSE") {//方案关闭
title = "方案已关闭";
params.d.deliverStatus = "closed";
}
var rtn = await rc.execPost3(params, requrl);
var j = JSON.parse(rtn.stdout);
if (j.status == 0) {
await this.cacheManager["AliCache"].cache(cachestr, null, 600000);//插入缓存
//给业务员发信息
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": "你有"+ title +"的交付单，请尽快处理",
"content": "交付单编号" + jj.data.delivery_code + ",产品类型是" + jj.data.product_name,
"sender": "管理员",
"sender_id": 0,
"msgType": "single",
"target": { "id": jj.data.salesman_id, "name": jj.data.salesman_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"
}
await this.msgService.create(msg);
}
return {
"status": 1, //1代表成功，否则失败
"msg": "",
"data": "",
"requestId": ""
}
}
else {
return j;
}
}
}
catch (error) {
return system.getResultError(error);
}
}
} }
module.exports = new AliHandler(); module.exports = new AliHandler();
// (async ()=>{ // (async ()=>{
......
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