kuake/extend/logicmodel/ChainLogic.php

<?php


namespace logicmodel;



use datamodel\Goods;
use datamodel\GoodsHash;
use datamodel\Users;
use fast\Http;
use think\Env;
use think\Exception;
use traits\think\Instance;

class ChainLogic
{
    use Instance;
    protected $host;
    protected $api=[
        'register'=>'/register',
        'create_goods'=>'/IssueAddr',
        'transfer'=>'/transferFrom',
    ];
    protected $mainAccount='';
    protected $nftId='';
    #https://39.101.175.93:8088/transfer?fromAccountName=？&commodityHash=？&toAccountName=？转移商品，fromAccountName转移人，commodityHash商品交易hash  toAccountName被转移人
    #https://39.101.175.93:8088/creatGoods?commodityId=？  创建商品返回交易hash  ，commodityId为商品
    #https://39.101.175.93:8088/register?accountName=？创建用户， accountName 为用户名
    public function __construct()
    {
        $this->host=Env::get('chain.host','http://39.101.175.93:8088');
        $this->setMainAccount('ad370ed99b189921e7fe26057c40aab9f4fee8385e47606f50f348b9a5530af0');
    }

    public function saveUserAddress(Users $users){
        $data=$this->request('register',[
            'accountName'=>$users['phone'],
        ]);
        $users['wallet_address']=$data['userAddressStr'];
        $users->save();
    }
    protected function request($api,$params){
        $url=sprintf('%s%s',$this->host,$this->api[$api]);
        $info=Http::post($url,$params);
        $this->record($api,$params,$info);
        $info=json_decode($info,true);
        if(empty($info) || empty($info['success']) || !$info['success']){
            api_error($info['message']??'请求出错');
        }
        return $info['result'];
    }
    public function saveGoodsHash(Goods $goods){
        $num=$goods['stock'];
        $existsCount=$goods->hash()->count();
        if($num>0 && $num-$existsCount>0){
            for ($i=0;$i<$num-$existsCount;$i++){
                $this->getGoodsHash($goods);
            }
        }
        $goods['hash_num']=$goods->hash()->count();
        $goods->save();
    }
    public function getGoodsHash(Goods $goods){
        $hash=$this->request('create_goods',[
            'account'=>$this->getMainAccount(),
            'nftId'=>$goods['id'],
            'tokenUrl'=>cdnurl($goods['image']),
        ]);
        $hashModel=$goods->hash()->save([
            'hash'=>$hash['txHash'],
            'token_id'=>$hash['tokenId'],
        ]);
        return $hashModel;
    }

    public function transfer(Users $fromUser,GoodsHash $goodsHash,Users $toUser){
        $this->request('transfer',[
            'from'=>$fromUser['wallet_address'],
            'to'  =>$toUser['wallet_address'],
            'tokenId'  =>$goodsHash['token_id'],
        ]);
    }

    public function buy(GoodsHash $goodsHash,Users $toUser){
        $hash=$this->request('transfer',[
            'from'=>$this->getMainAccount(),
            'to'  =>$toUser['wallet_address'],
            'tokenId'  =>$goodsHash['token_id'],
        ]);
        return $hash;
    }

    protected function record($api,$params,$result){
        $dir=sprintf('%s/chainlog',RUNTIME_PATH);
        if(!is_dir($dir)){
            mkdir($dir,0777,true);
        }
        file_put_contents($dir."/{$api}.log",date('Y-m-d H:i:s').' '.json_encode([
            'api'=>$api,
            'params'=>$params,
            'result'=>$result
        ],JSON_UNESCAPED_UNICODE).PHP_EOL,8);
    }


    /**
     * @param string $mainAccount
     */
    public function setMainAccount(string $mainAccount)
    {
        $this->mainAccount = $mainAccount;
        return $this;
    }

    /**
     * @return string
     */
    public function getMainAccount(): string
    {
        return $this->mainAccount;
    }

    /**
     * @param string $nftId
     */
    public function setNftId(string $nftId)
    {
        $this->nftId = $nftId;
        return $this;
    }

    /**
     * @return string
     */
    public function getNftId(): string
    {
        return $this->nftId;
    }
}