12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151 |
- package services
- import (
- "encoding/json"
- "errors"
- "fmt"
- "hongze/hongze_cygx/models"
- "hongze/hongze_cygx/models/company"
- "hongze/hongze_cygx/models/rai_serve"
- "hongze/hongze_cygx/models/roadshow"
- "hongze/hongze_cygx/utils"
- "strings"
- "time"
- )
- //权益服务统计
- //func init() {
- // UpdateRaiServeCompany()
- //}
- // 更新现有的权益服务客户数据
- func UpdateRaiServeCompany() (err error) {
- defer func() {
- if err != nil {
- fmt.Println(err)
- go utils.SendAlarmMsg("更新现有的权益服务客户数据失败 UpdateRaiServeCompany:"+err.Error(), 2)
- }
- }()
- var condition string
- var pars []interface{}
- condition = ` AND p.product_id = 2 AND (p.group_id = ? OR p.share_group_id = ?) `
- pars = append(pars, utils.RAI_SERVE_GROUP_ID, utils.RAI_SERVE_GROUP_ID)
- listCompanyProduct, e := company.GetCompanyProductAndCompanyListByCondition(condition, pars)
- if e != nil {
- err = errors.New("GetCompanyProductListByCondition, Err: " + e.Error())
- return
- }
- var items []*rai_serve.CygxRaiServeCompany
- for _, v := range listCompanyProduct {
- //mapNewCompanyId[v.CompanyId] = true
- //if mapOldCompanyId[v.CompanyId] {
- // continue
- //}
- item := new(rai_serve.CygxRaiServeCompany)
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.CreateTime = time.Now()
- item.SellerId = v.SellerId
- item.SellerName = v.SellerName
- item.StartDate = v.StartDate
- item.EndDate = v.EndDate
- item.ShareSeller = v.ShareSeller
- item.ShareSellerId = v.ShareSellerId
- item.Status = v.Status
- item.GroupId = v.GroupId
- item.ShareGroupId = v.ShareGroupId
- items = append(items, item)
- }
- //先删除老的再添加新的
- e = rai_serve.AddCygxRaiServeCompanyMulti(items)
- if e != nil {
- err = errors.New("AddCygxRaiServeCompanyMulti, Err: " + e.Error())
- return
- }
- return
- }
- // GetCompanyContractPermissionNameMapById 获取合并之后的合同所对应的权限种类名称
- func GetCompanyContractPermissionNameMapById(companyContractIds []int) (mapContractResp map[int]string, err error) {
- //return
- lenArr := len(companyContractIds)
- if lenArr == 0 {
- return
- }
- var condition string
- var pars []interface{}
- condition += " AND company_contract_id IN (" + utils.GetOrmInReplace(lenArr) + ")"
- pars = append(pars, companyContractIds)
- //companyContractList, e := company.GetCompanyContractList(condition, pars)
- //if e != nil && e.Error() != utils.ErrNoRow() {
- // err = errors.New("GetCompanyContractList, Err: " + e.Error())
- // return
- //}
- permissionList, e := models.GetChartPermissionList()
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetChartPermissionList, Err: " + e.Error())
- return
- }
- mappermissionName := make(map[int]string)
- for _, v := range permissionList {
- if v.ProductId == 2 {
- mappermissionName[v.ChartPermissionId] = v.Remark
- }
- }
- mapContractIdPerssion := make(map[int]string) //单个合同ID所对应的套餐或者权限名称
- //for _, v := range companyContractList {
- // if v.RaiPackageType == 1 {
- // mapContractIdPerssion[v.CompanyContractId] = "70w套餐,"
- // }
- // if v.RaiPackageType == 2 {
- // mapContractIdPerssion[v.CompanyContractId] = "45w套餐,"
- // }
- //}
- companyContractPermissionList, e := company.GetCompanyContractPermissionList(condition, pars)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetCompanyContractPermissionList, Err: " + e.Error())
- return
- }
- mapIsUpgrade := make(map[string]bool) //合同ID对应的行业是否有升级
- for _, v := range companyContractPermissionList {
- //如果开通的不是整个套餐,那么就做单独的子权限处理
- if strings.Count(mapContractIdPerssion[(v.CompanyContractId)], "w套餐") == 0 {
- if v.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
- if v.ExpensiveYx == 1 {
- mapContractIdPerssion[(v.CompanyContractId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(5w),"
- } else if v.ExpensiveYx == 2 {
- mapContractIdPerssion[(v.CompanyContractId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(10w),"
- } else {
- mapContractIdPerssion[(v.CompanyContractId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + ","
- }
- } else {
- mapContractIdPerssion[(v.CompanyContractId)] += mappermissionName[v.ChartPermissionId] + ","
- if v.IsUpgrade == 1 {
- //合同ID,权限名称形成唯一的主键索引
- perssionName := mappermissionName[v.ChartPermissionId]
- perssionName = strings.Replace(perssionName, "(客观)", "", -1)
- perssionName = strings.Replace(perssionName, "(主观)", "", -1)
- mapIsUpgrade[fmt.Sprint(v.CompanyContractId, "perssionName", perssionName)] = true
- }
- }
- } else {
- if v.ChartPermissionId == utils.ZHUAN_JIA_ID {
- mapContractIdPerssion[(v.CompanyContractId)] += utils.ZHUAN_JIA_NAME + ","
- }
- if v.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
- if v.ExpensiveYx == 1 {
- mapContractIdPerssion[(v.CompanyContractId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(5w),"
- } else if v.ExpensiveYx == 2 {
- mapContractIdPerssion[(v.CompanyContractId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(10w),"
- } else {
- mapContractIdPerssion[(v.CompanyContractId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + ","
- }
- }
- if v.ChartPermissionId == utils.YAN_XUAN_KOU_DIAN_BAO_ID {
- mapContractIdPerssion[(v.CompanyContractId)] += utils.YAN_XUAN_KOU_DIAN_BAO_NAME + ","
- }
- }
- }
- //合并客观权限
- for k, v := range mapContractIdPerssion {
- perssionName := v
- if strings.Count(v, utils.YI_YAO_NAME) == 2 {
- perssionName = strings.Replace(perssionName, "医药(主观)", "医药", -1)
- perssionName = strings.Replace(perssionName, "医药(客观)", "", -1)
- }
- if strings.Count(v, utils.XIAO_FEI_NAME) == 2 {
- perssionName = strings.Replace(perssionName, "消费(主观)", "消费", -1)
- perssionName = strings.Replace(perssionName, "消费(客观)", "", -1)
- }
- if strings.Count(v, utils.KE_JI_NAME) == 2 {
- perssionName = strings.Replace(perssionName, "科技(主观)", "科技", -1)
- perssionName = strings.Replace(perssionName, "科技(客观)", "", -1)
- }
- if strings.Count(v, utils.ZHI_ZAO_NAME) == 2 {
- perssionName = strings.Replace(perssionName, "智造(主观)", "智造", -1)
- perssionName = strings.Replace(perssionName, "智造(客观)", "", -1)
- }
- perssionName = strings.TrimRight(perssionName, ",")
- mapContractIdPerssion[k] = perssionName
- }
- mapContractResp = make(map[int]string, 0)
- //过滤多余的","
- for k, v := range mapContractIdPerssion {
- sliceName := strings.Split(v, ",")
- var nameArr []string
- for _, vName := range sliceName {
- if vName == "" {
- continue
- }
- if mapIsUpgrade[fmt.Sprint(k, "perssionName", vName)] {
- vName += "(升级)"
- }
- nameArr = append(nameArr, vName)
- }
- mapContractResp[k] = strings.Join(nameArr, ",")
- }
- return
- }
- // 根据公司ID获取目前行业所对应的正式权限
- func GetCompanyReportPermissionNameMapByCompanyId(companyIds []int) (mapContractResp map[int]string, err error) {
- lenArr := len(companyIds)
- if lenArr == 0 {
- return
- }
- var condition string
- var pars []interface{}
- condition += " AND company_id IN (" + utils.GetOrmInReplace(lenArr) + ") AND product_id = 2 AND status = '正式' "
- pars = append(pars, companyIds)
- permissionList, e := models.GetChartPermissionList()
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetChartPermissionList, Err: " + e.Error())
- return
- }
- mappermissionName := make(map[int]string)
- for _, v := range permissionList {
- if v.ProductId == 2 {
- mappermissionName[v.ChartPermissionId] = v.Remark
- }
- }
- mapContractIdPerssion := make(map[int]string) //单个合同ID所对应的套餐或者权限名称
- companyReportPermissionList, e := models.GetCompanyReportPermissionList(condition, pars)
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetCompanyReportPermissionList, Err: " + e.Error())
- return
- }
- mapIsUpgrade := make(map[string]bool) //合同ID对应的行业是否有升级
- for _, v := range companyReportPermissionList {
- //如果开通的不是整个套餐,那么就做单独的子权限处理
- if strings.Count(mapContractIdPerssion[(v.CompanyId)], "w套餐") == 0 {
- if v.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
- if v.ExpensiveYx == 1 {
- mapContractIdPerssion[(v.CompanyId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(5w),"
- } else if v.ExpensiveYx == 2 {
- mapContractIdPerssion[(v.CompanyId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(10w),"
- } else {
- mapContractIdPerssion[(v.CompanyId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + ","
- }
- } else {
- mapContractIdPerssion[(v.CompanyId)] += mappermissionName[v.ChartPermissionId] + ","
- if v.IsUpgrade == 1 {
- //合同ID,权限名称形成唯一的主键索引
- perssionName := mappermissionName[v.ChartPermissionId]
- perssionName = strings.Replace(perssionName, "(客观)", "", -1)
- perssionName = strings.Replace(perssionName, "(主观)", "", -1)
- mapIsUpgrade[fmt.Sprint(v.CompanyId, "perssionName", perssionName)] = true
- }
- }
- } else {
- if v.ChartPermissionId == utils.ZHUAN_JIA_ID {
- mapContractIdPerssion[(v.CompanyId)] += utils.ZHUAN_JIA_NAME + ","
- }
- if v.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
- if v.ExpensiveYx == 1 {
- mapContractIdPerssion[(v.CompanyId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(5w),"
- } else if v.ExpensiveYx == 2 {
- mapContractIdPerssion[(v.CompanyId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(10w),"
- } else {
- mapContractIdPerssion[(v.CompanyId)] += utils.CHART_PERMISSION_NAME_MF_YANXUAN + ","
- }
- }
- if v.ChartPermissionId == utils.YAN_XUAN_KOU_DIAN_BAO_ID {
- mapContractIdPerssion[(v.CompanyId)] += utils.YAN_XUAN_KOU_DIAN_BAO_NAME + ","
- }
- }
- }
- //合并客观权限
- for k, v := range mapContractIdPerssion {
- perssionName := v
- if strings.Count(v, utils.YI_YAO_NAME) == 2 {
- perssionName = strings.Replace(perssionName, "医药(主观)", "医药", -1)
- perssionName = strings.Replace(perssionName, "医药(客观)", "", -1)
- }
- if strings.Count(v, utils.XIAO_FEI_NAME) == 2 {
- perssionName = strings.Replace(perssionName, "消费(主观)", "消费", -1)
- perssionName = strings.Replace(perssionName, "消费(客观)", "", -1)
- }
- if strings.Count(v, utils.KE_JI_NAME) == 2 {
- perssionName = strings.Replace(perssionName, "科技(主观)", "科技", -1)
- perssionName = strings.Replace(perssionName, "科技(客观)", "", -1)
- }
- if strings.Count(v, utils.ZHI_ZAO_NAME) == 2 {
- perssionName = strings.Replace(perssionName, "智造(主观)", "智造", -1)
- perssionName = strings.Replace(perssionName, "智造(客观)", "", -1)
- }
- perssionName = strings.TrimRight(perssionName, ",")
- mapContractIdPerssion[k] = perssionName
- }
- mapContractResp = make(map[int]string, 0)
- //过滤多余的","
- for k, v := range mapContractIdPerssion {
- sliceName := strings.Split(v, ",")
- var nameArr []string
- for _, vName := range sliceName {
- if vName == "" {
- continue
- }
- if mapIsUpgrade[fmt.Sprint(k, "perssionName", vName)] {
- vName += "(升级)"
- }
- nameArr = append(nameArr, vName)
- }
- mapContractResp[k] = strings.Join(nameArr, ",")
- }
- return
- }
- // Redis对列消息中的结构体
- type RaiServeBillRedis struct {
- Content string `comment:"服务内容说明"`
- UserId int `comment:"用户ID"`
- ComapnyId int `comment:"公司ID"`
- SourceId int `comment:"来源ID"`
- Source string `comment:"来源"`
- RegisterPlatform int `comment:"来源 1小程序,2:网页"`
- ViewTime time.Time `comment:"浏览时间"`
- }
- // 权益服务统计添加到Redis队列中
- func CygxRaiServeBillRedisAdd(content, source string, userId, comapnyId, sourceId, registerPlatform int, viewTime time.Time) (err error) {
- defer func() {
- if err != nil {
- fmt.Println(err)
- msg := fmt.Sprint("source:", source, "userId:", userId, "sourceId", sourceId)
- go utils.SendAlarmMsg("权益服务统计添加到Redis队列中,写入Redis队列消息失败 CygxRaiServeBillRedisAdd:"+err.Error()+msg, 2)
- }
- }()
- log := &rai_serve.RaiServeBillRedis{Content: content, Source: source, UserId: userId, ComapnyId: comapnyId, SourceId: sourceId, RegisterPlatform: registerPlatform, ViewTime: viewTime}
- if utils.Re == nil {
- err := utils.Rc.LPush(utils.CYGX_RAI_SERVE_BILL_KEY, log)
- if err != nil {
- fmt.Println("RaiServeBillRedis LPush Err:" + err.Error())
- }
- }
- return
- }
- // CygxRaiServeBillRedisAddReduce 处理权益服务统计
- func CygxRaiServeBillRedisAddReduce() (err error) {
- for {
- //SourceType int `description:"1:报名、 2:取消报名、3:活动编辑、4:活动发布,取消发布、5:活动到会。"`
- utils.Rc.Brpop(utils.CYGX_RAI_SERVE_BILL_KEY, func(b []byte) {
- var log rai_serve.RaiServeBillRedis
- if err := json.Unmarshal(b, &log); err != nil {
- fmt.Println("json unmarshal wrong!")
- go utils.SendAlarmMsg("处理权益服务统计Redis队列消息失败:"+err.Error()+string(b), 2)
- }
- //如果不是共享给 权益服务组的,则不处理
- taotalRaiServe, err := company.GetCompanyProductAaiServeCount(log.ComapnyId, utils.RAI_SERVE_GROUP_ID)
- if err != nil {
- go utils.SendAlarmMsg("处理权益服务统计Redis队列消息失败:GetCompanyProductAaiServeCount"+err.Error()+string(b), 2)
- }
- fmt.Println("taotaRaiServe", taotalRaiServe)
- if taotalRaiServe == 0 {
- return
- }
- //如果已经有记录了就不处理
- taotalSource, err := rai_serve.GetCygxRaiServeBillCountByUserAndSource(log.UserId, log.SourceId, log.Source)
- if err != nil {
- go utils.SendAlarmMsg("处理权益服务统计Redis队列消息失败:GetCygxRaiServeBillCountByUserAndSource"+err.Error()+string(b), 2)
- }
- if taotalSource > 0 {
- return
- }
- switch log.Source {
- case utils.CYGX_OBJ_YANXUANSPECIAL: //研选专栏阅读记录处理
- go RaiServeBillRedisAddReduceByYanxuanspecial(log)
- fmt.Println("研选专栏阅读记录处理")
- break
- default:
- fmt.Println(string(b))
- go utils.SendAlarmMsg("处理研选活动扣点处理Redis队列消息失败:"+string(b), 2)
- }
- })
- }
- }
- // 处理权益服务统计->研选阅读记录
- func RaiServeBillRedisAddReduceByYanxuanspecial(log rai_serve.RaiServeBillRedis) (err error) {
- source := log.Source
- userId := log.UserId
- sourceId := log.SourceId
- defer func() {
- if err != nil {
- go utils.SendAlarmMsg("用户报名活动扣点,处理Redis队列消息失败:"+err.Error()+fmt.Sprint("source:", source, "userId:", userId, "sourceId", sourceId), 2)
- }
- }()
- wxUser, e := models.GetWxUserItemByUserId(userId)
- if e != nil {
- err = errors.New("GetWxUserItemByUserId, Err: " + e.Error())
- return
- }
- item := new(rai_serve.CygxRaiServeBill)
- item.Content = log.Content
- item.ServeTypeId = 5
- item.ServeTypeName = "阅读uv"
- item.UserId = wxUser.UserId
- item.Mobile = wxUser.Mobile
- item.Email = wxUser.Email
- item.CompanyId = wxUser.CompanyId
- item.CompanyName = wxUser.CompanyName
- item.RealName = wxUser.RealName
- item.RegisterPlatform = log.RegisterPlatform
- item.ServeCount = 0.5
- if wxUser.IsMaker == 1 {
- item.IsKp = wxUser.IsMaker
- item.ServeCount = item.ServeCount * 3
- }
- item.SourceId = log.SourceId
- item.Source = log.Source
- item.CreateTime = time.Now()
- item.ViewTime = log.ViewTime.Format(utils.FormatDateTime)
- err = rai_serve.AddCygxRaiServeBill(item)
- return
- }
- //func init() {
- // UpdateWeekAvg()
- //}
- // 批量更新企业服务明细记录
- func UpdateCygxRaiServeBillByCompanyIds() (err error) {
- defer func() {
- if err != nil {
- fmt.Println(err)
- go utils.SendAlarmMsg("批量更新企业服务明细记录失败: UpdateCygxRaiServeBillByCompanyIds Err"+err.Error(), 2)
- }
- }()
- companyList, e := rai_serve.GetCygxRaiServeCompanyAllList()
- if e != nil {
- err = errors.New("GetCygxRaiServeCompanyAllList, Err: " + e.Error())
- return
- }
- var companyIds []int
- var items []*rai_serve.CygxRaiServeBill
- for _, v := range companyList {
- companyIds = append(companyIds, v.CompanyId)
- }
- lencompanyId := len(companyIds)
- listisMakeruser, e := models.GetWxUserisMakerByCompanyIds(companyIds)
- if e != nil {
- err = errors.New("GetWxUserisMakerByCompanyIds, Err: " + e.Error())
- return
- }
- mapUserMaker := make(map[int]bool)
- for _, v := range listisMakeruser {
- mapUserMaker[v.UserId] = true
- }
- fmt.Println(mapUserMaker)
- var condition string
- var pars []interface{}
- createTime := time.Now().AddDate(0, 0, -80) // 查询12周以内的数据
- condition = " AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND create_time > ? "
- pars = append(pars, companyIds, createTime)
- //研选专栏阅读记录内容
- {
- listYanxuanSpecialRecord, e := models.GetCygxYanxuanSpecialRecordRespListAll(condition+" GROUP BY user_id, yanxuan_special_id ORDER BY create_time ASC ", pars)
- if e != nil {
- err = errors.New("GetCygxYanxuanSpecialRecordRespListAll, Err: " + e.Error())
- return
- }
- var yanxuanspecialIds []int
- for _, v := range listYanxuanSpecialRecord {
- yanxuanspecialIds = append(yanxuanspecialIds, v.YanxuanSpecialId)
- }
- var conditionYanxuanSpecial string
- var parsYanxuanSpecial []interface{}
- conditionYanxuanSpecial += ` AND id IN (` + utils.GetOrmInReplace(len(yanxuanspecialIds)) + `) `
- parsYanxuanSpecial = append(parsYanxuanSpecial, yanxuanspecialIds)
- listYanxuanSpecial, e := models.GetYanxuanSpecialListBycondition(conditionYanxuanSpecial, parsYanxuanSpecial, 0, len(yanxuanspecialIds))
- if e != nil && e.Error() != utils.ErrNoRow() {
- err = errors.New("GetYanxuanSpecialListBycondition, Err: " + e.Error())
- return
- }
- mapYanxuanSpecialTitle := make(map[int]string)
- for _, v := range listYanxuanSpecial {
- mapYanxuanSpecialTitle[v.Id] = v.Title
- }
- //研选阅读明细
- var conditionBill string
- var parsBill []interface{}
- conditionBill = " AND source = 'yanxuanspecial' AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND view_time > ? "
- parsBill = append(parsBill, companyIds, createTime)
- listBillByYanxuanspecial, e := rai_serve.GetCygxRaiServeBillListAll(conditionBill, parsBill)
- if e != nil {
- err = errors.New("GetCygxRaiServeBillListAll, Err: " + e.Error())
- return
- }
- mapYanxuanspecialBill := make(map[string]bool)
- for _, v := range listBillByYanxuanspecial {
- mapYanxuanspecialBill[fmt.Sprint("UID_", v.UserId, "SID_", v.SourceId)] = true
- }
- for _, v := range listYanxuanSpecialRecord {
- if mapYanxuanspecialBill[fmt.Sprint("UID_", v.UserId, "SID_", v.YanxuanSpecialId)] { // 如果内容存在就不插入
- continue
- }
- item := new(rai_serve.CygxRaiServeBill)
- item.Content = mapYanxuanSpecialTitle[v.YanxuanSpecialId]
- item.ServeTypeId = 5
- item.ServeTypeName = "阅读uv"
- item.UserId = v.UserId
- item.Mobile = v.Mobile
- item.Email = v.Email
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.RealName = v.RealName
- item.RegisterPlatform = v.RegisterPlatform
- item.ServeCount = 0.5
- if mapUserMaker[v.UserId] {
- item.IsKp = 1
- item.ServeCount = item.ServeCount * 3
- }
- item.SourceId = v.YanxuanSpecialId
- item.Source = utils.CYGX_OBJ_YANXUANSPECIAL
- item.CreateTime = time.Now()
- item.ViewTime = v.CreateTime
- item.WeekStartDate, item.WeekEndDate = utils.GetMondayAndSundayByTimeString(item.ViewTime)
- items = append(items, item)
- }
- }
- //研选专栏阅读记录内容end
- //文章阅读记录内容
- {
- listArticleRecord, e := models.GetCygxArticleHistoryRecordAllListNoLimit(condition+" GROUP BY user_id, article_id ORDER BY create_time ASC ", pars)
- if e != nil {
- err = errors.New("GetCygxArticleHistoryRecordAllListNoLimit, Err: " + e.Error())
- return
- }
- //return
- //var articleIds []int
- //for _, v := range listArticleRecord {
- // articleIds = append(articleIds, v.ArticleId)
- //}
- //
- //var conditionArticle string
- //var parsArticle []interface{}
- //conditionArticle += ` AND article_id IN (` + utils.GetOrmInReplace(len(articleIds)) + `) `
- //parsArticle = append(parsArticle, articleIds)
- //listArticle, e := models.GetCygxCygxArticleList(conditionArticle, parsArticle, 0, len(articleIds))
- //if e != nil && e.Error() != utils.ErrNoRow() {
- // err = errors.New("GetCygxCygxArticleList, Err: " + e.Error())
- // return
- //}
- //mapArticleTitle := make(map[int]string)
- //
- //for _, v := range listArticle {
- // mapArticleTitle[v.ArticleId] = v.Title
- //}
- //fmt.Println(mapArticleTitle[10080])
- //return
- //文章阅读明细
- var conditionBill string
- var parsBill []interface{}
- conditionBill = " AND source = 'article' AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND view_time > ? "
- parsBill = append(parsBill, companyIds, createTime)
- listBillByArticle, e := rai_serve.GetCygxRaiServeBillListAll(conditionBill, parsBill)
- if e != nil {
- err = errors.New("GetCygxRaiServeBillListAll, Err: " + e.Error())
- return
- }
- mapArticleBill := make(map[string]bool)
- for _, v := range listBillByArticle {
- mapArticleBill[fmt.Sprint("UID_", v.UserId, "SID_", v.SourceId)] = true
- }
- for _, v := range listArticleRecord {
- if mapArticleBill[fmt.Sprint("UID_", v.UserId, "SID_", v.ArticleId)] { // 如果内容存在就不插入
- continue
- }
- item := new(rai_serve.CygxRaiServeBill)
- item.Content = v.Title
- item.ServeTypeId = 5
- item.ServeTypeName = "阅读uv"
- item.UserId = v.UserId
- item.Mobile = v.Mobile
- item.Email = v.Email
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.RealName = v.RealName
- item.RegisterPlatform = v.RegisterPlatform
- item.ServeCount = 0.5
- if mapUserMaker[v.UserId] {
- item.IsKp = 1
- item.ServeCount = item.ServeCount * 3
- }
- item.SourceId = v.ArticleId
- item.Source = utils.CYGX_OBJ_ARTICLE
- item.CreateTime = time.Now()
- item.ViewTime = v.CreateTime
- item.WeekStartDate, item.WeekEndDate = utils.GetMondayAndSundayByTimeString(item.ViewTime)
- if strings.Contains(v.CategoryName, "固收") {
- item.ChartPermissionName = utils.GU_SHOU_NAME
- item.ChartPermissionId = utils.GU_SHOU_ID_CHART
- }
- if strings.Contains(v.CategoryName, "策略") {
- item.ChartPermissionName = utils.CE_LUE_NAME
- item.ChartPermissionId = utils.CE_LUE_ID
- }
- items = append(items, item)
- }
- }
- //文章阅读记录内容 end
- //活动记录内容
- {
- condition = " AND art.company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND a.activity_time > ? "
- signUpDetailList, e := models.GetSignupDetailBySignupjoinactivity(condition+" ORDER BY a.activity_time ASC ", pars)
- if e != nil {
- err = errors.New("GetSignupDetailBySignupjoinactivity, Err: " + e.Error())
- return
- }
- //文章阅读明细
- var conditionBill string
- var parsBill []interface{}
- conditionBill = " AND source = 'activity' AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND view_time > ? "
- parsBill = append(parsBill, companyIds, createTime)
- listBillByArticle, e := rai_serve.GetCygxRaiServeBillListAll(conditionBill, parsBill)
- if e != nil {
- err = errors.New("GetCygxRaiServeBillListAll, Err: " + e.Error())
- return
- }
- mapArticleBill := make(map[string]bool)
- for _, v := range listBillByArticle {
- mapArticleBill[fmt.Sprint("UID_", v.UserId, "SID_", v.SourceId)] = true
- }
- for _, v := range signUpDetailList {
- if mapArticleBill[fmt.Sprint("UID_", v.UserId, "SID_", v.ActivityId)] { // 如果内容存在就不插入
- continue
- }
- item := new(rai_serve.CygxRaiServeBill)
- item.Content = v.ActivityName
- if v.ActivityType == 1 {
- item.ServeTypeId = 1
- item.ServeTypeName = "线上活动"
- } else {
- item.ServeTypeId = 2
- item.ServeTypeName = "线下活动"
- }
- item.UserId = v.UserId
- item.Mobile = v.Mobile
- item.Email = v.Email
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.RealName = v.RealName
- //item.RegisterPlatform = v.RegisterPlatform
- item.ServeCount = 1
- if mapUserMaker[v.UserId] {
- item.IsKp = 1
- item.ServeCount = item.ServeCount * 3
- }
- item.SourceId = v.ActivityId
- item.Source = utils.CYGX_OBJ_ACTIVITY
- item.CreateTime = time.Now()
- item.ViewTime = v.ActivityTime
- item.ChartPermissionName = v.ChartPermissionName
- item.ChartPermissionId = v.ChartPermissionId
- item.WeekStartDate, item.WeekEndDate = utils.GetMondayAndSundayByTimeString(item.ViewTime)
- items = append(items, item)
- }
- }
- //活动记录内容 end
- //专项调研活动记录内容
- {
- condition = " AND art.company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND a.activity_time > ? "
- activitySpecialList, e := models.GetCygxActivitySpecialMeetingDetailList(condition+" ORDER BY a.activity_time ASC ", pars)
- if e != nil {
- err = errors.New("GetCygxActivitySpecialMeetingDetailList, Err: " + e.Error())
- return
- }
- //专项调研活动明细
- var conditionBill string
- var parsBill []interface{}
- conditionBill = " AND source = 'activityspecial' AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND view_time > ? "
- parsBill = append(parsBill, companyIds, createTime)
- listBillByArticle, e := rai_serve.GetCygxRaiServeBillListAll(conditionBill, parsBill)
- if e != nil {
- err = errors.New("GetCygxRaiServeBillListAll, Err: " + e.Error())
- return
- }
- mapArticleBill := make(map[string]bool)
- for _, v := range listBillByArticle {
- mapArticleBill[fmt.Sprint("UID_", v.UserId, "SID_", v.SourceId)] = true
- }
- for _, v := range activitySpecialList {
- if mapArticleBill[fmt.Sprint("UID_", v.UserId, "SID_", v.ActivityId)] { // 如果内容存在就不插入
- continue
- }
- item := new(rai_serve.CygxRaiServeBill)
- item.Content = v.ResearchTheme
- item.ServeTypeId = 3
- item.ServeTypeName = "专项调研"
- item.UserId = v.UserId
- item.Mobile = v.Mobile
- item.Email = v.Email
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.RealName = v.RealName
- //item.RegisterPlatform = v.RegisterPlatform
- item.ServeCount = 1
- if mapUserMaker[v.UserId] {
- item.IsKp = 1
- item.ServeCount = item.ServeCount * 3
- }
- item.SourceId = v.ActivityId
- item.Source = utils.CYGX_OBJ_ACTIVITYSPECIAL
- item.CreateTime = time.Now()
- item.ViewTime = v.ActivityTime
- item.ChartPermissionName = v.ChartPermissionName
- item.ChartPermissionId = v.ChartPermissionId
- item.WeekStartDate, item.WeekEndDate = utils.GetMondayAndSundayByTimeString(item.ViewTime)
- items = append(items, item)
- }
- }
- //专项调研活动记录内容 end
- //1v1路演
- {
- condition = " AND art.company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND rs.start_date > ? "
- calendarMeetingUserList, e := roadshow.GetRsCalendarMeetingUserList(condition+" ORDER BY rs.start_date ASC ", pars)
- if e != nil {
- err = errors.New("GetRsCalendarMeetingUserList, Err: " + e.Error())
- return
- }
- var rsCalendarIds []int
- for _, v := range calendarMeetingUserList {
- rsCalendarIds = append(rsCalendarIds, v.RsCalendarId)
- }
- //获取研究员信息
- researchers, e := roadshow.GetRsCalendarResearcherListByIds(rsCalendarIds)
- if e != nil {
- err = errors.New("GetRsCalendarResearcherListByIds, Err: " + e.Error())
- return
- }
- mapResearcherName := make(map[int][]string)
- for _, v := range researchers {
- mapResearcherName[v.RsCalendarId] = append(mapResearcherName[v.RsCalendarId], v.ResearcherName)
- }
- listEmail, e := models.GetAskEmail()
- if e != nil {
- err = errors.New("GetAskEmail, Err: " + e.Error())
- return
- }
- var ceLueResearcherName []string
- var guShouResearcherName []string
- for _, v := range listEmail {
- if v.ChartPermissionName == utils.CE_LUE_NAME {
- ceLueResearcherName = append(ceLueResearcherName, v.Name)
- }
- if v.ChartPermissionName == utils.GU_SHOU_NAME {
- guShouResearcherName = append(guShouResearcherName, v.Name)
- }
- }
- //专项调研活动明细
- var conditionBill string
- var parsBill []interface{}
- conditionBill = " AND source = 'rscalendar' AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND view_time > ? "
- parsBill = append(parsBill, companyIds, createTime)
- listBillByRscalendar, e := rai_serve.GetCygxRaiServeBillListAll(conditionBill, parsBill)
- if e != nil {
- err = errors.New("GetCygxRaiServeBillListAll, Err: " + e.Error())
- return
- }
- mapRscalendarBill := make(map[string]bool)
- for _, v := range listBillByRscalendar {
- mapRscalendarBill[fmt.Sprint("UID_", v.UserId, "SID_", v.SourceId)] = true
- }
- for _, v := range calendarMeetingUserList {
- if mapRscalendarBill[fmt.Sprint("UID_", v.UserId, "SID_", v.RsCalendarId)] { // 如果内容存在就不插入
- continue
- }
- item := new(rai_serve.CygxRaiServeBill)
- item.Content = strings.Join(mapResearcherName[v.RsCalendarId], ",")
- item.ServeTypeId = 4
- item.ServeTypeName = "一对一路演"
- item.UserId = v.UserId
- item.Mobile = v.Mobile
- item.Email = v.Email
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.RealName = v.RealName
- //item.RegisterPlatform = v.RegisterPlatform
- item.ServeCount = 1.5
- if mapUserMaker[v.UserId] {
- item.IsKp = 1
- item.ServeCount = item.ServeCount * 3
- }
- item.SourceId = v.RsCalendarId
- item.Source = utils.CYGX_OBJ_RS_CALENDAR
- item.CreateTime = time.Now()
- item.ViewTime = v.StartDate + " " + v.StartTime
- item.WeekStartDate, item.WeekEndDate = utils.GetMondayAndSundayByTimeString(item.ViewTime)
- if utils.InArrayByStr(guShouResearcherName, item.Content) {
- item.ChartPermissionName = utils.GU_SHOU_NAME
- item.ChartPermissionId = utils.GU_SHOU_ID_CHART
- }
- if utils.InArrayByStr(ceLueResearcherName, item.Content) {
- item.ChartPermissionName = utils.CE_LUE_NAME
- item.ChartPermissionId = utils.CE_LUE_ID
- }
- items = append(items, item)
- }
- }
- //1v1路演 end
- //交流反馈
- {
- condition = " AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND create_time > ? "
- userFeedbackList, e := rai_serve.GetCygxUserFeedbackList(condition+" ORDER BY user_feedback_id ASC ", pars)
- if e != nil {
- err = errors.New("GetCygxUserFeedbackList, Err: " + e.Error())
- return
- }
- //交流反馈明细
- var conditionBill string
- var parsBill []interface{}
- conditionBill = " AND source = 'userfeedback' AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND view_time > ? "
- parsBill = append(parsBill, companyIds, createTime)
- listBillByuserFeedback, e := rai_serve.GetCygxRaiServeBillListAll(conditionBill, parsBill)
- if e != nil {
- err = errors.New("GetCygxRaiServeBillListAll, Err: " + e.Error())
- return
- }
- mapRscalendarBill := make(map[string]bool)
- for _, v := range listBillByuserFeedback {
- mapRscalendarBill[fmt.Sprint("UID_", v.UserId, "SID_", v.SourceId)] = true
- }
- for _, v := range userFeedbackList {
- if mapRscalendarBill[fmt.Sprint("UID_", v.UserId, "SID_", v.UserFeedbackId)] { // 如果内容存在就不插入
- continue
- }
- item := new(rai_serve.CygxRaiServeBill)
- item.Content = v.Content
- item.ServeTypeId = 6
- item.ServeTypeName = "交流反馈"
- item.UserId = v.UserId
- item.Mobile = v.Mobile
- item.Email = v.Email
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.RealName = v.RealName
- item.ServeCount = 1
- if mapUserMaker[v.UserId] {
- item.IsKp = 1
- item.ServeCount = item.ServeCount * 3
- }
- item.SourceId = v.UserFeedbackId
- item.Source = utils.CYGX_OBJ_USER_FEEDBACK
- item.CreateTime = time.Now()
- item.ViewTime = v.CreateTime
- item.WeekStartDate, item.WeekEndDate = utils.GetMondayAndSundayByTimeString(item.ViewTime)
- items = append(items, item)
- }
- }
- //交流反馈 end
- fmt.Println(len(items))
- e = rai_serve.AddCygxRaiServeBillMulti(items)
- if e != nil {
- err = errors.New("AddCygxRaiServeBillMulti, Err: " + e.Error())
- return
- }
- return
- }
- func UpdateCygxRaiServeBillWeek() (err error) {
- defer func() {
- if err != nil {
- fmt.Println(err)
- go utils.SendAlarmMsg("批量更新企业服务明细记录失败: UpdateCygxRaiServeBillByCompanyIds Err"+err.Error(), 2)
- }
- }()
- now := time.Now()
- weeks := 12
- companyList, e := rai_serve.GetCygxRaiServeCompanyAllList()
- if e != nil {
- err = errors.New("GetCygxRaiServeCompanyAllList, Err: " + e.Error())
- return
- }
- var companyIds []int
- for _, v := range companyList {
- companyIds = append(companyIds, v.CompanyId)
- }
- listCompanyUserNum, e := models.GetWxUserNumByCompanyIds(companyIds)
- if e != nil {
- err = errors.New("GetWxUserisMakerByCompanyIds, Err: " + e.Error())
- return
- }
- mapCompanyUserNum := make(map[int]int) //企业对应的用户数量
- for _, v := range listCompanyUserNum {
- mapCompanyUserNum[v.CompanyId] = v.UserNum
- }
- lencompanyId := len(companyIds)
- //研选阅读明细
- var conditionBill string
- var parsBill []interface{}
- conditionBill = " AND company_id IN (" + utils.GetOrmInReplace(lencompanyId) + ") AND view_time > ? "
- parsBill = append(parsBill, companyIds, time.Now().AddDate(0, 0, -80))
- listBillByYanxuanspecial, e := rai_serve.GetCygxRaiServeBillListAll(conditionBill, parsBill)
- if e != nil {
- err = errors.New("GetCygxRaiServeBillListAll, Err: " + e.Error())
- return
- }
- mapWeekServeCount := make(map[string]float64)
- for _, v := range listBillByYanxuanspecial {
- mapWeekServeCount[fmt.Sprintf("CID_", v.CompanyId, "WEEK_", v.WeekStartDate)] += v.ServeCount
- }
- fmt.Println(companyIds)
- var items []*rai_serve.CygxRaiServeWeekBill
- for _, v := range companyList {
- for i := 0; i < weeks; i++ {
- item := new(rai_serve.CygxRaiServeWeekBill)
- // 计算当前周的周一
- monday := now.AddDate(0, 0, -int(now.Weekday()-time.Monday)-i*7)
- // 计算当前周的周日
- sunday := monday.AddDate(0, 0, 6)
- item.WeekStartDate = monday.Format(utils.FormatDate)
- item.WeekEndDate = sunday.Format(utils.FormatDate)
- item.CompanyId = v.CompanyId
- item.CompanyName = v.CompanyName
- item.UserTotal = mapCompanyUserNum[v.CompanyId]
- item.WeekServeCount = mapWeekServeCount[fmt.Sprintf("CID_", v.CompanyId, "WEEK_", item.WeekStartDate)]
- if mapCompanyUserNum[v.CompanyId] > 0 {
- item.CoverageRate = item.WeekServeCount / float64(mapCompanyUserNum[v.CompanyId])
- }
- item.CreateTime = time.Now()
- item.ModifyTime = time.Now()
- items = append(items, item)
- }
- }
- e = rai_serve.AddCygxRaiServeWeekBillMulti(items)
- if e != nil {
- err = errors.New("AddCygxRaiServeWeekBillMulti, Err: " + e.Error())
- return
- }
- return
- }
- func UpdateWeekAvg() (err error) {
- defer func() {
- if err != nil {
- fmt.Println(err)
- go utils.SendAlarmMsg("批量更新企业服务明细记录失败: UpdateCygxRaiServeBillByCompanyIds Err"+err.Error(), 2)
- }
- }()
- now := time.Now()
- weeks := 3
- monday := now.AddDate(0, 0, -int(now.Weekday()-time.Monday)-weeks*7)
- startDate := monday.Format(utils.FormatDate)
- var condition string
- var pars []interface{}
- condition = ` AND week_start_date >= ? `
- pars = append(pars, startDate)
- listWeekBill, e := rai_serve.GetCygxRaiServeWeekBillListAll(condition, pars)
- if e != nil {
- err = errors.New("GetCygxRaiServeWeekBillListAll, Err: " + e.Error())
- return
- }
- mapWeekServeCount := make(map[int]float64) //四周平均率总合
- for _, v := range listWeekBill {
- mapWeekServeCount[v.CompanyId] += v.WeekServeCount * 100
- }
- //获取近四周含有Kp 的公司
- condition = ""
- pars = make([]interface{}, 0)
- condition += ` AND week_start_date >= ? AND is_kp = 1 GROUP BY company_id `
- pars = append(pars, startDate)
- listIsKpWeekBill, e := rai_serve.GetCygxRaiServeBillListAll(condition, pars)
- if e != nil {
- err = errors.New("GetCygxRaiServeWeekBillListAll, Err: " + e.Error())
- return
- }
- mapWeekIsKp := make(map[int]bool) //最近四周是否包含KP
- for _, v := range listIsKpWeekBill {
- mapWeekIsKp[v.CompanyId] = true
- }
- companyList, e := rai_serve.GetCygxRaiServeCompanyAllList()
- if e != nil {
- err = errors.New("GetCygxRaiServeCompanyAllList, Err: " + e.Error())
- return
- }
- var formalCompanyIds []int // 当前正式客户ID
- var formalNoCompanyIds []int // 当前非正式客户ID
- for _, v := range companyList {
- if v.Status == "正式" {
- formalCompanyIds = append(formalCompanyIds, v.CompanyId)
- } else {
- formalNoCompanyIds = append(formalNoCompanyIds, v.CompanyId)
- }
- }
- var itemsUpdate []*rai_serve.CygxRaiServeCompany
- if len(formalCompanyIds) > 0 { //正式客户信息
- condition = ""
- pars = make([]interface{}, 0)
- condition = ` AND product_id = 2 AND company_id IN (` + utils.GetOrmInReplace(len(formalCompanyIds)) + `) AND status = 1 AND end_date > ? `
- pars = append(pars, formalCompanyIds, time.Now())
- listCompanyContract, e := company.GetCompanyContractList(condition, pars)
- if e != nil {
- err = errors.New("GetCompanyContractList, Err: " + e.Error())
- return
- }
- companyMoney := make(map[int]float64)
- for _, v := range listCompanyContract {
- companyMoney[v.CompanyId] += v.Money
- }
- permissionNameMapByCompanyId, e := GetCompanyReportPermissionNameMapByCompanyId(formalCompanyIds)
- if e != nil {
- err = errors.New("GetCompanyReportPermissionNameMapByCompanyId, Err: " + e.Error())
- return
- }
- for _, v := range formalCompanyIds {
- item := new(rai_serve.CygxRaiServeCompany)
- item.CompanyId = v
- item.Money = companyMoney[v]
- item.PermissionName = permissionNameMapByCompanyId[v]
- item.ServeCoverageRate = utils.SubFloatToString(mapWeekServeCount[v]/4, 2)
- if mapWeekIsKp[v] {
- item.IsUserMaker = 1
- }
- itemsUpdate = append(itemsUpdate, item)
- }
- }
- //正式客户数据修改
- e = rai_serve.UpdateCygxRaiServeCompanyMulti(itemsUpdate)
- if e != nil {
- err = errors.New("UpdateCygxRaiServeCompanyMulti, Err: " + e.Error())
- return
- }
- //非正式客户数据修改
- var itemsUpdateFormalNo []*rai_serve.CygxRaiServeCompany
- if len(formalNoCompanyIds) > 0 { //非正式客户信息
- condition = ""
- pars = make([]interface{}, 0)
- condition = ` AND product_id = 2 AND company_id IN (` + utils.GetOrmInReplace(len(formalNoCompanyIds)) + `) AND status = 1 AND end_date < ? GROUP BY company_id ORDER BY company_contract_id DESC `
- pars = append(pars, formalNoCompanyIds, time.Now())
- listCompanyContractLastId, e := company.GetCompanyContractLastList(condition, pars) //获取关联的最后一笔合同信息
- if e != nil {
- err = errors.New("GetCompanyContractLastList, Err: " + e.Error())
- return
- }
- var companyContractIds []int
- for _, v := range listCompanyContractLastId {
- companyContractIds = append(companyContractIds, v.CompanyContractId)
- }
- condition = ""
- pars = make([]interface{}, 0)
- condition = ` AND product_id = 2 AND company_id IN (` + utils.GetOrmInReplace(len(formalNoCompanyIds)) + `) AND status = 1 AND company_contract_id IN (` + utils.GetOrmInReplace(len(companyContractIds)) + `) AND end_date < ? GROUP BY company_id ORDER BY company_contract_id DESC `
- pars = append(pars, formalNoCompanyIds, companyContractIds, time.Now())
- listCompanyContractLast, e := company.GetCompanyContractList(condition, pars)
- if e != nil {
- err = errors.New("GetCompanyContractList, Err: " + e.Error())
- return
- }
- permissionNameMapByContractId, e := GetCompanyContractPermissionNameMapById(companyContractIds)
- if e != nil {
- err = errors.New("GetCompanyReportPermissionNameMapByCompanyId, Err: " + e.Error())
- return
- }
- for _, v := range listCompanyContractLast {
- item := new(rai_serve.CygxRaiServeCompany)
- item.CompanyId = v.CompanyId
- item.Money = v.Money
- item.StartDate = v.StartDate
- item.EndDate = v.EndDate
- item.ServeCoverageRate = utils.SubFloatToString(mapWeekServeCount[v.CompanyId]/4, 2)
- if mapWeekIsKp[v.CompanyId] {
- item.IsUserMaker = 1
- }
- item.PermissionName = permissionNameMapByContractId[v.CompanyContractId]
- itemsUpdateFormalNo = append(itemsUpdateFormalNo, item)
- }
- }
- e = rai_serve.UpdateCygxRaiServeCompanyFormalNoMulti(itemsUpdateFormalNo)
- if e != nil {
- err = errors.New("UpdateCygxRaiServeCompanyFormalNoMulti, Err: " + e.Error())
- return
- }
- fmt.Println(" UpdateWeekAvg end")
- return
- }
|