ProcessController.php 56 KB

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