修改学校查重

app/controller/school.js

@@ -7,12 +7,16 @@ const { CrudController } = require('naf-framework-mongoose/lib/controller');
 
 // 学校管理
 class SchoolController extends Controller {
-
   constructor(ctx) {
     super(ctx);
     this.service = this.ctx.service.school;
   }
 
+  // 去重查询学校
+  async findSchool() {
+    const data = await this.service.findSchool(this.ctx.query);
+    this.ctx.ok({ ...data });
+  }
   // 学生名单上报
   async stuimport() {
     const res = await this.service.stuimport(this.ctx.request.body);
@@ -22,7 +26,6 @@ class SchoolController extends Controller {
     const data = await this.service.exportSchool(this.ctx.request.body);
     this.ctx.ok({ data });
   }
-
 }
 
 module.exports = CrudController(SchoolController, meta);

app/router.js

@@ -209,6 +209,7 @@ module.exports = app => {
   router.post('attendance', '/api/train/attendance/attendancecreate', controller.attendance.attendancecreate);
   router.post('attendance', '/api/train/attendance/attendancecreateList', controller.attendance.attendancecreateList);
   // 学校上传学生名单
+  router.get('/api/train/school/findSchool', controller.school.findSchool);
   router.resources('school', '/api/train/school', controller.school); // index、create、show、destroy
   router.post('school', '/api/train/school/update/:id', controller.school.update);
   router.post('/api/train/school/import', controller.school.stuimport); // 名单上传

app/service/headteacher.js

@@ -22,7 +22,7 @@ class HeadteacherService extends CrudService {
       sort = sort.map(f => ({ [f]: desc ? -1 : 1 })).reduce((p, c) => ({ ...p, ...c }), {});
     }
 
-    const rs = await this.model.find(trimData(filter), projection, { skip, limit, sort }).lean();
+    let rs = await this.model.find(trimData(filter), projection, { skip, limit, sort }).lean();
     if (rs.length > 0) rs = JSON.parse(JSON.stringify(rs));
     const ids = rs.map(i => ObjectId(i._id).toString());
     const users = await this.umodel.find({ uid: ids }).lean();

app/service/school.js

@@ -74,6 +74,46 @@ class SchoolService extends CrudService {
     return await this.model.count(query);
   }
 
+  // 去重查询学校
+  async findSchool({ name, skip, limit, ...info }) {
+    let data = [];
+    const query = { ...info };
+    if (name) {
+      query.name = { $regex: name };
+    }
+    const AggregateInfo = [
+      // 这里可以添加其他查询条件，例如过滤特定字段等
+      { $match: query },
+      // 去除重复数据
+      { $group: { _id: '$code', uniqueData: { $first: '$$ROOT' } } },
+      { $replaceRoot: { newRoot: '$uniqueData' } },
+      { $addFields: { id: '$_id' } },
+      // 分页查询
+      { $skip: parseInt(skip) },
+    ];
+    if (limit) AggregateInfo.push({ $limit: parseInt(limit) });
+    const res = await this.model.aggregate(AggregateInfo);
+    if (res && res.length > 0) {
+      data = JSON.parse(JSON.stringify(res));
+      const ids = res.map(i => i._id);
+      const users = await this.umodel.find({ uid: { $in: ids } }, '+passwd').lean();
+      for (const tea of data) {
+        const r = users.find(f => f.uid === tea._id);
+        if (r) {
+          const passwd = _.get(r.passwd, 'secret');
+          if (passwd) tea.passwd = passwd;
+        }
+      }
+    }
+    const count = await this.model.aggregate([
+      { $match: query },
+      { $group: { _id: '$code' } },
+      { $count: 'distinctCount' },
+    ]);
+    const total = _.get(count[0], 'distinctCount') || 0;
+    return { total, data };
+  }
+
   async stuimport(data) {
     const { filepath, termid, schid, type, batchid } = data;
     assert(filepath, 'filepath不能为空');