Compare commits
4 Commits
sql_query_
...
zip-code-t
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
52656e0420 | ||
|
|
c6606a98dd | ||
|
|
2e5444bed8 | ||
|
|
4852a5586c |
@@ -149,3 +149,23 @@ func (s *userService) GetContactType() (retVal []viewmodel.ContactType, err erro
|
|||||||
|
|
||||||
return s.mapEntity.User.ToContactTypeModelSlice(entity), nil
|
return s.mapEntity.User.ToContactTypeModelSlice(entity), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *userService) SaveContact(contact viewmodel.Contact) (retVal viewmodel.Contact, err error) {
|
||||||
|
entity := s.mapEntity.User.ToContactEntity(contact)
|
||||||
|
entity, err = s.svc.Users.SaveContact(entity)
|
||||||
|
if err != nil {
|
||||||
|
return retVal, errors.Wrap(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return s.mapEntity.User.ToContactModel(entity), err
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *userService) RemoveContact(contact viewmodel.Contact) (retVal viewmodel.Contact, err error) {
|
||||||
|
entity := s.mapEntity.User.ToContactEntity(contact)
|
||||||
|
entity, err = s.svc.Users.RemoveContact(entity)
|
||||||
|
if err != nil {
|
||||||
|
return retVal, errors.Wrap(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return s.mapEntity.User.ToContactModel(entity), err
|
||||||
|
}
|
||||||
|
|||||||
@@ -158,8 +158,11 @@ func (mapping *userMapping) ToContactTypeModelSlice(list []entity.ContactType) (
|
|||||||
// ToContactModel maps a Contact entity to Contact view model
|
// ToContactModel maps a Contact entity to Contact view model
|
||||||
func (mapping *userMapping) ToContactModel(item entity.ContactInfo) viewmodel.Contact {
|
func (mapping *userMapping) ToContactModel(item entity.ContactInfo) viewmodel.Contact {
|
||||||
return viewmodel.Contact{
|
return viewmodel.Contact{
|
||||||
Type: mapping.ToContactTypeModel(item.Type),
|
ID: item.UUID,
|
||||||
Value: item.Value,
|
User: mapping.ToUserModel(item.User),
|
||||||
|
Author: mapping.ToUserModel(item.Author),
|
||||||
|
Type: mapping.ToContactTypeModel(item.Type),
|
||||||
|
Value: item.Value,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -177,8 +180,11 @@ func (mapping *userMapping) ToContactModelSlice(list []entity.ContactInfo) (retV
|
|||||||
// ToContactEntity maps a Contact entity to Contact view model
|
// ToContactEntity maps a Contact entity to Contact view model
|
||||||
func (mapping *userMapping) ToContactEntity(item viewmodel.Contact) entity.ContactInfo {
|
func (mapping *userMapping) ToContactEntity(item viewmodel.Contact) entity.ContactInfo {
|
||||||
return entity.ContactInfo{
|
return entity.ContactInfo{
|
||||||
Type: mapping.ToContactTypeEntity(item.Type),
|
UUID: item.ID,
|
||||||
Value: item.Value,
|
User: mapping.ToUserEntity(item.User),
|
||||||
|
Author: mapping.ToUserEntity(item.Author),
|
||||||
|
Type: mapping.ToContactTypeEntity(item.Type),
|
||||||
|
Value: item.Value,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -42,3 +42,287 @@ type EntityResponse struct {
|
|||||||
Name string `json:"name"`
|
Name string `json:"name"`
|
||||||
Status bool `json:"status"`
|
Status bool `json:"status"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type Interchange271 struct {
|
||||||
|
XMLName xml.Name `json:"-" xml:"Interchange"`
|
||||||
|
Isa ISA271 `json:"isa,omitempty" xml:"ISA"`
|
||||||
|
Division Division271 `json:"division,omitempty" xml:"Division"`
|
||||||
|
IEA IEA271 `json:"iea,omitempty" xml:"IEA"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type IEA271 struct {
|
||||||
|
IEA01 string `json:"iea01,omitempty" xml:"IEA01"`
|
||||||
|
IEA02 string `json:"iea02,omitempty" xml:"IEA02"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ISA271 struct {
|
||||||
|
Isa01 string `json:"isa01,omitempty" xml:"ISA01"`
|
||||||
|
Isa02 string `json:"isa02,omitempty" xml:"ISA02"`
|
||||||
|
Isa03 string `json:"isa03,omitempty" xml:"ISA03"`
|
||||||
|
Isa04 string `json:"isa04,omitempty" xml:"ISA04"`
|
||||||
|
Isa05 string `json:"isa05,omitempty" xml:"ISA05"`
|
||||||
|
Isa06 string `json:"isa06,omitempty" xml:"ISA06"`
|
||||||
|
Isa07 string `json:"isa07,omitempty" xml:"ISA07"`
|
||||||
|
Isa08 string `json:"isa08,omitempty" xml:"ISA08"`
|
||||||
|
Isa09 string `json:"isa09,omitempty" xml:"ISA09"`
|
||||||
|
Isa10 string `json:"isa10,omitempty" xml:"ISA10"`
|
||||||
|
Isa11 string `json:"isa11,omitempty" xml:"ISA11"`
|
||||||
|
Isa12 string `json:"isa12,omitempty" xml:"ISA12"`
|
||||||
|
Isa13 string `json:"isa13,omitempty" xml:"ISA13"`
|
||||||
|
Isa14 string `json:"isa14,omitempty" xml:"ISA14"`
|
||||||
|
Isa15 string `json:"isa15,omitempty" xml:"ISA15"`
|
||||||
|
Isa16 string `json:"isa16,omitempty" xml:"ISA16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Division271 struct {
|
||||||
|
GS GS271 `json:"gs,omitempty" xml:"GS"`
|
||||||
|
HealthCareEligibilityResponse HealthCareEligibilityBenefitResponse271 `json:"eligibility_response,omitempty" xml:"Health_Care_Eligibility_Benefit_Response"`
|
||||||
|
GE GE271 `json:"ge,omitempty" xml:"GE"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type GS271 struct {
|
||||||
|
GS01 string `json:"gs01,omitempty" xml:"GS01"`
|
||||||
|
GS02 string `json:"gs02,omitempty" xml:"GS02"`
|
||||||
|
GS03 string `json:"gs03,omitempty" xml:"GS03"`
|
||||||
|
GS04 string `json:"gs04,omitempty" xml:"GS04"`
|
||||||
|
GS05 string `json:"gs05,omitempty" xml:"GS05"`
|
||||||
|
GS06 string `json:"gs06,omitempty" xml:"GS06"`
|
||||||
|
GS07 string `json:"gs07,omitempty" xml:"GS07"`
|
||||||
|
GS08 string `json:"gs08,omitempty" xml:"GS08"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type GE271 struct {
|
||||||
|
GE01 string `json:"ge01,omitempty" xml:"GE01"`
|
||||||
|
GE02 string `json:"ge02,omitempty" xml:"GE02"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type HealthCareEligibilityBenefitResponse271 struct {
|
||||||
|
ST0010 ST `json:"st0010,omitempty" xml:"ST_0010"`
|
||||||
|
BHT0020 BHT `json:"bht0020,omitempty" xml:"BHT_0020"`
|
||||||
|
LoopHL0030 []LoopHL0030271 `json:"hl0030,omitempty" xml:"Loop_HL_0030"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ST struct {
|
||||||
|
ST01 string `json:"st01,omitempty" xml:"ST01"`
|
||||||
|
ST02 string `json:"st02,omitempty" xml:"ST02"`
|
||||||
|
ST03 string `json:"st03,omitempty" xml:"ST03"`
|
||||||
|
ST04 string `json:"st04,omitempty" xml:"ST04"`
|
||||||
|
ST05 string `json:"st05,omitempty" xml:"ST05"`
|
||||||
|
ST06 string `json:"st06,omitempty" xml:"ST06"`
|
||||||
|
ST07 string `json:"st07,omitempty" xml:"ST07"`
|
||||||
|
ST08 string `json:"st08,omitempty" xml:"ST08"`
|
||||||
|
ST09 string `json:"st09,omitempty" xml:"ST09"`
|
||||||
|
ST10 string `json:"st10,omitempty" xml:"ST10"`
|
||||||
|
ST11 string `json:"st11,omitempty" xml:"ST11"`
|
||||||
|
ST12 string `json:"st12,omitempty" xml:"ST12"`
|
||||||
|
ST13 string `json:"st13,omitempty" xml:"ST13"`
|
||||||
|
ST14 string `json:"st14,omitempty" xml:"ST14"`
|
||||||
|
ST15 string `json:"st15,omitempty" xml:"ST15"`
|
||||||
|
ST16 string `json:"st16,omitempty" xml:"ST16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type BHT struct {
|
||||||
|
BHT01 string `json:"bht01,omitempty" xml:"BHT01"`
|
||||||
|
BHT02 string `json:"bht02,omitempty" xml:"BHT02"`
|
||||||
|
BHT03 string `json:"bht03,omitempty" xml:"BHT03"`
|
||||||
|
BHT04 string `json:"bht04,omitempty" xml:"BHT04"`
|
||||||
|
BHT05 string `json:"bht05,omitempty" xml:"BHT05"`
|
||||||
|
BHT06 string `json:"bht06,omitempty" xml:"BHT06"`
|
||||||
|
BHT07 string `json:"bht07,omitempty" xml:"BHT07"`
|
||||||
|
BHT08 string `json:"bht08,omitempty" xml:"BHT08"`
|
||||||
|
BHT09 string `json:"bht09,omitempty" xml:"BHT09"`
|
||||||
|
BHT10 string `json:"bht10,omitempty" xml:"BHT10"`
|
||||||
|
BHT11 string `json:"bht11,omitempty" xml:"BHT11"`
|
||||||
|
BHT12 string `json:"bht12,omitempty" xml:"BHT12"`
|
||||||
|
BHT13 string `json:"bht13,omitempty" xml:"BHT13"`
|
||||||
|
BHT14 string `json:"bht14,omitempty" xml:"BHT14"`
|
||||||
|
BHT15 string `json:"bht15,omitempty" xml:"BHT15"`
|
||||||
|
BHT16 string `json:"bht16,omitempty" xml:"BHT16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopHL0030271 struct {
|
||||||
|
HL_0030 HL `json:"hl_0030,omitempty" xml:"HL_0030"`
|
||||||
|
NM1_0060 []LoopNM10060 `json:"nm1_0060,omitempty" xml:"Loop_NM1_0060"`
|
||||||
|
HL_0460 []LoopHL0460 `json:"hl_0460,omitempty" xml:"Loop_HL_0460"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopHL0460 struct {
|
||||||
|
HL_0460 HL `json:"hl_0460,omitempty" xml:"HL_0460"`
|
||||||
|
NM1_0490 []LoopNM10490 `json:"nm1_0490,omitempty" xml:"Loop_NM1_0490"`
|
||||||
|
HL_0890 []LoopHL0890 `json:"hl_0890,omitempty" xml:"Loop_HL_0890"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopNM10490 struct {
|
||||||
|
NM1_0490 NM1 `json:"nm1_0490,omitempty" xml:"NM1_0490"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopHL0890 struct {
|
||||||
|
HL_0890 HL `json:"hl_0890,omitempty" xml:"HL_0890"`
|
||||||
|
TRN_0900 TRN `json:"trn_0900,omitempty" xml:"TRN_0900"`
|
||||||
|
NM1_0920 []LoopNM10920 `json:"nm1_0920,omitempty" xml:"Loop_NM1_0920"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type REF struct {
|
||||||
|
REF01 string `json:"ref01,omitempty" xml:"REF01"`
|
||||||
|
REF02 string `json:"ref02,omitempty" xml:"REF02"`
|
||||||
|
REF03 string `json:"ref03,omitempty" xml:"REF03"`
|
||||||
|
REF04 string `json:"ref04,omitempty" xml:"REF04"`
|
||||||
|
REF05 string `json:"ref05,omitempty" xml:"REF05"`
|
||||||
|
REF06 string `json:"ref06,omitempty" xml:"REF06"`
|
||||||
|
REF07 string `json:"ref07,omitempty" xml:"REF07"`
|
||||||
|
REF08 string `json:"ref08,omitempty" xml:"REF08"`
|
||||||
|
REF09 string `json:"ref09,omitempty" xml:"REF09"`
|
||||||
|
REF10 string `json:"ref10,omitempty" xml:"REF10"`
|
||||||
|
REF11 string `json:"ref11,omitempty" xml:"REF11"`
|
||||||
|
REF12 string `json:"ref12,omitempty" xml:"REF12"`
|
||||||
|
REF13 string `json:"ref13,omitempty" xml:"REF13"`
|
||||||
|
REF14 string `json:"ref14,omitempty" xml:"REF14"`
|
||||||
|
REF15 string `json:"ref15,omitempty" xml:"REF15"`
|
||||||
|
REF16 string `json:"ref16,omitempty" xml:"REF16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type N3 struct {
|
||||||
|
N301 string `json:"n301,omitempty" xml:"N301"`
|
||||||
|
N302 string `json:"n302,omitempty" xml:"N302"`
|
||||||
|
N303 string `json:"n303,omitempty" xml:"N303"`
|
||||||
|
N304 string `json:"n304,omitempty" xml:"N304"`
|
||||||
|
N305 string `json:"n305,omitempty" xml:"N305"`
|
||||||
|
N306 string `json:"n306,omitempty" xml:"N306"`
|
||||||
|
N307 string `json:"n307,omitempty" xml:"N307"`
|
||||||
|
N308 string `json:"n308,omitempty" xml:"N308"`
|
||||||
|
N309 string `json:"n309,omitempty" xml:"N309"`
|
||||||
|
N310 string `json:"n310,omitempty" xml:"N310"`
|
||||||
|
N311 string `json:"n311,omitempty" xml:"N311"`
|
||||||
|
N312 string `json:"n312,omitempty" xml:"N312"`
|
||||||
|
N313 string `json:"n313,omitempty" xml:"N313"`
|
||||||
|
N314 string `json:"n314,omitempty" xml:"N314"`
|
||||||
|
N315 string `json:"n315,omitempty" xml:"N315"`
|
||||||
|
N316 string `json:"n316,omitempty" xml:"N316"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type N4 struct {
|
||||||
|
N401 string `json:"n401,omitempty" xml:"N401"`
|
||||||
|
N402 string `json:"n402,omitempty" xml:"N402"`
|
||||||
|
N403 string `json:"n403,omitempty" xml:"N403"`
|
||||||
|
N404 string `json:"n404,omitempty" xml:"N404"`
|
||||||
|
N405 string `json:"n405,omitempty" xml:"N405"`
|
||||||
|
N406 string `json:"n406,omitempty" xml:"N406"`
|
||||||
|
N407 string `json:"n407,omitempty" xml:"N407"`
|
||||||
|
N408 string `json:"n408,omitempty" xml:"N408"`
|
||||||
|
N409 string `json:"n409,omitempty" xml:"N409"`
|
||||||
|
N410 string `json:"n410,omitempty" xml:"N410"`
|
||||||
|
N411 string `json:"n411,omitempty" xml:"N411"`
|
||||||
|
N412 string `json:"n412,omitempty" xml:"N412"`
|
||||||
|
N413 string `json:"n413,omitempty" xml:"N413"`
|
||||||
|
N414 string `json:"n414,omitempty" xml:"N414"`
|
||||||
|
N415 string `json:"n415,omitempty" xml:"N415"`
|
||||||
|
N416 string `json:"n416,omitempty" xml:"N416"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopNM10920 struct {
|
||||||
|
NM1_0920 NM1 `json:"nm1_0920,omitempty" xml:"NM1_0920"`
|
||||||
|
REF_0930 []REF `json:"ref_0930,omitempty" xml:"REF_0930"`
|
||||||
|
N3_0950 N3 `json:"n3_0950,omitempty" xml:"N3_0950"`
|
||||||
|
N4_0960 N4 `json:"n4_0960,omitempty" xml:"N4_0960"`
|
||||||
|
DMG_1000 DMG `json:"dmg_1000,omitempty" xml:"DMG_1000"`
|
||||||
|
INS_1010 INS `json:"ins_1010,omitempty" xml:"INS_1010"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type DMG struct {
|
||||||
|
DMG01 string `json:"dmg01,omitempty" xml:"DMG01"`
|
||||||
|
DMG02 string `json:"dmg02,omitempty" xml:"DMG02"`
|
||||||
|
DMG03 string `json:"dmg03,omitempty" xml:"DMG03"`
|
||||||
|
DMG04 string `json:"dmg04,omitempty" xml:"DMG04"`
|
||||||
|
DMG05 string `json:"dmg05,omitempty" xml:"DMG05"`
|
||||||
|
DMG06 string `json:"dmg06,omitempty" xml:"DMG06"`
|
||||||
|
DMG07 string `json:"dmg07,omitempty" xml:"DMG07"`
|
||||||
|
DMG08 string `json:"dmg08,omitempty" xml:"DMG08"`
|
||||||
|
DMG09 string `json:"dmg09,omitempty" xml:"DMG09"`
|
||||||
|
DMG10 string `json:"dmg10,omitempty" xml:"DMG10"`
|
||||||
|
DMG11 string `json:"dmg11,omitempty" xml:"DMG11"`
|
||||||
|
DMG12 string `json:"dmg12,omitempty" xml:"DMG12"`
|
||||||
|
DMG13 string `json:"dmg13,omitempty" xml:"DMG13"`
|
||||||
|
DMG14 string `json:"dmg14,omitempty" xml:"DMG14"`
|
||||||
|
DMG15 string `json:"dmg15,omitempty" xml:"DMG15"`
|
||||||
|
DMG16 string `json:"dmg16,omitempty" xml:"DMG16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type INS struct {
|
||||||
|
INS01 string `json:"ins01,omitempty" xml:"INS01"`
|
||||||
|
INS02 string `json:"ins02,omitempty" xml:"INS02"`
|
||||||
|
INS03 string `json:"ins03,omitempty" xml:"INS03"`
|
||||||
|
INS04 string `json:"ins04,omitempty" xml:"INS04"`
|
||||||
|
INS05 string `json:"ins05,omitempty" xml:"INS05"`
|
||||||
|
INS06 string `json:"ins06,omitempty" xml:"INS06"`
|
||||||
|
INS07 string `json:"ins07,omitempty" xml:"INS07"`
|
||||||
|
INS08 string `json:"ins08,omitempty" xml:"INS08"`
|
||||||
|
INS09 string `json:"ins09,omitempty" xml:"INS09"`
|
||||||
|
INS10 string `json:"ins10,omitempty" xml:"INS10"`
|
||||||
|
INS11 string `json:"ins11,omitempty" xml:"INS11"`
|
||||||
|
INS12 string `json:"ins12,omitempty" xml:"INS12"`
|
||||||
|
INS13 string `json:"ins13,omitempty" xml:"INS13"`
|
||||||
|
INS14 string `json:"ins14,omitempty" xml:"INS14"`
|
||||||
|
INS15 string `json:"ins15,omitempty" xml:"INS15"`
|
||||||
|
INS16 string `json:"ins16,omitempty" xml:"INS16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type TRN struct {
|
||||||
|
TRN01 string `json:"trn01,omitempty" xml:"TRN01"`
|
||||||
|
TRN02 string `json:"trn02,omitempty" xml:"TRN02"`
|
||||||
|
TRN03 string `json:"trn03,omitempty" xml:"TRN03"`
|
||||||
|
TRN04 string `json:"trn04,omitempty" xml:"TRN04"`
|
||||||
|
TRN05 string `json:"trn05,omitempty" xml:"TRN05"`
|
||||||
|
TRN06 string `json:"trn06,omitempty" xml:"TRN06"`
|
||||||
|
TRN07 string `json:"trn07,omitempty" xml:"TRN07"`
|
||||||
|
TRN08 string `json:"trn08,omitempty" xml:"TRN08"`
|
||||||
|
TRN09 string `json:"trn09,omitempty" xml:"TRN09"`
|
||||||
|
TRN10 string `json:"trn10,omitempty" xml:"TRN10"`
|
||||||
|
TRN11 string `json:"trn11,omitempty" xml:"TRN11"`
|
||||||
|
TRN12 string `json:"trn12,omitempty" xml:"TRN12"`
|
||||||
|
TRN13 string `json:"trn13,omitempty" xml:"TRN13"`
|
||||||
|
TRN14 string `json:"trn14,omitempty" xml:"TRN14"`
|
||||||
|
TRN15 string `json:"trn15,omitempty" xml:"TRN15"`
|
||||||
|
TRN16 string `json:"trn16,omitempty" xml:"TRN16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type HL struct {
|
||||||
|
HL01 string `json:"hl01,omitempty" xml:"HL01"`
|
||||||
|
HL02 string `json:"hl02,omitempty" xml:"HL02"`
|
||||||
|
HL03 string `json:"hl03,omitempty" xml:"HL03"`
|
||||||
|
HL04 string `json:"hl04,omitempty" xml:"HL04"`
|
||||||
|
HL05 string `json:"hl05,omitempty" xml:"HL05"`
|
||||||
|
HL06 string `json:"hl06,omitempty" xml:"HL06"`
|
||||||
|
HL07 string `json:"hl07,omitempty" xml:"HL07"`
|
||||||
|
HL08 string `json:"hl08,omitempty" xml:"HL08"`
|
||||||
|
HL09 string `json:"hl09,omitempty" xml:"HL09"`
|
||||||
|
HL10 string `json:"hl10,omitempty" xml:"HL10"`
|
||||||
|
HL11 string `json:"hl11,omitempty" xml:"HL11"`
|
||||||
|
HL12 string `json:"hl12,omitempty" xml:"HL12"`
|
||||||
|
HL13 string `json:"hl13,omitempty" xml:"HL13"`
|
||||||
|
HL14 string `json:"hl14,omitempty" xml:"HL14"`
|
||||||
|
HL15 string `json:"hl15,omitempty" xml:"HL15"`
|
||||||
|
HL16 string `json:"hl16,omitempty" xml:"HL16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopNM10060 struct {
|
||||||
|
NM10060 NM1 `json:"nm1_0060,omitempty" xml:"NM1_0060"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type NM1 struct {
|
||||||
|
NM101 string `json:"nm101,omitempty" xml:"NM101"`
|
||||||
|
NM102 string `json:"nm102,omitempty" xml:"NM102"`
|
||||||
|
NM103 string `json:"nm103,omitempty" xml:"NM103"`
|
||||||
|
NM104 string `json:"nm104,omitempty" xml:"NM104"`
|
||||||
|
NM105 string `json:"nm105,omitempty" xml:"NM105"`
|
||||||
|
NM106 string `json:"nm106,omitempty" xml:"NM106"`
|
||||||
|
NM107 string `json:"nm107,omitempty" xml:"NM107"`
|
||||||
|
NM108 string `json:"nm108,omitempty" xml:"NM108"`
|
||||||
|
NM109 string `json:"nm109,omitempty" xml:"NM109"`
|
||||||
|
NM110 string `json:"nm110,omitempty" xml:"NM110"`
|
||||||
|
NM111 string `json:"nm111,omitempty" xml:"NM111"`
|
||||||
|
NM112 string `json:"nm112,omitempty" xml:"NM112"`
|
||||||
|
NM113 string `json:"nm113,omitempty" xml:"NM113"`
|
||||||
|
NM114 string `json:"nm114,omitempty" xml:"NM114"`
|
||||||
|
NM115 string `json:"nm115,omitempty" xml:"NM115"`
|
||||||
|
NM116 string `json:"nm116,omitempty" xml:"NM116"`
|
||||||
|
}
|
||||||
|
|||||||
@@ -5,7 +5,9 @@ import (
|
|||||||
"crypto/md5"
|
"crypto/md5"
|
||||||
"encoding/hex"
|
"encoding/hex"
|
||||||
"encoding/xml"
|
"encoding/xml"
|
||||||
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"html"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"net/http"
|
"net/http"
|
||||||
"strings"
|
"strings"
|
||||||
@@ -72,14 +74,37 @@ func (s bxeService) GetPayerDetails(subscriberID string) ([]bcbsimodel.EntityRes
|
|||||||
return response, nil
|
return response, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s bxeService) CheckEligibility(eligibility viewmodel.Eligibility) (bcbsimodel.MemberEligibilityResponse, error) {
|
func (s bxeService) Get271(eligibility viewmodel.Eligibility) (bcbsimodel.Interchange271, error) {
|
||||||
payer, err := s.GetPayerDetails(eligibility.Subscriber.SubscriberID)
|
resp, err := s.CheckEligibility(eligibility)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return bcbsimodel.MemberEligibilityResponse{}, err
|
return bcbsimodel.Interchange271{}, err
|
||||||
}
|
}
|
||||||
|
|
||||||
eligibility.Payer.PayerID = payer[0].ID
|
if resp.QueryResult.HIPPA271.T271 != "" {
|
||||||
eligibility.Payer.PayerName = payer[0].Name
|
xmlString := html.UnescapeString(resp.QueryResult.HIPPA271.T271)
|
||||||
|
xmlReader := strings.NewReader(xmlString)
|
||||||
|
|
||||||
|
var f bcbsimodel.Interchange271
|
||||||
|
err = xml.NewDecoder(xmlReader).Decode(&f)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("Error to unmarshal: ", err.Error())
|
||||||
|
return bcbsimodel.Interchange271{}, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return f, nil
|
||||||
|
} else {
|
||||||
|
return bcbsimodel.Interchange271{}, errors.New("No 271 response")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s bxeService) CheckEligibility(eligibility viewmodel.Eligibility) (bcbsimodel.MemberEligibilityResponse, error) {
|
||||||
|
// payer, err := s.GetPayerDetails(eligibility.Subscriber.SubscriberID)
|
||||||
|
// if err != nil {
|
||||||
|
// return bcbsimodel.MemberEligibilityResponse{}, err
|
||||||
|
// }
|
||||||
|
|
||||||
|
eligibility.Payer.PayerID = "621"
|
||||||
|
eligibility.Payer.PayerName = "blue_cross_blue_shield_il"
|
||||||
|
|
||||||
envelope := bcbsimodel.GetEnvelope(eligibility)
|
envelope := bcbsimodel.GetEnvelope(eligibility)
|
||||||
apiKey := s.cfg.BXE.APIKey
|
apiKey := s.cfg.BXE.APIKey
|
||||||
@@ -99,14 +124,14 @@ func (s bxeService) CheckEligibility(eligibility viewmodel.Eligibility) (bcbsimo
|
|||||||
|
|
||||||
resp, err := client.Do(req)
|
resp, err := client.Do(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Println("Error WebService: ", err)
|
fmt.Println("Error WebService Request: ", err)
|
||||||
return bcbsimodel.MemberEligibilityResponse{}, err
|
return bcbsimodel.MemberEligibilityResponse{}, err
|
||||||
}
|
}
|
||||||
defer resp.Body.Close()
|
defer resp.Body.Close()
|
||||||
|
|
||||||
bReturn, err := ioutil.ReadAll(resp.Body)
|
bReturn, err := ioutil.ReadAll(resp.Body)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Println("Error WebService: ", err)
|
fmt.Println("Error WebService getting byte: ", err)
|
||||||
return bcbsimodel.MemberEligibilityResponse{}, err
|
return bcbsimodel.MemberEligibilityResponse{}, err
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -118,7 +143,7 @@ func (s bxeService) CheckEligibility(eligibility viewmodel.Eligibility) (bcbsimo
|
|||||||
var result bcbsimodel.EnvelopeResponse
|
var result bcbsimodel.EnvelopeResponse
|
||||||
err = xml.Unmarshal([]byte(sResponse), &result)
|
err = xml.Unmarshal([]byte(sResponse), &result)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Println("Error WebService: ", err)
|
fmt.Println("Error WebService getting object: ", err)
|
||||||
return bcbsimodel.MemberEligibilityResponse{}, err
|
return bcbsimodel.MemberEligibilityResponse{}, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package viewmodel
|
package viewmodel
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"encoding/xml"
|
||||||
"time"
|
"time"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -53,3 +54,287 @@ type ServiceInfo struct {
|
|||||||
DateOfService time.Time `json:"date_of_service,omitempty"`
|
DateOfService time.Time `json:"date_of_service,omitempty"`
|
||||||
ServiceTypeCodes []string `json:"service_type_codes,omitempty"`
|
ServiceTypeCodes []string `json:"service_type_codes,omitempty"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type Interchange271 struct {
|
||||||
|
XMLName xml.Name `json:"-" xml:"Interchange"`
|
||||||
|
Isa ISA271 `json:"isa,omitempty" xml:"ISA"`
|
||||||
|
Division Division271 `json:"division,omitempty" xml:"Division"`
|
||||||
|
IEA IEA271 `json:"iea,omitempty" xml:"IEA"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type IEA271 struct {
|
||||||
|
IEA01 string `json:"iea01,omitempty" xml:"IEA01"`
|
||||||
|
IEA02 string `json:"iea02,omitempty" xml:"IEA02"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ISA271 struct {
|
||||||
|
Isa01 string `json:"isa01,omitempty" xml:"ISA01"`
|
||||||
|
Isa02 string `json:"isa02,omitempty" xml:"ISA02"`
|
||||||
|
Isa03 string `json:"isa03,omitempty" xml:"ISA03"`
|
||||||
|
Isa04 string `json:"isa04,omitempty" xml:"ISA04"`
|
||||||
|
Isa05 string `json:"isa05,omitempty" xml:"ISA05"`
|
||||||
|
Isa06 string `json:"isa06,omitempty" xml:"ISA06"`
|
||||||
|
Isa07 string `json:"isa07,omitempty" xml:"ISA07"`
|
||||||
|
Isa08 string `json:"isa08,omitempty" xml:"ISA08"`
|
||||||
|
Isa09 string `json:"isa09,omitempty" xml:"ISA09"`
|
||||||
|
Isa10 string `json:"isa10,omitempty" xml:"ISA10"`
|
||||||
|
Isa11 string `json:"isa11,omitempty" xml:"ISA11"`
|
||||||
|
Isa12 string `json:"isa12,omitempty" xml:"ISA12"`
|
||||||
|
Isa13 string `json:"isa13,omitempty" xml:"ISA13"`
|
||||||
|
Isa14 string `json:"isa14,omitempty" xml:"ISA14"`
|
||||||
|
Isa15 string `json:"isa15,omitempty" xml:"ISA15"`
|
||||||
|
Isa16 string `json:"isa16,omitempty" xml:"ISA16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type Division271 struct {
|
||||||
|
GS GS271 `json:"gs,omitempty" xml:"GS"`
|
||||||
|
HealthCareEligibilityResponse HealthCareEligibilityBenefitResponse271 `json:"eligibility_response,omitempty" xml:"Health_Care_Eligibility_Benefit_Response"`
|
||||||
|
GE GE271 `json:"ge,omitempty" xml:"GE"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type GS271 struct {
|
||||||
|
GS01 string `json:"gs01,omitempty" xml:"GS01"`
|
||||||
|
GS02 string `json:"gs02,omitempty" xml:"GS02"`
|
||||||
|
GS03 string `json:"gs03,omitempty" xml:"GS03"`
|
||||||
|
GS04 string `json:"gs04,omitempty" xml:"GS04"`
|
||||||
|
GS05 string `json:"gs05,omitempty" xml:"GS05"`
|
||||||
|
GS06 string `json:"gs06,omitempty" xml:"GS06"`
|
||||||
|
GS07 string `json:"gs07,omitempty" xml:"GS07"`
|
||||||
|
GS08 string `json:"gs08,omitempty" xml:"GS08"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type GE271 struct {
|
||||||
|
GE01 string `json:"ge01,omitempty" xml:"GE01"`
|
||||||
|
GE02 string `json:"ge02,omitempty" xml:"GE02"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type HealthCareEligibilityBenefitResponse271 struct {
|
||||||
|
ST0010 ST `json:"st0010,omitempty" xml:"ST_0010"`
|
||||||
|
BHT0020 BHT `json:"bht0020,omitempty" xml:"BHT_0020"`
|
||||||
|
LoopHL0030 []LoopHL0030271 `json:"hl0030,omitempty" xml:"Loop_HL_0030"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type ST struct {
|
||||||
|
ST01 string `json:"st01,omitempty" xml:"ST01"`
|
||||||
|
ST02 string `json:"st02,omitempty" xml:"ST02"`
|
||||||
|
ST03 string `json:"st03,omitempty" xml:"ST03"`
|
||||||
|
ST04 string `json:"st04,omitempty" xml:"ST04"`
|
||||||
|
ST05 string `json:"st05,omitempty" xml:"ST05"`
|
||||||
|
ST06 string `json:"st06,omitempty" xml:"ST06"`
|
||||||
|
ST07 string `json:"st07,omitempty" xml:"ST07"`
|
||||||
|
ST08 string `json:"st08,omitempty" xml:"ST08"`
|
||||||
|
ST09 string `json:"st09,omitempty" xml:"ST09"`
|
||||||
|
ST10 string `json:"st10,omitempty" xml:"ST10"`
|
||||||
|
ST11 string `json:"st11,omitempty" xml:"ST11"`
|
||||||
|
ST12 string `json:"st12,omitempty" xml:"ST12"`
|
||||||
|
ST13 string `json:"st13,omitempty" xml:"ST13"`
|
||||||
|
ST14 string `json:"st14,omitempty" xml:"ST14"`
|
||||||
|
ST15 string `json:"st15,omitempty" xml:"ST15"`
|
||||||
|
ST16 string `json:"st16,omitempty" xml:"ST16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type BHT struct {
|
||||||
|
BHT01 string `json:"bht01,omitempty" xml:"BHT01"`
|
||||||
|
BHT02 string `json:"bht02,omitempty" xml:"BHT02"`
|
||||||
|
BHT03 string `json:"bht03,omitempty" xml:"BHT03"`
|
||||||
|
BHT04 string `json:"bht04,omitempty" xml:"BHT04"`
|
||||||
|
BHT05 string `json:"bht05,omitempty" xml:"BHT05"`
|
||||||
|
BHT06 string `json:"bht06,omitempty" xml:"BHT06"`
|
||||||
|
BHT07 string `json:"bht07,omitempty" xml:"BHT07"`
|
||||||
|
BHT08 string `json:"bht08,omitempty" xml:"BHT08"`
|
||||||
|
BHT09 string `json:"bht09,omitempty" xml:"BHT09"`
|
||||||
|
BHT10 string `json:"bht10,omitempty" xml:"BHT10"`
|
||||||
|
BHT11 string `json:"bht11,omitempty" xml:"BHT11"`
|
||||||
|
BHT12 string `json:"bht12,omitempty" xml:"BHT12"`
|
||||||
|
BHT13 string `json:"bht13,omitempty" xml:"BHT13"`
|
||||||
|
BHT14 string `json:"bht14,omitempty" xml:"BHT14"`
|
||||||
|
BHT15 string `json:"bht15,omitempty" xml:"BHT15"`
|
||||||
|
BHT16 string `json:"bht16,omitempty" xml:"BHT16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopHL0030271 struct {
|
||||||
|
HL_0030 HL `json:"hl_0030,omitempty" xml:"HL_0030"`
|
||||||
|
NM1_0060 []LoopNM10060 `json:"nm1_0060,omitempty" xml:"Loop_NM1_0060"`
|
||||||
|
HL_0460 []LoopHL0460 `json:"hl_0460,omitempty" xml:"Loop_HL_0460"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopHL0460 struct {
|
||||||
|
HL_0460 HL `json:"hl_0460,omitempty" xml:"HL_0460"`
|
||||||
|
NM1_0490 []LoopNM10490 `json:"nm1_0490,omitempty" xml:"Loop_NM1_0490"`
|
||||||
|
HL_0890 []LoopHL0890 `json:"hl_0890,omitempty" xml:"Loop_HL_0890"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopNM10490 struct {
|
||||||
|
NM1_0490 NM1 `json:"nm1_0490,omitempty" xml:"NM1_0490"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopHL0890 struct {
|
||||||
|
HL_0890 HL `json:"hl_0890,omitempty" xml:"HL_0890"`
|
||||||
|
TRN_0900 TRN `json:"trn_0900,omitempty" xml:"TRN_0900"`
|
||||||
|
NM1_0920 []LoopNM10920 `json:"nm1_0920,omitempty" xml:"Loop_NM1_0920"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type REF struct {
|
||||||
|
REF01 string `json:"ref01,omitempty" xml:"REF01"`
|
||||||
|
REF02 string `json:"ref02,omitempty" xml:"REF02"`
|
||||||
|
REF03 string `json:"ref03,omitempty" xml:"REF03"`
|
||||||
|
REF04 string `json:"ref04,omitempty" xml:"REF04"`
|
||||||
|
REF05 string `json:"ref05,omitempty" xml:"REF05"`
|
||||||
|
REF06 string `json:"ref06,omitempty" xml:"REF06"`
|
||||||
|
REF07 string `json:"ref07,omitempty" xml:"REF07"`
|
||||||
|
REF08 string `json:"ref08,omitempty" xml:"REF08"`
|
||||||
|
REF09 string `json:"ref09,omitempty" xml:"REF09"`
|
||||||
|
REF10 string `json:"ref10,omitempty" xml:"REF10"`
|
||||||
|
REF11 string `json:"ref11,omitempty" xml:"REF11"`
|
||||||
|
REF12 string `json:"ref12,omitempty" xml:"REF12"`
|
||||||
|
REF13 string `json:"ref13,omitempty" xml:"REF13"`
|
||||||
|
REF14 string `json:"ref14,omitempty" xml:"REF14"`
|
||||||
|
REF15 string `json:"ref15,omitempty" xml:"REF15"`
|
||||||
|
REF16 string `json:"ref16,omitempty" xml:"REF16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type N3 struct {
|
||||||
|
N301 string `json:"n301,omitempty" xml:"N301"`
|
||||||
|
N302 string `json:"n302,omitempty" xml:"N302"`
|
||||||
|
N303 string `json:"n303,omitempty" xml:"N303"`
|
||||||
|
N304 string `json:"n304,omitempty" xml:"N304"`
|
||||||
|
N305 string `json:"n305,omitempty" xml:"N305"`
|
||||||
|
N306 string `json:"n306,omitempty" xml:"N306"`
|
||||||
|
N307 string `json:"n307,omitempty" xml:"N307"`
|
||||||
|
N308 string `json:"n308,omitempty" xml:"N308"`
|
||||||
|
N309 string `json:"n309,omitempty" xml:"N309"`
|
||||||
|
N310 string `json:"n310,omitempty" xml:"N310"`
|
||||||
|
N311 string `json:"n311,omitempty" xml:"N311"`
|
||||||
|
N312 string `json:"n312,omitempty" xml:"N312"`
|
||||||
|
N313 string `json:"n313,omitempty" xml:"N313"`
|
||||||
|
N314 string `json:"n314,omitempty" xml:"N314"`
|
||||||
|
N315 string `json:"n315,omitempty" xml:"N315"`
|
||||||
|
N316 string `json:"n316,omitempty" xml:"N316"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type N4 struct {
|
||||||
|
N401 string `json:"n401,omitempty" xml:"N401"`
|
||||||
|
N402 string `json:"n402,omitempty" xml:"N402"`
|
||||||
|
N403 string `json:"n403,omitempty" xml:"N403"`
|
||||||
|
N404 string `json:"n404,omitempty" xml:"N404"`
|
||||||
|
N405 string `json:"n405,omitempty" xml:"N405"`
|
||||||
|
N406 string `json:"n406,omitempty" xml:"N406"`
|
||||||
|
N407 string `json:"n407,omitempty" xml:"N407"`
|
||||||
|
N408 string `json:"n408,omitempty" xml:"N408"`
|
||||||
|
N409 string `json:"n409,omitempty" xml:"N409"`
|
||||||
|
N410 string `json:"n410,omitempty" xml:"N410"`
|
||||||
|
N411 string `json:"n411,omitempty" xml:"N411"`
|
||||||
|
N412 string `json:"n412,omitempty" xml:"N412"`
|
||||||
|
N413 string `json:"n413,omitempty" xml:"N413"`
|
||||||
|
N414 string `json:"n414,omitempty" xml:"N414"`
|
||||||
|
N415 string `json:"n415,omitempty" xml:"N415"`
|
||||||
|
N416 string `json:"n416,omitempty" xml:"N416"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopNM10920 struct {
|
||||||
|
NM1_0920 NM1 `json:"nm1_0920,omitempty" xml:"NM1_0920"`
|
||||||
|
REF_0930 []REF `json:"ref_0930,omitempty" xml:"REF_0930"`
|
||||||
|
N3_0950 N3 `json:"n3_0950,omitempty" xml:"N3_0950"`
|
||||||
|
N4_0960 N4 `json:"n4_0960,omitempty" xml:"N4_0960"`
|
||||||
|
DMG_1000 DMG `json:"dmg_1000,omitempty" xml:"DMG_1000"`
|
||||||
|
INS_1010 INS `json:"ins_1010,omitempty" xml:"INS_1010"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type DMG struct {
|
||||||
|
DMG01 string `json:"dmg01,omitempty" xml:"DMG01"`
|
||||||
|
DMG02 string `json:"dmg02,omitempty" xml:"DMG02"`
|
||||||
|
DMG03 string `json:"dmg03,omitempty" xml:"DMG03"`
|
||||||
|
DMG04 string `json:"dmg04,omitempty" xml:"DMG04"`
|
||||||
|
DMG05 string `json:"dmg05,omitempty" xml:"DMG05"`
|
||||||
|
DMG06 string `json:"dmg06,omitempty" xml:"DMG06"`
|
||||||
|
DMG07 string `json:"dmg07,omitempty" xml:"DMG07"`
|
||||||
|
DMG08 string `json:"dmg08,omitempty" xml:"DMG08"`
|
||||||
|
DMG09 string `json:"dmg09,omitempty" xml:"DMG09"`
|
||||||
|
DMG10 string `json:"dmg10,omitempty" xml:"DMG10"`
|
||||||
|
DMG11 string `json:"dmg11,omitempty" xml:"DMG11"`
|
||||||
|
DMG12 string `json:"dmg12,omitempty" xml:"DMG12"`
|
||||||
|
DMG13 string `json:"dmg13,omitempty" xml:"DMG13"`
|
||||||
|
DMG14 string `json:"dmg14,omitempty" xml:"DMG14"`
|
||||||
|
DMG15 string `json:"dmg15,omitempty" xml:"DMG15"`
|
||||||
|
DMG16 string `json:"dmg16,omitempty" xml:"DMG16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type INS struct {
|
||||||
|
INS01 string `json:"ins01,omitempty" xml:"INS01"`
|
||||||
|
INS02 string `json:"ins02,omitempty" xml:"INS02"`
|
||||||
|
INS03 string `json:"ins03,omitempty" xml:"INS03"`
|
||||||
|
INS04 string `json:"ins04,omitempty" xml:"INS04"`
|
||||||
|
INS05 string `json:"ins05,omitempty" xml:"INS05"`
|
||||||
|
INS06 string `json:"ins06,omitempty" xml:"INS06"`
|
||||||
|
INS07 string `json:"ins07,omitempty" xml:"INS07"`
|
||||||
|
INS08 string `json:"ins08,omitempty" xml:"INS08"`
|
||||||
|
INS09 string `json:"ins09,omitempty" xml:"INS09"`
|
||||||
|
INS10 string `json:"ins10,omitempty" xml:"INS10"`
|
||||||
|
INS11 string `json:"ins11,omitempty" xml:"INS11"`
|
||||||
|
INS12 string `json:"ins12,omitempty" xml:"INS12"`
|
||||||
|
INS13 string `json:"ins13,omitempty" xml:"INS13"`
|
||||||
|
INS14 string `json:"ins14,omitempty" xml:"INS14"`
|
||||||
|
INS15 string `json:"ins15,omitempty" xml:"INS15"`
|
||||||
|
INS16 string `json:"ins16,omitempty" xml:"INS16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type TRN struct {
|
||||||
|
TRN01 string `json:"trn01,omitempty" xml:"TRN01"`
|
||||||
|
TRN02 string `json:"trn02,omitempty" xml:"TRN02"`
|
||||||
|
TRN03 string `json:"trn03,omitempty" xml:"TRN03"`
|
||||||
|
TRN04 string `json:"trn04,omitempty" xml:"TRN04"`
|
||||||
|
TRN05 string `json:"trn05,omitempty" xml:"TRN05"`
|
||||||
|
TRN06 string `json:"trn06,omitempty" xml:"TRN06"`
|
||||||
|
TRN07 string `json:"trn07,omitempty" xml:"TRN07"`
|
||||||
|
TRN08 string `json:"trn08,omitempty" xml:"TRN08"`
|
||||||
|
TRN09 string `json:"trn09,omitempty" xml:"TRN09"`
|
||||||
|
TRN10 string `json:"trn10,omitempty" xml:"TRN10"`
|
||||||
|
TRN11 string `json:"trn11,omitempty" xml:"TRN11"`
|
||||||
|
TRN12 string `json:"trn12,omitempty" xml:"TRN12"`
|
||||||
|
TRN13 string `json:"trn13,omitempty" xml:"TRN13"`
|
||||||
|
TRN14 string `json:"trn14,omitempty" xml:"TRN14"`
|
||||||
|
TRN15 string `json:"trn15,omitempty" xml:"TRN15"`
|
||||||
|
TRN16 string `json:"trn16,omitempty" xml:"TRN16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type HL struct {
|
||||||
|
HL01 string `json:"hl01,omitempty" xml:"HL01"`
|
||||||
|
HL02 string `json:"hl02,omitempty" xml:"HL02"`
|
||||||
|
HL03 string `json:"hl03,omitempty" xml:"HL03"`
|
||||||
|
HL04 string `json:"hl04,omitempty" xml:"HL04"`
|
||||||
|
HL05 string `json:"hl05,omitempty" xml:"HL05"`
|
||||||
|
HL06 string `json:"hl06,omitempty" xml:"HL06"`
|
||||||
|
HL07 string `json:"hl07,omitempty" xml:"HL07"`
|
||||||
|
HL08 string `json:"hl08,omitempty" xml:"HL08"`
|
||||||
|
HL09 string `json:"hl09,omitempty" xml:"HL09"`
|
||||||
|
HL10 string `json:"hl10,omitempty" xml:"HL10"`
|
||||||
|
HL11 string `json:"hl11,omitempty" xml:"HL11"`
|
||||||
|
HL12 string `json:"hl12,omitempty" xml:"HL12"`
|
||||||
|
HL13 string `json:"hl13,omitempty" xml:"HL13"`
|
||||||
|
HL14 string `json:"hl14,omitempty" xml:"HL14"`
|
||||||
|
HL15 string `json:"hl15,omitempty" xml:"HL15"`
|
||||||
|
HL16 string `json:"hl16,omitempty" xml:"HL16"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type LoopNM10060 struct {
|
||||||
|
NM10060 NM1 `json:"nm1_0060,omitempty" xml:"NM1_0060"`
|
||||||
|
}
|
||||||
|
|
||||||
|
type NM1 struct {
|
||||||
|
NM101 string `json:"nm101,omitempty" xml:"NM101"`
|
||||||
|
NM102 string `json:"nm102,omitempty" xml:"NM102"`
|
||||||
|
NM103 string `json:"nm103,omitempty" xml:"NM103"`
|
||||||
|
NM104 string `json:"nm104,omitempty" xml:"NM104"`
|
||||||
|
NM105 string `json:"nm105,omitempty" xml:"NM105"`
|
||||||
|
NM106 string `json:"nm106,omitempty" xml:"NM106"`
|
||||||
|
NM107 string `json:"nm107,omitempty" xml:"NM107"`
|
||||||
|
NM108 string `json:"nm108,omitempty" xml:"NM108"`
|
||||||
|
NM109 string `json:"nm109,omitempty" xml:"NM109"`
|
||||||
|
NM110 string `json:"nm110,omitempty" xml:"NM110"`
|
||||||
|
NM111 string `json:"nm111,omitempty" xml:"NM111"`
|
||||||
|
NM112 string `json:"nm112,omitempty" xml:"NM112"`
|
||||||
|
NM113 string `json:"nm113,omitempty" xml:"NM113"`
|
||||||
|
NM114 string `json:"nm114,omitempty" xml:"NM114"`
|
||||||
|
NM115 string `json:"nm115,omitempty" xml:"NM115"`
|
||||||
|
NM116 string `json:"nm116,omitempty" xml:"NM116"`
|
||||||
|
}
|
||||||
|
|||||||
@@ -15,6 +15,7 @@ type WebhookResponse struct {
|
|||||||
//RideRequest has the data to dispatch a ride
|
//RideRequest has the data to dispatch a ride
|
||||||
type RideRequest struct {
|
type RideRequest struct {
|
||||||
UserUUID string `json:"user_uuid,omitempty"`
|
UserUUID string `json:"user_uuid,omitempty"`
|
||||||
|
UserConsent bool `json:"user_consent,omitempty"`
|
||||||
Status string `json:"status,omitempty"`
|
Status string `json:"status,omitempty"`
|
||||||
RideID string `json:"ride_id,omitempty"`
|
RideID string `json:"ride_id,omitempty"`
|
||||||
RideType string `json:"ride_type,omitempty"`
|
RideType string `json:"ride_type,omitempty"`
|
||||||
|
|||||||
@@ -26,8 +26,11 @@ type User struct {
|
|||||||
}
|
}
|
||||||
|
|
||||||
type Contact struct {
|
type Contact struct {
|
||||||
Type ContactType `json:"type,omitempty"`
|
ID string `json:"id,omitempty"`
|
||||||
Value string `json:"contact,omitempty"`
|
User User `json:"-"`
|
||||||
|
Type ContactType `json:"type,omitempty"`
|
||||||
|
Value string `json:"contact,omitempty"`
|
||||||
|
Author User `json:"-"`
|
||||||
}
|
}
|
||||||
|
|
||||||
type ContactType struct {
|
type ContactType struct {
|
||||||
|
|||||||
@@ -79,18 +79,23 @@ p, *, *, *, *, *, *, /v1/nemt/organization/type, GET
|
|||||||
p, AD, *, *, *, *, *, /v1/nemt/organization/*, GET
|
p, AD, *, *, *, *, *, /v1/nemt/organization/*, GET
|
||||||
p, AD, *, *, *, *, *, /v1/nemt/organization/*, POST
|
p, AD, *, *, *, *, *, /v1/nemt/organization/*, POST
|
||||||
p, AD, *, *, *, *, *, /v1/nemt/organization/*, PUT
|
p, AD, *, *, *, *, *, /v1/nemt/organization/*, PUT
|
||||||
|
p, AD, *, *, *, *, *, /v1/nemt/organization/*, DELETE
|
||||||
p, SCHDAD, *, *, *, [equal*], *, /v1/nemt/organization/*, GET
|
p, SCHDAD, *, *, *, [equal*], *, /v1/nemt/organization/*, GET
|
||||||
p, SCHDAD, *, *, *, [equal*], *, /v1/nemt/organization/*, POST
|
p, SCHDAD, *, *, *, [equal*], *, /v1/nemt/organization/*, POST
|
||||||
p, SCHDAD, *, *, *, [equal*], *, /v1/nemt/organization/*, PUT
|
p, SCHDAD, *, *, *, [equal*], *, /v1/nemt/organization/*, PUT
|
||||||
|
p, SCHDAD, *, *, *, [equal*], *, /v1/nemt/organization/*, DELETE
|
||||||
p, PLANAD, *, *, *, [equal*], *, /v1/nemt/organization/*, GET
|
p, PLANAD, *, *, *, [equal*], *, /v1/nemt/organization/*, GET
|
||||||
p, PLANAD, *, *, *, [equal*], *, /v1/nemt/organization/*, POST
|
p, PLANAD, *, *, *, [equal*], *, /v1/nemt/organization/*, POST
|
||||||
p, PLANAD, *, *, *, [equal*], *, /v1/nemt/organization/*, PUT
|
p, PLANAD, *, *, *, [equal*], *, /v1/nemt/organization/*, PUT
|
||||||
|
p, PLANAD, *, *, *, [equal*], *, /v1/nemt/organization/*, DELETE
|
||||||
p, BDCAD, *, *, *, *, *, /v1/nemt/organization/*, GET
|
p, BDCAD, *, *, *, *, *, /v1/nemt/organization/*, GET
|
||||||
p, BDCAD, *, *, *, *, *, /v1/nemt/organization/*, POST
|
p, BDCAD, *, *, *, *, *, /v1/nemt/organization/*, POST
|
||||||
p, BDCAD, *, *, *, *, *, /v1/nemt/organization/*, PUT
|
p, BDCAD, *, *, *, *, *, /v1/nemt/organization/*, PUT
|
||||||
|
p, BDCAD, *, *, *, *, *, /v1/nemt/organization/*, DELETE
|
||||||
p, BCBSIAD, *, *, *, *, *, /v1/nemt/organization/*, GET
|
p, BCBSIAD, *, *, *, *, *, /v1/nemt/organization/*, GET
|
||||||
p, BCBSIAD, *, *, *, *, *, /v1/nemt/organization/*, POST
|
p, BCBSIAD, *, *, *, *, *, /v1/nemt/organization/*, POST
|
||||||
p, BCBSIAD, *, *, *, *, *, /v1/nemt/organization/*, PUT
|
p, BCBSIAD, *, *, *, *, *, /v1/nemt/organization/*, PUT
|
||||||
|
p, BCBSIAD, *, *, *, *, *, /v1/nemt/organization/*, DELETE
|
||||||
p, SPT, *, programsupport, *, *, *, /v1/nemt/organization/*, GET
|
p, SPT, *, programsupport, *, *, *, /v1/nemt/organization/*, GET
|
||||||
p, SP, *, provider, *, *, *, /v1/nemt/organization, GET
|
p, SP, *, provider, *, *, *, /v1/nemt/organization, GET
|
||||||
p, SP, *, plan, *, *, *, /v1/nemt/organization, GET
|
p, SP, *, plan, *, *, *, /v1/nemt/organization, GET
|
||||||
@@ -108,4 +113,3 @@ p, BCBSIAD, *, bcbsi, *, *, *, /v1/nemt/eligibility, POST
|
|||||||
p, BDCAD, *, techsupport, *, *, *, /v1/nemt/eligibility, POST
|
p, BDCAD, *, techsupport, *, *, *, /v1/nemt/eligibility, POST
|
||||||
p, PLANAD, *, plan, *, *, *, /v1/nemt/eligibility, POST
|
p, PLANAD, *, plan, *, *, *, /v1/nemt/eligibility, POST
|
||||||
p, AD, *, *, *, *, *, /v1/nemt/eligibility, POST
|
p, AD, *, *, *, *, *, /v1/nemt/eligibility, POST
|
||||||
|
|
||||||
|
|||||||
|
@@ -74,8 +74,8 @@ user-uuid = "11a49fa4-fbc7-4fe9-87fe-52a5bc3b71f8"
|
|||||||
|
|
||||||
[bxe]
|
[bxe]
|
||||||
url = "https://api-pve.bcbs.com/BXDirectConnect/V30"
|
url = "https://api-pve.bcbs.com/BXDirectConnect/V30"
|
||||||
key = "dacg7jtsmb6ajr3z553jbczg"
|
key = "c63z7gv9a5qz2zgx7zcm3253"
|
||||||
secret = "vFhNeWE8JdJpbDZQtcm6AHjX"
|
secret = "hK4Yc9jtBrxaZTr4UU2VsfX9"
|
||||||
|
|
||||||
[blue365]
|
[blue365]
|
||||||
url = "https://api-cloud.bcbs.com/blue365deals-stg/v1/validatePrefix/"
|
url = "https://api-cloud.bcbs.com/blue365deals-stg/v1/validatePrefix/"
|
||||||
|
|||||||
@@ -74,8 +74,8 @@ user-uuid = "11a49fa4-fbc7-4fe9-87fe-52a5bc3b71f8"
|
|||||||
|
|
||||||
[bxe]
|
[bxe]
|
||||||
url = "https://api-pve.bcbs.com/BXDirectConnect/V30"
|
url = "https://api-pve.bcbs.com/BXDirectConnect/V30"
|
||||||
key = "dacg7jtsmb6ajr3z553jbczg"
|
key = "c63z7gv9a5qz2zgx7zcm3253"
|
||||||
secret = "vFhNeWE8JdJpbDZQtcm6AHjX"
|
secret = "hK4Yc9jtBrxaZTr4UU2VsfX9"
|
||||||
|
|
||||||
[blue365]
|
[blue365]
|
||||||
url = "https://api-cloud.bcbs.com/blue365deals-stg/v1/validatePrefix/"
|
url = "https://api-cloud.bcbs.com/blue365deals-stg/v1/validatePrefix/"
|
||||||
|
|||||||
@@ -294,7 +294,7 @@ func (c *organizationRepo) GetAllTypes() ([]entity.OrganizationType, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (c *organizationRepo) GetTypeByKey(key string) (entity.OrganizationType, error) {
|
func (c *organizationRepo) GetTypeByKey(key string) (entity.OrganizationType, error) {
|
||||||
return c.parseTypeEntity(c.conn.QueryRow(c.getTypeQuery()+" WHERE b.organization_type_key=?", key))
|
return c.parseTypeEntity(c.conn.QueryRow(c.getTypeQuery()+" WHERE organization_type_key=? ", key))
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c *organizationRepo) GetByType(organizationTypeKey string, user entity.User) ([]entity.Organization, error) {
|
func (c *organizationRepo) GetByType(organizationTypeKey string, user entity.User) ([]entity.Organization, error) {
|
||||||
|
|||||||
@@ -63,7 +63,8 @@ func (c *userRepo) GetContacts(userID int64) ([]entity.ContactInfo, error) {
|
|||||||
a.user_id,
|
a.user_id,
|
||||||
b.contact_type_id,
|
b.contact_type_id,
|
||||||
b.key contact_type_key,
|
b.key contact_type_key,
|
||||||
b.name contact_type_name
|
b.name contact_type_name,
|
||||||
|
a.contact_uuid
|
||||||
FROM tab_contact a
|
FROM tab_contact a
|
||||||
INNER JOIN tab_contact_type b
|
INNER JOIN tab_contact_type b
|
||||||
ON a.contact_type_id = b.contact_type_id
|
ON a.contact_type_id = b.contact_type_id
|
||||||
@@ -79,7 +80,7 @@ func (c *userRepo) GetContacts(userID int64) ([]entity.ContactInfo, error) {
|
|||||||
retVal := make([]entity.ContactInfo, 0)
|
retVal := make([]entity.ContactInfo, 0)
|
||||||
for rows.Next() {
|
for rows.Next() {
|
||||||
contact := entity.ContactInfo{}
|
contact := entity.ContactInfo{}
|
||||||
err = rows.Scan(&contact.ID, &contact.Value, &contact.UserID, &contact.Type.ID, &contact.Type.Key, &contact.Type.Value)
|
err = rows.Scan(&contact.ID, &contact.Value, &contact.User.ID, &contact.Type.ID, &contact.Type.Key, &contact.Type.Value, &contact.UUID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
@@ -354,9 +355,11 @@ func (c *userRepo) Create(user entity.User) (retVal entity.User, err error) {
|
|||||||
|
|
||||||
if retVal.Email != "" {
|
if retVal.Email != "" {
|
||||||
contact := entity.ContactInfo{
|
contact := entity.ContactInfo{
|
||||||
Type: entity.ContactType{Key: "email"},
|
Type: entity.ContactType{Key: "email"},
|
||||||
Value: retVal.Email,
|
Value: retVal.Email,
|
||||||
UserID: retVal.ID,
|
User: entity.User{
|
||||||
|
ID: retVal.ID,
|
||||||
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
contact, err = c.addContactInfo(contact)
|
contact, err = c.addContactInfo(contact)
|
||||||
@@ -367,9 +370,11 @@ func (c *userRepo) Create(user entity.User) (retVal entity.User, err error) {
|
|||||||
|
|
||||||
if retVal.PhoneNumber != "" {
|
if retVal.PhoneNumber != "" {
|
||||||
contact := entity.ContactInfo{
|
contact := entity.ContactInfo{
|
||||||
Type: entity.ContactType{Key: "phone"},
|
Type: entity.ContactType{Key: "phone"},
|
||||||
Value: retVal.PhoneNumber,
|
Value: retVal.PhoneNumber,
|
||||||
UserID: retVal.ID,
|
User: entity.User{
|
||||||
|
ID: retVal.ID,
|
||||||
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
contact, err = c.addContactInfo(contact)
|
contact, err = c.addContactInfo(contact)
|
||||||
@@ -387,19 +392,10 @@ func (c *userRepo) SaveContact(contact entity.ContactInfo) (entity.ContactInfo,
|
|||||||
|
|
||||||
func (c *userRepo) RemoveContact(contact entity.ContactInfo) (entity.ContactInfo, error) {
|
func (c *userRepo) RemoveContact(contact entity.ContactInfo) (entity.ContactInfo, error) {
|
||||||
const (
|
const (
|
||||||
query = `INSERT INTO tab_contact(contact_type_id, user_id, contact)
|
query = `DELETE FROM tab_contact WHERE contact_uuid = ?;`
|
||||||
SELECT a.contact_type_id, ? user_id, ? contact
|
|
||||||
FROM
|
|
||||||
tab_contact_type a
|
|
||||||
LEFT JOIN tab_contact b
|
|
||||||
ON a.contact_type_id = b.contact_type_id
|
|
||||||
AND b.user_id = ?
|
|
||||||
AND b.contact = ?
|
|
||||||
WHERE a.key = ?
|
|
||||||
AND b.contact_id IS NULL;`
|
|
||||||
)
|
)
|
||||||
|
|
||||||
result, err := c.conn.Exec(query, contact.UserID, contact.Value, contact.UserID, contact.Value, contact.Type.Key)
|
result, err := c.conn.Exec(query, contact.UUID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return contact, err
|
return contact, err
|
||||||
}
|
}
|
||||||
@@ -415,8 +411,8 @@ func (c *userRepo) RemoveContact(contact entity.ContactInfo) (entity.ContactInfo
|
|||||||
|
|
||||||
func (c *userRepo) addContactInfo(contact entity.ContactInfo) (entity.ContactInfo, error) {
|
func (c *userRepo) addContactInfo(contact entity.ContactInfo) (entity.ContactInfo, error) {
|
||||||
const (
|
const (
|
||||||
query = `INSERT INTO tab_contact(contact_type_id, user_id, contact)
|
query = `INSERT INTO tab_contact(contact_type_id, user_id, contact, contact_uuid)
|
||||||
SELECT a.contact_type_id, ? user_id, ? contact
|
SELECT a.contact_type_id, ? user_id, ? contact, ? contact_uuid
|
||||||
FROM
|
FROM
|
||||||
tab_contact_type a
|
tab_contact_type a
|
||||||
LEFT JOIN tab_contact b
|
LEFT JOIN tab_contact b
|
||||||
@@ -427,7 +423,13 @@ func (c *userRepo) addContactInfo(contact entity.ContactInfo) (entity.ContactInf
|
|||||||
AND b.contact_id IS NULL;`
|
AND b.contact_id IS NULL;`
|
||||||
)
|
)
|
||||||
|
|
||||||
result, err := c.conn.Exec(query, contact.UserID, contact.Value, contact.UserID, contact.Value, contact.Type.Key)
|
sUUID, err := uuid.NewV4()
|
||||||
|
if err != nil {
|
||||||
|
return contact, err
|
||||||
|
}
|
||||||
|
|
||||||
|
contact.UUID = sUUID.String()
|
||||||
|
result, err := c.conn.Exec(query, contact.User.ID, contact.Value, contact.UUID, contact.User.ID, contact.Value, contact.Type.Key)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return contact, err
|
return contact, err
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -27,6 +27,8 @@ type UserRepo interface {
|
|||||||
GetAddressByUUID(addressUUID string) (entity.Address, error)
|
GetAddressByUUID(addressUUID string) (entity.Address, error)
|
||||||
GetContactType() (retVal []entity.ContactType, err error)
|
GetContactType() (retVal []entity.ContactType, err error)
|
||||||
RemoveAddress(addressUUID string) error
|
RemoveAddress(addressUUID string) error
|
||||||
|
SaveContact(contact entity.ContactInfo) (entity.ContactInfo, error)
|
||||||
|
RemoveContact(contact entity.ContactInfo) (entity.ContactInfo, error)
|
||||||
}
|
}
|
||||||
|
|
||||||
// RideRepo defines the data set for Rides
|
// RideRepo defines the data set for Rides
|
||||||
|
|||||||
@@ -34,8 +34,10 @@ type User struct {
|
|||||||
|
|
||||||
type ContactInfo struct {
|
type ContactInfo struct {
|
||||||
ID int64 `db:"contact_id" json:"contact_id"`
|
ID int64 `db:"contact_id" json:"contact_id"`
|
||||||
|
UUID string `db:"contact_uuid" json:"contact_uuid"`
|
||||||
Type ContactType `db:"contact_type" json:"contact_type"`
|
Type ContactType `db:"contact_type" json:"contact_type"`
|
||||||
UserID int64 `db:"user_id" json:"-"`
|
User User `db:"user" json:"-"`
|
||||||
|
Author User `db:"author" json:"-"`
|
||||||
Value string `db:"value" json:"value"`
|
Value string `db:"value" json:"value"`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -82,6 +82,26 @@ func (s *userService) SaveAddress(address entity.Address) (entity.Address, error
|
|||||||
return s.svc.db.Users().SaveAddress(address)
|
return s.svc.db.Users().SaveAddress(address)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (s *userService) SaveContact(contact entity.ContactInfo) (entity.ContactInfo, error) {
|
||||||
|
user, err := s.svc.db.Users().GetByUUID(contact.User.UUID, "")
|
||||||
|
if err != nil {
|
||||||
|
return entity.ContactInfo{}, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
contact.User = user
|
||||||
|
return s.svc.db.Users().SaveContact(contact)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (s *userService) RemoveContact(contact entity.ContactInfo) (entity.ContactInfo, error) {
|
||||||
|
user, err := s.svc.db.Users().GetByUUID(contact.User.UUID, "")
|
||||||
|
if err != nil {
|
||||||
|
return entity.ContactInfo{}, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
contact.User = user
|
||||||
|
return s.svc.db.Users().RemoveContact(contact)
|
||||||
|
}
|
||||||
|
|
||||||
// GetAddressByUUID returns a list of users by profile
|
// GetAddressByUUID returns a list of users by profile
|
||||||
func (s *userService) GetAddressByUUID(addressUUID string) (entity.Address, error) {
|
func (s *userService) GetAddressByUUID(addressUUID string) (entity.Address, error) {
|
||||||
return s.svc.db.Users().GetAddressByUUID(addressUUID)
|
return s.svc.db.Users().GetAddressByUUID(addressUUID)
|
||||||
|
|||||||
1602
returnExample.xml
Normal file
1602
returnExample.xml
Normal file
File diff suppressed because it is too large
Load Diff
15
server/authorization/address.go
Normal file
15
server/authorization/address.go
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
package authorization
|
||||||
|
|
||||||
|
import (
|
||||||
|
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
||||||
|
)
|
||||||
|
|
||||||
|
func CanCreateAddress(user viewmodel.User, organization viewmodel.Organization) bool {
|
||||||
|
//rules are the same for address creation and for organization creation
|
||||||
|
return CanCreateOrganization(user, organization)
|
||||||
|
}
|
||||||
|
|
||||||
|
func CanUpdateAddress(user viewmodel.User, organization viewmodel.Organization) bool {
|
||||||
|
return CanCreateAddress(user, organization)
|
||||||
|
}
|
||||||
1
server/authorization/authorization.go
Normal file
1
server/authorization/authorization.go
Normal file
@@ -0,0 +1 @@
|
|||||||
|
package authorization
|
||||||
15
server/authorization/contact.go
Normal file
15
server/authorization/contact.go
Normal file
@@ -0,0 +1,15 @@
|
|||||||
|
package authorization
|
||||||
|
|
||||||
|
import (
|
||||||
|
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
||||||
|
)
|
||||||
|
|
||||||
|
func CanCreateContact(user viewmodel.User, organization viewmodel.Organization) bool {
|
||||||
|
//rules are the same for contact creation and for organization creation
|
||||||
|
return CanCreateOrganization(user, organization)
|
||||||
|
}
|
||||||
|
|
||||||
|
func CanUpdateContact(user viewmodel.User, organization viewmodel.Organization) bool {
|
||||||
|
return CanCreateAddress(user, organization)
|
||||||
|
}
|
||||||
76
server/authorization/organization.go
Normal file
76
server/authorization/organization.go
Normal file
@@ -0,0 +1,76 @@
|
|||||||
|
package authorization
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
||||||
|
)
|
||||||
|
|
||||||
|
func isAChildOrganization(potentialParent viewmodel.Organization, potentialChild viewmodel.Organization) bool {
|
||||||
|
for _, org := range potentialParent.ChildOrgs {
|
||||||
|
if potentialChild.UUID == org.UUID {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
func isSameOrganization(organizationA viewmodel.Organization, organizationB viewmodel.Organization) bool {
|
||||||
|
return organizationA.UUID == organizationB.UUID
|
||||||
|
}
|
||||||
|
|
||||||
|
func grabOrgFromUser(user viewmodel.User) (viewmodel.Organization, error) {
|
||||||
|
if len(user.Profiles) < 1 {
|
||||||
|
return viewmodel.Organization{}, fmt.Errorf("User has no organizations %v", user)
|
||||||
|
}
|
||||||
|
|
||||||
|
return user.Profiles[0].Organization, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func grabOrgFromUserDirectly(user viewmodel.User) (viewmodel.Organization, error) {
|
||||||
|
if len(user.Organizations) < 1 {
|
||||||
|
return viewmodel.Organization{}, fmt.Errorf("User has no organizations %v", user)
|
||||||
|
}
|
||||||
|
|
||||||
|
return user.Organizations[0], nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func CanCreateOrganization(user viewmodel.User, organization viewmodel.Organization ) bool {
|
||||||
|
userRole, err := grabProfileFromUser(user)
|
||||||
|
if err != nil {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Admin BCBSI
|
||||||
|
Admin Technical Support
|
||||||
|
Super Admin Technical Support
|
||||||
|
|
||||||
|
Manage all Organizations*/
|
||||||
|
if userRole.Key == bcbsiAdmin || userRole.Key == brighterDevAdmin || userRole.Key == superAdmin{
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
userOrg, err := grabOrgFromUser(user)
|
||||||
|
if err != nil{
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Admin Provider
|
||||||
|
Admin Plan
|
||||||
|
|
||||||
|
Manage the authenticated Authorized User's Organization and child Organizations */
|
||||||
|
if userRole.Key == providerAdmin || userRole.Key == planAdmin{
|
||||||
|
if isSameOrganization(userOrg, organization) || isAChildOrganization(userOrg, organization) {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
func CanUpdateOrganization(user viewmodel.User, organization viewmodel.Organization) bool{
|
||||||
|
return CanCreateOrganization(user, organization)
|
||||||
|
}
|
||||||
62
server/authorization/profile.go
Normal file
62
server/authorization/profile.go
Normal file
@@ -0,0 +1,62 @@
|
|||||||
|
package authorization
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
||||||
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
superAdmin = "AD"
|
||||||
|
scheduler = "SP"
|
||||||
|
support = "SPT"
|
||||||
|
member = "US"
|
||||||
|
brighterDevAdmin = "BDCAD"
|
||||||
|
bcbsiAdmin = "BCBSIAD"
|
||||||
|
planAdmin = "PLANAD"
|
||||||
|
providerAdmin = "SCHDAD"
|
||||||
|
)
|
||||||
|
|
||||||
|
func grabProfileFromUser(user viewmodel.User) (viewmodel.Profile, error) {
|
||||||
|
if len(user.Profiles) < 1 {
|
||||||
|
return viewmodel.Profile{}, fmt.Errorf("User has no profiles %v", user)
|
||||||
|
}
|
||||||
|
return user.Profiles[0], nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func morePrivileged(who viewmodel.Profile, towardsWhom viewmodel.Profile) bool {
|
||||||
|
order := []string{superAdmin, brighterDevAdmin, bcbsiAdmin, planAdmin, providerAdmin, support, scheduler, member}
|
||||||
|
for _, value := range order {
|
||||||
|
if value == who.Key {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
if value == towardsWhom.Key {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// should hapen only in case profile key is empty
|
||||||
|
// and that's something fishy so let's deny!
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
func equallyOrMorePrivileged(who viewmodel.Profile, towardsWhom viewmodel.Profile) bool {
|
||||||
|
if who.Key == towardsWhom.Key {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
return morePrivileged(who, towardsWhom)
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func lessPrivilegedThanAdmin(who viewmodel.Profile) bool {
|
||||||
|
switch who.Key {
|
||||||
|
case member:
|
||||||
|
return true
|
||||||
|
case scheduler:
|
||||||
|
return true
|
||||||
|
case support:
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
return false
|
||||||
|
}
|
||||||
86
server/authorization/user.go
Normal file
86
server/authorization/user.go
Normal file
@@ -0,0 +1,86 @@
|
|||||||
|
package authorization
|
||||||
|
|
||||||
|
import "bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
||||||
|
|
||||||
|
/*
|
||||||
|
CanCreateUser returns true if currentUser is allowed to create updatingUser according to
|
||||||
|
authorization rules
|
||||||
|
*/
|
||||||
|
func CanCreateUser(currentUser viewmodel.User, updatingUser viewmodel.User) bool {
|
||||||
|
|
||||||
|
if len(currentUser.Profiles) < 1 {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(updatingUser.Profiles) < 1 {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
currentUserOrganization, err := grabOrgFromUser(currentUser)
|
||||||
|
if err != nil {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
updatingUserOrganization, err := grabOrgFromUserDirectly(updatingUser)
|
||||||
|
if err != nil {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
currentUserRole, err := grabProfileFromUser(currentUser)
|
||||||
|
if err != nil {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
updatingUserRole, err := grabProfileFromUser(updatingUser)
|
||||||
|
if err != nil {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
/*
|
||||||
|
Admin Provider
|
||||||
|
Manage all Authorized Users of the provider Organization or child organization
|
||||||
|
|
||||||
|
The (Provider) Admin can manage Authorized Users of their Parent/ Top-level Org , but not Admins
|
||||||
|
*/
|
||||||
|
|
||||||
|
currentUserHigherOrEqualOrg := isSameOrganization(currentUserOrganization, updatingUserOrganization) || isAChildOrganization(currentUserOrganization, updatingUserOrganization)
|
||||||
|
currentUserLowerOrg := isAChildOrganization(updatingUserOrganization, currentUserOrganization)
|
||||||
|
if currentUserRole.Key == providerAdmin && currentUserHigherOrEqualOrg && equallyOrMorePrivileged(currentUserRole, updatingUserRole) {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
if currentUserRole.Key == providerAdmin && currentUserLowerOrg && lessPrivilegedThanAdmin(updatingUserRole) {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Admin BCBSI
|
||||||
|
Manage all Authorized Users except Admins
|
||||||
|
|
||||||
|
return false
|
||||||
|
*/
|
||||||
|
|
||||||
|
if currentUserRole.Key == bcbsiAdmin && lessPrivilegedThanAdmin(updatingUserRole) {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Admin Technical Support Manage all Authorized Users except Admins */
|
||||||
|
|
||||||
|
if currentUserRole.Key == brighterDevAdmin && lessPrivilegedThanAdmin(updatingUserRole) {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Admin Plan Manage all Authorized Users of a single participating Plan except Admins */
|
||||||
|
|
||||||
|
if currentUserRole.Key == planAdmin && lessPrivilegedThanAdmin(updatingUserRole) && isSameOrganization(currentUserOrganization, updatingUserOrganization) {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Super Admin Technical Support
|
||||||
|
Manage all Members, INCLUDING Admins */
|
||||||
|
|
||||||
|
if currentUserRole.Key == superAdmin {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
return false
|
||||||
|
|
||||||
|
}
|
||||||
@@ -1,6 +1,10 @@
|
|||||||
package eligibilityroute
|
package eligibilityroute
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"encoding/xml"
|
||||||
|
"fmt"
|
||||||
|
"html"
|
||||||
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
|
|
||||||
"bitbucket.org/nemt/nemt-portal-api/application/applicationservice"
|
"bitbucket.org/nemt/nemt-portal-api/application/applicationservice"
|
||||||
@@ -42,8 +46,22 @@ func (c *controller) handleEligibility(ctx echo.Context) error {
|
|||||||
|
|
||||||
ret, err := c.bcbsi.BXE.CheckEligibility(eligibility)
|
ret, err := c.bcbsi.BXE.CheckEligibility(eligibility)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
fmt.Println("Error Here: ", err.Error())
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
return routeutils.ResponseAPIOK(ctx, ret)
|
if ret.QueryResult.HIPPA271.T271 != "" {
|
||||||
|
xmlString := html.UnescapeString(ret.QueryResult.HIPPA271.T271)
|
||||||
|
xmlReader := strings.NewReader(xmlString)
|
||||||
|
|
||||||
|
var f viewmodel.Interchange271
|
||||||
|
err = xml.NewDecoder(xmlReader).Decode(&f)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("Error to unmarshal: ", err.Error())
|
||||||
|
}
|
||||||
|
|
||||||
|
return ctx.JSON(200, f)
|
||||||
|
} else {
|
||||||
|
return routeutils.ResponseAPIOK(ctx, ret)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -10,6 +10,7 @@ import (
|
|||||||
"bitbucket.org/nemt/nemt-portal-api/infra/cache"
|
"bitbucket.org/nemt/nemt-portal-api/infra/cache"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/infra/config"
|
"bitbucket.org/nemt/nemt-portal-api/infra/config"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/server/router/routeutils"
|
"bitbucket.org/nemt/nemt-portal-api/server/router/routeutils"
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/server/authorization"
|
||||||
"github.com/labstack/echo"
|
"github.com/labstack/echo"
|
||||||
)
|
)
|
||||||
|
|
||||||
@@ -64,6 +65,11 @@ func (c *controller) handleAddOrganization(ctx echo.Context) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if !authorization.CanCreateOrganization(authUser, org) {
|
||||||
|
return routeutils.ResponseAPIAuthorizationError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
org.Author.ID = authUser.ID
|
org.Author.ID = authUser.ID
|
||||||
org.LastEditor.ID = authUser.ID
|
org.LastEditor.ID = authUser.ID
|
||||||
|
|
||||||
@@ -127,6 +133,15 @@ func (c *controller) handleParent(ctx echo.Context) error {
|
|||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
organization, err := c.svc.Organization.GetByUUID(orgUUID, authUser)
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !authorization.CanUpdateOrganization(authUser, organization){
|
||||||
|
return routeutils.ResponseAPIAuthorizationError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
resp, err := c.svc.Organization.SetParentOrganization(orgUUID, parent.UUID, authUser)
|
resp, err := c.svc.Organization.SetParentOrganization(orgUUID, parent.UUID, authUser)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
@@ -152,6 +167,15 @@ func (c *controller) handleChild(ctx echo.Context) error {
|
|||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
organization, err := c.svc.Organization.GetByUUID(orgUUID, authUser)
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !authorization.CanUpdateOrganization(authUser, organization){
|
||||||
|
return routeutils.ResponseAPIAuthorizationError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
_, err = c.svc.Organization.SetParentOrganization(child.UUID, orgUUID, authUser)
|
_, err = c.svc.Organization.SetParentOrganization(child.UUID, orgUUID, authUser)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
@@ -246,6 +270,18 @@ func (c *controller) handleAddAddress(ctx echo.Context) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
organization, err := c.svc.Organization.GetByUUID(orgUUID, authUser)
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !authorization.CanCreateAddress(authUser, organization) {
|
||||||
|
return routeutils.ResponseAPIAuthorizationError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
|
return routeutils.ResponseAPIAuthorizationError(ctx)
|
||||||
|
|
||||||
address.CreatedUser.ID = authUser.ID
|
address.CreatedUser.ID = authUser.ID
|
||||||
address.UpdatedUser.ID = authUser.ID
|
address.UpdatedUser.ID = authUser.ID
|
||||||
|
|
||||||
@@ -278,6 +314,7 @@ func (c *controller) handleRemoveContact(ctx echo.Context) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
contact.UpdatedUser.ID = authUser.ID
|
contact.UpdatedUser.ID = authUser.ID
|
||||||
|
|
||||||
err = c.svc.Organization.InactivateOrganizationContact(orgUUID, contact, authUser)
|
err = c.svc.Organization.InactivateOrganizationContact(orgUUID, contact, authUser)
|
||||||
@@ -309,6 +346,16 @@ func (c *controller) handleAddContact(ctx echo.Context) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
organization, err := c.svc.Organization.GetByUUID(orgUUID, authUser)
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !authorization.CanCreateContact(authUser, organization) {
|
||||||
|
return routeutils.ResponseAPIAuthorizationError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
contact.CreatedUser.ID = authUser.ID
|
contact.CreatedUser.ID = authUser.ID
|
||||||
contact.UpdatedUser.ID = authUser.ID
|
contact.UpdatedUser.ID = authUser.ID
|
||||||
|
|
||||||
|
|||||||
@@ -33,6 +33,18 @@ func ResponseAPIOK(c echo.Context, data interface{}) error {
|
|||||||
return c.JSON(http.StatusOK, data)
|
return c.JSON(http.StatusOK, data)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ResponseAPIErrorWithData returns a standard API error with additional data to the response
|
||||||
|
func ResponseAPIErrorWithData(c echo.Context, status int, message string, redirect bool, data interface{}) error {
|
||||||
|
returnValue := resultWrapper{
|
||||||
|
Error: true,
|
||||||
|
Message: message,
|
||||||
|
Redirect: redirect,
|
||||||
|
Data: data,
|
||||||
|
}
|
||||||
|
|
||||||
|
return c.JSON(status, returnValue)
|
||||||
|
}
|
||||||
|
|
||||||
// ResponseAPIError returns a standard API error to the response
|
// ResponseAPIError returns a standard API error to the response
|
||||||
func ResponseAPIError(c echo.Context, status int, message string, redirect bool) error {
|
func ResponseAPIError(c echo.Context, status int, message string, redirect bool) error {
|
||||||
returnValue := resultWrapper{
|
returnValue := resultWrapper{
|
||||||
@@ -49,6 +61,11 @@ func ResponseAPIAuthError(c echo.Context, message string, redirect bool) error {
|
|||||||
return ResponseAPIError(c, http.StatusUnauthorized, message, redirect)
|
return ResponseAPIError(c, http.StatusUnauthorized, message, redirect)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ResponseAPIAuthorizationError returns a standard API auth error to the response
|
||||||
|
func ResponseAPIAuthorizationError(c echo.Context) error {
|
||||||
|
return ResponseAPIError(c, http.StatusForbidden, "Forbidden by controller", false)
|
||||||
|
}
|
||||||
|
|
||||||
// ResponseAPIServiceError returns a standard API service unavailable error to the response
|
// ResponseAPIServiceError returns a standard API service unavailable error to the response
|
||||||
func ResponseAPIServiceError(c echo.Context, message string) error {
|
func ResponseAPIServiceError(c echo.Context, message string) error {
|
||||||
return ResponseAPIError(c, http.StatusServiceUnavailable, message, false)
|
return ResponseAPIError(c, http.StatusServiceUnavailable, message, false)
|
||||||
@@ -59,6 +76,11 @@ func ResponseAPIValidationError(c echo.Context, message string) error {
|
|||||||
return ResponseAPIError(c, http.StatusUnprocessableEntity, message, false)
|
return ResponseAPIError(c, http.StatusUnprocessableEntity, message, false)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ResponseAPICustomValidationError returns a standard API validation error with custom data to the response
|
||||||
|
func ResponseAPICustomValidationError(c echo.Context, message string, data interface{}) error {
|
||||||
|
return ResponseAPIErrorWithData(c, http.StatusUnprocessableEntity, message, false, data)
|
||||||
|
}
|
||||||
|
|
||||||
// ResponseAPIFieldValidationError returns a standard API field validation error to the response
|
// ResponseAPIFieldValidationError returns a standard API field validation error to the response
|
||||||
func ResponseAPIFieldValidationError(c echo.Context, field string, message string) error {
|
func ResponseAPIFieldValidationError(c echo.Context, field string, message string) error {
|
||||||
err := errors.NewValidationError(field, message)
|
err := errors.NewValidationError(field, message)
|
||||||
@@ -70,6 +92,11 @@ func ResponseAPINotFoundError(c echo.Context) error {
|
|||||||
return ResponseAPIError(c, http.StatusNotFound, "Not Found", false)
|
return ResponseAPIError(c, http.StatusNotFound, "Not Found", false)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//ResponseAPINotEligible returns a standard API not eligible to the response
|
||||||
|
func ResponseAPINotEligibleError(c echo.Context) error {
|
||||||
|
return ResponseAPIError(c, http.StatusForbidden, "Eligibility Not Found or Error", false)
|
||||||
|
}
|
||||||
|
|
||||||
func ignoreDefaultWrappedErrors(c echo.Context, errorToHandle *errors.WrappedError, handler func(echo.Context, error) error) error {
|
func ignoreDefaultWrappedErrors(c echo.Context, errorToHandle *errors.WrappedError, handler func(echo.Context, error) error) error {
|
||||||
err := errorToHandle.GetOriginalError()
|
err := errorToHandle.GetOriginalError()
|
||||||
|
|
||||||
|
|||||||
@@ -15,6 +15,7 @@ import (
|
|||||||
"bitbucket.org/nemt/nemt-portal-api/infra/auth"
|
"bitbucket.org/nemt/nemt-portal-api/infra/auth"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/infra/config"
|
"bitbucket.org/nemt/nemt-portal-api/infra/config"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/server/router/routeutils"
|
"bitbucket.org/nemt/nemt-portal-api/server/router/routeutils"
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/server/validation"
|
||||||
"github.com/labstack/echo"
|
"github.com/labstack/echo"
|
||||||
uuid "github.com/satori/go.uuid"
|
uuid "github.com/satori/go.uuid"
|
||||||
"google.golang.org/api/googleapi/transport"
|
"google.golang.org/api/googleapi/transport"
|
||||||
@@ -231,6 +232,11 @@ func (c *controller) handle(ctx echo.Context) error {
|
|||||||
return routeutils.ResponseAPIValidationError(ctx, "User not found")
|
return routeutils.ResponseAPIValidationError(ctx, "User not found")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//Validate ride request
|
||||||
|
if validationErrors := validation.ValidateRide(&requestRide, &user) ; len(validationErrors) > 0 {
|
||||||
|
return routeutils.ResponseAPICustomValidationError(ctx, "ride validation failed", validationErrors)
|
||||||
|
}
|
||||||
|
|
||||||
createdUser, err := auth.GetUserDetail(ctx, c.cfg)
|
createdUser, err := auth.GetUserDetail(ctx, c.cfg)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
|||||||
@@ -8,13 +8,18 @@ import (
|
|||||||
"time"
|
"time"
|
||||||
|
|
||||||
"bitbucket.org/nemt/nemt-portal-api/application/applicationservice"
|
"bitbucket.org/nemt/nemt-portal-api/application/applicationservice"
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/application/third/eligibility/bcbsi"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
"bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/domain"
|
"bitbucket.org/nemt/nemt-portal-api/domain"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/infra/auth"
|
"bitbucket.org/nemt/nemt-portal-api/infra/auth"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/infra/cache"
|
"bitbucket.org/nemt/nemt-portal-api/infra/cache"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/infra/config"
|
"bitbucket.org/nemt/nemt-portal-api/infra/config"
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/server/authorization"
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/server/validation"
|
||||||
"bitbucket.org/nemt/nemt-portal-api/server/router/routeutils"
|
"bitbucket.org/nemt/nemt-portal-api/server/router/routeutils"
|
||||||
"github.com/labstack/echo"
|
"github.com/labstack/echo"
|
||||||
|
"golang.org/x/net/context"
|
||||||
|
"googlemaps.github.io/maps"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
@@ -23,15 +28,17 @@ var (
|
|||||||
)
|
)
|
||||||
|
|
||||||
type controller struct {
|
type controller struct {
|
||||||
svc *applicationservice.Service
|
svc *applicationservice.Service
|
||||||
cfg *config.Config
|
cfg *config.Config
|
||||||
|
bcbsi *bcbsi.Service
|
||||||
}
|
}
|
||||||
|
|
||||||
func controllerInstance(svc *applicationservice.Service, cfg *config.Config) *controller {
|
func controllerInstance(svc *applicationservice.Service, cfg *config.Config) *controller {
|
||||||
once.Do(func() {
|
once.Do(func() {
|
||||||
instance = &controller{
|
instance = &controller{
|
||||||
svc: svc,
|
svc: svc,
|
||||||
cfg: cfg,
|
cfg: cfg,
|
||||||
|
bcbsi: bcbsi.New(cfg),
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
return instance
|
return instance
|
||||||
@@ -127,6 +134,62 @@ func (c *controller) handleRemoveAddress(ctx echo.Context) error {
|
|||||||
return routeutils.ResponseNoContent(ctx, addressID)
|
return routeutils.ResponseNoContent(ctx, addressID)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c *controller) handlePortalContact(ctx echo.Context) error {
|
||||||
|
userID, err := routeutils.GetAndValidateStringParam(ctx, "user_uuid", "mandatory field")
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
item, err := c.svc.Users.GetByUUID(userID, "")
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
createdUser, err := auth.GetUserDetail(ctx, c.cfg)
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
if item.ID == "" {
|
||||||
|
return routeutils.ResponseAPIValidationError(ctx, "User not found")
|
||||||
|
} else {
|
||||||
|
var Contact viewmodel.Contact
|
||||||
|
if err := ctx.Bind(&Contact); err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
Contact.User = item
|
||||||
|
Contact.Author = createdUser
|
||||||
|
Contact, err = c.svc.Users.SaveContact(Contact)
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Contact.User, err = c.svc.Users.GetByUUID(userID, "")
|
||||||
|
// if err != nil {
|
||||||
|
// return routeutils.HandleAPIError(ctx, err)
|
||||||
|
// }
|
||||||
|
|
||||||
|
return routeutils.ResponseAPIOK(ctx, Contact)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *controller) handleRemoveContact(ctx echo.Context) error {
|
||||||
|
contactUUID, err := routeutils.GetAndValidateStringParam(ctx, "contact_uuid", "mandatory field")
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
contact := viewmodel.Contact{
|
||||||
|
ID: contactUUID,
|
||||||
|
}
|
||||||
|
contact, err = c.svc.Users.RemoveContact(contact)
|
||||||
|
if err != nil {
|
||||||
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return routeutils.ResponseNoContent(ctx, contact)
|
||||||
|
}
|
||||||
|
|
||||||
func (c *controller) handleMemberAddress(ctx echo.Context) error {
|
func (c *controller) handleMemberAddress(ctx echo.Context) error {
|
||||||
userID, err := routeutils.GetAndValidateStringParam(ctx, "user_uuid", "mandatory field")
|
userID, err := routeutils.GetAndValidateStringParam(ctx, "user_uuid", "mandatory field")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -269,6 +332,7 @@ func (c *controller) handleGetPortal(ctx echo.Context) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (c *controller) handleMember(ctx echo.Context) error {
|
func (c *controller) handleMember(ctx echo.Context) error {
|
||||||
|
fmt.Println("\n\nHandle member\n\n")
|
||||||
var user viewmodel.User
|
var user viewmodel.User
|
||||||
if err := ctx.Bind(&user); err != nil {
|
if err := ctx.Bind(&user); err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
@@ -319,6 +383,66 @@ func (c *controller) handleMember(ctx echo.Context) error {
|
|||||||
}
|
}
|
||||||
user.Profiles = append(user.Profiles, profile)
|
user.Profiles = append(user.Profiles, profile)
|
||||||
|
|
||||||
|
eligibility := viewmodel.Eligibility{}
|
||||||
|
eligibility.Provider.ProviderNPI = "1699849786"
|
||||||
|
eligibility.Provider.ProviderName = "LITHOLINK CORPORATION"
|
||||||
|
eligibility.TrackingID = user.ID
|
||||||
|
eligibility.Subscriber.SubscriberID = *user.Member
|
||||||
|
eligibility.Subscriber.PatientType = "S"
|
||||||
|
eligibility.Subscriber.Name.First = user.First
|
||||||
|
eligibility.Subscriber.Name.Last = user.Last
|
||||||
|
eligibility.Subscriber.DemographicInfo.DateOfBirth = *user.BirthDate
|
||||||
|
eligibility.Subscriber.DemographicInfo.Gender = *user.Gender
|
||||||
|
eligibility.ServiceInfo.DateOfService = time.Now()
|
||||||
|
eligibility.ServiceInfo.ServiceTypeCodes = []string{"30"}
|
||||||
|
|
||||||
|
fmt.Println("\n\nGet271\n\n")
|
||||||
|
resp, err := c.bcbsi.BXE.Get271(eligibility)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("Eligibility Not Found or Error: ", err.Error())
|
||||||
|
return routeutils.ResponseAPINotEligibleError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
|
address := viewmodel.Address{}
|
||||||
|
header := resp.Division.HealthCareEligibilityResponse.LoopHL0030[0].HL_0460[0].HL_0890[0].NM1_0920[0].N3_0950
|
||||||
|
body := resp.Division.HealthCareEligibilityResponse.LoopHL0030[0].HL_0460[0].HL_0890[0].NM1_0920[0].N4_0960
|
||||||
|
|
||||||
|
address.AddressTypeName = "Home"
|
||||||
|
address.AddressType = "home"
|
||||||
|
address.Name = fmt.Sprintf("%s, %s", header.N301, body.N401)
|
||||||
|
address.Address = fmt.Sprintf("%s, %s", header.N301, body.N401)
|
||||||
|
address.CreatedUserUUID = authUser.ID
|
||||||
|
address.User = user
|
||||||
|
|
||||||
|
googleMapsAPI, err := maps.NewClient(maps.WithClientIDAndSignature("gme-bluecrossandblue1", "msqgD-jdqCyR0M_1u5C1HION5iI="))
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("Error to instantiate googles api: ", err.Error())
|
||||||
|
return routeutils.ResponseAPINotEligibleError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
|
r := &maps.GeocodingRequest{
|
||||||
|
Address: address.Address + " " + body.N402 + ", " + body.N403,
|
||||||
|
}
|
||||||
|
|
||||||
|
result, err := googleMapsAPI.Geocode(context.Background(), r)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("Error to instantiate googles api: ", err.Error())
|
||||||
|
return routeutils.ResponseAPINotEligibleError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(result) > 0 {
|
||||||
|
address.Latitude = result[0].Geometry.Location.Lat
|
||||||
|
address.Longitude = result[0].Geometry.Location.Lng
|
||||||
|
|
||||||
|
_, err := c.svc.Users.SaveAddress(address)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Println("Error to save address: ", err.Error())
|
||||||
|
return routeutils.ResponseAPINotEligibleError(ctx)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//Get ZIP code and check if it is participating
|
||||||
|
|
||||||
user, err = c.svc.Users.Create(user, authUser)
|
user, err = c.svc.Users.Create(user, authUser)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
@@ -389,6 +513,10 @@ func (c *controller) handlePortal(ctx echo.Context) error {
|
|||||||
return routeutils.HandleAPIError(ctx, err)
|
return routeutils.HandleAPIError(ctx, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if !authorization.CanCreateUser(authUser, user) {
|
||||||
|
return routeutils.ResponseAPIAuthorizationError(ctx)
|
||||||
|
}
|
||||||
|
|
||||||
if len(user.Profiles) == 0 {
|
if len(user.Profiles) == 0 {
|
||||||
return routeutils.ResponseAPIAuthError(ctx, "profile is required", false)
|
return routeutils.ResponseAPIAuthError(ctx, "profile is required", false)
|
||||||
}
|
}
|
||||||
@@ -411,6 +539,10 @@ func (c *controller) handlePortal(ctx echo.Context) error {
|
|||||||
}
|
}
|
||||||
user.Pass = string(pass)
|
user.Pass = string(pass)
|
||||||
|
|
||||||
|
if passwordValidationErrors := validation.ValidatePassword(&user) ; len(passwordValidationErrors) > 0 {
|
||||||
|
return routeutils.ResponseAPICustomValidationError(ctx, "Password not strong enough", passwordValidationErrors)
|
||||||
|
}
|
||||||
|
|
||||||
if len(user.Name) == 0 && len(user.First) == 0 && len(user.Last) == 0 {
|
if len(user.Name) == 0 && len(user.First) == 0 && len(user.Last) == 0 {
|
||||||
return routeutils.ResponseAPIAuthError(ctx, "name is required", false)
|
return routeutils.ResponseAPIAuthError(ctx, "name is required", false)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -17,6 +17,8 @@ const (
|
|||||||
userDetailRoute = "/portal/:user_uuid"
|
userDetailRoute = "/portal/:user_uuid"
|
||||||
userAddressRoute = "/portal/:user_uuid/address"
|
userAddressRoute = "/portal/:user_uuid/address"
|
||||||
userRemoveAddressRoute = "/portal/:user_uuid/address/:address_uuid"
|
userRemoveAddressRoute = "/portal/:user_uuid/address/:address_uuid"
|
||||||
|
userContactRoute = "/portal/:user_uuid/contact"
|
||||||
|
userRemoveContactRoute = "/portal/:user_uuid/contact/:contact_uuid"
|
||||||
portalRoute = "/portal"
|
portalRoute = "/portal"
|
||||||
portalBulkRoute = "/portal/bulk"
|
portalBulkRoute = "/portal/bulk"
|
||||||
contacttypeRoute = "/contacttype"
|
contacttypeRoute = "/contacttype"
|
||||||
@@ -41,6 +43,9 @@ func Register(r *echo.Group, cfg *config.Config, svc *applicationservice.Service
|
|||||||
r.POST(userAddressRoute, ctrl.handlePortalAddress)
|
r.POST(userAddressRoute, ctrl.handlePortalAddress)
|
||||||
r.PUT(userRemoveAddressRoute, ctrl.handleRemoveAddress)
|
r.PUT(userRemoveAddressRoute, ctrl.handleRemoveAddress)
|
||||||
|
|
||||||
|
r.POST(userContactRoute, ctrl.handlePortalContact)
|
||||||
|
r.PUT(userRemoveContactRoute, ctrl.handleRemoveContact)
|
||||||
|
|
||||||
//Can be cached
|
//Can be cached
|
||||||
r.GET(contacttypeRoute, ctrl.handleContactType)
|
r.GET(contacttypeRoute, ctrl.handleContactType)
|
||||||
|
|
||||||
|
|||||||
@@ -193,8 +193,6 @@ func (a *Config) objectRelation(object interface{}, currentUser viewmodel.User)
|
|||||||
case viewmodel.User:
|
case viewmodel.User:
|
||||||
if obj.ID == currentUser.ID {
|
if obj.ID == currentUser.ID {
|
||||||
return "[self]"
|
return "[self]"
|
||||||
} else {
|
|
||||||
return "[other]"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return "[other]"
|
return "[other]"
|
||||||
|
|||||||
183
server/validation/tnc.go
Normal file
183
server/validation/tnc.go
Normal file
@@ -0,0 +1,183 @@
|
|||||||
|
package validation
|
||||||
|
|
||||||
|
import (
|
||||||
|
|
||||||
|
"time"
|
||||||
|
"fmt"
|
||||||
|
"strconv"
|
||||||
|
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/infra/errors"
|
||||||
|
|
||||||
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
tripTypeFromVisit = "From Visit"
|
||||||
|
tripTypeToVisit = "To Visit"
|
||||||
|
tripTypeFromVisitWillCall = "From Visit / Will Call"
|
||||||
|
tripTypeRoundTrip = "Round Trip"
|
||||||
|
tripTypeRountTripWillCall = "Round Trip / Will Call"
|
||||||
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
loadingTime = 30 //in minutes
|
||||||
|
minimumLoadTime = 30 //in minutes
|
||||||
|
minimumPickupTime = 10 //in minutes
|
||||||
|
)
|
||||||
|
|
||||||
|
const (
|
||||||
|
hoursInDay = 24
|
||||||
|
hoursIn180Days = 24*180
|
||||||
|
time8Hours = 8
|
||||||
|
time10Minutes = 10
|
||||||
|
)
|
||||||
|
|
||||||
|
func ValidateRide(requestRide *viewmodel.RideRequest, user *viewmodel.User) []errors.ValidationError {
|
||||||
|
var result []errors.ValidationError
|
||||||
|
|
||||||
|
//Step #1 validation
|
||||||
|
|
||||||
|
if userID, err := strconv.Atoi(user.ID) ; err != nil || userID <= 0 {
|
||||||
|
result = append(result, errors.ValidationError{Field : "user_uuid", Message : "Step #1 - Choose a Member" })
|
||||||
|
}
|
||||||
|
|
||||||
|
if originID, err := strconv.Atoi(requestRide.Origin.ID) ; err != nil || originID <= 0 {
|
||||||
|
result = append (result, errors.ValidationError{Field : "origin.id", Message : "Step #1 - Choose a Pickup Address"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if !requestRide.UserConsent {
|
||||||
|
result = append (result, errors.ValidationError{Field : "user_consent", Message : "Step #1 - Member must consent to Terms of Use"})
|
||||||
|
}
|
||||||
|
|
||||||
|
//Step #2 validation
|
||||||
|
|
||||||
|
if destinationID, err := strconv.Atoi(requestRide.Destination.ID) ; err!= nil || destinationID <= 0 {
|
||||||
|
result = append (result, errors.ValidationError{Field : "destination.id", Message : "Step #2 - Choose a Provider"})
|
||||||
|
}
|
||||||
|
|
||||||
|
//Step #3 validation
|
||||||
|
|
||||||
|
isVisitDayToday := requestRide.VisitDate.Day() == time.Now().Day() && requestRide.VisitDate.Month() == time.Now().Month() && requestRide.VisitDate.Year() == time.Now().Year()
|
||||||
|
before8Hours := time.Now().Add(-time.Hour*time8Hours)
|
||||||
|
|
||||||
|
if requestRide.VisitDate == nil {
|
||||||
|
result = append (result, errors.ValidationError{Field : "visit_date", Message : "Step #3 - Choose a Date for the Visit"})
|
||||||
|
}else{
|
||||||
|
dayBeforeToday := time.Now().Add(-time.Hour*hoursInDay)
|
||||||
|
if requestRide.VisitDate.Before(dayBeforeToday) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "visit_date", Message : "Step #3 - Visit cannot occur more than one day before today"})
|
||||||
|
}
|
||||||
|
|
||||||
|
dayAfter180Days := time.Now().Add(time.Hour*hoursIn180Days)
|
||||||
|
if requestRide.VisitDate.After(dayAfter180Days) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "visit_date", Message : "Step #3 - Visit cannot occur more than 180 days after today"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if requestRide.VisitTime == nil {
|
||||||
|
result = append (result, errors.ValidationError{Field : "visit_time", Message : "Step #3 - Choose a Time for the Visit"})
|
||||||
|
}else{
|
||||||
|
if isVisitDayToday && requestRide.VisitTime.Before(before8Hours) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "visit_time", Message : "Step #3 - Visit is more than 8 hours in the past"})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//Step #4 validation
|
||||||
|
|
||||||
|
if requestRide.TripType.Value == "" {
|
||||||
|
result = append (result, errors.ValidationError{Field : "trip_type.value", Message : "Step #4 - Choose a Trip Type"})
|
||||||
|
}
|
||||||
|
|
||||||
|
timeWithDurationAndLoadingTime := requestRide.VisitTime.Add(-time.Duration(requestRide.Duration)*time.Second).Add(-loadingTime*time.Minute)
|
||||||
|
after10Minutes := time.Now().Add(time.Minute*time10Minutes)
|
||||||
|
|
||||||
|
switch requestRide.TripType.Value {
|
||||||
|
case tripTypeToVisit:
|
||||||
|
if requestRide.PickupTime == nil {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Choose a Pickup Time"})
|
||||||
|
}else{
|
||||||
|
if requestRide.PickupTime.After(*requestRide.VisitTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time must occur before Visit Time"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if requestRide.PickupTime.After(timeWithDurationAndLoadingTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time less than required time before Visit Time"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if isVisitDayToday && requestRide.PickupTime.Before(before8Hours) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Visit cannot occour in the past"})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
case tripTypeFromVisit :
|
||||||
|
if requestRide.PickupTime == nil {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Choose a Pickup Time"})
|
||||||
|
}else{
|
||||||
|
timeWithMinimumPickupTime := time.Now().Add(minimumPickupTime*time.Minute)
|
||||||
|
if isVisitDayToday && requestRide.PickupTime.Before(timeWithMinimumPickupTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : fmt.Sprint("Step #4 - Time must be more than %d minutes from now",minimumPickupTime)})
|
||||||
|
}
|
||||||
|
|
||||||
|
if requestRide.PickupTime.Before(*requestRide.VisitTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time less than required time after Visit Time"})
|
||||||
|
}
|
||||||
|
|
||||||
|
timeWithMinimumLoadTime := time.Now().Add(minimumLoadTime*time.Minute)
|
||||||
|
if requestRide.PickupTime.Before(timeWithMinimumLoadTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time less than Minimum Load Time before Visit Time"})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
case tripTypeFromVisitWillCall:
|
||||||
|
//no special validation for this case
|
||||||
|
|
||||||
|
case tripTypeRoundTrip:
|
||||||
|
if requestRide.PickupTime == nil {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Choose a Pickup Time"})
|
||||||
|
}else{
|
||||||
|
if requestRide.PickupTime.After(*requestRide.VisitTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time must occur before Visit Time"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if requestRide.PickupTime.After(timeWithDurationAndLoadingTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time less than required time before Visit Time"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if isVisitDayToday && requestRide.PickupTime.Before(after10Minutes) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time must be at least 10 minutes from now"})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if requestRide.ReturnTime == nil {
|
||||||
|
result = append (result, errors.ValidationError{Field : "return_time", Message : "Step #4 - Choose a Pickup Time"})
|
||||||
|
}else{
|
||||||
|
if isVisitDayToday {
|
||||||
|
if requestRide.ReturnTime.Before(before8Hours) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "return_time", Message : "Step #4 - Return Time is more than 8 hours after Visit Time"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if requestRide.ReturnTime.Before(after10Minutes) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "return_time", Message : "Step #4 - Return Time must be at least 10 minutes from now"})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
case tripTypeRountTripWillCall:
|
||||||
|
if requestRide.PickupTime == nil {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Choose a Pickup Time"})
|
||||||
|
}else{
|
||||||
|
if requestRide.PickupTime.After(*requestRide.VisitTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time must occur before Visit Time"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if requestRide.PickupTime.After(timeWithDurationAndLoadingTime) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Pickup Time less than required time after Visit Time"})
|
||||||
|
}
|
||||||
|
|
||||||
|
if isVisitDayToday && requestRide.PickupTime.Before(before8Hours) {
|
||||||
|
result = append (result, errors.ValidationError{Field : "pickup_time", Message : "Step #4 - Visit cannot occur in the past "})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return result
|
||||||
|
}
|
||||||
67
server/validation/user.go
Normal file
67
server/validation/user.go
Normal file
@@ -0,0 +1,67 @@
|
|||||||
|
package validation
|
||||||
|
|
||||||
|
import (
|
||||||
|
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/application/viewmodel"
|
||||||
|
"bitbucket.org/nemt/nemt-portal-api/infra/errors"
|
||||||
|
|
||||||
|
)
|
||||||
|
|
||||||
|
func characterIsUpperCase(character rune) bool {
|
||||||
|
return (character >= 65) && (character <= 90)
|
||||||
|
}
|
||||||
|
|
||||||
|
func characterIsLowerCase(character rune) bool {
|
||||||
|
return (character >= 97) && (character <= 122)
|
||||||
|
}
|
||||||
|
|
||||||
|
func characterIsNumber(character rune) bool {
|
||||||
|
return (character >= 48) && (character <= 57)
|
||||||
|
}
|
||||||
|
|
||||||
|
func ValidatePassword(user *viewmodel.User) []errors.ValidationError {
|
||||||
|
var result []errors.ValidationError
|
||||||
|
|
||||||
|
userOrganizationName := ""
|
||||||
|
if len(user.Organizations) > 0{
|
||||||
|
userOrganizationName = user.Organizations[0].Name
|
||||||
|
}
|
||||||
|
|
||||||
|
if (len(user.Pass) < 8) {
|
||||||
|
result = append(result, errors.ValidationError{Field : "password", Message : "Password must be at least 8 characters."})
|
||||||
|
}
|
||||||
|
|
||||||
|
if (strings.Contains(user.Pass, user.First)){
|
||||||
|
result = append(result, errors.ValidationError{Field : "password", Message : "Password cannot include your First Name."})
|
||||||
|
}
|
||||||
|
|
||||||
|
if (strings.Contains(user.Pass, user.Last)){
|
||||||
|
result = append(result, errors.ValidationError{Field : "password", Message : "Password cannot include your Last Name."})
|
||||||
|
}
|
||||||
|
|
||||||
|
if (strings.Contains(user.Pass, userOrganizationName)){
|
||||||
|
result = append(result, errors.ValidationError{Field : "password", Message : "Password cannot include your Organization Name."})
|
||||||
|
}
|
||||||
|
|
||||||
|
containsUpperCaseLetter := false;
|
||||||
|
containsLowerCaseLetter := false;
|
||||||
|
containsNumber := false;
|
||||||
|
|
||||||
|
for _, character := range user.Pass {
|
||||||
|
containsUpperCaseLetter = containsUpperCaseLetter || characterIsUpperCase(character)
|
||||||
|
containsLowerCaseLetter = containsLowerCaseLetter || characterIsLowerCase(character)
|
||||||
|
containsNumber = containsNumber || characterIsNumber(character)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !containsUpperCaseLetter || !containsLowerCaseLetter || !containsNumber {
|
||||||
|
result = append(result, errors.ValidationError{Field : "password", Message : "Password must contain one of EACH :"})
|
||||||
|
result = append(result, errors.ValidationError{Field : "password-tab", Message : "an uppercase letter"})
|
||||||
|
result = append(result, errors.ValidationError{Field : "password-tab", Message : "a lowercase letter"})
|
||||||
|
result = append(result, errors.ValidationError{Field : "password-tab", Message : "a number"})
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
return result
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user