1

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/exception/ExceptionDefinition.java

@@ -102,6 +102,8 @@ public class ExceptionDefinition {
 
     public static  ServiceExceptionDefinition ADVERTISEMENT_SQL_UPDATE_FAILED =
             new ServiceExceptionDefinition(22003, "修改广告数据库失败");
+    public static  ServiceExceptionDefinition CHECK_SQL_UPDATE_FAILED =
+            new ServiceExceptionDefinition(22004, "姓名、身份证号、银行卡号、不一致，请重新提交");
 
     public static  ServiceExceptionDefinition ADMIN_UNKNOWN_EXCEPTION =
             new ServiceExceptionDefinition(50000, "管理员系统未知异常");

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/service/impl/IdentityAuthenticationInfoServiceImpl.java

@@ -15,6 +15,7 @@ import com.yh.saas.plugin.yiliangyiyun.exception.*;
 import com.yh.saas.plugin.yiliangyiyun.mapper.IdentityAuthenticationInfoMapper;
 import com.yh.saas.plugin.yiliangyiyun.service.*;
 import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.yh.saas.plugin.yiliangyiyun.util.EntityAnalyse;
 import org.apache.commons.collections.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
@@ -142,6 +143,9 @@ public class IdentityAuthenticationInfoServiceImpl extends ServiceImpl<IdentityA
     @Override
     @Transactional(rollbackFor = Exception.class)
     public String addIdentityAuthenticationInfo(IdentityAuthenticationInfo identityAuthenticationInfo) throws ServiceException {
+
+        // 银联三要素验证
+        EntityAnalyse.checkPerson(identityAuthenticationInfo.getPayeeNumberCard(),identityAuthenticationInfo.getPayeeName(),identityAuthenticationInfo.getBankCard());
         // 根据传参手机号判断手机号是否存在
         //  空是新增
         identityAuthenticationInfo.setId(IdGenerator.generateUUID());

winsea-haixin-plugin-yiliangyiyun/src/main/java/com/yh/saas/plugin/yiliangyiyun/util/EntityAnalyse.java

@@ -7,6 +7,8 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper;
 import com.baomidou.mybatisplus.mapper.Wrapper;
 import com.yh.saas.plugin.yiliangyiyun.entity.view.ConfigDO;
 import com.yh.saas.plugin.yiliangyiyun.entity.view.DistinguishView;
+import com.yh.saas.plugin.yiliangyiyun.exception.AppServiceException;
+import com.yh.saas.plugin.yiliangyiyun.exception.ExceptionDefinition;
 import org.apache.http.HttpEntity;
 import org.apache.http.HttpResponse;
 import org.apache.http.NameValuePair;
@@ -17,6 +19,11 @@ import org.apache.http.impl.client.HttpClients;
 import org.apache.http.message.BasicNameValuePair;
 import org.apache.http.util.EntityUtils;
 
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.net.*;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -172,4 +179,71 @@ public class EntityAnalyse {
         }
         return null;
     }
+
+
+    public  static void checkPerson(String idCard,String name,String accountNo) throws ServiceException {
+        String host = "https://bcard3and4.market.alicloudapi.com";// 【1】请求地址 支持http 和 https 及 WEBSOCKET
+        String path = "/bank3CheckNew";// 【2】后缀
+        String appcode = "2d59bfa794994f5f94d1d98b7b5bd102"; // 【3】开通服务后 买家中心-查看AppCode
+//        String idCard = "511126******064713";// 【4】请求参数，详见文档描述
+//        String name = "杨过";// 【4】请求参数，详见文档描述
+//        String accountNo = "600000******01313";// 【4】请求参数，详见文档描述
+        try {
+            String urlSend = host + path + "?idCard=" + idCard + "&name="+ URLEncoder.encode(name, "UTF-8") + "&accountNo="+ accountNo;  // 【5】拼接请求链接
+            URL url = new URL(urlSend);
+            HttpURLConnection httpURLCon = (HttpURLConnection) url.openConnection();
+            httpURLCon.setRequestProperty("Authorization", "APPCODE " + appcode);// 格式Authorization:APPCODE (中间是英文空格)
+            int httpCode = httpURLCon.getResponseCode();
+            if (httpCode == 200) {
+                String json = read(httpURLCon.getInputStream());
+                System.out.println("正常请求计费(其他均不计费)");
+                System.out.println("获取返回的json:");
+                System.out.print(json);
+            } else {
+
+                Map<String, List<String>> map = httpURLCon.getHeaderFields();
+                String error = map.get("X-Ca-Error-Message").get(0);
+                if (httpCode == 400 && error.equals("Invalid AppCode `not exists`")) {
+                    System.out.println("AppCode错误 ");
+                } else if (httpCode == 400 && error.equals("Invalid Url")) {
+                    System.out.println("请求的 Method、Path 或者环境错误");
+                } else if (httpCode == 400 && error.equals("Invalid Param Location")) {
+                    System.out.println("参数错误");
+                } else if (httpCode == 403 && error.equals("Unauthorized")) {
+                    System.out.println("服务未被授权（或URL和Path不正确）");
+                } else if (httpCode == 403 && error.equals("Quota Exhausted")) {
+                    System.out.println("套餐包次数用完 ");
+                } else if (httpCode == 403 && error.equals("Api Market Subscription quota exhausted")) {
+                    System.out.println("套餐包次数用完，请续购套餐");
+                } else {
+                    System.out.println("参数名错误 或 其他错误");
+                    System.out.println(error);
+                }
+                throw new AppServiceException(ExceptionDefinition.CHECK_SQL_UPDATE_FAILED);
+            }
+
+        } catch (MalformedURLException e) {
+            System.out.println("URL格式错误");
+        } catch (UnknownHostException e) {
+            System.out.println("URL地址错误");
+        } catch (Exception e) {
+            // 打开注释查看详细报错异常信息
+            // e.printStackTrace();
+        }
+    }
+
+    /*
+     * 读取返回结果
+     */
+    private static String read(InputStream is) throws IOException {
+        StringBuffer sb = new StringBuffer();
+        BufferedReader br = new BufferedReader(new InputStreamReader(is));
+        String line = null;
+        while ((line = br.readLine()) != null) {
+            line = new String(line.getBytes(), "utf-8");
+            sb.append(line);
+        }
+        br.close();
+        return sb.toString();
+    }
 }