123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181 |
- <?php
- namespace addons\qingdongams\model;
- use think\Exception;
- use think\Model;
- use traits\model\SoftDelete;
- /**
- *联系人表
- */
- class Contacts Extends Model {
- use SoftDelete;
- // 表名,不含前缀
- protected $name = 'qingdongams_contacts';
- // 开启自动写入时间戳字段
- protected $autoWriteTimestamp = 'int';
- // 定义时间戳字段名
- protected $createTime = 'createtime';
- protected $updateTime = 'updatetime';
- protected $deleteTime = 'deletetime';
- protected $field = true;
- //客户
- public function customer() {
- return $this->hasOne(Customer::class, 'id', 'customer_id')->field('id,name,follow');
- }
- //负责人
- public function ownerStaff() {
- return $this->hasOne(Staff::class, 'id', 'owner_staff_id')->field('id,name');
- }
- /**
- *
- */
- public static function getList() {
- return self::where(['owner_staff_id'=>['in',Staff::getMyStaffIds()]])->field('id,name')->select();
- }
- //创建联系人
- public static function createContacts($params) {
- //自定义字段
- $other = [];
- foreach ($params as $name => $val) {
- if (strstr( $name,'other_') !== false) {
- if(is_array($val)){
- $other[$name] = implode(',',$val);
- }else{
- $other[$name] = $val;
- }
- unset($params[$name]);
- }else{
- if(empty($params[$name])){
- $params[$name]=NULL;
- }
- }
- }
- $staff = Staff::info();
- if($staff){
- $params['create_staff_id'] = $staff->id;
- $owner_staff_id = $staff->id;
- if($params['customer_id']){
- $owner_staff_id = Customer::where(array('id'=>$params['customer_id']))->value('owner_staff_id');
- }
- $params['owner_staff_id'] = $owner_staff_id;
- }
- $model = new self;
- $result = $model->allowField(true)->save($params);
- if (false === $result) {
- // 验证失败 输出错误信息
- throw new Exception($model->getError());
- }
- $lastId=$model->getLastInsID();
- $otherModel = new ContactsOther();
- if ($otherModel->save(['id' => $lastId, 'otherdata' => json_encode($other, JSON_UNESCAPED_UNICODE)]) === false) {
- // 验证失败 输出错误信息
- throw new Exception($otherModel->getError());
- }
- //创建日志
- OperationLog::createLog(OperationLog::CONTACTS_TYPE,$lastId, '创建联系人');
- //新增跟进记录
- Record::quickCreateRecord(Record::CUSTOMER_TYPE, $params['customer_id'], '新增联系人:' . $params['name']);
- OperationLog::createLog(OperationLog::CUSTOMER_TYPE, $params['customer_id'], '新增联系人:' . $params['name']);
- return $lastId;
- }
- //修改联系人
- public static function updateContacts($params) {
- //自定义字段
- $other = [];
- foreach ($params as $name => $val) {
- if (strstr($name,'other_') !== false) {
- if(is_array($val)){
- $other[$name] = implode(',',$val);
- }else{
- $other[$name] = $val;
- }
- unset($params[$name]);
- }else{
- if(empty($params[$name])){
- $params[$name]=NULL;
- }
- }
- }
- $model = new self;
- // 调用当前模型对应的User验证器类进行数据验证
- $result = $model->save($params, ['id' => $params['id']]);
- if (false === $result) {
- // 验证失败 输出错误信息
- throw new Exception($model->getError());
- }
- $otherModel = new ContactsOther();
- if ($otherModel->save(['otherdata' => json_encode($other, JSON_UNESCAPED_UNICODE)],['id' => $params['id']]) === false) {
- // 验证失败 输出错误信息
- throw new Exception($otherModel->getError());
- }
- return true;
- }
- //导入
- public static function importContacts($data) {
- $addContacts = [];
- $addOther = [];
- foreach ($data as $params) {
- //自定义字段
- $other = [];
- foreach ($params as $name => $val) {
- if (strstr($name, 'other_') !== false) {
- if(is_array($val)){
- $other[$name] = implode(',',$val);
- }else{
- $other[$name] = $val;
- }
- unset($params[$name]);
- }else{
- if(empty($params[$name])){
- $params[$name]=NULL;
- }
- }
- }
- $params['createtime'] = time();
- $params['next_time'] = date('Y-m-d H:i:s');
- $other['id'] = $params['id'];
- $addOther[] = ['id' => $params['id'], 'otherdata' => json_encode($other, JSON_UNESCAPED_UNICODE)];
- $addContacts[] = $params;
- }
- $model = new self;
- // 调用当前模型对应的User验证器类进行数据验证
- $result = $model->allowField(true)->insertAll($addContacts);
- $otherModel = new ContactsOther();
- $otherModel->allowField(true)->insertAll($addOther);
- return true;
- }
- //获取联系人相关信息
- public function contactsOther() {
- return $this->belongsTo(ContactsOther::class,'id','id');
- }
- public function getUpdatetimeAttr($value) {
- if ($value) {
- return date('Y-m-d H:i', $value);
- }
- return $value;
- }
- }
|