package project.web.api.monitor;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import kernel.exception.BusinessException;
import kernel.web.BaseAction;
import kernel.web.ResultObject;
import project.monitor.pledgegalaxy.PledgeGalaxyProfit;
import project.monitor.pledgegalaxy.PledgeGalaxyProfitService;
import project.monitor.pledgegalaxy.PledgeGalaxyStatusConstants;
import project.monitor.pledgegalaxy.PledgeLock;
import project.party.PartyService;
import project.party.model.Party;
import project.syspara.SysparaService;

/**
 * 质押2.0
 * 银河数码-AI量化交易投资收益
 *
 */
@RestController
@CrossOrigin
public class PledgeGalaxyProfitController extends BaseAction {
	
	private Logger logger = LoggerFactory.getLogger(PledgeGalaxyProfitController.class);
	
	@Autowired
	PledgeGalaxyProfitService pledgeGalaxyProfitService;
	
	@Autowired
	SysparaService sysparaService;
	
	@Autowired
	PartyService partyService;

	public final String action = "/api/pledgeGalaxyProfit!";
	
	/**
	 * 收益记录列表
	 */
	@RequestMapping(action + "queryList.action")
	public Object list(HttpServletRequest request) {
		
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		List<Map<String, Object>> datas = new ArrayList<Map<String, Object>>();
		
		String page_no = request.getParameter("page_no");
		
		try {
			String partyId = getLoginPartyId();
			int pageNo = Integer.valueOf(page_no);
			datas = pledgeGalaxyProfitService.pagedQuery(pageNo, 40, partyId).getElements();
		} catch (Exception e) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", e.fillInStackTrace());
		}
		resultObject.setData(datas);
		return resultObject;
	}
//	
//	/**
//	 * 领取收益 审核到账
//	 */
//	@RequestMapping(action + "receive.action")
//	public Object receive(HttpServletRequest request) {
//		
//		ResultObject resultObject = new ResultObject();
//		resultObject = readSecurityContextFromSession(resultObject);
//		if (!"0".equals(resultObject.getCode())) {
//			return resultObject;
//		}
//		
//		try {
//			String id = request.getParameter("id");
//			pledgeGalaxyProfitService.updateReceive(id);
//			
//			resultObject.setMsg("领取成功");
//			resultObject.setCode("0");
//		} catch (Exception e) {
//			resultObject.setCode("1");
//			resultObject.setMsg("程序错误");
//			logger.error("error:", e.fillInStackTrace());
//		}
//		return resultObject;
//	}
	
	/**
	 * 领取收益 及时到账
	 */
	@RequestMapping(action + "receiveToWallet.action")
	public Object receiveToWallet(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		resultObject = readSecurityContextFromSession(resultObject);
		if (!"0".equals(resultObject.getCode())) {
			return resultObject;
		}
		String id = request.getParameter("id");

		boolean lock = false;
		PledgeGalaxyProfit profit = pledgeGalaxyProfitService.get(id);
		String partyId = profit.getPartyId();
		try {
			
			if (PledgeGalaxyStatusConstants.PLEDGE_APPLY != profit.getStatus()) {
				throw new BusinessException("Redeemed");
			}
			
			Party party = partyService.cachePartyBy(profit.getPartyId(), false);
			if (!party.getEnabled()) {
				throw new BusinessException(1, "您的账户已被冻结");
			}

			if (!PledgeLock.add(partyId)) {
				throw new BusinessException("Please try again later");
			}
			lock = true;
			
			pledgeGalaxyProfitService.updateReceiveToWallet(profit);
			resultObject.setMsg("领取成功");
			resultObject.setCode("0");
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		} catch (Exception e) {
			resultObject.setCode("1");
			resultObject.setMsg("程序错误");
			logger.error("error:", e.fillInStackTrace());
		} finally {
			if (lock) {
				PledgeLock.remove(partyId);
			}
		}
		return resultObject;
	}
}