ProcessController.php 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Exports\WaybillExport;
  4. use App\Owner;
  5. use App\Process;
  6. use App\ProcessDaily;
  7. use App\ProcessDailyParticipant;
  8. use App\ProcessesContent;
  9. use App\ProcessMethod;
  10. use App\ProcessStatistic;
  11. use App\Tutorial;
  12. use App\UserDetail;
  13. use App\UserDutyCheck;
  14. use Carbon\Carbon;
  15. use Illuminate\Database\Eloquent\Builder;
  16. use Illuminate\Http\Request;
  17. use Illuminate\Support\Facades\Auth;
  18. use Illuminate\Support\Facades\DB;
  19. use Illuminate\Support\Facades\Gate;
  20. use Illuminate\Support\Facades\Validator;
  21. use Maatwebsite\Excel\Facades\Excel;
  22. use Ramsey\Uuid\Uuid;
  23. class ProcessController extends Controller
  24. {
  25. public function conditionQuery(Request $request,$processes){
  26. if(!Gate::allows('二次加工管理-查询')){ return redirect(url('/')); }
  27. $today=Carbon::now()->subDays(15);
  28. if ($request->input('commodity_barcode')){
  29. $barcode=$request->input('commodity_barcode');
  30. $processes=$processes->with('processesContents')->whereHas('processesContents',function (Builder $query)use($barcode){
  31. $query->whereHas('commodity',function (Builder $builder)use($barcode){
  32. $builder->whereHas('barcodes',function (Builder $builder)use($barcode){
  33. $builder->where('code','like',$barcode.'%');
  34. });
  35. });
  36. });
  37. }
  38. if ($request->input('date_start')){
  39. $processes=$processes->where('created_at','>=',$request->input('date_start'));
  40. }
  41. if ($request->input('date_end')){
  42. $processes=$processes->where('created_at','<=',$request->input('date_end'));
  43. }
  44. if ($request->input('owner_id')){
  45. $processes=$processes->where('owner_id',$request->input('owner_id'));
  46. }
  47. if ($request->input('status')){
  48. $processes=$processes->where('status',$request->input('status'));
  49. }
  50. if ($request->input('wms_code')){
  51. $wms_code=$request->input('wms_code');
  52. $date=$today->format('Y-m-d');
  53. $processes=$processes->whereHas('processesContents',function (Builder $builder)use ($wms_code,$date){
  54. $builder->where('wms_code','like','%'.$wms_code.'%')
  55. ->where('created_at','>',$date);
  56. });
  57. }
  58. $processes=$processes->paginate($request->input('paginate')??50);
  59. return $processes;
  60. }
  61. /**
  62. * Display a listing of the resource.
  63. * @param Request $request
  64. * @return \Illuminate\Http\Response
  65. */
  66. public function index(Request $request)
  67. {
  68. if(!Gate::allows('二次加工管理-查询')){ return redirect(url('/')); }
  69. $processes=Process::with(['tutorials','processesContents'=>function($query){
  70. return $query->with(['commodity'=>function($query){
  71. return $query->with('barcodes');
  72. }]);
  73. }])->orderBy('processes.id','DESC');
  74. if ($request->input('checkSign')){
  75. $excel=$this->isExport($request,$processes);
  76. return $excel;
  77. }
  78. $processes=$this->conditionQuery($request,$processes);
  79. $owners=Owner::select('id','name')->get();
  80. return view('process.index',['processes'=>$processes,'owners'=>$owners,'request'=>$request->input()]);
  81. }
  82. //获取导出数据
  83. public function isExport(Request $request,$processes){
  84. if(!Gate::allows('二次加工管理-查询')){ return redirect(url('/')); }
  85. if ($request->input('checkSign')=="-1"){
  86. $processes=$this->conditionQuery($request,$processes);
  87. $excel=$this->export($processes);
  88. return $excel;
  89. }
  90. $id = explode( ',',$request->input('checkSign'));
  91. $processes=$processes->whereIn('id',$id)->get();
  92. $excel=$this->export($processes);
  93. return $excel;
  94. }
  95. //获取每日参与人
  96. public function getDailyParticipant(Request $request){
  97. if(!Gate::allows('二次加工管理-登记工时')){ return redirect(url('/')); }
  98. $today=Carbon::now()->format('Y-m-d');
  99. $id=$request->input('id');
  100. $processDailies=ProcessDaily::with(['processDailyParticipants','process'])->orderBy('date','DESC')
  101. ->where('process_id',$id)->get();
  102. if (count($processDailies)>0){
  103. $result=$this->createDeficiencyData($processDailies,$today);
  104. if ($result){
  105. $processDailies=ProcessDaily::with(['processDailyParticipants','process'])
  106. ->orderBy('date','DESC')->where('process_id',$id)->get();
  107. }
  108. $processDailies=$this->countManHour($processDailies);
  109. }
  110. return $processDailies;
  111. }
  112. //根据参与人查找打卡记录计算工时信息
  113. public function countManHour($processDailies){
  114. foreach ($processDailies as $processDaily){
  115. $date=$processDaily->date;
  116. foreach ($processDaily->processDailyParticipants as $processDailyParticipant){
  117. $processDailyParticipant->started_at=Carbon::parse($processDailyParticipant->started_at)->format('H:i');
  118. $processDailyParticipant->ended_at=Carbon::parse($processDailyParticipant->ended_at)->format('H:i');
  119. $processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$date);
  120. }
  121. }
  122. return $processDailies;
  123. }
  124. //计算单参与人工时信息
  125. public function countParticipantManHour($processDailyParticipant,$date){
  126. $user=$processDailyParticipant->user_id;
  127. $userDutyCheckStart=UserDutyCheck::select('id','checked_at')->where('user_id',$user)
  128. ->where('checked_at','like',$date.'%')->where('type','登入')->orderBy('id')->first();
  129. $userDutyCheckEnd=UserDutyCheck::select('id','checked_at')->where('user_id',$user)
  130. ->where('checked_at','like',$date.'%')->where('type','登出')->orderBy('id','desc')->first();
  131. //跨日情况寻找下一天
  132. if (!$userDutyCheckEnd){
  133. $date=date("Y-m-d",strtotime("+1 day",strtotime($date)));
  134. $userDutyCheckEnd=UserDutyCheck::select('id','checked_at')->where('user_id',$user)
  135. ->where('checked_at','like',$date.'%')->where('type','登出')->orderBy('id','desc')->first();
  136. }
  137. if (!$userDutyCheckStart || !$userDutyCheckEnd){
  138. return $processDailyParticipant;
  139. }
  140. $dateStart=Carbon::parse($userDutyCheckStart->checked_at);
  141. $dateEnd=Carbon::parse($userDutyCheckEnd->checked_at);
  142. $hour=($dateEnd->diffInSeconds($dateStart))/3600; //打卡工时
  143. if ($processDailyParticipant->dinner_duration)$hour=$hour-(($processDailyParticipant->dinner_duration)/60); //减晚饭时间
  144. $hour=$this->isHour($userDutyCheckStart,$hour); //去除休息时间
  145. $processDailyParticipant->hour=round($hour,2);
  146. if ($hour&&$processDailyParticipant->hour_count){
  147. $diff=abs(round($processDailyParticipant->hour_count-$hour,2));
  148. $processDailyParticipant->diff=$diff;
  149. }
  150. //计件工 保留
  151. /*if ($processDailyParticipant->unit_count){
  152. return $processDailyParticipant;
  153. }*/
  154. if ($hour&&$hour>8){
  155. $processDailyParticipant->billingHour=8;
  156. return $processDailyParticipant;
  157. }
  158. if ($hour&&$hour<=8){
  159. $processDailyParticipant->billingHour=round($hour,2);
  160. }
  161. return $processDailyParticipant;
  162. }
  163. //打卡工时减休息时间
  164. public function isHour($userDutyCheckStart,$hour){
  165. $date=$userDutyCheckStart->checked_at;
  166. $date=Carbon::parse($date)->format('H');
  167. if ((int)$date<=11){
  168. $hour=$hour-1;
  169. }
  170. return $hour;
  171. }
  172. //生成二次加工单缺失时间记录及本日记录
  173. public function createDeficiencyData($processDailies,$today){
  174. $processDailiesArr=[];
  175. foreach ($processDailies as $processDaily){
  176. $processDailiesArr[$processDaily->date]=$processDaily;
  177. }
  178. $processDailyOne=$processDailies[count($processDailies)-1];
  179. $startDate=Carbon::parse($processDailyOne->date);
  180. $diffDay=$startDate->diffInDays($today,true);
  181. $remain=$processDailyOne->remain;
  182. $processId=$processDailyOne->process_id;
  183. for ($i=1;$i<=$diffDay;$i++){
  184. $date=date("Y-m-d",strtotime('+'.strval($i)." day",strtotime($startDate)));
  185. if (!isset($processDailiesArr[$date])){
  186. $processDaily=new ProcessDaily([
  187. 'process_id'=>$processId,
  188. 'date'=>$date,
  189. 'output'=>0,
  190. 'remain'=>$remain
  191. ]);
  192. $processDaily->save();
  193. }
  194. if (isset($processDailiesArr[$date])){
  195. $remain=$remain-($processDailiesArr[$date]->output);
  196. }
  197. }
  198. return true;
  199. }
  200. //驳回二次加工单
  201. public function reject($id){
  202. if(!Gate::allows('二次加工管理-接单与驳回')){ return redirect(url('/')); }
  203. $process=Process::select('id','status')->find($id);
  204. $process->status="驳回";
  205. $process->update();
  206. $this->log(__METHOD__,"驳回二次加工单_".__FUNCTION__,json_encode($process),Auth::user()['id']);
  207. return $process;
  208. }
  209. //接单
  210. public function receive($id){
  211. if(!Gate::allows('二次加工管理-接单与驳回')){ return redirect(url('/')); }
  212. $process=Process::select('id','status','amount')->find($id);
  213. $amount=$process->amount;
  214. $today=Carbon::now()->format('Y-m-d');
  215. $processDaily=new ProcessDaily([
  216. 'process_id'=>$id,
  217. 'date'=>$today,
  218. 'output'=>0,
  219. 'remain'=>$amount,
  220. ]);
  221. $processDaily->save();
  222. $process->status="待加工";
  223. $process->update();
  224. $this->log(__METHOD__,"接单二次加工单_".__FUNCTION__,json_encode($process),Auth::user()['id']);
  225. return $process;
  226. }
  227. //完成
  228. public function accomplish($id){
  229. if(!Gate::allows('二次加工管理-验收完成')){ return redirect(url('/')); }
  230. $process=Process::with('processDailies')->find($id);
  231. if (count($process->processDailies)>0){
  232. $completed_amount=0;
  233. foreach ($process->processDailies as $processDaily){
  234. $completed_amount=$completed_amount+($processDaily->output);
  235. }
  236. $process->completed_amount=$completed_amount;
  237. }
  238. $process->status="已完成";
  239. $process->update();
  240. //统计:
  241. $revenue=($process->unit_price)*($process->completed_amount); //收入合计
  242. $processDailies=ProcessDaily::with('processDailyParticipants')->where('process_id',$id)->where('output','>',0)->get();
  243. $duration_days=count($processDailies); //完成天数
  244. $duration_man_hours=0; //总工时
  245. $total_cost=0; //合计成本
  246. foreach ($processDailies as $processDailyOne){
  247. foreach ($processDailyOne->processDailyParticipants as $processDailyParticipant){
  248. $processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$processDailyOne->date);
  249. $duration_man_hours=$duration_man_hours+($processDailyParticipant->billingHour);
  250. if ($processDailyParticipant->unit_count){
  251. $total_cost=$total_cost+(($processDailyParticipant->unit_count)*($processDailyParticipant->unit_price));
  252. continue;
  253. }
  254. $total_cost=$total_cost+(($processDailyParticipant->billingHour)*($processDailyParticipant->hour_price));
  255. }
  256. };
  257. $gross_profit=$revenue-$total_cost; //毛利润
  258. $gross_profit_rate=$gross_profit/$revenue; //毛利率
  259. $processStatistic=ProcessStatistic::find($id);
  260. $processStatistic->revenue=$revenue;
  261. $processStatistic->duration_days=$duration_days;
  262. $processStatistic->duration_man_hours=$duration_man_hours;
  263. $processStatistic->total_cost=$total_cost;
  264. $processStatistic->gross_profit=$gross_profit;
  265. $processStatistic->gross_profit_rate=$gross_profit_rate;
  266. $processStatistic->update();
  267. $this->log(__METHOD__,"完成二次加工单_".__FUNCTION__,json_encode($process)." || ".json_encode($processStatistic),Auth::user()['id']);
  268. return $process;
  269. }
  270. //修改当日产量
  271. public function updateDailyOutput(Request $request){
  272. if(!Gate::allows('二次加工管理-登记工时')){ return redirect(url('/')); }
  273. $errors=$this->validator($request)->errors();
  274. if (count($errors)>0)return ['status'=>"error",'data'=>$errors];
  275. $id=$request->input('id');
  276. $output=$request->input('output');
  277. $processDaily=ProcessDaily::with('process')->find($id);
  278. $processDaily->output=$output;
  279. $processDaily->update();
  280. $result=$this->countRemains($processDaily);
  281. $processDailies=$result['processDailies'];
  282. //$remain=$this->countRemain($processDaily);
  283. //$processDaily->remain=$remain;
  284. $this->log(__METHOD__,"修改当日产量".__FUNCTION__,json_encode($processDaily),Auth::user()['id']);
  285. $response=[];
  286. $response['status']='success';
  287. $response['data']=$processDailies;
  288. if (isset($result['process'])){$response['process']=$result['process'];}
  289. return $response;
  290. }
  291. //每次修改,去查询该单下全部日期,逐个替换,前一天剩余减当天产量为当天剩余,无前天记录去拿单子预期产量
  292. public function countRemains($processDaily){
  293. if (!$processDaily || !$processDaily->process) return;
  294. $processDailies=ProcessDaily::where('process_id',$processDaily->process_id)->orderBy('date')->get();
  295. for ($i=0;$i<count($processDailies);$i++){
  296. if ($i==0&&$processDailies[$i]->date>=$processDaily->date){
  297. $processDailies[$i]->remain=($processDaily->process->amount)-$processDailies[$i]->output;
  298. $processDailies[$i]->update();
  299. }
  300. if ($i>0&&$processDailies[$i]->date>=$processDaily->date){
  301. $processDailies[$i]->remain=($processDailies[$i-1]->remain)-$processDailies[$i]->output;
  302. $processDailies[$i]->update();
  303. }
  304. }
  305. //同步二次加工单统计
  306. $processDailiesStatistic=$processDailies->where('output','>',0);
  307. $processStatistic=ProcessStatistic::find($processDaily->process_id);
  308. $processStatistic->top_capacity=$processDailiesStatistic->max('output');
  309. $processStatistic->bottom_capacity=$processDailiesStatistic->min('output');
  310. $processStatistic->average_capacity=$processDailiesStatistic->avg('output');
  311. $processStatistic->update();
  312. //修改二次加工单状态
  313. $result=[];
  314. if (count($processDailies)>0 && ($processDailies[(count($processDailies)-1)]->remain)<=0){
  315. $result['process']=$this->changeProcessCheck($processDaily->process_id);
  316. }
  317. $result['processDailies']=$processDailies;
  318. return $result;
  319. }
  320. //剩余小于等于0,状态待验收
  321. public function changeProcessCheck($process_id){
  322. $process=Process::select('id','status')->find($process_id);
  323. if ($process->status=="加工中"){
  324. $process->status="待验收";
  325. $process->update();
  326. $processStatistic=ProcessStatistic::find($process_id);
  327. $processStatistic->ended_at=date('Y-m-d H:i:s');
  328. $processStatistic->update();
  329. $this->log(__METHOD__,"二次加工单待验收".__FUNCTION__,json_encode($process)." || ".json_encode($processStatistic),Auth::user()['id']);
  330. }
  331. return $process_id;
  332. }
  333. /*//计算当日剩余 根据日期
  334. public function countRemain($processDaily){
  335. if (!$processDaily || !$processDaily->process) return;
  336. $processDailies=ProcessDaily::where('process_id',$processDaily->process_id)
  337. ->where('date','<=',$processDaily->date)->get();
  338. $sum=0;
  339. foreach ($processDailies as $processDaily){
  340. $sum=$sum+($processDaily->output);
  341. }
  342. return ($processDaily->process->amount)-$sum;
  343. }*/
  344. //添加参与人
  345. public function shortProcessDailyParticipant(Request $request){
  346. if(!Gate::allows('二次加工管理-登记工时')){ return redirect(url('/')); }
  347. $errors=$this->validatorProcessDailyParticipant($request)->errors();
  348. if (count($errors)>0)return ['status'=>"error",'data'=>$errors];
  349. $user_id=$request->input('user_id');
  350. $started_at=$request->input('started_at');
  351. $ended_at=$request->input('ended_at');
  352. $daily_id=$request->input('daily_id');
  353. $hour_count=$request->input('hour_count');
  354. $unit_count=$request->input('unit_count');
  355. $hour_price=$request->input('hour_price');
  356. $unit_price=$request->input('unit_price');
  357. $dinner_duration=$request->input('dinner_duration');
  358. $remark=$request->input('remark');
  359. $processDailyParticipant=new ProcessDailyParticipant([
  360. 'process_daily_id'=>$daily_id,
  361. 'user_id'=>$user_id,
  362. 'started_at'=>$started_at,
  363. 'ended_at'=>$ended_at,
  364. 'hour_price'=>$hour_price,
  365. 'hour_count'=>$hour_count,
  366. 'unit_price'=>$unit_price,
  367. 'unit_count'=>$unit_count,
  368. 'dinner_duration'=>$dinner_duration,
  369. 'remark'=>$remark,
  370. ]);
  371. $processDailyParticipant->save();
  372. $this->log(__METHOD__,"添加新参与人".__FUNCTION__,json_encode($processDailyParticipant),Auth::user()['id']);
  373. $result=[];
  374. $processDaily=ProcessDaily::with('process')->select('process_id','date')->find($daily_id);
  375. $date=$processDaily->date;
  376. $processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$date);
  377. if ($processDaily->process && $processDaily->process->status=="待加工"){
  378. $process=Process::find($processDaily->process_id);
  379. $process->status="加工中";
  380. $process->update();
  381. $result['process']=$processDaily->process_id;
  382. $processStatistic=ProcessStatistic::find($processDaily->process_id);
  383. $processStatistic->started_at=date('Y-m-d H:i:s');
  384. $processStatistic->update();
  385. $this->log(__METHOD__,"二次加工单加工中".__FUNCTION__,json_encode($process)." || ".json_encode($processStatistic),Auth::user()['id']);
  386. }
  387. $result['status']="success";
  388. $result['data']=$processDailyParticipant;
  389. return $result;
  390. }
  391. //验证参与人
  392. public function verifyUserName(Request $request){
  393. $userName=$request->input('userName');
  394. if (!$userName) return;
  395. $result=$this->seekUserLabor($userName);
  396. return $result;
  397. }
  398. //根据全名查询临时工
  399. public function seekUserLabor($userName){
  400. $userDetails=UserDetail::with('user_labor')->where('type','临时工')->where('full_name',$userName)->get();
  401. if (!$userDetails)return;
  402. if (count($userDetails)==1){
  403. if (!$userDetails[0]->user_labor)return;
  404. return $userDetails[0];
  405. }
  406. //多个同名
  407. foreach ($userDetails as $userDetail){
  408. $userDutyCheck=UserDutyCheck::select('checked_at')->where("user_id",$userDetail->user_id)->orderBy('checked_at','DESC')->first();
  409. if ($userDutyCheck)$userDetail->checked_at=$userDutyCheck->checked_at;
  410. }
  411. if (!$userDetails)return;
  412. return $userDetails;
  413. }
  414. //修改参与人
  415. public function updateProcessDailyParticipant(Request $request){
  416. if(!Gate::allows('二次加工管理-登记工时')){ return redirect(url('/')); }
  417. $id=$request->input('id');
  418. if (!$id) return ['status'=>"error",'data'=>"修改失败,ID未传递"];
  419. $errors=$this->validatorProcessDailyParticipant($request)->errors();
  420. if (count($errors)>0)return ['status'=>"error",'data'=>$errors];
  421. $processDailyParticipant=ProcessDailyParticipant::with('processDaily')->find($id);
  422. if (!$processDailyParticipant || ! $processDailyParticipant->processDaily) return ['status'=>"error",'data'=>"修改失败,该信息不存在"];
  423. $processDailyParticipant->user_id=$request->input('user_id');
  424. $processDailyParticipant->started_at=$request->input('started_at');
  425. $processDailyParticipant->ended_at=$request->input('ended_at');
  426. $processDailyParticipant->hour_count=$request->input('hour_count');
  427. $processDailyParticipant->unit_count=$request->input('unit_count');
  428. $processDailyParticipant->hour_price=$request->input('hour_price');
  429. $processDailyParticipant->unit_price=$request->input('unit_price');
  430. $processDailyParticipant->dinner_duration=$request->input('dinner_duration');
  431. $processDailyParticipant->remark=$request->input('remark');
  432. $processDailyParticipant->update();
  433. $this->log(__METHOD__,"修改参与人".__FUNCTION__,json_encode($processDailyParticipant),Auth::user()['id']);
  434. $processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$processDailyParticipant->processDaily->date);
  435. return ['status'=>"success",'data'=>$processDailyParticipant];
  436. }
  437. //参与人审核
  438. public function processDailyParticipantAudit($id){
  439. if(!Gate::allows('二次加工管理-登记工时-审核')){ return redirect(url('/')); }
  440. $processDailyParticipant=ProcessDailyParticipant::select('id','status')->find($id);
  441. if (!$processDailyParticipant) return ['success'=>false];
  442. $processDailyParticipant->status='已审核';
  443. $processDailyParticipant->update();
  444. $this->log(__METHOD__,"登记工时参与人审核".__FUNCTION__,json_encode($processDailyParticipant),Auth::user()['id']);
  445. return ['success'=>true,'processDailyParticipant'=>$processDailyParticipant];
  446. }
  447. /*//临时工详情
  448. public function showUserDetail(Request $request){
  449. $id=$request->input('user_id');
  450. $userDetail=UserDetail::with('user_labor')->find($id);
  451. if (!$userDetail) return ['success'=>'false'];
  452. return ['success'=>'true','userDetail'=>$userDetail];
  453. }*/
  454. //获取全部教程
  455. public function getTutorials($id){
  456. $process=Process::with('tutorials')->find($id);
  457. $tutorials_id=[];
  458. if ($process->tutorials){
  459. foreach ($process->tutorials as $tutorial){
  460. array_push($tutorials_id,$tutorial->id);
  461. }
  462. }
  463. $tutorials=Tutorial::where('owner_id',$process->owner_id)->get();
  464. if ($tutorials_id && $tutorials) $tutorials=$tutorials->diff(Tutorial::whereIn('id',$tutorials_id)->get());
  465. return ['success'=>true,'data'=>$tutorials];
  466. }
  467. //添加教程关联
  468. public function selectedTutorial(Request $request){
  469. $process_id=$request->input('process_id');
  470. $tutorial_id=$request->input('tutorial_id');
  471. if (!$process_id || !$tutorial_id) return ['success'=>false,'data'=>'二次加工或教程传递错误!'];
  472. $tutorial=Tutorial::find($tutorial_id);
  473. if (!$tutorial)return ['success'=>false,'data'=>'未找到相关教程!'];
  474. $tutorial->processes()->syncWithoutDetaching([$process_id]);
  475. $this->log(__METHOD__,"添加教程关联".__FUNCTION__,json_encode($process_id),Auth::user()['id']);
  476. return ['success'=>true,'data'=>$tutorial];
  477. }
  478. //删除教程关联
  479. public function deleteTutorial(Request $request){
  480. $process_id=$request->input('process_id');
  481. $tutorial_id=$request->input('tutorial_id');
  482. if (!$process_id || !$tutorial_id) return ['success'=>false,'data'=>'二次加工或教程传递错误!'];
  483. DB::table('process_tutorial')->where('process_id',$process_id)->where('tutorial_id',$tutorial_id)->delete();
  484. $this->log(__METHOD__,"删除教程关联".__FUNCTION__,json_encode($process_id),Auth::user()['id']);
  485. return ['success'=>true];
  486. }
  487. /**
  488. * Show the form for creating a new resource.
  489. *
  490. * @return \Illuminate\Http\Response
  491. */
  492. public function create()
  493. {
  494. $processMethods=ProcessMethod::get();
  495. return view('process/create',['processMethods'=>$processMethods]);
  496. }
  497. //货主ID获取教程
  498. public function ownerGetTutorials($owner_id){
  499. $tutorials=Tutorial::where('owner_id',$owner_id)->get();
  500. return $tutorials;
  501. }
  502. //考勤
  503. public function createReplenishClock(){
  504. return view('process/checking-in/createReplenishClock');
  505. }
  506. //搜索临时工下打卡信息
  507. public function checkUserLabors(Request $request){
  508. $full_name=$request->input('full_name');
  509. $userDetail=UserDetail::with(['userDutyChecks'=>function ($query){
  510. return $query->orderBy('checked_at','DESC')->limit(5);
  511. }])->where('full_name',$full_name)->get();
  512. return ['success'=>true,'data'=>$userDetail];
  513. }
  514. //录入补卡
  515. public function storeReplenishClock(Request $request){
  516. $errors=$this->validatorUserDutyCheck($request)->errors();
  517. if (count($errors)>0)return ['success'=>false,'data'=>$errors];
  518. $user_id=$request->input('user_id');
  519. $checked_at=$request->input('checked_at');
  520. $type=$request->input('type');
  521. $userDutyCheck=new UserDutyCheck([
  522. 'user_id'=>$user_id,
  523. 'checked_at'=>$checked_at,
  524. 'type'=>$type,
  525. 'source'=>'补入',
  526. ]);
  527. $userDutyCheck->save();
  528. $this->log(__METHOD__,"录入补卡".__FUNCTION__,json_encode($userDutyCheck),Auth::user()['id']);
  529. return ['success'=>true,'data'=>$userDutyCheck];
  530. }
  531. //去往打卡审核
  532. public function clockAudit(){
  533. $date=date('Y-m-d');
  534. $userDutyChecks=UserDutyCheck::with('userDetail')->where('checked_at','like',$date."%")->get();
  535. return view('process/checking-in/clockAudit',['userDutyChecks'=>$userDutyChecks]);
  536. }
  537. //打卡审核
  538. public function storeClockAudit(Request $request){
  539. $id=$request->input('id');
  540. $type=$request->input('type');
  541. $userDutyCheck=UserDutyCheck::find($id);
  542. $userDutyCheck->type=$type;
  543. $userDutyCheck->verify_user_id=Auth::user()['id'];
  544. $userDutyCheck->update();
  545. $this->log(__METHOD__,"打卡审核".__FUNCTION__,json_encode($userDutyCheck),Auth::user()['id']);
  546. return $userDutyCheck->verify_user_id;
  547. }
  548. //打卡审核时判断是否异常
  549. public function isException(Request $request){
  550. $id=$request->input('id');
  551. $checked_at=$request->input('checked_at');
  552. $type=$request->input('type');
  553. $user_id=$request->input('user_id');
  554. if (!$id || !$checked_at || !$type || !$user_id)return ['exception'=>'数据异常!','duration_man_hour'=>''];
  555. $userDutyCheck=UserDutyCheck::where('user_id',$user_id)->where('checked_at','<',$checked_at)->first();
  556. if (!$userDutyCheck)return ['exception'=>'','duration_man_hour'=>''];
  557. $dateStart=Carbon::parse($userDutyCheck->checked_at);
  558. $dateEnd=Carbon::parse($checked_at);
  559. $minute=($dateEnd->diffInMinutes($dateStart));
  560. if ($type=="登入"&&$userDutyCheck->type=="登入"&&$minute>30){
  561. return ['exception'=>'无出场纪录!','duration_man_hour'=>''];
  562. }
  563. if ($type=="登出"&&$userDutyCheck->type=="登出"&&$minute>30){
  564. return ['exception'=>'无入场纪录!','duration_man_hour'=>''];
  565. }
  566. if ($type=="登出"&&$userDutyCheck->type=="登入"&&$minute>=720){
  567. return ['exception'=>'时间异常!','duration_man_hour'=>''];
  568. }
  569. if ($type=="登出"&&$userDutyCheck->type=="登入"){
  570. return ['exception'=>'','duration_man_hour'=>$minute/60];
  571. }
  572. return ['exception'=>'','duration_man_hour'=>''];
  573. }
  574. //去往任务审核
  575. public function missionAudit(Request $request){
  576. $processDailyParticipants=ProcessDailyParticipant::with(['processDaily','user_detail'])
  577. ->orderBy('id','DESC');
  578. $start_date=$request->input('start_date');
  579. $end_date=$request->input('end_date');
  580. $full_name=$request->input('full_name');
  581. $mobile_phone=$request->input('mobile_phone');
  582. if ($start_date) {
  583. $processDailyParticipants->whereHas('processDaily',function (Builder $builder)use($start_date){
  584. $builder->where('date','>=',$start_date);
  585. });
  586. }
  587. if ($end_date) {
  588. $processDailyParticipants->whereHas('processDaily',function (Builder $builder)use($end_date){
  589. $builder->where('date','<=',$end_date);
  590. });
  591. }
  592. if ($full_name){
  593. $processDailyParticipants->whereHas('user_detail',function (Builder $builder)use($full_name){
  594. $builder->where('full_name',$full_name);
  595. });
  596. }
  597. if ($mobile_phone){
  598. $processDailyParticipants->whereHas('user_detail',function (Builder $builder)use($mobile_phone){
  599. $builder->where('mobile_phone',$mobile_phone);
  600. });
  601. }
  602. $processDailyParticipants=$processDailyParticipants->paginate($request->input('paginate')?$request->input('paginate'):50);
  603. foreach ($processDailyParticipants as $processDailyParticipant){
  604. if ($processDailyParticipant->processDaily){
  605. $processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$processDailyParticipant->processDaily->date);
  606. }
  607. }
  608. return view('process/checking-in/missionAudit',['processDailyParticipants'=>$processDailyParticipants,'request'=>$request->input()]);
  609. }
  610. //任务审核
  611. public function storeMissionAudit(Request $request){
  612. $id=$request->input('id');
  613. if (!$id)return ['error'=>'提交审核失败!'];
  614. $processDailyParticipant=ProcessDailyParticipant::find($id);
  615. if (!$id)return ['error'=>'未找到对应记录!'];
  616. $processDailyParticipant->status='已审核';
  617. $processDailyParticipant->update();
  618. $this->log(__METHOD__,"任务审核".__FUNCTION__,json_encode($processDailyParticipant),Auth::user()['id']);
  619. return;
  620. }
  621. public function store(Request $request)
  622. {
  623. if(!Gate::allows('二次加工管理-录入')){ return redirect(url('/')); }
  624. $errors=$this->validatorProcess($request)->errors();
  625. if (count($errors)>0)return ['error'=>$errors,'data'=>"process"];
  626. $errors=[];
  627. foreach ($request->input('processContents') as $processContent){
  628. if ($processContent['addBtnShow'])continue;
  629. $error=$this->validatorProcessContent($processContent)->errors();
  630. if (count($error)>0)$errors[$processContent['wms_code']]=$error;
  631. }
  632. if (count($errors)>0)return ['error'=>$errors];
  633. $process=new Process([
  634. 'code'=>Uuid::uuid1(),
  635. 'owner_id'=>$request->input('owner_id'),
  636. 'process_method_id'=>$request->input('process_method_id'),
  637. 'unit_price'=>$request->input('unit_price'),
  638. 'remark'=>$request->input('remark'),
  639. 'amount'=>$request->input('amount'),
  640. ]);
  641. $process->save();
  642. $process->code='P'.date ("Ymd").str_pad($process->id,3,"0",STR_PAD_LEFT);
  643. $process->update();
  644. $processStatistic=new ProcessStatistic([
  645. 'process_id'=>$process->id,
  646. ]);
  647. $processStatistic->save();
  648. $this->log(__METHOD__,"录入二次加工单".__FUNCTION__,json_encode($process)." || ".json_encode($processStatistic),Auth::user()['id']);
  649. foreach ($request->input('processContents') as $processContent){
  650. if ($processContent['addBtnShow'])continue;
  651. $processContentOne=new ProcessesContent([
  652. 'process_id'=>$process->id,
  653. 'bill_type'=>$processContent['bill_type'],
  654. 'commodity_id'=>$processContent['commodity_id'],
  655. 'wms_code'=>$processContent['wms_code'],
  656. 'amount'=>$processContent['amount'],
  657. ]);
  658. $processContentOne->save();
  659. $this->log(__METHOD__,"录入二次加工单内容单".__FUNCTION__,json_encode($processContentOne),Auth::user()['id']);
  660. }
  661. if ($request->input('tutorials'))$process->tutorials()->sync($request->input('tutorials'));
  662. return;
  663. }
  664. /**
  665. * Display the specified resource.
  666. *
  667. * @param int $id
  668. * @return \Illuminate\Http\Response
  669. */
  670. public function show($id)
  671. {
  672. //
  673. }
  674. /**
  675. * Show the form for editing the specified resource.
  676. *
  677. * @param int $id
  678. * @return \Illuminate\Http\Response
  679. */
  680. public function edit($id)
  681. {
  682. //
  683. }
  684. /**
  685. * Update the specified resource in storage.
  686. *
  687. * @param \Illuminate\Http\Request $request
  688. * @param int $id
  689. * @return \Illuminate\Http\Response
  690. */
  691. public function update(Request $request, $id)
  692. {
  693. //
  694. }
  695. /**
  696. * Remove the specified resource from storage.
  697. *
  698. * @param int $id
  699. * @return \Illuminate\Http\Response
  700. */
  701. public function destroy($id)
  702. {
  703. //
  704. }
  705. //执行
  706. public function export($processes){
  707. if(!Gate::allows('二次加工管理-查询')){ return '没有权限'; }
  708. $row=[[
  709. 'id'=>'ID',
  710. 'code'=>'任务号',
  711. 'owner_name'=>'货主',
  712. 'process_method_name'=>'加工类型',
  713. 'amount'=>'预期数量',
  714. 'completed_amount'=>'实际数量',
  715. 'status'=>'状态',
  716. 'unit_price'=>'单价',
  717. 'created_at'=>'提交日期',
  718. 'bill_type'=>'单据类型',
  719. 'wms_code'=>'单据号',
  720. 'commodity_barcode'=>'商品编码',
  721. 'commodity_name'=>'商品名称',
  722. 'thisAmount'=>'本次数量',
  723. ]];
  724. $list=[];
  725. $i=0;
  726. foreach ($processes as $process){
  727. if (!$process->processesContents){
  728. $w=[
  729. 'id'=>$process->id,
  730. 'code'=>$process->code ,
  731. 'owner_name'=>$process->owner_name ,
  732. 'process_method_name'=>$process->process_method_name,
  733. 'amount'=>$process->amount,
  734. 'unit_price'=>$process->unit_price,
  735. 'created_at'=>$process->created_at ,
  736. 'completed_amount'=>$process->completed_amount,
  737. 'status'=>$process->status,
  738. ];
  739. $list[$i]=$w;
  740. $i++;
  741. continue;
  742. }
  743. foreach($process->processesContents as $processesContent){
  744. $barcodes="";
  745. if ($processesContent->commodity && $processesContent->commodity->barcodes){
  746. foreach ($processesContent->commodity->barcodes as $barcode){
  747. if (!$barcodes){$barcodes=$barcode->code; continue;}
  748. $barcodes=$barcodes.",".$barcode->code;
  749. }
  750. }
  751. $w=[
  752. 'id'=>$process->id,
  753. 'code'=>$process->code ,
  754. 'owner_name'=>$process->owner_name ,
  755. 'bill_type'=>$processesContent->bill_type ,
  756. 'wms_code'=>$processesContent->wms_code ,
  757. 'process_method_name'=>$process->process_method_name,
  758. 'amount'=>$process->amount,
  759. 'thisAmount'=>$processesContent->amount,
  760. 'unit_price'=>$process->unit_price,
  761. 'created_at'=>$process->created_at ,
  762. 'commodity_barcode'=>$barcodes,
  763. 'commodity_name'=>$processesContent->commodity_name ,
  764. 'completed_amount'=>$process->completed_amount,
  765. 'status'=>$process->status,
  766. ];
  767. $list[$i]=$w;
  768. $i++;
  769. }
  770. }
  771. return Excel::download(new WaybillExport($row,$list),date('YmdHis', time()).'-二次加工单.xlsx');
  772. }
  773. public function validatorProcessContent(array $processContent){
  774. $validator=Validator::make($processContent,[
  775. 'wms_code'=>['required'],
  776. 'owner_id'=>['required','integer'],
  777. 'commodity_id'=>['required','integer'],
  778. 'bill_type'=>['required'],
  779. 'amount'=>['required','min:0','max:999999','integer']
  780. ],[
  781. 'required'=>':attribute 不应为空',
  782. 'min'=>':attribute 不得为0或为负',
  783. 'integer'=>':attribute 必须为整数',
  784. 'max'=>':attribute 输入值过大',
  785. ],[
  786. 'owner_id'=>'货主',
  787. 'wms_code'=>'单据号',
  788. 'commodity_id'=>'商品',
  789. 'bill_type'=>'单据类型',
  790. 'amount'=>'商品数量',
  791. ]);
  792. return $validator;
  793. }
  794. public function validatorProcess(Request $request){
  795. $validator=Validator::make($request->input(),[
  796. 'owner_id'=>['required'],
  797. 'process_method_id'=>['required','integer'],
  798. 'amount'=>['required','integer'],
  799. 'unit_price'=>['required','min:0','max:999999','numeric'],
  800. ],[
  801. 'required'=>':attribute 不应为空',
  802. 'min'=>':attribute 不得为0或为负',
  803. 'numeric'=>':attribute 必须为数字',
  804. 'max'=>':attribute 输入值过大',
  805. 'integer' =>':attribute 必须为整数',
  806. ],[
  807. 'owner_id'=>'货主',
  808. 'process_method_id'=>'加工类型',
  809. 'amount'=>'数量',
  810. 'unit_price'=>'单价',
  811. ]);
  812. return $validator;
  813. }
  814. public function validator(Request $request){
  815. $validator=Validator::make($request->input(),[
  816. 'id'=>['required','integer'],
  817. 'output'=>'required|min:0|max:999999|numeric',
  818. ],[
  819. 'required'=>':attribute 不应为空',
  820. 'min'=>':attribute 不得为0或为负',
  821. 'numeric'=>':attribute 必须为数字',
  822. 'max'=>':attribute 输入值过大',
  823. ],[
  824. 'output'=>'每日产量'
  825. ]);
  826. return $validator;
  827. }
  828. public function validatorUserDutyCheck(Request $request){
  829. $validator=Validator::make($request->input(),[
  830. 'user_id'=>'required',
  831. 'checked_at'=>'required|date_format:Y-m-d H:i',
  832. 'type'=>'required',
  833. ],[
  834. 'date_format'=>':attribute 格式错误',
  835. ],['checked_at'=>'日期']);
  836. return $validator;
  837. }
  838. //参与人信息校验
  839. public function validatorProcessDailyParticipant(Request $request){
  840. $validator=Validator::make($request->input(),[
  841. 'daily_id'=>'filled',
  842. 'user_id'=>'required',
  843. 'started_at'=>'required|date_format:H:i',
  844. 'ended_at'=>'required|date_format:H:i',
  845. 'hour_price'=>'required_without:unit_price|min:0|max:999999|numeric',
  846. 'unit_price'=>'required_without:hour_price|min:0|max:999999|numeric',
  847. 'dinner_duration'=>'nullable|integer',
  848. 'hour_count'=>'required_with:hour_price|min:0|max:999999|numeric',
  849. 'unit_count'=>'required_with:unit_price|min:0|max:999999|numeric',
  850. 'remark'=>'nullable',
  851. ],[
  852. 'required'=>':attribute 不应为空',
  853. 'min'=>':attribute 不得为0或为负',
  854. 'numeric'=>':attribute 必须为数字',
  855. 'max'=>':attribute 输入值过大',
  856. 'required_without'=>':attribute 计时与计件至少填一项',
  857. 'date_format'=>':attribute 格式错误',
  858. 'integer'=>':attribute 选择错误',
  859. ],[
  860. 'daily_id'=>'所属每日单',
  861. 'user_id'=>'参与人',
  862. 'started_at'=>'开始时间',
  863. 'ended_at'=>'结束时间',
  864. 'hour_price'=>'计时工资',
  865. 'unit_price'=>'计件工资',
  866. 'dinner_duration'=>'晚饭时间',
  867. 'hour_count'=>'计时工时',
  868. 'unit_count'=>'计件数量',
  869. 'remark'=>'备注',
  870. ]);
  871. return $validator;
  872. }
  873. }