package com.yeshi.fanli.controller.client.v2;

import java.io.PrintWriter;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.List;

import javax.annotation.Resource;

import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.yeshi.utils.JsonUtil;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.dto.ConfigParamsDTO;
import com.yeshi.fanli.entity.accept.AcceptData;
import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
import com.yeshi.fanli.entity.bus.clazz.GoodsSubClass;
import com.yeshi.fanli.entity.bus.clazz.TaoBaoClass;
import com.yeshi.fanli.entity.bus.lable.QualityFactory;
import com.yeshi.fanli.entity.taobao.SearchFilter;
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
import com.yeshi.fanli.entity.taobao.TaoBaoSearchResult;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.clazz.GoodsSubClassLabelService;
import com.yeshi.fanli.service.inter.goods.GoodsClassService;
import com.yeshi.fanli.service.inter.goods.GoodsSubClassService;
import com.yeshi.fanli.service.inter.goods.TaoBaoClassService;
import com.yeshi.fanli.service.inter.lable.LabelClassService;
import com.yeshi.fanli.service.inter.lable.QualityGoodsService;
import com.yeshi.fanli.service.inter.lable.TaoKeGoodsService;
import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;
import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import com.yeshi.fanli.vo.goods.GoodsDetailVO;
import com.yeshi.fanli.vo.goods.GoodsSubClassLabelVO;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

@Controller
@RequestMapping("api/v2/class")
public class GoodsClassControllerV2 {

	@Resource
	private GoodsClassService goodsClassService;

	@Resource
	private GoodsSubClassLabelService goodsSubClassLabelService;

	@Resource
	private GoodsSubClassService goodsSubClassService;

	@Resource(name = "taskExecutor")
	private TaskExecutor executor;

	@Resource
	private QualityGoodsService qualityGoodsService;

	@Resource
	private TaoKeGoodsService taoKeGoodsService;

	@Resource
	private TaoBaoClassService taoBaoClassService;

	@Resource
	private HongBaoManageService hongBaoManageService;

	@Resource
	private LabelClassService labelClassService;

	@Resource
	private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;

	/**
	 * 一级分类
	 * 
	 * @param acceptData
	 * @param out
	 */
	@RequestMapping(value = "listClass", method = RequestMethod.POST)
	public void listClass(AcceptData acceptData, PrintWriter out) {
		List<GoodsClass> list = goodsClassService.getEffectiveClassCache();
		if (list == null) {
			list = new ArrayList<GoodsClass>();
		}

		JSONObject data = new JSONObject();
		data.put("list", JsonUtil.getApiCommonGson().toJson(list));
		out.print(JsonUtil.loadTrueResult(data));
	}

	/**
	 * 二级分类、标签
	 * 
	 * @param acceptData
	 * @param gcid
	 * @param out
	 */
	@RequestMapping(value = "listSubMap", method = RequestMethod.POST)
	public void listSubMap(AcceptData acceptData, Long cid, PrintWriter out) {
		if (cid == null) {
			out.print(JsonUtil.loadFalseResult("参数不能为空"));
			return;
		}

		List<GoodsSubClassLabelVO> list = goodsSubClassLabelService.listSubMapCache(cid);
		if (list == null) {
			list = new ArrayList<GoodsSubClassLabelVO>();
		}

		JSONObject data = new JSONObject();
		data.put("list", JsonUtil.getApiCommonGson().toJson(list));
		out.print(JsonUtil.loadTrueResult(data));
	}

