package service

import (
	"app.yhyue.com/moapp/jyOrder/entity"
	"app.yhyue.com/moapp/jyOrder/rpc/jyOrder"
	"app.yhyue.com/moapp/jyOrder/util"
	"log"
)

type OrderService struct{}

func (s OrderService) CreateOrder(in *jyOrder.Request) (int64, string, int64) {
	orm := entity.Engine.NewSession()
	defer orm.Close()
	err0 := orm.Begin()
	if err0 != nil {
		log.Panicln("事务开启失败：", err0)
	}
	order := &entity.Order{}
	order.Pay_money = in.PayMoney
	order.Order_money = in.OrderMoney
	order.User_nickname = in.UserNickname
	order.Pay_time = util.ConversionDateTime(in.PayTime)
	order.Order_status = in.OrderStatus
	order.Create_time = util.ConversionDateTime(in.CreateTime)
	order.User_openid = in.UserOpenid
	order.Service_status = in.ServiceStatus
	order.Filter = in.Filter
	order.Prepay_id = in.PrepayId
	order.Code_url = in.CodeUrl
	order.Out_trade_no = in.OutTradeNo
	order.Filter_keys = in.FilterKeys
	order.Filter_publishtime = util.ConversionDateTime(in.FilterPublishtime)
	order.Data_count = in.DataCount
	order.User_mail = in.UserMail
	order.Data_spec = in.DataSpec
	order.Original_price = in.OriginalPrice
	order.Order_code = in.OrderCode
	order.Prepay_time = util.ConversionDateTime(in.PrepayTime)
	order.Product_type = in.ProductType
	order.Filter_id = in.FilterId
	order.Pay_way = in.PayWay
	order.User_phone = in.UserPhone
	order.Applybill_status = in.ApplybillStatus
	order.Download_url = in.DownloadUrl
	order.Applybill_type = in.ApplybillType
	order.Applybill_taxnum = in.ApplybillTaxnum
	order.Applybill_company = in.ApplybillCompany
	order.User_id = in.UserId
	order.Vip_starttime = util.ConversionDateTime(in.VipStarttime)
	order.Vip_endtime = util.ConversionDateTime(in.VipEndtime)
	order.Vip_type = in.VipType
	order.Course_status = in.CourseStatus
	order.Dis_word = in.DisWord
	order.Discount_price = in.DiscountPrice
	order.D_relation_id = in.DRelationId
	order.Return_status = in.ReturnStatus
	order.Refund_status = in.RefundStatus
	order.Is_backstage_order = in.IsBackstageOrder
	order.Salesperson = in.Salesperson
	order.Company_name = in.CompanyName
	order.BillingMode = in.BillingMode
	order.Sale_time = util.ConversionDateTime(in.SaleTime)
	if in.EntryTime != "" {
		order.Entry_time = util.ConversionDateTime(in.EntryTime)
	}
	order.Commission = in.Commission
	order.ProceduresMoney = in.ProceduresMoney
	order.DistributionChannel = in.SalesChannel
	order.OrderChannel = in.OrderChannel
	order.SigningSubject = in.PaybackCompany
	order.SalespersonId = in.SalespersonId
	order.CreatePerson = in.CreatePerson
	/*order.Payment_type = in.PaymentType
	order.Source_order_id = in.SourceOrderId*/

	numb, err := orm.Table("dataexport_order").Insert(order)
	log.Println(numb, err)
	if err != nil || numb == int64(0) {
		log.Panicln("创建订单失败：", err)
		orm.Rollback()
		return entity.ErrorCode, "创建订单失败", entity.ErrorCode
	}
	orm.Commit()
	return entity.SuccessCode, "创建订单成功", order.Id
}

func (s OrderService) CreateOrderDetailed(in *jyOrder.RequestDetailed) (int64, string, int64) {
	orm := entity.Engine.NewSession()
	defer orm.Close()
	err0 := orm.Begin()
	if err0 != nil {
		log.Panicln("事务开启失败：", err0)
	}
	orderDetailed := &entity.OrderDetailed{}
	orderDetailed.Order_id = in.OrderId
	orderDetailed.Relation_id = in.RelationId
	orderDetailed.Operator = in.Operator
	orderDetailed.Sale_time = util.ConversionDateTime(in.SaleTime)
	numb, err := orm.Table("dataexport_order_detailed").Insert(orderDetailed)
	if err != nil || numb == int64(0) {
		log.Panicln("创建订单明细失败：", err)
		orm.Rollback()
		return entity.ErrorCode, "创建订单明细失败", entity.ErrorCode
	}
	orm.Commit()
	return entity.SuccessCode, "创建订单明细成功", orderDetailed.Id
}