123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- package cygx
- import (
- "errors"
- "fmt"
- "hongze/hz_crm_api/models/cygx"
- "hongze/hz_crm_api/services/alarm_msg"
- "hongze/hz_crm_api/utils"
- "time"
- )
- // 更新研选专栏 写入首页最新 cygx_resource_data 表
- func UpdateYanxuanSpecialResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- go alarm_msg.SendAlarmMsg(fmt.Sprint("更新研选专栏失败ourceId: ", sourceId), 2)
- }
- }()
- var source = utils.CYGX_OBJ_YANXUANSPECIAL
- var condition string
- var pars []interface{}
- condition = ` AND status = 3 AND id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetCygxYanxuanSpecialCount(condition, pars)
- if e != nil {
- err = errors.New("GetCygxYanxuanSpecialCount, Err: " + e.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = cygx.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + e.Error())
- return
- }
- } else {
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxResourceDataBySourceAndIdCount(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- publishDate := time.Now().Format(utils.FormatDateTime)
- item := new(cygx.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- item.PublishDate = publishDate
- item.CreateTime = time.Now()
- if totalData == 0 {
- _, e := cygx.AddCygxResourceData(item)
- if e != nil {
- err = errors.New("AddCygxResourceData, Err: " + e.Error())
- return
- }
- } else {
- e = cygx.UpdateResourceDataByItem(item)
- if e != nil {
- err = errors.New("UpdateResourceDataByItem, Err: " + e.Error())
- return
- }
- }
- }
- return
- }
|