	/**
	 * 分类下的精选商品
	 */
	@RequestMapping("getClassGoods")
	public void getClassGoods(AcceptData acceptData, long gcid, int page, PrintWriter out) {
		GoodsClass goodsClass = goodsClassService.getGoodsClassCache(gcid);
		if (goodsClass == null) {
			out.print(JsonUtil.loadFalseResult("不存在该分类"));
			return;
		}

		if (page < 1)
			page = 1;

		int pageSize = Constant.PAGE_SIZE;

		List<QualityFactory> listQuery = qualityGoodsService.listQueryByClassId((page - 1) * pageSize, pageSize, gcid);
		// 总条数
		long counttotal = 5000;

		List<TaoBaoGoodsBrief> updateGoodsList = new ArrayList<>();

		// 精选库数据小于10时，网络进行查询
		if (listQuery == null || listQuery.size() < 10) {
			long count = qualityGoodsService.countQueryClassId(gcid);
			int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
			page = page - totalPage;
			if (page < 1)
				page = 1;

			// 淘宝类目id
			String taoBaoCatIds = taoBaoClassService.getTaoBaoCatIds(gcid);

			SearchFilter filter = null;

			String searchParam = goodsClass.getSearchParam();
			if (!StringUtil.isNullOrEmpty(searchParam)) {
				Gson gs = new Gson();
				filter = gs.fromJson(searchParam, SearchFilter.class);
			} else {
				filter = new SearchFilter();
			}

			filter.setMaterialId("6707");
			filter.setPage(page);
			filter.setPageSize(pageSize);
			filter.setCateIds(taoBaoCatIds);

			JSONObject result = taoKeGoodsService.searchWuLiaoV2(filter);
			out.print(JsonUtil.loadTrueResult(result));
			return;
		}

		Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
				.excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create();

		BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
		BigDecimal shareRate = hongBaoManageService.getShareRate();
		ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE);
		
		// 精选库数据
		JSONArray array = new JSONArray();
		for (QualityFactory selectionGoods : listQuery) {
			TaoBaoGoodsBrief taoBaoGoodsBrief = selectionGoods.getTaoBaoGoodsBrief();
			if (taoBaoGoodsBrief == null) {
				continue;
			}
			updateGoodsList.add(taoBaoGoodsBrief);
			GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertTaoBao(taoBaoGoodsBrief, paramsDTO);
			array.add(gson.toJson(goodsDetailVO));
		}

