feat: 商机回调

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

@@ -114,6 +114,7 @@ class AliHandler {
         var j = JSON.parse(rtn.stdout);
         var j = JSON.parse(rtn.stdout);
         if (j.status == 0) {
         if (j.status == 0) {
           j.status = 1;
           j.status = 1;
+          await this.cacheManager["AliCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180000);//插入redis缓存
         }
         }
         return j
         return j
       }
       }
@@ -122,6 +123,37 @@ class AliHandler {
     }
     }
   }
   }
 
 
+  /**
+   * 商机批次 
+   * @param {*} datajson 
+   */
+  async batchChanceCallback(datajson) {
+    console.log("put in queue  [batchChanceCallback]", datajson);
+    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 {
+        // TODO: 回调写库
+        await this.cacheManager["AliCache"].cache(cachestr, JSON.stringify({ cachestr: cachestr }), 180000);//插入redis缓存
+        return {
+          "status": 1,    //1代表成功，否则失败
+          "msg": "处理成功!",
+          "data": "",
+          "requestId": ""
+        }
+      }
+    } catch (error) {
+      return system.getResultError(error);
+    }
+  }
+
 
 
   //退回商机处理
   //退回商机处理
   async needClose(datajson) {
   async needClose(datajson) {