소스 검색

fixed bug.

zhou.xiaoning 1 년 전
부모
커밋
a1738b1a71
2개의 변경된 파일17개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      controllers/quote/history.go
  2. 15 0
      models/common.go

+ 2 - 2
controllers/quote/history.go

@@ -651,7 +651,7 @@ func QueryTSData(c *gin.Context) {
 
 		// 补数据第二步:按尾部的时间(当前服务器时间或最后休市时间)进行全补
 		// 获取服务器时间
-		s, _ := models.GetServerTime()
+		s, _ := models.GetServerTime2()
 		endTime, err := time.ParseInLocation("2006-01-02T15:04:05Z", *s, time.Local)
 		if err != nil {
 			logger.GetLogger().Errorf("QueryTSData failed: %s", err.Error())
@@ -738,7 +738,7 @@ func QueryTSData(c *gin.Context) {
 		// TODO: - 下面这块操作需求确认
 		// 如果查询结果是空数据,则使用昨结价补到服务器时间(或最后休市时间)
 		// 获取服务器时间
-		s, _ := models.GetServerTime()
+		s, _ := models.GetServerTime2()
 		endTime, err := time.ParseInLocation("2006-01-02T15:04:05Z", *s, time.Local)
 		if err != nil {
 			logger.GetLogger().Errorf("QueryTSData failed: %s", err.Error())

+ 15 - 0
models/common.go

@@ -752,6 +752,21 @@ func GetServerTime() (*string, error) {
 	return nil, nil
 }
 
+func GetServerTime2() (*string, error) {
+	engine := db.GetEngine()
+
+	rst, err := engine.QueryString("select sysdate from dual")
+	if err != nil {
+		return nil, err
+	}
+	if len(rst) > 0 {
+		r := rst[0]["SYSDATE"]
+		return &r, nil
+	}
+
+	return nil, nil
+}
+
 // QueryErrorInfosRsp 获取数据库错误信息模型
 type QueryErrorInfosRsp struct {
 	Errorid     int64  `json:"errorid"  xorm:"'ERRORID'" binding:"required"` // 异常ID