505 lines
16 KiB
Go
505 lines
16 KiB
Go
package test
|
|
|
|
import (
|
|
"fmt"
|
|
"github.com/jinzhu/gorm"
|
|
_ "github.com/jinzhu/gorm/dialects/mysql"
|
|
"go-admin/app/admin/models"
|
|
"go-admin/app/admin/models/kuaidi"
|
|
orm "go-admin/common/global"
|
|
"go-admin/logger"
|
|
"golang.org/x/crypto/bcrypt"
|
|
"net/url"
|
|
|
|
//"go-admin/models/tools"
|
|
//"os"
|
|
"testing"
|
|
"time"
|
|
//"text/template"
|
|
)
|
|
|
|
func TestGoModelTemplate(t *testing.T) {
|
|
//t1, err := template.ParseFiles("model.go.template")
|
|
//if err != nil {
|
|
// t.Error(err)
|
|
//}
|
|
//table := tools.SysTables{}
|
|
//table.TBName = "sys_tables"
|
|
//tab, err := table.Get()
|
|
//if err != nil {
|
|
// t.Error(err)
|
|
//}
|
|
//file, err := os.Create("models/" + table.PackageName + ".go")
|
|
//if err != nil {
|
|
// t.Error(err)
|
|
//}
|
|
//defer file.Close()
|
|
//
|
|
//_ = t1.Execute(file, tab)
|
|
t.Log("")
|
|
|
|
//t1, err := template.ParseFiles("api.go.template")
|
|
//if err != nil {
|
|
// t.Error(err)
|
|
//}
|
|
//table := tools.SysTables{}
|
|
//table.TBName = "sys_tables"
|
|
//tab, _ := table.Get()
|
|
//file, err := os.Create("apis/" + table.PackageName + ".go")
|
|
//if err != nil {
|
|
// t.Error(err)
|
|
//}
|
|
//defer file.Close()
|
|
//
|
|
//_ = t1.Execute(file, tab)
|
|
//t.Log("")
|
|
}
|
|
|
|
func TestGoApiTemplate(t *testing.T) {
|
|
|
|
GoodsStoke()
|
|
}
|
|
|
|
const storeId = 15
|
|
|
|
func GoodsStoke() {
|
|
InitDBTest()
|
|
//models.GameCardGoodsStock{}
|
|
//models.GameCardGoods{}
|
|
|
|
var goods []models.GameCardGoods
|
|
err := DBTest.Table("game_card_goods").Where("store_id=?", storeId).Find(&goods).Error
|
|
if err != nil {
|
|
fmt.Println("err:", err)
|
|
}
|
|
goodsMap := make(map[uint64]uint32)
|
|
goodsRentMap := make(map[uint64]uint32)
|
|
for i, _ := range goods {
|
|
goodsMap[goods[i].GameCardId] += 1
|
|
if goods[i].Status == 1 {
|
|
goodsRentMap[goods[i].GameCardId] += 1
|
|
}
|
|
}
|
|
|
|
var goodsStock []models.GameCardGoodsStock
|
|
err = DBTest.Table("game_card_goods_stock").Where("store_id=?", storeId).Find(&goodsStock).Error
|
|
if err != nil {
|
|
fmt.Println("err:", err)
|
|
}
|
|
for i, _ := range goodsStock {
|
|
storeStock, ok := goodsMap[goodsStock[i].GameCardId]
|
|
if !ok {
|
|
//fmt.Println("游戏Id:")
|
|
}
|
|
rentStock, ok := goodsRentMap[goodsStock[i].GameCardId]
|
|
|
|
//if goodsStock[i].StoreStock != storeStock || goodsStock[i].RentStock != rentStock {
|
|
if goodsStock[i].RentStock != rentStock {
|
|
fmt.Println("游戏Id:", goodsStock[i].GameCardId, goodsStock[i].StoreStock, goodsStock[i].RentStock)
|
|
fmt.Println("游戏Id:", goodsStock[i].GameCardId, storeStock, rentStock, "真实库存")
|
|
fmt.Println("游戏Id:库存不对", goodsStock[i].GameCardId)
|
|
|
|
//sql := fmt.Sprintf("UPDATE game_card_goods_stock SET rent_stock=%d WHERE store_id=%d AND game_card_id=%d", rentStock, storeId, goodsStock[i].GameCardId)
|
|
//fmt.Println("sql:", sql)
|
|
//err := DBTest.Exec(sql).Error
|
|
//if err != nil {
|
|
// fmt.Println("err:", err)
|
|
//}
|
|
} else {
|
|
//fmt.Println("游戏Id:库存正确", goodsStock[i].GameCardId)
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
var DBTest *gorm.DB
|
|
|
|
func InitDBTest() {
|
|
var err error
|
|
//dialect := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local",
|
|
// "mh_pro", "fLeytnBFCRB553ab", "39.108.188.218", "3306",
|
|
// "mh_pro")
|
|
dialect := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local",
|
|
"mh_dev", "m5h4parZsXjbeiFh", "39.108.188.218", "3306",
|
|
"mh_dev")
|
|
|
|
DBTest, err = gorm.Open("mysql", dialect)
|
|
if err != nil {
|
|
fmt.Println("Connect Database Error, error = ", err)
|
|
panic(err)
|
|
}
|
|
DBTest.DB().SetMaxOpenConns(1000)
|
|
DBTest.DB().SetMaxIdleConns(500)
|
|
DBTest.DB().SetConnMaxLifetime(time.Second * 10)
|
|
DBTest.LogMode(true)
|
|
DBTest.SingularTable(true)
|
|
DBTest.AutoMigrate(
|
|
//&models.Article{},
|
|
//&models.ArticleCollect{},
|
|
//&models.CannibalizeStockTask{},
|
|
//&models.CannibalizeGameCardGoods{},
|
|
|
|
models.SysUser{},
|
|
models.ExpireMemberSmsSend{},
|
|
)
|
|
|
|
if err := DBTest.DB().Ping(); err != nil {
|
|
fmt.Println("Ping Database Fail, error = ", err)
|
|
panic(err)
|
|
}
|
|
fmt.Println("DB init success")
|
|
}
|
|
|
|
func TestInitDBTest(t *testing.T) {
|
|
InitDBTest()
|
|
}
|
|
|
|
var DBProd *gorm.DB
|
|
|
|
func InitDBProd() {
|
|
var err error
|
|
dialect := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local",
|
|
"mh_pro", "fLeytnBFCRB553ab", "39.108.188.218", "3306",
|
|
"mh_pro")
|
|
|
|
DBProd, err = gorm.Open("mysql", dialect)
|
|
if err != nil {
|
|
fmt.Println("Connect Database Error, error = ", err)
|
|
panic(err)
|
|
}
|
|
DBProd.DB().SetMaxOpenConns(1000)
|
|
DBProd.DB().SetMaxIdleConns(500)
|
|
DBProd.DB().SetConnMaxLifetime(time.Second * 10)
|
|
DBProd.LogMode(true)
|
|
DBProd.SingularTable(true)
|
|
DBProd.AutoMigrate(
|
|
models.SysUser{},
|
|
models.ExpireMemberSmsSend{},
|
|
)
|
|
|
|
if err := DBProd.DB().Ping(); err != nil {
|
|
fmt.Println("Ping Database Fail, error = ", err)
|
|
panic(err)
|
|
}
|
|
fmt.Println("DB init success")
|
|
}
|
|
|
|
func TestInitDBProd(t *testing.T) {
|
|
InitDBProd()
|
|
}
|
|
|
|
func TestUserAddName(t *testing.T) {
|
|
UserAddName()
|
|
}
|
|
|
|
func UserAddName() {
|
|
InitDBProd()
|
|
nameMap := map[uint32]string{
|
|
5151411: "钟林",
|
|
59834104: "张露丹",
|
|
32742391: "罗鹰翔",
|
|
10548743: "罗笑谦",
|
|
96944919: "唐朝霞",
|
|
51846105: "蒲键发",
|
|
5850964: "代小艳",
|
|
31197378: "李鑫凯",
|
|
96658713: "杨淳",
|
|
14680227: "赵鹏",
|
|
65610369: "陈吉平",
|
|
13673929: "马盛豪",
|
|
71615842: "詹若慧",
|
|
26580935: "刘凡瑛",
|
|
21785997: "杨权南",
|
|
28610013: "黎一才",
|
|
91733893: "蔡显荣",
|
|
22465825: "陶德源",
|
|
25354617: "黄子健",
|
|
44114412: "王迈",
|
|
86443412: "张彬",
|
|
44005620: "冯子豪",
|
|
13541666: "吴逸欣",
|
|
45886563: "苟浩川",
|
|
42522553: "刘威",
|
|
35064958: "毕杨阳",
|
|
19324196: "胡阳",
|
|
79850633: "何林月",
|
|
61415201: "赵潘",
|
|
91659241: "卢宇休",
|
|
15243331: "刘恭德",
|
|
97074634: "林浩斌",
|
|
40370226: "陈剑鹏",
|
|
49468994: "杨俊海",
|
|
92004706: "方泽玲",
|
|
73391379: "周靖文",
|
|
51858559: "连志弘",
|
|
34075903: "廖伟",
|
|
41584397: "杨铭",
|
|
69438798: "罗可人",
|
|
60320897: "官西湖",
|
|
51850341: "李锐",
|
|
56228118: "王于滔",
|
|
18396180: "潘梦妮",
|
|
48739259: "张鑫淼",
|
|
45507685: "邹骐骏",
|
|
}
|
|
//ids := []uint32{25257310,5151411,59834104,32742391,10548743,96944919,51846105,5850964,31197378,96658713,14680227,65610369,13673929,71615842,26580935,21785997,28610013,91733893,22465825,25354617,44114412,86443412,44005620,13541666,45886563,42522553,35064958,19324196,61415201,91659241,15243331,97074634,40370226,49468994,92004706,73391379,
|
|
//}
|
|
fmt.Println("nameMap:", nameMap)
|
|
|
|
//sql := fmt.Sprintln("SELECT * FROM `user` WHERE uid IN (25257310,5151411,59834104,32742391,10548743,96944919,51846105,5850964,31197378,96658713,14680227,65610369,13673929,71615842,26580935,21785997,28610013,91733893,22465825,25354617,44114412,86443412,44005620,13541666,45886563,42522553,35064958,19324196,61415201,91659241,15243331,97074634,40370226,49468994,92004706,73391379)")
|
|
sql := fmt.Sprintln("SELECT * FROM `user` WHERE uid IN (25257310,5151411,59834104,32742391,10548743,96944919,51846105,5850964,31197378,96658713,14680227,65610369,13673929,71615842,26580935,21785997,28610013,91733893,22465825,25354617,44114412,86443412,44005620,13541666,45886563,42522553,35064958,19324196,79850633,61415201,91659241,15243331,97074634,40370226,49468994,92004706,73391379,51858559,34075903,41584397,69438798,60320897,51850341,56228118)")
|
|
var users []models.UserInfo
|
|
err := DBProd.Raw(sql).Scan(&users).Error
|
|
if err != nil {
|
|
fmt.Println("err:", err.Error())
|
|
}
|
|
|
|
for i, _ := range users {
|
|
name, ok := nameMap[users[i].Uid]
|
|
if ok && users[i].ShopAssistantName == "" {
|
|
|
|
sql := fmt.Sprintf("UPDATE `user` SET shop_assistant_name = '%s' WHERE uid = %d", name, users[i].Uid)
|
|
err := DBProd.Exec(sql).Error
|
|
if err != nil {
|
|
fmt.Println("err:", err.Error())
|
|
}
|
|
fmt.Println("Name:", name)
|
|
}
|
|
//fmt.Println("Uid:", users[i].Uid)
|
|
fmt.Println("Name:", users[i].ShopAssistantName)
|
|
}
|
|
}
|
|
|
|
// 收益生效
|
|
func TestShareCardProfitEffectShareCard(t *testing.T) {
|
|
ShareCardProfitEffectShareCard()
|
|
}
|
|
|
|
func ShareCardProfitEffectShareCard() {
|
|
InitIODBTest()
|
|
orm.Eloquent = IODBTest
|
|
models.ShareCardProfitEffectCard()
|
|
}
|
|
|
|
// 发放游戏积分
|
|
func TestShareCardProvideVmUser(t *testing.T) {
|
|
ShareCardProvideVmUser()
|
|
}
|
|
|
|
func ShareCardProvideVmUser() {
|
|
//InitDBTest()
|
|
InitIODBTest()
|
|
orm.Eloquent = IODBTest
|
|
|
|
models.ShareCardProfitEffectCard()
|
|
models.ShareCardProvideVm()
|
|
}
|
|
|
|
// 发放用户积分
|
|
func TestShareCardUserVmRecordCreate(t *testing.T) {
|
|
ShareCardUserVmRecordCreate()
|
|
}
|
|
|
|
func ShareCardUserVmRecordCreate() {
|
|
InitIODBTest()
|
|
orm.Eloquent = IODBTest
|
|
|
|
models.ShareCardUserVmRecord()
|
|
}
|
|
|
|
// 分配用户收回卡
|
|
func TestShareCardRetrieveCardSetCard(t *testing.T) {
|
|
//ShareCardRetrieveCardSetCard()
|
|
|
|
InitIODBTest()
|
|
orm.Eloquent = IODBTest
|
|
models.ShareCardRetrieveCardSetStockCardCron()
|
|
}
|
|
|
|
// 订阅 推送物流状态
|
|
func TestSubscribeExpressState(t *testing.T) {
|
|
//kuaidi.SubscribeExpressState("shentong", "777081382580032")
|
|
kuaidi.SubscribeExpressState("yunda", "462325443141899")
|
|
}
|
|
|
|
func TestKuaiDiStatePush(t *testing.T) {
|
|
|
|
body := "param=%7B%22status%22%3A%22polling%22%2C%22message%22%3A%22%22%2C%22lastResult%22%3A%7B%22message%22%3A%22ok%22%2C%22nu%22%3A%22YT6074326614455%22%2C%22ischeck%22%3A%220%22%2C%22com%22%3A%22yuantong%22%2C%22status%22%3A%22200%22%2C%22state%22%3A0%2C%22data%22%3A%5B%7B%22time%22%3A%222022-01-25+15%3A19%3A10%22%2C%22context%22%3A%22%E3%80%90%E8%B4%B5%E9%98%B3%E5%B8%82%E3%80%91%E5%B7%B2%E5%88%B0%E8%BE%BE+%E8%B4%B5%E5%B7%9E%E8%B4%B5%E9%98%B3%E5%88%86%E6%8B%A8%E4%BA%A4%E4%BB%98%E4%B8%AD%E5%BF%83%22%2C%22ftime%22%3A%222022-01-25+15%3A19%3A10%22%2C%22areaCode%22%3A%22CN520100000000%22%2C%22areaName%22%3A%22%E8%B4%B5%E5%B7%9E%2C%E8%B4%B5%E9%98%B3%E5%B8%82%22%2C%22status%22%3A%22%E5%9C%A8%E9%80%94%22%2C%22location%22%3Anull%2C%22areaCenter%22%3Anull%2C%22areaPinYin%22%3Anull%2C%22statusCode%22%3Anull%7D%2C%7B%22time%22%3A%222022-01-24+03%3A27%3A18%22%2C%22context%22%3A%22%E3%80%90%E6%88%90%E9%83%BD%E5%B8%82%E3%80%91%E5%B7%B2%E7%A6%BB%E5%BC%80+%E5%9B%9B%E5%B7%9D%E6%88%90%E9%83%BD%E5%88%86%E6%8B%A8%E4%BA%A4%E4%BB%98%E4%B8%AD%E5%BF%83%EF%BC%9B%E5%8F%91%E5%BE%80+%E8%B4%B5%E9%98%B3%E5%8C%97%E5%9C%B0%E5%8C%BA%E5%8C%85%22%2C%22ftime%22%3A%222022-01-24+03%3A27%3A18%22%2C%22areaCode%22%3A%22CN510100000000%22%2C%22areaName%22%3A%22%E5%9B%9B%E5%B7%9D%2C%E6%88%90%E9%83%BD%E5%B8%82%22%2C%22status%22%3A%22%E5%9C%A8%E9%80%94%22%2C%22location%22%3Anull%2C%22areaCenter%22%3Anull%2C%22areaPinYin%22%3Anull%2C%22statusCode%22%3Anull%7D%2C%7B%22time%22%3A%222022-01-24+03%3A23%3A02%22%2C%22context%22%3A%22%E3%80%90%E6%88%90%E9%83%BD%E5%B8%82%E3%80%91%E5%B7%B2%E5%88%B0%E8%BE%BE+%E5%9B%9B%E5%B7%9D%E6%88%90%E9%83%BD%E5%88%86%E6%8B%A8%E4%BA%A4%E4%BB%98%E4%B8%AD%E5%BF%83%22%2C%22ftime%22%3A%222022-01-24+03%3A23%3A02%22%2C%22areaCode%22%3A%22CN510100000000%22%2C%22areaName%22%3A%22%E5%9B%9B%E5%B7%9D%2C%E6%88%90%E9%83%BD%E5%B8%82%22%2C%22status%22%3A%22%E5%9C%A8%E9%80%94%22%2C%22location%22%3Anull%2C%22areaCenter%22%3Anull%2C%22areaPinYin%22%3Anull%2C%22statusCode%22%3Anull%7D%2C%7B%22time%22%3A%222022-01-23+15%3A46%3A17%22%2C%22context%22%3A%22%E3%80%90%E6%88%90%E9%83%BD%E5%B8%82%E3%80%91%E5%9B%9B%E5%B7%9D%E6%88%90%E9%83%BD%E6%96%B0%E9%83%BD%E5%8C%BA%E5%A4%A9%E6%96%B0%E5%85%AC%E5%8F%B8-%E6%93%8D%E4%BD%9C%E9%83%A8%EF%BC%88135****1234%EF%BC%89+%E5%B7%B2%E6%8F%BD%E6%94%B6%22%2C%22ftime%22%3A%222022-01-23+15%3A46%3A17%22%2C%22areaCode%22%3A%22CN510114000000%22%2C%22areaName%22%3A%22%E5%9B%9B%E5%B7%9D%2C%E6%88%90%E9%83%BD%E5%B8%82%2C%E6%96%B0%E9%83%BD%E5%8C%BA%22%2C%22status%22%3A%22%E6%8F%BD%E6%94%B6%22%2C%22location%22%3Anull%2C%22areaCenter%22%3Anull%2C%22areaPinYin%22%3Anull%2C%22statusCode%22%3Anull%7D%5D%2C%22loop%22%3Afalse%7D%7D"
|
|
|
|
//allReq := new(url.Values)
|
|
|
|
//url.Parse(body)
|
|
|
|
//unescape, err := url.QueryUnescape(body)
|
|
//if err != nil {
|
|
// logger.Error("err:", err)
|
|
//}
|
|
|
|
unescape, err := url.ParseQuery(body)
|
|
if err != nil {
|
|
logger.Error("err:", logger.Field("err", err))
|
|
}
|
|
//unescapeJson, _ := json.Marshal(unescape)
|
|
|
|
paramJson := unescape.Get("param")
|
|
|
|
fmt.Println("unescape:", unescape)
|
|
//fmt.Println("state:", unescape.Get("state"))
|
|
|
|
fmt.Println("unescapeJson:", string(paramJson))
|
|
}
|
|
|
|
func TestMapCount(t *testing.T) {
|
|
|
|
countMap := make(map[uint32]uint32)
|
|
countMap[100] = 100
|
|
countMap[101] = 101
|
|
AddMap(&countMap)
|
|
|
|
for k, v := range countMap {
|
|
fmt.Println("k:", k, v)
|
|
}
|
|
}
|
|
|
|
func AddMap(count *map[uint32]uint32) {
|
|
for k, v := range *count {
|
|
if k == 100 {
|
|
(*count)[k] = v - 17
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
func TestTimeZeroData(t *testing.T) {
|
|
InitIODBTest()
|
|
orm.Eloquent = IODBTest
|
|
//models.ShareCardRetrieveCard{}
|
|
err := orm.Eloquent.Table("share_card_retrieve_card").Where("id=?", 204).Updates(map[string]interface{}{
|
|
//"state": RetrieveStateSentCard,
|
|
//"state": retrieveState,
|
|
"receipt_time": time.Time{},
|
|
}).Error
|
|
if err != nil {
|
|
logger.Error("err:", logger.Field("err", err))
|
|
}
|
|
//NewShareCardRetrieveCardQuerySet(DB).IDEq(189).GetUpdater().SetStoreId()
|
|
|
|
}
|
|
|
|
func TestGoodsPutDownAway(t *testing.T) {
|
|
InitDBTest()
|
|
orm.Eloquent = IODBTest
|
|
models.GoodsPutDownAway()
|
|
}
|
|
|
|
type SysCasbinRule struct {
|
|
PType string `json:"p_type" gorm:"size:100;"`
|
|
V0 string `json:"v0" gorm:"size:100;"`
|
|
V1 string `json:"v1" gorm:"size:100;"`
|
|
V2 string `json:"v2" gorm:"size:100;"`
|
|
V3 string `json:"v3" gorm:"size:100;"`
|
|
V4 string `json:"v4" gorm:"size:100;"`
|
|
V5 string `json:"v5" gorm:"size:100;"`
|
|
}
|
|
|
|
func TestUpdateSysMute(t *testing.T) {
|
|
InitDBTest()
|
|
var mus []models.Menu
|
|
err := DBTest.Table("sys_menu").Where("menu_id>?", 714).Where("path!=''").Find(&mus).Error
|
|
if err != nil {
|
|
fmt.Println("err:", err)
|
|
}
|
|
for i, _ := range mus {
|
|
rule := &SysCasbinRule{
|
|
PType: "p",
|
|
V0: "admin",
|
|
V1: mus[i].Path,
|
|
V2: "POST",
|
|
V3: "",
|
|
V4: "",
|
|
V5: "",
|
|
}
|
|
err = DBTest.Create(rule).Error
|
|
if err != nil {
|
|
fmt.Println("err:", err)
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestUpdateDe(t *testing.T) {
|
|
InitDBTest()
|
|
}
|
|
|
|
func TestUpdateStorePassWd(t *testing.T) {
|
|
InitIODBPro()
|
|
orm.Eloquent = IODBPro
|
|
list := []string{"super-admin", "super-admin-2",
|
|
"admin", "admin-2", "cw-deovo", "dz-swt", "dy-swt", "dz-spw", "dy-spw", "dz-sgd", "dy-sgd", "dz-shb", "dy-shb",
|
|
"dz-cyt", "dy-cyt", "dz-cut", "dy-cut", "dz-cbt", "dy-cbt", "dz-cjt", "dy-cjt", "dz-ckw", "dy-ckw", "dz-cst",
|
|
"dy-cst", "dz-slw", "dy-slw"}
|
|
|
|
//passes := []string{"uM4rUKdm0i", "R4l9zrQC2n", "r0rSOWezr8", "McA2ydvGnT", "je3KvHkSCI", "vVLMc0nR3m", "lUfhGmP10G", "GTybJ7tMyR", "VQpGubl5pO", "Ev2N50vFrF", "0KNpLHxoi1", "WdO1Rv8FId", "oGRNkv98Vt", "73N0v2jKaJ", "2EAaYoJ7JB", "1ttf3yHpqE", "oo4JfwHtPi", "G4ca7aePHP", "sG9Yc4BzTS", "92mUaxtk0S", "nhZ7ri6JCx", "Ap53rjKH4x", "zei1NlyyP1", "TKoaciae49", "NeB1BxkxGN", "oNeOaetr3G", "W6Eg1095jP"}
|
|
passes := []string{"o5wl76ogps", "9041rqb2sl", "fhn07rxz1n", "3ytu0o9nx3", "r2n6lgukoc", "5k2js8zz3k", "1z0vivh5kh", "oi8jolwx7q", "7evejzqecf", "kj2myxxshm", "m2vvyuwuzf", "s3abpjb5q2", "jw6wauitze", "80ansm6p72", "2ek34nmjf1", "fd3xqrtl36", "qubxi495tn", "tny44szjy7", "zwfra32edd", "3ekv24oo1n", "90al6cqwox", "bv67e4pmr6", "hslcf2iqlq", "kgyh5hssqq", "3r6fsoe5gl", "rb7bjktirg", "w1crto37r6"}
|
|
for i, _ := range list {
|
|
var sysUsers models.SysUser
|
|
err := orm.Eloquent.Table("sys_user").Where("username=?", list[i]).Find(&sysUsers).Error
|
|
if err != nil {
|
|
logger.Error("find sys users err:", logger.Field("err", err))
|
|
}
|
|
|
|
fmt.Println("list:", list[i], " ", passes[i])
|
|
var hash []byte
|
|
if hash, err = bcrypt.GenerateFromPassword([]byte(passes[i]), bcrypt.DefaultCost); err != nil {
|
|
return
|
|
}
|
|
|
|
fmt.Println("sysUsers:", sysUsers.PassWord.Password)
|
|
fmt.Println("hash:", string(hash))
|
|
//err = orm.Eloquent.Table("sys_user").Where("user_id=?", sysUsers[i].UserId).Update("password", string(hash)).Error
|
|
//if err != nil {
|
|
// logger.Error("update err:", err)
|
|
//}
|
|
}
|
|
}
|
|
|
|
func TestUpdateStorePassWdTest(t *testing.T) {
|
|
InitIODBTest()
|
|
orm.Eloquent = IODBTest
|
|
var sysUsers []models.SysUser
|
|
err := orm.Eloquent.Debug().Table("sys_user").Where("username IN (?)", []string{"wxjm"}).Find(&sysUsers).Error
|
|
if err != nil {
|
|
logger.Error("find sys users err:", logger.Field("err", err))
|
|
}
|
|
passes := []string{"JlPP2ZnAT1"}
|
|
for i, _ := range sysUsers {
|
|
//pwd := models.SysUserPwd{
|
|
// OldPassword: sysUsers[i].Password,
|
|
// NewPassword: passes[i],
|
|
//}
|
|
|
|
//sysuser := models.SysUser{}
|
|
//sysuser.UserId = sysUsers[i].UserId
|
|
//sysuser.SetPwd(pwd)
|
|
var hash []byte
|
|
if hash, err = bcrypt.GenerateFromPassword([]byte(passes[i]), bcrypt.DefaultCost); err != nil {
|
|
return
|
|
}
|
|
|
|
fmt.Println("sysUsers:", sysUsers[i].PassWord.Password)
|
|
fmt.Println("hash:", string(hash))
|
|
|
|
err = orm.Eloquent.Table("sys_user").Where("user_id=?", sysUsers[i].UserId).Update("password", string(hash)).Error
|
|
if err != nil {
|
|
logger.Error("update err:", logger.Field("err", err))
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestUpdateExpireMemberLevel(t *testing.T) {
|
|
fmt.Println("test UpdateExpireMemberLevel start")
|
|
InitIODBTest()
|
|
orm.Eloquent = IODBTest
|
|
models.UpdateExpireMemberLevel()
|
|
fmt.Println("test UpdateExpireMemberLevel end")
|
|
}
|