diff --git a/AndroidManifest.xml b/AndroidManifest.xml
index e9940ad..a845f8d 100644
--- a/AndroidManifest.xml
+++ b/AndroidManifest.xml
@@ -193,6 +193,11 @@
             </intent-filter>
         </receiver>
 
+        <receiver
+            android:name="com.ectrip.cyt.receiver.AlarmReceiver"
+            android:enabled="true"
+            android:exported="true" />
+
         <activity
             android:name="android_serialport_api.print_tool.ConsoleActivity"
             android:screenOrientation="portrait"
@@ -376,6 +381,8 @@
                 <category android:name="android.intent.category.DEFAULT" />
             </intent-filter>
         </service>
+        <service android:name="com.ectrip.cyt.service.FtpParamerService" />
+        <service android:name="com.ectrip.cyt.service.UploadLogService" />
         <!--
         <receiver android:name="com.eztlib.blu.BluetoothConnectActivityReceiver" >
             <intent-filter>
diff --git a/CYTAndroid4.0.iml b/CYTAndroid4.0.iml
index 8e80fc2..ec6a3d2 100644
--- a/CYTAndroid4.0.iml
+++ b/CYTAndroid4.0.iml
@@ -111,6 +111,13 @@
     <orderEntry type="library" name="Gradle: D./desk file/work/CYTAndroid4.0/libs/zkandroididcardreader.jar" level="project" />
     <orderEntry type="library" name="Gradle: D./desk file/work/CYTAndroid4.0/libs/iodev2.jar" level="project" />
     <orderEntry type="library" name="Gradle: D./desk file/work/CYTAndroid4.0/libs/decoderapijni.jar" level="project" />
+    <orderEntry type="library" name="Gradle: D./desk file/work/CYTAndroid4.0/libs/android-logging-log4j-1.0.3.jar" level="project" />
+    <orderEntry type="library" name="Gradle: D./desk file/work/CYTAndroid4.0/libs/log4j-1.2.17.jar" level="project" />
+    <orderEntry type="library" name="Gradle: D./desk file/work/CYTAndroid4.0/libs/zypos1.8.jar" level="project" />
+    <orderEntry type="library" name="Gradle: D./desk file/work/CYTAndroid4.0/libs/jsch-0.1.54.jar" level="project" />
     <orderEntry type="library" name="Gradle: D./desk file/work/CYTAndroid4.0/libs/bw_pos_sdk2.0.18.jar" level="project" />
+    <orderEntry type="library" name="Gradle: org.jetbrains:annotations-java5:15.0" level="project" />
+    <orderEntry type="library" name="Gradle: com.squareup.okhttp3:okhttp:3.6.0" level="project" />
+    <orderEntry type="library" name="Gradle: com.squareup.okio:okio:1.11.0" level="project" />
   </component>
 </module>
