ProcessController.php 39 KB

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