1

business/partner/im/im.go

@@ -547,6 +547,7 @@ func CheckAndReply(req *JXMsg, elmAppID string) (err error) {
 			} else {
 				temp.MsgContent = AutoReplyByAppID[mt.AppID]
 			}
+			temp.MsgSource = mtwmapi.MsgSourceStore
 			temp.Cts = int(time.Now().Unix())
 			temp.MsgID = RandTimeNumber()
 
@@ -611,28 +612,18 @@ func GetCustomTemplate(appID, vendorStoreID string) (storeTemplate string) {
 	return storeTemplate
 }
 
-// AddOrGetCustomReply 增加以及获取门店自定义回复模板
-func AddOrGetCustomReply(appID, vendorStoreID, replyTemplate string, opType int) (storeTemplate string, err error) {
-	if len(appID) == 0 || len(vendorStoreID) == 0 {
+// AddCustomReply 增加门店自定义回复模板
+func AddCustomReply(appID, vendorStoreID, replyTemplate string) (storeTemplate string, err error) {
+	if len(appID) == 0 || len(vendorStoreID) == 0 || len(replyTemplate) == 0 {
 		return "", errors.New("参数错误请检查！")
 	}
 
 	key := GenCustomReplyID(appID, vendorStoreID)
 
-	switch opType {
-	case OpTypeAdd: //新增或修改
-		if len(replyTemplate) == 0 {
-			return "", errors.New("新增或修改门店自定义回复模板，不允许为空")
-		}
-		err = rdb.Del(key)
-		if err == nil {
-			err = rdb.Set(key, replyTemplate, 0)
-		}
-		return "", err
-
-	case OpTypeGet:
-		storeTemplate = GetCustomTemplate(appID, vendorStoreID)
-		return storeTemplate, nil
+	err = rdb.Del(key)
+	if err == nil {
+		err = rdb.Set(key, replyTemplate, 0)
 	}
-	return "", nil
+	return "", err
+
 }