ProcessController.php 57 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Commodity;
  4. use App\CommodityBarcode;
  5. use App\Exports\Export;
  6. use App\LaborReport;
  7. use App\Owner;
  8. use App\Process;
  9. use App\ProcessDaily;
  10. use App\ProcessDailyParticipant;
  11. use App\ProcessesContent;
  12. use App\ProcessMethod;
  13. use App\ProcessStatistic;
  14. use App\Sign;
  15. use App\Tutorial;
  16. use App\UserDetail;
  17. use App\UserDutyCheck;
  18. use App\UserLabor;
  19. use Carbon\Carbon;
  20. use Illuminate\Database\Eloquent\Builder;
  21. use Illuminate\Http\Request;
  22. use Illuminate\Support\Facades\Auth;
  23. use Illuminate\Support\Facades\DB;
  24. use Illuminate\Support\Facades\Gate;
  25. use Illuminate\Support\Facades\Validator;
  26. use Maatwebsite\Excel\Facades\Excel;
  27. use PDO;
  28. use Ramsey\Uuid\Uuid;
  29. class ProcessController extends Controller
  30. {
  31. private function conditionQuery(Request $request,$processes){
  32. if(!Gate::allows('二次加工管理-查询')){ return redirect(url('/')); }
  33. $today=Carbon::now()->subDays(15)->format('Y-m-d');;
  34. if ($request->input('commodity_barcode')){
  35. $barcode=$request->input('commodity_barcode');
  36. $processesTem=clone $processes;
  37. $processesTem=$processesTem->whereHas('processesContents',function ($query)use($barcode){
  38. $query->whereHas('commodity',function ($builder)use($barcode){
  39. $builder->whereHas('barcodes',function ($builder)use($barcode){
  40. $builder->where('code','like',$barcode.'%');
  41. });
  42. });
  43. })->where('created_at','>=',$today);
  44. if ($processesTem->count()>0)$processes=$processesTem;
  45. else{
  46. $processes=$processes->whereHas('processesContents',function ($query)use($barcode){
  47. $query->whereHas('commodity',function ($builder)use($barcode){
  48. $builder->whereHas('barcodes',function ($builder)use($barcode){
  49. $builder->where('code',$barcode);
  50. });
  51. });
  52. });
  53. }
  54. }
  55. if ($request->input('date_start')){
  56. $date_start=$request->input('date_start')." 00:00:00";
  57. $processes=$processes->where('created_at','>=',$date_start);
  58. }
  59. if ($request->input('date_end')){
  60. $date_end=$request->input('date_end')." 23:59:59";
  61. $processes=$processes->where('created_at','<=',$date_end);
  62. }
  63. if ($request->input('owner_id')){
  64. $processes=$processes->where('owner_id',$request->input('owner_id'));
  65. }
  66. if ($request->input('status')){
  67. $processes=$processes->where('status',$request->input('status'));
  68. }
  69. if ($request->input('code')){
  70. $processes=$processes->where('code','like',$request->input('code')."%");
  71. }
  72. if ($request->input('wms_code')){
  73. $processesTem=clone $processes;
  74. $wms_code=$request->input('wms_code');
  75. $processesTem=$processesTem->whereHas('processesContents',function ($builder)use ($wms_code,$today){
  76. $builder->where('wms_code','like','%'.$wms_code.'%');
  77. })->where('created_at','>=',$today);
  78. if ($processesTem->count()>0)$processes=$processesTem;
  79. else{
  80. $processes=$processes->whereHas('processesContents',function ($builder)use ($wms_code,$today){
  81. $builder->where('wms_code',$wms_code);
  82. });
  83. }
  84. }
  85. if (!$request->is_accomplish)$processes=$processes->where('status','!=','交接完成');
  86. $processes=$processes->paginate($request->input('paginate')??50);
  87. return $processes;
  88. }
  89. /**
  90. * Display a listing of the resource.
  91. * @param Request $request
  92. * @return \Illuminate\Http\Response
  93. */
  94. public function index(Request $request)
  95. {
  96. if(!Gate::allows('二次加工管理-查询')){ return redirect(url('/')); }
  97. $processes=Process::filterAuthorities()->with(['tutorials','signs','processesContents'=>function($query){
  98. return $query->with(['commodity'=>function($query){
  99. return $query->with('barcodes');
  100. }]);
  101. }])->orderBy('processes.id','DESC');
  102. if ($request->input('checkSign')){
  103. $excel=$this->isExport($request,$processes);
  104. return $excel;
  105. }
  106. $processes=$this->conditionQuery($request,$processes);
  107. $owners=Owner::filterAuthorities()->select('id','name')->get();
  108. return view('process.index',['processes'=>$processes,'owners'=>$owners,'request'=>$request->input()]);
  109. }
  110. //获取导出数据
  111. public function isExport(Request $request,$processes){
  112. if(!Gate::allows('二次加工管理-查询')){ return redirect(url('/')); }
  113. if ($request->input('checkSign')=="-1"){
  114. $processes=$this->conditionQuery($request,$processes);
  115. $excel=$this->export($processes);
  116. return $excel;
  117. }
  118. $id = explode( ',',$request->input('checkSign'));
  119. $processes=$processes->whereIn('id',$id)->get();
  120. $excel=$this->export($processes);
  121. return $excel;
  122. }
  123. //获取每日参与人
  124. public function getDailyParticipant(Request $request){
  125. if(!Gate::allows('二次加工管理-登记工时')){ return redirect(url('/')); }
  126. $today=Carbon::now()->format('Y-m-d');
  127. $id=$request->input('id');
  128. $processDailies=ProcessDaily::with(['processDailyParticipants','process'])->orderBy('date','DESC')
  129. ->where('process_id',$id)->get();
  130. $process=Process::find($id);
  131. if (count($processDailies)>0){
  132. if ((($process->amount)-($process->completed_amount))<=0 || $process->status=='交接完成')$result=true;
  133. else $result=$this->createDeficiencyData($processDailies,$today);
  134. if ($result){
  135. $processDailies=ProcessDaily::with(['processDailyParticipants','process'])
  136. ->orderBy('date','DESC')->where('process_id',$id)->get();
  137. }
  138. //$processDailies=$this->countManHour($processDailies);
  139. }
  140. return $processDailies;
  141. }
  142. /*//根据参与人查找打卡记录计算工时信息
  143. public function countManHour($processDailies){
  144. foreach ($processDailies as $processDaily){
  145. $date=$processDaily->date;
  146. foreach ($processDaily->processDailyParticipants as $processDailyParticipant){
  147. $processDailyParticipant->started_at=Carbon::parse($processDailyParticipant->started_at)->format('H:i');
  148. $processDailyParticipant->ended_at=Carbon::parse($processDailyParticipant->ended_at)->format('H:i');
  149. $processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$date);
  150. }
  151. }
  152. return $processDailies;
  153. }*/
  154. /*//计算单参与人工时信息
  155. public function countParticipantManHour($processDailyParticipant,$date){
  156. $user_id=$processDailyParticipant->user_id;
  157. $userDutyCheckStart=UserDutyCheck::select('id','checked_at')->where('user_id',$user_id)
  158. ->where('checked_at','like',$date.'%')->where('type','登入')->orderBy('id')->first();
  159. $userDutyCheckEnd=UserDutyCheck::select('id','checked_at')->where('user_id',$user_id)
  160. ->where('checked_at','like',$date.'%')->where('type','登出')->orderBy('id','desc')->first();
  161. //跨日情况寻找下一天
  162. if (!$userDutyCheckEnd){
  163. $date=date("Y-m-d",strtotime("+1 day",strtotime($date)));
  164. $userDutyCheckEnd=UserDutyCheck::select('id','checked_at')->where('user_id',$user_id)
  165. ->where('checked_at','like',$date.'%')->where('type','登出')->orderBy('id','desc')->first();
  166. }
  167. if (!$userDutyCheckStart || !$userDutyCheckEnd){
  168. return $processDailyParticipant;
  169. }
  170. $dateStart=Carbon::parse($userDutyCheckStart->checked_at);
  171. $dateEnd=Carbon::parse($userDutyCheckEnd->checked_at);
  172. $hour=($dateEnd->diffInSeconds($dateStart))/3600; //打卡工时
  173. if ($processDailyParticipant->dinner_duration)$hour=$hour-(($processDailyParticipant->dinner_duration)/60); //减晚饭时间
  174. $hour=$this->isHour($userDutyCheckStart,$hour); //去除休息时间
  175. $processDailyParticipant->hour=round($hour,2);
  176. if ($hour&&$processDailyParticipant->hour_count){
  177. $diff=abs(round($processDailyParticipant->hour_count-$hour,2));
  178. $processDailyParticipant->diff=$diff;
  179. }
  180. //计件工 保留
  181. // if ($processDailyParticipant->unit_count){
  182. // return $processDailyParticipant;
  183. //}
  184. if ($hour&&$hour>8){
  185. $processDailyParticipant->billingHour=8;
  186. return $processDailyParticipant;
  187. }
  188. if ($hour&&$hour<=8){
  189. $processDailyParticipant->billingHour=round($hour,2);
  190. }
  191. return $processDailyParticipant;
  192. }*/
  193. /* //打卡工时减休息时间
  194. private function isHour($userDutyCheckStart,$hour){
  195. $date=$userDutyCheckStart->checked_at;
  196. $date=Carbon::parse($date)->format('H');
  197. if ((int)$date<=11){
  198. $hour=$hour-1;
  199. }
  200. return $hour;
  201. }*/
  202. //生成二次加工单缺失时间记录及本日记录
  203. private function createDeficiencyData($processDailies,$today){
  204. $processDailiesArr=[];
  205. foreach ($processDailies as $processDaily){
  206. $processDailiesArr[$processDaily->date]=$processDaily;
  207. }
  208. $processDailyOne=$processDailies[count($processDailies)-1];
  209. $startDate=Carbon::parse($processDailyOne->date);
  210. $diffDay=$startDate->diffInDays($today,true);
  211. $remain=$processDailyOne->remain;
  212. $processId=$processDailyOne->process_id;
  213. for ($i=1;$i<=$diffDay;$i++){
  214. $date=date("Y-m-d",strtotime('+'.strval($i)." day",strtotime($startDate)));
  215. if (!isset($processDailiesArr[$date])){
  216. $processDaily=new ProcessDaily([
  217. 'process_id'=>$processId,
  218. 'date'=>$date,
  219. 'output'=>0,
  220. 'remain'=>$remain
  221. ]);
  222. $processDaily->save();
  223. }
  224. if (isset($processDailiesArr[$date])){
  225. $remain=$remain-($processDailiesArr[$date]->output);
  226. }
  227. }
  228. $this->log(__METHOD__,"生成加工单每日记录".__FUNCTION__,json_encode($processDailies),Auth::user()['id']);
  229. return true;
  230. }
  231. //驳回二次加工单
  232. public function reject($id){
  233. if(!Gate::allows('二次加工管理-接单与驳回')){ return redirect(url('/')); }
  234. $process=Process::select('id','status')->find($id);
  235. $process->status="已驳回";
  236. $process->update();
  237. $process->createOperatorLog('驳回');
  238. $this->log(__METHOD__,"驳回二次加工单_".__FUNCTION__,json_encode($process),Auth::user()['id']);
  239. return $process;
  240. }
  241. //接单
  242. public function receive($id){
  243. if(!Gate::allows('二次加工管理-接单与驳回')){ return redirect(url('/')); }
  244. $process=Process::select('id','status','amount')->find($id);
  245. $amount=$process->amount;
  246. $today=Carbon::now()->format('Y-m-d');
  247. $processDaily=ProcessDaily::where('date',$today)->where('process_id',$id)->first();
  248. if (!$processDaily){
  249. $processDaily=new ProcessDaily([
  250. 'process_id'=>$id,
  251. 'date'=>$today,
  252. 'output'=>0,
  253. 'remain'=>$amount,
  254. ]);
  255. $processDaily->save();
  256. }
  257. $process->status="待加工";
  258. $process->update();
  259. $process->createOperatorLog('接单');
  260. $this->log(__METHOD__,"接单二次加工单_".__FUNCTION__,json_encode($process),Auth::user()['id']);
  261. return $process;
  262. }
  263. //完成
  264. public function accomplish(Request $request){
  265. if(!Gate::allows('二次加工管理-交接完成')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  266. $process=Process::with('processDailies')->find($request->id);
  267. if (!$process)return ['success'=>false];
  268. $result=$this->statistic($process);
  269. if (!$result['success'])return $result;
  270. $process->update(['status'=>'交接完成']);
  271. $process->createOperatorLog('交接完成');
  272. $processStatistic=$result['data'];
  273. $this->log(__METHOD__,"完成二次加工单_".__FUNCTION__,json_encode($process)." || ".json_encode($processStatistic),Auth::user()['id']);
  274. return ['success'=>true,'data'=>'交接完成'];
  275. }
  276. private function statistic(Process $process){
  277. if (count($process->processDailies)>0){
  278. $completed_amount=0;
  279. foreach ($process->processDailies as $processDaily){
  280. $completed_amount=$completed_amount+($processDaily->output);
  281. }
  282. $process->completed_amount=$completed_amount;
  283. }
  284. //统计:
  285. $revenue=($process->unit_price)*($process->completed_amount); //收入合计
  286. $processDailies=ProcessDaily::with('processDailyParticipants')->where('process_id',$process->id)->where('output','>',0)->get();
  287. $duration_days=count($processDailies); //完成天数
  288. $duration_man_hours=0; //总工时
  289. $total_cost=0; //合计成本
  290. foreach ($processDailies as $processDailyOne){
  291. foreach ($processDailyOne->processDailyParticipants as $processDailyParticipant){
  292. //$processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$processDailyOne->date);
  293. $duration_man_hours += $processDailyParticipant->hour_count;
  294. if ($processDailyParticipant->unit_count){
  295. $total_cost += ($processDailyParticipant->unit_count)*($processDailyParticipant->unit_price);
  296. continue;
  297. }
  298. $total_cost += ($processDailyParticipant->hour_count)*($processDailyParticipant->hour_price);
  299. }
  300. };
  301. $gross_profit=$revenue-$total_cost; //毛利润
  302. if ($gross_profit<=0)return ['success'=>false,'data'=>'该单未产生费用,无法计算毛利率!'];
  303. $gross_profit_rate=$gross_profit/$revenue; //毛利率
  304. $processStatistic=ProcessStatistic::find($process->id);
  305. $processStatistic->revenue=$revenue;
  306. $processStatistic->duration_days=$duration_days;
  307. $processStatistic->duration_man_hours=$duration_man_hours;
  308. $processStatistic->total_cost=$total_cost;
  309. $processStatistic->gross_profit=$gross_profit;
  310. $processStatistic->gross_profit_rate=$gross_profit_rate;
  311. $processStatistic->update();
  312. $this->log(__METHOD__,"修改二次加工单统计单_".__FUNCTION__,json_encode($processStatistic),Auth::user()['id']);
  313. return ['success'=>true,'data'=>$processStatistic];
  314. }
  315. //修改当日产量
  316. public function updateDailyOutput(Request $request){
  317. if(!Gate::allows('二次加工管理-登记工时')){ return redirect(url('/')); }
  318. $errors=$this->validator($request)->errors();
  319. if (count($errors)>0)return ['status'=>"error",'data'=>$errors];
  320. $id=$request->input('id');
  321. $output=$request->input('output');
  322. $processDaily=ProcessDaily::with('process')->find($id);
  323. $processDaily->output=$output;
  324. $processDaily->update();
  325. $result=$this->countRemains($processDaily);
  326. $processDailies=$result['processDailies'];
  327. $this->log(__METHOD__,"修改当日产量".__FUNCTION__,json_encode($processDaily),Auth::user()['id']);
  328. $response=[];
  329. $response['status']='success';
  330. $response['data']=$processDailies;
  331. if (isset($result['process'])){$response['process']=$result['process'];}
  332. return $response;
  333. }
  334. //每次修改,去查询该单下全部日期,逐个替换,前一天剩余减当天产量为当天剩余,无前天记录去拿单子预期产量
  335. private function countRemains($processDaily){
  336. if (!$processDaily || !$processDaily->process) return;
  337. $processDailies=ProcessDaily::where('process_id',$processDaily->process_id)->orderBy('date')->get();
  338. for ($i=0;$i<count($processDailies);$i++){
  339. if ($i==0&&$processDailies[$i]->date>=$processDaily->date){
  340. $processDailies[$i]->remain=($processDaily->process->amount)-$processDailies[$i]->output;
  341. $processDailies[$i]->update();
  342. }
  343. if ($i>0&&$processDailies[$i]->date>=$processDaily->date){
  344. $processDailies[$i]->remain=($processDailies[$i-1]->remain)-$processDailies[$i]->output;
  345. $processDailies[$i]->update();
  346. }
  347. }
  348. //同步二次加工单统计
  349. $processDailiesStatistic=$processDailies->where('output','>',0);
  350. $processStatistic=ProcessStatistic::find($processDaily->process_id); //如非录入渠道建单不生成统计单,报错
  351. $processStatistic->top_capacity=$processDailiesStatistic->max('output');
  352. $processStatistic->bottom_capacity=$processDailiesStatistic->min('output');
  353. $processStatistic->average_capacity=$processDailiesStatistic->avg('output');
  354. $processStatistic->update();
  355. //修改二次加工单状态
  356. $result=[];
  357. /*if (count($processDailies)>0 && ($processDailies[(count($processDailies)-1)]->remain)<=0){
  358. $result['process']=$this->changeProcessCheck($processDaily->process_id); //保留 目前小于0后等待人工确认再进入待验收
  359. }*/
  360. $result['processDailies']=$processDailies;
  361. return $result;
  362. }
  363. //剩余小于等于0,状态待验收
  364. private function changeProcessCheck($process_id){
  365. $process=Process::select('id','status')->find($process_id);
  366. if ($process->status=="加工中"){
  367. $process->status="待验收";
  368. $process->update();
  369. $processStatistic=ProcessStatistic::find($process_id);
  370. $processStatistic->ended_at=date('Y-m-d H:i:s');
  371. $processStatistic->update();
  372. $this->log(__METHOD__,"二次加工单待验收".__FUNCTION__,json_encode($process)." || ".json_encode($processStatistic),Auth::user()['id']);
  373. }
  374. return $process_id;
  375. }
  376. public function storeProcessDailyParticipant(Request $request){
  377. if(!Gate::allows('二次加工管理-登记工时')){ return redirect(url('/')); }
  378. $errors=$this->validatorProcessDailyParticipant($request)->errors();
  379. if (count($errors)>0)return ['status'=>"error",'data'=>$errors];
  380. $user_id=$request->input('user_id');
  381. $started_at=$request->input('started_at');
  382. $ended_at=$request->input('ended_at');
  383. $daily_id=$request->input('daily_id');
  384. $hour_count=$request->input('hour_count');
  385. $unit_count=$request->input('unit_count');
  386. $hour_price=$request->input('hour_price');
  387. $unit_price=$request->input('unit_price');
  388. $dinner_duration=$request->input('dinner_duration');
  389. $remark=$request->input('remark');
  390. $userLabor=UserLabor::find($user_id);
  391. $processDaily=processDaily::find($daily_id);
  392. if ($userLabor->isOccupiedAt($processDaily->date,$ended_at)){
  393. ['status'=>"warning",'data'=>'该临时工此时间段已存在工作记录!'];
  394. };
  395. $processDailyParticipant=new ProcessDailyParticipant([
  396. 'process_daily_id'=>$daily_id,
  397. 'user_id'=>$user_id,
  398. 'started_at'=>$started_at,
  399. 'ended_at'=>$ended_at,
  400. 'hour_price'=>$hour_price,
  401. 'hour_count'=>$hour_count,
  402. 'unit_price'=>$unit_price,
  403. 'unit_count'=>$unit_count,
  404. 'dinner_duration'=>$dinner_duration,
  405. 'remark'=>$remark,
  406. ]);
  407. $processDailyParticipant->save();
  408. $this->log(__METHOD__,"添加新参与人".__FUNCTION__,json_encode($processDailyParticipant),Auth::user()['id']);
  409. $processDailyParticipant->load(['processDaily'=>function($query){
  410. $query->with('process');
  411. }]);
  412. if ($processDailyParticipant->processDaily && $processDailyParticipant->processDaily->process &&
  413. $processDailyParticipant->processDaily->process->status=='交接完成'){
  414. $this->statistic($processDailyParticipant->processDaily->process);
  415. }
  416. $result=[];
  417. $processDaily=ProcessDaily::with('process')->select('process_id','date')->find($daily_id);
  418. //$date=$processDaily->date;
  419. //$processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$date);
  420. if ($processDaily->process && $processDaily->process->status=="待加工"){
  421. $process=Process::find($processDaily->process_id);
  422. $process->status="加工中";
  423. $process->update();
  424. $result['process']=$processDaily->process_id;
  425. $processStatistic=ProcessStatistic::find($processDaily->process_id);
  426. $processStatistic->started_at=date('Y-m-d H:i:s');
  427. $processStatistic->update();
  428. $this->log(__METHOD__,"二次加工单加工中".__FUNCTION__,json_encode($process)." || ".json_encode($processStatistic),Auth::user()['id']);
  429. }
  430. $result['status']="success";
  431. $result['data']=$processDailyParticipant;
  432. return $result;
  433. }
  434. //验证参与人
  435. public function verifyUserName(Request $request){
  436. $userName=$request->input('userName');
  437. if (!$userName) return ['success'=>false,'data'=>'未输入参与者!'];
  438. $date = $request->date;
  439. if (!$date){
  440. $processDailyParticipant=ProcessDailyParticipant::query()->find($request->id);
  441. $date=$processDailyParticipant->process_daily_date;
  442. }
  443. return $this->seekUserLabor($userName,$date);
  444. }
  445. //根据全名查询临时工
  446. public function seekUserLabor($userName,$date){
  447. $userDetails=UserDetail::with('userLabor')->where('type','临时工')->where('full_name',$userName)->get();
  448. if (!$userDetails)return ['success'=>false,'data'=>'未找到临时工信息!'];
  449. if (count($userDetails)==1){
  450. if (!$userDetails[0]->userLabor)return ['success'=>false,'data'=>'该员工非临时工身份!'];
  451. $laborReport=LaborReport::where('check_in_at','like',$date.'%')->where('user_id',$userDetails[0]->user_id)->first();
  452. if ($laborReport){
  453. $userDetails[0]->started_at=Carbon::parse($laborReport->thisRoundOnlineStartTime)->format('H:i');
  454. $userDetails[0]->ended_at=Carbon::parse($laborReport->thisRoundOnlineEndTime)->format('H:i');
  455. }
  456. return ['success'=>true,'data'=>$userDetails[0]];
  457. }
  458. //多个同名
  459. foreach ($userDetails as $userDetail){
  460. $userDutyCheck=UserDutyCheck::select('checked_at')->where("user_id",$userDetail->user_id)->orderBy('checked_at','DESC')->first();
  461. $laborReport=LaborReport::where('check_in_at','like',$date.'%')->where('user_id',$userDetail->user_id)->first();
  462. if ($laborReport) {
  463. $userDetail->started_at = Carbon::parse($laborReport->thisRoundOnlineStartTime)->format('H:i');
  464. $userDetail->ended_at = Carbon::parse($laborReport->thisRoundOnlineEndTime)->format('H:i');
  465. }
  466. if ($userDutyCheck)$userDetail->checked_at=$userDutyCheck->checked_at;
  467. }
  468. if (!$userDetails)return ['success'=>false,'data'=>'未找到临时工信息!'];
  469. return ['success'=>true,'data'=>$userDetails];
  470. }
  471. //修改参与人
  472. public function updateProcessDailyParticipant(Request $request){
  473. if(!Gate::allows('二次加工管理-登记工时')){ return redirect(url('/')); }
  474. $id=$request->input('id');
  475. if (!$id) return ['status'=>"error",'data'=>"修改失败,ID未传递"];
  476. $errors=$this->validatorProcessDailyParticipant($request)->errors();
  477. if (count($errors)>0)return ['status'=>"error",'data'=>$errors];
  478. $processDailyParticipant=ProcessDailyParticipant::with(['processDaily'=>function($query){
  479. $query->with('process');
  480. },'userLabor'])->find($id);
  481. if (!$processDailyParticipant || !$processDailyParticipant->processDaily
  482. || !$processDailyParticipant->processDaily->process || !$processDailyParticipant->userLabor) return ['status'=>"error",'data'=>"修改失败,该信息不存在"];
  483. if ($processDailyParticipant->userLabor->isOccupiedAt($processDailyParticipant->processDaily->date,$request->started_at)){
  484. ['status'=>"error",'data'=>"该临时工此时间段已存在工作记录"];
  485. }
  486. $processDailyParticipant->user_id=$request->input('user_id');
  487. $processDailyParticipant->started_at=$request->input('started_at');
  488. $processDailyParticipant->ended_at=$request->input('ended_at');
  489. $processDailyParticipant->hour_count=$request->input('hour_count');
  490. $processDailyParticipant->unit_count=$request->input('unit_count');
  491. $processDailyParticipant->hour_price=$request->input('hour_price');
  492. $processDailyParticipant->unit_price=$request->input('unit_price');
  493. $processDailyParticipant->dinner_duration=$request->input('dinner_duration');
  494. $processDailyParticipant->remark=$request->input('remark');
  495. $processDailyParticipant->update();
  496. $this->log(__METHOD__,"修改参与人".__FUNCTION__,json_encode($processDailyParticipant),Auth::user()['id']);
  497. if ($processDailyParticipant->processDaily->process->status=='交接完成'){
  498. $this->statistic($processDailyParticipant->processDaily->process);
  499. }
  500. //$processDailyParticipant=$this->countParticipantManHour($processDailyParticipant,$processDailyParticipant->processDaily->date);
  501. return ['status'=>"success",'data'=>$processDailyParticipant];
  502. }
  503. /*//参与人审核
  504. public function processDailyParticipantAudit($id){
  505. if(!Gate::allows('人事管理-任务审核')){ return redirect(url('/')); }
  506. $processDailyParticipant=ProcessDailyParticipant::select('id','status')->find($id);
  507. if (!$processDailyParticipant) return ['success'=>false];
  508. $processDailyParticipant->status='已审核';
  509. $processDailyParticipant->update();
  510. $this->log(__METHOD__,"登记工时参与人审核".__FUNCTION__,json_encode($processDailyParticipant),Auth::user()['id']);
  511. return ['success'=>true,'processDailyParticipant'=>$processDailyParticipant];
  512. }*/
  513. //获取全部教程
  514. public function getTutorials($id){
  515. $process=Process::with('tutorials')->find($id);
  516. $tutorials_id=[];
  517. if ($process->tutorials){
  518. foreach ($process->tutorials as $tutorial){
  519. array_push($tutorials_id,$tutorial->id);
  520. }
  521. }
  522. $tutorials=Tutorial::where('owner_id',$process->owner_id)->get();
  523. if ($tutorials_id && $tutorials) $tutorials=$tutorials->diff(Tutorial::whereIn('id',$tutorials_id)->get());
  524. return ['success'=>true,'data'=>$tutorials];
  525. }
  526. //添加教程关联
  527. public function selectedTutorial(Request $request){
  528. if(!Gate::allows('二次加工管理-教程管理')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  529. $process_id=$request->input('process_id');
  530. $tutorial_id=$request->input('tutorial_id');
  531. if (!$process_id || !$tutorial_id) return ['success'=>false,'data'=>'二次加工或教程传递错误!'];
  532. $tutorial=Tutorial::find($tutorial_id);
  533. if (!$tutorial)return ['success'=>false,'data'=>'未找到相关教程!'];
  534. $tutorial->processes()->syncWithoutDetaching([$process_id]);
  535. $this->log(__METHOD__,"添加教程关联".__FUNCTION__,json_encode($process_id),Auth::user()['id']);
  536. return ['success'=>true,'data'=>$tutorial];
  537. }
  538. //删除教程关联
  539. public function deleteTutorial(Request $request){
  540. if(!Gate::allows('二次加工管理-教程管理')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  541. $process_id=$request->input('process_id');
  542. $tutorial_id=$request->input('tutorial_id');
  543. if (!$process_id || !$tutorial_id) return ['success'=>false,'data'=>'二次加工或教程传递错误!'];
  544. DB::table('process_tutorial')->where('process_id',$process_id)->where('tutorial_id',$tutorial_id)->delete();
  545. $this->log(__METHOD__,"删除教程关联".__FUNCTION__,json_encode($process_id),Auth::user()['id']);
  546. return ['success'=>true];
  547. }
  548. /**
  549. * Show the form for creating a new resource.
  550. *
  551. * @return \Illuminate\Http\Response
  552. */
  553. public function create()
  554. {
  555. if(!Gate::allows('二次加工管理-录入')){ return redirect(url('/')); }
  556. $processMethods=ProcessMethod::get();
  557. return view('process/create',['processMethods'=>$processMethods]);
  558. }
  559. //货主ID获取教程
  560. public function ownerGetTutorials($owner_id){
  561. $tutorials=Tutorial::where('owner_id',$owner_id)->get();
  562. return $tutorials;
  563. }
  564. public function store(Request $request)
  565. {
  566. if(!Gate::allows('二次加工管理-录入')){ return redirect(url('/')); }
  567. $errors=$this->validatorProcess($request)->errors();
  568. if (count($errors)>0)return ['error'=>$errors,'data'=>"process"];
  569. $errors=[];
  570. foreach ($request->input('processContents') as $processContent){
  571. if ($processContent['addBtnShow'])continue;
  572. $error=$this->validatorProcessContent($processContent)->errors();
  573. if (count($error)>0)$errors[$processContent['wms_code']]=$error;
  574. }
  575. if (count($errors)>0)return ['error'=>$errors];
  576. $process=new Process([
  577. 'code'=>Uuid::uuid1(),
  578. 'owner_id'=>$request->input('owner_id'),
  579. 'process_method_id'=>$request->input('process_method_id'),
  580. 'unit_price'=>$request->input('unit_price'),
  581. 'remark'=>$request->input('remark'),
  582. 'amount'=>$request->input('amount'),
  583. 'status'=>'待审核',
  584. ]);
  585. $process->save();
  586. $process->createOperatorLog('创建');
  587. $processContents=[];
  588. foreach ($request->input('processContents') as $processContent){
  589. $wmsCode_commoditySku=$processContent['wms_code'].'_'.$processContent['commodity_sku'].'_'.$processContent['type'];
  590. array_push($processContents,$wmsCode_commoditySku);
  591. }
  592. $removeDuplicateProcessContents=array_unique($processContents);
  593. if (count($processContents)>count($removeDuplicateProcessContents)){
  594. return ['success'=>false,'data'=>'录入商品不可重复!'];
  595. }else{
  596. foreach ($request->input('processContents') as $processContent){
  597. if ($processContent['addBtnShow'])continue;
  598. $processContentOne=new ProcessesContent([
  599. 'process_id'=>$process->id,
  600. 'bill_type'=>$processContent['bill_type'],
  601. 'commodity_id'=>$processContent['commodity_id'],
  602. 'wms_code'=>$processContent['wms_code'],
  603. 'amount'=>$processContent['amount'],
  604. ]);
  605. if ($processContent['type'])$processContentOne->type='成品单';
  606. $processContentOne->save();
  607. if (isset($processContent['is_update_commodity_name'])){
  608. Sign::create([
  609. 'signable_type'=>'processes_contents',
  610. 'signable_id'=>$processContentOne->id,
  611. 'field'=>'commodity_name',
  612. 'mark'=>$processContent['commodity_name'],
  613. ]);
  614. }
  615. }
  616. }
  617. $process->code='P'.date ("Ymd").str_pad($process->id,3,"0",STR_PAD_LEFT);
  618. $process->update();
  619. $processStatistic=new ProcessStatistic([
  620. 'process_id'=>$process->id,
  621. ]);
  622. $processStatistic->save();
  623. $this->log(__METHOD__,"录入二次加工单".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  624. if ($request->input('tutorials'))$process->tutorials()->sync($request->input('tutorials'));
  625. return;
  626. }
  627. //修改价格
  628. function updateUnitPrice(Request $request){
  629. if(!Gate::allows('二次加工管理-修改价格')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  630. $errors=Validator::make($request->input(),[
  631. 'id' => 'required',
  632. 'unit_price'=>['required','numeric'],
  633. ])->errors();
  634. if (count($errors)>0)return ['success'=>false,'data'=>'非法参数!'];
  635. $process=Process::with('signs')->find($request->id);
  636. if (!$process || $process->status!='交接完成' || count($process->signs)>0)return ['success'=>false,'data'=>'无法操作该二次加工单!'];
  637. $process->createSignUnitPrice($request->unit_price);
  638. $sign=$process->createSign('发起修改');
  639. $this->log(__METHOD__,"修改二次加工单价格_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  640. return ['success'=>true,'sign'=>$sign];
  641. }
  642. //二次加工组审核 两个方法大体相同 拆分原因是为了精确区分权限
  643. function workGroupVerify(Request $request){
  644. if(!Gate::allows('二次加工管理-组长确认')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  645. $this->log(__METHOD__,"修改二次加工单价格二次加工组确认_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  646. return $this->verify($request->id,'二次加工组确认');
  647. }
  648. //二次加工组审核
  649. function accountantVerify(Request $request){
  650. if(!Gate::allows('二次加工管理-财务确认')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  651. $this->log(__METHOD__,"修改二次加工单价格财务确认_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  652. return $this->verify($request->id,'财务确认');
  653. }
  654. private function verify($id,$msg){
  655. $process=Process::with(['signs','processDailies'])->find($id);
  656. if (!$process || count($process->signs)<1)return false;
  657. $signMap=[];
  658. foreach ($process->signs as $sign){
  659. $signMap[$sign->mark]=true;
  660. }
  661. if (isset($signMap[$msg]))return ['success'=>false,'data'=>'该单已被确认过!'];
  662. if (isset($signMap['二次加工组确认'])){
  663. $signUnitPrice=$process->signUnitPrice();
  664. if ($signUnitPrice){
  665. $process->update(['unit_price' => $signUnitPrice->mark]);
  666. $this->statistic($process);
  667. }
  668. $process->createSign('财务确认');
  669. $process->destroySign();
  670. return ['success'=>true,'data'=>false];
  671. }
  672. if (isset($signMap['财务确认'])){
  673. $signUnitPrice=$process->signUnitPrice();
  674. if ($signUnitPrice){
  675. $process->update(['unit_price' => $signUnitPrice->mark]);
  676. $this->statistic($process);
  677. }
  678. $process->createSign('二次加工组确认');
  679. $process->destroySign();
  680. return ['success'=>true,'data'=>false];
  681. }
  682. $sign = $process->createSign($msg);
  683. return ['success'=>true,'data'=>$sign];
  684. }
  685. //审核
  686. function audit(Request $request){
  687. if(!Gate::allows('二次加工管理-审核')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  688. $process=Process::find($request->id);
  689. if (!$process)return ['success'=>false];
  690. $process->update(['status'=>'待接单']);
  691. $process->createOperatorLog('审核');
  692. $this->log(__METHOD__,"二次加工单审核_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  693. return ['success'=>true];
  694. }
  695. /**
  696. * Show the form for editing the specified resource.
  697. *
  698. * @param int $id
  699. * @return \Illuminate\Http\Response
  700. */
  701. public function edit($id)
  702. {
  703. if(!Gate::allows('二次加工管理-编辑')){ return redirect(url('/')); }
  704. $process=Process::with(['processesContents'=>function($query){
  705. return $query->with(['commodity'=>function($query){
  706. return $query->with('barcodes');
  707. }]);
  708. }])->find($id);
  709. $processMethods=ProcessMethod::get();
  710. return view('process.edit',['process'=>$process,'processMethods'=>$processMethods]);
  711. }
  712. public function show($id){
  713. $process=Process::with(['processesContents'=>function($query){
  714. $query->with(['commodity'=>function($query){
  715. $query->with('barcodes');
  716. }]);
  717. },'tutorials'])->find($id);
  718. return view('process.show',compact('process'));
  719. }
  720. /**
  721. * Update the specified resource in storage.
  722. *
  723. * @param \Illuminate\Http\Request $request
  724. * @param int $id
  725. * @return \Illuminate\Http\Response
  726. */
  727. public function update(Request $request, $id)
  728. {
  729. if(!Gate::allows('二次加工管理-编辑')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  730. $errors=$this->validatorProcess($request)->errors();
  731. if (count($errors)>0)return ['error'=>$errors,'data'=>"process"];
  732. $errors=[];
  733. foreach ($request->input('processContents') as $processContent){
  734. if ($processContent['addBtnShow'])continue;
  735. $error=$this->validatorProcessContent($processContent)->errors();
  736. if (count($error)>0)$errors[$processContent['wms_code']]=$error;
  737. }
  738. if (count($errors)>0)return ['error'=>$errors];
  739. $process=Process::find($id);
  740. if (!$request->is_hide){
  741. $process->owner_id=$request->input('owner_id');
  742. $process->process_method_id=$request->input('process_method_id');
  743. $process->unit_price=$request->input('unit_price');
  744. $process->remark=$request->input('remark');
  745. $process->amount=$request->input('amount');
  746. if ($process->status=='已驳回')$process->status='待接单';
  747. $process->update();
  748. $process->createOperatorLog('编辑');
  749. }
  750. $processContents=[];
  751. foreach ($request->input('processContents') as $processContent){
  752. $wmsCode_commoditySku=$processContent['wms_code'].'_'.$processContent['commodity_sku'].'_'.$processContent['type'];
  753. array_push($processContents,$wmsCode_commoditySku);
  754. }
  755. $removeDuplicateProcessContents=array_unique($processContents);
  756. if (count($processContents)>count($removeDuplicateProcessContents)){
  757. return ['success'=>false,'data'=>'录入商品不可重复!'];
  758. }else{
  759. $ProcessesContents=ProcessesContent::where('process_id',$process->id)->get();
  760. $ids=array_column($ProcessesContents->toArray(),'id');
  761. Sign::where('signable_type','processes_contents')->whereIn('signable_id',$ids)->delete();
  762. ProcessesContent::where('process_id',$process->id)->delete();
  763. foreach ($request->input('processContents') as $processContent){
  764. if ($processContent['addBtnShow'])continue;
  765. $processContentOne=new ProcessesContent([
  766. 'process_id'=>$process->id,
  767. 'bill_type'=>$processContent['bill_type'],
  768. 'commodity_id'=>$processContent['commodity_id'],
  769. 'wms_code'=>$processContent['wms_code'],
  770. 'amount'=>$processContent['amount'],
  771. ]);
  772. if ($processContent['type'])$processContentOne->type='成品单';
  773. $processContentOne->save();
  774. if (isset($processContent['is_update_commodity_name'])){
  775. Sign::create([
  776. 'signable_type'=>'processes_contents',
  777. 'signable_id'=>$processContentOne->id,
  778. 'field'=>'commodity_name',
  779. 'mark'=>$processContent['commodity_name'],
  780. ]);
  781. }
  782. }
  783. }
  784. $this->log(__METHOD__,"编辑二次加工单_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  785. return;
  786. }
  787. //删除二次加工内容单 弃用,保留,改为全部提交后一次性验证,不在操作时就允许删除
  788. public function deleteProcessContent($id){
  789. if(!Gate::allows('二次加工管理-删除')){ return redirect(url('/')); }
  790. $processContent=ProcessesContent::find($id);
  791. if (!$processContent) return ['success'=>false,'data'=>'未找到对应二次加工内容单'];
  792. $processContent->delete();
  793. return ['success'=>true];
  794. }
  795. //回滚二次加工单状态
  796. function rollback(Request $request){
  797. if(!Gate::allows('二次加工管理-回滚')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  798. if (!$request->id)return ['success'=>false];
  799. $process=Process::find($request->id);
  800. switch ($process->status){
  801. case '待接单':
  802. $process->status='待审核';break;
  803. case '待加工':
  804. $process->status='待接单';break;
  805. case '已驳回':
  806. $process->status='待审核';break;
  807. case '加工中':
  808. $process->status='待接单';break;
  809. case '待验收':
  810. $process->status='加工中';break;
  811. case '待交接':
  812. $process->status='待验收';break;
  813. }
  814. $process->save();
  815. $process->createOperatorLog('回滚');
  816. $this->log(__METHOD__,"回滚二次加工单_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  817. return ['success'=>true,'data'=>$process->status];
  818. }
  819. //加工完成
  820. function processAccomplish(Request $request){
  821. if(!Gate::allows('二次加工管理-登记工时')){ return ['success'=>false,'data'=>'您无权进行该操作!']; }
  822. $process= Process::find($request->id);
  823. if (!$process)return ['success'=>false];
  824. $process->update([
  825. 'status'=>'待验收'
  826. ]);
  827. $process->createOperatorLog('加工完成');
  828. $this->log(__METHOD__,"标记加工完成_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  829. return ['success'=>true,'data'=>'待验收'];
  830. }
  831. //质量验收
  832. function checkAndAccept(Request $request){
  833. $process= Process::find($request->id);
  834. if (!$process)return ['success'=>false];
  835. $process->update([
  836. 'status'=>'待交接'
  837. ]);
  838. $process->createOperatorLog('质量验收');
  839. $this->log(__METHOD__,"质量验收二次加工单_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  840. return ['success'=>true,'data'=>'待交接'];
  841. }
  842. //回收站
  843. function recycle(Request $request){
  844. if(!Gate::allows('二次加工管理-删除')){ return redirect('/'); }
  845. $processes=Process::filterAuthorities()->onlyTrashed()->paginate($request->paginate??50);
  846. return view('process.recycle',compact('processes'));
  847. }
  848. //回收站恢复
  849. function recover(Request $request){
  850. if(!Gate::allows('二次加工管理-删除')){ return redirect('/'); }
  851. $checkData=$request->checkData;
  852. $this->log(__METHOD__,"回收站恢复二次加工单_".__FUNCTION__,json_encode($request->input()),Auth::user()['id']);
  853. return ['success'=>Process::withTrashed()->whereIn('id',$checkData)->restore()];
  854. }
  855. /**
  856. * Remove the specified resource from storage.
  857. * @param int $id
  858. * @return array
  859. */
  860. public function destroy($id)
  861. {
  862. if(!Gate::allows('二次加工管理-删除')){ return redirect('/'); }
  863. $this->log(__METHOD__,"删除二次加工单进回收站_".__FUNCTION__,json_encode($id),Auth::user()['id']);
  864. return ['success'=>Process::destroy($id)];
  865. }
  866. //修改二次加工单每日单的起始日期
  867. public function updateStartDate(Request $request){
  868. $start_date=$request->start_date;
  869. $process_id=$request->process_id;
  870. if (!$start_date || !$process_id)return ['success'=>false,'data'=>'起始日期为空或单据已不存在!'];
  871. $processDailiesId=[];
  872. $processDailies=ProcessDaily::where('process_id',$process_id)->get();
  873. $is_process_daily=false;
  874. foreach ($processDailies as $processDaily){
  875. if ($processDaily->date == $start_date){
  876. $is_process_daily=true;
  877. }
  878. if (Carbon::parse($processDaily->date)->lt(Carbon::parse($start_date))){
  879. array_push($processDailiesId,$processDaily->id);
  880. unset($processDaily);
  881. }
  882. }
  883. ProcessDaily::destroy($processDailiesId);
  884. ProcessDailyParticipant::whereIn('process_daily_id',$processDailiesId)->delete();
  885. $process=Process::find($process_id);
  886. if (!$is_process_daily && $process){
  887. $ProcessDailyNow=ProcessDaily::create([
  888. 'process_id'=>$process_id,
  889. 'date'=>$start_date,
  890. 'output'=>0,
  891. 'remain'=>$process->amount,
  892. ]);
  893. $processDailies->push($ProcessDailyNow);
  894. }
  895. $today=Carbon::now()->format('Y-m-d');
  896. $this->createDeficiencyData($processDailies,$today);
  897. $processDailies=ProcessDaily::with('processDailyParticipants')->where('process_id',$process_id)
  898. ->orderBy('date','DESC')->get();
  899. $this->log(__METHOD__,"修改二次加工单加工日记录_".__FUNCTION__,json_encode($request),Auth::user()['id']);
  900. return ['success'=>true,'data'=>$processDailies];
  901. }
  902. //修改二次加工单终止日期
  903. public function updateEndDate(Request $request){
  904. $end_date=$request->date;
  905. $process_id=$request->process_id;
  906. if (!$end_date || !$process_id)return ['success'=>false,'data'=>'终止日期为空或单据已不存在!'];
  907. $processDailiesId=[];
  908. $processDailies=ProcessDaily::where('process_id',$process_id)->orderBy('date','DESC')->get();
  909. foreach ($processDailies as $processDaily){
  910. if (Carbon::parse($processDaily->date)->gt(Carbon::parse($end_date))){
  911. array_push($processDailiesId,$processDaily->id);
  912. unset($processDaily);
  913. }
  914. }
  915. ProcessDaily::destroy($processDailiesId);
  916. ProcessDailyParticipant::whereIn('process_daily_id',$processDailiesId)->delete();
  917. $this->createDeficiencyData($processDailies,$end_date);
  918. $processDailies=ProcessDaily::with('processDailyParticipants')->where('process_id',$process_id)
  919. ->orderBy('date','DESC')->get();
  920. $this->createAutomaticSupplement($process_id);
  921. $this->log(__METHOD__,"修改二次加工单加工日记录_".__FUNCTION__,json_encode($request),Auth::user()['id']);
  922. return ['success'=>true,'data'=>$processDailies];
  923. }
  924. //增加填充标记
  925. private function createAutomaticSupplement($process_id){
  926. Sign::create([
  927. 'signable_type'=>'processes',
  928. 'signable_id'=>$process_id,
  929. 'field'=>'automatic_supplement',
  930. 'mark'=>"停止自动补充每日记录单"
  931. ]);
  932. }
  933. //删除临时工工作记录
  934. public function destroyDailyParticipant($id){
  935. if (ProcessDailyParticipant::destroy($id)) return ['success'=>true];
  936. return ['success'=>false , 'data'=>'记录不存在!'];
  937. }
  938. //导入商品数据
  939. public function importPasteData(Request $request){
  940. $commodities = explode("\n",$request->data); //拆分行
  941. $owner='';
  942. $processContents=[];
  943. foreach ($commodities as $commodity){
  944. $commodity = array_filter(preg_split('/[\t]+/is',$commodity)); //拆分列
  945. if (count($commodity)<count($request->rows)){
  946. unset($commodity);
  947. continue;
  948. }
  949. $commodityData=[];
  950. $wmsCode='';
  951. $barcode='';
  952. $amount=0;
  953. foreach ($request->rows as $index => $row){
  954. if ($row == '货主'){
  955. if (isset($commodity[$index]) && $commodity[$index] && !$owner){
  956. $owner=Owner::where('code',$commodity[$index])->orWhere('name',$commodity[$index])->first();
  957. if (!$owner){
  958. $owner = Owner::create([
  959. 'code' => $commodity[$index],
  960. 'name' => $commodity[$index]
  961. ]);
  962. }
  963. }
  964. }
  965. if ($row == '单据'){
  966. $wmsCode = isset($commodity[$index]) ? $commodity[$index] : '';
  967. }
  968. if ($row == 'SKU'){
  969. $commodityData['sku'] = isset($commodity[$index]) ? $commodity[$index] : '';
  970. }
  971. if ($row == '品名'){
  972. $commodityData['name'] = isset($commodity[$index]) ? $commodity[$index] : '';
  973. }
  974. if ($row == '条码'){
  975. $barcode = isset($commodity[$index]) ? $commodity[$index] : '';
  976. }
  977. if ($row == '数量'){
  978. $amount = isset($commodity[$index]) ? $commodity[$index] : '';
  979. }
  980. }
  981. $commodity = Commodity::query()->whereNull('owner_id')
  982. ->where('sku',$commodityData['sku'])->where('name',$commodityData['name'])->first();
  983. if (!$commodity)$commodity = Commodity::create($commodityData);
  984. $commodityBarCode=CommodityBarcode::create([
  985. 'code' => $barcode,
  986. 'commodity_id' => $commodity->id
  987. ]);
  988. $processContent=['bill_type'=>'入库单','commodity_id'=>$commodity->id,'wms_code'=>$wmsCode,'amount'=>$amount,
  989. 'commodity_name'=>$commodity->name,'commodity_barcodes'=>[$commodityBarCode],'commodity_sku'=>$commodity->sku,
  990. 'lineNo'=>1,'owner_id'=>$owner->id,'owner_name'=>$owner->name,'addBtnShow'=>false,'type'=>false];
  991. array_push($processContents,$processContent);
  992. $processContent['type']=true;
  993. array_push($processContents,$processContent);
  994. }
  995. return ['success'=>true,'data'=>$processContents];
  996. }
  997. //执行
  998. public function export($processes){
  999. if(!Gate::allows('二次加工管理-查询')){ return '没有权限'; }
  1000. $row=[[
  1001. 'id'=>'ID',
  1002. 'code'=>'任务号',
  1003. 'owner_name'=>'货主',
  1004. 'process_method_name'=>'加工类型',
  1005. 'amount'=>'预期数量',
  1006. 'completed_amount'=>'实际数量',
  1007. 'status'=>'状态',
  1008. 'remark'=>'备注',
  1009. 'unit_price'=>'单价',
  1010. 'created_at'=>'提交日期',
  1011. 'bill_type'=>'单据类型',
  1012. 'wms_code'=>'单据号',
  1013. 'commodity_barcode'=>'商品编码',
  1014. 'commodity_name'=>'商品名称',
  1015. 'thisAmount'=>'本次数量',
  1016. ]];
  1017. $list=[];
  1018. $i=0;
  1019. foreach ($processes as $process){
  1020. if (!$process->processesContents){
  1021. $w=[
  1022. 'id'=>$process->id,
  1023. 'code'=>$process->code ,
  1024. 'owner_name'=>$process->owner_name ,
  1025. 'process_method_name'=>$process->process_method_name,
  1026. 'amount'=>$process->amount,
  1027. 'unit_price'=>$process->unit_price,
  1028. 'created_at'=>$process->created_at ,
  1029. 'completed_amount'=>$process->completed_amount,
  1030. 'status'=>$process->status,
  1031. 'remark'=>$process->remark,
  1032. ];
  1033. $list[$i]=$w;
  1034. $i++;
  1035. continue;
  1036. }
  1037. foreach($process->processesContents as $processesContent){
  1038. $barcodes="";
  1039. if ($processesContent->commodity && $processesContent->commodity->barcodes){
  1040. foreach ($processesContent->commodity->barcodes as $barcode){
  1041. if (!$barcodes){$barcodes=$barcode->code; continue;}
  1042. $barcodes=$barcodes.",".$barcode->code;
  1043. }
  1044. }
  1045. $w=[
  1046. 'id'=>$process->id,
  1047. 'code'=>$process->code ,
  1048. 'owner_name'=>$process->owner_name ,
  1049. 'bill_type'=>$processesContent->bill_type ,
  1050. 'wms_code'=>$processesContent->wms_code ,
  1051. 'process_method_name'=>$process->process_method_name,
  1052. 'amount'=>$process->amount,
  1053. 'thisAmount'=>$processesContent->amount,
  1054. 'unit_price'=>$process->unit_price,
  1055. 'created_at'=>$process->created_at ,
  1056. 'commodity_barcode'=>$barcodes,
  1057. 'commodity_name'=>$processesContent->commodity_name ,
  1058. 'completed_amount'=>$process->completed_amount,
  1059. 'status'=>$process->status,
  1060. 'remark'=>$process->remark,
  1061. ];
  1062. $list[$i]=$w;
  1063. $i++;
  1064. }
  1065. }
  1066. return Excel::download(new Export($row,$list),date('YmdHis', time()).'-二次加工单.xlsx');
  1067. }
  1068. public function validatorProcessContent(array $processContent){
  1069. $validator=Validator::make($processContent,[
  1070. 'wms_code'=>['required'],
  1071. 'commodity_id'=>['required','integer'],
  1072. 'bill_type'=>['required'],
  1073. 'amount'=>['required','min:0','max:999999','integer']
  1074. ],[
  1075. 'required'=>':attribute 不应为空',
  1076. 'min'=>':attribute 不得为0或为负',
  1077. 'integer'=>':attribute 必须为整数',
  1078. 'max'=>':attribute 输入值过大',
  1079. ],[
  1080. 'wms_code'=>'单据号',
  1081. 'commodity_id'=>'商品',
  1082. 'bill_type'=>'单据类型',
  1083. 'amount'=>'商品数量',
  1084. ]);
  1085. return $validator;
  1086. }
  1087. public function validatorProcess(Request $request){
  1088. $validator=Validator::make($request->input(),[
  1089. 'owner_id'=>['required'],
  1090. 'process_method_id'=>['required','integer'],
  1091. 'amount'=>['required','integer'],
  1092. 'unit_price'=>['required','min:0','max:999999','numeric'],
  1093. ],[
  1094. 'required'=>':attribute 不应为空',
  1095. 'min'=>':attribute 不得为0或为负',
  1096. 'numeric'=>':attribute 必须为数字',
  1097. 'max'=>':attribute 输入值过大',
  1098. 'integer' =>':attribute 必须为整数',
  1099. ],[
  1100. 'owner_id'=>'货主',
  1101. 'process_method_id'=>'加工类型',
  1102. 'amount'=>'数量',
  1103. 'unit_price'=>'单价',
  1104. ]);
  1105. return $validator;
  1106. }
  1107. public function validator(Request $request){
  1108. $validator=Validator::make($request->input(),[
  1109. 'id'=>['required','integer'],
  1110. 'output'=>'required|min:0|max:999999|numeric',
  1111. ],[
  1112. 'required'=>':attribute 不应为空',
  1113. 'min'=>':attribute 不得为0或为负',
  1114. 'numeric'=>':attribute 必须为数字',
  1115. 'max'=>':attribute 输入值过大',
  1116. ],[
  1117. 'output'=>'每日产量'
  1118. ]);
  1119. return $validator;
  1120. }
  1121. //参与人信息校验
  1122. public function validatorProcessDailyParticipant(Request $request){
  1123. $validator=Validator::make($request->input(),[
  1124. 'daily_id'=>'filled',
  1125. 'user_id'=>'required',
  1126. 'started_at'=>'required|date_format:H:i',
  1127. 'ended_at'=>'required|date_format:H:i',
  1128. 'hour_price'=>'required_without:unit_price|min:0|max:999999|nullable|numeric',
  1129. 'unit_price'=>'required_without:hour_price|min:0|max:999999|nullable|numeric',
  1130. 'dinner_duration'=>'nullable|integer',
  1131. 'hour_count'=>'required_with:hour_price|min:0|max:999999|nullable|numeric',
  1132. 'unit_count'=>'required_with:unit_price|min:0|max:999999|nullable|numeric',
  1133. 'remark'=>'nullable',
  1134. ],[
  1135. 'required'=>':attribute 不应为空',
  1136. 'min'=>':attribute 不得为0或为负',
  1137. 'numeric'=>':attribute 必须为数字',
  1138. 'max'=>':attribute 输入值过大',
  1139. 'required_without'=>':attribute 计时与计件至少填一项',
  1140. 'date_format'=>':attribute 格式错误',
  1141. 'integer'=>':attribute 选择错误',
  1142. 'required_with'=>':attribute 必须填写',
  1143. ],[
  1144. 'daily_id'=>'所属每日单',
  1145. 'user_id'=>'参与人',
  1146. 'started_at'=>'开始时间',
  1147. 'ended_at'=>'结束时间',
  1148. 'hour_price'=>'计时工资',
  1149. 'unit_price'=>'计件工资',
  1150. 'dinner_duration'=>'晚饭时间',
  1151. 'hour_count'=>'计时工时',
  1152. 'unit_count'=>'计件数量',
  1153. 'remark'=>'备注',
  1154. ]);
  1155. return $validator;
  1156. }
  1157. }