/*** 这是一个HSF接口Provider实现，示例代码中省略了典型的try-catch结构*/@ServiceEntrance(name="归因计费服务")@Overridepublic Result<RatingDTO> rating(RatingRequest request) {    validateRatingParam(request);
    //构建流程上下文并启动处理流程    RatingProcessContext context = new RatingProcessContext();    context.setRatingRequest(request);
    ProcessResult processResult =  processEngine.start(ProcessNS.PROCESS_RATING, context);
    if(processResult.isSuccess()) {        return Result.success(buildRatingResultDTO(context));    }else{        return Result.fail(processResult.getErrorCode(), processResult.getErrorMessage());    }}

<?xml version="1.0" encoding="UTF-8"?><onion-process-config>  <!--      支持基本的逻辑编排：顺序、并行、条件、跳转、循环、分组、子流程      实际上用的最多的是最基本的顺序编排  -->  <process id="rating_process" name="内容计佣处理流程">      <node-list>          <!--归因计佣相关的activity-->          <activity name="初始化数据" bean="ratingInitActivity"/>          <activity name="在线归因" bean="ratingAttributeActivity"/>          <activity name="归因后初始化数据" bean="ratingAttributeAfterInitActivity"/>          <activity name="黑名单商品校验" bean="ratingBlackCheckActivity"/>          <activity name="按费用项计佣" bean="ratingRatioActivity"/>          <activity name="同步账房处理" bean="ratingAutoPayCenterActivity"/>          <activity name="初始化达人外部引流" bean="ratingInitOuterTrackRuleActivity"/>          <activity name="按费用项构建分佣关系" bean="ratingCommissionListActivity"/>          <activity name="按费用项构建加码分佣关系" bean="ratingExtraCommissionListActivity"/>          <activity name="扣佣结果组装" bean="ratingResultBuildActivity"/>      </node-list>  </process>
  <!-- 这里再放一个并行流程的示例 -->  <process id="itemCompleteParallelProcess" name="商品补标流程" parallel="true"           executor="itemCompleteExecutor" timeout="500">      <node-list>          <activity name="商品补标活动A" bean="itemCompleteActivityA"/>          <activity name="商品补标活动B" bean="itemCompleteActivityB"/>          <activity name="商品补标活动C" bean="itemCompleteActivityC"/>          <activity name="商品补标活动D" bean="itemCompleteActivityD"/>          <activity name="商品补标活动E" bean="itemCompleteActivityE"/>          <activity name="商品补标活动F" bean="itemCompleteActivityF">              <dependency-list>                  <!-- 整体各个活动之间并行执行，但是F要依赖A执行完成 -->                  <dependency ref="itemCompleteActivityA"/>              </dependency-list>          </activity>      </node-list>  </process></onion-process-config>

/** * 归因活动 * @author jiangxin.zcg * @date 2022/10/25 */@Componentpublic class RatingAttributeToActivity implements ProcessActivity<RatingProcessContext> {
    @Autowired    private RatingDomainService ratingDomainService;
    @Override    public ActivityResult execute(RatingProcessContext context) {        AttributeToRequest request = new AttributeToRequest();        request.setRatingRequest(context.getRatingRequest());
        //调用领域服务完成归因过程        AttributeResultDTO attributeResultDTO = ratingDomainService.attributeTo(request);        context.setAttributeToTrack(attributeResultDTO.getTrackDTO());
        //后面计费的业务实例在这里构建，根据归因结果确定了业务身份        TcpRatingInstance ratingInstance = new TcpRatingInstance();        ratingInstance.setBizInstanceId(BizInstanceId.of(context.getAttributeToTrack().getBizcode(),                context.getRatingRequest().getBizOrderId()));        ratingInstance.setRatingRequest(context.getRatingRequest());
        context.setRatingInstance(ratingInstance);
        //这里实际上因为有了归因计费的业务实例，也有了业务身份，也就是可以调用ratingDomainService的其他方法，做一些这个业务特有的扩展了
        return ActivityResult.SUCCESS;    }
}

@Domain(id = DomainNS.DOMAIN_TCP_RATING, name = "归因计费域")public class RatingDomainService implements IDomainService<TcpRatingExtTemplate> {
    /**     * 归因领域服务     */    @DomainService(name="归因服务")    public AttributeResultDTO attributeTo(AttributeToRequest request){        //找到lastClick        List<TcpTrackDTO> trackList = request.getRatingRequest().getTrackList();        TcpTrackDTO lastClick = trackList.get(trackList.size() - 1);
        AttributeResultDTO result = new AttributeResultDTO();        result.setBizcode(lastClick.getBizcode());        result.setTrackDTO(lastClick);
        return result;    }
    /**     * 计费领域服务     */    @DomainService(name="计费服务")    public List<RatingDetailDTO> ratioCalculate(RatioCalculateRequest request){        List<RatingDetailDTO> resultList = Lists.newLinkedList();        BizTypeRatingOutput bizTypeRatingOutput;        for (RatioCalculateInstance instance : request.getRatingInstance().getRatioCalculateInstanceList()) {            BizTypeRatingInput input = new BizTypeRatingInput();            input.setInstance(instance);            //不同的bizType调用扩展点做计费            bizTypeRatingOutput = this.invokeFirstMatched(instance,                    TcpRatingExtTemplate.EXT_TCP_BIZTYPE_RATING,                    ext -> ext.bizTypeRating(input));
            if(bizTypeRatingOutput != null){                resultList.addAll(bizTypeRatingOutput.getRatingDetailList());            }        }
        return resultList;    }}