添加操作日志

dal/order/OrderActionLog/OrderActionLog.go

@@ -82,17 +82,17 @@ func Insert(order_id int, operator_id int, operator_type int, event string) (err
         panic(err)
     }
 
-    // id, err := result.LastInsertId()
-    // if err != nil {
-    //     panic(err)
-    // }
+    id, err := result.LastInsertId()
+    if err != nil {
+        panic(err)
+    }
 
-    // affected, err := result.RowsAffected()
-    // if err != nil {
-    //     panic(err)
-    // }
+    affected, err := result.RowsAffected()
+    if err != nil {
+        panic(err)
+    }
 
-    // fmt.Printf("last insert id:%d affect rows:%d\n", id, affected)
+    fmt.Printf("last insert id:%d affect rows:%d\n", id, affected)
 
     return err
 }
\ No newline at end of file

order/sendPurchaseEmail/main.go

@@ -9,7 +9,6 @@ import (
 	"github.com/ichunt2019/logger"
 	"sync"
 	"time"
-	"go-queue-server/dal/order/OrderActionLog"
 )
 
 

order/sendPurchaseEmail/sendEmail/sendEmail.go

@@ -7,6 +7,7 @@ import (
 	"encoding/json"
 	"strings"
 	"io/ioutil"
+	"go-queue-server/dal/order/OrderActionLog"
 )
 
 type JosnResp struct {
@@ -46,9 +47,11 @@ func SendPurchaseEmail(data string) (err error) {
 	json.Unmarshal([]byte(data), &data_map)
 
     order_id := data_map["order_id"];
+    operator_id := data_map["operator_id"];
+    operator_event := data_map["operator_event"];
 
     // 添加操作日志
-    
+    OrderActionLog.Insert(order_id, operator_id, 2, operator_event)
 
     // 推送ERP
 

util/ding/ding.go

+package ding
+
+import (
+	"net/http"
+	"encoding/json"
+)
+
+func send() {
+	
+}
\ No newline at end of file