ProcessController.php 37 KB

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