API tools faq
paste
Advertisement
vmoench

wf_timers

vmoench
Mar 14th, 2011
2,881
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
PowerBuilder 15.87 KB | None | 0 0
raw download clone embed print report
  1. /*
  2.  * Funktion wf_timer()
  3.  * Return: Long
  4.  * Arguments: (None)
  5.  */
  6.  
  7. // Wird folgendermaßen aus dem timer() Event aufgerufen:
  8.  
  9. // DK: Test ob Cron-Tabelle Einträge enthält
  10. //SELECT FIRST("it_cron"."bez")
  11. //INTO :ls_taskplaner
  12. //FROM "it_cron"
  13. //USING sqlca;
  14.  
  15. // DK: Wenn nicht wird der neue Taskplaner genutzt
  16. //IF sqlca.sqlcode = 100 THEN
  17.     //wf_timer()
  18.     //RETURN 0
  19. //END IF
  20.  
  21.  
  22. /***
  23.  * Prozesse Zeit gesteuert ausführen
  24.  */
  25.  
  26. i_counter++
  27. st_timer.text = "Timer-Event um: " +  String(now()) + " Uhr"
  28.  
  29. // DK: Falls ein Prozess bereits aktiv ist herausspringen
  30. IF processactive THEN
  31.     st_timer.text = "Prozess aktiv um " +  String(now()) + " Uhr"
  32.     RETURN 0
  33. END IF
  34.  
  35. DECLARE c_task CURSOR FOR  
  36.   SELECT
  37.             /* Tasks */
  38.             COALESCE("it_taskplaner_task"."lfdnr", 0),
  39.          COALESCE("it_taskplaner_task"."text", ''),
  40.          COALESCE("it_taskplaner_task"."status", 20),
  41.             COALESCE("it_taskplaner_task"."kommando_lfdnr", 0),
  42.            
  43.             /* Zeiten */
  44.             COALESCE("it_taskplaner_zeit"."lfdnr", 0),
  45.             COALESCE("it_taskplaner_zeit"."typ", 10),
  46.             COALESCE("it_taskplaner_zeit"."status", 20),
  47.             COALESCE("it_taskplaner_zeit"."startdatum", TODAY()),
  48.             COALESCE("it_taskplaner_zeit"."startzeit", NOW()),
  49.             COALESCE("it_taskplaner_zeit"."stopzeit", NOW()),
  50.             COALESCE("it_taskplaner_zeit"."intervall", 0),
  51.             COALESCE("it_taskplaner_zeit"."einheit_lfdnr", 0),
  52.             COALESCE("it_taskplaner_zeit"."argument", ''),
  53.             COALESCE("it_taskplaner_zeit"."sprache", 0)
  54.            
  55.     FROM "it_taskplaner_task",
  56.             "it_taskplaner_zeit"
  57.            
  58.     WHERE "it_taskplaner_task"."status" = 10 /* 10 = aktiv, 20 = inaktiv */
  59.     AND "it_taskplaner_task"."lfdnr" = "it_taskplaner_zeit"."task_lfdnr"
  60.     ORDER BY "it_taskplaner_zeit"."startdatum", "it_taskplaner_zeit"."startzeit"
  61.     USING sqlcur;
  62.  
  63. OPEN c_task ;
  64.      
  65. IF sqlcur.sqlcode <> 0 then
  66.         Error.of_Intern('w_it_batch','Fehler beim Aktualisieren der Tabelle it_taskplaner_task. (Cursor) ' + String(sqlcur.sqlcode))
  67. END IF
  68.  
  69. mle_status.text = "Prozesscheck " + String( i_counter ) + "~r~n"
  70.  
  71. /***
  72.  * DK: In allen Einträgen in dieser Minute prüfen
  73.  *     ob für aktuelle Zeit ein Auftrag vorliegt
  74.  */
  75.  
  76. STRING ls_task_text, ls_zeit_argument
  77. LONG ll_task_lfdnr, ll_task_status, ll_task_kommando_lfdnr, ll_zeit_lfdnr, ll_zeit_typ, ll_zeit_sprache, ll_zeit_status, ll_einheit_lfdnr
  78. DATE ld_zeit_startdatum
  79. TIME lt_zeit_startzeit, lt_zeit_stopzeit
  80. DOUBLE ld_zeit_intervall
  81.  
  82. LONG weiter
  83. weiter = 1
  84.  
  85. // DK: Fetch der Ergebnisse
  86. DO WHILE weiter > 0
  87.     FETCH NEXT c_task INTO :ll_task_lfdnr, :ls_task_text, :ll_task_status, :ll_task_kommando_lfdnr, :ll_zeit_lfdnr,
  88.                                   :ll_zeit_typ, :ll_zeit_status, :ld_zeit_startdatum, :lt_zeit_startzeit, :lt_zeit_stopzeit,
  89.                                   :ld_zeit_intervall, :ll_einheit_lfdnr, :ls_zeit_argument, :ll_zeit_sprache;
  90.    
  91.     // DK: Fetch in Ordnung
  92.     CHOOSE CASE sqlcur.sqlcode
  93.         CASE 0
  94.             LONG ll_kommando_lfdnr
  95.             STRING ls_kommando_text, ls_kommando_kommando
  96.            
  97.             SELECT "it_taskplaner_kommando"."lfdnr",
  98.                      "it_taskplaner_kommando"."text",
  99.                      "it_taskplaner_kommando"."kommando"
  100.                      
  101.             INTO     :ll_kommando_lfdnr,
  102.                      :ls_kommando_text,
  103.                      :ls_kommando_kommando
  104.                      
  105.             FROM     "it_taskplaner_kommando"
  106.             WHERE    "it_taskplaner_kommando"."lfdnr" = :ll_task_kommando_lfdnr
  107.             USING  sqlca;
  108.            
  109.             IF sqlca.sqlcode < 0 THEN
  110.                 msg.MsgBox("Fehler", "Keine gültige Verknüpfung mit der Tabelle it_taskplaner_kommando vorhanden!")
  111.                 HALT
  112.             END IF
  113.            
  114.             STRING ls_task_einheit_text
  115.             LONG ll_task_einheit_lfdnr, ll_task_einheit_faktor
  116.            
  117.             SELECT "it_taskplaner_zeit_einheit"."lfdnr",
  118.                      "it_taskplaner_zeit_einheit"."text",
  119.                      "it_taskplaner_zeit_einheit"."faktor"
  120.                      
  121.             INTO     :ll_task_einheit_lfdnr,
  122.                      :ls_task_einheit_text,
  123.                      :ll_task_einheit_faktor
  124.                      
  125.             FROM     "it_taskplaner_zeit_einheit"
  126.             WHERE    "it_taskplaner_zeit_einheit"."lfdnr" = :ll_einheit_lfdnr
  127.             USING    sqlca;
  128.            
  129.             IF sqlca.sqlcode < 0 THEN
  130.                 msg.MsgBox("Fehler", "Keine gültige Verknüpfung mit der Tabelle it_taskplaner_zeit_einheit vorhanden!")
  131.                 HALT
  132.             END IF
  133.            
  134.             // DK: Startdatum erreicht / überschritten
  135.             IF ld_zeit_startdatum >= TODAY() THEN
  136.                 CHOOSE CASE ll_zeit_typ
  137.                     // DK: Intervall
  138.                     CASE 10
  139.                         TIME lt_cur_time
  140.                         STRING ls_cur_time, ls_zeit_startzeit, ls_zeit_stopzeit, ls_kalk_zeit
  141.                         LONG ll_multiplikant
  142.                         BOOLEAN lb_intervall, lb_fertig
  143.                        
  144.                         // DK: Aktuelle Zeit
  145.                         lt_cur_time = TIME(STRING(NOW(), "hh:mm"))
  146.                        
  147.                         // DK: Zeiten aus der Tabelle als String
  148.                         ls_cur_time = STRING(NOW(), "hh:mm")
  149.                         ls_zeit_startzeit = STRING(lt_zeit_startzeit, "hh:mm")
  150.                         ls_zeit_stopzeit = STRING(lt_zeit_stopzeit, "hh:mm")
  151.                        
  152.                         // DK: Weitere Hilfsvariablen initialisieren
  153.                         ll_multiplikant = 1
  154.                         lb_intervall = FALSE
  155.                         lb_fertig = FALSE
  156.                        
  157.                         // DK: Kalkulierte Zeit auf Startzeit setzen
  158.                         ls_kalk_zeit = STRING(lt_zeit_startzeit, "hh:mm")
  159.                        
  160.                         // DK: Momentane Zeit kleiner / gleich Stopzeit
  161.                         IF lt_cur_time <= lt_zeit_stopzeit THEN
  162.                            
  163.                             // DK: Solange die kalkulierte Zeit kleiner / gleich der Stoppzeit ist und die Bedingung noch nicht durchlaufen wurde
  164.                             DO WHILE ls_kalk_zeit <= ls_zeit_stopzeit AND lb_fertig = FALSE
  165.                                
  166.                                 // DK: Prüfe ob die aktuelle Zeit der kalkulierten Zeit entspricht
  167.                                 IF ls_cur_time = ls_kalk_zeit THEN
  168.                                     lb_intervall = TRUE
  169.                                    
  170.                                     //-----------------------------------------------------------------------------        
  171.                                     // Transfer
  172.                                     IF POS(ls_kommando_kommando,"transfer") > 0         THEN cbx_transfer.checked = TRUE
  173.                                    
  174.                                     //-----------------------------------------------------------------------------
  175.                                     // Sprache
  176.                                     IF ll_zeit_sprache = 0 THEN rb_sprache1.checked = TRUE
  177.                                     IF ll_zeit_sprache = 1 THEN rb_sprache2.checked = TRUE
  178.                                     IF ll_zeit_sprache = 2 THEN rb_sprache3.checked = TRUE
  179.                                     IF ll_zeit_sprache = 3 THEN rb_sprache4.checked = TRUE
  180.                                     IF ll_zeit_sprache = 4 THEN rb_sprache5.checked = TRUE
  181.                                     IF ll_zeit_sprache = 5 THEN rb_sprache6.checked = TRUE
  182.                        
  183.                                     //-----------------------------------------------------------------------------
  184.                                     // Export
  185.                                     IF POS(ls_kommando_kommando,"exArtikelstamm") > 0   THEN cbx_artikelstamm_ex.checked = TRUE
  186.                                     IF POS(ls_kommando_kommando,"exGrundlagen") > 0         THEN cbx_grundlagen_ex.checked  = TRUE
  187.                                     IF POS(ls_kommando_kommando,"exKundenstamm") > 0    THEN cbx_kundenstamm_ex.checked     = TRUE
  188.                                     IF POS(ls_kommando_kommando,"exKonditionen") > 0    THEN cbx_konditionen_ex.checked     = TRUE
  189.                                     IF POS(ls_kommando_kommando,"exOffenePosten") > 0   THEN cbx_op_ex.checked              = TRUE
  190.                                     IF POS(ls_kommando_kommando,"exDispo") > 0          THEN cbx_dispo_ex.checked           = TRUE
  191.                                     IF POS(ls_kommando_kommando,"exAdressen") > 0       THEN cbx_adressen_ex.checked        = TRUE
  192.                                     IF POS(ls_kommando_kommando,"exBestand") > 0            THEN cbx_bestand_ex.checked         = TRUE
  193.                        
  194.                                     //-----------------------------------------------------------------------------
  195.                                     // Upload
  196.                                     IF POS(ls_kommando_kommando,"ulArtikelstamm") > 0   THEN cbx_artikelstamm_ex.checked = TRUE AND cbx_transfer.checked = TRUE
  197.                                     IF POS(ls_kommando_kommando,"ulBestand") > 0            THEN cbx_bestand_ex.checked         = TRUE AND cbx_transfer.checked = TRUE
  198.                                     IF POS(ls_kommando_kommando,"ulGrundlagen") > 0         THEN cbx_konditionen_ex.checked     = TRUE AND cbx_transfer.checked = TRUE
  199.                                     IF POS(ls_kommando_kommando,"ulKundenstamm") > 0    THEN cbx_kundenstamm_ex.checked     = TRUE AND cbx_transfer.checked = TRUE
  200.                                     IF POS(ls_kommando_kommando,"ulKonditionen") > 0    THEN cbx_konditionen_ex.checked     = TRUE AND cbx_transfer.checked = TRUE
  201.                                     IF POS(ls_kommando_kommando,"ulOffenePosten") > 0   THEN cbx_op_ex.checked              = TRUE AND cbx_transfer.checked = TRUE
  202.                                     IF POS(ls_kommando_kommando,"ulDispo") > 0          THEN cbx_dispo_ex.checked           = TRUE AND cbx_transfer.checked = TRUE
  203.                                     IF POS(ls_kommando_kommando,"ulAdressen") > 0       THEN cbx_adressen_ex.checked        = TRUE AND cbx_transfer.checked = TRUE
  204.                        
  205.                                     //-----------------------------------------------------------------------------
  206.                                     // Download
  207.                                     IF POS(ls_kommando_kommando,"dlKundenstamm") > 0    THEN cbx_kundenstamm_im.checked     = TRUE AND cbx_transfer.checked = TRUE
  208.                                     IF POS(ls_kommando_kommando,"dlAuftraege") > 0      THEN cbx_auftraege_im.checked   = TRUE AND cbx_transfer.checked = TRUE
  209.                                     IF POS(ls_kommando_kommando,"dlStatistik") > 0      THEN cbx_statistik_im.checked   = TRUE AND cbx_transfer.checked = TRUE
  210.                                     IF POS(ls_kommando_kommando,"dlNewsletter") > 0         THEN cbx_newsletter_dl.checked  = TRUE AND cbx_transfer.checked = TRUE  
  211.                                    
  212.                                     //-----------------------------------------------------------------------------
  213.                                     // Import
  214.                                     IF POS(ls_kommando_kommando,"imAuftraege") > 0      THEN cbx_auftraege_im.checked   = TRUE
  215.                                     IF POS(ls_kommando_kommando,"imStatistik") > 0      THEN cbx_statistik_im.checked   = TRUE
  216.                                     IF POS(ls_kommando_kommando,"imKundenstamm") > 0        THEN
  217.                                         cbx_kundenstamm_im.checked  = TRUE
  218.                                         //msg.MsgBox("Info", "Kundenstamm markiert bei Intervall " + STRING(ld_zeit_intervall))
  219.                                     END IF
  220.                                     IF POS(ls_kommando_kommando,"executesql") > 0           THEN cbx_sql.checked                = TRUE
  221.                                     IF POS(ls_kommando_kommando,"imNewsletter") > 0     THEN cbx_newsletter_dl.checked  = TRUE
  222.                                    
  223.                                     //-----------------------------------------------------------------------------
  224.                                     // Export Kundenindividuelle Daten
  225.                                     IF POS(ls_kommando_kommando,"exIndArtikelstamm") > 0 THEN ddlb_genartikel_pers.text  = ls_zeit_argument
  226.                                     IF POS(ls_kommando_kommando,"exIndBestand") > 0      THEN ddlb_syncbestand_pers.text = ls_zeit_argument
  227.                                                    
  228.                                     //-----------------------------------------------------------------------------        
  229.                                     // Media
  230.                                     IF POS(ls_kommando_kommando,"syncmedia") > 0            THEN cbx_media.checked = TRUE
  231.                                    
  232.                                     //-----------------------------------------------------------------------------        
  233.                                     // System
  234.                                     IF POS(ls_kommando_kommando,"shutdown") > 0         THEN
  235.                                         POST close(this)
  236.                                         POST close(w_haupt)
  237.                                     END IF
  238.                                    
  239.                                     lb_fertig = TRUE
  240.                                 END IF
  241.                                 IF NOT lb_intervall THEN ll_multiplikant++
  242.                                 ls_kalk_zeit = STRING(RelativeTime(lt_zeit_startzeit, ll_multiplikant * ld_zeit_intervall * ll_task_einheit_faktor * 60))
  243.                                 ls_kalk_zeit = STRING(TIME(ls_kalk_zeit), "hh:mm")
  244.                             LOOP
  245.                         END IF
  246.                        
  247.                     // DK: Fixzeit
  248.                     CASE 20
  249.                         // DK: Prüfen ob Startzeit der aktuellen Zeit entspricht
  250.                         IF STRING(lt_zeit_startzeit, "hh:mm") = STRING(NOW(), "hh:mm") THEN
  251.                             //-----------------------------------------------------------------------------        
  252.                             // Transfer
  253.                             IF POS(ls_kommando_kommando,"transfer") > 0         THEN cbx_transfer.checked = TRUE
  254.                            
  255.                             //-----------------------------------------------------------------------------
  256.                             // Sprache
  257.                             IF ll_zeit_sprache = 0 THEN rb_sprache1.checked = TRUE
  258.                             IF ll_zeit_sprache = 1 THEN rb_sprache2.checked = TRUE
  259.                             IF ll_zeit_sprache = 2 THEN rb_sprache3.checked = TRUE
  260.                             IF ll_zeit_sprache = 3 THEN rb_sprache4.checked = TRUE
  261.                             IF ll_zeit_sprache = 4 THEN rb_sprache5.checked = TRUE
  262.                             IF ll_zeit_sprache = 5 THEN rb_sprache6.checked = TRUE
  263.                
  264.                             //-----------------------------------------------------------------------------
  265.                             // Export
  266.                             IF POS(ls_kommando_kommando,"exArtikelstamm") > 0   THEN cbx_artikelstamm_ex.checked = TRUE
  267.                             IF POS(ls_kommando_kommando,"exGrundlagen") > 0         THEN cbx_grundlagen_ex.checked  = TRUE
  268.                             IF POS(ls_kommando_kommando,"exKundenstamm") > 0    THEN cbx_kundenstamm_ex.checked     = TRUE
  269.                             IF POS(ls_kommando_kommando,"exKonditionen") > 0    THEN cbx_konditionen_ex.checked     = TRUE
  270.                             IF POS(ls_kommando_kommando,"exOffenePosten") > 0   THEN cbx_op_ex.checked              = TRUE
  271.                             IF POS(ls_kommando_kommando,"exDispo") > 0          THEN cbx_dispo_ex.checked           = TRUE
  272.                             IF POS(ls_kommando_kommando,"exAdressen") > 0       THEN cbx_adressen_ex.checked        = TRUE
  273.                             IF POS(ls_kommando_kommando,"exBestand") > 0            THEN cbx_bestand_ex.checked         = TRUE
  274.                
  275.                             //-----------------------------------------------------------------------------
  276.                             // Upload
  277.                             IF POS(ls_kommando_kommando,"ulArtikelstamm") > 0   THEN cbx_artikelstamm_ex.checked = TRUE AND cbx_transfer.checked = TRUE
  278.                             IF POS(ls_kommando_kommando,"ulBestand") > 0            THEN cbx_bestand_ex.checked         = TRUE AND cbx_transfer.checked = TRUE
  279.                             IF POS(ls_kommando_kommando,"ulGrundlagen") > 0         THEN cbx_konditionen_ex.checked     = TRUE AND cbx_transfer.checked = TRUE
  280.                             IF POS(ls_kommando_kommando,"ulKundenstamm") > 0    THEN cbx_kundenstamm_ex.checked     = TRUE AND cbx_transfer.checked = TRUE
  281.                             IF POS(ls_kommando_kommando,"ulKonditionen") > 0    THEN cbx_konditionen_ex.checked     = TRUE AND cbx_transfer.checked = TRUE
  282.                             IF POS(ls_kommando_kommando,"ulOffenePosten") > 0   THEN cbx_op_ex.checked              = TRUE AND cbx_transfer.checked = TRUE
  283.                             IF POS(ls_kommando_kommando,"ulDispo") > 0          THEN cbx_dispo_ex.checked           = TRUE AND cbx_transfer.checked = TRUE
  284.                             IF POS(ls_kommando_kommando,"ulAdressen") > 0       THEN cbx_adressen_ex.checked        = TRUE AND cbx_transfer.checked = TRUE
  285.                
  286.                             //-----------------------------------------------------------------------------
  287.                             // Download
  288.                             IF POS(ls_kommando_kommando,"dlKundenstamm") > 0    THEN cbx_kundenstamm_im.checked     = TRUE AND cbx_transfer.checked = TRUE
  289.                             IF POS(ls_kommando_kommando,"dlAuftraege") > 0      THEN cbx_auftraege_im.checked   = TRUE AND cbx_transfer.checked = TRUE
  290.                             IF POS(ls_kommando_kommando,"dlStatistik") > 0      THEN cbx_statistik_im.checked   = TRUE AND cbx_transfer.checked = TRUE
  291.                             IF POS(ls_kommando_kommando,"dlNewsletter") > 0         THEN cbx_newsletter_dl.checked  = TRUE AND cbx_transfer.checked = TRUE  
  292.                            
  293.                             //-----------------------------------------------------------------------------
  294.                             // Import
  295.                             IF POS(ls_kommando_kommando,"imAuftraege") > 0      THEN cbx_auftraege_im.checked   = TRUE
  296.                             IF POS(ls_kommando_kommando,"imStatistik") > 0      THEN cbx_statistik_im.checked   = TRUE
  297.                             IF POS(ls_kommando_kommando,"imKundenstamm") > 0        THEN cbx_kundenstamm_im.checked     = TRUE
  298.                             IF POS(ls_kommando_kommando,"executesql") > 0           THEN cbx_sql.checked                = TRUE
  299.                             IF POS(ls_kommando_kommando,"imNewsletter") > 0     THEN cbx_newsletter_dl.checked  = TRUE
  300.                            
  301.                             //-----------------------------------------------------------------------------
  302.                             // Export Kundenindividuelle Daten
  303.                             IF POS(ls_kommando_kommando,"exIndArtikelstamm") > 0 THEN ddlb_genartikel_pers.text  = ls_zeit_argument
  304.                             IF POS(ls_kommando_kommando,"exIndBestand") > 0      THEN ddlb_syncbestand_pers.text = ls_zeit_argument
  305.                                            
  306.                             //-----------------------------------------------------------------------------        
  307.                             // Media
  308.                             IF POS(ls_kommando_kommando,"syncmedia") > 0            THEN cbx_media.checked = TRUE
  309.                            
  310.                             //-----------------------------------------------------------------------------        
  311.                             // System
  312.                             IF POS(ls_kommando_kommando,"shutdown") > 0         THEN
  313.                                 POST close(this)
  314.                                 POST close(w_haupt)
  315.                             END IF
  316.                         END IF
  317.                        
  318.                 END CHOOSE
  319.             END IF
  320.            
  321.         // DK: Keinen weiteren Datensatz gefunden
  322.         CASE 100
  323.             weiter = 0
  324.            
  325.         // DK: Es ist ein Fehler im Cursor aufgetreten
  326.         CASE ELSE
  327.             msg.MsgBox("Fehler", "Es ist ein Fehler im Cursor c_task aufgetreten!")
  328.             RETURN 0
  329.            
  330.     END CHOOSE
  331. LOOP
  332.  
  333. CLOSE c_task;
  334.  
  335. //-----------------------------------------------------------------------------
  336. // Nun Prozesse ausführen
  337.  
  338. this.PostEvent ( "ue_startbat" )
  339.  
  340. RETURN 1
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!