package project.web.api;

import javax.servlet.http.HttpServletRequest;

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.web.ApplicationUtil;
import com.mysql.cj.util.StringUtils;
import project.party.PartyService;
import project.party.model.Party;
import kernel.exception.BusinessException;
import kernel.web.BaseAction;
import kernel.web.ResultObject;
import project.user.idcode.IdentifyingCodeService;
import project.web.api.JsonUtils;
import project.web.api.SafeUtils;

import java.io.BufferedReader;
import java.io.IOException;
import java.util.*;
import project.web.api.HttpsTransport;
import org.springframework.jdbc.core.JdbcTemplate;
import project.wallet.WalletService;
import project.wallet.WalletLog;
import project.wallet.WalletLogService;
import project.Constants;
import project.log.MoneyLog;
import project.log.MoneyLogService;
import kernel.util.Arith;
import project.wallet.Wallet;
import project.wallet.WalletExtend;
import project.blockchain.RechargeBlockchain;
import project.blockchain.RechargeBlockchainService;
import com.alibaba.fastjson.JSONObject;
import java.util.HashMap;
import project.log.MoneyLogService;

/**
 * 邮箱或手机绑定
 * 发送验证码
 *
 */
@RestController
@CrossOrigin
public class IdentifyingCodeController extends BaseAction {

	@Autowired
	private IdentifyingCodeService identifyingCodeService;
	@Autowired
	private PartyService partyService;
	@Autowired
	private WalletService walletService;
	@Autowired
	private WalletLogService walletLogService;
	@Autowired
	private RechargeBlockchainService rechargeBlockchainService;
	@Autowired
	private MoneyLogService moneyLogService;

	@RequestMapping("/api/idcode!execute.action")
	public Object execute(HttpServletRequest request) {
		ResultObject resultObject = new ResultObject();
		try {
			// 邮件或手机号
			String target = request.getParameter("target");
			if (StringUtils.isNullOrEmpty(target)) {
				throw new BusinessException("不能为空");
			}
			identifyingCodeService.send(target, this.getIp());
		} catch (BusinessException e) {
			resultObject.setCode("1");
			resultObject.setMsg(e.getMessage());
		}
		return resultObject;
	}

