|
@@ -76,14 +76,14 @@ func UpdateActivityResourceData(sourceId int) (err error) {
|
|
|
}
|
|
|
var resourceDataId int
|
|
|
publishDate := time.Now().Format(utils.FormatDateTime)
|
|
|
+ item := new(cygx.CygxResourceData)
|
|
|
+ item.SourceId = sourceId
|
|
|
+ item.Source = source
|
|
|
+ //分析师电话会(C类)
|
|
|
+ item.SearchTag = strings.TrimRight(detail.ActivityTypeName, "(C类)")
|
|
|
+ item.PublishDate = publishDate
|
|
|
+ item.CreateTime = time.Now()
|
|
|
if totalData == 0 {
|
|
|
- item := new(cygx.CygxResourceData)
|
|
|
- item.SourceId = sourceId
|
|
|
- item.Source = source
|
|
|
- //分析师电话会(C类)
|
|
|
- item.SearchTag = strings.TrimRight(detail.ActivityTypeName, "(C类)")
|
|
|
- item.PublishDate = publishDate
|
|
|
- item.CreateTime = time.Now()
|
|
|
newId, e := cygx.AddCygxResourceData(item)
|
|
|
if e != nil {
|
|
|
err = errors.New("AddCygxResourceData, Err: " + err.Error())
|
|
@@ -91,12 +91,11 @@ func UpdateActivityResourceData(sourceId int) (err error) {
|
|
|
}
|
|
|
resourceDataId = int(newId)
|
|
|
} else {
|
|
|
- e = cygx.UpdateResourceData(sourceId, source, publishDate)
|
|
|
+ e = cygx.UpdateResourceDataByItem(item)
|
|
|
if e != nil {
|
|
|
err = errors.New("UpdateResourceData, Err: " + err.Error())
|
|
|
return
|
|
|
}
|
|
|
-
|
|
|
sourceDetail, e := cygx.GetCygxResourceDataByIdAndSource(sourceId, source)
|
|
|
if e != nil {
|
|
|
err = errors.New("UpdateResourceData, Err: " + err.Error())
|