package wffz.jxmjkh.controller; import lombok.SneakyThrows; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import wffz.common.contants.ConstantProperties; import wffz.jxmjkh.service.JxMjKhTxService; import java.util.ArrayList; import java.util.List; import java.util.Map; public class SaveResultTask implements Runnable { private JxMjKhTxService jxMjKhTxService; // 上一次查询结果 private static List<Map<String, Object>> lastResult = new ArrayList<>(); private ConstantProperties constantProperties; public SaveResultTask(JxMjKhTxService jxMjKhTxService) { this.jxMjKhTxService = jxMjKhTxService; run(); } @SneakyThrows @Override public void run() { //查询表中的数据并保存在lastResult lastResult = jxMjKhTxService.getLastData(constantProperties.getJsbh()); // 获取当前接口查询结果 List<Map<String, Object>> result = jxMjKhTxService.selectJxMjkhTxData(constantProperties.getJsbh()); // 待插入的数据 List<Map<String, Object>> toBeInserted = new ArrayList<>(); // 待更新的数据 List<Map<String, Object>> toBeUpdated = new ArrayList<>(); // 待删除的数据 List<Map<String, Object>> toBeDeleted = new ArrayList<>(); // 遍历上一次查询结果，看看是否需要更新或删除 for (Map<String, Object> last : lastResult) { boolean found = false; for (Map<String, Object> current : result) { if (StringUtils.equals((CharSequence) current.get("jsbh"), (CharSequence) last.get("jsbh")) && StringUtils.equals((CharSequence) current.get("txxId"), (CharSequence) last.get("txxId")) && StringUtils.equals((CharSequence) current.get("sm"), (CharSequence) last.get("sm"))) { found = true; break; } } if (!found) { toBeDeleted.add(last); } } // 遍历当前查询结果，看看是否需要插入或更新 for (Map<String, Object> current : result) { boolean found = false; for (Map<String, Object> last : lastResult) { if (StringUtils.equals((CharSequence) current.get("jsbh"), (CharSequence) last.get("jsbh")) && StringUtils.equals((CharSequence) current.get("txxId"), (CharSequence) last.get("txxId")) && StringUtils.equals((CharSequence) current.get("sm"), (CharSequence) last.get("sm"))) { found = true; break; } } if (found) { toBeUpdated.add(current); } else { toBeInserted.add(current); } } // 批量插入 if (!toBeInserted.isEmpty()) { jxMjKhTxService.batchInsert(toBeInserted); } // 批量更新 if (!toBeUpdated.isEmpty()) { jxMjKhTxService.batchUpdate(toBeUpdated); } // 批量删除 if (!toBeDeleted.isEmpty()) { jxMjKhTxService.batchDelete(toBeDeleted); } // 保存本次查询结果 lastResult = result; } }代码不运行

这是一个保存查询结果的任务类，其中使用了Spring框架的@Autowired注解来注入依赖的JxMjKhTxService服务。任务主要是根据查询结果来进行数据的插入、更新和删除操作，以保持数据库中的数据与查询结果的一致性。其中，待插入、更新和删除的数据保存在相应的列表中，最后通过JxMjKhTxService的批量操作方法来实现对数据库的批量插入、更新和删除。

相关问题

package wffz.jxmjkh.controller; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.annotation.EnableScheduling; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; @Configuration @EnableScheduling public class ScheduleConfig { @Bean(name = "scheduledExecutorService") public ScheduledExecutorService scheduledExecutorService() { return Executors.newSingleThreadScheduledExecutor(); } } 优化修改线程池大小

在这段代码中，线程池的大小被设置为1，这意味着在任何给定时间只有一个任务可以执行。如果需要同时执行多个任务，可以增加线程池的大小。

修改线程池大小的方法取决于使用的线程池类型。在这个例子中，线程池类型是ScheduledExecutorService，可以通过调用Executors.newScheduledThreadPool()方法来创建一个基于时间调度的线程池，然后设置线程池的大小。

修改后的代码如下所示：

@Configuration
@EnableScheduling
public class ScheduleConfig {

    @Value("${threadpool.size}")
    private int threadPoolSize;

    @Bean(name = "scheduledExecutorService")
    public ScheduledExecutorService scheduledExecutorService() {
        return Executors.newScheduledThreadPool(threadPoolSize);
    }
}

在这个例子中，线程池的大小由配置文件中的 "threadpool.size" 属性指定。可以在应用程序的配置文件中添加这个属性，然后设置线程池的大小。例如，在 application.properties 文件中，可以添加以下行：

threadpool.size=10

这将设置线程池的大小为10。需要根据应用程序的实际需求来调整线程池的大小。

package wffz.jxmjkh.controller; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; import wffz.common.contants.ConstantProperties; import wffz.jxmjkh.service.JxMjKhTxService; import javax.annotation.PostConstruct; import java.text.ParseException; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; @RestController public class JxMjkhTxController { @Autowired private ScheduledExecutorService scheduledExecutorService; @Autowired private JxMjKhTxService jxMjKhTxService; @Autowired private ConstantProperties constantProperties; @PostConstruct public void init() { scheduledExecutorService.scheduleAtFixedRate(new SaveResultTask(jxMjKhTxService), 0, 1, TimeUnit.MINUTES); } @GetMapping("/saveTxData") public List<Map<String, Object>> getResult() throws ParseException { return jxMjKhTxService.selectJxMjkhTxData(constantProperties.getJsbh()); } }

这是一个使用 Spring Boot 框架开发的 RESTful 风格的接口控制器类。其中包含了以下注解：

- `@RestController`: 表示该类为一个 RESTful 接口控制器。
- `@Autowired`: 表示自动注入依赖对象。
- `@PostConstruct`: 表示在对象创建后进行初始化操作。
- `@GetMapping`: 表示该方法处理 HTTP GET 请求。

该类中包含的方法有：

- `init()`: 在对象创建后调用，启动一个定时任务，每分钟执行一次 `SaveResultTask` 类的 `run()` 方法。
- `getResult()`: 处理 HTTP GET 请求，返回经过处理后的结果列表。