- add jd order comment msg.

business/jd/controller/order.go

@@ -194,28 +194,31 @@ func adjustOrder(order *jdapi.CallbackOrderMsg) error {
 	return newOrder(order)
 }
 
-func normalOrderStatus(order *jdapi.CallbackOrderMsg) error {
-	db := orm.NewOrm()
-	rec := &models.Jdorder{
-		JdOrderID: utils.Str2Int64(order.BillID),
-	}
-
-	err := db.Read(rec, "JdOrderId")
-	if err != nil {
-		globals.SugarLogger.Warnf("error when accessing db:%v", err)
+func normalOrderStatus(msg *jdapi.CallbackOrderMsg) (err error) {
+	if msg.StatusID == jdapi.OrderStatusAddComment || msg.StatusID == jdapi.OrderStatusModifyComment {
+		err = globals2.FreshFoodAPI.JDOrderComment(msg)
 	} else {
-		if rec.OrderStatus == utils.Str2Int(order.StatusID) {
-			globals.SugarLogger.Infof("Duplicate message order:%v", order)
-		} else {
-			rec.OrderStatus = utils.Str2Int(order.StatusID)
-			rec.OrderStatusTime = order.Timestamp
+		db := orm.NewOrm()
+		rec := &models.Jdorder{
+			JdOrderID: utils.Str2Int64(msg.BillID),
+		}
 
-			if err = globals2.FreshFoodAPI.JDOrderStatus(rec); err == nil {
-				rec.Code = "0"
-				err = utils.CallFuncLogError(func() error {
-					_, err := db.Update(rec, "OrderStatus", "OrderStatusTime", "Code")
-					return err
-				}, globals2.ErrStrAccessDB)
+		err = db.Read(rec, "JdOrderId")
+		if err != nil {
+			globals.SugarLogger.Warnf("error when accessing db:%v", err)
+		} else {
+			if rec.OrderStatus == utils.Str2Int(msg.StatusID) {
+				globals.SugarLogger.Infof("Duplicate message msg:%v", msg)
+			} else {
+				if err = globals2.FreshFoodAPI.JDOrderStatus(msg); err == nil {
+					rec.OrderStatus = utils.Str2Int(msg.StatusID)
+					rec.OrderStatusTime = msg.Timestamp
+					rec.Code = "0"
+					err = utils.CallFuncLogError(func() error {
+						_, err := db.Update(rec, "OrderStatus", "OrderStatusTime", "Code")
+						return err
+					}, globals2.ErrStrAccessDB)
+				}
 			}
 		}
 	}