Spring BootのWEB画面上に非同期処理によるメール送信処理を追加してみた(ソースコード編)

今回も引き続き、Spring BootのWEB画面上で、ユーザーを追加・変更したタイミングで非同期でメール送信を行う処理のサンプルプログラムについて述べる。ここでは、具体的なサンプルプログラムのソースコードを共有する。

前提条件

下記記事を参照のこと。

Spring BootのWEB画面上に非同期処理によるメール送信処理を追加してみた(完成イメージと前提条件)今回は、Spring BootのWEB画面上で、ユーザーを追加・変更したタイミングで非同期でメール送信を行う処理を追加してみたので、その...

作成したサンプルプログラムの内容

作成したサンプルプログラムの構成は以下の通り。

なお、上図の赤枠は、前提条件に記載したソースコードと比較し、変更になったソースコードを示す。赤枠のソースコードについては今後記載する。

まず、build.gradleに、メール送信ができるような設定を追加する。

plugins {
	id 'org.springframework.boot' version '2.1.7.RELEASE'
	id 'java'
}

apply plugin: 'io.spring.dependency-management'

group = 'com.example'
version = '0.0.1-SNAPSHOT'
sourceCompatibility = '1.8'

repositories {
	mavenCentral()
}

dependencies {
	implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
	implementation 'org.springframework.boot:spring-boot-starter-web'
	testImplementation 'org.springframework.boot:spring-boot-starter-test'
	compileOnly 'org.projectlombok:lombok:1.18.10'
	annotationProcessor 'org.projectlombok:lombok:1.18.10'
	compile files('lib/ojdbc6.jar')
	implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:2.1.1'
	compile group: 'org.springframework.data', name: 'spring-data-commons-core', version: '1.1.0.RELEASE'
	//メールを利用できるようにするために追加
	implementation 'org.springframework.boot:spring-boot-starter-mail'
}

plugins {

id 'org.springframework.boot' version '2.1.7.RELEASE'

id 'java'

}

apply plugin: 'io.spring.dependency-management'

group = 'com.example'

version = '0.0.1-SNAPSHOT'

sourceCompatibility = '1.8'

repositories {

mavenCentral()

}

dependencies {

implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'

implementation 'org.springframework.boot:spring-boot-starter-web'

testImplementation 'org.springframework.boot:spring-boot-starter-test'

compileOnly 'org.projectlombok:lombok:1.18.10'

annotationProcessor 'org.projectlombok:lombok:1.18.10'

compile files('lib/ojdbc6.jar')

implementation 'org.mybatis.spring.boot:mybatis-spring-boot-starter:2.1.1'

compile group: 'org.springframework.data', name: 'spring-data-commons-core', version: '1.1.0.RELEASE'

//メールを利用できるようにするために追加

implementation 'org.springframework.boot:spring-boot-starter-mail'

}

また、application.ymlに、メール送信のための設定を追加する。

server:
  port: 8084
# DB接続情報
spring:
  # DB接続情報
  datasource:
    url: jdbc:oracle:thin:@localhost:1521:xe
    username: USER01
    password: USER01
    driverClassName: oracle.jdbc.driver.OracleDriver
  # メール送信情報
  mail:
    host: smtp.gmail.com
    port: 587
    username: (GMAILアカウント)@gmail.com
    password: (GMAILパスワード)
    properties:
      mail:
        smtp:
          auth: true
          starttls:
            enable: true
# SQLログ出力
logging:
  level:
    org:
      springframework: warn
    com:
      example:
        demo:
          UserDataMapper: debug
# 一覧画面で1ページに表示する行数
demo:
  list:
    pageSize: 2

server:

port: 8084

# DB接続情報

spring:

# DB接続情報

datasource:

url: jdbc:oracle:thin:@localhost:1521:xe

username: USER01

password: USER01

driverClassName: oracle.jdbc.driver.OracleDriver

# メール送信情報

mail:

host: smtp.gmail.com

port: 587

username: (GMAILアカウント)@gmail.com

password: (GMAILパスワード)

properties:

mail:

smtp:

auth: true

starttls:

enable: true

# SQLログ出力

logging:

level:

org:

springframework: warn

com:

example:

demo:

UserDataMapper: debug

# 一覧画面で1ページに表示する行数

demo:

list:

pageSize: 2

削除または保存していないWordドキュメントの復元方法【4DDiG Windowsデータ復元】ワード(Word)データ等のファイルを誤って削除してしまった場合は、通常はデータの復元ができませんが、4DDiGというソフトウェアを利用...

さらに、非同期処理が行えるよう、Spring Bootを起動するクラスに@EnableAsyncアノテーションを付与する。

package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.MessageSource;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.validation.beanvalidation.LocalValidatorFactoryBean;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;

@EnableAsync
@SpringBootApplication
public class DemoApplication implements WebMvcConfigurer {

	@Autowired
	private MessageSource messageSource;

	public static void main(String[] args) {
		SpringApplication.run(DemoApplication.class, args);
	}

	@Bean
	public LocalValidatorFactoryBean validator() {
		//Spring Bootデフォルトのエラーメッセージのプロパティファイルを
		//ValidationMessages.propertiesからmessages.propertiesに変更する
		LocalValidatorFactoryBean localValidatorFactoryBean 
                                           = new LocalValidatorFactoryBean();
		localValidatorFactoryBean.setValidationMessageSource(messageSource);
		return localValidatorFactoryBean;
	}

	@Override
	public org.springframework.validation.Validator getValidator() {
		return validator();
	}
}

package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.context.MessageSource;

import org.springframework.context.annotation.Bean;

import org.springframework.scheduling.annotation.EnableAsync;

import org.springframework.validation.beanvalidation.LocalValidatorFactoryBean;

import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;

@EnableAsync

@SpringBootApplication

public class DemoApplication implements WebMvcConfigurer {

@Autowired

private MessageSource messageSource;

public static void main(String[] args) {

SpringApplication.run(DemoApplication.class, args);

}

@Bean

public LocalValidatorFactoryBean validator() {

//Spring Bootデフォルトのエラーメッセージのプロパティファイルを

//ValidationMessages.propertiesからmessages.propertiesに変更する

LocalValidatorFactoryBean localValidatorFactoryBean

= new LocalValidatorFactoryBean();

localValidatorFactoryBean.setValidationMessageSource(messageSource);

return localValidatorFactoryBean;

}

@Override

public org.springframework.validation.Validator getValidator() {

return validator();

}

また、メール送信を行う処理をサービスクラスの「sendCompleteMail」メソッドに追加する。こちらのメソッドは、非同期処理が行えるよう@Asyncアノテーションを付与し、JavaMailSenderクラスのsendメソッドによってメール送信を行っている。

package com.example.demo;

import org.springframework.validation.BindingResult;
import org.springframework.data.domain.Pageable;
import java.util.List;

public interface DemoService {

