ProcessController.php 55 KB

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