prodcom-data/scripts/map_prodcom.dlog

:DirectObservation[?ID] ,
[?ID, :objectDirectlyDefinedBy, ?PRCCode] ,
# TODO Generalise the region (not just the UK)
[?ID, :hasRegion, gnd:2635167] ,
[?ID, :hasTimePeriod, ?TimePeriod] ,
[?ID, :hasRole, :SoldProduction] ,
[?ID, :partOfDataset, ?Dataset] ,
[?ID, :bound, :ExactBound] ,
[?ID, :metric, quantitykind:Mass] ,
ufu:NG(?ID, ufu:unit, ?UnitID)
        :- ufrd:PRODCOM_DATA(?IDstring, ?PRCCODEstring, ?PRODQNT, ?QNTUNIT),

        [:CurrentImport, :hasTimePeriod, ?TimePeriod],
        [:CurrentImport, :partOfDataset, ?Dataset],
        [:CurrentImport, :useDataPrefix, ?DataPrefix],  # STR(ufpcd2016:)
        [:CurrentImport, :useObjectPrefix, ?ObjectPrefix],  # STR(ufpc2016:)

        # TODO Fix the prefix with the year
        BIND(IRI(CONCAT(STR(?DataPrefix), "Observation-", SHA256(?IDstring))) AS ?ID) ,
        BIND(IRI(CONCAT(STR(?ObjectPrefix), "Object-", SHA256(?PRCCODEstring))) AS ?PRCCode) ,
        BIND(IRI(CONCAT(STR(:), "Unit-", SHA256(?QNTUNIT))) AS ?UnitID) .

# if ?PRODQNT is not "absent"
ufu:NG(?ID, ufu:measurementUnit, ?PRODQNT)
        :- ufrd:PRODCOM_DATA(?IDstring, ?PRCCODEstring, ?PRODQNT, ?QNTUNIT), FILTER(BOUND(?PRODQNT)),
        [:CurrentImport, :useDataPrefix, ?DataPrefix],  # STR(ufpcd2016:)
        BIND(IRI(CONCAT(STR(?DataPrefix), "Observation-", SHA256(?IDstring))) AS ?ID) .