    /**
     * ユーザーデータリストを取得
     * @param searchForm 検索用Formオブジェクト
     * @param pageable ページネーションオブジェクト
     * @return ユーザーデータリスト
     */
    List<DemoForm> demoFormList(SearchForm searchForm, Pageable pageable);

    /**
     * 引数のIDに対応するユーザーデータを取得
     * @param id ID
     * @return ユーザーデータ
     */
    DemoForm findById(String id);

    /**
     * 引数のIDに対応するユーザーデータを削除
     * @param id ID
     */
    void deleteById(String id);

    /**
     * 引数のユーザーデータがあれば更新し、無ければ削除
     * @param demoForm 追加・更新用Formオブジェクト
     */
    void createOrUpdate(DemoForm demoForm);

    /**
     * 追加・更新用Formオブジェクトのチェック処理を行い、画面遷移先を返す
     * @param demoForm 追加・更新用Formオブジェクト
     * @param result バインド結果
     * @param normalPath 正常時の画面遷移先
     * @return 画面遷移先
     */
    String checkForm(DemoForm demoForm, BindingResult result, String normalPath);

    /**
     * 検索用Formオブジェクトのチェック処理を行い、画面遷移先を返す
     * @param searchForm 検索用Formオブジェクト
     * @param result バインド結果
     * @return 画面遷移先
     */
    String checkSearchForm(SearchForm searchForm, BindingResult result);

    /**
     * ユーザー検索時に利用するページング用オブジェクトを生成する
     * @param pageNumber ページ番号
     * @return ページング用オブジェクト
     */
    Pageable getPageable(int pageNumber);

    /**
     * 一覧画面の全ページ数を取得する
     * @param searchForm 検索用Formオブジェクト
     * @return 全ページ数
     */
    int getAllPageNum(SearchForm searchForm);

    /**
     * 引数のユーザーデータの更新完了メールを送信する(非同期で実施)
     * @param demoForm 追加・更新用Formオブジェクト
     */
    void sendCompleteMail(DemoForm demoForm);
}

package com.example.demo;

import org.springframework.validation.BindingResult;

import org.springframework.data.domain.Pageable;

import java.util.List;

public interface DemoService {

/**

* ユーザーデータリストを取得

* @param searchForm 検索用Formオブジェクト

* @param pageable ページネーションオブジェクト

* @return ユーザーデータリスト

List<DemoForm> demoFormList(SearchForm searchForm, Pageable pageable);

/**

* 引数のIDに対応するユーザーデータを取得

* @param id ID

* @return ユーザーデータ

DemoForm findById(String id);

/**

* 引数のIDに対応するユーザーデータを削除

* @param id ID

void deleteById(String id);

/**

* 引数のユーザーデータがあれば更新し、無ければ削除

* @param demoForm 追加・更新用Formオブジェクト

void createOrUpdate(DemoForm demoForm);

/**

* 追加・更新用Formオブジェクトのチェック処理を行い、画面遷移先を返す

* @param demoForm 追加・更新用Formオブジェクト

* @param result バインド結果

* @param normalPath 正常時の画面遷移先

* @return 画面遷移先

String checkForm(DemoForm demoForm, BindingResult result, String normalPath);

/**

* 検索用Formオブジェクトのチェック処理を行い、画面遷移先を返す

* @param searchForm 検索用Formオブジェクト

* @param result バインド結果

* @return 画面遷移先

String checkSearchForm(SearchForm searchForm, BindingResult result);

/**

* ユーザー検索時に利用するページング用オブジェクトを生成する

* @param pageNumber ページ番号

* @return ページング用オブジェクト

Pageable getPageable(int pageNumber);

/**

* 一覧画面の全ページ数を取得する

* @param searchForm 検索用Formオブジェクト

* @return 全ページ数

int getAllPageNum(SearchForm searchForm);

/**

* 引数のユーザーデータの更新完了メールを送信する(非同期で実施)

* @param demoForm 追加・更新用Formオブジェクト

void sendCompleteMail(DemoForm demoForm);

}

サラリーマン型フリーランスSEという働き方でお金の不安を解消しよう先日、「サラリーマン型フリーランスSE」という働き方を紹介するYouTube動画を視聴しましたので、その内容をご紹介します。「サ...

package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.domain.Sort;
import org.springframework.mail.SimpleMailMessage;
import org.springframework.mail.javamail.JavaMailSender;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.BindingResult;
import org.springframework.data.domain.Pageable;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;

@Service
public class DemoServiceImpl implements DemoService{

    /**
     * ユーザーデータテーブル(user_data)へアクセスするマッパー
     */
    @Autowired
    private UserDataMapper mapper;

    /**
     * メール送信オブジェクト
     */
    @Autowired
    private JavaMailSender javaMailSender;

    /**
     * 1ページに表示する行数(application.ymlから取得)
     */
    @Value("${demo.list.pageSize}")
    private String listPageSize;

    /**
     * メールが利用可能か(application.ymlから取得)
     */
    @Value("${spring.mail.properties.mail.smtp.starttls.enable}")
    private String mailEnabled;

