feat: 异常收集接口、自动提单

master
luziqi 3 years ago
parent acad2ac97a
commit 4dbbce488e

@ -0,0 +1,88 @@
package common
import (
"errors"
"fmt"
"time"
"github.com/imroc/req/v3"
"github.com/tidwall/gjson"
)
const API_tbapi = "http://qa.flatincbr.work:5354"
type BugInfo struct {
ProjectName string `json:"project_name"` // tb项目名称
ProjectID string `json:"project_id"` // tb项目id
ExecutorID string `json:"executor_id"` // tb缺陷的处理人
Title string `json:"title"` // tb缺陷的标题
Content string `json:"content"` // tb缺陷的备注
InvolveMembers []string `json:"involve_members"` // tb缺陷的参与人
Pf string `json:"pf"` // 所属平台除了adr/ios其它不处理
}
func NewBug(project_name string) BugInfo {
var v BugInfo
v.ProjectName = project_name
return v
}
// 指定执行者
func (b *BugInfo) SetExecutor(id string) *BugInfo {
b.ExecutorID = id
return b
}
// 指定参与者
func (b *BugInfo) SetInvolveMember(id ...string) *BugInfo {
b.InvolveMembers = id
return b
}
// 设置标题
func (b *BugInfo) SetTitle(title string) *BugInfo {
b.Title = title
return b
}
// 设置备注内容
func (b *BugInfo) SetContent(content string) *BugInfo {
b.Content = content
return b
}
// 设置所属平台adr/ios
func (b *BugInfo) SetPlatform(pf string) *BugInfo {
b.Pf = pf
return b
}
func (b *BugInfo) Create() (string, error) {
// buf, err := json.Marshal(b)
// if err != nil {
// fmt.Println("序列化失败:", err)
// return "", err
// }
// fmt.Println(string(buf))
client := req.C().
SetTimeout(10 * time.Second)
resp, err := client.R().
SetBodyJsonMarshal(b).
Post(API_tbapi + "/api/tb/v2/bug/create")
if err != nil {
fmt.Println("Teambition提单失败", err)
return "", err
}
if resp.IsErrorState() {
fmt.Println("Teambition提单失败", resp.StatusCode, resp.String())
return "", err
}
bug_id := gjson.Get(resp.String(), "data").String()
if len(bug_id) == 0 {
return "", errors.New("请求成功但返回bug_id为空")
}
fmt.Println("Teambition提单成功, id =", bug_id)
return bug_id, nil
}

