= 32) {
+ System.arraycopy(tempBytes, tempBytes.length - 32, bytes, 0, 32);
+ } else {
+ System.arraycopy(tempBytes, 0, bytes, 32 - tempBytes.length, tempBytes.length);
+ }
+ return bytes;
+ }
+
+ public static Fraction add(Fraction a, Fraction b) {
+ if (a.getDen().equals(b.getDen())) {
+ return new Fraction(add(a.getNum(), b.getNum()), a.getDen());
+ } else {
+ return new Fraction(add(mul(a.getNum(), b.getDen()), mul(a.getDen(), b.getNum())), mul(a.getDen(), b.getDen()));
+ }
+ }
+
+ public static Fraction sub(Fraction a, Fraction b) {
+ if (a.getDen().equals(b.getDen())) {
+ return new Fraction(sub(a.getNum(), b.getNum()), a.getDen());
+ } else {
+ return new Fraction(sub(mul(a.getNum(), b.getDen()), mul(a.getDen(), b.getNum())), mul(a.getDen(), b.getDen()));
+ }
+ }
+
+ public static Fraction neg(Fraction a) {
+ return new Fraction(neg(a.getNum()), a.getDen());
+ }
+
+ public static Fraction mul(Fraction a, Fraction b) {
+ return new Fraction(mul(a.getNum(), b.getNum()), mul(a.getDen(), b.getDen()));
+ }
+
+ public static Fraction div(Fraction a, Fraction b) {
+ return new Fraction(mul(a.getNum(), b.getDen()), mul(a.getDen(), b.getNum()));
+ }
+
+ public static BigInteger toU256(Fraction a) {
+ return div(a.getNum(), a.getDen());
+ }
+
+ public static boolean equal(Fraction a, Fraction b) {
+ return mul(a.getNum(), b.getDen()).equals(mul(a.getDen(), b.getNum()));
+ }
+
+ static Point mul2(Point a) {
+ Fraction lambda = div(mul(mul(a.getX(), a.getX()), new Fraction(BigInteger.valueOf(3))), add(a.getY(), a.getY()));
+ Fraction x = sub(mul(lambda, lambda), add(a.getX(), a.getX()));
+ Fraction y = sub(mul(lambda, sub(a.getX(), x)), a.getY());
+ return new Point(x, y);
+ }
+
+ public static Point add(Point a, Point b) {
+ if (a.isZero()) return b;
+ if (b.isZero()) return a;
+
+ if (equal(a.getX(), b.getX())) {
+ if (equal(a.getY(), b.getY())) {
+ return mul2(a);
+ } else {
+ return Point.ZERO;
+ }
+ } else {
+ Fraction lambda = div(sub(b.getY(), a.getY()), sub(b.getX(), a.getX()));
+ Fraction x = sub(mul(lambda, lambda), add(a.getX(), b.getX()));
+ Fraction y = sub(mul(lambda, sub(a.getX(), x)), a.getY());
+ return new Point(x, y);
+ }
+ }
+
+ public static Point mul(Point p, BigInteger n) {
+ if (p.isZero() || n.equals(BigInteger.ZERO)) return Point.ZERO;
+
+ int bitLength = n.bitLength();
+ Point ret = Point.ZERO, temp = p;
+ for (int i = 0; i < bitLength; i++) {
+ if (n.testBit(i)) {
+ ret = add(ret, temp);
+ }
+ if (i != bitLength - 1) {
+ temp = mul2(temp);
+ }
+ }
+ return ret;
+ }
+
+
+ static final BigInteger G_X = new BigInteger("79BE667EF9DCBBAC55A06295CE870B07029BFCDB2DCE28D959F2815B16F81798", 16);
+ static final BigInteger G_Y = new BigInteger("483ADA7726A3C4655DA4FBFC0E1108A8FD17B448A68554199C47D08FFB10D4B8", 16);
+ static final Point G = new Point(new Fraction(G_X), new Fraction(G_Y));
+ static final Point[] G_TABLE = new Point[256];
+
+ static {
+ G_TABLE[0] = G;
+ for (int i = 1; i < 256; i++) {
+ G_TABLE[i] = mul2(G_TABLE[i - 1]);
+ }
+ }
+
+ public static Point mulG(BigInteger n) {
+ Point r = Point.ZERO;
+ for (int i = 0; i < 256; i++) {
+ if (n.testBit(i)) {
+ r = add(r, G_TABLE[i]);
+ }
+ }
+ return r;
+ }
+
+}
\ No newline at end of file
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Point.java b/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Point.java
new file mode 100644
index 0000000..d8ee474
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Point.java
@@ -0,0 +1,35 @@
+package com.onlychain.signsdk.secp256k1;
+
+public final class Point {
+ public static final Point ZERO = new Point();
+
+ private final Fraction x, y;
+
+ public Fraction getX() {
+ return x;
+ }
+
+ public Fraction getY() {
+ return y;
+ }
+
+ private Point() {
+ x = null;
+ y = null;
+ }
+
+ public Point(Fraction x, Fraction y) {
+ if (x == null || y == null) throw new NullPointerException();
+ this.x = x;
+ this.y = y;
+ }
+
+ public boolean isZero() {
+ return x == null;
+ }
+
+ @Override
+ public String toString() {
+ return String.format("(%s, %s)", ModP.toString(ModP.toU256(x)), ModP.toString(ModP.toU256(y)));
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/PublicKey.java b/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/PublicKey.java
new file mode 100644
index 0000000..9af5358
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/PublicKey.java
@@ -0,0 +1,65 @@
+package com.onlychain.signsdk.secp256k1;
+
+import java.math.BigInteger;
+import java.util.Arrays;
+
+public final class PublicKey {
+ private BigInteger x, y;
+
+ public BigInteger getX() {
+ return x;
+ }
+
+ public BigInteger getY() {
+ return y;
+ }
+
+ public PublicKey(BigInteger x, BigInteger y) {
+ this.x = x;
+ this.y = y;
+ }
+
+ static final byte EVEN_PUBLIC_KEY = 2;
+ static final byte ODD_PUBLIC_KEY = 3;
+ static final byte FULL_PUBLIC_KEY = 4;
+
+ public byte[] serialize(boolean compressed) {
+ int len = compressed ? 33 : 65;
+ byte[] ret = new byte[len];
+ byte[] x = ModP.toByteArray(this.x);
+ System.arraycopy(x, 0, ret, 1, 32);
+ if (compressed) {
+ ret[0] = y.testBit(0) ? ODD_PUBLIC_KEY : EVEN_PUBLIC_KEY;
+ } else {
+ byte[] y = ModP.toByteArray(this.y);
+ System.arraycopy(y, 0, ret, 33, 32);
+ ret[0] = FULL_PUBLIC_KEY;
+ }
+ return ret;
+ }
+
+ public static PublicKey parse(byte[] publicKeyBytes) {
+ if (publicKeyBytes.length < 33) throw new InvalidPublicKeyException("长度太小");
+ BigInteger x = new BigInteger(1, Arrays.copyOfRange(publicKeyBytes, 1, 33));
+ if (publicKeyBytes[0] == EVEN_PUBLIC_KEY || publicKeyBytes[0] == ODD_PUBLIC_KEY) {
+ try {
+ BigInteger y = ModP.sqrt(ModP.add(ModP.pow(x, BigInteger.valueOf(3)), BigInteger.valueOf(7)));
+ if (y.testBit(0) != (publicKeyBytes[0] == ODD_PUBLIC_KEY)) {
+ y = ModP.neg(y);
+ }
+ return new PublicKey(x, y);
+ } catch (ArithmeticException e) {
+ throw new InvalidPublicKeyException("无效的公钥");
+ }
+ } else if (publicKeyBytes[0] == FULL_PUBLIC_KEY) {
+ if (publicKeyBytes.length < 65) throw new InvalidPublicKeyException("长度太小");
+ BigInteger y = new BigInteger(1, Arrays.copyOfRange(publicKeyBytes, 33, 65));
+ if (!ModP.add(ModP.pow(x, BigInteger.valueOf(3)), BigInteger.valueOf(7)).equals(ModP.square(y))) {
+ throw new InvalidPublicKeyException("无效的公钥");
+ }
+ return new PublicKey(x, y);
+ } else {
+ throw new InvalidPublicKeyException("不支持的公钥类型");
+ }
+ }
+}
\ No newline at end of file
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Secp256k1.java b/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Secp256k1.java
new file mode 100644
index 0000000..c8235f2
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Secp256k1.java
@@ -0,0 +1,59 @@
+package com.onlychain.signsdk.secp256k1;
+
+import java.math.BigInteger;
+import java.security.NoSuchAlgorithmException;
+import java.security.SecureRandom;
+
+public final class Secp256k1 {
+ private Secp256k1() {
+ }
+
+ static SecureRandom RNG;
+
+ static {
+ try {
+ RNG = SecureRandom.getInstance("SHA1PRNG");
+ } catch (NoSuchAlgorithmException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static byte[] createPrivateKey() {
+ while (true) {
+ BigInteger k = new BigInteger(256, RNG);
+ if (k.equals(BigInteger.ZERO) || k.compareTo(ModN.N) >= 0) continue;
+ return ModP.toByteArray(k);
+ }
+ }
+
+ public static PublicKey createPublicKey(byte[] privateKey) {
+ BigInteger k = ModP.byteArrayToU256(privateKey);
+ if (k.equals(BigInteger.ZERO) || k.compareTo(ModN.N) >= 0) throw new InvalidPrivateKeyException();
+ Point p = ModP.mul(ModP.G, k);
+ return new PublicKey(ModP.toU256(p.getX()), ModP.toU256(p.getY()));
+ }
+
+ public static Signature sign(byte[] privateKey, byte[] message) {
+ if (privateKey.length != 32) throw new InvalidPrivateKeyException("私钥长度必须是32字节");
+ if (message.length != 32) throw new InvalidMessageException();
+
+ BigInteger dA = ModN.byteArrayToU256(privateKey);
+ BigInteger m = ModN.byteArrayToU256(message);
+ byte[] tempPrivKey = createPrivateKey();
+ PublicKey tempPubKey = createPublicKey(tempPrivKey);
+ BigInteger k = ModN.byteArrayToU256(tempPrivKey);
+ BigInteger s = ModN.div(ModN.add(m, ModN.mul(dA, tempPubKey.getX())), k);
+ return new Signature(tempPubKey.getX(), s);
+ }
+
+ public static boolean verify(PublicKey publicKey, byte[] message, Signature signature) {
+ if (message.length != 32) throw new InvalidMessageException();
+
+ BigInteger m = ModN.byteArrayToU256(message);
+ BigInteger s_inv = ModN.inv(signature.getS());
+ BigInteger u1 = ModN.mul(s_inv, m);
+ BigInteger u2 = ModN.mul(s_inv, signature.getR());
+ Point p = ModP.add(ModP.mulG(u1), ModP.mul(new Point(new Fraction(publicKey.getX()), new Fraction(publicKey.getY())), u2));
+ return ModP.equal(p.getX(), new Fraction(signature.getR()));
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Signature.java b/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Signature.java
new file mode 100644
index 0000000..be95b81
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/secp256k1/Signature.java
@@ -0,0 +1,105 @@
+package com.onlychain.signsdk.secp256k1;
+
+import java.math.BigInteger;
+
+public final class Signature {
+ private BigInteger r, s;
+
+ public BigInteger getR() {
+ return r;
+ }
+
+ public BigInteger getS() {
+ return s;
+ }
+
+ public Signature(BigInteger r, BigInteger s) {
+ this.r = r;
+ this.s = s;
+ }
+
+ static final class ParseIndex {
+ public int value;
+ }
+
+ static int parseInt(byte[] bytes, ParseIndex index) {
+ if (index.value >= bytes.length) throw new InvalidSignatureException();
+ int len = bytes[index.value] & 0xff;
+ if (len < 128) {
+ index.value++;
+ if (index.value + len > bytes.length) throw new InvalidSignatureException();
+ return len;
+ }
+ int lenBytes = len ^ 0x80;
+ if (lenBytes > 4 || bytes.length - index.value < 1 + lenBytes) throw new InvalidSignatureException();
+ int dataLen = bytes[index.value + 1] & 0xff;
+ int dataOffset = index.value + 1 + dataLen;
+ for (int i = index.value + 2; i < dataOffset; i++) {
+ dataLen = (dataLen << 8) | (bytes[i] & 0xff);
+ }
+ if (bytes.length - index.value < 1 + lenBytes + dataOffset) throw new InvalidSignatureException();
+ index.value = dataOffset;
+ return dataLen;
+ }
+
+ static BigInteger parseU256(byte[] bytes, ParseIndex index) {
+ if (bytes[index.value++] != 2) throw new InvalidSignatureException();
+ int u256Len = parseInt(bytes, index);
+ byte[] buffer = new byte[32];
+ if (u256Len > 32) {
+ while (bytes[index.value] == 0) {
+ u256Len--;
+ index.value++;
+ }
+ if (u256Len > 32) throw new InvalidSignatureException();
+ }
+ System.arraycopy(bytes, index.value, buffer, 32 - u256Len, u256Len);
+ index.value += u256Len;
+ return new BigInteger(1, buffer);
+ }
+
+ public static Signature parse(byte[] signBytes) {
+ if (signBytes.length == 0) throw new InvalidSignatureException("长度太小");
+ ParseIndex i = new ParseIndex();
+ if (signBytes[i.value++] != 0x30) throw new InvalidSignatureException();
+ parseInt(signBytes, i);
+
+ BigInteger r = parseU256(signBytes, i);
+ BigInteger s = parseU256(signBytes, i);
+ return new Signature(r, s);
+ }
+
+ public byte[] serialize() {
+ byte[] R = ModP.toByteArray(r);
+ byte[] S = ModP.toByteArray(s);
+ int rlen = 33;
+ do {
+ if (R[33 - rlen] < 0) break;
+ rlen--;
+ } while (R[32 - rlen] == 0);
+ int slen = 33;
+ do {
+ if (S[33 - slen] < 0) break;
+ slen--;
+ } while (S[32 - slen] == 0);
+
+ byte[] buffer = new byte[6 + rlen + slen];
+ buffer[0] = 0x30;
+ buffer[1] = (byte)(4 + rlen + slen);
+ buffer[2] = 2;
+ buffer[3] = (byte)rlen;
+ if (rlen == 33) {
+ System.arraycopy(R, 0, buffer, 5, 32);
+ } else {
+ System.arraycopy(R, 32 - rlen, buffer, 4, rlen);
+ }
+ buffer[4 + rlen] = 2;
+ buffer[5 + rlen] = (byte)slen;
+ if (slen == 33) {
+ System.arraycopy(S, 0, buffer, 7 + rlen, 32);
+ } else {
+ System.arraycopy(S, 32 - slen, buffer, 6 + rlen, slen);
+ }
+ return buffer;
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/utils/Assertions.java b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Assertions.java
new file mode 100644
index 0000000..709045e
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Assertions.java
@@ -0,0 +1,16 @@
+package com.onlychain.signsdk.utils;
+
+public class Assertions {
+
+ /**
+ * Verify that the provided precondition holds true.
+ *
+ * @param assertionResult assertion value
+ * @param errorMessage error message if precondition failure
+ */
+ public static void verifyPrecondition(boolean assertionResult, String errorMessage) {
+ if (!assertionResult) {
+ throw new RuntimeException(errorMessage);
+ }
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/utils/Bytes.java b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Bytes.java
new file mode 100644
index 0000000..12aefad
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Bytes.java
@@ -0,0 +1,22 @@
+package com.onlychain.signsdk.utils;
+
+import java.util.Arrays;
+
+public class Bytes {
+
+ private Bytes() {}
+
+ public static byte[] trimLeadingBytes(byte[] bytes, byte b) {
+ int offset = 0;
+ for (; offset < bytes.length - 1; offset++) {
+ if (bytes[offset] != b) {
+ break;
+ }
+ }
+ return Arrays.copyOfRange(bytes, offset, bytes.length);
+ }
+
+ public static byte[] trimLeadingZeroes(byte[] bytes) {
+ return trimLeadingBytes(bytes, (byte) 0);
+ }
+}
\ No newline at end of file
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/utils/CheckUtils.java b/SignSdk/src/main/java/com/onlychain/signsdk/utils/CheckUtils.java
new file mode 100644
index 0000000..917664a
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/utils/CheckUtils.java
@@ -0,0 +1,26 @@
+package com.onlychain.signsdk.utils;
+
+/**
+ * 验证签名
+ */
+public class CheckUtils {
+
+ /**
+ * 检查是否属于OC合法地址
+ * @param input
+ * @return
+ */
+ public static boolean checkAddress(String input){
+ if(input.length()==42){
+ String head=input.substring(0,2).toLowerCase();
+ String body=input.substring(2,input.length()).toLowerCase();
+ String regex="^[A-Fa-f0-9]+$";
+ if(head.equals("oc")&&body.matches(regex))
+ return true;
+ }
+ return false;
+ }
+
+
+
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/utils/Leb128Utils.java b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Leb128Utils.java
new file mode 100644
index 0000000..c4ca54c
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Leb128Utils.java
@@ -0,0 +1,125 @@
+package com.onlychain.signsdk.utils;
+
+/**
+ * @James
+ * 对数值进行LEB128编码和解码
+ */
+public final class Leb128Utils {
+
+ private Leb128Utils() {
+ // This space intentionally left blank.
+ }
+
+
+ public static int unsignedLeb128Size(long value) {
+ // TODO: This could be much cleverer.
+
+ long remaining = value >>> 7;
+ int count = 0;
+
+ while (remaining != 0) {
+ value = remaining;
+ remaining >>>= 7;
+ count++;
+ }
+ return count + 1;
+ }
+
+
+ public static int signedLeb128Size(int value) {
+ int remaining = value >> 7;
+ int count = 0;
+ boolean hasMore = true;
+ int end = ((value & Integer.MIN_VALUE) == 0) ? 0 : -1;
+
+ while (hasMore) {
+ hasMore = (remaining != end)
+ || ((remaining & 1) != ((value >> 6) & 1));
+
+ value = remaining;
+ remaining >>= 7;
+ count++;
+ }
+
+ return count;
+ }
+
+
+
+ /**
+ * 根据长整型获取无符号LEB128编码
+ * @param value
+ * @return
+ */
+ public static String encodeUleb128(long value) {
+ byte[] buffer = new byte[unsignedLeb128Size(value)];
+ int bufferIndex=0;
+ long remaining = value >>> 7;
+ while (remaining != 0) {
+ buffer[bufferIndex] = (byte)((value & 0x7f) | 0x80);
+ bufferIndex++;
+ value = remaining;
+ remaining >>>= 7;
+ }
+ buffer[bufferIndex] = (byte)(value & 0x7f);
+ return OcMath.toHexStringNoPrefix(buffer);
+ }
+
+ /**
+ * 根据字符串获取无符号LEB128编码
+ * 输入值不超过long的最大值
+ * @param value
+ * @return
+ */
+ public static String encodeUleb128(String value) {
+ return encodeUleb128(Long.valueOf(value));
+ }
+
+
+ /**
+ *解码LEB128 支持64位
+ * @param input
+ * @return
+ */
+ public static long decodeUnsigned(byte[] input) {
+ long result = 0;
+ long shift = 0;
+ int i = 0;
+ while (true) {
+ long byteTemp= Long.valueOf(input[i++] & 0xfF);
+ result |= Long.valueOf((byteTemp & 0x7F) << shift);
+ if ((byteTemp & 0x80) == 0)
+ break;
+ shift += 7;
+ }
+ return result;
+ }
+
+ /**
+ * 校验是否到达LEB最末尾数
+ * @param hex
+ * @return true:已经到达leb末尾
+ * @throws Exception
+ */
+ public static boolean isLebEnd(String hex) {
+ if (hex.length()==2){
+ byte[] data= OcMath.hexStringToByteArray(hex);
+ int resultSig=((data[0]& 0xfF)& 0x80);
+ if(resultSig!=0)
+ return false;
+ else
+ return true;
+ }
+ return true;
+ }
+
+
+ /**
+ * 解码LEB128 支持64位
+ * @param input
+ * @return
+ */
+ public static long decodeUnsigned(String input) {
+ return decodeUnsigned(OcMath.hexStringToByteArray(input));
+ }
+}
\ No newline at end of file
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/utils/Numeric.java b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Numeric.java
new file mode 100644
index 0000000..0a8d61a
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Numeric.java
@@ -0,0 +1,227 @@
+package com.onlychain.signsdk.utils;
+
+
+import com.onlychain.signsdk.exceptions.MessageDecodingException;
+import com.onlychain.signsdk.exceptions.MessageEncodingException;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.util.Arrays;
+
+
+/**
+ * Message codec functions.
+ *
+ * Implementation as per https://github.com/ethereum/wiki/wiki/JSON-RPC#hex-value-encoding
+ */
+public final class Numeric {
+
+ private static final String HEX_PREFIX = "0x";
+
+ private Numeric() {
+ }
+
+ public static String encodeQuantity(BigInteger value) {
+ if (value.signum() != -1) {
+ return HEX_PREFIX + value.toString(16);
+ } else {
+ throw new MessageEncodingException("Negative values are not supported");
+ }
+ }
+
+ public static BigInteger decodeQuantity(String value) {
+ if (!isValidHexQuantity(value)) {
+ throw new MessageDecodingException("Value must be in format 0x[1-9]+[0-9]* or 0x0");
+ }
+ try {
+ return new BigInteger(value.substring(2), 16);
+ } catch (NumberFormatException e) {
+ throw new MessageDecodingException("Negative ", e);
+ }
+ }
+
+ private static boolean isValidHexQuantity(String value) {
+ if (value == null) {
+ return false;
+ }
+
+ if (value.length() < 3) {
+ return false;
+ }
+
+ if (!value.startsWith(HEX_PREFIX)) {
+ return false;
+ }
+
+ // If TestRpc resolves the following issue, we can reinstate this code
+ // https://github.com/ethereumjs/testrpc/issues/220
+ // if (value.length() > 3 && value.charAt(2) == '0') {
+ // return false;
+ // }
+
+ return true;
+ }
+
+ public static String cleanHexPrefix(String input) {
+ if (containsHexPrefix(input)) {
+ return input.substring(2);
+ } else {
+ return input;
+ }
+ }
+
+ public static String prependHexPrefix(String input) {
+ if (!containsHexPrefix(input)) {
+ return HEX_PREFIX + input;
+ } else {
+ return input;
+ }
+ }
+
+ public static boolean containsHexPrefix(String input) {
+ return input.length() > 1 && input.charAt(0) == '0' && input.charAt(1) == 'x';
+ }
+
+ public static BigInteger toBigInt(byte[] value, int offset, int length) {
+ return toBigInt((Arrays.copyOfRange(value, offset, offset + length)));
+ }
+
+ public static BigInteger toBigInt(byte[] value) {
+ return new BigInteger(1, value);
+ }
+
+ public static BigInteger toBigInt(String hexValue) {
+ String cleanValue = cleanHexPrefix(hexValue);
+ return toBigIntNoPrefix(cleanValue);
+ }
+
+ public static BigInteger toBigIntNoPrefix(String hexValue) {
+ return new BigInteger(hexValue, 16);
+ }
+
+ public static String toHexStringWithPrefix(BigInteger value) {
+ return HEX_PREFIX + value.toString(16);
+ }
+
+ public static String toHexStringNoPrefix(BigInteger value) {
+ return value.toString(16);
+ }
+
+ public static String toHexStringNoPrefix(byte[] input) {
+ return toHexString(input, 0, input.length, false);
+ }
+
+ public static String toHexStringWithPrefixZeroPadded(BigInteger value, int size) {
+ return toHexStringZeroPadded(value, size, true);
+ }
+
+ public static String toHexStringWithPrefixSafe(BigInteger value) {
+ String result = toHexStringNoPrefix(value);
+ if (result.length() < 2) {
+ result = Strings.zeros(1) + result;
+ }
+ return HEX_PREFIX + result;
+ }
+
+ public static String toHexStringNoPrefixZeroPadded(BigInteger value, int size) {
+ return toHexStringZeroPadded(value, size, false);
+ }
+
+ private static String toHexStringZeroPadded(BigInteger value, int size, boolean withPrefix) {
+ String result = toHexStringNoPrefix(value);
+
+ int length = result.length();
+ if (length > size) {
+ throw new UnsupportedOperationException(
+ "Value " + result + "is larger then length " + size);
+ } else if (value.signum() < 0) {
+ throw new UnsupportedOperationException("Value cannot be negative");
+ }
+
+ if (length < size) {
+ result = Strings.zeros(size - length) + result;
+ }
+
+ if (withPrefix) {
+ return HEX_PREFIX + result;
+ } else {
+ return result;
+ }
+ }
+
+ public static byte[] toBytesPadded(BigInteger value, int length) {
+ byte[] result = new byte[length];
+ byte[] bytes = value.toByteArray();
+
+ int bytesLength;
+ int srcOffset;
+ if (bytes[0] == 0) {
+ bytesLength = bytes.length - 1;
+ srcOffset = 1;
+ } else {
+ bytesLength = bytes.length;
+ srcOffset = 0;
+ }
+
+ if (bytesLength > length) {
+ throw new RuntimeException("Input is too large to put in byte array of size " + length);
+ }
+
+ int destOffset = length - bytesLength;
+ System.arraycopy(bytes, srcOffset, result, destOffset, bytesLength);
+ return result;
+ }
+
+ public static byte[] hexStringToByteArray(String input) {
+ String cleanInput = cleanHexPrefix(input);
+
+ int len = cleanInput.length();
+
+ if (len == 0) {
+ return new byte[] {};
+ }
+
+ byte[] data;
+ int startIdx;
+ if (len % 2 != 0) {
+ data = new byte[(len / 2) + 1];
+ data[0] = (byte) Character.digit(cleanInput.charAt(0), 16);
+ startIdx = 1;
+ } else {
+ data = new byte[len / 2];
+ startIdx = 0;
+ }
+
+ for (int i = startIdx; i < len; i += 2) {
+ data[(i + 1) / 2] = (byte) ((Character.digit(cleanInput.charAt(i), 16) << 4)
+ + Character.digit(cleanInput.charAt(i + 1), 16));
+ }
+ return data;
+ }
+
+ public static String toHexString(byte[] input, int offset, int length, boolean withPrefix) {
+ StringBuilder stringBuilder = new StringBuilder();
+ if (withPrefix) {
+ stringBuilder.append("0x");
+ }
+ for (int i = offset; i < offset + length; i++) {
+ stringBuilder.append(String.format("%02x", input[i] & 0xFF));
+ }
+
+ return stringBuilder.toString();
+ }
+
+ public static String toHexString(byte[] input) {
+ return toHexString(input, 0, input.length, true);
+ }
+
+ public static byte asByte(int m, int n) {
+ return (byte) ((m << 4) | n);
+ }
+
+ public static boolean isIntegerValue(BigDecimal value) {
+ return value.signum() == 0
+ || value.scale() <= 0
+ || value.stripTrailingZeros().scale() <= 0;
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/utils/OcMath.java b/SignSdk/src/main/java/com/onlychain/signsdk/utils/OcMath.java
new file mode 100644
index 0000000..4dabfa2
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/utils/OcMath.java
@@ -0,0 +1,228 @@
+package com.onlychain.signsdk.utils;
+
+
+
+import com.onlychain.signsdk.exceptions.MessageDecodingException;
+import com.onlychain.signsdk.exceptions.MessageEncodingException;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.nio.charset.StandardCharsets;
+import java.util.Arrays;
+
+public final class OcMath {
+
+ private static final String HEX_PREFIX = "0x";
+
+ private OcMath() {
+ }
+
+
+ public static String hexStringToText(String input) {
+ return new String(OcMath.hexStringToByteArray(input), StandardCharsets.UTF_8);
+ }
+
+ public static String encodeQuantity(BigInteger value) {
+ if (value.signum() != -1) {
+ return HEX_PREFIX + value.toString(16);
+ } else {
+ throw new MessageEncodingException("Negative values are not supported");
+ }
+ }
+
+ public static BigInteger decodeQuantity(String value) {
+ if (!isValidHexQuantity(value)) {
+ throw new MessageDecodingException("Value must be in format 0x[1-9]+[0-9]* or 0x0");
+ }
+ try {
+ return new BigInteger(value.substring(2), 16);
+ } catch (NumberFormatException e) {
+ throw new MessageDecodingException("Negative ", e);
+ }
+ }
+
+ private static boolean isValidHexQuantity(String value) {
+ if (value == null) {
+ return false;
+ }
+
+ if (value.length() < 3) {
+ return false;
+ }
+
+ if (!value.startsWith(HEX_PREFIX)) {
+ return false;
+ }
+
+ // If TestRpc resolves the following issue, we can reinstate this code
+ // https://github.com/ethereumjs/testrpc/issues/220
+ // if (value.length() > 3 && value.charAt(2) == '0') {
+ // return false;
+ // }
+
+ return true;
+ }
+
+ public static String cleanHexPrefix(String input) {
+ if (containsHexPrefix(input)) {
+ return input.substring(2);
+ } else {
+ return input;
+ }
+ }
+
+ public static String prependHexPrefix(String input) {
+ if (!containsHexPrefix(input)) {
+ return HEX_PREFIX + input;
+ } else {
+ return input;
+ }
+ }
+
+ public static boolean containsHexPrefix(String input) {
+ return input.length() > 1 && input.charAt(0) == '0' && input.charAt(1) == 'x';
+ }
+
+ public static BigInteger toBigInt(byte[] value, int offset, int length) {
+ return toBigInt((Arrays.copyOfRange(value, offset, offset + length)));
+ }
+
+ public static BigInteger toBigInt(byte[] value) {
+ return new BigInteger(1, value);
+ }
+
+ public static BigInteger toBigInt(String hexValue) {
+ String cleanValue = cleanHexPrefix(hexValue);
+ return toBigIntNoPrefix(cleanValue);
+ }
+
+ public static BigInteger toBigIntNoPrefix(String hexValue) {
+ return new BigInteger(hexValue, 16);
+ }
+
+ public static String toHexStringWithPrefix(BigInteger value) {
+ return HEX_PREFIX + value.toString(16);
+ }
+
+ public static String toHexStringNoPrefix(BigInteger value) {
+ return value.toString(16);
+ }
+
+ public static String toHexStringNoPrefix(byte[] input) {
+ return toHexString(input, 0, input.length, false);
+ }
+
+ public static String toHexStringWithPrefixZeroPadded(BigInteger value, int size) {
+ return toHexStringZeroPadded(value, size, true);
+ }
+
+ public static String toHexStringWithPrefixSafe(BigInteger value) {
+ String result = toHexStringNoPrefix(value);
+ if (result.length() < 2) {
+ result = Strings.zeros(1) + result;
+ }
+ return HEX_PREFIX + result;
+ }
+
+ public static String toHexStringNoPrefixZeroPadded(BigInteger value, int size) {
+ return toHexStringZeroPadded(value, size, false);
+ }
+
+ private static String toHexStringZeroPadded(BigInteger value, int size, boolean withPrefix) {
+ String result = toHexStringNoPrefix(value);
+
+ int length = result.length();
+ if (length > size) {
+ throw new UnsupportedOperationException(
+ "Value " + result + "is larger then length " + size);
+ } else if (value.signum() < 0) {
+ throw new UnsupportedOperationException("Value cannot be negative");
+ }
+
+ if (length < size) {
+ result = Strings.zeros(size - length) + result;
+ }
+
+ if (withPrefix) {
+ return HEX_PREFIX + result;
+ } else {
+ return result;
+ }
+ }
+
+ public static byte[] toBytesPadded(BigInteger value, int length) {
+ byte[] result = new byte[length];
+ byte[] bytes = value.toByteArray();
+
+ int bytesLength;
+ int srcOffset;
+ if (bytes[0] == 0) {
+ bytesLength = bytes.length - 1;
+ srcOffset = 1;
+ } else {
+ bytesLength = bytes.length;
+ srcOffset = 0;
+ }
+
+ if (bytesLength > length) {
+ throw new RuntimeException("Input is too large to put in byte array of size " + length);
+ }
+
+ int destOffset = length - bytesLength;
+ System.arraycopy(bytes, srcOffset, result, destOffset, bytesLength);
+ return result;
+ }
+
+ public static byte[] hexStringToByteArray(String input) {
+ String cleanInput = cleanHexPrefix(input);
+
+ int len = cleanInput.length();
+
+ if (len == 0) {
+ return new byte[] {};
+ }
+
+ byte[] data;
+ int startIdx;
+ if (len % 2 != 0) {
+ data = new byte[(len / 2) + 1];
+ data[0] = (byte) Character.digit(cleanInput.charAt(0), 16);
+ startIdx = 1;
+ } else {
+ data = new byte[len / 2];
+ startIdx = 0;
+ }
+
+ for (int i = startIdx; i < len; i += 2) {
+ data[(i + 1) / 2] = (byte) ((Character.digit(cleanInput.charAt(i), 16) << 4)
+ + Character.digit(cleanInput.charAt(i + 1), 16));
+ }
+ return data;
+ }
+
+ public static String toHexString(byte[] input, int offset, int length, boolean withPrefix) {
+ StringBuilder stringBuilder = new StringBuilder();
+ if (withPrefix) {
+ stringBuilder.append("0x");
+ }
+ for (int i = offset; i < offset + length; i++) {
+ stringBuilder.append(String.format("%02x", input[i] & 0xFF));
+ }
+
+ return stringBuilder.toString();
+ }
+
+ public static String toHexString(byte[] input) {
+ return toHexString(input, 0, input.length, true);
+ }
+
+ public static byte asByte(int m, int n) {
+ return (byte) ((m << 4) | n);
+ }
+
+ public static boolean isIntegerValue(BigDecimal value) {
+ return value.signum() == 0
+ || value.scale() <= 0
+ || value.stripTrailingZeros().scale() <= 0;
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/utils/Strings.java b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Strings.java
new file mode 100644
index 0000000..e27aba8
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/utils/Strings.java
@@ -0,0 +1,57 @@
+package com.onlychain.signsdk.utils;
+
+import java.util.List;
+
+/**
+ * String utility functions.
+ */
+public class Strings {
+
+ private Strings() {}
+
+ public static String toCsv(List src) {
+ return join(src, ", ");
+ }
+
+ public static String join(List src, String delimiter) {
+ if (src != null) {
+ StringBuilder builder = new StringBuilder();
+ if (!src.isEmpty()) {
+ builder.append(src.get(0));
+ }
+ for (int i = 1; i < src.size(); i++) {
+ builder.append(delimiter).append(src.get(i));
+ }
+ return builder.toString();
+ }
+ return null;
+ }
+
+ public static String capitaliseFirstLetter(String string) {
+ if (string == null || string.length() == 0) {
+ return string;
+ } else {
+ return string.substring(0, 1).toUpperCase() + string.substring(1);
+ }
+ }
+
+ public static String lowercaseFirstLetter(String string) {
+ if (string == null || string.length() == 0) {
+ return string;
+ } else {
+ return string.substring(0, 1).toLowerCase() + string.substring(1);
+ }
+ }
+
+ public static String zeros(int n) {
+ return repeat('0', n);
+ }
+
+ public static String repeat(char value, int n) {
+ return new String(new char[n]).replace("\0", String.valueOf(value));
+ }
+
+ public static boolean isEmpty(String s) {
+ return s == null || s.length() == 0;
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/utils/WalletUtils.java b/SignSdk/src/main/java/com/onlychain/signsdk/utils/WalletUtils.java
new file mode 100644
index 0000000..7e91674
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/utils/WalletUtils.java
@@ -0,0 +1,71 @@
+package com.onlychain.signsdk.utils;
+
+
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.crypto.Hash;
+import com.onlychain.signsdk.crypto.RIPEMD160Digest;
+import com.onlychain.signsdk.secp256k1.Secp256k1;
+
+public class WalletUtils {
+
+ /**
+ * 根据私钥生成账户信息
+ * @return
+ */
+ public static AccountBean createAccount(){
+ return createAccount(Secp256k1.createPrivateKey());
+ }
+
+ /**
+ * 随机创建一组私钥、公钥、地址
+ * @return
+ */
+ public static AccountBean createAccount(byte[] privateKey){
+ AccountBean mAccountBean=new AccountBean();
+ try {
+ byte[] publicKey = Secp256k1.createPublicKey(privateKey).serialize(true);
+ mAccountBean.setPrivateKey(OcMath.toHexStringNoPrefix(privateKey));
+ mAccountBean.setPublicKey(OcMath.toHexStringNoPrefix(publicKey));
+ mAccountBean.setAddress(createAddress(publicKey));
+ }catch (Exception e){
+
+ }
+ return mAccountBean;
+ }
+
+
+ /**
+ * 获取整交易的TxId
+ * @param input
+ * @return
+ */
+ public static String getTxId(byte[] input){
+ return OcMath.toHexStringNoPrefix(Hash.sha256(Hash.sha256(input)));
+ }
+
+ /**
+ * 获取整交易的TxId
+ * @param input
+ * @return
+ */
+ public static String getTxId(String input){
+ return OcMath.toHexStringNoPrefix(Hash.sha256(Hash.sha256(OcMath.hexStringToByteArray(input))));
+ }
+
+ public static byte[] getTxIdBin(String input){
+ return Hash.sha256(Hash.sha256(OcMath.hexStringToByteArray(input)));
+ }
+
+ public static byte[] getTxIdBin(byte[] input){
+ return Hash.sha256(Hash.sha256(input));
+ }
+
+ public static String createAddress(byte[] publicKey) {
+ byte[] sha256 = Hash.sha256(publicKey);
+ RIPEMD160Digest digest = new RIPEMD160Digest();
+ digest.update(sha256, 0, sha256.length);
+ byte[] out = new byte[digest.getDigestSize()];
+ digest.doFinal(out, 0);
+ return OcMath.toHexStringNoPrefix(out).toLowerCase();
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/base/ApiConfig.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/base/ApiConfig.java
new file mode 100644
index 0000000..e175d3a
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/base/ApiConfig.java
@@ -0,0 +1,87 @@
+package com.onlychain.signsdk.wallet.base;
+
+import java.util.LinkedHashMap;
+
+public class ApiConfig {
+ public static String API_selectPurse;
+ public static String API_receiveAction;
+ public static String API_getSystemInfo;
+ public static String API_queryAction;
+ public static String API_queryBlock;
+ public static String IPs;
+
+ private static ApiConfig INSTANCE = null;
+ public static ApiConfig getInstance() {
+ if(INSTANCE == null){
+ INSTANCE = new ApiConfig();
+ }
+ return INSTANCE;
+ }
+
+
+ /**
+ * 初始化
+ * @param IP
+ */
+ public static ApiConfig init(String IP) {
+ IPs=IP;
+ //获取钱包资产列表
+ API_selectPurse= IP+"/Trading/selectPurse";
+ //提交交易
+ API_receiveAction= IP+"/Action/receiveAction";
+ //获取系统时间、高度、轮次、轮次时间
+ API_getSystemInfo= IP+"/Node/getSystemInfo";
+ //查询某一个区块
+ API_queryBlock= IP+"/Block/queryBlock";
+ //查询某一个Txid的Action
+ API_queryAction= IP+"/Action/queryAction";
+ return getInstance();
+ }
+
+ //获取钱包资产列表
+ public String getSystemInfoUrl(){
+ return IPs+"/Node/getSystemInfo";
+ }
+
+ //获取钱包资产列表
+ public LinkedHashMap selectPurseUrl(String address){
+ return selectPurse(address);
+ }
+ public static LinkedHashMap selectPurse(String address){
+ LinkedHashMap map=new LinkedHashMap<>();
+ map.put("address",address);
+ return map;
+ }
+
+ //提交交易
+ public LinkedHashMap receiveActionUrl(String message){
+ return receiveAction(message);
+ }
+ public static LinkedHashMap receiveAction(String message){
+ LinkedHashMap map=new LinkedHashMap<>();
+ map.put("message",message);
+ return map;
+ }
+
+ //查询某一个区块
+ public LinkedHashMap queryBlockUrl(String height){
+ return queryBlock(height);
+ }
+ public static LinkedHashMap queryBlock(String height){
+ LinkedHashMap map=new LinkedHashMap<>();
+ map.put("height",Integer.valueOf(height));
+ return map;
+ }
+
+ //查询某一个Txid的Action
+ public LinkedHashMap queryActionUrl(String txId){
+ return queryAction(txId);
+ }
+ public static LinkedHashMap queryAction(String txId){
+ LinkedHashMap map=new LinkedHashMap<>();
+ map.put("txId",txId);
+ return map;
+ }
+
+
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/iface/ImpGetAction.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/iface/ImpGetAction.java
new file mode 100644
index 0000000..938102e
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/iface/ImpGetAction.java
@@ -0,0 +1,6 @@
+package com.onlychain.signsdk.wallet.iface;
+
+public interface ImpGetAction {
+
+ public void receive(String actionStr);
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/iface/ImpQueryAction.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/iface/ImpQueryAction.java
new file mode 100644
index 0000000..c8b9f2e
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/iface/ImpQueryAction.java
@@ -0,0 +1,9 @@
+package com.onlychain.signsdk.wallet.iface;
+
+public interface ImpQueryAction {
+
+
+ public void inChainSuceess(StringBuffer json);
+ public void inChainFail();
+
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/GetVinCoin.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/GetVinCoin.java
new file mode 100644
index 0000000..fe6c632
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/GetVinCoin.java
@@ -0,0 +1,234 @@
+package com.onlychain.signsdk.wallet.tranfer;
+
+import com.alibaba.fastjson.JSON;
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.bean.PurseBean;
+import com.onlychain.signsdk.net.Request;
+import com.onlychain.signsdk.utils.CheckUtils;
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+
+public abstract class GetVinCoin {
+
+public abstract void walletCoinList(StringBuffer json);
+public abstract void getCoinFail(Exception e);
+ //代表被开通权益的资产
+ public static final int TYPE_4_FOR_INTEREST=4;
+ //代表可用于普通转账的资产
+ public static final int TYPE_1_FOR_TRANSFER=1;
+ //计算单位基数
+ public static final String BASE_NUMBER="100000000";
+
+ private StringBuffer jsons;
+ public GetVinCoin(AccountBean mAccountBean) {
+ if (CheckUtils.checkAddress(mAccountBean.getAddress()))
+ {
+ new Request(ApiConfig.API_selectPurse, ApiConfig.selectPurse(mAccountBean.getAddressNoPrefix())) {
+ @Override
+ public void success(StringBuffer json) {
+ jsons=json;
+ walletCoinList(json);
+ }
+
+ @Override
+ public void fail(Exception e) {
+ getCoinFail(e);
+ }
+ };
+ }else {
+ getCoinFail(new Exception("请输入正确的地址 = oc+40位16进制chars"));
+ }
+ }
+ public GetVinCoin(String address) {
+ if (CheckUtils.checkAddress(address))
+ {
+ new Request(ApiConfig.API_selectPurse, ApiConfig.selectPurse(address.split("oc")[1])) {
+ @Override
+ public void success(StringBuffer json) {
+ jsons=json;
+ walletCoinList(json);
+ }
+
+ @Override
+ public void fail(Exception e) {
+ getCoinFail(e);
+ }
+ };
+ }else {
+ getCoinFail(new Exception("请输入正确的地址 = oc+40位16进制chars"));
+ }
+ }
+
+ /**
+ * 获取所有零钱列表
+ * @return
+ */
+ public List getCoinList(){
+ return JSON.parseObject(jsons.toString(), PurseBean.class).getRecord();
+ }
+ public List getCoinList(StringBuffer jsons){
+ return JSON.parseObject(jsons.toString(), PurseBean.class).getRecord();
+ }
+ /**
+ * 根据类型获取零钱列表
+ * @param type
+ * @return
+ */
+ public List getCoinList(int type){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList())
+ if (coin.getActionType()==type)
+ coinList.add(coin);
+ return coinList;
+ }
+ public List getCoinList(List coinsList,int type){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: coinsList)
+ if (coin.getActionType()==type)
+ coinList.add(coin);
+ return coinList;
+ }
+ public List getCoinList(StringBuffer jsons,int type){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList(jsons))
+ if (coin.getActionType()==type)
+ coinList.add(coin);
+ return coinList;
+ }
+ /**
+ * 根据是否小于指定高度获取指定零钱,比如获取已解锁零钱
+ * @param height
+ * @return
+ */
+ public List getCoinListForHeight(long height){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList(TYPE_1_FOR_TRANSFER))
+ if (coin.getLockTime() < height)
+ coinList.add(coin);
+ return coinList;
+ }
+ public List getCoinListForHeight(StringBuffer json,long height){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList(json,TYPE_1_FOR_TRANSFER))
+ if (coin.getLockTime() < height)
+ coinList.add(coin);
+ return coinList;
+ }
+
+ public List getCoinListForLock(long height){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList(TYPE_1_FOR_TRANSFER))
+ if (coin.getLockTime() >= height)
+ coinList.add(coin);
+ return coinList;
+ }
+ /**
+ * 获取指定金额范围内的可用零钱列表
+ * @param startValue
+ * @param endValue
+ * @return
+ */
+ public List getCoinListByRange(String startValue,String endValue){
+ List coinList=new ArrayList<>();
+
+ BigDecimal startDecimal=new BigDecimal(startValue);
+ BigDecimal endDecimal=new BigDecimal(endValue);
+ startDecimal=startDecimal.multiply(new BigDecimal(BASE_NUMBER));
+ endDecimal=endDecimal.multiply(new BigDecimal(BASE_NUMBER));
+ for (PurseBean.RecordBean coin : getCoinList(TYPE_1_FOR_TRANSFER))
+ {
+ BigDecimal valueDecimal= new BigDecimal(coin.getValue());
+ int startFlag =valueDecimal.compareTo(startDecimal);
+ int endFlag = valueDecimal.compareTo(endDecimal);
+ if (startFlag>-1 && endFlag<1)
+ coinList.add(coin);
+ }
+
+ return coinList;
+ }
+
+ /**
+ * 获取最适合开通权益的零钱
+ * @return
+ */
+ public PurseBean.RecordBean getCoinForInterest(){
+ return getCoinForMin("100","120");
+ }
+
+ /**
+ * 自定义获取指定范围内的一笔最小零钱
+ * @param startValue
+ * @param endValue
+ * @return
+ */
+ public PurseBean.RecordBean getCoinForMin(String startValue,String endValue){
+ List getCoinListByRange = getCoinListByRange(startValue,endValue);
+ List bigDecimal = new ArrayList();
+ for (PurseBean.RecordBean coin : getCoinListByRange)
+ bigDecimal.add(new BigDecimal(coin.getValue()));
+ for (PurseBean.RecordBean coin : getCoinListByRange)
+ if (coin.getValue() == Float.valueOf(Collections.min(bigDecimal).toString()))
+ return coin;
+ return new PurseBean.RecordBean();
+ }
+
+ /**
+ * 自定义获取指定范围内的一笔最大零钱
+ * @param startValue
+ * @param endValue
+ * @return
+ */
+ public PurseBean.RecordBean getCoinForMax(String startValue,String endValue){
+ List getCoinListByRange = getCoinListByRange(startValue,endValue);
+ List bigDecimal = new ArrayList();
+ for (PurseBean.RecordBean coin : getCoinListByRange)
+ bigDecimal.add(new BigDecimal(coin.getValue()));
+ for (PurseBean.RecordBean coin : getCoinListByRange)
+ if (coin.getValue() == Float.valueOf(Collections.max(bigDecimal).toString()))
+ return coin;
+ return new PurseBean.RecordBean();
+ }
+
+ /**
+ * 获取余额,包含可用和不可用
+ * @return
+ */
+ public BigDecimal getBalance(){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : getCoinList())
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum.divide(new BigDecimal(BASE_NUMBER));
+ }
+
+ /**
+ * 根据类型获取余额
+ * @param type
+ * @return
+ */
+ public BigDecimal getBalance(int type){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : getCoinList(type))
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum.divide(new BigDecimal(BASE_NUMBER));
+ }
+
+ public BigDecimal getBalance(List coins){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : coins)
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum.divide(new BigDecimal(BASE_NUMBER));
+ }
+
+
+ public BigDecimal getBalanceLong(List coins){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : coins)
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum;
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/GetVinCoinLocal.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/GetVinCoinLocal.java
new file mode 100644
index 0000000..f3ec3df
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/GetVinCoinLocal.java
@@ -0,0 +1,198 @@
+package com.onlychain.signsdk.wallet.tranfer;
+
+import com.alibaba.fastjson.JSON;
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.bean.PurseBean;
+import com.onlychain.signsdk.net.Request;
+import com.onlychain.signsdk.utils.CheckUtils;
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+
+public class GetVinCoinLocal {
+
+ //代表被开通权益的资产
+ public static final int TYPE_4_FOR_INTEREST=4;
+ //代表可用于普通转账的资产
+ public static final int TYPE_1_FOR_TRANSFER=1;
+ //计算单位基数
+ public static final String BASE_NUMBER="100000000";
+
+ private StringBuffer jsons;
+ public GetVinCoinLocal(StringBuffer jsons) {
+ this.jsons=jsons;
+ }
+
+
+ /**
+ * 获取所有零钱列表
+ * @return
+ */
+ public List getCoinList(){
+ return JSON.parseObject(jsons.toString(), PurseBean.class).getRecord();
+ }
+ public List getCoinList(StringBuffer jsons){
+ return JSON.parseObject(jsons.toString(), PurseBean.class).getRecord();
+ }
+ /**
+ * 根据类型获取零钱列表
+ * @param type
+ * @return
+ */
+ public List getCoinList(int type){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList())
+ if (coin.getActionType()==type)
+ coinList.add(coin);
+ return coinList;
+ }
+ public List getCoinList(List coinsList,int type){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: coinsList)
+ if (coin.getActionType()==type)
+ coinList.add(coin);
+ return coinList;
+ }
+ public List getCoinList(StringBuffer jsons,int type){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList(jsons))
+ if (coin.getActionType()==type)
+ coinList.add(coin);
+ return coinList;
+ }
+ /**
+ * 根据是否小于指定高度获取指定零钱,比如获取已解锁零钱
+ * @param height
+ * @return
+ */
+ public List getCoinListForHeight(long height){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList(TYPE_1_FOR_TRANSFER))
+ if (coin.getLockTime() < height)
+ coinList.add(coin);
+ return coinList;
+ }
+ public List getCoinListForHeight(StringBuffer json,long height){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList(json,TYPE_1_FOR_TRANSFER))
+ if (coin.getLockTime() < height)
+ coinList.add(coin);
+ return coinList;
+ }
+
+ public List getCoinListForLock(long height){
+ List coinList=new ArrayList<>();
+ for (PurseBean.RecordBean coin: getCoinList(TYPE_1_FOR_TRANSFER))
+ if (coin.getLockTime() >= height)
+ coinList.add(coin);
+ return coinList;
+ }
+ /**
+ * 获取指定金额范围内的可用零钱列表
+ * @param startValue
+ * @param endValue
+ * @return
+ */
+ public List getCoinListByRange(String startValue,String endValue){
+ List coinList=new ArrayList<>();
+
+ BigDecimal startDecimal=new BigDecimal(startValue);
+ BigDecimal endDecimal=new BigDecimal(endValue);
+ startDecimal=startDecimal.multiply(new BigDecimal(BASE_NUMBER));
+ endDecimal=endDecimal.multiply(new BigDecimal(BASE_NUMBER));
+ for (PurseBean.RecordBean coin : getCoinList(TYPE_1_FOR_TRANSFER))
+ {
+ BigDecimal valueDecimal= new BigDecimal(coin.getValue());
+ int startFlag =valueDecimal.compareTo(startDecimal);
+ int endFlag = valueDecimal.compareTo(endDecimal);
+ if (startFlag>-1 && endFlag<1)
+ coinList.add(coin);
+ }
+
+ return coinList;
+ }
+
+ /**
+ * 获取最适合开通权益的零钱
+ * @return
+ */
+ public PurseBean.RecordBean getCoinForInterest(){
+ return getCoinForMin("100","120");
+ }
+
+ /**
+ * 自定义获取指定范围内的一笔最小零钱
+ * @param startValue
+ * @param endValue
+ * @return
+ */
+ public PurseBean.RecordBean getCoinForMin(String startValue,String endValue){
+ List getCoinListByRange = getCoinListByRange(startValue,endValue);
+ List bigDecimal = new ArrayList();
+ for (PurseBean.RecordBean coin : getCoinListByRange)
+ bigDecimal.add(new BigDecimal(coin.getValue()));
+ for (PurseBean.RecordBean coin : getCoinListByRange)
+ if (coin.getValue() == Float.valueOf(Collections.min(bigDecimal).toString()))
+ return coin;
+ return new PurseBean.RecordBean();
+ }
+
+ /**
+ * 自定义获取指定范围内的一笔最大零钱
+ * @param startValue
+ * @param endValue
+ * @return
+ */
+ public PurseBean.RecordBean getCoinForMax(String startValue,String endValue){
+ List getCoinListByRange = getCoinListByRange(startValue,endValue);
+ List bigDecimal = new ArrayList();
+ for (PurseBean.RecordBean coin : getCoinListByRange)
+ bigDecimal.add(new BigDecimal(coin.getValue()));
+ for (PurseBean.RecordBean coin : getCoinListByRange)
+ if (coin.getValue() == Float.valueOf(Collections.max(bigDecimal).toString()))
+ return coin;
+ return new PurseBean.RecordBean();
+ }
+
+ /**
+ * 获取余额,包含可用和不可用
+ * @return
+ */
+ public BigDecimal getBalance(){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : getCoinList())
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum.divide(new BigDecimal(BASE_NUMBER));
+ }
+
+ /**
+ * 根据类型获取余额
+ * @param type
+ * @return
+ */
+ public BigDecimal getBalance(int type){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : getCoinList(type))
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum.divide(new BigDecimal(BASE_NUMBER));
+ }
+
+ public BigDecimal getBalance(List coins){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : coins)
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum.divide(new BigDecimal(BASE_NUMBER));
+ }
+
+
+ public BigDecimal getBalanceLong(List coins){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : coins)
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum;
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/MakeAction.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/MakeAction.java
new file mode 100644
index 0000000..4e17c8c
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/MakeAction.java
@@ -0,0 +1,96 @@
+package com.onlychain.signsdk.wallet.tranfer;
+
+
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.bean.BaseActionBean;
+import com.onlychain.signsdk.bean.HeadBean;
+import com.onlychain.signsdk.bean.OutBean;
+import com.onlychain.signsdk.bean.PurseBean;
+import com.onlychain.signsdk.crypto.Hash;
+import com.onlychain.signsdk.secp256k1.Secp256k1;
+import com.onlychain.signsdk.utils.Leb128Utils;
+import com.onlychain.signsdk.utils.OcMath;
+import com.onlychain.signsdk.utils.WalletUtils;
+
+import java.math.BigInteger;
+import java.util.List;
+
+public class MakeAction {
+ AccountBean mAccountBean;
+ List coinList;
+ List outList;
+ int actionType=1;
+ long lockHeight=0;
+
+ public MakeAction(AccountBean mAccountBean,int actionType,List coinList, List outList) {
+ this.mAccountBean = mAccountBean;
+ this.actionType=actionType;
+ this.coinList = coinList;
+ this.outList=outList;
+ this.lockHeight=-1;
+ }
+
+ public MakeAction(AccountBean mAccountBean,int actionType,List coinList, List outList,long lockHeight) {
+ this.mAccountBean = mAccountBean;
+ this.actionType=actionType;
+ this.coinList = coinList;
+ this.outList=outList;
+ this.lockHeight=lockHeight;
+ }
+
+
+ /**
+ * 普通交易
+ * @return
+ */
+ public BaseActionBean createAction(String height){
+ HeadBean head=new HeadBean(actionType,setVInBody()+setVOutBody());
+ HeadBean.EndBean mEndBean = new HeadBean.EndBean(height,mAccountBean.getPublicKey(),head.toString());
+ if(actionType==4)
+ mEndBean.setLockTimeAdd1Year(height);
+
+ if(actionType==1)
+ if (lockHeight>0)
+ mEndBean.setLockTimeForCoin(lockHeight);
+
+ String result=mEndBean.getResult();
+ String sigStr = OcMath.toHexStringNoPrefix(Secp256k1.sign(mAccountBean.getPrivateKeyBin(), WalletUtils.getTxIdBin(result)).serialize());
+ BaseActionBean mBaseActionBean=new BaseActionBean();
+ mBaseActionBean.setMessage(result);
+ mBaseActionBean.setSignStr(sigStr);
+// mBaseActionBean.setTxid(WalletUtils.getTxId(result));
+ return mBaseActionBean;
+ }
+
+
+ private String setVInBody(){
+ StringBuffer result=new StringBuffer();
+ //LEB128 输入笔数
+ String number= Leb128Utils.encodeUleb128(coinList.size());
+ for(PurseBean.RecordBean coin:coinList)
+ {
+// String txN=Leb128Utils.encodeUleb128(coin.getN());
+ String txN=OcMath.toHexStringNoPrefixZeroPadded(new BigInteger(String.valueOf(coin.getN())),2);
+ String scriptContent = coin.getTxId()+txN+Script.getLockScript(mAccountBean.getAddressNoPrefix());
+// System.out.println("text--------------"+scriptContent);
+ scriptContent= Script.vInScript(mAccountBean, Hash.sha256(Hash.sha256(OcMath.hexStringToByteArray(scriptContent))));
+ result = result.append(coin.getTxId()).append(txN).append(scriptContent);
+ }
+ return number+result.toString();
+ }
+
+
+ private String setVOutBody(){
+ StringBuffer result=new StringBuffer();
+ //LEB128 输出笔数
+ String number= Leb128Utils.encodeUleb128(outList.size());
+ for(OutBean out:outList)
+ {
+ result = result.append(OcMath.toHexStringNoPrefixZeroPadded(new BigInteger(String.valueOf(out.getValue())),16)).append(Script.vOutScript(out.getAddress()));
+ }
+ return number+result.toString();
+ }
+
+
+
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/QueryUtils.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/QueryUtils.java
new file mode 100644
index 0000000..49db9fe
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/QueryUtils.java
@@ -0,0 +1,83 @@
+package com.onlychain.signsdk.wallet.tranfer;
+
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.onlychain.signsdk.net.Request;
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+import com.onlychain.signsdk.wallet.iface.ImpQueryAction;
+
+public class QueryUtils {
+ private ImpQueryAction impQueryAction;
+ private String txId;
+ private int number=0;
+ private Thread runTask;
+ private int howNumStop=0;
+
+
+ /**
+ * 轮询确认对应TXID是否成功上链
+ * @param howNumStop 尝试查询次数，次数满回调为失败
+ * @param txId
+ * @param impQueryAction
+ */
+ public QueryUtils(int howNumStop,final String txId,ImpQueryAction impQueryAction) {
+ this.txId=txId;
+ this.impQueryAction=impQueryAction;
+ this.howNumStop=howNumStop;
+ runTask=new Thread(new Runnable() {
+ @Override
+ public void run() {
+ while (runTask!=null){
+ queryAction(txId);
+ try {
+ Thread.sleep(2000);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ });
+ runTask.start();
+ }
+
+ public QueryUtils() {
+
+ }
+
+
+ public void queryAction(String txId){
+ new Request(ApiConfig.API_queryAction, ApiConfig.queryAction(txId)) {
+ @Override
+ public void success(StringBuffer json) {
+ try{
+ JSONObject record = JSON.parseObject(json.toString());
+ number+=1;
+ if(record!=null && !record.get("record").toString().equals("[]") )
+ {
+ runTask=null;
+ impQueryAction.inChainSuceess(json);
+ }
+ else if(number>=howNumStop){
+ runTask=null;
+ impQueryAction.inChainFail();
+ }
+ }catch (Exception e){
+ e.printStackTrace();
+ runTask=null;
+ impQueryAction.inChainFail();
+ System.out.println("请检查节点或网络");
+ }
+
+
+ }
+ @Override
+ public void fail(Exception e) {
+
+ }
+ };
+
+ }
+
+
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/Script.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/Script.java
new file mode 100644
index 0000000..bfc22c0
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/Script.java
@@ -0,0 +1,56 @@
+package com.onlychain.signsdk.wallet.tranfer;
+
+
+
+
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.secp256k1.Secp256k1;
+import com.onlychain.signsdk.secp256k1.Signature;
+import com.onlychain.signsdk.utils.OcMath;
+
+import java.math.BigInteger;
+
+public class Script {
+
+ /**
+ * 交易输入脚本
+ * @param mAccountBean 账户对象
+ * @param message 消息
+ * @return 脚本结果
+ */
+ public static String vInScript(AccountBean mAccountBean, byte[] message){
+ String sigResult;
+ String sigContent;
+ Signature sig = Secp256k1.sign(mAccountBean.getPrivateKeyBin(), message);
+// System.out.println("sig--------------"+OcMath.toHexStringNoPrefix(sig.serialize()));
+ byte[] sigByte=sig.serialize();
+ String sigStr= OcMath.toHexStringNoPrefix(sigByte);
+ String publicKeyStr=OcMath.toHexStringNoPrefix(mAccountBean.getPublicKeyBin());
+
+ sigContent=OcMath.toHexStringNoPrefixZeroPadded(new BigInteger(String.valueOf(sigByte.length)),2)+sigStr+OcMath.toHexStringNoPrefixZeroPadded(new BigInteger(String.valueOf(mAccountBean.getPublicKeyBin().length)),2)+publicKeyStr;
+ sigResult=OcMath.toHexStringNoPrefixZeroPadded(new BigInteger(String.valueOf(OcMath.hexStringToByteArray(sigContent).length)),4)+sigContent;
+ return sigResult;
+ }
+
+
+ /**
+ * 交易输出脚本
+ * @param address 地址
+ * @return 脚本结果
+ */
+ public static String vOutScript(String address){
+ String scriptResult=getLockScript(address);
+ scriptResult=OcMath.toHexStringNoPrefixZeroPadded(new BigInteger(String.valueOf(OcMath.hexStringToByteArray(scriptResult).length)),4)+scriptResult;
+ return scriptResult;
+ }
+
+
+ /**
+ * 锁定脚本
+ * @param address
+ * @return
+ */
+ public static String getLockScript(String address){
+ return "76a914"+address+"88ac";
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/StartTranfer.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/StartTranfer.java
new file mode 100644
index 0000000..b89af07
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/StartTranfer.java
@@ -0,0 +1,257 @@
+package com.onlychain.signsdk.wallet.tranfer;
+
+
+import com.alibaba.fastjson.JSON;
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.bean.BaseActionBean;
+import com.onlychain.signsdk.bean.GetSystemInfoBean;
+import com.onlychain.signsdk.bean.OutBean;
+import com.onlychain.signsdk.bean.PurseBean;
+import com.onlychain.signsdk.net.Request;
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+import com.onlychain.signsdk.wallet.iface.ImpGetAction;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoin.BASE_NUMBER;
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoin.TYPE_1_FOR_TRANSFER;
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoin.TYPE_4_FOR_INTEREST;
+
+/**
+ * 各类交易类型封装在此
+ */
+public abstract class StartTranfer {
+ public abstract void receiveAction(BaseActionBean localCommitBean, StringBuffer json);
+ public abstract void receiveFail(Exception e);
+ private String ActionMsg;
+ private String Json;
+ private AccountBean mAccountBean;
+ private List outList;
+ private List coinLis;
+
+ public StartTranfer(AccountBean mAccountBean) {
+ this.mAccountBean=mAccountBean;
+ }
+
+
+ public StartTranfer inputCoin(List coinLis){
+ this.coinLis=coinLis;
+ return this;
+ }
+
+ public StartTranfer inputCoin(PurseBean.RecordBean coin){
+ List coinLis=new ArrayList<>();
+ coinLis.add(coin);
+ this.coinLis=coinLis;
+ return this;
+ }
+
+
+ public StartTranfer inputAddress(List outList){
+ this.outList=outList;
+ return this;
+ }
+
+ public StartTranfer inputAddressList(List outoutList){
+ //最多不要超过50
+ if (outoutList.size()>50)
+ return null;
+ this.outList=outoutList;
+ return this;
+ }
+
+
+ public StartTranfer inputAddress(OutBean out){
+ this.outList=new ArrayList<>();
+ this.outList.add(out);
+ return this;
+ }
+
+ public StartTranfer openInterest(PurseBean.RecordBean coin){
+ List coinLis=new ArrayList<>();
+ coinLis.add(coin);
+ this.coinLis=coinLis;
+// commit(TYPE_4_FOR_INTEREST);
+ return this;
+ }
+
+
+ public void commit(){
+ commit(TYPE_1_FOR_TRANSFER);
+ }
+
+ /**
+ * 获取质押裸交易数据
+ * @return
+ */
+ public void getPledgeSignData(final ImpGetAction mImpGetAction){
+ final long pledgeCoin=Long.valueOf(String.valueOf(sumCoinList(this.coinLis)));
+ this.outList=new ArrayList<>();
+ this.outList.add(new OutBean(pledgeCoin,mAccountBean.getAddressNoPrefix()));
+
+ new Request(ApiConfig.API_getSystemInfo) {
+ @Override
+ public void success(StringBuffer json) {
+ GetSystemInfoBean.RecordBean mGetSystemInfoBean= JSON.parseObject(json.toString(), GetSystemInfoBean.class).getRecord();
+ //根据coin数量计算锁定高度
+ long lockHeight=(30*(int)Math.floor(pledgeCoin/Long.valueOf(BASE_NUMBER)))+Long.valueOf(String.valueOf(mGetSystemInfoBean.getBlockHeight()));
+ MakeAction mMakeAction = new MakeAction(mAccountBean,TYPE_1_FOR_TRANSFER,coinLis,outList,lockHeight);
+ final BaseActionBean localCommitBean=mMakeAction.createAction(String.valueOf(mGetSystemInfoBean.getBlockHeight()));
+ mImpGetAction.receive(localCommitBean.getCommitData());
+ }
+ @Override
+ public void fail(Exception e) {
+ receiveFail(new Exception("获取最新高度失败,请检查节点是否正常"));
+ }
+ };
+ }
+
+
+ /**
+ * 合并零钱或拆额零钱
+ * @param excreteCoin
+ * @return
+ */
+ public StartTranfer inputExcreteCoins(long excreteCoin){
+ this.outList=new ArrayList<>();
+ this.outList.add(new OutBean(excreteCoin,mAccountBean.getAddressNoPrefix()));
+ return this;
+ }
+
+ /**
+ * 获取签名数据
+ * @param actionType
+ * @param mImpGetAction
+ */
+ public void getAction(final int actionType,final ImpGetAction mImpGetAction){
+ //找零
+ long findCoin=0;
+ if(actionType==TYPE_1_FOR_TRANSFER){
+ findCoin= Long.valueOf(sumCoinList(coinLis).subtract(sumOutList(outList)).toString());
+ //如果零钱全部转出则无需给自己找零
+ if (findCoin!=0)
+ this.outList.add(new OutBean(findCoin,mAccountBean.getAddressNoPrefix()));
+ }else if(actionType==TYPE_4_FOR_INTEREST){
+ this.outList=new ArrayList<>();
+ this.outList.add(new OutBean(this.coinLis.get(0).getValue(),mAccountBean.getAddressNoPrefix()));
+ }
+
+
+ if(coinLis!=null&&coinLis.size()>0&&Long.valueOf(sumCoinList(coinLis).toString())>0)
+ {
+ if (findCoin<0)
+ {
+ System.out.println("有余额但不够抵扣");
+ return;
+ }
+ }else {
+ System.out.println("完全没有余额");
+ return;
+ }
+ new Request(ApiConfig.API_getSystemInfo) {
+ @Override
+ public void success(StringBuffer json) {
+
+ GetSystemInfoBean.RecordBean mGetSystemInfoBean=JSON.parseObject(json.toString(), GetSystemInfoBean.class).getRecord();
+
+ MakeAction mMakeAction = new MakeAction(mAccountBean,actionType,coinLis,outList);
+ final BaseActionBean localCommitBean=mMakeAction.createAction(String.valueOf(mGetSystemInfoBean.getBlockHeight()));
+ mImpGetAction.receive(localCommitBean.getCommitData());
+ }
+ @Override
+ public void fail(Exception e) {
+ receiveFail(new Exception("获取最新高度失败,请检查节点是否正常"));
+ }
+ };
+ }
+
+
+ public void commit(final int actionType){
+ //找零
+ long findCoin=0;
+ if(actionType==TYPE_1_FOR_TRANSFER){
+ findCoin= Long.valueOf(sumCoinList(coinLis).subtract(sumOutList(outList)).toString());
+ //如果零钱全部转出则无需给自己找零
+ if (findCoin!=0)
+ this.outList.add(new OutBean(findCoin,mAccountBean.getAddressNoPrefix()));
+ }else if(actionType==TYPE_4_FOR_INTEREST){
+ this.outList=new ArrayList<>();
+ this.outList.add(new OutBean(this.coinLis.get(0).getValue(),mAccountBean.getAddressNoPrefix()));
+ }
+
+
+ if(coinLis!=null&&coinLis.size()>0&&Long.valueOf(sumCoinList(coinLis).toString())>0)
+ {
+ if (findCoin<0)
+ {
+ System.out.println("有余额但不够抵扣");
+ return;
+ }
+ }else {
+ System.out.println("完全没有余额");
+ return;
+ }
+
+ System.out.println(sumCoinList(coinLis));
+ System.out.println(sumOutList(outList));
+ System.out.println(findCoin);
+
+ doCommit(actionType);
+ }
+
+
+
+
+ /**
+ * 做最后整合提交
+ */
+ public void doCommit(final int actionType){
+ //先从节点获取最新高度信息
+ new Request(ApiConfig.API_getSystemInfo) {
+ @Override
+ public void success(StringBuffer json) {
+ GetSystemInfoBean.RecordBean mGetSystemInfoBean=JSON.parseObject(json.toString(), GetSystemInfoBean.class).getRecord();
+
+ MakeAction mMakeAction = new MakeAction(mAccountBean,actionType,coinLis,outList);
+ final BaseActionBean localCommitBean=mMakeAction.createAction(String.valueOf(mGetSystemInfoBean.getBlockHeight()));
+
+ System.out.println("提交的目标数据："+localCommitBean.getCommitData());
+
+ //开始将Action序列化信息提交至节点
+ new Request(ApiConfig.API_receiveAction,ApiConfig.receiveAction(localCommitBean.getCommitData())) {
+ @Override
+ public void success(StringBuffer json) {
+ receiveAction(localCommitBean,json);
+ }
+
+ @Override
+ public void fail(Exception e) {
+ receiveFail(e);
+ }
+ };
+ }
+ @Override
+ public void fail(Exception e) {
+ receiveFail(new Exception("获取最新高度失败,请检查节点是否正常"));
+ }
+ };
+ }
+
+
+
+ public BigDecimal sumCoinList(List coinList){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : coinList)
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum;
+ }
+
+ public BigDecimal sumOutList(List outList){
+ BigDecimal sum=new BigDecimal("0");
+ for (OutBean out : outList)
+ sum=sum.add(new BigDecimal(out.getValue()));
+ return sum;
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/StartTranferLocal.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/StartTranferLocal.java
new file mode 100644
index 0000000..fb1a1ec
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/tranfer/StartTranferLocal.java
@@ -0,0 +1,205 @@
+package com.onlychain.signsdk.wallet.tranfer;
+
+
+import com.alibaba.fastjson.JSON;
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.bean.BaseActionBean;
+import com.onlychain.signsdk.bean.GetSystemInfoBean;
+import com.onlychain.signsdk.bean.OutBean;
+import com.onlychain.signsdk.bean.PurseBean;
+import com.onlychain.signsdk.net.Request;
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+import com.onlychain.signsdk.wallet.iface.ImpGetAction;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoin.BASE_NUMBER;
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoin.TYPE_1_FOR_TRANSFER;
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoin.TYPE_4_FOR_INTEREST;
+
+/**
+ * 各类交易类型封装在此
+ */
+public class StartTranferLocal {
+ private String ActionMsg;
+ private String Json;
+ private AccountBean mAccountBean;
+ private List outList;
+ private List coinLis;
+
+ public StartTranferLocal(AccountBean mAccountBean) {
+ this.mAccountBean=mAccountBean;
+ }
+
+
+ public StartTranferLocal inputCoin(List coinLis){
+ this.coinLis=coinLis;
+ return this;
+ }
+
+ public StartTranferLocal inputCoin(PurseBean.RecordBean coin){
+ List coinLis=new ArrayList<>();
+ coinLis.add(coin);
+ this.coinLis=coinLis;
+ return this;
+ }
+
+
+ public StartTranferLocal inputAddress(List outList){
+ this.outList=outList;
+ return this;
+ }
+
+ public StartTranferLocal inputAddressList(List outoutList){
+ //最多不要超过50
+ if (outoutList.size()>50)
+ return null;
+ this.outList=outoutList;
+ return this;
+ }
+
+
+ public StartTranferLocal inputAddress(OutBean out){
+ this.outList=new ArrayList<>();
+ this.outList.add(out);
+ return this;
+ }
+
+ public StartTranferLocal openInterest(PurseBean.RecordBean coin){
+ List coinLis=new ArrayList<>();
+ coinLis.add(coin);
+ this.coinLis=coinLis;
+// commit(TYPE_4_FOR_INTEREST);
+ return this;
+ }
+
+/*
+ public void commit(){
+ commit(TYPE_1_FOR_TRANSFER);
+ }*/
+
+ /**
+ * 获取质押裸交易数据
+ * @return
+ */
+ public BaseActionBean getPledgeSignData(long Height){
+ final long pledgeCoin=Long.valueOf(String.valueOf(sumCoinList(this.coinLis)));
+ this.outList=new ArrayList<>();
+ this.outList.add(new OutBean(pledgeCoin,mAccountBean.getAddressNoPrefix()));
+ //根据coin数量计算锁定高度
+ long lockHeight=(30*(int)Math.floor(pledgeCoin/Long.valueOf(BASE_NUMBER)))+Long.valueOf(String.valueOf(Height));
+ MakeAction mMakeAction = new MakeAction(mAccountBean,TYPE_1_FOR_TRANSFER,coinLis,outList,lockHeight);
+ return mMakeAction.createAction(String.valueOf(Height));
+ }
+
+
+ /**
+ * 合并零钱或拆额零钱
+ * @param excreteCoin
+ * @return
+ */
+ public StartTranferLocal inputExcreteCoins(long excreteCoin){
+ this.outList=new ArrayList<>();
+ this.outList.add(new OutBean(excreteCoin,mAccountBean.getAddressNoPrefix()));
+ return this;
+ }
+
+ /**
+ * 获取签名数据
+ * @param actionType
+ * @param height
+ */
+ public BaseActionBean getAction( int actionType,long height){
+ //找零
+ long findCoin=0;
+ if(actionType==TYPE_1_FOR_TRANSFER){
+ findCoin= Long.valueOf(sumCoinList(coinLis).subtract(sumOutList(outList)).toString());
+ //如果零钱全部转出则无需给自己找零
+ if (findCoin!=0)
+ this.outList.add(new OutBean(findCoin,mAccountBean.getAddressNoPrefix()));
+ }else if(actionType==TYPE_4_FOR_INTEREST){
+ this.outList=new ArrayList<>();
+ this.outList.add(new OutBean(this.coinLis.get(0).getValue(),mAccountBean.getAddressNoPrefix()));
+ }
+
+
+ if(coinLis!=null&&coinLis.size()>0&&Long.valueOf(sumCoinList(coinLis).toString())>0)
+ {
+ if (findCoin<0)
+ {
+ System.out.println("有余额但不够抵扣");
+ return null;
+ }
+ }else {
+ System.out.println("完全没有余额");
+ return null;
+ }
+
+ MakeAction mMakeAction = new MakeAction(mAccountBean,actionType,coinLis,outList);
+ return mMakeAction.createAction(String.valueOf(height));
+ }
+
+
+ public void commit(int actionType,long height){
+ //找零
+ long findCoin=0;
+ if(actionType==TYPE_1_FOR_TRANSFER){
+ findCoin= Long.valueOf(sumCoinList(coinLis).subtract(sumOutList(outList)).toString());
+ //如果零钱全部转出则无需给自己找零
+ if (findCoin!=0)
+ this.outList.add(new OutBean(findCoin,mAccountBean.getAddressNoPrefix()));
+ }else if(actionType==TYPE_4_FOR_INTEREST){
+ this.outList=new ArrayList<>();
+ this.outList.add(new OutBean(this.coinLis.get(0).getValue(),mAccountBean.getAddressNoPrefix()));
+ }
+
+
+ if(coinLis!=null&&coinLis.size()>0&&Long.valueOf(sumCoinList(coinLis).toString())>0)
+ {
+ if (findCoin<0)
+ {
+ System.out.println("有余额但不够抵扣");
+ return;
+ }
+ }else {
+ System.out.println("完全没有余额");
+ return;
+ }
+
+ System.out.println(sumCoinList(coinLis));
+ System.out.println(sumOutList(outList));
+ System.out.println(findCoin);
+
+ doCommit(actionType, height);
+ }
+
+
+
+
+ /**
+ * 做最后整合提交
+ */
+ public BaseActionBean doCommit( int actionType,long height){
+ //先从节点获取最新高度信息
+ MakeAction mMakeAction = new MakeAction(mAccountBean,actionType,coinLis,outList);
+ return mMakeAction.createAction(String.valueOf(height));
+ }
+
+
+
+ public BigDecimal sumCoinList(List coinList){
+ BigDecimal sum=new BigDecimal("0");
+ for (PurseBean.RecordBean coin : coinList)
+ sum=sum.add(new BigDecimal(coin.getValue()));
+ return sum;
+ }
+
+ public BigDecimal sumOutList(List outList){
+ BigDecimal sum=new BigDecimal("0");
+ for (OutBean out : outList)
+ sum=sum.add(new BigDecimal(out.getValue()));
+ return sum;
+ }
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/viewblock/GetBlockData.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/viewblock/GetBlockData.java
new file mode 100644
index 0000000..f691f76
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/viewblock/GetBlockData.java
@@ -0,0 +1,38 @@
+package com.onlychain.signsdk.wallet.viewblock;
+
+
+import com.alibaba.fastjson.JSON;
+import com.onlychain.signsdk.bean.BlockBean;
+import com.onlychain.signsdk.net.Request;
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+
+import java.util.List;
+
+public abstract class GetBlockData {
+ private String height;
+ public abstract void getSuccess(StringBuffer json,List tradList);
+
+
+ public GetBlockData(String height) {
+ this.height = height;
+ queryBlock();
+ }
+
+
+ private void queryBlock(){
+ new Request(ApiConfig.API_queryBlock,ApiConfig.queryBlock(height)) {
+ @Override
+ public void success(StringBuffer json) {
+
+ BlockBean.RecordBean mRecord= JSON.parseObject(json.toString(), BlockBean.class).getRecord();
+ getSuccess(json,mRecord.getTradingInfo());
+ }
+ @Override
+ public void fail(Exception e) {
+
+ }
+ };
+
+ }
+
+}
diff --git a/SignSdk/src/main/java/com/onlychain/signsdk/wallet/viewblock/HexConvertJson.java b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/viewblock/HexConvertJson.java
new file mode 100644
index 0000000..52d2b2b
--- /dev/null
+++ b/SignSdk/src/main/java/com/onlychain/signsdk/wallet/viewblock/HexConvertJson.java
@@ -0,0 +1,140 @@
+package com.onlychain.signsdk.wallet.viewblock;
+
+
+
+import com.alibaba.fastjson.JSON;
+import com.onlychain.signsdk.bean.AnalysisBean;
+import com.onlychain.signsdk.utils.Leb128Utils;
+import com.onlychain.signsdk.utils.OcMath;
+import com.onlychain.signsdk.utils.WalletUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * 16进制转Json
+ */
+public class HexConvertJson {
+ private String actionStr;
+ private AnalysisBean actionBaseBean;
+ private String headStr;
+ public HexConvertJson(String actionStr) {
+ this.actionStr = actionStr;
+ actionBaseBean=new AnalysisBean();
+
+ setHead();
+ }
+
+
+ private void setHead(){
+ headStr=actionStr.substring(0,6);
+ actionBaseBean.setVersion(OcMath.toBigIntNoPrefix(headStr.substring(0,2)).toString());
+ actionBaseBean.setActionType(OcMath.toBigIntNoPrefix(headStr.substring(2,4)).toString());
+ actionBaseBean.setTxId(OcMath.toHexStringNoPrefix(WalletUtils.getTxIdBin(actionStr)));
+
+ if(isTypes())
+ {
+ setBody();
+ }else {
+// System.out.println("只支持actionType为1或4的交易类型解析");
+ }
+ }
+
+ /**
+ * actionType类型过滤
+ * @return
+ */
+ private boolean isTypes(){
+ if(actionBaseBean.getActionType().equals("1")||actionBaseBean.getActionType().equals("4"))
+ return true;
+ else return false;
+ }
+
+ private void setBody(){
+ int bodyStartIndex=headStr.length()+getLebNum(headStr).length();
+ AnalysisBean.TradingBean mTradingBean=new AnalysisBean.TradingBean();
+ List vinList=new ArrayList<>();
+ List voutList=new ArrayList<>();
+ for (int i = 0; i< Leb128Utils.decodeUnsigned(getLebNum(headStr)); i++)
+ {
+ AnalysisBean.TradingBean.VinBean vinObj=new AnalysisBean.TradingBean.VinBean();
+ bodyStartIndex=bodyStartIndex+64;
+ vinObj.setTxId(actionStr.substring(bodyStartIndex-64,bodyStartIndex));
+ String lebStrN=actionStr.substring(bodyStartIndex,bodyStartIndex+2);
+ vinObj.setN(String.valueOf(OcMath.toBigIntNoPrefix(lebStrN)));
+ bodyStartIndex=bodyStartIndex+lebStrN.length();
+
+// System.out.println(vinObj.getN());
+ int scriptLength=Integer.valueOf(OcMath.toBigIntNoPrefix(actionStr.substring(bodyStartIndex,bodyStartIndex+4)).toString())*2;
+ bodyStartIndex=bodyStartIndex+4;
+ vinObj.setScriptSig(actionStr.substring(bodyStartIndex,bodyStartIndex+scriptLength));
+ bodyStartIndex=bodyStartIndex+scriptLength;
+
+ vinList.add(vinObj);
+ }
+
+ String outSizeLeb=getLebNum(actionStr.substring(0,bodyStartIndex));
+ bodyStartIndex=bodyStartIndex+outSizeLeb.length();
+ for (int i=0;i coinList = getCoinList(json);
+ for (PurseBean.RecordBean pur:coinList)
+ System.out.println("（含权益、锁定、可流通的零钱）"+pur.getValue()+" TYPE:"+ pur.getActionType());
+
+ System.out.println("\n");
+
+ List coinListFor4 = getCoinList(coinList,TYPE_4_FOR_INTEREST);
+ for (PurseBean.RecordBean pur:coinListFor4)
+ System.out.println("（含权益的零钱）"+pur.getValue()+" TYPE:"+ pur.getActionType());
+
+ System.out.println("\n");
+
+ List coinListFor1 = getCoinList(coinList,TYPE_1_FOR_TRANSFER);
+ for (PurseBean.RecordBean pur:coinListFor1)
+ System.out.println("（含锁定、可流通的零钱）"+pur.getValue()+" TYPE:"+ pur.getActionType());
+
+
+ System.out.println("\n");
+
+ //获取主网最新高度进行零钱锁定筛选可获得可流通的零钱和质押中零钱
+ new Request(ApiConfig.API_getSystemInfo) {
+ @Override
+ public void success(StringBuffer json) {
+ long lastHeight=JSON.parseObject(json.toString(),GetSystemInfoBean.class).getRecord().getBlockHeight();
+ List coinPurse=getCoinListForHeight(lastHeight);
+ for (PurseBean.RecordBean pur:coinPurse)
+ System.out.println("（可流通的零钱）"+pur.getValue()+" TYPE:"+ pur.getActionType());
+
+ System.out.println("\n");
+
+
+ List coinPurseLock=getCoinListForLock(lastHeight);
+ for (PurseBean.RecordBean pur:coinPurseLock)
+ System.out.println("（投票质押中的零钱）"+pur.getValue()+" TYPE:"+ pur.getActionType());
+
+ }
+ @Override
+ public void fail(Exception e) {
+
+ }
+ };
+
+ }
+
+ @Override
+ public void getCoinFail(Exception e) {
+ //地址错误时候抛出异常
+ System.out.println(e);
+ }
+ };
+
+
+
+
+
+
+
+
+
+
+
+
+
+ }
+
+
+
+}
diff --git a/app/src/main/java/com/onlychain/ocsignsdk/AboutSign.java b/app/src/main/java/com/onlychain/ocsignsdk/AboutSign.java
new file mode 100644
index 0000000..b662ec6
--- /dev/null
+++ b/app/src/main/java/com/onlychain/ocsignsdk/AboutSign.java
@@ -0,0 +1,118 @@
+package com.onlychain.ocsignsdk;
+
+import com.onlychain.ocsignsdk.data.JsonData;
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.bean.BaseActionBean;
+import com.onlychain.signsdk.bean.OutBean;
+import com.onlychain.signsdk.bean.PurseBean;
+import com.onlychain.signsdk.net.Request;
+import com.onlychain.signsdk.utils.OcMath;
+import com.onlychain.signsdk.utils.WalletUtils;
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+import com.onlychain.signsdk.wallet.tranfer.GetVinCoinLocal;
+import com.onlychain.signsdk.wallet.tranfer.StartTranferLocal;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoinLocal.BASE_NUMBER;
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoinLocal.TYPE_1_FOR_TRANSFER;
+import static com.onlychain.signsdk.wallet.tranfer.GetVinCoinLocal.TYPE_4_FOR_INTEREST;
+
+/**
+ * 关于所有的裸签名操作
+ */
+public class AboutSign {
+
+ public static void main(String[] args) {
+
+ //解析本地零钱json，或取出数据库中零钱列表对象
+ //TODO 注意！！！
+ //TODO 注意！！！
+ //TODO 注意！！！,此处输入的JsonData.coinListJson零钱数据一定要正确，否则以下签名结果都是无法通过主网验证,此处JsonData.coinListJson零钱为模拟数据，非实际测试零钱
+ GetVinCoinLocal mGetVinCoinLocal = new GetVinCoinLocal(new StringBuffer(JsonData.coinListJson));
+
+ //通过高度筛选出可用的零钱
+ List coinPurse= mGetVinCoinLocal.getCoinListForHeight(1570004);
+ for (PurseBean.RecordBean pur:coinPurse)
+ System.out.println("（可流通的零钱）"+pur.getValue()+" TYPE:"+ pur.getActionType());
+
+ //————————————————————————————————————————————————————————————————————————————————————————————————————————————
+ //初始化IP配置
+ String ip="http://39.98.135.66:9082";
+ ApiConfig.init(ip);
+
+ //模拟一个最新高度
+ long height=1570004;
+ //打印获取当前主网最新高度的API
+ System.out.println(ApiConfig.API_getSystemInfo);
+ System.out.println(ApiConfig.init(ip).getSystemInfoUrl());
+
+ //带网络请求获取最新高度,如需请求其它功能只需替换 ApiConfig.API_getSystemInfo ，如 ApiConfig.API_selectPurse
+ new Request(ApiConfig.API_getSystemInfo){
+ @Override
+ public void success(StringBuffer json) {
+ //通过解析json取得高度，可将次高度存全局数据库进行控制零钱是否质押解锁
+ }
+
+ @Override
+ public void fail(Exception e) {
+
+ }
+ };
+
+ //导入账户
+ AccountBean mAccountBean=WalletUtils.createAccount(OcMath.hexStringToByteArray("ea23e889d590a443831a785a398ce74179f09dece2fe5bfda41f795c50240c62"));
+ StartTranferLocal mStartTranferLocal= new StartTranferLocal(mAccountBean);
+
+ //TODO 生成单笔转账交易签名
+ OutBean mOutBean= new OutBean();
+ //设置目标转账地址
+ mOutBean.setAddress("274579901ace0417d662a203c8c3dbbb40693d8d");
+ mOutBean.setValue(10000*Long.valueOf(BASE_NUMBER));
+ BaseActionBean singleTrans = mStartTranferLocal.inputCoin(coinPurse).inputAddress(mOutBean).getAction(TYPE_1_FOR_TRANSFER,height);
+ System.out.println("单笔转账："+singleTrans.getCommitData());
+
+ //TODO 生成批量转账交易签名
+ List outoutList = new ArrayList<>();
+ outoutList.add(mOutBean);
+ outoutList.add(new OutBean(10000*Long.valueOf(BASE_NUMBER),"374579901ace0417d662a203c8c3dbbb40693d8d"));
+ BaseActionBean moreTrans = mStartTranferLocal.inputCoin(coinPurse).inputAddressList(outoutList).getAction(TYPE_1_FOR_TRANSFER,height);
+ System.out.println("多笔转账："+moreTrans.getCommitData());
+
+ //TODO 单笔或多笔零钱质押签名
+ BaseActionBean mPledge = mStartTranferLocal.inputCoin(coinPurse).getPledgeSignData(height);
+ System.out.println("单笔或多笔零钱质押："+mPledge.getCommitData());
+
+ //TODO 单笔或多笔零钱拆额与合并签名
+ BaseActionBean mExcreteCoins = mStartTranferLocal.inputCoin(coinPurse).inputExcreteCoins(990*Long.valueOf(BASE_NUMBER)).getAction(TYPE_1_FOR_TRANSFER,height);
+ System.out.println("单笔或多笔零钱拆额与合并："+mExcreteCoins.getCommitData());
+
+ //TODO 开通权益签名,有符合指定范围的零钱才会触发以下打印
+ BaseActionBean mOpenInterest = mStartTranferLocal.openInterest(mGetVinCoinLocal.getCoinForMin("20","30")).getAction(TYPE_4_FOR_INTEREST,height);
+ System.out.println("开通权益："+mOpenInterest.getCommitData());
+
+ //TODO 获取某交易签名的订单号
+ System.out.println("签名数据的订单凭据（TXID）："+mOpenInterest.getTxid());
+
+ //TODO 获取验证构造的签名合法性
+ System.out.println("验证提交签名的合法性："+mOpenInterest.checkSig(mAccountBean.getPublicKeyBin()));
+
+ //TODO 获取验证构造的签名合法性
+ System.out.println("验证指定签名的合法性："+mOpenInterest.checkSign(mAccountBean.getPublicKeyBin(),mOpenInterest.getMessage(),mOpenInterest.getSignStr()));
+
+
+ //TODO 提交签名至主网,谨慎开启
+/* new Request(ApiConfig.API_receiveAction,ApiConfig.receiveAction(mOpenInterest.getCommitData())) {
+ @Override
+ public void success(StringBuffer json) {
+
+ }
+
+ @Override
+ public void fail(Exception e) {
+
+ }
+ };*/
+ }
+}
diff --git a/app/src/main/java/com/onlychain/ocsignsdk/ApiSignTools.java b/app/src/main/java/com/onlychain/ocsignsdk/ApiSignTools.java
new file mode 100644
index 0000000..fdd4290
--- /dev/null
+++ b/app/src/main/java/com/onlychain/ocsignsdk/ApiSignTools.java
@@ -0,0 +1,31 @@
+package com.onlychain.ocsignsdk;
+
+
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.bean.BaseActionBean;
+import com.onlychain.signsdk.utils.OcMath;
+import com.onlychain.signsdk.utils.WalletUtils;
+
+/**
+ * 对自定义消息进行加签和解签
+ * 使用场景：只允许来自本人的私钥（公钥、地址）身份进行访问自己数据，避免有人通过接口可以查看他人数据
+ */
+public class ApiSignTools {
+ public static void main(String[] args) {
+ //根据确定的私钥生成账户
+ final AccountBean mAccountBean= WalletUtils.createAccount(OcMath.hexStringToByteArray("1a23e889d590a443831a785a398ce74179f09dece2fe5bfda41f795c50240c62"));
+ //对消息进行加签和验签
+ BaseActionBean mBaseActionBean=new BaseActionBean();
+
+ //移动端:对带有公钥的json数据加签,将签名结果加入请求header中
+ String jsonMsgX="{\\\"msg\\\":{\\\"publicKey\\\":\\\"0355c48844bb6392dbd251167c92904eabbbc1982b39dc7ebcb2141063f0281e1f\\\",\\\"title\\\":\\\"下方标题\\\",\\\"content\\\":\\\"这是内容\\\"}}";
+ String jsonMsg="ismessage";
+ System.out.println(mAccountBean.getPrivateKey());
+ System.out.println(mBaseActionBean.makeSign(mAccountBean.getPrivateKeyBin(),jsonMsg));
+
+
+
+ //服务端:提取json中公钥、整json内容以及header中的sign对其验签
+ System.out.println(mBaseActionBean.checkApiSign(mAccountBean.getPublicKeyBin(),jsonMsg,"30450221008fe7f0f7bb55da842522ba91565065eae37c0bf3b06b402b129c34b288d8084402202247716b7cb03545eb455ef36c7c4070db905250615a9a4b975d49f5dadc2441"));
+ }
+}
diff --git a/app/src/main/java/com/onlychain/ocsignsdk/CommitBlockApp.java b/app/src/main/java/com/onlychain/ocsignsdk/CommitBlockApp.java
new file mode 100644
index 0000000..04007d9
--- /dev/null
+++ b/app/src/main/java/com/onlychain/ocsignsdk/CommitBlockApp.java
@@ -0,0 +1,224 @@
+package com.onlychain.ocsignsdk;
+
+import com.alibaba.fastjson.JSON;
+import com.onlychain.signsdk.bean.AccountBean;
+import com.onlychain.signsdk.bean.BaseActionBean;
+import com.onlychain.signsdk.bean.GetSystemInfoBean;
+import com.onlychain.signsdk.bean.OutBean;
+import com.onlychain.signsdk.bean.PurseBean;
+import com.onlychain.signsdk.net.Request;
+import com.onlychain.signsdk.utils.OcMath;
+import com.onlychain.signsdk.utils.WalletUtils;
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+import com.onlychain.signsdk.wallet.iface.ImpGetAction;
+import com.onlychain.signsdk.wallet.iface.ImpQueryAction;
+import com.onlychain.signsdk.wallet.tranfer.GetVinCoin;
+import com.onlychain.signsdk.wallet.tranfer.QueryUtils;
+import com.onlychain.signsdk.wallet.tranfer.StartTranfer;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
+
+public class CommitBlockApp
+{
+ static List coinPurse;
+ public static void main(String[] args )
+ {
+ //根据随机私钥生成账户
+ AccountBean mAccountBeanRandom= WalletUtils.createAccount();
+ //获取带oc前缀的地址
+ System.out.println("随机版，带oc前缀的地址 "+mAccountBeanRandom.getAddress());
+ //获取不带oc前缀的地址
+ System.out.println("随机版，不带oc前缀的地址 "+mAccountBeanRandom.getAddressNoPrefix());
+ //获取公钥
+ System.out.println("随机版，公钥 "+mAccountBeanRandom.getPublicKey());
+
+ //根据确定的私钥生成账户
+ final AccountBean mAccountBean=WalletUtils.createAccount(OcMath.hexStringToByteArray("ea23e889d590a443831a785a398ce74179f09dece2fe5bfda41f795c50240c62"));
+ //获取带oc前缀的地址
+ System.out.println("带oc前缀的地址 "+mAccountBean.getAddress());
+ //获取不带oc前缀的地址
+ System.out.println("不带oc前缀的地址 "+mAccountBean.getAddressNoPrefix());
+ //获取公钥
+ System.out.println("公钥 "+mAccountBean.getPublicKey());
+
+ //更换节点IP
+ ApiConfig.init("http://39.98.135.66:9082");
+
+ //获取链上指定地址的钱包零钱
+ new GetVinCoin(mAccountBean) {
+ @Override
+ public void walletCoinList(StringBuffer json) {
+
+ //获取钱包所有的零钱列表
+ getCoinList();
+ //获取钱包可流通的零钱列表
+ getCoinList(TYPE_1_FOR_TRANSFER);
+ //获取钱包开通权益的零钱列表
+ getCoinList(TYPE_4_FOR_INTEREST);
+
+ //获取所有类型的余额
+ System.out.println("获取所有类型的余额 "+getBalance());
+ //获取可流通类型的余额
+ System.out.println("获取零钱类型为1的所有余额 "+getBalance(TYPE_1_FOR_TRANSFER));
+ //获取被开通权益的余额
+ System.out.println("获取被开通权益的余额 "+getBalance(TYPE_4_FOR_INTEREST));
+ //判断权益是否开通成功
+ System.out.println("是否拥有权益："+(getBalance(TYPE_4_FOR_INTEREST).compareTo(new BigDecimal("20"))>-1 ? "有":"没有"));
+
+ //获取一笔最适合开通权益的零钱（默认在20~30之间取）
+ System.out.println("获取一笔最适合开通权益的零钱 "+getCoinForInterest().getValue()/Long.valueOf(BASE_NUMBER));
+ //在指定范围内，获取一笔最大的零钱
+ System.out.println("在指定范围内获取一笔最大的零钱 "+getCoinForMax("0","10000").getValue()/Long.valueOf(BASE_NUMBER));
+ //在指定范围内，获取一笔最小的零钱
+ System.out.println("在指定范围内获取一笔最小的零钱 "+getCoinForMin("10","10000").getValue()/Long.valueOf(BASE_NUMBER));
+
+
+ final StartTranfer mStartTranfer=new StartTranfer(mAccountBean) {
+ @Override
+ public void receiveAction(final BaseActionBean localCommitBean, StringBuffer json) {
+ //获取Action的签名
+ System.out.println(localCommitBean.getSignStr());
+ //获取Action的消息体
+ System.out.println(localCommitBean.getMessage());
+ //获取Action的txid
+ System.out.println(localCommitBean.getTxid());
+ //使用公钥验证消息签名的真实性
+ System.out.println(localCommitBean.checkSig(mAccountBean.getPublicKeyBin()));
+ //获取提交后的结果,提交成功不等于上链成功，需要通过查询txid为准
+ System.out.println("提交成功的返回结果=="+json);
+
+ //通过查询Txid来确定是否上链成功
+ new QueryUtils(4,localCommitBean.getTxid(), new ImpQueryAction() {
+ @Override
+ public void inChainSuceess(StringBuffer json) {
+ System.out.println("上链成功的交易数据："+json);
+ System.out.println("上链成功TXID："+localCommitBean.getTxid());
+ }
+ @Override
+ public void inChainFail() {
+ System.out.println("上链失败");
+ }
+ });
+ }
+ @Override
+ public void receiveFail(Exception e) {
+ System.out.println(e);
+ }
+ };
+
+ // 开始向节点提交签名后的数据
+ //获取当前钱包的零钱是否存在至少一笔type为4的标准权益质押量
+ if(getBalance(TYPE_4_FOR_INTEREST).compareTo(new BigDecimal("20"))>-1)
+ {
+ //TODO --------------------------------以下业务不能同时运行
+
+ new Request(ApiConfig.API_getSystemInfo) {
+ @Override
+ public void success(StringBuffer json) {
+ //设定转账的目标地址
+ OutBean mOutBean= new OutBean();
+ mOutBean.setAddress("274579901ace0417d662a203c8c3dbbb40693d8d");
+ mOutBean.setValue(10000*Long.valueOf(BASE_NUMBER));
+
+ OutBean mOutBean2= new OutBean();
+ mOutBean2.setAddress("419d0c3fde261eeaecd2c47b484f20db3ef7558b");
+ mOutBean2.setValue(1*Long.valueOf(BASE_NUMBER));
+
+ OutBean mOutBean3= new OutBean();
+ mOutBean3.setAddress("479d0c3fde261eeaecd2c47b484f20db3ef7558b");
+ mOutBean3.setValue(1*Long.valueOf(BASE_NUMBER));
+
+ List outoutList = new ArrayList<>();
+ outoutList.add(mOutBean);
+ outoutList.add(mOutBean2);
+ outoutList.add(mOutBean3);
+
+
+ GetSystemInfoBean.RecordBean mGetSystemInfoBean= JSON.parseObject(json.toString(), GetSystemInfoBean.class).getRecord();
+ System.out.println("最新高度=="+mGetSystemInfoBean.getBlockHeight());
+ /* for (PurseBean.RecordBean pr:getCoinListForHeight(mGetSystemInfoBean.getBlockHeight()))
+ System.out.println(pr.getValue());*/
+
+ //获取可用零钱（不含权益零钱、锁定零钱）
+ coinPurse=getCoinListForHeight(mGetSystemInfoBean.getBlockHeight());
+ //获取可流通类型的余额
+ System.out.println("获取可流通类型的余额 "+getBalance(coinPurse));
+
+
+ //TODO 提交普通单笔转账交易
+// mStartTranfer.inputCoin(coinPurse).inputAddress(mOutBean).commit();
+ //TODO 获取单笔转账签名
+ mStartTranfer.inputCoin(coinPurse).inputAddress(mOutBean).getAction(TYPE_1_FOR_TRANSFER, new ImpGetAction() {
+ @Override
+ public void receive(String actionStr) {
+ System.out.println(actionStr);
+ }
+ });
+
+ //TODO 提交普通批量转账交易
+ //mStartTranfer.inputCoin(coinPurse).inputAddressList(outoutList).commit();
+ //TODO 获取普通批量转账交易签名
+ /* mStartTranfer.inputCoin(coinPurse).inputAddressList(outoutList).getAction(TYPE_1_FOR_TRANSFER, new ImpGetAction() {
+ @Override
+ public void receive(String actionStr) {
+ System.out.println(actionStr);
+ }
+ });*/
+ //TODO 获取质押的裸交易数据
+ /* mStartTranfer.inputCoin(coinPurse).getPledgeSignData(new ImpGetAction() {
+ @Override
+ public void receive(String actionStr) {
+ System.out.println("得到质押裸交易签名==="+actionStr);
+ }
+ });*/
+
+ //TODO 对零钱进行合并或拆额，如果自己的out为1个则为合并，如果自己的out为2个则为拆额 ,取整用 X*Long.valueOf(BASE_NUMBER)
+ //TODO 选某笔零钱进行拆额
+// mStartTranfer.inputCoin(coinPurse).inputExcreteCoins(20*Long.valueOf(BASE_NUMBER)).commit();
+ //TODO 获取选某笔零钱进行拆额签名
+ /* mStartTranfer.inputCoin(coinPurse.get(0)).inputExcreteCoins(3900l).getAction(TYPE_1_FOR_TRANSFER, new ImpGetAction() {
+ @Override
+ public void receive(String actionStr) {
+ System.out.println(actionStr);
+ }
+ });*/
+
+ //TODO 选多笔零钱进行合并
+// mStartTranfer.inputCoin(coinPurse).inputExcreteCoins(getBalanceLong(coinPurse).longValue()).commit();
+ //TODO 获取多笔零钱进行合并的签名,输入coinPurse零钱如果只有一笔，则没有合并的意义
+ /* mStartTranfer.inputCoin(coinPurse).inputExcreteCoins(getBalanceLong(coinPurse).longValue()).getAction(TYPE_1_FOR_TRANSFER, new ImpGetAction() {
+ @Override
+ public void receive(String actionStr) {
+ System.out.println(actionStr);
+ }
+ });*/
+ }
+ @Override
+ public void fail(Exception e) {
+
+ }
+ };
+
+ } else{
+ //TODO 开通权益
+ mStartTranfer.openInterest(getCoinForMin("20","30")).commit(TYPE_4_FOR_INTEREST);
+ //TODO 获取开通权益签名
+ /* mStartTranfer.openInterest(getCoinForMin("20","30")).getAction(TYPE_4_FOR_INTEREST, new ImpGetAction() {
+ @Override
+ public void receive(String actionStr) {
+ System.out.println(actionStr);
+ }
+ });*/
+ }
+ }
+
+ @Override
+ public void getCoinFail(Exception e) {
+ System.out.println((e));
+ }
+ };
+
+ }
+}
diff --git a/app/src/main/java/com/onlychain/ocsignsdk/ViewBlockApp.java b/app/src/main/java/com/onlychain/ocsignsdk/ViewBlockApp.java
new file mode 100644
index 0000000..8864003
--- /dev/null
+++ b/app/src/main/java/com/onlychain/ocsignsdk/ViewBlockApp.java
@@ -0,0 +1,42 @@
+package com.onlychain.ocsignsdk;
+
+
+
+import com.onlychain.signsdk.wallet.base.ApiConfig;
+import com.onlychain.signsdk.wallet.viewblock.GetBlockData;
+import com.onlychain.signsdk.wallet.viewblock.HexConvertJson;
+
+import java.util.List;
+
+/**
+ * 16进制Action本地解析，目前只保留actionType1和actionType4
+ */
+public class ViewBlockApp {
+ public static void main(String[] args) {
+ //更换节点IP
+ ApiConfig.init("http://39.98.135.66:9082");
+
+ //获取指定高度的区块数据并解析成json,目前只保留actionType1和actionType4
+ final long height=1349624;
+ new GetBlockData(String.valueOf(height)) {
+ @Override
+ public void getSuccess(StringBuffer json,List tradList) {
+ System.out.println("通过API获取到指定高度的区块数据 ： "+json);
+ for (String temp:tradList)
+ {
+ String result = new HexConvertJson(temp).getJson();
+
+ if (result!=null)
+ System.out.println("得到高度: "+height+" 的 [tradingInfo] 数据，且"+"TYPE为"+
+ temp.substring(0,2)+"的数据 : "
+ +result);
+ }
+ }
+ };
+
+
+ //对指定的序列化Action数据进行解析,格式为json
+ System.out.println();
+ System.out.println("指定Action解析 ： "+new HexConvertJson("010101021aaea3ca7f1c55967907869884386ac47f291a2cb618f5052385a787bb4e7ddb00006a47304502206f77a998f3da616e246b1f7e8f9828a390da606d31825f0b906e773b77c47603022100da17bab74105c9333c240c4d5361d030664056b4a767b4b99e7d8be002c8982e210355c48844bb6392dbd251167c92904eabbbc1982b39dc7ebcb2141063f0281e1f1aaea3ca7f1c55967907869884386ac47f291a2cb618f5052385a787bb4e7ddb01006a47304502202b0a958bfd2fef35281273a1386ccca23112fe755bf4778ee73f9424d24f948c022100d7cee58f73d6c2968c7fdfa200392d7f2a240a6ef67298f6e3a4355d97fb5190210355c48844bb6392dbd251167c92904eabbbc1982b39dc7ebcb2141063f0281e1f02000000e8d4a51000001976a914274579901ace0417d662a203c8c3dbbb40693d8d88ac000064d9f81b8550001976a9143b349701a36b457339e53ead5159750efc1f2a8988ac00000000000000000000edbebafa05d4e95f0355c48844bb6392dbd251167c92904eabbbc1982b39dc7ebcb2141063f0281e1f01003045022006c695010408f24d99376fcaea26ca9e3e40a2a8bb0fd5880eb3867920d2db62022100f05337482d70aed28cd09e7c1182b173336f14212d086071ab7e269d67bf007d").getJson());
+ }
+}
diff --git a/app/src/main/java/com/onlychain/ocsignsdk/data/JsonData.java b/app/src/main/java/com/onlychain/ocsignsdk/data/JsonData.java
new file mode 100644
index 0000000..9afdcd7
--- /dev/null
+++ b/app/src/main/java/com/onlychain/ocsignsdk/data/JsonData.java
@@ -0,0 +1,49 @@
+package com.onlychain.ocsignsdk.data;
+
+public class JsonData {
+ public static String coinListJson="{\n" +
+ " \"code\": 200,\n" +
+ " \"record\": [\n" +
+ " {\n" +
+ " \"txId\": \"15216c78776a7b039a3783314aeb343971c828487091774d7344f1756ee95618\",\n" +
+ " \"n\": 0,\n" +
+ " \"value\": 2600000000,\n" +
+ " \"reqSigs\": \"76a9143b349701a36b457339e53ead5159750efc1f2a8988ac\",\n" +
+ " \"createdBlock\": 693,\n" +
+ " \"lockTime\": 15768694,\n" +
+ " \"address\": \"3b349701a36b457339e53ead5159750efc1f2a89\",\n" +
+ " \"actionType\": 4\n" +
+ " },\n" +
+ " {\n" +
+ " \"txId\": \"1aaea3ca7f1c55967907869884386ac47f291a2cb618f5052385a787bb4e7ddb\",\n" +
+ " \"n\": 0,\n" +
+ " \"value\": 2000000000,\n" +
+ " \"reqSigs\": \"76a9143b349701a36b457339e53ead5159750efc1f2a8988ac\",\n" +
+ " \"createdBlock\": 1529147,\n" +
+ " \"lockTime\": 0,\n" +
+ " \"address\": \"3b349701a36b457339e53ead5159750efc1f2a89\",\n" +
+ " \"actionType\": 1\n" +
+ " },\n" +
+ " {\n" +
+ " \"txId\": \"1aaea3ca7f1c55967907869884386ac47f291a2cb618f5052385a787bb4e7ddb\",\n" +
+ " \"n\": 1,\n" +
+ " \"value\": 111885333234000,\n" +
+ " \"reqSigs\": \"76a9143b349701a36b457339e53ead5159750efc1f2a8988ac\",\n" +
+ " \"createdBlock\": 1529147,\n" +
+ " \"lockTime\": 0,\n" +
+ " \"address\": \"3b349701a36b457339e53ead5159750efc1f2a89\",\n" +
+ " \"actionType\": 1\n" +
+ " },\n" +
+ " {\n" +
+ " \"txId\": \"4a0da305c486f2f6c26ad8b1353edbb8078bb8443b9739ddbd2b88249de7c208\",\n" +
+ " \"n\": 0,\n" +
+ " \"value\": 10000000000,\n" +
+ " \"reqSigs\": \"76a9143b349701a36b457339e53ead5159750efc1f2a8988ac\",\n" +
+ " \"createdBlock\": 908843,\n" +
+ " \"lockTime\": 100000000,\n" +
+ " \"address\": \"3b349701a36b457339e53ead5159750efc1f2a89\",\n" +
+ " \"actionType\": 4\n" +
+ " }\n" +
+ " ]\n" +
+ "}";
+}
diff --git a/build.gradle b/build.gradle
index df01e52..dbd9d97 100644
--- a/build.gradle
+++ b/build.gradle
@@ -16,6 +16,7 @@ allprojects {
repositories {
google()
jcenter()
+ maven { url 'https://jitpack.io' }
}
}
diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties
index 1b16c34..3c1c441 100644
--- a/gradle/wrapper/gradle-wrapper.properties
+++ b/gradle/wrapper/gradle-wrapper.properties
@@ -1,5 +1,6 @@
+#Tue Sep 01 18:33:26 CST 2020
distributionBase=GRADLE_USER_HOME
distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-6.1.1-bin.zip
zipStoreBase=GRADLE_USER_HOME
zipStorePath=wrapper/dists
+distributionUrl=https\://services.gradle.org/distributions/gradle-6.1.1-all.zip