Seitenhistorie

import java.util.ArrayList;
import java.util.Calendar;
import java.util.List;

import org.nuclos.api.context.JobContext;
import org.nuclos.api.exception.BusinessException;
import org.nuclos.api.provider.QueryProvider;
import org.nuclos.api.provider.UserProvider;
import org.nuclos.api.rule.JobRule;
import org.nuclos.api.rule.TransactionalJobRule;
import org.nuclos.system.User;

public class DSGVOGesperrteUserLoeschen implements JobRule, TransactionalJobRule {
	@Override
	public void execute(final JobContext context) throws BusinessException {
		User user = (User) context.getTransactionalObject();
		context.joblog("delete user " + user.getUsername());
		UserProvider.delete(user);
	}

	@Override
	public List<Object> getTransactionalObjects(final JobContext context) {
		Calendar calendar = Calendar.getInstance();
		calendar.add(Calendar.DAY_OF_YEAR, -90); // Letzte Änderung am User ist 90 Tage her
		return new ArrayList<>(QueryProvider.execute(QueryProvider.create(User.class)
				.where(User.Locked.eq(true))
				.and(User.ChangedAt.Lt(calendar.getTime()))));
	}
}

Äußerste Vorsicht bei Verwendung dieser Funktion ist geboten. Fehldatenbestände könnten sonst die Folge sein!

import java.util.Arrays;
import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

import org.nuclos.api.businessobject.Query;
import org.nuclos.api.businessobject.attribute.Attribute;
import org.nuclos.api.businessobject.attribute.NumericAttribute;
import org.nuclos.api.businessobject.facade.Modifiable;
import org.nuclos.api.context.JobContext;
import org.nuclos.api.exception.BusinessException;
import org.nuclos.api.provider.BusinessObjectProvider;
import org.nuclos.api.provider.QueryProvider;
import org.nuclos.api.rule.JobRule;
import org.nuclos.api.rule.TransactionalJobRule;
import org.nuclos.api.transaction.CurrentTransaction;

public class DSGVOAnonymisiereAlleMetainformationen implements JobRule, TransactionalJobRule {

	private JobContext context;

	@Override
	public void execute(final JobContext context) throws BusinessException {
		this.context = context;
		Class entityClass = (Class) context.getTransactionalObject();
		String className = entityClass.getName();
		Attribute changedBy = getAttribute(entityClass, "ChangedBy");
		NumericAttribute changedAt = (NumericAttribute) getAttribute(entityClass, "ChangedAt");

		Calendar calendar = Calendar.getInstance();
		calendar.add(Calendar.DAY_OF_YEAR, -90);
		Date dateLastChange90d = calendar.getTime(); // Letzte Änderung ist 90 Tage her

		CurrentTransaction.disableRuleExecution();
		CurrentTransaction.disableBusinessObjectMetaUpdate();

		long countAnonymized = processQuery(className, QueryProvider.create(entityClass)
				.where(changedBy.neq("*****"))
				.and(changedAt.Lt(dateLastChange90d)));

		context.joblog(String.format("%s: %d anonymized", className, countAnonymized));
	}

	private long processQuery(final String className, final Query query) throws BusinessException {
		final long chunkSize = 500;
		final long offset = 0;
		query.setChunkSize(chunkSize);
		query.setOffset(offset);
		long counter = 0;
		boolean existMoreEntries = true;
		while (existMoreEntries) {
			context.joblog(String.format("%s: process objects %d - %d", className, counter, (counter + chunkSize)));
			List entries = QueryProvider.execute(query);
			if (entries.isEmpty()) {
				existMoreEntries = false;
			}
			else {
				for (Object entry : entries) {
					Modifiable modifiable = (Modifiable) entry;
					modifiable.setCreatedBy("*****");
					modifiable.setChangedBy("*****");
					modifiable.save();
					counter++;
				}
				if (entries.size() < chunkSize) {
					existMoreEntries = false;
				}
			}
		}
		return counter;
	}

	private Attribute getAttribute(Class entityClass, String name) {
		return Arrays.stream(entityClass.getDeclaredFields())
				.filter(field -> field.getName().equals(name))
				.findFirst()
				.map(field -> {
					try {
						return (Attribute) field.get(null);
					} catch (IllegalAccessException ex) {
						throw new RuntimeException(ex);
					}
				})
				.orElseThrow(() -> new RuntimeException(String.format("Attribute %s.%s does not exist", entityClass, name)));
	}

	@Override
	public List<Object> getTransactionalObjects(final JobContext context) {
		return BusinessObjectProvider.getAllModifiableBusinessObjectClassNames().stream()
				.sorted()
				.map(className -> {
					try {
						return Class.forName(className);
					} catch (ClassNotFoundException e) {
						throw new RuntimeException(e);
					}
				})
				.collect(Collectors.toList());
	}
}