完成数据提交

http/internal/server/http/erp/company.go

+package erp
+
+import (
+	"encoding/json"
+	"fmt"
+	bm "github.com/go-kratos/kratos/pkg/net/http/blademaster"
+	"kaopu-server/http/internal/dao"
+	"strings"
+)
+
+//erp需要获取的公司信息
+
+const SELECTERPCOMBASIC = "select " +
+	"com_name ,com_organization ,establishment_time ,customer_property ,registered_capital ,legal_representative,tianyancha_json ,com_address " +
+	" from lie_com_basicinfos where com_name = ?"
+
+type ErpCompanyInfo struct {
+	ComName 				string	`json:"com_name"` //'公司名称'
+	ComOrganization 		string	`json:"com_organization"` //'组织结构代码'
+	EstanlishmentTime 		int64	`json:"establishment_time"` //'公司成立时间'
+	RegisteredCapital 		string		`json:"registered_capital"` //'注册资本'
+	CustomerProperty 		string		`json:"customer_property"` //'客户性质'
+	LegalRepresentative 	string		`json:"legal_representative"` //'法定代表人'
+	TianyanchaJson 			string		`json:"tianyancha_json"`
+	ComAddress 				string		`json:"com_address"` //'公司地址'
+	TianyanchaInfo ErpTianYanChaCompanyInfo `json:"tyc_info"` //'tycjson'
+}
+
+
+type ErpTianYanChaCompanyInfo struct {
+	RegNumber string `json:"regNumber"`
+	CreditCode string `json:"creditCode"`
+	TaxNumber string `json:"taxNumber"`
+	RegCapitalCurrency 		string `json:"regCapitalCurrency"`
+}
+
+type ErpResultStruct struct {
+	Result ErpTianYanChaCompanyInfo `json:"result"`
+}
+
+
+func GetCompanyInfo(c *bm.Context)  {
+
+	var erpCompanyInfo ErpCompanyInfo
+	var erpJson ErpResultStruct
+	companyName,_ := c.Params.Get("company_name")
+	db,closedb,err := dao.NewDB()
+	if err != nil {
+		fmt.Println(err)
+	}
+	err = db.QueryRow(c,SELECTERPCOMBASIC,companyName).Scan(&erpCompanyInfo.ComName,&erpCompanyInfo.ComOrganization,&erpCompanyInfo.EstanlishmentTime,
+	&erpCompanyInfo.CustomerProperty,&erpCompanyInfo.RegisteredCapital,&erpCompanyInfo.LegalRepresentative,&erpCompanyInfo.TianyanchaJson,&erpCompanyInfo.ComAddress)
+
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	jsonArr := strings.Split(erpCompanyInfo.TianyanchaJson,"||||")
+	if len(jsonArr) > 1 {
+		err = json.Unmarshal([]byte(jsonArr[0]),&erpJson)
+		erpCompanyInfo.TianyanchaInfo = erpJson.Result
+	}
+	erpCompanyInfo.TianyanchaJson = ""
+	c.JSON(erpCompanyInfo,nil)
+	closedb()
+}
\ No newline at end of file

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

@@ -10,7 +10,7 @@ import (
 
 
 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 INSERTCOMPANYBASICINFO  = "insert into `lie_com_basicinfos` (`com_credits_id`,`com_name`,`create_time`,`tianyancha_json`)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 " +

http/internal/server/http/server.go

 package http
 
 import (
+	"kaopu-server/http/internal/server/http/erp"
 	"kaopu-server/http/internal/server/http/member"
 	"net/http"
 
@@ -42,6 +43,9 @@ func initRouter(e *bm.Engine) {
 		//会员系统的接口
 		g.GET("/member/company_info/:company_name", member.GetCompanyInfo)
 
+		//会员系统的接口
+		g.GET("/erp/company_info/:company_name", erp.GetCompanyInfo)
+
 	}
 }