diff --git a/app/task/svc/svc_hc_recharge_goods.go b/app/task/svc/svc_hc_recharge_goods.go index 847c5f6..78ac2e2 100644 --- a/app/task/svc/svc_hc_recharge_goods.go +++ b/app/task/svc/svc_hc_recharge_goods.go @@ -3,12 +3,17 @@ package svc import ( "applet/app/db" "applet/app/db/model" + offical "applet/app/db/official" "applet/app/utils" "code.fnuoos.com/go_rely_warehouse/zyos_go_third_party_api.git/hc_card" "time" ) func HcRechargeGoods() { + hcType := offical.SysCfgByKeyStr("hc_type") + if hcType != "1" { + return + } param := map[string]string{} list := hc_card.HcRechargeList(param) for _, v := range list { @@ -30,7 +35,7 @@ func HcRechargeGoods() { IsDelete: 0, } var data model.HcCardCate - db.ZhimengDb.Where("g_id=? and type=?", tmp.GId, tmp.Type).Get(&data) + db.Db.Where("g_id=? and type=?", tmp.GId, tmp.Type).Get(&data) id := 0 if data.Id > 0 { id = data.Id @@ -41,9 +46,9 @@ func HcRechargeGoods() { data.GId = v.GId data.AccountType = v.AccountType data.IsDelete = 0 - db.ZhimengDb.Where("id=?", data.Id).Update(&data) + db.Db.Where("id=?", data.Id).Update(&data) } else { - db.ZhimengDb.InsertOne(&tmp) + db.Db.InsertOne(&tmp) id = tmp.Id } ids := []int{-1} @@ -62,7 +67,7 @@ func HcRechargeGoods() { IsDelete: 0, } var specData model.HcCardList - db.ZhimengDb.Where("l_id=? and spec_id=?", id, v1.SpecId).Get(&specData) + db.Db.Where("l_id=? and spec_id=?", id, v1.SpecId).Get(&specData) if specData.Id > 0 { specData.UpdateTime = int(time.Now().Unix()) specData.GId = v.GId @@ -73,23 +78,27 @@ func HcRechargeGoods() { specData.SpecId = v1.SpecId specData.SpecImg = v1.SpecImg specData.IsDelete = 0 - db.ZhimengDb.Where("id=?", data.Id).Update(&specData) + db.Db.Where("id=?", data.Id).Update(&specData) } else { - db.ZhimengDb.InsertOne(&specTmp) + db.Db.InsertOne(&specTmp) } ids = append(ids, v1.SpecId) } if len(ids) > 0 { - db.ZhimengDb.NotIn("spec_id", ids).And("l_id=?", id).Cols("is_delete").Update(&model.HcCardList{IsDelete: 1}) + db.Db.NotIn("spec_id", ids).And("l_id=?", id).Cols("is_delete").Update(&model.HcCardList{IsDelete: 1}) } } if len(list) > 0 { - db.ZhimengDb.Where("type=? and update_time 0 { id = data.Id @@ -120,9 +129,9 @@ func HcTicketGoods() { data.GoodsLogo = v.GoodsLogo data.GId = v.GId data.IsDelete = 0 - db.ZhimengDb.Where("id=?", data.Id).Update(&data) + db.Db.Where("id=?", data.Id).Update(&data) } else { - db.ZhimengDb.InsertOne(&tmp) + db.Db.InsertOne(&tmp) id = tmp.Id } ids := []int{-1} @@ -140,7 +149,7 @@ func HcTicketGoods() { IsDelete: 0, } var specData model.HcCardList - db.ZhimengDb.Where("l_id=? and spec_id=?", id, v1.SpecId).Get(&specData) + db.Db.Where("l_id=? and spec_id=?", id, v1.SpecId).Get(&specData) if specData.Id > 0 { specData.UpdateTime = int(time.Now().Unix()) specData.GId = v.GId @@ -150,19 +159,19 @@ func HcTicketGoods() { specData.SpecId = v1.SpecId specData.SpecImg = v1.SpecImg specData.IsDelete = 0 - db.ZhimengDb.Where("id=?", data.Id).Update(&specData) + db.Db.Where("id=?", data.Id).Update(&specData) } else { - db.ZhimengDb.InsertOne(&specTmp) + db.Db.InsertOne(&specTmp) } ids = append(ids, v1.SpecId) } if len(ids) > 0 { - db.ZhimengDb.NotIn("spec_id", ids).And("l_id=?", id).Cols("is_delete").Update(&model.HcCardList{IsDelete: 1}) + db.Db.NotIn("spec_id", ids).And("l_id=?", id).Cols("is_delete").Update(&model.HcCardList{IsDelete: 1}) } } if len(list) > 0 { - db.ZhimengDb.Where("type=? and update_time