tj

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

@@ -118,6 +118,9 @@ class AccessAuthAPI extends WEBBase {
             case "getLoginInfo"://通过userpin获取用户登录信息
             case "getLoginInfo"://通过userpin获取用户登录信息
                 opResult = await this.utilsAuthSve.getLoginInfo(pobj, pobj.actionBody);
                 opResult = await this.utilsAuthSve.getLoginInfo(pobj, pobj.actionBody);
                 break;
                 break;
+            case "channelUserLogin":
+                opResult = await this.utilsAuthSve.channelUserLogin(pobj,pobj.actionBody,req);
+                break;
             case "logout"://用户退出
             case "logout"://用户退出
                 opResult = await this.utilsAuthSve.userLogout(pobj, pobj.actionBody);
                 opResult = await this.utilsAuthSve.userLogout(pobj, pobj.actionBody);
                 break;
                 break;

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

@@ -159,5 +159,48 @@ class UtilsAuthService extends AppServiceBase {
     return applogout;
     return applogout;
   }
   }
 
 
+  /**
+   * 官网首页跳转自主注册
+   * @param pobj
+   * @param actionBody
+   * @param req
+   * @returns {Promise<void>}
+   */
+  async channelUserLogin(pobj,actionBody,req){
+    //官网登录地址
+    let skipUrl = 'http://gsbweb.qifu.gongsibao.com';
+    let opResult = system.getResult(null, "req Failure");
+
+    //----通过Authorization 获取用户信息
+    let Authorization = req.headers["authorization"] || "";
+    if(!Authorization){
+      opResult =system.getResultFail(-99,'用户未登录',{redirectUrl:'skipUrl'});
+      return opResult;
+    }
+    let icCompanyUrl = 'https://icompanytest.gongsibao.com/api/tUserInfo/info';
+    let subData = {
+      Authorization:Authorization
+    }
+    let rtn = await this.execClient.execFqGet(subData,icCompanyUrl);
+    if (!rtn || !rtn.stdout) {
+      return system.getResult(null, "execPost data is empty");
+    }
+    var userInfo = JSON.parse(rtn.stdout);
+    //----结束
+    //---渠道用户登录，有则返回userpin ，没有则注册用户并返回userpin
+    let channelUserId = userInfo.mobile;
+    actionBody.channelUserId = channelUserId;
+    let loginRt = await this.getLoginByUserName(pobj,actionBody);
+    if (loginRt.status != 0 && loginRt.status != 2060) {
+      return loginRt;
+    }
+    opResult.data={ userpin: pobj.actionBody.userpin }
+    if (loginRt.status == 2060) {
+      opResult.msg = loginRt.msg;
+      opResult.data.userpin = loginRt.data.userpin;
+    }
+    return opResult;
+  }
+
 }
 }
 module.exports = UtilsAuthService;
 module.exports = UtilsAuthService;

center-channel/app/base/utils/execClient.js

@@ -77,6 +77,12 @@ class ExecClient {
         console.log(cmd);
         console.log(cmd);
         return cmd;
         return cmd;
     }
     }
+    FetchFqGetCmd(subData, url) {
+        var cmd = this.cmdFeishuGetPattern.replace(/\{url\}/g, url).replace(/\{Authorization\}/g, "Bearer "+subData.Authorization);
+        console.log(cmd);
+        return cmd;
+    }
+
     //飞书小程序GET请求
     //飞书小程序GET请求
     FetchFeishuGetCmd(subData, url) {
     FetchFeishuGetCmd(subData, url) {
         var cmd = this.cmdFeishuGetPattern.replace(
         var cmd = this.cmdFeishuGetPattern.replace(
@@ -96,6 +102,14 @@ class ExecClient {
         var result = await this.exec(cmd);
         var result = await this.exec(cmd);
         return result;
         return result;
     }
     }
+
+    async execFqGet(subData,url){
+        let cmd = this.FetchFqGetCmd(subData,url);
+        console.log(cmd);
+        var result = await this.exec(cmd);
+        return result;
+    }
+
     async execGet2(subData, url) {
     async execGet2(subData, url) {
         let cmd = this.FetchGetCmd(subData, url);
         let cmd = this.FetchGetCmd(subData, url);
         console.log(cmd);
         console.log(cmd);