SQuiz/common
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add amo repo method

Browse Source
This commit is contained in:
Pavel 2024-05-06 20:43:50 +03:00
parent ff72e7b041
commit 3d390409ec
2 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dal/db_query/queries.sql
View File

@ -1030,4 +1030,4 @@ WHERE t.AccessToken = $4;
-- name: UpdatingDealAmoStatus :exec -- name: UpdatingDealAmoStatus :exec
UPDATE amoCRMStatuses SET Status = $1 UPDATE amoCRMStatuses SET Status = $1
WHERE AnswerID = $2 AND AmoID = (SELECT u.AmoID FROM tokens AS t JOIN users AS u ON t.AccountID = u.AccountID WHERE t.AccessToken = $3); WHERE AnswerID = $2 AND DealID = $4 AND AmoID = (SELECT u.AmoID FROM tokens AS t JOIN users AS u ON t.AccountID = u.AccountID WHERE t.AccessToken = $3);

20
repository/amo/amo.go
View File

@ -874,15 +874,15 @@ func (r *AmoRepository) GettingAmoUsersTrueResults(ctx context.Context) ([]model
return results, nil return results, nil
} }
type SaveDealDeps struct { type SaveDealAmoDeps struct {
DealID int32 DealID int32
AnswerID int64 AnswerID int64
Status string Status string
AccessToken string AccessToken string
} }
func (r *AmoRepository) SaveDealStatus(ctx context.Context, deps SaveDealDeps) error { func (r *AmoRepository) SaveDealAmoStatus(ctx context.Context, deps SaveDealAmoDeps) error {
err := r.queries.SettingDealStatus(ctx, sqlcgen.SettingDealStatusParams{ err := r.queries.SettingDealAmoStatus(ctx, sqlcgen.SettingDealAmoStatusParams{
Dealid: deps.DealID, Dealid: deps.DealID,
Answerid: deps.AnswerID, Answerid: deps.AnswerID,
Status: deps.Status, Status: deps.Status,
@ -895,3 +895,17 @@ func (r *AmoRepository) SaveDealStatus(ctx context.Context, deps SaveDealDeps) e
return nil return nil
} }
func (r *AmoRepository) UpdatingDealAmoStatus(ctx context.Context, deps SaveDealAmoDeps) error {
err := r.queries.UpdatingDealAmoStatus(ctx, sqlcgen.UpdatingDealAmoStatusParams{
Status: deps.Status,
Answerid: deps.AnswerID,
Accesstoken: deps.AccessToken,
})
if err != nil {
return err
}
return nil
}