Skip to content

孙龙 / kaopu-server

Go to a project
Commit 8314ff4e by Joneq
Options

完成公司信息的算法统计

parent 90dc6642
Inline Side-by-side
Showing with 278 additions and 54 deletions
cmd/static/company_info.go
package main
var(
currentScore float32
totalScore float32
)
//公司信息计算
func CompanyInfo() {
totalScore = 0
EstablishmentTime()
CompanyNature()
ChangeslegalInFiveYears()
......@@ -10,51 +22,134 @@ func CompanyInfo() {
AnnualTaxRate()
lawsuitsInPastTwoYars()
NumberOfSocial()
insertScoreMsg.FinalScore ,insertScoreMsg.TotalScore,insertScoreMsg.CurrentScore = totalScore,totalScore,totalScore
insertScoreMsg.Weight = 50
setInserScoreChanFooter(1,0,1)
}
//成立时间（1分）
//成立时间（1分） 大于五年1分，小于零分
func EstablishmentTime() {
setInserScoreHeader(1,1,8)
insertScoreMsg.TotalScore = 5
insertScoreMsg.FinalScore = 5
insertScoreMsg.CurrentScore = 2
insertScoreMsg.Weight = 50
insertScoreMsg.ComCreditsId = 2
socreRecordChan <- insertScoreMsg
establishment_time := stringTurnInt64(companyBasicInfo["establishment_time"])
diffTime := getTimeStamp() - establishment_time
//两年以上有分
if diffTime > (3600 * 24 * 365 * 5) {
currentScore = 1
} else {
currentScore = 0
}
totalScore += currentScore
//设置分数
insertScoreMsg.FinalScore ,insertScoreMsg.TotalScore,insertScoreMsg.CurrentScore = currentScore,currentScore,currentScore
insertScoreMsg.Weight = 50
setInserScoreChanFooter(1,1,8)
}
//公司性质（1分）
//公司性质（1分）上，国，央，一分，其它零分
func CompanyNature() {
setInserScoreHeader(1,1,9)
customer_property := stringTurnInt64(companyBasicInfo["customer_property"])
if customer_property == 0 {
currentScore = 0
}else{
currentScore = 1
}
totalScore += currentScore
//设置分数
insertScoreMsg.FinalScore ,insertScoreMsg.TotalScore,insertScoreMsg.CurrentScore = currentScore,currentScore,currentScore
insertScoreMsg.Weight = 50
setInserScoreChanFooter(1,1,9)
}
//5年内法人变更次数（1分）
func ChangeslegalInFiveYears() {
five_legal_change := stringTurnInt64(companyBasicInfo["five_legal_change"])
//两次以上0分，以下一分
if five_legal_change < 2 {
currentScore = 1
}else{
currentScore = 0
}
totalScore += currentScore
setInserScoreChanFooter(1,1,10)
}
//注册资本（2分）
func RegisteredCapital() {
registered_capital := stringTurnInt64(companyBasicInfo["registered_capital"])
if registered_capital < 500000 {
currentScore = 0
}else if registered_capital > 2000000 {
currentScore = 2
}else{
currentScore = 1
}
totalScore += currentScore
setInserScoreChanFooter(1,1,11)
}
//年纳税额（2分）
func AnnualTaxRate() {
year_tax_payable := stringTurnFloat64(companyBasicInfo["year_tax_payable"])
if year_tax_payable < 20000 {
currentScore = 0
}else if year_tax_payable > 50000{
currentScore = 2
}else{
currentScore = 1
}
totalScore += currentScore
setInserScoreChanFooter(1,1,12)
}
//近两年内有无诉讼（2分）
func lawsuitsInPastTwoYars() {
two_years_no_lawsuit := stringTurnInt64(companyBasicInfo["two_years_no_lawsuit"])
if two_years_no_lawsuit == 1 {
currentScore = 0
}else{
currentScore = 2
}
totalScore += currentScore
setInserScoreChanFooter(1,1,13)
}
//社保参保人数（1分）
func NumberOfSocial() {
social_security_participants := stringTurnInt64(companyBasicInfo["social_security_participants"])
if social_security_participants > 5 {
currentScore = 1
}else{
currentScore = 0
}
totalScore += currentScore
setInserScoreChanFooter(1,1,14)
}
cmd/static/main.go
......@@ -9,17 +9,22 @@ import (
"kaopu-server/internal/dao"
"kaopu-server/internal/model"
"kaopu-server/internal/service"
"strconv"
"time"
)
var (
//获取的公司信息
companyData []map[string]interface{}
companyData []map[string]string
//插入分值的通道,限制一千，超过等待
socreRecordChan = make(chan model.Scores, 1000)
//分数的数据
insertScoreMsg model.Scores
//公司的详细数据
companyBasicInfo map[string]string
isOver = make(chan int)
)
......@@ -35,18 +40,24 @@ func main() {
//调用服务获取公司信息,然后进行全局赋值
companyData,_ = svc.GetCompanyCresitsList(ctx)
CompanyInfo()
//insertId,err := svc.InsertScores(ctx,insertScoreMsg)
//fmt.Print(err)
//fmt.Print(insertId)
//fmt.Print(companyData)
//EnterPriseCredit()
//HistoryBussiness()
//PersonalCredit()
//AddScore()
//延迟100秒用来执行协程的错误返回
time.Sleep(100000 * time.Millisecond)
for _,v :=range companyData{
insertScoreMsg.ComCreditsId = stringTurnInt64(v["id"])
companyBasicInfo,_ = svc.GetCompanyBaseInfoByCid(ctx,insertScoreMsg.ComCreditsId)
CompanyInfo()
//EnterPriseCredit()
//HistoryBussiness()
//PersonalCredit()
//AddScore()
}
// 判断所有协程是否退出
for range isOver {
close(isOver)
}
}
......@@ -67,10 +78,10 @@ func getConfig() {
//协程增加分值记录
func insertRecord() {
//声明service层
connect := dao.New()
ctx := context.Background()
for {
//声明service层
connect := dao.New()
ctx := context.Background()
// 从通道中拿出消息
insertScoreMsg := <- socreRecordChan
insertId,err := connect.InsertScores(ctx,insertScoreMsg)
......@@ -78,11 +89,26 @@ func insertRecord() {
fmt.Print(insertId)
//插入数据
}
isOver <- 1
}
//设置插入的分数头
func setInserScoreHeader(_typy,project_pid,project_id int8) {
insertScoreMsg.Type = _typy
insertScoreMsg.ProjectPid = project_pid
insertScoreMsg.ProjectId = project_id
func setInserScoreChanFooter(_typy,project_pid,project_id int8) {
insertScoreMsg.Type,insertScoreMsg.ProjectPid,insertScoreMsg.ProjectId = _typy,project_pid,project_id
socreRecordChan <- insertScoreMsg
}
func getTimeStamp()(timestamp int64) {
return time.Now().Unix()
}
func stringTurnInt64(val string) (int64) {
intval,_ := strconv.ParseInt(val, 10, 64)
return intval
}
func stringTurnFloat64(val string)(float64) {
floatval,_ := strconv.ParseFloat(val, 64)
return floatval
}
\ No newline at end of file
internal/dao/com_basicinfos.go 0 → 100644
package dao
import (
"context"
"fmt"
"github.com/pkg/errors"
"github.com/bilibili/kratos/pkg/database/sql"
)
//通过UID获取用户信息
func (d *dao) GetCompanyBaseInfoByCid(c context.Context, companyId int64) (res map[string]string, err error) {
var (
rows *sql.Rows
)
if rows, err = d.db.Query(c, "select "+ SqlField + " from lie_com_basicinfos where com_credits_id = ?",companyId); err != nil {
err = errors.WithStack(err)
return
}
defer rows.Close()
if err != nil{
fmt.Println("select fail,err:",err)
return
}
twoMap,err := GetAllParam(rows)
for _,v:=range twoMap{
res = v
break
}
return
}
\ No newline at end of file
internal/dao/com_credits.go
......@@ -8,7 +8,7 @@ import (
)
//列表方式获取会员信息
func (d *dao) GetCompanyCresitsList(ctx context.Context) (res []map[string]interface{}, err error) {
func (d *dao) GetCompanyCresitsList(ctx context.Context) (res []map[string]string, err error) {
var (
rows *sql.Rows
)
......@@ -24,7 +24,7 @@ func (d *dao) GetCompanyCresitsList(ctx context.Context) (res []map[string]inter
return
}
return getAllParam(rows)
return GetAllParam(rows)
}
......
internal/dao/common.go
......@@ -14,7 +14,7 @@ var(
//根据指针行获取所有的参数
func getAllParam(rows *sql.Rows)(res []map[string]interface{}, err error) {
func GetAllParam(rows *sql.Rows)(res []map[string]string, err error) {
cols,err := rows.Columns()
if err != nil{
fmt.Println("get columns fail,err:",err)
......@@ -22,13 +22,14 @@ func getAllParam(rows *sql.Rows)(res []map[string]interface{}, err error) {
}
vals := make([][]byte, len(cols))
scans := make([]interface{},len(cols))
for i := range vals{
scans[i] = &vals[i]
}
row := make(map[string]interface{})
row := make(map[string]string)
for rows.Next(){
err = rows.Scan(scans...)
......@@ -39,9 +40,12 @@ func getAllParam(rows *sql.Rows)(res []map[string]interface{}, err error) {
for k,v:=range vals{
key := cols[k]
row[key] = v
row[key] = string(v)
}
res = append(res,row)
}
return
}
\ No newline at end of file
}
internal/dao/dao.go
......@@ -21,9 +21,9 @@ type (
GetUserList(ctx context.Context) (r []*model.Users, err error)
//---静态开始
GetCompanyCresitsList(ctx context.Context) (r []map[string]interface{}, err error)
GetCompanyCresitsList(ctx context.Context) (r []map[string]string, 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)
//---静态结束
}
)
......
internal/dao/scores.go
......@@ -2,18 +2,17 @@ package dao
import (
"context"
"fmt"
"kaopu-server/internal/model"
"github.com/bilibili/kratos/pkg/log"
"kaopu-server/internal/model"
"time"
)
//增加记录
func (d *dao) InsertScores(ctx context.Context,score model.Scores) (insertId int64,err error) {
insertSql := "INSERT INTO `lie_scores` (`type`)VALUES(?)"
insertSql := "INSERT INTO `lie_scores` (`type`, `project_pid`, `project_id`, `total_score`, `current_score`, `weight`, `final_score`, `com_credits_id`, `create_time`)VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?)"
row,err := d.db.Exec(ctx,insertSql,1)
fmt.Print(11111)
row,err := d.db.Exec(ctx,insertSql,score.Type,score.ProjectPid,score.ProjectId,score.TotalScore,score.CurrentScore,score.Weight,score.FinalScore,score.ComCreditsId,time.Now().Unix())
if err != nil {
log.Error("db.DemoExec.Exec(%s) error(%v)", insertSql, err)
......
internal/model/com_credits_basicinfos.go → internal/model/com_basicinfos.go
......@@ -20,6 +20,10 @@ type ComCreditsBasicInfos struct {
ComContact string `json:"com_contact"` //'企业联系人'
ContactFixTelephone string `json:"contact_fix_telephone"` //'企业联系人固定电话'
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"`
SocialSecurityParticiPant int16 `json:"social_security_participants"`
CreateTime int64 `json:"create_time"` //'创建时间'
UpdateTime int64 `json:"update_time"` //'更新时间'
}
......@@ -34,7 +38,7 @@ type ComCreditsBasicInfos struct {
`establishment_time` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '公司成立时间',
`com_leader` varchar(60) NOT NULL DEFAULT '' COMMENT '公司负责人',
`registered_capital` decimal(14,4) unsigned NOT NULL DEFAULT '0.0000' COMMENT '注册资本',
`customer_property` varchar(50) NOT NULL DEFAULT '' COMMENT '客户性质',
`customer_property` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '客户性质 0 其它 1上市 2国企 3央企',
`score_time` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '评分时间',
`com_address` varchar(100) NOT NULL DEFAULT '' COMMENT '公司地址',
`legal_representative` varchar(50) NOT NULL DEFAULT '' COMMENT '法定代表人',
......@@ -46,6 +50,10 @@ type ComCreditsBasicInfos struct {
`com_contact` varchar(50) NOT NULL DEFAULT '' COMMENT '企业联系人',
`contact_fix_telephone` varchar(15) NOT NULL DEFAULT '' COMMENT '企业联系人',
`contact_mobile_phone` char(11) NOT NULL DEFAULT '' COMMENT '企业联系人移动电话',
`five_legal_change` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '5年内法人变更次数',
`year_tax_payable` decimal(14,4) unsigned NOT NULL DEFAULT '0.0000' COMMENT '年纳税额',
`two_years_no_lawsuit` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '近两年内有无诉讼 1有 ',
`social_security_participants` smallint(10) unsigned NOT NULL DEFAULT '0' COMMENT '社保参保人数',
`create_time` int(11) unsigned NOT NULL DEFAULT '0',
`update_time` int(11) unsigned NOT NULL DEFAULT '0',
PRIMARY KEY (`id`),
......
internal/service/service.go
......@@ -62,23 +62,22 @@ func (s *Service) GetUserList(ctx context.Context) (res []*model.Users, err erro
//----------静态开始
// 获取公司用户列表
func (s *Service) GetCompanyCresitsList(ctx context.Context) (res []map[string]interface{}, err error) {
func (s *Service) GetCompanyCresitsList(c context.Context) (res []map[string]string, err error) {
//调用DB方法，获取会员数据
res, err = s.dao.GetCompanyCresitsList(ctx)
res, err = s.dao.GetCompanyCresitsList(c)
fmt.Print(err)
return
}
//插入分数记录
func (s *Service) InsertScores(ctx context.Context,score model.Scores) (insertId int64, err error) {
// 获取公司用户列表
func (s *Service) GetCompanyBaseInfoByCid(c context.Context, companyId int64) (res map[string]string, err error) {
//调用DB方法，获取会员数据
insertId,err = s.dao.InsertScores(ctx,score)
if err != nil {
panic(err.Error()) // proper error handling instead of panic in your app
}
res, err = s.dao.GetCompanyBaseInfoByCid(c,companyId)
fmt.Print(err)
return
}
//----------静态结束
\ No newline at end of file
logs/info.log
......@@ -227,3 +227,57 @@
[2019/11/25 14:31:31.937] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:62] caipu-server start
[2019/11/25 14:41:01.973] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:62] caipu-server start
[2019/11/25 14:41:52.333] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:62] caipu-server start
[2019/11/25 15:58:03.453] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:63] caipu-server start
[2019/11/25 15:58:10.193] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:63] caipu-server start
[2019/11/25 15:58:18.486] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:63] caipu-server start
[2019/11/25 15:58:25.374] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:63] caipu-server start
[2019/11/25 16:04:52.834] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 16:06:34.256] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:73] caipu-server start
[2019/11/25 16:07:09.622] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:73] caipu-server start
[2019/11/25 16:07:30.215] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:73] caipu-server start
[2019/11/25 16:08:23.058] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:73] caipu-server start
[2019/11/25 17:09:19.290] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:73] caipu-server start
[2019/11/25 17:10:22.523] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:73] caipu-server start
[2019/11/25 17:10:59.905] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:73] caipu-server start
[2019/11/25 17:11:40.761] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 17:13:25.558] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:73] caipu-server start
[2019/11/25 17:14:04.150] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 17:16:46.948] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 17:17:24.147] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 17:17:29.643] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 17:18:50.226] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 17:25:29.873] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:75] caipu-server start
[2019/11/25 17:35:25.055] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 17:36:13.579] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 17:39:49.852] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 17:47:44.444] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 17:50:18.355] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 17:50:45.717] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 17:52:10.937] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 17:52:43.048] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 17:55:49.638] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:77] caipu-server start
[2019/11/25 17:58:01.863] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 17:58:20.307] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 17:59:10.185] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:01:29.302] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:02:17.206] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:05:47.821] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:06:16.273] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:06:26.723] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:06:47.276] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:06:58.597] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:07:31.941] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:76] caipu-server start
[2019/11/25 18:44:04.196] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 18:44:14.482] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 18:45:26.884] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 18:45:31.148] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 18:45:53.256] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:69] caipu-server start
[2019/11/25 18:46:51.750] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:69] caipu-server start
[2019/11/25 19:29:39.290] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 19:30:01.571] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 19:34:09.822] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 19:35:34.066] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 19:36:50.037] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 19:37:02.573] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:70] caipu-server start
[2019/11/25 19:46:54.194] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
[2019/11/25 19:48:42.586] [INFO] [/usr/local/var/www/ichunt/kaopu-server/cmd/static/main.go:74] caipu-server start
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment