import org.bson.Document
var result =mongo.database("business").collection("pjc_px_bak").aggregate(Arrays.asList(new Document("$match",
new Document("ITEM", "800074165"))))
for (item in result.iterator()) {
log.info("输出")
log.info(item['ITEM'])
}
return result.iterator().arrayLikeToList()package com.ruoyi.framework.config;
import com.ruoyi.framework.interceptor.apiInterceptor;
import com.ruoyi.framework.interceptor.jimuInterceptor;
import lombok.AllArgsConstructor;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
/**
* 积木报表拦截器
* 只有登录的用户才可以访问，不可匿名访问
* @author liuhuan
* @title: InterceptorConfig
* @description: TODO
* @projectName ruoyi
* @date 2021/6/239:24 上午
* @return V1.0.0
*/
@Configuration
@AllArgsConstructor
public class InterceptorConfig extends WebMvcConfigurerAdapter {
private jimuInterceptor jimuInterceptor;
private apiInterceptor apiInterceptor;
@Override
public void addInterceptors(InterceptorRegistry registry) {
registry.addInterceptor(jimuInterceptor).addPathPatterns("/jmreport/view/**");
registry.addInterceptor(jimuInterceptor).addPathPatterns("/jmreport/list/**");
registry.addInterceptor(jimuInterceptor).addPathPatterns("/jmreport/index/**");
// registry.addInterceptor(apiInterceptor).addPathPatterns ("/api/**");
}
}默认情况下启动项目，自动执行Job，如果不想自动运行Job可在yml配置默认不启动Job
package com.example.demo.config;
import org.springframework.batch.core.*;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.core.scope.context.ChunkContext;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.Map;
/**
* @author H__D
* @description
* @date 2021/10/30
*/
@Configuration
// 启用批处理功能
@EnableBatchProcessing
public class JobConfiguration implements StepExecutionListener{
// 注入创建任务的对象
@Autowired
private JobBuilderFactory jobBuilderFactory;
// 注入创建步骤的对象
@Autowired
private StepBuilderFactory stepBuilderFactory;
@Bean(name = "helloworldJob")
public Job helloworldJob() {
System.out.println("ab");
return jobBuilderFactory.get("helloworldJob")
.start(step1())
.build();
}
private Map<String, JobParameter> parameters;
@Bean
public Step step1() {
return stepBuilderFactory.get("step1")
.listener(this)
.tasklet(new Tasklet() {
@Override
public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext) throws Exception {
System.out.println(Thread.currentThread().getName() + "------" + "hello world");
System.out.println("传递de参数值为："+parameters.get("msg").getValue());
// 返回执行完成状态
return RepeatStatus.FINISHED;
}
}).build();
}
/**
* 利用step监听器将参数赋值到step
* @param stepExecution
*/
@Override
public void beforeStep(StepExecution stepExecution) {
parameters = stepExecution.getJobParameters().getParameters();
}
@Override
public ExitStatus afterStep(StepExecution stepExecution) {
return null;
}
}@Component
@ConfigurationProperties(prefix = "gen")
@PropertySource(value = { "classpath:generator.yml" })
public class GenConfig
{
/** 作者 */
public static String author;
/** 生成包路径 */
public static String packageName;
/** 自动去除表前缀，默认是false */
public static boolean autoRemovePre;
/** 表前缀(类名不会包含表前缀) */
public static String tablePrefix;
public static String getAuthor()
{
return author;
}
@Value("${author}")
public void setAuthor(String author)
{
GenConfig.author = author;
}
public static String getPackageName()
{
return packageName;
}
@Value("${packageName}")
public void setPackageName(String packageName)
{
GenConfig.packageName = packageName;
}
public static boolean getAutoRemovePre()
{
return autoRemovePre;
}
@Value("${autoRemovePre}")
public void setAutoRemovePre(boolean autoRemovePre)
{
GenConfig.autoRemovePre = autoRemovePre;
}
public static String getTablePrefix()
{
return tablePrefix;
}
@Value("${tablePrefix}")
public void setTablePrefix(String tablePrefix)
{
GenConfig.tablePrefix = tablePrefix;
}
}