ServiceWorkLogic.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | likeadmin快速开发前后端分离管理后台(PHP版)
  4. // +----------------------------------------------------------------------
  5. // | 欢迎阅读学习系统程序代码,建议反馈是我们前进的动力
  6. // | 开源版本可自由商用,可去除界面版权logo
  7. // | gitee下载:https://gitee.com/likeshop_gitee/likeadmin
  8. // | github下载:https://github.com/likeshop-github/likeadmin
  9. // | 访问官网:https://www.likeadmin.cn
  10. // | likeadmin团队 版权所有 拥有最终解释权
  11. // +----------------------------------------------------------------------
  12. // | author: likeadminTeam
  13. // +----------------------------------------------------------------------
  14. namespace app\adminapi\logic\works;
  15. use app\api\logic\PerformanceLogic;
  16. use app\common\model\dict\DictData;
  17. use app\common\model\master_worker\MasterWorker;
  18. use app\common\model\master_worker\MasterWorkerAccountLog;
  19. use app\common\model\performance\PerformanceRules;
  20. use app\common\model\recharge\OrderGoods;
  21. use app\common\model\recharge\RechargeOrder;
  22. use app\common\model\spare_part\SparePart;
  23. use app\common\model\works\ServiceWork;
  24. use app\common\logic\BaseLogic;
  25. use app\common\model\works\ServiceWorkAllocateWorkerLog;
  26. use app\common\model\works\ServiceWorkAppointmentLog;
  27. use app\common\model\works\ServiceWorkLog;
  28. use app\common\model\works\ServiceWorkSpare;
  29. use app\workerapi\logic\ServiceWorkerAllocateWorkerLogic;
  30. use app\workerapi\logic\ServiceWorkLogLogic;
  31. use think\db\Query;
  32. use think\Exception;
  33. use think\facade\Db;
  34. /**
  35. * ServiceWork逻辑
  36. * Class ServiceWorkLogic
  37. * @package app\adminapi\logic\works
  38. */
  39. class ServiceWorkLogic extends BaseLogic
  40. {
  41. /**
  42. * @notes 编辑
  43. * @param array $params
  44. * @return bool
  45. * @author likeadmin
  46. * @date 2024/07/10 18:17
  47. */
  48. public static function edit(array $params): bool
  49. {
  50. Db::startTrans();
  51. try {
  52. ServiceWork::where('id', $params['id'])->update([
  53. 'address' => $params['address'],
  54. 'appointment_time' => strtotime($params['appointment_time']),
  55. 'lon' => $params['lon'],
  56. 'lat' => $params['lat'],
  57. ]);
  58. Db::commit();
  59. return true;
  60. } catch (\Exception $e) {
  61. Db::rollback();
  62. self::setError($e->getMessage());
  63. return false;
  64. }
  65. }
  66. /**
  67. *
  68. * @return false|void
  69. */
  70. public static function pickWork($params)
  71. {
  72. Db::startTrans();
  73. try {
  74. $work = ServiceWork::where(['master_worker_id'=>$params['user_id'],'work_sn'=>$params['work_sn']])->findOrEmpty();
  75. if($work->isEmpty()){
  76. throw new Exception('工单不存在');
  77. }
  78. $receive_time = time();
  79. $work->work_status = 2;//待联系
  80. $work->service_status = 1;//服务中
  81. $work->receive_time = $receive_time;
  82. $work->save();
  83. //添加变更日志
  84. $work_log = [
  85. 'work_id'=>$work->id,
  86. 'master_worker_id'=>$work->master_worker_id,
  87. 'opera_log'=>'编号['.$params['user_info']['worker_number'].']'.$params['user_info']['real_name'].'于'.date('y-m-d H:i:s',$receive_time).'领取了工单',
  88. ];
  89. ServiceWorkLogLogic::add($work_log);
  90. Db::commit();
  91. }
  92. catch (\Exception $e) {
  93. Db::rollback();
  94. self::setError($e->getMessage());
  95. return false;
  96. }
  97. }
  98. /**
  99. * 预约成功,等待上门
  100. * @return false|void
  101. */
  102. public static function appointWork($params)
  103. {
  104. Db::startTrans();
  105. try {
  106. $work = ServiceWork::where(['master_worker_id'=>$params['user_id'],'work_sn'=>$params['work_sn']])->findOrEmpty();
  107. if($work->isEmpty()){
  108. throw new Exception('工单不存在');
  109. }
  110. if($work->work_status != 2){
  111. throw new Exception('请勿重复点击');
  112. }
  113. //验证更改的预约时间必须是在领单时间内的半小内修改,否则不允许修改
  114. if(strtotime($work->appointment_time) != strtotime($params['appointment_time']) && (time()-strtotime($work->receive_time))>1800){
  115. throw new Exception('距离领单时间已超过半小时,无法修改预约时间,请联系客服');
  116. }
  117. $work->work_status = 3;//待上门
  118. $work->appointment_time = strtotime($params['appointment_time']);
  119. $work->save();
  120. //添加变更日志
  121. $work_log = [
  122. 'work_id'=>$work->id,
  123. 'master_worker_id'=>$work->master_worker_id,
  124. 'opera_log'=>'编号['.$params['user_info']['worker_number'].']'.$params['user_info']['real_name'].'于'.date('y-m-d H:i:s',time()).'联系了客户,确认了于'.$params['appointment_time'].$params['address'].'预约上门',
  125. ];
  126. ServiceWorkLogLogic::add($work_log);
  127. Db::commit();
  128. }
  129. catch (\Exception $e) {
  130. self::setError($e->getMessage());
  131. return false;
  132. }
  133. }
  134. /**
  135. * 工程师确认上门
  136. * @param $params
  137. * @return false|void
  138. */
  139. public static function confirmDoor($params)
  140. {
  141. Db::startTrans();
  142. try {
  143. $work = ServiceWork::where(['master_worker_id'=>$params['user_id'],'work_sn'=>$params['work_sn']])->findOrEmpty();
  144. if($work->isEmpty()){
  145. throw new Exception('工单不存在');
  146. }
  147. if($work->work_status != 3){
  148. throw new Exception('请勿重复点击');
  149. }
  150. $work->work_status = 4;//已上门
  151. $work->save();
  152. //添加变更日志
  153. $work_log = [
  154. 'work_id'=>$work->id,
  155. 'master_worker_id'=>$work->master_worker_id,
  156. '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()).'已上门',
  157. ];
  158. ServiceWorkLogLogic::add($work_log);
  159. Db::commit();
  160. }
  161. catch (\Exception $e) {
  162. Db::rollback();
  163. self::setError($e->getMessage());
  164. return false;
  165. }
  166. }
  167. /**
  168. * 工程师确认报价单
  169. * @param $params
  170. * @return false|void
  171. */
  172. public static function confirmPrice($params)
  173. {
  174. Db::startTrans();
  175. try {
  176. $work = ServiceWork::where(['master_worker_id'=>$params['user_id'],'work_sn'=>$params['work_sn']])->findOrEmpty();
  177. if($work->isEmpty()){
  178. throw new Exception('工单不存在');
  179. }
  180. //搜索待支付订单
  181. $paid_order = RechargeOrder::where(['work_id'=>$work['id'],'pay_status'=>1])->findOrEmpty()->toArray();
  182. if(empty($paid_order)){
  183. throw new Exception('订单错误');
  184. }
  185. if($work->work_status != 4){
  186. throw new Exception('请勿重复操作');
  187. }
  188. // 关联配件信息.计算配件总价 id company_price original_price offering_price number
  189. $spare_total = 0;
  190. isset($params['spare_parts']) && $params['spare_parts'] && $params['spare_parts'] = json_decode($params['spare_parts'], true);
  191. if(isset($params['spare_parts']) && $params['spare_parts']){
  192. $spare_parts = $params['spare_parts'];
  193. foreach ($spare_parts as $spare){
  194. $spare_total += $spare['company_price']*$spare['number'];
  195. }
  196. $work->spare_total = $spare_total;
  197. $service_work_spare = ServiceWorkSpare::where(['service_work_id'=>$work['id']])->findOrEmpty();
  198. if($service_work_spare->isEmpty()){
  199. //新增
  200. $service_work_spare = ServiceWorkSpare::create([
  201. 'service_work_id'=>$work['id'],
  202. 'spare_parts'=>$params['spare_parts'],
  203. 'remark'=>''
  204. ]);
  205. }else{
  206. //修改
  207. $service_work_spare->spare_parts = $params['spare_parts'];
  208. $service_work_spare->save();
  209. }
  210. $work->service_work_spare_id = $service_work_spare->id;
  211. }
  212. // order_amount 原 = $params['amount'] 修改为 = 配件总价 + 服务尾款
  213. $order_amount = $params['amount'] + $spare_total;
  214. //定金存在尾款结算功能,全款直接提交
  215. if($paid_order['payment_type']==1){
  216. $un_order = RechargeOrder::where(['work_id'=>$work['id'],'pay_status'=>0])->findOrEmpty();
  217. if($un_order->isEmpty()){
  218. //新增待支付尾款
  219. $order_data = [
  220. 'order_type'=>$paid_order['order_type'],
  221. 'sn'=>generate_sn(\app\common\model\orders\RechargeOrder::class, 'sn'),
  222. 'work_id'=>$paid_order['work_id'],
  223. 'user_id'=>$paid_order['user_id'],
  224. 'payment_type'=>2,
  225. 'order_total'=>$order_amount,
  226. //'order_amount'=>$params['amount'],
  227. 'order_amount'=>$order_amount,
  228. 'order_terminal'=>$paid_order['order_terminal']
  229. ];
  230. RechargeOrder::create($order_data);
  231. }else{
  232. //修改尾款信息
  233. $un_order->order_total = $order_amount;
  234. //$un_order->order_amount = $params['amount'];
  235. $un_order->order_amount = $order_amount;
  236. $un_order->save();
  237. }
  238. //更新服务费用
  239. $work->service_fee = $paid_order['paid_amount']+$params['amount'];
  240. }
  241. //总工单费用
  242. $work->work_total = $order_amount + $paid_order['paid_amount'];
  243. $work->work_images = $params['work_images'];
  244. $work->user_confirm_status = 1;//待确认报价
  245. $work->price_approval = 0;
  246. $work->save();
  247. //添加变更日志
  248. $work_log = [
  249. 'work_id'=>$work->id,
  250. 'master_worker_id'=>$work->master_worker_id,
  251. '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()).'提交了报价单',
  252. ];
  253. ServiceWorkLogLogic::add($work_log);
  254. Db::commit();
  255. }
  256. catch (\Exception $e) {
  257. Db::rollback();
  258. self::setError($e->getMessage());
  259. return false;
  260. }
  261. }
  262. /**
  263. * 工程师确认服务完成
  264. * @param $params
  265. * @return false|void
  266. */
  267. public static function confirmServiceFinish($params)
  268. {
  269. Db::startTrans();
  270. try {
  271. $work = ServiceWork::where(['master_worker_id'=>$params['user_id'],'work_sn'=>$params['work_sn']])->findOrEmpty();
  272. if($work->isEmpty()){
  273. throw new Exception('工单不存在');
  274. }
  275. if($work->user_confirm_status !=2){
  276. throw new Exception('请勿重复操作');
  277. }
  278. $work->finished_images = $params['finished_images'];
  279. $work->user_confirm_status = 3;//待确认服务完成
  280. $work->save();
  281. //添加变更日志
  282. $work_log = [
  283. 'work_id'=>$work->id,
  284. 'master_worker_id'=>$work->master_worker_id,
  285. '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()).'提交了待用户确认服务完成',
  286. ];
  287. ServiceWorkLogLogic::add($work_log);
  288. Db::commit();
  289. } catch (\Exception $e) {
  290. Db::rollback();
  291. self::setError($e->getMessage());
  292. return false;
  293. }
  294. }
  295. public static function allocateWorker($params,$userInfo){
  296. Db::startTrans();
  297. try {
  298. $work = ServiceWork::findOrEmpty($params['id']);
  299. if($work->isEmpty()){
  300. throw new Exception('工单不存在');
  301. }
  302. if($work->work_status >=6 ){
  303. throw new \Exception('工单状态只能修改待结算之前的');
  304. }
  305. if($work->master_worker_id == $params['master_worker_id']){
  306. throw new \Exception('分配的工程师相同');
  307. }
  308. $worker = MasterWorker::where(['id'=>$params['master_worker_id'],'is_disable' =>0])->findOrEmpty();
  309. if($worker->isEmpty()){
  310. throw new \Exception('工程师不存在或被禁用');
  311. }
  312. if($worker->master_worker_id){
  313. MasterWorker::setWorktotal('dec',$worker->master_worker_id);
  314. }
  315. $work->master_worker_id = $params['master_worker_id'];
  316. $work->work_status = 1;
  317. $work->dispatch_time = time();
  318. MasterWorker::setWorktotal('inc',$params['master_worker_id']);
  319. $work->save();
  320. $work_log = [
  321. 'work_id'=>$work->id,
  322. 'master_worker_id'=>$work->master_worker_id,
  323. 'opera_log'=>'后台用户['.$userInfo['admin_id'].']'.$userInfo['name'].'于'.date('Y-m-d H:i:s',time()).'分配了工程师'.'编号['.$worker->worker_number.']'.$worker->real_name
  324. ];
  325. ServiceWorkerAllocateWorkerLogic::add($work_log);
  326. Db::commit();
  327. return true;
  328. }catch(\Exception $e){
  329. Db::rollback();
  330. self::setError($e->getMessage());
  331. return false;
  332. }
  333. }
  334. /**
  335. * 工单详情
  336. * @param $params
  337. * @return array|false
  338. */
  339. public static function detail($params){
  340. $work_where = !empty($params['work_sn'])?['work_sn'=>$params['work_sn']]:['id'=>$params['id']];
  341. $result = ServiceWork::with([
  342. 'worker'=> function(Query $query) {
  343. $query->field('id,worker_number,real_name,mobile');
  344. },
  345. 'allocateWorkerLog' =>function(Query $query){
  346. $query->field('id,work_id,opera_log,create_time');
  347. },
  348. 'serviceWorkLog' =>function(Query $query){
  349. $query->field('id,work_id,opera_log,create_time');
  350. }
  351. ])->append(['id','work_status_text','service_status_text'])
  352. ->where($work_where)
  353. ->findOrEmpty()->toArray();
  354. //工程师工单按钮状态
  355. $work_service_status = 0;
  356. $work_service_status_text = '待派单';
  357. //工单状态
  358. if($result['work_status'] == 1){
  359. $work_service_status = 1;
  360. $work_service_status_text = '待领单';
  361. }
  362. if($result['work_status'] == 2){
  363. $work_service_status = 2;
  364. $work_service_status_text = '预约上门';
  365. }
  366. if($result['work_status'] == 3){
  367. $work_service_status = 3;
  368. $work_service_status_text = '等待上门';
  369. if(date('Y-m-d') === date('Y-m-d',strtotime($result['appointment_time']))){
  370. $work_service_status = 4;
  371. $work_service_status_text = '确认上门';
  372. }
  373. }
  374. if($result['work_status'] == 4 and $result['user_confirm_status']==0){
  375. $work_service_status = 5;
  376. $work_service_status_text = '确认报价';
  377. }
  378. if($result['work_status'] == 4 and $result['user_confirm_status']==1){
  379. $work_service_status = 6;
  380. $work_service_status_text = '用户确认报价中';
  381. }
  382. if($result['work_status'] == 5 and $result['user_confirm_status']==2){
  383. $work_service_status = 7;
  384. $work_service_status_text = '完成服务';
  385. }
  386. if($result['work_status'] == 5 and $result['user_confirm_status']==3){
  387. $work_service_status = 8;
  388. $work_service_status_text = '用户确认完成服务中';
  389. }
  390. if($result['work_status'] ==6){
  391. $work_service_status = 9;
  392. $work_service_status_text = '待结算';
  393. }
  394. if($result['work_status'] ==7){
  395. $work_service_status = 10;
  396. $work_service_status_text = '已完结';
  397. }
  398. if($result['work_status'] ==8){
  399. $work_service_status = 11;
  400. $work_service_status_text = '已评价';
  401. }
  402. if($result['work_status'] ==9){
  403. $work_service_status = 12;
  404. $work_service_status_text = '已退费';
  405. }
  406. $result['work_service_status'] = $work_service_status;
  407. $result['work_service_status_text'] = $work_service_status_text;
  408. //搜索当前工单下的所有订单记录
  409. $result['pay_orders'] = RechargeOrder::with(['orderGoods'=>function(Query $query){
  410. $query->field('id,sn,goods_id,goods_name,goods_image,goods_number,good_unit,goods_size,goods_payment_type,goods_type,goods_brand,base_service_fee,service_total,service_fee')->order(['id'=>'desc']);
  411. }])->where(['work_id'=>$result['id']])->field('id as order_id,sn,order_type,pay_status,payment_type,pay_way,pay_time,order_amount,order_total,coupon_price,create_time')->order('id asc')->select()->toArray();
  412. $pay_status_data = DictData::where('type_value','pay_status')->column('name','value');
  413. $payment_type_data = DictData::where('type_value','payment_type')->column('name','value');
  414. $pay_way_data = DictData::where('type_value','pay_way')->column('name','value');
  415. $order_type_data = DictData::where('type_value','order_type')->column('name','value');
  416. $coupon_price = 0;
  417. foreach ($result['pay_orders'] as $k=>&$v){
  418. $v['pay_status_name'] = $pay_status_data[$v['pay_status']];
  419. $v['payment_type_name'] = $payment_type_data[$v['payment_type']];
  420. $v['pay_way_name'] = $pay_way_data[$v['pay_way']];
  421. $v['order_type_name'] = $order_type_data[$v['order_type']];
  422. $v['pay_time'] = $v['pay_time'] && is_numeric($v['pay_time']) ? date('Y-m-d H:i:s',$v['pay_time']):'';
  423. if($v['payment_type']!=1 and !empty($result['spare_total'])){
  424. $v['order_total'] = $v['order_total'] - $result['spare_total'];
  425. $v['order_amount'] = $v['order_amount'] - $result['spare_total'];
  426. }
  427. $coupon_price += $v['coupon_price'];
  428. //服务支付类别
  429. if(!empty($v['orderGoods'][0]['goods_payment_type'])){
  430. $goods_payment_type = $v['orderGoods'][0]['goods_payment_type'];
  431. }
  432. }
  433. $result['goods_payment_type'] = !empty($goods_payment_type)?$goods_payment_type:1;
  434. //汇总优惠卷额度
  435. $result['coupon_price'] = $coupon_price;
  436. //工单总支付金额
  437. $result['worker_account'] = $result['work_amount'];
  438. // 配件信息
  439. $result['spare_parts'] = [];
  440. if($result['service_work_spare_id']){
  441. $work_spare_parts = json_decode(ServiceWorkSpare::where('id',$result['service_work_spare_id'])->value('spare_parts'),true);
  442. $spare_parts = SparePart::where('id','in',array_column($work_spare_parts,'id'))
  443. ->field(['id', 'goods_category_id', 'spare_name', 'spare_image', 'spare_number', 'spare_unit','spare_status'])
  444. ->select()
  445. ->toArray();
  446. $spare_parts = array_column($spare_parts,null,'id');
  447. foreach (array_column($work_spare_parts,null,'id') as $k=>&$v){
  448. $spare_parts[$k] = array_merge($spare_parts[$k],$v);
  449. }
  450. $result['spare_parts'] = array_values($spare_parts)??[];
  451. }
  452. //查收工程师提成金额
  453. $result['change_amount'] = MasterWorkerAccountLog::where(['work_sn'=>$result['work_sn'],'action'=>1])->value('change_amount');
  454. return $result;
  455. }
  456. public static function getDetailWorkServiceStatus($params)
  457. {
  458. $result = ServiceWork::where('id',$params['id'])->field('work_status,user_confirm_status,appointment_time,price_approval,appoint_approval')->findOrEmpty()->toArray();
  459. //工程师工单按钮状态
  460. $work_service_status = 0;
  461. //工单状态
  462. if($result['work_status'] == 1){
  463. $work_service_status = 1;
  464. }
  465. if($result['work_status'] == 2){
  466. $work_service_status = 2;
  467. }
  468. if($result['work_status'] == 3){
  469. $work_service_status = 3;
  470. if(date('Y-m-d') === date('Y-m-d',strtotime($result['appointment_time']))){
  471. $work_service_status = 4;
  472. }
  473. }
  474. if($result['work_status'] == 4 and $result['user_confirm_status']==0){
  475. $work_service_status = 5;
  476. }
  477. if($result['work_status'] == 4 and $result['user_confirm_status']==1){
  478. $work_service_status = 6;
  479. }
  480. if($result['work_status'] == 5 and $result['user_confirm_status']==2){
  481. $work_service_status = 7;
  482. }
  483. if($result['work_status'] == 5 and $result['user_confirm_status']==3){
  484. $work_service_status = 8;
  485. }
  486. if($result['work_status'] ==6){
  487. $work_service_status = 9;
  488. }
  489. if($result['work_status'] ==7){
  490. $work_service_status = 10;
  491. }
  492. if($result['work_status'] ==8){
  493. $work_service_status = 11;
  494. }
  495. if($result['work_status'] ==9){
  496. $work_service_status = 12;
  497. }
  498. return ['work_service_status'=>$work_service_status,'price_approval'=>$result['price_approval'],'appoint_approval'=>$result['appoint_approval']];
  499. }
  500. /**
  501. * @notes 取消操作
  502. * @param array $params
  503. * @return bool
  504. * @author likeadmin
  505. * @date 2024/09/19 10:48
  506. */
  507. public static function cancel(array $params): bool
  508. {
  509. Db::startTrans();
  510. try {
  511. $serviceWorkInfo = ServiceWork::find($params['id']);
  512. if((int)$serviceWorkInfo['work_status'] !== 0){
  513. throw new \Exception('该工单不可取消');
  514. }
  515. ServiceWork::where('id', $params['id'])->update([
  516. 'work_status' => 9,
  517. 'remark' => $params['remark']??''
  518. ]);
  519. // 对应订单状态修改
  520. RechargeOrder::where('work_id', $params['id'])->update([
  521. 'pay_status' => 2
  522. ]);
  523. ServiceWorkLog::create([
  524. 'work_id' => $params['id'],
  525. 'master_worker_id' => $serviceWorkInfo['master_worker_id'],
  526. 'opera_log' => "工单:{$serviceWorkInfo['work_sn']}已取消"
  527. ]);
  528. // 退款
  529. Db::commit();
  530. return true;
  531. } catch (\Exception $e) {
  532. Db::rollback();
  533. self::setError($e->getMessage());
  534. return false;
  535. }
  536. }
  537. /**
  538. * @notes 工程师结算操作
  539. * @param array $params
  540. * @return bool
  541. * @author likeadmin
  542. * @date 2024/09/19 10:48
  543. */
  544. public static function settlement(array $params): bool
  545. {
  546. Db::startTrans();
  547. try {
  548. $serviceWorkInfo = ServiceWork::find($params['id']);
  549. if((int)$serviceWorkInfo['work_pay_status'] !== 3){
  550. throw new \Exception('该工单非待结算状态');
  551. }
  552. //获取工单对应的商品id
  553. $order_sns = \app\common\model\orders\RechargeOrder::where('work_id',$serviceWorkInfo->id)->column('sn');
  554. $goods_id = OrderGoods::whereIn('sn',$order_sns)->value('goods_id');
  555. $rule = PerformanceRules::whereFindInSet('goods_id',$goods_id)->findOrEmpty();
  556. if($rule->isEmpty()){
  557. throw new \Exception('请配置商品业绩规则');
  558. }
  559. PerformanceLogic::calculatePerformance($serviceWorkInfo);
  560. Db::commit();
  561. return true;
  562. } catch (\Exception $e) {
  563. Db::rollback();
  564. self::setError($e->getMessage());
  565. return false;
  566. }
  567. }
  568. /**
  569. * 获取所有改约通知
  570. * @param $userId
  571. * @return array|false
  572. */
  573. public static function getAppointmentNotice($userId)
  574. {
  575. return ServiceWork::where(['master_worker_id'=>$userId,'appoint_approval'=>1])
  576. ->field(['id', 'work_sn','real_name','mobile', 'address', 'title', 'appointment_time'])
  577. ->order(['appointment_time' => 'asc'])//上门时间排序
  578. ->select()->each(function (&$item){
  579. $item['last_appointment_time'] = date('Y-m-d H:i:s',ServiceWorkAppointmentLog::where('work_id',$item['id'])->order('id desc')->value('last_appointment_time'));
  580. })
  581. ->toArray();
  582. }
  583. /**
  584. * @param $params
  585. * @return bool
  586. */
  587. public static function submitAppointment($params)
  588. {
  589. Db::startTrans();
  590. try {
  591. $serviceWork = ServiceWork::where('work_sn',$params['work_sn'])->findOrEmpty();
  592. if($serviceWork->isEmpty()){
  593. throw new \Exception('工单不存在');
  594. }
  595. $serviceWork->appoint_approval = 2;
  596. $serviceWork->save();
  597. Db::commit();
  598. return true;
  599. } catch (\Exception $e) {
  600. Db::rollback();
  601. self::setError($e->getMessage());
  602. return false;
  603. }
  604. }
  605. /**
  606. * @param $params
  607. * @return bool
  608. */
  609. public static function submitChangePrice($params)
  610. {
  611. Db::startTrans();
  612. try {
  613. $serviceWork = ServiceWork::where('work_sn',$params['work_sn'])->findOrEmpty();
  614. if($serviceWork->isEmpty()){
  615. throw new \Exception('工单不存在');
  616. }
  617. $serviceWork->work_status = 4;
  618. $serviceWork->user_confirm_status = 0;
  619. $serviceWork->price_approval = 2;
  620. $serviceWork->save();
  621. Db::commit();
  622. return true;
  623. } catch (\Exception $e) {
  624. Db::rollback();
  625. self::setError($e->getMessage());
  626. return false;
  627. }
  628. }
  629. public static function notApproved($params)
  630. {
  631. Db::startTrans();
  632. try {
  633. $serviceWork = ServiceWork::where('id',$params['id'])->findOrEmpty();
  634. if($serviceWork->isEmpty()){
  635. throw new \Exception('工单不存在');
  636. }
  637. $serviceWork->refund_approval = 3;
  638. $serviceWork->save();
  639. Db::commit();
  640. return true;
  641. } catch (\Exception $e) {
  642. Db::rollback();
  643. self::setError($e->getMessage());
  644. return false;
  645. }
  646. }
  647. public static function againDoor($params)
  648. {
  649. Db::startTrans();
  650. try {
  651. $serviceWork = ServiceWork::where('work_sn',$params['work_sn'])->findOrEmpty();
  652. if($serviceWork->isEmpty()){
  653. throw new \Exception('工单不存在');
  654. }
  655. //更新预约日志
  656. //更新工单未确认上门的状态
  657. $serviceWork->work_status = 3;
  658. $serviceWork->user_confirm_status = 0;
  659. ServiceWorkAppointmentLog::create([
  660. 'work_id'=>$serviceWork->id,
  661. 'last_appointment_time'=>$serviceWork->appointment_time,
  662. 'this_appointment_time'=>strtotime($params['appointment_time']),
  663. ]);
  664. $serviceWork->appointment_time = strtotime($params['appointment_time']);
  665. $serviceWork->save();
  666. Db::commit();
  667. return true;
  668. } catch (\Exception $e) {
  669. Db::rollback();
  670. self::setError($e->getMessage());
  671. return false;
  672. }
  673. }
  674. public static function cancelAllocation($params,$userInfo){
  675. Db::startTrans();
  676. try {
  677. $work = ServiceWork::findOrEmpty($params['id']);
  678. if($work->isEmpty()){
  679. throw new Exception('工单不存在');
  680. }
  681. if($work->work_status >=6 ){
  682. throw new \Exception('工单状态只能修改待结算之前的');
  683. }
  684. $worker = MasterWorker::where(['id'=>$work->master_worker_id])->findOrEmpty();
  685. if($worker->isEmpty()){
  686. throw new \Exception('工程师不存在');
  687. }
  688. MasterWorker::setWorktotal('dec',$work->master_worker_id);
  689. $work->master_worker_id = 0;
  690. $work->work_status = 0;
  691. $work->dispatch_time = 0;
  692. $work->save();
  693. $work_log = [
  694. 'work_id'=>$work->id,
  695. 'master_worker_id'=>$params['master_worker_id'],
  696. 'opera_log'=>'后台用户['.$userInfo['admin_id'].']'.$userInfo['name'].'于'.date('Y-m-d H:i:s',time()).'取消了工程师'.'编号['.$worker->worker_number.']'.$worker->real_name
  697. ];
  698. ServiceWorkerAllocateWorkerLogic::add($work_log);
  699. Db::commit();
  700. return true;
  701. }catch(\Exception $e){
  702. Db::rollback();
  703. dd($e->getMessage());
  704. self::setError($e->getMessage());
  705. return false;
  706. }
  707. }
  708. }