调整单调整的商品发给赵哥

business/jxcallback/scheduler/basesch/basesch_ext.go

@@ -2,12 +2,15 @@ package basesch
 
 import (
 	"fmt"
+	"strings"
 	"time"
 
+	"git.rosy.net.cn/baseapi/platformapi/dingdingapi"
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/baseapi/utils/errlist"
 	"git.rosy.net.cn/jx-callback/business/jxstore/cms"
 	"git.rosy.net.cn/jx-callback/business/jxutils"
+	"git.rosy.net.cn/jx-callback/business/jxutils/ddmsg"
 	"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
 	"git.rosy.net.cn/jx-callback/business/jxutils/tasksch"
 	"git.rosy.net.cn/jx-callback/business/model"
@@ -123,6 +126,18 @@ func (c *BaseScheduler) PickupGoodsAndUpdateStatus(ctx *jxcontext.Context, vendo
 func (c *BaseScheduler) AdjustOrder(ctx *jxcontext.Context, order *model.GoodsOrder, removedSkuList []*model.OrderSku, reason string) (err error) {
 	if c.IsReallyCallPlatformAPI {
 		err = partner.GetPurchaseOrderHandlerFromVendorID(order.VendorID).AdjustOrder(ctx, order, removedSkuList, reason)
+		if err == nil {
+			var skuIDs []string
+			for _, v := range removedSkuList {
+				skuIDs = append(skuIDs, utils.Int2Str(v.SkuID))
+			}
+			noticeMsg := fmt.Sprintf("商品skuID列表：%v，订单号(点击进入详情)：%v", strings.Join(skuIDs, ","), globals.BackstageHost+"/#/ordermanager/"+order.VendorOrderID)
+			user, err := dao.GetUserByID(dao.GetDB(), "mobile", "18982250714")
+			if user != nil && err == nil {
+				ddmsg.SendUserMessage(dingdingapi.MsgTyeText, user.UserID, "调整单调整商品", noticeMsg)
+			}
+
+		}
 	}
 	return err
 }