package com.yeshi.fanli.controller.admin;

import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.UUID;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.multipart.MultipartFile;
import org.springframework.web.multipart.MultipartHttpServletRequest;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.tencentcloud.COSManager;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.dto.dynamic.ActivityUserRule;
import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser;
import com.yeshi.fanli.entity.bus.activity.ActivityUser;
import com.yeshi.fanli.service.inter.activity.ActivityUserService;
import com.yeshi.fanli.tag.PageEntity;
import com.yeshi.fanli.util.FilePathEnum;
import com.yeshi.fanli.util.StringUtil;

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

@Controller
@RequestMapping("admin/new/api/v1/activityuser")
public class ActivityUserAdminController {

	@Resource
	private ActivityUserService activityUserService;

	private String uploadPic(MultipartFile file) {
		// 文件解析
		try {
			InputStream inputStream = file.getInputStream();
			String contentType = file.getContentType();
			String type = contentType.substring(contentType.indexOf("/") + 1);
			// 文件路径
			String filePath = FilePathEnum.activityUserPortrait.getPath() + UUID.randomUUID().toString().replace("-", "") + "." + type;
			// 执行上传
			String fileLink = COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();
			return fileLink;
		} catch (IOException e) {
			e.printStackTrace();
		}
		return null;
	}

	/**
	 * 获取活动用户列表
	 * 
	 * @param callback
	 * @param out
	 */
	@RequestMapping(value = "listActivityUserRules")
	public void listActivityUserRules(String callback, PrintWriter out) {
		ActivityUserRule[] rules = ActivityRuleUser.RULES;
		JSONArray array = new JSONArray();
		for (ActivityUserRule rule : rules) {
			array.add(rule);
		}
		out.print(callback + "(" + JsonUtil.loadTrueResult(array) + ")");
	}

	/**
	 * 获取用户列表
	 * 
	 * @param callback
	 * @param rule
	 * @param out
	 */
	@RequestMapping(value = "listActivityUser")
	public void listActivityUser(String callback, Integer rule, int pageIndex, int pageSize, PrintWriter out) {
		List<ActivityRuleUser> list = activityUserService.listByRuleCode(rule, 1, 100);
		long count = activityUserService.countByRuleCode(rule);
		JSONObject data = new JSONObject();
		JSONArray dataArray = new JSONArray();
		Map<Integer, ActivityUserRule> ruleMap = new HashMap<>();

		Gson gson = new GsonBuilder().setDateFormat("yyyy-MM-dd HH:mm").create();

		for (ActivityUserRule r : ActivityRuleUser.RULES)
			ruleMap.put(r.getRuleCode(), r);

		for (ActivityRuleUser r : list) {
			if (r.getRuleCode() != null)
				r.setRule(ruleMap.get(r.getRuleCode()));
			dataArray.add(gson.toJson(r));
		}
		data.put("data", dataArray);
		data.put("pe", new PageEntity(pageIndex, pageSize, count,
				(int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1)));
		if (StringUtil.isNullOrEmpty(callback)) {
			out.print(JsonUtil.loadTrueResult(data));
		} else {
			out.print(callback + "(" + JsonUtil.loadTrueResult(data) + ")");
		}
	}

	@RequestMapping(value = "deleteActivityUser")
	public void deleteActivityUsers(String callback, String ids, PrintWriter out) {
		JSONArray array = JSONArray.fromObject(ids);
		for (int i = 0; i < array.size(); i++) {
			// 删除
			if (array.optLong(i) != 1L) {
				activityUserService.deleteByRuleUserId(array.optLong(i));
			}
		}
		JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("删除成功"));
	}

	@RequestMapping(value = "saveActivityUser")
	public void save(String callback, ActivityRuleUser user, HttpServletRequest request, PrintWriter out) {

		if (user == null || user.getRuleCode() == null || user.getActivityUser() == null) {
			out.print(callback + "(" + JsonUtil.loadFalseResult("数据不完整") + ")");
			return;
		}

		String picUrl = null;

		if (request instanceof MultipartHttpServletRequest) {
			MultipartHttpServletRequest fileRequest = (MultipartHttpServletRequest) request;
			MultipartFile multipartFile = fileRequest.getFile("file");
			if (multipartFile != null)
				picUrl = uploadPic(multipartFile);
		}

		if (user.getId() != null)// 更改
		{
			ActivityRuleUser old = activityUserService.selectRuleUserByPrimaryKey(user.getId());
			if (old != null) {
				// 更改里面的用户与昵称
				if (old.getActivityUser() != null) {
					ActivityUser update = new ActivityUser(old.getActivityUser().getId());
					update.setNickName(user.getActivityUser().getNickName());
					update.setPortrait(picUrl);
					activityUserService.updateActivityUser(update);
				}
			}
			user.setActivityUser(null);
			activityUserService.updateActivityRuleUser(user);
			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("保存成功"));
		} else {// 新增
			user.getActivityUser().setPortrait(picUrl);
			activityUserService.addActivityRuleUser(user);
			JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("保存成功"));
		}

	}

}