1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315 |
- package cygx
- import (
- "errors"
- "fmt"
- "hongze/hz_crm_api/models/cygx"
- "hongze/hz_crm_api/services/alarm_msg"
- "hongze/hz_crm_api/utils"
- "strconv"
- "time"
- )
- //首页最新页面数据逻辑处理
- //activity
- //activityspecial
- //activityvideo
- //activityvoice
- //article
- //meetingreviewchapt
- //minutessummary
- //newchart
- //productinterior
- //reportselection
- //researchsummary
- //roadshow
- //func init() {
- // UpdateActivityResourceData(2703)
- //}
- // 更新活动
- func UpdateActivityResourceData(sourceId int) {
- var err error
- //time.Sleep(3*time.Second) // 有时候同时添加多个活动,延迟三秒
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新活动 失败,UpdateActivityResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_ACTIVITY
- var condition string
- var pars []interface{}
- condition = ` AND publish_status = 1 AND activity_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetActivityCount(condition, pars)
- if e != nil {
- err = errors.New("GetCygxReportSelection, Err: " + e.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = cygx.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + e.Error())
- return
- }
- //删除 cygx_resource_data 表关联的产业ID,标的ID
- e = cygx.DeleteCygxResourceDataGroup(sourceId, source)
- if e != nil {
- err = errors.New("DeleteCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- } else {
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxReportSelectionBySourceAndId(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- detail, e := cygx.GetAddActivityInfoById(sourceId)
- if e != nil {
- err = errors.New("GetCygxReportSelectionInfoById, Err: " + e.Error())
- return
- }
- var resourceDataId int
- publishDate := time.Now().Format(utils.FormatDateTime)
- item := new(cygx.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- //分析师电话会(C类)
- item.SearchTag = detail.ActivityTypeName
- item.ChartPermissionId = detail.ChartPermissionId
- item.PublishDate = publishDate
- item.CreateTime = time.Now()
- if totalData == 0 {
- newId, e := cygx.AddCygxResourceData(item)
- if e != nil {
- err = errors.New("AddCygxResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = int(newId)
- } else {
- e = cygx.UpdateResourceDataByItem(item)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- sourceDetail, e := cygx.GetCygxResourceDataByIdAndSource(sourceId, source)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = sourceDetail.Id
- }
- //建立首页资源表,与产业的关系
- industrialList, e := cygx.GetIndustrialActivityGroupManagementList(sourceId, 1)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetIndustrialActivityGroupManagementList, Err: " + e.Error() + "activityId:" + strconv.Itoa(sourceId))
- return
- }
- var industrialItems []*cygx.CygxResourceDataIndustrialGroupManagement
- for _, v := range industrialList {
- var industrialItem = new(cygx.CygxResourceDataIndustrialGroupManagement)
- industrialItem.SourceId = sourceId
- industrialItem.Source = source
- industrialItem.IndustrialManagementId = v.IndustrialManagementId
- industrialItem.ResourceDataId = resourceDataId
- industrialItem.CreateTime = time.Now()
- industrialItems = append(industrialItems, industrialItem)
- }
- //建立首页资源表,与标的 的关系
- subjectList, e := cygx.GetSubjectActivityGroupManagementList(sourceId, 1)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetIndustrialActivityGroupManagementList, Err: " + e.Error() + "activityId:" + strconv.Itoa(sourceId))
- return
- }
- var subjectItems []*cygx.CygxResourceDataIndustrialGroupSubject
- for _, v := range subjectList {
- var subjectItem = new(cygx.CygxResourceDataIndustrialGroupSubject)
- subjectItem.SourceId = sourceId
- subjectItem.Source = source
- subjectItem.IndustrialSubjectId = v.IndustrialSubjectId
- subjectItem.ResourceDataId = resourceDataId
- subjectItem.CreateTime = time.Now()
- subjectItems = append(subjectItems, subjectItem)
- }
- //插入关联信息
- e = cygx.AddCygxResourceDataGroup(sourceId, source, industrialItems, subjectItems)
- if e != nil {
- err = errors.New("AddCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- }
- return
- }
- // 更新专项调研活动
- func UpdateActivitySpecialResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新活动 失败,UpdateActivitySpecialResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_ACTIVITYSPECIAL
- var condition string
- var pars []interface{}
- condition = ` AND publish_status = 1 AND activity_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetActivityCount(condition, pars)
- if e != nil {
- err = errors.New("GetCygxReportSelection, Err: " + e.Error())
- return
- }
- activityInfo, e := cygx.GetAddActivityInfoSpecialById(sourceId)
- if e != nil {
- err = errors.New("GetAddActivityInfoSpecialById, Err: " + e.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = cygx.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + e.Error())
- return
- }
- //删除 cygx_resource_data 表关联的产业ID,标的ID
- e = cygx.DeleteCygxResourceDataGroup(sourceId, source)
- if e != nil {
- err = errors.New("DeleteCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- } else {
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxReportSelectionBySourceAndId(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- var resourceDataId int
- publishDate := time.Now().Format(utils.FormatDateTime)
- item := new(cygx.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- //分析师电话会(C类)
- item.SearchTag = ""
- item.PublishDate = publishDate
- item.ChartPermissionId = activityInfo.ChartPermissionId
- item.CreateTime = time.Now()
- if totalData == 0 {
- newId, e := cygx.AddCygxResourceData(item)
- if e != nil {
- err = errors.New("AddCygxResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = int(newId)
- } else {
- e = cygx.UpdateResourceDataByItem(item)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- sourceDetail, e := cygx.GetCygxResourceDataByIdAndSource(sourceId, source)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = sourceDetail.Id
- }
- //建立首页资源表,与产业的关系
- industrialList, e := cygx.GetIndustrialActivityGroupManagementList(sourceId, 2)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetIndustrialActivityGroupManagementList, Err: " + e.Error() + "activityId:" + strconv.Itoa(sourceId))
- return
- }
- var industrialItems []*cygx.CygxResourceDataIndustrialGroupManagement
- for _, v := range industrialList {
- var industrialItem = new(cygx.CygxResourceDataIndustrialGroupManagement)
- industrialItem.SourceId = sourceId
- industrialItem.Source = source
- industrialItem.IndustrialManagementId = v.IndustrialManagementId
- industrialItem.ResourceDataId = resourceDataId
- industrialItem.CreateTime = time.Now()
- industrialItems = append(industrialItems, industrialItem)
- }
- //建立首页资源表,与标的 的关系
- subjectList, e := cygx.GetSubjectArticleGroupManagementList(sourceId)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetSubjectArticleGroupManagementList, Err: " + e.Error() + "sourceId:" + strconv.Itoa(sourceId))
- return
- }
- var subjectItems []*cygx.CygxResourceDataIndustrialGroupSubject
- for _, v := range subjectList {
- var subjectItem = new(cygx.CygxResourceDataIndustrialGroupSubject)
- subjectItem.SourceId = sourceId
- subjectItem.Source = source
- subjectItem.IndustrialSubjectId = v.IndustrialSubjectId
- subjectItem.ResourceDataId = resourceDataId
- subjectItem.CreateTime = time.Now()
- subjectItems = append(subjectItems, subjectItem)
- }
- //插入关联信息
- e = cygx.AddCygxResourceDataGroup(sourceId, source, industrialItems, subjectItems)
- if e != nil {
- err = errors.New("AddCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- }
- return
- }
- // 更新文章
- func UpdateArticleResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新文章 失败,UpdateArticleResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_ARTICLE
- var condition string
- var pars []interface{}
- condition = ` AND publish_status = 1 AND article_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetCygxArticleCount(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: " + e.Error())
- return
- }
- //删除 cygx_resource_data 表关联的产业ID,标的ID
- e = cygx.DeleteCygxResourceDataGroup(sourceId, source)
- if e != nil {
- err = errors.New("DeleteCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- } else {
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxReportSelectionBySourceAndId(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- detail, e := cygx.GetArticleDetailByArticleId(sourceId)
- if e != nil {
- err = errors.New("GetCygxReportSelectionInfoById, Err: " + e.Error())
- return
- }
- var resourceDataId int
- publishDate := time.Now().Format(utils.FormatDateTime)
- item := new(cygx.CygxResourceData)
- if detail.ArticleTypeId > 0 {
- item.SearchTag = detail.ArticleTypeName // 研选类型名称
- item.ChartPermissionId = utils.CHART_PERMISSION_ID_YANXUAN
- } else {
- item.SearchTag = detail.MatchTypeName
- //获取文章分类详情
- detailCategory, _ := cygx.GetCygxReportMappingCelueMaxDetailByCategoryId(detail.CategoryId)
- if detailCategory != nil {
- item.ChartPermissionId = detailCategory.ChartPermissionId
- }
- }
- item.SourceId = sourceId
- item.Source = source
- item.PublishDate = publishDate
- item.CreateTime = time.Now()
- if totalData == 0 {
- newId, e := cygx.AddCygxResourceData(item)
- if e != nil {
- err = errors.New("AddCygxResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = int(newId)
- } else {
- e = cygx.UpdateResourceDataByItem(item)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- sourceDetail, e := cygx.GetCygxResourceDataByIdAndSource(sourceId, source)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = sourceDetail.Id
- }
- //建立首页资源表,与产业的关系
- industrialList, e := cygx.GetIndustrialArticleGroupManagementList(sourceId)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetIndustrialArticleGroupManagementList, Err: " + e.Error() + "sourceId:" + strconv.Itoa(sourceId))
- return
- }
- var industrialItems []*cygx.CygxResourceDataIndustrialGroupManagement
- for _, v := range industrialList {
- var industrialItem = new(cygx.CygxResourceDataIndustrialGroupManagement)
- industrialItem.SourceId = sourceId
- industrialItem.Source = source
- industrialItem.IndustrialManagementId = v.IndustrialManagementId
- industrialItem.ResourceDataId = resourceDataId
- industrialItem.CreateTime = time.Now()
- industrialItems = append(industrialItems, industrialItem)
- }
- //建立首页资源表,与标的 的关系
- subjectList, e := cygx.GetSubjectArticleGroupManagementList(sourceId)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetSubjectArticleGroupManagementList, Err: " + e.Error() + "sourceId:" + strconv.Itoa(sourceId))
- return
- }
- var subjectItems []*cygx.CygxResourceDataIndustrialGroupSubject
- for _, v := range subjectList {
- var subjectItem = new(cygx.CygxResourceDataIndustrialGroupSubject)
- subjectItem.SourceId = sourceId
- subjectItem.Source = source
- subjectItem.IndustrialSubjectId = v.IndustrialSubjectId
- subjectItem.ResourceDataId = resourceDataId
- subjectItem.CreateTime = time.Now()
- subjectItems = append(subjectItems, subjectItem)
- }
- //插入关联信息
- e = cygx.AddCygxResourceDataGroup(sourceId, source, industrialItems, subjectItems)
- if e != nil {
- err = errors.New("AddCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- }
- return
- }
- // 更新产品内测
- func UpdateProductInteriorResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新产品内测 失败,UpdateProductInteriorResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_PRODUCTINTERIOR
- var condition string
- var pars []interface{}
- condition = ` AND visible_range = 1 AND product_interior_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetCygxProductInteriorCount(condition, pars)
- if e != nil {
- err = errors.New("GetCygxReportSelection, Err: " + e.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = cygx.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + e.Error())
- return
- }
- //删除 cygx_resource_data 表关联的产业ID,标的ID
- e = cygx.DeleteCygxResourceDataGroup(sourceId, source)
- if e != nil {
- err = errors.New("DeleteCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- } else {
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxReportSelectionBySourceAndId(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- detail, e := cygx.GetCygxProductInteriorDetail(sourceId)
- if e != nil {
- err = errors.New("GetCygxReportSelectionInfoById, Err: " + err.Error())
- return
- }
- mapMatchTypeName := GetCygxReportMappingCygxListMap() //报告匹配类型
- var resourceDataId int
- publishDate := time.Now().Format(utils.FormatDateTime)
- item := new(cygx.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- item.SearchTag = mapMatchTypeName[detail.MatchTypeId]
- item.PublishDate = publishDate
- item.ChartPermissionId = detail.ChartPermissionId
- item.CreateTime = time.Now()
- if totalData == 0 {
- newId, e := cygx.AddCygxResourceData(item)
- if e != nil {
- err = errors.New("AddCygxResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = int(newId)
- } else {
- e = cygx.UpdateResourceDataByItem(item)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- sourceDetail, e := cygx.GetCygxResourceDataByIdAndSource(sourceId, source)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = sourceDetail.Id
- }
- //建立首页资源表,与产业的关系
- industrialList, e := cygx.GetProductInteriorIndustrialGroupManagementList(sourceId)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetIndustrialArticleGroupManagementList, Err: " + e.Error() + "sourceId:" + strconv.Itoa(sourceId))
- return
- }
- var industrialItems []*cygx.CygxResourceDataIndustrialGroupManagement
- for _, v := range industrialList {
- var industrialItem = new(cygx.CygxResourceDataIndustrialGroupManagement)
- industrialItem.SourceId = sourceId
- industrialItem.Source = source
- industrialItem.IndustrialManagementId = v.IndustrialManagementId
- industrialItem.ResourceDataId = resourceDataId
- industrialItem.CreateTime = time.Now()
- industrialItems = append(industrialItems, industrialItem)
- }
- //建立首页资源表,与标的 的关系
- subjectList, e := cygx.GetProductInteriorIndustrialGroupSubjecttList(sourceId)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetSubjectArticleGroupManagementList, Err: " + e.Error() + "sourceId:" + strconv.Itoa(sourceId))
- return
- }
- var subjectItems []*cygx.CygxResourceDataIndustrialGroupSubject
- for _, v := range subjectList {
- var subjectItem = new(cygx.CygxResourceDataIndustrialGroupSubject)
- subjectItem.SourceId = sourceId
- subjectItem.Source = source
- subjectItem.IndustrialSubjectId = v.IndustrialSubjectId
- subjectItem.ResourceDataId = resourceDataId
- subjectItem.CreateTime = time.Now()
- subjectItems = append(subjectItems, subjectItem)
- }
- //插入关联信息
- e = cygx.AddCygxResourceDataGroup(sourceId, source, industrialItems, subjectItems)
- if e != nil {
- err = errors.New("AddCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- }
- return
- }
- // 更新晨会精华
- func UpdateMeetingreviewchaptResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新产品内测 失败,UpdateMeetingreviewchaptResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_MEETINGREVIEWCHAPT
- total, e := cygx.GetCygxMorningMeetingReviewChapterCount(sourceId)
- if e != nil {
- err = errors.New("GetCygxReportSelection, Err: " + e.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = cygx.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + e.Error())
- return
- }
- //删除 cygx_resource_data 表关联的产业ID,标的ID
- e = cygx.DeleteCygxResourceDataGroup(sourceId, source)
- if e != nil {
- err = errors.New("DeleteCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- } else {
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxReportSelectionBySourceAndId(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- detail, e := cygx.GetCygxMorningMeetingReviewChapterDetail(sourceId)
- if e != nil {
- err = errors.New("GetCygxMorningMeetingReviewChapterDetail" + e.Error())
- return
- }
- var resourceDataId int
- publishDate := time.Now().Format(utils.FormatDateTime)
- item := new(cygx.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- item.SearchTag = "晨会精华"
- item.PublishDate = publishDate
- item.ChartPermissionId = detail.ChartPermissionId
- item.CreateTime = time.Now()
- if totalData == 0 {
- newId, e := cygx.AddCygxResourceData(item)
- if e != nil {
- err = errors.New("AddCygxResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = int(newId)
- } else {
- e = cygx.UpdateResourceDataByItem(item)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- sourceDetail, e := cygx.GetCygxResourceDataByIdAndSource(sourceId, source)
- if e != nil {
- err = errors.New("UpdateResourceData, Err: " + e.Error())
- return
- }
- resourceDataId = sourceDetail.Id
- }
- var condition string
- var pars []interface{}
- condition = " AND industrial_management_id = ? "
- pars = append(pars, detail.IndustryId)
- //建立首页资源表,与产业的关系
- industrialList, e := cygx.GetTopOneMonthArtReadNumIndustryAll(condition, pars)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetTopOneMonthArtReadNumIndustryAll, Err: " + e.Error() + "sourceId:" + strconv.Itoa(sourceId))
- return
- }
- var industrialItems []*cygx.CygxResourceDataIndustrialGroupManagement
- for _, v := range industrialList {
- var industrialItem = new(cygx.CygxResourceDataIndustrialGroupManagement)
- industrialItem.SourceId = sourceId
- industrialItem.Source = source
- industrialItem.IndustrialManagementId = v.IndustrialManagementId
- industrialItem.ResourceDataId = resourceDataId
- industrialItem.CreateTime = time.Now()
- industrialItems = append(industrialItems, industrialItem)
- }
- //return
- var subjectItems []*cygx.CygxResourceDataIndustrialGroupSubject
- //晨会精华如果关联的标的就做查询
- if detail.IndustrialSubjectIds != "" {
- condition = ""
- pars = make([]interface{}, 0)
- condition = " AND industrial_subject_id IN (" + detail.IndustrialSubjectIds + ") "
- //建立首页资源表,与标的 的关系
- subjectList, e := cygx.GetCygxIndustrialSubjectListCondition(condition, pars)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetCygxIndustrialSubjectListCondition, Err: " + e.Error() + "sourceId:" + strconv.Itoa(sourceId))
- return
- }
- for _, v := range subjectList {
- var subjectItem = new(cygx.CygxResourceDataIndustrialGroupSubject)
- subjectItem.SourceId = sourceId
- subjectItem.Source = source
- subjectItem.IndustrialSubjectId = v.IndustrialSubjectId
- subjectItem.ResourceDataId = resourceDataId
- subjectItem.CreateTime = time.Now()
- subjectItems = append(subjectItems, subjectItem)
- }
- }
- //插入关联信息
- e = cygx.AddCygxResourceDataGroup(sourceId, source, industrialItems, subjectItems)
- if e != nil {
- err = errors.New("AddCygxResourceDataGroup, Err: " + e.Error())
- return
- }
- }
- return
- }
- // 更新报告精选(重点公司)
- func UpdateReportSelectionResourceData(sourceId int) {
- var 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 AND article_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetCygxReportSelection(condition, pars)
- if e != nil {
- err = errors.New("GetCygxReportSelection, 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.GetCygxReportSelectionBySourceAndId(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- detail, e := cygx.GetCygxReportSelectionInfoById(sourceId)
- if e != nil {
- err = errors.New("GetCygxReportSelectionInfoById, Err: " + e.Error())
- return
- }
- publishDate := detail.PublishDate
- item := new(cygx.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- item.SearchTag = "重点公司"
- 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
- }
- // 更新本周研究汇总
- func UpdateResearchSummaryResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新本周研究汇总 失败,UpdateResearchSummaryResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_RESEARCHSUMMARY
- var condition string
- var pars []interface{}
- condition = ` AND visible_range = 1 AND article_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetCygxResearchSummary(condition, pars)
- if e != nil {
- err = errors.New("GetCygxResearchSummary, 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.GetCygxReportSelectionBySourceAndId(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.SearchTag = "本周研究汇总"
- 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
- }
- // 更新上周纪要汇总
- func UpdateMinutesSummaryResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新上周纪要汇总 失败,UpdateMinutesSummaryResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_MINUTESSUMMARY
- var condition string
- var pars []interface{}
- condition = ` AND visible_range = 1 AND article_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetCygxMinutesSummary(condition, pars)
- if e != nil {
- err = errors.New("GetCygxResearchSummary, 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.GetCygxReportSelectionBySourceAndId(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.SearchTag = "上周纪要汇总"
- 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
- }
- // 更新活动音频
- func UpdateActivityVoiceResourceData(sourceId int) {
- time.Sleep(1 * time.Second) // 添加1秒的延迟
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新更新活动音频 失败,UpdateActivityVoiceResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_ACTIVITYVOICE
- var condition string
- var pars []interface{}
- condition = ` AND activity_voice_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetCygxActivityVoiceCount(condition, pars)
- if e != nil {
- err = errors.New("GetCygxResearchSummary, Err: " + e.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = cygx.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + e.Error())
- return
- }
- } else {
- //获取音频详情
- voiceDetail, e := cygx.GetCygxActivityVoiceReqDetailByActivityVoiceId(sourceId)
- if e != nil {
- err = errors.New("GetCygxActivityVoiceReqDetail" + e.Error())
- return
- }
- activityId := voiceDetail.ActivityId
- //获取活动详情
- activityInfo, e := cygx.GetAddActivityInfoById(activityId)
- if e != nil {
- err = errors.New("GetAddActivityInfoById, Err: " + e.Error())
- return
- }
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxReportSelectionBySourceAndId(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
- //易董办会的分析师电话会,为路演回放
- if (activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 7) && activityInfo.IsYidongConduct == 1 {
- item.SearchTag = "路演回放"
- } else {
- item.SearchTag = "调研反馈"
- }
- item.PublishDate = publishDate
- item.ChartPermissionId = activityInfo.ChartPermissionId
- item.CreateTime = utils.StrDateToDate(activityInfo.ActivityTime)
- 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
- }
- // 更新活动视频
- func UpdateActivityVideoResourceData(sourceId int) {
- time.Sleep(1 * time.Second) // 添加1秒的延迟
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新更新活动视频 失败,UpdateActivityVideoResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_ACTIVITYVIDEO
- var condition string
- var pars []interface{}
- condition = ` AND v.video_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetActivityVideoCount(condition, pars)
- if e != nil {
- err = errors.New("GetCygxResearchSummary, Err: " + e.Error())
- return
- }
- //如果取消发布了就做删除处理
- if total == 0 {
- e = cygx.DeleteResourceData(sourceId, source)
- if e != nil {
- err = errors.New("DeleteResourceData, Err: " + e.Error())
- return
- }
- } else {
- videoDetail, e := cygx.GetCygxActivityVideoReqDetailByVideoId(sourceId)
- if e != nil {
- err = errors.New("GetCygxActivityVoiceReqDetail" + e.Error())
- return
- }
- activityId := videoDetail.ActivityId
- activityInfo, e := cygx.GetAddActivityInfoById(activityId)
- if e != nil {
- err = errors.New("GetAddActivityInfoById, Err: " + e.Error())
- return
- }
- //判断是否存在,如果不存在就新增,存在就更新
- totalData, e := cygx.GetCygxReportSelectionBySourceAndId(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
- //易董办会的分析师电话会,为路演回放
- if (activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 7) && activityInfo.IsYidongConduct == 1 {
- item.SearchTag = "路演回放"
- } else {
- item.SearchTag = "调研反馈"
- }
- item.PublishDate = publishDate
- item.ChartPermissionId = activityInfo.ChartPermissionId
- item.CreateTime = utils.StrDateToDate(activityInfo.ActivityTime)
- 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
- }
- // 更新产业视频
- func UpdateMicroRoadshowResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("err:", err)
- go alarm_msg.SendAlarmMsg("更新产业视频 失败,UpdateMicroRoadshowResourceData Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId), 3)
- }
- }()
- var source = utils.CYGX_OBJ_ROADSHOW
- var condition string
- var pars []interface{}
- condition = ` AND publish_status = 1 AND video_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetMicroRoadshowVideoListCount(condition, pars)
- if e != nil {
- err = errors.New("GetMicroRoadshowVideoListCount, 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.GetCygxReportSelectionBySourceAndId(sourceId, source)
- if e != nil {
- err = errors.New("GetCygxReportSelectionBySourceAndId, Err: " + e.Error())
- return
- }
- detail, e := cygx.GetMicroRoadshowVideoByVideoId(sourceId)
- 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.SearchTag = ""
- item.PublishDate = publishDate
- item.ChartPermissionId = detail.ChartPermissionId
- 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
- }
- //func init() {
- // UpdateAskserieVideoResourceData(7)
- //}
- // 更新问答系列 写入首页最新 cygx_resource_data 表
- func UpdateAskserieVideoResourceData(sourceId int) {
- var err error
- defer func() {
- if err != nil {
- fmt.Println(err)
- go alarm_msg.SendAlarmMsg(fmt.Sprint("更新问答系列ourceId: ", sourceId, err.Error()), 2)
- }
- }()
- var source = utils.CYGX_OBJ_ASKSERIEVIDEO
- var condition string
- var pars []interface{}
- condition = ` AND publish_status = 1 AND askserie_video_id = ? `
- pars = append(pars, sourceId)
- total, e := cygx.GetCygxAskserieVideoCount(condition, pars)
- if e != nil {
- err = errors.New("GetCygxAskserieVideoCount, 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
- }
- detail, e := cygx.GetCygxAskserieVideoDetail(sourceId)
- if e != nil {
- err = errors.New("GetCygxAskserieVideoDetail, Err: " + e.Error())
- return
- }
- publishDate := time.Now().Format(utils.FormatDateTime)
- item := new(cygx.CygxResourceData)
- item.SourceId = sourceId
- item.Source = source
- item.PublishDate = publishDate
- item.ChartPermissionId = detail.ChartPermissionId
- 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
- }
- func init23() {
- //var condition string
- //var pars []interface{}
- //
- //{
- // //活动
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_ACTIVITY)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // UpdateActivityResourceData(v.SourceId)
- // }
- //}
- //12.4
- //{
- // //活动
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_ACTIVITY)
- // if err != nil {
- // fmt.Println(err)
- // }
- //
- // for _, v := range list {
- // detail, e := cygx.GetAddActivityInfoById(v.SourceId)
- // if e != nil {
- // err = errors.New("GetCygxReportSelectionInfoById, Err: " + e.Error())
- // fmt.Println(err)
- // return
- // }
- // item := new(cygx.CygxResourceData)
- // item.SourceId = v.SourceId
- // item.Source = utils.CYGX_OBJ_ACTIVITY
- // item.ChartPermissionId = detail.ChartPermissionId
- // fmt.Println(v.Source)
- // err = cygx.UpdateChartPermissionIdResourceDataByItem(item)
- // if err != nil {
- // fmt.Println(err)
- // return
- // }
- // }
- //}
- //{
- // //专项调研活动
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_ACTIVITYSPECIAL)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // UpdateActivitySpecialResourceData(v.SourceId)
- // }
- //}
- //{
- // //文章
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_ARTICLE)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // UpdateArticleResourceData(v.SourceId)
- // }
- //}
- //{
- // //文章//12.4
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_ARTICLE)
- // if err != nil {
- // fmt.Println(err)
- // return
- // }
- // for _, v := range list {
- // detail, e := cygx.GetArticleDetailByArticleId(v.SourceId)
- // if e != nil {
- // err = errors.New("GetCygxReportSelectionInfoById, Err: " + e.Error())
- // fmt.Println(err)
- // return
- // }
- //
- // item := new(cygx.CygxResourceData)
- // if detail.ArticleTypeId > 0 {
- // //item.SearchTag = detail.ArticleTypeName // 研选类型名称
- // item.ChartPermissionId = utils.CHART_PERMISSION_ID_YANXUAN
- // } else {
- // //item.SearchTag = detail.MatchTypeName
- // //获取文章分类详情
- // detailCategory, _ := cygx.GetCygxReportMappingCelueMaxDetailByCategoryId(detail.CategoryId)
- // if detailCategory != nil {
- // item.ChartPermissionId = detailCategory.ChartPermissionId
- // }else{
- // detailCategoryTwo, _ := cygx.GetCygxReportMappingCelueMaxDetailByCategoryId(detail.CategoryIdTwo)
- // if detailCategoryTwo != nil {
- // item.ChartPermissionId = detailCategoryTwo.ChartPermissionId
- // }
- // }
- // }
- // item.SourceId = v.SourceId
- // item.Source = utils.CYGX_OBJ_ARTICLE
- // fmt.Println(v.Source)
- // err = cygx.UpdateChartPermissionIdResourceDataByItem(item)
- // if err != nil {
- // fmt.Println(err)
- // return
- // }
- // }
- //}
- //{
- // //产品内测
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_PRODUCTINTERIOR)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // UpdateProductInteriorResourceData(v.SourceId)
- // }
- //}
- //
- //{
- // //晨会精华
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_MEETINGREVIEWCHAPT)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // UpdateMeetingreviewchaptResourceData(v.SourceId)
- // }
- //}
- //
- //{
- // //重点公司
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_REPORTSELECTION)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // //UpdateReportSelectionResourceData(v.SourceId)
- // }
- //}
- //
- //{
- // //更新本周研究汇总
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_RESEARCHSUMMARY)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // //UpdateResearchSummaryResourceData(v.SourceId)
- // }
- //}
- //
- //{
- // //更新本周研究汇总
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_MINUTESSUMMARY)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // //UpdateMinutesSummaryResourceData(v.SourceId)
- // }
- //}
- //{
- // //活动音频
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_ACTIVITYVOICE)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // UpdateActivityVoiceResourceData(v.SourceId)
- // }
- //}
- //{
- // //活动视频
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_ACTIVITYVIDEO)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // UpdateActivityVideoResourceData(v.SourceId)
- // }
- //}
- //{
- // //活动音频
- // list, err := cygx.GetCygxResourceDataListBysource(utils.CYGX_OBJ_ROADSHOW)
- // if err != nil {
- // fmt.Println(err)
- // }
- // for _, v := range list {
- // fmt.Println(v.Source)
- // UpdateMicroRoadshowResourceData(v.SourceId)
- // }
- //}
- }
|