风控信息完成

README.md

@@ -5,3 +5,12 @@
 
 2.运行命令
  go run cmd/main.go -conf=./configs/
+ 
+ 
+3队列服务
+go run ./cmd/dong/ -conf=./configs/ -m -1
+go run ./cmd/static/ -conf=./configs/ all
+
+
+3.1 队列json：
+{"com_credits_id":"338","erp_company_code":""}
\ No newline at end of file

cmd/http/main.go

-package main
-
-import (
-	"flag"
-	"os"
-	"os/signal"
-	"syscall"
-	"time"
-
-	"kaopu-server/internal/di"
-	"github.com/go-kratos/kratos/pkg/conf/paladin"
-	"github.com/go-kratos/kratos/pkg/log"
-)
-
-func main() {
-	flag.Parse()
-	log.Init(nil) // debug flag: log.dir={path}
-	defer log.Close()
-	log.Info("biligo start")
-	paladin.Init()
-	_, closeFunc, err := di.InitApp()
-	if err != nil {
-		panic(err)
-	}
-	c := make(chan os.Signal, 1)
-	signal.Notify(c, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT)
-	for {
-		s := <-c
-		log.Info("get a signal %s", s.String())
-		switch s {
-		case syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT:
-			closeFunc()
-			log.Info("biligo exit")
-			time.Sleep(time.Second)
-			return
-		case syscall.SIGHUP:
-		default:
-			return
-		}
-	}
-}

http/internal/dao/db.go

@@ -13,10 +13,10 @@ func NewDB() (db *sql.DB, cf func(), err error) {
 		cfg sql.Config
 		ct paladin.TOML
 	)
