Accounting für Taxiunternehmer

src/routes/admin/accounting/getCompanyCosts.ts → src/lib/server/db/getCompanyCosts.ts

@@ -7,32 +7,36 @@ import { groupBy } from '$lib/util/groupBy';
 import { DAY, HOUR } from '$lib/util/time';
 import type { UnixtimeMs } from '$lib/util/UnixtimeMs';
 
-export async function getCompanyCosts() {
-	const tours: (TourWithRequests & { interval: Interval })[] = (await getToursWithRequests()).map(
-		(t) => {
-			return {
-				...t,
-				interval: new Interval(t.startTime, t.endTime)
-			};
-		}
-	);
+export async function getCompanyCosts(companyId?: number) {
+	const tours: (TourWithRequests & { interval: Interval })[] = (
+		await getToursWithRequests(true, companyId)
+	).map((t) => {
+		return {
+			...t,
+			interval: new Interval(t.startTime, t.endTime)
+		};
+	});
 	tours.sort((t1, t2) => t1.startTime - t2.startTime);
 	if (tours.length === 0) {
 		return {
 			tours: [],
 			earliestTime: Date.now(),
+			latestTime: Date.now(),
 			companyCostsPerDay: []
 		};
 	}
 	const earliestTime =
 		tours.reduce((min, entry) => (entry.startTime < min.startTime ? entry : min), tours[0])
 			.startTime - DAY;
-
-	const today = Math.ceil(Date.now() / DAY) * DAY;
+	const latestTime =
+		tours.reduce((max, entry) => (entry.endTime > max.endTime ? entry : max), tours[0]).endTime +
+		DAY;
 	const availabilities = await db
 		.selectFrom('availability')
+		.innerJoin('vehicle', 'vehicle.id', 'availability.vehicle')
+		.$if(companyId != undefined, (qb) => qb.where('vehicle.company', '=', companyId!))
 		.where('availability.endTime', '>=', earliestTime)
-		.where('availability.startTime', '<=', today)
+		.where('availability.startTime', '<=', latestTime)
 		.select(['availability.vehicle as vehicleId', 'availability.startTime', 'availability.endTime'])
 		.orderBy('availability.endTime', 'asc')
 		.execute();
@@ -51,7 +55,7 @@ export async function getCompanyCosts() {
 	};
 	const firstDay = new Date(earliestTime - DAY);
 	const firstDayStart = Math.floor(firstDay.getTime() / DAY) * DAY;
-	const days = Array.from({ length: Math.ceil((today - firstDayStart) / DAY) }, (_, i) => {
+	const days = Array.from({ length: Math.ceil((latestTime - firstDayStart) / DAY) }, (_, i) => {
 		const offset = getOffset(firstDayStart + DAY * i + HOUR * 12);
 		const offsetNextDay = getOffset(firstDayStart + DAY * (i + 1) + HOUR * 12);
 		return new Interval(
@@ -232,6 +236,7 @@ export async function getCompanyCosts() {
 	return {
 		tours,
 		earliestTime,
+		latestTime,
 		companyCostsPerDay: companyCostsPerDay.flatMap((companyCosts) =>
 			Array.from(companyCosts).map(
 				([

src/lib/server/db/getTours.ts

@@ -71,27 +71,79 @@ export type Tours = Awaited<ReturnType<typeof getTours>>;
 export type Tour = Tours[0];
 export type TourEvent = Tour['events'][0];
 
-export const getToursWithRequests = async () => {
+export const getToursWithRequests = async (
+	selectCancelled: boolean,
+	companyId?: number,
+	timeRange?: [UnixtimeMs, UnixtimeMs]
+) => {
+	console.log({ companyId });
 	return await db
 		.selectFrom('tour')
 		.innerJoin('vehicle', 'vehicle.id', 'tour.vehicle')
 		.innerJoin('company', 'company.id', 'vehicle.company')
+		.$if(!selectCancelled, (qb) => qb.where('tour.cancelled', '=', false))
+		.$if(companyId != undefined, (qb) => qb.where('company.id', '=', companyId!))
+		.$if(!!timeRange, (qb) =>
+			qb.where('tour.departure', '<', timeRange![1]).where('tour.arrival', '>', timeRange![0])
+		)
 		.select((eb) => [
 			'tour.fare as fare',
 			'tour.departure as startTime',
 			'tour.arrival as endTime',
 			'tour.cancelled',
+			'tour.id as tourId',
+			'tour.message',
 			'company.name as companyName',
 			'company.id as companyId',
+			'company.lat as companyLat',
+			'company.lng as companyLng',
 			'vehicle.id as vehicleId',
+			'vehicle.licensePlate',
 			jsonArrayFrom(
 				eb
 					.selectFrom('request')
 					.whereRef('tour.id', '=', 'request.tour')
-					.select(['request.luggage', 'request.passengers', 'request.ticketChecked'])
+					.$if(!selectCancelled, (qb) => qb.where('tour.cancelled', '=', false))
+					.select([
+						'request.luggage',
+						'request.passengers',
+						'request.ticketChecked',
+						jsonArrayFrom(
+							eb
+								.selectFrom('event')
+								.innerJoin('request', 'request.id', 'event.request')
+								.whereRef('tour.id', '=', 'request.tour')
+								.innerJoin('user', 'user.id', 'request.customer')
+								.$if(!selectCancelled, (qb) => qb.where('tour.cancelled', '=', false))
+								.select([
+									'tour.id as tour',
+									'user.name as customerName',
+									'user.phone as customerPhone',
+									'event.id',
+									'event.communicatedTime',
+									'event.address',
+									'event.eventGroup',
+									'event.isPickup',
+									'event.lat',
+									'event.lng',
+									'event.nextLegDuration',
+									'event.prevLegDuration',
+									'event.scheduledTimeStart',
+									'event.scheduledTimeEnd',
+									'event.cancelled',
+									'request.bikes',
+									'request.customer',
+									'request.luggage',
+									'request.passengers',
+									'request.wheelchairs',
+									'request.id as requestId'
+								])
+								.select(sql<string>`md5(request.ticket_code)`.as('ticketHash'))
+								.orderBy('event.scheduledTimeStart')
+						).as('events')
+					])
 			).as('requests')
 		])
-		.where('tour.fare', 'is not', null)
 		.execute();
 };