import java.io.IOException;
import java.util.Date;
import com.common.DateTimeUtil;
import com.common.StringUtil;
import com.pi4j.io.serial.Baud;
import com.pi4j.io.serial.DataBits;
import com.pi4j.io.serial.FlowControl;
import com.pi4j.io.serial.Parity;
import com.pi4j.io.serial.Serial;
import com.pi4j.io.serial.SerialConfig;
import com.pi4j.io.serial.SerialFactory;
import com.pi4j.io.serial.SerialPort;
import com.pi4j.io.serial.StopBits;
import com.pi4j.util.CommandArgumentParser;
import com.pi4j.util.Console;
/**
 * This example code demonstrates how to perform serial communications using the Raspberry Pi.
 *
 * @author Robert Savage
 */
public class SerialListenSMS {
 /**
  * This example program supports the following optional command arguments/options:
  * "--device (device-path)"     [DEFAULT: /dev/ttyAMA0]
  * "--baud (baud-rate)"      [DEFAULT: 38400]
  * "--data-bits (5|6|7|8)"     [DEFAULT: 8]
  * "--parity (none|odd|even)"     [DEFAULT: none]
  * "--stop-bits (1|2)"      [DEFAULT: 1]
  * "--flow-control (none|hardware|software)" [DEFAULT: none]
  *
  * @param args
  * @throws InterruptedException
  * @throws IOException
  */
 public static void main(String args[]) throws InterruptedException, IOException {
  // !! ATTENTION !!
  // By default, the serial port is configured as a console port
  // for interacting with the Linux OS shell. If you want to use
  // the serial port in a software program, you must disable the
  // OS from using this port.
  //
  // Please see this blog article for instructions on how to disable
  // the OS console for this port:
  // https://www.cube-controls.com/2015/11/02/disable-serial-port-terminal-output-on-raspbian/
  // create Pi4J console wrapper/helper
  // (This is a utility class to abstract some of the boilerplate code)
  final Console console = new Console();
  // print program title/header
  console.title("<-- The Pi4J Project -->", "監(jiān)聽串口(GPIO15-Tx / GPIO16-Rx)數(shù)據(jù)并寫入Memcached中");
  // allow for user to exit program using CTRL-C
  console.promptForExit();
  // create an instance of the serial communications class
  final Serial serial = SerialFactory.createInstance();
  byte [] data = new byte[1024];  //數(shù)據(jù)緩沖區(qū)  
  try {
   // create serial config object
   SerialConfig config = new SerialConfig();
   System.out.println(">>>"+SerialPort.getDefaultPort());
   config.device(SerialPort.getDefaultPort())  // "/dev/ttyACM0"
     .baud(Baud._115200)
     .dataBits(DataBits._8)
     .parity(Parity.NONE)
     .stopBits(StopBits._1)
     .flowControl(FlowControl.NONE);
   // parse optional command argument options to override the default serial settings.
   if(args.length > 0){
    config = CommandArgumentParser.getSerialConfig(config, args);
   }
   // display connection details
   console.box(" Connecting to: " + config.toString(),
     " Data received on serial port will be displayed below.");
   // open the default serial device/port with the configuration settings
   serial.open(config);
   serial.flush();
   System.out.println("serial.isOpen():"+serial.isOpen());
   /**初始化GPRS模塊**/
   boolean isinit = initGPRS(serial);
   long trydelay = 2000;
   while(!isinit){
    System.out.println("初始化GPRS模塊不成功, 請檢查模塊工作狀態(tài)燈, 以及SIM卡是否接觸良好..."+trydelay);
    Thread.sleep(trydelay+=1000);
    isinit = initGPRS(serial);
    if(trydelay>(10*1000)){return;}  //檢測10次都不成功時, 退出程序
   }
   /**初始化短信參數(shù)**/
   isinit = initGPRS_SMS(serial);
   trydelay = 2000;
   while(!isinit){
    System.out.println("初始化短信參數(shù)不成功, 請檢查模塊工作狀態(tài)燈, 以及SIM卡是否接觸良好.");
    Thread.sleep(trydelay+=1000);
    isinit = initGPRS_SMS(serial);
    if(trydelay>(10*1000)){return;}  //檢測10次都不成功時, 退出程序
   }
   //每次開機時嘗試讀取一次存儲卡中的短信
   String res = new String(sendCMD(serial, "AT+CMGL=\"ALL\""), "GBK");
   System.out.println("AT+CMGL=\"REC READ\".res:"+res);
   if(res.indexOf("OK")==-1){
    System.out.println("設置失敗!");
   }
   //下面進入主程序
   System.out.println("進入短信監(jiān)聽程序:");
   long old_msg_delay = 60000;   //設置舊短信搜索間隔時間(毫秒),在SIM卡內(nèi)存中搜索數(shù)據(jù)
   long old_msg_count = 0;    //舊短信計時器
   int index = 1;
   data = null;
   while(true){
    System.out.print(".");
    if(!serial.isOpen()){
     System.out.println("串口未打開, 退出程序");
     break;
    } 
    if(old_msg_count>=old_msg_delay){
     //
     System.out.println("發(fā)送獲取SIM卡內(nèi)存中的所有信息的指令");
     sendCMD(serial, "AT+CMGL=\"ALL\"");
     old_msg_count = 0;
    }else{
     old_msg_count+=1000;
     //System.out.println("old_msg_count..."+old_msg_count);
    }
    if(serial.available()>0){
     while(serial.available()>0){
      data=serial.read();    //此處接收到的數(shù)據(jù)上限是1024
      //System.out.print(new String(serial.read(), "utf-8"));
     }
     serial.flush();
    }
    if(data!=null){
     //接收到數(shù)據(jù)
     String cc = new String(data, "GBK");  //處理中文
     System.out.println("cc:"+cc);
     if(cc!=null && !cc.trim().equals("")){
      //處理數(shù)據(jù)
      /**
       * 有新短信時:
       * +CIEV: "MESSAGE",1
       * 
       * +CMTI: "SM",1
       */
      if(cc.indexOf("+CMTI")!=-1){
       index = getIndexFromNewSMS(cc);
       System.out.println("發(fā)現(xiàn)新短信.index:"+index);
       sendCMD(serial, "AT+CMGR="+index);
      }
      if(cc.indexOf("+CMGR")!=-1){
       String[] contents = getContentFromIndex(index, cc);
       System.out.println("[AT+CMGR=index]讀取存在卡上的短信內(nèi)容.分析后:");
       if(contents!=null){
        System.out.println("新短信內(nèi)容:");
        for(String tt : contents){
         System.out.println(tt);
        }
        //保存讀到的短信 -> 服務器
        if(sendDataToServer(contents)){
         //刪除已讀出的短信
         System.out.println("刪除已讀出的新短信.index:"+contents[0]);
         delSMSByIndex(serial, Integer.parseInt(contents[0]));
        }
       }else{
        System.out.println("新短信內(nèi)容:null");
       }
      }
      /**
       * 查詢舊短信時:
       * AT+CMGL="ALL"
       * 
       * +CMGL: 1,"REC READ","18620671820",,"2017/10/26,11:37:03+08",161,25
       * just because the people11
       * +CMGL: 2,"REC READ","18620671820",,"2017/10/26,11:37:03+08",161,25
       * just because the people11
       */
      if(cc.indexOf("CMGL:")!=-1){
       //獲取第1條短信
       String[] contents = getContentFromStorageSMS(cc);
       System.out.println("[AT+CMGL=\"ALL\"]存在卡上的短信內(nèi)容.分析后:");
       for(String tt : contents){
        System.out.println(tt);
       }
       //保存讀到的短信
       if(sendDataToServer(contents)){
        //刪除已讀出的短信
        System.out.println("刪除已讀出的舊短信.index:"+contents[0]);
        delSMSByIndex(serial, Integer.parseInt(contents[0]));
       }
      }
     }else{
      System.out.println("data:"+new String(data));
      System.out.println("data(byte[]) 轉(zhuǎn)換成 String時出錯");
     }
    }
    //if(cc!=null && !cc.trim().equals(""))System.out.println(cc);
    data = null;
    Thread.sleep(1000);
   }
  }
  catch(IOException ex) {
   console.println(" ==>> SERIAL SETUP FAILED : " + ex.getMessage());
   return;
  }
 }
 /**
  * 把短信上傳到服務器中
  * @param contents 數(shù)組
    [0] - 短信位置索引
    [1] - 電話號碼
    [2] - 日期+時間 2017/10/26 11:37:03+08
    [3] - 短信內(nèi)容
  * @return
  */
 public static boolean sendDataToServer(String[] contents){
  System.out.println("嘗試上傳短信數(shù)據(jù)");
  try{
   //移除時間中的時區(qū) +08 2017/10/26 12:38:14+08...2017-10-26 12:38:14
   String d = contents[2].substring(0,contents[2].lastIndexOf("+"));
   d = d.replace("/", "-").replace(" ", "%20");
   StringBuffer url = new StringBuffer("http://192.168.6.2:9080/webService.do?method=saveSMSBank");
   String vno = DateTimeUtil.dateToString(new Date(), "yyyyMMdd");
   vno = StringUtil.encodePassword(vno, "MD5");
   url.append("&vno=").append(vno);
   url.append("&smstype=0");
   url.append("&port=2");
   url.append("&recTime=").append(d);  //need: 2013-12-05%2014:35:20
   url.append("&phone=").append(contents[1]);
   url.append("&serialNo=0");
   url.append("&nums=0");
   url.append("&submitPort=0");
   url.append("&sendid=").append(contents[1]);
   url.append("&sendtype=0");
   url.append("&sendNo=0");
   String xx = new String(contents[3].getBytes(), "UTF-8");
   url.append("&txt=").append(java.net.URLEncoder.encode(xx, "UTF-8"));
   System.out.println("sendDataToServer().url:"+url.toString());
   String resurl = StringUtil.getContentByUrl2(url.toString());
   System.out.println("sendDataToServer().resurl:"+resurl);
   if(resurl.trim().equals("200")){
    System.out.println("數(shù)據(jù)上傳成功!");
    return true;
   }else if(resurl.trim().equals("401")){
    System.out.println("這個電話號碼和短信內(nèi)容已上傳過, 數(shù)據(jù)重復!");
    System.out.println("清除SIM卡上的短信!");
    return true;
   }
  }catch(Exception e){
   e.printStackTrace();
   return false;
  }
  return false;
 }
 /**
  * 解析返回的短信內(nèi)容
  * @return
  */
 public static String[] getContentFromIndex(int index, String res){
  try{
   System.out.println("嘗試讀取短信...getContentFromIndex.res:"+res);
   if(res.indexOf("OK")!=-1){
    System.out.println("獲取短信成功,解析內(nèi)容...");
    /**
     * +CMGR: "REC READ","18620671820",,"2017/10/26,11:37:03+08",161,17,0,0,"+8613010200500",145,25
     * just because the people11
     * 
     * +CMGR: "REC READ","18620671820",,"2017/10/26,11:37:03+08",161,17,0,0,"+8613010200500",145,25
     * ---------------- ------------- - ---------- ----------- --- -- - - ---------------- --- --
     * [0]    [1]   [2] [3]  [4]   [5] [6][7][8] [9]   [10][11]
     */
    String[] ccs = res.split("\r\n");
    String phone = new String();
    String sendDate = new String();
    String content = new String();
    boolean isvalid = false;   //數(shù)據(jù)獲取成功
    for(int i=0;i<ccs.length;i++){
     if(ccs[i].indexOf("CMGR:")!=-1){
      String[] temp1 = ccs[i].split(",");
      phone = temp1[1];
      sendDate = temp1[3]+" "+temp1[4];
      content = ccs[i+1];
      isvalid = true;
      break;  //只處理1條
     }
    }
    if(!isvalid)return null;
    //處理雙引號
    phone = phone.substring(1,phone.length()-1);
    sendDate = sendDate.substring(1,sendDate.length()-1);
    String[] resu = new String[4];
    resu[0] = String.valueOf(index);
    resu[1] = phone.trim();
    resu[2] = sendDate;
    resu[3] = content;
    return resu;
   }else if(res.indexOf("CMS ERROR")!=-1){
    //CMS ERROR:321 表示所讀取的內(nèi)存位置出錯,一般是指定位置無短信內(nèi)容所致
    System.out.println("獲取短信失敗,錯誤內(nèi)容...");
    return null;
   }
  }catch(Exception e){
   e.printStackTrace();
  }
  return null;
 }
 /**
  * 有新短信時,獲取短信內(nèi)容: 
  * +CIEV: "MESSAGE",1
  * 
  * +CMTI: "SM",1
  * 
  * @return index 短信所在的內(nèi)存位置 index
  */
 public static int getIndexFromNewSMS(String cc){
  try{
   String[] ccs = cc.split("\r\n");
   for(String v : ccs){
    if(v.indexOf("CMTI: \"SM\",")!=-1){
     String c = v.substring(v.indexOf(",")+1);
     return Integer.parseInt(c);
    }
   }
  }catch(Exception e){
   e.printStackTrace();
  }
  return 0;
 }
 /**
  * 查詢舊短信, 每次只抓1條:
  * +CMGL: 4,"REC READ","106907931100",,"2017/07/02,10:15:19+08"
  * -------- ---------- -------------- ----------- ------------
  * [0]  [1]  [2]   [3] [4]  [5]
  【小米】[小米移動]您2017年6月共消費1.32元，當前余額97.88元。其中：數(shù)據(jù)流量費1.32元；語音通信費0元；短/彩信費0元
  +CMGL: 5,"REC READ","106908761100",,"2017/08/02,10:15:30+08"
  。查詢賬單 http://10046.mi.com 。
  +CMGL: 6,"REC READ","106908761100",,"2017/08/02,10:15:30+08"
  【小米】[小米移動]您2017年7月共消費0.81元，當前余額97.01元。其中：數(shù)據(jù)流量費0.81元；語音通信費0元；短/彩信費0元
  OK
  @return 數(shù)組
    [0] - 短信位置索引
    [1] - 電話號碼
    [2] - 日期+時間
    [3] - 短信內(nèi)容
  */
 public static String[] getContentFromStorageSMS(String cc){
  String[] ccs = cc.split("\r\n");
  String smsIndex = new String();
  String phone = new String();
  String sendDate = new String();
  String content = new String();
  for(int i=0;i<ccs.length;i++){
   if(ccs[i].indexOf("CMGL:")!=-1){
    //smsIndex = Integer.parseInt(ccs[i].substring(ccs[i].indexOf("CMGL:")+5, ccs[i].indexOf(",")));
    smsIndex = ccs[i].substring(ccs[i].indexOf("CMGL:")+5, ccs[i].indexOf(","));
    String[] temp1 = ccs[i].split(",");
    phone = temp1[2];
    sendDate = temp1[4]+" "+temp1[5];
    content = ccs[i+1];
    break;  //只處理1條
   }
  }
  //處理雙引號
  phone = phone.substring(1,phone.length()-1);
  sendDate = sendDate.substring(1,sendDate.length()-1);
  String[] res = new String[4];
  res[0] = smsIndex.trim();
  res[1] = phone.trim();
  res[2] = sendDate;
  res[3] = content;
  return res;
 }
 /**
  * 刪除指定位置上的短信
  * AT+CMGD=4
  * @param index 短信索引位置
  * @return
  */
 public static boolean delSMSByIndex(Serial serial, int index){
  String res = new String(sendCMD(serial, "AT+CMGD="+index));
  System.out.println("AT+CMGD="+index+":"+res);
  //if(res.indexOf("OK")==-1){
  // System.out.println("刪除["+index+"]位置的短信失敗!");
  // return false;
  //}
  return true;
 }
 /**
  * 
  *   初始化GPRS.模塊
  *   AT  100ms 握手 / SIM卡檢測等
  *   AT+CPIN? 100ms 查詢是否檢測到SIM卡
  *   AT+CSQ 100ms 信號質(zhì)量測試，值為0-31,31表示最好
  *   AT+CCID 100ms 讀取SIM的CCID(SIM卡背面20位數(shù)字)，可以檢測是否有SIM卡或者是否接觸良好
  *   AT+CREG? 500ms 檢測是否注冊網(wǎng)絡
  * @return
  */
 public static boolean initGPRS(Serial serial){
  if(!serial.isOpen()){return false;}  //串口未準備好
  byte[] buffs = new byte[128];
  try{
   System.out.println("try send AT to module...");
   //char cmd[] = {'A', 'T'};
   //byte cmd[] = "AT".getBytes();
   //buffs = sendCMD(serial, "AT".getBytes());
   System.out.print("\r\nGPRS模塊檢測中...");
   buffs = sendCMD(serial, "AT");
   String res = new String(buffs);
   if(res.indexOf("OK")==-1){
    System.out.println("GPRS模塊未準備好, 請檢查電源和串口波特率是否正確!");
    return false;
   }
   System.out.println(" ...[正常]\r\n");
   //System.out.println("AT.res:"+res);
   System.out.print("\r\n檢測SIM卡...");
   res = new String(sendCMD(serial, "AT+CPIN?"));
   if(res.indexOf("READY")==-1){
    System.out.println("SIM卡未準備好!");
    return false;
   }
   System.out.println(" ...[正常]\r\n");
   //System.out.println("AT+CPIN?.res:"+res);
   System.out.print("\r\n信號質(zhì)量測試，值為0-31,31表示最好...");
   res = new String(sendCMD(serial, "AT+CSQ"));
   if(res.indexOf("ERROR")!=-1){
    System.out.println("信號質(zhì)量測試檢測失敗");
    return false;
   }
   /**
    * +CSQ: 24,99
    */
   String[] vs = res.split("\r\n");
   for(String v : vs){
    if(v.indexOf(":")!=-1){
     String x = v.substring(v.indexOf(":")+1);
     //System.out.println("x:"+x);
     System.out.println(" ...信號強度:["+x.trim()+"]\r\n");
    }
   }
   //System.out.println("AT+CSQ.res:"+res);
   res = new String(sendCMD(serial, "AT+CCID"));
   System.out.println("AT+CCID.res:"+res);
   res = new String(sendCMD(serial, "AT+CREG?"));
   System.out.println("AT+CREG.res:"+res);
  }catch(Exception e){
   e.printStackTrace();
   return false;
  }
  return true;
 }
 /**
  * 
  * 初始化GPRS.設置短信模式及短信接收參數(shù)
  *   AT+CMGF=1    0-PDU, 1-文本格式
  *  AT+CSDH=1
  *  AT+CPMS="SM","SM","SM" 將信息保存在SIM卡中, SM-表示存在SIM卡上
  *  AT+CNMI=2,1,0,1,1  收接通知,并存在指定位置(與AT+CPMS設置有關)
  * 
  * 設置好后, 收到短信:
  *   +CIEV: "MESSAGE",1
  *   +CMTI: "SM",1   表示存儲位置index=1
  * @return
  */
 public static boolean initGPRS_SMS(Serial serial){
  if(!serial.isOpen()){return false;}  //串口未準備好
  String res = new String();
  try{
   System.out.print("\r\n設置短信格式...");
   res = new String(sendCMD(serial, "AT+CMGF=1"));
   if(res.indexOf("OK")==-1){
    System.out.println("設置失敗!");
    return false;
   }
   System.out.println(" ...[文本格式]\r\n");
   Thread.sleep(100);
   System.out.print("\r\nAT+CSDH=1...");
   res = new String(sendCMD(serial, "AT+CSDH=1"));
   if(res.indexOf("OK")==-1){
    System.out.println("設置失敗!");
    return false;
   }
   System.out.println(" ...[DONE]\r\n");
   Thread.sleep(100);
   System.out.print("\r\n設置信息保存位置...");
   res = new String(sendCMD(serial, "AT+CPMS=\"SM\",\"SM\",\"SM\""));
   if(res.indexOf("OK")==-1){
    System.out.println("設置失敗!");
    return false;
   }
   System.out.println(" ...[SIM卡]\r\n");
   Thread.sleep(100);
   System.out.print("\r\n收接通知,并存在指定位置...");
   res = new String(sendCMD(serial, "AT+CNMI=2,1,0,1,1"));
   if(res.indexOf("OK")==-1){
    System.out.println("設置失敗!");
    return false;
   }
   System.out.println(" ...[DONE]\r\n");
   Thread.sleep(100);
  }catch(Exception e){
   e.printStackTrace();
   return false;
  }
  return true;
 }
 //public static byte[] sendCMD(Serial serial, byte[] cmd){
 public static byte[] sendCMD(Serial serial, String cmd){
  long overtime = 10000;  //每條指令超時上限 5秒
  long timecount = 0;   //計時器
  byte[] buffs = new byte[128];
  try {
   serial.writeln(cmd+"\r");
   //serial.writeln("AT\r");
   timecount = 0;
   while(timecount<overtime){
    //System.out.print(serial.available());
    if(serial.available()>0){
     while(serial.available()>0){
      buffs = serial.read();
      //System.out.print(new String(serial.read()));
      //System.out.print(new String(buffs));
     }
     serial.flush();
     timecount = overtime;  //exit while
    }
    timecount += 100;
    Thread.sleep(100);
   }
   //System.out.println("sendCMD:"+new String(buffs));
  } catch (IllegalStateException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  } catch (Exception e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
  return buffs;
 }
}
// END SNIPPET: serial-snippet