|
@@ -9,7 +9,7 @@ import (
|
|
|
"errors"
|
|
|
"fmt"
|
|
|
"log"
|
|
|
- "qmx_admin/src/util"
|
|
|
+ "qmx_admin/src/config"
|
|
|
"regexp"
|
|
|
"strconv"
|
|
|
"strings"
|
|
@@ -34,7 +34,7 @@ func SalePersonList(context *admin.Context) (interface{}, error) {
|
|
|
}
|
|
|
|
|
|
str := ""
|
|
|
- if util.AdminDB.Count("request_auth", map[string]interface{}{"user_id": context.User.Id, "request_call": context.Request.Call}) > 0 {
|
|
|
+ if config.AdminDB.Count("request_auth", map[string]interface{}{"user_id": context.User.Id, "request_call": context.Request.Call}) > 0 {
|
|
|
if param.SalePerson != "" {
|
|
|
str += " sale_person like '%" + param.SalePerson + "%' and"
|
|
|
}
|
|
@@ -68,11 +68,11 @@ func SalePersonList(context *admin.Context) (interface{}, error) {
|
|
|
sqlF += " order by create_time ASC limit " + fmt.Sprint(param.Page.Offset) + " " + "," + " " + fmt.Sprint(param.Page.PageSize)
|
|
|
}
|
|
|
|
|
|
- count := util.JysqlDB.CountBySql(sqlC)
|
|
|
- res := util.JysqlDB.SelectBySql(sqlF)
|
|
|
+ count := config.JysqlDB.CountBySql(sqlC)
|
|
|
+ res := config.JysqlDB.SelectBySql(sqlF)
|
|
|
if res != nil && len(*res) > 0 {
|
|
|
data := map[string]interface{}{}
|
|
|
- resDict := util.JysqlDB.Find("dict_item", map[string]interface{}{"state": 1}, "item_code,item_name,parent_code,parent_name", "", -1, 1)
|
|
|
+ resDict := config.JysqlDB.Find("dict_item", map[string]interface{}{"state": 1}, "item_code,item_name,parent_code,parent_name", "", -1, 1)
|
|
|
if resDict != nil && len(*resDict) > 0 {
|
|
|
for _, val := range *resDict {
|
|
|
itemCode := common.ObjToString(val["item_code"])
|
|
@@ -88,7 +88,7 @@ func SalePersonList(context *admin.Context) (interface{}, error) {
|
|
|
}
|
|
|
saleCode := common.ObjToString(val["saleDep"])
|
|
|
if saleCode != "" {
|
|
|
- saleCodeD := util.JysqlDB.FindOne("dict_dep", map[string]interface{}{"code": saleCode}, "", "")
|
|
|
+ saleCodeD := config.JysqlDB.FindOne("dict_dep", map[string]interface{}{"code": saleCode}, "", "")
|
|
|
if saleCodeD != nil && len(*saleCodeD) > 0 {
|
|
|
showField := common.ObjToString((*saleCodeD)["showField"])
|
|
|
saleDepShow := common.ObjToString((*saleCodeD)["show"])
|
|
@@ -126,7 +126,7 @@ func SalePersonAdd(context *admin.Context) (interface{}, error) {
|
|
|
return nil, err
|
|
|
}
|
|
|
//根据订单编号
|
|
|
- order := util.JysqlDB.FindOne("dataexport_order", map[string]interface{}{"order_code": param.OrderCode, "is_backstage_order": 0}, "order_code,salesperson_id,salesperson,create_time", "")
|
|
|
+ order := config.JysqlDB.FindOne("dataexport_order", map[string]interface{}{"order_code": param.OrderCode, "is_backstage_order": 0}, "order_code,salesperson_id,salesperson,create_time", "")
|
|
|
if order == nil {
|
|
|
return nil, errors.New("订单编号不存在")
|
|
|
}
|
|
@@ -139,7 +139,7 @@ func SalePersonAdd(context *admin.Context) (interface{}, error) {
|
|
|
return nil, errors.New("已超过订单创建时间7天")
|
|
|
}
|
|
|
//判断是否有待审核的销售补录信息
|
|
|
- count := util.JysqlDB.Count("supplement_sale_person", map[string]interface{}{"order_code": param.OrderCode})
|
|
|
+ count := config.JysqlDB.Count("supplement_sale_person", map[string]interface{}{"order_code": param.OrderCode})
|
|
|
if count > 0 {
|
|
|
return nil, errors.New("存在待审核数据")
|
|
|
}
|
|
@@ -155,8 +155,8 @@ func SalePersonAdd(context *admin.Context) (interface{}, error) {
|
|
|
"salesperson_id": param.SalesPersonId,
|
|
|
"saleDep": param.SaleDep,
|
|
|
}
|
|
|
- ok := util.JysqlDB.ExecTx("新增补录信息", func(tx *sql.Tx) bool {
|
|
|
- in1 := util.JysqlDB.Insert("supplement_sale_person", in)
|
|
|
+ ok := config.JysqlDB.ExecTx("新增补录信息", func(tx *sql.Tx) bool {
|
|
|
+ in1 := config.JysqlDB.Insert("supplement_sale_person", in)
|
|
|
//插入审核记录表
|
|
|
insertData := map[string]interface{}{
|
|
|
"operator": context.User.Username,
|
|
@@ -166,7 +166,7 @@ func SalePersonAdd(context *admin.Context) (interface{}, error) {
|
|
|
"order_code": param.OrderCode,
|
|
|
"audit_type": 1,
|
|
|
}
|
|
|
- in2 := util.JysqlDB.InsertByTx(tx, "audit_records", insertData)
|
|
|
+ in2 := config.JysqlDB.InsertByTx(tx, "audit_records", insertData)
|
|
|
return in1 > 0 && in2 > 0
|
|
|
})
|
|
|
|
|
@@ -195,7 +195,7 @@ func SalePersonEdit(context *admin.Context) (interface{}, error) {
|
|
|
return nil, err
|
|
|
}
|
|
|
//先查询补录信息状态
|
|
|
- data := util.JysqlDB.FindOne("supplement_sale_person", map[string]interface{}{"id": param.Id}, "state,order_code", "")
|
|
|
+ data := config.JysqlDB.FindOne("supplement_sale_person", map[string]interface{}{"id": param.Id}, "state,order_code", "")
|
|
|
var state, newState int
|
|
|
if data != nil && len(*data) > 0 {
|
|
|
state = common.IntAll((*data)["state"])
|
|
@@ -217,8 +217,8 @@ func SalePersonEdit(context *admin.Context) (interface{}, error) {
|
|
|
"salesperson_id": param.SalesPersonId,
|
|
|
"saleDep": param.SaleDep,
|
|
|
}
|
|
|
- ok := util.JysqlDB.ExecTx("编辑补录信息", func(tx *sql.Tx) bool {
|
|
|
- up := util.JysqlDB.UpdateByTx(tx, "supplement_sale_person", map[string]interface{}{"id": param.Id}, up)
|
|
|
+ ok := config.JysqlDB.ExecTx("编辑补录信息", func(tx *sql.Tx) bool {
|
|
|
+ up := config.JysqlDB.UpdateByTx(tx, "supplement_sale_person", map[string]interface{}{"id": param.Id}, up)
|
|
|
//插入审核记录表
|
|
|
insertData := map[string]interface{}{
|
|
|
"operator": context.User.Username,
|
|
@@ -228,7 +228,7 @@ func SalePersonEdit(context *admin.Context) (interface{}, error) {
|
|
|
"order_code": param.OrderCode,
|
|
|
"audit_type": 1,
|
|
|
}
|
|
|
- in := util.JysqlDB.InsertByTx(tx, "audit_records", insertData)
|
|
|
+ in := config.JysqlDB.InsertByTx(tx, "audit_records", insertData)
|
|
|
return up && in > 0
|
|
|
})
|
|
|
if ok {
|
|
@@ -248,19 +248,19 @@ func SalePersonDetail(context *admin.Context) (interface{}, error) {
|
|
|
if err != nil {
|
|
|
return nil, err
|
|
|
}
|
|
|
- data := util.JysqlDB.FindOne("supplement_sale_person", map[string]interface{}{"id": param.Id}, "", "")
|
|
|
+ data := config.JysqlDB.FindOne("supplement_sale_person", map[string]interface{}{"id": param.Id}, "", "")
|
|
|
if data != nil && len(*data) > 0 {
|
|
|
orderCode := common.ObjToString((*data)["order_code"])
|
|
|
saleCode := common.ObjToString((*data)["saleDep"])
|
|
|
if saleCode != "" {
|
|
|
- saleCodeD := util.JysqlDB.FindOne("dict_dep", map[string]interface{}{"code": saleCode}, "", "")
|
|
|
+ saleCodeD := config.JysqlDB.FindOne("dict_dep", map[string]interface{}{"code": saleCode}, "", "")
|
|
|
if saleCodeD != nil && len(*saleCodeD) > 0 {
|
|
|
saleDepShow := common.ObjToString((*saleCodeD)["show"])
|
|
|
(*data)["saleDepShow"] = saleDepShow
|
|
|
}
|
|
|
}
|
|
|
dataDict := map[string]interface{}{}
|
|
|
- resDict := util.JysqlDB.Find("dict_item", map[string]interface{}{"state": 1}, "item_code,item_name,parent_code,parent_name", "", -1, 1)
|
|
|
+ resDict := config.JysqlDB.Find("dict_item", map[string]interface{}{"state": 1}, "item_code,item_name,parent_code,parent_name", "", -1, 1)
|
|
|
if resDict != nil && len(*resDict) > 0 {
|
|
|
for _, val := range *resDict {
|
|
|
itemCode := common.ObjToString(val["item_code"])
|
|
@@ -275,7 +275,7 @@ func SalePersonDetail(context *admin.Context) (interface{}, error) {
|
|
|
}
|
|
|
}
|
|
|
//查询审核轨迹
|
|
|
- auditRecord := util.JysqlDB.Find("audit_records", map[string]interface{}{"order_code": orderCode, "audit_type": 1}, "", "create_time desc", -1, -1)
|
|
|
+ auditRecord := config.JysqlDB.Find("audit_records", map[string]interface{}{"order_code": orderCode, "audit_type": 1}, "", "create_time desc", -1, -1)
|
|
|
(*data)["auditRecord"] = auditRecord
|
|
|
return data, nil
|
|
|
}
|
|
@@ -295,7 +295,7 @@ func SuppleInfoExamine(context *admin.Context) (interface{}, error) {
|
|
|
return nil, err
|
|
|
}
|
|
|
//审核前状态
|
|
|
- data := util.JysqlDB.FindOne("supplement_sale_person", map[string]interface{}{"id": param.Id}, "", "")
|
|
|
+ data := config.JysqlDB.FindOne("supplement_sale_person", map[string]interface{}{"id": param.Id}, "", "")
|
|
|
if data != nil && len(*data) > 0 {
|
|
|
oldState := common.IntAll((*data)["state"])
|
|
|
newState := 1
|
|
@@ -315,9 +315,9 @@ func SuppleInfoExamine(context *admin.Context) (interface{}, error) {
|
|
|
operatorType = 3
|
|
|
}
|
|
|
}
|
|
|
- ok := util.JysqlDB.ExecTx("审核补录销售信息", func(tx *sql.Tx) bool {
|
|
|
+ ok := config.JysqlDB.ExecTx("审核补录销售信息", func(tx *sql.Tx) bool {
|
|
|
//更新补录信息
|
|
|
- up := util.JysqlDB.UpdateByTx(tx, "supplement_sale_person", map[string]interface{}{"id": param.Id}, map[string]interface{}{"state": newState})
|
|
|
+ up := config.JysqlDB.UpdateByTx(tx, "supplement_sale_person", map[string]interface{}{"id": param.Id}, map[string]interface{}{"state": newState})
|
|
|
//插入审核记录表
|
|
|
insertData := map[string]interface{}{
|
|
|
"operator": context.User.Username,
|
|
@@ -328,7 +328,7 @@ func SuppleInfoExamine(context *admin.Context) (interface{}, error) {
|
|
|
"order_code": param.OrderCode,
|
|
|
"audit_type": 1,
|
|
|
}
|
|
|
- in := util.JysqlDB.InsertByTx(tx, "audit_records", insertData)
|
|
|
+ in := config.JysqlDB.InsertByTx(tx, "audit_records", insertData)
|
|
|
ok := true
|
|
|
if newState == 3 { //二审通过更新订单表
|
|
|
now := time.Now()
|
|
@@ -343,7 +343,7 @@ func SuppleInfoExamine(context *admin.Context) (interface{}, error) {
|
|
|
"sale_time": saleTime.Format(date.Date_Full_Layout),
|
|
|
"saleDep": (*data)["saleDep"],
|
|
|
}
|
|
|
- ok = util.JysqlDB.UpdateByTx(tx, "dataexport_order", map[string]interface{}{"order_code": param.OrderCode}, upData)
|
|
|
+ ok = config.JysqlDB.UpdateByTx(tx, "dataexport_order", map[string]interface{}{"order_code": param.OrderCode}, upData)
|
|
|
}
|
|
|
return up && in > 0 && ok
|
|
|
})
|
|
@@ -366,7 +366,7 @@ func OrdersExamine(context *admin.Context) (interface{}, error) {
|
|
|
return nil, err
|
|
|
}
|
|
|
//查询订单
|
|
|
- order := util.JysqlDB.FindOne("dataexport_order", map[string]interface{}{"order_code": param.OrderCode}, "", "")
|
|
|
+ order := config.JysqlDB.FindOne("dataexport_order", map[string]interface{}{"order_code": param.OrderCode}, "", "")
|
|
|
if order != nil && len(*order) == 0 {
|
|
|
return nil, errors.New("没有查询到订单信息")
|
|
|
}
|
|
@@ -403,16 +403,16 @@ func OrdersExamine(context *admin.Context) (interface{}, error) {
|
|
|
userData *map[string]interface{}
|
|
|
ok1 bool
|
|
|
)
|
|
|
- userData, ok1 = util.MQFW.FindOne("user", map[string]interface{}{"s_phone": (*order)["user_phone"]})
|
|
|
+ userData, ok1 = config.MQFW.FindOne("user", map[string]interface{}{"s_phone": (*order)["user_phone"]})
|
|
|
if ok1 && userData != nil && len(*userData) > 0 {
|
|
|
userId = mongodb.BsonIdToSId((*userData)["_id"])
|
|
|
} else {
|
|
|
- userData, ok1 = util.MQFW.FindOne("user", map[string]interface{}{"s_m_phone": (*order)["user_phone"]})
|
|
|
+ userData, ok1 = config.MQFW.FindOne("user", map[string]interface{}{"s_m_phone": (*order)["user_phone"]})
|
|
|
if ok1 && userData != nil && len(*userData) > 0 {
|
|
|
userId = mongodb.BsonIdToSId((*userData)["_id"])
|
|
|
}
|
|
|
}
|
|
|
- ok := util.JysqlDB.ExecTx("审核订单", func(tx *sql.Tx) bool {
|
|
|
+ ok := config.JysqlDB.ExecTx("审核订单", func(tx *sql.Tx) bool {
|
|
|
upData := map[string]interface{}{
|
|
|
"audit_status": newState,
|
|
|
}
|
|
@@ -424,7 +424,7 @@ func OrdersExamine(context *admin.Context) (interface{}, error) {
|
|
|
}
|
|
|
upData["sale_time"] = saleTime.Format(date.Date_Full_Layout)
|
|
|
//“协议归档状态”如若为“已归档”,则“订单状态”更新为“已完成”,如若为“未归档”,则订单状态仍为“未完成”
|
|
|
- contractData := util.JysqlDB.FindOne("contract", map[string]interface{}{"order_code": param.OrderCode}, "contract_archive_status", "")
|
|
|
+ contractData := config.JysqlDB.FindOne("contract", map[string]interface{}{"order_code": param.OrderCode}, "contract_archive_status", "")
|
|
|
if contractData != nil && len(*contractData) > 0 {
|
|
|
if common.IntAll((*contractData)["contract_archive_status"]) == 1 {
|
|
|
upData["order_status"] = 1
|
|
@@ -463,7 +463,7 @@ func OrdersExamine(context *admin.Context) (interface{}, error) {
|
|
|
upData["filter"] = string(filterByte)
|
|
|
}
|
|
|
//更新订单
|
|
|
- up := util.JysqlDB.UpdateByTx(tx, "dataexport_order", map[string]interface{}{"order_code": param.OrderCode}, upData)
|
|
|
+ up := config.JysqlDB.UpdateByTx(tx, "dataexport_order", map[string]interface{}{"order_code": param.OrderCode}, upData)
|
|
|
//插入审核记录表
|
|
|
insertData := map[string]interface{}{
|
|
|
"operator": context.User.Username,
|
|
@@ -474,7 +474,7 @@ func OrdersExamine(context *admin.Context) (interface{}, error) {
|
|
|
"order_code": param.OrderCode,
|
|
|
"audit_type": 2,
|
|
|
}
|
|
|
- in := util.JysqlDB.InsertByTx(tx, "audit_records", insertData)
|
|
|
+ in := config.JysqlDB.InsertByTx(tx, "audit_records", insertData)
|
|
|
return up && in > 0
|
|
|
})
|
|
|
if !ok {
|
|
@@ -499,7 +499,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
if serverMap[serverId] != 0 {
|
|
|
serverId = serverMap[serverId]
|
|
|
}
|
|
|
- serverData := util.JysqlDB.FindOne("bigmember_service", map[string]interface{}{"id": mainId}, "", "")
|
|
|
+ serverData := config.JysqlDB.FindOne("bigmember_service", map[string]interface{}{"id": mainId}, "", "")
|
|
|
frequency := 0
|
|
|
if serverData != nil && len(*serverData) > 0 {
|
|
|
if serverId == 11 || serverId == 15 {
|
|
@@ -518,7 +518,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
}
|
|
|
|
|
|
sql2 := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
|
- serverDatas := util.JysqlDB.SelectBySql(sql2, serverId, userId)
|
|
|
+ serverDatas := config.JysqlDB.SelectBySql(sql2, serverId, userId)
|
|
|
|
|
|
if serverDatas != nil && len(*serverDatas) > 0 {
|
|
|
iStatus := common.If(true, 0, 1)
|
|
@@ -528,7 +528,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
} else {
|
|
|
sql2 = "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(sql2, fmt.Sprint(frequency), date.NowFormat(date.Date_Full_Layout), date.FormatDate(&startTime, date.Date_Full_Layout), date.FormatDate(&endTime, date.Date_Full_Layout), fmt.Sprint(iStatus), serverId, userId)
|
|
|
+ status1 := config.JysqlDB.UpdateOrDeleteBySql(sql2, fmt.Sprint(frequency), date.NowFormat(date.Date_Full_Layout), date.FormatDate(&startTime, date.Date_Full_Layout), date.FormatDate(&endTime, date.Date_Full_Layout), fmt.Sprint(iStatus), serverId, userId)
|
|
|
if status1 < 0 {
|
|
|
return false, errors.New("新建服务-更新服务表出错")
|
|
|
}
|
|
@@ -544,7 +544,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
"l_createtime": date.NowFormat(date.Date_Full_Layout),
|
|
|
"l_updatetime": date.NowFormat(date.Date_Full_Layout),
|
|
|
}
|
|
|
- orderId := util.JysqlDB.Insert("bigmember_service_user", insert)
|
|
|
+ orderId := config.JysqlDB.Insert("bigmember_service_user", insert)
|
|
|
if orderId > 0 {
|
|
|
log.Println("用户服务表插入成功", userId)
|
|
|
} else {
|
|
@@ -563,7 +563,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
set := map[string]interface{}{
|
|
|
"$set": sets,
|
|
|
}
|
|
|
- ok := util.MQFW.UpdateById("user", userId, set)
|
|
|
+ ok := config.MQFW.UpdateById("user", userId, set)
|
|
|
if !ok {
|
|
|
log.Println("大会员子账号创建订单user表大会员状态更新失败")
|
|
|
return false, errors.New("大会员子账号创建订单user表大会员状态更新失败")
|
|
@@ -579,7 +579,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
"l_createtime": date.NowFormat(date.Date_Full_Layout),
|
|
|
"l_updatetime": date.NowFormat(date.Date_Full_Layout),
|
|
|
}
|
|
|
- orderId := util.JysqlDB.Insert("bigmember_service_user", insert)
|
|
|
+ orderId := config.JysqlDB.Insert("bigmember_service_user", insert)
|
|
|
if orderId > 0 {
|
|
|
log.Println("插入用户服务表成功", userId)
|
|
|
} else {
|
|
@@ -592,7 +592,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
for _, v := range serverArr {
|
|
|
if common.IntAll(v["id"]) == 16 {
|
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
|
- serverData := util.JysqlDB.SelectBySql(sqls, 12, userId)
|
|
|
+ serverData := config.JysqlDB.SelectBySql(sqls, 12, userId)
|
|
|
updateCountBefore := common.IntAll((*serverData)[0]["i_frequency"])
|
|
|
updateCountAfter := updateCountBefore + common.IntAll(v["count"])
|
|
|
serverId := 12
|
|
@@ -605,7 +605,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
"i_updatecount_after": updateCountAfter,
|
|
|
"l_createtime": date.NowFormat(date.Date_Full_Layout),
|
|
|
}
|
|
|
- orderId := util.JysqlDB.Insert("bigmember_recharge", insert)
|
|
|
+ orderId := config.JysqlDB.Insert("bigmember_recharge", insert)
|
|
|
if orderId > 0 {
|
|
|
log.Println("插入充值表成功", v, userId)
|
|
|
} else {
|
|
@@ -614,7 +614,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
}
|
|
|
|
|
|
sqls1 := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
|
- serverData1 := util.JysqlDB.SelectBySql(sqls1, 13, userId)
|
|
|
+ serverData1 := config.JysqlDB.SelectBySql(sqls1, 13, userId)
|
|
|
updateCountBefore1 := common.IntAll((*serverData1)[0]["i_frequency"])
|
|
|
updatecountAfter1 := updateCountBefore1 + common.IntAll(v["count"])
|
|
|
serverId1 := 13
|
|
@@ -627,7 +627,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
"i_updatecount_after": updatecountAfter1,
|
|
|
"l_createtime": date.NowFormat(date.Date_Full_Layout),
|
|
|
}
|
|
|
- orderId1 := util.JysqlDB.Insert("bigmember_recharge", insert1)
|
|
|
+ orderId1 := config.JysqlDB.Insert("bigmember_recharge", insert1)
|
|
|
if orderId1 > 0 {
|
|
|
log.Println("插入充值表成功", v, userId)
|
|
|
} else {
|
|
@@ -635,9 +635,9 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
return false, errors.New("插入充值表失败")
|
|
|
}
|
|
|
sql3 := "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ? where s_serviceid = ? and s_userid = ?"
|
|
|
- status1 := util.JysqlDB.UpdateOrDeleteBySql(sql3, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), 12, userId)
|
|
|
+ status1 := config.JysqlDB.UpdateOrDeleteBySql(sql3, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), 12, userId)
|
|
|
sql3 = "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ? where s_serviceid = ? and s_userid = ?"
|
|
|
- status2 := util.JysqlDB.UpdateOrDeleteBySql(sql3, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), 13, userId)
|
|
|
+ status2 := config.JysqlDB.UpdateOrDeleteBySql(sql3, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), 13, userId)
|
|
|
if status1 == -1 {
|
|
|
return false, errors.New("服务表更新失败")
|
|
|
}
|
|
@@ -652,11 +652,11 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
if serverMap[common.IntAll(v["id"])] != 0 {
|
|
|
serverIdTmp = serverMap[common.IntAll(v["id"])]
|
|
|
}
|
|
|
- status := util.JysqlDB.UpdateOrDeleteBySql(sqlUp2, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), fmt.Sprint(serverIdTmp), userId)
|
|
|
+ status := config.JysqlDB.UpdateOrDeleteBySql(sqlUp2, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), fmt.Sprint(serverIdTmp), userId)
|
|
|
if status != -1 {
|
|
|
log.Println("更新补充包数量成功", v, userId)
|
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ? and i_status != -1"
|
|
|
- serverData := util.JysqlDB.SelectBySql(sqls, serverIdTmp, userId)
|
|
|
+ serverData := config.JysqlDB.SelectBySql(sqls, serverIdTmp, userId)
|
|
|
updateCountBefore := common.IntAll((*serverData)[0]["i_frequency"])
|
|
|
updateCountAfter := updateCountBefore + common.IntAll(v["count"])
|
|
|
serverId := common.IntAll(serverIdTmp)
|
|
@@ -669,7 +669,7 @@ func BigMemberSupple(startTime, endTime time.Time, userId string, filterMap map[
|
|
|
"i_updatecount_after": updateCountAfter,
|
|
|
"l_createtime": date.NowFormat(date.Date_Full_Layout),
|
|
|
}
|
|
|
- orderId := util.JysqlDB.Insert("bigmember_recharge", insert)
|
|
|
+ orderId := config.JysqlDB.Insert("bigmember_recharge", insert)
|
|
|
if orderId > 0 {
|
|
|
log.Println("插入充值表成功", v, userId)
|
|
|
} else {
|
|
@@ -701,7 +701,7 @@ func BigMemberExtend(filterMap map[string]interface{}, userId, orderCode string,
|
|
|
"i_member_status": -bigMemberStatus,
|
|
|
}
|
|
|
/*//更新订单信息
|
|
|
- ok := util.JysqlDB.Update(DataExportOrder, map[string]interface{}{"order_code": orderCode}, map[string]interface{}{"vip_starttime": startTime.Format(date.Date_Full_Layout), "vip_endtime": endTime.Format(date.Date_Full_Layout)})
|
|
|
+ ok := config.JysqlDB.Update(DataExportOrder, map[string]interface{}{"order_code": orderCode}, map[string]interface{}{"vip_starttime": startTime.Format(date.Date_Full_Layout), "vip_endtime": endTime.Format(date.Date_Full_Layout)})
|
|
|
if !ok {
|
|
|
return false, errors.New("更新订单信息出错")
|
|
|
}*/
|
|
@@ -709,7 +709,7 @@ func BigMemberExtend(filterMap map[string]interface{}, userId, orderCode string,
|
|
|
set := map[string]interface{}{
|
|
|
"$set": setMap,
|
|
|
}
|
|
|
- ok := util.MQFW.UpdateById("user", userId, set)
|
|
|
+ ok := config.MQFW.UpdateById("user", userId, set)
|
|
|
if !ok {
|
|
|
return false, errors.New("大会员创建订单user表大会员状态更新失败")
|
|
|
} else {
|
|
@@ -719,7 +719,7 @@ func BigMemberExtend(filterMap map[string]interface{}, userId, orderCode string,
|
|
|
if serverMap[serverId] != 0 {
|
|
|
serverId = serverMap[serverId]
|
|
|
}
|
|
|
- serverData := util.JysqlDB.FindOne("bigmember_service", map[string]interface{}{"id": mainId}, "", "")
|
|
|
+ serverData := config.JysqlDB.FindOne("bigmember_service", map[string]interface{}{"id": mainId}, "", "")
|
|
|
frequency := 0
|
|
|
var lEndtime time.Time
|
|
|
if serverData != nil && len(*serverData) > 0 {
|
|
@@ -739,10 +739,10 @@ func BigMemberExtend(filterMap map[string]interface{}, userId, orderCode string,
|
|
|
var status1 int64
|
|
|
if effectState {
|
|
|
sql1 := "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ?,l_endtime = ? where s_serviceid = ? and s_userid = ?"
|
|
|
- status1 = util.JysqlDB.UpdateOrDeleteBySql(sql1, frequency, date.NowFormat(date.Date_Full_Layout), date.FormatDate(&lEndtime, date.Date_Full_Layout), serverId, userId)
|
|
|
+ status1 = config.JysqlDB.UpdateOrDeleteBySql(sql1, frequency, date.NowFormat(date.Date_Full_Layout), date.FormatDate(&lEndtime, date.Date_Full_Layout), serverId, userId)
|
|
|
} else {
|
|
|
sql1 := "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ?,l_endtime = ?,l_starttime = ?,i_status = ? where s_serviceid = ? and s_userid = ?"
|
|
|
- status1 = util.JysqlDB.UpdateOrDeleteBySql(sql1, frequency, date.NowFormat(date.Date_Full_Layout), endTime, startTime, 0, serverId, userId)
|
|
|
+ status1 = config.JysqlDB.UpdateOrDeleteBySql(sql1, frequency, date.NowFormat(date.Date_Full_Layout), endTime, startTime, 0, serverId, userId)
|
|
|
}
|
|
|
if status1 > 0 {
|
|
|
log.Println("用户服务表更新成功", userId)
|
|
@@ -751,15 +751,15 @@ func BigMemberExtend(filterMap map[string]interface{}, userId, orderCode string,
|
|
|
}
|
|
|
}
|
|
|
//更新子账号延长服务
|
|
|
- userData, ok := util.MQFW.Find("user", map[string]interface{}{"s_member_mainid": userId, "i_member_sub_status": 1}, nil, nil, false, -1, -1)
|
|
|
+ userData, ok := config.MQFW.Find("user", map[string]interface{}{"s_member_mainid": userId, "i_member_sub_status": 1}, nil, nil, false, -1, -1)
|
|
|
if ok && userData != nil && len(*userData) > 0 {
|
|
|
var status1 int64
|
|
|
if effectState {
|
|
|
sql2 := "update bigmember_service_user set l_updatetime = ?,l_endtime = ? where s_serviceid = 2 and s_userid = ?"
|
|
|
- status1 = util.JysqlDB.UpdateOrDeleteBySql(sql2, date.NowFormat(date.Date_Full_Layout), date.FormatDate(&effectiveDate, date.Date_Full_Layout), userId)
|
|
|
+ status1 = config.JysqlDB.UpdateOrDeleteBySql(sql2, date.NowFormat(date.Date_Full_Layout), date.FormatDate(&effectiveDate, date.Date_Full_Layout), userId)
|
|
|
} else {
|
|
|
sql2 := "update bigmember_service_user set l_updatetime = ?,l_endtime = ?,l_starttime = ?,i_status = ? where s_serviceid = 2 and s_userid = ?"
|
|
|
- status1 = util.JysqlDB.UpdateOrDeleteBySql(sql2, date.NowFormat(date.Date_Full_Layout), endTime, startTime, 0, userId)
|
|
|
+ status1 = config.JysqlDB.UpdateOrDeleteBySql(sql2, date.NowFormat(date.Date_Full_Layout), endTime, startTime, 0, userId)
|
|
|
}
|
|
|
if status1 > 0 {
|
|
|
log.Println("用户服务表更新成功", userId)
|
|
@@ -768,7 +768,7 @@ func BigMemberExtend(filterMap map[string]interface{}, userId, orderCode string,
|
|
|
}
|
|
|
for _, v := range *userData {
|
|
|
userId := mongodb.BsonIdToSId(v["_id"])
|
|
|
- oks := util.MQFW.UpdateById("user", userId, map[string]interface{}{
|
|
|
+ oks := config.MQFW.UpdateById("user", userId, map[string]interface{}{
|
|
|
"$set": setMap,
|
|
|
})
|
|
|
if !oks {
|
|
@@ -785,7 +785,7 @@ func SupplePackage(userId string, serverArr []map[string]interface{}) (bool, err
|
|
|
for _, v := range serverArr {
|
|
|
if common.IntAll(v["id"]) == 16 {
|
|
|
sqls := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ?"
|
|
|
- serverData := util.JysqlDB.SelectBySql(sqls, 12, userId)
|
|
|
+ serverData := config.JysqlDB.SelectBySql(sqls, 12, userId)
|
|
|
updateCountBefore := common.IntAll((*serverData)[0]["i_frequency"])
|
|
|
updateCountAfter := updateCountBefore + common.IntAll(v["count"])
|
|
|
serverId := 12
|
|
@@ -798,7 +798,7 @@ func SupplePackage(userId string, serverArr []map[string]interface{}) (bool, err
|
|
|
"i_updatecount_after": updateCountAfter,
|
|
|
"l_createtime": date.NowFormat(date.Date_Full_Layout),
|
|
|
}
|
|
|
- orderId := util.JysqlDB.Insert("bigmember_recharge", insert)
|
|
|
+ orderId := config.JysqlDB.Insert("bigmember_recharge", insert)
|
|
|
if orderId > 0 {
|
|
|
log.Println("插入充值表成功", v, userId)
|
|
|
} else {
|
|
@@ -806,7 +806,7 @@ func SupplePackage(userId string, serverArr []map[string]interface{}) (bool, err
|
|
|
return false, errors.New("插入充值表失败")
|
|
|
}
|
|
|
sqls1 := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ?"
|
|
|
- serverData1 := util.JysqlDB.SelectBySql(sqls1, 13, userId)
|
|
|
+ serverData1 := config.JysqlDB.SelectBySql(sqls1, 13, userId)
|
|
|
updateCountBefore1 := common.IntAll((*serverData1)[0]["i_frequency"])
|
|
|
updateCountAfter1 := updateCountBefore1 + common.IntAll(v["count"])
|
|
|
serverId1 := 13
|
|
@@ -819,7 +819,7 @@ func SupplePackage(userId string, serverArr []map[string]interface{}) (bool, err
|
|
|
"i_updatecount_after": updateCountAfter1,
|
|
|
"l_createtime": date.NowFormat(date.Date_Full_Layout),
|
|
|
}
|
|
|
- orderId1 := util.JysqlDB.Insert("bigmember_recharge", insert1)
|
|
|
+ orderId1 := config.JysqlDB.Insert("bigmember_recharge", insert1)
|
|
|
if orderId1 > 0 {
|
|
|
log.Println("插入充值表成功", v, userId)
|
|
|
} else {
|
|
@@ -827,9 +827,9 @@ func SupplePackage(userId string, serverArr []map[string]interface{}) (bool, err
|
|
|
return false, errors.New("插入充值表失败")
|
|
|
}
|
|
|
sql1 := "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ? where s_serviceid = ? and s_userid = ?"
|
|
|
- status1 := util.JysqlDB.UpdateOrDeleteBySql(sql1, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), 12, userId)
|
|
|
+ status1 := config.JysqlDB.UpdateOrDeleteBySql(sql1, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), 12, userId)
|
|
|
sql1 = "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ? where s_serviceid = ? and s_userid = ?"
|
|
|
- status2 := util.JysqlDB.UpdateOrDeleteBySql(sql1, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), 13, userId)
|
|
|
+ status2 := config.JysqlDB.UpdateOrDeleteBySql(sql1, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), 13, userId)
|
|
|
if status1 == -1 {
|
|
|
return false, errors.New("服务表更新失败")
|
|
|
}
|
|
@@ -840,10 +840,10 @@ func SupplePackage(userId string, serverArr []map[string]interface{}) (bool, err
|
|
|
}
|
|
|
|
|
|
sql2 := "update bigmember_service_user set i_frequency = i_frequency + ?,l_updatetime = ? where s_serviceid = ? and s_userid = ?"
|
|
|
- status := util.JysqlDB.UpdateOrDeleteBySql(sql2, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), fmt.Sprint(v["id"]), userId)
|
|
|
+ status := config.JysqlDB.UpdateOrDeleteBySql(sql2, fmt.Sprint(v["count"]), date.NowFormat(date.Date_Full_Layout), fmt.Sprint(v["id"]), userId)
|
|
|
if status != -1 {
|
|
|
sql3 := "select * from bigmember_service_user where s_serviceid = ? and s_userid = ?"
|
|
|
- serverData := util.JysqlDB.SelectBySql(sql3, v["id"], userId)
|
|
|
+ serverData := config.JysqlDB.SelectBySql(sql3, v["id"], userId)
|
|
|
updateCountBefore := common.IntAll((*serverData)[0]["i_frequency"])
|
|
|
updateCountAfter := updateCountBefore + common.IntAll(v["count"])
|
|
|
serverId := common.IntAll(v["id"])
|
|
@@ -856,7 +856,7 @@ func SupplePackage(userId string, serverArr []map[string]interface{}) (bool, err
|
|
|
"i_updatecount_after": updateCountAfter,
|
|
|
"l_createtime": date.NowFormat(date.Date_Full_Layout),
|
|
|
}
|
|
|
- orderId := util.JysqlDB.Insert("bigmember_recharge", insert)
|
|
|
+ orderId := config.JysqlDB.Insert("bigmember_recharge", insert)
|
|
|
if orderId > 0 {
|
|
|
log.Println("插入充值表成功", v, userId)
|
|
|
} else {
|
|
@@ -875,7 +875,7 @@ func getBigMemberProductTypeByOrderCode(orderCode string) string {
|
|
|
if orderCode == "" {
|
|
|
return ""
|
|
|
}
|
|
|
- res := util.JysqlDB.FindOne("dataexport_order", map[string]interface{}{"order_code": orderCode, "product_type": "大会员"}, "filter", "id desc")
|
|
|
+ res := config.JysqlDB.FindOne("dataexport_order", map[string]interface{}{"order_code": orderCode, "product_type": "大会员"}, "filter", "id desc")
|
|
|
if res == nil || len(*res) == 0 {
|
|
|
return ""
|
|
|
}
|
|
@@ -924,7 +924,7 @@ func SubAccount(param SubAccountParam) (bool, error) {
|
|
|
switch param.BuySubject {
|
|
|
//个人
|
|
|
case 1:
|
|
|
- if !util.MQFW.UpdateById("user", param.UserId, map[string]interface{}{
|
|
|
+ if !config.MQFW.UpdateById("user", param.UserId, map[string]interface{}{
|
|
|
"$set": map[string]interface{}{
|
|
|
"i_pay_sub_num": param.BuyCount,
|
|
|
//"i_free_sub_num": 0,
|
|
@@ -934,7 +934,7 @@ func SubAccount(param SubAccountParam) (bool, error) {
|
|
|
return false, errors.New("user表大会员状态更新失败")
|
|
|
} else {
|
|
|
if param.InsertBigService {
|
|
|
- orderId := util.JysqlDB.Insert("bigmember_service_user", map[string]interface{}{
|
|
|
+ orderId := config.JysqlDB.Insert("bigmember_service_user", map[string]interface{}{
|
|
|
"s_userid": param.UserId,
|
|
|
"s_serviceid": 2,
|
|
|
"l_starttime": date.FormatDate(¶m.StartTime, date.Date_Full_Layout),
|