以太坊彩票合约案例

作者: 前端老邹_伯通 | 来源:发表于2018-11-12 22:05 被阅读77次

一.合约案例简介

此案例为入门案例，从合约 -> 编译 -> web3部署和调用

二.彩票合约源码

pragma solidity ^0.4.25;
// 彩票合约
contract LotteryShop{

    //购买彩票事件，在购买彩票方法中调用
    event BuyLottery(address indexed buyer,uint money,uint16 luckNum);
    //开奖事件，在开奖方法中调用
    event DrawLottery(address winner,uint money,uint16 luckNum);

    //购买记录（购买者的address, 彩票号码）
    mapping(address=>uint) buyMapping;
    //购买用户的地址
    address[] usrAdrList;

    //管理员地址
    address manageAdr;
    //合约地址
    address contractAdr;

    constructor() public payable{
        //将合约部署人的地址保存起来作为管理员地址
        manageAdr=msg.sender;
        //将当前合约对象的地址保存
        contractAdr= address(this);
    }

    //0.1 显示管理员地址
    function ShowManageAdr() constant returns(address){
        return manageAdr;
    }

    //0.2 显示调用者的彩票数据
    function ShowInvokerCaiPiao() constant returns(uint){
        return buyMapping[msg.sender];
    }

    //0.3 显示管理员余额
    function ShowManageBalance() constant returns(uint){
        return manageAdr.balance;
    }
    //0.4 显示合约余额
    function ShowContractMoney() constant returns(uint){
        return contractAdr.balance;
    }
    //0.5 获取买家地址列表
    function getAllUsrAddress() view returns(address[]){
        return usrAdrList;
    }

    //0.5 买彩票方法
    function BuyCaiPiao(uint16 haoMa) payable{
        //0. 判断用户账户是否有1 eth
        require(msg.value == 1 ether);
        //1. 判断彩票购买列表里是否已经存在当前用户
        require(buyMapping[msg.sender]==0);

        //2. 将用户的钱转到合约账户
        contractAdr.send(msg.value);

        //3.1 调用事件日志
        emit BuyLottery(msg.sender,msg.value,haoMa);

        //3.2 添加到mapping
        buyMapping[msg.sender] = haoMa;
        //3.3 将地址存入 买家数组
        usrAdrList.push(msg.sender);
    }

    //1. 开奖 - 必须是管理员才能操作
    function KaiJiang() adminOnly payable returns(uint){
        //1.生成一个随机的开奖号码
        uint256 luckNum = uint256(keccak256(abi.encodePacked(block.difficulty,now)));
        //1.1 取模10，保证奖号在10以内
        luckNum = luckNum % 3;

        address tempAdr;
        //2.循环用户地址数组
        for(uint32 i=0; i< usrAdrList.length;i++){
            tempAdr = usrAdrList[i];
            //2.1 判断用户地址 在 mapping中 对应的 CaiPiao.hao 的数字是否一样
            if(buyMapping[tempAdr] == luckNum){
                //2.2 记录日志
                emit DrawLottery(tempAdr,contractAdr.balance,uint16(luckNum));
                //2.3 将合约里所有的钱转给 中奖账户地址
                tempAdr.send(contractAdr.balance);
                break;
            }
        }
        //3.返回 中奖号码
        return luckNum;
    }

    //2. 重置数据
    function resetData() adminOnly{
        //2.1 循环 买家数组，删除 购买记录mapping中对应的记录
        for(uint16 i = 0;i<usrAdrList.length;i++){
            delete buyMapping[usrAdrList[i]];
        }
        //2.2 删除 买家数组
        delete usrAdrList;
    }

    //3. 销毁合约
    function kill() adminOnly{
        //3.1 调用合约自毁函数，把合约账户余额转给当前调用者（管理员）
        selfdestruct(msg.sender);
    }

    //4. 管理员修饰符，只允许管理员操作
    modifier adminOnly() {
        require(msg.sender == manageAdr);
        //代码修饰器所修饰函数的代码
        _;
    }
}

三.nodeJs 编译合约并保存为文件

const solc = require('solc');
const path = require('path');
const fs = require('fs');

//1.1 合约代码文件路径
const sourceFilePath = path.resolve(__dirname,'./LotteryShop.sol');
//1.2 合约编译成字节码后的保存文件路径
const bytecodeFilePath = path.resolve(__dirname,'./LotteryShop.bytecode');
//2.读取文件
const source = fs.readFileSync(sourceFilePath,'utf-8');
//3.编译合约原文件
const result = solc.compile(source,1);
//console.log(result);

console.log('1.编译完成:'+sourceFilePath);
//3.1 将编译后的代码写入到文件中，这样部署文件 就不需要每次都重新编译，而是直接读取编译好的合约字节码和abi就行了
fs.writeFileSync(bytecodeFilePath,JSON.stringify(result.contracts[':LotteryShop']),'utf-8');
console.log('2.字节文件写入完成:'+bytecodeFilePath);

//4.暴露给外部访问
//module.exports=result.contracts[':CaiPiaoShop'];

四.web3调用代码

//1.1 导入 编译好的 合约的 字节代码 和 abi
const path = require('path');
const fs = require('fs');
//1.2 合约编译后的文件路径
const bytecodeFilePath = path.resolve(__dirname,'./LotteryShop.bytecode');
const bytecodeJsonStr = fs.readFileSync(bytecodeFilePath,'utf-8');
const byteCodeJsonObj = JSON.parse(bytecodeJsonStr);
//const {bytecode,interface} = require('./compilCaiPiao');
const bytecode = byteCodeJsonObj.bytecode;
const interface = byteCodeJsonObj.interface;

