mail
Mail收发邮件。
diff --git a/web/admin/demo/dyn/openai.php b/web/admin/demo/dyn/openai.php
index a34f26c..81c35ff 100644
--- a/web/admin/demo/dyn/openai.php
+++ b/web/admin/demo/dyn/openai.php
@@ -11,6 +11,8 @@ class openai {
$csql = new \ciy\sql('zc_ai_key');
$csql->where('id', 1);
$aikeyrow = $db->getone($csql);
+ if(!is_array($aikeyrow))
+ return $senddata('AI密钥不存在');
$openai = new \ciy\openai($aikeyrow);
$openai->debug();
$retai = $openai->chat($messages, function($data) {
diff --git a/web/admin/demo/dyn/sse.go b/web/admin/demo/dyn/sse.go
new file mode 100644
index 0000000..5d7e656
--- /dev/null
+++ b/web/admin/demo/dyn/sse.go
@@ -0,0 +1,72 @@
+package dyn
+
+import (
+ "ciyon/web/admin"
+ c "ciyon/zciyon"
+ "net/http"
+ "time"
+)
+
+func SSE_get(w http.ResponseWriter, r *http.Request) bool {
+ if !c.SSEInit(w) {
+ w.Write([]byte("不支持SSE Flush"))
+ return false
+ }
+ post := c.NewCiyPost(w, r)
+ rsuser, err := admin.Verifyuser(r, c.CiyDB, post)
+ if err != nil {
+ c.SSESend_event(w, "请重新登录")
+ return false
+ }
+ if admin.Nopower(c.CiyDB, c.Toint(rsuser["id"]), "p610r") {
+ c.SSESend_event(w, "您未被授权操作")
+ return false
+ }
+ param := post.Get("bb")
+ c.SSESend_data(w, param)
+ for i := 0; i < 100; i++ {
+ if i%10 == 1 {
+ c.SSESend_data(w, "sse: "+c.Tostr(i), i)
+ }
+ if !c.SSESend_event(w, c.Tostr(i)) {
+ return true
+ }
+ c.Sleep(0.05)
+ }
+ c.SSESend_event(w, "ok")
+ return true
+}
+
+func SSE_get_ch(w http.ResponseWriter, r *http.Request) bool {
+ if !c.SSEInit(w) {
+ w.Write([]byte("不支持SSE Flush"))
+ return false
+ }
+ post := c.NewCiyPost(w, r)
+ rsuser, err := admin.Verifyuser(r, c.CiyDB, post)
+ if err != nil {
+ c.SSESend_event(w, "请重新登录")
+ return false
+ }
+ if admin.Nopower(c.CiyDB, c.Toint(rsuser["id"]), "p610r") {
+ c.SSESend_event(w, "您未被授权操作")
+ return false
+ }
+ param := post.Get("param")
+ c.SSESend_data(w, param)
+
+ done := r.Context().Done()
+ ticker := time.NewTicker(time.Second)
+ defer ticker.Stop()
+
+ for {
+ select {
+ case <-done:
+ return false
+ case <-ticker.C:
+ if !c.SSESend_data(w, time.Now().Format(time.RFC3339)) {
+ return true
+ }
+ }
+ }
+}
diff --git a/web/admin/index.html b/web/admin/index.html
index 0eefd26..8fb8467 100644
--- a/web/admin/index.html
+++ b/web/admin/index.html
@@ -9,6 +9,15 @@
+