加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
q.go 33.23 KB
一键复制 编辑 原始数据 按行查看 历史
springrain 提交于 2024-11-11 12:14 . v1.8.17 来自 达梦8.1.4.6
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455
/*
* Copyright (c) 2000-2018, 达梦数据库有限公司.
* All rights reserved.
*/
package dm
import (
"database/sql/driver"
"math"
"strconv"
"strings"
"gitee.com/chunanyong/dm/util"
)
const (
LOADPREC_DEFAULT = 2
LOADPREC_MAX = 9
SECDPREC_DEFAULT = 6
SECDPREC_MAX = 6
QUA_D byte = 3
QUA_DH byte = 4
QUA_DHM byte = 5
QUA_DHMS byte = 6
QUA_H byte = 7
QUA_HM byte = 8
QUA_HMS byte = 9
QUA_M byte = 10
QUA_MS byte = 11
QUA_S byte = 12
)
type DmIntervalDT struct {
_type byte
leadScale int
secScale int
negative bool
days int
hours int
minutes int
seconds int
fraction int
scaleForSvr int
Valid bool
}
func (dt *DmIntervalDT) init() {
dt._type = QUA_D
dt.leadScale = 2
dt.secScale = 6
dt.negative = false
dt.days = 0
dt.hours = 0
dt.minutes = 0
dt.seconds = 0
dt.fraction = 0
dt.scaleForSvr = 0
dt.Valid = true
}
func newDmIntervalDTByBytes(bytes []byte) *DmIntervalDT {
dt := new(DmIntervalDT)
dt.init()
dt._type = bytes[21]
dt.scaleForSvr = int(Dm_build_931.Dm_build_1033(bytes, 20))
dt.leadScale = (dt.scaleForSvr >> 4) & 0x0000000F
dt.secScale = dt.scaleForSvr & 0x0000000F
switch dt._type {
case QUA_D:
dt.days = int(Dm_build_931.Dm_build_1033(bytes, 0))
case QUA_DH:
dt.days = int(Dm_build_931.Dm_build_1033(bytes, 0))
dt.hours = int(Dm_build_931.Dm_build_1033(bytes, 4))
case QUA_DHM:
dt.days = int(Dm_build_931.Dm_build_1033(bytes, 0))
dt.hours = int(Dm_build_931.Dm_build_1033(bytes, 4))
dt.minutes = int(Dm_build_931.Dm_build_1033(bytes, 8))
case QUA_DHMS:
dt.days = int(Dm_build_931.Dm_build_1033(bytes, 0))
dt.hours = int(Dm_build_931.Dm_build_1033(bytes, 4))
dt.minutes = int(Dm_build_931.Dm_build_1033(bytes, 8))
dt.seconds = int(Dm_build_931.Dm_build_1033(bytes, 12))
dt.fraction = int(Dm_build_931.Dm_build_1033(bytes, 16))
case QUA_H:
dt.hours = int(Dm_build_931.Dm_build_1033(bytes, 4))
case QUA_HM:
dt.hours = int(Dm_build_931.Dm_build_1033(bytes, 4))
dt.minutes = int(Dm_build_931.Dm_build_1033(bytes, 8))
case QUA_HMS:
dt.hours = int(Dm_build_931.Dm_build_1033(bytes, 4))
dt.minutes = int(Dm_build_931.Dm_build_1033(bytes, 8))
dt.seconds = int(Dm_build_931.Dm_build_1033(bytes, 12))
dt.fraction = int(Dm_build_931.Dm_build_1033(bytes, 16))
case QUA_M:
dt.minutes = int(Dm_build_931.Dm_build_1033(bytes, 8))
case QUA_MS:
dt.minutes = int(Dm_build_931.Dm_build_1033(bytes, 8))
dt.seconds = int(Dm_build_931.Dm_build_1033(bytes, 12))
dt.fraction = int(Dm_build_931.Dm_build_1033(bytes, 16))
case QUA_S:
dt.seconds = int(Dm_build_931.Dm_build_1033(bytes, 12))
dt.fraction = int(Dm_build_931.Dm_build_1033(bytes, 16))
}
if dt.days < 0 {
dt.days = -dt.days
dt.negative = true
}
if dt.hours < 0 {
dt.hours = -dt.hours
dt.negative = true
}
if dt.minutes < 0 {
dt.minutes = -dt.minutes
dt.negative = true
}
if dt.seconds < 0 {
dt.seconds = -dt.seconds
dt.negative = true
}
if dt.fraction < 0 {
dt.fraction = -dt.fraction
dt.negative = true
}
return dt
}
func NewDmIntervalDTByString(str string) (dt *DmIntervalDT, err error) {
defer func() {
if p := recover(); p != nil {
err = ECGO_INVALID_TIME_INTERVAL.throw()
}
}()
dt = new(DmIntervalDT)
dt.init()
if str == "" {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
leadStr := strings.TrimSpace(strings.ToUpper(str))
if !(strings.Index(leadStr, "INTERVAL ") == 0) {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
leadStr = strings.TrimSpace(leadStr[strings.Index(leadStr, " "):])
endIndex := 0
var valueStr string
if endIndex = strings.Index(leadStr[1:], "'"); leadStr[0] == '\'' && endIndex != -1 {
endIndex += 1
valueStr = strings.TrimSpace(leadStr[1:endIndex])
valueStr = dt.checkSign(valueStr)
leadStr = strings.TrimSpace(leadStr[endIndex+1:])
}
if valueStr == "" {
leadStr = dt.checkSign(leadStr)
if endIndex = strings.Index(leadStr[1:], "'"); leadStr[0] != '\'' || endIndex == -1 {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
endIndex += 1
valueStr = strings.TrimSpace(leadStr[1:endIndex])
leadStr = strings.TrimSpace(leadStr[endIndex+1:])
}
strLeadPrec := ""
strSecPrec := ""
leadPrecIndex := 0
secPrecIndex := 0
toIndex := 0
if leadPrecIndex = strings.Index(leadStr, "DAY"); leadPrecIndex != -1 {
toIndex = strings.Index(leadStr[leadPrecIndex:], "TO")
if toIndex == -1 {
strLeadPrec = strings.TrimSpace(leadStr[leadPrecIndex:])
if err := dt.setDay(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else {
toIndex += leadPrecIndex
strLeadPrec = strings.TrimSpace(leadStr[leadPrecIndex:toIndex])
if strings.Index(leadStr[toIndex:], "HOUR") != -1 {
if err := dt.setDayToHour(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else if strings.Index(leadStr[toIndex:], "MINUTE") != -1 {
if err := dt.setDayToMinute(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else if secPrecIndex = strings.Index(leadStr[toIndex:], "SECOND"); secPrecIndex != -1 {
secPrecIndex += toIndex
strSecPrec = leadStr[secPrecIndex:]
if err := dt.setDayToSecond(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
}
if err := dt.setPrecForSvr(leadStr, strLeadPrec, strSecPrec); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
return dt, nil
}
if leadPrecIndex = strings.Index(leadStr, "HOUR"); leadPrecIndex != -1 {
toIndex = strings.Index(leadStr[leadPrecIndex:], "TO")
if toIndex == -1 {
toIndex += leadPrecIndex
strLeadPrec = leadStr[leadPrecIndex:]
if err := dt.setHour(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else {
strLeadPrec = leadStr[leadPrecIndex:toIndex]
if strings.Index(leadStr[toIndex:], "MINUTE") != -1 {
if err := dt.setHourToMinute(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else if secPrecIndex = strings.Index(leadStr[toIndex:], "SECOND"); secPrecIndex != -1 {
secPrecIndex += toIndex
strSecPrec = leadStr[secPrecIndex:]
if err := dt.setHourToSecond(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
}
if err := dt.setPrecForSvr(leadStr, strLeadPrec, strSecPrec); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
return dt, nil
}
if leadPrecIndex = strings.Index(leadStr, "MINUTE"); leadPrecIndex != -1 {
toIndex = strings.Index(leadStr, "TO")
if toIndex == -1 {
toIndex += leadPrecIndex
strLeadPrec = leadStr[leadPrecIndex:]
if err := dt.setMinute(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else {
strLeadPrec = leadStr[leadPrecIndex:toIndex]
if secPrecIndex = strings.Index(leadStr[toIndex:], "SECOND"); secPrecIndex != -1 {
strSecPrec = leadStr[secPrecIndex:]
if err := dt.setMinuteToSecond(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
} else {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
}
if err := dt.setPrecForSvr(leadStr, strLeadPrec, strSecPrec); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
return dt, nil
}
if leadPrecIndex = strings.Index(leadStr, "SECOND"); leadPrecIndex != -1 {
if err := dt.setSecond(valueStr); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
leadStr = strings.TrimSpace(leadStr[leadPrecIndex:])
colonIndex := strings.Index(leadStr, ",")
if colonIndex != -1 {
strLeadPrec = strings.TrimSpace(leadStr[:colonIndex]) + ")"
strSecPrec = "(" + strings.TrimSpace(leadStr[:colonIndex+1])
}
if err := dt.setPrecForSvr(leadStr, strLeadPrec, strSecPrec); err != nil {
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
return dt, nil
}
return nil, ECGO_INVALID_TIME_INTERVAL.throw()
}
func (dt *DmIntervalDT) GetDay() int {
return dt.days
}
func (dt *DmIntervalDT) GetHour() int {
return dt.hours
}
func (dt *DmIntervalDT) GetMinute() int {
return dt.minutes
}
func (dt *DmIntervalDT) GetSecond() int {
return dt.seconds
}
func (dt *DmIntervalDT) GetMsec() int {
return dt.fraction
}
func (dt *DmIntervalDT) GetDTType() byte {
return dt._type
}
func (dt *DmIntervalDT) String() string {
if !dt.Valid {
return ""
}
var l, destLen int
var dStr, hStr, mStr, sStr, nStr string
interval := "INTERVAL "
switch dt._type {
case QUA_D:
dStr := strconv.FormatInt(int64(float64(dt.days)), 10)
if dt.negative {
interval += "-"
}
if len(dStr) < dt.leadScale {
l = len(dStr)
destLen = dt.leadScale
for destLen > l {
dStr = "0" + dStr
destLen--
}
}
interval += "'" + dStr + "' DAY(" + strconv.FormatInt(int64(dt.leadScale), 10) + ")"
case QUA_DH:
dStr = strconv.FormatInt(int64(float64(dt.days)), 10)
hStr = strconv.FormatInt(int64(float64(dt.hours)), 10)
if dt.negative {
interval += "-"
}
if len(dStr) < dt.leadScale {
l = len(dStr)
destLen = dt.leadScale
for destLen > l {
dStr = "0" + dStr
destLen--
}
}
if len(hStr) < 2 {
hStr = "0" + hStr
}
interval += "'" + dStr + " " + hStr + "' DAY(" + strconv.FormatInt(int64(dt.leadScale), 10) + ") TO HOUR"
case QUA_DHM:
dStr = strconv.FormatInt(int64(float64(dt.days)), 10)
hStr = strconv.FormatInt(int64(float64(dt.hours)), 10)
mStr = strconv.FormatInt(int64(float64(dt.minutes)), 10)
if dt.negative {
interval += "-"
}
if len(dStr) < dt.leadScale {
l = len(dStr)
destLen = dt.leadScale
for destLen > l {
dStr = "0" + dStr
destLen--
}
}
if len(hStr) < 2 {
hStr = "0" + hStr
}
if len(mStr) < 2 {
mStr = "0" + mStr
}
interval += "'" + dStr + " " + hStr + ":" + mStr + "' DAY(" + strconv.FormatInt(int64(dt.leadScale), 10) + ") TO MINUTE"
case QUA_DHMS:
dStr = strconv.FormatInt(int64(float64(dt.days)), 10)
hStr = strconv.FormatInt(int64(float64(dt.hours)), 10)
mStr = strconv.FormatInt(int64(float64(dt.minutes)), 10)
sStr = strconv.FormatInt(int64(float64(dt.seconds)), 10)
nStr = dt.getMsecString()
if dt.negative {
interval += "-"
}
if len(dStr) < dt.leadScale {
l = len(dStr)
destLen = dt.leadScale
for destLen > l {
dStr = "0" + dStr
destLen--
}
}
if len(hStr) < 2 {
hStr = "0" + hStr
}
if len(mStr) < 2 {
mStr = "0" + mStr
}
if len(sStr) < 2 {
sStr = "0" + sStr
}
interval += "'" + dStr + " " + hStr + ":" + mStr + ":" + sStr
if nStr != "" {
interval += "." + nStr
}
interval += "' DAY(" + strconv.FormatInt(int64(dt.leadScale), 10) + ") TO SECOND(" + strconv.FormatInt(int64(dt.secScale), 10) + ")"
case QUA_H:
hStr = strconv.FormatInt(int64(float64(dt.hours)), 10)
if dt.negative {
interval += "-"
}
if len(hStr) < dt.leadScale {
l = len(hStr)
destLen = dt.leadScale
for destLen > l {
hStr = "0" + hStr
destLen--
}
}
interval += "'" + hStr + "' HOUR(" + strconv.FormatInt(int64(dt.leadScale), 10) + ")"
case QUA_HM:
hStr = strconv.FormatInt(int64(float64(dt.hours)), 10)
mStr = strconv.FormatInt(int64(float64(dt.minutes)), 10)
if dt.negative {
interval += "-"
}
if len(hStr) < dt.leadScale {
l = len(hStr)
destLen = dt.leadScale
for destLen > l {
hStr = "0" + hStr
destLen--
}
}
if len(mStr) < 2 {
mStr = "0" + mStr
}
interval += "'" + hStr + ":" + mStr + "' HOUR(" + strconv.FormatInt(int64(dt.leadScale), 10) + ") TO MINUTE"
case QUA_HMS:
nStr = dt.getMsecString()
hStr = strconv.FormatInt(int64(float64(dt.hours)), 10)
mStr = strconv.FormatInt(int64(float64(dt.minutes)), 10)
sStr = strconv.FormatInt(int64(float64(dt.seconds)), 10)
if dt.negative {
interval += "-"
}
if len(hStr) < dt.leadScale {
l = len(hStr)
destLen = dt.leadScale
for destLen > l {
hStr = "0" + hStr
destLen--
}
}
if len(mStr) < 2 {
mStr = "0" + mStr
}
if len(sStr) < 2 {
sStr = "0" + sStr
}
interval += "'" + hStr + ":" + mStr + ":" + sStr
if nStr != "" {
interval += "." + nStr
}
interval += "' HOUR(" + strconv.FormatInt(int64(dt.leadScale), 10) + ") TO SECOND(" + strconv.FormatInt(int64(dt.secScale), 10) + ")"
case QUA_M:
mStr = strconv.FormatInt(int64(float64(dt.minutes)), 10)
if dt.negative {
interval += "-"
}
if len(mStr) < dt.leadScale {
l = len(mStr)
destLen = dt.leadScale
for destLen > l {
mStr = "0" + mStr
destLen--
}
}
interval += "'" + mStr + "' MINUTE(" + strconv.FormatInt(int64(dt.leadScale), 10) + ")"
case QUA_MS:
nStr = dt.getMsecString()
mStr = strconv.FormatInt(int64(float64(dt.minutes)), 10)
sStr = strconv.FormatInt(int64(float64(dt.seconds)), 10)
if dt.negative {
interval += "-"
}
if len(mStr) < dt.leadScale {
l = len(mStr)
destLen = dt.leadScale
for destLen > l {
mStr = "0" + mStr
destLen--
}
}
if len(sStr) < 2 {
sStr = "0" + sStr
}
interval += "'" + mStr + ":" + sStr
if nStr != "" {
interval += "." + nStr
}
interval += "' MINUTE(" + strconv.FormatInt(int64(dt.leadScale), 10) + ") TO SECOND(" + strconv.FormatInt(int64(dt.secScale), 10) + ")"
case QUA_S:
nStr = dt.getMsecString()
sStr = strconv.FormatInt(int64(float64(dt.seconds)), 10)
if dt.negative {
interval += "-"
}
if len(sStr) < dt.leadScale {
l = len(sStr)
destLen = dt.leadScale
for destLen > l {
sStr = "0" + sStr
destLen--
}
}
interval += "'" + sStr
if nStr != "" {
interval += "." + nStr
}
interval += "' SECOND(" + strconv.FormatInt(int64(dt.leadScale), 10) + ", " + strconv.FormatInt(int64(dt.secScale), 10) + ")"
}
return interval
}
func (dest *DmIntervalDT) Scan(src interface{}) error {
if dest == nil {
return ECGO_STORE_IN_NIL_POINTER.throw()
}
switch src := src.(type) {
case nil:
*dest = *new(DmIntervalDT)
(*dest).Valid = false
return nil
case *DmIntervalDT:
*dest = *src
return nil
case string:
ret, err := NewDmIntervalDTByString(src)
if err != nil {
return err
}
*dest = *ret
return nil
default:
return UNSUPPORTED_SCAN
}
}
func (dt DmIntervalDT) Value() (driver.Value, error) {
if !dt.Valid {
return nil, nil
}
return dt, nil
}
func (dt *DmIntervalDT) checkScale(leadScale int) (int, error) {
switch dt._type {
case QUA_D:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.days))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.days))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_DH:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.days))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.days))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
if int64(math.Abs(float64((dt.hours)))) > 23 {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_DHM:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.days))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.days))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
if int64(math.Abs(float64(dt.hours))) > 23 || int64(math.Abs(float64(dt.minutes))) > 59 {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_DHMS:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.days))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.days))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
if int64(math.Abs(float64(dt.hours))) > 23 || int64(math.Abs(float64(dt.minutes))) > 59 ||
int64(math.Abs(float64(dt.seconds))) > 59 {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_H:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.hours))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.hours))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_HM:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.hours))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.hours))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
if int64(math.Abs(float64(dt.minutes))) > 59 {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_HMS:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.hours))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.hours))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
if int64(math.Abs(float64(dt.minutes))) > 59 || int64(math.Abs(float64(dt.seconds))) > 59 {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_M:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.minutes))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.minutes))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_MS:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.minutes))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.minutes))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
if int64(math.Abs(float64(dt.seconds))) > 59 {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
case QUA_S:
if leadScale == -1 {
leadScale = len(strconv.FormatInt(int64(math.Abs(float64(dt.minutes))), 10))
} else if leadScale < len(strconv.FormatInt(int64(math.Abs(float64(dt.minutes))), 10)) {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
}
if leadScale > LOADPREC_MAX {
return 0, ECGO_INVALID_TIME_INTERVAL.throw()
}
return leadScale, nil
}
func (dt *DmIntervalDT) parsePrec(leadStr string) (int, error) {
leftBtId := strings.Index(leadStr, "(")
rightBtId := strings.Index(leadStr, ")")
var prec int64 = -1
if rightBtId != -1 && leftBtId != -1 && rightBtId > leftBtId+1 {
strPrec := strings.TrimSpace(leadStr[leftBtId+1 : rightBtId])
var err error
prec, err = strconv.ParseInt(strPrec, 10, 32)
if err != nil {
return -1, err
}
}
return int(prec), nil
}
func (dt *DmIntervalDT) setPrecForSvr(fullStr string, leadScale string, secScale string) error {
prec, err := dt.parsePrec(leadScale)
if err != nil {
return err
}
prec, err = dt.checkScale(prec)
if err != nil {
return err
}
if prec < LOADPREC_DEFAULT {
dt.leadScale = LOADPREC_DEFAULT
} else {
dt.leadScale = prec
}
prec, err = dt.parsePrec(secScale)
if err != nil {
return err
}
if prec >= 0 && prec < SECDPREC_MAX {
dt.secScale = prec
} else {
dt.secScale = SECDPREC_DEFAULT
}
dt.scaleForSvr = (int(dt._type) << 8) + (dt.leadScale << 4) + dt.secScale
return nil
}
func (dt *DmIntervalDT) checkSign(str string) string {
if str[0] == '-' {
str = strings.TrimSpace(str[1:])
dt.negative = true
} else if str[0] == '+' {
str = strings.TrimSpace(str[1:])
dt.negative = false
}
return str
}
func (dt *DmIntervalDT) setDay(value string) error {
list := util.Split(value, " :.")
if len(list) > 1 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_D
i, err := strconv.ParseInt(value, 10, 32)
if err != nil {
return err
}
if i < 0 {
dt.days = int(-i)
dt.negative = true
} else {
dt.days = int(i)
}
return nil
}
func (dt *DmIntervalDT) setHour(value string) error {
list := util.Split(value, " :.")
if len(list) > 1 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_H
i, err := strconv.ParseInt(value, 10, 32)
if err != nil {
return err
}
if i < 0 {
dt.hours = int(-i)
dt.negative = true
} else {
dt.hours = int(i)
}
return nil
}
func (dt *DmIntervalDT) setMinute(value string) error {
list := util.Split(value, " :.")
if len(list) > 1 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_M
i, err := strconv.ParseInt(value, 10, 32)
if err != nil {
return err
}
if i < 0 {
dt.minutes = int(-i)
dt.negative = true
} else {
dt.minutes = int(i)
}
return nil
}
func (dt *DmIntervalDT) setSecond(value string) error {
list := util.Split(value, " :.")
if len(list) > 2 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_S
i, err := strconv.ParseInt(list[0], 10, 32)
if err != nil {
return err
}
nano := 0
if len(list) > 1 {
strNano := "0" + "." + list[1]
d_v, err := strconv.ParseFloat(strNano, 64)
if err != nil {
return err
}
nx := math.Pow10(dt.secScale)
nano = (int)(d_v * nx)
}
if i < 0 {
dt.seconds = int(-i)
} else {
dt.seconds = int(i)
}
if nano < 0 {
dt.fraction = -nano
} else {
dt.fraction = nano
}
if i < 0 || nano < 0 {
dt.negative = true
}
return nil
}
func (dt *DmIntervalDT) setHourToSecond(value string) error {
list := util.Split(value, " :.")
if len(list) > 4 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_HMS
h, err := strconv.ParseInt(list[0], 10, 32)
if err != nil {
return err
}
m, err := strconv.ParseInt(list[1], 10, 32)
if err != nil {
return err
}
s, err := strconv.ParseInt(list[2], 10, 32)
if err != nil {
return err
}
nano := 0
if len(list) > 3 {
strNano := "0" + "." + list[3]
d_v, err := strconv.ParseFloat(strNano, 64)
if err != nil {
return err
}
nx := math.Pow10(dt.secScale)
nano = (int)(d_v * nx)
}
if h < 0 {
dt.hours = int(-h)
} else {
dt.hours = int(h)
}
if m < 0 {
dt.minutes = int(-m)
} else {
dt.minutes = int(m)
}
if s < 0 {
dt.seconds = int(-s)
} else {
dt.seconds = int(s)
}
if nano < 0 {
dt.fraction = -nano
} else {
dt.fraction = nano
}
if h < 0 || m < 0 || s < 0 || nano < 0 {
dt.negative = true
}
return nil
}
func (dt *DmIntervalDT) setHourToMinute(value string) error {
value = strings.TrimSpace(value)
list := util.Split(value, " :.")
if len(list) > 2 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_HM
h, err := strconv.ParseInt(list[0], 10, 32)
if err != nil {
return err
}
m, err := strconv.ParseInt(list[1], 10, 32)
if err != nil {
return err
}
if h < 0 {
dt.hours = int(-h)
} else {
dt.hours = int(h)
}
if m < 0 {
dt.minutes = int(-m)
} else {
dt.minutes = int(m)
}
if h < 0 || m < 0 {
dt.negative = true
}
return nil
}
func (dt *DmIntervalDT) setMinuteToSecond(value string) error {
list := util.Split(value, " :.")
if len(list) > 3 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_MS
m, err := strconv.ParseInt(list[0], 10, 32)
if err != nil {
return err
}
s, err := strconv.ParseInt(list[1], 10, 32)
if err != nil {
return err
}
nano := 0
if len(list) > 2 {
strNano := "0" + "." + list[2]
d_v, err := strconv.ParseFloat(strNano, 64)
if err != nil {
return err
}
nx := math.Pow10(dt.secScale)
nano = (int)(d_v * nx)
}
if m < 0 {
dt.minutes = int(-m)
} else {
dt.minutes = int(m)
}
if s < 0 {
dt.seconds = int(-s)
} else {
dt.seconds = int(s)
}
if nano < 0 {
dt.fraction = -nano
} else {
dt.fraction = nano
}
if m < 0 || s < 0 || nano < 0 {
dt.negative = true
}
return nil
}
func (dt *DmIntervalDT) setDayToHour(value string) error {
list := util.Split(value, " :.")
if len(list) > 2 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_DH
d, err := strconv.ParseInt(list[0], 10, 32)
if err != nil {
return err
}
h, err := strconv.ParseInt(list[1], 10, 32)
if err != nil {
return err
}
if d < 0 {
dt.days = int(-d)
} else {
dt.days = int(d)
}
if h < 0 {
dt.hours = int(-h)
} else {
dt.hours = int(h)
}
if d < 0 || h < 0 {
dt.negative = true
}
return nil
}
func (dt *DmIntervalDT) setDayToMinute(value string) error {
list := util.Split(value, " :.")
if len(list) > 3 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_DHM
d, err := strconv.ParseInt(list[0], 10, 32)
if err != nil {
return err
}
h, err := strconv.ParseInt(list[1], 10, 32)
if err != nil {
return err
}
m, err := strconv.ParseInt(list[2], 10, 32)
if err != nil {
return err
}
if d < 0 {
dt.days = int(-d)
} else {
dt.days = int(d)
}
if h < 0 {
dt.hours = int(-h)
} else {
dt.hours = int(h)
}
if m < 0 {
dt.minutes = int(-m)
} else {
dt.minutes = int(m)
}
if d < 0 || h < 0 || m < 0 {
dt.negative = true
}
return nil
}
func (dt *DmIntervalDT) setDayToSecond(value string) error {
list := util.Split(value, " :.")
if len(list) > 5 {
return ECGO_INVALID_TIME_INTERVAL.throw()
}
dt._type = QUA_DHMS
d, err := strconv.ParseInt(list[0], 10, 32)
if err != nil {
return err
}
h, err := strconv.ParseInt(list[1], 10, 32)
if err != nil {
return err
}
m, err := strconv.ParseInt(list[2], 10, 32)
if err != nil {
return err
}
s, err := strconv.ParseInt(list[3], 10, 32)
if err != nil {
return err
}
nano := 0
if len(list) > 4 {
strNano := "0" + "." + list[4]
d_v, err := strconv.ParseFloat(strNano, 64)
if err != nil {
return err
}
nx := math.Pow10(dt.secScale)
nano = (int)(d_v * nx)
}
if d < 0 {
dt.days = int(-d)
} else {
dt.days = int(d)
}
if h < 0 {
dt.hours = int(-h)
} else {
dt.hours = int(h)
}
if m < 0 {
dt.minutes = int(-m)
} else {
dt.minutes = int(m)
}
if s < 0 {
dt.seconds = int(-s)
} else {
dt.seconds = int(s)
}
if nano < 0 {
dt.fraction = -nano
} else {
dt.fraction = nano
}
if d < 0 || h < 0 || m < 0 || s < 0 || nano < 0 {
dt.negative = true
}
return nil
}
func (dt *DmIntervalDT) getMsecString() string {
nano := strconv.Itoa(dt.fraction)
for i := 6 - len(nano); i > 0; i-- {
nano = "0" + nano
}
if len(nano) > dt.secScale {
nano = nano[:dt.secScale]
}
return nano
}
func (dt *DmIntervalDT) encode(scale int) ([]byte, error) {
if scale == 0 {
scale = dt.scaleForSvr
}
day, hour, minute, second, f := dt.days, dt.hours, dt.minutes, dt.seconds, dt.fraction
if scale != dt.scaleForSvr {
convertDT, err := dt.convertTo(scale)
if err != nil {
return nil, err
}
day, hour, minute, second, f = convertDT.days, convertDT.hours, convertDT.minutes, convertDT.seconds, convertDT.fraction
} else {
loadPrec := (scale >> 4) & 0x0000000F
if _, err := dt.checkScale(loadPrec); err != nil {
return nil, err
}
}
bytes := make([]byte, 24)
if dt.negative {
Dm_build_931.Dm_build_947(bytes, 0, int32(-day))
Dm_build_931.Dm_build_947(bytes, 4, int32(-hour))
Dm_build_931.Dm_build_947(bytes, 8, int32(-minute))
Dm_build_931.Dm_build_947(bytes, 12, int32(-second))
Dm_build_931.Dm_build_947(bytes, 16, int32(-f))
Dm_build_931.Dm_build_947(bytes, 20, int32(scale))
} else {
Dm_build_931.Dm_build_947(bytes, 0, int32(day))
Dm_build_931.Dm_build_947(bytes, 4, int32(hour))
Dm_build_931.Dm_build_947(bytes, 8, int32(minute))
Dm_build_931.Dm_build_947(bytes, 12, int32(second))
Dm_build_931.Dm_build_947(bytes, 16, int32(f))
Dm_build_931.Dm_build_947(bytes, 20, int32(scale))
}
return bytes, nil
}
func (dt *DmIntervalDT) convertTo(scale int) (*DmIntervalDT, error) {
destType := (scale & 0x0000FF00) >> 8
leadPrec := (scale >> 4) & 0x0000000F
secScale := scale & 0x0000000F
dayIndex := 0
hourIndex := 1
minuteIndex := 2
secondIndex := 3
fractionIndex := 4
orgDT := make([]int, 5)
destDT := make([]int, 5)
switch dt._type {
case QUA_D:
orgDT[dayIndex] = dt.days
case QUA_DH:
orgDT[dayIndex] = dt.days
orgDT[hourIndex] = dt.hours
case QUA_DHM:
orgDT[dayIndex] = dt.days
orgDT[hourIndex] = dt.hours
orgDT[minuteIndex] = dt.minutes
case QUA_DHMS:
orgDT[dayIndex] = dt.days
orgDT[hourIndex] = dt.hours
orgDT[minuteIndex] = dt.minutes
orgDT[secondIndex] = dt.seconds
orgDT[fractionIndex] = dt.fraction
case QUA_H:
orgDT[dayIndex] = dt.hours / 24
orgDT[hourIndex] = dt.hours % 24
case QUA_HM:
orgDT[dayIndex] = dt.hours / 24
orgDT[hourIndex] = dt.hours % 24
orgDT[minuteIndex] = dt.minutes
case QUA_HMS:
orgDT[dayIndex] = dt.hours / 24
orgDT[hourIndex] = dt.hours % 24
orgDT[minuteIndex] = dt.minutes
orgDT[secondIndex] = dt.seconds
orgDT[fractionIndex] = dt.fraction
case QUA_M:
orgDT[dayIndex] = dt.minutes / (24 * 60)
orgDT[hourIndex] = (dt.minutes % (24 * 60)) / 60
orgDT[minuteIndex] = (dt.minutes % (24 * 60)) % 60
case QUA_MS:
orgDT[dayIndex] = dt.minutes / (24 * 60)
orgDT[hourIndex] = (dt.minutes % (24 * 60)) / 60
orgDT[minuteIndex] = (dt.minutes % (24 * 60)) % 60
orgDT[secondIndex] = dt.seconds
orgDT[fractionIndex] = dt.fraction
case QUA_S:
orgDT[dayIndex] = dt.seconds / (24 * 60 * 60)
orgDT[hourIndex] = (dt.seconds % (24 * 60 * 60)) / (60 * 60)
orgDT[minuteIndex] = ((dt.seconds % (24 * 60 * 60)) % (60 * 60)) / 60
orgDT[secondIndex] = ((dt.seconds % (24 * 60 * 60)) % (60 * 60)) % 60
orgDT[fractionIndex] = dt.fraction
}
switch byte(destType) {
case QUA_D:
destDT[dayIndex] = orgDT[dayIndex]
if orgDT[hourIndex] >= 12 {
incrementDay(QUA_D, destDT)
}
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[dayIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_DH:
destDT[dayIndex] = orgDT[dayIndex]
destDT[hourIndex] = orgDT[hourIndex]
if orgDT[minuteIndex] >= 30 {
incrementHour(QUA_DH, destDT)
}
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[dayIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_DHM:
destDT[dayIndex] = orgDT[dayIndex]
destDT[hourIndex] = orgDT[hourIndex]
destDT[minuteIndex] = orgDT[minuteIndex]
if orgDT[secondIndex] >= 30 {
incrementMinute(QUA_DHM, destDT)
}
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[dayIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_DHMS:
destDT[dayIndex] = orgDT[dayIndex]
destDT[hourIndex] = orgDT[hourIndex]
destDT[minuteIndex] = orgDT[minuteIndex]
destDT[secondIndex] = orgDT[secondIndex]
destDT[fractionIndex] = orgDT[fractionIndex]
dt.convertMSecond(QUA_DHMS, destDT, secScale)
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[dayIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_H:
destDT[hourIndex] = orgDT[dayIndex]*24 + orgDT[hourIndex]
if orgDT[minuteIndex] >= 30 {
incrementHour(QUA_H, destDT)
}
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[hourIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_HM:
destDT[hourIndex] = orgDT[dayIndex]*24 + orgDT[hourIndex]
destDT[minuteIndex] = orgDT[minuteIndex]
if orgDT[secondIndex] >= 30 {
incrementMinute(QUA_HM, destDT)
}
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[hourIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_HMS:
destDT[hourIndex] = orgDT[dayIndex]*24 + orgDT[hourIndex]
destDT[minuteIndex] = orgDT[minuteIndex]
destDT[secondIndex] = orgDT[secondIndex]
destDT[fractionIndex] = orgDT[fractionIndex]
dt.convertMSecond(QUA_HMS, destDT, secScale)
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[hourIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_M:
destDT[minuteIndex] = orgDT[dayIndex]*24*60 + orgDT[hourIndex]*60 + orgDT[minuteIndex]
if orgDT[secondIndex] >= 30 {
incrementMinute(QUA_M, destDT)
}
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[minuteIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_MS:
destDT[minuteIndex] = orgDT[dayIndex]*24*60 + orgDT[hourIndex]*60 + orgDT[minuteIndex]
destDT[secondIndex] = orgDT[secondIndex]
destDT[fractionIndex] = orgDT[fractionIndex]
dt.convertMSecond(QUA_MS, destDT, secScale)
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[minuteIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
case QUA_S:
destDT[secondIndex] = orgDT[dayIndex]*24*60*60 + orgDT[hourIndex]*60*60 + orgDT[minuteIndex]*60 + orgDT[secondIndex]
destDT[fractionIndex] = orgDT[fractionIndex]
dt.convertMSecond(QUA_S, destDT, secScale)
if leadPrec < len(strconv.Itoa(int(math.Abs(float64(destDT[secondIndex]))))) {
return nil, ECGO_INTERVAL_OVERFLOW.throw()
}
}
return &DmIntervalDT{
_type: byte(destType),
negative: dt.negative,
leadScale: (scale >> 4) & 0x0000000F,
secScale: scale & 0x0000000F,
scaleForSvr: scale,
days: destDT[dayIndex],
hours: destDT[hourIndex],
minutes: destDT[minuteIndex],
seconds: destDT[secondIndex],
fraction: destDT[fractionIndex],
Valid: true,
}, nil
}
func (dt DmIntervalDT) convertMSecond(destType byte, destDT []int, destSecScale int) {
fractionIndex := 4
orgFraction := destDT[fractionIndex]
if destSecScale == 0 || destSecScale < dt.secScale {
n := int(math.Pow(10, 6-float64(destSecScale)-1))
f := orgFraction / n / 10
if (orgFraction/n)%10 >= 5 {
f++
f = f * n * 10
if f == 1000000 {
destDT[fractionIndex] = 0
incrementSecond(destType, destDT)
return
}
}
destDT[fractionIndex] = f
}
}
func incrementDay(destType byte, dt []int) {
dayIndex := 0
dt[dayIndex]++
}
func incrementHour(destType byte, dt []int) {
hourIndex := 1
dt[hourIndex]++
if dt[hourIndex] == 24 && destType < QUA_H {
incrementDay(destType, dt)
dt[hourIndex] = 0
}
}
func incrementMinute(destType byte, dt []int) {
minuteIndex := 2
dt[minuteIndex]++
if dt[minuteIndex] == 60 && destType < QUA_M {
incrementHour(destType, dt)
dt[minuteIndex] = 0
}
}
func incrementSecond(destType byte, dt []int) {
secondIndex := 3
dt[secondIndex]++
if dt[secondIndex] == 60 && destType < QUA_S {
incrementMinute(destType, dt)
dt[secondIndex] = 0
}
}
func (dt *DmIntervalDT) checkValid() error {
if !dt.Valid {
return ECGO_IS_NULL.throw()
}
return nil
}
func (d *DmIntervalDT) GormDataType() string {
return "INTERVAL DAY TO SECOND"
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化