常連

### 実現したいこと
添付ソースを下記①、②のように修正する場合、
  SpringBatchConfigクラスの修正内容（できればサンプル）
  SampleStepクラスの作成方法（できればサンプル）
を教えていただけますでしょうか。
※特にjobからstepの参照が難しいです。

①SpringBatchConfigクラスにはpublic Job job(Step step1)メソッドのみ残す。

②下記メソッドはSampleStepクラスを新規作成し、そのクラスに移動する。
　・reader() メソッド
　・processor()メソッド
　・writer()メソッド
　・step1(ItemReader<String> reader, ItemProcessor<String, String> processor, ItemWriter<String> writer) メソッド


```ここに言語を入力
    
```

### 発生している問題・分からないこと
SpringBatchConfigクラスでjob、step、reader() 、processor()、writer()を纏めて記載しているが、別クラスへの分け方がわかりません。



### 該当のソースコード

```java
import java.util.Arrays;
import java.util.List;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.job.builder.JobBuilder;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.step.builder.StepBuilder;
import org.springframework.batch.item.ItemProcessor;
import org.springframework.batch.item.ItemReader;
import org.springframework.batch.item.ItemWriter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;

@Configuration
@EnableBatchProcessing
public class SpringBatchConfig {

	private final JobLauncher jobLaunchrer;
	private final JobRepository jobRepository;
	private final PlatformTransactionManager transactionManager;


    public SpringBatchConfig(JobLauncher jobLaunchrer, JobRepository jobRepository,
			PlatformTransactionManager transactionManager) {
		super();
		this.jobLaunchrer = jobLaunchrer;
		this.jobRepository = jobRepository;
		this.transactionManager = transactionManager;
	}

	@Bean
    public ItemReader<String> reader() {
        return new ItemReader<>() {
            private final List<String> data = Arrays.asList("John", "Jane", "Foo", "Bar");
            private int index = 0;

            @Override
            public String read() {
                if (index < data.size()) {
                    return data.get(index++);
                } else {
                    return null; // nullを返すと処理が終了
                }
            }
        };
    }

    @Bean
    public ItemProcessor<String, String> processor() {
        return item -> "Proccss = , " + item + "!";
    }

    @Bean
    public ItemWriter<String> writer() {
        return items -> items.forEach(System.out::println);
    }

    @Bean
    public Step step1(ItemReader<String> reader, ItemProcessor<String, String> processor, ItemWriter<String> writer) {
        return new StepBuilder("step1", jobRepository)
                .<String, String>chunk(1, transactionManager) 
                .reader(reader)
                .processor(processor)
                .writer(writer)
                .build();
    }
        
    // Jobの定義
    @Bean
    public Job job(Step step1) {
    	System.out.println("SpringBatchConfig Job");
    	
        return new JobBuilder("helloJob", jobRepository)
                .start(step1)
                .build();
    }
}

```

### 試したこと・調べたこと
- [x] teratailやGoogle等で検索した
- [ ] ソースコードを自分なりに変更した
- [ ] 知人に聞いた
- [ ] その他

##### 上記の詳細・結果
SampleStepクラスを作成、implements Stepしましたが、移植方法が全然わかりませんでした。

### 補足
特になし

Spring batchのStepクラスの作成方法

### 前提

Spring Batch 5.0以降で書き方が変更になったのですが、
現在使用している参考書｢悲惨なミスをなくすSpringBatch入門書: Spring解体新書(バッチ編): 基礎から学べるSpring Batch｣は、5.0以降に対応した書き方になっていないため、5.0以降に対応した書き方を教えて頂きたいです。
また、Spring Batch 5.0以降に対応した書き方をしているサイト・参考書が知りたい

ここに実現したいことを箇条書きで書いてください。
- [ ] Spring Batch 5.0以降の書き方でBatchを実行したい
- [ ] Spring Batch 5.0以降に対応した書き方をしているサイト・参考書が知りたい

### 発生している問題・エラーメッセージ
以下のサイトを参考にしたところエラーメッセージが発生してしまいました。
https://github.com/spring-projects/spring-batch/wiki/Spring-Batch-5.0-Migration-Guide

