后台:记录最新更新人

This commit is contained in:
luying
2021-06-10 14:31:49 +08:00
parent 16fd00f9cd
commit 5c5ee8b7fc
8 changed files with 24 additions and 19 deletions

View File

@@ -81,7 +81,7 @@ export default class Activity extends Service {
public async deleteActivity(activityId: number) { public async deleteActivity(activityId: number) {
const { ctx } = this; const { ctx } = this;
const result = await ActivityModel.deleteActivity(activityId); const result = await ActivityModel.deleteActivity(activityId, ctx.user?.uid);
if (result) { if (result) {
return ctx.service.utils.resResult(STATUS.SUCCESS); return ctx.service.utils.resResult(STATUS.SUCCESS);
} else { } else {
@@ -125,7 +125,7 @@ export default class Activity extends Service {
public async saveActivitiesToGroup(groupId: number, activityIds: number[]) { public async saveActivitiesToGroup(groupId: number, activityIds: number[]) {
const { ctx } = this; const { ctx } = this;
try { try {
await ActivityGroupModel.setActivitiesToGroupData(groupId, activityIds); await ActivityGroupModel.setActivitiesToGroupData(groupId, activityIds, ctx.user?.uid);
} catch(e) { } catch(e) {
return ctx.service.utils.resResult(STATUS.INTERNAL_ERR, null, e.stack); return ctx.service.utils.resResult(STATUS.INTERNAL_ERR, null, e.stack);

View File

@@ -84,15 +84,15 @@ export default class Activity extends BaseModel {
let newGroup = await ActivityGroupModel.createGroup(); let newGroup = await ActivityGroupModel.createGroup();
groupId = newGroup.groupId; groupId = newGroup.groupId;
} }
await ActivityGroupModel.addActivitiesToGroupData(groupId, aids); await ActivityGroupModel.addActivitiesToGroupData(groupId, aids, uid);
} }
return result; return result;
} }
//删除活动 //删除活动
public static async deleteActivity(activityId: number) { public static async deleteActivity(activityId: number, uid = 1) {
let result = await ActivityModel.deleteMany({ activityId }); let result = await ActivityModel.deleteMany({ activityId });
await ActivityGroupModel.pullByActivityIds([activityId]); await ActivityGroupModel.pullByActivityIds([activityId], uid);
return result; return result;
} }
@@ -140,7 +140,6 @@ export default class Activity extends BaseModel {
public static async updateGroupId(activityIds: number[], groupId: number, uid = 1) { public static async updateGroupId(activityIds: number[], groupId: number, uid = 1) {
let result = await ActivityModel.updateMany({ activityId: { $in: activityIds } }, { $set: { groupId, updatedBy: uid }, $setOnInsert: { createdBy: uid } }); let result = await ActivityModel.updateMany({ activityId: { $in: activityIds } }, { $set: { groupId, updatedBy: uid }, $setOnInsert: { createdBy: uid } });
console.log(result)
return result; return result;
} }
} }

View File

@@ -48,21 +48,21 @@ export default class Activity_Group extends BaseModel {
} }
//更新询组 //更新询组
public static async setActivitiesToGroupData(groupId: number, activities: number[]) { public static async setActivitiesToGroupData(groupId: number, activities: number[], uid = 1) {
await this.pullByActivityIds(activities); // 先将原先的删除 await this.pullByActivityIds(activities, uid); // 先将原先的删除
let result: ActivityGroupModelType = await ActivityGroupModel.findOneAndUpdate({ groupId }, let result: ActivityGroupModelType = await ActivityGroupModel.findOneAndUpdate({ groupId },
{ $set: { activities } }, { new: true }).lean(true); { $set: { activities } }, { new: true }).lean(true);
await ActivityModel.updateGroupId(activities, groupId); await ActivityModel.updateGroupId(activities, groupId, uid);
result = await this.updateTime(result.groupId, result.activities); result = await this.updateTime(result.groupId, result.activities);
return result; return result;
} }
//更新询组 //更新询组
public static async addActivitiesToGroupData(groupId: number, activities: number[]) { public static async addActivitiesToGroupData(groupId: number, activities: number[], uid = 1) {
await this.pullByActivityIds(activities); // 先将原先的删除 await this.pullByActivityIds(activities, uid); // 先将原先的删除
let result: ActivityGroupModelType = await ActivityGroupModel.findOneAndUpdate({ groupId }, let result: ActivityGroupModelType = await ActivityGroupModel.findOneAndUpdate({ groupId },
{ $addToSet: { activities: { $each: activities } } }, { new: true }).lean(true); { $addToSet: { activities: { $each: activities } } }, { new: true }).lean(true);
await ActivityModel.updateGroupId(activities, groupId); await ActivityModel.updateGroupId(activities, groupId, uid);
result = await this.updateTime(result.groupId, result.activities); result = await this.updateTime(result.groupId, result.activities);
return result; return result;
} }
@@ -82,8 +82,8 @@ export default class Activity_Group extends BaseModel {
// 删除活动id // 删除活动id
public static async pullByActivityIds(activities: number[]) { public static async pullByActivityIds(activities: number[], uid = 1) {
await ActivityModel.updateGroupId(activities, 0); await ActivityModel.updateGroupId(activities, 0, uid);
let activityGroups = await ActivityGroupModel.find({ activities: { $in: activities } }); let activityGroups = await ActivityGroupModel.find({ activities: { $in: activities } });
for(let { groupId } of activityGroups) { for(let { groupId } of activityGroups) {
let result = await ActivityGroupModel.findOneAndUpdate({ groupId }, { $pull: { activities: { $in: activities } } }, { new: true }).lean(true); let result = await ActivityGroupModel.findOneAndUpdate({ groupId }, { $pull: { activities: { $in: activities } } }, { new: true }).lean(true);

View File

@@ -1,6 +1,6 @@
import BaseModel from './BaseModel'; import BaseModel from './BaseModel';
import { index, getModelForClass, prop, DocumentType } from '@typegoose/typegoose'; import { index, getModelForClass, prop, DocumentType } from '@typegoose/typegoose';
import moment = require('moment'); // import moment = require('moment');
/** /**

View File

@@ -37,7 +37,7 @@ export default class Activity_Self_Service extends BaseModel {
} }
//添加挑战记录 //添加挑战记录
public static async addChallengeRecord(serverId: number, activityId: number, roleId: string, roundIndex: number, count: number, time: Date) { public static async addChallengeRecord(serverId: number, activityId: number, roleId: string, roundIndex: number, count: number, _time: Date) {
let result: ActivitySelfServiceModelType = await ActivitySelfServiceModel.findOneAndUpdate( let result: ActivitySelfServiceModelType = await ActivitySelfServiceModel.findOneAndUpdate(
{ serverId, roleId, activityId, roundIndex, }, { serverId, roleId, activityId, roundIndex, },
{ $push: { challengeRecords: { count, time: new Date() } } }, { upsert: true, new: true }).lean(true); { $push: { challengeRecords: { count, time: new Date() } } }, { upsert: true, new: true }).lean(true);

View File

@@ -14,7 +14,14 @@ export default class Serverlist extends BaseModel {
gameId: number; // 游戏id Game表的id gameId: number; // 游戏id Game表的id
@prop({ required: true }) @prop({ required: true })
id: number; // 小区id id: number; // 小区id 自增
@prop({ required: true })
serverId: string; // 显示id不同serverType下id一定不同但是serverId可能相同
public get serverStr() {
return `S${this.serverId}`;
}
@prop({ required: true }) @prop({ required: true })
name: string; // 小区区名 name: string; // 小区区名

View File

@@ -16,7 +16,7 @@ const plugin: EggPlugin = {
package: 'egg-alinode', package: 'egg-alinode',
}, },
xtransit: { xtransit: {
enable: true, enable: false,
package: 'egg-xtransit', package: 'egg-xtransit',
} }
}; };

View File

@@ -17,7 +17,6 @@ import 'egg-view';
import 'egg-view-nunjucks'; import 'egg-view-nunjucks';
import 'egg-cors'; import 'egg-cors';
import 'egg-alinode'; import 'egg-alinode';
import 'egg-xtransit';
import { EggPluginItem } from 'egg'; import { EggPluginItem } from 'egg';
declare module 'egg' { declare module 'egg' {
interface EggPlugin { interface EggPlugin {