实名相关

com.sharemao.core.task/src/main/java/com/sharemao/core/task/iot2/ct/RealNameV2.java

@@ -1,10 +1,13 @@
 package com.sharemao.core.task.iot2.ct;
 
 import com.nianzai.base.dao.util.DAOHelper;
+import com.nianzai.util.DateTimeUtil;
 import com.sharemao.core.task.iot.bw.BW;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
@@ -23,9 +26,8 @@ public class RealNameV2 {
 	{
 	 	String sql="select * from iccid_to_realname";
 	   	List<Map<String,Object>> simlist=DAOHelper.find("mifi", sql);
-		if(simlist!=null && simlist.size()>0)
+		if(simlist!=null && !simlist.isEmpty())
 		{
-			int k=0;
 			for(Map<String,Object> m:simlist)
 			{
 				String iccid=m.get("iccid").toString();
@@ -38,46 +40,28 @@ public class RealNameV2 {
 				String status;
                 if (kasid==59){
                     status = CTAPI.zysm(iccid,resettm);
-                } else if(kasid==23 || kasid==25 || kasid==26 || kasid==46 || kasid==47 || kasid==50 || kasid==66 || kasid==67){
+                } else if(kasid==23 || kasid==25 || kasid==26 || kasid==46 || kasid==47 || kasid==50 || kasid==66 || kasid==67 || kasid==89 || kasid==90){
                     status = BW.getRealname(iccid,resettm);
                 } else {
                     status =CTAPI.sm(token, iccid,kasid,resettm);
                 }
 
-				int i=0;
-				while("TOKEN不存在或已过期，请重新获取".equals(status))
-				{
-					i+=1;
-					try {
-						Thread.sleep(30000);
-					} catch (InterruptedException e) {
-						e.printStackTrace();
-					}
-					token=CTAPI.getToken(kasid);
-                    if (kasid==59){
-                        status = CTAPI.zysm(iccid,resettm);
-                    } else if(kasid==23 || kasid==25 || kasid==26 || kasid==46 || kasid==47 || kasid==50 || kasid==66 || kasid==67 || kasid==89 || kasid==90){
-                        status = BW.getRealname(iccid,resettm);
-                    } else {
-                        status = CTAPI.sm(token, iccid, kasid, resettm);
-                    }
-					if (i==10) {
-						break;
-					}
-				}
-
 				log.info("kasid="+kasid+",iccid="+iccid+",status="+status);
 
-				if(!"TOKEN不存在或已过期，请重新获取".equals(status)) {
+				if("已实名".equals(status)) {
 					String up="update iccidtemp set realstate='"+status+"' where iccid='"+iccid+"'";
 					DAOHelper.execute("ufiiccid", up);
-                    if ("已实名".equals(status)) {
-                        String del = "delete from iccid_to_realname where iccid='" + iccid + "'";
-                        DAOHelper.execute("mifi", del);
-                    }
-				}
-				k++;
+                    String del = "delete from iccid_to_realname where iccid='" + iccid + "'";
+                    DAOHelper.execute("mifi", del);
+                }
 			}
+
+//            LocalDateTime now = LocalDateTime.now();
+//            LocalDateTime before2Hours = now.minusHours(2);
+//            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
+//            String formattedTime = before2Hours.format(formatter);
+//            String del = "delete from iccid_to_realname where crttm<'" + formattedTime + "'";
+//            DAOHelper.execute("mifi", del);
 		}
 	}
 }

com.sharemao.web.fe/src/main/java/ink/mifi/fe/tools/CTAPI.java

@@ -1,10 +1,17 @@
 package ink.mifi.fe.tools;
 
+import java.io.BufferedReader;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.URL;
 import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;
 import java.util.*;
 import java.util.Map.Entry;
 
+import com.alibaba.fastjson.JSON;
+import com.nianzai.util.CodecUtil;
 import org.apache.commons.codec.digest.DigestUtils;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -15,6 +22,8 @@ import com.nianzai.util.DateTimeUtil;
 
 import cn.hutool.http.HttpUtil;
 
+import javax.net.ssl.HttpsURLConnection;
+
 public class CTAPI 
 {
 
@@ -22,12 +31,7 @@ public class CTAPI
 
 	public static void main(String[] args)
 	{
-        String token=getToken(80);
-        String content=quicksm(token,"898604431625D1665436",80,"1");
-        System.out.println(content);
-
-//		String content=zyquicksm("898604F61925C0225986");
-//		System.out.println(content);
+        bwquicksm("89860441192580181043");
 	}
 	
 	public static String getToken(int index)
@@ -432,4 +436,65 @@ public class CTAPI
         }
 		return re;
 	}
