cassandra-server add app_id

app/service/gjj/product.js

@@ -134,8 +134,8 @@ class ProductService extends Service {
   async getAllProductsByType(type) {
 
     const { ctx } = this;
-    const url = this.config.NODE_BASE_URL + '/cassandra-server/bu_basic/list?type=' + type;
-    const products_results = await ctx.helper.send_request(url, {}, { method: 'GET' });
+    const url = this.config.NODE_BASE_URL + '/cassandra-server/bu_basic/list';
+    const products_results = await ctx.helper.send_request(url, {type, app_id: ctx.appId}, { method: 'GET' });
     // ctx.logger.info(JSON.stringify({ url, products_results }));
     let products = [];
     if (products_results.status !== 200 || !products_results.data || !products_results.data.ret) {
@@ -171,7 +171,7 @@ class ProductService extends Service {
     const userId = ctx.userId;
     const appUserId = ctx.appUserId;
     const url = ctx.app.config.NODE_BASE_URL + '/cassandra-server/loan_list/bu_class/list';
-    const param = { uid: userId, app_uid: appUserId };
+    const param = { uid: userId, app_uid: appUserId, app_id: ctx.appId };
     const resp = await ctx.helper.send_request(url, param, { method: 'GET' });
     if (resp.status !== 200) {
       ctx.failed('[bu_class]内部接口错误');
@@ -204,7 +204,7 @@ class ProductService extends Service {
   async getCommonBusinessList() {
     const { ctx } = this;
     const url = ctx.app.config.NODE_BASE_URL + '/cassandra-server/bu_basic/list';
-    const param = { type: 4 };
+    const param = { type: 4, app_id: ctx.appId };
     const resp = await ctx.helper.send_request(url, param, { method: 'GET' });
     if (resp.status !== 200) {
       ctx.failed('[bu_basic]内部接口错误');