package com.yeshi.fanli.controller.admin.user.cloud;

import java.io.PrintWriter;
import java.util.List;

import javax.annotation.Resource;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.yeshi.utils.JsonUtil;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.cloud.UserCloud;
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudGoods;
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudGroup;
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudOrder;
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudSendContent;
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudSendRecord;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.dynamic.GoodsEvaluateService;
import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudGoodsService;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudGroupService;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudManageService;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudOrderService;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudSendContentService;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudSendRecordService;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;
import com.yeshi.fanli.service.manger.alipay.UserCloudAlipayManager;
import com.yeshi.fanli.tag.PageEntity;
import com.yeshi.fanli.util.Constant;

import net.sf.json.JSONObject;

@Controller
@RequestMapping("admin/new/api/v1/cloud")
public class  UserCloudAdminController {

	@Resource
	private UserCloudService userCloudService;

	@Resource
	private UserCloudOrderService userCloudOrderService;

	@Resource
	private UserCloudGroupService userCloudGroupService;

	@Resource
	private UserCloudGoodsService userCloudGoodsService;

	@Resource
	private UserInfoService userInfoService;

	@Resource
	private UserCloudSendRecordService userCloudSendRecordService;

	@Resource
	private UserCloudManageService userCloudManageService;

	@Resource
	private UserCloudAlipayManager userCloudAlipayManager;
	
	@Resource
	private GoodsEvaluateService goodsEvaluateService;
	
	@Resource
	private UserCloudSendContentService userCloudSendContentService;
	
	
	
