drb/app/Service/SportsBagService.php

<?php

namespace App\Service;

use App\Model\BasicType;
use App\Model\Construction;
use App\Model\Employee;
use App\Model\EmployeeDepartPermission;
use App\Model\PurchaseOrder;
use App\Model\SalesOrder;
use App\Model\SeeRange;
use App\Model\SportsBag;
use App\Model\SportsBagProductInfo;
use App\Model\WxEmployeeOfficial;
use Illuminate\Support\Facades\DB;

class SportsBagService extends Service
{
    public function edit($data,$user){
        list($status,$msg) = $this->orderRule($data,$user,false);
        if(!$status) return [$status,$msg];

        $params = $this->getDataFile($data);
        (new OperationLogService())->setOperationList($params,$user,2);

        try{
            DB::beginTransaction();
            $material_model = SportsBag::where('id',$data['id'])->first();
            $material_model->title = $data['title'];
            $material_model->purchase_attribute = $data['purchase_attribute'];
            $material_model->is_attribute = $data['is_attribute'];
            $material_model->mark = $data['mark'] ?? "";
            $material_model->number = $data['number'];
            $material_model->start_time = $data['start_time'] ?? 0;
            $material_model->end_time = $data['end_time'] ?? 0;
            $material_model->total_amount = $data['total_amount'] ?? 0;
            $material_model->save();
            $time = time();

            SportsBagProductInfo::where('del_time',0)
                ->where('sports_bag_id',$data['id'])
                ->update(['del_time' => $time]);
            if(!empty($data['product'])){
                $map = (new ProductService())->getProductDetail(array_column($data['product'],'product_id'));
                $sub = [];
                foreach ($data['product'] as $value){
                    $tmp = $map[$value['product_id']] ?? [];
                    $sub[] = [
                        'sports_bag_id' => $material_model->id,
                        'product_id' => $value['product_id'],
                        'number' => $value['number'],
                        'mark' => $value['mark'] ?? '',
                        'cost' => $value['cost'] ?? 0,
                        'retail_price' => $tmp['retail_price'] ?? 0,
                        'crt_time' => $time,
                        'basic_type_id' => $value['basic_type_id'],
                        'price' => $value['price'],
                    ];
                }
                SportsBagProductInfo::insert($sub);
            }

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        if(! empty($data['check'])) {
            list($status,$msg) = (new CheckService())->checkAll([
                "id" => $material_model->id,
                "order_number" => $data['order_number'],
                "opt_case" => CheckService::twl,
                "menu_id" => $data['menu_id']
            ],$user);
            if(! $status) return [true, '保存成功，活动包确认失败，异常信息：' . $msg];
        }

        return [true,''];
    }

    public function add($data,$user){
        list($status,$msg) = $this->orderRule($data,$user);
        if(!$status) return [$status,$msg];

        try{
            DB::beginTransaction();
            $material_model = new SportsBag();
            $material_model->order_number = $data['order_number'];
            $material_model->purchase_attribute = $data['purchase_attribute'];
            $material_model->is_attribute = $data['is_attribute'];
            $material_model->title = $data['title'];
            $material_model->mark = $data['mark'] ?? "";
            $material_model->number = $data['number'];
            $material_model->start_time = $data['start_time'] ?? 0;
            $material_model->end_time = $data['end_time'] ?? 0;
            $material_model->crt_id = $user['id'];
            $material_model->depart_id = $data['depart_id'] ?? 0;
            $material_model->top_depart_id = $data['top_depart_id'] ?? 0;
            $material_model->total_amount = $data['total_amount'] ?? 0;
            $material_model->save();
            $time = time();

            if(!empty($data['product'])){
                $map = (new ProductService())->getProductDetail(array_column($data['product'],'product_id'));
                $sub = [];
                foreach ($data['product'] as $value){
                    $tmp = $map[$value['product_id']] ?? [];
                    $sub[] = [
                        'sports_bag_id' => $material_model->id,
                        'product_id' => $value['product_id'],
                        'number' => $value['number'],
                        'mark' => $value['mark'] ?? '',
                        'cost' => $value['cost'] ?? 0,
                        'retail_price' => $tmp['retail_price'] ?? 0,
                        'crt_time' => $time,
                        'basic_type_id' => $value['basic_type_id'],
                        'price' => $value['price'],
                    ];
                }
                SportsBagProductInfo::insert($sub);
            }

            if(! empty($data['check'])) {
                list($status,$msg) = (new CheckService())->checkAll([
                    "id" => $material_model->id,
                    "order_number" => $data['order_number'],
                    "opt_case" => CheckService::twl,
                    "menu_id" => $data['menu_id']
                ],$user);
                if(! $status) return [true, '保存成功，活动包确认失败，异常信息：' . $msg];
            }

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            if (str_contains($e->getMessage(), '1062') || str_contains($e->getMessage(), 'Duplicate entry')) {
                return [false, '网络环境波动，请重新操作'];
            }
            return [false,$e->getMessage()];
        }

        (new OperationLogService())->setOperationList($data,$user);

        if(! empty($data['check'])) {
            list($status,$msg) = (new CheckService())->checkAll([
                "id" => $material_model->id,
                "order_number" => $data['order_number'],
                "opt_case" => CheckService::twl,
                "menu_id" => $data['menu_id']
            ],$user);
            if(! $status) return [true, '保存成功，活动包确认失败，异常信息：' . $msg];
        }

        return [true,''];
    }

    public function detail($data){
        if($this->isEmpty($data,'id')) return [false,'请选择数据'];

        $order = SportsBag::where('id',$data['id'])
            ->where('del_time',0)
            ->first();
        if(empty($order)) return [false, '活动包不存在或已被删除'];
        $order = $order->toArray();
        $purchase_attribute = explode(',',$order['purchase_attribute']);
        if($order['is_attribute'] == 1){
            $purchase_attribute = explode(',',$order['purchase_attribute']);
            $str2 = "";
            foreach ($purchase_attribute as $value){
                $tmp = SalesOrder::$model_type_title[$value] ?? "";
                if(! empty($tmp)) $str2 .= $tmp . ',';
            }
            $order['purchase_attribute_title'] = rtrim($str2,',');
        }else{
            $basic_type = BasicType::whereIn('id',$purchase_attribute)->pluck('title','id')->toArray();
            $str = "";
            if(! empty($basic_type)){
                foreach ($purchase_attribute as $value){
                    $str .= $basic_type[$value] . ',';
                }
            }
            $order['purchase_attribute_title'] = rtrim($str,',');
        }

        $start_time = $order['start_time'] ? date("Y-m-d H:i",$order['start_time']) : '';
        $end_time = $order['end_time'] ? date("Y-m-d H:i",$order['end_time']) : '';
        $order['sports_bag_time'] = $start_time . '——' . $end_time;

        $order['product'] = $order['depart'] = $order['employee'] = [];
        $info = SportsBagProductInfo::where('del_time',0)
            ->where('sports_bag_id',$data['id'])
            ->get()->toArray();
        $map = (new ProductService())->getProductDetail(array_column($info,'product_id'));
        foreach ($info as $value){
            $tmp = $map[$value['product_id']] ?? [];
            $value['title'] = $tmp['title'] ?? "";
            $value['code'] = $tmp['code'] ?? "";
            $value['size'] = $tmp['size'] ?? "";
            $value['unit'] = $tmp['unit'] ?? "";
            $value['bar_code'] = $tmp['bar_code'] ?? "";
            $order['product'][] = $value;
        }

        $order['crt_name'] = Employee::where('id',$order['crt_id'])->value('emp_name');
        $order['crt_time'] = $order['crt_time'] ? date("Y-m-d H:i:s",$order['crt_time']): '';

        $state_array = $this->getStateMake([$order]);
        $order['state_title'] = $this->makeState($order,$state_array);

        //可见范围
        $return = (new RangeService())->RangeDetail($order['id'],SeeRange::type_eight);
        $order['depart'] = $return[0] ?? [];
        $order['employee'] = $return[1] ?? [];

        return [true, $order];
    }

    public function del($data,$user){
        if($this->isEmpty($data,'id')) return [false,'请选择数据！'];
        $order = SportsBag::where('del_time',0)->where('id',$data['id'])->first();
        if(empty($order)) return [false,'活动包不存在或已被删除'];
        if($order['state'] > SportsBag::STATE_ZERO) return [false, '请确认活动包状态，删除失败！'];

        try{
            DB::beginTransaction();
            SportsBag::where('id',$data['id'])->update([
                'del_time'=>time()
            ]);
            SportsBagProductInfo::where('sports_bag_id',$data['id'])->update([
                'del_time'=>time()
            ]);
            (new RangeService())->RangeDelete($data['id'],SeeRange::type_eight);

            DB::commit();
        }catch (\Throwable $e){
            DB::rollBack();
            return [false,$e->getMessage()];
        }

        return [true,''];
    }

    public function getList($data,$user){
        $model = SportsBag::SportsBagClear($user,$data);
        $model = $model->where('del_time',0)
            ->select('id','title','number','start_time','end_time','crt_time','crt_id','mark','total_amount','state','order_number','purchase_attribute',"is_attribute")
            ->orderby('id', 'desc');

        if(! empty($data['order_number'])) $model->where('order_number', 'LIKE', '%'.$data['order_number'].'%');
        if(! empty($data['is_attribute'])) $model->where('is_attribute',$data['is_attribute']);
        if(! empty($data['purchase_attribute'])) $model->whereRaw("FIND_IN_SET(?, purchase_attribute)", [$data['purchase_attribute']]);
        if(isset($data['state'])) $model->where('state', $data['state']);
        if(isset($data['valid'])) {
            //获取有效时间内的活动包
            $time = time();
            $model->where('start_time','<=',$time);
            $model->where('end_time','>=',$time);
        }
        if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
        if(! empty($data['mark'])) $model->where('mark', 'LIKE', '%'.$data['mark'].'%');
        if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
            $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
            $model->where('crt_time','>=',$return[0]);
            $model->where('crt_time','<=',$return[1]);
        }
        if(! empty($data['sports_bag_time'][0]) && ! empty($data['sports_bag_time'][1])) {
            $start_time = $this->changeDateToDateMin($data['sports_bag_time'][0]);
            $end_time = $this->changeDateToDateMin($data['sports_bag_time'][1]);
            $model->where('start_time','>=',$start_time);
            $model->where('end_time','<=',$end_time);
        }

        $list = $this->limit($model,'',$data);
        $list = $this->fillListData($list,$data);

        return [true, $list];
    }

