hz_crm_api/services/cygx/industrial_management.go

package cygx

import (
	"errors"
	"fmt"
	"hongze/hz_crm_api/models"
	"hongze/hz_crm_api/models/cygx"
	"hongze/hz_crm_api/services/alarm_msg"
	"hongze/hz_crm_api/utils"
	"strconv"
	"time"
)

//func init() {
//	GetIndustrialManagementArticleNewPublishData(607)
//}

// 批量修改获取产业关联文章的最新发布时间
func GetIndustrialManagementArticleNewPublishData(industrialManagementId int) (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			go alarm_msg.SendAlarmMsg("批量修改获取产业关联文章的最新发布时间GetIndustrialManagementArticleNewPublishData ErrMsg:"+err.Error(), 2)

		}
	}()
	articleNewPublishDataList, e := cygx.GetIndustrialManagementArticleNewPublishData()
	if e != nil {
		err = errors.New("获取客户剩余报名次数失败 GetIndustrialManagementArticleNewPublishData, Err: " + e.Error())
		return
	}
	mapUPdateTime := make(map[int]string)
	var industrialManagementIds []int
	for _, v := range articleNewPublishDataList {
		if v.IndustrialManagementId != industrialManagementId {
			continue
		}
		if v.IndustrialManagementId > 0 {
			industrialManagementIds = append(industrialManagementIds, v.IndustrialManagementId)
		}
		mapUPdateTime[v.IndustrialManagementId] = v.UpdateTime
	}
	if len(industrialManagementIds) == 0 {
		return
	}
	//时间线的更新时间
	listtimelinePublishdate, err := cygx.GetTimeLineReportIndustrialPublishdateList(industrialManagementIds)
	if err != nil && err.Error() != utils.ErrNoRow() {
		return
	}
	for _, v := range listtimelinePublishdate {
		if v.IndustrialManagementId == industrialManagementId {
			if utils.StrTimeToTime(v.PublishDate).After(utils.StrTimeToTime(mapUPdateTime[v.IndustrialManagementId])) {
				mapUPdateTime[v.IndustrialManagementId] = v.PublishDate
			}
		}
	}
	err = cygx.UpdateIndustrialManagementArticleNewPublishData(mapUPdateTime)
	return
}

// AddUserIndustryFllowByNewId 出现了新的产业，给选择推送方式的用户自动添加关注
func AddUserIndustryFllowByNewId(industrialManagementId int) (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			go alarm_msg.SendAlarmMsg("出现了新的产业，给选择推送方式的用户自动添加关注。失败 ErrMsg:"+err.Error()+"industrialManagementId"+strconv.Itoa(industrialManagementId), 2)
		}
	}()
	//获取小助手提交过勾选项的用户
	var condition string
	condition = " AND  is_refuse = 0 "
	chooseSendtList, e := cygx.GetCygxXzsChooseSend(condition)
	if e != nil {
		err = errors.New("GetCygxXzsChooseSend , Err: " + e.Error())
		return
	}
	var mobiles []string
	for _, v := range chooseSendtList {
		if v.Mobile != "" {
			mobiles = append(mobiles, v.Mobile)
		}
	}

	userList, e := models.GetWxUserListByUserMobileHaveCompany(mobiles)
	if e != nil {
		err = errors.New("GetWxUserListByUserMobileHaveCompany" + e.Error())
		return
	}
	var industryFllowItems []*cygx.CygxIndustryFllow
	for _, vUser := range userList {
		item := new(cygx.CygxIndustryFllow)
		item.IndustrialManagementId = industrialManagementId
		item.UserId = vUser.UserId
		item.Email = vUser.Email
		item.Mobile = vUser.Mobile
		item.RealName = vUser.RealName
		item.CompanyId = vUser.CompanyId
		item.CompanyName = vUser.CompanyName
		item.Source = 3 // 通过程序或者管理员手动添加的关注
		item.Type = 1
		item.CreateTime = time.Now()
		item.ModifyTime = time.Now()
		industryFllowItems = append(industryFllowItems, item)
	}
	e = cygx.AddCygxIndustryFllowMulti(industryFllowItems)
	if e != nil {
		err = errors.New("AddCygxIndustryFllowMulti , Err: " + e.Error())
		return
	}

	//更新用户关注产业的标签
	for _, v := range industryFllowItems {
		IndustryFllowUserLabelLogAdd(v.IndustrialManagementId, 0, v.UserId)
	}
	return
}