commit
05c98dcb14
|
@ -64,6 +64,10 @@ import { TermConditionModel } from './modules/web-information/term-condition/dat
|
|||
import { FaqModel } from './modules/web-information/faq/data/models/faq.model';
|
||||
import { FaqModule } from './modules/web-information/faq/faq.module';
|
||||
import { UploadModule } from './modules/configuration/upload/upload.module';
|
||||
import { NewsModule } from './modules/web-information/news/news.module';
|
||||
import { NewsModel } from './modules/web-information/news/data/models/news.model';
|
||||
import { BannerModule } from './modules/web-information/banner/banner.module';
|
||||
import { BannerModel } from './modules/web-information/banner/data/models/banner.model';
|
||||
|
||||
@Module({
|
||||
imports: [
|
||||
|
@ -81,6 +85,7 @@ import { UploadModule } from './modules/configuration/upload/upload.module';
|
|||
database: process.env.DEFAULT_DB_NAME,
|
||||
entities: [
|
||||
...UserPrivilegeModels,
|
||||
BannerModel,
|
||||
ErrorLogModel,
|
||||
FaqModel,
|
||||
GateModel,
|
||||
|
@ -88,6 +93,7 @@ import { UploadModule } from './modules/configuration/upload/upload.module';
|
|||
ItemCategoryModel,
|
||||
ItemRateModel,
|
||||
LogModel,
|
||||
NewsModel,
|
||||
PaymentMethodModel,
|
||||
RefundModel,
|
||||
RefundItemModel,
|
||||
|
@ -146,8 +152,10 @@ import { UploadModule } from './modules/configuration/upload/upload.module';
|
|||
SeasonPeriodModule,
|
||||
|
||||
// web information
|
||||
BannerModule,
|
||||
FaqModule,
|
||||
GateModule,
|
||||
NewsModule,
|
||||
TermConditionModule,
|
||||
|
||||
// report
|
||||
|
|
|
@ -1,9 +1,11 @@
|
|||
export enum MODULE_NAME {
|
||||
BANNER = 'banners',
|
||||
FAQ = 'faqs',
|
||||
GATE = 'gates',
|
||||
ITEM = 'items',
|
||||
ITEM_CATEGORY = 'item-categories',
|
||||
ITEM_RATE = 'item-rates',
|
||||
NEWS = 'news',
|
||||
PAYMENT_METHOD = 'payment-methods',
|
||||
RECONCILIATION = 'reconciliations',
|
||||
REFUND = 'refunds',
|
||||
|
|
|
@ -1,4 +1,5 @@
|
|||
export enum TABLE_NAME {
|
||||
BANNER = 'banners',
|
||||
ERROR_LOG = 'log_errors',
|
||||
FAQ = 'faqs',
|
||||
ITEM = 'items',
|
||||
|
@ -6,6 +7,7 @@ export enum TABLE_NAME {
|
|||
ITEM_RATE = 'item_rates',
|
||||
GATE = 'gates',
|
||||
LOG = 'logs',
|
||||
NEWS = 'news',
|
||||
PAYMENT_METHOD = 'payment_methods',
|
||||
PRICE_FORMULA = 'price_formulas',
|
||||
REFUND = 'refunds',
|
||||
|
|
|
@ -0,0 +1,19 @@
|
|||
import { MigrationInterface, QueryRunner } from 'typeorm';
|
||||
|
||||
export class News1721109817371 implements MigrationInterface {
|
||||
name = 'News1721109817371';
|
||||
|
||||
public async up(queryRunner: QueryRunner): Promise<void> {
|
||||
await queryRunner.query(
|
||||
`CREATE TYPE "public"."news_status_enum" AS ENUM('active', 'cancel', 'confirmed', 'draft', 'expired', 'inactive', 'partial refund', 'pending', 'proses refund', 'refunded', 'rejected', 'settled', 'waiting')`,
|
||||
);
|
||||
await queryRunner.query(
|
||||
`CREATE TABLE "news" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "creator_id" character varying(36), "creator_name" character varying(125), "editor_id" character varying(36), "editor_name" character varying(125), "created_at" bigint NOT NULL, "updated_at" bigint NOT NULL, "status" "public"."news_status_enum" NOT NULL DEFAULT 'draft', "image_url" character varying, "title" character varying, "teaser" character varying, "description" character varying, CONSTRAINT "PK_39a43dfcb6007180f04aff2357e" PRIMARY KEY ("id"))`,
|
||||
);
|
||||
}
|
||||
|
||||
public async down(queryRunner: QueryRunner): Promise<void> {
|
||||
await queryRunner.query(`DROP TABLE "news"`);
|
||||
await queryRunner.query(`DROP TYPE "public"."news_status_enum"`);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,19 @@
|
|||
import { MigrationInterface, QueryRunner } from 'typeorm';
|
||||
|
||||
export class Banner1721111093665 implements MigrationInterface {
|
||||
name = 'Banner1721111093665';
|
||||
|
||||
public async up(queryRunner: QueryRunner): Promise<void> {
|
||||
await queryRunner.query(
|
||||
`CREATE TYPE "public"."banners_status_enum" AS ENUM('active', 'cancel', 'confirmed', 'draft', 'expired', 'inactive', 'partial refund', 'pending', 'proses refund', 'refunded', 'rejected', 'settled', 'waiting')`,
|
||||
);
|
||||
await queryRunner.query(
|
||||
`CREATE TABLE "banners" ("id" uuid NOT NULL DEFAULT uuid_generate_v4(), "creator_id" character varying(36), "creator_name" character varying(125), "editor_id" character varying(36), "editor_name" character varying(125), "created_at" bigint NOT NULL, "updated_at" bigint NOT NULL, "status" "public"."banners_status_enum" NOT NULL DEFAULT 'draft', "image_url" character varying, "title" character varying, "link" character varying, CONSTRAINT "PK_e9b186b959296fcb940790d31c3" PRIMARY KEY ("id"))`,
|
||||
);
|
||||
}
|
||||
|
||||
public async down(queryRunner: QueryRunner): Promise<void> {
|
||||
await queryRunner.query(`DROP TABLE "banners"`);
|
||||
await queryRunner.query(`DROP TYPE "public"."banners_status_enum"`);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,54 @@
|
|||
import { Module } from '@nestjs/common';
|
||||
import { ConfigModule } from '@nestjs/config';
|
||||
import { TypeOrmModule } from '@nestjs/typeorm';
|
||||
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||
import { BannerDataService } from './data/services/banner-data.service';
|
||||
import { BannerReadService } from './data/services/banner-read.service';
|
||||
import { BannerReadController } from './infrastructure/banner-read.controller';
|
||||
import { BannerReadOrchestrator } from './domain/usecases/banner-read.orchestrator';
|
||||
import { BannerDataController } from './infrastructure/banner-data.controller';
|
||||
import { BannerDataOrchestrator } from './domain/usecases/banner-data.orchestrator';
|
||||
import { CreateBannerManager } from './domain/usecases/managers/create-banner.manager';
|
||||
import { CqrsModule } from '@nestjs/cqrs';
|
||||
import { IndexBannerManager } from './domain/usecases/managers/index-banner.manager';
|
||||
import { DeleteBannerManager } from './domain/usecases/managers/delete-banner.manager';
|
||||
import { UpdateBannerManager } from './domain/usecases/managers/update-banner.manager';
|
||||
import { ActiveBannerManager } from './domain/usecases/managers/active-banner.manager';
|
||||
import { ConfirmBannerManager } from './domain/usecases/managers/confirm-banner.manager';
|
||||
import { InactiveBannerManager } from './domain/usecases/managers/inactive-banner.manager';
|
||||
import { DetailBannerManager } from './domain/usecases/managers/detail-banner.manager';
|
||||
import { BatchDeleteBannerManager } from './domain/usecases/managers/batch-delete-banner.manager';
|
||||
import { BatchActiveBannerManager } from './domain/usecases/managers/batch-active-banner.manager';
|
||||
import { BatchConfirmBannerManager } from './domain/usecases/managers/batch-confirm-banner.manager';
|
||||
import { BatchInactiveBannerManager } from './domain/usecases/managers/batch-inactive-banner.manager';
|
||||
import { BannerModel } from './data/models/banner.model';
|
||||
|
||||
@Module({
|
||||
imports: [
|
||||
ConfigModule.forRoot(),
|
||||
TypeOrmModule.forFeature([BannerModel], CONNECTION_NAME.DEFAULT),
|
||||
CqrsModule,
|
||||
],
|
||||
controllers: [BannerDataController, BannerReadController],
|
||||
providers: [
|
||||
IndexBannerManager,
|
||||
DetailBannerManager,
|
||||
CreateBannerManager,
|
||||
DeleteBannerManager,
|
||||
UpdateBannerManager,
|
||||
ActiveBannerManager,
|
||||
ConfirmBannerManager,
|
||||
InactiveBannerManager,
|
||||
BatchDeleteBannerManager,
|
||||
BatchActiveBannerManager,
|
||||
BatchConfirmBannerManager,
|
||||
BatchInactiveBannerManager,
|
||||
|
||||
BannerDataService,
|
||||
BannerReadService,
|
||||
|
||||
BannerDataOrchestrator,
|
||||
BannerReadOrchestrator,
|
||||
],
|
||||
})
|
||||
export class BannerModule {}
|
|
@ -0,0 +1,19 @@
|
|||
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||
import { BannerEntity } from '../../domain/entities/banner.entity';
|
||||
import { Column, Entity } from 'typeorm';
|
||||
import { BaseStatusModel } from 'src/core/modules/data/model/base-status.model';
|
||||
|
||||
@Entity(TABLE_NAME.BANNER)
|
||||
export class BannerModel
|
||||
extends BaseStatusModel<BannerEntity>
|
||||
implements BannerEntity
|
||||
{
|
||||
@Column('varchar', { name: 'image_url', nullable: true })
|
||||
image_url: string;
|
||||
|
||||
@Column('varchar', { name: 'title', nullable: true })
|
||||
title: string;
|
||||
|
||||
@Column('varchar', { name: 'link', nullable: true })
|
||||
link: string;
|
||||
}
|
|
@ -0,0 +1,17 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseDataService } from 'src/core/modules/data/service/base-data.service';
|
||||
import { BannerEntity } from '../../domain/entities/banner.entity';
|
||||
import { InjectRepository } from '@nestjs/typeorm';
|
||||
import { BannerModel } from '../models/banner.model';
|
||||
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||
import { Repository } from 'typeorm';
|
||||
|
||||
@Injectable()
|
||||
export class BannerDataService extends BaseDataService<BannerEntity> {
|
||||
constructor(
|
||||
@InjectRepository(BannerModel, CONNECTION_NAME.DEFAULT)
|
||||
private repo: Repository<BannerModel>,
|
||||
) {
|
||||
super(repo);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,17 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BannerEntity } from '../../domain/entities/banner.entity';
|
||||
import { InjectRepository } from '@nestjs/typeorm';
|
||||
import { BannerModel } from '../models/banner.model';
|
||||
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||
import { Repository } from 'typeorm';
|
||||
import { BaseReadService } from 'src/core/modules/data/service/base-read.service';
|
||||
|
||||
@Injectable()
|
||||
export class BannerReadService extends BaseReadService<BannerEntity> {
|
||||
constructor(
|
||||
@InjectRepository(BannerModel, CONNECTION_NAME.DEFAULT)
|
||||
private repo: Repository<BannerModel>,
|
||||
) {
|
||||
super(repo);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,7 @@
|
|||
import { BaseStatusEntity } from 'src/core/modules/domain/entities/base-status.entity';
|
||||
|
||||
export interface BannerEntity extends BaseStatusEntity {
|
||||
image_url: string;
|
||||
title: string;
|
||||
link: string;
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class BannerChangeStatusEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class BannerCreatedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class BannerDeletedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class BannerUpdatedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,3 @@
|
|||
import { BaseFilterEntity } from 'src/core/modules/domain/entities/base-filter.entity';
|
||||
|
||||
export interface FilterBannerEntity extends BaseFilterEntity {}
|
|
@ -0,0 +1,106 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { CreateBannerManager } from './managers/create-banner.manager';
|
||||
import { BannerDataService } from '../../data/services/banner-data.service';
|
||||
import { BannerEntity } from '../entities/banner.entity';
|
||||
import { DeleteBannerManager } from './managers/delete-banner.manager';
|
||||
import { UpdateBannerManager } from './managers/update-banner.manager';
|
||||
import { BaseDataTransactionOrchestrator } from 'src/core/modules/domain/usecase/orchestrators/base-data-transaction.orchestrator';
|
||||
import { ActiveBannerManager } from './managers/active-banner.manager';
|
||||
import { InactiveBannerManager } from './managers/inactive-banner.manager';
|
||||
import { ConfirmBannerManager } from './managers/confirm-banner.manager';
|
||||
import { STATUS } from 'src/core/strings/constants/base.constants';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BatchConfirmBannerManager } from './managers/batch-confirm-banner.manager';
|
||||
import { BatchInactiveBannerManager } from './managers/batch-inactive-banner.manager';
|
||||
import { BatchActiveBannerManager } from './managers/batch-active-banner.manager';
|
||||
import { BatchDeleteBannerManager } from './managers/batch-delete-banner.manager';
|
||||
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||
|
||||
@Injectable()
|
||||
export class BannerDataOrchestrator extends BaseDataTransactionOrchestrator<BannerEntity> {
|
||||
constructor(
|
||||
private createManager: CreateBannerManager,
|
||||
private updateManager: UpdateBannerManager,
|
||||
private deleteManager: DeleteBannerManager,
|
||||
private activeManager: ActiveBannerManager,
|
||||
private confirmManager: ConfirmBannerManager,
|
||||
private inactiveManager: InactiveBannerManager,
|
||||
private batchDeleteManager: BatchDeleteBannerManager,
|
||||
private batchActiveManager: BatchActiveBannerManager,
|
||||
private batchConfirmManager: BatchConfirmBannerManager,
|
||||
private batchInactiveManager: BatchInactiveBannerManager,
|
||||
private serviceData: BannerDataService,
|
||||
) {
|
||||
super();
|
||||
}
|
||||
|
||||
async create(data): Promise<BannerEntity> {
|
||||
this.createManager.setData(data);
|
||||
this.createManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.createManager.execute();
|
||||
return this.createManager.getResult();
|
||||
}
|
||||
|
||||
async update(dataId, data): Promise<BannerEntity> {
|
||||
this.updateManager.setData(dataId, data);
|
||||
this.updateManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.updateManager.execute();
|
||||
return this.updateManager.getResult();
|
||||
}
|
||||
|
||||
async delete(dataId): Promise<string> {
|
||||
this.deleteManager.setData(dataId);
|
||||
this.deleteManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.deleteManager.execute();
|
||||
return this.deleteManager.getResult();
|
||||
}
|
||||
|
||||
async batchDelete(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchDeleteManager.setData(dataIds);
|
||||
this.batchDeleteManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.batchDeleteManager.execute();
|
||||
return this.batchDeleteManager.getResult();
|
||||
}
|
||||
|
||||
async active(dataId): Promise<string> {
|
||||
this.activeManager.setData(dataId, STATUS.ACTIVE);
|
||||
this.activeManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.activeManager.execute();
|
||||
return this.activeManager.getResult();
|
||||
}
|
||||
|
||||
async batchActive(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchActiveManager.setData(dataIds, STATUS.ACTIVE);
|
||||
this.batchActiveManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.batchActiveManager.execute();
|
||||
return this.batchActiveManager.getResult();
|
||||
}
|
||||
|
||||
async confirm(dataId): Promise<string> {
|
||||
this.confirmManager.setData(dataId, STATUS.ACTIVE);
|
||||
this.confirmManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.confirmManager.execute();
|
||||
return this.confirmManager.getResult();
|
||||
}
|
||||
|
||||
async batchConfirm(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchConfirmManager.setData(dataIds, STATUS.ACTIVE);
|
||||
this.batchConfirmManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.batchConfirmManager.execute();
|
||||
return this.batchConfirmManager.getResult();
|
||||
}
|
||||
|
||||
async inactive(dataId): Promise<string> {
|
||||
this.inactiveManager.setData(dataId, STATUS.INACTIVE);
|
||||
this.inactiveManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.inactiveManager.execute();
|
||||
return this.inactiveManager.getResult();
|
||||
}
|
||||
|
||||
async batchInactive(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchInactiveManager.setData(dataIds, STATUS.INACTIVE);
|
||||
this.batchInactiveManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.batchInactiveManager.execute();
|
||||
return this.batchInactiveManager.getResult();
|
||||
}
|
||||
}
|
|
@ -0,0 +1,33 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { IndexBannerManager } from './managers/index-banner.manager';
|
||||
import { BannerReadService } from '../../data/services/banner-read.service';
|
||||
import { BannerEntity } from '../entities/banner.entity';
|
||||
import { PaginationResponse } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BaseReadOrchestrator } from 'src/core/modules/domain/usecase/orchestrators/base-read.orchestrator';
|
||||
import { DetailBannerManager } from './managers/detail-banner.manager';
|
||||
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||
|
||||
@Injectable()
|
||||
export class BannerReadOrchestrator extends BaseReadOrchestrator<BannerEntity> {
|
||||
constructor(
|
||||
private indexManager: IndexBannerManager,
|
||||
private detailManager: DetailBannerManager,
|
||||
private serviceData: BannerReadService,
|
||||
) {
|
||||
super();
|
||||
}
|
||||
|
||||
async index(params): Promise<PaginationResponse<BannerEntity>> {
|
||||
this.indexManager.setFilterParam(params);
|
||||
this.indexManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.indexManager.execute();
|
||||
return this.indexManager.getResult();
|
||||
}
|
||||
|
||||
async detail(dataId: string): Promise<BannerEntity> {
|
||||
this.detailManager.setData(dataId);
|
||||
this.detailManager.setService(this.serviceData, TABLE_NAME.BANNER);
|
||||
await this.detailManager.execute();
|
||||
return this.detailManager.getResult();
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerChangeStatusEvent } from '../../entities/event/banner-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class ActiveBannerManager extends BaseUpdateStatusManager<BannerEntity> {
|
||||
getResult(): string {
|
||||
return `Success active data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerChangeStatusEvent } from '../../entities/event/banner-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchActiveBannerManager extends BaseBatchUpdateStatusManager<BannerEntity> {
|
||||
validateData(data: BannerEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerChangeStatusEvent } from '../../entities/event/banner-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchConfirmBannerManager extends BaseBatchUpdateStatusManager<BannerEntity> {
|
||||
validateData(data: BannerEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchDeleteManager } from 'src/core/modules/domain/usecase/managers/base-batch-delete.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerDeletedEvent } from '../../entities/event/banner-deleted.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchDeleteBannerManager extends BaseBatchDeleteManager<BannerEntity> {
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async validateData(data: BannerEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerDeletedEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerChangeStatusEvent } from '../../entities/event/banner-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchInactiveBannerManager extends BaseBatchUpdateStatusManager<BannerEntity> {
|
||||
validateData(data: BannerEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerChangeStatusEvent } from '../../entities/event/banner-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class ConfirmBannerManager extends BaseUpdateStatusManager<BannerEntity> {
|
||||
getResult(): string {
|
||||
return `Success active data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,42 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import {
|
||||
EventTopics,
|
||||
columnUniques,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BaseCreateManager } from 'src/core/modules/domain/usecase/managers/base-create.manager';
|
||||
import { BannerCreatedEvent } from '../../entities/event/banner-created.event';
|
||||
|
||||
@Injectable()
|
||||
export class CreateBannerManager extends BaseCreateManager<BannerEntity> {
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get uniqueColumns(): columnUniques[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerCreatedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseDeleteManager } from 'src/core/modules/domain/usecase/managers/base-delete.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerDeletedEvent } from '../../entities/event/banner-deleted.event';
|
||||
|
||||
@Injectable()
|
||||
export class DeleteBannerManager extends BaseDeleteManager<BannerEntity> {
|
||||
getResult(): string {
|
||||
return `Success`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerDeletedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,53 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseDetailManager } from 'src/core/modules/domain/usecase/managers/base-detail.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import { RelationParam } from 'src/core/modules/domain/entities/base-filter.entity';
|
||||
|
||||
@Injectable()
|
||||
export class DetailBannerManager extends BaseDetailManager<BannerEntity> {
|
||||
async prepareData(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get relations(): RelationParam {
|
||||
return {
|
||||
// relation only join (for query purpose)
|
||||
joinRelations: [],
|
||||
|
||||
// relation join and select (relasi yang ingin ditampilkan),
|
||||
selectRelations: [],
|
||||
|
||||
// relation yang hanya ingin dihitung (akan return number)
|
||||
countRelations: [],
|
||||
};
|
||||
}
|
||||
|
||||
get selects(): string[] {
|
||||
return [
|
||||
`${this.tableName}.id`,
|
||||
`${this.tableName}.created_at`,
|
||||
`${this.tableName}.creator_name`,
|
||||
`${this.tableName}.updated_at`,
|
||||
`${this.tableName}.editor_name`,
|
||||
|
||||
`${this.tableName}.status`,
|
||||
`${this.tableName}.image_url`,
|
||||
`${this.tableName}.title`,
|
||||
`${this.tableName}.link`,
|
||||
];
|
||||
}
|
||||
|
||||
get setFindProperties(): any {
|
||||
return {
|
||||
id: this.dataId,
|
||||
};
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerChangeStatusEvent } from '../../entities/event/banner-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class InactiveBannerManager extends BaseUpdateStatusManager<BannerEntity> {
|
||||
getResult(): string {
|
||||
return `Success inactive data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,66 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseIndexManager } from 'src/core/modules/domain/usecase/managers/base-index.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import { SelectQueryBuilder } from 'typeorm';
|
||||
import {
|
||||
Param,
|
||||
RelationParam,
|
||||
} from 'src/core/modules/domain/entities/base-filter.entity';
|
||||
|
||||
@Injectable()
|
||||
export class IndexBannerManager extends BaseIndexManager<BannerEntity> {
|
||||
async prepareData(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get relations(): RelationParam {
|
||||
return {
|
||||
// relation only join (for query purpose)
|
||||
joinRelations: [],
|
||||
|
||||
// relation join and select (relasi yang ingin ditampilkan),
|
||||
selectRelations: [],
|
||||
|
||||
// relation yang hanya ingin dihitung (akan return number)
|
||||
countRelations: [],
|
||||
};
|
||||
}
|
||||
|
||||
get selects(): string[] {
|
||||
return [
|
||||
`${this.tableName}.id`,
|
||||
`${this.tableName}.created_at`,
|
||||
`${this.tableName}.creator_name`,
|
||||
`${this.tableName}.updated_at`,
|
||||
`${this.tableName}.editor_name`,
|
||||
|
||||
`${this.tableName}.status`,
|
||||
`${this.tableName}.image_url`,
|
||||
`${this.tableName}.title`,
|
||||
`${this.tableName}.link`,
|
||||
];
|
||||
}
|
||||
|
||||
get specificFilter(): Param[] {
|
||||
return [
|
||||
{
|
||||
cols: `${this.tableName}.name`,
|
||||
data: this.filterParam.names,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
setQueryFilter(
|
||||
queryBuilder: SelectQueryBuilder<BannerEntity>,
|
||||
): SelectQueryBuilder<BannerEntity> {
|
||||
return queryBuilder;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,46 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateManager } from 'src/core/modules/domain/usecase/managers/base-update.manager';
|
||||
import { BannerEntity } from '../../entities/banner.entity';
|
||||
import { BannerModel } from '../../../data/models/banner.model';
|
||||
import { BannerUpdatedEvent } from '../../entities/event/banner-updated.event';
|
||||
import {
|
||||
EventTopics,
|
||||
columnUniques,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
@Injectable()
|
||||
export class UpdateBannerManager extends BaseUpdateManager<BannerEntity> {
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get uniqueColumns(): columnUniques[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return BannerModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: BannerUpdatedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,78 @@
|
|||
import {
|
||||
Body,
|
||||
Controller,
|
||||
Delete,
|
||||
Param,
|
||||
Patch,
|
||||
Post,
|
||||
Put,
|
||||
} from '@nestjs/common';
|
||||
import { BannerDataOrchestrator } from '../domain/usecases/banner-data.orchestrator';
|
||||
import { BannerDto } from './dto/banner.dto';
|
||||
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
|
||||
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
|
||||
import { BannerEntity } from '../domain/entities/banner.entity';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BatchIdsDto } from 'src/core/modules/infrastructure/dto/base-batch.dto';
|
||||
import { Public } from 'src/core/guards';
|
||||
|
||||
@ApiTags(`${MODULE_NAME.BANNER.split('-').join(' ')} - data`)
|
||||
@Controller(`v1/${MODULE_NAME.BANNER}`)
|
||||
@Public(false)
|
||||
@ApiBearerAuth('JWT')
|
||||
export class BannerDataController {
|
||||
constructor(private orchestrator: BannerDataOrchestrator) {}
|
||||
|
||||
@Post()
|
||||
async create(@Body() data: BannerDto): Promise<BannerEntity> {
|
||||
return await this.orchestrator.create(data);
|
||||
}
|
||||
|
||||
@Put('/batch-delete')
|
||||
async batchDeleted(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchDelete(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/active')
|
||||
async active(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.active(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-active')
|
||||
async batchActive(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchActive(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/confirm')
|
||||
async confirm(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.confirm(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-confirm')
|
||||
async batchConfirm(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchConfirm(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/inactive')
|
||||
async inactive(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.inactive(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-inactive')
|
||||
async batchInactive(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchInactive(body.ids);
|
||||
}
|
||||
|
||||
@Put(':id')
|
||||
async update(
|
||||
@Param('id') dataId: string,
|
||||
@Body() data: BannerDto,
|
||||
): Promise<BannerEntity> {
|
||||
return await this.orchestrator.update(dataId, data);
|
||||
}
|
||||
|
||||
@Delete(':id')
|
||||
async delete(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.delete(dataId);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,30 @@
|
|||
import { Controller, Get, Param, Query } from '@nestjs/common';
|
||||
import { FilterBannerDto } from './dto/filter-banner.dto';
|
||||
import { Pagination } from 'src/core/response';
|
||||
import { PaginationResponse } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BannerEntity } from '../domain/entities/banner.entity';
|
||||
import { BannerReadOrchestrator } from '../domain/usecases/banner-read.orchestrator';
|
||||
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
|
||||
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
|
||||
import { Public } from 'src/core/guards';
|
||||
|
||||
@ApiTags(`${MODULE_NAME.BANNER.split('-').join(' ')} - read`)
|
||||
@Controller(`v1/${MODULE_NAME.BANNER}`)
|
||||
@Public(false)
|
||||
@ApiBearerAuth('JWT')
|
||||
export class BannerReadController {
|
||||
constructor(private orchestrator: BannerReadOrchestrator) {}
|
||||
|
||||
@Get()
|
||||
@Pagination()
|
||||
async index(
|
||||
@Query() params: FilterBannerDto,
|
||||
): Promise<PaginationResponse<BannerEntity>> {
|
||||
return await this.orchestrator.index(params);
|
||||
}
|
||||
|
||||
@Get(':id')
|
||||
async detail(@Param('id') id: string): Promise<BannerEntity> {
|
||||
return await this.orchestrator.detail(id);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,26 @@
|
|||
import { BaseStatusDto } from 'src/core/modules/infrastructure/dto/base-status.dto';
|
||||
import { BannerEntity } from '../../domain/entities/banner.entity';
|
||||
import { ApiProperty } from '@nestjs/swagger';
|
||||
|
||||
export class BannerDto extends BaseStatusDto implements BannerEntity {
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: false,
|
||||
example: 'https://...',
|
||||
})
|
||||
image_url: string;
|
||||
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: true,
|
||||
example: 'The Flash Speed Force',
|
||||
})
|
||||
title: string;
|
||||
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: false,
|
||||
example: 'Get ready to take on the first ride-within-a-ride experience',
|
||||
})
|
||||
link: string;
|
||||
}
|
|
@ -0,0 +1,6 @@
|
|||
import { BaseFilterDto } from 'src/core/modules/infrastructure/dto/base-filter.dto';
|
||||
import { FilterBannerEntity } from '../../domain/entities/filter-banner.entity';
|
||||
|
||||
export class FilterBannerDto
|
||||
extends BaseFilterDto
|
||||
implements FilterBannerEntity {}
|
|
@ -1,3 +1,5 @@
|
|||
import { BaseFilterEntity } from 'src/core/modules/domain/entities/base-filter.entity';
|
||||
|
||||
export interface FilterFaqEntity extends BaseFilterEntity {}
|
||||
export interface FilterFaqEntity extends BaseFilterEntity {
|
||||
titles: string[];
|
||||
}
|
||||
|
|
|
@ -50,8 +50,8 @@ export class IndexFaqManager extends BaseIndexManager<FaqEntity> {
|
|||
get specificFilter(): Param[] {
|
||||
return [
|
||||
{
|
||||
cols: `${this.tableName}.name`,
|
||||
data: this.filterParam.names,
|
||||
cols: `${this.tableName}.title`,
|
||||
data: this.filterParam.titles,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
|
|
@ -1,4 +1,12 @@
|
|||
import { BaseFilterDto } from 'src/core/modules/infrastructure/dto/base-filter.dto';
|
||||
import { FilterFaqEntity } from '../../domain/entities/filter-faq.entity';
|
||||
import { ApiProperty } from '@nestjs/swagger';
|
||||
import { Transform } from 'class-transformer';
|
||||
|
||||
export class FilterFaqDto extends BaseFilterDto implements FilterFaqEntity {}
|
||||
export class FilterFaqDto extends BaseFilterDto implements FilterFaqEntity {
|
||||
@ApiProperty({ type: ['string'], required: false })
|
||||
@Transform((body) => {
|
||||
return Array.isArray(body.value) ? body.value : [body.value];
|
||||
})
|
||||
titles: string[];
|
||||
}
|
||||
|
|
|
@ -0,0 +1,22 @@
|
|||
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||
import { NewsEntity } from '../../domain/entities/news.entity';
|
||||
import { Column, Entity } from 'typeorm';
|
||||
import { BaseStatusModel } from 'src/core/modules/data/model/base-status.model';
|
||||
|
||||
@Entity(TABLE_NAME.NEWS)
|
||||
export class NewsModel
|
||||
extends BaseStatusModel<NewsEntity>
|
||||
implements NewsEntity
|
||||
{
|
||||
@Column('varchar', { name: 'image_url', nullable: true })
|
||||
image_url: string;
|
||||
|
||||
@Column('varchar', { name: 'title', nullable: true })
|
||||
title: string;
|
||||
|
||||
@Column('varchar', { name: 'teaser', nullable: true })
|
||||
teaser: string;
|
||||
|
||||
@Column('varchar', { name: 'description', nullable: true })
|
||||
description: string;
|
||||
}
|
|
@ -0,0 +1,17 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseDataService } from 'src/core/modules/data/service/base-data.service';
|
||||
import { NewsEntity } from '../../domain/entities/news.entity';
|
||||
import { InjectRepository } from '@nestjs/typeorm';
|
||||
import { NewsModel } from '../models/news.model';
|
||||
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||
import { Repository } from 'typeorm';
|
||||
|
||||
@Injectable()
|
||||
export class NewsDataService extends BaseDataService<NewsEntity> {
|
||||
constructor(
|
||||
@InjectRepository(NewsModel, CONNECTION_NAME.DEFAULT)
|
||||
private repo: Repository<NewsModel>,
|
||||
) {
|
||||
super(repo);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,17 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { NewsEntity } from '../../domain/entities/news.entity';
|
||||
import { InjectRepository } from '@nestjs/typeorm';
|
||||
import { NewsModel } from '../models/news.model';
|
||||
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||
import { Repository } from 'typeorm';
|
||||
import { BaseReadService } from 'src/core/modules/data/service/base-read.service';
|
||||
|
||||
@Injectable()
|
||||
export class NewsReadService extends BaseReadService<NewsEntity> {
|
||||
constructor(
|
||||
@InjectRepository(NewsModel, CONNECTION_NAME.DEFAULT)
|
||||
private repo: Repository<NewsModel>,
|
||||
) {
|
||||
super(repo);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class NewsChangeStatusEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class NewsCreatedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class NewsDeletedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { IEvent } from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
export class NewsUpdatedEvent {
|
||||
constructor(public readonly data: IEvent) {}
|
||||
}
|
|
@ -0,0 +1,5 @@
|
|||
import { BaseFilterEntity } from 'src/core/modules/domain/entities/base-filter.entity';
|
||||
|
||||
export interface FilterNewsEntity extends BaseFilterEntity {
|
||||
titles: string[];
|
||||
}
|
|
@ -0,0 +1,8 @@
|
|||
import { BaseStatusEntity } from 'src/core/modules/domain/entities/base-status.entity';
|
||||
|
||||
export interface NewsEntity extends BaseStatusEntity {
|
||||
image_url: string;
|
||||
title: string;
|
||||
teaser: string;
|
||||
description: string;
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class ActiveNewsManager extends BaseUpdateStatusManager<NewsEntity> {
|
||||
getResult(): string {
|
||||
return `Success active data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchActiveNewsManager extends BaseBatchUpdateStatusManager<NewsEntity> {
|
||||
validateData(data: NewsEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchConfirmNewsManager extends BaseBatchUpdateStatusManager<NewsEntity> {
|
||||
validateData(data: NewsEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchDeleteManager } from 'src/core/modules/domain/usecase/managers/base-batch-delete.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsDeletedEvent } from '../../entities/event/news-deleted.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchDeleteNewsManager extends BaseBatchDeleteManager<NewsEntity> {
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async validateData(data: NewsEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsDeletedEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { BaseBatchUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-batch-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { Injectable } from '@nestjs/common';
|
||||
|
||||
@Injectable()
|
||||
export class BatchInactiveNewsManager extends BaseBatchUpdateStatusManager<NewsEntity> {
|
||||
validateData(data: NewsEntity): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
getResult(): BatchResult {
|
||||
return this.result;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class ConfirmNewsManager extends BaseUpdateStatusManager<NewsEntity> {
|
||||
getResult(): string {
|
||||
return `Success active data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,42 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import {
|
||||
EventTopics,
|
||||
columnUniques,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { BaseCreateManager } from 'src/core/modules/domain/usecase/managers/base-create.manager';
|
||||
import { NewsCreatedEvent } from '../../entities/event/news-created.event';
|
||||
|
||||
@Injectable()
|
||||
export class CreateNewsManager extends BaseCreateManager<NewsEntity> {
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get uniqueColumns(): columnUniques[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsCreatedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseDeleteManager } from 'src/core/modules/domain/usecase/managers/base-delete.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsDeletedEvent } from '../../entities/event/news-deleted.event';
|
||||
|
||||
@Injectable()
|
||||
export class DeleteNewsManager extends BaseDeleteManager<NewsEntity> {
|
||||
getResult(): string {
|
||||
return `Success`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsDeletedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,54 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseDetailManager } from 'src/core/modules/domain/usecase/managers/base-detail.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import { RelationParam } from 'src/core/modules/domain/entities/base-filter.entity';
|
||||
|
||||
@Injectable()
|
||||
export class DetailNewsManager extends BaseDetailManager<NewsEntity> {
|
||||
async prepareData(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get relations(): RelationParam {
|
||||
return {
|
||||
// relation only join (for query purpose)
|
||||
joinRelations: [],
|
||||
|
||||
// relation join and select (relasi yang ingin ditampilkan),
|
||||
selectRelations: [],
|
||||
|
||||
// relation yang hanya ingin dihitung (akan return number)
|
||||
countRelations: [],
|
||||
};
|
||||
}
|
||||
|
||||
get selects(): string[] {
|
||||
return [
|
||||
`${this.tableName}.id`,
|
||||
`${this.tableName}.created_at`,
|
||||
`${this.tableName}.creator_name`,
|
||||
`${this.tableName}.updated_at`,
|
||||
`${this.tableName}.editor_name`,
|
||||
|
||||
`${this.tableName}.status`,
|
||||
`${this.tableName}.image_url`,
|
||||
`${this.tableName}.title`,
|
||||
`${this.tableName}.teaser`,
|
||||
`${this.tableName}.description`,
|
||||
];
|
||||
}
|
||||
|
||||
get setFindProperties(): any {
|
||||
return {
|
||||
id: this.dataId,
|
||||
};
|
||||
}
|
||||
}
|
|
@ -0,0 +1,45 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateStatusManager } from 'src/core/modules/domain/usecase/managers/base-update-status.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import {
|
||||
EventTopics,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsChangeStatusEvent } from '../../entities/event/news-change-status.event';
|
||||
|
||||
@Injectable()
|
||||
export class InactiveNewsManager extends BaseUpdateStatusManager<NewsEntity> {
|
||||
getResult(): string {
|
||||
return `Success inactive data ${this.result.title}`;
|
||||
}
|
||||
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsChangeStatusEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,67 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseIndexManager } from 'src/core/modules/domain/usecase/managers/base-index.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import { SelectQueryBuilder } from 'typeorm';
|
||||
import {
|
||||
Param,
|
||||
RelationParam,
|
||||
} from 'src/core/modules/domain/entities/base-filter.entity';
|
||||
|
||||
@Injectable()
|
||||
export class IndexNewsManager extends BaseIndexManager<NewsEntity> {
|
||||
async prepareData(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get relations(): RelationParam {
|
||||
return {
|
||||
// relation only join (for query purpose)
|
||||
joinRelations: [],
|
||||
|
||||
// relation join and select (relasi yang ingin ditampilkan),
|
||||
selectRelations: [],
|
||||
|
||||
// relation yang hanya ingin dihitung (akan return number)
|
||||
countRelations: [],
|
||||
};
|
||||
}
|
||||
|
||||
get selects(): string[] {
|
||||
return [
|
||||
`${this.tableName}.id`,
|
||||
`${this.tableName}.created_at`,
|
||||
`${this.tableName}.creator_name`,
|
||||
`${this.tableName}.updated_at`,
|
||||
`${this.tableName}.editor_name`,
|
||||
|
||||
`${this.tableName}.status`,
|
||||
`${this.tableName}.image_url`,
|
||||
`${this.tableName}.title`,
|
||||
`${this.tableName}.teaser`,
|
||||
`${this.tableName}.description`,
|
||||
];
|
||||
}
|
||||
|
||||
get specificFilter(): Param[] {
|
||||
return [
|
||||
{
|
||||
cols: `${this.tableName}.title`,
|
||||
data: this.filterParam.titles,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
||||
setQueryFilter(
|
||||
queryBuilder: SelectQueryBuilder<NewsEntity>,
|
||||
): SelectQueryBuilder<NewsEntity> {
|
||||
return queryBuilder;
|
||||
}
|
||||
}
|
|
@ -0,0 +1,46 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { BaseUpdateManager } from 'src/core/modules/domain/usecase/managers/base-update.manager';
|
||||
import { NewsEntity } from '../../entities/news.entity';
|
||||
import { NewsModel } from '../../../data/models/news.model';
|
||||
import { NewsUpdatedEvent } from '../../entities/event/news-updated.event';
|
||||
import {
|
||||
EventTopics,
|
||||
columnUniques,
|
||||
validateRelations,
|
||||
} from 'src/core/strings/constants/interface.constants';
|
||||
|
||||
@Injectable()
|
||||
export class UpdateNewsManager extends BaseUpdateManager<NewsEntity> {
|
||||
async validateProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async beforeProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
async afterProcess(): Promise<void> {
|
||||
return;
|
||||
}
|
||||
|
||||
get validateRelations(): validateRelations[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get uniqueColumns(): columnUniques[] {
|
||||
return [];
|
||||
}
|
||||
|
||||
get entityTarget(): any {
|
||||
return NewsModel;
|
||||
}
|
||||
|
||||
get eventTopics(): EventTopics[] {
|
||||
return [
|
||||
{
|
||||
topic: NewsUpdatedEvent,
|
||||
data: this.data,
|
||||
},
|
||||
];
|
||||
}
|
||||
}
|
|
@ -0,0 +1,106 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { CreateNewsManager } from './managers/create-news.manager';
|
||||
import { NewsDataService } from '../../data/services/news-data.service';
|
||||
import { NewsEntity } from '../entities/news.entity';
|
||||
import { DeleteNewsManager } from './managers/delete-news.manager';
|
||||
import { UpdateNewsManager } from './managers/update-news.manager';
|
||||
import { BaseDataTransactionOrchestrator } from 'src/core/modules/domain/usecase/orchestrators/base-data-transaction.orchestrator';
|
||||
import { ActiveNewsManager } from './managers/active-news.manager';
|
||||
import { InactiveNewsManager } from './managers/inactive-news.manager';
|
||||
import { ConfirmNewsManager } from './managers/confirm-news.manager';
|
||||
import { STATUS } from 'src/core/strings/constants/base.constants';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BatchConfirmNewsManager } from './managers/batch-confirm-news.manager';
|
||||
import { BatchInactiveNewsManager } from './managers/batch-inactive-news.manager';
|
||||
import { BatchActiveNewsManager } from './managers/batch-active-news.manager';
|
||||
import { BatchDeleteNewsManager } from './managers/batch-delete-news.manager';
|
||||
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||
|
||||
@Injectable()
|
||||
export class NewsDataOrchestrator extends BaseDataTransactionOrchestrator<NewsEntity> {
|
||||
constructor(
|
||||
private createManager: CreateNewsManager,
|
||||
private updateManager: UpdateNewsManager,
|
||||
private deleteManager: DeleteNewsManager,
|
||||
private activeManager: ActiveNewsManager,
|
||||
private confirmManager: ConfirmNewsManager,
|
||||
private inactiveManager: InactiveNewsManager,
|
||||
private batchDeleteManager: BatchDeleteNewsManager,
|
||||
private batchActiveManager: BatchActiveNewsManager,
|
||||
private batchConfirmManager: BatchConfirmNewsManager,
|
||||
private batchInactiveManager: BatchInactiveNewsManager,
|
||||
private serviceData: NewsDataService,
|
||||
) {
|
||||
super();
|
||||
}
|
||||
|
||||
async create(data): Promise<NewsEntity> {
|
||||
this.createManager.setData(data);
|
||||
this.createManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.createManager.execute();
|
||||
return this.createManager.getResult();
|
||||
}
|
||||
|
||||
async update(dataId, data): Promise<NewsEntity> {
|
||||
this.updateManager.setData(dataId, data);
|
||||
this.updateManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.updateManager.execute();
|
||||
return this.updateManager.getResult();
|
||||
}
|
||||
|
||||
async delete(dataId): Promise<string> {
|
||||
this.deleteManager.setData(dataId);
|
||||
this.deleteManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.deleteManager.execute();
|
||||
return this.deleteManager.getResult();
|
||||
}
|
||||
|
||||
async batchDelete(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchDeleteManager.setData(dataIds);
|
||||
this.batchDeleteManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.batchDeleteManager.execute();
|
||||
return this.batchDeleteManager.getResult();
|
||||
}
|
||||
|
||||
async active(dataId): Promise<string> {
|
||||
this.activeManager.setData(dataId, STATUS.ACTIVE);
|
||||
this.activeManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.activeManager.execute();
|
||||
return this.activeManager.getResult();
|
||||
}
|
||||
|
||||
async batchActive(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchActiveManager.setData(dataIds, STATUS.ACTIVE);
|
||||
this.batchActiveManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.batchActiveManager.execute();
|
||||
return this.batchActiveManager.getResult();
|
||||
}
|
||||
|
||||
async confirm(dataId): Promise<string> {
|
||||
this.confirmManager.setData(dataId, STATUS.ACTIVE);
|
||||
this.confirmManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.confirmManager.execute();
|
||||
return this.confirmManager.getResult();
|
||||
}
|
||||
|
||||
async batchConfirm(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchConfirmManager.setData(dataIds, STATUS.ACTIVE);
|
||||
this.batchConfirmManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.batchConfirmManager.execute();
|
||||
return this.batchConfirmManager.getResult();
|
||||
}
|
||||
|
||||
async inactive(dataId): Promise<string> {
|
||||
this.inactiveManager.setData(dataId, STATUS.INACTIVE);
|
||||
this.inactiveManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.inactiveManager.execute();
|
||||
return this.inactiveManager.getResult();
|
||||
}
|
||||
|
||||
async batchInactive(dataIds: string[]): Promise<BatchResult> {
|
||||
this.batchInactiveManager.setData(dataIds, STATUS.INACTIVE);
|
||||
this.batchInactiveManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.batchInactiveManager.execute();
|
||||
return this.batchInactiveManager.getResult();
|
||||
}
|
||||
}
|
|
@ -0,0 +1,33 @@
|
|||
import { Injectable } from '@nestjs/common';
|
||||
import { IndexNewsManager } from './managers/index-news.manager';
|
||||
import { NewsReadService } from '../../data/services/news-read.service';
|
||||
import { NewsEntity } from '../entities/news.entity';
|
||||
import { PaginationResponse } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BaseReadOrchestrator } from 'src/core/modules/domain/usecase/orchestrators/base-read.orchestrator';
|
||||
import { DetailNewsManager } from './managers/detail-news.manager';
|
||||
import { TABLE_NAME } from 'src/core/strings/constants/table.constants';
|
||||
|
||||
@Injectable()
|
||||
export class NewsReadOrchestrator extends BaseReadOrchestrator<NewsEntity> {
|
||||
constructor(
|
||||
private indexManager: IndexNewsManager,
|
||||
private detailManager: DetailNewsManager,
|
||||
private serviceData: NewsReadService,
|
||||
) {
|
||||
super();
|
||||
}
|
||||
|
||||
async index(params): Promise<PaginationResponse<NewsEntity>> {
|
||||
this.indexManager.setFilterParam(params);
|
||||
this.indexManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.indexManager.execute();
|
||||
return this.indexManager.getResult();
|
||||
}
|
||||
|
||||
async detail(dataId: string): Promise<NewsEntity> {
|
||||
this.detailManager.setData(dataId);
|
||||
this.detailManager.setService(this.serviceData, TABLE_NAME.NEWS);
|
||||
await this.detailManager.execute();
|
||||
return this.detailManager.getResult();
|
||||
}
|
||||
}
|
|
@ -0,0 +1,12 @@
|
|||
import { BaseFilterDto } from 'src/core/modules/infrastructure/dto/base-filter.dto';
|
||||
import { FilterNewsEntity } from '../../domain/entities/filter-news.entity';
|
||||
import { ApiProperty } from '@nestjs/swagger';
|
||||
import { Transform } from 'class-transformer';
|
||||
|
||||
export class FilterNewsDto extends BaseFilterDto implements FilterNewsEntity {
|
||||
@ApiProperty({ type: ['string'], required: false })
|
||||
@Transform((body) => {
|
||||
return Array.isArray(body.value) ? body.value : [body.value];
|
||||
})
|
||||
titles: string[];
|
||||
}
|
|
@ -0,0 +1,33 @@
|
|||
import { BaseStatusDto } from 'src/core/modules/infrastructure/dto/base-status.dto';
|
||||
import { NewsEntity } from '../../domain/entities/news.entity';
|
||||
import { ApiProperty } from '@nestjs/swagger';
|
||||
|
||||
export class NewsDto extends BaseStatusDto implements NewsEntity {
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: false,
|
||||
example: 'https://...',
|
||||
})
|
||||
image_url: string;
|
||||
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: true,
|
||||
example: 'The Flash Speed Force',
|
||||
})
|
||||
title: string;
|
||||
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: false,
|
||||
example: 'Get ready to take on the first ride-within-a-ride experience',
|
||||
})
|
||||
teaser: string;
|
||||
|
||||
@ApiProperty({
|
||||
type: String,
|
||||
required: false,
|
||||
example: 'description',
|
||||
})
|
||||
description: string;
|
||||
}
|
|
@ -0,0 +1,78 @@
|
|||
import {
|
||||
Body,
|
||||
Controller,
|
||||
Delete,
|
||||
Param,
|
||||
Patch,
|
||||
Post,
|
||||
Put,
|
||||
} from '@nestjs/common';
|
||||
import { NewsDataOrchestrator } from '../domain/usecases/news-data.orchestrator';
|
||||
import { NewsDto } from './dto/news.dto';
|
||||
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
|
||||
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
|
||||
import { NewsEntity } from '../domain/entities/news.entity';
|
||||
import { BatchResult } from 'src/core/response/domain/ok-response.interface';
|
||||
import { BatchIdsDto } from 'src/core/modules/infrastructure/dto/base-batch.dto';
|
||||
import { Public } from 'src/core/guards';
|
||||
|
||||
@ApiTags(`${MODULE_NAME.NEWS.split('-').join(' ')} - data`)
|
||||
@Controller(`v1/${MODULE_NAME.NEWS}`)
|
||||
@Public(false)
|
||||
@ApiBearerAuth('JWT')
|
||||
export class NewsDataController {
|
||||
constructor(private orchestrator: NewsDataOrchestrator) {}
|
||||
|
||||
@Post()
|
||||
async create(@Body() data: NewsDto): Promise<NewsEntity> {
|
||||
return await this.orchestrator.create(data);
|
||||
}
|
||||
|
||||
@Put('/batch-delete')
|
||||
async batchDeleted(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchDelete(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/active')
|
||||
async active(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.active(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-active')
|
||||
async batchActive(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchActive(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/confirm')
|
||||
async confirm(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.confirm(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-confirm')
|
||||
async batchConfirm(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchConfirm(body.ids);
|
||||
}
|
||||
|
||||
@Patch(':id/inactive')
|
||||
async inactive(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.inactive(dataId);
|
||||
}
|
||||
|
||||
@Put('/batch-inactive')
|
||||
async batchInactive(@Body() body: BatchIdsDto): Promise<BatchResult> {
|
||||
return await this.orchestrator.batchInactive(body.ids);
|
||||
}
|
||||
|
||||
@Put(':id')
|
||||
async update(
|
||||
@Param('id') dataId: string,
|
||||
@Body() data: NewsDto,
|
||||
): Promise<NewsEntity> {
|
||||
return await this.orchestrator.update(dataId, data);
|
||||
}
|
||||
|
||||
@Delete(':id')
|
||||
async delete(@Param('id') dataId: string): Promise<string> {
|
||||
return await this.orchestrator.delete(dataId);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,30 @@
|
|||
import { Controller, Get, Param, Query } from '@nestjs/common';
|
||||
import { FilterNewsDto } from './dto/filter-news.dto';
|
||||
import { Pagination } from 'src/core/response';
|
||||
import { PaginationResponse } from 'src/core/response/domain/ok-response.interface';
|
||||
import { NewsEntity } from '../domain/entities/news.entity';
|
||||
import { NewsReadOrchestrator } from '../domain/usecases/news-read.orchestrator';
|
||||
import { ApiBearerAuth, ApiTags } from '@nestjs/swagger';
|
||||
import { MODULE_NAME } from 'src/core/strings/constants/module.constants';
|
||||
import { Public } from 'src/core/guards';
|
||||
|
||||
@ApiTags(`${MODULE_NAME.NEWS.split('-').join(' ')} - read`)
|
||||
@Controller(`v1/${MODULE_NAME.NEWS}`)
|
||||
@Public(false)
|
||||
@ApiBearerAuth('JWT')
|
||||
export class NewsReadController {
|
||||
constructor(private orchestrator: NewsReadOrchestrator) {}
|
||||
|
||||
@Get()
|
||||
@Pagination()
|
||||
async index(
|
||||
@Query() params: FilterNewsDto,
|
||||
): Promise<PaginationResponse<NewsEntity>> {
|
||||
return await this.orchestrator.index(params);
|
||||
}
|
||||
|
||||
@Get(':id')
|
||||
async detail(@Param('id') id: string): Promise<NewsEntity> {
|
||||
return await this.orchestrator.detail(id);
|
||||
}
|
||||
}
|
|
@ -0,0 +1,54 @@
|
|||
import { Module } from '@nestjs/common';
|
||||
import { ConfigModule } from '@nestjs/config';
|
||||
import { TypeOrmModule } from '@nestjs/typeorm';
|
||||
import { CONNECTION_NAME } from 'src/core/strings/constants/base.constants';
|
||||
import { NewsDataService } from './data/services/news-data.service';
|
||||
import { NewsReadService } from './data/services/news-read.service';
|
||||
import { NewsReadController } from './infrastructure/news-read.controller';
|
||||
import { NewsReadOrchestrator } from './domain/usecases/news-read.orchestrator';
|
||||
import { NewsDataController } from './infrastructure/news-data.controller';
|
||||
import { NewsDataOrchestrator } from './domain/usecases/news-data.orchestrator';
|
||||
import { CreateNewsManager } from './domain/usecases/managers/create-news.manager';
|
||||
import { CqrsModule } from '@nestjs/cqrs';
|
||||
import { IndexNewsManager } from './domain/usecases/managers/index-news.manager';
|
||||
import { DeleteNewsManager } from './domain/usecases/managers/delete-news.manager';
|
||||
import { UpdateNewsManager } from './domain/usecases/managers/update-news.manager';
|
||||
import { ActiveNewsManager } from './domain/usecases/managers/active-news.manager';
|
||||
import { ConfirmNewsManager } from './domain/usecases/managers/confirm-news.manager';
|
||||
import { InactiveNewsManager } from './domain/usecases/managers/inactive-news.manager';
|
||||
import { DetailNewsManager } from './domain/usecases/managers/detail-news.manager';
|
||||
import { BatchDeleteNewsManager } from './domain/usecases/managers/batch-delete-news.manager';
|
||||
import { BatchActiveNewsManager } from './domain/usecases/managers/batch-active-news.manager';
|
||||
import { BatchConfirmNewsManager } from './domain/usecases/managers/batch-confirm-news.manager';
|
||||
import { BatchInactiveNewsManager } from './domain/usecases/managers/batch-inactive-news.manager';
|
||||
import { NewsModel } from './data/models/news.model';
|
||||
|
||||
@Module({
|
||||
imports: [
|
||||
ConfigModule.forRoot(),
|
||||
TypeOrmModule.forFeature([NewsModel], CONNECTION_NAME.DEFAULT),
|
||||
CqrsModule,
|
||||
],
|
||||
controllers: [NewsDataController, NewsReadController],
|
||||
providers: [
|
||||
IndexNewsManager,
|
||||
DetailNewsManager,
|
||||
CreateNewsManager,
|
||||
DeleteNewsManager,
|
||||
UpdateNewsManager,
|
||||
ActiveNewsManager,
|
||||
ConfirmNewsManager,
|
||||
InactiveNewsManager,
|
||||
BatchDeleteNewsManager,
|
||||
BatchActiveNewsManager,
|
||||
BatchConfirmNewsManager,
|
||||
BatchInactiveNewsManager,
|
||||
|
||||
NewsDataService,
|
||||
NewsReadService,
|
||||
|
||||
NewsDataOrchestrator,
|
||||
NewsReadOrchestrator,
|
||||
],
|
||||
})
|
||||
export class NewsModule {}
|
|
@ -1,3 +1,5 @@
|
|||
import { BaseFilterEntity } from 'src/core/modules/domain/entities/base-filter.entity';
|
||||
|
||||
export interface FilterTermConditionEntity extends BaseFilterEntity {}
|
||||
export interface FilterTermConditionEntity extends BaseFilterEntity {
|
||||
titles: string[];
|
||||
}
|
||||
|
|
|
@ -50,8 +50,8 @@ export class IndexTermConditionManager extends BaseIndexManager<TermConditionEnt
|
|||
get specificFilter(): Param[] {
|
||||
return [
|
||||
{
|
||||
cols: `${this.tableName}.name`,
|
||||
data: this.filterParam.names,
|
||||
cols: `${this.tableName}.title`,
|
||||
data: this.filterParam.titles,
|
||||
},
|
||||
];
|
||||
}
|
||||
|
|
|
@ -1,6 +1,15 @@
|
|||
import { BaseFilterDto } from 'src/core/modules/infrastructure/dto/base-filter.dto';
|
||||
import { FilterTermConditionEntity } from '../../domain/entities/filter-term-condition.entity';
|
||||
import { Transform } from 'class-transformer';
|
||||
import { ApiProperty } from '@nestjs/swagger';
|
||||
|
||||
export class FilterTermConditionDto
|
||||
extends BaseFilterDto
|
||||
implements FilterTermConditionEntity {}
|
||||
implements FilterTermConditionEntity
|
||||
{
|
||||
@ApiProperty({ type: ['string'], required: false })
|
||||
@Transform((body) => {
|
||||
return Array.isArray(body.value) ? body.value : [body.value];
|
||||
})
|
||||
titles: string[];
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue