ProcessController.php 56 KB

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