|
|
@@ -28,19 +28,6 @@ func UpdateRaiServeCompany() (err error) {
|
|
|
}
|
|
|
}()
|
|
|
|
|
|
- //获取当前所有的权益服务客户ID
|
|
|
- //listRaiServeCompanyId, e := rai_serve.GetCygxRaiServeCompanyAllList()
|
|
|
- //if e != nil {
|
|
|
- // err = errors.New("GetCygxRaiServeCompanyAllList, Err: " + e.Error())
|
|
|
- // return
|
|
|
- //}
|
|
|
- //mapOldCompanyId := make(map[int]bool) //原来的所属机构
|
|
|
- //mapNewCompanyId := make(map[int]bool) // 现有的所属机构
|
|
|
- //var deleteCompanyIds []int // 需要删除的机构
|
|
|
- //for _, v := range listRaiServeCompanyId {
|
|
|
- // mapOldCompanyId[v.CompanyId] = true
|
|
|
- //}
|
|
|
-
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
|
condition = ` AND p.product_id = 2 AND (p.group_id = ? OR p.share_group_id = ?) `
|
|
|
@@ -61,8 +48,6 @@ func UpdateRaiServeCompany() (err error) {
|
|
|
item.CompanyId = v.CompanyId
|
|
|
item.CompanyName = v.CompanyName
|
|
|
item.CreateTime = time.Now()
|
|
|
- //item.Money = 100
|
|
|
- //item.ServeCoverageRate = "66.66%"
|
|
|
item.SellerId = v.SellerId
|
|
|
item.SellerName = v.SellerName
|
|
|
item.StartDate = v.StartDate
|
|
|
@@ -70,15 +55,11 @@ func UpdateRaiServeCompany() (err error) {
|
|
|
item.ShareSeller = v.ShareSeller
|
|
|
item.ShareSellerId = v.ShareSellerId
|
|
|
item.Status = v.Status
|
|
|
- //item.PermissionName = "科技"
|
|
|
+ item.GroupId = v.GroupId
|
|
|
+ item.ShareGroupId = v.ShareGroupId
|
|
|
items = append(items, item)
|
|
|
}
|
|
|
|
|
|
- //for _, v := range listRaiServeCompanyId {
|
|
|
- // if !mapNewCompanyId[v.CompanyId] {
|
|
|
- // deleteCompanyIds = append(deleteCompanyIds, v.CompanyId)
|
|
|
- // }
|
|
|
- //}
|
|
|
//先删除老的再添加新的
|
|
|
e = rai_serve.AddCygxRaiServeCompanyMulti(items)
|
|
|
if e != nil {
|
|
|
@@ -86,113 +67,6 @@ func UpdateRaiServeCompany() (err error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- //listRaiServeCompanyNow, e := rai_serve.GetCygxRaiServeCompanyAllList()
|
|
|
- //if e != nil {
|
|
|
- // err = errors.New("GetCygxRaiServeCompanyAllList_Now, Err: " + e.Error())
|
|
|
- // return
|
|
|
- //}
|
|
|
-
|
|
|
- var formalCompanyIds []int // 当前正式客户ID
|
|
|
- var formalNoCompanyIds []int // 当前非正式客户ID
|
|
|
-
|
|
|
- for _, v := range listCompanyProduct {
|
|
|
- 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 = "61.8"
|
|
|
- itemsUpdate = append(itemsUpdate, item)
|
|
|
- }
|
|
|
-
|
|
|
- fmt.Println(companyMoney)
|
|
|
- }
|
|
|
-
|
|
|
- //正式客户数据修改
|
|
|
- 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
|
|
|
- }
|
|
|
- fmt.Println("permissionNameMapByContractId", permissionNameMapByContractId)
|
|
|
- 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 = " 61.8"
|
|
|
- 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
|
|
|
- }
|
|
|
-
|
|
|
return
|
|
|
}
|
|
|
|
|
|
@@ -473,10 +347,6 @@ func CygxRaiServeBillRedisAdd(content, source string, userId, comapnyId, sourceI
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//func init() {
|
|
|
-// CygxRaiServeBillRedisAddReduce()
|
|
|
-//}
|
|
|
-
|
|
|
// CygxRaiServeBillRedisAddReduce 处理权益服务统计
|
|
|
func CygxRaiServeBillRedisAddReduce() (err error) {
|
|
|
for {
|
|
|
@@ -559,9 +429,9 @@ func RaiServeBillRedisAddReduceByYanxuanspecial(log rai_serve.RaiServeBillRedis)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-func init() {
|
|
|
- UpdateCygxRaiServeBillWeek()
|
|
|
-}
|
|
|
+//func init() {
|
|
|
+// UpdateWeekAvg()
|
|
|
+//}
|
|
|
|
|
|
// 批量更新企业服务明细记录
|
|
|
func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
@@ -685,26 +555,26 @@ func UpdateCygxRaiServeBillByCompanyIds() (err 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])
|
|
|
+ //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
|
|
|
|
|
|
//文章阅读明细
|
|
|
@@ -728,7 +598,7 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
continue
|
|
|
}
|
|
|
item := new(rai_serve.CygxRaiServeBill)
|
|
|
- item.Content = mapArticleTitle[v.ArticleId]
|
|
|
+ item.Content = v.Title
|
|
|
item.ServeTypeId = 5
|
|
|
item.ServeTypeName = "阅读uv"
|
|
|
item.UserId = v.UserId
|
|
|
@@ -749,6 +619,15 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
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)
|
|
|
}
|
|
|
}
|
|
|
@@ -808,6 +687,8 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
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)
|
|
|
}
|
|
|
@@ -863,6 +744,8 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
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)
|
|
|
}
|
|
|
@@ -893,6 +776,24 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
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{}
|
|
|
@@ -934,6 +835,15 @@ func UpdateCygxRaiServeBillByCompanyIds() (err error) {
|
|
|
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)
|
|
|
}
|
|
|
}
|
|
|
@@ -1079,6 +989,163 @@ func UpdateCygxRaiServeBillWeek() (err error) {
|
|
|
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
|
|
|
}
|
xingzai