Create Custom Sourcing Criterion

1@SourcingCriterionInfo(
2    name = "mySourcingCriterion",
3    type = "company.sourcing.criterion.my",
4    tags = { "ATS-agnostic" } // or "ATS-dependent", "Exclusion"
5)
6public class MySourcingCriterion extends BaseSourcingCriterion {
7
8    @SourcingCriterionParam(name = "value", component = "integer")
9    private Integer threshold;
10
11    @Override
12    public void parseParams(final JsonNode params) {
13        // parse threshold, lists, units, etc.
14    }
15
16    @Override
17    protected float execute(final SourcingCriteriaUtils.CriterionContext ctx) {
18        // Return:
19        //  -1f to exclude a location,
20        //   0..1f (or any float) to score/rank a location.
21        return 0.75f;
22    }
23
24    // Override normalize(...) only if the default doesn’t fit your scale
25}

1@RuleInfo(
2        name = "SampleCreateFulfilmentWithSourcingProfile",
3        description = "Applies Sourcing Profile {" + "profileRef" + "} to a sourcing request (Order, Fulfilment Option, etc.) and produces Fulfilment(s)",
4        accepts = {@EventInfo(entityType = "ORDER"),
5                @EventInfo(entityType = "FULFILMENT_CHOICE")}
6)
7@ParamString(name = "profileRef", description = "Profile reference to apply.")
8@Slf4j
9public class SampleCreateFulfilmentWithSourcingProfile implements Rule {
10
11    static {
12        // register custom criteria
13        SourcingCriteriaTypeRegistry.register("fc.sourcing.criterion.customCriteria", CustomCriteria.class);
14        // register custom condition
15        SourcingConditionTypeRegistry.register("fc.sourcing.condition.customCondition", CustomCondition.class);
16    }
17
18    @Override
19    public void run(Context context) {
20        SourcingCriteriaTypeRegistry.getTypeNameToClassMap().forEach((key, value) -> log.info("registered: {}", key));
21        SourcingProfile sourcingProfile = loadSourcingProfile(context);
22        if (sourcingProfile.getSourcingStrategies() != null) {
23            SourcingContext sourcingContext = loadSourcingContext(context, SourcingUtils::getUnfulfilledItems);
24            SourcingUtils.SourcingPlan plan = findPlanBasedOnStrategies(context, sourcingContext, sourcingProfile,
25                    ImmutableList.of("ACTIVE", "AT_RISK"), null);
26            if (plan.getFulfilments() != null) {
27                fillFulfilmentType(sourcingContext, plan.getFulfilments());
28                createFulfilments(context, sourcingContext, plan.getFulfilments());
29            }
30        }
31    }
32}