import org.ligoj.bootstrap.core.security.SecurityHelper; //导入依赖的package包/类
@Override
protected void executeInternal(final JobExecutionContext arg0) throws JobExecutionException {
	// Extract the job data to execute the operation
	final int schedule = arg0.getMergedJobDataMap().getInt("schedule");
	final ApplicationContext context = ObjectUtils.defaultIfNull((ApplicationContext) arg0.getMergedJobDataMap().get("context"),
			SpringUtils.getApplicationContext());
	final VmSchedule entity = context.getBean(VmScheduleRepository.class).findOneExpected(schedule);
	log.info("Executing {} for schedule {}, subscription {}", entity.getOperation(), entity.getId(), entity.getSubscription().getId());

	// Set the user
	context.getBean(SecurityHelper.class).setUserName(SecurityHelper.SYSTEM_USERNAME);

	// Execute the operation
	context.getBean(VmResource.class).execute(entity.getSubscription(), entity.getOperation());
	log.info("Succeed {} for schedule {}, subscription {}", entity.getOperation(), entity.getId(), entity.getSubscription().getId());
}
 

import org.ligoj.bootstrap.core.security.SecurityHelper; //导入依赖的package包/类
@Before
public void setup() {
	task = new UserAtomicLdapTask();
	task.resource = Mockito.mock(UserOrgResource.class);
	task.securityHelper = new SecurityHelper();
	initSpringSecurityContext(DEFAULT_USER);

	final UserOrg user = new UserOrg();
	user.setCompany("untouched");
	user.setDepartment("untouched");
	user.setFirstName("untouched");
	user.setLastName("untouched");
	user.setName(DEFAULT_USER);
	user.setLocalId("untouched");
	user.setMails(new ArrayList<>());
	user.setGroups(new ArrayList<>());
	Mockito.when(task.resource.findById(DEFAULT_USER)).thenReturn(user);
}
 

import org.ligoj.bootstrap.core.security.SecurityHelper; //导入依赖的package包/类
/**
 * Updated entity test
 */
@Test
public void testAuditUpdate() throws InterruptedException {
	final SystemBench entity = new SystemBench();
	em.persist(entity);
	em.flush();
	Thread.sleep(200); // NOSONAR -- Have to pause the thread for the test
	SecurityContextHolder.clearContext();
	entity.setPrfBool(true);
	em.flush();
	Assert.assertEquals(DEFAULT_USER, entity.getCreatedBy());
	Assert.assertNotNull(entity.getCreatedDate());
	Assert.assertEquals(SecurityHelper.SYSTEM_USERNAME, entity.getLastModifiedBy());
	Assert.assertNotNull(entity.getLastModifiedDate());
	Assert.assertNotEquals(entity.getLastModifiedDate(),entity.getCreatedDate());
}
 

import org.ligoj.bootstrap.core.security.SecurityHelper; //导入依赖的package包/类
@Before
public void setup() {
	task = new UserFullLdapTask();
	task.resource = Mockito.mock(UserOrgResource.class);
	task.securityHelper = new SecurityHelper();
	task.jaxrsFactory = ServerProviderFactory.getInstance();
	initSpringSecurityContext(DEFAULT_USER);
}
 

import org.ligoj.bootstrap.core.security.SecurityHelper; //导入依赖的package包/类
/**
 * Persisted entity test
 */
@Test
public void testAuditCreate() {
	SecurityContextHolder.clearContext();
	final SystemBench entity = new SystemBench();
	em.persist(entity);
	em.flush();
	Assert.assertEquals(SecurityHelper.SYSTEM_USERNAME, entity.getCreatedBy());
	Assert.assertNotNull(entity.getCreatedDate());
	Assert.assertEquals(SecurityHelper.SYSTEM_USERNAME, entity.getLastModifiedBy());
	Assert.assertNotNull(entity.getLastModifiedDate());
	Assert.assertEquals(entity.getLastModifiedDate(), entity.getCreatedDate());
}
 

import org.ligoj.bootstrap.core.security.SecurityHelper; //导入依赖的package包/类
/**
 * Updated entity test
 */
