Skip to content

孙龙 / kaopu-server

Go to a project
Commit f0337fa7 by Joneq
Options

完成公司信息算法

parents 8314ff4e 46601ca6
Inline Side-by-side
Showing with 197 additions and 77 deletions
.gitignore
...@@ -16,3 +16,4 @@ Homestead.json ...@@ -16,3 +16,4 @@ Homestead.json
/configs /configs
cmd/cmd.exe cmd/cmd.exe
cmd/move/logs/ cmd/move/logs/
/cmd/dong/logs/*.log
cmd/dong/main.go 0 → 100644
package main
import (
"flag"
"context"
"kaopu-server/internal/service"
"github.com/bilibili/kratos/pkg/conf/paladin"
"github.com/bilibili/kratos/pkg/log"
"time"
"fmt"
"os"
)
func main() {
//获取输入参数
var mod int;
flag.IntVar(&mod, "m", 0, "请输入模块id") // 单独计算某个模块，默认计算全部,0计算全部
flag.Parse()
if err := paladin.Init(); err != nil {
panic(err)
}
//模块对应的值
var model_dong = map[int]string{
0:"所有",
35:"逾期金额率",
36:"发生逾期笔数率",
37:"平均逾期支付时间(天）",
38:"平均付款时间（天）",
39:"正常收款笔数率",
40:"近6个月账期变化率",
41:"交货及时率",
42:"退货率",
43:"近6个月逾期变化率",
44:"近6个月参保人数变化率",
}
_ ,ok := model_dong[mod]
if !ok {
fmt.Println("模块名称输入错误！")
os.Exit(1)
}
ctx := context.Background() //上下文
svc := service.New()
switch mod{
case 35: //计算逾期率
fmt.Println("计算逾期率开始："+time.Now().Format("2006-01-02 15:04:05"))
svc.CountYuqi(ctx,mod);
default:
fmt.Println(mod)
//实例化所有
}
//初始化日志目录
log.Init(&log.Config{Dir: "logs"})
defer log.Close()
log.Info("caipu-server start")
//声明service层
//svc := service.New()
//ctx := context.Background()
////调用会员服务
//for{
// // svc.GetUserList(ctx)
// fmt.Println("nnii")
// fmt.Println(time.Now())
time.Sleep(time.Second)
//}
}
cmd/move/main.go deleted 100644 → 0
package main
import (
"flag"
"context"
"kaopu-server/internal/service"
"github.com/bilibili/kratos/pkg/conf/paladin"
"github.com/bilibili/kratos/pkg/log"
)
func main() {
//获取输入参数
flag.Parse()
if err := paladin.Init(); err != nil {
panic(err)
}
//初始化日志目录
log.Init(&log.Config{Dir: "logs"})
defer log.Close()
log.Info("caipu-server start")
//声明service层
svc := service.New()
ctx := context.Background()
//调用会员服务
svc.GetUserList(ctx)
}
cmd/move/yuqi.go deleted 100644 → 0
package main
import (
"flag"
"context"
"kaopu-server/internal/service"
"github.com/bilibili/kratos/pkg/conf/paladin"
"github.com/bilibili/kratos/pkg/log"
)
func main() {
//获取输入参数
flag.Parse()
if err := paladin.Init(); err != nil {
panic(err)
}
//初始化日志目录
log.Init(&log.Config{Dir: "logs"})
defer log.Close()
log.Info("caipu-server start")
//声明service层
svc := service.New()
ctx := context.Background()
//调用会员服务
svc.GetUserList(ctx)
}
internal/dao/common.go
...@@ -11,8 +11,6 @@ var( ...@@ -11,8 +11,6 @@ var(
SqlField string = "*" SqlField string = "*"
) )
//根据指针行获取所有的参数 //根据指针行获取所有的参数
func GetAllParam(rows *sql.Rows)(res []map[string]string, err error) { func GetAllParam(rows *sql.Rows)(res []map[string]string, err error) {
cols,err := rows.Columns() cols,err := rows.Columns()
...@@ -46,6 +44,3 @@ func GetAllParam(rows *sql.Rows)(res []map[string]string, err error) { ...@@ -46,6 +44,3 @@ func GetAllParam(rows *sql.Rows)(res []map[string]string, err error) {
} }
return return
} }
internal/dao/dao.go
...@@ -25,6 +25,8 @@ type ( ...@@ -25,6 +25,8 @@ 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)
//---静态结束 //---静态结束
CountYuqi(ctx context.Context,project_id int) (r []map[string]interface{},err error) //计算逾期
} }
) )
......
internal/dao/yuqi_dao.go 0 → 100644
package dao
import (
"context"
"fmt"
"github.com/bilibili/kratos/pkg/database/sql"
//"github.com/pkg/errors"
//"strconv"
"kaopu-server/internal/model"
"os"
)
const (
_sql1= "select id,project_name from lie_model where project_id=? limit 1" //查询项目配置
_sql2 = "select * from lie_basic_info "
)
var(
project_res []map[string]interface{}
)
//计算逾期分数
func (d *dao) CountYuqi(ctx context.Context,project_id int) (r []map[string]interface{},err error) {
var (
// rows *sql.Rows
row *sql.Row
mod *model.Models
)
mod = new(model.Models)
row = d.db.QueryRow(ctx, _sql1,project_id)
if err = row.Scan(&mod.Id, &mod.Project_name); err != nil {
err = nil
return
}
fmt.Println(mod.Id)
os.Exit(1)
//if row, err = d.db.QueryRow(ctx, _sql1,project_id); err != nil {
////查询项目配置
////if rows, err = d.db.Query(ctx, fmt.Sprintf(_sql2,strconv.Itoa(project_id))); err != nil {
// err = errors.WithStack(err)
// return
//}
//defer rows.Close()
//if err != nil{
// fmt.Println("select fail,err:",err)
// return
//}
//
//project_res,_ = getAllParam(rows); //
//if project_res == nil {
// return
//}
//fmt.Println(project_res)
//os.Exit(1)
return
}
internal/model/model.go deleted 100644 → 0
package model
// Kratos hello kratos.
type Kratos struct {
Hello string
}
\ No newline at end of file
internal/model/models.go 0 → 100644
package model
// Kratos hello kratos.
type Models struct {
Id int64 `json:"id"`
Project_id string `json:"project_id"`
Project_name string `json:"project_name"`
Classify_type int `json:"classify_type"`
}
//CREATE TABLE `lie_model` (
//`id` int(10) unsigned NOT NULL AUTO_INCREMENT COMMENT '模型ID',
//`type` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '项目类型：1静态 2动态 3银行端',
//`project_id` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '项目ID',
//`project_name` varchar(128) CHARACTER SET utf8 NOT NULL DEFAULT '' COMMENT '项目名称',
//`classify_type` tinyint(1) unsigned NOT NULL DEFAULT '0' COMMENT '分类类型，1-公司信息，2-企业征信，3-个人征信，4-历史交易情况，5-加分项，6-动态模型',
//`numeric_type` tinyint(2) unsigned NOT NULL DEFAULT '0' COMMENT '数值类型',
//`unit` tinyint(2) unsigned NOT NULL DEFAULT '0' COMMENT '单位',
//`full_score` int(5) unsigned NOT NULL DEFAULT '0' COMMENT '满分分值',
//`weight` decimal(5,2) unsigned NOT NULL DEFAULT '0.00' COMMENT '权重',
//`ladder` int(3) unsigned NOT NULL DEFAULT '0' COMMENT '阶梯（项目阶梯总数目）',
//`max_score` int(5) unsigned NOT NULL DEFAULT '0' COMMENT '最高分值（项目各阶梯分值之和）',
//`status` tinyint(1) NOT NULL DEFAULT '1' COMMENT '状态，1-启用，-1-禁用',
//`creator` varchar(64) CHARACTER SET utf8 NOT NULL DEFAULT '' COMMENT '创建人',
//`create_time` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '创建时间',
//`update_time` int(10) unsigned NOT NULL DEFAULT '0' COMMENT '更新时间',
//PRIMARY KEY (`id`),
//KEY `project_time` (`classify_type`,`create_time`) USING BTREE,
//KEY `status_time` (`status`,`create_time`) USING BTREE
//) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8mb4 COMMENT='模型配置表'
\ No newline at end of file
internal/service/dong_service.go 0 → 100644
/*
动态模型server
*/
package service
import (
"context"
"fmt"
)
//计算逾期率
func (s *Service) CountYuqi(ctx context.Context,project_id int) (res []map[string]interface{}, err error) {
//调用DB方法，获取会员数据
res, err = s.dao.CountYuqi(ctx,project_id)
fmt.Print(err)
return
}
\ No newline at end of file
internal/service/service.go
...@@ -7,7 +7,7 @@ import ( ...@@ -7,7 +7,7 @@ import (
"kaopu-server/internal/model" "kaopu-server/internal/model"
"github.com/bilibili/kratos/pkg/conf/paladin" "github.com/bilibili/kratos/pkg/conf/paladin"
"github.com/pkg/errors" "github.com/pkg/errors"
) )
// Service service. // Service service.
......
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