ProjectService.php 57 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314
  1. <?php
  2. namespace App\Service;
  3. use App\Model\Employee;
  4. use App\Model\Project;
  5. use App\Model\ProjectEmployee;
  6. use App\Model\ProjectStage;
  7. use App\Model\ProjectStageNode;
  8. use App\Model\ProjectStageNodeMission;
  9. use App\Model\ProjectStageNodeMissionDetail;
  10. use Illuminate\Support\Facades\DB;
  11. class ProjectService extends Service
  12. {
  13. public function getProjectEmployee($data, $type = 1){
  14. $data_id_column = ProjectEmployee::$type_id[$type] ?? "";
  15. if(empty($data_id_column)) return ['name' => "", 'name_id' => ""];
  16. if(is_array($data['id'])){
  17. $employee = ProjectEmployee::where('del_time',0)
  18. ->whereIn($data_id_column, $data['id'])
  19. ->where('type', $type)
  20. ->select($data_id_column, 'employee_id')
  21. ->get()->toArray();
  22. $employee_id = array_column($employee, 'employee_id');
  23. $man = Employee::whereIn('id', $employee_id)
  24. ->pluck('emp_name','id')
  25. ->toArray();
  26. $array = [];
  27. foreach ($employee as $value){
  28. $tmp = $man[$value['employee_id']] ?? "";
  29. if(isset($array[$value[$data_id_column]])){
  30. $array[$value[$data_id_column]]['name'] .= ',' . $tmp;
  31. $array[$value[$data_id_column]]['name_id'] .= ',' . $value['employee_id'];
  32. }else{
  33. $array[$value[$data_id_column]] = [
  34. 'name' => $tmp,
  35. 'name_id' => $value['employee_id'],
  36. ];
  37. }
  38. }
  39. return $array;
  40. }else{
  41. $employee = ProjectEmployee::where('del_time',0)
  42. ->where($data_id_column, $data['id'])
  43. ->where('type', $type)
  44. ->select('employee_id')
  45. ->get()->toArray();
  46. $employee = array_column($employee, 'employee_id');
  47. $man = Employee::whereIn('id', $employee)
  48. ->pluck('emp_name','id')
  49. ->toArray();
  50. $title = $title_id = "";
  51. foreach ($employee as $value){
  52. $tmp = $man[$value] ?? "";
  53. if($tmp) $title .= $tmp . ',';
  54. $title_id .= $value . ',';
  55. }
  56. $title = rtrim($title, ',');
  57. $title_id = rtrim($title_id, ',');
  58. return ['name' => $title, 'name_id' => $title_id];
  59. }
  60. }
  61. public function projectEmployee($data, $type = 0, $is_add = true){
  62. //关联字段
  63. $data_id_column = ProjectEmployee::$type_id[$type] ?? "";
  64. if(empty($data_id_column)) return;
  65. //关联类型
  66. $type_array = ProjectEmployee::$type_id_type[$type] ?? [];
  67. if(! $is_add) {
  68. ProjectEmployee::where('del_time',0)
  69. ->where($data_id_column, $data['id'])
  70. ->whereIn('type',$type_array)
  71. ->update(['del_time' => time()]);
  72. }
  73. if(! empty($data['employee_id'])){
  74. $array = [];
  75. foreach (ProjectEmployee::$type_id as $v){
  76. $array[$v] = 0;
  77. }
  78. if(isset($array[$data_id_column])) $array[$data_id_column] = $data['id'];
  79. $tmp = [
  80. 'employee_id' => 0,
  81. 'type' => $type,
  82. ];
  83. $tmp = array_merge($tmp, $array);
  84. $insert = [];
  85. $employee = explode(',', $data['employee_id']);
  86. foreach ($employee as $value){
  87. $tmp['employee_id'] = $value;
  88. $insert[] = $tmp;
  89. }
  90. ProjectEmployee::insert($insert);
  91. }
  92. }
  93. public function edit($data){
  94. list($status,$msg) = $this->projectRule($data,false);
  95. if(! $status) return [$status,$msg];
  96. DB::beginTransaction();
  97. try{
  98. $model = Project::where('id',$data['id'])->first();
  99. $model->order_number = $data['order_number'] ?? "";
  100. $model->title = $data['title'] ?? "";
  101. $model->importance = $data['importance'] ?? 0;
  102. $model->company = $data['company'] ?? "";
  103. $model->project_cycle = $data['project_cycle'] ?? 0;
  104. $model->business_director = $data['business_director'] ?? 0;
  105. $model->technical_director = $data['technical_director'] ?? 0;
  106. $model->online_director = $data['online_director'] ?? 0;
  107. $model->after_sale_director = $data['after_sale_director'] ?? 0;
  108. $model->project_amount = $data['project_amount'] ?? 0;
  109. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  110. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  111. $model->finish_time = $data['finish_time'] ?? 0;
  112. $model->budget = $data['budget'] ?? 0;
  113. $model->stage = $data['stage'] ?? 0;
  114. $model->save();
  115. $this->projectEmployee($data, ProjectEmployee::type_one, false);
  116. DB::commit();
  117. }catch (\Exception $exception){
  118. DB::rollBack();
  119. return [false,$exception->getMessage()];
  120. }
  121. return [true, ''];
  122. }
  123. public function add($data,$user){
  124. list($status,$msg) = $this->projectRule($data);
  125. if(! $status) return [$status,$msg];
  126. try{
  127. DB::beginTransaction();
  128. $model = new Project();
  129. $model->order_number = $data['order_number'] ?? "";
  130. $model->title = $data['title'] ?? "";
  131. $model->importance = $data['importance'] ?? 0;
  132. $model->company = $data['company'] ?? "";
  133. $model->project_cycle = $data['project_cycle'] ?? 0;
  134. $model->business_director = $data['business_director'] ?? 0;
  135. $model->technical_director = $data['technical_director'] ?? 0;
  136. $model->online_director = $data['online_director'] ?? 0;
  137. $model->after_sale_director = $data['after_sale_director'] ?? 0;
  138. $model->project_amount = $data['project_amount'] ?? 0;
  139. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  140. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  141. $model->finish_time = $data['finish_time'] ?? 0;
  142. $model->budget = $data['budget'] ?? 0;
  143. $model->stage = $data['stage'] ?? 0;
  144. $model->crt_id = $user['id'];
  145. $model->save();
  146. $data['id'] = $model->id;
  147. $this->projectEmployee($data, ProjectEmployee::type_one);
  148. DB::commit();
  149. }catch (\Exception $exception){
  150. DB::rollBack();
  151. return [false,$exception->getMessage()];
  152. }
  153. return [true, ''];
  154. }
  155. public function del($data){
  156. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  157. DB::beginTransaction();
  158. try {
  159. $this->projectEmployee($data, ProjectEmployee::type_one, false);
  160. Project::where('id',$data['id'])->update([
  161. 'del_time' => time()
  162. ]);
  163. ProjectStage::where('project_id',$data['id'])->where('del_time',0)->update([
  164. 'del_time' => time()
  165. ]);
  166. ProjectStageNode::where('project_id',$data['id'])->where('del_time',0)->update([
  167. 'del_time' => time()
  168. ]);
  169. ProjectStageNodeMission::where('project_id',$data['id'])->where('del_time',0)->update([
  170. 'del_time' => time()
  171. ]);
  172. ProjectStageNodeMissionDetail::where('project_id',$data['id'])->where('del_time',0)->update([
  173. 'del_time' => time()
  174. ]);
  175. DB::commit();
  176. }catch (\Exception $exception){
  177. DB::rollBack();
  178. return [false,$exception->getMessage()];
  179. }
  180. return [true,'删除成功'];
  181. }
  182. public function detail($data){
  183. if(empty($data['id'])) return [false, "ID不能为空"];
  184. $project = Project::where('id',$data['id'])->first();
  185. if(empty($project) || $project->del_time > 0) return [false, '项目不存在或已被删除'];
  186. $project = $project->toArray();
  187. //组织数据
  188. $emp_id = [$project['business_director'], $project['technical_director'], $project['online_director'], $project['after_sale_director'], $project['crt_id']];
  189. $emp_id = array_unique($emp_id);
  190. $emp_map = Employee::whereIn('id',$emp_id)->pluck('emp_name','id')->toArray();
  191. $start_time = $project['plan_start_time'] ? date("Y-m-d H:i",$project['plan_start_time']) : '';
  192. $end_time = $project['plan_end_time'] ? date("Y-m-d H:i",$project['plan_end_time']) : '';
  193. $project['plan_time'] = $start_time . '——' . $end_time;
  194. $project['crt_time'] = $project['crt_time'] ? date("Y-m-d H:i:s",$project['crt_time']): '';
  195. $project['finish_time'] = $project['finish_time'] ? date("Y-m-d",$project['finish_time']): '';
  196. $project['business_director_title'] = $emp_map[$project['business_director']] ?? "";
  197. $project['technical_director_title'] = $emp_map[$project['technical_director']] ?? "";
  198. $project['online_director_title'] = $emp_map[$project['online_director']] ?? "";
  199. $project['after_sale_director_title'] = $emp_map[$project['after_sale_director']] ?? "";
  200. $project['crt_name'] = $emp_map[$project['crt_id']] ?? "";
  201. //项目成员
  202. $return = $this->getProjectEmployee($data, ProjectEmployee::type_one);
  203. $project['employee_title'] = $return['name'] ?? "";
  204. $project['employee_id'] = $return['name_id'] ?? "";
  205. //任务报告
  206. $project_stage_node_mission_detail = ProjectStageNodeMissionDetail::where('del_time',0)
  207. ->where('project_id',$data['id'])
  208. ->get()->toArray();
  209. $employee_id = array_unique(array_column($project_stage_node_mission_detail,'crt_id'));
  210. $emp_map = Employee::whereIn('id',$employee_id)->pluck('emp_name','id')->toArray();
  211. $project_stage_node_mission_detail_map = [];
  212. foreach ($project_stage_node_mission_detail as $key => $value){
  213. $start_time = $value['start_time'] ? date("Y-m-d H:i",$value['start_time']) : '';
  214. $end_time = $value['end_time'] ? date("Y-m-d H:i",$value['end_time']) : '';
  215. $project_stage_node_mission_detail[$key]['time'] = $start_time . '——' . $end_time;
  216. $project_stage_node_mission_detail[$key]['crt_name'] = $emp_map[$value['crt_id']] ?? "";
  217. $project_stage_node_mission_detail_map[$value['project_stage_node_mission_id']][] = $project_stage_node_mission_detail[$key];
  218. }
  219. //任务
  220. $project_stage_node_mission = ProjectStageNodeMission::where('del_time',0)
  221. ->where('project_id',$data['id'])
  222. ->get()->toArray();
  223. $map = [];
  224. $project_stage_node_mission_id = array_column($project_stage_node_mission, 'id');
  225. foreach ($project_stage_node_mission_id as $value){
  226. //任务成员
  227. $return = $this->getProjectEmployee(['id' => $value], ProjectEmployee::type_four);
  228. $map[$value] = $return;
  229. }
  230. $project_stage_node_mission_map = [];
  231. foreach ($project_stage_node_mission as $key => $value){
  232. $tmp = $map[$value['id']] ?? [];
  233. $project_stage_node_mission[$key]['employee_title'] = $tmp['name'] ?? "";
  234. $project_stage_node_mission[$key]['employee_id'] = $tmp['name_id'] ?? "";
  235. $son = $project_stage_node_mission_detail_map[$value['id']] ?? [];
  236. $project_stage_node_mission[$key]['children'] = $son;
  237. $project_stage_node_mission_map[$value['project_stage_node_id']][] = $project_stage_node_mission[$key];
  238. }
  239. //节点
  240. $project_stage_node = ProjectStageNode::where('del_time',0)
  241. ->where('project_id',$data['id'])
  242. ->get()->toArray();
  243. $map = [];
  244. $project_stage_node_id = array_column($project_stage_node, 'id');
  245. foreach ($project_stage_node_id as $value){
  246. //节点成员
  247. $return = $this->getProjectEmployee(['id' => $value], ProjectEmployee::type_three);
  248. $map[$value] = $return;
  249. }
  250. $project_stage_node_map = [];
  251. foreach ($project_stage_node as $key => $value){
  252. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  253. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  254. $project_stage_node[$key]['plan_time'] = $start_time . '——' . $end_time;
  255. $project_stage_node[$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  256. $tmp = $map[$value['id']] ?? [];
  257. $project_stage_node[$key]['employee_title'] = $tmp['name'] ?? "";
  258. $project_stage_node[$key]['employee_id'] = $tmp['name_id'] ?? "";
  259. $son = $project_stage_node_mission_map[$value['id']] ?? [];
  260. $project_stage_node[$key]['children'] = $son;
  261. $project_stage_node_map[$value['project_stage_id']][] = $project_stage_node[$key];
  262. }
  263. //阶段
  264. $project_stage = ProjectStage::where('del_time',0)
  265. ->where('project_id',$data['id'])
  266. ->get()->toArray();
  267. $map = [];
  268. $project_stage_id = array_column($project_stage, 'id');
  269. foreach ($project_stage_id as $value){
  270. //阶段成员
  271. $return = $this->getProjectEmployee(['id' => $value], ProjectEmployee::type_two);
  272. $map[$value] = $return;
  273. }
  274. foreach ($project_stage as $key => $value){
  275. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  276. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  277. $project_stage[$key]['plan_time'] = $start_time . '——' . $end_time;
  278. $project_stage[$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  279. $tmp = $map[$value['id']] ?? [];
  280. $project_stage[$key]['employee_title'] = $tmp['name'] ?? "";
  281. $project_stage[$key]['employee_id'] = $tmp['name_id'] ?? "";
  282. $project_stage[$key]['children'] = $project_stage_node_map[$value['id']] ?? [];
  283. }
  284. // $project['project_stage'] = $project_stage;
  285. // $project['project_stage_node'] = $project_stage_node;
  286. // $project['project_stage_node_mission'] = $project_stage_node_mission;
  287. // $project['project_stage_node_mission_detail'] = $project_stage_node_mission_detail;
  288. $project['children'] = $project_stage;
  289. return [true, $project];
  290. }
  291. public function projectList($data,$user){
  292. $model = Project::where('del_time',0)
  293. ->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','order_number')
  294. ->orderBy('id','desc');
  295. if(! empty($data['title'])) $model->where('title',$data['title']);
  296. if(! empty($data['order_number'])) $model->where('order_number',$data['order_number']);
  297. if(! empty($data['company'])) $model->where('company',$data['company']);
  298. if(isset($data['importance'])) $model->where('importance',$data['importance']);
  299. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  300. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  301. $model->where('crt_time','>=',$return[0]);
  302. $model->where('crt_time','<=',$return[1]);
  303. }
  304. $list = $this->limit($model,'',$data);
  305. $list = $this->organizationData($list);
  306. return [true, $list];
  307. }
  308. public function organizationData($data) {
  309. if (empty($data['data'])) return $data;
  310. $map = $this->getProjectEmployee(['id' => array_column($data['data'], 'id')], ProjectEmployee::type_one);
  311. $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')));
  312. $emp_map = Employee::whereIn('id',$emp_id)->pluck('emp_name','id')->toArray();
  313. foreach ($data['data'] as $key => $value){
  314. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  315. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  316. $data['data'][$key]['plan_time'] = $start_time . '——' . $end_time;
  317. $data['data'][$key]['crt_name'] = $emp_map[$value['crt_id']] ?? "";
  318. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  319. $data['data'][$key]['finish_time'] = $value['finish_time'] ? date("Y-m-d",$value['finish_time']): '';
  320. $data['data'][$key]['business_director_title'] = $emp_map[$value['business_director']] ?? "";
  321. $data['data'][$key]['technical_director_title'] = $emp_map[$value['technical_director']] ?? "";
  322. $data['data'][$key]['online_director_title'] = $emp_map[$value['online_director']] ?? "";
  323. $data['data'][$key]['after_sale_director_title'] = $emp_map[$value['after_sale_director']] ?? "";
  324. $tmp = $map[$value['id']] ?? [];
  325. $data['data'][$key]['employee_title'] = $tmp['name'] ?? "";
  326. $data['data'][$key]['employee_id'] = $tmp['name_id'] ?? "";
  327. }
  328. return $data;
  329. }
  330. public function projectRule(&$data, $is_check = true){
  331. if(empty($data['order_number'])) return [false, '项目编号不能为空'];
  332. if(empty($data['title'])) return [false,'项目名称不能为空'];
  333. if(isset($data['project_cycle'])){
  334. if(! is_numeric($data['project_cycle']) || floatval($data['project_cycle']) < 0.0) return [false, '项目周期请输入合法的数字(天数)'];
  335. }
  336. if(isset($data['project_amount'])){
  337. $res = $this->checkNumber($data['project_amount']);
  338. if(! $res) return [false, '项目金额请输入不超过两位小数并且大于的等于0的数值'];
  339. }
  340. if(isset($data['budget'])){
  341. $res = $this->checkNumber($data['budget']);
  342. if(! $res) return [false, '预算请输入不超过两位小数并且大于的等于0的数值'];
  343. }
  344. if(isset($data['stage'])){
  345. $res = $this->checkNumber($data['budget'], 0);
  346. if(! $res) return [false, '阶段数请输入大于等于0的整数'];
  347. }
  348. if(! empty($data['plan_time'][0]) && ! empty($data['plan_time'][1])){
  349. $data['plan_start_time'] = $this->changeDateToDateMin($data['plan_time'][0]);
  350. $data['plan_end_time'] = $this->changeDateToDateMin($data['plan_time'][1]);
  351. }
  352. if(! empty($data['finish_time'])) $data['finish_time'] = $this->changeDateToDate($data['finish_time']);
  353. if($is_check){
  354. $bool = Project::where('order_number',$data['order_number'])->exists();
  355. }else{
  356. if(empty($data['id'])) return [false, '项目ID不能为空'];
  357. $boolean = Project::where('id',$data['id'])->where('del_time',0)->exists();
  358. if(! $boolean) return [false, '项目不存在或已被删除'];
  359. $bool = Project::where('order_number',$data['order_number'])
  360. ->where('id','<>',$data['id'])
  361. ->exists();
  362. }
  363. if($bool) return [false, '项目编号已存在'];
  364. return [true, ''];
  365. }
  366. public function editStage($data){
  367. list($status,$msg) = $this->stageRule($data,false);
  368. if(! $status) return [$status,$msg];
  369. DB::beginTransaction();
  370. try{
  371. $model = ProjectStage::where('id',$data['id'])->first();
  372. $model->project_id = $data['project_id'] ?? 0;
  373. $model->title = $data['title'] ?? "";
  374. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  375. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  376. $model->start_time = $data['start_time'] ?? 0;
  377. $model->receivable_amount = $data['receivable_amount'] ?? 0;
  378. $model->receipt_amount = $data['receipt_amount'] ?? 0;
  379. $model->save();
  380. $this->projectEmployee($data, ProjectEmployee::type_two, false);
  381. DB::commit();
  382. }catch (\Exception $exception){
  383. DB::rollBack();
  384. return [false,$exception->getMessage()];
  385. }
  386. return [true, ''];
  387. }
  388. public function addStage($data,$user){
  389. list($status,$msg) = $this->stageRule($data);
  390. if(! $status) return [$status,$msg];
  391. try{
  392. DB::beginTransaction();
  393. $model = new ProjectStage();
  394. $model->project_id = $data['project_id'] ?? 0;
  395. $model->title = $data['title'] ?? "";
  396. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  397. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  398. $model->start_time = $data['start_time'] ?? 0;
  399. $model->receivable_amount = $data['receivable_amount'] ?? 0;
  400. $model->receipt_amount = $data['receipt_amount'] ?? 0;
  401. $model->save();
  402. $data['id'] = $model->id;
  403. $this->projectEmployee($data, ProjectEmployee::type_two);
  404. DB::commit();
  405. }catch (\Exception $exception){
  406. DB::rollBack();
  407. return [false,$exception->getMessage()];
  408. }
  409. return [true, ''];
  410. }
  411. public function delStage($data){
  412. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  413. DB::beginTransaction();
  414. try {
  415. $this->projectEmployee($data, ProjectEmployee::type_two, false);
  416. ProjectStage::where('id',$data['id'])->where('del_time',0)->update([
  417. 'del_time' => time()
  418. ]);
  419. ProjectStageNode::where('project_stage_id',$data['id'])->where('del_time',0)->update([
  420. 'del_time' => time()
  421. ]);
  422. ProjectStageNodeMission::where('project_stage_id',$data['id'])->where('del_time',0)->update([
  423. 'del_time' => time()
  424. ]);
  425. ProjectStageNodeMissionDetail::where('project_stage_id',$data['id'])->where('del_time',0)->update([
  426. 'del_time' => time()
  427. ]);
  428. DB::commit();
  429. }catch (\Exception $exception){
  430. DB::rollBack();
  431. return [false,$exception->getMessage()];
  432. }
  433. return [true,'删除成功'];
  434. }
  435. public function stageRule(&$data, $is_check = true){
  436. if(empty($data['project_id'])) return [false,'项目ID不能为空'];
  437. $bool = Project::where('id',$data['project_id'])->where('del_time',0)->exists();
  438. if(! $bool) return [false, '该项目不存在或已被删除'];
  439. if(empty($data['title'])) return [false, '阶段名称不能为空'];
  440. if(isset($data['receivable_amount'])){
  441. $res = $this->checkNumber($data['receivable_amount']);
  442. if(! $res) return [false, '阶段应收金额请输入不超过两位小数并且大于的等于0的数值'];
  443. }
  444. if(isset($data['receipt_amount'])){
  445. $res = $this->checkNumber($data['receipt_amount']);
  446. if(! $res) return [false, '阶段实收金额请输入不超过两位小数并且大于的等于0的数值'];
  447. }
  448. if(! empty($data['plan_time'][0]) && ! empty($data['plan_time'][1])){
  449. $data['plan_start_time'] = $this->changeDateToDateMin($data['plan_time'][0]);
  450. $data['plan_end_time'] = $this->changeDateToDateMin($data['plan_time'][1]);
  451. }
  452. if(! empty($data['start_time'])) $data['start_time'] = $this->changeDateToDate($data['start_time']);
  453. if($is_check){
  454. $bool = ProjectStage::where('project_id',$data['project_id'])
  455. ->where('title',$data['title'])
  456. ->exists();
  457. }else{
  458. if(empty($data['id'])) return [false, '阶段ID不能为空'];
  459. $boolean = ProjectStage::where('id',$data['id'])->where('del_time',0)->exists();
  460. if(! $boolean) return [false, '项目阶段不存在或已被删除'];
  461. $bool = ProjectStage::where('project_id',$data['project_id'])
  462. ->where('id','<>',$data['id'])
  463. ->where('title',$data['title'])
  464. ->exists();
  465. }
  466. if($bool) return [false, '项目阶段名已存在'];
  467. return [true, ''];
  468. }
  469. public function projectStageList($data,$user){
  470. $model = ProjectStage::where('del_time',0)
  471. ->select('id','title','project_id','plan_start_time','plan_end_time','start_time','receivable_amount','receipt_amount','crt_time')
  472. ->orderBy('id','desc');
  473. if(! empty($data['title'])) $model->where('title',$data['title']);
  474. if(! empty($data['project_title'])) {
  475. $project_id = $this->searchProject(['title' => $data['project_title']]);
  476. $model->whereIn('project_id', $project_id);
  477. }
  478. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  479. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  480. $model->where('crt_time','>=',$return[0]);
  481. $model->where('crt_time','<=',$return[1]);
  482. }
  483. $list = $this->limit($model,'',$data);
  484. $list = $this->organizationStageData($list);
  485. return [true, $list];
  486. }
  487. public function organizationStageData($data) {
  488. if (empty($data['data'])) return $data;
  489. $map = $this->getProjectEmployee(['id' => array_column($data['data'], 'id')], ProjectEmployee::type_two);
  490. $project_map = $this->getProject(array_column($data['data'],'project_id'));
  491. foreach ($data['data'] as $key => $value){
  492. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  493. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  494. $data['data'][$key]['plan_time'] = $start_time . '——' . $end_time;
  495. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  496. $data['data'][$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  497. $data['data'][$key]['project_title'] = $project_map[$value['project_id']] ?? "";
  498. $tmp = $map[$value['id']] ?? [];
  499. $data['data'][$key]['employee_title'] = $tmp['name'] ?? "";
  500. $data['data'][$key]['employee_id'] = $tmp['name_id'] ?? "";
  501. }
  502. return $data;
  503. }
  504. public function editStageNode($data){
  505. list($status,$msg) = $this->stageRuleNode($data,false);
  506. if(! $status) return [$status,$msg];
  507. DB::beginTransaction();
  508. try{
  509. $model = ProjectStageNode::where('id',$data['id'])->first();
  510. $model->project_id = $data['project_id'] ?? 0;
  511. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  512. $model->title = $data['title'] ?? "";
  513. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  514. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  515. $model->start_time = $data['start_time'] ?? 0;
  516. $model->save();
  517. $this->projectEmployee($data, ProjectEmployee::type_three, false);
  518. DB::commit();
  519. }catch (\Exception $exception){
  520. DB::rollBack();
  521. return [false,$exception->getMessage()];
  522. }
  523. return [true, ''];
  524. }
  525. public function addStageNode($data,$user){
  526. list($status,$msg) = $this->stageRuleNode($data);
  527. if(! $status) return [$status,$msg];
  528. try{
  529. DB::beginTransaction();
  530. $model = new ProjectStageNode();
  531. $model->project_id = $data['project_id'] ?? 0;
  532. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  533. $model->title = $data['title'] ?? "";
  534. $model->plan_start_time = $data['plan_start_time'] ?? 0;
  535. $model->plan_end_time = $data['plan_end_time'] ?? 0;
  536. $model->start_time = $data['start_time'] ?? 0;
  537. $model->save();
  538. $data['id'] = $model->id;
  539. $this->projectEmployee($data, ProjectEmployee::type_three);
  540. DB::commit();
  541. }catch (\Exception $exception){
  542. DB::rollBack();
  543. return [false,$exception->getMessage()];
  544. }
  545. return [true, ''];
  546. }
  547. public function delStageNode($data){
  548. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  549. DB::beginTransaction();
  550. try {
  551. $this->projectEmployee($data, ProjectEmployee::type_three, false);
  552. ProjectStageNode::where('id',$data['id'])->where('del_time',0)->update([
  553. 'del_time' => time()
  554. ]);
  555. ProjectStageNodeMission::where('project_stage_node_id',$data['id'])->where('del_time',0)->update([
  556. 'del_time' => time()
  557. ]);
  558. ProjectStageNodeMissionDetail::where('project_stage_node_id',$data['id'])->where('del_time',0)->update([
  559. 'del_time' => time()
  560. ]);
  561. DB::commit();
  562. }catch (\Exception $exception){
  563. DB::rollBack();
  564. return [false,$exception->getMessage()];
  565. }
  566. return [true,'删除成功'];
  567. }
  568. public function stageRuleNode(&$data, $is_check = true){
  569. if(empty($data['project_stage_id'])) return [false,'项目阶段ID不能为空'];
  570. $stage = ProjectStage::where('id',$data['project_stage_id'])->where('del_time',0)->first();
  571. if(empty($stage)) return [false, '该项目阶段不存在或已被删除'];
  572. $stage = $stage->toArray();
  573. $data['project_id'] = $stage['project_id'];
  574. if(empty($data['title'])) return [false, '节点名称不能为空'];
  575. if(! empty($data['plan_time'][0]) && ! empty($data['plan_time'][1])){
  576. $data['plan_start_time'] = $this->changeDateToDateMin($data['plan_time'][0]);
  577. $data['plan_end_time'] = $this->changeDateToDateMin($data['plan_time'][1]);
  578. }
  579. if(! empty($data['start_time'])) $data['start_time'] = $this->changeDateToDate($data['start_time']);
  580. if($is_check){
  581. $bool = ProjectStageNode::where('project_id',$data['project_id'])
  582. ->where('project_stage_id',$data['project_stage_id'])
  583. ->where('title',$data['title'])
  584. ->exists();
  585. }else{
  586. if(empty($data['id'])) return [false, '阶段节点ID不能为空'];
  587. $boolean = ProjectStageNode::where('id',$data['id'])->where('del_time',0)->exists();
  588. if(! $boolean) return [false, '项目阶段节点不存在或已被删除'];
  589. $bool = ProjectStageNode::where('project_id',$data['project_id'])
  590. ->where('project_stage_id',$data['project_stage_id'])
  591. ->where('id','<>',$data['id'])
  592. ->where('title',$data['title'])
  593. ->exists();
  594. }
  595. if($bool) return [false, '项目阶段节点名已存在'];
  596. return [true, ''];
  597. }
  598. public function projectStageNodeList($data,$user){
  599. $model = ProjectStageNode::where('del_time',0)
  600. ->select('id','project_stage_id','project_id','plan_start_time','plan_end_time','start_time','crt_time','title')
  601. ->orderBy('id','desc');
  602. if(! empty($data['project_stage_title'])) {
  603. $project_stage_id = $this->searchProjectStage(['title' => $data['project_stage_title']]);
  604. $model->whereIn('project_stage_id', $project_stage_id);
  605. }
  606. if(! empty($data['project_title'])) {
  607. $project_id = $this->searchProject(['title' => $data['project_title']]);
  608. $model->whereIn('project_id', $project_id);
  609. }
  610. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  611. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  612. $model->where('crt_time','>=',$return[0]);
  613. $model->where('crt_time','<=',$return[1]);
  614. }
  615. $list = $this->limit($model,'',$data);
  616. $list = $this->organizationStageNodeData($list);
  617. return [true, $list];
  618. }
  619. public function organizationStageNodeData($data) {
  620. if (empty($data['data'])) return $data;
  621. $map = $this->getProjectEmployee(['id' => array_column($data['data'], 'id')], ProjectEmployee::type_three);
  622. $project_map = $this->getProject(array_column($data['data'],'project_id'));
  623. $project_stage_map = $this->getProjectStage(array_column($data['data'],'project_stage_id'));
  624. foreach ($data['data'] as $key => $value){
  625. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  626. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  627. $data['data'][$key]['plan_time'] = $start_time . '——' . $end_time;
  628. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  629. $data['data'][$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  630. $data['data'][$key]['project_title'] = $project_map[$value['project_id']] ?? "";
  631. $data['data'][$key]['project_stage_title'] = $project_stage_map[$value['project_stage_id']] ?? "";
  632. $tmp = $map[$value['id']] ?? [];
  633. $data['data'][$key]['employee_title'] = $tmp['name'] ?? "";
  634. $data['data'][$key]['employee_id'] = $tmp['name_id'] ?? "";
  635. }
  636. return $data;
  637. }
  638. public function editStageNodeMission($data){
  639. list($status,$msg) = $this->stageRuleNodeMission($data,false);
  640. if(! $status) return [$status,$msg];
  641. DB::beginTransaction();
  642. try{
  643. $model = ProjectStageNodeMission::where('id',$data['id'])->first();
  644. $model->project_id = $data['project_id'] ?? 0;
  645. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  646. $model->project_stage_node_id = $data['project_stage_node_id'] ?? 0;
  647. $model->title = $data['title'] ?? "";
  648. $model->content = $data['content'] ?? 0;
  649. $model->save();
  650. $this->projectEmployee($data, ProjectEmployee::type_four, false);
  651. DB::commit();
  652. }catch (\Exception $exception){
  653. DB::rollBack();
  654. return [false,$exception->getMessage()];
  655. }
  656. return [true, ''];
  657. }
  658. public function addStageNodeMission($data,$user){
  659. list($status,$msg) = $this->stageRuleNodeMission($data);
  660. if(! $status) return [$status,$msg];
  661. try{
  662. DB::beginTransaction();
  663. $model = new ProjectStageNodeMission();
  664. $model->project_id = $data['project_id'] ?? 0;
  665. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  666. $model->project_stage_node_id = $data['project_stage_node_id'] ?? 0;
  667. $model->title = $data['title'] ?? "";
  668. $model->content = $data['content'] ?? 0;
  669. $model->save();
  670. $data['id'] = $model->id;
  671. $this->projectEmployee($data, ProjectEmployee::type_four);
  672. DB::commit();
  673. }catch (\Exception $exception){
  674. DB::rollBack();
  675. return [false,$exception->getMessage()];
  676. }
  677. return [true, ''];
  678. }
  679. public function delStageNodeMission($data){
  680. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  681. DB::beginTransaction();
  682. try {
  683. $this->projectEmployee($data, ProjectEmployee::type_four, false);
  684. ProjectStageNodeMission::where('id',$data['id'])->where('del_time',0)->update([
  685. 'del_time' => time()
  686. ]);
  687. ProjectStageNodeMissionDetail::where('project_stage_node_mission_id',$data['id'])->where('del_time',0)->update([
  688. 'del_time' => time()
  689. ]);
  690. DB::commit();
  691. }catch (\Exception $exception){
  692. DB::rollBack();
  693. return [false,$exception->getMessage()];
  694. }
  695. return [true,'删除成功'];
  696. }
  697. public function stageRuleNodeMission(&$data, $is_check = true){
  698. if(empty($data['project_stage_node_id'])) return [false,'项目阶段节点ID不能为空'];
  699. $stage = ProjectStageNode::where('id',$data['project_stage_node_id'])->where('del_time',0)->first();
  700. if(empty($stage)) return [false, '该项目阶段节点不存在或已被删除'];
  701. $stage = $stage->toArray();
  702. $data['project_id'] = $stage['project_id'];
  703. $data['project_stage_id'] = $stage['project_stage_id'];
  704. if(empty($data['title'])) return [false, '节点任务名称不能为空'];
  705. if(empty($data['content'])) return [false, '节点任务内容不能为空'];
  706. if($is_check){
  707. $bool = ProjectStageNodeMission::where('project_id',$data['project_id'])
  708. ->where('project_stage_id',$data['project_stage_id'])
  709. ->where('project_stage_node_id',$data['project_stage_node_id'])
  710. ->where('title',$data['title'])
  711. ->exists();
  712. }else{
  713. if(empty($data['id'])) return [false, '阶段节点任务ID不能为空'];
  714. $boolean = ProjectStageNodeMission::where('id',$data['id'])->where('del_time',0)->exists();
  715. if(! $boolean) return [false, '项目阶段节点任务不存在或已被删除'];
  716. $bool = ProjectStageNodeMission::where('project_id',$data['project_id'])
  717. ->where('project_stage_id',$data['project_stage_id'])
  718. ->where('project_stage_node_id',$data['project_stage_node_id'])
  719. ->where('id','<>',$data['id'])
  720. ->where('title',$data['title'])
  721. ->exists();
  722. }
  723. if($bool) return [false, '节点任务名称已存在'];
  724. return [true, ''];
  725. }
  726. public function projectStageNodeMissionList($data,$user){
  727. $model = ProjectStageNodeMission::where('del_time',0)
  728. ->select('id','project_stage_id','project_id','project_stage_node_id','title','content','crt_time')
  729. ->orderBy('id','desc');
  730. if(! empty($data['project_stage_title'])) {
  731. $project_stage_id = $this->searchProjectStage(['title' => $data['project_stage_title']]);
  732. $model->whereIn('project_stage_id', $project_stage_id);
  733. }
  734. if(! empty($data['project_title'])) {
  735. $project_id = $this->searchProject(['title' => $data['project_title']]);
  736. $model->whereIn('project_id', $project_id);
  737. }
  738. if(! empty($data['project_stage_node_title'])) {
  739. $project_stage_node_id = $this->searchProjectStageNode(['title' => $data['project_stage_node_title']]);
  740. $model->whereIn('project_stage_node_id', $project_stage_node_id);
  741. }
  742. if(! empty($data['title'])) $model->where('title', 'LIKE', '%'.$data['title'].'%');
  743. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  744. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  745. $model->where('crt_time','>=',$return[0]);
  746. $model->where('crt_time','<=',$return[1]);
  747. }
  748. $list = $this->limit($model,'',$data);
  749. $list = $this->organizationStageNodeMissionData($list);
  750. return [true, $list];
  751. }
  752. public function organizationStageNodeMissionData($data) {
  753. if (empty($data['data'])) return $data;
  754. $map = $this->getProjectEmployee(['id' => array_column($data['data'], 'id')], ProjectEmployee::type_four);
  755. $project_map = $this->getProject(array_column($data['data'],'project_id'));
  756. $project_stage_map = $this->getProjectStage(array_column($data['data'],'project_stage_id'));
  757. $project_stage_node_map = $this->getProjectStageNode(array_column($data['data'],'project_stage_node_id'));
  758. foreach ($data['data'] as $key => $value){
  759. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  760. $data['data'][$key]['project_title'] = $project_map[$value['project_id']] ?? "";
  761. $data['data'][$key]['project_stage_title'] = $project_stage_map[$value['project_stage_id']] ?? "";
  762. $data['data'][$key]['project_stage_node_title'] = $project_stage_node_map[$value['project_stage_node_id']] ?? "";
  763. $tmp = $map[$value['id']] ?? [];
  764. $data['data'][$key]['employee_title'] = $tmp['name'] ?? "";
  765. $data['data'][$key]['employee_id'] = $tmp['name_id'] ?? "";
  766. }
  767. return $data;
  768. }
  769. public function editStageNodeMissionDetail($data){
  770. list($status,$msg) = $this->stageRuleNodeMissionDetail($data,false);
  771. if(! $status) return [$status,$msg];
  772. DB::beginTransaction();
  773. try{
  774. $model = ProjectStageNodeMissionDetail::where('id',$data['id'])->first();
  775. $model->project_id = $data['project_id'] ?? 0;
  776. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  777. $model->project_stage_node_id = $data['project_stage_node_id'] ?? 0;
  778. $model->project_stage_node_mission_id = $data['project_stage_node_mission_id'] ?? 0;
  779. $model->start_time = $data['start_time'] ?? 0;
  780. $model->end_time = $data['end_time'] ?? 0;
  781. $model->content = $data['content'] ?? 0;
  782. $model->completion_degree = $data['completion_degree'] ?? "";
  783. $model->save();
  784. DB::commit();
  785. }catch (\Exception $exception){
  786. DB::rollBack();
  787. return [false,$exception->getMessage()];
  788. }
  789. return [true, ''];
  790. }
  791. public function addStageNodeMissionDetail($data,$user){
  792. list($status,$msg) = $this->stageRuleNodeMissionDetail($data);
  793. if(! $status) return [$status,$msg];
  794. try{
  795. DB::beginTransaction();
  796. $model = new ProjectStageNodeMissionDetail();
  797. $model->project_id = $data['project_id'] ?? 0;
  798. $model->project_stage_id = $data['project_stage_id'] ?? 0;
  799. $model->project_stage_node_id = $data['project_stage_node_id'] ?? 0;
  800. $model->project_stage_node_mission_id = $data['project_stage_node_mission_id'] ?? 0;
  801. $model->start_time = $data['start_time'] ?? 0;
  802. $model->end_time = $data['end_time'] ?? 0;
  803. $model->content = $data['content'] ?? 0;
  804. $model->completion_degree = $data['completion_degree'] ?? "";
  805. $model->crt_id = $user['id'] ?? "";
  806. $model->save();
  807. DB::commit();
  808. }catch (\Exception $exception){
  809. DB::rollBack();
  810. return [false,$exception->getMessage()];
  811. }
  812. return [true, ''];
  813. }
  814. public function delStageNodeMissionDetail($data){
  815. if($this->isEmpty($data,'id')) return [false,'ID必须!'];
  816. DB::beginTransaction();
  817. try {
  818. ProjectStageNodeMissionDetail::where('id',$data['id'])->where('del_time',0)->update([
  819. 'del_time' => time()
  820. ]);
  821. DB::commit();
  822. }catch (\Exception $exception){
  823. DB::rollBack();
  824. return [false,$exception->getMessage()];
  825. }
  826. return [true,'删除成功'];
  827. }
  828. public function stageRuleNodeMissionDetail(&$data, $is_check = true){
  829. if(empty($data['project_stage_node_mission_id'])) return [false,'项目阶段节点任务ID不能为空'];
  830. $stage = ProjectStageNodeMission::where('id',$data['project_stage_node_mission_id'])->where('del_time',0)->first();
  831. if(empty($stage)) return [false, '该项目阶段节点任务不存在或已被删除'];
  832. $stage = $stage->toArray();
  833. $data['project_id'] = $stage['project_id'];
  834. $data['project_stage_id'] = $stage['project_stage_id'];
  835. $data['project_stage_node_id'] = $stage['project_stage_node_id'];
  836. if(! empty($data['time'][0]) && ! empty($data['time'][1])){
  837. $data['start_time'] = $this->changeDateToDateMin($data['time'][0]);
  838. $data['end_time'] = $this->changeDateToDateMin($data['time'][1]);
  839. }
  840. if(empty($data['content'])) return [false, '节点任务报告内容不能为空'];
  841. if(! isset($data['completion_degree'])) return [false, '任务报告完成度不能为空'];
  842. $res = $this->checkNumber($data['completion_degree'], 0);
  843. if(! $res) return [false, '任务报告完成度请输入大于等于0的整数'];
  844. if($is_check){
  845. }else{
  846. if(empty($data['id'])) return [false, '阶段节点任务ID不能为空'];
  847. $boolean = ProjectStageNodeMissionDetail::where('id',$data['id'])->where('del_time',0)->exists();
  848. if(! $boolean) return [false, '项目阶段节点任务报告不存在或已被删除'];
  849. }
  850. return [true, ''];
  851. }
  852. public function projectStageNodeMissionDetailList($data,$user){
  853. $model = ProjectStageNodeMissionDetail::where('del_time',0)
  854. ->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')
  855. ->orderBy('id','desc');
  856. if(! empty($data['project_stage_title'])) {
  857. $project_stage_id = $this->searchProjectStage(['title' => $data['project_stage_title']]);
  858. $model->whereIn('project_stage_id', $project_stage_id);
  859. }
  860. if(! empty($data['project_title'])) {
  861. $project_id = $this->searchProject(['title' => $data['project_title']]);
  862. $model->whereIn('project_id', $project_id);
  863. }
  864. if(! empty($data['project_stage_node_title'])) {
  865. $project_stage_node_id = $this->searchProjectStageNode(['title' => $data['project_stage_node_title']]);
  866. $model->whereIn('project_stage_node_id', $project_stage_node_id);
  867. }
  868. if(! empty($data['project_stage_node_mission_title'])) {
  869. $project_stage_node_mission_id = $this->searchProjectStageNodeMission(['title' => $data['project_stage_node_mission_title']]);
  870. $model->whereIn('project_stage_node_mission_title', $project_stage_node_mission_id);
  871. }
  872. if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) {
  873. $return = $this->changeDateToTimeStampAboutRange($data['crt_time']);
  874. $model->where('crt_time','>=',$return[0]);
  875. $model->where('crt_time','<=',$return[1]);
  876. }
  877. $list = $this->limit($model,'',$data);
  878. $list = $this->organizationStageNodeMissionDetailData($list);
  879. return [true, $list];
  880. }
  881. public function organizationStageNodeMissionDetailData($data) {
  882. if (empty($data['data'])) return $data;
  883. $project_map = $this->getProject(array_column($data['data'],'project_id'));
  884. $project_stage_map = $this->getProjectStage(array_column($data['data'],'project_stage_id'));
  885. $project_stage_node_map = $this->getProjectStageNode(array_column($data['data'],'project_stage_node_id'));
  886. $project_stage_node_mission_map = $this->getProjectStageNodeMission(array_column($data['data'],'project_stage_node_mission_id'));
  887. foreach ($data['data'] as $key => $value){
  888. $data['data'][$key]['crt_time'] = $value['crt_time'] ? date("Y-m-d H:i:s",$value['crt_time']): '';
  889. $data['data'][$key]['start_time'] = $value['start_time'] ? date("Y-m-d H:i",$value['start_time']): '';
  890. $data['data'][$key]['end_time'] = $value['end_time'] ? date("Y-m-d H:i",$value['end_time']): '';
  891. $data['data'][$key]['project_title'] = $project_map[$value['project_id']] ?? "";
  892. $data['data'][$key]['project_stage_title'] = $project_stage_map[$value['project_stage_id']] ?? "";
  893. $data['data'][$key]['project_stage_node_title'] = $project_stage_node_map[$value['project_stage_node_id']] ?? "";
  894. $data['data'][$key]['project_stage_node_mission_title'] = $project_stage_node_mission_map[$value['project_stage_node_mission_id']] ?? "";
  895. }
  896. return $data;
  897. }
  898. public function getSonData($data, $user){
  899. if(empty($data['id'])) return [false, '数据id不能为空'];
  900. if(empty($data['type'])) return [false, '查询类型不能为空'];
  901. $id = $data['id'];
  902. $type = $data['type'];
  903. if($type == 1){
  904. $main = Project::where('del_time',0)
  905. ->where('id',$id)
  906. ->first();
  907. if(empty($main)) return [false, '项目不存在或已删除'];
  908. $main = $main->toArray();
  909. //项目成员
  910. $return = $this->getProjectEmployee($main, ProjectEmployee::type_one);
  911. $main['employee_title'] = $return['name'] ?? "";
  912. $main['employee_id'] = $return['name_id'] ?? "";
  913. //阶段
  914. $project_stage = ProjectStage::where('del_time',0)
  915. ->where('project_id',$id)
  916. ->get()->toArray();
  917. $map = [];
  918. $project_stage_id = array_column($project_stage, 'id');
  919. foreach ($project_stage_id as $value){
  920. //阶段成员
  921. $return = $this->getProjectEmployee(['id' => $value], ProjectEmployee::type_two);
  922. $map[$value] = $return;
  923. }
  924. foreach ($project_stage as $key => $value){
  925. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  926. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  927. $project_stage[$key]['plan_time'] = $start_time . '——' . $end_time;
  928. $project_stage[$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  929. $tmp = $map[$value['id']] ?? [];
  930. $project_stage[$key]['employee_title'] = $tmp['name'] ?? "";
  931. $project_stage[$key]['employee_id'] = $tmp['name_id'] ?? "";
  932. }
  933. $main['children'] = $project_stage;
  934. return [true, $main];
  935. }elseif($type == 2){
  936. $main = ProjectStage::where('del_time',0)
  937. ->where('id',$id)
  938. ->first();
  939. if(empty($main)) return [false, '项目的阶段不存在或已删除'];
  940. $main = $main->toArray();
  941. //阶段成员
  942. $return = $this->getProjectEmployee($main, ProjectEmployee::type_two);
  943. $main['employee_title'] = $return['name'] ?? "";
  944. $main['employee_id'] = $return['name_id'] ?? "";
  945. //节点
  946. $project_stage_node = ProjectStageNode::where('del_time',0)
  947. ->where('project_stage_id',$id)
  948. ->get()->toArray();
  949. $map = [];
  950. $project_stage_node_id = array_column($project_stage_node, 'id');
  951. foreach ($project_stage_node_id as $value){
  952. //节点成员
  953. $return = $this->getProjectEmployee(['id' => $value], ProjectEmployee::type_three);
  954. $map[$value] = $return;
  955. }
  956. foreach ($project_stage_node as $key => $value){
  957. $start_time = $value['plan_start_time'] ? date("Y-m-d H:i",$value['plan_start_time']) : '';
  958. $end_time = $value['plan_end_time'] ? date("Y-m-d H:i",$value['plan_end_time']) : '';
  959. $project_stage_node[$key]['plan_time'] = $start_time . '——' . $end_time;
  960. $project_stage_node[$key]['start_time'] = $value['start_time'] ? date("Y-m-d",$value['start_time']): '';
  961. $tmp = $map[$value['id']] ?? [];
  962. $project_stage_node[$key]['employee_title'] = $tmp['name'] ?? "";
  963. $project_stage_node[$key]['employee_id'] = $tmp['name_id'] ?? "";
  964. }
  965. $main['children'] = $project_stage_node;
  966. return [true, $main];
  967. }elseif($type == 3){
  968. $main = ProjectStageNode::where('del_time',0)
  969. ->where('id',$id)
  970. ->first();
  971. if(empty($main)) return [false, '项目阶段节点不存在或已删除'];
  972. $main = $main->toArray();
  973. //节点成员
  974. $return = $this->getProjectEmployee($main, ProjectEmployee::type_three);
  975. $main['employee_title'] = $return['name'] ?? "";
  976. $main['employee_id'] = $return['name_id'] ?? "";
  977. //任务
  978. $project_stage_node_mission = ProjectStageNodeMission::where('del_time',0)
  979. ->where('project_stage_node_id',$id)
  980. ->get()->toArray();
  981. $map = [];
  982. $project_stage_node_mission_id = array_column($project_stage_node_mission, 'id');
  983. foreach ($project_stage_node_mission_id as $value){
  984. //任务成员
  985. $return = $this->getProjectEmployee(['id' => $value], ProjectEmployee::type_four);
  986. $map[$value] = $return;
  987. }
  988. foreach ($project_stage_node_mission as $key => $value){
  989. $tmp = $map[$value['id']] ?? [];
  990. $project_stage_node_mission[$key]['employee_title'] = $tmp['name'] ?? "";
  991. $project_stage_node_mission[$key]['employee_id'] = $tmp['name_id'] ?? "";
  992. }
  993. $main['children'] = $project_stage_node_mission;
  994. return [true, $main];
  995. }elseif ($type == 4){
  996. $main = ProjectStageNodeMission::where('del_time',0)
  997. ->where('id',$id)
  998. ->first();
  999. if(empty($main)) return [false, '项目阶段节点下该任务不存在或已删除'];
  1000. $main = $main->toArray();
  1001. //任务成员
  1002. $return = $this->getProjectEmployee($main, ProjectEmployee::type_four);
  1003. $main['employee_title'] = $return['name'] ?? "";
  1004. $main['employee_id'] = $return['name_id'] ?? "";
  1005. //任务报告
  1006. $project_stage_node_mission_detail = ProjectStageNodeMissionDetail::where('del_time',0)
  1007. ->where('project_stage_node_mission_id',$data['id'])
  1008. ->get()->toArray();
  1009. $employee_id = array_unique(array_column($project_stage_node_mission_detail,'crt_id'));
  1010. $emp_map = Employee::whereIn('id',$employee_id)->pluck('emp_name','id')->toArray();
  1011. foreach ($project_stage_node_mission_detail as $key => $value){
  1012. $start_time = $value['start_time'] ? date("Y-m-d H:i",$value['start_time']) : '';
  1013. $end_time = $value['end_time'] ? date("Y-m-d H:i",$value['end_time']) : '';
  1014. $project_stage_node_mission_detail[$key]['time'] = $start_time . '——' . $end_time;
  1015. $project_stage_node_mission_detail[$key]['crt_name'] = $emp_map[$value['crt_id']] ?? "";
  1016. }
  1017. $main['children'] = $project_stage_node_mission_detail;
  1018. return [true, $main];
  1019. }
  1020. return [false, '查询类型不存在'];
  1021. }
  1022. public function searchProject($data){
  1023. $model = new Project();
  1024. $model->where('del_time',0);
  1025. if(empty($data['title'])){
  1026. $model->where('title', 'LIKE', '%'.$data['title'].'%');
  1027. $id = $model->select('id')->get()->toArray();
  1028. return array_column($id,'id');
  1029. }
  1030. return [];
  1031. }
  1032. public function getProject($project_id = []){
  1033. if(empty($project_id)) return [];
  1034. $map = Project::whereIn('id', $project_id)
  1035. ->pluck('title','id')
  1036. ->toArray();
  1037. return $map;
  1038. }
  1039. public function searchProjectStage($data){
  1040. $model = new ProjectStage();
  1041. $model->where('del_time',0);
  1042. if(empty($data['title'])){
  1043. $model->where('title', 'LIKE', '%'.$data['title'].'%');
  1044. $id = $model->select('id')->get()->toArray();
  1045. return array_column($id,'id');
  1046. }
  1047. return [];
  1048. }
  1049. public function getProjectStage($project_stage_id = []){
  1050. if(empty($project_stage_id)) return [];
  1051. $map = ProjectStage::whereIn('id', $project_stage_id)
  1052. ->pluck('title','id')
  1053. ->toArray();
  1054. return $map;
  1055. }
  1056. public function searchProjectStageNode($data){
  1057. $model = new ProjectStageNode();
  1058. $model->where('del_time',0);
  1059. if(empty($data['title'])){
  1060. $model->where('title', 'LIKE', '%'.$data['title'].'%');
  1061. $id = $model->select('id')->get()->toArray();
  1062. return array_column($id,'id');
  1063. }
  1064. return [];
  1065. }
  1066. public function getProjectStageNode($project_stage_node_id = []){
  1067. if(empty($project_stage_node_id)) return [];
  1068. $map = ProjectStageNode::whereIn('id', $project_stage_node_id)
  1069. ->pluck('title','id')
  1070. ->toArray();
  1071. return $map;
  1072. }
  1073. public function searchProjectStageNodeMission($data){
  1074. $model = new ProjectStageNodeMission();
  1075. $model->where('del_time',0);
  1076. if(empty($data['title'])){
  1077. $model->where('title', 'LIKE', '%'.$data['title'].'%');
  1078. $id = $model->select('id')->get()->toArray();
  1079. return array_column($id,'id');
  1080. }
  1081. return [];
  1082. }
  1083. public function getProjectStageNodeMission($project_stage_node_mission_id = []){
  1084. if(empty($project_stage_node_mission_id)) return [];
  1085. $map = ProjectStageNodeMission::whereIn('id', $project_stage_node_mission_id)
  1086. ->pluck('title','id')
  1087. ->toArray();
  1088. return $map;
  1089. }
  1090. }