package com.foxinmy.weixin4j.mp.api;
   
   import java.util.List;
   
   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.mp.message.NotifyMessage;
  import com.foxinmy.weixin4j.token.TokenManager;
  import com.foxinmy.weixin4j.tuple.MpArticle;
  import com.foxinmy.weixin4j.tuple.MpNews;
  import com.foxinmy.weixin4j.tuple.NotifyTuple;
  import com.foxinmy.weixin4j.util.StringUtil;
  
  /**
   * 客服消息API
   *
   * @className NotifyApi
   * @author jinyu(foxinmy@gmail.com)
   * @date 2014年9月26日
   * @since JDK 1.6
   */
  public class NotifyApi extends MpApi {
  
  	private final TokenManager tokenManager;
  	private final MassApi massApi;
  
  	public NotifyApi(TokenManager tokenManager) {
  		this.tokenManager = tokenManager;
  		this.massApi = new MassApi(tokenManager);
  	}
  
  	/**
  	 * 发送客服消息(在48小时内不限制发送次数)
  	 *
  	 * @param notify
  	 *            客服消息对象
  	 * @return 处理结果
  	 * @see {@link #sendNotify(NotifyMessage, String)}
  	 * @throws WeixinException
  	 */
  	public ApiResult sendNotify(NotifyMessage notify) throws WeixinException {
  		return sendNotify(notify, null);
  	}
  
  	/**
  	 * 发送客服消息(在48小时内不限制发送次数)
  	 *
  	 * @param notify
  	 *            客服消息对象
  	 * @param kfAccount
  	 *            客服账号 可为空
  	 * @throws WeixinException
  	 * @return 处理结果
  	 * @see <a
  	 *      href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140547&token=&lang=zh_CN">发送客服消息</a>
  	 * @see com.foxinmy.weixin4j.tuple.Text
  	 * @see com.foxinmy.weixin4j.tuple.Image
  	 * @see com.foxinmy.weixin4j.tuple.Voice
  	 * @see com.foxinmy.weixin4j.tuple.Video
  	 * @see com.foxinmy.weixin4j.tuple.Music
  	 * @see com.foxinmy.weixin4j.tuple.News
  	 * @see com.foxinmy.weixin4j.mp.message.NotifyMessage
  	 */
  	public ApiResult sendNotify(NotifyMessage notify, String kfAccount)
  			throws WeixinException {
  		NotifyTuple tuple = notify.getTuple();
  		if (tuple instanceof MpNews) {
  			MpNews _news = (MpNews) tuple;
  			List<MpArticle> _articles = _news.getArticles();
  			if (StringUtil.isBlank(_news.getMediaId())) {
  				if (_articles.isEmpty()) {
  					throw new WeixinException(
  							"notify fail:mediaId or articles is required");
  				}
  				tuple = new MpNews(massApi.uploadArticle(_articles));
  			}
  		}
  		String msgtype = tuple.getMessageType();
  		JSONObject obj = new JSONObject();
  		obj.put("touser", notify.getTouser());
  		obj.put("msgtype", msgtype);
  		obj.put(msgtype, tuple);
  		if (StringUtil.isNotBlank(kfAccount)) {
  			JSONObject kf = new JSONObject();
  			kf.put("kf_account", kfAccount);
  			obj.put("customservice", kf);
  		}
  		String custom_notify_uri = getRequestUri("custom_notify_uri");
  		Token token = tokenManager.getCache();
  		WeixinResponse response = weixinExecutor.post(
  				String.format(custom_notify_uri, token.getAccessToken()),
  				obj.toJSONString());
  
  		return response.getAsResult();
  	}
  }