瀏覽代碼

fix:最近一次更新订单记录

duxin 1 月之前
父節點
當前提交
75e30cc9e3

+ 5 - 1
internal/controller/orderHandler.go

@@ -259,6 +259,7 @@ func SaveOrderHandler(r *ghttp.Request) {
 				"zero_type":             param.ZeroOrderType,
 				"remark":                param.OrderRemark,
 				"user_id":               jyutil.GetCommonUserIdByPhone(ctx, param.PersonPhone, param.CompanyName, param.BuySubject),
+				"last_update_time":      date.NowFormat(date.Date_Full_Layout),
 				"return_status":         common.If(param.ContractMoney == 0, 1, 0),
 			}); err != nil {
 				return gerror.Wrap(err, "插入订单表异常")
@@ -385,6 +386,7 @@ func UpdateOrderHandler(r *ghttp.Request) {
 				"buy_subject":           param.BuySubject,
 				"payment_user":          param.PaymentUser,
 				"zero_type":             param.ZeroOrderType,
+				"last_update_time":      date.NowFormat(date.Date_Full_Layout),
 				"remark":                param.OrderRemark,
 				"user_id":               jyutil.GetCommonUserIdByPhone(ctx, param.PersonPhone, param.CompanyName, param.BuySubject),
 				"return_status":         common.If(param.ContractMoney == 0, 1, 0),
@@ -408,6 +410,7 @@ func UpdateOrderHandler(r *ghttp.Request) {
 				}
 			}
 			//编辑回退订单或未完成订单
+			upOrder["last_update_time"] = date.NowFormat(date.Date_Full_Layout)
 			if _, err = g.DB().Ctx(ctx).Update(ctx, "dataexport_order", upOrder, "order_code=? and order_status=0 ", param.OrderCode); err != nil {
 				return gerror.Wrap(err, "修改订单表内容异常")
 			}
@@ -442,7 +445,8 @@ func UpdateOrderHandler(r *ghttp.Request) {
 			}
 			if len(delDetailIds) > 0 { //存在删除的订单
 				g.DB().Ctx(ctx).Update(ctx, "dataexport_order", map[string]interface{}{
-					"status": -1,
+					"status":           -1,
+					"last_update_time": date.NowFormat(date.Date_Full_Layout),
 				}, fmt.Sprintf(" id in (%s)", strings.Join(delDetailIds, ",")))
 			}
 			return nil

+ 1 - 0
internal/logic/order/cancellation.go

@@ -59,6 +59,7 @@ func Cancellation(ctx context.Context, param model.OrderDetailParams) error {
 			return errors.New("订单回退记录失败")
 		}
 	}
+	upOrder["last_update_time"] = date.NowFormat(date.Date_Full_Layout)
 	g.DB().Update(ctx, "dataexport_order", upOrder, map[string]interface{}{
 		"order_code": param.OrderCode,
 	})

+ 1 - 0
internal/logic/order/editBatchReturn.go

@@ -171,6 +171,7 @@ func EditBatchReturn(ctx context.Context, param model.OrdersEditBatchReturn) err
 		if gconv.Int(value["order_status"]) == 0 {
 			updateData["order_status"] = 1
 		}
+		updateData["last_update_time"] = date.NowFormat(date.Date_Full_Layout)
 		_, err1 := g.DB().Ctx(ctx).Update(ctx, "dataexport_order", updateData, map[string]interface{}{"id": value["id"]})
 		if err1 != nil {
 			return err1

+ 1 - 0
internal/logic/order/examine.go

@@ -200,6 +200,7 @@ func OrdersExamine(ctx context.Context, param model.OrdersExamine) error {
 		}
 	}
 	//更新订单
