RWACha-API/application/api/controller/Exchange.php

<?php


namespace app\api\controller;

use app\api\logic\WelfareLoginc;
use app\common\controller\Api;
use app\common\logic\BscApi;
use app\common\model\ProductLists;
use app\common\model\LedgerFrozenChangeModel;
use app\common\model\ProductOrder;
use app\common\model\ProductWelfareRede;
use app\common\model\RwaExchangeRecordModel;
use app\common\model\LedgerWalletModel;
use app\common\model\LedgerTeacChangeModel;
use fast\Action;
use fast\Asset;
use think\Db;
use think\Exception;
use think\Log;

//Teac兑换
class Exchange extends Api
{

      protected string $lan = '';

      public function _initialize()
      {
            parent::_initialize();
            $this->lan = $this->request->getLan();
      }

  
      //Rwa福利兑换配置
      public function getWelfareRedeList(ProductWelfareRede $productWelfareRede){

            $list = $productWelfareRede
                  ->order('weigh desc')
                  ->paginate($this->pageSize);
            $this->success('ok', $list);
      }

      //Rwa福利兑换详情
      public function getWelfareRedeDetail(ProductWelfareRede $productWelfareRede){

            $ids = $this->request->post('ids');
            if (empty($ids)) $this->error(__('Parameter error'));
            $this->success('ok', $productWelfareRede::get($ids));
      }


      //Rwa兑换
      public function submitWelfare(LedgerWalletModel $ledgerWalletModel)
      {
            $coin = $this->request->post('coin'); // 代币
            $coin_from_address = $this->request->post('coin_from_address'); // 代码转入地址
            $usdt_from_address = $this->request->post('usdt_from_address'); // U转入地址
            if (empty($coin) || empty($coin_from_address) || empty($usdt_from_address)) {
                  $this->error(__('Parameter error'));
            }
            //检查区块链地址是否合法
            if(!(isErc20AddressValid($coin_from_address) && isErc20AddressValid($usdt_from_address))){
                  $this->error(__('Invalid parameters'));
            }

            $welfare_config = config('welfare_rede');
            if (!in_array($coin, $welfare_config['currency'])) {
                  $this->error(__('Invalid parameters'));
            }

            $check_user = (new RwaExchangeRecordModel())->where('user_id', $this->auth->id)->where('status', 200)->count();
            if($check_user >= 4){
                  $this->error('每人限制兑换两套，您已达上限');
            }

            $BscApi = new BscApi($welfare_config['contract_address'][$coin]);
            $result_coin = $BscApi->getTransactionRecordsByAddress($coin_from_address, $welfare_config['transfer_address'], 49990000);
            if ($result_coin['code'] == 0) {
                  $this->error($result_coin['msg']);
            }
            Log::info($result_coin, '代币所有转入记录');
            $coin_list = [];
            foreach ($result_coin['data'] as $value) {
                  if ($value['amount'] == $welfare_config['currency_price'][$coin]) {
                  $coin_list[] = $value;
                  }
            }
            if (empty($coin_list)) {
                  $this->error('未识别到代币转入记录');
            }
            Log::info($coin_list, '代币精准转入记录');

            $coin_data = [];
            foreach ($coin_list as $item) {
                  $check_info = (new RwaExchangeRecordModel())->where('tx_hash', $item['hash'])->find();
                  if (empty($check_info)) {
                  $coin_data = $item;
                  break;
                  }
            }
            if (empty($coin_data)) {
                  $this->error('未识别到新代币转入记录');
            }
            Log::info($coin_list, '代币可用转入记录');

            $BscApi = new BscApi($welfare_config['contract_address']['USDT']);
            $result_usdt = $BscApi->getTransactionRecordsByAddress($usdt_from_address, $welfare_config['transfer_address'], 49990000);
            if ($result_usdt['code'] == 0) {
                  $this->error($result_usdt['msg']);
            }
            Log::info($result_usdt, 'USDT所有转入记录');

            $usdt_list = [];
            foreach ($result_usdt['data'] as $value) {
                  if ($value['amount'] == $welfare_config['currency_price']['USDT']) {
                  $usdt_list[] = $value;
                  }
            }
            if (empty($usdt_list)) {
                  $this->error('未识别到USDT转入记录');
            }
            Log::info($usdt_list, 'USDT精准转入记录');

            $usdt_data = [];
            foreach ($usdt_list as $item) {
                  $check_info = (new RwaExchangeRecordModel())->where('tx_hash', $item['hash'])->find();
                  if (empty($check_info)) {
                  $usdt_data = $item;
                  break;
                  }
            }
            if (empty($usdt_data)) {
                  $this->error('未识别到新USDT转入记录');
            }
            Log::info($usdt_list, 'USDT可用入记录');

            $order_no = date('YmdHis') . rand(1000, 9999);
            $inster_data = [
                  [
                  'order_no' => $order_no,
                  'tx_hash' => $coin_data['hash'],
                  'user_id' => $this->auth->id,
                  'symbol' => $coin,
                  'amount' => $coin_data['amount'],
                  'product_id' => $welfare_config['product_id'],
                  'from_address' => $coin_data['from'],
                  'to_address' => $coin_data['to'],
                  'status' => 200,
                  'create_time' => time(),
                  ],
                  [
                  'order_no' => $order_no,
                  'tx_hash' => $usdt_data['hash'],
                  'user_id' => $this->auth->id,
                  'symbol' => 'USDT',
                  'amount' => $usdt_data['amount'],
                  'product_id' => $welfare_config['product_id'],
                  'from_address' => $usdt_data['from'],
                  'to_address' => $usdt_data['to'],
                  'status' => 200,
                  'create_time' => time(),
                  ]
            ];
            Log::info($inster_data, '插入数据');
            $product_id = $welfare_config['product_id'];
            $product_info =  (new ProductLists())->where('id', $product_id)->find();
            if (empty($product_info))  $this->error('产品不存在');
            try {
                  Db::startTrans();
                  $rs = Db::name('rwa_exchange_record')->fetchSql(false)->insertAll($inster_data);
                  //添加标记茶宝记录
                  $ledgerWalletModel->changeWalletAccount($this->auth->id, Asset::FROZEN, $usdt_data['amount'], LedgerFrozenChangeModel::RwaExchangeRecord, 0);
                  //发放产品
                  $rs = WelfareLoginc::setUserProductOrder(1, false, $order_no, 0, $product_info['id'], $this->auth->id, ProductOrder::RwaExchange);
                  Db::commit();
                  $this->success('ok', $order_no);
            } catch (Exception $e) {
                  Db::rollback();
                  $this->error($e->getMessage(), null, $e->getCode());
            }
      }


