| | |
| | | import com.java110.entity.center.AppRoute; |
| | | import com.java110.entity.center.AppService; |
| | | import com.java110.entity.center.DataFlowLinksCost; |
| | | import com.java110.event.service.api.ServiceDataFlowEventPublishing; |
| | | import com.java110.core.event.service.api.ServiceDataFlowEventPublishing; |
| | | import org.apache.commons.lang3.math.NumberUtils; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | |
| | | reqJson = decrypt(reqJson, headers); |
| | | } |
| | | |
| | | //1.0 创建数据流 |
| | | //1.0 创建数据流 appId serviceCode |
| | | dataFlow = DataFlowFactory.newInstance(ApiDataFlow.class).builder(reqJson, headers); |
| | | |
| | | //2.0 加载配置信息 |
| | |
| | | if (!StringUtil.isNullOrNone(dataFlow.getAppRoutes().get(0).getSecurityCode())) { |
| | | String sign = AuthenticationFactory.apiDataFlowMd5(dataFlow); |
| | | if (!sign.equals(dataFlow.getReqSign().toLowerCase())) { |
| | | throw new NoAuthorityException(ResponseConstant.RESULT_CODE_NO_AUTHORITY_ERROR, "签名失败"); |
| | | throw new NoAuthorityException(ResponseConstant.RESULT_CODE_NO_AUTHORITY_ERROR, "签名失败"+sign); |
| | | } |
| | | } |
| | | |