		JSONObject data = new JSONObject();
		data.put("nav", null);
		data.put("count", counttotal);
		data.put("result", array);
		out.print(JsonUtil.loadTrueResult(data));
		try {
			taoBaoGoodsUpdateService.addUpdateQueueAsync(updateGoodsList);
		} catch (Exception e) {
		}
	}

	/**
	 * 获取二级分类商品
	 * 
	 * @param acceptData
	 * @param page
	 * @param scid
	 * @param filter
	 * @param order
	 *            来源：【推荐：0 | 综合：4 、综合只看有券 1 、综合只看天猫 1 | 价格：低到高3 高到低2 | 销量：1】
	 *            排序值：【销量由高到低: 1 ； 销量由低到高 5； 价格从高到低: 2 ； 价格从低到高:3 ； 推广量高到低:4 ；
	 *            其他默认： 销量由高到低】
	 * 
	 * @param startprice
	 *            起始价格
	 * @param endprice
	 *            结束价格
	 * @param fastFilter
	 *            fastFilter 有券 [{"type":"quantype"}] 天猫商品 [{"type":"shoptype"}]
	 * @param totalSales
	 *            销量以上
	 * @param out
	 */
	@RequestMapping(value = "getSubGoods", method = RequestMethod.POST)
	public void getSecondClassGoods(AcceptData acceptData, int page, long scid, String filter, String order,
			String startprice, String endprice, String fastFilter, Integer totalSales, PrintWriter out) {

		try {
			GoodsSubClass goodsSubClass = goodsSubClassService.getSubClassByPrimaryKeyCache(scid);
			if (goodsSubClass == null) {
				out.print(JsonUtil.loadFalseResult("不存在该分类"));
				return;
			}

			// 统计点击量
			if (page == 1) {
				goodsSubClassService.countClick(acceptData, goodsSubClass);
			}

			SearchFilter sf = new SearchFilter();
			String catesId = "";
			// 查询是否有淘宝分类ID
			List<TaoBaoClass> tbClassList = taoBaoClassService.listBySystemSubCid(0, 10, goodsSubClass.getId());
			if (tbClassList != null && tbClassList.size() > 0)
				for (TaoBaoClass tbc : tbClassList) {
					catesId += tbc.getCategoryId() + ",";
				}
			if (catesId.endsWith(","))
				catesId = catesId.substring(0, catesId.length() - 1);
			sf.setCateIds(catesId);

			// 按分类名称搜索
			if (!StringUtil.isNullOrEmpty(catesId)) {
				String searchParam = goodsSubClass.getSearchJson();
				Gson gs = new Gson();
				SearchFilter searchfilter = gs.fromJson(searchParam, SearchFilter.class);
				searchfilter.setCateIds(catesId);
				searchfilter.setPage(page);
				searchfilter.setPageSize(20);
				if (Integer.parseInt(order) == 0)
					searchfilter.setMaterialId("6707");
				taoKeGoodsService.setSearchFilter(searchfilter, filter, order, startprice, endprice, fastFilter,
						totalSales);
				TaoBaoSearchResult searchResult = TaoKeApiUtil.searchWuLiao(searchfilter);
				long count = searchResult.getPageEntity().getTotalCount();

				List<TaoBaoGoodsBrief> resultGoodsList = searchResult.getTaoBaoGoodsBriefs();
				// 查询是否超过了最大的商品数
				if ((resultGoodsList == null || resultGoodsList.size() < 20)
						&& !StringUtil.isNullOrEmpty(goodsSubClass.getKey())) {
					if (resultGoodsList == null)
						resultGoodsList = new ArrayList<>();

					// 需要根据关键字查询
					searchfilter.setCateIds(null);
					searchfilter.setPage((int) (count % 20 == 0 ? count / 20 - 1 : count / 20));
					searchfilter.setPageSize(20);
					searchfilter.setKey(goodsSubClass.getKey());
					TaoBaoSearchResult searchResult2 = TaoKeApiUtil.searchWuLiao(searchfilter);
					if (searchResult2 != null) {
						List<TaoBaoGoodsBrief> resultListTemp = searchResult2.getTaoBaoGoodsBriefs();
						if (resultListTemp != null)
							resultGoodsList.addAll(resultListTemp);
					}
				}

				Gson gson2 = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
						.excludeFieldsWithoutExposeAnnotation().create();

				JSONArray array = new JSONArray();
				if (resultGoodsList != null) {
					BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();
					BigDecimal shareRate = hongBaoManageService.getShareRate();
					ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE);
					for (TaoBaoGoodsBrief goods : resultGoodsList) {
						GoodsDetailVO goodsDetailVO = GoodsDetailVOFactory.convertTaoBao(goods, paramsDTO);
						array.add(gson2.toJson(goodsDetailVO));
					}
				}
				JSONObject result = new JSONObject();
				result.put("result", array);
				result.put("count", result.optLong("count") + count);
				out.print(JsonUtil.loadTrueResult(result));
				return;
			} else {
				String searchParam = goodsSubClass.getSearchJson();
				Gson gs = new Gson();
				SearchFilter searchfilter = gs.fromJson(searchParam, SearchFilter.class);
				searchfilter.setCateIds(catesId);
				searchfilter.setPage(page);
				searchfilter.setPageSize(20);
				if (Integer.parseInt(order) == 0)
					searchfilter.setMaterialId("6707");
				searchfilter.setKey(goodsSubClass.getKey());
				taoKeGoodsService.setSearchFilter(searchfilter, filter, order, startprice, endprice, fastFilter,
						totalSales);

				JSONObject result = taoKeGoodsService.searchWuLiaoV2(searchfilter);
				out.print(JsonUtil.loadTrueResult(result));
				return;
			}
		} catch (Exception e) {
			out.print(JsonUtil.loadFalseResult("数据异常"));
			LogHelper.errorDetailInfo(e);
		}
	}

}