team/znc-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
liangzai
2025-08-18 18:56:00 +08:00
parent 0b0548d495
commit 13074b4ac2
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
app/main/api/internal/service/apirequestService.go
View File

@@ -99,6 +99,9 @@ func (a *ApiRequestService) ProcessRequests(params []byte, productID int64) ([]b
go func(i int, feature *model.Feature) { go func(i int, feature *model.Feature) {
defer wg.Done() defer wg.Done()
// 错开并发请求时间，每个请求之间固定延迟50毫秒
time.Sleep(50 * time.Millisecond)
select { select {
case <-ctx.Done(): case <-ctx.Done():
return return
@@ -388,6 +391,10 @@ func (a *ApiRequestService) ProcessPersonEnterpriseProRequest(params []byte) ([]
wg.Add(1) wg.Add(1)
go func(origIndex int, companyInfo gjson.Result) { go func(origIndex int, companyInfo gjson.Result) {
defer wg.Done() defer wg.Done()
// 错开并发请求时间，每个请求之间固定延迟50毫秒
time.Sleep(50 * time.Millisecond)
logx.Infof("开始处理企业[%d]，企业名称: %s，统一社会信用代码: %s", origIndex, companyInfo.Get("basicInfo.name").String(), companyInfo.Get("basicInfo.creditCode").String()) logx.Infof("开始处理企业[%d]，企业名称: %s，统一社会信用代码: %s", origIndex, companyInfo.Get("basicInfo.name").String(), companyInfo.Get("basicInfo.creditCode").String())
// 提取企业名称和统一社会信用代码 // 提取企业名称和统一社会信用代码
orgName := companyInfo.Get("basicInfo.name") orgName := companyInfo.Get("basicInfo.name")
@@ -415,8 +422,9 @@ func (a *ApiRequestService) ProcessPersonEnterpriseProRequest(params []byte) ([]
// 调用QYGL8271接口获取企业涉诉信息 // 调用QYGL8271接口获取企业涉诉信息
lawsuitResp, err := a.tianyuanapi.CallInterface("QYGL8271", map[string]interface{}{ lawsuitResp, err := a.tianyuanapi.CallInterface("QYGL8271", map[string]interface{}{
"ent_name": orgName.String(), "ent_name": orgName.String(),
"ent_code": creditCode.String(), "ent_code": creditCode.String(),
"auth_date": generateAuthDateRange(),
}) })
// 无论是否有错误，都继续处理 // 无论是否有错误，都继续处理
if err != nil { if err != nil {
@@ -540,8 +548,8 @@ func (a *ApiRequestService) ProcessPersonEnterpriseProRequest(params []byte) ([]
func (a *ApiRequestService) ProcesFLXG0V4BRequest(params []byte) ([]byte, error) { func (a *ApiRequestService) ProcesFLXG0V4BRequest(params []byte) ([]byte, error) {
name := gjson.GetBytes(params, "name") name := gjson.GetBytes(params, "name")
idCard := gjson.GetBytes(params, "id_card") idCard := gjson.GetBytes(params, "id_card")
if !name.Exists() || !idCard.Exists(){ if !name.Exists() || !idCard.Exists() {
return nil, errors.New("api请求, BehaviorRiskScan, 获取相关参数失败") return nil, errors.New("api请求, FLXG0V4B, 获取相关参数失败")
} }
resp, err := a.tianyuanapi.CallInterface("FLXG0V4B", map[string]interface{}{ resp, err := a.tianyuanapi.CallInterface("FLXG0V4B", map[string]interface{}{
@@ -558,6 +566,7 @@ func (a *ApiRequestService) ProcesFLXG0V4BRequest(params []byte) ([]byte, error)
} }
return respBytes, nil return respBytes, nil
} }
// ProcessFLXG0687Request 反诈反赌核验 // ProcessFLXG0687Request 反诈反赌核验
func (a *ApiRequestService) ProcessFLXG0687Request(params []byte) ([]byte, error) { func (a *ApiRequestService) ProcessFLXG0687Request(params []byte) ([]byte, error) {
idCard := gjson.GetBytes(params, "id_card") idCard := gjson.GetBytes(params, "id_card")