@Test
public void testAuditUpdateWithNew() throws InterruptedException {
	
	// Initial save
	final SystemBench entity = new SystemBench();
	em.persist(entity);
	em.flush();
	em.clear();
	Thread.sleep(200); // NOSONAR -- Have to pause the thread for the test

	// Update from a new instance
	SecurityContextHolder.clearContext();
	SystemBench entityUpdate = new SystemBench();
	entityUpdate.setId(entity.getId().intValue());
	entityUpdate.setPrfBool(true);
	em.merge(entityUpdate);
	em.flush();
	em.clear();

	// Reload the entity to check the state
	entityUpdate = em.find(SystemBench.class,entity.getId());
	Assert.assertEquals(DEFAULT_USER, entityUpdate.getCreatedBy());
	Assert.assertNotNull(entityUpdate.getCreatedDate());
	Assert.assertEquals(SecurityHelper.SYSTEM_USERNAME, entityUpdate.getLastModifiedBy());
	Assert.assertNotNull(entityUpdate.getLastModifiedDate());
	Assert.assertNotEquals(entityUpdate.getLastModifiedDate(),entityUpdate.getCreatedDate());
}
 

import org.ligoj.bootstrap.core.security.SecurityHelper; //导入依赖的package包/类
@Test
public void createAndUpdateSchedule() throws Exception {
	final ApplicationContext mockContext = Mockito.mock(ApplicationContext.class);
	final VmScheduleRepository vmScheduleRepository = Mockito.mock(VmScheduleRepository.class);
	final VmResource mockResource = Mockito.mock(VmResource.class);
	final Subscription entity = this.subscriptionRepository.findOneExpected(subscription);
	Mockito.when(mockContext.getBean(VmScheduleRepository.class)).thenReturn(vmScheduleRepository);
	Mockito.when(mockContext.getBean(SecurityHelper.class)).thenReturn(Mockito.mock(SecurityHelper.class));
	Mockito.when(mockContext.getBean(VmResource.class)).thenReturn(mockResource);

	final StdScheduler scheduler = (StdScheduler) vmSchedulerFactoryBean.getScheduler();
	final QuartzScheduler qscheduler = (QuartzScheduler) FieldUtils.getField(StdScheduler.class, "sched", true).get(scheduler);
	final QuartzSchedulerResources resources = (QuartzSchedulerResources) FieldUtils.getField(QuartzScheduler.class, "resources", true)
			.get(qscheduler);
	final JobDetail jobDetail = scheduler.getJobDetail(scheduler.getJobKeys(GroupMatcher.anyJobGroup()).iterator().next());

	// "ON" call would fail
	Mockito.doThrow(new RuntimeException()).when(mockResource).execute(entity, VmOperation.ON);

	try {
		// Mock the factory
		jobDetail.getJobDataMap().put("context", mockContext);
		((RAMJobStore) resources.getJobStore()).storeJob(jobDetail, true);

		Assert.assertEquals(1, this.vmScheduleRepository.findAll().size());

		// Schedule all operations within the next 2 seconds
		final String cron = "" + ((DateUtils.newCalendar().get(Calendar.SECOND) + 2) % 60) + " * * * * ?";
		final int id = mockSchedule(vmScheduleRepository, resource.createSchedule(newSchedule(cron, VmOperation.OFF)));
		mockSchedule(vmScheduleRepository, resource.createSchedule(newSchedule(cron + " *", VmOperation.ON)));
		Assert.assertEquals(3, this.vmScheduleRepository.findAll().size());

		// Yield for the schedules
		Thread.sleep(2500);

		// Check the executions
		Mockito.verify(mockResource).execute(entity, VmOperation.OFF);
		Mockito.verify(mockResource).execute(entity, VmOperation.ON); // Failed
		Mockito.verify(mockResource, Mockito.never()).execute(entity, VmOperation.REBOOT);
		Mockito.verify(mockResource, Mockito.never()).execute(entity, VmOperation.RESET);
		Mockito.verify(mockResource, Mockito.never()).execute(entity, VmOperation.SHUTDOWN);
		Mockito.verify(mockResource, Mockito.never()).execute(entity, VmOperation.SUSPEND);

		// Update the CRON and the operation
		final VmScheduleVo vo = newSchedule("" + ((DateUtils.newCalendar().get(Calendar.SECOND) + 2) % 60) + " * * * * ?",
				VmOperation.SHUTDOWN);
		vo.setId(id);
		vo.setSubscription(subscription);
		resource.updateSchedule(vo);
		Assert.assertEquals(3, this.vmScheduleRepository.findAll().size());

		// Yield for the schedules
		Thread.sleep(2500);
		Mockito.verify(mockResource).execute(entity, VmOperation.SHUTDOWN);
	} finally {
		// Restore the factory's context
		jobDetail.getJobDataMap().put("context", applicationContext);
		((RAMJobStore) resources.getJobStore()).storeJob(jobDetail, true);
	}
}