123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566 |
- package cygx
- import (
- "errors"
- "fmt"
- "hongze/hz_crm_api/models/cygx"
- "hongze/hz_crm_api/services/alarm_msg"
- "hongze/hz_crm_api/utils"
- "strconv"
- "strings"
- "time"
- )
- //首页最新页面数据逻辑处理
- // 更新报告精选(重点公司)
- func UpdateReportSelectionResourceData(sourceId int) (err error) {
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新报告精选(重点公司) 失败,UpdateReportSelectionResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_REPORTSELECTION
- var condition string
- var pars []interface{}
- condition = ` AND visible_range = 1 `
- total, e := cygx.GetCygxReportSelection(condition, pars)
- if e != nil {
- err = errors.New("GetCygxReportSelection, Err: " + err.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = cygx.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + err.Error())
- return
- }
- } else {
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxReportSelectionBySourceAndId(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelection, Err: " + err.Error())
- return
- }
- detail, e := cygx.GetCygxReportSelectionInfoById(sourceId)
- if e != nil {
- err = errors.New("GetCygxReportSelectionInfoById, Err: " + err.Error())
- return
- }
- publishDate := detail.PublishDate
- if totalData == 0 {
- item := new(cygx.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- item.SearchTag = "重点公司"
- item.PublishDate = publishDate
- item.CreateTime = time.Now()
- _, err = cygx.AddCygxResourceData(item)
- } else {
- err = cygx.UpdateResourceData(sourceId, source, publishDate)
- }
- }
- return
- }
|