    /**
     * {@inheritDoc}
     */
    @Override
    public List<DemoForm> demoFormList(SearchForm searchForm, Pageable pageable) {
        List<DemoForm> demoFormList = new ArrayList<>();
        //ユーザーデータテーブル(user_data)から検索条件に合うデータを取得する
        Collection<UserData> userDataList = mapper.findBySearchForm(searchForm, pageable);
        for (UserData userData : userDataList) {
            demoFormList.add(getDemoForm(userData));
        }
        return demoFormList;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public DemoForm findById(String id) {
        Long longId = stringToLong(id);
        UserData userData = mapper.findById(longId);
        return getDemoForm(userData);
    }

    /**
     * {@inheritDoc}
     */
    @Override
    @Transactional(readOnly = false)
    public void deleteById(String id){
        Long longId = stringToLong(id);
        mapper.deleteById(longId);
    }

    /**
     * {@inheritDoc}
     */
    @Override
    @Transactional(readOnly = false)
    public void createOrUpdate(DemoForm demoForm){
        //更新・追加処理を行うエンティティを生成
        UserData userData = getUserData(demoForm);
        //追加・更新処理
        if(demoForm.getId() == null){
            userData.setId(mapper.findMaxId() + 1);
            mapper.create(userData);
        }else{
            mapper.update(userData);
        }
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public String checkForm(DemoForm demoForm, BindingResult result, String normalPath){
        //formオブジェクトのチェック処理を行う
        if(result.hasErrors()){
            //エラーがある場合は、入力画面のままとする
            return "input";
        }
        //生年月日の日付チェック処理を行う
        //エラーがある場合は、エラーメッセージ・エラーフィールドの設定を行い、
        //入力画面のままとする
        int checkDate = DateCheckUtil.checkDate(demoForm.getBirthYear()
                , demoForm.getBirthMonth(), demoForm.getBirthDay());
        switch(checkDate){
            case 1:
                //生年月日_年が空文字の場合のエラー処理
                result.rejectValue("birthYear", "validation.date-empty"
                        , new String[]{"生年月日_年"}, "");
                return "input";
            case 2:
                //生年月日_月が空文字の場合のエラー処理
                result.rejectValue("birthMonth", "validation.date-empty"
                        , new String[]{"生年月日_月"}, "");
                return "input";
            case 3:
                //生年月日_日が空文字の場合のエラー処理
                result.rejectValue("birthDay", "validation.date-empty"
                        , new String[]{"生年月日_日"}, "");
                return "input";
            case 4:
                //生年月日の日付が不正な場合のエラー処理
                result.rejectValue("birthYear", "validation.date-invalidate");
                //生年月日_月・生年月日_日は、エラーフィールドの設定を行い、
                //メッセージを空文字に設定している
                result.rejectValue("birthMonth", "validation.empty-msg");
                result.rejectValue("birthDay", "validation.empty-msg");
                return "input";
            case 5:
                //生年月日の日付が未来日の場合のエラー処理
                result.rejectValue("birthYear", "validation.date-future");
                //生年月日_月・生年月日_日は、エラーフィールドの設定を行い、
                //メッセージを空文字に設定している
                result.rejectValue("birthMonth", "validation.empty-msg");
                result.rejectValue("birthDay", "validation.empty-msg");
                return "input";
            default:
                //性別が不正に書き換えられていないかチェックする
                if(!demoForm.getSexItems().keySet().contains(demoForm.getSex())){
                    result.rejectValue("sex", "validation.sex-invalidate");
                    return "input";
                }
                //エラーチェックに問題が無いので、正常時の画面遷移先に遷移
                return normalPath;
        }
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public String checkSearchForm(SearchForm searchForm, BindingResult result){
        int checkDate =DateCheckUtil.checkSearchForm(searchForm);
        switch (checkDate){
            case 1:
                //生年月日_fromが不正な場合のエラー処理
                result.rejectValue("fromBirthYear", "validation.date-invalidate-from");
                result.rejectValue("fromBirthMonth", "validation.empty-msg");
                result.rejectValue("fromBirthDay", "validation.empty-msg");
                return "search";
            case 2:
                //生年月日_toが不正な場合のエラー処理
                result.rejectValue("toBirthYear", "validation.date-invalidate-to");
                result.rejectValue("toBirthMonth", "validation.empty-msg");
                result.rejectValue("toBirthDay", "validation.empty-msg");
                return "search";
            case 3:
                //生年月日_from＞生年月日_toの場合のエラー処理
                result.rejectValue("fromBirthYear", "validation.date-invalidate-from-to");
                result.rejectValue("fromBirthMonth", "validation.empty-msg");
                result.rejectValue("fromBirthDay", "validation.empty-msg");
                result.rejectValue("toBirthYear", "validation.empty-msg");
                result.rejectValue("toBirthMonth", "validation.empty-msg");
                result.rejectValue("toBirthDay", "validation.empty-msg");
                return "search";
            default:
                //正常な場合はnullを返却
                return null;
        }
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public Pageable getPageable(int pageNumber){
        Pageable pageable = new Pageable() {
            @Override
            public int getPageNumber() {
                //現在ページ数を返却
                return pageNumber;
            }

            @Override
            public int getPageSize() {
                //1ページに表示する行数を返却
                //listPageSizeは、本プログラムの先頭に定義している
                return Integer.parseInt(listPageSize);
            }

            @Override
            public int getOffset() {
                //表示開始位置を返却
                //例えば、1ページに2行表示する場合の、2ページ目の表示開始位置は
                //(2-1)*2+1=3 で計算される
                return ((pageNumber - 1) * Integer.parseInt(listPageSize) + 1);
            }

            @Override
            public Sort getSort() {
                //ソートは使わないのでnullを返却
                return null;
            }
        };
        return pageable;
    }

    /**
     * {@inheritDoc}
     */
    @Override
    public int getAllPageNum(SearchForm searchForm) {
        //1ページに表示する行数を取得
        int listPageSizeNum = Integer.parseInt(listPageSize);
        if(listPageSizeNum == 0){
            return 1;
        }
        //一覧画面に表示する全データを取得
        //第二引数のpageableにnullを設定することで、一覧画面に表示する全データが取得できる
        Collection<UserData> userDataList = mapper.findBySearchForm(searchForm, null);
        //全ページ数を計算
        //例えば、1ページに2行表示する場合で、全データ件数が5の場合、
        //(5+2-1)/2=3 と計算される
        int allPageNum = (userDataList.size() + listPageSizeNum - 1) / listPageSizeNum;
        return allPageNum == 0 ? 1 : allPageNum;
    }

    /**
     * {@inheritDoc}
     */
    //@Asyncアノテーションで、このメソッドが非同期で実行されるようにする
    @Async
    @Override
    public void sendCompleteMail(DemoForm demoForm){
        //メール利用可の場合は、メールを送信
        if("true".equals(mailEnabled)){
            SimpleMailMessage message = new SimpleMailMessage();
            message.setTo("stanahas@amber.plala.or.jp");
            message.setSubject("登録・変更完了 : " + demoForm.getName());
            message.setText(getMailText(demoForm));
            javaMailSender.send(message);
        }
    }

    /**
     * DemoFormオブジェクトに引数のユーザーデータの各値を設定する
     * @param userData ユーザーデータ
     * @return DemoFormオブジェクト
     */
    private DemoForm getDemoForm(UserData userData){
        if(userData == null){
            return null;
        }
        DemoForm demoForm = new DemoForm();
        demoForm.setId(String.valueOf(userData.getId()));
        demoForm.setName(userData.getName());
        demoForm.setBirthYear(String.valueOf(userData.getBirthY()));
        demoForm.setBirthMonth(String.valueOf(userData.getBirthM()));
        demoForm.setBirthDay(String.valueOf(userData.getBirthD()));
        demoForm.setSex(userData.getSex());
        demoForm.setMemo(userData.getMemo());
        demoForm.setSex_value(userData.getSex_value());
        return demoForm;
    }

    /**
     * UserDataオブジェクトに引数のフォームの各値を設定する
     * @param demoForm DemoFormオブジェクト
     * @return ユーザーデータ
     */
    private UserData getUserData(DemoForm demoForm){
        UserData userData = new UserData();
        if(!DateCheckUtil.isEmpty(demoForm.getId())){
            userData.setId(Long.valueOf(demoForm.getId()));
        }
        userData.setName(demoForm.getName());
        userData.setBirthY(Integer.valueOf(demoForm.getBirthYear()));
        userData.setBirthM(Integer.valueOf(demoForm.getBirthMonth()));
        userData.setBirthD(Integer.valueOf(demoForm.getBirthDay()));
        userData.setSex(demoForm.getSex());
        userData.setMemo(demoForm.getMemo());
        userData.setSex_value(demoForm.getSex_value());
        return userData;
    }

    /**
     * 引数の文字列をLong型に変換する
     * @param id ID
     * @return Long型のID
     */
    private Long stringToLong(String id){
        try{
            return Long.parseLong(id);
        }catch(NumberFormatException ex){
            return null;
        }
    }

    /**
     * メール本文を生成し返却する
     * @param demoForm DemoFormオブジェクト
     * @return メール本文
     */
    private String getMailText(DemoForm demoForm){
        String line_separator = System.lineSeparator();
        StringBuilder sb = new StringBuilder();
        sb.append("下記ユーザーの登録・変更処理が完了しました。");
        sb.append(line_separator);
        sb.append(line_separator);
        sb.append("名前 : " + demoForm.getName());
        sb.append(line_separator);
        sb.append("生年月日 : "
                + demoForm.getBirthYear() + "年"
                + demoForm.getBirthMonth() + "月"
                + demoForm.getBirthDay() + "日");
        sb.append(line_separator);
        sb.append("性別 : "
                + demoForm.getSexItems().get(demoForm.getSex()));
        sb.append(line_separator);
        sb.append("メモ : " + demoForm.getMemo());
        return sb.toString();
    }

}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

311

312

313

314

315

316

317

318

319

320

321

322

323

324

325

326

327

328

329

330

331

332

333

334

335

336

337

338

339

package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.data.domain.Sort;

import org.springframework.mail.SimpleMailMessage;

import org.springframework.mail.javamail.JavaMailSender;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.validation.BindingResult;

import org.springframework.data.domain.Pageable;

import java.util.ArrayList;

import java.util.Collection;

import java.util.List;

@Service

public class DemoServiceImpl implements DemoService{

/**

* ユーザーデータテーブル(user_data)へアクセスするマッパー

@Autowired

private UserDataMapper mapper;

/**

* メール送信オブジェクト

@Autowired

private JavaMailSender javaMailSender;

/**

* 1ページに表示する行数(application.ymlから取得)

@Value("${demo.list.pageSize}")

private String listPageSize;

/**

* メールが利用可能か(application.ymlから取得)

@Value("${spring.mail.properties.mail.smtp.starttls.enable}")

private String mailEnabled;

/**

* {@inheritDoc}

@Override

public List<DemoForm> demoFormList(SearchForm searchForm, Pageable pageable) {

List<DemoForm> demoFormList = new ArrayList<>();

//ユーザーデータテーブル(user_data)から検索条件に合うデータを取得する

Collection<UserData> userDataList = mapper.findBySearchForm(searchForm, pageable);

for (UserData userData : userDataList) {

demoFormList.add(getDemoForm(userData));

}

return demoFormList;

}

/**

* {@inheritDoc}

@Override

public DemoForm findById(String id) {

Long longId = stringToLong(id);

UserData userData = mapper.findById(longId);

return getDemoForm(userData);

}

/**

* {@inheritDoc}

@Override

@Transactional(readOnly = false)

public void deleteById(String id){

Long longId = stringToLong(id);

mapper.deleteById(longId);

}

/**

* {@inheritDoc}

@Override

@Transactional(readOnly = false)

public void createOrUpdate(DemoForm demoForm){

//更新・追加処理を行うエンティティを生成

UserData userData = getUserData(demoForm);

//追加・更新処理

if(demoForm.getId() == null){

userData.setId(mapper.findMaxId() + 1);

mapper.create(userData);

}else{

mapper.update(userData);

}

/**

* {@inheritDoc}

@Override

public String checkForm(DemoForm demoForm, BindingResult result, String normalPath){

//formオブジェクトのチェック処理を行う

if(result.hasErrors()){

//エラーがある場合は、入力画面のままとする

return "input";

}

//生年月日の日付チェック処理を行う

//エラーがある場合は、エラーメッセージ・エラーフィールドの設定を行い、

//入力画面のままとする

int checkDate = DateCheckUtil.checkDate(demoForm.getBirthYear()

, demoForm.getBirthMonth(), demoForm.getBirthDay());

switch(checkDate){

case 1:

//生年月日_年が空文字の場合のエラー処理

result.rejectValue("birthYear", "validation.date-empty"

, new String[]{"生年月日_年"}, "");

return "input";

case 2:

//生年月日_月が空文字の場合のエラー処理

result.rejectValue("birthMonth", "validation.date-empty"

, new String[]{"生年月日_月"}, "");

return "input";

case 3:

//生年月日_日が空文字の場合のエラー処理

result.rejectValue("birthDay", "validation.date-empty"

, new String[]{"生年月日_日"}, "");

return "input";

case 4:

//生年月日の日付が不正な場合のエラー処理

result.rejectValue("birthYear", "validation.date-invalidate");

//生年月日_月・生年月日_日は、エラーフィールドの設定を行い、

//メッセージを空文字に設定している

result.rejectValue("birthMonth", "validation.empty-msg");

result.rejectValue("birthDay", "validation.empty-msg");

return "input";

case 5:

//生年月日の日付が未来日の場合のエラー処理

result.rejectValue("birthYear", "validation.date-future");

//生年月日_月・生年月日_日は、エラーフィールドの設定を行い、

//メッセージを空文字に設定している

result.rejectValue("birthMonth", "validation.empty-msg");

result.rejectValue("birthDay", "validation.empty-msg");

return "input";

default:

//性別が不正に書き換えられていないかチェックする

if(!demoForm.getSexItems().keySet().contains(demoForm.getSex())){

result.rejectValue("sex", "validation.sex-invalidate");

return "input";

}

//エラーチェックに問題が無いので、正常時の画面遷移先に遷移

return normalPath;

}

/**

* {@inheritDoc}

@Override

public String checkSearchForm(SearchForm searchForm, BindingResult result){

int checkDate =DateCheckUtil.checkSearchForm(searchForm);

switch (checkDate){

case 1:

//生年月日_fromが不正な場合のエラー処理

result.rejectValue("fromBirthYear", "validation.date-invalidate-from");

result.rejectValue("fromBirthMonth", "validation.empty-msg");

result.rejectValue("fromBirthDay", "validation.empty-msg");

return "search";

case 2:

//生年月日_toが不正な場合のエラー処理

result.rejectValue("toBirthYear", "validation.date-invalidate-to");

result.rejectValue("toBirthMonth", "validation.empty-msg");

result.rejectValue("toBirthDay", "validation.empty-msg");

return "search";

case 3:

//生年月日_from＞生年月日_toの場合のエラー処理

result.rejectValue("fromBirthYear", "validation.date-invalidate-from-to");

result.rejectValue("fromBirthMonth", "validation.empty-msg");

result.rejectValue("fromBirthDay", "validation.empty-msg");

result.rejectValue("toBirthYear", "validation.empty-msg");

result.rejectValue("toBirthMonth", "validation.empty-msg");

result.rejectValue("toBirthDay", "validation.empty-msg");

return "search";

default:

//正常な場合はnullを返却

return null;

}

/**

* {@inheritDoc}

@Override

public Pageable getPageable(int pageNumber){

Pageable pageable = new Pageable() {

@Override

public int getPageNumber() {

//現在ページ数を返却

return pageNumber;

}

@Override

public int getPageSize() {

//1ページに表示する行数を返却

//listPageSizeは、本プログラムの先頭に定義している

return Integer.parseInt(listPageSize);

}

@Override

public int getOffset() {

//表示開始位置を返却

//例えば、1ページに2行表示する場合の、2ページ目の表示開始位置は

//(2-1)*2+1=3 で計算される

return ((pageNumber - 1) * Integer.parseInt(listPageSize) + 1);

}

@Override

public Sort getSort() {

//ソートは使わないのでnullを返却

return null;

}

};

return pageable;

}

/**

* {@inheritDoc}

@Override

public int getAllPageNum(SearchForm searchForm) {

//1ページに表示する行数を取得

int listPageSizeNum = Integer.parseInt(listPageSize);

if(listPageSizeNum == 0){

return 1;

}

//一覧画面に表示する全データを取得

//第二引数のpageableにnullを設定することで、一覧画面に表示する全データが取得できる

Collection<UserData> userDataList = mapper.findBySearchForm(searchForm, null);

//全ページ数を計算

//例えば、1ページに2行表示する場合で、全データ件数が5の場合、

//(5+2-1)/2=3 と計算される

int allPageNum = (userDataList.size() + listPageSizeNum - 1) / listPageSizeNum;

return allPageNum == 0 ? 1 : allPageNum;

}

/**

* {@inheritDoc}

//@Asyncアノテーションで、このメソッドが非同期で実行されるようにする

@Async

@Override

public void sendCompleteMail(DemoForm demoForm){

//メール利用可の場合は、メールを送信

if("true".equals(mailEnabled)){

SimpleMailMessage message = new SimpleMailMessage();

message.setTo("stanahas@amber.plala.or.jp");

message.setSubject("登録・変更完了 : " + demoForm.getName());

message.setText(getMailText(demoForm));

javaMailSender.send(message);

}

/**

* DemoFormオブジェクトに引数のユーザーデータの各値を設定する

* @param userData ユーザーデータ

* @return DemoFormオブジェクト

private DemoForm getDemoForm(UserData userData){

if(userData == null){

return null;

}

DemoForm demoForm = new DemoForm();

demoForm.setId(String.valueOf(userData.getId()));

demoForm.setName(userData.getName());

demoForm.setBirthYear(String.valueOf(userData.getBirthY()));

demoForm.setBirthMonth(String.valueOf(userData.getBirthM()));

demoForm.setBirthDay(String.valueOf(userData.getBirthD()));

demoForm.setSex(userData.getSex());

demoForm.setMemo(userData.getMemo());

demoForm.setSex_value(userData.getSex_value());

return demoForm;

}

/**

* UserDataオブジェクトに引数のフォームの各値を設定する

* @param demoForm DemoFormオブジェクト

* @return ユーザーデータ

private UserData getUserData(DemoForm demoForm){

UserData userData = new UserData();

if(!DateCheckUtil.isEmpty(demoForm.getId())){

userData.setId(Long.valueOf(demoForm.getId()));

}

userData.setName(demoForm.getName());

userData.setBirthY(Integer.valueOf(demoForm.getBirthYear()));

userData.setBirthM(Integer.valueOf(demoForm.getBirthMonth()));

userData.setBirthD(Integer.valueOf(demoForm.getBirthDay()));

userData.setSex(demoForm.getSex());

userData.setMemo(demoForm.getMemo());

userData.setSex_value(demoForm.getSex_value());

return userData;

}

/**

* 引数の文字列をLong型に変換する

* @param id ID

* @return Long型のID

private Long stringToLong(String id){

try{

return Long.parseLong(id);

}catch(NumberFormatException ex){

return null;

}

/**

* メール本文を生成し返却する

* @param demoForm DemoFormオブジェクト

* @return メール本文

private String getMailText(DemoForm demoForm){

String line_separator = System.lineSeparator();

StringBuilder sb = new StringBuilder();

sb.append("下記ユーザーの登録・変更処理が完了しました。");

sb.append(line_separator);

sb.append("名前 : " + demoForm.getName());

sb.append(line_separator);

sb.append("生年月日 : "

+ demoForm.getBirthYear() + "年"

+ demoForm.getBirthMonth() + "月"

+ demoForm.getBirthDay() + "日");

sb.append(line_separator);

sb.append("性別 : "

+ demoForm.getSexItems().get(demoForm.getSex()));

sb.append(line_separator);

sb.append("メモ : " + demoForm.getMemo());

return sb.toString();

}

さらに、コントローラクラスの内容は以下の通りで、sendメソッド内に、メール送信を非同期で行うメソッドの呼び出しを追加している。

package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.ModelAttribute;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.SessionAttributes;
import org.springframework.validation.BindingResult;
import org.springframework.web.bind.support.SessionStatus;
import org.springframework.data.domain.Pageable;
import java.util.ArrayList;
import java.util.List;

@Controller
@SessionAttributes(types = {DemoForm.class, SearchForm.class})
public class DemoController {

    /**
     * Demoサービスクラスへのアクセス
     */
    @Autowired
    private DemoService demoService;

    /**
     * ユーザーデータテーブル(user_data)のデータを取得して返却する
     * @return ユーザーデータリスト
     */
    @ModelAttribute("demoFormList")
    public List<DemoForm> userDataList(){
        List<DemoForm> demoFormList = new ArrayList<>();
        return demoFormList;
    }

    /**
     * 追加・更新用Formオブジェクトを初期化して返却する
     * @return 追加・更新用Formオブジェクト
     */
    @ModelAttribute("demoForm")
    public DemoForm createDemoForm(){
        DemoForm demoForm = new DemoForm();
        return demoForm;
    }

    /**
     * 検索用Formオブジェクトを初期化して返却する
     * @return 検索用Formオブジェクト
     */
    @ModelAttribute("searchForm")
    public SearchForm createSearchForm(){
        SearchForm searchForm = new SearchForm();
        return searchForm;
    }

    /**
     * 初期表示(検索)画面に遷移する
     * @return 検索画面へのパス
     */
    @RequestMapping("/")
    public String index(){
        return "search";
    }

    /**
     * 検索処理を行い、一覧画面に遷移する
     * @param searchForm 検索用Formオブジェクト
     * @param model Modelオブジェクト
     * @param result バインド結果
     * @return 一覧画面へのパス
     */
    @PostMapping("/search")
    public String search(SearchForm searchForm, Model model, BindingResult result){
        //検索用Formオブジェクトのチェック処理
        String returnVal = demoService.checkSearchForm(searchForm, result);
        if(returnVal != null){
            return returnVal;
        }
        //現在ページ数を1ページ目に設定し、一覧画面に遷移する
        searchForm.setCurrentPageNum(1);
        return movePageInList(model, searchForm);
    }

    /**
     * 一覧画面で「先頭へ」リンク押下時に次ページを表示する
     * @param searchForm 検索用Formオブジェクト
     * @param model Modelオブジェクト
     * @return 一覧画面へのパス
     */
    @GetMapping("/firstPage")
    public String firstPage(SearchForm searchForm, Model model){
        //現在ページ数を先頭ページに設定する
        searchForm.setCurrentPageNum(1);
        return movePageInList(model, searchForm);
    }

    /**
     * 一覧画面で「前へ」リンク押下時に次ページを表示する
     * @param searchForm 検索用Formオブジェクト
     * @param model Modelオブジェクト
     * @return 一覧画面へのパス
     */
    @GetMapping("/backPage")
    public String backPage(SearchForm searchForm, Model model){
        //現在ページ数を前ページに設定する
        searchForm.setCurrentPageNum(searchForm.getCurrentPageNum() - 1);
        return movePageInList(model, searchForm);
    }

    /**
     * 一覧画面で「次へ」リンク押下時に次ページを表示する
     * @param searchForm 検索用Formオブジェクト
     * @param model Modelオブジェクト
     * @return 一覧画面へのパス
     */
    @GetMapping("/nextPage")
    public String nextPage(SearchForm searchForm, Model model){
        //現在ページ数を次ページに設定する
        searchForm.setCurrentPageNum(searchForm.getCurrentPageNum() + 1);
        return movePageInList(model, searchForm);
    }

    /**
     * 一覧画面で「最後へ」リンク押下時に次ページを表示する
     * @param searchForm 検索用Formオブジェクト
     * @param model Modelオブジェクト
     * @return 一覧画面へのパス
     */
    @GetMapping("/lastPage")
    public String lastPage(SearchForm searchForm, Model model){
        //現在ページ数を最終ページに設定する
        searchForm.setCurrentPageNum(demoService.getAllPageNum(searchForm));
        return movePageInList(model, searchForm);
    }

    /**
     * 更新処理を行う画面に遷移する
     * @param id 更新対象のID
     * @param model Modelオブジェクト
     * @return 入力・更新画面へのパス
     */
    @GetMapping("/update")
    public String update(@RequestParam("id") String id, Model model){
        //更新対象のユーザーデータを取得
        DemoForm demoForm = demoService.findById(id);
        //ユーザーデータを更新
        model.addAttribute("demoForm", demoForm);
        return "input";
    }

    /**
     * 削除確認画面に遷移する
     * @param id 更新対象のID
     * @param model Modelオブジェクト
     * @return 削除確認画面へのパス
     */
    @GetMapping("/delete_confirm")
    public String delete_confirm(@RequestParam("id") String id, Model model){
        //削除対象のユーザーデータを取得
        DemoForm demoForm = demoService.findById(id);
        //ユーザーデータを更新
        model.addAttribute("demoForm", demoForm);
        return "confirm_delete";
    }

    /**
     * 削除処理を行う
     * @param demoForm 追加・更新用Formオブジェクト
     * @return 一覧画面の表示処理
     */
    @PostMapping(value = "/delete", params = "next")
    public String delete(DemoForm demoForm){
        //指定したユーザーデータを削除
        demoService.deleteById(demoForm.getId());
        //一覧画面に遷移
        return "redirect:/to_index";
    }

    /**
     * 削除完了後に一覧画面に戻る
     * @param searchForm 検索用Formオブジェクト
     * @param model Modelオブジェクト
     * @return 一覧画面
     */
    @GetMapping("/to_index")
    public String toIndex(SearchForm searchForm, Model model){
        //一覧画面に戻り、1ページ目のリストを表示する
        searchForm.setCurrentPageNum(1);
        return movePageInList(model, searchForm);
    }

    /**
     * 削除確認画面から一覧画面に戻る
     * @param model Modelオブジェクト
     * @param searchForm 検索用Formオブジェクト
     * @return 一覧画面
     */
    @PostMapping(value = "/delete", params = "back")
    public String confirmDeleteBack(Model model, SearchForm searchForm){
        //一覧画面に戻る
        return movePageInList(model, searchForm);
    }

    /**
     * 追加処理を行う画面に遷移する
     * @param model Modelオブジェクト
     * @return 入力・更新画面へのパス
     */
    @PostMapping(value = "/add", params = "next")
    public String add(Model model){
        model.addAttribute("demoForm", new DemoForm());
        return "input";
    }

    /**
     * 追加処理を行う画面から検索画面に戻る
     * @return 検索画面へのパス
     */
    @PostMapping(value = "/add", params = "back")
    public String addBack(){
        return "search";
    }

    /**
     * エラーチェックを行い、エラーが無ければ確認画面に遷移し、
     * エラーがあれば入力画面のままとする
     * @param demoForm 追加・更新用Formオブジェクト
     * @param result バインド結果
     * @return 確認画面または入力画面へのパス
     */
    @PostMapping(value = "/confirm", params = "next")
    public String confirm(@Validated DemoForm demoForm, BindingResult result){
        //生年月日の日付チェック処理を行い、画面遷移する
        return demoService.checkForm(demoForm, result, "confirm");
    }

    /**
     * 一覧画面に戻る
     * @param model Modelオブジェクト
     * @param searchForm 検索用Formオブジェクト
     * @return 一覧画面の表示処理
     */
    @PostMapping(value = "/confirm", params = "back")
    public String confirmBack(Model model, SearchForm searchForm){
        //一覧画面に戻る
        return movePageInList(model, searchForm);
    }

    /**
     * 完了画面に遷移する
     * @param demoForm 追加・更新用Formオブジェクト
     * @param result バインド結果
     * @return 完了画面
     */
    @PostMapping(value = "/send", params = "next")
    public String send(@Validated DemoForm demoForm, BindingResult result){
        //チェック処理を行い、エラーがなければ、更新・追加処理とメール送信処理を行う
        String normalPath = "redirect:/complete";
        String checkPath = demoService.checkForm(demoForm, result, "redirect:/complete");
        if(normalPath.equals(checkPath)){
            //ユーザーデータがあれば更新し、無ければ削除
            demoService.createOrUpdate(demoForm);
            //メール送信を非同期で行う
            demoService.sendCompleteMail(demoForm);
        }
        return checkPath;
    }

    /**
     * 完了画面に遷移する
     * @param sessionStatus セッションステータス
     * @return 完了画面
     */
    @GetMapping("/complete")
    public String complete(SessionStatus sessionStatus){
        //セッションオブジェクトを破棄
        sessionStatus.setComplete();
        return "complete";
    }

    /**
     * 入力画面に戻る
     * @return 入力画面
     */
    @PostMapping(value = "/send", params = "back")
    public String sendBack(){
        return "input";
    }

    /**
     * 一覧画面に戻り、指定した現在ページのリストを表示する
     * @param model Modelオブジェクト
     * @param searchForm 検索用Formオブジェクト
     * @return 一覧画面の表示処理
     */
    private String movePageInList(Model model, SearchForm searchForm){
        //現在ページ数, 総ページ数を設定
        model.addAttribute("currentPageNum", searchForm.getCurrentPageNum());
        model.addAttribute("allPageNum", demoService.getAllPageNum(searchForm));
        //ページング用オブジェクトを生成し、現在ページのユーザーデータリストを取得
        Pageable pageable = demoService.getPageable(searchForm.getCurrentPageNum());
        List<DemoForm> demoFormList = demoService.demoFormList(searchForm, pageable);
        //ユーザーデータリストを更新
        model.addAttribute("demoFormList", demoFormList);
        return "list";
    }
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

138

139

140

141

142

143

144

145

146

147

148

149

150

151

152

153

154

155

156

157

158

159

160

161

162

163

164

165

166

167

168

169

170

171

172

173

174

175

176

177

178

179

180

181

182

183

184

185

186

187

188

189

190

191

192

193

194

195

196

197

198

199

200

201

202

203

204

205

206

207

208

209

210

211

212

213

214

215

216

217

218

219

220

221

222

223

224

225

226

227

228

229

230

231

232

233

234

235

236

237

238

239

240

241

242

243

244

245

246

247

248

249

250

251

252

253

254

255

256

257

258

259

260

261

262

263

264

265

266

267

268

269

270

271

272

273

274

275

276

277

278

279

280

281

282

283

284

285

286

287

288

289

290

291

292

293

294

295

296

297

298

299

300

301

302

303

304

305

306

307

308

309

310

package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.ui.Model;

import org.springframework.validation.annotation.Validated;

import org.springframework.web.bind.annotation.ModelAttribute;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.SessionAttributes;

import org.springframework.validation.BindingResult;

import org.springframework.web.bind.support.SessionStatus;

import org.springframework.data.domain.Pageable;

import java.util.ArrayList;

import java.util.List;

@Controller

@SessionAttributes(types = {DemoForm.class, SearchForm.class})

public class DemoController {

/**

* Demoサービスクラスへのアクセス

@Autowired

private DemoService demoService;

/**

* ユーザーデータテーブル(user_data)のデータを取得して返却する

* @return ユーザーデータリスト

@ModelAttribute("demoFormList")

public List<DemoForm> userDataList(){

List<DemoForm> demoFormList = new ArrayList<>();

return demoFormList;

}

/**

* 追加・更新用Formオブジェクトを初期化して返却する

* @return 追加・更新用Formオブジェクト

@ModelAttribute("demoForm")

public DemoForm createDemoForm(){

DemoForm demoForm = new DemoForm();

return demoForm;

}

/**

* 検索用Formオブジェクトを初期化して返却する

* @return 検索用Formオブジェクト

@ModelAttribute("searchForm")

public SearchForm createSearchForm(){

SearchForm searchForm = new SearchForm();

return searchForm;

}

/**

* 初期表示(検索)画面に遷移する

* @return 検索画面へのパス

@RequestMapping("/")

public String index(){

return "search";

}

/**

* 検索処理を行い、一覧画面に遷移する

* @param searchForm 検索用Formオブジェクト

* @param model Modelオブジェクト

* @param result バインド結果

* @return 一覧画面へのパス

@PostMapping("/search")

public String search(SearchForm searchForm, Model model, BindingResult result){

//検索用Formオブジェクトのチェック処理

String returnVal = demoService.checkSearchForm(searchForm, result);

if(returnVal != null){

return returnVal;

}

//現在ページ数を1ページ目に設定し、一覧画面に遷移する

searchForm.setCurrentPageNum(1);

return movePageInList(model, searchForm);

}

/**

* 一覧画面で「先頭へ」リンク押下時に次ページを表示する

* @param searchForm 検索用Formオブジェクト

* @param model Modelオブジェクト

* @return 一覧画面へのパス

@GetMapping("/firstPage")

public String firstPage(SearchForm searchForm, Model model){

//現在ページ数を先頭ページに設定する

searchForm.setCurrentPageNum(1);

return movePageInList(model, searchForm);

}

/**

* 一覧画面で「前へ」リンク押下時に次ページを表示する

* @param searchForm 検索用Formオブジェクト

* @param model Modelオブジェクト

* @return 一覧画面へのパス

@GetMapping("/backPage")

public String backPage(SearchForm searchForm, Model model){

//現在ページ数を前ページに設定する

searchForm.setCurrentPageNum(searchForm.getCurrentPageNum() - 1);

return movePageInList(model, searchForm);

}

/**

* 一覧画面で「次へ」リンク押下時に次ページを表示する

* @param searchForm 検索用Formオブジェクト

* @param model Modelオブジェクト

* @return 一覧画面へのパス

@GetMapping("/nextPage")

public String nextPage(SearchForm searchForm, Model model){

//現在ページ数を次ページに設定する

searchForm.setCurrentPageNum(searchForm.getCurrentPageNum() + 1);

return movePageInList(model, searchForm);

}

/**

* 一覧画面で「最後へ」リンク押下時に次ページを表示する

* @param searchForm 検索用Formオブジェクト

* @param model Modelオブジェクト

* @return 一覧画面へのパス

@GetMapping("/lastPage")

public String lastPage(SearchForm searchForm, Model model){

//現在ページ数を最終ページに設定する

searchForm.setCurrentPageNum(demoService.getAllPageNum(searchForm));

return movePageInList(model, searchForm);

}

/**

* 更新処理を行う画面に遷移する

* @param id 更新対象のID

* @param model Modelオブジェクト

* @return 入力・更新画面へのパス

@GetMapping("/update")

public String update(@RequestParam("id") String id, Model model){

//更新対象のユーザーデータを取得

DemoForm demoForm = demoService.findById(id);

//ユーザーデータを更新

model.addAttribute("demoForm", demoForm);

return "input";

}

/**

* 削除確認画面に遷移する

* @param id 更新対象のID

* @param model Modelオブジェクト

* @return 削除確認画面へのパス

@GetMapping("/delete_confirm")

public String delete_confirm(@RequestParam("id") String id, Model model){

//削除対象のユーザーデータを取得

DemoForm demoForm = demoService.findById(id);

//ユーザーデータを更新

model.addAttribute("demoForm", demoForm);

return "confirm_delete";

}

/**

* 削除処理を行う

* @param demoForm 追加・更新用Formオブジェクト

* @return 一覧画面の表示処理

@PostMapping(value = "/delete", params = "next")

public String delete(DemoForm demoForm){

//指定したユーザーデータを削除

demoService.deleteById(demoForm.getId());

//一覧画面に遷移

return "redirect:/to_index";

}

/**

* 削除完了後に一覧画面に戻る

* @param searchForm 検索用Formオブジェクト

* @param model Modelオブジェクト

* @return 一覧画面

@GetMapping("/to_index")

public String toIndex(SearchForm searchForm, Model model){

//一覧画面に戻り、1ページ目のリストを表示する

searchForm.setCurrentPageNum(1);

return movePageInList(model, searchForm);

}

/**

* 削除確認画面から一覧画面に戻る

* @param model Modelオブジェクト

* @param searchForm 検索用Formオブジェクト

* @return 一覧画面

@PostMapping(value = "/delete", params = "back")

public String confirmDeleteBack(Model model, SearchForm searchForm){

//一覧画面に戻る

return movePageInList(model, searchForm);

}

/**

* 追加処理を行う画面に遷移する

* @param model Modelオブジェクト

* @return 入力・更新画面へのパス

@PostMapping(value = "/add", params = "next")

public String add(Model model){

model.addAttribute("demoForm", new DemoForm());

return "input";

}

/**

* 追加処理を行う画面から検索画面に戻る

* @return 検索画面へのパス

@PostMapping(value = "/add", params = "back")

public String addBack(){

return "search";

}

/**

* エラーチェックを行い、エラーが無ければ確認画面に遷移し、

* エラーがあれば入力画面のままとする

* @param demoForm 追加・更新用Formオブジェクト

* @param result バインド結果

* @return 確認画面または入力画面へのパス

@PostMapping(value = "/confirm", params = "next")

public String confirm(@Validated DemoForm demoForm, BindingResult result){

//生年月日の日付チェック処理を行い、画面遷移する

return demoService.checkForm(demoForm, result, "confirm");

}

/**

* 一覧画面に戻る

* @param model Modelオブジェクト

* @param searchForm 検索用Formオブジェクト

* @return 一覧画面の表示処理

@PostMapping(value = "/confirm", params = "back")

public String confirmBack(Model model, SearchForm searchForm){

//一覧画面に戻る

return movePageInList(model, searchForm);

}

/**

* 完了画面に遷移する

* @param demoForm 追加・更新用Formオブジェクト

* @param result バインド結果

* @return 完了画面

@PostMapping(value = "/send", params = "next")

public String send(@Validated DemoForm demoForm, BindingResult result){

//チェック処理を行い、エラーがなければ、更新・追加処理とメール送信処理を行う

String normalPath = "redirect:/complete";

String checkPath = demoService.checkForm(demoForm, result, "redirect:/complete");

if(normalPath.equals(checkPath)){

//ユーザーデータがあれば更新し、無ければ削除

demoService.createOrUpdate(demoForm);

//メール送信を非同期で行う

demoService.sendCompleteMail(demoForm);

}

return checkPath;

}

/**

* 完了画面に遷移する

* @param sessionStatus セッションステータス

* @return 完了画面

@GetMapping("/complete")

public String complete(SessionStatus sessionStatus){

//セッションオブジェクトを破棄

sessionStatus.setComplete();

return "complete";

}

/**

* 入力画面に戻る

* @return 入力画面

@PostMapping(value = "/send", params = "back")

public String sendBack(){

return "input";

}

/**

* 一覧画面に戻り、指定した現在ページのリストを表示する

* @param model Modelオブジェクト

* @param searchForm 検索用Formオブジェクト

* @return 一覧画面の表示処理

private String movePageInList(Model model, SearchForm searchForm){

//現在ページ数, 総ページ数を設定

model.addAttribute("currentPageNum", searchForm.getCurrentPageNum());

model.addAttribute("allPageNum", demoService.getAllPageNum(searchForm));

//ページング用オブジェクトを生成し、現在ページのユーザーデータリストを取得

Pageable pageable = demoService.getPageable(searchForm.getCurrentPageNum());

List<DemoForm> demoFormList = demoService.demoFormList(searchForm, pageable);

//ユーザーデータリストを更新

model.addAttribute("demoFormList", demoFormList);

return "list";

}

その他のソースコード内容は、以下のサイトを参照のこと。
https://github.com/purin-it/java/tree/master/spring-boot-async-mail-2/demo

要点まとめ

非同期処理を行えるようにするには、Spring Bootの起動クラスに@EnableAsyncアノテーションを付与し、非同期処理を行うメソッドに@Asyncアノテーションを付与すればよい。
メール送信は、JavaMailSenderクラスのsendメソッドにより行える。

前提条件

作成したサンプルプログラムの内容

要点まとめ

Spring Boot上でマテリアライズドビューを利用してみた

MongoTemplateを利用して複雑な条件検索を行ってみた

MyBatis Generatorを使ってMapperやEntityを自動生成してみた

OracleのIN句で1000件を超える項目を指定してみた

MyBatisのSQL文をXMLファイルに配置してみた

各DBのIN句で1000件を超える項目を指定してみた