      //Teac兑换列表
      public function getTeacList(ProductLists $productLists){
             
            $list = $productLists::where('is_teac', 1)
                  ->where('status', 1)
                  ->field('id,teac_price,thum,'.$this->lan.'_name as name')
                  ->order('weigh desc')
                  ->paginate($this->pageSize);
            $this->success('ok', $list);
      }

      //Teac兑换详情
      public function getTeacDetail(ProductLists $productLists){
             
            $ids = $this->request->post('product_id/d', 0);
            $list = $productLists::where('is_teac', 1)
                  ->where('id', $ids)->where('status', 1)
                  ->field('id,teac_price,images,'.$this->lan.'_name as name,details')
                  ->find();
            $this->success('ok', $list);
      }

      //Teac兑换购买
      public function getTeacOrder(ProductLists $productLists, LedgerWalletModel $ledgerWalletModel, ProductOrder $productOrder){
             
            $params = $this->request->post();
            $validate = \think\Loader::validate('Exchange');
            if(!$validate->scene('order')->check($params)) $this->error($validate->getError());

            $rows = $productLists::where('id', $params['product_id'])->where('is_teac', 1)->where('status', 1)->find();
            if(empty($rows)) throw new Exception(__("产品暂未开放"));
            // 启动事务
            Db::startTrans();
            try {

                  $teac = $ledgerWalletModel::getWalletTeac($this->auth->id);

                  $amount = bcmul($params['stock'], $rows->teac_price, 2);
                  if(bccomp($amount, $teac, 2) > 0) throw new Exception(__("Teac购买金额足"), 15001);
                  
                  //添加产品
                  $productOrder::setPopularNoAreaOrder($params['stock'], 0, 0, $params['product_id'], $this->auth->id, $productOrder::TeacExchange);

                  // 更新Teac和账变
                  $ledgerWalletModel->changeWalletAccount($this->auth->id, Asset::TEAC, -$amount, LedgerTeacChangeModel::Exchange, 0);

                  // 提交事务
                  Db::commit();
            } catch (Exception $e) {
                  // 回滚事务
                  Db::rollback();
                  $this->error($e->getMessage(), null, $e->getCode());
            }
     
            $this->success('ok');
      }

}