```
org.springframework.beans.factory.BeanDefinitionStoreException: Invalid bean definition with name 'helloTasklet' defined in class path resource [com/example/demo/config/BatchConfig.class]: @Bean definition illegally overridden by existing bean definition: Root bean: class [org.springframework.aop.scope.ScopedProxyFactoryBean]; scope=; abstract=false; lazyInit=null; autowireMode=0; dependencyCheck=0; autowireCandidate=true; primary=false; factoryBeanName=null; factoryMethodName=null; initMethodNames=null; destroyMethodNames=null; defined in BeanDefinition defined in file [C:\pleiades\2022-06\workspace\BatchHelloWorldTasklet\target\classes\com\example\demo\tasklet\HelloTasklet.class]
```

### ファイル構成
![イメージ説明](https://ddjkaamml8q8x.cloudfront.net/questions/2023-01-22/13234c1f-b222-42c3-aa0f-0363fa4fda2c.png)

### 該当のソースコード
BatchConfig.java(Spring Batch 5.0以前の書き方)
```java
package com.example.demo.config;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
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.launch.support.RunIdIncrementer;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
@EnableBatchProcessing
public class BatchConfig {

    /** JobBuilderのFactoryクラス */
    @Autowired
    private JobBuilderFactory jobBuilderFactory;

    /** StepBuilderのFactoryクラス */
    @Autowired
    private StepBuilderFactory stepBuilderFactory;

    /** HelloTasklet */
    @Autowired
    private Tasklet helloTasklet;

    /** TaskletのStepを生成 */
    @Bean
    public Step taskletStep1() {
        return stepBuilderFactory.get("HelloTaskletStep1") // Builderの取得
            .tasklet(helloTasklet) // Taskletのセット
            .build(); // Stepの生成
    }

    /** Jobを生成 */
    @Bean
    public Job taskletJob() throws Exception {
        return jobBuilderFactory.get("HelloWorldTaskletJob") // Builderの取得
            .incrementer(new RunIdIncrementer()) // IDのインクリメント
            .start(taskletStep1()) // 最初のStep
            .build(); // Jobの生成
    }
}
```
BatchConfig.java(Spring Batch 5.0以降の書き方)
```java
package com.example.demo.config;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.job.builder.JobBuilder;
import org.springframework.batch.core.launch.support.RunIdIncrementer;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.step.builder.StepBuilder;
import org.springframework.batch.core.step.tasklet.Tasklet;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;

import com.example.demo.tasklet.HelloTasklet;

@Configuration
@EnableBatchProcessing
public class BatchConfig {
	
	@Bean
	public Tasklet helloTasklet() {
		return new HelloTasklet();
	}
	
	@Bean
	public Step taskletStep1(JobRepository jobRepository, Tasklet helloTasklet, PlatformTransactionManager transactionManager) {
		return new StepBuilder("HelloTaskletStep1", jobRepository) 
				.tasklet(helloTasklet, transactionManager) 
				.build();
	}
	
	@Bean
	public Job taskletJob(JobRepository jobRepository, Step step) {
		return new JobBuilder("HelloTaskletStep", jobRepository)
				.incrementer(new RunIdIncrementer()) 
				.start(step) 
				.build(); 
	}
}
```

HelloTasklet.java(Spring Batch 5.0以前の書き方)　※　このクラスは書き方を変えておらず共通
```java
package com.example.demo.tasklet;

import org.springframework.batch.core.StepContribution;
import org.springframework.batch.core.configuration.annotation.StepScope;
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.stereotype.Component;
import lombok.extern.slf4j.Slf4j;

@Component
@StepScope
@Slf4j
public class HelloTasklet implements Tasklet {

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext)
            throws Exception {
        log.info("Hello World");
        return RepeatStatus.FINISHED;
    }
}
```

### 補足情報（FW/ツールのバージョンなど）
Spring Boot 3.0.2
Java 19

### 参考にしたサイト/資料
- [ ] 悲惨なミスをなくすSpringBatch入門書: Spring解体新書(バッチ編): 基礎から学べるSpring Batch
- [ ] https://github.com/spring-projects/spring-batch/wiki/Spring-Batch-5.0-Migration-Guide



Spring Batch 5.0以降の書き方を知りたい

### 状況

[WinSCPを使用して、gzファイルをローカルにダウンロードし、7zipで解凍する]というバッチで、ダウンロードに失敗しています。
ソースは単純に get {パス}{ファイル名}　です。

### 発生している問題・エラーメッセージ

```
 No mapping for the unicode character exists in the target multi-byte code page
ファイルはUTF-8かUTF-16である必要があります。
```



### 試したこと

■ほかの端末では正常に動くことから、そちらのWinSCPと全く同じ環境設定にする
（デフォルトの文字コードは932）
→効果なし

■ツールのパスを全てアルファベットにし、WinSCPの環境設定でデフォルトの文字コードをUTF-8にする
→効果なし

■WInSCPが接続する際にサーバー証明書の認証などで止まってしまうのかと考え、自分でWinSCPを立ち上げて目当てのサーバーに接続してみる
→証明書などでひっかかることなく接続でき、効果もなし

### 補足

■gzファイルはlinuxサーバーにのっていて、Windowsにダウンロードしたいです

■うまくいく端末もいかない端末も、Windows10 64bit Proです。

■解凍ツールは7zipで固定です（職場PCなので制限があります。。。）

■親バッチを叩くと大量のバッチが走る自動ツールの、1番初めの処理です。
ここだけ手動でダウンロード＆解凍しても、つづきからツールを動かすことはできないので、
なんとか解決したいです。

無知でお恥ずかしい限りですが、ご教授お願いいたします。

【getコマンド】文字コードが理由でダウンロードできない

閲覧ありがとうございます。
mybatisで起きたエラーの対処法について質問させていただきます。

エラー内容
```Error
rg.mybatis.spring.MyBatisSystemException at MainTest.java:20
        Caused by: org.apache.ibatis.reflection.ReflectionException at MainTest.java:20
```
値がないとのことでエラーが起きていると思われます。
したがって、値の取得方法についてご教授願います。

```java
public class FoodsParam{
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer id;
    @Column(nullable = false)
    private String name;
    private String type;
    private Integer price;
    
    FoodsParam(){
    }
    
    public FoodsParam(String type, Integer price){
        this.type = type;
        this.price = price;
    }
}
```
```java
@Mapper
public interface FoodsMapper{
     List<Map<String, Object>> findByTypeAndPriceUsingClass(FoodsParam param);
}
```
```java
public class MainTest{
    @Autowired
    private FoodsMapper foodsMapper; 
    
    @Test
    void test(){
    System.out.println(foodsMapper.findByTypeAndPriceUsingClass(
        new FoodsParam("野菜", 500)));
    }
}
```
```mapper
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="curriculum.mapper.FoodsMapper">
    <select id="findByTypeAndPriceUsingClass" resultType="curriculum.domain.FoodsParam">
        Select
         *
        From
         foods
        Where 
        type = #{type} AND price <![CDATA[ <= ]]> #{limit}
    </select>
</mapper>
```

ご回答のほどよろしくお願いいたします。

[Mybatis] 値の取得がわからない。エラー：org.apache.ibatis.reflection.ReflectionException

### 実現したいこと
以下のサイトを参考に、SpringBatchでハローワールドを出力しようとしていますが、出力できません。
	参考①：
		https://qiita.com/kawakawaryuryu/items/4b3f5cc7574b7bd6b625
		https://kagamihoge.hatenablog.com/entry/2023/03/24/192846


### 発生している問題・分からないこと
実行自体は正常終了しており、特にエラーになっていないため、
何が足りないのか、何がうまく行っていないのかも読み取れない状況です。

1点、コンソール上には以下のワーニングが出力されていました。
```
WARN 32268 --- [ccc] [  restartedMain] o.m.s.mapper.ClassPathMapperScanner      : No MyBatis mapper was found in '[aaa.bbb.ccc]' package. Please check your configuration.
```

このエラーメッセージを調べてみると、以下のサイトのように
Mapperクラスでの定義／指定不足が原因との情報にたどり着きました。
	参考②：
		https://qiita.com/azmint/items/7c6040e9136dd6d0f556
		https://teratail.com/questions/301664

しかし、上記「参考①」の中には「Mapper」という単語は出てこず
何をどうすれば、ハローワールドが出力されるかわからない状態です。




### 該当のソースコード

```Java:TestApplication.java
package aaa.bbb.ccc;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class TestApplication {
	public static void main(String[] args) {
		SpringApplication.run(TestApplication .class, args);
    }
}
```

```Java:BatchConfig.java
package aaa.bbb.ccc;

import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.job.builder.JobBuilder;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.step.builder.StepBuilder;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.transaction.PlatformTransactionManager;

@Configuration
public class BatchConfig {
	  @Bean
	  Job job(JobRepository jobRepository, PlatformTransactionManager txManager) {
	    Step step = new StepBuilder("sampleStep", jobRepository)
	        .tasklet((contribution, chunkContext) -> {
	          System.out.println("Hello World.");
	          return RepeatStatus.FINISHED;
	        }, txManager)
	          .build();

	    return new JobBuilder("sampleJob", jobRepository)
	        .start(step)
	          .build();
	  }
}
```

```build.gradle
plugins {
	id 'java'
	id 'org.springframework.boot' version '3.4.0'
	id 'io.spring.dependency-management' version '1.1.6'
}

group = 'aaa.bbb'
version = '0.0.1-SNAPSHOT'

java {
	toolchain {
		languageVersion = JavaLanguageVersion.of(21)
	}
}

configurations {
	compileOnly {
		extendsFrom annotationProcessor
	}
}

repositories {
	mavenCentral()
}

dependencies {
	implementation 'org.springframework.boot:spring-boot-starter-batch'
	implementation 'org.springframework.boot:spring-boot-starter-web'
	implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:3.0.4'
	compileOnly 'org.projectlombok:lombok'
	developmentOnly 'org.springframework.boot:spring-boot-devtools'
	runtimeOnly 'com.mysql:mysql-connector-j'
	annotationProcessor 'org.projectlombok:lombok'
	testImplementation 'org.springframework.boot:spring-boot-starter-test'
	testImplementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter-test:3.0.4'
	testImplementation 'org.springframework.batch:spring-batch-test'
	testRuntimeOnly 'org.junit.platform:junit-platform-launcher'
}

tasks.named('test') {
	useJUnitPlatform()
}

```

```application.properties
spring.application.name=ccc
spring.batch.job.enabled=false
mybatis.configuration.map-underscore-to-camel-case=true
spring.datasource.url=jdbc:mysql://localhost:3306/testdb?enabledTLSProtocols=TLSv1.2
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
```

### 試したこと・調べたこと
- [x] teratailやGoogle等で検索した
- [x] ソースコードを自分なりに変更した
- [x] 知人に聞いた
- [ ] その他

##### 上記の詳細・結果
エラーが出ていないため、解消する情報にたどり着けなかった。

### 補足
特になし

SpringBatchを実行しHelloWorldを出力したい

### 前提・実現したいこと

SpringBatchとMyBatisを使ってCSVをデータベースに登録するバッチを作成しています。
バッチはチャンクモデルで作成していて、以下のような構成になっています。

1. ItemReader・・・アクティブテーブルを読む
2. ItemProcessor・・・アクティブデータに登録されているパスのCSVを読む
3. ItemWriter・・・CSVファイルの中身を登録する

1のアクティブテーブルは、他システムが登録しているもので、キー情報とCSVのファイルパスが登録されています。
ItemProcessorでそのファイルを読み込み、フォーマットを統一してListに詰めます。
ItemWriterでListを受取ってDBに登録します。

最初に調べた時に、StepBuilderFactoryに`chunk(1000)`など設定しておくと、1000件ずつコミットしてくれると理解しました。
が、実際に動かしてみて初めて、CSVファイルの中身の件数じゃなくて、Readerで取得されるデータの件数で制御されることに気づきました…。

どのようにしたら分割でコミットができるのでしょうか？

### 発生している問題・エラーメッセージ

```
org.springframework.dao.TransientDataAccessResourceException: 
batch.XXXMapper.insertBulk (batch index #1) failed. 
Cause: java.sql.tion: Packet for query is too large (5,636,232 > 4,194,304). You can change this value on the server by setting the 'max_allowed_packet' variable.
```
max_allowed_packetを変えたらいいよと言われてるのは分かるのですが、このファイルが最大という訳でもないので分割でコミットしたいと思ってます。

### 該当のソースコード
■Step
```java
    @Bean
    public Step insertCsvStep(
    		ItemReader<Activity> reader,
			ItemProcessor<Activity, List<XXXData>> processor,
			ItemWriter<List<XXXData>> writer) {
		return stepBuilderFactory.get("insertCsvStep")
                .<Activity, List<XXXData>> chunk(1000)
				.reader(reader)
				.processor(processor)
				.writer(writer)
				.build();
    }
```
■ItemReader
※単純にデータを取ってくるだけなので省略（多くて10件ぐらい）

■ItemProcessor
※ファイルによって項目数が違うのでsplitで分割しながら読んでます
```java
	@Override
	public List<XXXData> process(Activity activity) throws Exception {
		BufferedReader br = null;
        // ItemWriterに渡すリスト
		List<XXXData> result = new ArrayList<XXXData>();
		try {
			File f = new File(activity.getPath());
			br = new BufferedReader(new FileReader(f));

			String sLine;
			while ((sLine = br.readLine()) != null) {
				csv = sLine.split(",", 0);
				
				XXXData data = new XXXData();
                :
                (諸々の加工処理）
                :
				result.add(data);
			}
		} catch (Exception e) {
			// 省略
		} finally {
			if(br != null) br.close();
		}
		return result;
	}
```
■ItemWriter
```java
	@Bean
	public MyBatisBatchItemWriter<List<XXXData>> insertXXXData() {
		return new MyBatisBatchItemWriterBuilder<List<XXXData>>()
					.sqlSessionFactory(sqlSessionFactory)
					.statementId("batch.infra.mapper.XXXDataMapper.insertBulk")
					.build();
	}
```

■Mapper(xml)
```xml
  <insert id="insertBulk" parameterType="java.util.List">
    INSERT INTO xxx_data (
      system_id,
      :
    ) 
    VALUES 
      <foreach item="record" collection="list" separator=",">
        (
          #{record.system_id,jdbcType=VARCHAR},
          :
        )
      </foreach>  
  </insert>
```

### 試したこと

application.ymlで下記のように設定を追加してみましたが、同じでした。
```yml
mybatis:
  executor-type: BATCH
  configuration:
    default-executor-type: BATCH
```

### 補足情報（FW/ツールのバージョンなど）
SpringBoot2.3.1(プロジェクト作成時にSpringBatchを選択）
Java 13

分割コミットをする方法がわかりません

### 前提・実現したいこと
Spring Batchを作成しています。
実行時に分岐する為、処理をまとめたいと思いますが、FlowBuilderで作成したFlowをJobへ渡すと
最初の処理が終わらなくなってしまいます。

最終的にやりたいことは
Step1がOKだったら、Step2・Step3・Step4の順で実行
Step1がNGだったら、Step3・Step4を実行
のようにしたく、Step3とStep4をまとめたいため、Flowを使用しようとしております。
※下記ソースコードではまだ分岐まで行っておらず、Flowで処理をまとめるところでつまずいております。

### 発生している問題・エラーメッセージ
下記ソースにて無限ループになってしまいます。

### 該当のソースコード

```Java
  @Bean
  public Job job(@Qualifier("flow1") final Flow flow1
  )
      throws Exception {

    return jobBuilderFactory.get(_JOB_NAME)
        .incrementer(new RunIdIncrementer())
        .start(flow1)
        .end()
        .build();
  }
  
  @Bean
  public Flow flow1(
      @Qualifier("step1") final Step step1,
      @Qualifier("step2") final Step step2) throws Throwable {
    return new FlowBuilder<SimpleFlow>("retryModeFlow")
        .start(step1)
        .next(step2)
        .build();
  }

  
  @Bean
  public Step step1() throws Throwable {
    return stepBuilderFactory
        .get(_JOB_STEP_NAME)
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step1");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }
  
  @Bean
  public Step step2() throws Throwable {
    return stepBuilderFactory
        .get(_JOB_STEP_NAME)
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step2");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }
```

上記を実行したところ、結果が
```
step1
step1
step1
step1
step1
...
```
となってしまいます。

### 試したこと
Flowを使用せずJobBuilterに直接Stepを渡した場合だと、正常に終了いたします。
```Java
  @Bean
  public Job job(@Qualifier("flow1") final Flow flow1
  )
      throws Exception {

    return jobBuilderFactory.get(_JOB_NAME)
        .incrementer(new RunIdIncrementer())
        .start(step1)
        .next(step2)
        .build();
  }
  
  
  @Bean
  public Step step1() throws Throwable {
    return stepBuilderFactory
        .get(_JOB_STEP_NAME)
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step1");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }
  
  @Bean
  public Step step2() throws Throwable {
    return stepBuilderFactory
        .get(_JOB_STEP_NAME)
        .tasklet(new Tasklet() {
          @Override public RepeatStatus execute(StepContribution contribution,
              ChunkContext chunkContext) throws Exception {
            System.out.println("step2");
            return RepeatStatus.FINISHED;
          }
        })
        .build();
  }
```
```
step1
step2
```

### 補足情報（FW/ツールのバージョンなど）
こちらを参考に作成しております。
https://spring.pleiades.io/spring-batch/docs/current/reference/html/step.html#external-flows

Versions
spring-boot-starter-parent : 2.0.1.RELEASE

お詳しい方、ご教授の程よろしくお願いいたします。

Spring Batch Flowの実行で無限ループになってしまう

### 前提・実現したいこと

batで**カレントディレクトリ**と、**サブディレクトリ**の特定の文字をファイル名から削除したい。

例
削除したいワード：あいうえお-

**before**
￥あいうえお-フォルダ
￥あいうえお-フォルダ￥あいうえお-かきくけこ.zip

**after**
￥フォルダ
￥フォルダ￥かきくけこ.zip


### 試したこと

※１　[このサイト](https://detail.chiebukuro.yahoo.co.jp/qa/question_detail/q1097809530)を参考に、カレントディレクト内の特定文字を削除することはできました。

サブディレクトリも一括で削除しようと以下のことを試したが実現できませんでした。
・for /r でサブディレクトリのパスを取得し、さらにfor /f "tokens=*"を回す。　※２
・"for /R %target_dir% %%i in (*.txt) do ren %%i %%~ni"のような拡張子変更のrenを改変た

4時間ぐらい格闘したのですが実現できませんでした。
分かる方いましたら、ご教授お願い致します。


### カレントディレクトリのみのソースコード　※１

```ここに言語名を入力
@echo off
setlocal enabledelayedexpansion

echo =============================================
echo リネームを開始します。
echo =============================================

pushd %~dp0

:: リネームしたファイル数
set /a FILE_NUM=0

::削除するキーワード
set keyword=asdfg

for /f "tokens=*" %%i in (!s!) do (
    set a=%%i
    echo s=!s!

    ::リネーム
    ren "!a!" "!a:%keyword%=!"

    echo a=!a!
    ::リネーム名出力
    echo !a:%keyword%=!

    set /a FILE_NUM+=1
)

echo =============================================
echo %FILE_NUM%個のファイルをリネームしました。
echo =============================================

pause
```


### 試したソースコード　※２

```ここに言語名を入力
@echo off
setlocal enabledelayedexpansion

echo =============================================
echo リネームを開始します。
echo =============================================

pushd %~dp0

:: リネームしたファイル数
set /a FILE_NUM=0

::削除するキーワード
set keyword=asdfg

for /r %%f in (*) do (
    set s=%%f

    for /f "tokens=*" %%i in (!s!) do (
        set a=%%i
        echo s=!s!

        ::リネーム
        ren "!a!" "!a:%keyword%=!"

        echo a=!a!
        ::リネーム名出力
        echo !a:%keyword%=!

        set /a FILE_NUM+=1
    )
)

echo =============================================
echo %FILE_NUM%個のファイルをリネームしました。
echo =============================================

pause
```
### 環境
・Windows10