Merge branch 'main' of https://github.com/764763903a/xdd-plus

models/asset.go

@@ -65,6 +65,21 @@ func DailyAssetsPush() {
 		}
 	}
 }
+func (ck *JdCookie) Query1() string {
+	name:="jd_bean_change_new.js"
+	envs:=[]Env{{Name:"pins",Value:"&"+ck.PtPin}}
+	msg:=runTask(&Task{Path:name,Envs:envs},&Sender{})
+	//log.Info(msg)
+	if !strings.Contains(msg,"cookies"){
+		msg=regexp.MustCompile(`^(.+\s+){3}|\s*.+\s*$|.*东东工厂.*\s*`).ReplaceAllString(msg,"")
+		msg=fmt.Sprintf("账号昵称：%s\n绑定QQ: %v\n用户等级：%v\n等级名称：%v\n更新时间: %s\n%s",ck.Nickname,ck.QQ,ck.UserLevel,ck.LevelName,ck.CreateAt,msg)
+	}else if CookieOK(ck){
+		msg=fmt.Sprintf("查询失败\n账号: %s\n备注: %s\n%s",ck.PtPin,ck.Note,msg)
+	}else{
+		msg=fmt.Sprintf("失效账号\n账号: %s\n备注: %s",ck.PtPin,ck.Note)
+	}
+	return msg
+}
 
 func (ck *JdCookie) Query() string {
 	msgs := []string{
@@ -75,6 +90,7 @@ func (ck *JdCookie) Query() string {
 	}
 	asset := Asset{}
 	if CookieOK(ck) {
+		msgs = append(msgs, fmt.Sprintf("绑定QQ：%v", ck.QQ))
 		msgs = append(msgs, fmt.Sprintf("用户等级：%v", ck.UserLevel))
 		msgs = append(msgs, fmt.Sprintf("等级名称：%v", ck.LevelName))
 		cookie := fmt.Sprintf("pt_key=%s;pt_pin=%s;", ck.PtKey, ck.PtPin)

models/command.go

@@ -239,6 +239,15 @@ var codeSignals = []CodeSignal{
 			return nil
 		},
 	},
+	{
+		Command: []string{"详细查询", "query"},
+		Handle: func(sender *Sender) interface{} {
+			sender.handleJdCookies(func(ck *JdCookie) {
+				sender.Reply(ck.Query1())
+			})
+			return nil
+		},
+	},
 	{
 		Command: []string{"发送", "通知", "notify", "send"},
 		Admin:   true,
@@ -257,6 +266,63 @@ var codeSignals = []CodeSignal{
 			return nil
 		},
 	},
+	{
+		Command: []string{"我要钱","给点钱","我干","给我钱"},
+		Handle: func(sender *Sender) interface{} {
+			cost := Int(sender.JoinContens())
+			if !sender.IsAdmin{
+				if cost>1{
+					return "你只能获得1东币"
+					}else{
+					AddCoin(sender.UserID)
+					return "太可怜了，给你1东币"
+					}
+			}else{
+				AddCoin(sender.UserID)
+				sender.Reply(fmt.Sprintf("你获得1枚东币。"))
+			}
+			return nil
+		},
+	},
+	{
+		Command: []string{"梭哈","拼了","梭了"},
+		Handle: func(sender *Sender) interface{} {
+			u := &User{}
+			cost := GetCoin(sender.UserID)
+			
+			if cost <= 0 || cost > 10000 {
+				cost = 1
+			}
+			
+			if err := db.Where("number = ?", sender.UserID).First(u).Error; err != nil || u.Coin < cost {
+				return "东币不足，先去打卡吧。"
+			}else{
+				sender.Reply(fmt.Sprintf("你使用%d枚东币。", cost))
+			}
+			baga := 0
+			if u.Coin > 100000 {
+				baga = u.Coin
+				cost = u.Coin
+			}
+			r := time.Now().Nanosecond() % 10
+			if r < 7 || baga > 0 {
+				sender.Reply(fmt.Sprintf("很遗憾你失去了%d枚东币。", cost))
+				cost = -cost
+			} else {
+				if r == 9 {
+					cost *= 4
+					sender.Reply(fmt.Sprintf("恭喜你4倍暴击获得%d枚东币，20秒后自动转入余额。", cost))
+					time.Sleep(time.Second * 20)
+				} else {
+					sender.Reply(fmt.Sprintf("很幸运你获得%d枚东币，10秒后自动转入余额。", cost))
+					time.Sleep(time.Second * 10)
+				}
+				sender.Reply(fmt.Sprintf("%d枚东币已到账。", cost))
+			}
+			db.Model(u).Update("coin", gorm.Expr(fmt.Sprintf("coin + %d", cost)))
+			return nil
+		},
+	},
 	{
 		Command: []string{"赌一把"},
 		Handle: func(sender *Sender) interface{} {
@@ -274,7 +340,7 @@ var codeSignals = []CodeSignal{
 				cost = u.Coin
 			}
 			r := time.Now().Nanosecond() % 10
-			if r < 5 || baga > 0 {
+			if r < 6 || baga > 0 {
 				sender.Reply(fmt.Sprintf("很遗憾你失去了%d枚东币。", cost))
 				cost = -cost
 			} else {
@@ -568,8 +634,8 @@ var codeSignals = []CodeSignal{
 		Admin:   true,
 		Handle: func(sender *Sender) interface{} {
 			sender.handleJdCookies(func(ck *JdCookie) {
-				ck.Update(Hack, True)
-				sender.Reply(fmt.Sprintf("已设置屏蔽助力账号%s(%s)", ck.PtPin, ck.Nickname))
+				ck.Update(Priority, -1)
+				sender.Reply(fmt.Sprintf("已屏蔽账号%s(%s)", ck.PtPin, ck.Nickname,ck.Priority))
 			})
 			return nil
 		},
@@ -579,8 +645,8 @@ var codeSignals = []CodeSignal{
 		Admin:   true,
 		Handle: func(sender *Sender) interface{} {
 			sender.handleJdCookies(func(ck *JdCookie) {
-				ck.Update(Hack, False)
-				sender.Reply(fmt.Sprintf("已设置取消屏蔽助力账号%s(%s)", ck.PtPin, ck.Nickname))
+				ck.Update(Priority, 2)
+				sender.Reply(fmt.Sprintf("已取消屏蔽账号%s(%s)", ck.PtPin, ck.Nickname,ck.Priority))
 			})
 			return nil
 		},