tj

center-channel/app/base/api/impl/auth/taskapi.js

@@ -13,6 +13,10 @@ class AccessAuthAPI extends APIBase {
         var rtn = await this.gatewaypushlogSve.taskAliIcapi();
         var rtn = await this.gatewaypushlogSve.taskAliIcapi();
         return rtn;
         return rtn;
     }
     }
+    async taskAgainFqPushInfo(pobj, qobj, req) {//再次推送蜂擎业务数据
+        var rtn = await this.utilsPushSve.aliBusiness2Fq(pobj)
+        return rtn;
+    }
     async taskAgainPushOneNewBusInfo(pobj, qobj, req) {//再次推送新rpc业务数据
     async taskAgainPushOneNewBusInfo(pobj, qobj, req) {//再次推送新rpc业务数据
         var rtn = await this.utilsPushSve.againPushBusInfo(pobj);
         var rtn = await this.utilsPushSve.againPushBusInfo(pobj);
         if (rtn.status == 0) {
         if (rtn.status == 0) {

center-channel/app/base/db/models/common/oplog.js

@@ -13,7 +13,7 @@ module.exports = (db, DataTypes) => {
       defaultValue: "info",
       defaultValue: "info",
     },
     },
     op: DataTypes.STRING(4000),
     op: DataTypes.STRING(4000),
-    content: DataTypes.STRING(5000),
+    content: DataTypes.TEXT('long'),
     resultInfo: DataTypes.TEXT('long'),
     resultInfo: DataTypes.TEXT('long'),
     clientIp: DataTypes.STRING,
     clientIp: DataTypes.STRING,
     agent: DataTypes.STRING(500),
     agent: DataTypes.STRING(500),

center-channel/app/base/service/impl/utilsSve/utilsPushSve.js

@@ -12,6 +12,16 @@ class UtilsPushService extends AppServiceBase {
     var reqUrl = settings.centerAppUrl() + "action/opProduct/springBoard";
     var reqUrl = settings.centerAppUrl() + "action/opProduct/springBoard";
     var productItemInterfaceResult = await this.restPostUrl(pobj, reqUrl);
     var productItemInterfaceResult = await this.restPostUrl(pobj, reqUrl);
     pobj.interface_info = productItemInterfaceResult.data;
     pobj.interface_info = productItemInterfaceResult.data;
+    //日志记录
+    this.logCtl.info({
+      appid: pobj.appInfo ? pobj.appInfo.uapp_id || "" : "",
+      appkey: pobj.appInfo ? pobj.appInfo.uapp_key || "" : "",
+      requestId: pobj.requestId || "",
+      op: "service/impl/utilsSve/utilsPushSve.js/service/app.base.js/aliBusiness2Fq",
+      content: JSON.stringify(pobj),
+      resultInfo: productItemInterfaceResult.data.length > 0 ? JSON.stringify(productItemInterfaceResult.data) : "接口数据为空",
+      optitle: pobj.opType + "推送蜂擎获取的接口信息->aliBusiness2Fq",
+    });
     this.pushBusInfo(pobj, opType, 1);
     this.pushBusInfo(pobj, opType, 1);
   }
   }
 
 
@@ -41,7 +51,7 @@ class UtilsPushService extends AppServiceBase {
     }
     }
     return system.getResultSuccess();
     return system.getResultSuccess();
   }
   }
-  
+
   async reflexAction(interface_info, opType, pobj, isDelProductInfo) {
   async reflexAction(interface_info, opType, pobj, isDelProductInfo) {
     var refResult = null;
     var refResult = null;
     pobj.interface_info = interface_info;
     pobj.interface_info = interface_info;