| | |
|---|
| | | |
|---|
| | | func UpdatePurchaseStatus(source, number string) { |
|---|
| | | if source == "SRM_PURCHASE" { |
|---|
| | | count, err := models.NewOperationSearch().SetSourceNumber(number).SetStatus(constvar.OperationStatus_Ready).Count() |
|---|
| | | if err != nil || count > 0 { |
|---|
| | | return |
|---|
| | | } |
|---|
| | | cl := purchase_wms.NewPurchaseServiceClient(init_client.SrmConn) |
|---|
| | | _, err := cl.UpdatePurchaseStatus(context.Background(), &purchase_wms.UpdatePurchaseStatusRequest{Number: number}) |
|---|
| | | _, err = cl.UpdatePurchaseStatus(context.Background(), &purchase_wms.UpdatePurchaseStatusRequest{Number: number}) |
|---|
| | | if err != nil { |
|---|
| | | logx.Errorf("grpc dial UpdatePurchaseStatus service error: %v", err) |
|---|
| | | } |
|---|
| | |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
| | | if err := db.Offset((params.Page - 1) * params.PageSize).Limit(params.PageSize).Find(&records).Error; err != nil { |
|---|
| | | if err := db.Offset((params.Page - 1) * params.PageSize).Limit(params.PageSize).Order("wms_operation.created_at desc").Find(&records).Error; err != nil { |
|---|
| | | util.ResponseFormat(c, code.RequestError, "查找失败:"+err.Error()) |
|---|
| | | return |
|---|
| | | } |
|---|
