123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313 |
- <?php
- namespace addons\qingdongams\model;
- use think\Db;
- use think\Exception;
- use think\Model;
- use traits\model\SoftDelete;
- /**
- * 商机管理
- */
- class Business Extends Model
- {
- use SoftDelete;
- // 表名,不含前缀
- protected $name = 'qingdongams_business';
- // 开启自动写入时间戳字段
- protected $autoWriteTimestamp = 'int';
- // 定义时间戳字段名
- protected $createTime = 'createtime';
- protected $updateTime = 'updatetime';
- protected $deleteTime = 'deletetime';
- //创建商机
- public static function createBusiness($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;
- }
- }
- }
- $product = [];
- if (isset($params['product']) && $params['product']) {
- $product = $params['product'];
- unset($params['product']);
- foreach ($product as $tkey => $t) {
- unset($product[$tkey]['id']);
- if($t['number'] <=0){
- throw new Exception('产品数量必须大于0');
- }
- }
- }
- $customer=Customer::where(['id'=>$params['customer_id']])->find();
- if(empty($customer)){
- throw new Exception('客户不存在');
- }
- $params['owner_staff_id'] = $customer->owner_staff_id;
- $staff = Staff::info();
- if (!empty($staff)) {
- $params['create_staff_id'] = $staff->id;
- }
- $Model = new self;
- $result = $Model->allowField(true)->save($params);
- if (false === $result) {
- // 验证失败 输出错误信息
- throw new Exception($Model->getError());
- }
- $lastId = $Model->id;
- $otherModel = new BusinessOther();
- if ($otherModel->save(['id' => $lastId, 'otherdata' => json_encode($other, JSON_UNESCAPED_UNICODE)]) === false) {
- // 验证失败 输出错误信息
- throw new Exception($otherModel->getError());
- }
- $addProduct = [];
- foreach ($product as $v) {
- $v['business_id'] = $lastId;
- $addProduct[] = $v;
- }
- if ($addProduct) {
- $productModel = new BusinessProduct();
- $productModel->allowField(true)->saveAll($addProduct);
- }
- OperationLog::createLog(OperationLog::BUSINESS_TYPE, $lastId, '创建商机');
- return true;
- }
- //修改商机
- public static function updateBusiness($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;
- }
- }
- }
- $product = [];
- if (isset($params['product'])) {
- $product = $params['product'];
- unset($params['product']);
- if(isset($params['row[product'])){
- unset($params['row[product']);
- }
- if(!is_array($product)){
- $product = json_decode($product,true);
- }
- foreach ($product as $tkey => $t) {
- unset($product[$tkey]['id']);
- if($t['number'] <=0){
- throw new Exception('产品数量必须大于0');
- }
- }
- }
- $Model = new self;
- // 调用当前模型对应的User验证器类进行数据验证
- $result = $Model->allowField(true)->save($params, ['id' => $params['id']]);
- if (false === $result) {
- // 验证失败 输出错误信息
- throw new Exception($Model->getError());
- }
- $otherModel = new BusinessOther();
- if ($otherModel->save(['otherdata' => json_encode($other, JSON_UNESCAPED_UNICODE)], ['id' => $params['id']]) === false) {
- // 验证失败 输出错误信息
- throw new Exception($otherModel->getError());
- }
- $addProduct = [];
- if($product){
- foreach ($product as $v) {
- $v['business_id'] = $params['id'];
- $addProduct[] = $v;
- }
- }
- if ($addProduct) {
- $productModel = new BusinessProduct();
- $productModel->where(['business_id' => $params['id']])->delete();
- $productModel->allowField(true)->saveAll($addProduct);
- }
- return true;
- }
- //获取更新时间
- public function getUpdatetimeAttr($value) {
- return date('Y-m-d H:i:s', $value);
- }
- //负责人
- public function ownerStaff() {
- return $this->hasOne(Staff::class, 'id', 'owner_staff_id')->field('id,name,img');
- }
- //客户
- public function customer() {
- return $this->hasOne(Customer::class, 'id', 'customer_id')->field('id,name,follow');
- }
- //商机
- public function businessOther() {
- return $this->hasOne(BusinessOther::class, 'id', 'id');
- }
- //
- public function staff() {
- return $this->hasOne(Staff::class, 'id', 'owner_staff_id')->field('id,name,img,department_id,post');
- }
- //产品
- public function product(){
- return $this->hasMany(BusinessProduct::class,'business_id','id')->with('productOne');
- }
- /**
- * 批量转移商机
- */
- public static function batchTransfer($ids, $staff_id) {
- Db::startTrans();
- try {
- if (Business::where(['id' => ['in',$ids]])->update([
- 'owner_staff_id' => $staff_id,
- 'updatetime' => time()
- ]) == false) {
- throw new Exception('修改失败');
- }
- $staff = Staff::get($staff_id);
- foreach ($ids as $id){
- OperationLog::createLog(OperationLog::BUSINESS_TYPE, $id, '将商机转移给:' . $staff['name']);
- }
- Db::commit();
- } catch (Exception $e) {
- Db::rollback();
- throw new Exception($e->getMessage());
- }
- return true;
- }
- public static function getList() {
- return self::where(['owner_staff_id'=>['in',Staff::getMyStaffIds()]])->field('id,name')->select();
- }
- /**
- * 推进商机
- */
- public static function batchStatus($params) {
- Db::startTrans();
- try {
- (new self())->save(['status'=>$params['type']],['id'=>$params['id']]);
- $ret = array(
- 'business_id'=>$params['id'],
- 'type'=>$params['type'],
- 'remark'=>$params['remark'],
- 'file'=>$params['file'],
- );
- $result = BusinessStatus::create($ret);
- if ($result == false) {
- throw new Exception('推进失败');
- }
- Db::commit();
- } catch (Exception $e) {
- Db::rollback();
- throw new Exception($e->getMessage());
- }
- return true;
- }
- /**
- * 导入商机
- * @param $data
- * @return bool
- */
- public static function importBusiness($data) {
- $addBusiness = [];
- $addOther = [];
- $addLog=[];
- 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;
- }
- }
- }
- $other['id'] = $params['id'];
- $params['next_time'] = date('Y-m-d H:i:s');
- $params['createtime'] = time();
- $params['updatetime'] = time();
- $addOther[] = ['id' => $params['id'], 'otherdata' => json_encode($other, JSON_UNESCAPED_UNICODE)];
- $addLog[] = [
- 'content' => '导入商机',
- 'operation_type' => 2,
- 'operation_id' => 30,
- 'relation_type' => OperationLog::BUSINESS_TYPE,
- 'relation_id' => $params['id'],
- 'createtime' => time()
- ];
- $addBusiness[] = $params;
- }
- $customer = new self;
- // 调用当前模型对应的User验证器类进行数据验证
- $result = $customer->allowField(true)->insertAll($addBusiness);
- $otherModel = new BusinessOther();
- $otherModel->allowField(true)->insertAll($addOther);
- $logModel = new OperationLog();
- $logModel->allowField(true)->insertAll($addLog);
- return true;
- }
- }
|