diff --git a/business/jxutils/tasksch/task.go b/business/jxutils/tasksch/task.go
index 8bc3a63ce..bb04f2c5a 100644
--- a/business/jxutils/tasksch/task.go
+++ b/business/jxutils/tasksch/task.go
@@ -3,7 +3,8 @@ package tasksch
 import (
 	"encoding/json"
 	"fmt"
-	"git.rosy.net.cn/jx-callback/business/jxutils/weixinmsg"
+	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
+	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
 	"strings"
 	"sync"
 	"time"
@@ -173,6 +174,18 @@ func (t *BaseTask) GetID() string {
 	return t.ID
 }
 
+func (t *BaseTask) GetIsGetResultCalled() bool {
+	return t.isGetResultCalled
+}
+
+func (t *BaseTask) GetParent() ITask {
+	return t.parent
+}
+
+func (t *BaseTask) GetContext() *jxcontext.Context {
+	return t.ctx
+}
+
 func (t *BaseTask) Run() {
 }
 
@@ -495,8 +508,7 @@ func SendMessage(t *BaseTask) {
 			} else {
 				content += ",\n" + t.Error()
 			}
-			// ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content)
-			weixinmsg.SendMsgToUser(authInfo.UserID, weixinmsg.WX_NORMAL_STORE_MSG_TEMPLATE_ID, "异步任务完成:"+content)
+			ddmsg.SendUserMessage(dingdingapi.MsgTyeText, authInfo.UserID, "异步任务完成", content)
 		}
 	}
 }
diff --git a/business/partner/purchase/jd/store.go b/business/partner/purchase/jd/store.go
index b0a5c3996..b9ae1feff 100644
--- a/business/partner/purchase/jd/store.go
+++ b/business/partner/purchase/jd/store.go
@@ -159,6 +159,9 @@ func (p *PurchaseHandler) UpdateStore(db *dao.DaoDB, storeID int, userName strin
 			} else {
 				storeParams.OutSystemID = store.VendorStoreID
 			}
+			if storeParams.OutSystemID == "" {
+				storeParams.OutSystemID = utils.Int2Str(store.ID)
+			}
 			if store.SyncStatus&(model.SyncFlagNewMask|model.SyncFlagStoreName) != 0 {
 				if store.VendorStoreName != "" {
 					storeParams.StationName = store.VendorStoreName
@@ -205,7 +208,6 @@ func (p *PurchaseHandler) UpdateStore(db *dao.DaoDB, storeID int, userName strin
 				modifyCloseStatus = true
 				_, storeParams.CloseStatus = JxStoreStatus2JdStatus(jxutils.MergeStoreStatus(store.Status, store.JdStoreStatus)) // 1storeParams.CloseStatus
 			}
-
 			fillOpTimeParams(storeParams, store.GetOpTimeList())
 			errList := errlist.New()
 			if globals.EnableJdStoreWrite {