no message

services/activity_points.go

@@ -1571,30 +1571,29 @@ func ActivitySpecialCompanyApprovalReduce(log models.YanXuanActivityPointsRedis)
 			err = errors.New("GetCompanyContractPermissionList, Err: " + e.Error())
 			return
 		}
-		if len(list) == 0 {
-			return
-		}
-		//获取权益主观权限
-		listRaiSubjectivity, e := models.GetChartPermissionListRaiSubjectivity()
-		if e != nil && e.Error() != utils.ErrNoRow() {
-			err = errors.New("GetChartPermissionListRaiSubjectivity, Err: " + e.Error())
-		}
-		mapRaiSubjectivity := make(map[int]bool)
-		mapPermissionName := make(map[int]string)
-		for _, v := range listRaiSubjectivity {
-			mapRaiSubjectivity[v.ChartPermissionId] = true
-			mapPermissionName[v.ChartPermissionId] = v.ChartPermissionName
-		}
-		for _, v := range list {
-			//如果是升级则加点
-			if v.IsUpgrade == 1 && mapRaiSubjectivity[v.ChartPermissionId] {
-				itemBill.BillDetailed += 4
-				companyPointsNum += 4
+		if len(list) > 0 {
+			//获取权益主观权限
+			listRaiSubjectivity, e := models.GetChartPermissionListRaiSubjectivity()
+			if e != nil && e.Error() != utils.ErrNoRow() {
+				err = errors.New("GetChartPermissionListRaiSubjectivity, Err: " + e.Error())
 			}
+			mapRaiSubjectivity := make(map[int]bool)
+			mapPermissionName := make(map[int]string)
+			for _, v := range listRaiSubjectivity {
+				mapRaiSubjectivity[v.ChartPermissionId] = true
+				mapPermissionName[v.ChartPermissionId] = v.ChartPermissionName
+			}
+			for _, v := range list {
+				//如果是升级则加点
+				if v.IsUpgrade == 1 && mapRaiSubjectivity[v.ChartPermissionId] {
+					itemBill.BillDetailed += 4
+					companyPointsNum += 4
+				}
+			}
+			itemBill.Total = fmt.Sprint(companyPointsNum, "次")
+			itemBill.Content = "行业升级套餐转正"
+			items = append(items, itemBill)
 		}
-		itemBill.Total = fmt.Sprint(companyPointsNum, "次")
-		itemBill.Content = "行业升级套餐转正"
-		items = append(items, itemBill)
 	}
 
 	//更新对应机构的剩余点数
@@ -1604,7 +1603,80 @@ func ActivitySpecialCompanyApprovalReduce(log models.YanXuanActivityPointsRedis)
 	itemCompany.Points = companyPointsNum
 	itemCompany.ModifyTime = time.Now()
 	itemCompanys = append(itemCompanys, itemCompany)
-
 	err = models.AddCygxActivitySpecialTripBillMulti(items, itemCompanys)
 	return
 }
+
+//func init() {
+//	initCygx14_5_01()
+//}
+
+func initCygx14_5_01() {
+	// 获取流水信息
+	var condition string
+	var pars []interface{}
+	condition += ` AND  points != 0  `
+	list, err := models.GetCygxActivityPointsCompanyList(condition, pars)
+	if err != nil {
+		fmt.Println(err)
+		return
+	}
+	for _, v := range list {
+		fmt.Println("v.CompanyId", v.CompanyId)
+		companyId := v.CompanyId
+		total, e := models.GetCygxActivitySpecialPermissionPointsCountByCompanyId(companyId)
+		if e != nil {
+			err = errors.New("GetCygxActivityPointsCompanyCountByCompanyId, Err: " + e.Error())
+			return
+		}
+		var companyPointsNum float64
+		if total == 0 {
+			companyPointsNum = 0
+			itemPointsCompany := new(models.CygxActivitySpecialPermissionPoints)
+			itemPointsCompany.CompanyId = companyId
+			itemPointsCompany.CompanyName = v.CompanyName
+			itemPointsCompany.CreateTime = time.Now()
+			itemPointsCompany.ModifyTime = time.Now()
+			e = models.AddCygxActivitySpecialPermissionPoints(itemPointsCompany)
+			if e != nil {
+				err = errors.New("AddCygxActivitySpecialPermissionPoints, Err: " + e.Error())
+				return
+			}
+		} else {
+			// 获取用户所在公司剩余的点
+			companyPointsNum, e = models.GetCygxActivitySpecialPermissionPoints(v.CompanyId)
+			if e != nil && e.Error() != utils.ErrNoRow() {
+				err = errors.New("GetCygxActivitySpecialPermissionPoints, Err: " + e.Error())
+				return
+			}
+		}
+
+		//获取需要添加的流水信息
+		var items []*models.CygxActivitySpecialTripBill
+		itemBill := new(models.CygxActivitySpecialTripBill)
+
+		itemBill.CreateTime = time.Now()
+
+		itemBill.CompanyId = v.CompanyId
+		itemBill.CompanyName = v.CompanyName
+		itemBill.Source = 3
+		itemBill.DoType = 0
+		itemBill.BillDetailed = v.Points / 2 // 流水减一
+		//itemBill.RegisterPlatform = utils.REGISTER_PLATFORM
+
+		itemBill.Content = "研选点数清零，1/2比例折算进专项/路演点数"
+		itemBill.Total = fmt.Sprint(companyPointsNum+itemBill.BillDetailed, "次")
+		itemBill.TableSource = utils.CYGX_OBJ_ACTIVITYSPECIAL
+		items = append(items, itemBill)
+		//更新对应机构的剩余点数
+		var itemCompanys []*models.CygxActivitySpecialPermissionPoints
+		itemCompany := new(models.CygxActivitySpecialPermissionPoints)
+		itemCompany.CompanyId = v.CompanyId
+		itemCompany.Points = companyPointsNum + itemBill.BillDetailed
+		itemCompany.ModifyTime = time.Now()
+		itemCompanys = append(itemCompanys, itemCompany)
+
+		err = models.AddCygxActivitySpecialTripBillMulti(items, itemCompanys)
+	}
+	fmt.Println("enddd145")
+}