|
@@ -220,12 +220,14 @@ class FutureManager {
|
|
|
responseBack: (isSuccess: Boolean, respData: List<FutureEntrustData>?, error: Error?) -> Unit
|
|
responseBack: (isSuccess: Boolean, respData: List<FutureEntrustData>?, error: Error?) -> Unit
|
|
|
) {
|
|
) {
|
|
|
MyOkHttpUtils().query(
|
|
MyOkHttpUtils().query(
|
|
|
- URL = SPUtils.getInstance().getString(Constant.goCommonSearchUrl) + "/Ermcp/QueryErmcpHisOrderDetails",
|
|
|
|
|
|
|
+ URL = SPUtils.getInstance()
|
|
|
|
|
+ .getString(Constant.goCommonSearchUrl) + "/Ermcp/QueryErmcpHisOrderDetails",
|
|
|
params = params,
|
|
params = params,
|
|
|
type = "1",
|
|
type = "1",
|
|
|
- callback = object : ResponseCallback<BaseResult<List<FutureEntrustData>>>(){
|
|
|
|
|
|
|
+ callback = object : ResponseCallback<BaseResult<List<FutureEntrustData>>>() {
|
|
|
override fun onResponse(response: BaseResult<List<FutureEntrustData>>?, id: Int) {
|
|
override fun onResponse(response: BaseResult<List<FutureEntrustData>>?, id: Int) {
|
|
|
- GlobalDataCollection.instance?.futureHisEntrustData = response?.data as ArrayList<FutureEntrustData>?
|
|
|
|
|
|
|
+ GlobalDataCollection.instance?.futureHisEntrustData =
|
|
|
|
|
+ response?.data as ArrayList<FutureEntrustData>?
|
|
|
responseBack(true, response?.data, null)
|
|
responseBack(true, response?.data, null)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -246,12 +248,13 @@ class FutureManager {
|
|
|
fun queryErmcpHisTradeDetails(
|
|
fun queryErmcpHisTradeDetails(
|
|
|
params: Map<String, String>,
|
|
params: Map<String, String>,
|
|
|
responseBack: (isSuccess: Boolean, respData: List<DealOrderData>?, error: Error?) -> Unit
|
|
responseBack: (isSuccess: Boolean, respData: List<DealOrderData>?, error: Error?) -> Unit
|
|
|
- ){
|
|
|
|
|
|
|
+ ) {
|
|
|
MyOkHttpUtils().query(
|
|
MyOkHttpUtils().query(
|
|
|
- URL = SPUtils.getInstance().getString(Constant.goCommonSearchUrl) + "/Ermcp/QueryErmcpHisTradeDetails",
|
|
|
|
|
|
|
+ URL = SPUtils.getInstance()
|
|
|
|
|
+ .getString(Constant.goCommonSearchUrl) + "/Ermcp/QueryErmcpHisTradeDetails",
|
|
|
params = params,
|
|
params = params,
|
|
|
type = "1",
|
|
type = "1",
|
|
|
- callback = object : ResponseCallback<BaseResult<List<DealOrderData>>>(){
|
|
|
|
|
|
|
+ callback = object : ResponseCallback<BaseResult<List<DealOrderData>>>() {
|
|
|
override fun onResponse(response: BaseResult<List<DealOrderData>>?, id: Int) {
|
|
override fun onResponse(response: BaseResult<List<DealOrderData>>?, id: Int) {
|
|
|
responseBack(true, response?.data, null)
|
|
responseBack(true, response?.data, null)
|
|
|
}
|
|
}
|
|
@@ -398,12 +401,13 @@ class FutureManager {
|
|
|
fun queryAmountLog(
|
|
fun queryAmountLog(
|
|
|
params: Map<String, String>,
|
|
params: Map<String, String>,
|
|
|
responseBack: (isSuccess: Boolean, respData: List<AmountLogData>?, error: Error?) -> Unit
|
|
responseBack: (isSuccess: Boolean, respData: List<AmountLogData>?, error: Error?) -> Unit
|
|
|
- ){
|
|
|
|
|
|
|
+ ) {
|
|
|
MyOkHttpUtils().query(
|
|
MyOkHttpUtils().query(
|
|
|
- URL = SPUtils.getInstance().getString(Constant.goCommonSearchUrl) + "/TaAccount/QueryAmountLog",
|
|
|
|
|
|
|
+ URL = SPUtils.getInstance()
|
|
|
|
|
+ .getString(Constant.goCommonSearchUrl) + "/TaAccount/QueryAmountLog",
|
|
|
params = params,
|
|
params = params,
|
|
|
type = "1",
|
|
type = "1",
|
|
|
- callback = object : ResponseCallback<BaseResult<List<AmountLogData>>>(){
|
|
|
|
|
|
|
+ callback = object : ResponseCallback<BaseResult<List<AmountLogData>>>() {
|
|
|
override fun onResponse(response: BaseResult<List<AmountLogData>>?, id: Int) {
|
|
override fun onResponse(response: BaseResult<List<AmountLogData>>?, id: Int) {
|
|
|
responseBack(true, response?.data, null)
|
|
responseBack(true, response?.data, null)
|
|
|
}
|
|
}
|
|
@@ -416,6 +420,42 @@ class FutureManager {
|
|
|
)
|
|
)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 委托撤单
|
|
|
|
|
+ * @param orderId Long 委托单号
|
|
|
|
|
+ * @param marketId Int 市场id
|
|
|
|
|
+ * @param accountId Long 资金账户
|
|
|
|
|
+ * @param goodsId Int 商品id
|
|
|
|
|
+ */
|
|
|
|
|
+ fun cancelOrder(orderId: Long, marketId: Int, accountId: Long, goodsId: Int,
|
|
|
|
|
+ callback: (isCompleted: Boolean, err: Error?) -> Unit) {
|
|
|
|
|
+ val tradeSocketManager = MyApplication.getInstance()?.tradeSocketManager.guard {
|
|
|
|
|
+ callback(false, Error("交易链路未初始化"))
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ val reqPacket = FutureAdapter.getCancelOrderReqInfo(
|
|
|
|
|
+ orderId, marketId, accountId, goodsId
|
|
|
|
|
+ )
|
|
|
|
|
+
|
|
|
|
|
+ tradeSocketManager.send(
|
|
|
|
|
+ reqPacket,
|
|
|
|
|
+ FunCode.ChannelOrderRsp,
|
|
|
|
|
+ object : Callback<Packet50> {
|
|
|
|
|
+ override fun onSuccess(rsp: Packet50?) {
|
|
|
|
|
+ val rst = FutureAdapter.analysisChannelOrderRsq(rsp!!)
|
|
|
|
|
+ callback(rst.first, rst.second)
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ override fun onFail(err: Error?) {
|
|
|
|
|
+ // 发送数据失败
|
|
|
|
|
+ callback(false, err)
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ }
|
|
|
|
|
+ )
|
|
|
|
|
+
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|
|
}
|