@ -959,6 +959,35 @@ const docTemplate = `{
}
}
},
"/api/monkey/v2/task/get_anomalies": {
"get": {
"description": "通过任务id获取Monkey异常信息",
"consumes": [
"application/x-www-form-urlencoded"
],
"tags": [
"Monkey相关 /api/monkey/v2/"
],
"summary": "获取Monkey异常信息",
"parameters": [
{
"type": "integer",
"description": "任务id",
"name": "task_id",
"in": "query",
"required": true
}
],
"responses": {
"200": {
"description": "返回任务结果",
"schema": {
"$ref": "#/definitions/models.Response"
}
}
}
}
},
"/api/monkey/v2/task/handle/set": {
"post": {
"description": "更新Monkey任务跟进状态",
@ -995,6 +1024,59 @@ const docTemplate = `{
}
}
},
"/api/monkey/v2/task/store_anomaly": {
"post": {
"description": "上报Monkey异常",
"consumes": [
"application/x-www-form-urlencoded"
],
"tags": [
"Monkey相关 /api/monkey/v2/"
],
"summary": "上报Monkey异常",
"parameters": [
{
"type": "integer",
"description": "任务id",
"name": "task_id",
"in": "formData",
"required": true
},
{
"type": "string",
"description": "要更新的任务状态",
"name": "crash_log_list",
"in": "formData"
},
{
"type": "string",
"description": "要更新的任务状态",
"name": "activity_name_info",
"in": "formData"
},
{
"type": "string",
"description": "要更新的任务状态",
"name": "device_name",
"in": "formData"
},
{
"type": "string",
"description": "要更新的任务状态",
"name": "status",
"in": "formData"
}
],
"responses": {
"200": {
"description": "返回更新后的任务信息",
"schema": {
"$ref": "#/definitions/models.Response"
}
}
}
}
},
"/api/project/v1/app": {
"get": {
"description": "根据应用名称app_name获取应用信息",

@ -947,6 +947,35 @@
}
}
},
"/api/monkey/v2/task/get_anomalies": {
"get": {
"description": "通过任务id获取Monkey异常信息",
"consumes": [
"application/x-www-form-urlencoded"
],
"tags": [
"Monkey相关 /api/monkey/v2/"
],
"summary": "获取Monkey异常信息",
"parameters": [
{
"type": "integer",
"description": "任务id",
"name": "task_id",
"in": "query",
"required": true
}
],
"responses": {
"200": {
"description": "返回任务结果",
"schema": {
"$ref": "#/definitions/models.Response"
}
}
}
}
},
"/api/monkey/v2/task/handle/set": {
"post": {
"description": "更新Monkey任务跟进状态",
@ -983,6 +1012,59 @@
}
}
},
"/api/monkey/v2/task/store_anomaly": {
"post": {
"description": "上报Monkey异常",
"consumes": [
"application/x-www-form-urlencoded"
],
"tags": [
"Monkey相关 /api/monkey/v2/"
],
"summary": "上报Monkey异常",
"parameters": [
{
"type": "integer",
"description": "任务id",
"name": "task_id",
"in": "formData",
"required": true
},
{
"type": "string",
"description": "要更新的任务状态",
"name": "crash_log_list",
"in": "formData"
},
{
"type": "string",
"description": "要更新的任务状态",
"name": "activity_name_info",
"in": "formData"
},
{
"type": "string",
"description": "要更新的任务状态",
"name": "device_name",
"in": "formData"
},
{
"type": "string",
"description": "要更新的任务状态",
"name": "status",
"in": "formData"
}
],
"responses": {
"200": {
"description": "返回更新后的任务信息",
"schema": {
"$ref": "#/definitions/models.Response"
}
}
}
}
},
"/api/project/v1/app": {
"get": {
"description": "根据应用名称app_name获取应用信息",

@ -635,6 +635,25 @@ paths:
summary: 获取Monkey任务的执行命令
tags:
- Monkey相关 /api/monkey/v2/
/api/monkey/v2/task/get_anomalies:
get:
consumes:
- application/x-www-form-urlencoded
description: 通过任务id获取Monkey异常信息
parameters:
- description: 任务id
in: query
name: task_id
required: true
type: integer
responses:
"200":
description: 返回任务结果
schema:
$ref: '#/definitions/models.Response'
summary: 获取Monkey异常信息
tags:
- Monkey相关 /api/monkey/v2/
/api/monkey/v2/task/handle/set:
post:
consumes:
@ -659,6 +678,41 @@ paths:
summary: 更新任务跟进状态
tags:
- Monkey相关 /api/monkey/v2/
/api/monkey/v2/task/store_anomaly:
post:
consumes:
- application/x-www-form-urlencoded
description: 上报Monkey异常
parameters:
- description: 任务id
in: formData
name: task_id
required: true
type: integer
- description: 要更新的任务状态
in: formData
name: crash_log_list
type: string
- description: 要更新的任务状态
in: formData
name: activity_name_info
type: string
- description: 要更新的任务状态
in: formData
name: device_name
type: string
- description: 要更新的任务状态
in: formData
name: status
type: string
responses:
"200":
description: 返回更新后的任务信息
schema:
$ref: '#/definitions/models.Response'
summary: 上报Monkey异常
tags:
- Monkey相关 /api/monkey/v2/
/api/project/v1/app:
get:
consumes:

@ -54,6 +54,9 @@ require (
github.com/quic-go/qtls-go1-20 v0.1.0 // indirect
github.com/quic-go/quic-go v0.32.0 // indirect
github.com/satori/go.uuid v1.2.0 // indirect
github.com/tidwall/gjson v1.14.4 // indirect
github.com/tidwall/match v1.1.1 // indirect
github.com/tidwall/pretty v1.2.0 // indirect
github.com/ugorji/go/codec v1.2.7 // indirect
golang.org/x/crypto v0.7.0 // indirect
golang.org/x/exp v0.0.0-20221205204356-47842c84f3db // indirect

@ -164,6 +164,12 @@ github.com/swaggo/gin-swagger v1.5.2/go.mod h1:Cbj/MlHApPOjZdf4joWFXLLgmZVPyh54G
github.com/swaggo/swag v1.8.1/go.mod h1:ugemnJsPZm/kRwFUnzBlbHRd0JY9zE1M4F+uy2pAaPQ=
github.com/swaggo/swag v1.8.4 h1:oGB351qH1JqUqK1tsMYEE5qTBbPk394BhsZxmUfebcI=
github.com/swaggo/swag v1.8.4/go.mod h1:jMLeXOOmYyjk8PvHTsXBdrubsNd9gUJTTCzL5iBnseg=
github.com/tidwall/gjson v1.14.4 h1:uo0p8EbA09J7RQaflQ1aBRffTR7xedD2bcIVSYxLnkM=
github.com/tidwall/gjson v1.14.4/go.mod h1:/wbyibRr2FHMks5tjHJ5F8dMZh3AcwJEMf5vlfC0lxk=
github.com/tidwall/match v1.1.1 h1:+Ho715JplO36QYgwN9PGYNhgZvoUSc9X2c80KVTi+GA=
github.com/tidwall/match v1.1.1/go.mod h1:eRSPERbgtNPcGhD8UCthc6PmLEQXEWd3PRB5JTxsfmM=
github.com/tidwall/pretty v1.2.0 h1:RWIZEg2iJ8/g6fDDYzMpobmaoGh5OLl4AXtGUGPcqCs=
github.com/tidwall/pretty v1.2.0/go.mod h1:ITEVvHYasfjBbM0u2Pg8T2nJnzm8xPwvNhhsoaGGjNU=
github.com/ugorji/go v1.2.7/go.mod h1:nF9osbDWLy6bDVv/Rtoh6QgnvNDpmCalQV5urGCCS6M=
github.com/ugorji/go/codec v1.2.7 h1:YPXUKf7fYbp/y8xloBqZOw2qaVggbfwMlI8WM3wZUJ0=
github.com/ugorji/go/codec v1.2.7/go.mod h1:WGN1fab3R1fzQlVQTkfxVtIBhWDRqOviHU95kRgeqEY=

@ -0,0 +1,33 @@
package models
import (
"autogo/global"
"encoding/json"
"fmt"
)
type MonkeyAnomaly struct {
global.MODEL
TaskId int `json:"task_id"`
Udid string `json:"udid"`
AnomalyInfos string `json:"-" gorm:"anomaly_infos"`
Anomalies []string `json:"anomalies" gorm:"-"`
CoverdPages string `json:"coverd_pages"`
Logs string `json:"logs"`
}
func (m *MonkeyAnomaly) TableName() string {
return "monkey_anomalies"
}
func (m *MonkeyAnomaly) JsonReady() {
var strs []string
if len(m.AnomalyInfos) > 3 {
err := json.Unmarshal([]byte(m.AnomalyInfos), &strs)
if err != nil {
fmt.Println("[JsonReady]", "序列化失败")
return
}
m.Anomalies = strs
}
}

@ -66,7 +66,7 @@ func (task *MonkeyTask) Cmd(udid string, filename string) string {
// }
// cmd_str += " >> /home/app/logs/task_output/task_" + cast.ToString(task.Id) + ".log 2>&1"
case "ios":
cmd_str = "docker run -d --rm --name monkey_task_" + cast.ToString(task.Id) + "_" + udid + " "
cmd_str = "docker run -d --rm --net=host --name monkey_task_" + cast.ToString(task.Id) + "_" + udid + " "
cmd_str += "-e TASK_ID=" + cast.ToString(task.Id) + " "
cmd_str += "-e BUNDLE_ID=" + task.PackageName + " "
cmd_str += "-e RUNTIME=" + cast.ToString(task.RunTime) + " "

@ -0,0 +1,161 @@
package monkey
import (
"autogo/common"
"autogo/controllers"
"autogo/dbsql"
"autogo/models"
"encoding/json"
"fmt"
"net/http"
"strings"
"github.com/gin-gonic/gin"
"github.com/spf13/cast"
)
type anomaly struct {
TaskId int `json:"task_id"`
Udid string `json:"udid"`
Anomalies []string `json:"anomalies"`
CoverdPages []string `json:"coverd_pages"`
Logs []string `json:"logs"`
}
// @Tags Monkey相关 /api/monkey/v2/
// @Summary 上报Monkey异常
// @Description 上报Monkey异常
// @accept x-www-form-urlencoded
// @Param task_id formData int true "任务id"
// @Param crash_log_list formData string false "要更新的任务状态"
// @Param activity_name_info formData string false "要更新的任务状态"
// @Param device_name formData string false "要更新的任务状态"
// @Param status formData string false "要更新的任务状态"
// @Success 200 {object} models.Response "返回更新后的任务信息"
// @Router /api/monkey/v2/task/store_anomaly [post]
func StoreMonkeyAnomaly(c *gin.Context) {
rsp := controllers.NewResponse()
var ano anomaly
err := c.ShouldBindJSON(&ano)
if err != nil {
c.JSON(http.StatusOK, rsp.Error("json解析失败: "+err.Error()))
return
}
var res models.MonkeyAnomaly
res.TaskId = cast.ToInt(ano.TaskId)
if res.TaskId < 1 {
rsp.Error("task_id error:" + c.PostForm("task_id"))
c.JSON(http.StatusOK, rsp)
return
}
if len(ano.Anomalies) > 0 {
buf, _ := json.Marshal(ano.Anomalies)
res.Anomalies = ano.Anomalies
res.AnomalyInfos = string(buf)
}
if len(ano.CoverdPages) > 0 {
res.CoverdPages = strings.Join(ano.CoverdPages, ",")
}
res.Udid = ano.Udid
if len(ano.Logs) > 0 {
res.Logs = strings.Join(ano.Logs, ",")
}
db, err := dbsql.GetConn(dbsql.DSN)
if err != nil {
rsp.Error(err.Error())
c.JSON(http.StatusOK, rsp)
return
}
defer dbsql.Close(db)
db.Table(res.TableName()).Model(models.MonkeyAnomaly{}).Create(&res)
if res.ID < 1 {
rsp.Error("保存Monkey异常失败")
c.JSON(http.StatusOK, rsp)
return
}
rsp.Success()
rsp.Data = res
c.JSON(http.StatusOK, rsp)
go createTbBug(res)
}
// @Tags Monkey相关 /api/monkey/v2/
// @Summary 获取Monkey异常信息
// @Description 通过任务id获取Monkey异常信息
// @accept x-www-form-urlencoded
// @Param task_id query int true "任务id"
// @Success 200 {object} models.Response "返回任务结果"
// @Router /api/monkey/v2/task/get_anomalies [get]
func GetMonkeyAnomaliesByTaskId(c *gin.Context) {
rsp := controllers.NewResponse()
var list []models.MonkeyAnomaly
db, err := dbsql.GetConn(dbsql.DSN)
if err != nil {
rsp.Error(err.Error())
c.JSON(http.StatusOK, rsp)
return
}
defer dbsql.Close(db)
db.Where("task_id = ?", c.Query("task_id")).Find(&list)
for i, _ := range list {
list[i].JsonReady()
}
rsp.Success()
rsp.Data = list
c.JSON(http.StatusOK, rsp)
}
func createTbBug(ano models.MonkeyAnomaly) {
db, err := dbsql.GetConn(dbsql.DSN)
if err != nil {
fmt.Println("[createTbBug]", err)
return
}
defer dbsql.Close(db)
var task models.MonkeyTask
db.Model(models.MonkeyTask{}).Where("id = ?", ano.TaskId).Last(&task)
if task.Id < 1 {
fmt.Println("[createTbBug]", "没有找到monkey任务id -", ano.TaskId)
return
}
content := ""
content += "**关联Monkey报告** [点击查看](http://qa.flatincbr.work/#/monkey/result/" + cast.ToString(ano.TaskId) + ")" + "\n\n<br>\n\n"
content += "**上报时间:**" + ano.CreateTime.Format("2006-01-02 15:04:05") + "\n\n<br>\n\n"
content += "**应用版本:**" + task.Version + "\n\n<br>\n\n"
content += "**信息预览:**" + "\n\n"
for _, v := range ano.Anomalies {
for i, vv := range strings.Split(v, "\n") {
content += "> " + vv + "\n"
if i > 10 {
break
}
}
content += "> " + "——————————————————————" + "\n"
}
content += "> " + "(...更多请查看Monkey报告)" + "\n"
content += "\n"
bug := common.NewBug("crushu") //task.Project
bug.SetExecutor("62733beb6918b259138d7577").
SetInvolveMember("62733beb6918b259138d7577").
SetTitle("【Monkey测试】任务id=" + cast.ToString(task.Id) + "发生异常").
SetPlatform(task.Platform).
SetContent(content)
id, err := bug.Create()
if err != nil {
fmt.Println(err)
return
}
fmt.Println("缺陷创建成功:", "https://www.teambition.com/task/"+id)
}

@ -455,7 +455,19 @@ func StopMonkeyTask(c *gin.Context) {
list := GetTaskFromDocker(task_id)
for _, v := range list {
StopDockerContainer(v.Name)
db.Table("device").Model(models.Device{}).Where("udid = ?", v.Device).Update("status", "online")
}
// 重置设备状态
var task models.MonkeyTask
db.Table(task.TableName()).Model(models.MonkeyTask{}).Where("id = ?", task_id).Last(&task)
if strings.Contains(task.Devices, ",") {
// 多台设备
for _, v := range strings.Split(task.Devices, ",") {
db.Table("device").Model(models.Device{}).Where("udid = ?", v).Update("status", "online")
}
} else if len(task.Devices) > 1 {
// 有一台设备
db.Table("device").Model(models.Device{}).Where("udid = ?", task.Devices).Update("status", "online")
}
db.Table("monkey_task").Model(models.MonkeyTask{}).Where("id = ?", task_id).Update("status", "CANCEL")

@ -1,231 +1,255 @@
package main
import (
"autogo/common"
"autogo/dbsql"
"autogo/device"
"autogo/models"
"autogo/monkey"
"fmt"
"net/http"
"os/exec"
"strings"
"time"
"github.com/imroc/req/v3"
)
func main() {
buglyHelper()
return
cmd := exec.Command("docker", "ps")
output, err := cmd.Output()
if err != nil {
fmt.Println(err)
return
}
lines := strings.Split(string(output), "\n")
for i, line := range lines {
if i == 0 {
continue // skip header line
}
fields := strings.Fields(line)
if len(fields) >= 7 {
fmt.Printf("Container ID: %s, Name: %s\n", fields[0], fields[len(fields)-1])
getRuntime(fields[0])
}
}
fmt.Println("end")
}
func buglyHelper() {
var rsp BuglyRsp
url := `https://bugly.qq.com/v2/search?start=0&userSearchPage=%2Fv2%2Fworkbench%2Fapps&pid=2&platformId=2&date=last_7_day&sortOrder=desc&useSearchTimes=2&rows=10&sortField=matchCount&appId=447d39aea1&fsn=f0726b64-a3ac-4e0d-a89d-c9148c82a5e6`
client := req.C().
SetTimeout(5 * time.Second)
resp, err := client.R().
SetCookies(cookies()...).
SetHeader("X-Token", "536325371").
SetHeader("Accept", "application/json;charset=utf-8").
SetHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.75 Safari/537.36").
// SetHeader("Cookie", "ptui_loginuin=188107463; RK=vOtUmiA9WS; ptcz=d265861b48af6f48ea0f924ded6af2b654f74146c1dc4d8632cb48e67edf7484; _ga=GA1.2.1584569153.1684823271; _qpsvr_localtk=0.9318772864960871; token-skey=b9694495-0a28-882a-01f9-d038d9e43bc7; token-lifeTime=1686922095; bugly-session=s:xz-9qL2pRzO3Mz8Wu_I7Svl2SLCWJfLE.MqN7buOfwmbUlRkdLauxXaddtaS3lebknTnCdPQOmtw; referrer=eyJpdiI6IkFcLzJDUTlValNtS0lUaGRFdkg3d2pRPT0iLCJ2YWx1ZSI6Ims4YUp6cUxyZlc0N25hOEJ2QWpZUlZQa2RKc1o3N3RiRHZXVVI1MlJLZ1RrSEtaQ2VmY1BtNEhMUjg4QjJSaExnc05cLzdiaGc2SHFtOTgzdnljMmlxUjd3d0FNZWdZdFwvNjdsT2ZYaG84M21Yd25FV1N0UTJyZTd3TDBId3hiQzNhN1wvS2RTZ1ZvdVFDYStKeEIrcGNnWWs1bno3dHdjTkVWdHIrYmRYTWNUb3Z1UGVvMXdoSE50djJBZ05hZ2pXUiIsIm1hYyI6IjgwNDI0ZjI2MjI0ZDFhMDA3MjBhYjQ4MWIwYjJiZTIzY2U5YjNkZjYyNGFkNTA5NGFjN2U4Y2U3ZTQwMDVlYWQifQ==; bugly_session=eyJpdiI6IjNmQzhJamU1cUlVd08yZHdWMkpTcmc9PSIsInZhbHVlIjoiZ3dFUXZUWmZ6XC8rbTZITG1DRVdrdDUrM1p0RE5nemgzeVhJa2huYWhieVB4SVFRMnlyWFFCU2JCQVpmRHNRQjdubnhhRWVJcUd3OEdzSk1zKzF2WGt3PT0iLCJtYWMiOiIwZjc4MGFmMDk1YzUyZTQ4Zjc5MjcwMDMyNGUzNmMxYjE5MjRlNTQ2MjliMzA3NmQyMGVjODRiZDgyMDU2NGQ1In0=").
SetHeader("Accept", "application/json;charset=utf-8").
SetHeader("Accept-Encoding", "gzip, deflate, br").
SetHeader("Accept-Language", "zh-CN,zh;q=0.9").
SetHeader("Connection", "keep-alive").
SetSuccessResult(&rsp).
// SetResult(&rsp).
Get(url)
if err != nil {
fmt.Println(err)
return
}
if resp.IsErrorState() {
fmt.Println(resp.StatusCode)
return
}
fmt.Println(len(rsp.Ret.IssueList))
}
func cookies() []*http.Cookie {
var cookies []*http.Cookie
var c1 http.Cookie
c1.Name = "bugly-session"
c1.Value = "s:xz-9qL2pRzO3Mz8Wu_I7Svl2SLCWJfLE.MqN7buOfwmbUlRkdLauxXaddtaS3lebknTnCdPQOmtw"
cookies = append(cookies, &c1)
var c3 http.Cookie
c3.Name = "bugly_session"
c3.Value = "eyJpdiI6IlpuTkc5aXcwRHdUR1JGdDhIUmJMbGc9PSIsInZhbHVlIjoiRTZhVmxya3R3Sjl6UzBKQjRLa0EyNXlVV0lVYlNWVnpvVWFrbzVRS0k5am9UK3Y2MHN5czc3XC9JV0ZJNCtBQkdBbW4rZFh5RmFrcWYzODhOanV0OE9BPT0iLCJtYWMiOiI2MmJlYTI2MWE0M2U4NTFlNjJhYzkwZTAyOTQ3MTgxZmYwMTc0ZGJjOGE4MTE0ZjQ1Y2VmN2I5NjJkYTk2ZGY5In0="
cookies = append(cookies, &c3)
return cookies
}
func getRuntime(containerID string) {
// 执行 docker inspect 命令获取容器创建时间
cmd := exec.Command("docker", "inspect", "-f", "{{.Created}}", containerID)
output, err := cmd.Output()
if err != nil {
fmt.Println(err)
return
}
// 将输出结果转换为时间格式
createdTime, err := time.Parse(time.RFC3339Nano, strings.TrimSpace(string(output)))
if err != nil {
fmt.Println(err)
return
}
// 计算容器已经运行的时间
uptime := time.Since(createdTime)
// 将容器运行时间转换为秒级时间戳输出
uptimeInSeconds := int64(uptime.Seconds())
fmt.Printf("Container %s has been running for %d seconds\n", containerID, uptimeInSeconds)
}
func sib() {
if device.CheckSib() {
fmt.Println("sib已安装")
fmt.Println(device.GetIOSDevices())
} else {
fmt.Println("sib未安装")
}
}
func tmp1() {
dbsql.DSN = dbsql.DSN_local
db, err := dbsql.GetConn(dbsql.DSN)
if err != nil {
fmt.Println(err)
return
}
defer dbsql.Close(db)
var task models.MonkeyTask
db.Last(&task)
common.PushMonkeyResult(task)
return
// dbsql.DSN = dbsql.DSN_local
// db, err := dbsql.GetConn(dbsql.DSN)
// if err != nil {
// fmt.Println(err)
// return
// }
// defer dbsql.Close(db)
var list []models.MonkeyTask
db.Model(models.MonkeyTask{}).Order("id DESC").Find(&list)
for _, v := range list {
if v.PackageURL != "" {
app, err := common.GetBranch(v.PackageName, v.PackageURL)
if err != nil {
fmt.Println(v.Id, "-", err, "||", v.PackageURL)
err = nil
} else {
fmt.Println(v.Id, "-", app.Branch)
db.Model(models.MonkeyTask{}).Where("id = ?", v.Id).Update("version", app.Version+"_"+app.VersionCode)
}
}
}
}
func Dir() {
err := monkey.CreateDir("files")
if err != nil {
fmt.Println(err)
}
err = monkey.CreateDir("files/1")
if err != nil {
fmt.Println(err)
}
err = monkey.CreateAndWriteFile("files/1/2.txt", []byte("hidiuniduini"))
if err != nil {
fmt.Println(err)
}
}
type BuglyRsp struct {
Status int `json:"status"`
Msg string `json:"msg"`
Ret struct {
AppID string `json:"appId"`
PlatformID string `json:"platformId"`
IssueList []struct {
IssueID int `json:"issueId"`
IssueHash string `json:"issueHash"`
IssueCount int `json:"issueCount"`
CrashInfo struct {
CrashID string `json:"crashId"`
TagID int `json:"tagId"`
} `json:"crashInfo"`
IssueVersions []struct {
Version string `json:"version"`
Count int `json:"count"`
DeviceCount int `json:"deviceCount"`
} `json:"issueVersions"`
FtName string `json:"ftName"`
IssueDocMap struct {
ID string `json:"id"`
IssueID int `json:"issueId"`
Status int `json:"status"`
Count int `json:"count"`
SysCount int `json:"sysCount"`
ProductVersion string `json:"productVersion"`
DeviceCount int `json:"deviceCount"`
SysDeviceCount int `json:"sysDeviceCount"`
LastUpdateTime string `json:"lastUpdateTime"`
FirstUploadTime string `json:"firstUploadTime"`
LastUploadTime string `json:"lastUploadTime"`
ExpName string `json:"expName"`
ExpFingure string `json:"expFingure"`
IsSystemStack int `json:"isSystemStack"`
KeyStack string `json:"keyStack"`
Type string `json:"type"`
AverageBattery float64 `json:"averageBattery"`
AverageMemory float64 `json:"averageMemory"`
AverageSD float64 `json:"averageSD"`
AverageStorage float64 `json:"averageStorage"`
CrossVersionIssueID int `json:"crossVersionIssueId"`
VersionIssueIds []int `json:"versionIssueIds"`
SubIssueVersions string `json:"subIssueVersions"`
ExpMessage string `json:"expMessage"`
RootCount int `json:"rootCount"`
SysRootCount int `json:"sysRootCount"`
ExpAddr string `json:"expAddr"`
RefSdkAppID string `json:"refSdkAppId"`
RefSdkIssueID string `json:"refSdkIssueId"`
CrashRecordCount int `json:"crashRecordCount"`
} `json:"issueDocMap"`
CrossVersionIssueID int `json:"crossVersionIssueId"`
EsCount int `json:"esCount"`
EsDeviceCount int `json:"esDeviceCount"`
} `json:"issueList"`
NumFound int `json:"numFound"`
CrashNums int `json:"crashNums"`
AnrNums int `json:"anrNums"`
ErrorNums int `json:"errorNums"`
} `json:"ret"`
}
package main
import (
"autogo/common"
"autogo/dbsql"
"autogo/device"
"autogo/models"
"autogo/monkey"
"autogo/test"
"fmt"
"net/http"
"os/exec"
"strings"
"time"
"github.com/imroc/req/v3"
"github.com/spf13/cast"
)
func main() {
test.GetMonkeyResult()
return
db, err := dbsql.GetConn(dbsql.DSN_local)
if err != nil {
return
}
defer dbsql.Close(db)
var list []models.MonkeyTask
db.Model(models.MonkeyTask{}).Where("crash_count > 0 AND is_del = 0").Find(&list)
str := ""
for _, v := range list {
str += "\"" + cast.ToString(v.Id) + "\" "
}
fmt.Println(str)
return
buglyHelper()
return
cmd := exec.Command("docker", "ps")
output, err := cmd.Output()
if err != nil {
fmt.Println(err)
return
}
lines := strings.Split(string(output), "\n")
for i, line := range lines {
if i == 0 {
continue // skip header line
}
fields := strings.Fields(line)
if len(fields) >= 7 {
fmt.Printf("Container ID: %s, Name: %s\n", fields[0], fields[len(fields)-1])
getRuntime(fields[0])
}
}
fmt.Println("end")
}
func buglyHelper() {
var rsp BuglyRsp
url := `https://bugly.qq.com/v2/search?start=0&userSearchPage=%2Fv2%2Fworkbench%2Fapps&pid=2&platformId=2&date=last_7_day&sortOrder=desc&useSearchTimes=3&rows=10&sortField=matchCount&appId=447d39aea1&fsn=8799e426-34c8-4a75-bd0d-1e186509eb5e`
client := req.C().
SetTimeout(5 * time.Second)
resp, err := client.R().
SetCookies(cookies()...).
SetHeader("X-Token", "957369952").
SetHeader("Accept", "application/json;charset=utf-8").
SetHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/62.0.3202.75 Safari/537.36").
// SetHeader("Cookie", "bugly-session=s%3AqQZzQXsgw0wv_lFKAOT88ND_yh_B1f6H.au%2F78LCSHj5zhwqe%2FljmOXGP7TBW3yHnMwypYesrn34;bugly_session=eyJpdiI6InV1R3R0TmZ2S01HTkVBSGpucThXZXc9PSIsInZhbHVlIjoiam1lM3o1cVJISjNyZVJ6U3JJYzhmK1M1UVJiUlhCS1wvRTh6T1d4XC93NDdiY3FITVNJQXRpVFd6Y1BBV1wvZTBhOWR0MHBxNTlRdGNYdExoS2VWK2swckE9PSIsIm1hYyI6IjliMDExNTdmMzgyODFmNTEyYzVmMGQ3MGMxYTdjOTZmMDNjYzVjYzlkYzcxMmVjNmUyMzk4YWE2OTRmNzY4NzAifQ%3D%3D;").
SetHeader("Accept", "application/json;charset=utf-8").
SetHeader("Accept-Encoding", "gzip, deflate, br").
SetHeader("Accept-Language", "zh-CN,zh;q=0.9").
SetHeader("Connection", "keep-alive").
SetSuccessResult(&rsp).
// SetResult(&rsp).
Get(url)
if err != nil {
fmt.Println(err)
return
}
if resp.IsErrorState() {
fmt.Println(resp.StatusCode)
return
}
if len(rsp.Ret.IssueList) > 0 {
fmt.Println(len(rsp.Ret.IssueList))
} else {
fmt.Println(resp.String())
}
}
func cookies() []*http.Cookie {
var cookies []*http.Cookie
// var c1 http.Cookie
// c1.Name = "bugly-session"
// c1.Value = "s:qQZzQXsgw0wv_lFKAOT88ND_yh_B1f6H.au/78LCSHj5zhwqe/ljmOXGP7TBW3yHnMwypYesrn34"
// cookies = append(cookies, &c1)
var c3 http.Cookie
c3.Name = "bugly_session"
c3.Value = "eyJpdiI6InV1R3R0TmZ2S01HTkVBSGpucThXZXc9PSIsInZhbHVlIjoiam1lM3o1cVJISjNyZVJ6U3JJYzhmK1M1UVJiUlhCS1wvRTh6T1d4XC93NDdiY3FITVNJQXRpVFd6Y1BBV1wvZTBhOWR0MHBxNTlRdGNYdExoS2VWK2swckE9PSIsIm1hYyI6IjliMDExNTdmMzgyODFmNTEyYzVmMGQ3MGMxYTdjOTZmMDNjYzVjYzlkYzcxMmVjNmUyMzk4YWE2OTRmNzY4NzAifQ=="
cookies = append(cookies, &c3)
return cookies
}
func getRuntime(containerID string) {
// 执行 docker inspect 命令获取容器创建时间
cmd := exec.Command("docker", "inspect", "-f", "{{.Created}}", containerID)
output, err := cmd.Output()
if err != nil {
fmt.Println(err)
return
}
// 将输出结果转换为时间格式
createdTime, err := time.Parse(time.RFC3339Nano, strings.TrimSpace(string(output)))
if err != nil {
fmt.Println(err)
return
}
// 计算容器已经运行的时间
uptime := time.Since(createdTime)
// 将容器运行时间转换为秒级时间戳输出
uptimeInSeconds := int64(uptime.Seconds())
fmt.Printf("Container %s has been running for %d seconds\n", containerID, uptimeInSeconds)
}
func sib() {
if device.CheckSib() {
fmt.Println("sib已安装")
fmt.Println(device.GetIOSDevices())
} else {
fmt.Println("sib未安装")
}
}
func tmp1() {
dbsql.DSN = dbsql.DSN_local
db, err := dbsql.GetConn(dbsql.DSN)
if err != nil {
fmt.Println(err)
return
}
defer dbsql.Close(db)
var task models.MonkeyTask
db.Last(&task)
common.PushMonkeyResult(task)
return
// dbsql.DSN = dbsql.DSN_local
// db, err := dbsql.GetConn(dbsql.DSN)
// if err != nil {
// fmt.Println(err)
// return
// }
// defer dbsql.Close(db)
var list []models.MonkeyTask
db.Model(models.MonkeyTask{}).Order("id DESC").Find(&list)
for _, v := range list {
if v.PackageURL != "" {
app, err := common.GetBranch(v.PackageName, v.PackageURL)
if err != nil {
fmt.Println(v.Id, "-", err, "||", v.PackageURL)
err = nil
} else {
fmt.Println(v.Id, "-", app.Branch)
db.Model(models.MonkeyTask{}).Where("id = ?", v.Id).Update("version", app.Version+"_"+app.VersionCode)
}
}
}
}
func Dir() {
err := monkey.CreateDir("files")
if err != nil {
fmt.Println(err)
}
err = monkey.CreateDir("files/1")
if err != nil {
fmt.Println(err)
}
err = monkey.CreateAndWriteFile("files/1/2.txt", []byte("hidiuniduini"))
if err != nil {
fmt.Println(err)
}
}
type BuglyRsp struct {
Status int `json:"status"`
Msg string `json:"msg"`
Ret struct {
AppID string `json:"appId"`
PlatformID string `json:"platformId"`
IssueList []struct {
IssueID int `json:"issueId"`
IssueHash string `json:"issueHash"`
IssueCount int `json:"issueCount"`
CrashInfo struct {
CrashID string `json:"crashId"`
TagID int `json:"tagId"`
} `json:"crashInfo"`
IssueVersions []struct {
Version string `json:"version"`
Count int `json:"count"`
DeviceCount int `json:"deviceCount"`
} `json:"issueVersions"`
FtName string `json:"ftName"`
IssueDocMap struct {
ID string `json:"id"`
IssueID int `json:"issueId"`
Status int `json:"status"`
Count int `json:"count"`
SysCount int `json:"sysCount"`
ProductVersion string `json:"productVersion"`
DeviceCount int `json:"deviceCount"`
SysDeviceCount int `json:"sysDeviceCount"`
LastUpdateTime string `json:"lastUpdateTime"`
FirstUploadTime string `json:"firstUploadTime"`
LastUploadTime string `json:"lastUploadTime"`
ExpName string `json:"expName"`
ExpFingure string `json:"expFingure"`
IsSystemStack int `json:"isSystemStack"`
KeyStack string `json:"keyStack"`
Type string `json:"type"`
AverageBattery float64 `json:"averageBattery"`
AverageMemory float64 `json:"averageMemory"`
AverageSD float64 `json:"averageSD"`
AverageStorage float64 `json:"averageStorage"`
CrossVersionIssueID int `json:"crossVersionIssueId"`
VersionIssueIds []int `json:"versionIssueIds"`
SubIssueVersions string `json:"subIssueVersions"`
ExpMessage string `json:"expMessage"`
RootCount int `json:"rootCount"`
SysRootCount int `json:"sysRootCount"`
ExpAddr string `json:"expAddr"`
RefSdkAppID string `json:"refSdkAppId"`
RefSdkIssueID string `json:"refSdkIssueId"`
CrashRecordCount int `json:"crashRecordCount"`
} `json:"issueDocMap"`
CrossVersionIssueID int `json:"crossVersionIssueId"`
EsCount int `json:"esCount"`
EsDeviceCount int `json:"esDeviceCount"`
} `json:"issueList"`
NumFound int `json:"numFound"`
CrashNums int `json:"crashNums"`
AnrNums int `json:"anrNums"`
ErrorNums int `json:"errorNums"`
} `json:"ret"`
}

@ -0,0 +1,71 @@
package test
import (
"autogo/common"
"autogo/dbsql"
"autogo/models"
"encoding/json"
"fmt"
"strings"
"github.com/spf13/cast"
)
func GetMonkeyResult() {
var res models.MonkeyResult
dbsql.SetDSN("Flatincbr.com")
db, err := dbsql.GetConn(dbsql.DSN_local)
if err != nil {
fmt.Println(err)
return
}
defer dbsql.Close(db)
db.Model(models.MonkeyResult{}).Last(&res)
var strs []string
json.Unmarshal([]byte(res.CrashLogs), &strs)
if len(strs) > 0 {
res.CrashLogList = strs
}
json.Unmarshal([]byte(res.ActivityNameInfo), &strs)
if len(strs) > 0 {
res.ActivityList = strs
}
json.Unmarshal([]byte(res.Logs), &strs)
if len(strs) > 0 {
res.LogList = strs
}
var task models.MonkeyTask
db.Table(task.TableName()).Model(models.MonkeyTask{}).Where("id = ?", res.TaskId).Last(&task)
// buf, _ := json.Marshal(res)
content := ""
content += "**关联Monkey报告** [点击查看](http://qa.flatincbr.work/#/monkey/result/" + cast.ToString(res.TaskId) + ")" + "\n\n<br>\n\n"
content += "**上报时间:**" + res.CreateTime.Format("2006-01-02 15:04:05") + "\n\n<br>\n\n"
content += "**应用版本:**" + task.Version + "\n\n<br>\n\n"
content += "**信息预览:**" + "\n\n"
for i, v := range strings.Split(res.CrashLogList[0], "\n") {
content += "> " + v + "\n"
if i > 10 {
break
}
}
content += "> " + "(...更多请查看Monkey报告)" + "\n"
content += "\n"
// fmt.Println(content)
bug := common.NewBug("crushu")
bug.SetExecutor("62733beb6918b259138d7577").
SetInvolveMember("62733beb6918b259138d7577").
SetTitle("【Monkey测试】测试缺陷标题byProjectName").
SetPlatform("adr").
SetContent(content)
id, err := bug.Create()
if err != nil {
fmt.Println(err)
return
}
fmt.Println("缺陷创建成功:", "https://www.teambition.com/task/"+id)
}
Loading…
Cancel
Save