fix: 分配 更新状态 发送信息

center-manage/app/base/service/impl/common/channelhandlers/tx.js

@@ -14,7 +14,7 @@ class TxHandler {
    * @param {*} datajson 
    */
   //新商机处理
-  async addChance (datajson) {
+  async addChance(datajson) {
     console.log("put in queue", datajson);
     try {
       var cachestr = sha235(JSON.stringify(datajson));
@@ -71,6 +71,7 @@ class TxHandler {
         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,
@@ -89,6 +90,7 @@ class TxHandler {
             }
             this.msgService.create(msg);
           }
+        }
         return j;
       }
     }
@@ -101,7 +103,7 @@ class TxHandler {
   }
 
   //退回商机处理
-  async needClose (datajson) {
+  async needClose(datajson) {
     console.log("put in queue" + JSON.stringify(datajson) + "DDDDDDDDDDDDDDDDDDDDDDDDDDDDDDD");
     try {
       var cachestr = sha235(JSON.stringify(datajson));
@@ -141,6 +143,7 @@ class TxHandler {
           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,
@@ -159,6 +162,7 @@ class TxHandler {
               }
               this.msgService.create(msg);
             }
+          }
 
           return {
             "status": 1,    //1代表成功，否则失败
@@ -179,7 +183,7 @@ class TxHandler {
   }
 
   //交付单处理
-  async orderSubmit (datajson) {
+  async orderSubmit(datajson) {
     console.log("put in queue-----------------------------------------------------------------------------------------------------", datajson);
     try {
       var cachestr = sha235(JSON.stringify(datajson));
@@ -417,17 +421,22 @@ class TxHandler {
             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);//更新商机状态为已完成
-          var j1 = JSON.parse(rtn.stdout);
+            j1 = JSON.parse(rtn.stdout);
             console.log("j1---------------------------------" + rtn.stdout);
+
+          }
           if (j.status == 0 && j1.status == 0) {
             await this.cacheManager["TxCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180);
             //给业务员发信息
@@ -468,7 +477,7 @@ class TxHandler {
   }
 
   //关闭交付单处理
-  async orderClose (datajson) {
+  async orderClose(datajson) {
     console.log("put in queue", datajson);
     try {
       var cachestr = sha235(JSON.stringify(datajson));
@@ -544,8 +553,8 @@ class TxHandler {
 
   }
 
-  async createLeads(datajson){//财税需求处理
-    try{
+  async createLeads(datajson) {//财税需求处理
+    try {
       var cachestr = sha235(JSON.stringify(datajson));
       var cacheInfo = await this.cacheManager["TxCache"].getCache(cachestr);
       if (cacheInfo && cacheInfo != 'undefined') {
@@ -556,7 +565,7 @@ class TxHandler {
           "requestId": ""
         }
       }
-      else{
+      else {
         var rc = system.getObject("util.execClient");
         var requrl = this.icUrl + "/bizoptCtl/insertInfo";//这个地方要改
         var params = {
@@ -575,7 +584,7 @@ class TxHandler {
 
       }
     }
-    catch (error){
+    catch (error) {
       return system.getResultError(error);
     }