R/create_precedence_df.R

In edeaR: Exploratory and Descriptive Event-Based Data Analysis

create_precedence_df <- function(log) {
	UseMethod("create_precedence_df")
}

#' @export
create_precedence_df.eventlog <- function(log) {

	AID <- NULL
	CID <- NULL
	AIID <- NULL
	TS <- NULL
	start_time <- NULL
	end_time <- NULL
	#next_activity <- NULL
	#next_start_time <- NULL
	#next_end_time <- NULL



	log_dt <- log %>%
		rename(AID = activity_id(log),
			   CID = case_id(log),
			   AIID = activity_instance_id(log),
			   TS = timestamp(log)) %>%
		as.data.table()

	log_dt <- log_dt[, .('start_time' = min(TS),
						 'end_time' = max(TS),
						 'min_order' = min(.order)),
					 by = .(AID, AIID, CID)]

	starts <- log_dt[order(start_time, end_time, min_order), .SD[1] , .(CID)][, c("AID", "end_time", "min_order") := .("Start", start_time, min(min_order) - 1)]
	ends <- log_dt[order(start_time, end_time, min_order), .SD[.N] , .(CID)][, c("AID", "start_time", "min_order") := .("End", end_time, max(min_order) + 1)]

	log_dt <- rbind(starts, log_dt, ends)

	log_dt[order(start_time, end_time, min_order), c("next_activity", "next_start_time", "next_end_time") := .(shift(as.character(AID), n = -1),
																											  shift(start_time, n = -1),
																											  shift(end_time, n = -1)), by = .(CID)]

	as_tibble(log_dt)
}

#' @export
create_precedence_df.activitylog <- function(log) {

	AID <- NULL
	CID <- NULL
	start_time <- NULL
	end_time <- NULL
	#next_activity <- NULL
	#next_start_time <- NULL
	#next_end_time <- NULL
	start <- NULL



	log_dt <- log %>%
		#as_tibble() %>%
		rename(AID = activity_id(log),
			   CID = case_id(log)) %>%
		select(AID, CID, .order, start, complete) %>%
		as.data.table()

	starts <- log_dt[order(start, complete, .order), .SD[1] , .(CID)][, c("AID", "complete", ".order") := .("Start", start, min(.order) - 1)]
	ends <- log_dt[order(start, complete, .order), .SD[.N] , .(CID)][, c("AID", "start", ".order") := .("End", complete, max(.order) + 1)]

	log_dt <- rbind(starts, log_dt, ends)

	log_dt[order(start, complete, .order), c("next_activity", "next_start_time", "next_end_time") := .(shift(as.character(AID), n = -1),
																											  shift(start, n = -1),
																											  shift(complete, n = -1)), by = .(CID)]

	as_tibble(log_dt) %>%
		rename(start_time = start,
			   end_time = complete,
			   min_order = .order)
}