50 lines
1.5 KiB
Go
50 lines
1.5 KiB
Go
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()
|
|
}
|