package com.l7tech.server.task; import com.l7tech.gateway.common.task.JobStatus; import com.l7tech.gateway.common.task.ScheduledTask; 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.identity.IdentityProviderFactory; import com.l7tech.server.polback.PolicyBackedServiceRegistry; 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.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.Scheduler; import org.quartz.SchedulerException; import org.quartz.SimpleScheduleBuilder; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.TriggerKey; 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("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; @Override public void onApplicationEvent(ApplicationEvent param1) { // $VF: Couldn't be decompiled // Please report this to the Vineflower issue tracker, at https://github.com/Vineflower/vineflower/issues with a copy of the class file (if you have the rights to distribute it!) // java.lang.RuntimeException: parsing failure! // at org.jetbrains.java.decompiler.modules.decompiler.decompose.DomHelper.parseGraph(DomHelper.java:211) // at org.jetbrains.java.decompiler.main.rels.MethodProcessor.codeToJava(MethodProcessor.java:174) // // Bytecode: // 000: aload 1 // 001: instanceof com/l7tech/server/event/system/ReadyForMessages // 004: ifeq 012 // 007: aload 0 // 008: invokevirtual com/l7tech/server/task/ScheduledTaskJobManager.b ()V // 00b: goto 12c // 00e: invokestatic com/l7tech/server/task/ScheduledTaskJobManager.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 011: athrow // 012: aload 1 // 013: instanceof com/l7tech/server/event/system/Stopped // 016: ifeq 024 // 019: aload 0 // 01a: invokevirtual com/l7tech/server/task/ScheduledTaskJobManager.a ()V // 01d: goto 12c // 020: invokestatic com/l7tech/server/task/ScheduledTaskJobManager.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 023: athrow // 024: aload 1 // 025: instanceof com/l7tech/server/event/EntityInvalidationEvent // 028: ifeq 12c // 02b: aload 1 // 02c: checkcast com/l7tech/server/event/EntityInvalidationEvent // 02f: astore 2 // 030: ldc com/l7tech/gateway/common/task/ScheduledTask // 032: aload 2 // 033: invokevirtual com/l7tech/server/event/EntityInvalidationEvent.getEntityClass ()Ljava/lang/Class; // 036: invokevirtual java/lang/Object.equals (Ljava/lang/Object;)Z // 039: ifeq 12c // 03c: bipush 0 // 03d: istore 3 // 03e: iload 3 // 03f: aload 2 // 040: invokevirtual com/l7tech/server/event/EntityInvalidationEvent.getEntityOperations ()[C // 043: arraylength // 044: if_icmpge 12c // 047: aload 2 // 048: invokevirtual com/l7tech/server/event/EntityInvalidationEvent.getEntityOperations ()[C // 04b: iload 3 // 04c: caload // 04d: istore 4 // 04f: aload 2 // 050: invokevirtual com/l7tech/server/event/EntityInvalidationEvent.getEntityIds ()[Lcom/l7tech/objectmodel/Goid; // 053: iload 3 // 054: aaload // 055: astore 5 // 057: iload 4 // 059: lookupswitch 205 3 67 35 68 199 85 35 // 07c: aload 0 // 07d: getfield com/l7tech/server/task/ScheduledTaskJobManager.scheduledTaskManager Lcom/l7tech/server/task/ScheduledTaskManager; // 080: aload 5 // 082: invokeinterface com/l7tech/server/task/ScheduledTaskManager.findByPrimaryKey (Lcom/l7tech/objectmodel/Goid;)Lcom/l7tech/objectmodel/PersistentEntity; 2 // 087: checkcast com/l7tech/gateway/common/task/ScheduledTask // 08a: astore 6 // 08c: aload 0 // 08d: aload 6 // 08f: invokevirtual com/l7tech/server/task/ScheduledTaskJobManager.scheduleJob (Lcom/l7tech/gateway/common/task/ScheduledTask;)V // 092: iload 4 // 094: bipush 67 // 096: if_icmpne 0e9 // 099: aload 6 // 09b: invokevirtual com/l7tech/gateway/common/task/ScheduledTask.getJobType ()Lcom/l7tech/gateway/common/task/JobType; // 09e: getstatic com/l7tech/gateway/common/task/JobType.RECURRING Lcom/l7tech/gateway/common/task/JobType; // 0a1: invokevirtual com/l7tech/gateway/common/task/JobType.equals (Ljava/lang/Object;)Z // 0a4: ifeq 0e9 // 0a7: goto 0ae // 0aa: invokestatic com/l7tech/server/task/ScheduledTaskJobManager.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 0ad: athrow // 0ae: aload 6 // 0b0: invokevirtual com/l7tech/gateway/common/task/ScheduledTask.getJobStatus ()Lcom/l7tech/gateway/common/task/JobStatus; // 0b3: getstatic com/l7tech/gateway/common/task/JobStatus.SCHEDULED Lcom/l7tech/gateway/common/task/JobStatus; // 0b6: invokevirtual com/l7tech/gateway/common/task/JobStatus.equals (Ljava/lang/Object;)Z // 0b9: ifeq 0e9 // 0bc: goto 0c3 // 0bf: invokestatic com/l7tech/server/task/ScheduledTaskJobManager.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 0c2: athrow // 0c3: aload 6 // 0c5: invokevirtual com/l7tech/gateway/common/task/ScheduledTask.isExecuteOnCreate ()Z // 0c8: ifeq 0e9 // 0cb: goto 0d2 // 0ce: invokestatic com/l7tech/server/task/ScheduledTaskJobManager.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 0d1: athrow // 0d2: aload 0 // 0d3: aload 6 // 0d5: aload 0 // 0d6: invokevirtual com/l7tech/server/task/ScheduledTaskJobManager.c ()Ljava/util/Date; // 0d9: getstatic com/l7tech/server/task/ScheduledTaskJobManager.g [Ljava/lang/String; // 0dc: bipush 15 // 0de: aaload // 0df: invokevirtual com/l7tech/server/task/ScheduledTaskJobManager.a (Lcom/l7tech/gateway/common/task/ScheduledTask;Ljava/util/Date;Ljava/lang/String;)V // 0e2: goto 0e9 // 0e5: invokestatic com/l7tech/server/task/ScheduledTaskJobManager.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 0e8: athrow // 0e9: goto 126 // 0ec: astore 6 // 0ee: getstatic com/l7tech/server/task/ScheduledTaskJobManager.a Ljava/util/logging/Logger; // 0f1: getstatic java/util/logging/Level.WARNING Ljava/util/logging/Level; // 0f4: invokevirtual java/util/logging/Logger.isLoggable (Ljava/util/logging/Level;)Z // 0f7: ifeq 11d // 0fa: getstatic com/l7tech/server/task/ScheduledTaskJobManager.a Ljava/util/logging/Logger; // 0fd: getstatic java/util/logging/Level.WARNING Ljava/util/logging/Level; // 100: getstatic com/l7tech/server/task/ScheduledTaskJobManager.g [Ljava/lang/String; // 103: bipush 0 // 104: aaload // 105: bipush 1 // 106: anewarray 139 // 109: dup // 10a: bipush 0 // 10b: aload 5 // 10d: aastore // 10e: invokestatic java/text/MessageFormat.format (Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; // 111: aload 6 // 113: invokevirtual java/util/logging/Logger.log (Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V // 116: goto 11d // 119: invokestatic com/l7tech/server/task/ScheduledTaskJobManager.a (Ljava/lang/Exception;)Ljava/lang/Exception; // 11c: athrow // 11d: goto 126 // 120: aload 0 // 121: aload 5 // 123: invokevirtual com/l7tech/server/task/ScheduledTaskJobManager.removeJob (Lcom/l7tech/objectmodel/Goid;)V // 126: iinc 3 1 // 129: goto 03e // 12c: return // try (74 -> 88): 89 com/l7tech/objectmodel/FindException // try (66 -> 77): 78 com/l7tech/objectmodel/FindException // try (58 -> 71): 72 com/l7tech/objectmodel/FindException // try (52 -> 63): 64 com/l7tech/objectmodel/FindException // try (8 -> 14): 14 com/l7tech/objectmodel/FindException // try (0 -> 6): 6 com/l7tech/objectmodel/FindException // try (46 -> 91): 92 com/l7tech/objectmodel/FindException // try (93 -> 111): 112 com/l7tech/objectmodel/FindException } private void a() { if (this.e != null) { try { this.e.shutdown(); } catch (SchedulerException var2) { a.log(Level.WARNING, g[18], var2); } } } private void b() { try { ScheduledPolicyRunner.getInstance(this); for (ScheduledTask var2 : this.scheduledTaskManager.findAll()) { try { if (var2.getJobStatus().equals(JobStatus.SCHEDULED)) { this.scheduleJob(var2); } } catch (Exception var3) { throw a(var3); } } } catch (Exception var4) { a.log(Level.WARNING, g[31], ExceptionUtils.getDebugException(var4)); } } protected Scheduler getScheduler() { if (this.e == null) { try { String[] var5 = g; int var1 = this.config.getIntProperty(var5[37], 10); SimpleThreadPool var2 = new SimpleThreadPool(var1, 5); var2.initialize(); Properties var3 = new Properties(); var3.setProperty(var5[30], var5[20]); var3.setProperty(var5[8], Integer.toString(var1)); StdSchedulerFactory var4 = new StdSchedulerFactory(var3); this.e = var4.getScheduler(); if (this.e == null) { a.log(Level.WARNING, var5[12]); return null; } this.e.getListenerManager().addTriggerListener(new d(this)); this.e.start(); var5 = g; a.log(Level.INFO, var5[32]); } catch (Exception var6) { a.log(Level.WARNING, g[40], ExceptionUtils.getDebugException(var6)); } } return this.e; } public void scheduleJob(ScheduledTask var1) { if (var1.getJobStatus().equals(JobStatus.DISABLED)) { this.removeJob(var1.getGoid()); } else { switch (com.l7tech.server.task.b.a[var1.getJobType().ordinal()]) { case 1: this.scheduleOneTimeJob(var1); break; case 2: this.scheduleRecurringJob(var1); break; default: a.info(g[6] + var1.getJobType()); } } } public void scheduleOneTimeJob(ScheduledTask var1) { this.a(var1, new Date(var1.getExecutionDate()), null); } private void a(ScheduledTask var1, Date var2, String var3) { try { if (var1.getJobStatus().equals(JobStatus.COMPLETED)) { return; } } catch (Exception var10) { throw a(var10); } try { Trigger var4 = this.a( var1, TriggerBuilder.newTrigger().startAt(var2).withSchedule(SimpleScheduleBuilder.simpleSchedule().withMisfireHandlingInstructionIgnoreMisfires()), var3 ); try { if (this.getScheduler().checkExists(var4.getKey())) { this.getScheduler().rescheduleJob(var4.getKey(), var4); a.log(Level.INFO, g[43] + var1.getName()); return; } } catch (Exception var8) { throw a(var8); } JobDetail var5 = this.a(var1); label30: { try { if (this.getScheduler().checkExists(var5.getKey())) { this.getScheduler().scheduleJob(var4); break label30; } } catch (Exception var7) { throw a(var7); } this.getScheduler().scheduleJob(var5, var4); } Logger var12 = a; Level var13 = Level.INFO; String var14 = var1.getName(); String[] var11 = g; var12.log(var13, var11[17] + var14); } catch (Exception var9) { Logger var10000 = a; Level var10001 = Level.WARNING; String var10002 = var1.getName(); String var10003 = ExceptionUtils.getMessage(var9); String[] var6 = g; var10000.log(var10001, var6[2] + var10002 + var6[19] + var10003, ExceptionUtils.getDebugException(var9)); } } private Date c() { String[] var3 = g; Integer var1 = SyspropUtil.getInteger(var3[26], 16000); a.log(Level.INFO, var3[13] + var1 + var3[3]); GregorianCalendar var2 = new GregorianCalendar(); var2.setTimeInMillis(System.currentTimeMillis()); var2.add(14, var1); return var2.getTime(); } private JobDetail a(ScheduledTask var1) { return JobBuilder.newJob(ScheduledServiceQuartzJob.class).withIdentity(var1.getId()).build(); } private Trigger a(ScheduledTask var1, TriggerBuilder var2, @Nullable String var3) { String var4 = var3 == null ? var1.getId() : var1.getId() + var3; TriggerBuilder var10000 = var2.withIdentity(var4); String[] var5 = g; String var10001 = var5[34]; String var10002; if (var1.isUseOneNode()) { var10002 = var5[35]; } else { var5 = g; var10002 = var5[10]; } var10000 = var10000.usingJobData(var10001, var10002); var5 = g; return var10000.usingJobData(var5[41], var1.getName()) .usingJobData(var5[39], var1.getJobType().toString()) .usingJobData(var5[36], var1.getId()) .usingJobData(var5[33], var1.getPolicyGoid().toString()) .usingJobData(var5[24], var1.getIdProviderGoid() == null ? (String)null : var1.getIdProviderGoid().toString()) .usingJobData(g[23], var1.getUserId()) .forJob(var1.getId()) .build(); } private Trigger a(ScheduledTask var1, TriggerBuilder var2) { return this.a(var1, var2, null); } public void scheduleRecurringJob(ScheduledTask var1) { Trigger var2 = this.a( var1, TriggerBuilder.newTrigger().withSchedule(CronScheduleBuilder.cronSchedule(var1.getCronExpression()).withMisfireHandlingInstructionIgnoreMisfires()) ); try { try { if (this.getScheduler().checkExists(TriggerKey.triggerKey(var1.getId()))) { this.getScheduler().rescheduleJob(TriggerKey.triggerKey(var1.getId()), var2); a.log(Level.INFO, g[29] + var1.getName()); return; } } catch (Exception var5) { throw a(var5); } this.getScheduler().scheduleJob(this.a(var1), var2); Logger var10000 = a; Level var10001 = Level.INFO; String var10002 = var1.getName(); String[] var4 = g; var10000.log(var10001, var4[4] + var10002); } catch (Exception var6) { a.log(Level.WARNING, g[1] + var1.getName(), ExceptionUtils.getDebugException(var6)); } } public void removeJob(Goid var1) { try { boolean var2 = this.getScheduler().unscheduleJob(TriggerKey.triggerKey(var1.toString())); try { if (var2) { a.log(Level.INFO, g[25] + var1.toString()); } } catch (Exception var3) { throw a(var3); } } catch (Exception var4) { a.log(Level.WARNING, g[14] + var1.toString(), ExceptionUtils.getDebugException(var4)); } } static { String[] var5 = new String[44]; int var3 = 0; String var2 = "\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"; int var4 = "\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(); char var1 = '2'; int var7 = -1; label24: while (true) { byte var10000 = 1; String var10001 = var2.substring(++var7, var7 + var1); byte var10002 = -1; while (true) { String var8 = a(var10000, a(var10001)); switch (var10002) { case 0: var5[var3++] = var8; if ((var7 += var1) >= var4) { g = var5; String[] var9 = g; JOB_DETAIL_NODE_ALL = g[22]; d = var9[21]; c = var9[5]; JOB_DETAIL_NODE = var9[28]; JOB_DETAIL_ENITTY_GOID = var9[42]; JOB_DETAIL_ID_PROVIDER_GOID = var9[38]; JOB_DETAIL_JOBTYPE = var9[27]; JOB_DETAIL_POLICY_GOID = var9[7]; JOB_DETAIL_NAME = var9[11]; JOB_DETAIL_NODE_ONE = var9[9]; JOB_DETAIL_USER_ID = var9[16]; a = Logger.getLogger(ScheduledTaskJobManager.class.getName()); return; } var1 = var2.charAt(var7); break; default: var5[var3++] = var8; if ((var7 += var1) < var4) { var1 = var2.charAt(var7); continue label24; } var2 = "a|P]d\u0007\u007fk{@\u001dK|A\u0014d\u0017Ua2N[r^JaaG\\u\u001aMhw@\u0014v\u0011J$"; var4 = "a|P]d\u0007\u007fk{@\u001dK|A\u0014d\u0017Ua2N[r^JaaG\\u\u001aMhw@\u0014v\u0011J$".length(); var1 = '\n'; var7 = -1; } var10000 = 77; var10001 = var2.substring(++var7, var7 + var1); var10002 = 0; } } } private static Exception a(Exception var0) { return var0; } private static char[] a(String var0) { char[] var10000 = var0.toCharArray(); if (var10000.length < 2) { var10000[0] = (char)(var10000[0] ^ 117); } return var10000; } private static String a(int var0, char[] var1) { int var10003 = var1.length; int var10002 = var0; char[] var10001 = var1; int var10000 = var10003; for (int var2 = 0; var10000 > var2; var2++) { var10001[var2] = (char)(var10001[var2] ^ var10002 ^ switch (var2 % 7) { case 0 -> 73; case 1 -> 95; case 2 -> 105; case 3 -> 121; case 4 -> 93; case 5 -> 51; default -> 117; }); } return new String(var10001).intern(); } }