gsb

xggsve-common/app/base/api/impl/op/action.js

@@ -96,6 +96,9 @@ class ActionAPI extends APIBase {
             case "deliverAll":
                 opResult = await this.deliverSve.apiAll(action_body);
                 break;
+            case "channelDics":
+                opResult = await this.deliverSve.channelDics(action_body);
+                break;
             case "deliverPage":
                 opResult = await this.deliverSve.apiPage(action_body);
                 break;

xggsve-common/app/base/db/impl/deliver/deliverDao.js

@@ -20,6 +20,19 @@ class DeliverDao extends Dao {
     return await this.customQuery(sql.join(" "),params) || [];
   }
 
+  async channelDics(channel_id) {
+    let sql = [];
+    sql.push("SELECT");
+    sql.push("t1.id, t1.name");
+    sql.push("FROM `d_deliver_channel` t2");
+    sql.push("INNER JOIN `d_deliver` t1 ON t2.`deliver_id` = t1.`id`");
+    sql.push("WHERE channel_id = :channel_id");
+    sql.push("ORDER BY t1.created_at ASC");
+    return await this.customQuery(sql.join(" "), {
+      channel_id: channel_id
+    }) || [];
+  }
+
   async delById(id, t) {
     var sql = "DELETE FROM d_deliver WHERE id = :id";
     return await this.customUpdate(sql, {

xggsve-common/app/base/service/impl/deliver/deliverSve.js

@@ -201,6 +201,15 @@ class DeliverService extends ServiceBase {
     return system.getResultSuccess(list);
   }
 
+  async channelDics(params) {
+    if (!params.channel_id) {
+      return system.getResultSuccess([]);
+    }
+
+    let rs = await this.dao.channelDics(params.channel_id);
+    return system.getResultSuccess(rs);
+  }
+
   async delById(id) {
     if (!id) {
       return system.getResult(null, "删除失败");