add publickey

cachedata/cache_test.go

@@ -15,15 +15,15 @@ func newCache() *CacheData {
 		return _cache
 	}
 	_cache = NewCacheData(context.Background(), RedisConnParam{
-		Addr:     "192.168.1.10:6379",
-		Password: "",
+		Addr:     "43.198.252.255:6379",
+		Password: "iH0g2CqzjI6SfercGwsT",
 		DbIndex:  0,
 	}, model.DbConfig{
-		Host:   "192.168.1.211",
+		Host:   "43.198.252.255",
 		Port:   3306,
-		DbName: "liuxuzhong",
-		Passwd: "12345678",
-		User:   "root",
+		DbName: "ai",
+		Passwd: "RFnnKHRar5xk7TEF",
+		User:   "ai",
 	})
 	return _cache
 }
@@ -31,8 +31,8 @@ func newCache() *CacheData {
 func TestCacheData_Query(t *testing.T) {
 	cache := newCache()
 
-	testPath := "/start/docker"
-	testUid := int64(19)
+	testPath := "/txt2Img/demianhjw/aigic"
+	testUid := int64(23)
 
 	task, err := cache.Query(testPath, testUid)
 	if err != nil {

cachedata/payment.go

@@ -291,7 +291,7 @@ func (c *CacheData) costForFee(uid int64, fee int64) error {
 	}
 	if fee < 0 {
 		txp := c.rdb.TxPipeline()
-		txp.DecrBy(c.ctx, chargeKey, fee)
+		txp.DecrBy(c.ctx, chargeKey, -fee)
 		_, err := txp.Exec(c.ctx)
 		return err
 	}

model/taskType.go

@@ -10,6 +10,7 @@ type TaskType struct {
 	Desc            string    `orm:"column(desc)" db:"desc" json:"desc" form:"desc"`     //  任务类型描述
 	Price           int64     `orm:"column(price)" db:"price" json:"price" form:"price"` //  该任务类型的费用
 	Complexity      int64     `orm:"column(complexity)" db:"complexity" json:"complexity" form:"complexity"`
+	PublicKey       string    `orm:"column(public_key)" db:"public_key" json:"public_key" form:"public_key"`
 	HardwareRequire string    `orm:"column(hardware_require)" db:"hardware_require" json:"hardware_require" form:"hardware_require"`
 	ImageId         string    `orm:"column(image_id)" db:"image_id" json:"image_id" form:"image_id"`
 	ImageUrl        string    `orm:"column(image_url)" db:"image_url" json:"image_url" form:"image_url"`