    public function fillListData($data,$ergs){
        if(empty($data['data'])) return $data;

        $emp_id = array_unique(array_merge_recursive(array_column($data['data'],'crt_id')));
        $emp_map = Employee::whereIn('id',$emp_id)
                    ->pluck('emp_name','id')
                    ->toArray();
        $product = [];
        if(! empty($ergs['product'])){
            $sales_p_info = SportsBagProductInfo::where('del_time',0)
                ->whereIn('sports_bag_id',array_column($data['data'],'id'))
                ->get()->toArray();
            $map = (new ProductService())->getProductDetail(array_column($sales_p_info,'product_id'));
            foreach ($sales_p_info as $value){
                $tmp = $map[$value['product_id']] ?? [];
                $value['title'] = $tmp['title'] ?? "";
                $value['code'] = $tmp['code'] ?? "";
                $value['size'] = $tmp['size'] ?? "";
                $value['unit'] = $tmp['unit'] ?? "";
                $value['bar_code'] = $tmp['bar_code'] ?? "";
                $product[$value['sports_bag_id']][] = $value;
            }
        }

        //订单状态数据组织
        $state_array = $this->getStateMake($data['data']);

        foreach ($data['data'] as $key => $value){
            $start_time = $value['start_time'] ? date("Y-m-d H:i",$value['start_time']) : '';
            $end_time = $value['end_time'] ? date("Y-m-d H:i",$value['end_time']) : '';
            $data['data'][$key]['sports_bag_time'] = $start_time . '——' . $end_time;
            $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']) : '';
            $data['data'][$key]['crt_name'] = $emp_map[$value['crt_id']] ?? '';
            $data['data'][$key]['state_title'] = $this->makeState($data['data'][$key], $state_array);
            $data['data'][$key]['product'] = $product[$value['id']] ?? [];
            $data['data'][$key]['is_attribute_title'] = SportsBag::$attribute_name[$value['is_attribute']] ?? "";
        }

        return $data;
    }

