|
@@ -3768,7 +3768,7 @@ func NewBigOrder(subStatus, dateType int, startdate, enddate time.Time, userId,
|
|
order_id := util.JyOrder("/CreateOrder", paramOrder)
|
|
order_id := util.JyOrder("/CreateOrder", paramOrder)
|
|
log.Println("大会员创建订单", userId, order_id, code)
|
|
log.Println("大会员创建订单", userId, order_id, code)
|
|
if 0 < order_id {
|
|
if 0 < order_id {
|
|
- defer ClearBigVipUserPower(qutil.InterfaceToStr(paramOrder["user_id"])) //订单创建成功后默认清空权限缓存
|
|
|
|
|
|
+ defer ClearBigVipUserPower(fmt.Sprint(qutil.Int64All(paramOrder["user_id"]))) //订单创建成功后默认清空权限缓存
|
|
// 销售渠道为内部员工赠送及豁免用户赠送时更新用户人群分类
|
|
// 销售渠道为内部员工赠送及豁免用户赠送时更新用户人群分类
|
|
if param.SalesChannel == util.SaleChannel052 || param.SalesChannel == util.SaleChannel053 {
|
|
if param.SalesChannel == util.SaleChannel052 || param.SalesChannel == util.SaleChannel053 {
|
|
UpdateUserType(param.SalesChannel, userId)
|
|
UpdateUserType(param.SalesChannel, userId)
|
|
@@ -3860,7 +3860,7 @@ func NewBigOrder(subStatus, dateType int, startdate, enddate time.Time, userId,
|
|
}
|
|
}
|
|
}
|
|
}
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
- serverDatas := util.JysqlDB.SelectBySql(sqls, serverId, qutil.InterfaceToStr(paramOrder["user_id"]))
|
|
|
|
|
|
+ serverDatas := util.JysqlDB.SelectBySql(sqls, serverId, fmt.Sprint(qutil.Int64All(paramOrder["user_id"])))
|
|
if serverDatas != nil && len(*serverDatas) > 0 {
|
|
if serverDatas != nil && len(*serverDatas) > 0 {
|
|
i_status := qutil.If(dateType == 1, 0, 1)
|
|
i_status := qutil.If(dateType == 1, 0, 1)
|
|
sql := ""
|
|
sql := ""
|
|
@@ -3869,14 +3869,14 @@ func NewBigOrder(subStatus, dateType int, startdate, enddate time.Time, userId,
|
|
} else {
|
|
} else {
|
|
sql = "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ?,l_starttime = ?,l_endtime = ?,i_status = ? where s_serviceid = ? and s_userid = ?"
|
|
sql = "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ?,l_starttime = ?,l_endtime = ?,i_status = ? where s_serviceid = ? and s_userid = ?"
|
|
}
|
|
}
|
|
- status1 := util.JysqlDB.UpdateOrDeleteBySql(sql, fmt.Sprint(frequency), qutil.NowFormat(qutil.Date_Full_Layout), qutil.FormatDate(&startdate, qutil.Date_Full_Layout), qutil.FormatDate(&enddate, qutil.Date_Full_Layout), fmt.Sprint(i_status), serverId, qutil.InterfaceToStr(paramOrder["user_id"]))
|
|
|
|
|
|
+ status1 := util.JysqlDB.UpdateOrDeleteBySql(sql, fmt.Sprint(frequency), qutil.NowFormat(qutil.Date_Full_Layout), qutil.FormatDate(&startdate, qutil.Date_Full_Layout), qutil.FormatDate(&enddate, qutil.Date_Full_Layout), fmt.Sprint(i_status), serverId, fmt.Sprint(qutil.Int64All(paramOrder["user_id"])))
|
|
if status1 < 0 {
|
|
if status1 < 0 {
|
|
return errors.New("新建服务-更新服务表出错")
|
|
return errors.New("新建服务-更新服务表出错")
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
insert := map[string]interface{}{
|
|
insert := map[string]interface{}{
|
|
"s_smainid": mainId,
|
|
"s_smainid": mainId,
|
|
- "s_userid": qutil.InterfaceToStr(paramOrder["user_id"]),
|
|
|
|
|
|
+ "s_userid": fmt.Sprint(qutil.Int64All(paramOrder["user_id"])),
|
|
"s_serviceid": serverId,
|
|
"s_serviceid": serverId,
|
|
"i_frequency": frequency,
|
|
"i_frequency": frequency,
|
|
"l_starttime": qutil.FormatDate(&startdate, qutil.Date_Full_Layout),
|
|
"l_starttime": qutil.FormatDate(&startdate, qutil.Date_Full_Layout),
|
|
@@ -3887,7 +3887,7 @@ func NewBigOrder(subStatus, dateType int, startdate, enddate time.Time, userId,
|
|
}
|
|
}
|
|
order_id := util.JysqlDB.Insert("bigmember_service_user", insert)
|
|
order_id := util.JysqlDB.Insert("bigmember_service_user", insert)
|
|
if order_id > 0 {
|
|
if order_id > 0 {
|
|
- log.Println("用户服务表插入成功", qutil.InterfaceToStr(paramOrder["user_id"]))
|
|
|
|
|
|
+ log.Println("用户服务表插入成功", fmt.Sprint(qutil.Int64All(paramOrder["user_id"])))
|
|
} else {
|
|
} else {
|
|
return errors.New("用户服务表插入失败")
|
|
return errors.New("用户服务表插入失败")
|
|
}
|
|
}
|
|
@@ -3918,17 +3918,17 @@ func NewBigOrder(subStatus, dateType int, startdate, enddate time.Time, userId,
|
|
}
|
|
}
|
|
}
|
|
}
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
- serverDatas := util.JysqlDB.SelectBySql(sqls, serverId, qutil.InterfaceToStr(paramOrder["user_id"]))
|
|
|
|
|
|
+ serverDatas := util.JysqlDB.SelectBySql(sqls, serverId, fmt.Sprint(qutil.Int64All(paramOrder["user_id"])))
|
|
if serverDatas != nil && len(*serverDatas) > 0 {
|
|
if serverDatas != nil && len(*serverDatas) > 0 {
|
|
i_status := qutil.If(dateType == 1, 0, 1)
|
|
i_status := qutil.If(dateType == 1, 0, 1)
|
|
sql := "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ?,l_starttime = ?,l_endtime = ?,i_status = ? where s_serviceid = ? and s_userid = ?"
|
|
sql := "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ?,l_starttime = ?,l_endtime = ?,i_status = ? where s_serviceid = ? and s_userid = ?"
|
|
- status1 := util.JysqlDB.UpdateOrDeleteBySql(sql, fmt.Sprint(frequency), qutil.NowFormat(qutil.Date_Full_Layout), qutil.FormatDate(&startdate, qutil.Date_Full_Layout), qutil.FormatDate(&enddate, qutil.Date_Full_Layout), fmt.Sprint(i_status), serverId, qutil.InterfaceToStr(paramOrder["user_id"]))
|
|
|
|
|
|
+ status1 := util.JysqlDB.UpdateOrDeleteBySql(sql, fmt.Sprint(frequency), qutil.NowFormat(qutil.Date_Full_Layout), qutil.FormatDate(&startdate, qutil.Date_Full_Layout), qutil.FormatDate(&enddate, qutil.Date_Full_Layout), fmt.Sprint(i_status), serverId, fmt.Sprint(qutil.Int64All(paramOrder["user_id"])))
|
|
if status1 < 0 {
|
|
if status1 < 0 {
|
|
return errors.New("新建服务-更新服务表出错")
|
|
return errors.New("新建服务-更新服务表出错")
|
|
}
|
|
}
|
|
} else {
|
|
} else {
|
|
insert := map[string]interface{}{
|
|
insert := map[string]interface{}{
|
|
- "s_userid": qutil.InterfaceToStr(paramOrder["user_id"]),
|
|
|
|
|
|
+ "s_userid": fmt.Sprint(qutil.Int64All((paramOrder["user_id"])),
|
|
"s_smainid": mainId,
|
|
"s_smainid": mainId,
|
|
"s_serviceid": serverId,
|
|
"s_serviceid": serverId,
|
|
"i_frequency": frequency,
|
|
"i_frequency": frequency,
|
|
@@ -3947,7 +3947,7 @@ func NewBigOrder(subStatus, dateType int, startdate, enddate time.Time, userId,
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
- ClearBigVipUserPower(qutil.InterfaceToStr(paramOrder["user_id"]))
|
|
|
|
|
|
+ ClearBigVipUserPower(fmt.Sprint(qutil.Int64All(paramOrder["user_id"])))
|
|
}
|
|
}
|
|
if param.PaySub > 0 || param.FreeSub > 0 {
|
|
if param.PaySub > 0 || param.FreeSub > 0 {
|
|
sets := map[string]interface{}{
|
|
sets := map[string]interface{}{
|
|
@@ -3993,12 +3993,12 @@ func NewBigOrder(subStatus, dateType int, startdate, enddate time.Time, userId,
|
|
for _, v := range param.ServerArr {
|
|
for _, v := range param.ServerArr {
|
|
if qutil.IntAll(v["id"]) == 16 {
|
|
if qutil.IntAll(v["id"]) == 16 {
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
- serverData := util.JysqlDB.SelectBySql(sqls, 12, qutil.InterfaceToStr(paramOrder["user_id"]))
|
|
|
|
|
|
+ serverData := util.JysqlDB.SelectBySql(sqls, 12, fmt.Sprint(qutil.Int64All(paramOrder["user_id"])))
|
|
updatecount_before := qutil.IntAll((*serverData)[0]["i_frequency"])
|
|
updatecount_before := qutil.IntAll((*serverData)[0]["i_frequency"])
|
|
updatecount_after := updatecount_before + qutil.IntAll(v["count"])
|
|
updatecount_after := updatecount_before + qutil.IntAll(v["count"])
|
|
serverId := 12
|
|
serverId := 12
|
|
insert := map[string]interface{}{
|
|
insert := map[string]interface{}{
|
|
- "s_userid": qutil.InterfaceToStr(paramOrder["user_id"]),
|
|
|
|
|
|
+ "s_userid": fmt.Sprint(qutil.Int64All(paramOrder["user_id"])),
|
|
"s_serviceid": serverId,
|
|
"s_serviceid": serverId,
|
|
"l_updatetime_before": (*serverData)[0]["l_endtime"],
|
|
"l_updatetime_before": (*serverData)[0]["l_endtime"],
|
|
"l_updatetime_after": (*serverData)[0]["l_endtime"],
|
|
"l_updatetime_after": (*serverData)[0]["l_endtime"],
|
|
@@ -4014,7 +4014,7 @@ func NewBigOrder(subStatus, dateType int, startdate, enddate time.Time, userId,
|
|
return errors.New("插入充值表失败")
|
|
return errors.New("插入充值表失败")
|
|
}
|
|
}
|
|
sqls1 := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
sqls1 := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
- serverData1 := util.JysqlDB.SelectBySql(sqls1, 13, qutil.InterfaceToStr(paramOrder["user_id"]))
|
|
|
|
|
|
+ serverData1 := util.JysqlDB.SelectBySql(sqls1, 13, fmt.Sprint(qutil.Int64All(paramOrder["user_id"])))
|
|
updatecount_before1 := qutil.IntAll((*serverData1)[0]["i_frequency"])
|
|
updatecount_before1 := qutil.IntAll((*serverData1)[0]["i_frequency"])
|
|
updatecount_after1 := updatecount_before1 + qutil.IntAll(v["count"])
|
|
updatecount_after1 := updatecount_before1 + qutil.IntAll(v["count"])
|
|
serverId1 := 13
|
|
serverId1 := 13
|