自动回复

business/partner/purchase/mtwm/order_comment.go

@@ -1,6 +1,8 @@
 package mtwm
 
 import (
+	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
+	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
 	"strings"
 	"time"
 
@@ -53,9 +55,13 @@ func (c *PurchaseHandler) RefreshComment(fromTime, toTime time.Time) (err error)
 	task := tasksch.NewParallelTask("mtwm RefreshComment", nil, jxcontext.AdminCtx,
 		func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
 			storeID := batchItemList[0].(int)
+
 			storeDetail, _ := dao.GetStoreDetail(dao.GetDB(), storeID, model.VendorIDMTWM, "")
 			commentList, _ := getAPI(storeDetail.VendorOrgCode, storeID, storeDetail.VendorStoreID).CommentQuery(storeDetail.VendorStoreID, startDateStr, endDateStr, 0, 0, mtwmapi.CommentReplyStatusNotReplied)
 			var orderCommentList []*model.OrderComment
+			if storeID == 669247 {
+				ddmsg.SendUserMessage(dingdingapi.MsgTyeText, "2452A93EEB9111EC9B06525400E86DC0", "自动好评回复:", utils.Int2Str(669247)+":"+utils.Int2Str(len(commentList)))
+			}
 			if len(commentList) == model.NO || commentList == nil {
 				return nil, nil
 			}