    public function makeState($value, $state_array){
        $nowStamp = time();
        if(! empty($state_array[$value['order_number']])){
            $return = $state_array[$value['order_number']];
            if($value['state'] == SportsBag::State_minus_one){
                $state = "驳回:" . $return;
            }else{
                $state = "待" . $return . "审核";
            }
        }elseif($value['state'] == SportsBag::STATE_ZERO){
            $state = "待" . $value['crt_name'] . "提交";
        }else{
            $attribute_2 = "";
            if($value['state'] == SportsBag::STATE_TWO){
                if($nowStamp < $value['start_time']){
                    $attribute_2 = "待开始";
                }elseif ($nowStamp > $value['end_time']){
                    $attribute_2 = "已结束";
                }elseif ($nowStamp >= $value['start_time'] && $nowStamp <= $value['end_time']){
                    $attribute_2 = "正在进行";
                }
            }
            $state = SportsBag::$name[$value['state']] ?? '';
            if(! empty($attribute_2)) $state = $state . "($attribute_2)";
        }

        return $state;
    }

    public function getStateMake($data){
        if(empty($data)) return [];

        $order_no = [];
        foreach ($data as $value){
            if(! in_array($value['state'], [SportsBag::State_minus_one,SportsBag::STATE_ONE])) continue;

            $order_no[] = $value['order_number'];
        }

        return (new OaService())->getOaTeamDetailList($order_no);
    }

