From 64e57cf446f66221df729f89889bfc6fb915b7a1 Mon Sep 17 00:00:00 2001
From: maliang <maliang@lymsh.com>
Date: Tue, 14 Mar 2017 09:09:20 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4LinkedWork?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/lyms/synch/LinkedWork.java   | 14 -------------
 .../src/main/java/com/lyms/synch/SyncnCenter.java  | 24 ++++++++++++++++++++++
 2 files changed, 24 insertions(+), 14 deletions(-)
 delete mode 100644 core.sdk/src/main/java/com/lyms/synch/LinkedWork.java

diff --git a/core.sdk/src/main/java/com/lyms/synch/LinkedWork.java b/core.sdk/src/main/java/com/lyms/synch/LinkedWork.java
deleted file mode 100644
index c451929..0000000
--- a/core.sdk/src/main/java/com/lyms/synch/LinkedWork.java
+++ /dev/null
@@ -1,14 +0,0 @@
-package com.lyms.synch;
-
-/**
- * <li>@ClassName: LinkedWork
- * <li>@Description: 任务链表
- * <p>
- * 主要解决多任务循环执行的过程
- * <li>@author maliang
- * <li>@date 2017年3月13日
- * <li>
- */
-public class LinkedWork {
-
-}
diff --git a/core.sdk/src/main/java/com/lyms/synch/SyncnCenter.java b/core.sdk/src/main/java/com/lyms/synch/SyncnCenter.java
index d7aef6f..ff9a89a 100644
--- a/core.sdk/src/main/java/com/lyms/synch/SyncnCenter.java
+++ b/core.sdk/src/main/java/com/lyms/synch/SyncnCenter.java
@@ -10,6 +10,7 @@ import com.lyms.synch.entity.ModelType;
 import com.lyms.synch.entity.SyncnModel;
 import com.lyms.synch.queue.SyncnQueue;
 import com.lyms.util.HttpUtils;
+import com.lyms.util.StrUtils;
 
 /**
  * <li>@ClassName: SyncnCenter
@@ -133,6 +134,29 @@ public class SyncnCenter {
 		}
 
 		/**
+		 * <li>@Description:回调方法，调用远端接口
+		 * <p>
+		 * 跟 {@link #ackGet(Map)} {@link #ackPost(Map)} 的区别是，后两者需要自己设定callback
+		 * 地址跟参数，可以指定任意地址
+		 * <li>@return
+		 * <li>创建人：maliang
+		 * <li>创建时间：2017年3月14日
+		 * <li>修改人：
+		 * <li>修改时间：
+		 */
+		public String ack(Object object) {
+			if (model != null && StringUtils.isNotBlank(model.getRemote())) {
+				model.setId(StrUtils.uuid());
+				model.setMethod("POST");
+				model.setTs(System.currentTimeMillis());
+				model.setData(object);
+				model.setType(ModelType.ACK.name());
+				return HttpUtils.REMOTE.post(model);
+			}
+			return null;
+		}
+
+		/**
 		 * <li>@Description:该方法为回执方法，将会调用目标接口，返回提示对应消息处理成功
 		 * <p>
 		 * 使用方式 pull(type,callBack).ackGet();
-- 
1.8.3.1