开放数据联盟链智能合约 #

package cn.opendatachain.nmdccontract;

import lombok.Data;

/**
 * Dataset 上链数据集示例
 * @author 郭志斌
 * @version nmdc-contract 1.0.0.RELEASE
 * <b>Creation Time:</b> 2022/7/22 14:06
 */
@Data
public class Dataset {

    /**
     * 数据集标题
     */
    private String title;

    /**
     * 数据集标识 CSTR
     */
    private String cstr;

    /**
     * 数据集关键字
     */
    private String keyword;
	
	  // 除基础数据类型外,合约支持存储复杂 json 数据格式，属性可包括 List<Object>,Map<String.Object> 等数据结构，以实际上链需求为准

}

package cn.opendatachain.nmdccontract;

import cn.opendatachain.common.core.domain.ContractPayload;
import cn.opendatachain.common.rsocket.ODCResponse;
import cn.opendatachain.contract.annotation.ODCContract;
import cn.opendatachain.contract.context.Context;
import cn.opendatachain.contract.context.Transaction;
import cn.opendatachain.contract.util.JsonUtils;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;

/**
 * TestContract ODC 智能合约示例
 *
 * @author 郭志斌
 * @version nmdc-contract 1.0.0.RELEASE
 * <b>Creation Time:</b> 2022/9/13 15:44
 */

@Slf4j
@RestController
@Tag(name = "测试智能合约")
@ODCContract(name = "test-contract")
public class TestContract {

    /**
     * 智能合约上下文
     */
    private final Context context;

    /**
     * JSON 工具类
     */
    private final JsonUtils jsonUtils;

    /**
     * 构造方法 注入合约引擎上下文及其他对象,也可以使用 @Autowired 进行对象注入
     *
     * @param context   上下文
     * @param jsonUtils 工具类
     */
    public TestContract(Context context, JsonUtils jsonUtils) {
        this.context = context;
        this.jsonUtils = jsonUtils;
    }

    /**
     * 数据上链
     *
     * @param dataset 数据上链对象
     * @return Mono<ODCResponse>
     */
    @Operation(summary = "数据上链")
    @PostMapping("/test.upsert")
    public Mono<ODCResponse> upsert(@RequestBody Dataset dataset) {
        //获取交易对象
        Transaction transaction = context.getTransaction();

        //转换为 json 数据格式
        String json = jsonUtils.toJson(dataset);
        log.debug("获取原始上链数据 json ：{}", json);

        // 省略获取 Dataset 后数据的校验

        //构建数据上链相关参数及签名
        ContractPayload payload = transaction.payloadBuilder(dataset.getCstr(), json);

        log.debug("ContractPayload ： {}", jsonUtils.toJson(payload));

        // 数据上链
        return transaction.upsert(payload);
    }
	
    /**
     * 批量数据上链 - 如何调用智能合约接口详见智能合约进阶章节
     *
     * @param dataset 数据上链对象
     * @return Mono<ODCResponse>
     */
	   @Operation(summary = "批量数据上链")
    @PostMapping("/test.upsert.batch")
    public Publisher<ODCResponse> upsertBatch(@RequestBody List<Dataset> datasets) throws IllegalAccessException {
        //获取交易对象
        Transaction transaction = context.getTransaction();

        //获取批量数据并转换为可上链对象 ContractPayload 列表
        List<ContractPayload> payloads = datasets.stream().map(ds ->
            transaction.payloadBuilder(ds.getCstr(), jsonUtils.toJson(ds))
        ).collect(Collectors.toList());

        log.debug("ContractPayloads size is : {}", payloads.size());

        // 批量数据上链
        return transaction.upsertBatch(payloads);
    }
	
		/**
		 * 数据上链 - 不存储状态数据
		 *
		 * @param dataset 数据上链对象
		 * @return Mono<ODCResponse>
		 */
		@Operation(summary = "数据上链-不存储状态数据")
		@PostMapping("/dataset.upsert.notSaveStatus")
		public Mono<ODCResponse> notSaveStatus(@RequestBody Dataset dataset) {
			//获取交易对象
			Transaction transaction = context.getTransaction();

			//转换为 json 数据格式
			String json = jsonUtils.toJson(dataset);
			log.debug("接受数据 json ：{}", json);

			//构建数据上链对象及签名信息
			ContractPayload payload = transaction.payloadBuilder(dataset.getCstr(), json);

			log.debug("ContractPayload ： {}", jsonUtils.toJson(payload));

			// 数据上链
			return transaction.notSaveStatus(payload);
		}

    /**
     * 历史数据查询
     *
     * @param uid 数据标识,推荐使用 cstr
     * @return Mono<ODCResponse>
     */
    @Operation(summary = "历史数据查询")
    @GetMapping("/test.history")
    public Mono<ODCResponse> history(@RequestParam(name = "uid") String uid) {
        //获取交易对象
        Transaction transaction = context.getTransaction();

        //构建数据查询相关参数及签名
        ContractPayload payload = transaction.payloadQueryBuilder(uid);

        log.debug("ContractPayload ： {}", jsonUtils.toJson(payload));

        // 查询历史
        return transaction.history(payload);

    }

    /**
     * 获取状态数据查询
     *
     * @param uid 数据标识,推荐使用 cstr
     * @return Mono<ODCResponse>
     */
    @Operation(summary = "获取最新状态数据")
    @GetMapping("/test.latestStatus")
    public Mono<ODCResponse> latestStatus(@RequestParam(name = "uid") String uid) {
        //获取交易对象
        Transaction transaction = context.getTransaction();

        //构建数据查询相关参数及签名
        ContractPayload payload = transaction.payloadQueryBuilder(uid);

        log.debug("ContractPayload ： {}", jsonUtils.toJson(payload));

        return transaction.latestStatus(payload);
    }

}

package cn.opendatachain.nmdccontract;

import cn.opendatachain.contract.OpenDataChainContract;
import org.springframework.boot.autoconfigure.SpringBootApplication;

/**
 * TestContractApp 智能合约启动类
 *
 * @author 郭志斌
 * @version nmdc-contract 1.0.0.RELEASE
 * <b>Creation Time:</b> 2022/7/23 22:29
 */
@SpringBootApplication
public class TestContractApp extends OpenDataChainContract{

	//程序启动入口
    public static void main(String[] args) {        
        OpenDataChainContract.run(NmdcContractApp.class,args);
    }
}