sujinwen

2017-07-25 c7caa54d8d58af6159f2c758ad5d6687d461a333

 VisitFace/DemoForBsk/app/src/main/java/cn/com/basic/face/service/DataSynchronService.java

@@ -1,15 +1,21 @@
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.CommonVariables;

import cn.com.basic.face.discern.query.condition.AttendanceQueryCondition;

import cn.com.basic.face.discern.query.item.AttendanceQueryItem;

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;





/**

@@ -21,25 +27,83 @@
public class DataSynchronService {





    /**

     * 所有数据交互方式

     */

    public  void  dataTransfer(){

                //拼接请求url

                RequestParams params = new RequestParams(AppApi.BASE_URL + AppApi.Query.ATTENDANCE_QUERY);

                //传递参数，key为String，value为object

                params.addBodyParameter(AttendanceQueryCondition.FieldNames.username, "测试");

                params.addBodyParameter(CommonVariables.Page.PAGE_NUM,  "测试");

                params.addBodyParameter(CommonVariables.Page.PAGE_SIZE, CommonVariables.Page.DEFAULT_PAGE_SIZE);

                //统一发送post请求，BaseCommonCallBack作为回调

                x.http().post(params, new BaseCommonCallBack() {

                    public void success() {

                        //list则为返回对象

                        List<AttendanceQueryItem> list = getList(AttendanceQueryItem.class);

                    }

                });

        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();

          }



       }







}