package test;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import cn.hutool.core.text.csv.CsvUtil;
import com.alibaba.fastjson.JSONObject;
import com.nianzai.base.dao.util.DAOHelper;
import com.nianzai.base.mvc.util.Utils;
import com.nianzai.util.Callback;
import com.nianzai.util.DateTimeUtil;
import com.nianzai.util.FileUtil;
import com.sharemao.manager.dao.BaseDao;
import com.sharemao.manager.entity.Account;
import com.sharemao.manager.service.base.RCPService;
import com.sharemao.manager.util.ProjectConstants;
import com.sharemao.manager.util.ProjectTools;

/**
 * 贴片卡设备入实名库
 * @author oem
 *
 */
public class SMD 
{
	public static void main(String[] args) throws Exception 
	{
//		sim2();
//        updrv();
//        show();

        int t=0;
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < 32; i++) {
            String sql="select devid from device"+i+" where mode = 6 or mode =7 or mode=8";
            List<Map<String, Object>> devices =RCPService.getMifiService().getMapList(sql);
            t += devices.size();
            if (devices != null) {
                devices.stream().forEach(item -> {
                    String devid = String.valueOf(item.get("devid"));
                    sb.append(",'").append(devid).append("'");
                });
            }
        }
        System.out.println("("+sb.substring(1)+")");
        System.out.println(t);
    }

	//内置卡1入库
	public static void sim2() throws Exception
	{
    	String filename="E:/deviceinbase/b.txt";
    	PrintWriter writer = new PrintWriter(new FileWriter("E:/deviceinbase/b.sql", true));
    	BufferedReader reader = new BufferedReader(new FileReader(filename));
        String line;
        while ((line = reader.readLine()) != null) {
        	String[] cc=line.split("\t");
        	String sqli="insert into smd(sn,iccid,access_number,orgid,rmode,flag) values('"+cc[0].trim()+"','"+cc[1].trim().toUpperCase()+"','"+cc[2].trim()+"',3,2,3);";
			writer.println(sqli);
        }
        writer.close();
        reader.close();
	}

	
	public static void inserttab() throws IOException
	{
    	String filename="E:/deviceinbase/962.txt";
    	PrintWriter writer = new PrintWriter(new FileWriter("E:/deviceinbase/962.sql", true));
    	FileUtil.readFileByLine(filename, "UTF-8", new Callback<String>(){
			public void execute(String line) 
			{
				
				String[] cc=line.split("\t");
				String iccidString=cc[0];
				String d="insert into iccidtemp(orgid,iccid,kasid,cardstate,realstate,flowAmount,flowAmount1) value(3,'"+cc[0]+"',65,'在用','未实名',0,0);";
				writer.println(d);
//				DAOHelper.executeCount("xc_base", sqli);
			}
		});
        writer.close();
	}
	
	public static void updatetest()
	{
    	String filename="D:/a125.txt";
    	FileUtil.readFileByLine(filename, "UTF-8", new Callback<String>(){
			public void execute(String line) 
			{
				System.out.println(line);
				String[] cc=line.split("\t");
				System.out.println("iccid="+cc[1]+",imei="+cc[0]);
				
				String sqli="update sim set imei='"+cc[1].trim()+"' where iccid='"+cc[0].trim()+"'";
				System.out.println(sqli);
				DAOHelper.executeCount("simp", sqli);
			}
		});
	}
	
	public static void updrv()
	{
    	String filename="E:\\deviceinbase\\294.txt";
    	FileUtil.readFileByLine(filename, "UTF-8", new Callback<String>(){
			public void execute(String line) 
			{
//				System.out.println(line);
				
				
				//三岁15,马小伟5，华秒455  超级智能平台392  锦程文化395  A友加时代415 臻涛562 鱼度9 心语14 网小飞16 众创云通12 诺点科技19 通硕电子25 奇科通讯26 安阳腾研27 ZAP 29  华夏行8  30鑫蓝物联  31维霓网络
				//1电信2联通3移动
				String sqli="insert into deviceupd(devid,curver,updver,url,flag) values('"+line+"','3.6.1','3.6.3','http://qiniucloud.szlocom.com/%E5%B0%8F%E6%A9%99/FOTA/CPE/470/fota_lc470_lcxc_vsim_v3.6.1_to_vsim_v3.6.3.zip',0);";
				System.out.println(sqli);
//				DAOHelper.executeCount("xc_base", sqli);
			}
		});
	}
	public static void show() throws IOException {
    	String filename="E:\\deviceinbase\\lezhao.txt";
    	FileUtil.readFileByLine(filename, "UTF-8", new Callback<String>(){
			public void execute(String line)
			{
//				String sqli="update devinit set showdialog=1 where devid ='"+line+"';";
//                writer.println(sqli);
//                writer.flush();

//                String sql="select * from device where sn='"+line+"'";
//                List<Map<String, Object>> devices = DAOHelper.find("fcs", sql);
//                if (devices!=null&&devices.size()>0){
//                    System.out.println(line);
//                }

//                String[] lines = line.split("\t");
//                String iccid = lines[0];
//                String imei = lines[1];
//                String sql="update sim set imei='"+imei+"' where iccid='"+iccid+"'";
//                RCPService.getSimpService().execSql(sql);

//                String sqli2="update device"+(Long.parseLong(line)%32)+" set devstat=0 where devid='"+line+"';";
//                RCPService.getMifiService().execSql(sqli2);

                String sql="select * from device"+(Long.parseLong(line)%32)+" where devid='"+line+"'";
                List<Map<String, Object>> devices =RCPService.getMifiService().getMapList(sql);
                if (devices == null) {
                    System.out.println(line);
                }
            }
		});
	}
	public static void qiewang()
	{
        int i=0;
    	String filename="E:\\deviceinbase\\qiewang.txt";
    	FileUtil.readFileByLine(filename, "UTF-8", new Callback<String>(){
			public void execute(String devid)
			{
                String sql="select * from "+ ProjectTools.getTableNameBySN(devid)+" where devid='"+devid+"'";
                Map<String, Object> map = RCPService.getMifiService().getMap(sql);
                String mode = String.valueOf(map.get("mode"));
                if (!mode.equals("2")){
                    String simsql = "update "+ProjectTools.getTableNameBySN(devid)+" set mode = 2 where devid = '"+devid+"'";
                    System.out.println(simsql);
                    RCPService.getMifiService().execSql(simsql);

                    String dbsql = "select count(1) c from devcrond where devid = '"+devid+"'";
                    long num = (long) RCPService.getBaseService().getMap(dbsql).get("c");
                    String devsql;
                    if(num>0){
                        devsql = "update devcrond set operate = 1, assist = '0', state = 0, crttm="+DateTimeUtil.longtime()
                                +" where devid = '"+devid+"'";
                    }else {
                        devsql = "insert into devcrond(devid,operate,assist,crttm) values ('" + devid + "',1,'0'," + DateTimeUtil.longtime() + ")";
                    }
                    System.out.println(devsql);
                    RCPService.getBaseService().execSql(devsql);
                }
            }
		});
	}
}