ProjectService.php 44 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019
  1. <?php
  2. namespace App\Service;
  3. use App\Model\Employee;
  4. use App\Model\Project;
  5. use App\Model\ProjectStage;
  6. use App\Model\ProjectStageNode;
  7. use App\Model\ProjectStageNodeMission;
  8. use App\Model\ProjectStageNodeMissionDetail;
  9. use Illuminate\Support\Facades\DB;
  10. class ProjectService extends Service
  11. {
  12. public function edit($data){
  13. list($status,$msg) = $this->projectRule($data,false);
  14. if(! $status) return [$status,$msg];
  15. DB::beginTransaction();
  16. try{
  17. $model = Project::where('id',$data['id'])->first();
  18. $model->title = $data['title'] ?? "";
  19. $model->importance = $data['importance'] ?? 0;
  20. $model->company = $data['company'] ?? "";
  21. $model->project_cycle = $data['project_cycle'] ?? 0;
  22. $model->business_director = $data['business_director'] ?? 0;
  23. $model->technical_director = $data['technical_director'] ?? 0;
  24. $model->online_director = $data['online_director'] ?? 0;
  25. $model->after_sale_director = $data['after_sale_director'] ?? 0;
  26. $model->project_amount = $data['project_amount'] ?? 0;
  27. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  28. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  29. $model->finish_time = $data['finish_time'] ?? 0;
  30. $model->budget = $data['budget'] ?? 0;
  31. $model->stage = $data['stage'] ?? 0;
  32. $model->save();
  33. DB::commit();
  34. }catch (\Exception $exception){
  35. DB::rollBack();
  36. return [false,$exception->getMessage()];
  37. }
  38. return [true, ''];
  39. }
  40. public function add($data,$user){
  41. list($status,$msg) = $this->projectRule($data);
  42. if(! $status) return [$status,$msg];
  43. try{
  44. DB::beginTransaction();
  45. $model = new Project();
  46. $model->title = $data['title'] ?? "";
  47. $model->importance = $data['importance'] ?? 0;
  48. $model->company = $data['company'] ?? "";
  49. $model->project_cycle = $data['project_cycle'] ?? 0;
  50. $model->business_director = $data['business_director'] ?? 0;
  51. $model->technical_director = $data['technical_director'] ?? 0;
  52. $model->online_director = $data['online_director'] ?? 0;
  53. $model->after_sale_director = $data['after_sale_director'] ?? 0;
  54. $model->project_amount = $data['project_amount'] ?? 0;
  55. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  56. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  57. $model->finish_time = $data['finish_time'] ?? 0;
  58. $model->budget = $data['budget'] ?? 0;
  59. $model->stage = $data['stage'] ?? 0;
  60. $model->crt_id = $user['id'];
  61. $model->save();
  62. DB::commit();
  63. }catch (\Exception $exception){
  64. DB::rollBack();
  65. return [false,$exception->getMessage()];
  66. }
  67. return [true, ''];
  68. }
  69. public function del($data){
  70. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  71. DB::beginTransaction();
  72. try {
  73. Project::where('id',$data['id'])->update([
  74. 'del_time' => time()
  75. ]);
  76. ProjectStage::where('project_id',$data['id'])->where('del_time',0)->update([
  77. 'del_time' => time()
  78. ]);
  79. ProjectStageNode::where('project_id',$data['id'])->where('del_time',0)->update([
  80. 'del_time' => time()
  81. ]);
  82. ProjectStageNodeMission::where('project_id',$data['id'])->where('del_time',0)->update([
  83. 'del_time' => time()
  84. ]);
  85. ProjectStageNodeMissionDetail::where('project_id',$data['id'])->where('del_time',0)->update([
  86. 'del_time' => time()
  87. ]);
  88. DB::commit();
  89. }catch (\Exception $exception){
  90. DB::rollBack();
  91. return [false,$exception->getMessage()];
  92. }
  93. return [true,'删除成功'];
  94. }
  95. public function detail($data){
  96. if(empty($data['id'])) return [false, "ID不能为空"];
  97. $project = Project::where('id',$data['id'])->first();
  98. if(empty($project) || $project->del_time > 0) return [false, '项目不存在或已被删除'];
  99. $project = $project->toArray();
  100. //组织数据
  101. $emp_id = [$project['business_director'], $project['technical_director'], $project['online_director'], $project['after_sale_director'], $project['crt_id']];
  102. $emp_id = array_unique($emp_id);
  103. $emp_map = Employee::whereIn('id',$emp_id)->pluck('emp_name','id')->toArray();
  104. $start_time = $project['plan_start_time'] ? date("Y-m-d H:i",$project['plan_start_time']) : '';
  105. $end_time = $project['plan_end_time'] ? date("Y-m-d H:i",$project['plan_end_time']) : '';
  106. $project['plan_time'] = $start_time . '——' . $end_time;
  107. $project['crt_time'] = $project['crt_time'] ? date("Y-m-d H:i:s",$project['crt_time']): '';
  108. $project['finish_time'] = $project['finish_time'] ? date("Y-m-d",$project['finish_time']): '';
  109. $project['business_director_title'] = $emp_map[$project['business_director']] ?? "";
  110. $project['technical_director_title'] = $emp_map[$project['technical_director']] ?? "";
  111. $project['online_director_title'] = $emp_map[$project['online_director']] ?? "";
  112. $project['after_sale_director_title'] = $emp_map[$project['after_sale_director']] ?? "";
  113. $project['crt_name'] = $emp_map[$project['crt_id']] ?? "";
  114. //任务报告
  115. $project_stage_node_mission_detail = ProjectStageNodeMissionDetail::where('del_time',0)
  116. ->where('project_id',$data['id'])
  117. ->get()->toArray();
  118. $employee_id = array_unique(array_column($project_stage_node_mission_detail,'crt_id'));
  119. $emp_map = Employee::whereIn('id',$employee_id)->pluck('emp_name','id')->toArray();
  120. $project_stage_node_mission_detail_map = [];
  121. foreach ($project_stage_node_mission_detail as $key => $value){
  122. $start_time = $value['start_time'] ? date("Y-m-d H:i",$value['start_time']) : '';
  123. $end_time = $value['end_time'] ? date("Y-m-d H:i",$value['end_time']) : '';
  124. $project_stage_node_mission_detail[$key]['time'] = $start_time . '——' . $end_time;
  125. $project_stage_node_mission_detail[$key]['crt_name'] = $emp_map[$value['crt_id']] ?? "";
  126. $project_stage_node_mission_detail_map[$value['project_stage_node_mission_id']][] = $project_stage_node_mission_detail[$key];
  127. }
  128. //任务
  129. $project_stage_node_mission = ProjectStageNodeMission::where('del_time',0)
  130. ->where('project_id',$data['id'])
  131. ->get()->toArray();
  132. //获取人员名称
  133. $emp_map = $this->returnEmployeeTitle($project_stage_node_mission);
  134. $project_stage_node_mission_map = [];
  135. foreach ($project_stage_node_mission as $key => $value){
  136. $title = "";
  137. $tmp = explode(',', $value['employee_id']);
  138. foreach ($tmp as $val){
  139. $title_tmp = $emp_map[$val] ?? "";
  140. if($title_tmp) $title .= $title_tmp . ",";
  141. }
  142. $project_stage_node_mission[$key]['employee_title'] = rtrim($title,',');
  143. $son = $project_stage_node_mission_detail_map[$value['id']] ?? [];
  144. $project_stage_node_mission[$key]['children'] = $son;
  145. $project_stage_node_mission_map[$value['project_stage_node_id']][] = $project_stage_node_mission[$key];
  146. }
  147. //节点
  148. $project_stage_node = ProjectStageNode::where('del_time',0)
  149. ->where('project_id',$data['id'])
  150. ->get()->toArray();
  151. $project_stage_node_map = [];
  152. foreach ($project_stage_node as $key => $value){
  153. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  154. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  155. $project_stage_node[$key]['plan_time'] = $start_time . '——' . $end_time;
  156. $project_stage_node[$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  157. $son = $project_stage_node_mission_map[$value['id']] ?? [];
  158. $project_stage_node[$key]['children'] = $son;
  159. $project_stage_node_map[$value['project_stage_id']][] = $project_stage_node[$key];
  160. }
  161. //阶段
  162. $project_stage = ProjectStage::where('del_time',0)
  163. ->where('project_id',$data['id'])
  164. ->get()->toArray();
  165. foreach ($project_stage as $key => $value){
  166. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  167. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  168. $project_stage[$key]['plan_time'] = $start_time . '——' . $end_time;
  169. $project_stage[$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  170. $project_stage[$key]['children'] = $project_stage_node_map[$value['id']] ?? [];
  171. }
  172. // $project['project_stage'] = $project_stage;
  173. // $project['project_stage_node'] = $project_stage_node;
  174. // $project['project_stage_node_mission'] = $project_stage_node_mission;
  175. // $project['project_stage_node_mission_detail'] = $project_stage_node_mission_detail;
  176. $project['children'] = $project_stage;
  177. return [true, $project];
  178. }
  179. public function projectList($data,$user){
  180. $model = Project::where('del_time',0)
  181. ->select('id','title','importance','company','project_cycle','business_director','technical_director','online_director','after_sale_director','project_amount','plan_start_time','plan_end_time','finish_time','budget','stage','crt_time','crt_id')
  182. ->orderBy('id','desc');
  183. if(! empty($data['title'])) $model->where('title',$data['title']);
  184. if(! empty($data['company'])) $model->where('company',$data['company']);
  185. if(isset($data['importance'])) $model->where('importance',$data['importance']);
  186. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  187. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  188. $model->where('crt_time','>=',$return[0]);
  189. $model->where('crt_time','<=',$return[1]);
  190. }
  191. $list = $this->limit($model,'',$data);
  192. $list = $this->organizationData($list);
  193. return [true, $list];
  194. }
  195. public function organizationData($data) {
  196. if (empty($data['data'])) return $data;
  197. $emp_id = array_unique(array_merge_recursive(array_column($data['data'], 'business_director'), array_column($data['data'], 'technical_director'),array_column($data['data'], 'online_director'),array_column($data['data'], 'after_sale_director'),array_column($data['data'],'crt_id')));
  198. $emp_map = Employee::whereIn('id',$emp_id)->pluck('emp_name','id')->toArray();
  199. foreach ($data['data'] as $key => $value){
  200. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  201. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  202. $data['data'][$key]['plan_time'] = $start_time . '——' . $end_time;
  203. $data['data'][$key]['crt_name'] = $emp_map[$value['crt_id']] ?? "";
  204. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  205. $data['data'][$key]['finish_time'] = $value['finish_time'] ? date("Y-m-d",$value['finish_time']): '';
  206. $data['data'][$key]['business_director_title'] = $emp_map[$value['business_director']] ?? "";
  207. $data['data'][$key]['technical_director_title'] = $emp_map[$value['technical_director']] ?? "";
  208. $data['data'][$key]['online_director_title'] = $emp_map[$value['online_director']] ?? "";
  209. $data['data'][$key]['after_sale_director_title'] = $emp_map[$value['after_sale_director']] ?? "";
  210. }
  211. return $data;
  212. }
  213. public function projectRule(&$data, $is_check = true){
  214. if(empty($data['title'])) return [false,'项目名称不能为空'];
  215. if(isset($data['project_cycle'])){
  216. if(! is_numeric($data['project_cycle']) || floatval($data['project_cycle']) < 0.0) return [false, '项目周期请输入合法的数字(天数)'];
  217. }
  218. if(isset($data['project_amount'])){
  219. $res = $this->checkNumber($data['project_amount']);
  220. if(! $res) return [false, '项目金额请输入不超过两位小数并且大于的等于0的数值'];
  221. }
  222. if(isset($data['budget'])){
  223. $res = $this->checkNumber($data['budget']);
  224. if(! $res) return [false, '预算请输入不超过两位小数并且大于的等于0的数值'];
  225. }
  226. if(isset($data['stage'])){
  227. $res = $this->checkNumber($data['budget'], 0);
  228. if(! $res) return [false, '阶段数请输入大于等于0的整数'];
  229. }
  230. if(! empty($data['plan_time'][0]) && ! empty($data['plan_time'][1])){
  231. $data['plan_start_time'] = $this->changeDateToDateMin($data['plan_time'][0]);
  232. $data['plan_end_time'] = $this->changeDateToDateMin($data['plan_time'][1]);
  233. }
  234. if(! empty($data['finish_time'])) $data['finish_time'] = $this->changeDateToDate($data['finish_time']);
  235. if($is_check){
  236. }else{
  237. if(empty($data['id'])) return [false, '项目ID不能为空'];
  238. $boolean = Project::where('id',$data['id'])->where('del_time',0)->exists();
  239. if(! $boolean) return [false, '项目不存在或已被删除'];
  240. }
  241. return [true, ''];
  242. }
  243. public function editStage($data){
  244. list($status,$msg) = $this->stageRule($data,false);
  245. if(! $status) return [$status,$msg];
  246. DB::beginTransaction();
  247. try{
  248. $model = ProjectStage::where('id',$data['id'])->first();
  249. $model->project_id = $data['project_id'] ?? 0;
  250. $model->title = $data['title'] ?? "";
  251. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  252. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  253. $model->start_time = $data['start_time'] ?? 0;
  254. $model->receivable_amount = $data['receivable_amount'] ?? 0;
  255. $model->receipt_amount = $data['receipt_amount'] ?? 0;
  256. $model->save();
  257. DB::commit();
  258. }catch (\Exception $exception){
  259. DB::rollBack();
  260. return [false,$exception->getMessage()];
  261. }
  262. return [true, ''];
  263. }
  264. public function addStage($data,$user){
  265. list($status,$msg) = $this->stageRule($data);
  266. if(! $status) return [$status,$msg];
  267. try{
  268. DB::beginTransaction();
  269. $model = new ProjectStage();
  270. $model->project_id = $data['project_id'] ?? 0;
  271. $model->title = $data['title'] ?? "";
  272. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  273. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  274. $model->start_time = $data['start_time'] ?? 0;
  275. $model->receivable_amount = $data['receivable_amount'] ?? 0;
  276. $model->receipt_amount = $data['receipt_amount'] ?? 0;
  277. $model->save();
  278. DB::commit();
  279. }catch (\Exception $exception){
  280. DB::rollBack();
  281. return [false,$exception->getMessage()];
  282. }
  283. return [true, ''];
  284. }
  285. public function delStage($data){
  286. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  287. DB::beginTransaction();
  288. try {
  289. ProjectStage::where('id',$data['id'])->where('del_time',0)->update([
  290. 'del_time' => time()
  291. ]);
  292. ProjectStageNode::where('project_stage_id',$data['id'])->where('del_time',0)->update([
  293. 'del_time' => time()
  294. ]);
  295. ProjectStageNodeMission::where('project_stage_id',$data['id'])->where('del_time',0)->update([
  296. 'del_time' => time()
  297. ]);
  298. ProjectStageNodeMissionDetail::where('project_stage_id',$data['id'])->where('del_time',0)->update([
  299. 'del_time' => time()
  300. ]);
  301. DB::commit();
  302. }catch (\Exception $exception){
  303. DB::rollBack();
  304. return [false,$exception->getMessage()];
  305. }
  306. return [true,'删除成功'];
  307. }
  308. public function stageRule(&$data, $is_check = true){
  309. if(empty($data['project_id'])) return [false,'项目ID不能为空'];
  310. $bool = Project::where('id',$data['project_id'])->where('del_time',0)->exists();
  311. if(! $bool) return [false, '该项目不存在或已被删除'];
  312. if(empty($data['title'])) return [false, '阶段名称不能为空'];
  313. if(isset($data['receivable_amount'])){
  314. $res = $this->checkNumber($data['receivable_amount']);
  315. if(! $res) return [false, '阶段应收金额请输入不超过两位小数并且大于的等于0的数值'];
  316. }
  317. if(isset($data['receipt_amount'])){
  318. $res = $this->checkNumber($data['receipt_amount']);
  319. if(! $res) return [false, '阶段实收金额请输入不超过两位小数并且大于的等于0的数值'];
  320. }
  321. if(! empty($data['plan_time'][0]) && ! empty($data['plan_time'][1])){
  322. $data['plan_start_time'] = $this->changeDateToDateMin($data['plan_time'][0]);
  323. $data['plan_end_time'] = $this->changeDateToDateMin($data['plan_time'][1]);
  324. }
  325. if(! empty($data['start_time'])) $data['start_time'] = $this->changeDateToDate($data['start_time']);
  326. if($is_check){
  327. $bool = ProjectStage::where('project_id',$data['project_id'])
  328. ->where('title',$data['title'])
  329. ->exists();
  330. }else{
  331. if(empty($data['id'])) return [false, '阶段ID不能为空'];
  332. $boolean = ProjectStage::where('id',$data['id'])->where('del_time',0)->exists();
  333. if(! $boolean) return [false, '项目阶段不存在或已被删除'];
  334. $bool = ProjectStage::where('project_id',$data['project_id'])
  335. ->where('id','<>',$data['id'])
  336. ->where('title',$data['title'])
  337. ->exists();
  338. }
  339. if($bool) return [false, '项目阶段名已存在'];
  340. return [true, ''];
  341. }
  342. public function projectStageList($data,$user){
  343. $model = ProjectStage::where('del_time',0)
  344. ->select('id','title','project_id','plan_start_time','plan_end_time','start_time','receivable_amount','receipt_amount','crt_time')
  345. ->orderBy('id','desc');
  346. if(! empty($data['title'])) $model->where('title',$data['title']);
  347. if(! empty($data['project_title'])) {
  348. $project_id = $this->searchProject(['title' => $data['project_title']]);
  349. $model->whereIn('project_id', $project_id);
  350. }
  351. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  352. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  353. $model->where('crt_time','>=',$return[0]);
  354. $model->where('crt_time','<=',$return[1]);
  355. }
  356. $list = $this->limit($model,'',$data);
  357. $list = $this->organizationStageData($list);
  358. return [true, $list];
  359. }
  360. public function organizationStageData($data) {
  361. if (empty($data['data'])) return $data;
  362. $project_map = $this->getProject(array_column($data['data'],'project_id'));
  363. foreach ($data['data'] as $key => $value){
  364. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  365. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  366. $data['data'][$key]['plan_time'] = $start_time . '——' . $end_time;
  367. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  368. $data['data'][$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  369. $data['data'][$key]['project_title'] = $project_map[$value['project_id']] ?? "";
  370. }
  371. return $data;
  372. }
  373. public function editStageNode($data){
  374. list($status,$msg) = $this->stageRuleNode($data,false);
  375. if(! $status) return [$status,$msg];
  376. DB::beginTransaction();
  377. try{
  378. $model = ProjectStageNode::where('id',$data['id'])->first();
  379. $model->project_id = $data['project_id'] ?? 0;
  380. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  381. $model->title = $data['title'] ?? "";
  382. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  383. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  384. $model->start_time = $data['start_time'] ?? 0;
  385. $model->save();
  386. DB::commit();
  387. }catch (\Exception $exception){
  388. DB::rollBack();
  389. return [false,$exception->getMessage()];
  390. }
  391. return [true, ''];
  392. }
  393. public function addStageNode($data,$user){
  394. list($status,$msg) = $this->stageRuleNode($data);
  395. if(! $status) return [$status,$msg];
  396. try{
  397. DB::beginTransaction();
  398. $model = new ProjectStageNode();
  399. $model->project_id = $data['project_id'] ?? 0;
  400. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  401. $model->title = $data['title'] ?? "";
  402. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  403. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  404. $model->start_time = $data['start_time'] ?? 0;
  405. $model->save();
  406. DB::commit();
  407. }catch (\Exception $exception){
  408. DB::rollBack();
  409. return [false,$exception->getMessage()];
  410. }
  411. return [true, ''];
  412. }
  413. public function delStageNode($data){
  414. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  415. DB::beginTransaction();
  416. try {
  417. ProjectStageNode::where('id',$data['id'])->where('del_time',0)->update([
  418. 'del_time' => time()
  419. ]);
  420. ProjectStageNodeMission::where('project_stage_node_id',$data['id'])->where('del_time',0)->update([
  421. 'del_time' => time()
  422. ]);
  423. ProjectStageNodeMissionDetail::where('project_stage_node_id',$data['id'])->where('del_time',0)->update([
  424. 'del_time' => time()
  425. ]);
  426. DB::commit();
  427. }catch (\Exception $exception){
  428. DB::rollBack();
  429. return [false,$exception->getMessage()];
  430. }
  431. return [true,'删除成功'];
  432. }
  433. public function stageRuleNode(&$data, $is_check = true){
  434. if(empty($data['project_stage_id'])) return [false,'项目阶段ID不能为空'];
  435. $stage = ProjectStage::where('id',$data['project_stage_id'])->where('del_time',0)->first();
  436. if(empty($stage)) return [false, '该项目阶段不存在或已被删除'];
  437. $stage = $stage->toArray();
  438. $data['project_id'] = $stage['project_id'];
  439. if(empty($data['title'])) return [false, '节点名称不能为空'];
  440. if(! empty($data['plan_time'][0]) && ! empty($data['plan_time'][1])){
  441. $data['plan_start_time'] = $this->changeDateToDateMin($data['plan_time'][0]);
  442. $data['plan_end_time'] = $this->changeDateToDateMin($data['plan_time'][1]);
  443. }
  444. if(! empty($data['start_time'])) $data['start_time'] = $this->changeDateToDate($data['start_time']);
  445. if($is_check){
  446. $bool = ProjectStageNode::where('project_id',$data['project_id'])
  447. ->where('project_stage_id',$data['project_stage_id'])
  448. ->where('title',$data['title'])
  449. ->exists();
  450. }else{
  451. if(empty($data['id'])) return [false, '阶段节点ID不能为空'];
  452. $boolean = ProjectStageNode::where('id',$data['id'])->where('del_time',0)->exists();
  453. if(! $boolean) return [false, '项目阶段节点不存在或已被删除'];
  454. $bool = ProjectStageNode::where('project_id',$data['project_id'])
  455. ->where('project_stage_id',$data['project_stage_id'])
  456. ->where('id','<>',$data['id'])
  457. ->where('title',$data['title'])
  458. ->exists();
  459. }
  460. if($bool) return [false, '项目阶段节点名已存在'];
  461. return [true, ''];
  462. }
  463. public function projectStageNodeList($data,$user){
  464. $model = ProjectStageNode::where('del_time',0)
  465. ->select('id','project_stage_id','project_id','plan_start_time','plan_end_time','start_time','crt_time','title')
  466. ->orderBy('id','desc');
  467. if(! empty($data['project_stage_title'])) {
  468. $project_stage_id = $this->searchProjectStage(['title' => $data['project_stage_title']]);
  469. $model->whereIn('project_stage_id', $project_stage_id);
  470. }
  471. if(! empty($data['project_title'])) {
  472. $project_id = $this->searchProject(['title' => $data['project_title']]);
  473. $model->whereIn('project_id', $project_id);
  474. }
  475. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  476. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  477. $model->where('crt_time','>=',$return[0]);
  478. $model->where('crt_time','<=',$return[1]);
  479. }
  480. $list = $this->limit($model,'',$data);
  481. $list = $this->organizationStageNodeData($list);
  482. return [true, $list];
  483. }
  484. public function organizationStageNodeData($data) {
  485. if (empty($data['data'])) return $data;
  486. $project_map = $this->getProject(array_column($data['data'],'project_id'));
  487. $project_stage_map = $this->getProjectStage(array_column($data['data'],'project_stage_id'));
  488. foreach ($data['data'] as $key => $value){
  489. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  490. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  491. $data['data'][$key]['plan_time'] = $start_time . '——' . $end_time;
  492. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  493. $data['data'][$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  494. $data['data'][$key]['project_title'] = $project_map[$value['project_id']] ?? "";
  495. $data['data'][$key]['project_stage_title'] = $project_stage_map[$value['project_stage_id']] ?? "";
  496. }
  497. return $data;
  498. }
  499. public function editStageNodeMission($data){
  500. list($status,$msg) = $this->stageRuleNodeMission($data,false);
  501. if(! $status) return [$status,$msg];
  502. DB::beginTransaction();
  503. try{
  504. $model = ProjectStageNodeMission::where('id',$data['id'])->first();
  505. $model->project_id = $data['project_id'] ?? 0;
  506. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  507. $model->project_stage_node_id = $data['project_stage_node_id'] ?? 0;
  508. $model->title = $data['title'] ?? "";
  509. $model->content = $data['content'] ?? 0;
  510. $model->employee_id = $data['employee_id'] ?? "";
  511. $model->save();
  512. DB::commit();
  513. }catch (\Exception $exception){
  514. DB::rollBack();
  515. return [false,$exception->getMessage()];
  516. }
  517. return [true, ''];
  518. }
  519. public function addStageNodeMission($data,$user){
  520. list($status,$msg) = $this->stageRuleNodeMission($data);
  521. if(! $status) return [$status,$msg];
  522. try{
  523. DB::beginTransaction();
  524. $model = new ProjectStageNodeMission();
  525. $model->project_id = $data['project_id'] ?? 0;
  526. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  527. $model->project_stage_node_id = $data['project_stage_node_id'] ?? 0;
  528. $model->title = $data['title'] ?? "";
  529. $model->content = $data['content'] ?? 0;
  530. $model->employee_id = $data['employee_id'] ?? "";
  531. $model->save();
  532. DB::commit();
  533. }catch (\Exception $exception){
  534. DB::rollBack();
  535. return [false,$exception->getMessage()];
  536. }
  537. return [true, ''];
  538. }
  539. public function delStageNodeMission($data){
  540. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  541. DB::beginTransaction();
  542. try {
  543. ProjectStageNodeMission::where('id',$data['id'])->where('del_time',0)->update([
  544. 'del_time' => time()
  545. ]);
  546. ProjectStageNodeMissionDetail::where('project_stage_node_mission_id',$data['id'])->where('del_time',0)->update([
  547. 'del_time' => time()
  548. ]);
  549. DB::commit();
  550. }catch (\Exception $exception){
  551. DB::rollBack();
  552. return [false,$exception->getMessage()];
  553. }
  554. return [true,'删除成功'];
  555. }
  556. public function stageRuleNodeMission(&$data, $is_check = true){
  557. if(empty($data['project_stage_node_id'])) return [false,'项目阶段节点ID不能为空'];
  558. $stage = ProjectStageNode::where('id',$data['project_stage_node_id'])->where('del_time',0)->first();
  559. if(empty($stage)) return [false, '该项目阶段节点不存在或已被删除'];
  560. $stage = $stage->toArray();
  561. $data['project_id'] = $stage['project_id'];
  562. $data['project_stage_id'] = $stage['project_stage_id'];
  563. if(empty($data['title'])) return [false, '节点任务名称不能为空'];
  564. if(empty($data['content'])) return [false, '节点任务内容不能为空'];
  565. if($is_check){
  566. $bool = ProjectStageNodeMission::where('project_id',$data['project_id'])
  567. ->where('project_stage_id',$data['project_stage_id'])
  568. ->where('project_stage_node_id',$data['project_stage_node_id'])
  569. ->where('title',$data['title'])
  570. ->exists();
  571. }else{
  572. if(empty($data['id'])) return [false, '阶段节点任务ID不能为空'];
  573. $boolean = ProjectStageNodeMission::where('id',$data['id'])->where('del_time',0)->exists();
  574. if(! $boolean) return [false, '项目阶段节点任务不存在或已被删除'];
  575. $bool = ProjectStageNodeMission::where('project_id',$data['project_id'])
  576. ->where('project_stage_id',$data['project_stage_id'])
  577. ->where('project_stage_node_id',$data['project_stage_node_id'])
  578. ->where('id','<>',$data['id'])
  579. ->where('title',$data['title'])
  580. ->exists();
  581. }
  582. if($bool) return [false, '节点任务名称已存在'];
  583. return [true, ''];
  584. }
  585. public function projectStageNodeMissionList($data,$user){
  586. $model = ProjectStageNodeMission::where('del_time',0)
  587. ->select('id','project_stage_id','project_id','project_stage_node_id','title','content','employee_id','crt_time')
  588. ->orderBy('id','desc');
  589. if(! empty($data['project_stage_title'])) {
  590. $project_stage_id = $this->searchProjectStage(['title' => $data['project_stage_title']]);
  591. $model->whereIn('project_stage_id', $project_stage_id);
  592. }
  593. if(! empty($data['project_title'])) {
  594. $project_id = $this->searchProject(['title' => $data['project_title']]);
  595. $model->whereIn('project_id', $project_id);
  596. }
  597. if(! empty($data['project_stage_node_title'])) {
  598. $project_stage_node_id = $this->searchProjectStageNode(['title' => $data['project_stage_node_title']]);
  599. $model->whereIn('project_stage_node_id', $project_stage_node_id);
  600. }
  601. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  602. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  603. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  604. $model->where('crt_time','>=',$return[0]);
  605. $model->where('crt_time','<=',$return[1]);
  606. }
  607. $list = $this->limit($model,'',$data);
  608. $list = $this->organizationStageNodeMissionData($list);
  609. return [true, $list];
  610. }
  611. public function organizationStageNodeMissionData($data) {
  612. if (empty($data['data'])) return $data;
  613. $emp_map = $this->returnEmployeeTitle($data['data']);
  614. $project_map = $this->getProject(array_column($data['data'],'project_id'));
  615. $project_stage_map = $this->getProjectStage(array_column($data['data'],'project_stage_id'));
  616. $project_stage_node_map = $this->getProjectStageNode(array_column($data['data'],'project_stage_node_id'));
  617. foreach ($data['data'] as $key => $value){
  618. $title = "";
  619. $tmp = explode(',', $value['employee_id']);
  620. foreach ($tmp as $val){
  621. $title_tmp = $emp_map[$val] ?? "";
  622. if($title_tmp) $title .= $title_tmp . ",";
  623. }
  624. $data['data'][$key]['employee_title'] = rtrim($title,',');
  625. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  626. $data['data'][$key]['project_title'] = $project_map[$value['project_id']] ?? "";
  627. $data['data'][$key]['project_stage_title'] = $project_stage_map[$value['project_stage_id']] ?? "";
  628. $data['data'][$key]['project_stage_node_title'] = $project_stage_node_map[$value['project_stage_node_id']] ?? "";
  629. }
  630. return $data;
  631. }
  632. public function editStageNodeMissionDetail($data){
  633. list($status,$msg) = $this->stageRuleNodeMissionDetail($data,false);
  634. if(! $status) return [$status,$msg];
  635. DB::beginTransaction();
  636. try{
  637. $model = ProjectStageNodeMissionDetail::where('id',$data['id'])->first();
  638. $model->project_id = $data['project_id'] ?? 0;
  639. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  640. $model->project_stage_node_id = $data['project_stage_node_id'] ?? 0;
  641. $model->project_stage_node_mission_id = $data['project_stage_node_mission_id'] ?? 0;
  642. $model->start_time = $data['start_time'] ?? 0;
  643. $model->end_time = $data['end_time'] ?? 0;
  644. $model->content = $data['content'] ?? 0;
  645. $model->completion_degree = $data['completion_degree'] ?? "";
  646. $model->save();
  647. DB::commit();
  648. }catch (\Exception $exception){
  649. DB::rollBack();
  650. return [false,$exception->getMessage()];
  651. }
  652. return [true, ''];
  653. }
  654. public function addStageNodeMissionDetail($data,$user){
  655. list($status,$msg) = $this->stageRuleNodeMissionDetail($data);
  656. if(! $status) return [$status,$msg];
  657. try{
  658. DB::beginTransaction();
  659. $model = new ProjectStageNodeMissionDetail();
  660. $model->project_id = $data['project_id'] ?? 0;
  661. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  662. $model->project_stage_node_id = $data['project_stage_node_id'] ?? 0;
  663. $model->project_stage_node_mission_id = $data['project_stage_node_mission_id'] ?? 0;
  664. $model->start_time = $data['start_time'] ?? 0;
  665. $model->end_time = $data['end_time'] ?? 0;
  666. $model->content = $data['content'] ?? 0;
  667. $model->completion_degree = $data['completion_degree'] ?? "";
  668. $model->crt_id = $user['id'] ?? "";
  669. $model->save();
  670. DB::commit();
  671. }catch (\Exception $exception){
  672. DB::rollBack();
  673. return [false,$exception->getMessage()];
  674. }
  675. return [true, ''];
  676. }
  677. public function delStageNodeMissionDetail($data){
  678. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  679. DB::beginTransaction();
  680. try {
  681. ProjectStageNodeMissionDetail::where('id',$data['id'])->where('del_time',0)->update([
  682. 'del_time' => time()
  683. ]);
  684. DB::commit();
  685. }catch (\Exception $exception){
  686. DB::rollBack();
  687. return [false,$exception->getMessage()];
  688. }
  689. return [true,'删除成功'];
  690. }
  691. public function stageRuleNodeMissionDetail(&$data, $is_check = true){
  692. if(empty($data['project_stage_node_mission_id'])) return [false,'项目阶段节点任务ID不能为空'];
  693. $stage = ProjectStageNodeMission::where('id',$data['project_stage_node_mission_id'])->where('del_time',0)->first();
  694. if(empty($stage)) return [false, '该项目阶段节点任务不存在或已被删除'];
  695. $stage = $stage->toArray();
  696. $data['project_id'] = $stage['project_id'];
  697. $data['project_stage_id'] = $stage['project_stage_id'];
  698. $data['project_stage_node_id'] = $stage['project_stage_node_id'];
  699. if(! empty($data['time'][0]) && ! empty($data['time'][1])){
  700. $data['start_time'] = $this->changeDateToDateMin($data['time'][0]);
  701. $data['end_time'] = $this->changeDateToDateMin($data['time'][1]);
  702. }
  703. if(empty($data['content'])) return [false, '节点任务报告内容不能为空'];
  704. if(! isset($data['completion_degree'])) return [false, '任务报告完成度不能为空'];
  705. $res = $this->checkNumber($data['completion_degree'], 0);
  706. if(! $res) return [false, '任务报告完成度请输入大于等于0的整数'];
  707. if($is_check){
  708. }else{
  709. if(empty($data['id'])) return [false, '阶段节点任务ID不能为空'];
  710. $boolean = ProjectStageNodeMissionDetail::where('id',$data['id'])->where('del_time',0)->exists();
  711. if(! $boolean) return [false, '项目阶段节点任务报告不存在或已被删除'];
  712. }
  713. return [true, ''];
  714. }
  715. public function projectStageNodeMissionDetailList($data,$user){
  716. $model = ProjectStageNodeMissionDetail::where('del_time',0)
  717. ->select('id','project_stage_id','project_id','project_stage_node_id','project_stage_node_mission_id','content','start_time','crt_time','end_time','completion_degree','crt_id')
  718. ->orderBy('id','desc');
  719. if(! empty($data['project_stage_title'])) {
  720. $project_stage_id = $this->searchProjectStage(['title' => $data['project_stage_title']]);
  721. $model->whereIn('project_stage_id', $project_stage_id);
  722. }
  723. if(! empty($data['project_title'])) {
  724. $project_id = $this->searchProject(['title' => $data['project_title']]);
  725. $model->whereIn('project_id', $project_id);
  726. }
  727. if(! empty($data['project_stage_node_title'])) {
  728. $project_stage_node_id = $this->searchProjectStageNode(['title' => $data['project_stage_node_title']]);
  729. $model->whereIn('project_stage_node_id', $project_stage_node_id);
  730. }
  731. if(! empty($data['project_stage_node_mission_title'])) {
  732. $project_stage_node_mission_id = $this->searchProjectStageNodeMission(['title' => $data['project_stage_node_mission_title']]);
  733. $model->whereIn('project_stage_node_mission_title', $project_stage_node_mission_id);
  734. }
  735. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  736. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  737. $model->where('crt_time','>=',$return[0]);
  738. $model->where('crt_time','<=',$return[1]);
  739. }
  740. $list = $this->limit($model,'',$data);
  741. $list = $this->organizationStageNodeMissionDetailData($list);
  742. return [true, $list];
  743. }
  744. public function organizationStageNodeMissionDetailData($data) {
  745. if (empty($data['data'])) return $data;
  746. $project_map = $this->getProject(array_column($data['data'],'project_id'));
  747. $project_stage_map = $this->getProjectStage(array_column($data['data'],'project_stage_id'));
  748. $project_stage_node_map = $this->getProjectStageNode(array_column($data['data'],'project_stage_node_id'));
  749. $project_stage_node_mission_map = $this->getProjectStageNodeMission(array_column($data['data'],'project_stage_node_mission_id'));
  750. foreach ($data['data'] as $key => $value){
  751. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  752. $data['data'][$key]['start_time'] = $value['start_time'] ? date("Y-m-d H:i",$value['start_time']): '';
  753. $data['data'][$key]['end_time'] = $value['end_time'] ? date("Y-m-d H:i",$value['end_time']): '';
  754. $data['data'][$key]['project_title'] = $project_map[$value['project_id']] ?? "";
  755. $data['data'][$key]['project_stage_title'] = $project_stage_map[$value['project_stage_id']] ?? "";
  756. $data['data'][$key]['project_stage_node_title'] = $project_stage_node_map[$value['project_stage_node_id']] ?? "";
  757. $data['data'][$key]['project_stage_node_mission_title'] = $project_stage_node_mission_map[$value['project_stage_node_mission_id']] ?? "";
  758. }
  759. return $data;
  760. }
  761. public function searchProject($data){
  762. $model = new Project();
  763. $model->where('del_time',0);
  764. if(empty($data['title'])){
  765. $model->where('title', 'LIKE', '%'.$data['title'].'%');
  766. $id = $model->select('id')->get()->toArray();
  767. return array_column($id,'id');
  768. }
  769. return [];
  770. }
  771. public function getProject($project_id = []){
  772. if(empty($project_id)) return [];
  773. $map = Project::whereIn('id', $project_id)
  774. ->pluck('title','id')
  775. ->toArray();
  776. return $map;
  777. }
  778. public function searchProjectStage($data){
  779. $model = new ProjectStage();
  780. $model->where('del_time',0);
  781. if(empty($data['title'])){
  782. $model->where('title', 'LIKE', '%'.$data['title'].'%');
  783. $id = $model->select('id')->get()->toArray();
  784. return array_column($id,'id');
  785. }
  786. return [];
  787. }
  788. public function getProjectStage($project_stage_id = []){
  789. if(empty($project_stage_id)) return [];
  790. $map = ProjectStage::whereIn('id', $project_stage_id)
  791. ->pluck('title','id')
  792. ->toArray();
  793. return $map;
  794. }
  795. public function searchProjectStageNode($data){
  796. $model = new ProjectStageNode();
  797. $model->where('del_time',0);
  798. if(empty($data['title'])){
  799. $model->where('title', 'LIKE', '%'.$data['title'].'%');
  800. $id = $model->select('id')->get()->toArray();
  801. return array_column($id,'id');
  802. }
  803. return [];
  804. }
  805. public function getProjectStageNode($project_stage_node_id = []){
  806. if(empty($project_stage_node_id)) return [];
  807. $map = ProjectStageNode::whereIn('id', $project_stage_node_id)
  808. ->pluck('title','id')
  809. ->toArray();
  810. return $map;
  811. }
  812. public function returnEmployeeTitle($data){
  813. $employee_array = [];
  814. $employee_id = array_column($data,'employee_id');
  815. foreach ($employee_id as $emp){
  816. $tmp = explode(',',$emp);
  817. foreach ($tmp as $val){
  818. if(! in_array($val, $employee_array)) $employee_array[] = $val;
  819. }
  820. }
  821. $emp_map = Employee::whereIn('id',$employee_array)->pluck('emp_name','id')->toArray();
  822. return $emp_map;
  823. }
  824. public function searchProjectStageNodeMission($data){
  825. $model = new ProjectStageNodeMission();
  826. $model->where('del_time',0);
  827. if(empty($data['title'])){
  828. $model->where('title', 'LIKE', '%'.$data['title'].'%');
  829. $id = $model->select('id')->get()->toArray();
  830. return array_column($id,'id');
  831. }
  832. return [];
  833. }
  834. public function getProjectStageNodeMission($project_stage_node_mission_id = []){
  835. if(empty($project_stage_node_mission_id)) return [];
  836. $map = ProjectStageNodeMission::whereIn('id', $project_stage_node_mission_id)
  837. ->pluck('title','id')
  838. ->toArray();
  839. return $map;
  840. }
  841. }