package com.yami.trading.admin.controller.loanOrder.internal;

import java.util.*;

import com.alibaba.fastjson2.JSON;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yami.trading.admin.controller.loanOrder.LoanConstants;
import com.yami.trading.admin.controller.loanOrder.LoanRelationOrderService;
import com.yami.trading.bean.loanOrder.LoanRelationOrder;
import com.yami.trading.common.util.DateUtils;
import com.yami.trading.common.util.UUIDGenerator;
import com.yami.trading.service.MoneyLogService;
import com.yami.trading.service.WalletService;
import com.yami.trading.service.data.DataService;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
@Transactional
public class LoanRelationOrderServiceImpl implements LoanRelationOrderService {

	@Autowired
	private DataService dataService;

	@Autowired
	private JdbcTemplate jdbcTemplate;

	@Autowired
	private WalletService walletService;

	@Autowired
	private MoneyLogService moneyLogService;

//	@Autowired
//	private LoanOrderService loanOrderService;
	
	/**
	 * 新增质押借币关联订单
	 */
	public void saveLoanRelationOrder(LoanRelationOrder relationOrder) {
		relationOrder.setUuid(UUIDGenerator.getUUID());
		relationOrder.setPledgeType(LoanConstants.PLEDGE_TYPE);
		relationOrder.setOrder_type(LoanConstants.PLEDGE_ORDER_TYPE_LOAN);
		relationOrder.setLoanCurrency("usd");
		relationOrder.setCreate_time(new Date());
		this.insertLoanRelationOrder(relationOrder);
	}
	
	/**
	 * 质押记录
	 */
	public List<Map<String, Object>> pagedQueryPledge(int pageNo, int pageSize, String loanRelationOrderId) {
		if (pageNo <= 0) pageNo = 1;
		Page page = new Page(pageNo, pageSize, Integer.MAX_VALUE);

//		List<LoanRelationOrder> orders = ApplicationUtil.executeSelect(LoanRelationOrder.class,"WHERE LOAN_RELATION_ORDER_ID=? ORDER BY CREATE_TIME DESC LIMIT ?,?",new Object[] {loanRelationOrderId,page.getFirstElementNumber(),pageSize});

		String str = "select * from t_LOAN_RELATION_ORDER WHERE LOAN_RELATION_ORDER_ID='"+loanRelationOrderId+"' ORDER BY CREATE_TIME DESC LIMIT "+((pageNo-1)*pageSize)+","+pageSize;
		System.out.println("质押记录 :str sql => " + str);
		List<Map<String,Object>> maps = jdbcTemplate.queryForList(str);

		List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
		for (Map<String, Object> map1 : maps) {
			LoanRelationOrder order = JSON.parseObject(JSON.toJSONString(map1), LoanRelationOrder.class);
			Map<String, Object> map = new HashMap<>();
			// 借款
			if (LoanConstants.PLEDGE_ORDER_TYPE_LOAN == order.getOrder_type()) {
				map.put("orderType", order.getOrder_type());
				map.put("loanAmount", order.getLoan_amount());
				map.put("pledgeType", order.getPledge_type());
				map.put("pledgeAmount", order.getPledge_amount());
				map.put("pledgeCurrency", order.getPledgeCurrency());
				map.put("createTime", DateUtils.format(order.getCreate_time(), DateUtils.DF_yyyyMMddHHmmss));
			}
			// 续借、强平、还款
			if (LoanConstants.PLEDGE_ORDER_TYPE_REFURBISH == order.getOrder_type() 
					|| LoanConstants.PLEDGE_ORDER_TYPE_CLOSEOUT == order.getOrder_type()
					|| LoanConstants.PLEDGE_ORDER_TYPE_REPAY == order.getOrder_type()) {
				map.put("orderType", order.getOrder_type());
				map.put("loanAmount", order.getLoan_amount());
				map.put("createTime", DateUtils.format(order.getCreate_time(), DateUtils.DF_yyyyMMddHHmmss));
			}
			// 补增质押
			if (LoanConstants.PLEDGE_ORDER_TYPE_REPLENISH == order.getOrder_type()) {
				map.put("orderType", order.getOrder_type());
				map.put("pledgeType", order.getPledge_type());
				map.put("pledgeAmount", order.getPledge_amount());
				map.put("pledgeCurrency", order.getPledgeCurrency());
				map.put("createTime", DateUtils.format(order.getCreate_time(), DateUtils.DF_yyyyMMddHHmmss));
			}
			if(ObjectUtils.isNotEmpty(map)) {
				list.add(map);
			}		
		}
		return list;
	}
	

	


	

	
	/**
	 * 后台质押记录
	 */
	public List<Map<String,Object>> queryLoanRelation(String loanRelationOrderId) {
//		List<Map<String,Object>> result = new ArrayList<Map<String,Object>>();
//		List<LoanRelationOrder> list = jdbcTemplate.query("SELECT * FROM T_LOAN_RELATION_ORDER WHERE LOAN_RELATION_ORDER_ID=? ORDER BY CREATE_TIME DESC",
//				RecordObjectMapper.newInstance(LoanRelationOrder.class), loanRelationOrderId);

		List<Map<String,Object>> result = jdbcTemplate.queryForList("SELECT * FROM T_LOAN_RELATION_ORDER WHERE LOAN_RELATION_ORDER_ID='"+loanRelationOrderId+"' ORDER BY CREATE_TIME DESC");

//		for (LoanRelationOrder order : list) {
//			Map<String,Object> data = new HashMap<String, Object>();
//			data.put("orderType", order.getOrder_type());
//			data.put("loanAmount", order.getLoanAmount());
//			data.put("pledgeType", order.getPledgeType());
//			data.put("pledgeAmount", order.getPledgeAmount());
//			data.put("pledgeCurrency", order.getPledgeCurrency());
//			data.put("createTime", DateUtils.format(order.getCreateTime(), DateUtils.DF_yyyyMMddHHmmss));
//			result.add(data);
//		}
		return result;
	}
	