    public function orderRule(&$data, $user, $is_check = true){
        if(empty($data['title'])) return [false,'请填写活动名称'];
        if(empty($data['sports_bag_time'][0]) || empty($data['sports_bag_time'][1])) return [false,'请填写活动时间范围'];
        if(empty($data['is_attribute'])) return [false, '请选择销售属性|采购属性'];
        if(empty($data['purchase_attribute'])) return [false, '请选择销售属性|采购属性对应的数据'];
        $data['start_time'] = $this->changeDateToDateMin($data['sports_bag_time'][0]);
        $data['end_time'] = $this->changeDateToDateMin($data['sports_bag_time'][1]);
        if(empty($data['number'])) return [false,'必选产品种数不能为空'];
        $res = $this->checkNumber($data['number']);
        if(! $res) return [false,'请输入正确的必选产品种数'];

        if(empty($data['total_amount'])) return [false,'活动包总金额不能为空'];
        $res = $this->checkNumber($data['total_amount']);
        if(! $res) return [false,'活动包总金额请输入不超过两位小数并且大于0的数值'];

        if(empty($data['product'])) return [false, '请选择产品'];
        foreach ($data['product'] as $value){
            if(empty($value['number'])) return [false,'产品数量不能为空'];
            $res = $this->checkNumber($value['number']);
            if(! $res) return [false,'请输入正确的产品数量'];

        }

        //所属部门 以及  顶级部门
        if(empty($data['depart_id'])) $data['depart_id'] = $this->getDepart($user);
        $data['top_depart_id'] = $user['depart_map'][$data['depart_id']] ?? 0;

        if($is_check){
            $order_number = (new OrderNoService())->createOrderNumber(SportsBag::prefix);
            if(empty($order_number)) return [false,'活动包唯一单号生成失败！'];
            $data['order_number'] = $order_number;
        }else{
            if($this->isEmpty($data,'id')) return [false,'活动包ID不能为空！'];
            $purchase = SportsBag::where('del_time',0)->where('id',$data['id'])->first();
            if(empty($purchase)) return [false, '活动包不存在或已被删除'];
            if($purchase->state > SportsBag::STATE_ZERO) return [false,'请确认活动包状态，修改失败'];
        }

        return [true, ''];
    }

