1 Star 0 Fork 0

zongyangleo / dm

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
q.go 33.26 KB
一键复制 编辑 原始数据 按行查看 历史
刘宗洋 提交于 2023-12-06 09:49 . v8.1.3.12
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454
/*
* Copyright (c) 2000-2018, 达梦数据库有限公司.
* All rights reserved.
*/
package dm
import (
"database/sql/driver"
"dm/util"
"math"
"strconv"
"strings"
)
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_1331.Dm_build_1433(bytes, 20))
dt.leadScale = (dt.scaleForSvr >> 4) & 0x0000000F
dt.secScale = dt.scaleForSvr & 0x0000000F
switch dt._type {
case QUA_D:
dt.days = int(Dm_build_1331.Dm_build_1433(bytes, 0))
case QUA_DH:
dt.days = int(Dm_build_1331.Dm_build_1433(bytes, 0))
dt.hours = int(Dm_build_1331.Dm_build_1433(bytes, 4))
case QUA_DHM:
dt.days = int(Dm_build_1331.Dm_build_1433(bytes, 0))
dt.hours = int(Dm_build_1331.Dm_build_1433(bytes, 4))
dt.minutes = int(Dm_build_1331.Dm_build_1433(bytes, 8))
case QUA_DHMS:
dt.days = int(Dm_build_1331.Dm_build_1433(bytes, 0))
dt.hours = int(Dm_build_1331.Dm_build_1433(bytes, 4))
dt.minutes = int(Dm_build_1331.Dm_build_1433(bytes, 8))
dt.seconds = int(Dm_build_1331.Dm_build_1433(bytes, 12))
dt.fraction = int(Dm_build_1331.Dm_build_1433(bytes, 16))
case QUA_H:
dt.hours = int(Dm_build_1331.Dm_build_1433(bytes, 4))
case QUA_HM:
dt.hours = int(Dm_build_1331.Dm_build_1433(bytes, 4))
dt.minutes = int(Dm_build_1331.Dm_build_1433(bytes, 8))
case QUA_HMS:
dt.hours = int(Dm_build_1331.Dm_build_1433(bytes, 4))
dt.minutes = int(Dm_build_1331.Dm_build_1433(bytes, 8))
dt.seconds = int(Dm_build_1331.Dm_build_1433(bytes, 12))
dt.fraction = int(Dm_build_1331.Dm_build_1433(bytes, 16))
case QUA_M:
dt.minutes = int(Dm_build_1331.Dm_build_1433(bytes, 8))
case QUA_MS:
dt.minutes = int(Dm_build_1331.Dm_build_1433(bytes, 8))
dt.seconds = int(Dm_build_1331.Dm_build_1433(bytes, 12))
dt.fraction = int(Dm_build_1331.Dm_build_1433(bytes, 16))
case QUA_S:
dt.seconds = int(Dm_build_1331.Dm_build_1433(bytes, 12))
dt.fraction = int(Dm_build_1331.Dm_build_1433(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_1331.Dm_build_1347(bytes, 0, int32(-day))
Dm_build_1331.Dm_build_1347(bytes, 4, int32(-hour))
Dm_build_1331.Dm_build_1347(bytes, 8, int32(-minute))
Dm_build_1331.Dm_build_1347(bytes, 12, int32(-second))
Dm_build_1331.Dm_build_1347(bytes, 16, int32(-f))
Dm_build_1331.Dm_build_1347(bytes, 20, int32(scale))
} else {
Dm_build_1331.Dm_build_1347(bytes, 0, int32(day))
Dm_build_1331.Dm_build_1347(bytes, 4, int32(hour))
Dm_build_1331.Dm_build_1347(bytes, 8, int32(minute))
Dm_build_1331.Dm_build_1347(bytes, 12, int32(second))
Dm_build_1331.Dm_build_1347(bytes, 16, int32(f))
Dm_build_1331.Dm_build_1347(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"
}
1
https://gitee.com/liuzongyang/dm.git
git@gitee.com:liuzongyang/dm.git
liuzongyang
dm
dm
main

搜索帮助