+	//北纬快速实名
+	public static String bwquicksm(String iccid)
+	{
+        String re="";
+        String url="https://ntf-oc.hb-vpc-prod.bwae.org/open-api/query/getRealNameUrl";
+        String timestamp=DateTimeUtil.longtime();
+        String appid="ju5duzoyvjne8kro";
+        String secret="buwl34s7zot82j2n";
+        String sign= CodecUtil.str2md5(appid+secret+timestamp);
+        Map<String,Object> m=new HashMap<String,Object>();
+        m.put("cardType", "0");
+        m.put("cardId", iccid);
+        String param= JSON.toJSONString(m);;
+        String content="";
+        try {
+            content = getContentByPost(url, param, timestamp, appid, sign);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        log.info(url+"===>"+content);
+        JSONObject resJson = JSONObject.parseObject(content);
+        JSONObject respStatus = JSONObject.parseObject(resJson.getString("respStatus"));
+        String resCode = respStatus.getString("code");
+        if(resCode.equals("0000"))
+        {
+            JSONObject respBody = JSONObject.parseObject(resJson.getString("respBody"));
+            re=respBody.getString("realNameUrl");
+        }
+		return re;
+	}
+    public static String getContentByPost(String urlStr,String param,String timestamp,String appid,String sign) throws IOException
+    {
+        URL url = new URL(urlStr);
+        HttpsURLConnection conn = (HttpsURLConnection) url.openConnection();
+        conn.setRequestProperty("User-Agent","Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; Trident/5.0)");
+        conn.setDoOutput(true);
+        conn.setDoInput(true);
+        conn.setRequestMethod("POST");
+        conn.setRequestProperty("Content-Type", "application/json");
+        conn.setRequestProperty("timestamp", timestamp);
+        conn.setRequestProperty("appid", appid);
+        conn.setRequestProperty("sign", sign);
+
+        conn.connect();
+        DataOutputStream out = new DataOutputStream(conn.getOutputStream());
+        out.write(param.getBytes());
+        out.flush();
+        out.close();
+        BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(),"utf-8"));
+        StringBuilder tempStr = new StringBuilder();
+        String fileLine="";
+        while((fileLine=br.readLine())!=null)
+        {
+            tempStr.append(fileLine);
+            tempStr.append("\r\n");
+        }
+        br.close();
+        conn.disconnect();
+
+        return new String(tempStr);
+    }
 }

com.sharemao.web.fe/src/main/java/ink/mifi/fe/tools/RealController.java

@@ -117,7 +117,10 @@ public class RealController
                             if (kid == 59){
                                 cturl = CTAPI.zyquicksm(iccid1);
                                 log.info("kid="+kid+",iccid1="+iccid1+",key="+key+",cturl="+cturl);
-                            } else {
+                            } else if (kid == 46 || kid == 25 || kid == 66 || kid == 89 || kid == 90){
+                                cturl = CTAPI.bwquicksm(iccid1);
+                                log.info("kid="+kid+",iccid1="+iccid1+",key="+key+",cturl="+cturl);
+                            }  else {
                                 if (kid == 57 || kid == 60) {
                                     token = screct;
                                 } else {