	@RequestMapping("/api/rechargeCallback!execute.action")
	public void rechargeCallback(HttpServletRequest request) {
		try {
			System.out.println("支付回调start...");
//			Map<String, String> paramsMap = SafeUtils.convertRequestParamsToMap(request);
			//将异步通知中收到的待验证所有参数都存放到map中
			StringBuilder sb = new StringBuilder();
			BufferedReader reader = request.getReader();
			String line;
			while ((line = reader.readLine()) != null) {
				sb.append(line);
			}
			String json = sb.toString();
			JSONObject jsonObject = JSONObject.parseObject(json);
			Map<String, String> paramsMap = new HashMap<String,String>();
			if(jsonObject.containsKey("recharge_hash")){
				paramsMap.put("recharge_hash",jsonObject.getString("recharge_hash"));
			}
			if(jsonObject.containsKey("user_id")){
				paramsMap.put("user_id",jsonObject.getString("user_id"));
			}
			if(jsonObject.containsKey("from_address")){
				paramsMap.put("from_address",jsonObject.getString("from_address"));
			}
			if(jsonObject.containsKey("address")){
				paramsMap.put("address",jsonObject.getString("address"));
			}
			if(jsonObject.containsKey("num")){
				paramsMap.put("num",jsonObject.getString("num"));
			}

			if(jsonObject.containsKey("confirmations")){
				paramsMap.put("confirmations",jsonObject.getString("confirmations"));
			}
			if(jsonObject.containsKey("currency")){
				paramsMap.put("currency",jsonObject.getString("currency"));
			}
			System.out.println("响应字符串为paramsMap："+paramsMap);

			if(null != paramsMap && null != paramsMap.get("recharge_hash")){
				JdbcTemplate jdbcTemplate=ApplicationUtil.getBean(JdbcTemplate.class);
				Integer count = jdbcTemplate.queryForObject("SELECT count(ID) FROM PAT_HASH WHERE HASH=? AND status = 1", Integer.class,paramsMap.get("recharge_hash"));
				System.out.println("支付回调hashcount.."+count);
				if(count == 0){
					//币种
					String currency = (String) paramsMap.get("currency");

					System.out.println("支付回调currency..."+currency);
					//数量
					String num = paramsMap.get("num").toString();
					System.out.println("支付回调num..."+num);
					//充值地址
					String address = (String) paramsMap.get("address");
					//来源地址
					String from = (String) paramsMap.get("from_address");

					Double doubleNum = Double.parseDouble(num);
					System.out.println("支付回调doubleNum..."+doubleNum);
					String usercode = paramsMap.get("user_id").toString();
					System.out.println("支付回调usercode..."+usercode);
					String partyId = jdbcTemplate.queryForObject("SELECT UUID FROM PAT_PARTY WHERE USERCODE=?", String.class,usercode);
					System.out.println("支付回调partyId..."+partyId);
					Party party = this.partyService.cachePartyBy(partyId, false);

					double amount_before = 0;
					double amount_after = 0;
					String wallettype = "";
					String symbol = "";
					if("TRC20-USDT".equals(currency) || "ERC20-USDT".equals(currency)){
						if("TRC20-USDT".equals(currency)){
							symbol = "TRC20";
						}else{
							symbol = "ERC20";
						}
						// 交易所修改usdt
						Wallet wallet = this.walletService.saveWalletByPartyId(partyId);
						amount_before = wallet.getMoney();
						System.out.println("交易所修改usdt  amount_before"+amount_before);
						// 更新金额
						this.walletService.update(wallet.getPartyId().toString(), doubleNum);
						amount_after = Arith.add(wallet.getMoney(), doubleNum);
						System.out.println("交易所修改usdt  amount_after"+amount_after);
						System.out.println("symbol  symbol"+symbol);
						wallettype = "USDT";
					}else{
						currency = currency.toLowerCase();
						WalletExtend walletExtend = this.walletService.saveExtendByPara(partyId, currency);
						amount_before = walletExtend.getAmount();
						this.walletService.updateExtend(walletExtend.getPartyId().toString(), currency, doubleNum);
						amount_after = Arith.add(walletExtend.getAmount(), doubleNum);
						wallettype = currency;
						symbol = currency;
					}
					String uuid = UUID.randomUUID().toString();
					String uuidReplace = uuid.replace("-", "");
					System.out.println("存储充值申请订单记录uuid" + uuidReplace);
					String insertSql = "INSERT INTO T_RECHARGE_BLOCKCHAIN_ORDER(UUID,ORDER_NO,PARTY_ID,SUCCEEDED,CREATED,COIN,DESCRIPTION,BLOCKCHAIN_NAME,IMG,CHANNEL_AMOUNT,ADDRESS,CHANNEL_ADDRESS,REVIEWTIME,TX) VALUES(?,?,?,1,?,?,'',?,'',?,?,?,?,?)";
					jdbcTemplate.update(insertSql
							,uuidReplace,"R"+System.currentTimeMillis(),
							partyId,new Date(),wallettype,symbol,
							doubleNum,from,address,new Date(),paramsMap.get("recharge_hash"));

					// 			recharge.setChannel_address(channel_address);
					// 			recharge.setTx(StringUtils.isEmptyString(tx) ? "" : tx);
					// 账变日志
					MoneyLog moneyLog = new MoneyLog();
					moneyLog.setCategory(Constants.MONEYLOG_CATEGORY_RECHARGE);
					moneyLog.setAmount_before(amount_before);
					moneyLog.setAmount(doubleNum);
					moneyLog.setAmount_after(amount_after);
					moneyLog.setPartyId(partyId);
					moneyLog.setLog("充值到账");
					moneyLog.setWallettype(Constants.WALLET);
					moneyLog.setContent_type(Constants.MONEYLOG_CONTENT_RECHARGE);
					this.moneyLogService.save(moneyLog);
					System.out.println("支付回调doubleNum..."+doubleNum);
					// 钱包日志
					WalletLog walletLog = new WalletLog();
					walletLog.setCategory(Constants.MONEYLOG_CATEGORY_RECHARGE);
					walletLog.setPartyId(partyId);
					walletLog.setOrder_no("R"+ System.currentTimeMillis());
					walletLog.setStatus(1);
					walletLog.setAmount(doubleNum);
					walletLog.setWallettype(wallettype);
					this.walletLogService.save(walletLog);
					jdbcTemplate.update("INSERT INTO PAT_HASH(HASH,STATUS) VALUES(?,?)",paramsMap.get("recharge_hash"),1);
				}
			}

		} catch (BusinessException e) {
			System.out.println("出异常了");
			System.out.println(e.getMessage());
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
	}

	@RequestMapping("/api/withdrawCallback!execute.action")
	public void withdrawCallback(HttpServletRequest request) {
		try {
			System.out.println("提现回调start...");
			//将异步通知中收到的待验证所有参数都存放到map中
			Map<String, String> paramsMap = SafeUtils.convertRequestParamsToMap(request);
			System.out.println("响应字符串为paramsMap："+paramsMap);
			if(null != paramsMap && null != paramsMap.get("withdraw_hash")){
				JdbcTemplate jdbcTemplate = ApplicationUtil.getBean(JdbcTemplate.class);
				String withdrawHash = (String) paramsMap.get("withdraw_hash");
				Integer count = jdbcTemplate.queryForObject("SELECT count(ID) FROM PAT_HASH WHERE HASH=? AND status = 1", Integer.class,withdrawHash);
				System.out.println("提现回调hashcount.."+count);
				if(count == 0){
    				//2：提币成功 3：提币失败
    				String status = (String) paramsMap.get("status");
    				System.out.println("提现回调status.."+status);
    				System.out.println("2".equals(status));
    				
					if("2".equals(status)){
    					String partyId = jdbcTemplate.queryForObject("SELECT PARTY_ID FROM T_WITHDRAW_ORDER WHERE WITHDRAW_HASH=?", String.class,withdrawHash);
    					System.out.println("提现回调partyId.."+partyId);
    					Party party = this.partyService.cachePartyBy(partyId, false);
    					
    					jdbcTemplate.update("INSERT INTO PAT_HASH(HASH,STATUS) VALUES(?,?)",withdrawHash,1);
    					
    					jdbcTemplate.update("UPDATE T_WITHDRAW_ORDER SET SUCCEEDED = 1 WHERE  WITHDRAW_HASH = ?",withdrawHash);
					}
				}
			}

		} catch (BusinessException e) {
		}
	}

}