diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/riskmanage/service/impl/RiskManageServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/riskmanage/service/impl/RiskManageServiceImpl.java index 8239cf8..b96652a 100644 --- a/src/main/java/com/chinaunicom/mall/ebtp/extend/riskmanage/service/impl/RiskManageServiceImpl.java +++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/riskmanage/service/impl/RiskManageServiceImpl.java @@ -13,6 +13,7 @@ import com.chinaunicom.mall.ebtp.extend.riskmanage.entity.RiskManageRegulationVO import com.chinaunicom.mall.ebtp.extend.riskmanage.service.IRiskManageService; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang.StringUtils; import org.springframework.stereotype.Service; import javax.annotation.Resource; @@ -70,9 +71,14 @@ public class RiskManageServiceImpl implements IRiskManageService { //调用节点 regulationGroupApply.setCallPointCode(regulation.getCallPointCode()); regulationGroupApply.setCallPointName(regulation.getCallPointName()); - - BaseCacheUser cacheUser = cacheUserService.getCacheUser(); - regulationGroupApply.setOuterVoList(CallRegulationUtil.getCallRegulationMap(params,regulationParams,cacheUser.getOrganizationId())); + String orgOu=Objects.isNull(params.get("orgOu"))?"":params.get("orgOu").toString(); + if(StringUtils.isBlank(orgOu) ){ + BaseCacheUser cacheUser = cacheUserService.getCacheUser(); + if(StringUtils.isNotBlank(cacheUser.getOrganizationId())){ + orgOu=cacheUser.getOrganizationId(); + } + } + regulationGroupApply.setOuterVoList(CallRegulationUtil.getCallRegulationMap(params,regulationParams,orgOu)); log.info("调用山分风控接口参数:{}", JsonUtils.objectToJson(regulationGroupApply)); //校验信息 return regulationService.applyRegulation(regulationGroupApply);