Compare commits

...

3 Commits

@ -423,20 +423,22 @@ class Customer extends ApiCommon
# 消息数据 # 消息数据
$message = []; $message = [];
# 获取公海规则数据
$customerPoolData = db('crm_customer_pool')->where('pool_id=' . $poolId)->column(['customer_type']);
$customerTypeArray = explode(',', $customerPoolData[0]);
# 获取客户数据 # 获取客户数据
$customerData = []; $customerData = [];
$customerList = db('crm_customer')->field(['customer_id', 'owner_user_id', 'name', 'crm_lthugd'])->whereIn('customer_id', $customerIds)->select(); $customerList = db('crm_customer')->field(['customer_id', 'owner_user_id', 'name', 'crm_lthugd'])->whereIn('customer_id', $customerIds)->select();
foreach ($customerList as $key => $value) {
$customerData[$value['customer_id']] = $value;
}
# 获取公海规则数据
$customerPoolData = db('crm_customer_pool')->field(['customer_type'])->where('pool_id=' . $poolId)->find();
# 判断客户类型是否符合公海池客户类型 foreach ($customerList as $key => $value) {
if (!in_array($customerData['crm_lthugd'], $customerPoolData)) { # 判断客户类型是否符合公海池客户类型
$message[] = '客户类型与公海池类型不匹配!'; if (!in_array($value['crm_lthugd'], $customerTypeArray)) {
return resultArray(['error' => $message]); $message[] = '客户类型与公海池类型不匹配!';
return resultArray(['error' => $message]);
}
$customerData[$value['customer_id']] = $value;
} }

Loading…
Cancel
Save