ProcessController.php 36 KB

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