-	if err = paladin.Get("db.toml").Unmarshal(&ct); err != nil {
+	if err = paladin.Get("mysql.toml").Unmarshal(&ct); err != nil {
 		return
 	}
-	if err = ct.Get("Client").UnmarshalTOML(&cfg); err != nil {
+	if err = ct.Get("Liexin_credit").UnmarshalTOML(&cfg); err != nil {
 		return
 	}
 	db = sql.NewMySQL(&cfg)
@@ -27,4 +27,4 @@ func NewDB() (db *sql.DB, cf func(), err error) {
 func (d *dao) RawArticle(ctx context.Context, id int64) (art *model.Article, err error) {
 	// get data from db
 	return
-}
+}
\ No newline at end of file

http/internal/dao/mc.go

@@ -28,7 +28,7 @@ func NewMC() (mc *memcache.Memcache, cf func(), err error) {
 	if err = paladin.Get("memcache.toml").Unmarshal(&ct); err != nil {
 		return
 	}
-	if err = ct.Get("Client").UnmarshalTOML(&cfg); err != nil {
+	if err = ct.Get("demo").UnmarshalTOML(&cfg); err != nil {
 		return
 	}
 	mc =  memcache.New(&cfg)

http/internal/dao/redis.go

@@ -16,7 +16,7 @@ func NewRedis() (r *redis.Redis, cf func(), err error) {
 	if err = paladin.Get("redis.toml").Unmarshal(&ct); err != nil {
 		return
 	}
-	if err = ct.Get("Client").UnmarshalTOML(&cfg); err != nil {
+	if err = ct.Get("demo").UnmarshalTOML(&cfg); err != nil {
 		return
 	}
 	r = redis.NewRedis(&cfg)

http/internal/model/member.go

+package model
+
+//会员系统需要的模型
+

http/internal/server/http/member/company.go

+package member
+
+import (
+	"fmt"
+	bm "github.com/go-kratos/kratos/pkg/net/http/blademaster"
+	"kaopu-server/http/internal/dao"
+	mm "kaopu-server/internal/model"
+	"time"
+)
+
+
+const INSERTCOMPANY  = "insert into `lie_com_credits` (`company_name`,`erp_company_code`,`create_time`,`update_time`,`status`)values(?,'',?,?,5)"
+const INSERTCOMPANYBASICINFO  = "insert into `lie_com_basicinfos` (`com_credits_id`,`com_name`,`create_time`)values(?,?,?)"
+const SELECTCOMCREDIT  = "select " +
+	"id,company_name,apply_account,erp_company_code,static_credit_score,dynamic_credit_score,total_credit_score,creator," +
+	"status,blacklist_hit,credit_invest_result,ichunt_hunting_core,recommended_amount,recom_time_limit,score_time,create_time,update_time,risk_type " +
+	"from lie_com_credits where company_name = ?"
+const SELECTCOMBASIC = "select " +
+	"id,com_credits_id,com_name ,com_organization ,establishment_time ,com_leader ,registered_capital ,customer_property ,score_time ,com_address " +
+	",legal_representative,legal_fixed_telephone,legal_mobile_phone,actual_controller,actual_fix_telephone,actual_mobile_phone,com_contact" +
+	",contact_fix_telephone,contact_mobile_phone,five_legal_change,year_tax_payable,two_years_no_lawsuit,social_security_participants,id_card_front" +
+	",id_card_back,pay_duty_pic" +
+	" from lie_com_basicinfos where com_credits_id = ?"
+
+//查询是否有该公司，没有就添加，添加了之后每天晚上会自动跑
+func GetCompanyInfo(c *bm.Context)  {
+
+	companyName,_ := c.Params.Get("company_name")
+	var comCredit mm.ComCredits
+	var comBasicInfo mm.ComCreditsBasicInfos
+	db,closedb,err := dao.NewDB()
+
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	err = db.QueryRow(c,SELECTCOMCREDIT,companyName).Scan(&comCredit.Id,&comCredit.CompanyName,&comCredit.ApplyAccount,&comCredit.ErpCompanyCode,&comCredit.StaticCreditScore,
+		&comCredit.DynamicCreditScore,&comCredit.TotalCreditScore,&comCredit.Creator,&comCredit.Status,&comCredit.BlacklistHit,&comCredit.CreditInvestResult,
+		&comCredit.IchuntHuntingCore,&comCredit.RecommendedAmount,&comCredit.RecomTimeLimit,&comCredit.ScoreTime,&comCredit.CreateTime,&comCredit.UpdateTime,&comCredit.RiskType)
+
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	//如果没有数据就添加，等每天晚上会自动去天眼查获取,如果存在再查找公司信息
+	if comCredit.Id == 0 {
+		currentTime := time.Now().Unix()
+		sqlResult,err := db.Exec(c,INSERTCOMPANY,companyName,currentTime,currentTime)
+		lastid,_ := sqlResult.LastInsertId()
+		//如果添加没问题，就继续添加
+		if err != nil {
+			fmt.Println(err)
+		}else{
+			comCredit.Id = lastid
+			comCredit.CompanyName = companyName
+			_,err  = db.Exec(c,INSERTCOMPANYBASICINFO,lastid,companyName,currentTime)
+			if err != nil {
+				fmt.Println(err)
+			}
+		}
+	}else{
+		fmt.Println(comCredit.Id)
+		err = db.QueryRow(c,SELECTCOMBASIC,comCredit.Id).Scan(&comBasicInfo.Id,&comBasicInfo.ComCreditsId,&comBasicInfo.ComName,&comBasicInfo.ComOrganization,
+			&comBasicInfo.EstanlishmentTime,&comBasicInfo.ComLeader,&comBasicInfo.RegisteredCapital,&comBasicInfo.CustomerProperty,&comBasicInfo.ScoreTime,
+			&comBasicInfo.ComAddress,&comBasicInfo.LegalRepresentative,&comBasicInfo.LegalFixedTelephone,&comBasicInfo.LegalMobilePhone,&comBasicInfo.ActualController,
+			&comBasicInfo.ActualFixTelephone,&comBasicInfo.ActualMobilePhone,&comBasicInfo.ComContact,&comBasicInfo.ContactFixTelephone,&comBasicInfo.ContactMobilePhone,
+			&comBasicInfo.FiveLegalChange,&comBasicInfo.YearTaxPayable,&comBasicInfo.TwoYearsnoLawsuit,&comBasicInfo.SocialSecurityParticiPant,&comBasicInfo.IdCardFront,
+			&comBasicInfo.IdCardBack,&comBasicInfo.PayDutyPic)
+		if err != nil{
+			fmt.Println(err)
+		}
+	}
+
+	closedb()
+	k := make(map[string]interface{})
+	k["com_credit"] = comCredit
+	k["com_basic_info"] = comBasicInfo
+	c.JSONMap(k,nil)
+}
\ No newline at end of file

http/internal/server/http/server.go

 package http
 
 import (
+	"kaopu-server/http/internal/server/http/member"
 	"net/http"
 
 	pb "kaopu-server/http/api"
@@ -37,6 +38,10 @@ func initRouter(e *bm.Engine) {
 	g := e.Group("/kaopu-server/http")
 	{
 		g.GET("/start", howToStart)
+
+		//会员系统的接口
+		g.GET("/member/company_info/:company_name", member.GetCompanyInfo)
+
 	}
 }
 

internal/model/com_basicinfos.go

@@ -8,7 +8,7 @@ type ComCreditsBasicInfos struct {
 	EstanlishmentTime 		int64	`json:"establishment_time"` //'公司成立时间'
 	ComLeader 				string	`json:"com_leader"` //'公司负责人'
 	RegisteredCapital 		string		`json:"registered_capital"` //'注册资本'
-	CustomerProperty 		int64		`json:"customer_property"` //'客户性质'
+	CustomerProperty 		string		`json:"customer_property"` //'客户性质'
 	ScoreTime 				int64		`json:"score_time"` //'评分时间'
 	ComAddress 				string		`json:"com_address"` //'公司地址'
 	LegalRepresentative 	string		`json:"legal_representative"` //'法定代表人'
@@ -22,7 +22,7 @@ type ComCreditsBasicInfos struct {
 	ContactMobilePhone 		string		`json:"contact_mobile_phone"` //'企业联系人移动电话'
 	FiveLegalChange 		int8		`json:"five_legal_change"`
 	YearTaxPayable 			float64		`json:"year_tax_payable"`
-	TwoYearsnoLawsuit 		int8		`json:"two_years_no_lawsuit"`
+	TwoYearsnoLawsuit 		string		`json:"two_years_no_lawsuit"`
 	SocialSecurityParticiPant 		int16		`json:"social_security_participants"`
 	IdCardFront 			string		`json:"id_card_front"`
 	IdCardBack 				string		`json:"id_card_back"`

internal/model/com_credits.go

@@ -18,6 +18,7 @@ type ComCredits struct {
 	ScoreTime 				int64		`json:"score_time"`
 	CreateTime 				int64		`json:"create_time"`
 	UpdateTime 				int64		`json:"update_time"`
+	RiskType 				string		`json:"risk_type"`
 }