//2.导入 hd钱包provider
const HDWalletProvider = require("truffle-hdwallet-provider");
//3.助记词（相当于是我们的私钥）
const mnemonic = "jar trumpet ..... cat beef"; // 12 word mnemonic
//4.创建 provider，可以用来访问 以太坊真实网络节点
const provider = new HDWalletProvider(mnemonic, "https://rinkeby.infura.io/v3/3a60f2b16......",0);//最后的0 是获取 助记词 的第1个地址

//5.创建web对象
const Web3 = require('web3');
const web3= new Web3(provider);

// “主函数”作为启动函数
async function main(){
    console.log('开始与以太网交互......');
    const usrAdr = await web3.eth.getAccounts();
    web3.eth.defaultAccount = usrAdr[0];
    console.log('当前调用者的地址:' + web3.eth.defaultAccount);

    //6.部署合约到 以太网节点
    //let contractObj =await deployContract();

    //7.调用合约
    //7.0 创建 远程智能合约（传入第6步已经部署好的合约地址）
    const contractObj = await new web3.eth.Contract(JSON.parse(interface),'0x8f27Ad244cFeabcCc45B81B7406a7EDEA53c5f97');
    console.log('获取【合约】对象成功!');

    // 7.1 调用 买彩票 的方法（合约对象，购买的号码）
    //await buyLottery(contractObj,2);

    // 7.2 显示合约账户余额
    //await showContracMoney(contractObj);
    // 查看调用者购买的号码
    //await showInvokerMoney(contractObj);

    // 7.3 开奖
    await withdrawLottery(contractObj);

    // 7.4 显示买家账户列表
    await showUsrList(contractObj);
    await showContracMoney(contractObj);
    await showInvokerMoney(contractObj);
    // 7.5 重置数据
    //await resetContract(contractObj);
    //await killContract(contractObj);
    //await showUsrList(contractObj);
    console.log('结束!');
}

// 启动
main();

// 1.部署合约
async function deployContract() {
    console.log('开始部署合约......');
    let contractObj = await new web3.eth.Contract(JSON.parse(interface))
        .deploy({
            data: bytecode,
            arguments: []
        }).send({
           from:web3.eth.defaultAccount,
            gas:'1000000'
        });

    console.log('部署成功，合约地址：【'+contractObj.options.address+'】'); // 0x8f27Ad244cFeabcCc45B81B7406a7EDEA53c5f97
    return contractObj;
}

// 2.买彩票
async function buyLottery(contractObj,luckNum) {
    console.log('开始购买彩票，稍等15秒~~');

    await contractObj.methods.BuyCaiPiao(luckNum).send(
        {
            from:web3.eth.defaultAccount,
            value:web3.utils.toWei('1','ether'),
            gas:'1000000'
        }
    );
    console.log('购买彩票完毕~~');
}

// 3.开奖
async function withdrawLottery(contractObj) {
    console.log('开奖进行中请等待15秒左右...');
    let luckNum;
    await contractObj.methods.KaiJiang().send({
        from:web3.eth.defaultAccount,
        gas:'1000000'
    },function (err,result) {
        //将返回的 开奖数字 赋值给 局部变量 luckNum
        luckNum = result;
        console.log('开奖完成, luckNum:');
        console.log(result);
    });
    console.log('开奖完成：'+luckNum);
}

// -------------------------------------------
// 4.显示合约余额
async function showContracMoney(contractObj) {
    let msg = await contractObj.methods.ShowContractMoney().call();
    console.log('合约账号里的余额：'+msg);
}
// 5.显示管理员地址
async function showManageAddress(contractObj) {
    let msg = await contractObj.methods.ShowManageAdr().call();
    console.log('合约管理员地址：'+msg);
}

// 6.查看调用者购买的号码
async function showInvokerMoney(contractObj) {
    //获取当前调用合约的账户
    const usrAdr = await web3.eth.getAccounts();

    // 1.因为 被调用合约里的ShowInverkCaiPiao()方法 需要使用 msg.sender
    // 所以在 call({from:当前调用者账号地址})的时候要指定from为当前调用者
    // let msg = await contractObj.methods.ShowInverkCaiPiao().call({
    //     from:usrAdr[0]
    // });

    // 2.或者，可以设置 web3.eth.defaultAccount = usrAdr[0]，再调用 call()时，会自动设置 from
    //设置给 默认账户
    web3.eth.defaultAccount = usrAdr[0];
    let msg1 = await contractObj.methods.ShowInvokerCaiPiao().call();
    console.log('调用者购买的号码：' + msg1);
}

// 7.重置合约数据
async function resetContract(contractObj) {
    // 因为 合约的 resetData 方法里 修改了 全局变量，所以需要使用 send 方法
    let msg = await contractObj.methods.resetData().send({
        from:web3.eth.defaultAccount,
        gas:'1000000'
    });

    console.log('交易记录：');
    console.log(msg);//打印从交易记录
    console.log('彩票购买记录 和 买家地址列表 已清零~~');
}
// 8.销毁合约
async function killContract(contractObj) {
    console.log('合约销毁开始~~');
    await contractObj.methods.kill().send({
        from:web3.eth.defaultAccount,
        gas:'1000000'
    });
    console.log('合约已作废~~');
}
// 9. 显示买家列表
async function showUsrList(contractObj) {
    let msg = await contractObj.methods.getAllUsrAddress().call();
    console.log('买家地址列表：');
    console.log(msg);

}

以太坊彩票合约案例

一.合约案例简介

二.彩票合约源码

三.nodeJs 编译合约并保存为文件

四.web3调用代码

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读