    public function checkSportsBag($id = []){
        if(empty($id)) return [true, ''];

        $now = time();
        $bag = SportsBag::whereIn('id',$id)
            ->select('id','title','start_time','end_time','state','del_time')
            ->get()->toArray();

        $return = [];
        foreach ($bag as $value){
            if($value['del_time'] > 0){
                $return[] = "活动包" . $value['title'] ."已删除或不存在";
            }elseif($value['state'] < SportsBag::STATE_TWO){
                $return[] = "活动包" . $value['title'] ."审核未通过";
            }elseif($now < $value['start_time'] || $now > $value['end_time']){
                $return[] = "活动包" . $value['title'] ."未在活动时间内，请稍等";
            }
        }

        if(! empty($return)){
            $msg = implode(' | ', $return);
            return [false, $msg];
        }

        return [true, ''];
    }

    //发送消息
    public function sportsBagSendWx($data, $user){
        list($status,$msg) = $this->sportsBagSendWxRule($data);
        if(! $status) return [false,$msg];

        //发送消息
        $send_data = $msg;
        (new OaService())->sendWxOaCheckMessage($send_data);

        return [true, ''];
    }

    public function sportsBagSendWxRule($data){
        if(empty($data['id'])) return [false,'请选择活动包'];
        if(empty($data['depart_id'])) return [false, '请选择门店'];

        $customer = SportsBag::where('del_time',0)
            ->where('state','>=',SportsBag::STATE_TWO)
            ->whereIn('id',$data['id'])
            ->get()->toArray();
        if(empty($customer)) return [false,'活动包未审核通过、不存在或已被删除'];

        $employee_id = EmployeeDepartPermission::whereIn('depart_id',$data['depart_id'])
            ->select('employee_id')
            ->get()->toArray();
        if(empty($employee_id)) return [true, '门店下无人员信息,公众号消息发送结束'];
        $employee_id = array_unique(array_column($employee_id,'employee_id'));
        $wx_map = WxEmployeeOfficial::whereIn('employee_id', $employee_id)
            ->pluck('openid','employee_id')
            ->toArray();
        $emp = Employee::whereIn('id', $employee_id)
            ->pluck('emp_name','id')
            ->toArray();
        $send_data = [];
        foreach ($employee_id as $value){
            $tmp = $emp[$value] ?? "";
            $open_id = $wx_map[$value] ?? "";
//            if(empty($open_id)) return [false, $tmp . "暂未关注微信公众号,公众号消息发送失败"];
            if(empty($open_id)) continue;

            foreach ($customer as $sport){
                //提醒
                $send_data[] = [
                    'employee_id' => $value,
                    'type' => 2,
                    'state' => 0,
                    'menu_id' => "30",
                    'openid' => $open_id,
                    'order_number' => $sport['order_number'],
                    'tmp_data' => [
                        $sport['order_number'],
                        "活动包消息提醒",
                        "已发送",
                        $tmp,
                        date('Y-m-d H:i:s'),
                    ],
                ];
            }
        }

        return [true, $send_data];
    }
}