wip:tj

internal/logic/product/subvip/check.go

@@ -64,7 +64,7 @@ func (p jySubVipProduct) Check(ctx context.Context, t int) error {
 			switch p.OrderDetail.ReqSubject {
 			case 1: //个人
 				if p.OrderDetail.ServiceType == 1 || p.OrderDetail.ServiceType == 4 { //校验是否有待生效的订单
-					num, err := g.DB().GetCount(ctx, "SELECT * FROM dataexport_order d inner join jy_order_detail jyd on(d.order_code=jyd.order_code) WHERE d.user_phone=? and jyd.product_type= 'VIP订阅' and (jyd.vip_type=0 or jyd.vip_type=3)", p.OrderDetail.Phone)
+					num, err := g.DB().GetCount(ctx, "SELECT count(*) FROM dataexport_order d inner join jy_order_detail jyd on(d.order_code=jyd.order_code) WHERE d.user_phone=? and jyd.product_type= 'VIP订阅' and (jyd.service_type=0 or jyd.service_type=3)", p.OrderDetail.Phone)
 					if err != nil {
 						return gerror.Wrapf(err, "查询账户订单信息异常")
 					}
@@ -72,7 +72,7 @@ func (p jySubVipProduct) Check(ctx context.Context, t int) error {
 						return errors.New("已存在同类型订单")
 					}
 				} else { //关联id是否存在
-					num, err := g.DB().GetCount(ctx, "SELECT * FROM jy_order_detail  WHERE status =1 and is_service_open=1 and  product_type ='VIP订阅' and d.linked_detail_id=? and  service_endtime>? ", p.OrderDetail.LinkedOrderId, time.Now().Format(time.DateTime))
+					num, err := g.DB().GetCount(ctx, "SELECT count(*) FROM jy_order_detail  WHERE status =1 and is_service_open=1 and  product_type ='VIP订阅' and d.linked_detail_id=? and  service_endtime>? ", p.OrderDetail.LinkedOrderId, time.Now().Format(time.DateTime))
 					if err != nil {
 						return gerror.Wrapf(err, "查询账户权益信息异常")
 					}
@@ -94,7 +94,7 @@ func (p jySubVipProduct) Check(ctx context.Context, t int) error {
 			case 2: //企业
 				//校验当前套餐内容是否满足升级续费
 				if p.OrderDetail.ServiceType == 3 || p.OrderDetail.ServiceType == 5 {
-					num, err := g.DB().GetCount(ctx, "SELECT * FROM jy_order_detail d inner join entniche_order eo (on d.id =eo.order_detail_id) inner join entniche_wait_empower ewe on(eo.wait_empower_id=ewe.id ) WHERE  d.status =1 and d.is_service_open=1 and  d.product_type ='VIP订阅' and d.linked_detail_id=? and ewe.ent_id=? and end_time>?", p.OrderDetail.LinkedOrderId, entId, time.Now().Format(time.DateTime))
+					num, err := g.DB().GetCount(ctx, "SELECT count(*) FROM jy_order_detail d inner join entniche_order eo (on d.id =eo.order_detail_id) inner join entniche_wait_empower ewe on(eo.wait_empower_id=ewe.id ) WHERE  d.status =1 and d.is_service_open=1 and  d.product_type ='VIP订阅' and d.linked_detail_id=? and ewe.ent_id=? and end_time>?", p.OrderDetail.LinkedOrderId, entId, time.Now().Format(time.DateTime))
 					if err != nil {
 						return gerror.Wrapf(err, "查询账户权益信息异常")
 					}