Packages

bpe

2.4.0
13.5.22-aleph 11.4.16 11.4.15 11.4.14 11.4.13 9.9.7 9.9.6 8.12.4 8.12.3 8.12.1 8.12.0 retired 8.2.1 8.2.0 8.1.0 7.11.0 7.10.4 7.10.3 7.10.2 7.10.1 7.9.1 7.9.0 7.8.2 7.8.1 7.8.0 7.6.4 7.6.3 7.6.2 7.6.1 7.6.0 7.5.15 7.5.14 7.5.13 7.5.12 7.5.11 7.5.10 7.5.9 7.5.8 7.5.7 7.5.6 7.5.5 7.5.3 7.5.2 7.5.1 7.5.0 7.4.11 7.4.10 7.4.9 7.4.8 7.4.7 7.4.6 7.4.5 7.4.4 7.4.3 7.4.2 7.4.1 7.4.0 7.3.0 7.2.8 7.2.7 7.2.6 7.1.6 7.1.5 7.1.4 7.1.3 7.1.2 6.12.7 6.12.6 6.12.5 6.12.3 6.12.2 6.12.1 6.12.0 6.11.0 6.10.0 6.5.3 6.5.2 6.5.1 6.5.0 6.4.0 6.3.0 5.12.0 5.11.4 5.11.3 5.11.2 5.11.1 5.11.0 5.8.7 5.8.6 5.8.5 5.8.4 5.8.3 5.8.2 5.8.1 5.8.0 5.7.0 5.6.0 5.5.2 5.5.1 5.4.0 5.2.0 5.1.3 5.1.2 5.1.1 4.12.4 4.12.3 4.12.2 4.12.1 4.12.0 4.11.8 4.11.7 4.11.6 4.11.5 4.11.4 4.11.3 4.11.2 4.11.1 4.11.0 4.10.24 4.10.23 4.10.22 4.10.21 4.10.20 4.10.19 4.10.18 4.10.17 4.10.16 4.10.15 4.10.14 4.10.13 4.10.12 4.10.11 4.10.10 4.10.9 4.10.8 4.10.7 4.10.6 4.10.5 4.10.4 4.10.3 4.10.2 4.10.1 4.10.0 4.9.18 4.9.17 4.9.16 4.9.15 4.9.14 4.9.13 4.9.12 4.9.11 4.9.10 4.9.9 4.9.8 4.9.7 4.9.6 4.9.5 4.9.4 4.9.3 4.9.2 4.9.1 4.9.0 4.8.1 4.8.0 4.7.5 4.7.3 4.7.2 4.7.1 4.7.0 4.6.0 2.4.0 0.7.16

ERP/1: RTP GST WebRTC ICE SDP H.264 H.265 MP4 MPEG-2 HLS HEVC

HexDocs

Current section

Files

Jump to
Readme
171 Versions
0 Dependencies
Dependants
Files
Activity
bpe src bpe_app.erl
Raw

src/bpe_app.erl 

-module(bpe_app).

-behaviour(application).

-include("bpe.hrl").

-include_lib("kvs/include/feed.hrl").

-export([start/2, stop/1, worker/1]).



start(_StartType, _StartArgs) ->

    Res = bpe_sup:start_link(),

    kvs:join(),

    Table = process,

    spawn(fun() -> case kvs:get(feed,Table) of

          {ok,Feed} -> kvs:fold(fun(A,Acc) -> {M,F} = application:get_env(bpe,process_worker,{?MODULE,worker}),

                                               M:F(A) end,[],

                       Table, Feed#feed.top,undefined, #iterator.prev,#kvs{mod=store_mnesia});

                 __ -> skip end end),

    Res.



stop(_State) -> ok.



worker(#process{id=Id}=P) ->

    case bpe:history(Id) of

         [H|_] -> worker_do(calendar:time_difference(H#history.time,calendar:local_time()),P);

            __ -> skip end.



worker_do({Days,Time},P) when Days >= 14 -> skip;

worker_do({Days,Time},P) when P#process.task =:= 'Payment'     -> kvs:info(?MODULE,"BPE Start: ~p~n",[bpe:start(P,[])]);

worker_do({Days,Time},P) when P#process.task =:= 'Delay'       -> kvs:info(?MODULE,"BPE Start: ~p~n",[bpe:start(P,[])]);

worker_do({Days,Time},P) when P#process.task =:= 'FirstDelay'  -> kvs:info(?MODULE,"BPE Start: ~p~n",[bpe:start(P,[])]);

worker_do({Days,Time},P) when P#process.task =:= 'SecondDelay' -> kvs:info(?MODULE,"BPE Start: ~p~n",[bpe:start(P,[])]);

worker_do({Days,Time},P) -> skip.