	/**
	 * 订单信息查询
	 * @param callback
	 * @param pageIndex
	 * @param key
	 * @param state
	 * @param out
	 */
	@RequestMapping(value = "queryOrder")
	public void queryOrder(String callback, Integer pageIndex, Integer pageSize, String key, Integer state, PrintWriter out) {
		try {
			if (pageIndex == null)
				pageIndex = 1;
			if (pageSize == null)
			    pageSize = Constant.PAGE_SIZE;
			List<UserCloudOrder> list = userCloudOrderService.query(pageIndex, pageSize, key, state);
			if (list == null || list.size() == 0) {
				out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据")));
				return;
			}
			
			for (UserCloudOrder cloudOrder: list) {
				UserInfo userInfo = userInfoService.getUserByIdWithMybatis(cloudOrder.getUid());
				if (userInfo == null)
					continue;
				
				cloudOrder.setNickName(userInfo.getNickName());
				cloudOrder.setPortrait(userInfo.getPortrait());
			}
			
			GsonBuilder gsonBuilder = new GsonBuilder();
			gsonBuilder.serializeNulls(); // 重点
			Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

			long count = userCloudOrderService.count(key, state);
			int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
			PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
			
			JSONObject data = new JSONObject();
			data.put("pe", pe);
			data.put("list", gson.toJson(list));
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));
		} catch (Exception e) {
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
			e.printStackTrace();
			LogHelper.errorDetailInfo(e);
		}
	}
 
	
	/**
	 * 开通成功记录
	 * @param callback
	 * @param pageIndex
	 * @param key
	 * @param state
	 * @param out
	 */
	@RequestMapping(value = "queryCloud")
	public void queryCloud(String callback, Integer pageIndex, Integer pageSize, String key, Integer state, PrintWriter out) {
		try {
			if (pageIndex == null)
				pageIndex = 1;
			if (pageSize == null)
			    pageSize = Constant.PAGE_SIZE;
			List<UserCloud> list = userCloudService.query(pageIndex, pageSize, key, state);
			if (list == null || list.size() == 0) {
				out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据")));
				return;
			}
			
			for (UserCloud userCloud: list) {
				UserInfo userInfo = userInfoService.getUserByIdWithMybatis(userCloud.getUid());
				if (userInfo == null)
					continue;
				
				userCloud.setNickName(userInfo.getNickName());
				userCloud.setPortrait(userInfo.getPortrait());
			}
			
			GsonBuilder gsonBuilder = new GsonBuilder();
			gsonBuilder.serializeNulls(); // 重点
			Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

			long count = userCloudService.count(key, state);
			int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
			PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
			
			JSONObject data = new JSONObject();
			data.put("pe", pe);
			data.put("list", gson.toJson(list));
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));
		} catch (Exception e) {
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
			e.printStackTrace();
			LogHelper.errorDetailInfo(e);
		}
	}
	
	
	/**
	 * 查询发送记录
	 * @param callback
	 * @param pageIndex
	 * @param pageSize
	 * @param key
	 * @param origin
	 * @param out
	 */
	@RequestMapping(value = "querySendRecord")
	public void querySendRecord(String callback, Integer pageIndex, Integer pageSize, String key, Integer origin, PrintWriter out) {
		try {
			if (pageIndex == null)
				pageIndex = 1;
			if (pageSize == null)
			    pageSize = Constant.PAGE_SIZE;
			List<UserCloudSendRecord> list = userCloudSendRecordService.query(pageIndex, pageSize, key, origin);
			if (list == null || list.size() == 0) {
				out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据")));
				return;
			}
			
			for (UserCloudSendRecord userCloud: list) {
				UserInfo userInfo = userInfoService.getUserByIdWithMybatis(userCloud.getUid());
				if (userInfo == null)
					continue;
				
				userCloud.setNickName(userInfo.getNickName());
				userCloud.setPortrait(userInfo.getPortrait());
			}
			
			GsonBuilder gsonBuilder = new GsonBuilder();
			gsonBuilder.serializeNulls(); // 重点
			Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

			long count = userCloudSendRecordService.count(key, origin);
			int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
			PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
			
			JSONObject data = new JSONObject();
			data.put("pe", pe);
			data.put("list", gson.toJson(list));
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));
		} catch (Exception e) {
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
			e.printStackTrace();
			LogHelper.errorDetailInfo(e);
		}
	}
	
	/**
	 * 查询发送内容
	 * @param callback
	 * @param pid
	 * @param origin
	 * @param out
	 */
	@RequestMapping(value = "getSendContent")
	public void getSendContent(String callback, String pid, Integer origin, PrintWriter out) {
		try {
			List<UserCloudSendContent> list = userCloudSendContentService.getByPid(pid);
			if (list == null || list.size() == 0) {
				out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据")));
				return;
			}
			
			GsonBuilder gsonBuilder = new GsonBuilder();
			gsonBuilder.serializeNulls(); // 重点
			Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

			long count = list.size();
			int totalPage = (int) (count % 20 == 0 ? count / 20 : count / 20 + 1);
			PageEntity pe = new PageEntity(1, 20, count, totalPage);
			
			JSONObject data = new JSONObject();
			data.put("pe", pe);
			data.put("list", gson.toJson(list));
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));
		} catch (Exception e) {
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
			e.printStackTrace();
			LogHelper.errorDetailInfo(e);
		}
	}
	
	/**
	 * 查询用户群信息
	 * @param callback
	 * @param uid
	 * @param out
	 */
	@RequestMapping(value = "getUserGroups")
	public void getUserGroups(String callback, Long uid, PrintWriter out) {
		try {
			List<UserCloudGroup> list = userCloudGroupService.listByUid(uid);
			if (list == null || list.size() == 0) {
				out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据")));
				return;
			}
			
			GsonBuilder gsonBuilder = new GsonBuilder();
			gsonBuilder.serializeNulls(); // 重点
			Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

			long count = list.size();
			int totalPage = (int) (count % 20 == 0 ? count / 20 : count / 20 + 1);
			PageEntity pe = new PageEntity(1, 20, count, totalPage);
			
			JSONObject data = new JSONObject();
			data.put("pe", pe);
			data.put("list", gson.toJson(list));
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));
		} catch (Exception e) {
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
			e.printStackTrace();
			LogHelper.errorDetailInfo(e);
		}
	}
	
	
	/**
	 * 开通成功记录
	 * @param callback
	 * @param pageIndex
	 * @param key
	 * @param state
	 * @param out
	 */
	@RequestMapping(value = "queryGoodsList")
	public void queryGoodsList(String callback, Integer pageIndex, Integer pageSize, String key, PrintWriter out) {
		try {
			if (pageIndex == null)
				pageIndex = 1;
			if (pageSize == null)
			    pageSize = Constant.PAGE_SIZE;
			
			List<UserCloudGoods> list = userCloudGoodsService.query(pageIndex, pageSize, key);
			if (list == null || list.size() == 0) {
				out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("暂无数据")));
				return;
			}
			
			for (UserCloudGoods userCloud: list) {
				UserInfo userInfo = userInfoService.getUserByIdWithMybatis(userCloud.getUid());
				if (userInfo == null)
					continue;
				
				userCloud.setNickName(userInfo.getNickName());
				userCloud.setPortrait(userInfo.getPortrait());
			}
			
			GsonBuilder gsonBuilder = new GsonBuilder();
			gsonBuilder.serializeNulls(); // 重点
			Gson gson = gsonBuilder.setDateFormat("yyyy/MM/dd HH:mm:ss").create();

			long count = userCloudGoodsService.count(key);
			int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
			PageEntity pe = new PageEntity(pageIndex, pageSize, count, totalPage);
			
			JSONObject data = new JSONObject();
			data.put("pe", pe);
			data.put("list", gson.toJson(list));
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(data)));
		} catch (Exception e) {
			out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("操作异常")));
			e.printStackTrace();
			LogHelper.errorDetailInfo(e);
		}
	}
	
	
}