ProcessController.php 57 KB

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