debug.lsp update
This commit is contained in:
122
debug.lsp
122
debug.lsp
@@ -1,118 +1,18 @@
|
||||
(include "/usr/local/var/mlisp/terminal.lsp")
|
||||
|
||||
(def #sql_srv_address "stocksriddle.one")
|
||||
(def #sql_srv_port 5388)
|
||||
|
||||
|
||||
(defn cron::sleep-to-next-minute ()
|
||||
(* 1000 (- 60 (int (date-to-str (get-universal-time) "%S")))))
|
||||
|
||||
|
||||
(defn cron::eval-time-spec (val time_spec)
|
||||
(cond
|
||||
((nil? time_spec)
|
||||
#t) ; no time_spec -> it's true
|
||||
((= time_spec "*")
|
||||
#t)
|
||||
((string-regex? time_spec "^[0-9]{1,4}$")
|
||||
(= val (int time_spec)))
|
||||
((string-regex? time_spec "^[0-9]{1,2}-[0-9]{1,2}$")
|
||||
(def interval (string-split time_spec "-"))
|
||||
(and (>= val (int (first interval))) (<= val (int (second interval)))))
|
||||
(#t
|
||||
nil) ; TODO exception
|
||||
)
|
||||
)
|
||||
|
||||
|
||||
(defn cron::add-job (name time_spec job)
|
||||
; TODO if already there replace it
|
||||
(set! cron::entries (push cron::entries (list name time_spec job)))
|
||||
)
|
||||
|
||||
|
||||
(defn cron::time-to-run (now time_spec)
|
||||
(defn exec-sql (sql)
|
||||
(do
|
||||
; second, minute, hour, day, month, year, day-of-the-week
|
||||
(def time (decode-universal-time (get-universal-time)))
|
||||
|
||||
(def time_minute (second time))
|
||||
(def time_hour (third time))
|
||||
(def time_day (fourth time))
|
||||
(def time_month (fifth time))
|
||||
(def time_year (sixth time))
|
||||
(def time_weekday (seventh time))
|
||||
|
||||
(def bool (cron::eval-time-spec time_minute (find-val-in-list time_spec "minute")))
|
||||
(set! bool (and bool (cron::eval-time-spec time_hour (find-val-in-list time_spec "hour"))))
|
||||
(set! bool (and bool (cron::eval-time-spec time_weekday (find-val-in-list time_spec "weekday"))))
|
||||
(set! bool (and bool (cron::eval-time-spec time_day (find-val-in-list time_spec "day"))))
|
||||
(set! bool (and bool (cron::eval-time-spec time_month (find-val-in-list time_spec "month"))))
|
||||
(set! bool (and bool (cron::eval-time-spec time_year (find-val-in-list time_spec "year"))))
|
||||
; (print "time-to-run test" bool)
|
||||
bool
|
||||
(def r (tcp-client #sql_srv_address #sql_srv_port sql))
|
||||
(print r)
|
||||
(first (eval (parse r)))
|
||||
))
|
||||
|
||||
(defn cron::run-job (name code)
|
||||
(do
|
||||
;(print "running job:" name "->" code)
|
||||
(def run_code (+ "(thread-create " (display code) ")"))
|
||||
(eval (parse run_code))
|
||||
)
|
||||
)
|
||||
(def sql "select distinct to_string(datetime, '%d.%m.%Y'),symbol,time,title from history_earnings_dates where datetime>=to_date('2022-03-02', '%Y-%m-%d') and datetime<=to_date('2022-03-19', '%Y-%m-%d')")
|
||||
(print "*" sql "*")
|
||||
(def row (exec-sql sql))
|
||||
(print row)
|
||||
|
||||
(defn cron::start ()
|
||||
(do
|
||||
(def wait_time (cron::sleep-to-next-minute))
|
||||
(print "cron daemon started, waiting" wait_time "miliseconds for first run")
|
||||
; (thread-sleep wait_time)
|
||||
(while (not cron::stop)
|
||||
(def now (get-universal-time))
|
||||
(for e cron::entries
|
||||
(def job_name (first e))
|
||||
(def time_spec (second e))
|
||||
(def job_code (third e))
|
||||
|
||||
; (print "\n\n")
|
||||
(def is_for_run (cron::time-to-run now time_spec))
|
||||
; (print "DEBUG" job_name "checked" is_for_run)
|
||||
(if is_for_run
|
||||
(cron::run-job job_name job_code)
|
||||
; (print "not running" job_name)
|
||||
)
|
||||
)
|
||||
|
||||
(thread-sleep (cron::sleep-to-next-minute))
|
||||
)
|
||||
(threads-join)
|
||||
))
|
||||
|
||||
|
||||
(defn cron::stop ()
|
||||
(set! cron::stop #t))
|
||||
|
||||
|
||||
(def cron::entries '()) ; must be here
|
||||
(def cron::stop nil) ; must be here
|
||||
|
||||
|
||||
|
||||
|
||||
(cron::add-job "every_min_print"
|
||||
'(("minute" "*"))
|
||||
'(print "executing: every_min_print"))
|
||||
; '(do (sleep 3) (print "executing: every_min_print")))
|
||||
|
||||
(cron::add-job "every_min_between_00_and_05"
|
||||
'(("minute" "00-05"))
|
||||
'(print "executing: every_min_between_00_and_05"))
|
||||
|
||||
(cron::add-job "13:20_working_day"
|
||||
'(("weekday" "1-5")("hour" "13")("minute" "20"))
|
||||
'(print "executing: 13:20_working_day"))
|
||||
|
||||
(cron::add-job "15:20_working_day"
|
||||
'(("weekday" "1-5")("hour" "15")("minute" "20"))
|
||||
'(print "executing: 15:20_working_day"))
|
||||
|
||||
|
||||
(cron::start)
|
||||
(exit 1)
|
||||
|
||||
|
||||
Reference in New Issue
Block a user