|
|
@@ -14,10 +14,11 @@
|
|
|
|
|
|
namespace app\adminapi\logic\works;
|
|
|
|
|
|
+use think\db\Query;
|
|
|
use think\Exception;
|
|
|
use think\facade\Db;
|
|
|
use app\common\logic\BaseLogic;
|
|
|
-use app\common\model\works\ServiceWork;
|
|
|
+use PhpOffice\PhpSpreadsheet\IOFactory;
|
|
|
use app\common\model\works\GroupServiceWork;
|
|
|
use app\workerapi\logic\GroupServiceWorkLogLogic;
|
|
|
use app\common\model\master_worker\MasterWorkerTemporary;
|
|
|
@@ -40,10 +41,9 @@ class GroupServiceWorkLogic extends BaseLogic
|
|
|
{
|
|
|
Db::startTrans();
|
|
|
try {
|
|
|
- ServiceWork::where('id', $params['id'])->update([
|
|
|
+ GroupServiceWork::where('id', $params['id'])->update([
|
|
|
'address' => $params['address'],
|
|
|
'appointment_time' => strtotime($params['appointment_time']),
|
|
|
- 'estimated_finish_time' => $params['estimated_finish_time'],
|
|
|
]);
|
|
|
Db::commit();
|
|
|
return true;
|
|
|
@@ -75,14 +75,16 @@ class GroupServiceWorkLogic extends BaseLogic
|
|
|
|
|
|
$work->finally_door_time = time();//最后上门时间
|
|
|
$work->work_status = 4;//已上门
|
|
|
+ $work->service_status = 1;//服务中
|
|
|
$work->work_images = $params['work_images'];
|
|
|
$work->save();
|
|
|
|
|
|
//添加变更日志
|
|
|
$work_log = [
|
|
|
+ 'type' => 3,
|
|
|
'work_id'=>$work->id,
|
|
|
'master_worker_id'=>$work->master_worker_id,
|
|
|
- 'opera_log'=>'编号['.$params['user_info']['worker_number'].']'.$params['user_info']['real_name'].'于'.date('y-m-d H:i:s',time()).'于'.date('Y-m-d H:i:s',time()).'已上门',
|
|
|
+ 'opera_log'=>'编号['.$params['user_info']['worker_number'].']'.$params['user_info']['real_name'].'于'.date('y-m-d H:i:s',time()).'已上门',
|
|
|
];
|
|
|
GroupServiceWorkLogLogic::add($work_log);
|
|
|
Db::commit();
|
|
|
@@ -117,22 +119,25 @@ class GroupServiceWorkLogic extends BaseLogic
|
|
|
throw new Exception('工单不存在');
|
|
|
}
|
|
|
if($params['code'] != $work->code) {
|
|
|
- throw new Exception('验证码错误');
|
|
|
+ throw new Exception('验收码错误');
|
|
|
}
|
|
|
|
|
|
- if($work->user_confirm_status !=2){
|
|
|
+ if($work->work_status !=4){
|
|
|
throw new Exception('请勿重复操作');
|
|
|
}
|
|
|
|
|
|
$work->finished_images = $params['finished_images'];
|
|
|
- $work->user_confirm_status = 3;//待确认服务完成
|
|
|
+ $work->user_confirm_status = 5;//用户确认完成
|
|
|
+ $work->work_status = 7;//服务工单已完结
|
|
|
+ $work->service_status = 3;//工单已完成
|
|
|
$work->save();
|
|
|
|
|
|
//添加变更日志
|
|
|
$work_log = [
|
|
|
+ 'type' => 4,
|
|
|
'work_id'=>$work->id,
|
|
|
'master_worker_id'=>$work->master_worker_id,
|
|
|
- 'opera_log'=>'编号['.$params['user_info']['worker_number'].']'.$params['user_info']['real_name'].'于'.date('y-m-d H:i:s',time()).'于'.date('Y-m-d H:i:s',time()).'提交了待用户确认服务完成',
|
|
|
+ 'opera_log'=>'编号['.$params['user_info']['worker_number'].']'.$params['user_info']['real_name'].'于'.date('y-m-d H:i:s',time()).'于'.date('Y-m-d H:i:s',time()).'提交了确认服务完成',
|
|
|
];
|
|
|
GroupServiceWorkLogLogic::add($work_log);
|
|
|
Db::commit();
|
|
|
@@ -143,32 +148,43 @@ class GroupServiceWorkLogic extends BaseLogic
|
|
|
return false;
|
|
|
}
|
|
|
}
|
|
|
-
|
|
|
+
|
|
|
public static function allocateWorker($params,$userInfo){
|
|
|
Db::startTrans();
|
|
|
try {
|
|
|
- $work = GroupServiceWork::findOrEmpty($params['id']);
|
|
|
- if($work->isEmpty()){
|
|
|
- throw new Exception('工单不存在');
|
|
|
- }
|
|
|
- if($work->work_status >=6 ){
|
|
|
- throw new \Exception('工单状态只能修改待结算之前的');
|
|
|
- }
|
|
|
- if($work->master_worker_id == $params['master_worker_id']){
|
|
|
- throw new \Exception('分配的工程师相同');
|
|
|
+ $ids = explode(",",$params['id']);
|
|
|
+ if (count($ids) > 50) {
|
|
|
+ throw new \Exception('单次最多分配50个');
|
|
|
}
|
|
|
$worker = MasterWorkerTemporary::where(['id'=>$params['master_worker_id'],'is_disable' =>0])->findOrEmpty();
|
|
|
if($worker->isEmpty()){
|
|
|
throw new \Exception('工程师不存在或被禁用');
|
|
|
}
|
|
|
|
|
|
- $work->master_worker_id = $params['master_worker_id'];
|
|
|
- $work->work_status = 3;
|
|
|
- $work->dispatch_time = time();
|
|
|
- $work->receive_time = time();
|
|
|
- $work->user_confirm_status = 2;
|
|
|
- $work->code = str_pad(rand(0, 9999), 4, '0', STR_PAD_LEFT);//从 0 - 9 中随机取 4 个数字
|
|
|
- $work->save();
|
|
|
+ //批量派单
|
|
|
+ $work = GroupServiceWork::whereIn('id',$ids)->where('work_status','<',6)->select()->toArray();
|
|
|
+
|
|
|
+ foreach($work as $item) {
|
|
|
+ if($item['master_worker_id'] != $params['master_worker_id']){
|
|
|
+ $work_log = [
|
|
|
+ 'type' => 1,
|
|
|
+ 'work_id'=>$item['id'],
|
|
|
+ 'master_worker_id'=>$params['master_worker_id'],
|
|
|
+ 'opera_log'=>'后台用户['.$userInfo['admin_id'].']'.$userInfo['name'].'于'.date('Y-m-d H:i:s',time()).'分配了工程师'.'编号['.$worker->worker_number.']'.$worker->real_name
|
|
|
+ ];
|
|
|
+ GroupServiceWorkLogLogic::add($work_log);
|
|
|
+
|
|
|
+ GroupServiceWork::where('id',$item['id'])->update([
|
|
|
+ 'master_worker_id' => $params['master_worker_id'],
|
|
|
+ 'work_status' => 3,
|
|
|
+ 'dispatch_time' => time(),
|
|
|
+ 'receive_time' => time(),
|
|
|
+ 'user_confirm_status' => 2,
|
|
|
+ 'code' => str_pad(rand(0, 9999), 4, '0', STR_PAD_LEFT),//从 0 - 9 中随机取 4 个数字
|
|
|
+ ]);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
Db::commit();
|
|
|
|
|
|
// 工程师派单通知【给工程师的通知】【公众号通知,不发短信】
|
|
|
@@ -208,19 +224,21 @@ class GroupServiceWorkLogic extends BaseLogic
|
|
|
throw new \Exception('工程师不存在');
|
|
|
}
|
|
|
$params['master_worker_id'] = (isset($params['master_worker_id']) && !empty($params['master_worker_id']))?$params['master_worker_id']:$work->master_worker_id;
|
|
|
- $work->master_worker_id = 0;
|
|
|
- $work->work_status = 0;
|
|
|
- $work->dispatch_time = 0;
|
|
|
- $work->receive_time = 0;
|
|
|
- $work->save();
|
|
|
-
|
|
|
+
|
|
|
//添加变更日志
|
|
|
$work_log = [
|
|
|
+ 'type' => 2,
|
|
|
'work_id'=>$work->id,
|
|
|
'master_worker_id'=>$work->master_worker_id,
|
|
|
'opera_log'=>'后台用户['.$userInfo['admin_id'].']'.$userInfo['name'].'于'.date('Y-m-d H:i:s',time()).'取消了工程师'.'编号['.$worker->worker_number.']'.$worker->real_name
|
|
|
];
|
|
|
GroupServiceWorkLogLogic::add($work_log);
|
|
|
+
|
|
|
+ $work->master_worker_id = 0;
|
|
|
+ $work->work_status = 0;
|
|
|
+ $work->dispatch_time = 0;
|
|
|
+ $work->receive_time = 0;
|
|
|
+ $work->save();
|
|
|
Db::commit();
|
|
|
return true;
|
|
|
}catch(\Exception $e){
|
|
|
@@ -238,10 +256,25 @@ class GroupServiceWorkLogic extends BaseLogic
|
|
|
*/
|
|
|
public static function detail($params){
|
|
|
$work_where = !empty($params['work_sn'])?['work_sn'=>$params['work_sn']]:['id'=>$params['id']];
|
|
|
- $result = GroupServiceWork::where($work_where)
|
|
|
+ if (!empty($params['master_worker_id'])) {
|
|
|
+ $work_where['master_worker_id'] = $params['master_worker_id'];
|
|
|
+ }
|
|
|
+ $result = GroupServiceWork::with([
|
|
|
+ 'worker'=> function(Query $query) {
|
|
|
+ $query->field('id,worker_number,real_name,mobile');
|
|
|
+ },
|
|
|
+ 'serviceWorkLog' =>function(Query $query){
|
|
|
+ $query->field('id,work_id,opera_log,create_time');
|
|
|
+ }
|
|
|
+ ])
|
|
|
+ ->where($work_where)
|
|
|
->append(['id','work_status_text','service_status_text'])
|
|
|
->findOrEmpty()->toArray();
|
|
|
-
|
|
|
+ if (empty($result)) {
|
|
|
+ self::setError('工单不存在');
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
//工程师工单按钮状态
|
|
|
$work_service_status = 0;
|
|
|
$work_service_status_text = '待派单';
|
|
|
@@ -290,4 +323,57 @@ class GroupServiceWorkLogic extends BaseLogic
|
|
|
return $result;
|
|
|
}
|
|
|
|
|
|
+ /**
|
|
|
+ * 导入拼团工单
|
|
|
+ */
|
|
|
+ public static function import($file) {
|
|
|
+
|
|
|
+ try {
|
|
|
+ // 移动文件到指定目录
|
|
|
+ $info = $file->move(root_path('public') . 'uploads');
|
|
|
+ if ($info) {
|
|
|
+ $filePath = $info->getPathname();
|
|
|
+
|
|
|
+ // 读取 Excel 文件
|
|
|
+ $spreadsheet = IOFactory::load($filePath);
|
|
|
+ $worksheet = $spreadsheet->getActiveSheet();
|
|
|
+ $highestRow = $worksheet->getHighestRow();
|
|
|
+
|
|
|
+ // 假设第一行为表头,从第二行开始读取数据
|
|
|
+ for ($row = 2; $row <= $highestRow; $row++) {
|
|
|
+ $data = [
|
|
|
+ 'title' => $worksheet->getCell('A' . $row)->getValue(),
|
|
|
+ 'real_name' => $worksheet->getCell('B' . $row)->getValue(),
|
|
|
+ 'mobile' => $worksheet->getCell('C' . $row)->getValue(),
|
|
|
+ 'address' => $worksheet->getCell('D' . $row)->getValue(),
|
|
|
+ 'area_name' => $worksheet->getCell('E'. $row)->getValue(),
|
|
|
+ 'appointment_time' => $worksheet->getCell('F'. $row)->getValue(),
|
|
|
+ 'work_total' => $worksheet->getCell('G'. $row)->getValue(),
|
|
|
+ 'work_amount' => $worksheet->getCell('H'. $row)->getValue(),
|
|
|
+ 'settlement_amount' => $worksheet->getCell('I'. $row)->getValue(),
|
|
|
+ 'remark' => $worksheet->getCell('J'. $row)->getValue(),
|
|
|
+ ];
|
|
|
+
|
|
|
+ if(empty($data['title']) || empty($data['real_name']) || empty($data['mobile']) || empty($data['address'])){
|
|
|
+ continue;
|
|
|
+ }
|
|
|
+ $data['third_type'] = 2;
|
|
|
+ $data['work_status'] = 3;
|
|
|
+ $data['work_pay_status'] = 2;
|
|
|
+ $data['category_type'] = 2;
|
|
|
+ $data['appointment_time'] = $data['appointment_time'] ? strtotime($data['appointment_time']) : 0;
|
|
|
+ $data['work_sn'] = generate_sn(GroupServiceWork::class, 'work_sn');
|
|
|
+ GroupServiceWork::create($data);
|
|
|
+ }
|
|
|
+ return true;
|
|
|
+ } else {
|
|
|
+ self::setError($file->getError());
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ } catch (\Exception $e) {
|
|
|
+ self::setError($e->getMessage());
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
}
|