zzd

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

@@ -636,6 +636,63 @@ class TxHandler {
             return system.getResultError(error)
             return system.getResultError(error)
         }
         }
     }
     }
+
+    // 服务状态变更通知
+    async ServiceStatusNotify (datajson) {
+      try {
+  
+        let rc = system.getObject("util.execClient");
+        let requrl = this.queueUrl;
+
+        let ab = Object.assign({}, datajson);
+        ab.status = ab.status === 6 ? "inserivice" : "closed";
+        let params = {
+          "actionType": "produceData",
+          "actionBody": {
+            "pushUrl": this.icUrl + "/deliverybillCtl/notifyServiceStatusChange",
+            "actionType": "notifyServiceStatusChange",
+            "identifyCode": "book-manage",
+            "messageBody": ab,
+            "headData": {
+              'Authorization': 'Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjE1OTg0MzQ2ODcsImlzcyI6InJFRVN6TU5ZUlM2RnBWNnZlY09vdExPNWdPcUNXSmFQIiwiaWF0IjoxNTk4NDMxMDg3fQ.isQ40HqHHfJ-rTsUQOhRIdu4XCitZU-AfzeqSH4kPbQ',
+              'XAPPKEY': 'f6b59b74-f943-4735-bb86-e05d6b7fd78e'
+            }
+          }
+        };
+        
+        let rtn = await rc.execPost(params, requrl);
+        let j = JSON.parse(rtn.stdout);
+        if (j.status === 1) {
+          return this.getResult(datajson.requestId);
+        } else {
+          return this.getResult(datajson.requestId, rtn.stderr);
+        }
+  
+      } catch (err) {
+        return this.getResult(datajson.requestId, err);
+      }
+    }
+
+    async getResult (reqId, err = "not err") {
+      if (err === "not err") {
+        return {
+          "requestId": reqId,
+          "success": true,
+          "errorCode": 0,
+          "errorMsg": "ok",
+          "data": null
+        }
+      } else {
+        return {
+          "requestId": reqId,
+          "success": false,
+          "errorCode": -1,
+          "errorMsg": err,
+          "data": null
+        }
+      }
+    }
+
 }
 }
 
 
 module.exports = new TxHandler();
 module.exports = new TxHandler();