您现在的位置是:首页 >技术教程 >区块链应用的开发网站首页技术教程
区块链应用的开发
经过前面两篇文章(【适合小白】区块链之我用可视化的方式部署Webase,区块链之我用可视化Webase开发智能合约)的洗礼,相信大家都对区块链这块多少有点了解了,在本章节小编将带大家演示一下区块链应用的开发。
首先需要导出刚才编译部署的智能合约项目。
项目导出之前,得先编译该项目。项目名称跟包名可自定义,channelIp为节点所在的IP地址,channelPort为节点所在的端口号,用户选择没有要求。
这里小编给大家提供一个若依的SpringBoot前后端分离框架方便大家开发。
链接:https://pan.baidu.com/s/1T50RdvhWYMvbRLtzogoeBA
提取码:r1h3
在本章节小编也将用这个框架作为示例给大家演示。
先用集成的开发工具打开这个框架,这里小编用的是IDEA。
打开后如图所示,这里小编有个建议,就是项目的路径下不要出现中文!这里只作为演示示例小编就没有去修改了。在这个框架中前端框架是ruoyi-trace,我们需要做改动的是ruoyi-admin、ruoyi-trace(这个其实就是我们在webase中导出的合约项目,只是我们需要把它合并到这个框架中)。
这是这个
合约项目下的相应内容,我们需要com.ruoyi.trace、resources下的所有文件都替换掉(替换成刚才从webase导出的相应的项目文件)。
替换后如图所示。
下面我们需要在tuoyi-admin中编写我们的合约层
在这个controller下新建一个trace项目,并编写代码,如下图所示。
在trace下我们新建一个类,开始编写我们的代码。
代码如下:
package com.ruoyi.web.controller.trace;
import com.ruoyi.common.core.controller.BaseController;
import com.ruoyi.common.core.domain.AjaxResult;
import org.example.demo.model.bo.TraceAddProductInputBO;
import org.example.demo.model.bo.TraceAddTraceByMiddlemanInputBO;
import org.example.demo.model.bo.TraceAddTraceBySuperMarketInputBO;
import org.example.demo.model.bo.TraceGetTraceInputBO;
import org.fisco.bcos.sdk.transaction.model.dto.CallResponse;
import org.fisco.bcos.sdk.transaction.model.dto.TransactionResponse;
import org.springframework.web.bind.annotation.*;
import org.example.demo.service.TraceService;
import javax.annotation.Resource;
import java.math.BigInteger;
import java.util.ArrayList;
/**
* @ClassName: TraceChainController
* @Description:
* @Author
* @Date 2023/2/7
* @Version 1.0
*/
@RestController
@RequestMapping("/trace")
public class TraceChainController extends BaseController {
@Resource
private TraceService traceService;
/**
* 新增水果接口
* @param traceFruitNewFruitInputBO
* @return
*/
@PostMapping("/addProduct")
public AjaxResult addProduct(@RequestBody TraceAddProductInputBO traceFruitNewFruitInputBO) {
try {
TransactionResponse response = traceService.addProduct(traceFruitNewFruitInputBO);
System.out.println(response);
response.getReceiptMessages();
if(response.getReturnCode()==0){//success
return AjaxResult.success(response);
}else{
return error(response.getReceiptMessages());
}
} catch (Exception e) {
e.printStackTrace();
}
return toAjax(1);
}
/**
*中间商操作接口
* @param traceFruitAddTraceInfoByMiddlemanInputBO
* @return
*/
@PostMapping("/addTraceInfoByMiddleman")
public AjaxResult addTraceInfoByMiddleman(@RequestBody TraceAddTraceByMiddlemanInputBO traceFruitAddTraceInfoByMiddlemanInputBO) {
try {
TransactionResponse response = traceService.addTraceByMiddleman(traceFruitAddTraceInfoByMiddlemanInputBO);
System.out.println(response);
response.getReceiptMessages();
if(response.getReturnCode()==0){//success
return AjaxResult.success(response);
}else{
return error(response.getReceiptMessages());
}
} catch (Exception e) {
e.printStackTrace();
}
return toAjax(1);
}
/**
* 超市操作接口
* @param traceFruitAddTraceInfoBySuperMarketInputBO
* @return
*/
@PostMapping("/addTraceInfoBySuperMarket")
public AjaxResult addTraceInfoBySuperMarket(@RequestBody TraceAddTraceBySuperMarketInputBO traceFruitAddTraceInfoBySuperMarketInputBO) {
try {
TransactionResponse response = traceService.addTraceBySuperMarket(traceFruitAddTraceInfoBySuperMarketInputBO);
System.out.println(response);
response.getReceiptMessages();
if(response.getReturnCode()==0){//success
return AjaxResult.success(response);
}else{
return error(response.getReceiptMessages());
}
} catch (Exception e) {
e.printStackTrace();
}
return toAjax(1);
}
/**
* 查询溯源信息接口
* @param traceNumber
* @return
*/
@GetMapping("/getTraceInfo")
public AjaxResult getTraceInfo(@RequestParam("traceNumber") BigInteger traceNumber) {
try {
TraceGetTraceInputBO traceFruitGetTraceInfoInputBO = new TraceGetTraceInputBO();
traceFruitGetTraceInfoInputBO.setTraceNumber(traceNumber);
CallResponse response = traceService.getTrace(traceFruitGetTraceInfoInputBO);
System.out.println(response);
if(response.getReturnCode()==0){//success
ArrayList rsList= (ArrayList) response.getReturnObject().get(0);
if(!(boolean)rsList.get(4)){
return error("溯源码不存在");
}
return AjaxResult.success(response.getReturnObject());
}else{
return error(response.getReturnMessage());
}
} catch (Exception e) {
e.printStackTrace();
}
return toAjax(1);
}
}
接下来我们需要把application.properties下的一些相关配置文件copy到aoolication.dev.yml(mysql的master相应的数据也需要稍作修改)中,如图所示:
需要注意的是,peers下的IP地址必须为配置节点的IP地址。
这个文件里面有创建数据表的sql语句,我们可以用工具创建这个表,这里小编用的是navicat。
选择好sql路劲运行。