allied-creation / allied-creation-cooperation · 提交

转到一个项目

作者 陈志颖
提交 975aa0967c464838b2680a8668996cfd904dc507 1 个父辈 d27708da

fix:关联组织机构数据查询修复

内嵌 并排对比
正在显示 29 个修改的文件 包含 32 行增加 和 26 行删除
@@ -14,7 +14,7 @@ type SearchContractUndertakerFeedbackQuery struct { @@ -14,7 +14,7 @@ type SearchContractUndertakerFeedbackQuery struct {
14 // 组织机构ID 14 // 组织机构ID
15 OrgId int64 `cname:"组织机构ID" json:"orgId"` 15 OrgId int64 `cname:"组织机构ID" json:"orgId"`
16 // 关联的组织机构ID列表 16 // 关联的组织机构ID列表
17 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 17 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
18 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 18 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
19 UserId int64 `cname:"用户ID" json:"userId"` 19 UserId int64 `cname:"用户ID" json:"userId"`
20 // 用户基础数据id 20 // 用户基础数据id
@@ -26,7 +26,7 @@ type SearchCooperationApplicationQuery struct { @@ -26,7 +26,7 @@ type SearchCooperationApplicationQuery struct {
26 // 组织机构ID 26 // 组织机构ID
27 OrgId int64 `cname:"组织机构ID" json:"orgId"` 27 OrgId int64 `cname:"组织机构ID" json:"orgId"`
28 // 关联的组织机构ID列表 28 // 关联的组织机构ID列表
29 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 29 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
30 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 30 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
31 UserId int64 `cname:"用户ID" json:"userId"` 31 UserId int64 `cname:"用户ID" json:"userId"`
32 // 用户基础数据id 32 // 用户基础数据id
@@ -21,6 +21,8 @@ type SearchCooperationContractQuery struct { @@ -21,6 +21,8 @@ type SearchCooperationContractQuery struct {
21 CompanyId int64 `cname:"公司ID" json:"companyId"` 21 CompanyId int64 `cname:"公司ID" json:"companyId"`
22 // 组织机构ID 22 // 组织机构ID
23 OrgId int64 `cname:"组织机构ID" json:"orgId"` 23 OrgId int64 `cname:"组织机构ID" json:"orgId"`
  24 + // 关联的组织机构ID列表
  25 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
24 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
25 UserId int64 `cname:"用户ID" json:"userId"` 27 UserId int64 `cname:"用户ID" json:"userId"`
26 // 用户基础数据id 28 // 用户基础数据id
@@ -21,6 +21,8 @@ type SearchCooperationContractByUndertakerQuery struct { @@ -21,6 +21,8 @@ type SearchCooperationContractByUndertakerQuery struct {
21 CompanyId int64 `cname:"公司ID" json:"companyId"` 21 CompanyId int64 `cname:"公司ID" json:"companyId"`
22 // 组织机构ID 22 // 组织机构ID
23 OrgId int64 `cname:"组织机构ID" json:"orgId"` 23 OrgId int64 `cname:"组织机构ID" json:"orgId"`
  24 + // 关联的组织机构ID列表
  25 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
24 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
25 UserId int64 `cname:"用户ID" json:"userId"` 27 UserId int64 `cname:"用户ID" json:"userId"`
26 // 用户基础数据id 28 // 用户基础数据id
@@ -22,7 +22,7 @@ type SearchCooperationContractChangeLogQuery struct { @@ -22,7 +22,7 @@ type SearchCooperationContractChangeLogQuery struct {
22 // 组织机构ID 22 // 组织机构ID
23 OrgId int64 `cname:"组织机构ID" json:"orgId"` 23 OrgId int64 `cname:"组织机构ID" json:"orgId"`
24 // 关联的组织机构ID列表 24 // 关联的组织机构ID列表
25 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 25 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
27 UserId int64 `cname:"用户ID" json:"userId"` 27 UserId int64 `cname:"用户ID" json:"userId"`
28 // 用户基础数据id 28 // 用户基础数据id
@@ -22,7 +22,7 @@ type SearchCooperationModeQuery struct { @@ -22,7 +22,7 @@ type SearchCooperationModeQuery struct {
22 // 组织机构ID 22 // 组织机构ID
23 OrgId int64 `cname:"组织机构ID" json:"orgId"` 23 OrgId int64 `cname:"组织机构ID" json:"orgId"`
24 // 关联的组织机构ID列表 24 // 关联的组织机构ID列表
25 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 25 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
27 UserId int64 `cname:"用户ID" json:"userId"` 27 UserId int64 `cname:"用户ID" json:"userId"`
28 // 用户基础数据id 28 // 用户基础数据id
@@ -24,7 +24,7 @@ type SearchCooperationProjectQuery struct { @@ -24,7 +24,7 @@ type SearchCooperationProjectQuery struct {
24 // 组织机构ID 24 // 组织机构ID
25 OrgId int64 `cname:"组织机构ID" json:"orgId"` 25 OrgId int64 `cname:"组织机构ID" json:"orgId"`
26 // 关联的组织机构ID列表 26 // 关联的组织机构ID列表
27 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 27 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
28 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 28 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
29 UserId int64 `cname:"用户ID" json:"userId"` 29 UserId int64 `cname:"用户ID" json:"userId"`
30 // 用户基础数据id 30 // 用户基础数据id
@@ -27,7 +27,7 @@ type SearchCreditAccountQuery struct { @@ -27,7 +27,7 @@ type SearchCreditAccountQuery struct {
27 // 组织机构ID 27 // 组织机构ID
28 OrgId int64 `cname:"组织机构ID" json:"orgId"` 28 OrgId int64 `cname:"组织机构ID" json:"orgId"`
29 // 关联的组织机构ID列表 29 // 关联的组织机构ID列表
30 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 30 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
31 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 31 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
32 UserId int64 `cname:"用户ID" json:"userId"` 32 UserId int64 `cname:"用户ID" json:"userId"`
33 // 用户基础数据id 33 // 用户基础数据id
@@ -19,7 +19,7 @@ type SearchDividendsEstimateQuery struct { @@ -19,7 +19,7 @@ type SearchDividendsEstimateQuery struct {
19 // 组织机构ID 19 // 组织机构ID
20 OrgId int64 `cname:"组织机构ID" json:"orgId"` 20 OrgId int64 `cname:"组织机构ID" json:"orgId"`
21 // 关联的组织机构ID列表 21 // 关联的组织机构ID列表
22 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 22 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
23 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 23 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
24 UserId int64 `cname:"用户ID" json:"userId"` 24 UserId int64 `cname:"用户ID" json:"userId"`
25 // 用户基础数据id 25 // 用户基础数据id
@@ -19,7 +19,7 @@ type SearchDividendsIncentivesEstimateQuery struct { @@ -19,7 +19,7 @@ type SearchDividendsIncentivesEstimateQuery struct {
19 // 组织机构ID 19 // 组织机构ID
20 OrgId int64 `cname:"组织机构ID" json:"orgId"` 20 OrgId int64 `cname:"组织机构ID" json:"orgId"`
21 // 关联的组织机构ID列表 21 // 关联的组织机构ID列表
22 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 22 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
23 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 23 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
24 UserId int64 `cname:"用户ID" json:"userId"` 24 UserId int64 `cname:"用户ID" json:"userId"`
25 // 用户基础数据id 25 // 用户基础数据id
@@ -19,7 +19,7 @@ type SearchMoneyIncentivesEstimateQuery struct { @@ -19,7 +19,7 @@ type SearchMoneyIncentivesEstimateQuery struct {
19 // 组织机构ID 19 // 组织机构ID
20 OrgId int64 `cname:"组织机构ID" json:"orgId"` 20 OrgId int64 `cname:"组织机构ID" json:"orgId"`
21 // 关联的组织机构ID列表 21 // 关联的组织机构ID列表
22 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 22 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
23 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 23 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
24 UserId int64 `cname:"用户ID" json:"userId"` 24 UserId int64 `cname:"用户ID" json:"userId"`
25 // 用户基础数据id 25 // 用户基础数据id
@@ -22,7 +22,7 @@ type SearchDividendsOrderQuery struct { @@ -22,7 +22,7 @@ type SearchDividendsOrderQuery struct {
22 // 组织机构ID 22 // 组织机构ID
23 OrgId int64 `cname:"组织机构ID" json:"orgId"` 23 OrgId int64 `cname:"组织机构ID" json:"orgId"`
24 // 关联的组织机构ID列表 24 // 关联的组织机构ID列表
25 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 25 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
27 UserId int64 `cname:"用户ID" json:"userId"` 27 UserId int64 `cname:"用户ID" json:"userId"`
28 // 用户基础数据id 28 // 用户基础数据id
@@ -16,7 +16,7 @@ type SearchDividendsOrderNumberQuery struct { @@ -16,7 +16,7 @@ type SearchDividendsOrderNumberQuery struct {
16 // 组织机构ID 16 // 组织机构ID
17 OrgId int64 `cname:"组织机构ID" json:"orgId"` 17 OrgId int64 `cname:"组织机构ID" json:"orgId"`
18 // 关联的组织机构ID列表 18 // 关联的组织机构ID列表
19 - OrgIds []int64 `cname:"关联的组织机构ID列表" json:"orgIds"` 19 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
20 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 20 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
21 UserId int64 `cname:"用户ID" json:"userId"` 21 UserId int64 `cname:"用户ID" json:"userId"`
22 // 用户基础数据id 22 // 用户基础数据id
@@ -19,6 +19,8 @@ type SearchDividendsReturnedOrderQuery struct { @@ -19,6 +19,8 @@ type SearchDividendsReturnedOrderQuery struct {
19 PageNumber int64 `cname:"页码" json:"pageNumber,omitempty"` 19 PageNumber int64 `cname:"页码" json:"pageNumber,omitempty"`
20 // 公司ID，通过集成REST上下文获取 20 // 公司ID，通过集成REST上下文获取
21 CompanyId int64 `cname:"公司ID" json:"companyId"` 21 CompanyId int64 `cname:"公司ID" json:"companyId"`
  22 + // 关联的组织机构ID列表
  23 + OrgIds []string `cname:"关联的组织机构ID列表" json:"orgIds"`
22 // 组织机构ID 24 // 组织机构ID
23 OrgId int64 `cname:"组织机构ID" json:"orgId"` 25 OrgId int64 `cname:"组织机构ID" json:"orgId"`
24 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员 26 // 用户ID，通过集成REST上下文获取，可翻译成发起人、承接人、推荐人、业务员
@@ -162,7 +162,7 @@ func (repository *ContractUndertakerFeedbackRepository) Find(queryOptions map[st @@ -162,7 +162,7 @@ func (repository *ContractUndertakerFeedbackRepository) Find(queryOptions map[st
162 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 162 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
163 query.Where("org->>'orgId' = '?'", orgId) 163 query.Where("org->>'orgId' = '?'", orgId)
164 } 164 }
165 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 165 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
166 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 166 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
167 } 167 }
168 // 搜索内容包括项目合约名称、承接人姓名、承接内容关键字 168 // 搜索内容包括项目合约名称、承接人姓名、承接内容关键字
@@ -243,7 +243,7 @@ func (repository *CooperationApplicationRepository) Find(queryOptions map[string @@ -243,7 +243,7 @@ func (repository *CooperationApplicationRepository) Find(queryOptions map[string
243 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 243 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
244 query.Where("org->>'orgId' = '?'", orgId) 244 query.Where("org->>'orgId' = '?'", orgId)
245 } 245 }
246 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 246 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
247 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 247 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
248 } 248 }
249 offsetLimitFlag := true 249 offsetLimitFlag := true
@@ -171,7 +171,7 @@ func (repository *CooperationContractChangeLogRepository) Find(queryOptions map[ @@ -171,7 +171,7 @@ func (repository *CooperationContractChangeLogRepository) Find(queryOptions map[
171 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 171 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
172 query.Where("org->>'orgId' = '?'", orgId) 172 query.Where("org->>'orgId' = '?'", orgId)
173 } 173 }
174 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 174 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
175 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 175 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
176 } 176 }
177 if offsetLimitFlag { 177 if offsetLimitFlag {
@@ -176,7 +176,7 @@ func (repository *CooperationContractRelevantRepository) Find(queryOptions map[s @@ -176,7 +176,7 @@ func (repository *CooperationContractRelevantRepository) Find(queryOptions map[s
176 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 176 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
177 query.Where("org->>'orgId' = '?'", orgId) 177 query.Where("org->>'orgId' = '?'", orgId)
178 } 178 }
179 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 179 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
180 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 180 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
181 } 181 }
182 if userBaseId, ok := queryOptions["userBaseId"]; ok && userBaseId.(int64) != 0 { 182 if userBaseId, ok := queryOptions["userBaseId"]; ok && userBaseId.(int64) != 0 {
@@ -995,7 +995,7 @@ func (repository *CooperationContractRepository) Find(queryOptions map[string]in @@ -995,7 +995,7 @@ func (repository *CooperationContractRepository) Find(queryOptions map[string]in
995 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 995 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
996 query.Where("org->>'orgId' = '?'", orgId) 996 query.Where("org->>'orgId' = '?'", orgId)
997 } 997 }
998 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 998 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
999 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 999 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
1000 } 1000 }
1001 if incentivesType, ok := queryOptions["incentivesType"]; ok && incentivesType.(int32) != 0 { 1001 if incentivesType, ok := queryOptions["incentivesType"]; ok && incentivesType.(int32) != 0 {
@@ -187,7 +187,7 @@ func (repository *CooperationContractUndertakerRepository) Find(queryOptions map @@ -187,7 +187,7 @@ func (repository *CooperationContractUndertakerRepository) Find(queryOptions map
187 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 187 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
188 query.Where("org->>'orgId' = '?'", orgId) 188 query.Where("org->>'orgId' = '?'", orgId)
189 } 189 }
190 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 190 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
191 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 191 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
192 } 192 }
193 if userBaseId, ok := queryOptions["userBaseId"]; ok && userBaseId.(int64) != 0 { 193 if userBaseId, ok := queryOptions["userBaseId"]; ok && userBaseId.(int64) != 0 {
@@ -187,7 +187,7 @@ func (repository *CooperationModeRepository) Find(queryOptions map[string]interf @@ -187,7 +187,7 @@ func (repository *CooperationModeRepository) Find(queryOptions map[string]interf
187 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 187 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
188 query.Where("org->>'orgId' = '?'", orgId) 188 query.Where("org->>'orgId' = '?'", orgId)
189 } 189 }
190 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 190 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
191 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 191 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
192 } 192 }
193 offsetLimitFlag := true 193 offsetLimitFlag := true
@@ -249,7 +249,7 @@ func (repository *CooperationProjectRepository) Find(queryOptions map[string]int @@ -249,7 +249,7 @@ func (repository *CooperationProjectRepository) Find(queryOptions map[string]int
249 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 249 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
250 query.Where("org->>'orgId' = '?'", orgId) 250 query.Where("org->>'orgId' = '?'", orgId)
251 } 251 }
252 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 252 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
253 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 253 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
254 } 254 }
255 if v, ok := queryOptions["status"]; ok && v.(int32) > 0 { 255 if v, ok := queryOptions["status"]; ok && v.(int32) > 0 {
@@ -218,7 +218,7 @@ func (repository *CreditAccountRepository) Find(queryOptions map[string]interfac @@ -218,7 +218,7 @@ func (repository *CreditAccountRepository) Find(queryOptions map[string]interfac
218 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 218 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
219 query.Where("org->>'orgId' = '?'", orgId) 219 query.Where("org->>'orgId' = '?'", orgId)
220 } 220 }
221 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 221 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
222 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 222 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
223 } 223 }
224 offsetLimitFlag := true 224 offsetLimitFlag := true
@@ -301,7 +301,7 @@ func (repository *DividendsEstimateRepository) Find(queryOptions map[string]inte @@ -301,7 +301,7 @@ func (repository *DividendsEstimateRepository) Find(queryOptions map[string]inte
301 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 301 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
302 query.Where("org->>'orgId' = '?'", orgId) 302 query.Where("org->>'orgId' = '?'", orgId)
303 } 303 }
304 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 304 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
305 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 305 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
306 } 306 }
307 offsetLimitFlag := true 307 offsetLimitFlag := true
@@ -171,7 +171,7 @@ func (repository *DividendsIncentivesRuleRepository) Find(queryOptions map[strin @@ -171,7 +171,7 @@ func (repository *DividendsIncentivesRuleRepository) Find(queryOptions map[strin
171 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 171 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
172 query.Where("org->>'orgId' = '?'", orgId) 172 query.Where("org->>'orgId' = '?'", orgId)
173 } 173 }
174 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 174 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
175 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 175 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
176 } 176 }
177 offsetLimitFlag := true 177 offsetLimitFlag := true
@@ -413,7 +413,7 @@ func (repository *DividendsOrderRepository) Find(queryOptions map[string]interfa @@ -413,7 +413,7 @@ func (repository *DividendsOrderRepository) Find(queryOptions map[string]interfa
413 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 413 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
414 query.Where("org->>'orgId' = '?'", orgId) 414 query.Where("org->>'orgId' = '?'", orgId)
415 } 415 }
416 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 416 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
417 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 417 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
418 } 418 }
419 offsetLimitFlag := true 419 offsetLimitFlag := true
@@ -415,7 +415,7 @@ func (repository *DividendsReturnedOrderRepository) Find(queryOptions map[string @@ -415,7 +415,7 @@ func (repository *DividendsReturnedOrderRepository) Find(queryOptions map[string
415 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 415 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
416 query.Where("org->>'orgId' = '?'", orgId) 416 query.Where("org->>'orgId' = '?'", orgId)
417 } 417 }
418 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 418 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
419 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 419 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
420 } 420 }
421 offsetLimitFlag := true 421 offsetLimitFlag := true
@@ -171,7 +171,7 @@ func (repository *MoneyIncentivesRuleRepository) Find(queryOptions map[string]in @@ -171,7 +171,7 @@ func (repository *MoneyIncentivesRuleRepository) Find(queryOptions map[string]in
171 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 171 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
172 query.Where("org->>'orgId' = '?'", orgId) 172 query.Where("org->>'orgId' = '?'", orgId)
173 } 173 }
174 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 174 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
175 query.Where("org->>'orgId' in (?)", pg.In(orgIds)) 175 query.Where("org->>'orgId' in (?)", pg.In(orgIds))
176 } 176 }
177 offsetLimitFlag := true 177 offsetLimitFlag := true
@@ -184,7 +184,7 @@ func (repository *OrderGoodRepository) Find(queryOptions map[string]interface{}) @@ -184,7 +184,7 @@ func (repository *OrderGoodRepository) Find(queryOptions map[string]interface{})
184 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 { 184 if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
185 query.Where("org_id = '?'", orgId) 185 query.Where("org_id = '?'", orgId)
186 } 186 }
187 - if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]int64)) > 0 { 187 + if orgIds, ok := queryOptions["orgIds"]; ok && len(orgIds.([]string)) > 0 {
188 query.Where("org_id in (?)", pg.In(orgIds)) 188 query.Where("org_id in (?)", pg.In(orgIds))
189 } 189 }
190 offsetLimitFlag := true 190 offsetLimitFlag := true