feat: 商机关闭推送

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

@@ -16,7 +16,7 @@ class AliHandler {
    */
    */
   //新商机处理
   //新商机处理
   async addChance(datajson) {
   async addChance(datajson) {
-    console.log("put in queue", datajson);
+    console.log("put in queue  [addChance]", datajson);
     try {
     try {
       var cachestr = sha235(JSON.stringify(datajson));
       var cachestr = sha235(JSON.stringify(datajson));
       var cacheInfo = await this.cacheManager["AliCache"].getCache(cachestr);
       var cacheInfo = await this.cacheManager["AliCache"].getCache(cachestr);
@@ -71,7 +71,7 @@ class AliHandler {
   }
   }
 
 
   async updateChanceStatus(datajson) {
   async updateChanceStatus(datajson) {
-    console.log("put in queue" + JSON.stringify(datajson) + "DDDDDDDDDDDDDDDDDDDDDDDDDDDDDDD");
+    console.log("put in queue  [updateChanceStatus]" + JSON.stringify(datajson) + "DDDDDDDDDDDDDDDDDDDDDDDDDDDDDDD");
     try {
     try {
       var cachestr = sha235(JSON.stringify(datajson));
       var cachestr = sha235(JSON.stringify(datajson));
       var cacheInfo = await this.cacheManager["AliCache"].getCache(cachestr);
       var cacheInfo = await this.cacheManager["AliCache"].getCache(cachestr);
@@ -86,10 +86,23 @@ class AliHandler {
         let { actionBody } = datajson;
         let { actionBody } = datajson;
         var rc = system.getObject("util.execClient");
         var rc = system.getObject("util.execClient");
         var requrl = this.icUrl + "/bizoptCtl/updateStatusByDemandCode";
         var requrl = this.icUrl + "/bizoptCtl/updateStatusByDemandCode";
-        var stau = {
+        var stau;
+        switch (actionBody.status) {
+          case "createSolution":
+            stau = {
               "businessMode": actionBody.intentionBizId,
               "businessMode": actionBody.intentionBizId,
               "currentStatus": "beforeConfirmation"
               "currentStatus": "beforeConfirmation"
             }
             }
+            break
+          case "closeNeed":
+            stau = {
+              "businessMode": actionBody.intentionBizId,
+              "currentStatus": "isClosed"
+            }
+            break
+          default:
+            return system.getResultError("status 状态值错误");
+        }
         let rtn = await rc.execPost3({ "d": stau }, requrl);//更新商机状态为已完成
         let rtn = await rc.execPost3({ "d": stau }, requrl);//更新商机状态为已完成
         var j = JSON.parse(rtn.stdout);
         var j = JSON.parse(rtn.stdout);
         return j
         return j