增加addscore项

cmd/static/main.go

@@ -27,7 +27,7 @@ var (
 	//公司的逾期数据
 	//公司的逾期数据
 	companySoreFields map[string]string
 	companySoreFields map[string]string
 	//公司的逾期数据
 	//公司的逾期数据
-	companyAddSore map[string]string
+	companyAddSore []map[string]string
 	//设置等待
 	//设置等待
 	wg sync.WaitGroup
 	wg sync.WaitGroup
 )
 )
@@ -116,6 +116,7 @@ func getCompanyRunInfo(c context.Context)  {
 	connect := dao.New()
 	connect := dao.New()
 	companyBasicInfo,_ = connect.GetCompanyBaseInfoByCid(c,insertScoreMsg.ComCreditsId)
 	companyBasicInfo,_ = connect.GetCompanyBaseInfoByCid(c,insertScoreMsg.ComCreditsId)
 	companySoreFields,_ = connect.GetCompanyScoreFieldsByCid(c,insertScoreMsg.ComCreditsId)
 	companySoreFields,_ = connect.GetCompanyScoreFieldsByCid(c,insertScoreMsg.ComCreditsId)
+	companyAddSore,_ = connect.GetCompanyAddSoreByCid(c,insertScoreMsg.ComCreditsId)
 }
 }
 
 
 func getTimeStamp()(timestamp int64)  {
 func getTimeStamp()(timestamp int64)  {

internal/dao/add_scores.go

@@ -8,7 +8,7 @@ import (
 )
 )
 
 
 //通过UID获取用户加分信息
 //通过UID获取用户加分信息
-func (d *dao) GeAddScoresByCid(c context.Context, companyId int64) (res map[string]string, err error) {
+func (d *dao) GetCompanyAddSoreByCid(c context.Context, companyId int64) (res []map[string]string, err error) {
 
 
 	var (
 	var (
 		rows *sql.Rows
 		rows *sql.Rows
@@ -25,12 +25,5 @@ func (d *dao) GeAddScoresByCid(c context.Context, companyId int64) (res map[stri
 		return
 		return
 	}
 	}
 
 
-	twoMap,err := GetAllParam(rows)
-
-	for _,v:=range twoMap{
-		res = v
-		break
-	}
-
-	return
+	return GetAllParam(rows)
 }
 }
\ No newline at end of file

internal/dao/dao.go

@@ -25,6 +25,7 @@ type (
 		InsertScores(ctx context.Context, score model.Scores) (insertId int64, err error)
 		InsertScores(ctx context.Context, score model.Scores) (insertId int64, err error)
 		GetCompanyBaseInfoByCid(c context.Context, companyId int64) (r map[string]string, err error)
 		GetCompanyBaseInfoByCid(c context.Context, companyId int64) (r map[string]string, err error)
 		GetCompanyScoreFieldsByCid(c context.Context, companyId int64) (r map[string]string, err error)
 		GetCompanyScoreFieldsByCid(c context.Context, companyId int64) (r map[string]string, err error)
+		GetCompanyAddSoreByCid(c context.Context, companyId int64) (r []map[string]string, err error)
 		//---静态结束
 		//---静态结束
 
 
         CountYuqi(ctx context.Context,project_id int) (r []map[string]interface{},err error)  //计算逾期
         CountYuqi(ctx context.Context,project_id int) (r []map[string]interface{},err error)  //计算逾期

internal/service/service.go

@@ -79,7 +79,7 @@ func (s *Service) GetCompanyBaseInfoByCid(c context.Context, companyId int64) (r
 	return
 	return
 }
 }
 
 
-// 获取公司用户列表
+// 获取公司征信信息
 func (s *Service) GetCompanyScoreFieldsByCid(c context.Context, companyId int64) (res map[string]string, err error) {
 func (s *Service) GetCompanyScoreFieldsByCid(c context.Context, companyId int64) (res map[string]string, err error) {
 
 
 	//调用DB方法，获取会员数据
 	//调用DB方法，获取会员数据
@@ -89,4 +89,14 @@ func (s *Service) GetCompanyScoreFieldsByCid(c context.Context, companyId int64)
 }
 }
 
 
 
 
+// 获取公司加分项
+func (s *Service) GetCompanyAddSore(c context.Context, companyId int64) (res []map[string]string, err error) {
+
+	//调用DB方法，获取会员数据
+	res, err = s.dao.GetCompanyAddSoreByCid(c,companyId)
+	fmt.Print(err)
+	return
+}
+
+
 //----------静态结束
 //----------静态结束
\ No newline at end of file