我有一個 RESTful API，用于通過 id 查詢一個資料，然后更新ExpiredTime = ExpiredTime input day。
由于我對回應式編程的經驗有限，我的代碼看起來很丑。如何改進它？
@Autowired
R2dbcEntityTemplate r2dbcEntityTemplate;
/**
*
* @param vo json with {tenantId:"",day:"1"}
* @return 404 OR 2XX
*/
@PatchMapping
public Mono<ResponseEntity<Void>> updateTime(@RequestBody TenantUpdate vo) {
return r2dbcEntityTemplate
.selectOne(query(where("tenant_id").is(vo.getTenantId())), Tenant.class)
.flatMap((Function<Tenant, Mono<Tenant>>) db -> {
if ( db.getTenantExpiredTime()==null){
db.setTenantExpiredTime(LocalDateTime.now());
}
db.setTenantExpiredTime(db.getTenantExpiredTime().plusDays(vo.getDay()));
return Mono.just(db);
})
//todo test ObjectOptimisticLockingFailureException
.flatMap(m -> r2dbcEntityTemplate.update(m))
.flatMap((Function<Tenant, Mono<? extends ResponseEntity<Void>>>)
m -> Mono.just(ResponseEntity.noContent().build()))
.switchIfEmpty(Mono.just(ResponseEntity
.notFound()
.build())
);
}
uj5u.com熱心網友回復：
你可以像這樣重寫它：
@PatchMapping
public Mono<ResponseEntity<Void>> updateTime(@RequestBody TenantUpdate request) {
return r2dbcTemplate.selectOne(query(where("tenant_id").is(request.getTenantId())), Tenant.class)
.map(t -> {
t.setTenantExpiredTime(t.getTenantExpiredTime() == null ? LocalDateTime.now() : t.getTenantExpiredTime().plusDays(request.getDay()));
return t;
})
//todo test ObjectOptimisticLockingFailureException
.flatMap(t -> r2dbcTemplate.update(t))
.map(t -> new ResponseEntity<Void>(HttpStatus.NO_CONTENT))
.switchIfEmpty(Mono.just(ResponseEntity.notFound().build()));
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/327895.html
標籤：春天 反应式编程 弹簧-webflux 项目反应堆 弹簧数据-r2dbc