\ No newline at end of file
diff --git a/build.gradle b/build.gradle
index 9cc1bbc..26bdc51 100644
--- a/build.gradle
+++ b/build.gradle
@@ -38,9 +38,12 @@ dependencies {
     implementation files('libs\\android-logging-log4j-1.0.3.jar')
     implementation files('libs\\log4j-1.2.17.jar')
     implementation files('libs\\zypos1.8.jar')
+    implementation files('libs\\jsch-0.1.54.jar')
+    implementation 'org.jetbrains:annotations-java5:15.0'
     compileOnly files('external_libs/classes_2.1.11_20160907.jar')
     compileOnly files('external_libs/bw_odm_20160526.jar')
     implementation files('libs/bw_pos_sdk2.0.18.jar')
+    implementation 'com.squareup.okhttp3:okhttp:3.6.0'
 //    implementation('com.android.support:support-v4:21.0.0')
 //    implementation('com.android.support:appcompat-v7:21.0.0'){ // You should exclude one of them not both of them
 //        exclude module: "support-v4"
diff --git a/libs/jsch-0.1.54.jar b/libs/jsch-0.1.54.jar
new file mode 100644
index 0000000..1372c8e
--- /dev/null
+++ b/libs/jsch-0.1.54.jar
diff --git a/src/com/ectrip/cyt/bean/BaseRequest.java b/src/com/ectrip/cyt/bean/BaseRequest.java
new file mode 100644
index 0000000..00980e9
--- /dev/null
+++ b/src/com/ectrip/cyt/bean/BaseRequest.java
@@ -0,0 +1,9 @@
+package com.ectrip.cyt.bean;
+
+/**
+ * This is a base request data type of Action
+ * Created by lingkitho on 2017/3/1.
+ */
+public class BaseRequest {
+
+}
diff --git a/src/com/ectrip/cyt/bean/BaseResponse.java b/src/com/ectrip/cyt/bean/BaseResponse.java
new file mode 100644
index 0000000..be0687c
--- /dev/null
+++ b/src/com/ectrip/cyt/bean/BaseResponse.java
@@ -0,0 +1,56 @@
+package com.ectrip.cyt.bean;
+
+/**
+ * This is a base response data type of Action
+ * Created by lingkitho on 2017/3/1.
+ */
+public class BaseResponse {
+
+    /**
+     *  response code
+     *  当核心的服务返回的数据为void或发成异常时，此字段才会赋值
+     */
+    private String code;
+
+    /**
+     * response message information
+     * 当核心的服务返回的数据为void或发成异常时，此字段才会赋值
+     */
+    private String msg;
+
+    /**
+     * 核心的服务返回的数据
+     */
+    private Object data;
+
+    public BaseResponse() {
+    }
+
+    public BaseResponse(Object data) {
+        this.data = data;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getMsg() {
+        return msg;
+    }
+
+    public void setMsg(String msg) {
+        this.msg = msg;
+    }
+
+    public Object getData() {
+        return data;
+    }
+
+    public void setData(Object data) {
+        this.data = data;
+    }
+}
diff --git a/src/com/ectrip/cyt/bean/DataTranfer.java b/src/com/ectrip/cyt/bean/DataTranfer.java
new file mode 100644
index 0000000..9b41479
--- /dev/null
+++ b/src/com/ectrip/cyt/bean/DataTranfer.java
@@ -0,0 +1,44 @@
+package com.ectrip.cyt.bean;
+
+/**
+ * Created by lingkitho on 2017/3/2.
+ */
+public class DataTranfer {
+    private String data;
+    private String signed;
+    private String securityType = "MD5";
+    private String method;
+
+
+    public String getMethod() {
+        return method;
+    }
+
+    public void setMethod(String method) {
+        this.method = method;
+    }
+
+    public String getData() {
+        return data;
+    }
+
+    public void setData(String data) {
+        this.data = data;
+    }
+
+    public String getSigned() {
+        return signed;
+    }
+
+    public void setSigned(String signed) {
+        this.signed = signed;
+    }
+
+    public String getSecurityType() {
+        return securityType;
+    }
+
+    public void setSecurityType(String securityType) {
+        this.securityType = securityType;
+    }
+}
diff --git a/src/com/ectrip/cyt/bean/GetFtp.java b/src/com/ectrip/cyt/bean/GetFtp.java
new file mode 100644
index 0000000..cf86004
--- /dev/null
+++ b/src/com/ectrip/cyt/bean/GetFtp.java
@@ -0,0 +1,28 @@
+package com.ectrip.cyt.bean;
+
+/**
+ * 从后台获取FTP参数
+ * 006
+ * Created by lingkitho on 2017/3/2.
+ */
+public class GetFtp extends BaseRequest {
+    private String accid; //园门ID
+
+    private String mac;
+
+    public String getMac() {
+        return mac;
+    }
+
+    public void setMac(String mac) {
+        this.mac = mac;
+    }
+
+    public String getAccid() {
+        return accid;
+    }
+
+    public void setAccid(String accid) {
+        this.accid = accid;
+    }
+}
diff --git a/src/com/ectrip/cyt/bean/ResultBean.java b/src/com/ectrip/cyt/bean/ResultBean.java
new file mode 100644
index 0000000..59bdd06
--- /dev/null
+++ b/src/com/ectrip/cyt/bean/ResultBean.java
@@ -0,0 +1,463 @@
+/**
+ * ResultBean.java
+ *
+ * This file was auto-generated from WSDL
+ * by the Apache Axis 1.4 Apr 22, 2006 (06:55:48 PDT) WSDL2Java emitter.
+ */
+
+package com.ectrip.cyt.bean;
+
+import com.alibaba.fastjson.JSON;
+
+public class ResultBean implements java.io.Serializable {
+
+    private int columnCount;
+
+    private String[] columnName;
+
+    private String[] columnNames;
+
+    private int currentPage;
+
+    private int eachPageNumber;
+
+    private int endNum;
+
+    private String[][] row;
+
+    private int rowsCount;
+
+    private java.util.Vector selectResult;
+
+    private int startNum;
+
+    private int totalNumber;
+
+    private int totalPages;
+
+    public ResultBean() {
+    }
+
+    public ResultBean(
+            int columnCount,
+            String[] columnName,
+            String[] columnNames,
+            int currentPage,
+            int eachPageNumber,
+            int endNum,
+            String[][] row,
+            int rowsCount,
+            java.util.Vector selectResult,
+            int startNum,
+            int totalNumber,
+            int totalPages) {
+        this.columnCount = columnCount;
+        this.columnName = columnName;
+        this.columnNames = columnNames;
+        this.currentPage = currentPage;
+        this.eachPageNumber = eachPageNumber;
+        this.endNum = endNum;
+        this.row = row;
+        this.rowsCount = rowsCount;
+        this.selectResult = selectResult;
+        this.startNum = startNum;
+        this.totalNumber = totalNumber;
+        this.totalPages = totalPages;
+    }
+
+
+    /**
+     * Gets the columnCount value for this ResultBean.
+     *
+     * @return columnCount
+     */
+    public int getColumnCount() {
+        return columnCount;
+    }
+
+
+    /**
+     * Sets the columnCount value for this ResultBean.
+     *
+     * @param columnCount
+     */
+    public void setColumnCount(int columnCount) {
+        this.columnCount = columnCount;
+    }
+
+
+    /**
+     * Gets the columnName value for this ResultBean.
+     *
+     * @return columnName
+     */
+    public String[] getColumnName() {
+        return columnName;
+    }
+
+
+    /**
+     * Sets the columnName value for this ResultBean.
+     *
+     * @param columnName
+     */
+    public void setColumnName(String[] columnName) {
+        this.columnName = columnName;
+    }
+
+    public String getColumnName(int i) {
+        return this.columnName[i];
+    }
+
+    public void setColumnName(int i, String _value) {
+        this.columnName[i] = _value;
+    }
+
+
+    /**
+     * Gets the columnNames value for this ResultBean.
+     *
+     * @return columnNames
+     */
+    public String[] getColumnNames() {
+        return columnNames;
+    }
+
+
+    /**
+     * Sets the columnNames value for this ResultBean.
+     *
+     * @param columnNames
+     */
+    public void setColumnNames(String[] columnNames) {
+        this.columnNames = columnNames;
+    }
+
+
+    /**
+     * Gets the currentPage value for this ResultBean.
+     *
+     * @return currentPage
+     */
+    public int getCurrentPage() {
+        return currentPage;
+    }
+
+
+    /**
+     * Sets the currentPage value for this ResultBean.
+     *
+     * @param currentPage
+     */
+    public void setCurrentPage(int currentPage) {
+        this.currentPage = currentPage;
+    }
+
+
+    /**
+     * Gets the eachPageNumber value for this ResultBean.
+     *
+     * @return eachPageNumber
+     */
+    public int getEachPageNumber() {
+        return eachPageNumber;
+    }
+
+
+    /**
+     * Sets the eachPageNumber value for this ResultBean.
+     *
+     * @param eachPageNumber
+     */
+    public void setEachPageNumber(int eachPageNumber) {
+        this.eachPageNumber = eachPageNumber;
+    }
+
+
+    /**
+     * Gets the endNum value for this ResultBean.
+     *
+     * @return endNum
+     */
+    public int getEndNum() {
+        return endNum;
+    }
+
+
+    /**
+     * Sets the endNum value for this ResultBean.
+     *
+     * @param endNum
+     */
+    public void setEndNum(int endNum) {
+        this.endNum = endNum;
+    }
+
+
+    /**
+     * Gets the row value for this ResultBean.
+     *
+     * @return row
+     */
+    public String[][] getRow() {
+        return row;
+    }
+
+
+    /**
+     * Sets the row value for this ResultBean.
+     *
+     * @param row
+     */
+    public void setRow(String[][] row) {
+        this.row = row;
+    }
+
+    public String[] getRow(int i) {
+        return this.row[i];
+    }
+
+    public void setRow(int i, String[] _value) {
+        this.row[i] = _value;
+    }
+
+
+    /**
+     * Gets the rowsCount value for this ResultBean.
+     *
+     * @return rowsCount
+     */
+    public int getRowsCount() {
+        return rowsCount;
+    }
+
+
+    /**
+     * Sets the rowsCount value for this ResultBean.
+     *
+     * @param rowsCount
+     */
+    public void setRowsCount(int rowsCount) {
+        this.rowsCount = rowsCount;
+    }
+
+
+    /**
+     * Gets the selectResult value for this ResultBean.
+     *
+     * @return selectResult
+     */
+    public java.util.Vector getSelectResult() {
+        return selectResult;
+    }
+
+
+    /**
+     * Sets the selectResult value for this ResultBean.
+     *
+     * @param selectResult
+     */
+    public void setSelectResult(java.util.Vector selectResult) {
+        this.selectResult = selectResult;
+    }
+
+
+    /**
+     * Gets the startNum value for this ResultBean.
+     *
+     * @return startNum
+     */
+    public int getStartNum() {
+        return startNum;
+    }
+
+
+    /**
+     * Sets the startNum value for this ResultBean.
+     *
+     * @param startNum
+     */
+    public void setStartNum(int startNum) {
+        this.startNum = startNum;
+    }
+
+
+    /**
+     * Gets the totalNumber value for this ResultBean.
+     *
+     * @return totalNumber
+     */
+    public int getTotalNumber() {
+        return totalNumber;
+    }
+
+
+    /**
+     * Sets the totalNumber value for this ResultBean.
+     *
+     * @param totalNumber
+     */
+    public void setTotalNumber(int totalNumber) {
+        this.totalNumber = totalNumber;
+    }
+
+
+    /**
+     * Gets the totalPages value for this ResultBean.
+     *
+     * @return totalPages
+     */
+    public int getTotalPages() {
+        return totalPages;
+    }
+
+
+    /**
+     * Sets the totalPages value for this ResultBean.
+     *
+     * @param totalPages
+     */
+    public void setTotalPages(int totalPages) {
+        this.totalPages = totalPages;
+    }
+
+    private Object __equalsCalc = null;
+
+    public synchronized boolean equals(Object obj) {
+        if (!(obj instanceof ResultBean)) return false;
+        ResultBean other = (ResultBean) obj;
+        if (obj == null) return false;
+        if (this == obj) return true;
+        if (__equalsCalc != null) {
+            return (__equalsCalc == obj);
+        }
+        __equalsCalc = obj;
+        boolean _equals;
+        _equals = true &&
+                this.columnCount == other.getColumnCount() &&
+                ((this.columnName == null && other.getColumnName() == null) ||
+                        (this.columnName != null &&
+                                java.util.Arrays.equals(this.columnName, other.getColumnName()))) &&
+                ((this.columnNames == null && other.getColumnNames() == null) ||
+                        (this.columnNames != null &&
+                                java.util.Arrays.equals(this.columnNames, other.getColumnNames()))) &&
+                this.currentPage == other.getCurrentPage() &&
+                this.eachPageNumber == other.getEachPageNumber() &&
+                this.endNum == other.getEndNum() &&
+                ((this.row == null && other.getRow() == null) ||
+                        (this.row != null &&
+                                java.util.Arrays.equals(this.row, other.getRow()))) &&
+                this.rowsCount == other.getRowsCount() &&
+                ((this.selectResult == null && other.getSelectResult() == null) ||
+                        (this.selectResult != null &&
+                                this.selectResult.equals(other.getSelectResult()))) &&
+                this.startNum == other.getStartNum() &&
+                this.totalNumber == other.getTotalNumber() &&
+                this.totalPages == other.getTotalPages();
+        __equalsCalc = null;
+        return _equals;
+    }
+
+    private boolean __hashCodeCalc = false;
+
+    public synchronized int hashCode() {
+        if (__hashCodeCalc) {
+            return 0;
+        }
+        __hashCodeCalc = true;
+        int _hashCode = 1;
+        _hashCode += getColumnCount();
+        if (getColumnName() != null) {
+            for (int i = 0;
+                 i < java.lang.reflect.Array.getLength(getColumnName());
+                 i++) {
+                Object obj = java.lang.reflect.Array.get(getColumnName(), i);
+                if (obj != null &&
+                        !obj.getClass().isArray()) {
+                    _hashCode += obj.hashCode();
+                }
+            }
+        }
+        if (getColumnNames() != null) {
+            for (int i = 0;
+                 i < java.lang.reflect.Array.getLength(getColumnNames());
+                 i++) {
+                Object obj = java.lang.reflect.Array.get(getColumnNames(), i);
+                if (obj != null &&
+                        !obj.getClass().isArray()) {
+                    _hashCode += obj.hashCode();
+                }
+            }
+        }
+        _hashCode += getCurrentPage();
+        _hashCode += getEachPageNumber();
+        _hashCode += getEndNum();
+        if (getRow() != null) {
+            for (int i = 0;
+                 i < java.lang.reflect.Array.getLength(getRow());
+                 i++) {
+                Object obj = java.lang.reflect.Array.get(getRow(), i);
+                if (obj != null &&
+                        !obj.getClass().isArray()) {
+                    _hashCode += obj.hashCode();
+                }
+            }
+        }
+        _hashCode += getRowsCount();
+        if (getSelectResult() != null) {
+            _hashCode += getSelectResult().hashCode();
+        }
+        _hashCode += getStartNum();
+        _hashCode += getTotalNumber();
+        _hashCode += getTotalPages();
+        __hashCodeCalc = false;
+        return _hashCode;
+    }
+
+    /**
+     * 取到具体显示的字段值 Creation date: (2000-8-12 11:45:24)
+     *
+     * @param rownum int 行数
+     * @param colnum int 列数
+     * @return java.lang.String
+     * @throws Exception The exception description.
+     */
+    public String getResult(int rownum, int colnum) {
+
+        if (selectResult.isEmpty()) {
+            return "";
+
+        } else {
+//            String[] tempRow = new Gson().fromJson((String) selectResult.elementAt(rownum),String[].class);
+            String[] tempRow = JSON.parseObject(selectResult.elementAt(rownum).toString(),String[].class);
+            return tempRow[colnum];
+
+        }
+
+    }
+
+    /**
+     * 重载getResult()方法 通过行数、字段名取到值
+     */
+    public String getResult(int rownum, String columName) {
+        int colnum = -1;
+        String result = "";
+        for (int j = 0; j < columnCount; j++) {
+
+            if (columnNames[j].equalsIgnoreCase(columName)) {
+                colnum = j;
+                break;
+            }
+        }
+
+        if (colnum != -1) {
+            // 有此字段
+            result = getResult(rownum, colnum);
+
+        }
+
+        return result;
+
+    }
+
+}
diff --git a/src/com/ectrip/cyt/constant/CallBackTypeConstant.java b/src/com/ectrip/cyt/constant/CallBackTypeConstant.java
new file mode 100644
index 0000000..f5b008a
--- /dev/null
+++ b/src/com/ectrip/cyt/constant/CallBackTypeConstant.java
@@ -0,0 +1,23 @@
+package com.ectrip.cyt.constant;
+
+/**
+ * Created by dc on 2017/3/10.
+ */
+
+public class CallBackTypeConstant {
+
+
+
+
+    public static final int DEVERROR = 9999;  //标志为硬件错误
+    public static final int CLOSE = 9998;  //标志关闭界面
+    public static final int PASSAGE = 10005; //标志闸机返回
+    public static final int PASSAGE_TEST = 20005; //标志闸机返回
+    public static final int CHECKTICKET = 24;   //标志网络请求回调为检票
+    public static final int TICKETPASSIDINTPUT = 31;   //标志网络请求回调为验证指纹
+    public static final int TICKETZWINTPUT = 30;   //标志网络请求回调为登记指纹
+    public static final int CHECKFACE = 32;
+
+    public static final int GETFEPPRARMETER = 27; //标识为FTP参数返回
+
+}
diff --git a/src/com/ectrip/cyt/constant/CheckTicketConstant.java b/src/com/ectrip/cyt/constant/CheckTicketConstant.java
new file mode 100644
index 0000000..b6653a5
--- /dev/null
+++ b/src/com/ectrip/cyt/constant/CheckTicketConstant.java
@@ -0,0 +1,46 @@
+package com.ectrip.cyt.constant;
+
+/**
+ * Created by lingkitho on 2017/3/2.
+ */
+public class CheckTicketConstant {
+
+    public static String IP;
+    public static final String httphead = "http://";
+    public static final String action = "/checkTicket/excuteCheckTicket.action";
+    public static final String MD5KEY = "029124EDC5E180631627E3AE44108724";
+    public static final String CHECKTICKET = "C001"; //检票
+    public static final String GETMYID = "C002"; //根据MAC值，获取闸机ID
+    public static final String GETSCENIC = "C003"; //获取景区服务商信息
+    public static final String GETSTATION = "C004"; //获取销售点信息
+    public static final String GETTICKET = "C005"; //获取票类型信息
+    public static final String GETFTP = "C006"; //从后台获取FTP参数
+    public static final String GETXPCS = "C007"; //从后台获取竹筏小票参数
+    public static final String GETZWCS = "C008"; //从后台获取指纹登记、验证参数
+    public static final String GETDAYTIMES = "C009"; //同步系统时间
+    public static final String GETRESULTBEAN = "C010"; //测试检票地址连接检票服务器是否正常
+    public static final String TICKETZWINTPUT = "C011"; //游客登记指纹时，登记成功后返回检票数据
+    public static final String TICKETPASSIDINTPUT = "C012"; //游客验证指纹时，验证成功后返回检票数据
+    public static final String CHECKEMPLOYEE = "C014"; //工作人员根据卡号，判断员工卡操作类型:是落杆或是入园
+    public static final String CHECKFANGXIN = "C015"; //工作人员根据卡号，判断是否是放行卡
+    public static final String EMPLOYEEINPUT = "C016"; //工作人员刷放行卡后，把信息返回
+    public static final String EMPLOYEEZWINPUT = "C017"; //工作人员登记指纹成功后，把信息返回
+    public static final String EMPLOYEEPASS = "C018"; //工作人员验证指纹后，把信息返回
+    public static final String CHANGEEMPLOYEECHANGERAFT = "C019"; //竹筏改签
+    public static final String CHECKIDENTITYCARD = "C020"; //导游验证身份证号
+    public static final String IDENTITYCARDZWINPUT = "C021"; //导游登记指纹后，返回信息
+    public static final String IDENTITYCARDPASS = "C022"; //导游验证指纹后，返回信息
+    public static final String STOPCHECKTICKETONETABLE = "C023"; //一票多人可暂停，第二次刷票暂停后，返回票信息（单表检票）
+    public static final String STOPCHECKTICKET = "C024"; //一票多人可暂停，第二次刷票暂停后，返回票信息
+    public static final String LOCLOFFLINECHECKTICKET = "C025"; //IC卡离线检票，检票完成后，把检票纪录上传到服务器
+    public static final String ICCHECKWRITELOG = "C026"; //在对IC卡完成写的操作后，纪录日志
+    public static final String GETZHIWEN = "C027"; //根据IC卡号，获取指纹信息
+    public static final String GETWEBCONTANT = "C028"; //获取后台参数
+    public static final String AUTOMETHOD = "C029"; //新增调用方法（畅游通票号检票、获取园门剩余人数、统计入园人数，把人数返回）
+    public static final String GETCHECKCOUNT = "C030"; //获取园门入园人数
+    public static final String GETESBACCESSEQUIPTAB = "C031"; //获取闸机中的指纹滑值参数
+    //    public static final String	QUERYTICKETPRICES	="C032"; //闸机上刷卡买票入园，获取闸机绑定的价格
+//    public static final String	SAVECHECKTICKET	="C033"; //闸机上在支付设备上完成支付后，根据闸机ID、价格ID检票
+    public static final String UPDATESTATUS = "C034"; //把闸机上的所有硬件，是否正常的状态传到服务器
+    public static final String CHECKFACE = "C047"; //人脸识别
+}
diff --git a/src/com/ectrip/cyt/constant/ParamContants.java b/src/com/ectrip/cyt/constant/ParamContants.java
index a858053..369ee6b 100644
--- a/src/com/ectrip/cyt/constant/ParamContants.java
+++ b/src/com/ectrip/cyt/constant/ParamContants.java
@@ -16,4 +16,12 @@ public class ParamContants {
     public static String GET_SHIP_NAME = "GET_SHIP_NAME";
     public static String GET_SHIP_ID = "GET_SHIP_ID";//
     public static String GET_PASS_TOTAL = "GET_PASS_TOTAL";//
+    public static String SET_FPT_HOST = "SET_FPT_HOST";//FTP地址
+    public static String SET_FPT_USETR = "SET_FPT_USETR";//FTP用户
+    public static String SET_FPT_PASSWORD = "SET_FPT_PASSWORD";//FTP密码
+    public static String SET_mac = "SET_mac";//mac地址
+    public static String SET_FPT_PORT = "SET_FPT_PORT";//FTP端口
+    public static String SET_ip = "SET_ip";//ip地址
+
+
 }
diff --git a/src/com/ectrip/cyt/exceptionsave/debug/ConfigureLog4J.java b/src/com/ectrip/cyt/exceptionsave/debug/ConfigureLog4J.java
index 6e796ba..f1f1260 100644
--- a/src/com/ectrip/cyt/exceptionsave/debug/ConfigureLog4J.java
+++ b/src/com/ectrip/cyt/exceptionsave/debug/ConfigureLog4J.java
@@ -28,7 +28,7 @@ public class ConfigureLog4J {
         // String needWriteMessage = myLogSdf.format(nowtime);
         //日志文件路径地址:SD卡下myc文件夹log文件夹的test文件
         String fileName = Environment.getExternalStorageDirectory()
-                + File.separator + "ectripLOG" + File.separator + "log"
+                + File.separator + "ectripLOG" + File.separator + "log_CYT"
                 + File.separator + "tdos.log";
         //设置文件名
         logConfigurator.setFileName(fileName);
diff --git a/src/com/ectrip/cyt/receiver/AlarmReceiver.java b/src/com/ectrip/cyt/receiver/AlarmReceiver.java
new file mode 100644
index 0000000..e895655
--- /dev/null
+++ b/src/com/ectrip/cyt/receiver/AlarmReceiver.java
@@ -0,0 +1,34 @@
+package com.ectrip.cyt.receiver;
+
+import android.content.BroadcastReceiver;
+import android.content.Context;
+import android.content.Intent;
+
+import com.ectrip.cyt.service.FtpParamerService;
+import com.ectrip.cyt.service.UploadLogService;
+import com.ectrip.cyt.utils.LogUtil;
+
+
+public class AlarmReceiver extends BroadcastReceiver {
+
+    public static final String ACTIION_UPLOAD = "UPLOAD";
+    public static final String ACTIION_FTPPARAMER = "FTPPARAMER";
+
+    @Override
+    public void onReceive(Context context, Intent intent) {
+        LogUtil.i("AlarmReceiver", "onReceive action = " + intent.getAction());
+        Intent intents;
+        switch (intent.getAction()) {
+            case ACTIION_UPLOAD:
+                intents = new Intent(context, UploadLogService.class);
+                context.startService(intents);
+                break;
+            case ACTIION_FTPPARAMER:
+                intents = new Intent(context, FtpParamerService.class);
+                context.startService(intents);
+                break;
+            default:
+                break;
+        }
+    }
+}
diff --git a/src/com/ectrip/cyt/service/FtpParamerService.java b/src/com/ectrip/cyt/service/FtpParamerService.java
new file mode 100644
index 0000000..e72fb15
--- /dev/null
+++ b/src/com/ectrip/cyt/service/FtpParamerService.java
@@ -0,0 +1,177 @@
+package com.ectrip.cyt.service;
+
+import android.annotation.SuppressLint;
+import android.app.Service;
+import android.content.Intent;
+import android.os.Handler;
+import android.os.IBinder;
+import android.os.Message;
+//import android.support.annotation.Nullable;
+import android.text.TextUtils;
+
+import com.ectrip.cyt.bean.GetFtp;
+import com.ectrip.cyt.bean.ResultBean;
+import com.ectrip.cyt.config.DevicTool;
+import com.ectrip.cyt.constant.CallBackTypeConstant;
+import com.ectrip.cyt.constant.CheckTicketConstant;
+import com.ectrip.cyt.constant.ParamContants;
+import com.ectrip.cyt.utils.LogUtil;
+import com.ectrip.cyt.utils.PreferenceUtils;
+import com.ectrip.trips.net.BasePostProtocol;
+import com.ectrip.trips.net.INetCallBack;
+import com.ectrip.trips.net.ModelTools;
+
+
+public class FtpParamerService extends Service {
+
+    private String TAG = "FtpParamerService";
+    private String myId;
+    private String accid;
+    private String mac;
+    private String url ;
+
+
+//    private final int MSG_FTP_TIME = 1;
+    private final int MSG_FTP_3721 = 2;
+//    private final int MSG_FTP_8650 = 3;
+//    private final int MSG_FTP_8612 = 4;
+//    private final int MSG_FTP_SLCK = 5;
+//    private final int MSG_FTP_ONE = 6;
+
+    @SuppressLint("HandlerLeak")
+    private Handler mHandle = new Handler() {
+        @Override
+        public void handleMessage(Message msg) {
+            super.handleMessage(msg);
+            switch (msg.what) {
+                case MSG_FTP_3721:
+                    initFtp3721();
+                    break;
+            }
+        }
+    };
+
+    @Override
+    public IBinder onBind(Intent intent) {
+
+        return null;
+    }
+
+    @Override
+    public void onCreate() {
+        super.onCreate();
+    }
+
+    @Override
+    public int onStartCommand(Intent intent, int flags, int startId) {
+        initData();
+        mHandle.sendEmptyMessageDelayed(MSG_FTP_3721, 2500);
+
+
+//        AlarmManager manager = (AlarmManager) getSystemService(ALARM_SERVICE);
+//        int anHour = 5 * 60 * 1000;
+//        long triggerAtTime = SystemClock.elapsedRealtime() + anHour;
+//        Intent intent1 = new Intent(this, AlarmReceiver.class);
+//        intent1.setAction(AlarmReceiver.ACTIION_CHECKDEV);
+//        PendingIntent pendingIntent = PendingIntent.getBroadcast(this, 0, intent1, PendingIntent.FLAG_UPDATE_CURRENT);
+//        manager.set(AlarmManager.ELAPSED_REALTIME_WAKEUP, triggerAtTime, pendingIntent);
+
+        return super.onStartCommand(intent, flags, startId);
+    }
+
+
+    private void initData() {
+        mac = PreferenceUtils.getString(this, ParamContants.SET_mac, "");
+        if(TextUtils.isEmpty(mac)){
+            mac = DevicTool.getInstance().getDevId();
+            PreferenceUtils.putString(this, ParamContants.SET_mac, mac);
+        }
+        String ip = PreferenceUtils.getString(this, ParamContants.SET_ip, "");
+        if (TextUtils.isEmpty(ip)) {
+            return;
+        }
+        url = CheckTicketConstant.httphead + ip + CheckTicketConstant.action;
+    }
+
+
+
+    /**
+     * 获取服务器参数,用于日志上传
+     */
+    private void initFtp3721() {
+        GetFtp getFtp = new GetFtp();
+        getFtp.setAccid("3721");  //闸机ID
+        getFtp.setMac(mac);
+        new BasePostProtocol().loadMoreData(url, ModelTools.getParam(getFtp, CheckTicketConstant.GETFTP), new MainNetCallBack(CallBackTypeConstant.GETFEPPRARMETER));
+    }
+
+
+
+
+    /**
+     * 网络请求的回调
+     */
+    class MainNetCallBack implements INetCallBack {
+        int type;
+
+        public MainNetCallBack(int type) {
+            this.type = type;
+        }
+
+        @Override
+        public void onFailure(String error) {
+
+            switch (type) {
+                case CallBackTypeConstant.GETFEPPRARMETER:
+                    LogUtil.d(TAG, "【获取ftp参数失败 == 3721】");
+                    break;
+                default:
+                    LogUtil.d(TAG, error);
+                    break;
+            }
+        }
+
+        @Override
+        public void onSuccessed(String result) {
+            LogUtil.d("HTTP", "【返回结果】" + result);
+            switch (type) {
+                case CallBackTypeConstant.GETFEPPRARMETER:
+                    getFtpParamer(result);
+                    break;
+                default:
+                    break;
+            }
+        }
+
+
+        @Override
+        public void onPrepare() {
+        }
+    }
+
+
+
+    private void getFtpParamer(String result) {
+        try {
+            ResultBean bean = ModelTools.parseRequest(result, ResultBean.class);
+            String host = bean.getResult(0, 0);
+            String port = bean.getResult(0, 1);
+            String username = bean.getResult(0, 2);
+            String password = bean.getResult(0, 3);
+            if (!TextUtils.isEmpty(host) && !TextUtils.isEmpty(username) && !TextUtils.isEmpty(password) && host.length() > 1 && username.length() > 1 && password.length() > 1) {
+                LogUtil.i(TAG, "【获取ftp参数正确】");
+                PreferenceUtils.putString(this,ParamContants.SET_FPT_HOST, host);
+                PreferenceUtils.putString(this,ParamContants.SET_FPT_USETR, username);
+                PreferenceUtils.putString(this,ParamContants.SET_FPT_PASSWORD, password);
+                PreferenceUtils.putString(this,ParamContants.SET_FPT_PORT, port);
+            } else {
+                LogUtil.e(TAG, "【获取ftp参数失败!】");
+            }
+        } catch (Exception e) {
+            LogUtil.e(TAG, LogUtil.getExMsg(e));
+        }
+
+    }
+
+
+}
diff --git a/src/com/ectrip/cyt/service/UploadLogService.java b/src/com/ectrip/cyt/service/UploadLogService.java
new file mode 100644
index 0000000..9035a1e
--- /dev/null
+++ b/src/com/ectrip/cyt/service/UploadLogService.java
@@ -0,0 +1,103 @@
+package com.ectrip.cyt.service;
+
+import android.app.AlarmManager;
+import android.app.PendingIntent;
+import android.app.Service;
+import android.content.Intent;
+import android.os.Environment;
+import android.os.IBinder;
+import android.os.SystemClock;
+import android.text.TextUtils;
+
+import com.ectrip.cyt.config.MyApp;
+import com.ectrip.cyt.constant.ParamContants;
+import com.ectrip.cyt.receiver.AlarmReceiver;
+import com.ectrip.cyt.utils.FtpsTools;
+import com.ectrip.cyt.utils.LogUtil;
+import com.ectrip.cyt.utils.PreferenceUtils;
+import com.ectrip.cyt.utils.ThreadUtils;
+
+
+import java.io.File;
+import java.util.ArrayList;
+import java.util.List;
+
+public class UploadLogService extends Service {
+
+    private String TAG = "UploadLogService";
+
+    @Override
+    public IBinder onBind(Intent intent) {
+        return null;
+    }
+
+    @Override
+    public void onCreate() {
+        super.onCreate();
+    }
+
+    @Override
+    public int onStartCommand(Intent intent, int flags, int startId) {
+        ThreadUtils.getInstance().exeute(new MyRunnable());
+
+        AlarmManager manager = (AlarmManager) getSystemService(ALARM_SERVICE);
+//        int anHour = 6 * 3600 * 1000;
+        int anHour = 3 * 3600 * 1000;
+//        int anHour = 120 * 1000;
+        long triggerAtTime = SystemClock.elapsedRealtime() + anHour;
+        Intent intent1 = new Intent(this, AlarmReceiver.class);
+        intent1.setAction(AlarmReceiver.ACTIION_UPLOAD);
+        PendingIntent pendingIntent = PendingIntent.getBroadcast(this, 0, intent1, PendingIntent.FLAG_UPDATE_CURRENT);
+        manager.set(AlarmManager.ELAPSED_REALTIME_WAKEUP, triggerAtTime, pendingIntent);
+
+        return super.onStartCommand(intent, flags, startId);
+    }
+
+    private class MyRunnable implements Runnable {
+        @Override
+        public void run() {
+            try {
+                Thread.sleep(30000);
+                LogUtil.i(TAG, "【开始自动上传日记】");
+                String foldPath = Environment.getExternalStorageDirectory()
+                        + File.separator + "ectripLOG" + File.separator + "log_CYT"
+                        + File.separator;
+                int countFile = FtpsTools.countFilesInFolder(foldPath);
+                List<String> fileNames = new ArrayList<>();
+                if(countFile > 0){
+                    fileNames.add(foldPath + "tdos.log");
+                    for(int i=1;i<countFile;i++){
+                        if(i >= 6){
+                            break;
+                        }
+                        fileNames.add(foldPath + "tdos.log" + "." + i);
+                    }
+                }
+//                String fileName = Environment.getExternalStorageDirectory().getAbsolutePath()
+//                        + File.separator + "EctripAndroid" + File.separator + "log"
+//                        + File.separator + "check.log";
+                String host = PreferenceUtils.getString(MyApp.getInstance(), ParamContants.SET_FPT_HOST);
+                String username = PreferenceUtils.getString(MyApp.getInstance(),ParamContants.SET_FPT_USETR);
+                String password = PreferenceUtils.getString(MyApp.getInstance(),ParamContants.SET_FPT_PASSWORD);
+                String mac = PreferenceUtils.getString(MyApp.getInstance(),ParamContants.SET_mac);
+                String portStr = PreferenceUtils.getString(MyApp.getInstance(),ParamContants.SET_FPT_PORT);
+                if (TextUtils.isEmpty(host) || TextUtils.isEmpty(username) || TextUtils.isEmpty(password) || TextUtils.isEmpty(mac)) {
+                    LogUtil.i(TAG, "【FTP参数不全】");
+
+
+                    return;
+                }
+                int port;
+                try {
+                    port = Integer.parseInt(portStr);
+                } catch (Exception e) {
+                    port = 22;
+                }
+                FtpsTools.Sftp_server_multiple(fileNames, host, username, password, mac, port);
+
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+    }
+}
diff --git a/src/com/ectrip/cyt/ui/MainActivity.java b/src/com/ectrip/cyt/ui/MainActivity.java
index c099db4..c8ca581 100644
--- a/src/com/ectrip/cyt/ui/MainActivity.java
+++ b/src/com/ectrip/cyt/ui/MainActivity.java
@@ -16,6 +16,7 @@ import android.graphics.Bitmap;
 import android.graphics.BitmapFactory;
 import android.os.Build;
 import android.os.Bundle;
+import android.os.Handler;
 import android.text.InputType;
 import android.text.TextUtils;
 import android.util.DisplayMetrics;
@@ -45,17 +46,21 @@ import com.ectrip.cyt.constant.DeviceType;
 import com.ectrip.cyt.constant.LogoType;
 import com.ectrip.cyt.constant.Module;
 import com.ectrip.cyt.constant.OrderCode;
+import com.ectrip.cyt.constant.ParamContants;
 import com.ectrip.cyt.constant.SelectAction;
 import com.ectrip.cyt.constant.constant;
 import com.ectrip.cyt.db.DbManager;
 import com.ectrip.cyt.response.LoginResponse;
+import com.ectrip.cyt.service.FtpParamerService;
 import com.ectrip.cyt.service.OrderRegularDelecteService;
+import com.ectrip.cyt.service.UploadLogService;
 import com.ectrip.cyt.shield_home.LockLayer.MToast;
 import com.ectrip.cyt.utils.AESEncryptor;
 import com.ectrip.cyt.utils.CommetryUtils;
 import com.ectrip.cyt.utils.DenstityUtils;
 import com.ectrip.cyt.utils.DesUtil;
 import com.ectrip.cyt.utils.LogUtil;
+import com.ectrip.cyt.utils.PreferenceUtils;
 import com.ectrip.cyt.utils.SharedPreferences2Obj;
 import com.ectrip.trips.check.R;
 import com.ectrip.trips.net.HttpHelper;
@@ -81,7 +86,7 @@ public class MainActivity extends BaseActivity implements OnItemClickListener, V
     private TextView login;
     private TextView unlogin;
     private TextView tv_username;
-
+    private final Handler mHandler = new Handler();
     @Override
     protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
@@ -93,6 +98,12 @@ public class MainActivity extends BaseActivity implements OnItemClickListener, V
         regularDelecte();
         typeJudgment();
         LogUtil.e(TAG, "硬件序列号 ： " + getSerialNumber() + "，型号 ：" + Build.MODEL);
+        mHandler.postDelayed(new Runnable() {
+            @Override
+            public void run() {
+                initService();
+            }
+        }, 3000);
     }
 
     /**
@@ -116,6 +127,15 @@ public class MainActivity extends BaseActivity implements OnItemClickListener, V
 
     }
 
+    private void initService() {
+
+        Intent ftp = new Intent(this, FtpParamerService.class);
+        startService(ftp);
+
+        Intent upLoad = new Intent(this, UploadLogService.class);
+        startService(upLoad);
+    }
+
 
     /**
      * 获取硬件的序列号
@@ -280,6 +300,7 @@ public class MainActivity extends BaseActivity implements OnItemClickListener, V
         if (listConfig != null && listConfig.size() > 0) {
             MyApp.getInstance().setServiceIp(listConfig.get(0).getEc_ip());
             MyApp.getInstance().KeyStr = listConfig.get(0).getEc_identity();
+            setFtpUrl(listConfig.get(0).getEc_ip());
             try {
                 String ec_signkey = AESEncryptor.decrypt(constant.decrypt,
                         listConfig.get(0).getEc_signkey());
@@ -304,6 +325,12 @@ public class MainActivity extends BaseActivity implements OnItemClickListener, V
 
     }
 
+    private void setFtpUrl(String ec_ip) {
+        int endIndex = ec_ip.trim().indexOf("/");
+        String url = ec_ip.trim().substring(0, endIndex);
+        PreferenceUtils.putString(MyApp.getInstance(), ParamContants.SET_ip,url);
+    }
+
     private void initView() {
         gridView1 = (GridView) findViewById(R.id.gridView1);
         adapter = new MainGridDataAdapter(MainActivity.this, initData());
diff --git a/src/com/ectrip/cyt/ui/SettingsActivity.java b/src/com/ectrip/cyt/ui/SettingsActivity.java
index 0903439..57f71fd 100644
--- a/src/com/ectrip/cyt/ui/SettingsActivity.java
+++ b/src/com/ectrip/cyt/ui/SettingsActivity.java
@@ -47,6 +47,7 @@ import antistatic.spinnerwheel.AbstractWheel;
 import com.ectrip.cyt.bean.ConfigBean;
 import com.ectrip.cyt.config.DevicTool;
 import com.ectrip.cyt.config.MyApp;
+import com.ectrip.cyt.constant.ParamContants;
 import com.ectrip.cyt.constant.constant;
 import com.ectrip.cyt.db.DbManager;
 import com.ectrip.cyt.shield_home.LockLayer.MToast;
@@ -54,6 +55,7 @@ import com.ectrip.cyt.spinnerwheel.adapters.NumericWheelAdapter;
 import com.ectrip.cyt.utils.AESEncryptor;
 import com.ectrip.cyt.utils.CommetryUtils;
 import com.ectrip.cyt.utils.LogUtil;
+import com.ectrip.cyt.utils.PreferenceUtils;
 import com.ectrip.cyt.utils.SharedPreferences2Obj;
 import com.ectrip.cyt.version.UpdateManager;
 import com.ectrip.trips.check.R;
diff --git a/src/com/ectrip/cyt/utils/DateUtils.java b/src/com/ectrip/cyt/utils/DateUtils.java
index a3b780e..04a7559 100644
--- a/src/com/ectrip/cyt/utils/DateUtils.java
+++ b/src/com/ectrip/cyt/utils/DateUtils.java
@@ -6,6 +6,7 @@ import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.util.Calendar;
 import java.util.Date;
+import java.util.Locale;
 import java.util.TimeZone;
 
 /**
@@ -681,4 +682,14 @@ public class DateUtils {
 	public static String getDays() {
 		return getTodayStr().substring(0, 10);
 	}
+
+	/**
+	 * 获取当前的时间 yyyy-MM-dd
+	 * @return
+	 */
+	public static String getCurrentDate() {
+		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd", Locale.CHINA);
+		Date date = new Date(System.currentTimeMillis());
+		return format.format(date);
+	}
 }
diff --git a/src/com/ectrip/cyt/utils/EncryptUtil.java b/src/com/ectrip/cyt/utils/EncryptUtil.java
new file mode 100644
index 0000000..bfdf4cb
--- /dev/null
+++ b/src/com/ectrip/cyt/utils/EncryptUtil.java
@@ -0,0 +1,152 @@
+package com.ectrip.cyt.utils;
+
+
+import java.io.UnsupportedEncodingException;
+import java.security.InvalidKeyException;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.security.SecureRandom;
+import java.security.spec.InvalidKeySpecException;
+
+import javax.crypto.BadPaddingException;
+import javax.crypto.Cipher;
+import javax.crypto.IllegalBlockSizeException;
+import javax.crypto.NoSuchPaddingException;
+import javax.crypto.SecretKey;
+import javax.crypto.SecretKeyFactory;
+import javax.crypto.spec.DESedeKeySpec;
+
+
+/**
+ * 基础加密算法类?当前支持des,md5码?
+ *
+ * @author huhaopeng
+ */
+public class EncryptUtil {
+
+    /**
+     * MD5值计码?p>
+     * MD5的算法在RFC1321 中定码?
+     * 在RFC 1321中，给出了Test suite用来码?码码你的实现是否正确码?
+     * MD5 ("") = d41d8cd98f00b204e9800998ecf8427e
+     * MD5 ("a") = 0cc175b9c0f1b6a831c399e269772661
+     * MD5 ("abc") = 900150983cd24fb0d6963f7d28e17f72
+     * MD5 ("message digest") = f96b697d7cb7938d525a2f31aaf161d0
+     * MD5 ("abcdefghijklmnopqrstuvwxyz") = c3fcd3d76192e4007dfb496cca67e13b
+     * @param str 源字符串
+     * @return md5码?
+     */
+    public final static byte[] md5(String str) {
+        try {
+            byte[] res = str.getBytes("UTF-8");
+            MessageDigest mdTemp = MessageDigest.getInstance("MD5".toUpperCase());
+            mdTemp.update(res);
+            byte[] hash = mdTemp.digest();
+            return hash;
+        } catch (Exception e) {
+            return null;
+        }
+    }
+
+    //hex repr. of md5
+    public final static String MD5Hex(String input) {
+        String s = null;
+        char hexDigits[] = { // 用来将字节转换成 16 进制表示的字码?
+                '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd',
+                'e', 'f'};
+        try {
+            MessageDigest md = MessageDigest
+                    .getInstance("MD5");
+            md.update(input.getBytes("utf-8"));
+            byte tmp[] = md.digest();
+
+            char str[] = new char[16 * 2];
+
+            int k = 0;
+            for (int i = 0; i < 16; i++) {
+
+                byte byte0 = tmp[i];
+                str[k++] = hexDigits[byte0 >>> 4 & 0xf];
+                str[k++] = hexDigits[byte0 & 0xf];
+            }
+            s = new String(str);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return s;
+    }
+
+    // 加密后解码?
+    public static String JM(byte[] inStr) {
+        String newStr = new String(inStr);
+        char[] a = newStr.toCharArray();
+        for (int i = 0; i < a.length; i++) {
+            a[i] = (char) (a[i] ^ 't');
+        }
+        String k = new String(a);
+        return k;
+    }
+
+
+
+
+
+
+
+    /**
+     * @param key 24位密码?
+     * @param str 源字符串
+     * @return
+     * @throws NoSuchAlgorithmException
+     * @throws NoSuchPaddingException
+     * @throws InvalidKeyException
+     * @throws UnsupportedEncodingException
+     * @throws InvalidKeySpecException
+     * @throws IllegalBlockSizeException
+     * @throws BadPaddingException
+     */
+    public static byte[] des3Encrypt(String key, String str) throws NoSuchAlgorithmException, NoSuchPaddingException, InvalidKeyException, UnsupportedEncodingException, InvalidKeySpecException, IllegalBlockSizeException, BadPaddingException {
+
+        byte[] newkey = key.getBytes();
+
+        SecureRandom sr = new SecureRandom();
+
+        DESedeKeySpec dks = new DESedeKeySpec(newkey);
+
+        SecretKeyFactory keyFactory = SecretKeyFactory.getInstance("DESede");
+
+        SecretKey securekey = keyFactory.generateSecret(dks);
+
+        Cipher cipher = Cipher.getInstance("DESede/ECB/PKCS5Padding");
+
+        cipher.init(Cipher.ENCRYPT_MODE, securekey, sr);
+
+        byte[] bt = cipher.doFinal(str.getBytes("utf-8"));
+
+        return bt;
+    }
+
+
+    public final static String taoBaoMD5(String s) {
+        char hexDigits[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
+                'a', 'b', 'c', 'd', 'e', 'f'};
+        try {
+            byte[] strTemp = s.getBytes("GBK");
+            MessageDigest mdTemp = MessageDigest.getInstance("MD5");
+            mdTemp.update(strTemp);
+            byte[] md = mdTemp.digest();
+            int j = md.length;
+            char str[] = new char[j * 2];
+            int k = 0;
+            for (int i = 0; i < j; i++) {
+                byte byte0 = md[i];
+                str[k++] = hexDigits[byte0 >>> 4 & 0xf];
+                str[k++] = hexDigits[byte0 & 0xf];
+            }
+            return new String(str);
+        } catch (Exception e) {
+            return null;
+        }
+    }
+}
+
diff --git a/src/com/ectrip/cyt/utils/FtpsTools.java b/src/com/ectrip/cyt/utils/FtpsTools.java
new file mode 100644
index 0000000..bdffb92
--- /dev/null
+++ b/src/com/ectrip/cyt/utils/FtpsTools.java
@@ -0,0 +1,313 @@
+package com.ectrip.cyt.utils;
+
+import com.jcraft.jsch.Channel;
+import com.jcraft.jsch.ChannelSftp;
+import com.jcraft.jsch.JSch;
+import com.jcraft.jsch.Session;
+import com.jcraft.jsch.SftpATTRS;
+import com.jcraft.jsch.SftpException;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.util.List;
+import java.util.Properties;
+import java.util.Vector;
+
+/**
+ * Created by dc on 2018/5/14.
+ */
+
+public class FtpsTools {
+    private final static String TAG = FtpsTools.class.getSimpleName();
+    /**
+     * 连接sftp服务器
+     *
+     * @param host     主机
+     * @param port     端口
+     * @param username 用户名
+     * @param password 密码
+     * @return
+     */
+    public ChannelSftp connect(String host, int port, String username, String password) {
+
+        ChannelSftp sftp = null;
+        try {
+            JSch jsch = new JSch();
+            jsch.getSession(username, host, port);
+            Session sshSession = jsch.getSession(username, host, port);
+            LogUtil.d("FTP", "FTP创建Session");
+            sshSession.setPassword(password);
+            Properties sshConfig = new Properties();
+            sshConfig.put("StrictHostKeyChecking", "no");
+            sshSession.setConfig(sshConfig);
+            sshSession.connect(5000);
+            LogUtil.d("FTP", "FTP创建连接");
+            Channel channel = sshSession.openChannel("sftp");
+            channel.connect();
+            sftp = (ChannelSftp) channel;
+            LogUtil.d("FTP", "FTP连接成功");
+        } catch (Exception e) {
+            LogUtil.d("FTP", "FTP连接失败-" + LogUtil.getExMsg(e));
+        }
+        return sftp;
+    }
+
+    /**
+     * 上传文件
+     *
+     * @param directory  上传的目录
+     * @param uploadFile 要上传的文件
+     * @param sftp
+     */
+    public void upload(String directory, String uploadFile, ChannelSftp sftp, String mac) {
+
+        try {
+            sftp.cd(directory);
+            File file = new File(uploadFile);
+            if (file.isFile()) {
+//                String filename = mac + ".log"; //文件名为当前时间来保存
+                sftp.put(new FileInputStream(file), file.getName());
+                LogUtil.i("FtpsTools", "上传成功！");
+            }
+        } catch (Exception e) {
+            LogUtil.d("FTP", "FTP上传失败-" + LogUtil.getExMsg(e));
+        }
+    }
+
+    /**
+     * 下载文件
+     *
+     * @param directory    下载目录
+     * @param downloadFile 下载的文件
+     * @param saveFile     存在本地的路径
+     * @param sftp
+     */
+    public void download(String directory, String downloadFile, String saveFile, ChannelSftp sftp) {
+
+        try {
+            sftp.cd(directory);
+            File file = new File(saveFile);
+            sftp.get(downloadFile, new FileOutputStream(file));
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 删除文件
+     *
+     * @param directory  要删除文件所在目录
+     * @param deleteFile 要删除的文件
+     * @param sftp
+     */
+    public void delete(String directory, String deleteFile, ChannelSftp sftp) {
+
+        try {
+            sftp.cd(directory);
+            sftp.rm(deleteFile);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    /**
+     * 列出目录下的文件
+     *
+     * @param directory 要列出的目录
+     * @param sftp
+     * @return
+     * @throws SftpException
+     */
+    public Vector listFiles(String directory, ChannelSftp sftp) throws SftpException {
+
+        return sftp.ls(directory);
+
+    }
+
+    //上传多个文件
+    public static void Sftp_server_multiple(List<String> files, String host, String username, String password, String mac, int port) {
+
+        FtpsTools sf = new FtpsTools();
+        String directory = "/home/ectrip/";
+        String logPath = "EctripCYTLog";
+        String logPathDate = DateUtils.getCurrentDate();
+        ChannelSftp sftp = sf.connect(host, port, username, password);
+        // 判断子目录文件夹是否存在，不存在即创建
+        SftpATTRS attrs = null;
+        try {
+            sftp.cd(directory);
+            attrs = sftp.stat(logPath);
+        } catch (Exception e) {
+            LogUtil.e("FTP", "FTP连接目录失败1-" + LogUtil.getExMsg(e));
+        }
+        try {
+            LogUtil.i("FTP", "attrs 1 == " + attrs);
+            if (attrs == null) {
+                sftp.mkdir(logPath); //创建目录
+                LogUtil.d("FTP", "FTP创建目录成功");
+            } else {
+                LogUtil.d("FTP", "已存在目录");
+            }
+        } catch (Exception e) {
+            LogUtil.e("FTP", "FTP创建目录失败-" + LogUtil.getExMsg(e));
+        }
+
+        try {
+            attrs = null;
+            sftp.cd(logPath);
+            attrs = sftp.stat(mac);
+        } catch (Exception e) {
+            LogUtil.d("FTP", "FTP连接目录失败2-" + LogUtil.getExMsg(e));
+        }
+
+        try {
+            LogUtil.i("FTP", "attrs 2 == " + attrs);
+            if (attrs == null) {
+                sftp.mkdir(mac); //创建目录
+                LogUtil.d("FTP", "FTP创建mac地址目录成功");
+            } else {
+                LogUtil.d("FTP", "已存在mac地址目录");
+            }
+        } catch (Exception e) {
+            LogUtil.e("FTP", "FTP创建mac地址目录失败-" + LogUtil.getExMsg(e));
+        }
+
+        try {
+            attrs = null;
+            sftp.cd(mac);
+            attrs = sftp.stat(logPathDate);
+        } catch (Exception e) {
+            LogUtil.d("FTP", "FTP连接目录失败2-" + LogUtil.getExMsg(e));
+        }
+
+        try {
+            LogUtil.i("FTP", "attrs 3 == " + attrs);
+            if (attrs == null) {
+                sftp.mkdir(logPathDate); //创建目录
+                LogUtil.d("FTP", "FTP创建日期目录成功");
+            } else {
+                LogUtil.d("FTP", "已存在日期目录");
+            }
+        } catch (Exception e) {
+            LogUtil.e("FTP", "FTP创建日期目录失败-" + LogUtil.getExMsg(e));
+        }
+
+        directory = directory + logPath + File.separator + mac + File.separator +logPathDate;
+        for (String file : files) {
+            LogUtil.i("FTP","上传日志文件 :" + file);
+            sf.upload(directory, file, sftp, mac);//上传文件到服务器
+        }
+
+    }
+
+    //上传文件
+    public static void Sftp_server(final String file, final String host, final String username, final String password, final String mac , final int port) {
+
+        new Thread(new Runnable() {
+            @Override
+            public void run() {
+                FtpsTools sf = new FtpsTools();
+                String directory = "/home/ectrip/";
+                String logPath = "EctripTScreenLog";
+                String uploadFile = file;
+                ChannelSftp sftp = sf.connect(host, port, username, password);
+                // 判断子目录文件夹是否存在，不存在即创建
+                SftpATTRS attrs = null;
+                try {
+                    sftp.cd(directory);
+                    attrs = sftp.stat(logPath);
+                } catch (Exception e) {
+                    LogUtil.d("FTP", "FTP创建目录失败-" + LogUtil.getExMsg(e));
+                }
+                try {
+                    if (attrs == null) {
+                        sftp.mkdir(logPath); //创建目录
+                        LogUtil.d("FTP", "FTP创建目录成功");
+                    } else {
+                        LogUtil.d("FTP", "已存在目录");
+                    }
+                } catch (Exception e) {
+                    LogUtil.d("FTP", "FTP创建目录失败-" + LogUtil.getExMsg(e));
+                }
+                directory = directory + logPath;
+                sf.upload(directory, uploadFile, sftp, mac);//上传文件到服务器
+            }
+        }).start();
+    }
+
+    /**
+     * 文件夹内文件的个数
+     * @param folderPath
+     * @return
+     * create by honceh 2023/9/1
+     */
+    public static int countFilesInFolder(String folderPath) {
+        File folder = new File(folderPath);
+        if (folder.isDirectory()) {
+            File[] files = folder.listFiles();
+            if (files != null) {
+                return files.length;
+            }
+        }
+        return 0;
+    }
+
+//    /**
+//     * 初始化ftp
+//     */
+//    public static void initFTP() {
+//        String[] params = {"FTTP", "3721"};
+//        String userId = DBUtils.queryData(ParameterContens.USER, null);
+//        String password = DBUtils.queryData(ParameterContens.PWD, null);
+//        Saleautoservice saleautoservice = new Saleautoservice();
+//        saleautoservice.setMd5Str("");
+//        saleautoservice.setUserId(userId);
+//        saleautoservice.setPassword(password);
+//        saleautoservice.setMethod(13);
+//        saleautoservice.setParameters(params);
+//        getFTPResult("saleautoservice", saleautoservice);
+//    }
+//
+//    private static void getFTPResult(String method, Object data) {
+//
+//        APIService.getInstance().loadData(method, data, BaseSaleResponse.class, new OnResultListener<BaseSaleResponse>() {
+//            @Override
+//            public void onResult(BaseSaleResponse result) {
+//                try {
+//                    if (result.getCode().equals("200")) {
+//                        ResultBean bean = JSON.parseObject(JSON.toJSONString(result.getData()), ResultBean.class);
+//                        ShowResultBean.show(bean);
+//                        //处理结果
+//                        LogUtil.i(TAG, "000" + result.getMsg());
+//                        String resultState = result.getMsg().toLowerCase();
+//                        if (TextUtils.equals("success", resultState)) {
+//                            LogUtil.i(TAG, "获取ftp服务器数据成功");
+//                            DBUtils.insertData(ParameterContens.SET_FPT_HOST, bean.getResult(0, "pmva"));
+//                            DBUtils.insertData(ParameterContens.SET_FPT_USETR, bean.getResult(0, "pmvc"));
+//                            DBUtils.insertData(ParameterContens.SET_FPT_PASSWORD, bean.getResult(0, "pmvd"));
+//                            DBUtils.insertData(ParameterContens.SET_FPT_PORT, bean.getResult(0, "pmvb"));
+//
+//                        } else {
+//                            LogUtil.i(TAG, "获取ftp服务器数据失败");
+//                        }
+//                    }
+//                } catch (Exception e) {
+//                    LogUtil.i(TAG, "获取ftp服务器数据异常");
+//                    LogUtil.d("ResultBean", LogUtil.getExMsg(e));
+//                }
+//            }
+//
+//            @Override
+//            public void onCompleted() {
+//
+//            }
+//
+//            @Override
+//            public void onError(String error) {
+//                LogUtil.d("ResultBean", error);
+//            }
+//        });
+//    }
+
+}
diff --git a/src/com/ectrip/cyt/utils/SignTools.java b/src/com/ectrip/cyt/utils/SignTools.java
new file mode 100644
index 0000000..e3f7efb
--- /dev/null
+++ b/src/com/ectrip/cyt/utils/SignTools.java
@@ -0,0 +1,35 @@
+package com.ectrip.cyt.utils;
+
+
+import com.ectrip.cyt.constant.CheckTicketConstant;
+
+
+/**
+ * 签名工具
+ * Created by lingkitho on 2017/3/1.
+ */
+public class SignTools {
+
+    /**
+     * 签名
+     * @param data
+     * @return
+     */
+    public static String getSign(String data) {
+        if(null != data) {
+            return EncryptUtil.MD5Hex(data + CheckTicketConstant.MD5KEY);
+        }else {
+            return null;
+        }
+    }
+
+    /**
+     * 检查签名
+     * @param signKey
+     * @param data
+     * @return
+     */
+    public static boolean chechSign(String signKey, String data){
+        return signKey.equals(getSign(data));
+    }
+}
diff --git a/src/com/ectrip/cyt/utils/ThreadUtils.java b/src/com/ectrip/cyt/utils/ThreadUtils.java
new file mode 100644
index 0000000..26b6182
--- /dev/null
+++ b/src/com/ectrip/cyt/utils/ThreadUtils.java
@@ -0,0 +1,64 @@
+package com.ectrip.cyt.utils;
+
+import java.util.concurrent.LinkedBlockingDeque;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+public class ThreadUtils {
+    private static ThreadPool instance;
+
+    private ThreadUtils() {
+    }
+
+    public static ThreadPool getInstance() {
+        if (instance == null) {
+            synchronized (ThreadUtils.class) {
+                if ((instance == null)) {
+                    int cpuCount = Runtime.getRuntime().availableProcessors(); // 获取cpu数量，即核数
+                    int threadCount = cpuCount * 2 + 1; //线程池中线程的个数---cpu核数*2+1--性能最佳
+                    LogUtil.i("ThreadUtils", "ThreadUtils count == " + threadCount);
+                    instance = new ThreadPool(threadCount, threadCount, 0L);
+
+                }
+            }
+        }
+        return instance;
+    }
+
+    public static class ThreadPool {
+        private int corePoolSize;
+        private int maximunPoolSize;
+        private long keepAliveTime;
+
+        private ThreadPoolExecutor executor;
+
+        public ThreadPool(int corePoolSize, int maximunPoolSize, long keepAliveTime) {
+            this.corePoolSize = corePoolSize;
+            this.maximunPoolSize = maximunPoolSize;
+            this.keepAliveTime = keepAliveTime;
+        }
+
+        public void exeute(Runnable runnable) {
+            if (executor == null) {
+                executor = new ThreadPoolExecutor(corePoolSize,
+                        maximunPoolSize, keepAliveTime, TimeUnit.SECONDS,
+                        new LinkedBlockingDeque<Runnable>(),
+                        new ThreadPoolExecutor.AbortPolicy());
+
+            }
+            executor.execute(runnable);
+        }
+
+        public void cancel(Runnable r) {
+            if (executor != null) {
+                executor.getQueue().remove(r);
+            }
+        }
+
+        public void close() {
+            if (executor != null) {
+                executor.shutdownNow();
+            }
+        }
+    }
+}
diff --git a/src/com/ectrip/trips/net/BasePostProtocol.java b/src/com/ectrip/trips/net/BasePostProtocol.java
new file mode 100644
index 0000000..8e42306
--- /dev/null
+++ b/src/com/ectrip/trips/net/BasePostProtocol.java
@@ -0,0 +1,102 @@
+package com.ectrip.trips.net;
+
+import android.os.Handler;
+import android.os.Message;
+
+import com.ectrip.cyt.utils.LogUtil;
+
+import java.io.IOException;
+
+import okhttp3.MediaType;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+import okhttp3.Response;
+
+
+public class BasePostProtocol {
+
+    private String url;
+    private String mParamsStr;
+    private Handler mHandler = new Handler() {
+        @Override
+        public void handleMessage(Message msg) {
+            super.handleMessage(msg);
+            switch (msg.what) {
+                case 100://成功
+                    String result = (String) msg.obj;
+                    callback.onSuccessed(result);
+                    break;
+                case 101://失败
+                    String error = (String) msg.obj;
+                    callback.onFailure(error);
+                    LogUtil.d("HTTP", error);
+                    break;
+            }
+
+        }
+    };
+    INetCallBack callback;
+
+    /**
+     * post 请求的方法
+     *
+     * @param url      请求地址
+     * @param paramStr 参数
+     */
+
+    public void loadMoreData(String url, String paramStr, final INetCallBack call) {
+        LogUtil.d("HTTP", "【请求地址】" + url);
+        LogUtil.d("HTTP", "【请求参数】" + paramStr);
+        mParamsStr = paramStr;
+        this.url = url;
+        callback = call;
+        callback.onPrepare();
+        new Thread(new Runnable() {
+
+            @Override
+            public void run() {
+                loadDataFromNet();
+            }
+        }).start();
+    }
+
+    private void loadDataFromNet() {
+        try {
+            OkHttpClient okHttpClient = OkHttpFactory.getOkHttpClient();
+            MediaType JSON = MediaType.parse("application/json; charset=utf-8");
+            RequestBody formBody = RequestBody.create(JSON, mParamsStr);
+            Request request = new Request.Builder().url(url).post(formBody).build();
+            Response response;
+            try {
+                response = okHttpClient.newCall(request).execute();
+                if (response.isSuccessful()) {
+                    Message message = Message.obtain();
+                    String result = response.body().string();
+                    LogUtil.d("HTTP", result);
+                    message.obj = result;
+                    message.what = 100;
+                    mHandler.sendMessage(message);
+                } else {
+                    Message message = Message.obtain();
+                    String error = response.body().string();
+                    LogUtil.d("HTTP", error);
+                    message.obj = error;
+                    message.what = 101;
+                    mHandler.sendMessage(message);
+                }
+            } catch (IOException e) {
+                Message message = Message.obtain();
+                String error = LogUtil.getExMsg(e);
+                LogUtil.d("HTTP", error);
+                message.obj = error;
+                message.what = 101;
+                mHandler.sendMessage(message);
+            }
+        } catch (Exception e) {
+            LogUtil.d("HTTP", LogUtil.getExMsg(e));
+        }
+
+    }
+
+}
diff --git a/src/com/ectrip/trips/net/INetCallBack.java b/src/com/ectrip/trips/net/INetCallBack.java
new file mode 100644
index 0000000..f232ce3
--- /dev/null
+++ b/src/com/ectrip/trips/net/INetCallBack.java
@@ -0,0 +1,11 @@
+package com.ectrip.trips.net;
+
+/**
+ * Created by dc on 2017/3/7.
+ */
+
+public interface INetCallBack {
+     void onFailure(String error);
+     void onSuccessed(String result);
+     void onPrepare();
+}
diff --git a/src/com/ectrip/trips/net/ModelTools.java b/src/com/ectrip/trips/net/ModelTools.java
new file mode 100644
index 0000000..ac7c812
--- /dev/null
+++ b/src/com/ectrip/trips/net/ModelTools.java
@@ -0,0 +1,189 @@
+package com.ectrip.trips.net;
+
+import com.alibaba.fastjson.JSON;
+import com.ectrip.cyt.bean.BaseRequest;
+import com.ectrip.cyt.bean.BaseResponse;
+import com.ectrip.cyt.bean.DataTranfer;
+import com.ectrip.cyt.utils.Base64;
+import com.ectrip.cyt.utils.LogUtil;
+import com.ectrip.cyt.utils.SignTools;
+
+
+/**
+ * This is a tool class for Check Ticket Http
+ * Created by lingkitho on 2017/3/1.
+ */
+public class ModelTools {
+
+    /**
+     * 解析请求体 - 将Http请求转换成Bean对象
+     * @param rawData 原始数据
+     * @param clazz   类模板
+     * @return Bean 对象
+     */
+    public static <T> T parseRequest(String rawData, Class<T> clazz) throws Exception {
+
+
+        DataTranfer dataTranfer = null;
+        String param;//请求数据
+        try {
+            dataTranfer = JSON.parseObject(rawData,DataTranfer.class);
+            if(null == dataTranfer){
+                throw new Exception("原始数据为空！");
+            }
+            if(null == dataTranfer.getSigned()){
+                throw new Exception("签名为空！");
+            }
+            boolean isOk = SignTools.chechSign(dataTranfer.getSigned(),dataTranfer.getData());
+            if(!isOk){
+                throw new Exception("签名验证失败！");
+            }
+
+        } catch (Exception e) {
+            throw new Exception("原始数据json格式不正确！"+ LogUtil.getExMsg(e));
+        }
+        try {
+            byte[] requestDataJson = Base64.decode(dataTranfer.getData());
+            param = new String(requestDataJson);
+        } catch (Exception e) {
+            throw new Exception("请求数据解密失败！请勿篡改数据。请检查参数！");
+        }
+        if(null != param && param.length()>0) {
+            try {
+                BaseResponse response = JSON.parseObject(param,BaseResponse.class);
+                if(response != null && response.getData() != null){
+                    T obj = JSON.parseObject(response.getData().toString(), clazz);
+                    LogUtil.i("CHECK","【请求数据返回成功】ResultBean="+response.getData().toString());
+                    if(null == obj){
+                        throw new Exception("转换后的请求实体为null，请检查参数");
+                    }
+                    return obj;
+                }
+                return  null;
+            } catch (Exception e) {
+                throw new Exception("json实体转换错误。请检查参数，且确保参数与接口对应");
+            }
+        }else{
+            return null;
+        }
+    }
+
+    public static BaseResponse parseRequestFace(String rawData) throws Exception {
+        BaseResponse response = null;
+
+        DataTranfer dataTranfer = null;
+        String param;//请求数据
+        try {
+            dataTranfer = JSON.parseObject(rawData,DataTranfer.class);
+            if(null == dataTranfer){
+                throw new Exception("原始数据为空！");
+            }
+            if(null == dataTranfer.getSigned()){
+                throw new Exception("签名为空！");
+            }
+            boolean isOk = SignTools.chechSign(dataTranfer.getSigned(),dataTranfer.getData());
+            if(!isOk){
+                throw new Exception("签名验证失败！");
+            }
+
+        } catch (Exception e) {
+            throw new Exception("原始数据json格式不正确！"+ LogUtil.getExMsg(e));
+        }
+        try {
+            byte[] requestDataJson = Base64.decode(dataTranfer.getData());
+            param = new String(requestDataJson);
+        } catch (Exception e) {
+            throw new Exception("请求数据解密失败！请勿篡改数据。请检查参数！");
+        }
+        if(null != param && param.length()>0) {
+            try {
+                response = JSON.parseObject(param,BaseResponse.class);
+//                if(response != null && response.getData() != null){
+////                    T obj = JSON.parseObject(response.getData().toString(), clazz);
+////                    T obj  = (T)response.getData();
+//                    LogUtil.i("CHECK","【请求数据返回成功】ResultBean="+response.getData().toString());
+//                    if(null == obj){
+//                        throw new Exception("转换后的请求实体为null，请检查参数");
+//                    }
+//                    return obj;
+//                }
+                return  response;
+            } catch (Exception e) {
+                throw new Exception("json实体转换错误。请检查参数，且确保参数与接口对应");
+            }
+        }else{
+            return null;
+        }
+    }
+
+
+    /**
+     * 解析请求体 - 将Http请求转换成Bean对象
+     * @param rawData 原始数据
+     * @param clazz   类模板
+     * @return Bean 对象
+     */
+    public static <T> T parseBaseRequest(String rawData, Class<T> clazz) throws Exception {
+
+        DataTranfer dataTranfer = null;
+        String param;//请求数据
+        try {
+            dataTranfer = JSON.parseObject(rawData,DataTranfer.class);
+            if(null == dataTranfer){
+                throw new Exception("原始数据为空！");
+            }
+            if(null == dataTranfer.getSigned()){
+                throw new Exception("签名为空！");
+            }
+            boolean isOk = SignTools.chechSign(dataTranfer.getSigned(),dataTranfer.getData());
+            if(!isOk){
+                throw new Exception("签名验证失败！");
+            }
+
+        } catch (Exception e) {
+            throw new Exception("原始数据json格式不正确！"+ LogUtil.getExMsg(e));
+        }
+        try {
+            byte[] requestDataJson = Base64.decode(dataTranfer.getData());
+            param = new String(requestDataJson);
+        } catch (Exception e) {
+            throw new Exception("请求数据解密失败！请勿篡改数据。请检查参数！");
+        }
+        if(null != param && param.length()>0) {
+            try {
+                    T obj = JSON.parseObject(param, clazz);
+                    if(null == obj){
+                        throw new Exception("转换后的请求实体为null，请检查参数");
+                    }
+                    return obj;
+            } catch (Exception e) {
+                throw new Exception("json实体转换错误。请检查参数，且确保参数与接口对应");
+            }
+        }else{
+            return null;
+        }
+    }
+
+    public static String getParam (BaseRequest data , String method){
+        String dataJson = JSON.toJSONString(data);//将请求的实体转换成json字符串
+        String dataBase64 = Base64.encode(dataJson.getBytes());//将字符串进行base64加密
+        String signed = SignTools.getSign(dataBase64);//获得签名
+        DataTranfer dataTranfer = new DataTranfer();//封装到body的实体
+        dataTranfer.setData(dataBase64);//将base64的加密串作为data
+        dataTranfer.setSigned(signed);//设置签名
+        dataTranfer.setMethod(method);//设置方法名
+
+        String param = JSON.toJSONString(dataTranfer);
+        return param;
+    }
+    public static String getParamFace (String dataBase64 , String method){
+        String signed = SignTools.getSign(dataBase64);//获得签名
+        DataTranfer dataTranfer = new DataTranfer();//封装到body的实体
+        dataTranfer.setData(dataBase64);//将base64的加密串作为data
+        dataTranfer.setSigned(signed);//设置签名
+        dataTranfer.setMethod(method);//设置方法名
+
+        String param = JSON.toJSONString(dataTranfer);
+        return param;
+    }
+}
diff --git a/src/com/ectrip/trips/net/OkHttpFactory.java b/src/com/ectrip/trips/net/OkHttpFactory.java
new file mode 100644
index 0000000..fa2b6a3
--- /dev/null
+++ b/src/com/ectrip/trips/net/OkHttpFactory.java
@@ -0,0 +1,23 @@
+package com.ectrip.trips.net;
+
+
+import java.util.concurrent.TimeUnit;
+
+import okhttp3.OkHttpClient;
+
+public class OkHttpFactory {
+
+    static OkHttpClient mOkHttpClient;
+
+    
+    public static OkHttpClient getOkHttpClient() {
+        if (mOkHttpClient == null) {
+            synchronized (OkHttpFactory.class) {
+                if (mOkHttpClient == null) {
+                    mOkHttpClient = new OkHttpClient.Builder().connectTimeout(300, TimeUnit.SECONDS).build();
+                }
+            }
+        }
+        return mOkHttpClient;
+    }
+}