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
                  ->where('status', $productWelfareRede::Normal)
                  ->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'));
            $welfare = $productWelfareRede::get($ids);
            $data_info = [
                'title' => $welfare['title'],
                'product_image' => $welfare['product_image'],
                'transfer_address' => $welfare['transfer_address'],
                'usdt_num' => round($welfare['usdt_num'],2),
                'is_token' => $welfare['is_token'],
                'token_name' => $welfare['token_name'],
                'token_num' => round($welfare['token_num'], 2),
            ];
            $this->success('ok', ['data'=>$data_info, 'desc'=> $welfare['describe']]);
      }


      //Rwa兑换
      public function submitWelfare(LedgerWalletModel $ledgerWalletModel, ProductWelfareRede $productWelfareRede)
      {
          $ids = $this->request->post('ids'); // 代币ids
          $coin_from_address = $this->request->post('coin_from_address'); // 代码转入地址
          $usdt_from_address = $this->request->post('usdt_from_address'); // U转入地址
          if (empty($ids) || empty($usdt_from_address)) {
              $this->error(__('Parameter error'));
          }
          //检查区块链地址是否合法
          if(!(isErc20AddressValid($usdt_from_address))){
              $this->error(__('Invalid parameters'));
          }
          //福利兑换记录
          $welfare_config = $productWelfareRede::where('id',$ids)->where('status', $productWelfareRede::Normal)->find();
          if (!$welfare_config) $this->error(__('Invalid parameters'));
          //检查是否在开启时间之内
          if(time() < $welfare_config['start_time'] || time() > $welfare_config['end_time']) $this->error(__('不在兑换时间范围内'));
          
          //检查是否已兑换过
          $check_user = (new RwaExchangeRecordModel())->where('user_id', $this->auth->id)->count();
          if($check_user >= 2) $this->error('每人限制兑换两套，您已达上限');
          
          $order_no = date('YmdHis') . rand(1000, 9999);
          $inster_data[] = [
              'order_no' => $order_no,
              'user_id' => $this->auth->id,
              'welfare_id' => $welfare_config['id'],
              'product_id' => $welfare_config['product_id'],
              'from_address_usdt' => $usdt_from_address,
              'amount_usdt' => $welfare_config['usdt_num'],
              'to_address' => $welfare_config['transfer_address'],
              'create_time' => time()
          ];
          //有代币参与时
          if($welfare_config->is_token >0){
              if (empty($coin_from_address)) {
                  $this->error(__('Parameter error'));
              }
              //检查区块链地址是否合法
              if(!(isErc20AddressValid($coin_from_address))){
                  $this->error(__('Invalid parameters'));
              }

              $BscApi = new BscApi($welfare_config->token_address);
              $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->token_num) {
                      $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_token', $item['hash'])->find();
                  if (empty($check_info)) {
                      $coin_data = $item;//获取未兑换过的代币转入记录
                      break;
                  }
              }
              if (empty($coin_data)) {
                  $this->error('未识别到新代币转入记录');
              }

              Log::info($coin_list, '代币可用转入记录');

              //拼装代币转入记录
              $inster_data['token_name'] = $welfare_config->token_name;
              $inster_data['from_address_token'] = $coin_data['from'];
              $inster_data['amount_token'] = $coin_data['amount'];
              $inster_data['tx_hash_token'] = $coin_data['hash'];
            }

          //USDT转入记录
          $BscApi = new BscApi('0x55d398326f99059ff775485246999027b3197955');
          $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->usdt_num) {
                  $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_usdt', $item['hash'])->find();
              if (empty($check_info)) {
                  $usdt_data = $item;
                  break;
              }
          }
          if (empty($usdt_data)) {
              $this->error('未识别到新USDT转入记录');
          }
          Log::info($usdt_list, 'USDT可用入记录');

          //记录
          $inster_data['tx_hash_usdt'] = $usdt_data['hash'];
          Log::info($inster_data, '插入数据');

          try {
              Db::startTrans();
              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::setUserWelfareProduct($this->auth->id, $welfare_config['product_id'], $order_no, 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');
      }

}