package com.doumee.job; import com.alibaba.fastjson.JSON; import com.doumee.core.job.BaseJob; import com.doumee.core.job.JobContext; import com.doumee.core.job.JobParam; import com.doumee.dao.system.model.SystemPermission; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import java.util.List; /** * 自动分发的定时任务 * @author Eva.Caesar Liu * @since 2025/03/31 16:44 */ @Slf4j @Component("distributableTestJob") public class DistributableTestJob extends BaseJob { @Override public JobContext execute(JobParam param) { JobContext jobContext = new JobContext(); List permissions = param.getRuntimeData(SystemPermission.class); StringBuilder context = new StringBuilder(); for (SystemPermission permission : permissions) { context.append(JSON.toJSONString(permission)); context.append("\n"); } jobContext.setHandleSuccessSize(permissions.size()); jobContext.setHandleTotalSize(permissions.size()); jobContext.setContext(context.toString()); return jobContext; } }