241 lines
6.9 KiB
Go
241 lines
6.9 KiB
Go
package dao
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils"
|
|
"git.rosy.net.cn/jx-callback/business/model"
|
|
)
|
|
|
|
type UserDeliveryAddressEx struct {
|
|
model.UserDeliveryAddress
|
|
|
|
UserName string `json:"userName"`
|
|
CityName string `json:"cityName"`
|
|
DistrictName string `json:"districtName"`
|
|
ParentCode int `json:"parentCode"`
|
|
}
|
|
|
|
type GetSelfInfoResult struct {
|
|
model.User
|
|
model.UserBill
|
|
UserMembers []*model.UserMember `json:"userMembers"`
|
|
}
|
|
|
|
func GetUserByID(db *DaoDB, fieldName, fieldValue string) (user *model.User, err error) {
|
|
sql := fmt.Sprintf(`
|
|
SELECT *
|
|
FROM user t1
|
|
WHERE t1.deleted_at = ? AND t1.status = ? AND t1.%s = ?
|
|
`, fieldName)
|
|
sqlParams := []interface{}{
|
|
utils.DefaultTimeValue,
|
|
model.UserStatusNormal,
|
|
fieldValue,
|
|
}
|
|
// globals.SugarLogger.Debugf("GetUserByID sql:%s, sqlParams:%s", sql, utils.Format4Output(sqlParams, false))
|
|
err = GetRow(db, &user, sql, sqlParams...)
|
|
return user, err
|
|
}
|
|
|
|
func GetUserByIDWithMembers(db *DaoDB, fieldName, fieldValue string) (getSelfInfoResult *GetSelfInfoResult, err error) {
|
|
sql := fmt.Sprintf(`
|
|
SELECT t1.*, t2.bill_id, t2.account_balance
|
|
FROM user t1
|
|
JOIN user_bill t2 ON t2.user_id = t1.user_id AND t2.deleted_at = ?
|
|
WHERE t1.deleted_at = ? AND t1.status = ? AND t1.%s = ?
|
|
`, fieldName)
|
|
sqlParams := []interface{}{
|
|
utils.DefaultTimeValue,
|
|
utils.DefaultTimeValue,
|
|
model.UserStatusNormal,
|
|
fieldValue,
|
|
}
|
|
// globals.SugarLogger.Debugf("GetUserByID sql:%s, sqlParams:%s", sql, utils.Format4Output(sqlParams, false))
|
|
err = GetRow(db, &getSelfInfoResult, sql, sqlParams...)
|
|
return getSelfInfoResult, err
|
|
}
|
|
|
|
type GetUsersResult struct {
|
|
model.User
|
|
AcceptOrderCount int `json:"acceptOrderCount"`
|
|
FinishedOrderCount int `json:"finishedOrderCount"`
|
|
}
|
|
|
|
func GetUsers(db *DaoDB, userType int, keyword string, userIDs, userID2s, mobiles []string, offset, pageSize int) (userList []*GetUsersResult, totalCount int, err error) {
|
|
offset = jxutils.FormalizePageOffset(offset)
|
|
pageSize = jxutils.FormalizePageSize(pageSize)
|
|
if userType == 0 {
|
|
userType = 255
|
|
}
|
|
sqlParams := []interface{}{}
|
|
sql := `
|
|
SELECT SQL_CALC_FOUND_ROWS
|
|
t1.*, t2.accept_order_count, t3.finished_order_count
|
|
FROM user t1
|
|
JOIN (SELECT user_id, COUNT(user_id) accept_order_count FROM job_order`
|
|
if len(userIDs) > 0 {
|
|
sql += " WHERE user_id IN (" + GenQuestionMarks(len(userIDs)) + ")"
|
|
sqlParams = append(sqlParams, userIDs)
|
|
}
|
|
sql += `GROUP BY 1)t2
|
|
JOIN (SELECT user_id, COUNT(user_id) finished_order_count FROM job_order WHERE 1 = 1 `
|
|
if len(userIDs) > 0 {
|
|
sql += " AND user_id IN (" + GenQuestionMarks(len(userIDs)) + ")"
|
|
sqlParams = append(sqlParams, userIDs)
|
|
}
|
|
sql += ` AND status = ? GROUP BY 1)t3
|
|
WHERE t1.status = 1 AND t1.deleted_at = ? AND t1.type & ? <> 0
|
|
AND t1.user_id = t2.user_id
|
|
AND t1.user_id = t3.user_id`
|
|
sqlParams = append(sqlParams, model.JobOrderStatusFinish, utils.DefaultTimeValue, userType)
|
|
if len(userIDs) > 0 {
|
|
sql += " AND t1.user_id IN (" + GenQuestionMarks(len(userIDs)) + ")"
|
|
sqlParams = append(sqlParams, userIDs)
|
|
}
|
|
if len(userID2s) > 0 {
|
|
sql += " AND t1.user_id2 IN (" + GenQuestionMarks(len(userID2s)) + ")"
|
|
sqlParams = append(sqlParams, userID2s)
|
|
}
|
|
if len(mobiles) > 0 {
|
|
sql += " AND t1.mobile IN (" + GenQuestionMarks(len(mobiles)) + ")"
|
|
sqlParams = append(sqlParams, mobiles)
|
|
}
|
|
if keyword != "" {
|
|
keywordLike := "%" + keyword + "%"
|
|
sql += " AND (t1.user_id LIKE ? OR t1.user_id2 LIKE ? OR t1.mobile LIKE ? OR t1.email LIKE ? OR t1.name LIKE ?)"
|
|
sqlParams = append(sqlParams, keywordLike, keywordLike, keywordLike, keywordLike, keywordLike)
|
|
}
|
|
sql += " LIMIT ? OFFSET ?"
|
|
sqlParams = append(sqlParams, pageSize, offset)
|
|
Begin(db)
|
|
defer Commit(db)
|
|
if err = GetRows(db, &userList, sql, sqlParams...); err == nil {
|
|
totalCount = GetLastTotalRowCount(db)
|
|
}
|
|
return userList, totalCount, err
|
|
}
|
|
|
|
func DeleteUsers(db *DaoDB, userIDs []string) (num int64, err error) {
|
|
if len(userIDs) > 0 {
|
|
sql := `
|
|
UPDATE user t1
|
|
JOIN auth_bind t2 ON t2.user_id = t1.user_id
|
|
SET
|
|
t1.deleted_at = ?,
|
|
t2.deleted_at = ?
|
|
WHERE t1.user_id IN (` + GenQuestionMarks(len(userIDs)) + ");"
|
|
now := time.Now()
|
|
sqlParams := []interface{}{
|
|
now,
|
|
now,
|
|
userIDs,
|
|
}
|
|
num, err = ExecuteSQL(db, sql, sqlParams...)
|
|
}
|
|
return num, err
|
|
}
|
|
|
|
func QueryUserDeliveryAddress(db *DaoDB, addressID int64, userIDs []string, addType int, offset, pageSize int) (addressList []*UserDeliveryAddressEx, totalCount int, err error) {
|
|
sql := `
|
|
SELECT SQL_CALC_FOUND_ROWS
|
|
t1.*,
|
|
t2.name user_name,
|
|
district.name district_name,
|
|
city.name city_name,
|
|
cp.code parent_code
|
|
FROM user_delivery_address t1
|
|
LEFT JOIN user t2 ON t2.user_id = t1.user_id
|
|
LEFT JOIN place district ON district.code = t1.district_code
|
|
LEFT JOIN place city ON city.code = t1.city_code
|
|
LEFT JOIN place cp ON cp.code = city.parent_code
|
|
WHERE t1.deleted_at = ?
|
|
`
|
|
sqlParams := []interface{}{
|
|
utils.DefaultTimeValue,
|
|
}
|
|
if addressID > 0 {
|
|
sql += " AND t1.id = ? "
|
|
sqlParams = append(sqlParams, addressID)
|
|
}
|
|
if len(userIDs) > 0 {
|
|
sql += " AND t1.user_id IN (" + GenQuestionMarks(len(userIDs)) + ")"
|
|
sqlParams = append(sqlParams, userIDs)
|
|
}
|
|
if addType != 0 {
|
|
sql += " AND t1.type = ? "
|
|
sqlParams = append(sqlParams, addType)
|
|
}
|
|
offset = jxutils.FormalizePageOffset(offset)
|
|
pageSize = jxutils.FormalizePageSize(pageSize)
|
|
sql += `
|
|
ORDER BY t1.is_default DESC, t1.consignee_name
|
|
LIMIT ? OFFSET ?`
|
|
sqlParams = append(sqlParams, pageSize, offset)
|
|
|
|
Begin(db)
|
|
defer Commit(db)
|
|
if err = GetRows(db, &addressList, sql, sqlParams...); err == nil {
|
|
totalCount = GetLastTotalRowCount(db)
|
|
}
|
|
return addressList, totalCount, err
|
|
}
|
|
|
|
func ClearUserDeliveryAddressDefault(db *DaoDB, userID string, defAddressID int) (err error) {
|
|
sql := `
|
|
UPDATE user_delivery_address t1
|
|
SET t1.is_default = 0
|
|
WHERE t1.deleted_at = ? AND t1.user_id = ?
|
|
`
|
|
sqlParams := []interface{}{
|
|
utils.DefaultTimeValue,
|
|
userID,
|
|
}
|
|
if defAddressID > 0 {
|
|
sql += " AND t1.id <> ?"
|
|
sqlParams = append(sqlParams, defAddressID)
|
|
}
|
|
_, err = ExecuteSQL(db, sql, sqlParams...)
|
|
return err
|
|
}
|
|
|
|
func GetUserOrderSMS(db *DaoDB, mobile, name string) (userOrderSms *model.UserOrderSms, err error) {
|
|
sql := `
|
|
SELECT *
|
|
FROM user_order_sms
|
|
WHERE 1=1
|
|
`
|
|
sqlParams := []interface{}{}
|
|
if mobile != "" {
|
|
sql += " AND mobile = ?"
|
|
sqlParams = append(sqlParams, mobile)
|
|
}
|
|
if name != "" {
|
|
sql += " AND name like ?"
|
|
sqlParams = append(sqlParams, "%"+name+"%")
|
|
}
|
|
err = GetRow(db, &userOrderSms, sql, sqlParams)
|
|
return userOrderSms, err
|
|
}
|
|
|
|
func GetUserMember(db *DaoDB, userID string, memberType int) (userMembers []*model.UserMember, err error) {
|
|
sql := `
|
|
SELECT a.*
|
|
FROM user_member a
|
|
WHERE a.deleted_at = ?
|
|
`
|
|
sqlParams := []interface{}{utils.DefaultTimeValue}
|
|
if userID != "" {
|
|
sql += " AND a.user_id = ?"
|
|
sqlParams = append(sqlParams, userID)
|
|
}
|
|
if memberType != 0 {
|
|
sql += " AND a.member_type = ?"
|
|
sqlParams = append(sqlParams, memberType)
|
|
}
|
|
err = GetRows(db, &userMembers, sql, sqlParams)
|
|
return userMembers, err
|
|
}
|