1、股东人企关系精准版加密方式修改 2、CallAPI传参方式修改
This commit is contained in:
parent
c27cb87ed2
commit
2dca92f4dd
@ -19,6 +19,7 @@ WestConfig:
|
|||||||
Url: "http://proxy.tianyuanapi.com/api/invoke"
|
Url: "http://proxy.tianyuanapi.com/api/invoke"
|
||||||
Key: "121a1e41fc1690dd6b90afbcacd80cf4"
|
Key: "121a1e41fc1690dd6b90afbcacd80cf4"
|
||||||
SecretId: "449159"
|
SecretId: "449159"
|
||||||
|
SecretSecondId: "296804"
|
||||||
UserRpc:
|
UserRpc:
|
||||||
Etcd:
|
Etcd:
|
||||||
Hosts:
|
Hosts:
|
||||||
|
@ -22,5 +22,6 @@ KqPusherConf:
|
|||||||
Topic: apirequest
|
Topic: apirequest
|
||||||
WestConfig:
|
WestConfig:
|
||||||
Url: "https://apimaster.westdex.com.cn/api/invoke"
|
Url: "https://apimaster.westdex.com.cn/api/invoke"
|
||||||
key: "121a1e41fc1690dd6b90afbcacd80cf4"
|
Key: "121a1e41fc1690dd6b90afbcacd80cf4"
|
||||||
secretId: "449159"
|
SecretId: "449159"
|
||||||
|
SecretSecondId: "296804"
|
@ -20,7 +20,8 @@ type KqPusherConf struct {
|
|||||||
Topic string
|
Topic string
|
||||||
}
|
}
|
||||||
type WestConfig struct {
|
type WestConfig struct {
|
||||||
Url string
|
Url string
|
||||||
Key string
|
Key string
|
||||||
SecretId string
|
SecretId string
|
||||||
|
SecretSecondId string
|
||||||
}
|
}
|
||||||
|
@ -90,7 +90,7 @@ func (l *FLXG162ALogic) FLXG162A(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG162AFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG162AFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G32BJ05", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G32BJ05", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -92,7 +92,7 @@ func (l *FLXG3D56Logic) FLXG3D56(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG3D56FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG3D56FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G26BJ05", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G26BJ05", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *FLXG54F5Logic) FLXG54F5(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG54F5FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG54F5FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G03HZ01", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G03HZ01", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *FLXG5876Logic) FLXG5876(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG5876FieldMapping, "")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG5876FieldMapping, "")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G03XM02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G03XM02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *FLXG9687Logic) FLXG9687(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG9687FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG9687FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G31BJ05", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G31BJ05", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *FLXG970FLogic) FLXG970F(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG970FFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXG970FFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("WEST00028", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("WEST00028", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *FLXGC9D1Logic) FLXGC9D1(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGC9D1FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGC9D1FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G30BJ05", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G30BJ05", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *FLXGCA3DLogic) FLXGCA3D(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGCA3DFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGCA3DFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G22BJ03", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G22BJ03", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *FLXGDEC7Logic) FLXGDEC7(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGDEC7FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGDEC7FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G23BJ03", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G23BJ03", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -86,7 +86,7 @@ func (l *IVYZ0B03Logic) IVYZ0B03(req *types.Request) (resp string, err *errs.App
|
|||||||
//logx.Infof("交易号:%s", transactionID)
|
//logx.Infof("交易号:%s", transactionID)
|
||||||
//apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGDEC7FieldMapping, "data")
|
//apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGDEC7FieldMapping, "data")
|
||||||
//
|
//
|
||||||
//westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G23BJ03", apiRequest)
|
//westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G23BJ03", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
//if callAPIErr != nil {
|
//if callAPIErr != nil {
|
||||||
// return "", errs.ErrSystem
|
// return "", errs.ErrSystem
|
||||||
//}
|
//}
|
||||||
|
@ -87,7 +87,7 @@ func (l *IVYZ2125Logic) IVYZ2125(req *types.Request) (resp string, err *errs.App
|
|||||||
//logx.Infof("交易号:%s", transactionID)
|
//logx.Infof("交易号:%s", transactionID)
|
||||||
//apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGDEC7FieldMapping, "data")
|
//apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGDEC7FieldMapping, "data")
|
||||||
//
|
//
|
||||||
//westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G23BJ03", apiRequest)
|
//westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G23BJ03", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
//if callAPIErr != nil {
|
//if callAPIErr != nil {
|
||||||
// return "", errs.ErrSystem
|
// return "", errs.ErrSystem
|
||||||
//}
|
//}
|
||||||
|
@ -90,7 +90,7 @@ func (l *IVYZ385ELogic) IVYZ385E(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.IVYZ385EFieldMapping, "")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.IVYZ385EFieldMapping, "")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("WEST00020", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("WEST00020", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -89,7 +89,7 @@ func (l *IVYZ5733Logic) IVYZ5733(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.IVYZ5733FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.IVYZ5733FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G09GX01", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G09GX01", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *IVYZ9363Logic) IVYZ9363(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.IVYZ9363FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.IVYZ9363FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G10GX01", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G10GX01", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -86,7 +86,7 @@ func (l *IVYZADEELogic) IVYZADEE(req *types.Request) (resp string, err *errs.App
|
|||||||
//logx.Infof("交易号:%s", transactionID)
|
//logx.Infof("交易号:%s", transactionID)
|
||||||
//apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGDEC7FieldMapping, "data")
|
//apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.FLXGDEC7FieldMapping, "data")
|
||||||
//
|
//
|
||||||
//westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("idCardThreeElements", apiRequest)
|
//westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("idCardThreeElements", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
//if callAPIErr != nil {
|
//if callAPIErr != nil {
|
||||||
// return "", errs.ErrSystem
|
// return "", errs.ErrSystem
|
||||||
//}
|
//}
|
||||||
|
@ -90,7 +90,7 @@ func (l *JRZQ0A03Logic) JRZQ0A03(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.JRZQ0A03FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.JRZQ0A03FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G27BJ05", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G27BJ05", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *JRZQ4AA8Logic) JRZQ4AA8(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.JRZQ4AA8FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.JRZQ4AA8FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G29BJ05", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G29BJ05", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *JRZQ8203Logic) JRZQ8203(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.JRZQ8203FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.JRZQ8203FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G28BJ05", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G28BJ05", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *JRZQDCBELogic) JRZQDCBE(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.JRZQDBCEFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.JRZQDBCEFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G20GZ01", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G20GZ01", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *QYGL2ACDLogic) QYGL2ACD(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGL2ACDFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGL2ACDFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("WEST00022", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("WEST00022", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *QYGL45BDLogic) QYGL45BD(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGL45BDFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGL45BDFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("WEST00021", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("WEST00021", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *QYGL6F2DLogic) QYGL6F2D(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGL6F2DFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGL6F2DFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G05XM02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G05XM02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *QYGL8261Logic) QYGL8261(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGL8261FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGL8261FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("Q03BJ03", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("Q03BJ03", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -79,18 +79,22 @@ func (l *QYGLB4C0Logic) QYGLB4C0(req *types.Request) (resp string, err *errs.App
|
|||||||
}
|
}
|
||||||
|
|
||||||
// 3、西部加密
|
// 3、西部加密
|
||||||
westConfig := l.svcCtx.Config.WestConfig
|
//westConfig := l.svcCtx.Config.WestConfig
|
||||||
encryptedFields, encryptStructFieldsErr := common.EncryptStructFields(data, westConfig.Key)
|
//encryptedFields, encryptStructFieldsErr := common.EncryptStructFields(data, westConfig.Key)
|
||||||
if encryptStructFieldsErr != nil {
|
//if encryptStructFieldsErr != nil {
|
||||||
logx.Errorf("西部加密错误:%v", encryptStructFieldsErr)
|
// logx.Errorf("西部加密错误:%v", encryptStructFieldsErr)
|
||||||
return "", errs.ErrSystem
|
// return "", errs.ErrSystem
|
||||||
|
//}
|
||||||
|
IDCard := crypto.Md5Encrypt(data.IDCard)
|
||||||
|
encryptedFields := map[string]interface{}{
|
||||||
|
"IDCard": IDCard,
|
||||||
}
|
}
|
||||||
|
|
||||||
// 4、发送请求到西部
|
// 4、发送请求到西部
|
||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGLB4C0FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.QYGLB4C0FieldMapping, "")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G05HZ01", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G05HZ01", apiRequest, l.svcCtx.Config.WestConfig.SecretSecondId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -91,7 +91,7 @@ func (l *YYSY09CDLogic) YYSY09CD(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSY09CDFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSY09CDFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G16BJ02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G16BJ02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *YYSY4B21Logic) YYSY4B21(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSY4B21FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSY4B21FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G25BJ02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G25BJ02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *YYSY4B37Logic) YYSY4B37(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSY4B37FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSY4B37FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G02BJ02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G02BJ02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -91,7 +91,7 @@ func (l *YYSY6F2ELogic) YYSY6F2E(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSY6F2EFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSY6F2EFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G15BJ02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G15BJ02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *YYSYBE08Logic) YYSYBE08(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSYBE08FieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSYBE08FieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G17BJ02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G17BJ02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -90,7 +90,7 @@ func (l *YYSYD50FLogic) YYSYD50F(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSYD50FFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSYD50FFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G18BJ02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G18BJ02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -88,7 +88,7 @@ func (l *YYSYF7DBLogic) YYSYF7DB(req *types.Request) (resp string, err *errs.App
|
|||||||
logx.Infof("交易号:%s", transactionID)
|
logx.Infof("交易号:%s", transactionID)
|
||||||
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSYF7DBFieldMapping, "data")
|
apiRequest := common.MapStructToAPIRequest(encryptedFields, westmodel.YYSYF7DBFieldMapping, "data")
|
||||||
|
|
||||||
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G19BJ02", apiRequest)
|
westResp, callAPIErr := l.svcCtx.WestDexService.CallAPI("G19BJ02", apiRequest, l.svcCtx.Config.WestConfig.SecretId)
|
||||||
if callAPIErr != nil {
|
if callAPIErr != nil {
|
||||||
if callAPIErr.Code == errs.ErrDataSource.Code {
|
if callAPIErr.Code == errs.ErrDataSource.Code {
|
||||||
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
encryptData, aesEncrypt := crypto.AesEncrypt(westResp, key)
|
||||||
|
@ -37,13 +37,13 @@ func NewWestDexService(config config.WestConfig) *WestDexService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// CallAPI 调用西部数据的 API
|
// CallAPI 调用西部数据的 API
|
||||||
func (w *WestDexService) CallAPI(code string, reqData map[string]interface{}) (resp []byte, err *errs.AppError) {
|
func (w *WestDexService) CallAPI(code string, reqData map[string]interface{}, secretId string) (resp []byte, err *errs.AppError) {
|
||||||
logx.Infof("西部请求传入%v", reqData)
|
logx.Infof("西部请求传入%v", reqData)
|
||||||
// 生成当前的13位时间戳
|
// 生成当前的13位时间戳
|
||||||
timestamp := strconv.FormatInt(time.Now().UnixNano()/int64(time.Millisecond), 10)
|
timestamp := strconv.FormatInt(time.Now().UnixNano()/int64(time.Millisecond), 10)
|
||||||
|
|
||||||
// 构造请求URL
|
// 构造请求URL
|
||||||
reqUrl := fmt.Sprintf("%s/%s/%s?timestamp=%s", w.config.Url, w.config.SecretId, code, timestamp)
|
reqUrl := fmt.Sprintf("%s/%s/%s?timestamp=%s", w.config.Url, secretId, code, timestamp)
|
||||||
|
|
||||||
jsonData, marshalErr := json.Marshal(reqData)
|
jsonData, marshalErr := json.Marshal(reqData)
|
||||||
if marshalErr != nil {
|
if marshalErr != nil {
|
||||||
|
@ -4,8 +4,10 @@ import (
|
|||||||
"bytes"
|
"bytes"
|
||||||
"crypto/aes"
|
"crypto/aes"
|
||||||
"crypto/cipher"
|
"crypto/cipher"
|
||||||
|
"crypto/md5"
|
||||||
"crypto/rand"
|
"crypto/rand"
|
||||||
"encoding/base64"
|
"encoding/base64"
|
||||||
|
"encoding/hex"
|
||||||
"errors"
|
"errors"
|
||||||
"io"
|
"io"
|
||||||
)
|
)
|
||||||
@ -94,3 +96,10 @@ func AesDecrypt(cipherTextBase64 string, key []byte) ([]byte, error) {
|
|||||||
|
|
||||||
return plainText, nil
|
return plainText, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Md5Encrypt 用于对传入的message进行MD5加密
|
||||||
|
func Md5Encrypt(message string) string {
|
||||||
|
hash := md5.New()
|
||||||
|
hash.Write([]byte(message)) // 将字符串转换为字节切片并写入
|
||||||
|
return hex.EncodeToString(hash.Sum(nil)) // 将哈希值转换为16进制字符串并返回
|
||||||
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user