@lvjiefly php-amqplib

package com.oktfolio.tero.common;

import com.fasterxml.jackson.annotation.JsonFormat;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.google.common.base.Strings;
import com.oktfolio.tero.common.enums.ResultCode;
import com.oktfolio.tero.common.enums.ResultCodeEnum;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;

import javax.annotation.Nonnull;
import javax.annotation.Nullable;
import java.time.LocalDateTime;
import java.util.Objects;

/**
* @author oktfolio [email protected]
* @date 2020/06/08
*/
@JsonInclude(JsonInclude.Include.NON_NULL)
public class ResultEntity<T> {
protected String code;
protected String message;
protected T data;
protected HttpStatus status;
@JsonFormat(pattern = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'")
protected LocalDateTime datetime;

public String getCode() {
return code;
}

public String getMessage() {
return message;
}

public T getData() {
return data;
}

public HttpStatus getStatus() {
return status;
}

public LocalDateTime getDatetime() {
return datetime;
}

private ResultEntity() {
}

public ResultEntity(String code, String message, T data, HttpStatus status, LocalDateTime datetime) {
this.code = code;
this.message = message;
this.data = data;
this.status = status;
this.datetime = datetime;
}

public static Builder builder() {
return new Builder();
}

public static class Builder {

protected String code;
protected String message;
protected HttpStatus status;
protected LocalDateTime datetime;

public Builder code(String code) {
this.code = code;
return this;
}

public Builder message(String message) {
this.message = message;
return this;
}

public Builder datetime(LocalDateTime datetime) {
this.datetime = datetime;
return this;
}

public Builder status(@Nonnull HttpStatus status) {
this.status = status;
return this;
}

public <T> ResultEntity<T> data(@Nullable T data) {
return new ResultEntity<>(code, message, data, status, datetime);
}

public <T> ResultEntity<T> build() {
return this.data(null);
}

}

public static <T> ResultEntity<T> ok() {
return ResultEntity.builder()
.status(HttpStatus.OK)
.build();
}

public static <T> ResultEntity<T> created() {
return ResultEntity.builder()
.status(HttpStatus.CREATED)
.build();
}

public static <T> ResultEntity<T> noContent() {
return ResultEntity.builder()
.status(HttpStatus.NO_CONTENT)
.build();
}

public static <T> ResultEntity<T> ok(T data) {
return ResultEntity.builder()
.status(HttpStatus.OK)
.datetime(LocalDateTime.now())
.data(data);
}

public static <T> ResultEntity<T> created(T data) {
return ResultEntity.builder()
.status(HttpStatus.CREATED)
.data(data);
}

public static <T> ResultEntity<T> of(@Nonnull ResultCode resultCode) {
return ResultEntity.builder()
.status(resultCode.status())
.code(resultCode.value())
.message(resultCode.message())
.datetime(LocalDateTime.now())
.build();
}

public static <T> ResultEntity<T> error() {
return ResultEntity.builder()
.status(ResultCodeEnum.ERROR.status())
.code(ResultCodeEnum.ERROR.value())
.message(ResultCodeEnum.ERROR.message())
.datetime(LocalDateTime.now())
.build();
}

public static <T> ResultEntity<T> error(@Nonnull HttpStatus status, @Nonnull String message) {
return ResultEntity.builder()
.status(status)
.code(ResultCodeEnum.ERROR.value())
.message(message)
.datetime(LocalDateTime.now())
.build();
}

public static <T> ResultEntity<T> notFound(@Nonnull ResultCode resultCode) {
return ResultEntity.builder()
.status(HttpStatus.NOT_FOUND)
.code(resultCode.value())
.message(resultCode.message())
.datetime(LocalDateTime.now())
.build();
}

public static <T> ResultEntity<T> badRequest(@Nonnull ResultCode resultCode) {
return ResultEntity.builder()
.status(HttpStatus.BAD_REQUEST)
.code(resultCode.value())
.message(resultCode.message())
.build();
}

public static <T> ResultEntity<T> unauthorized(@Nonnull ResultCode resultCode) {
return ResultEntity.builder()
.status(HttpStatus.UNAUTHORIZED)
.code(resultCode.value())
.message(resultCode.message())
.datetime(LocalDateTime.now())
.build();
}

public static <T> ResultEntity<T> unauthorized(String message) {
return ResultEntity.builder()
.status(HttpStatus.UNAUTHORIZED)
.code(ResultCodeEnum.ERROR.value())
.message(message)
.datetime(LocalDateTime.now())
.build();
}

public static <T> ResultEntity<T> forbidden(@Nonnull ResultCode resultCode) {
return ResultEntity.builder()
.status(HttpStatus.FORBIDDEN)
.code(resultCode.value())
.message(resultCode.message())
.datetime(LocalDateTime.now())
.build();
}

public static <T> ResultEntity<T> created(@Nonnull ResultCode resultCode) {
return ResultEntity.builder()
.status(HttpStatus.CREATED)
.code(resultCode.value())
.message(resultCode.message())
.build();
}

public static <T> ResultEntity<T> internalServerError() {
return ResultEntity.builder()
.status(ResultCodeEnum.INTERNAL_SERVER_ERROR.status())
.code(ResultCodeEnum.INTERNAL_SERVER_ERROR.value())
.message(ResultCodeEnum.INTERNAL_SERVER_ERROR.message())
.datetime(LocalDateTime.now())
.build();
}

public static <T> ResultEntity<T> internalServerError(@Nonnull ResultCode resultCode) {
return ResultEntity.builder()
.status(HttpStatus.INTERNAL_SERVER_ERROR)
.code(resultCode.value())
.message(resultCode.message())
.datetime(LocalDateTime.now())
.build();
}

public ResponseEntity<Object> responseEntity() {
if (Objects.isNull(this.data)
&& Strings.isNullOrEmpty(this.code)
&& Strings.isNullOrEmpty(this.message)
&& !Objects.isNull(this.status)) {
return new ResponseEntity<>(this.getStatus());
} else {
return new ResponseEntity<>(this, this.getStatus());
}
}
}

我是这么玩的。

Hikari 不香吗？用什么 Druid ？

我这个 TS 吹就很尴尬

那为什么不用 Hutool ？

杠一下，这并不 RESTful 。

TS 好评

gRPC is a modern open source high performance RPC framework that can run in any environment.

let product of products 不是 TypeScript 的特性吗？ products 不就是 Product[] 类型吗？遍历出来不就是 Product 类型吗？

@sunny352787 以前的事情啦，现在应该没有了。

@Oktfolio 但是我这样就需要兼顾 HTTP Status Code 和自定义 Code 。

```
public class ResultEntity {
private Integer code;
private String message;
private Object data;
@JsonIgnore
private HttpStatus status;
@JsonFormat(pattern = "yyyy-MM-dd'T'HH:mm:ss.SSS'Z'")
private LocalDateTime datetime;
}
```

个人项目的话。GET 以外的方法结果为 20x 的时候，除特殊情况什么都不返回，GET 只返回内容，没有上面的封装。有错误的时候才上面封装的内容。status 是方便在 service 层返回状态给 controller 用的，实际是会以 http 状态码返回给前端。会用到 GET POST DELETE PUT PATCH 五种 Method 。
```
public class ResultEntity implements Serializable {

private boolean success;
private String errorMsg;
private int errorCode;
private String errorLevel;
private Object content;
}

public class PageResultEntity implements Serializable {

private int currentPage;
private int pageSize;
private long totalCount;
private int pages;
private List<Object> data;

}
```
工作嘛，全用 GET POST，全返回 200，然后就是上面定义的内容了。

/login 不用管，实现自己的 AuthenticationSuccessHandler 。然后 Jwt 鉴权过滤器。当然我自己还实现了一个 json 登录的过滤器。

@yuyu12 一个 StringUtils 都不下二十个包路径。

索引。

最后上报时间

有个差不多的实现，坑挖了 2 年，一直没填。从 vendor 到 dep 到 mod，重新传了好几次，就是一行代码都没动。

```
[request_definition]
r = sub, obj, act

[policy_definition]
p = sub, obj, act

[role_definition]
g = _, _

[policy_effect]
e = some(where (p.eft == allow))

[matchers]
m = g(r.sub, p.sub) && keyMatch(r.obj, p.obj) && (r.act == p.act || p.act == "*")
```

```
func CasbinAuth() gin.HandlerFunc {
return func(c *gin.Context) {
claims := parseClaims(c)
user := claims.User.Username
path := c.Request.URL.Path
method := c.Request.Method

if !casbin.E.Enforce(user, path, method) {

result := common.Result{
Code: 20000,
Message: "login success",
Timestamp: time.Now().Unix(),
}

c.JSON( http.StatusUnauthorized, result)
c.Abort()
return
}
c.Next()
}
}
```

@ARhen Servlet 加注解其实也还好，缺点嘛...不支持 RESTful 。

360Chrome