|
|
@@ -6,6 +6,9 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
+import org.springframework.web.context.request.async.DeferredResult;
|
|
|
+
|
|
|
+import java.util.concurrent.CompletableFuture;
|
|
|
|
|
|
/**
|
|
|
* @author: guq
|
|
|
@@ -19,42 +22,74 @@ public class MessageLogController {
|
|
|
private MessageLogService messageLogService;
|
|
|
|
|
|
@RequestMapping("/save")
|
|
|
- public void save(@RequestBody DocBaseDTO baseDTO) {
|
|
|
- messageLogService.save(baseDTO);
|
|
|
+ public DeferredResult<String> save(@RequestBody DocBaseDTO baseDTO) {
|
|
|
+ // Create the deferredResult and initiate a callback object, task, with it
|
|
|
+ DeferredResult<String> deferredResult = new DeferredResult<>();
|
|
|
+ CompletableFuture.supplyAsync(() -> messageLogService.save(baseDTO))
|
|
|
+ .whenCompleteAsync((result, throwable) -> deferredResult.setResult(result));
|
|
|
+ return deferredResult;
|
|
|
}
|
|
|
|
|
|
@RequestMapping("/update")
|
|
|
- public void update(@RequestBody DocBaseDTO baseDTO) {
|
|
|
- messageLogService.update(baseDTO);
|
|
|
+ public DeferredResult<String> update(@RequestBody DocBaseDTO baseDTO) {
|
|
|
+ // Create the deferredResult and initiate a callback object, task, with it
|
|
|
+ DeferredResult<String> deferredResult = new DeferredResult<>();
|
|
|
+ CompletableFuture.supplyAsync(() -> messageLogService.update(baseDTO))
|
|
|
+ .whenCompleteAsync((result, throwable) -> deferredResult.setResult(result));
|
|
|
+ return deferredResult;
|
|
|
}
|
|
|
|
|
|
@RequestMapping("/delete")
|
|
|
- public void delete(@RequestBody DocBaseDTO baseDTO) {
|
|
|
- messageLogService.delete(baseDTO);
|
|
|
+ public DeferredResult<String> delete(@RequestBody DocBaseDTO baseDTO) {
|
|
|
+ // Create the deferredResult and initiate a callback object, task, with it
|
|
|
+ DeferredResult<String> deferredResult = new DeferredResult<>();
|
|
|
+ CompletableFuture.supplyAsync(() -> messageLogService.delete(baseDTO))
|
|
|
+ .whenCompleteAsync((result, throwable) -> deferredResult.setResult(result));
|
|
|
+ return deferredResult;
|
|
|
}
|
|
|
|
|
|
@RequestMapping("/deleteDetail")
|
|
|
- public void deleteDetail(@RequestBody DocBaseDTO baseDTO) {
|
|
|
- messageLogService.deleteDetail(baseDTO);
|
|
|
+ public DeferredResult<String> deleteDetail(@RequestBody DocBaseDTO baseDTO) {
|
|
|
+ // Create the deferredResult and initiate a callback object, task, with it
|
|
|
+ DeferredResult<String> deferredResult = new DeferredResult<>();
|
|
|
+ CompletableFuture.supplyAsync(() -> messageLogService.deleteDetail(baseDTO))
|
|
|
+ .whenCompleteAsync((result, throwable) -> deferredResult.setResult(result));
|
|
|
+ return deferredResult;
|
|
|
}
|
|
|
|
|
|
@RequestMapping("/audit")
|
|
|
- public void audit(@RequestBody DocBaseDTO baseDTO) {
|
|
|
- messageLogService.audit(baseDTO);
|
|
|
+ public DeferredResult<String> audit(@RequestBody DocBaseDTO baseDTO) {
|
|
|
+ // Create the deferredResult and initiate a callback object, task, with it
|
|
|
+ DeferredResult<String> deferredResult = new DeferredResult<>();
|
|
|
+ CompletableFuture.supplyAsync(() -> messageLogService.audit(baseDTO))
|
|
|
+ .whenCompleteAsync((result, throwable) -> deferredResult.setResult(result));
|
|
|
+ return deferredResult;
|
|
|
}
|
|
|
|
|
|
@RequestMapping("/unAudit")
|
|
|
- public void unAudit(@RequestBody DocBaseDTO baseDTO) {
|
|
|
- messageLogService.unAudit(baseDTO);
|
|
|
+ public DeferredResult<String> unAudit(@RequestBody DocBaseDTO baseDTO) {
|
|
|
+ // Create the deferredResult and initiate a callback object, task, with it
|
|
|
+ DeferredResult<String> deferredResult = new DeferredResult<>();
|
|
|
+ CompletableFuture.supplyAsync(() -> messageLogService.unAudit(baseDTO))
|
|
|
+ .whenCompleteAsync((result, throwable) -> deferredResult.setResult(result));
|
|
|
+ return deferredResult;
|
|
|
}
|
|
|
|
|
|
@RequestMapping("/close")
|
|
|
- public void close(@RequestBody DocBaseDTO baseDTO) {
|
|
|
- messageLogService.close(baseDTO);
|
|
|
+ public DeferredResult<String> close(@RequestBody DocBaseDTO baseDTO) {
|
|
|
+ // Create the deferredResult and initiate a callback object, task, with it
|
|
|
+ DeferredResult<String> deferredResult = new DeferredResult<>();
|
|
|
+ CompletableFuture.supplyAsync(() -> messageLogService.close(baseDTO))
|
|
|
+ .whenCompleteAsync((result, throwable) -> deferredResult.setResult(result));
|
|
|
+ return deferredResult;
|
|
|
}
|
|
|
|
|
|
@RequestMapping("/open")
|
|
|
- public void open(@RequestBody DocBaseDTO baseDTO) {
|
|
|
- messageLogService.open(baseDTO);
|
|
|
+ public DeferredResult<String> open(@RequestBody DocBaseDTO baseDTO) {
|
|
|
+ // Create the deferredResult and initiate a callback object, task, with it
|
|
|
+ DeferredResult<String> deferredResult = new DeferredResult<>();
|
|
|
+ CompletableFuture.supplyAsync(() -> messageLogService.open(baseDTO))
|
|
|
+ .whenCompleteAsync((result, throwable) -> deferredResult.setResult(result));
|
|
|
+ return deferredResult;
|
|
|
}
|
|
|
}
|