	/**
	 * 根据订单关联ID获取订单列表
	 */
	public List<LoanRelationOrder> queryOrders(String loanRelationOrderId, int orderType) {
//		List<LoanRelationOrder> list = jdbcTemplate.query("SELECT * FROM T_LOAN_RELATION_ORDER WHERE LOAN_RELATION_ORDER_ID=? AND ORDER_TYPE=?",
//				RecordObjectMapper.newInstance(LoanRelationOrder.class), loanRelationOrderId, orderType);
		List<LoanRelationOrder> list = new Vector<>();
		List<Map<String,Object>> list2 = jdbcTemplate.queryForList("SELECT * FROM T_LOAN_RELATION_ORDER WHERE LOAN_RELATION_ORDER_ID='"+loanRelationOrderId+"' AND ORDER_TYPE="+orderType);
		for(Map<String,Object> map1 : list2){
			LoanRelationOrder order = JSON.parseObject(JSON.toJSONString(map1), LoanRelationOrder.class);
			list.add(order);
		}

		//
		return list;
	}
	
	public void insertLoanRelationOrder(LoanRelationOrder order) {
		String insertSql = "INSERT INTO T_LOAN_RELATION_ORDER(UUID,LOAN_RELATION_ORDER_ID,PARTY_ID,ORDER_TYPE,LOAN_AMOUNT,LOAN_CURRENCY,"
				+ "PLEDGE_AMOUNT,PLEDGE_CURRENCY,PLEDGE_TYPE,CREATE_TIME) VALUES (?,?,?,?,?,?,?,?,?,?)";
		jdbcTemplate.update(insertSql,order.getUuid(),order.getLoanRelationOrderId(),order.getParty_id(),order.getOrder_type(),
				order.getLoan_amount(),order.getLoan_currency(),order.getPledge_amount(),order.getPledgeCurrency(),
				order.getPledge_type(),order.getCreate_time());
	}

//	public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
//		this.jdbcTemplate = jdbcTemplate;
//	}
//
//	public void setWalletService(WalletService walletService) {
//		this.walletService = walletService;
//	}
//
//	public void setMoneyLogService(MoneyLogService moneyLogService) {
//		this.moneyLogService = moneyLogService;
//	}
//
//	public void setDataService(DataService dataService) {
//		this.dataService = dataService;
//	}
//
//	public void setLoanOrderService(LoanOrderService loanOrderService) {
//		this.loanOrderService = loanOrderService;
//	}
//
}