sujinwen

2017-07-24 0a681611c0b0278e03e6da031c37a28d2973b7b2

git-svn-id: http://192.168.1.226/svn/proxy@856 454eff88-639b-444f-9e54-f578c98de674

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

@@ -3,13 +3,16 @@
import org.xutils.http.RequestParams;

import org.xutils.x;



import java.util.List;

import java.text.SimpleDateFormat;

import java.util.Date;



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 +24,70 @@
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 data                  同步数据

     * @param deviceCompanyId       设备所在机构id

     * @param tableName             表名

     */

    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 void  twoWaySynchron(Date synDate,String data,String deviceCompanyId,String tableName){

          try{

              RequestParams params = new RequestParams(AppApi.BASE_URL + AppApi.DOWN_SYNCHRON);

              SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

              params.addBodyParameter("tableName", tableName);

              params.addBodyParameter("synDate",sdf.format(synDate));

              if("company".equals(tableName)){

                  params.addBodyParameter("data", CompanyDao.getInstance().getCompanyList(deviceCompanyId).toString());

              }

              if("device".equals(tableName)){

                  params.addBodyParameter("data", DeviceDao.getInstance().getDeviceList(deviceCompanyId).toString());

              }

              if("dictionary".equals(tableName)){

                  params.addBodyParameter("data", DictionaryDao.getInstance().getDictionayList(deviceCompanyId).toString());

              }

              params.addBodyParameter("deviceCompanyId",deviceCompanyId);

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

                  public void success() {

                      SqliteSqlUtil.insert(getExtraList(SqliteSqlBean.class));

                  }

              });

          }catch(Exception e){

              e.printStackTrace();

          }



            }



       }



}