TonisOrmisson /
yii2-survey-base-models
| 1 | <?php |
||||
| 2 | |||||
| 3 | namespace andmemasin\surveybasemodels; |
||||
| 4 | |||||
| 5 | use andmemasin\myabstract\MyActiveRecord; |
||||
| 6 | use PascalDeVink\ShortUuid\ShortUuid; |
||||
| 7 | use Ramsey\Uuid\Uuid; |
||||
| 8 | use yii; |
||||
| 9 | |||||
| 10 | /** |
||||
| 11 | * This is the model class for a generic Respondent. |
||||
| 12 | * |
||||
| 13 | * @property int $respondent_id |
||||
| 14 | * @property int $survey_id |
||||
| 15 | * @property string $token |
||||
| 16 | * @property Survey $survey |
||||
| 17 | * @property string $email_address |
||||
| 18 | * @property string $alternative_email_addresses Inserted as CSV, stored as JSON |
||||
| 19 | * @property string $phone_number |
||||
| 20 | * @property string $alternative_phone_numbers Inserted as CSV, stored as JSON |
||||
| 21 | * |
||||
| 22 | * @property boolean $isRejected |
||||
| 23 | * @property string $shortToken If the token is uuid, then short-uuid will be returned |
||||
| 24 | */ |
||||
| 25 | class Respondent extends MyActiveRecord |
||||
| 26 | { |
||||
| 27 | const MAX_ALTERNATIVE_CONTACTS = 20; |
||||
| 28 | /** @var bool $checkDSNForEmails whether email validation also used DSN records to check if domain exists */ |
||||
| 29 | public static $checkDSNForEmails = true; |
||||
| 30 | |||||
| 31 | /** |
||||
| 32 | * @var array $surveyIdentifyingColumns names of the columns that identify a respondent as unique inside a survey |
||||
| 33 | */ |
||||
| 34 | public static $surveyIdentifyingColumns = ['phone_number','email_address']; |
||||
| 35 | |||||
| 36 | public function init() |
||||
| 37 | { |
||||
| 38 | parent::init(); |
||||
| 39 | } |
||||
| 40 | |||||
| 41 | |||||
| 42 | /** |
||||
| 43 | * {@inheritdoc} |
||||
| 44 | */ |
||||
| 45 | public function rules() |
||||
| 46 | { |
||||
| 47 | return array_merge([ |
||||
| 48 | [['survey_id','token'], 'required'], |
||||
| 49 | [['survey_id'], 'integer'], |
||||
| 50 | [['email_address'], 'validateEmail'], |
||||
| 51 | // email addresses always lowercase |
||||
| 52 | [['email_address','email_address'],'trim'], |
||||
| 53 | ['email_address','filter', 'filter' => 'strtolower'], |
||||
| 54 | [['alternative_email_addresses'], 'string'], |
||||
| 55 | [['alternative_email_addresses'], 'validateMultipleEmails'], |
||||
| 56 | [['phone_number','email_address'],'trim'], |
||||
| 57 | ['phone_number','filter', 'filter' => 'strtolower'], |
||||
| 58 | [['phone_number'],'string'], |
||||
| 59 | [['phone_number'],'validatePhoneNumber'], |
||||
| 60 | [['alternative_phone_numbers'], 'string'], |
||||
| 61 | [['alternative_phone_numbers'],'validateMultiplePhoneNumbers'], |
||||
| 62 | [['token'], 'unique'], |
||||
| 63 | ], parent::rules()); |
||||
| 64 | } |
||||
| 65 | |||||
| 66 | |||||
| 67 | |||||
| 68 | /** |
||||
| 69 | * @param string $attribute |
||||
| 70 | * @param string $address |
||||
| 71 | * @return bool |
||||
| 72 | */ |
||||
| 73 | public function validateEmail($attribute,$address = null){ |
||||
| 74 | |||||
| 75 | if($this->validateEmailFormat($attribute, $address) |
||||
| 76 | && !$this->isSameAsMainAddress($attribute, $address) |
||||
| 77 | && !$this->isEmailSurveyDuplicate($attribute, $address)){ |
||||
| 78 | return true; |
||||
| 79 | } |
||||
| 80 | return false; |
||||
| 81 | } |
||||
| 82 | |||||
| 83 | /** |
||||
| 84 | * @param string $attribute |
||||
| 85 | * @param string $address |
||||
| 86 | * @return bool |
||||
| 87 | */ |
||||
| 88 | private function validateEmailFormat($attribute, $address = null) |
||||
| 89 | { |
||||
| 90 | $validator = new yii\validators\EmailValidator(); |
||||
| 91 | $validator->checkDNS = static::$checkDSNForEmails; |
||||
| 92 | if (!$validator->validate($address)) { |
||||
| 93 | $this->addError($attribute, |
||||
| 94 | Yii::t('app', |
||||
| 95 | 'Invalid email address "{0}"',[$address] |
||||
| 96 | ).' '.Yii::t('app','Reason: {0}',[Yii::t('app','Invalid email format')]) |
||||
| 97 | ); |
||||
| 98 | return false; |
||||
| 99 | } |
||||
| 100 | return true; |
||||
| 101 | } |
||||
| 102 | |||||
| 103 | /** |
||||
| 104 | * @param string $attribute |
||||
| 105 | * @param string $address |
||||
| 106 | * @return bool |
||||
| 107 | */ |
||||
| 108 | private function isSameAsMainAddress($attribute, $address = null) |
||||
| 109 | { |
||||
| 110 | if(!$address or empty($address)){ |
||||
| 111 | return false; |
||||
| 112 | } |
||||
| 113 | $isSame = ($attribute=='email_address' ? false : $address == $this->email_address); |
||||
| 114 | if ($isSame) { |
||||
| 115 | $this->addError($attribute, |
||||
| 116 | Yii::t('app', |
||||
| 117 | 'Invalid email address "{0}"',[$address] |
||||
| 118 | ).' '.Yii::t('app','Reason: {0}',[Yii::t('app',$attribute. ' duplicates main address')]) |
||||
| 119 | ); |
||||
| 120 | } |
||||
| 121 | return $isSame; |
||||
| 122 | } |
||||
| 123 | |||||
| 124 | |||||
| 125 | public function validateMultipleEmails($attribute){ |
||||
| 126 | $addresses = yii\helpers\Json::decode($this->alternative_email_addresses); |
||||
| 127 | if($this->alternative_email_addresses && !empty($addresses)){ |
||||
| 128 | $cleanAddresses = []; |
||||
| 129 | if(!empty($addresses)){ |
||||
| 130 | $i=0; |
||||
| 131 | foreach ($addresses as $key => $address){ |
||||
| 132 | if($address <> ""){ |
||||
| 133 | // check the alternative numbers of that model for duplicates |
||||
| 134 | $checkItems = $addresses; |
||||
| 135 | unset($checkItems[$key]); |
||||
| 136 | if(in_array($address,$checkItems)){ |
||||
| 137 | $this->addError($attribute,Yii::t('app','Duplicate email in alternative email addresses')); |
||||
| 138 | } |
||||
| 139 | |||||
| 140 | $i++; |
||||
| 141 | if($i>=static::MAX_ALTERNATIVE_CONTACTS){ |
||||
| 142 | $this->addError($attribute,Yii::t('app','Maximum alternative addresses limit ({0}) reached for {1}',[static::MAX_ALTERNATIVE_CONTACTS,$this->email_address])); |
||||
| 143 | } |
||||
| 144 | $address = strtolower(trim($address)); |
||||
| 145 | if($this->validateEmail($attribute,$address)){ |
||||
| 146 | $cleanAddresses[]=$address; |
||||
| 147 | } |
||||
| 148 | } |
||||
| 149 | |||||
| 150 | } |
||||
| 151 | if(!empty($cleanAddresses)){ |
||||
| 152 | $this->alternative_email_addresses = yii\helpers\Json::encode($cleanAddresses); |
||||
| 153 | } else { |
||||
| 154 | $this->alternative_email_addresses = null; |
||||
| 155 | } |
||||
| 156 | } |
||||
| 157 | } |
||||
| 158 | } |
||||
| 159 | |||||
| 160 | |||||
| 161 | public function validatePhoneNumber($attribute, $phone_number = null){ |
||||
| 162 | $this->validateSameAsMainNumber($attribute, $phone_number); |
||||
| 163 | // TODO |
||||
| 164 | $isValidFormat = true; |
||||
|
0 ignored issues
–
show
Unused Code
introduced
by
Loading history...
|
|||||
| 165 | $this->validatePhoneSurveyDuplicate($attribute, $phone_number); |
||||
| 166 | } |
||||
| 167 | |||||
| 168 | public function validateMultiplePhoneNumbers($attribute){ |
||||
| 169 | if($this->alternative_phone_numbers){ |
||||
| 170 | $cleanItems = []; |
||||
|
0 ignored issues
–
show
|
|||||
| 171 | $items = yii\helpers\Json::decode($this->alternative_phone_numbers); |
||||
| 172 | |||||
| 173 | if (!empty($items)) { |
||||
| 174 | $i=0; |
||||
| 175 | foreach ($items as $key=> $item){ |
||||
| 176 | $item = strtolower(trim($item)); |
||||
| 177 | if ($item <> '') { |
||||
| 178 | $i++; |
||||
| 179 | $this->validateAlternativePhoneNumberInternalDuplicates($attribute, $item, $key); |
||||
| 180 | |||||
| 181 | if( $i >= static::MAX_ALTERNATIVE_CONTACTS){ |
||||
| 182 | $this->addError($attribute, Yii::t('app','Maximum alternative phone numbers limit ({0}) reached for {1}',[static::MAX_ALTERNATIVE_CONTACTS,$this->phone_number])); |
||||
| 183 | } |
||||
| 184 | |||||
| 185 | $this->validatePhoneNumber($attribute, $item); |
||||
| 186 | } |
||||
| 187 | } |
||||
| 188 | } |
||||
| 189 | } |
||||
| 190 | } |
||||
| 191 | |||||
| 192 | private function validateAlternativePhoneNumberInternalDuplicates($attribute, $number, $key) { |
||||
| 193 | $items = yii\helpers\Json::decode($this->alternative_phone_numbers); |
||||
| 194 | $checkItems = $items; |
||||
| 195 | unset($checkItems[$key]); |
||||
| 196 | if (in_array($number, $checkItems)) { |
||||
|
0 ignored issues
–
show
It seems like
$checkItems can also be of type null; however, parameter $haystack of in_array() does only seem to accept array, maybe add an additional type check?
(
Ignorable by Annotation
)
If this is a false-positive, you can also ignore this issue in your code via the
Loading history...
|
|||||
| 197 | $this->addError($attribute, Yii::t('app','Duplicate number in alternative phone numbers')); |
||||
| 198 | } |
||||
| 199 | } |
||||
| 200 | |||||
| 201 | |||||
| 202 | |||||
| 203 | /** |
||||
| 204 | * @param string $attribute |
||||
| 205 | * @param string $number |
||||
| 206 | * @return null |
||||
| 207 | */ |
||||
| 208 | private function validateSameAsMainNumber($attribute, $number = null) |
||||
| 209 | { |
||||
| 210 | if (!$number or empty($number)) { |
||||
| 211 | return null; |
||||
| 212 | } |
||||
| 213 | |||||
| 214 | $isSame = ($attribute=='phone_number' ? false : $number == $this->phone_number); |
||||
| 215 | |||||
| 216 | if ($isSame) { |
||||
| 217 | $this->addError($attribute, |
||||
| 218 | Yii::t('app', |
||||
| 219 | 'Invalid phone number "{0}"',[$number] |
||||
| 220 | ).' '.Yii::t('app','Reason: {0}',[Yii::t('app',$attribute. ' duplicates main phone number')]) |
||||
| 221 | ); |
||||
| 222 | } |
||||
| 223 | return null; |
||||
| 224 | } |
||||
| 225 | |||||
| 226 | |||||
| 227 | /** |
||||
| 228 | * @param string $attribute |
||||
| 229 | * @param string $phone_number Phone number to check duplicates for |
||||
| 230 | */ |
||||
| 231 | private function validatePhoneSurveyDuplicate($attribute, $phone_number){ |
||||
| 232 | $query = static::find(); |
||||
| 233 | // check only this survey |
||||
| 234 | $query->andWhere(['survey_id'=>$this->survey_id]); |
||||
| 235 | |||||
| 236 | if ($this->respondent_id) { |
||||
| 237 | // not itself |
||||
| 238 | $query->andWhere(['!=','respondent_id',$this->respondent_id]); |
||||
| 239 | } |
||||
| 240 | |||||
| 241 | $condition = ['or', |
||||
| 242 | '`phone_number`=:phone_number', |
||||
| 243 | '`alternative_phone_numbers` LIKE :phone_number2', |
||||
| 244 | ]; |
||||
| 245 | |||||
| 246 | $query->andWhere($condition,[':phone_number'=>$phone_number,':phone_number2'=>'%\"'.$phone_number.'\"%']); |
||||
| 247 | |||||
| 248 | if ($query->count() > 0) { |
||||
| 249 | $this->addError($attribute, |
||||
| 250 | Yii::t('app', |
||||
| 251 | 'Invalid phone number "{0}"',[$phone_number] |
||||
| 252 | ).' '.Yii::t('app','Reason: {0}',[Yii::t('app','Duplicate phone number')]) |
||||
| 253 | ); |
||||
| 254 | } |
||||
| 255 | } |
||||
| 256 | |||||
| 257 | |||||
| 258 | /** |
||||
| 259 | * @param string $email_address Email address to check duplicates for |
||||
| 260 | * @return bool |
||||
| 261 | */ |
||||
| 262 | public function isEmailSurveyDuplicate($attribute, $email_address){ |
||||
| 263 | $query = static::find(); |
||||
| 264 | // check only this survey |
||||
| 265 | $query->andWhere(['survey_id'=>$this->survey_id]); |
||||
| 266 | // not itself |
||||
| 267 | if($this->respondent_id){ |
||||
| 268 | // not itself |
||||
| 269 | $query->andWhere(['!=','respondent_id',$this->respondent_id]); |
||||
| 270 | } |
||||
| 271 | |||||
| 272 | $email_condition = ['or', |
||||
| 273 | '`email_address`=:email_address', |
||||
| 274 | '`alternative_email_addresses` LIKE :email_address2', |
||||
| 275 | ]; |
||||
| 276 | $query->andWhere($email_condition,[':email_address'=>$email_address,':email_address2'=>'%\"'.$email_address.'\"%']); |
||||
| 277 | if($query->count() > 0){ |
||||
| 278 | return true; |
||||
| 279 | } |
||||
| 280 | |||||
| 281 | $this->addError($attribute, |
||||
| 282 | Yii::t('app', |
||||
| 283 | 'Invalid email address "{0}"',[$email_address] |
||||
| 284 | ).' '.Yii::t('app','Reason: {0}',[Yii::t('app','Duplicates some other address')]) |
||||
| 285 | ); |
||||
| 286 | |||||
| 287 | return false; |
||||
| 288 | } |
||||
| 289 | |||||
| 290 | /** |
||||
| 291 | * {@inheritdoc} |
||||
| 292 | */ |
||||
| 293 | public function attributeLabels() |
||||
| 294 | { |
||||
| 295 | return [ |
||||
| 296 | 'token' => Yii::t('app', 'Unique Token'), |
||||
| 297 | ]; |
||||
| 298 | } |
||||
| 299 | |||||
| 300 | /** |
||||
| 301 | * @param string $token Respondents token |
||||
| 302 | * @return static |
||||
| 303 | */ |
||||
| 304 | public static function findByToken($token = null){ |
||||
| 305 | if($token){ |
||||
| 306 | $models = self::findByTokens([$token]); |
||||
| 307 | if (!empty($models)){ |
||||
| 308 | return $models[0]; |
||||
| 309 | } |
||||
| 310 | } |
||||
| 311 | return null; |
||||
| 312 | } |
||||
| 313 | |||||
| 314 | /** |
||||
| 315 | * @param string[] $tokens Respondents tokens |
||||
| 316 | * @return static[] |
||||
| 317 | */ |
||||
| 318 | public static function findByTokens($tokens){ |
||||
| 319 | /** @var static[] $model */ |
||||
| 320 | $models = static::find() |
||||
| 321 | ->andWhere(['in','token', $tokens]) |
||||
| 322 | ->all(); |
||||
| 323 | return $models; |
||||
| 324 | } |
||||
| 325 | |||||
| 326 | /** |
||||
| 327 | * Check whether respondent has rejected this specific survey or has a hard bounce on e_mail address |
||||
| 328 | * @return bool |
||||
| 329 | */ |
||||
| 330 | public function getIsRejected(){ |
||||
| 331 | if (Rejection::rejectedByCode($this->token)) { |
||||
| 332 | return true; |
||||
| 333 | } |
||||
| 334 | |||||
| 335 | if (Rejection::bouncedByEmailAddress($this->email_address)) { |
||||
| 336 | return true; |
||||
| 337 | } |
||||
| 338 | |||||
| 339 | return false; |
||||
| 340 | } |
||||
| 341 | |||||
| 342 | /** |
||||
| 343 | * Get the last respondent based on Email-address |
||||
| 344 | * @param string $email_address |
||||
| 345 | * @return static |
||||
| 346 | */ |
||||
| 347 | public static function getLatestByEmail($email_address){ |
||||
| 348 | /** @var static $model */ |
||||
| 349 | $model = static::find() |
||||
| 350 | ->andWhere(['email_address'=>$email_address]) |
||||
| 351 | ->orderBy([static::primaryKey()[0]=>SORT_DESC]) |
||||
| 352 | ->one(); |
||||
| 353 | return $model; |
||||
| 354 | } |
||||
| 355 | |||||
| 356 | /** |
||||
| 357 | * @return string |
||||
| 358 | */ |
||||
| 359 | public function getShortToken(){ |
||||
| 360 | if (Uuid::isValid($this->token)) { |
||||
| 361 | $uuid = Uuid::fromString($this->token); |
||||
| 362 | $shotUuid = new ShortUuid(); |
||||
| 363 | return $shotUuid->encode($uuid); |
||||
| 364 | } |
||||
| 365 | return $this->token; |
||||
| 366 | } |
||||
| 367 | |||||
| 368 | |||||
| 369 | } |