package com.foxinmy.weixin4j.mp.api;
   
   import java.util.ArrayList;
   import java.util.List;
   
   import com.alibaba.fastjson.JSON;
   import com.alibaba.fastjson.JSONObject;
   import com.foxinmy.weixin4j.exception.WeixinException;
   import com.foxinmy.weixin4j.http.weixin.ApiResult;
  import com.foxinmy.weixin4j.http.weixin.WeixinResponse;
  import com.foxinmy.weixin4j.model.Token;
  import com.foxinmy.weixin4j.model.paging.Pagedata;
  import com.foxinmy.weixin4j.mp.model.shakearound.Device;
  import com.foxinmy.weixin4j.mp.model.shakearound.DeviceAuditState;
  import com.foxinmy.weixin4j.mp.model.shakearound.ShakeUserInfo;
  import com.foxinmy.weixin4j.token.TokenManager;
  
  /**
   * 摇一摇周边
   *
   * @author fengyapeng
   * @auther: Feng Yapeng feng27156@gmail.com
   * @since: 2016 /10/12 21:13
   * @since 2016 -10-13 10:49:39
   */
  public class ShakeAroundApi extends MpApi {
  
  
      private final TokenManager tokenManager;
  
  
      /**
       * Instantiates a new Shake around api.
       *
       * @param tokenManager the token manager
       */
      public ShakeAroundApi(TokenManager tokenManager) {
          this.tokenManager = tokenManager;
      }
  
      /**
       * 申请配置设备所需的UUID、Major、Minor。申请成功后返回批次ID，可用返回的批次ID通过“查询设备ID申请状态”接口查询目前申请的审核状态。
       * 若单次申请的设备ID数量小于500个，系统会进行快速审核；若单次申请的设备ID数量大于等 500个 ，会在三个工作日内完成审核。
       * 如果已审核通过，可用返回的批次ID通过“查询设备列表”接口拉取本次申请的设备ID。 通过接口申请的设备ID，需先配置页面，若未配置页面，则摇不出页面信息。
       *
       * @param quantity    the quantity  申请的设备ID的数量，单次新增设备超过500个，需走人工审核流程
       * @param applyReason the apply reason 申请理由，不超过100个汉字或200个英文字母
       * @param comment     the comment 备注，不超过15个汉字或30个英文字母
       * @return the api result
       * @throws WeixinException the weixin exception
       * @author fengyapeng
       * @see <a href= "http://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1459246241&token=&lang=zh_CN"></a>
       * @since 2016 -10-12 21:21:47
       */
      public DeviceAuditState deviceApply(Integer quantity, String applyReason, String comment) throws WeixinException {
          String device_apply_uri = getRequestUri("shake_around_device_apply");
          Token token = this.tokenManager.getCache();
          JSONObject jsonObject = new JSONObject();
          jsonObject.put("quantity", quantity);
          jsonObject.put("apply_reason", applyReason);
          jsonObject.put("comment", comment);
          WeixinResponse response = weixinExecutor.post(String.format(device_apply_uri, token.getAccessToken()), jsonObject.toJSONString());
          DeviceAuditState result = JSON.parseObject(response.getAsJson().getString("data"), DeviceAuditState.class);
          result.setApplyTime(System.currentTimeMillis() / 1000);
          result.setAuditTime(0);
          return result;
      }
  
  
      /**
       * 查询设备ID申请的审核状态。若单次申请的设备ID数量小于等于500个，
       * 系统会进行快速审核；若单次申请的设备ID数量大于500个，则在三个工作日内完成审核。
       *
       * @param applyId the apply id 批次ID，申请设备ID时所返回的批次ID
       * @return the device audit state
       * @throws WeixinException the weixin exception
       * @author fengyapeng
       * @see <a href= "http://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1459246243&token=&lang=zh_CN"></a>
       * @since 2016 -10-12 21:57:04
       */
      public DeviceAuditState deviceQueryApplyStatus(int applyId) throws WeixinException {
          String device_apply_status_uri = getRequestUri("shake_around_device_apply_status_uri");
          Token token = this.tokenManager.getCache();
          JSONObject jsonObject = new JSONObject();
          jsonObject.put("apply_id", applyId);
          WeixinResponse response = weixinExecutor
                  .post(String.format(device_apply_status_uri, token.getAccessToken()), jsonObject.toJSONString());
          DeviceAuditState result = JSON.parseObject(response.getAsJson().getString("data"), DeviceAuditState.class);
          result.setApplyId(applyId);
          return result;
      }
  
      /**
       * 查询已有的设备ID、UUID、Major、Minor、激活状态、备注信息、关联门店、关联页面等信息。
       * 查询指定设备的信息
       *
       * @param device the device
       * @return the list
       * @throws WeixinException the weixin exception
      * @author fengyapeng
      * @since 2016 -10-13 10:11:34
      */
     public List<Device> deviceSearchDevices(List<Device> device) throws WeixinException {
         String device_search_uri = getRequestUri("shake_around_device_search_uri");
         JSONObject jsonObject = new JSONObject();
         jsonObject.put("type", 1);
         jsonObject.put("device_identifiers", device);
         WeixinResponse response = weixinExecutor
                 .post(String.format(device_search_uri, tokenManager.getAccessToken()), jsonObject.toJSONString());
         JSONObject json = response.getAsJson();
         String deviceStr = json.getJSONObject("data").getString("devices");
         return JSON.parseArray(deviceStr, Device.class);
     }
 
     /**
      * 查询已有的设备ID、UUID、Major、Minor、激活状态、备注信息、关联门店、关联页面等信息。
      * 按照分页信息查询设备
      *
      * @return the list
      * @throws WeixinException the weixin exception
      * @author fengyapeng
      * @since 2016 -10-13 10:11:34
      */
     public Pagedata<Device> deviceSearchDevices(int pageSize) throws WeixinException {
         return this.deviceSearchDevices(0, pageSize);
     }
 
     /**
      * 查询已有的设备ID、UUID、Major、Minor、激活状态、备注信息、关联门店、关联页面等信息
      * 根据上次查询的最后的设备编号按照分页查询
      *
      * @param lastDeviceId the last device id
      * @param pageSize     the page size
      * @return list pagedata
      * @throws WeixinException the weixin exception
      * @author fengyapeng
      * @since 2016 -10-13 10:52:20
      */
     public Pagedata<Device> deviceSearchDevices(int lastDeviceId, int pageSize) throws WeixinException {
         String device_search_uri = getRequestUri("shake_around_device_search_uri");
         JSONObject jsonObject = new JSONObject();
         jsonObject.put("type", 2);
         jsonObject.put("last_seen", lastDeviceId);
         if (pageSize > 50) {
             pageSize = 50;
         }
         jsonObject.put("count", pageSize);
         WeixinResponse response = weixinExecutor
                 .post(String.format(device_search_uri, tokenManager.getAccessToken()), jsonObject.toJSONString());
         JSONObject json = response.getAsJson();
         JSONObject data = json.getJSONObject("data");
         String deviceStr = data.getString("devices");
         List<Device> devices = JSON.parseArray(deviceStr, Device.class);
         Pagedata<Device> pagedata = new Pagedata<Device>(null, data.getIntValue("total_count"), devices);
         return pagedata;
     }
 
     /**
      * 查询已有的设备ID、UUID、Major、Minor、激活状态、备注信息、关联门店、关联页面等信息
      * 查询 设备Id 下的所有的设备
      *
      * @param applyId the apply id
      * @return the list
      * @author fengyapeng
      * @since 2016 -10-13 10:49:39
      */
     public List<Device> deviceSearchDevicesByApplyId(Integer applyId) throws WeixinException {
         List<Device> devices = new ArrayList<Device>();
         Pagedata<Device> pagedata = this.deviceSearchDevicesByApplyId(applyId, 50);
         devices = pagedata.getContent();
         for (int page = 50; page < pagedata.getTotalElements(); page = page + 50) {
             List<Device> _devices = pagedata.getContent();
             pagedata = this.deviceSearchDevicesByApplyId(applyId, _devices.get(_devices.size() - 1).getDeviceId(), 50);
             _devices = pagedata.getContent();
             devices.addAll(_devices);
         }
         return devices;
     }
 
 
     /**
      * 查询已有的设备ID、UUID、Major、Minor、激活状态、备注信息、关联门店、关联页面等信息
      * 分页获取设备id下的前多少设备
      *
      * @param applyId the apply id
      * @return the list
      * @author fengyapeng
      * @since 2016 -10-13 10:49:39
      */
     public Pagedata<Device> deviceSearchDevicesByApplyId(Integer applyId, int pageSize) throws WeixinException {
         return this.deviceSearchDevicesByApplyId(applyId, 0, pageSize);
     }
 
     /**
      * 查询已有的设备ID、UUID、Major、Minor、激活状态、备注信息、关联门店、关联页面等信息
      * 分页获取设备id下的根据上次查询的最后的设备编号前多少设备
      *
      * @param applyId the apply id
      * @return the list
      * @author fengyapeng
      * @since 2016 -10-13 10:49:39
      */
     public Pagedata<Device> deviceSearchDevicesByApplyId(Integer applyId, int lastDeviceId, int pageSize) throws WeixinException {
         String device_search_uri = getRequestUri("shake_around_device_search_uri");
         JSONObject jsonObject = new JSONObject();
         jsonObject.put("type", 3);
         jsonObject.put("apply_id", applyId);
         jsonObject.put("last_seen", lastDeviceId);
         if (pageSize > 50) {
             pageSize = 50;
         }
         jsonObject.put("count", pageSize);
         WeixinResponse response = weixinExecutor
                 .post(String.format(device_search_uri, tokenManager.getAccessToken()), jsonObject.toJSONString());
         JSONObject json = response.getAsJson();
         JSONObject data = json.getJSONObject("data");
         String deviceStr = data.getString("devices");
         List<Device> devices = JSON.parseArray(deviceStr, Device.class);
         Pagedata<Device> pagedata = new Pagedata<Device>(null, data.getIntValue("total_count"), devices);
         return pagedata;
     }
 
 
     /**
      * 编辑设备的备注信息。可用设备ID或完整的UUID、Major、Minor指定设备，二者选其一。
      *
      * @param device  the device
      * @param comment the comment
      * @return api result
      * @author fengyapeng
      * @since 2016 -10-13 14:33:06
      */
     public ApiResult deviceUpdateComment(Device device, String comment) throws WeixinException {
         String device_update_uri = getRequestUri("shake_around_device_update_uri");
         JSONObject jsonObject = new JSONObject();
         JSONObject deviceJsonObj = new JSONObject();
         jsonObject.put("device_identifier", deviceJsonObj);
         jsonObject.put("comment", comment);
         if (device.getDeviceId() == null) {
             deviceJsonObj.put("uuid", device.getUuid());
             deviceJsonObj.put("major", device.getMajor());
             deviceJsonObj.put("minor", device.getMinor());
         } else {
             deviceJsonObj.put("device_id", device.getDeviceId());
         }
         WeixinResponse weixinResponse = weixinExecutor
                 .post(String.format(device_update_uri, tokenManager.getAccessToken()), jsonObject.toJSONString());
         return weixinResponse.getAsResult();
 
     }
 
     /**
      * 获取设备信息，包括UUID、major、minor，以及距离、openID等信息.
      *
      *
      * <a herf="
      * http://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1443447963&token=&lang=zh_CN"></a>
      *
      * @param ticket     the ticket 摇周边业务的ticket，可在摇到的URL中得到，ticket生效时间为30分钟，每一次摇都会重新生成新的ticket
      * @return shake user info
      * @author fengyapeng
      * @since 2016 -10-21 19:34:38
      */
     public ShakeUserInfo getShakeUserInfo(String ticket) throws WeixinException {
         String user_get_shake_info_url = getRequestUri("shake_around_user_get_shake_info");
         JSONObject jsonObject = new JSONObject();
         jsonObject.put("ticket", ticket);
         WeixinResponse weixinResponse = weixinExecutor
                 .post(String.format(user_get_shake_info_url, tokenManager.getAccessToken()), jsonObject.toJSONString());
         return weixinResponse.getAsJson().getObject("data", ShakeUserInfo.class);
 
     }
 }