tj

fqboss/app/base/api/impl/tmsub.js

 var System = require("../../system");
 const logCtl = System.getObject("web.oplogCtl");
 const trademarkCtl = System.getObject("web.trademarkCtl");
+const settings = require("../../../config/settings");
 const md5 = require("MD5");
 class TmSub {
   constructor() {
@@ -282,6 +283,113 @@ class TmSub {
         }
       }
       if (actionProcess == "AliTm") {
+        var reqUrl = settings.channelApiUrl(actionProcess) + "/api/auth/accessAuth/getAppTokenByHosts";
+        var reqParam = {
+          "actionType": "getAppTokenByHosts",
+          "actionBody": {}
+        };
+        var rc = System.getObject("util.execClient");
+        var tokenReqResult = await rc.execPost(reqParam, reqUrl);
+        if (!tokenReqResult || !tokenReqResult.stdout) {
+          result.code = -150;
+        }
+        var tokenResult = JSON.parse(tokenReqResult.stdout);
+        if (tokenResult.status != 0) {
+          result.code = -150;
+        }
+        if (result.code == -150) {
+          var opResult = await this.opAliNotify(pobj.actionBody);
+          if (opResult.code != 1) {
+            this.oplogSve.createDb({
+              logLevel: "error",
+              optitle: "fq渠道商标状态通知DB异常---error",
+              op: "base/api/impl/tmsub/channelTmNotify",
+              content: JSON.stringify(pobj),
+              clientIp: ""
+            });
+            result.msg = "渠道商标状态通知异常";
+            result.message = "渠道商标状态通知异常";
+            return result;
+          }
+        }
+        reqUrl = settings.channelApiUrl(actionProcess) + "/api/action/tmTransaction/springBoard";
+        reqParam.actionType = "addPushContent";
+        reqParam.actionBody = {
+          pushUrl: settings.pushFqBossAliTmNotify(),
+          pushContent: pobj,
+        };
+        await rc.execPostTK(reqParam, reqUrl, tokenResult.data.token);
+      }
+      return result;
+    } catch (e) {
+      logCtl.error({
+        optitle: "fq渠道商标状态通知异常---error",
+        op: "base/api/impl/tmsub/channelTmNotify",
+        content: e.stack,
+        clientIp: ""
+      });
+      result.code = -200;
+      result.msg = "渠道商标状态通知异常：" + e.stack;
+    }
+    return result;
+  }
+  async channelTmNotifyByAli(pobj) {//渠道通知商标状态-用于阿里   
+    logCtl.info({
+      optitle: "渠道通知商标状态参数用于阿里---info",
+      op: "base/api/impl/tmsub/channelTmNotify",
+      content: JSON.stringify(pobj),
+      clientIp: ""
+    });
+    var result = { code: 1, msg: "SUCCESS" };
+    try {
+      var appCode = pobj.appCode || "";//应用编码
+      var actionProcess = pobj.actionProcess || "";//作业方
+      var sign = pobj.sign || "";//签名信息
+      if (!appCode) {
+        result.code = -100;
+        result.message = "appCode参数错误";
+        return result;
+      }
+      if (!actionProcess) {
+        result.code = -110;
+        result.message = "actionProcess参数错误";
+        return result;
+      }
+      if (!sign) {
+        result.code = -105;
+        result.message = "sign参数错误";
+        return result;
+      }
+      let applistCache = await this.cacheManager["ApplistCache"].getListByCache();
+      if (applistCache == null || applistCache == "" || applistCache == "undefined") {
+        result.code = -110;
+        result.message = "缓存app数据有误";
+        return result;
+      }
+      let appList = JSON.parse(applistCache);
+      if (appList == null || appList.length == 0) {
+        result.code = -120;
+        result.message = "缓存app数据有误！！";
+        return result;
+      }
+      var newList = appCode && sign ? appList.filter(item => item.app_code == appCode)
+        : appList.filter(item => item.app_code == appCode);//没有签名则用渠道自动提报
+
+      if (newList == null || newList.length == 0) {
+        result.code = -130;
+        result.message = "通过缓存获取app数据有误";
+        return result;
+      }
+      let appItem = newList[0];
+      if (appCode && sign) { // 验证签名
+        var signResult = await this.paramsSign(sign, pobj.actionBody, appItem.secret);
+        if (signResult.code != 1) {
+          result.code = -140;
+          result.message = "签名错误，请重试";
+          return result;
+        }
+      }
+      if (actionProcess == "AliTm") {
         var opResult = await this.opAliNotify(pobj.actionBody);
         // if (opResult.code == 1 && pobj.status && pobj.status == "2") {//阿里云审不通过---调用关闭注册方案(目前阿里那边自动关闭)
         //   var rc = System.getObject("util.aliyunClient");
@@ -296,10 +404,12 @@ class TmSub {
             clientIp: ""
           });
           result.code = -150;
+          result.status = -150;
           result.msg = "渠道商标状态通知异常";
           result.message = "渠道商标状态通知异常";
           return result;
         }
+        result.status = 0;
       }
       return result;
     } catch (e) {

fqboss/app/config/settings.js

@@ -40,6 +40,9 @@ var settings = {
   },
   channelApiUrl: function (channelCode) {
     if (this.env == "dev") {
+      if (channelCode == "AliTm") {
+        return "http://alitm.qifu.gongsibao.com:4012";
+      }
       return "http://centerorder.apps.com:4011";
     } else {
       if (channelCode == "jd") {
@@ -48,9 +51,19 @@ var settings = {
       if (channelCode == "gsbh5") {
         return "http://center-order-service";
       }
+      if (channelCode == "AliTm") {
+        return "http://alitm.qifu.gongsibao.com";
+      }
       return "https://zcchannel.gongsibao.com";//"http://zc-channel-service";
     }
   },
+  pushFqBossAliTmNotify: function (channelCode) {
+    if (this.env == "dev") {
+      return "http://192.168.201.137:3000/api/tmsub/channelTmNotifyByAli";
+    } else {
+      return "http://fqgirl.gongsibao.com/api/tmsub/channelTmNotifyByAli";
+    }
+  },
   reqEsAddrIc: function () {
     if (this.env == "dev") {
       var localsettings = require("./localsettings");