Class EventRepository

  • All Implemented Interfaces:
    de.fraunhofer.iese.mydata.policy.event.history.IEventRepository

    @Component("mydataEventRepository")
    public class EventRepository
    extends de.fraunhofer.iese.mydata.pdp.interfaces.AbstractEventRepository
    • Constructor Detail

      • EventRepository

        public EventRepository()
    • Method Detail

      • findByActionIdAndHistoricEventParametersAndOccurredAtMsBetween

        public List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEvent> findByActionIdAndHistoricEventParametersAndOccurredAtMsBetween​(de.fraunhofer.iese.mydata.policy.event.ActionId actionId,
                                                                                                                                                 List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEventParameter> p,
                                                                                                                                                 long start,
                                                                                                                                                 long end)
      • findByActionIdAndOccurredAtMsBetweenParamIndependant

        public List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEvent> findByActionIdAndOccurredAtMsBetweenParamIndependant​(de.fraunhofer.iese.mydata.policy.event.ActionId actionId,
                                                                                                                                       long start,
                                                                                                                                       long end)
      • saveEventOccurrence

        @Async
        public void saveEventOccurrence​(de.fraunhofer.iese.mydata.policy.event.Event event,
                                        Set<de.fraunhofer.iese.mydata.policy.event.history.HistoricEventTrackItem> trackItems)
      • findByOccurredAtMsBetweenAndActionId

        public List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEvent> findByOccurredAtMsBetweenAndActionId​(long start,
                                                                                                                       long end,
                                                                                                                       de.fraunhofer.iese.mydata.policy.event.ActionId actionId)
      • findByOccurredAtMsBeforeAndActionId

        public long findByOccurredAtMsBeforeAndActionId​(long end,
                                                        de.fraunhofer.iese.mydata.policy.event.ActionId actionId)
      • findByOccurredAtMsAfterAndActionId

        public long findByOccurredAtMsAfterAndActionId​(long start,
                                                       de.fraunhofer.iese.mydata.policy.event.ActionId actionId)
      • findByActionId

        public List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEvent> findByActionId​(de.fraunhofer.iese.mydata.policy.event.ActionId actionId)
      • findByActionIdAndMode

        public de.fraunhofer.iese.mydata.policy.event.history.HistoricEvent findByActionIdAndMode​(de.fraunhofer.iese.mydata.policy.event.ActionId actionId,
                                                                                                  String mode,
                                                                                                  List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEventParameter> parameters)
      • filterHistoricEventByModeAndParameters

        public de.fraunhofer.iese.mydata.policy.event.history.HistoricEvent filterHistoricEventByModeAndParameters​(String mode,
                                                                                                                   List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEvent> notFiltred,
                                                                                                                   List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEventParameter> parameters)
        Parameters:
        mode - : get the first or the last occurrence of the historic events
        notFiltred - : the list of historic events for a specific actionid
        parameters - : if no parameters are provided in the policy, it means the user is only interested when the historic events occurred, independently of the parameters it had
        Returns:
        HistoricEvent
      • findAll

        public List<de.fraunhofer.iese.mydata.policy.event.history.HistoricEvent> findAll()
      • deleteEventOccurrenceByActionId

        public void deleteEventOccurrenceByActionId​(de.fraunhofer.iese.mydata.policy.event.ActionId actionId)
      • getNumberOfEntries

        public int getNumberOfEntries()
      • updateValueChangeBlockPolicyId

        public void updateValueChangeBlockPolicyId​(de.fraunhofer.iese.mydata.policy.Policy newPolicy,
                                                   de.fraunhofer.iese.mydata.policy.PolicyId oldPolicyId)
      • saveValueChangeBlock

        public void saveValueChangeBlock​(de.fraunhofer.iese.mydata.policy.Policy policy,
                                         Map<String,​String> variableValueChangeBlock)
      • deleteValueChangeBlock

        public void deleteValueChangeBlock​(de.fraunhofer.iese.mydata.policy.PolicyId policyId,
                                           Map<String,​String> variableValueChangeBlock)
      • getValueChanged

        public String getValueChanged​(String id,
                                      de.fraunhofer.iese.mydata.policy.Policy policy)
      • setValueChanged

        public void setValueChanged​(de.fraunhofer.iese.mydata.policy.Policy policy,
                                    String id,
                                    String valueInPolicy)
                             throws de.fraunhofer.iese.mydata.policy.exception.ValueNotFoundException
        Throws:
        de.fraunhofer.iese.mydata.policy.exception.ValueNotFoundException
      • deleteValueChangedByPolicyId

        public void deleteValueChangedByPolicyId​(String pid)