57 lines
2.1 KiB
Go
57 lines
2.1 KiB
Go
package kafka
|
||
|
||
import (
|
||
"context"
|
||
"encoding/json"
|
||
"finclip-app-manager/infrastructure/config"
|
||
uuid "github.com/satori/go.uuid"
|
||
"time"
|
||
)
|
||
|
||
//tam备案
|
||
type TamRecordContent struct {
|
||
OrganId string `json:"organId"` //机构id
|
||
OrganName string `json:"organName"` //机构名称
|
||
SocialCreditCode string `json:"socialCreditCode"` //社会信用代码
|
||
OrganType string `json:"organType"` //机构类型
|
||
OrganProperty string `json:"organProperty"` //机构性质
|
||
Address string `json:"address"` //地址
|
||
Phone string `json:"phone"` //电话
|
||
Email string `json:"email"` //email
|
||
Website string `json:"website"` //网址
|
||
Foundation string `json:"foundation"` //成立时间
|
||
}
|
||
|
||
type TamBaseContent struct {
|
||
Id string `json:"id"` //业务层防止重复消费
|
||
DataType int `json:"dataType"` //数据类型，1：备案；2：异常数据上报
|
||
Data TamRecordContent `json:"data"`
|
||
}
|
||
|
||
func GenTamRecordContentData(ctx context.Context, organId, owner, socialCreditCode string) error {
|
||
if producer == nil {
|
||
return nil
|
||
}
|
||
|
||
var tamBaseContent TamBaseContent
|
||
tamBaseContent.Id = uuid.NewV4().String()
|
||
tamBaseContent.DataType = 1
|
||
tamBaseContent.Data.OrganId = organId
|
||
tamBaseContent.Data.OrganName = owner
|
||
tamBaseContent.Data.SocialCreditCode = socialCreditCode //需要改造成应用所属企业社会编码
|
||
tamBaseContent.Data.OrganType = "2"
|
||
tamBaseContent.Data.OrganProperty = "1"
|
||
tamBaseContent.Data.Address = "深圳市南山区侨香路4080号·侨城坊1栋26~33楼"
|
||
tamBaseContent.Data.Phone = "0755-8318 3333"
|
||
tamBaseContent.Data.Email = "ccs@sscc.com"
|
||
tamBaseContent.Data.Website = "https://open.fdep.cn/#/"
|
||
|
||
nowTime := time.Now().UnixNano() / 1000000
|
||
timeFormat := "2006-01-02 15:04:05"
|
||
tamBaseContent.Data.Foundation = time.Unix(nowTime/1000, 0).Format(timeFormat)
|
||
|
||
jsonBytes, _ := json.Marshal(tamBaseContent)
|
||
|
||
return sendMsg(ctx, config.GetConfig().KafkaTamTopic, string(jsonBytes))
|
||
}
|