|
|
@@ -137,14 +137,15 @@ func insertLogInfo(logInfo *logInfo){
|
|
|
logInfo.RespData = respBodyObj.Data
|
|
|
}
|
|
|
}
|
|
|
+ logInfo.CostTime = int(logInfo.RespTime.Sub(logInfo.ReqTime))
|
|
|
|
|
|
// 保存轨迹
|
|
|
fmt.Println("保存轨迹")
|
|
|
cqlformat := `insert into
|
|
|
log_info(req_date, req_time, req_method, req_url, req_proto, req_ua, req_referer, req_post_data, resp_time, resp_body, resp_code, resp_msg, resp_data, cost_time)
|
|
|
values(?,?,?,?,?,?,?,?,?,?,?,?,?,?);`
|
|
|
- reqDate := logInfo.ReqTime.Format("200601")
|
|
|
- q := session.Query(cqlformat, reqDate, logInfo.ReqTime, logInfo.ReqMethod, logInfo.ReqUrl, logInfo.ReqProto, logInfo.ReqUa, logInfo.ReqReferer, logInfo.ReqPostData, logInfo.RespTime, logInfo.RespBody, logInfo.RespCode, logInfo.RespMsg, logInfo.RespData, logInfo.CostTime)
|
|
|
+ reqDate := logInfo.ReqTime.Format("20060102")
|
|
|
+ q := session.Query(cqlformat, reqDate, logInfo.ReqTime.Format("2006-01-02 15:04:05"), logInfo.ReqMethod, logInfo.ReqUrl, logInfo.ReqProto, logInfo.ReqUa, logInfo.ReqReferer, logInfo.ReqPostData, logInfo.RespTime.Format("2006-01-02 15:04:05"), logInfo.RespBody, logInfo.RespCode, logInfo.RespMsg, logInfo.RespData, logInfo.CostTime)
|
|
|
err = q.Exec() // 应该可以使用批量插入
|
|
|
if err != nil{
|
|
|
fmt.Println("插入日志错误:", err)
|
huangrf