package data_manage //type lzSurveyData struct { // DataTime string `orm:"column(data_time)" description:"日期"` // InputValue string `orm:"column(input_value)" description:"值"` //} //type LongzhongSurveyData struct { // SurveyDataId int `orm:"column(survey_data_id);pk" gorm:"primaryKey"` // SurveyProductId int // ProjectQuotaId int64 // BreedId string // BreedName string // QuotaId string // QuotaName string // UnitId string // UnitName string // SampleType int64 // SampleId string // SampleName string // DeviceId string // Device string // ProductCraftId string // ProductCraft string // ProductLine string // InputMode int64 // Frequency int64 // InputValue string // TaskShouldFinishTime int64 // CustomId string // CustomType int64 // Custom string // QuotaSampleId int64 // TaskActualFinishTime int64 // AreaName string // ProvinceName string // ResearchStartData int64 // ResearchStopData int64 // DataTime string //} //func GetLzSurveyDataByTradeCode(condition string, pars []interface{}) (item []*lzSurveyData, err error) { // sql := ` SELECT a.* FROM longzhong_survey_data AS a // INNER JOIN longzhong_survey_product AS b ON a.survey_product_id=b.survey_product_id // WHERE 1=1 ` // o := global.DbMap[utils.DbNameIndex] // if condition != "" { // sql += condition // } // sql += ` ORDER BY a.data_time DESC ` // err = o.Raw(sql, pars).Find(&item).Error // return //} //func GetLzSurveyDataExistByTradeCode(surveyProductId int) (items []*LongzhongSurveyData, err error) { // sql := ` SELECT * FROM longzhong_survey_data WHERE 1=1 AND survey_product_id=? ` // o := global.DbMap[utils.DbNameIndex] // err = o.Raw(sql, surveyProductId).Find(&items).Error // return //} //func GetEdbDataLzByCodeAndDate(edbCode string, startDate string) (count int, err error) { // o := global.DbMap[utils.DbNameIndex] // sql := ` SELECT COUNT(1) AS count FROM edb_data_lz WHERE edb_code=? AND data_time=? ` // err = o.Raw(sql, edbCode, startDate).Scan(&count).Error // return //} //func ModifyEdbDataLz(edbInfoId int64, dataTime, value string) (err error) { // o := global.DbMap[utils.DbNameIndex] // sql := ` UPDATE edb_data_lz SET value=?,modify_time=NOW() WHERE edb_info_id=? AND data_time=? ` // err = o.Exec(sql, value, edbInfoId, dataTime).Error // return //}