xc/com.shuhaiwifi.task/src/main/java/com/shuhaiwifi/task/DelNoRealnameSMD.java

package com.shuhaiwifi.task;

import cn.hutool.core.codec.Base64;
import cn.hutool.crypto.Mode;
import cn.hutool.crypto.Padding;
import cn.hutool.crypto.symmetric.AES;
import com.alibaba.fastjson.JSONObject;
import com.shuhaiwifi.task.util.Utils;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import javax.crypto.spec.IvParameterSpec;
import javax.crypto.spec.SecretKeySpec;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.List;
import java.util.Map;

public class DelNoRealnameSMD
{

	private final static Log logger = LogFactory.getLog(DelNoRealnameSMD.class);

	static String appId="6vGGHwa43CHshDBfDZcuG3vX43weRCwj";
	static String appSecret="9XPzT9OUvmu2iSCq5gURllS5TEjt2WbP";
	static String tenantId="1452902210060161024";
	static String encodeKey="uBdUx82vPHkDKb284d7NkjFoNcKWBuka";
	static String ivKey="oCRU0D1wKfBlNeTz";
	static String password="Zeng@2024";
	
	static String token="";

	public static void main(String[] args) throws IOException {
        String appurl="https://sop.mingy-iot.com";
        String url=appurl+"/auc/oauth/token";
        String para="username=zeng&password="+getEncodePassWord()+"&grant_type=password&scope=server";
        String c=Utils.getContentByPost(url,para, tenantId, getLoginAuthorization(),1,"POST");
        JSONObject resJson = JSONObject.parseObject(c);
        token = resJson.getString("access_token");

        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        List<Map<String,Object>> simlist=RCPService.getSimpService().getMapList("select iccid from sim where scgrpid=14 ");
        StringBuilder iccidbuilder = new StringBuilder();
        int norealnamesimsize=0;
        int delsmdsize=0;
        for (Map<String, Object> item : simlist) {
            String iccid=String.valueOf(item.get("iccid"));
            String url2=appurl+"/platform/api/device/device-realname-status?iccid="+iccid;
            String c2= null;
            try {
                c2 = Utils.getContentByPost(url2,"", tenantId, getAuthorization(),0,"GET");
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
            JSONObject resJson2 = JSONObject.parseObject(c2);
            JSONObject data = resJson2.getJSONObject("data");
            String realNameStatus=data.getString("realNameStatus");
            if ("0".equals(realNameStatus)) {
//                System.out.println(iccid+"==========>"+c2);

                norealnamesimsize++;
                String sql="select sn from smd where iccid='"+iccid+"'";
                List<Map<String,Object>> smdlist=RCPService.getBaseService().getMapList(sql);
                if (smdlist != null && !smdlist.isEmpty()) {
                    String sn = String.valueOf(smdlist.get(0).get("sn"));
                    long between = 12 * 60 * 60 * 1000;
                    sql = "select devid,lastcntm from device" + Long.parseLong(sn) % 32 + " where devid='" + sn + "' ";

                    List<Map<String, Object>> devlist = RCPService.getMifiService().getMapList(sql);
                    long lastcntm = Long.parseLong(devlist.get(0).get("lastcntm").toString());
                    if (devlist != null && !devlist.isEmpty() && System.currentTimeMillis() - lastcntm < between) {

                    } else {
                        if (devlist != null && !devlist.isEmpty()) {
                            logger.info(sn + "==========>" + sdf.format(lastcntm) + "===>" + iccid);
                        }
                        iccidbuilder.append("'").append(iccid).append("'").append(",");
                        delsmdsize++;
                    }
                }
            }
        }
        logger.info("未实名的卡数："+norealnamesimsize+"==>需要删除12小时没有上线的设备卡数量："+delsmdsize);
        if (iccidbuilder.length()>0){
            String delsql = "delete from smd where iccid in ("+iccidbuilder.substring(0,iccidbuilder.length()-1)+")";
            logger.info(delsmdsize+"==>"+delsql);
            RCPService.getBaseService().execSql(delsql);
        }
	}
	

    public static String getAuthorization(){
        return  "Bearer " + token;
    }

	public static String getLoginAuthorization(){
        return  "Basic " + Base64.encode(appId + ":" + appSecret);
    }
	
    public static String getEncodePassWord(){
        AES aes = new AES(Mode.CBC, Padding.ZeroPadding,
                  new SecretKeySpec(encodeKey.getBytes(),"AES"),
                  new IvParameterSpec(ivKey.getBytes()));
        return aes.encryptBase64(password, StandardCharsets.UTF_8);
    }


}