/* * Decompiled with CFR 0.152. * * Could not load the following classes: * com.l7tech.gateway.common.task.JobStatus * com.l7tech.gateway.common.task.JobType * com.l7tech.gateway.common.task.ScheduledTask * com.l7tech.objectmodel.FindException * com.l7tech.objectmodel.Goid * com.l7tech.util.ExceptionUtils * com.l7tech.util.SyspropUtil * jakarta.inject.Inject * jakarta.inject.Named * org.jetbrains.annotations.Nullable * org.quartz.CronScheduleBuilder * org.quartz.JobBuilder * org.quartz.JobDetail * org.quartz.ScheduleBuilder * org.quartz.Scheduler * org.quartz.SchedulerException * org.quartz.SimpleScheduleBuilder * org.quartz.Trigger * org.quartz.TriggerBuilder * org.quartz.TriggerKey * org.quartz.TriggerListener * org.quartz.impl.StdSchedulerFactory * org.quartz.simpl.SimpleThreadPool * org.springframework.context.ApplicationContext * org.springframework.context.ApplicationEvent */ package com.l7tech.server.task; import com.l7tech.gateway.common.task.JobStatus; import com.l7tech.gateway.common.task.JobType; import com.l7tech.gateway.common.task.ScheduledTask; import com.l7tech.objectmodel.FindException; import com.l7tech.objectmodel.Goid; import com.l7tech.server.ServerConfig; import com.l7tech.server.audit.AuditContextFactory; import com.l7tech.server.cluster.ClusterInfoManager; import com.l7tech.server.cluster.ClusterMaster; import com.l7tech.server.event.EntityInvalidationEvent; import com.l7tech.server.event.system.ReadyForMessages; import com.l7tech.server.event.system.Stopped; import com.l7tech.server.identity.IdentityProviderFactory; import com.l7tech.server.polback.PolicyBackedServiceRegistry; import com.l7tech.server.task.ScheduledPolicyRunner; import com.l7tech.server.task.ScheduledServiceQuartzJob; import com.l7tech.server.task.ScheduledTaskManager; import com.l7tech.server.task.b; import com.l7tech.server.task.d; import com.l7tech.server.util.PostStartupApplicationListener; import com.l7tech.util.ExceptionUtils; import com.l7tech.util.SyspropUtil; import jakarta.inject.Inject; import jakarta.inject.Named; import java.text.MessageFormat; import java.util.Date; import java.util.GregorianCalendar; import java.util.Properties; import java.util.logging.Level; import java.util.logging.Logger; import org.jetbrains.annotations.Nullable; import org.quartz.CronScheduleBuilder; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.ScheduleBuilder; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.SimpleScheduleBuilder; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.TriggerKey; import org.quartz.TriggerListener; import org.quartz.impl.StdSchedulerFactory; import org.quartz.simpl.SimpleThreadPool; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationEvent; public class ScheduledTaskJobManager implements PostStartupApplicationListener { private static final Logger a; public static final String JOB_DETAIL_NODE; public static final String JOB_DETAIL_NAME; public static final String JOB_DETAIL_JOBTYPE; public static final String JOB_DETAIL_ENITTY_GOID; public static final String JOB_DETAIL_POLICY_GOID; public static final String JOB_DETAIL_USER_ID; public static final String JOB_DETAIL_ID_PROVIDER_GOID; public static final String JOB_DETAIL_NODE_ONE; public static final String JOB_DETAIL_NODE_ALL; private static final int b = 16000; private static final String c; static final String d; @Inject protected ScheduledTaskManager scheduledTaskManager; @Inject private ServerConfig config; @Inject protected PolicyBackedServiceRegistry pbsReg; @Inject protected IdentityProviderFactory identityProviderFactory; @Inject protected AuditContextFactory auditContextFactory; @Inject protected ApplicationContext applicationContext; @Inject @Named(value="clusterNodeId") protected String nodeId; @Inject protected ClusterMaster clusterMaster; @Inject protected ClusterInfoManager clusterInfoManager; private Scheduler e = null; private final int f = 10; private static final String[] g; /* * Unable to fully structure code */ public void onApplicationEvent(ApplicationEvent var1_1) { block22: { block23: { block21: { try { if (!(var1_1 instanceof ReadyForMessages)) break block21; this.b(); break block22; } catch (FindException v0) { throw ScheduledTaskJobManager.a((Exception)v0); } } try { if (!(var1_1 instanceof Stopped)) break block23; this.a(); break block22; } catch (FindException v1) { throw ScheduledTaskJobManager.a((Exception)v1); } } if (!(var1_1 instanceof EntityInvalidationEvent) || !ScheduledTask.class.equals((var2_2 = (EntityInvalidationEvent)var1_1).getEntityClass())) break block22; block20: for (var3_3 = 0; var3_3 < var2_2.getEntityOperations().length; ++var3_3) { var4_4 = var2_2.getEntityOperations()[var3_3]; var5_5 = var2_2.getEntityIds()[var3_3]; switch (var4_4) { case 'C': case 'U': { try { var6_6 = (ScheduledTask)this.scheduledTaskManager.findByPrimaryKey(var5_5); this.scheduleJob(var6_6); if (var4_4 != 'C') continue block20; if (!var6_6.getJobType().equals((Object)JobType.RECURRING)) continue block20; ** GOTO lbl32 catch (FindException v2) { throw ScheduledTaskJobManager.a((Exception)v2); } lbl32: // 2 sources if (!var6_6.getJobStatus().equals((Object)JobStatus.SCHEDULED)) continue block20; ** GOTO lbl36 catch (FindException v3) { throw ScheduledTaskJobManager.a((Exception)v3); } lbl36: // 1 sources try { if (!var6_6.isExecuteOnCreate()) continue block20; ** GOTO lbl41 catch (FindException v4) { throw ScheduledTaskJobManager.a((Exception)v4); } lbl41: // 1 sources this.a(var6_6, this.c(), ScheduledTaskJobManager.g[15]); ** break; } catch (FindException v5) { throw ScheduledTaskJobManager.a((Exception)v5); lbl45: // 1 sources continue block20; } } catch (FindException var6_7) { try { if (!ScheduledTaskJobManager.a.isLoggable(Level.WARNING)) continue block20; ScheduledTaskJobManager.a.log(Level.WARNING, MessageFormat.format(ScheduledTaskJobManager.g[0], new Object[]{var5_5}), var6_7); continue block20; } catch (FindException v6) { throw ScheduledTaskJobManager.a((Exception)v6); } } } case 'D': { this.removeJob(var5_5); } } } } } private void a() { if (this.e != null) { try { this.e.shutdown(); } catch (SchedulerException schedulerException) { a.log(Level.WARNING, g[18], schedulerException); } } } /* * Enabled force condition propagation * Lifted jumps to return sites */ private void b() { try { ScheduledPolicyRunner.getInstance(this); for (ScheduledTask scheduledTask : this.scheduledTaskManager.findAll()) { try { if (!scheduledTask.getJobStatus().equals((Object)JobStatus.SCHEDULED)) continue; this.scheduleJob(scheduledTask); } catch (Exception exception) { throw ScheduledTaskJobManager.a(exception); return; } } } catch (Exception exception) { a.log(Level.WARNING, g[31], ExceptionUtils.getDebugException((Throwable)exception)); } } protected Scheduler getScheduler() { if (this.e == null) { try { String[] stringArray = g; int n2 = this.config.getIntProperty(stringArray[37], 10); SimpleThreadPool simpleThreadPool = new SimpleThreadPool(n2, 5); simpleThreadPool.initialize(); Properties properties = new Properties(); properties.setProperty(stringArray[30], stringArray[20]); properties.setProperty(stringArray[8], Integer.toString(n2)); StdSchedulerFactory stdSchedulerFactory = new StdSchedulerFactory(properties); this.e = stdSchedulerFactory.getScheduler(); if (this.e == null) { a.log(Level.WARNING, stringArray[12]); return null; } this.e.getListenerManager().addTriggerListener((TriggerListener)new d(this)); this.e.start(); stringArray = g; a.log(Level.INFO, stringArray[32]); } catch (Exception exception) { a.log(Level.WARNING, g[40], ExceptionUtils.getDebugException((Throwable)exception)); } } return this.e; } public void scheduleJob(ScheduledTask scheduledTask) { if (scheduledTask.getJobStatus().equals((Object)JobStatus.DISABLED)) { this.removeJob(scheduledTask.getGoid()); return; } switch (com.l7tech.server.task.b.a[scheduledTask.getJobType().ordinal()]) { case 1: { this.scheduleOneTimeJob(scheduledTask); break; } case 2: { this.scheduleRecurringJob(scheduledTask); break; } default: { a.info(g[6] + String.valueOf(scheduledTask.getJobType())); } } } public void scheduleOneTimeJob(ScheduledTask scheduledTask) { this.a(scheduledTask, new Date(scheduledTask.getExecutionDate()), null); } private void a(ScheduledTask scheduledTask, Date date, String string) { block10: { try { if (scheduledTask.getJobStatus().equals((Object)JobStatus.COMPLETED)) { return; } } catch (Exception exception) { throw ScheduledTaskJobManager.a(exception); } try { block12: { JobDetail jobDetail; Trigger trigger; block11: { block9: { trigger = this.a(scheduledTask, TriggerBuilder.newTrigger().startAt(date).withSchedule((ScheduleBuilder)SimpleScheduleBuilder.simpleSchedule().withMisfireHandlingInstructionIgnoreMisfires()), string); try { if (!this.getScheduler().checkExists(trigger.getKey())) break block9; this.getScheduler().rescheduleJob(trigger.getKey(), trigger); a.log(Level.INFO, g[43] + scheduledTask.getName()); break block10; } catch (Exception exception) { throw ScheduledTaskJobManager.a(exception); } } jobDetail = this.a(scheduledTask); try { if (!this.getScheduler().checkExists(jobDetail.getKey())) break block11; this.getScheduler().scheduleJob(trigger); break block12; } catch (Exception exception) { throw ScheduledTaskJobManager.a(exception); } } this.getScheduler().scheduleJob(jobDetail, trigger); } String[] stringArray = g; a.log(Level.INFO, stringArray[17] + scheduledTask.getName()); } catch (Exception exception) { String[] stringArray = g; a.log(Level.WARNING, stringArray[2] + scheduledTask.getName() + stringArray[19] + ExceptionUtils.getMessage((Throwable)exception), ExceptionUtils.getDebugException((Throwable)exception)); } } } private Date c() { String[] stringArray = g; Integer n2 = SyspropUtil.getInteger((String)stringArray[26], (int)16000); a.log(Level.INFO, stringArray[13] + n2 + stringArray[3]); GregorianCalendar gregorianCalendar = new GregorianCalendar(); gregorianCalendar.setTimeInMillis(System.currentTimeMillis()); gregorianCalendar.add(14, n2); return gregorianCalendar.getTime(); } private JobDetail a(ScheduledTask scheduledTask) { return JobBuilder.newJob(ScheduledServiceQuartzJob.class).withIdentity(scheduledTask.getId()).build(); } private Trigger a(ScheduledTask scheduledTask, TriggerBuilder triggerBuilder, @Nullable String string) { String string2; String string3 = string == null ? scheduledTask.getId() : scheduledTask.getId() + string; TriggerBuilder triggerBuilder2 = triggerBuilder.withIdentity(string3); String[] stringArray = g; String string4 = stringArray[34]; if (scheduledTask.isUseOneNode()) { string2 = stringArray[35]; } else { stringArray = g; string2 = stringArray[10]; } stringArray = g; return triggerBuilder2.usingJobData(string4, string2).usingJobData(stringArray[41], scheduledTask.getName()).usingJobData(stringArray[39], scheduledTask.getJobType().toString()).usingJobData(stringArray[36], scheduledTask.getId()).usingJobData(stringArray[33], scheduledTask.getPolicyGoid().toString()).usingJobData(stringArray[24], scheduledTask.getIdProviderGoid() == null ? (String)null : scheduledTask.getIdProviderGoid().toString()).usingJobData(g[23], scheduledTask.getUserId()).forJob(scheduledTask.getId()).build(); } private Trigger a(ScheduledTask scheduledTask, TriggerBuilder triggerBuilder) { return this.a(scheduledTask, triggerBuilder, null); } public void scheduleRecurringJob(ScheduledTask scheduledTask) { block5: { Trigger trigger = this.a(scheduledTask, TriggerBuilder.newTrigger().withSchedule((ScheduleBuilder)CronScheduleBuilder.cronSchedule((String)scheduledTask.getCronExpression()).withMisfireHandlingInstructionIgnoreMisfires())); try { block4: { try { if (!this.getScheduler().checkExists(TriggerKey.triggerKey((String)scheduledTask.getId()))) break block4; this.getScheduler().rescheduleJob(TriggerKey.triggerKey((String)scheduledTask.getId()), trigger); a.log(Level.INFO, g[29] + scheduledTask.getName()); break block5; } catch (Exception exception) { throw ScheduledTaskJobManager.a(exception); } } this.getScheduler().scheduleJob(this.a(scheduledTask), trigger); String[] stringArray = g; a.log(Level.INFO, stringArray[4] + scheduledTask.getName()); } catch (Exception exception) { a.log(Level.WARNING, g[1] + scheduledTask.getName(), ExceptionUtils.getDebugException((Throwable)exception)); } } } public void removeJob(Goid goid) { try { boolean bl2 = this.getScheduler().unscheduleJob(TriggerKey.triggerKey((String)goid.toString())); try { if (bl2) { a.log(Level.INFO, g[25] + goid.toString()); } } catch (Exception exception) { throw ScheduledTaskJobManager.a(exception); } } catch (Exception exception) { a.log(Level.WARNING, g[14] + goid.toString(), ExceptionUtils.getDebugException((Throwable)exception)); } } /* * Unable to fully structure code */ static { block10: { block9: { var5 = new String[44]; var3_1 = 0; var2_2 = "\u001d0\t\u001a0WT<1H\u001e5\\\u0010h=\u001a\u001d=F\u0011,q\u001d\b8S\u0000-:H\u000b?Z\u0011,+\u0004\u001d8\u0012\u0000)-\u0003X\u007fID50\u000e?\u0001\u0014|F\u001bh=\u001a\u001d=F\u0011h,\r\u001b)@\u0006!0\u000fX6]\u0016h8\u0007\n|A\u0017 ;\f\r0W\u0010h*\t\u000b7\u0012/\u000e?\u0001\u0014|F\u001bh=\u001a\u001d=F\u0011h1\u0006\u001d|F\u001d%;H\u00123PT.1\u001aX/Q\u001c-:\u001d\u00149VT;\u001aV(S\u0007#p;\u001b4W\u0010=2\r\u001c\bS\u0007#\u0014\u0007\u001a\u0011S\u001a)9\r\nrQ\u0006-?\u001c\u001drV\u0011$?\u0011V1[\u0018$7\u001b\u0012\u001d0\u0003\u00163E\u001ah4\u0007\u001a|F\r8;RX\n81\u0004\u0011?K3'7\f!',\u000fV-G\u0015:*\u0012V(Z\u0006-?\f(3]\u0018f*\u0000\n9S\u0010\u000b1\u001d\u0016(\u0003\u00070\r\u0003\t2\u0004\u0004&?\u0005\u001d\u001a\u000e?\u0001\u00149VT<1H\u001b.W\u0015<;H\u000b?Z\u0011,+\u0004\u001d.\u0017\u00070H\u001b.W\u0015<;H\u001c9^\u00151~\u001b\u001d(\u0012\u0000'~\u001e\u000e?\u0001\u00149VT<1H\n9_\u001b>;H\u00123PT?7\u001c\u0010|[\u0010r~\te1\u0006;.W\u0015<;\u0006=-\r\n\u0015V\u001b\u00070\rX([\u0019-~\u0002\u0017>\u0012\u0007+6\r\u001c)^\u0011,~\u000e\u0017.\u0012!\u000e?\u0001\u00149VT<1H\u000b4G\u0000<7\u0006\u001f|V\u001b?0H\u000b?Z\u0011,+\u0004\u001d.\u0002r~\u0004<,\u001d\u001d\te1\u0006;.W\u0015<;\u0003\t2\u0004\u0006=-\r\n\u0015V\u000e!:8\n3D\u001d,;\u001a?3[\u0010\"\u00021\nX.W\u0019'(\r\u001c|T\u001b:~\u001b\u001b4W\u0010=2\r\u001c|F\u0015;5H\u00118\bB+1\u0005V0\u0005\u0000-=\u0000V/W\u0006>;\u001aV(S\u0007#p;\u001b4W\u0010=2\r\u001c\bS\u0007#\u0014\u0007\u001a\u0011S\u001a)9\r\nrQ\u0006-?\u001c\u001drV\u0011$?\u0011V1[\u0018$7\u001b\u0007\"1\n,%B\u0011\u0004&1\f\u001d\u001e\u001a;\u000b\r.@\u001d&9H\u00123PT:;\u001b\u001b4W\u0010=2\r\u001c|T\u001b:~$',\u000fV-G\u0015:*\u0012V/Q\u001c-:\u001d\u00149@Z;5\u0001\b\tB\u0010)*\r;4W\u0017#\u001f\u000e?\u0001\u00149VT<1H\u001b.W\u0015<;H\u000b?Z\u0011,+\u0004\u001d8\u0012\u001e'<\u001b\u0015\u001b=\u0000\u001d8G\u0018-,H\u00112[\u0000!?\u0004\u0011&W\u0010\n81\u0004\u0011?K3'7\f\u0004&1\f\u001d\u0003\u00070\r\n-0\u001c\u0011(K3'7\f\u0018;=\u0000\u001d8G\u0018-:<\u0019/YZ%?\u0010,4@\u0011):\u001b\u000e!:8\n3D\u001d,;\u001a?3[\u0010\u0007\"1\n,%B\u0011\u001a\u000e?\u0001\u00149VT<1H\u001b.W\u0015<;H\u000b?Z\u0011,+\u0004\u001d.\u0004&?\u0005\u001d"; var4_3 = "\u001d0\t\u001a0WT<1H\u001e5\\\u0010h=\u001a\u001d=F\u0011,q\u001d\b8S\u0000-:H\u000b?Z\u0011,+\u0004\u001d8\u0012\u0000)-\u0003X\u007fID50\u000e?\u0001\u0014|F\u001bh=\u001a\u001d=F\u0011h,\r\u001b)@\u0006!0\u000fX6]\u0016h8\u0007\n|A\u0017 ;\f\r0W\u0010h*\t\u000b7\u0012/\u000e?\u0001\u0014|F\u001bh=\u001a\u001d=F\u0011h1\u0006\u001d|F\u001d%;H\u00123PT.1\u001aX/Q\u001c-:\u001d\u00149VT;\u001aV(S\u0007#p;\u001b4W\u0010=2\r\u001c\bS\u0007#\u0014\u0007\u001a\u0011S\u001a)9\r\nrQ\u0006-?\u001c\u001drV\u0011$?\u0011V1[\u0018$7\u001b\u0012\u001d0\u0003\u00163E\u001ah4\u0007\u001a|F\r8;RX\n81\u0004\u0011?K3'7\f!',\u000fV-G\u0015:*\u0012V(Z\u0006-?\f(3]\u0018f*\u0000\n9S\u0010\u000b1\u001d\u0016(\u0003\u00070\r\u0003\t2\u0004\u0004&?\u0005\u001d\u001a\u000e?\u0001\u00149VT<1H\u001b.W\u0015<;H\u000b?Z\u0011,+\u0004\u001d.\u0017\u00070H\u001b.W\u0015<;H\u001c9^\u00151~\u001b\u001d(\u0012\u0000'~\u001e\u000e?\u0001\u00149VT<1H\n9_\u001b>;H\u00123PT?7\u001c\u0010|[\u0010r~\te1\u0006;.W\u0015<;\u0006=-\r\n\u0015V\u001b\u00070\rX([\u0019-~\u0002\u0017>\u0012\u0007+6\r\u001c)^\u0011,~\u000e\u0017.\u0012!\u000e?\u0001\u00149VT<1H\u000b4G\u0000<7\u0006\u001f|V\u001b?0H\u000b?Z\u0011,+\u0004\u001d.\u0002r~\u0004<,\u001d\u001d\te1\u0006;.W\u0015<;\u0003\t2\u0004\u0006=-\r\n\u0015V\u000e!:8\n3D\u001d,;\u001a?3[\u0010\"\u00021\nX.W\u0019'(\r\u001c|T\u001b:~\u001b\u001b4W\u0010=2\r\u001c|F\u0015;5H\u00118\bB+1\u0005V0\u0005\u0000-=\u0000V/W\u0006>;\u001aV(S\u0007#p;\u001b4W\u0010=2\r\u001c\bS\u0007#\u0014\u0007\u001a\u0011S\u001a)9\r\nrQ\u0006-?\u001c\u001drV\u0011$?\u0011V1[\u0018$7\u001b\u0007\"1\n,%B\u0011\u0004&1\f\u001d\u001e\u001a;\u000b\r.@\u001d&9H\u00123PT:;\u001b\u001b4W\u0010=2\r\u001c|T\u001b:~$',\u000fV-G\u0015:*\u0012V/Q\u001c-:\u001d\u00149@Z;5\u0001\b\tB\u0010)*\r;4W\u0017#\u001f\u000e?\u0001\u00149VT<1H\u001b.W\u0015<;H\u000b?Z\u0011,+\u0004\u001d8\u0012\u001e'<\u001b\u0015\u001b=\u0000\u001d8G\u0018-,H\u00112[\u0000!?\u0004\u0011&W\u0010\n81\u0004\u0011?K3'7\f\u0004&1\f\u001d\u0003\u00070\r\n-0\u001c\u0011(K3'7\f\u0018;=\u0000\u001d8G\u0018-:<\u0019/YZ%?\u0010,4@\u0011):\u001b\u000e!:8\n3D\u001d,;\u001a?3[\u0010\u0007\"1\n,%B\u0011\u001a\u000e?\u0001\u00149VT<1H\u001b.W\u0015<;H\u000b?Z\u0011,+\u0004\u001d.\u0004&?\u0005\u001d".length(); var1_4 = 50; var0_5 = -1; lbl7: // 2 sources while (true) { v0 = 1; v1 = ++var0_5; v2 = var2_2.substring(v1, v1 + var1_4); v3 = -1; break block9; break; } lbl13: // 1 sources while (true) { var5[var3_1++] = ScheduledTaskJobManager.a(v0, ScheduledTaskJobManager.a(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } var2_2 = "a|P]d\u0007\u007fk{@\u001dK|A\u0014d\u0017Ua2N[r^JaaG\\u\u001aMhw@\u0014v\u0011J$"; var4_3 = "a|P]d\u0007\u007fk{@\u001dK|A\u0014d\u0017Ua2N[r^JaaG\\u\u001aMhw@\u0014v\u0011J$".length(); var1_4 = 10; var0_5 = -1; lbl22: // 2 sources while (true) { v0 = 77; v4 = ++var0_5; v2 = var2_2.substring(v4, v4 + var1_4); v3 = 0; break block9; break; } break; } lbl28: // 1 sources while (true) { var5[var3_1++] = ScheduledTaskJobManager.a(v0, ScheduledTaskJobManager.a(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } break block10; break; } } switch (v3) { default: { ** continue; } ** case 0: lbl39: // 1 sources ** continue; } } ScheduledTaskJobManager.g = var5; ScheduledTaskJobManager.JOB_DETAIL_NODE_ALL = ScheduledTaskJobManager.g[22]; ScheduledTaskJobManager.d = ScheduledTaskJobManager.g[21]; ScheduledTaskJobManager.c = ScheduledTaskJobManager.g[5]; ScheduledTaskJobManager.JOB_DETAIL_NODE = ScheduledTaskJobManager.g[28]; ScheduledTaskJobManager.JOB_DETAIL_ENITTY_GOID = ScheduledTaskJobManager.g[42]; ScheduledTaskJobManager.JOB_DETAIL_ID_PROVIDER_GOID = ScheduledTaskJobManager.g[38]; ScheduledTaskJobManager.JOB_DETAIL_JOBTYPE = ScheduledTaskJobManager.g[27]; ScheduledTaskJobManager.JOB_DETAIL_POLICY_GOID = ScheduledTaskJobManager.g[7]; ScheduledTaskJobManager.JOB_DETAIL_NAME = ScheduledTaskJobManager.g[11]; ScheduledTaskJobManager.JOB_DETAIL_NODE_ONE = ScheduledTaskJobManager.g[9]; ScheduledTaskJobManager.JOB_DETAIL_USER_ID = ScheduledTaskJobManager.g[16]; ScheduledTaskJobManager.a = Logger.getLogger(ScheduledTaskJobManager.class.getName()); } private static Exception a(Exception exception) { return exception; } private static char[] a(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0x75); } return cArray; } /* * Handled impossible loop by duplicating code * Enabled aggressive block sorting */ private static String a(int n2, char[] cArray) { char[] cArray2; block11: { int n3; int n4; int n5; block10: { n5 = n2; cArray2 = cArray; n4 = cArray.length; n3 = 0; if (!true) break block10; n4 = n4; if (n4 <= n3) break block11; } do { n5 = n5; cArray2 = cArray2; int n6 = n3; cArray2[n6] = (char)(cArray2[n6] ^ (n5 ^ (switch (n3 % 7) { case 0 -> 73; case 1 -> 95; case 2 -> 105; case 3 -> 121; case 4 -> 93; case 5 -> 51; default -> 117; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } }