sujinwen

2017-07-24 84c967c436f9e643fe30de2f99e9f88d80fe1bf0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
package cn.com.basic.face.service; 
 
import com.alibaba.fastjson.JSONArray; 
 
import org.xutils.http.RequestParams; 
import org.xutils.x; 
 
import java.text.SimpleDateFormat; 
import java.util.Date; 
import java.util.List; 
 
import cn.com.basic.face.discern.common.BaseCommonCallBack; 
import cn.com.basic.face.discern.common.SqliteSqlBean; 
import cn.com.basic.face.service.sqlite.CompanyDao; 
import cn.com.basic.face.service.sqlite.DeviceDao; 
import cn.com.basic.face.service.sqlite.DictionaryDao; 
import cn.com.basic.face.util.AppApi; 
import cn.com.basic.face.util.SqliteSqlUtil; 
 
 
/** 
 *   数据同步服务接口 
 * Created by SJW 
 *              2017/7/18 0018. 
 */ 
 
public class DataSynchronService { 
 
 
        public static DataSynchronService instance=new DataSynchronService(); 
 
       public static DataSynchronService getInstance(){ 
           return instance; 
       } 
 
 
        /*** 
         * 向下同步，请求服务端，本地更新对应的数据库 
         * @param synDate   同步时间 
         * @param tableName  表名 
         * @param deviceCompanyId   设备所在机构id 
         * @return 
         */ 
       public  void  serviceToClient(Date synDate, final String tableName, String deviceCompanyId){ 
        try{ 
            RequestParams params = new RequestParams(AppApi.BASE_URL + AppApi.DOWN_SYNCHRON); 
            params.addBodyParameter("tableName", tableName); 
            params.addBodyParameter("synDate",String.valueOf(synDate)); 
            params.addBodyParameter("deviceCompanyId",deviceCompanyId); 
            x.http().post(params, new BaseCommonCallBack() { 
                public void success() { 
                    SqliteSqlUtil.insert(getExtraList(SqliteSqlBean.class)); 
                } 
            }); 
        }catch(Exception e){ 
            e.printStackTrace(); 
        } 
 
       } 
 
 
    /*** 
     * 双向同步 
     * @param synDate               同步时间 
     * @param deviceCompanyId       设备所在机构id 
     * @param tableName             表名 
     */ 
       public void  twoWaySynchron(Date synDate, final String deviceCompanyId, String tableName){ 
          try{ 
              RequestParams params = new RequestParams(AppApi.BASE_URL + AppApi.TWO_WAY_SYNCHRON); 
              SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
              final String temp=tableName; 
              params.addBodyParameter("tableName", tableName); 
              params.addBodyParameter("synDate",sdf.format(synDate)); 
              if("company".equals(tableName)){ 
                  params.addBodyParameter("data", JSONArray.toJSONString(CompanyDao.getInstance().getCompanyList(deviceCompanyId))); 
              } 
              if("device".equals(tableName)){ 
                  params.addBodyParameter("data", JSONArray.toJSONString(DeviceDao.getInstance().getDeviceList(deviceCompanyId))); 
              } 
              if("dictionary".equals(tableName)){ 
                  params.addBodyParameter("data", JSONArray.toJSONString(DictionaryDao.getInstance().getDictionayList(deviceCompanyId))); 
              } 
              params.addBodyParameter("deviceCompanyId",deviceCompanyId); 
              x.http().post(params, new BaseCommonCallBack() { 
                  public void success() { 
                      if("company".equals(temp)){ 
                          CompanyDao.getInstance().delCompanyList(deviceCompanyId); 
                      } 
                      if("device".equals(temp)){ 
                          DeviceDao.getInstance().delDevice(deviceCompanyId); 
                      } 
                      if("dictionary".equals(temp)){ 
                          DictionaryDao.getInstance().delDictionary(deviceCompanyId); 
                      } 
 
                      List<SqliteSqlBean> result= getExtraList(SqliteSqlBean.class); 
                      SqliteSqlUtil.insert(getExtraList(SqliteSqlBean.class)); 
                  } 
              }); 
          }catch(Exception e){ 
              e.printStackTrace(); 
          } 
 
       } 
 
 
 
}