You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
49 lines
1.5 KiB
49 lines
1.5 KiB
package dao |
|
|
|
import ( |
|
"context" |
|
"database/sql" |
|
"encoding/json" |
|
|
|
"go-common/app/common/openplatform/encoding" |
|
"go-common/app/service/openplatform/ticket-sales/api/grpc/type" |
|
rpc "go-common/app/service/openplatform/ticket-sales/api/grpc/v1" |
|
"go-common/library/log" |
|
) |
|
|
|
const ( |
|
// 更新购买人信息 |
|
_updateDetailBuyer = "update order_detail set buyer = ?,tel = ?,personal_id = ? where order_id = ?" |
|
// 更新配送信息 |
|
_updateDetailDelivery = "update order_detail set deliver_detail = ? where order_id = ?" |
|
) |
|
|
|
//UpdateDetailBuyer 更新购买人信息 |
|
func (d *Dao) UpdateDetailBuyer(c context.Context, req *rpc.UpBuyerRequest) (num int64, err error) { |
|
|
|
var res sql.Result |
|
PersonIDEnc, _ := encoding.Encrypt(req.Buyers.PersonalID, d.c.Encrypt) |
|
TelEnc, _ := encoding.Encrypt(req.Buyers.Tel, d.c.Encrypt) |
|
if res, err = d.db.Exec(c, _updateDetailBuyer, req.Buyers.Name, TelEnc, string(PersonIDEnc), req.OrderID); err != nil { |
|
log.Warn("更新订单详情%d失败", req.OrderID) |
|
return |
|
} |
|
return res.RowsAffected() |
|
} |
|
|
|
//UpdateDetailDelivery 更新配送信息 |
|
func (d *Dao) UpdateDetailDelivery(c context.Context, arg *_type.OrderDeliver, orderID int64) (num int64, err error) { |
|
var res sql.Result |
|
arg.Tel, _ = encoding.Encrypt(arg.Tel, d.c.Encrypt) |
|
DeliverDetail, err := json.Marshal(arg) |
|
|
|
if err != nil { |
|
log.Warn("更新订单详情%d失败", orderID) |
|
} |
|
|
|
if res, err = d.db.Exec(c, _updateDetailDelivery, string(DeliverDetail), orderID); err != nil { |
|
log.Warn("更新订单详情%d失败", orderID) |
|
return |
|
} |
|
return res.RowsAffected() |
|
}
|
|
|