+	upData["last_update_time"] = date.NowFormat(date.Date_Full_Layout)
 	_, err = g.DB().Ctx(ctx).Update(ctx, "dataexport_order", upData, map[string]interface{}{"order_code": param.OrderCode})
 	if err != nil {
 		return err

+ 1 - 1
internal/logic/order/logicalDelOrder.go

@@ -18,7 +18,7 @@ import (
 // OrderLogicalDelOrder 删除
 func OrderLogicalDelOrder(ctx context.Context, param model.OrderCopyLinkParams) (interface{}, error) {
 	ok := true
-	_, err := g.DB().Ctx(ctx).Update(ctx, "dataexport_order", map[string]interface{}{"del_status": 1, "del_time": date.NowFormat(date.Date_Full_Layout)}, map[string]interface{}{"id": param.Id})
+	_, err := g.DB().Ctx(ctx).Update(ctx, "dataexport_order", map[string]interface{}{"del_status": 1, "del_time": date.NowFormat(date.Date_Full_Layout), "last_update_time": date.NowFormat(date.Date_Full_Layout)}, map[string]interface{}{"id": param.Id})
 	if err == nil {
 		orderData, _ := g.DB().Ctx(ctx).GetOne(ctx, fmt.Sprintf("SELECT * FROM dataexport_order WHERE id =%s", param.Id))
 		if !orderData.IsEmpty() {

+ 1 - 1
internal/logic/order/redPunch.go

@@ -214,7 +214,7 @@ func OperateOrderRedPunch(ctx context.Context, params model.OrderRedPunchParams)
 			return err
 		}
 	}
-
+	updateData["last_update_time"] = date.NowFormat(date.Date_Full_Layout)
 	g.DB().Update(ctx, "dataexport_order", updateData, map[string]interface{}{"order_code": params.OrderCode})
 	for _, m := range insertDataArr {
 		g.DB().Insert(ctx, "moneyCorrection", m)

+ 5 - 3
internal/logic/order/refund.go

@@ -24,7 +24,8 @@ func ConfirmRefund(ctx context.Context, param model.OrderRefundParams) error {
 	qMap["order_code"] = orderCode
 	if param.IsOffline == 0 {
 		_, err := g.DB().Update(ctx, "dataexport_order", map[string]interface{}{
-			"refund_status": param.RefundStatus,
+			"refund_status":    param.RefundStatus,
+			"last_update_time": date.NowFormat(date.Date_Full_Layout),
 			//"order_status":  -2,
 		}, qMap)
 		if err == nil {
@@ -109,8 +110,9 @@ func ConfirmRefund(ctx context.Context, param model.OrderRefundParams) error {
 			returnStatus = 2
 		}
 		_, err := g.DB().Update(ctx, "dataexport_order", map[string]interface{}{
-			"refund_status": param.RefundStatus,
-			"return_status": returnStatus,
+			"refund_status":    param.RefundStatus,
+			"return_status":    returnStatus,
+			"last_update_time": date.NowFormat(date.Date_Full_Layout),
 		}, qMap)
 		return err
 

+ 3 - 1
internal/logic/order/saleRecord.go

@@ -2,6 +2,7 @@ package order
 
 import (
 	"app.yhyue.com/moapp/jybase/common"
+	"app.yhyue.com/moapp/jybase/date"
 	"context"
 	"fmt"
 	"github.com/gogf/gf/v2/frame/g"
@@ -433,7 +434,8 @@ func CommonChange(ctx context.Context, orderCode, operationTime string, operatio
 		return err
 	}
 	if _, err := g.DB().Update(ctx, "dataexport_order", g.Map{
-		"sale_time": affectTime,
+		"sale_time":        affectTime,
+		"last_update_time": date.NowFormat(date.Date_Full_Layout),
 	}, "order_code=?", orderCode); err != nil {
 		log.Printf("TakeEffectSale  %d %s", operationType, err.Error())
 	}

+ 3 - 1
internal/logic/order/serviceOpen.go

@@ -1,6 +1,7 @@
 package order
 
 import (
+	"app.yhyue.com/moapp/jybase/date"
 	"context"
 	"errors"
 	"fmt"
@@ -27,7 +28,8 @@ func ServiceOpen(ctx context.Context, param model.OrderOpenServiceParams) error
 	}
 	if gconv.String(orderData.Map()["user_phone"]) != param.Phone {
 		g.DB().Update(ctx, "dataexport_order", map[string]interface{}{
-			"user_phone": param.Phone,
+			"user_phone":       param.Phone,
+			"last_update_time": date.NowFormat(date.Date_Full_Layout),
 		}, map[string]interface{}{
 			"order_code": param.OrderCode,
 		})

+ 4 - 2
internal/logic/order/transferAccounts.go

@@ -2,6 +2,7 @@ package order
 
 import (
 	"app.yhyue.com/moapp/jybase/common"
+	"app.yhyue.com/moapp/jybase/date"
 	"app.yhyue.com/moapp/jybase/mongodb"
 	frpc "app.yhyue.com/moapp/jybase/rpc"
 	"context"
@@ -19,8 +20,9 @@ func TransferAccounts(ctx context.Context, param model.TransferAccountsParams) (
 	qMap := map[string]interface{}{}
 	qMap["order_code"] = orderCode
 	_, _ = g.DB().Update(ctx, "dataexport_order", map[string]interface{}{
-		"course_status": param.CourseStatus,
-		"pay_money":     param.PayMoney,
+		"course_status":    param.CourseStatus,
+		"pay_money":        param.PayMoney,
+		"last_update_time": date.NowFormat(date.Date_Full_Layout),
 	}, qMap)
 
 	if param.CourseStatus == 4 {

+ 2 - 1
internal/logic/order/uploadContractFile.go

@@ -2,6 +2,7 @@ package order
 
 import (
 	"app.yhyue.com/moapp/jybase/common"
+	"app.yhyue.com/moapp/jybase/date"
 	"context"
 	"errors"
 	"fmt"
@@ -45,7 +46,7 @@ func UploadContractFile(ctx context.Context, param model.UploadContract) error {
 			return err
 		}
 		if isCommonChange {
-			g.DB().Update(ctx, "dataexport_order", map[string]interface{}{"order_status": 1}, map[string]interface{}{
+			g.DB().Update(ctx, "dataexport_order", map[string]interface{}{"order_status": 1, "last_update_time": date.NowFormat(date.Date_Full_Layout)}, map[string]interface{}{
 				"order_code": param.OrderCode,
 			})
 		}

+ 3 - 1
internal/logic/product/otherProduct/saveUpdate.go

@@ -2,6 +2,7 @@ package otherProduct
 
 import (
 	"app.yhyue.com/moapp/jybase/common"
+	"app.yhyue.com/moapp/jybase/date"
 	"context"
 	"encoding/json"
 	"fmt"
@@ -104,7 +105,8 @@ func (p jyOtherProduct) SaveUpdate(ctx context.Context, masterKey string) error
 			}
 			filterStr, _ := json.Marshal(filterMap)
 			g.DB().Update(ctx, "dataexport_order", map[string]interface{}{
-				"filter": gconv.String(filterStr),
+				"filter":           gconv.String(filterStr),
+				"last_update_time": date.NowFormat(date.Date_Full_Layout),
 			}, map[string]interface{}{
 				"order_code": p.CycleClassOrderDetail.OrderCode,
 			})

+ 2 - 0
internal/logic/timedTask/automaticPayment.go

@@ -1,6 +1,7 @@
 package timedTask
 
 import (
+	"app.yhyue.com/moapp/jybase/date"
 	"app.yhyue.com/moapp/jybase/redis"
 	"context"
 	"encoding/json"
@@ -140,6 +141,7 @@ WHERE
 							}
 							if returnId > 0 {
 								log.Println("自动回款创建回款记录成功", id, orderCode)
+								updateData["last_update_time"] = date.NowFormat(date.Date_Full_Layout)
 								g.DB().Update(ctx, "dataexport_order", updateData, map[string]interface{}{"order_code": orderCode})
 								g.DB("cbs").Update(ctx, "transaction", map[string]interface{}{"ISRELATION": 1, "return_id": fmt.Sprint(returnId)}, map[string]interface{}{"id": id})
 								log.Println("自动回款开通权益", orderCode, gconv.Int(o["return_status"]), updateData["return_status"], returned_money, returnMoney, money)

+ 2 - 1
internal/logic/timedTask/onlineReturnMoney.go

@@ -1,6 +1,7 @@
 package timedTask
 
 import (
+	"app.yhyue.com/moapp/jybase/date"
 	"context"
 	"fmt"
 	"github.com/gogf/gf/v2/database/gdb"
@@ -72,7 +73,7 @@ func OnlineReturnMoney() {
 				} else {
 					orderUpdate["return_status"] = 2
 				}
-
+				orderUpdate["last_update_time"] = date.NowFormat(date.Date_Full_Layout)
 				if _, err := g.DB().Update(ctx, "dataexport_order", orderUpdate, map[string]interface{}{"order_code": orderCode}); err != nil {
 					return err
 				}