InspectService.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434
  1. <?php
  2. namespace app\common\Service;
  3. use think\Db;
  4. use app\common\enum\OrderEnum;
  5. use app\common\Service\OrderService;
  6. use app\common\exception\BusinessException;
  7. class InspectService
  8. {
  9. /**
  10. * 获取验货选项列表
  11. * @param array $params 查询参数
  12. * @return array
  13. */
  14. public static function getInspectionItems($params = [])
  15. {
  16. $where = [];
  17. // 父级ID筛选
  18. if (isset($params['parent_id'])) {
  19. $where['parent_id'] = $params['parent_id'];
  20. }
  21. // 状态筛选
  22. if (isset($params['status']) && $params['status'] !== '') {
  23. $where['status'] = $params['status'];
  24. }
  25. // 是否必检项筛选
  26. if (isset($params['is_required']) && $params['is_required'] !== '') {
  27. $where['is_required'] = $params['is_required'];
  28. }
  29. // 名称搜索
  30. if (isset($params['name']) && $params['name'] !== '') {
  31. $where['name'] = ['like', '%' . $params['name'] . '%'];
  32. }
  33. $query = (new \app\common\model\inspection\Item())->where($where)
  34. ->field('id,name,parent_id,is_required,status,standard_desc');
  35. // 排序
  36. $order = isset($params['order']) ? $params['order'] : 'id ASC';
  37. $query->order($order);
  38. // 分页处理
  39. if (isset($params['page']) && isset($params['page_size'])) {
  40. $result = $query->paginate([
  41. 'page' => $params['page'],
  42. 'list_rows' => $params['page_size']
  43. ]);
  44. return $result;
  45. }
  46. return $query->select();
  47. }
  48. /**
  49. * 获取树形结构的验货选项
  50. * @param array $params 查询参数
  51. * @return array
  52. */
  53. public function getInspectionItemTree($params = [])
  54. {
  55. // 获取所有选项
  56. $allItems = $this->getInspectionItems($params);
  57. if (is_object($allItems)) {
  58. // 分页对象转数组
  59. $allItems = $allItems->toArray()['data'];
  60. }
  61. return $this->buildTree($allItems);
  62. }
  63. /**
  64. * 构建树形结构
  65. * @param array $items 选项数组
  66. * @param int $parentId 父级ID
  67. * @return array
  68. */
  69. private function buildTree($items, $parentId = 0)
  70. {
  71. $tree = [];
  72. foreach ($items as $item) {
  73. if ($item['parent_id'] == $parentId) {
  74. $children = $this->buildTree($items, $item['id']);
  75. if (!empty($children)) {
  76. $item['children'] = $children;
  77. }
  78. $tree[] = $item;
  79. }
  80. }
  81. return $tree;
  82. }
  83. /**
  84. * 根据ID获取验货选项详情
  85. * @param int $id 选项ID
  86. * @return array|null
  87. */
  88. public function getInspectionItemById($id)
  89. {
  90. return Db::name('inspection_item')
  91. ->where('id', $id)
  92. ->where('deletetime', 'exp', 'IS NULL')
  93. ->find();
  94. }
  95. /**
  96. * 获取必检项列表
  97. * @param array $params 查询参数
  98. * @return array
  99. */
  100. public function getRequiredItems($params = [])
  101. {
  102. $params['is_required'] = 1;
  103. return $this->getInspectionItems($params);
  104. }
  105. /**
  106. * 获取顶级选项(parent_id = 0)
  107. * @param array $params 查询参数
  108. * @return array
  109. */
  110. public function getTopLevelItems($params = [])
  111. {
  112. $params['parent_id'] = 0;
  113. return $this->getInspectionItems($params);
  114. }
  115. /**
  116. * 获取指定父级下的子选项
  117. * @param int $parentId 父级ID
  118. * @param array $params 其他查询参数
  119. * @return array
  120. */
  121. public function getChildItems($parentId, $params = [])
  122. {
  123. $params['parent_id'] = $parentId;
  124. return $this->getInspectionItems($params);
  125. }
  126. /**
  127. * 搜索验货选项
  128. * @param string $keyword 搜索关键词
  129. * @param array $params 其他查询参数
  130. * @return array
  131. */
  132. public function searchItems($keyword, $params = [])
  133. {
  134. $params['name'] = $keyword;
  135. return $this->getInspectionItems($params);
  136. }
  137. /**
  138. * 提交验货任务 接口总方法
  139. * @param array $taskData 任务数据
  140. * @param array $resultData 验货结果数据
  141. * @return array
  142. */
  143. public static function submitInspectionTask($taskData, $resultData)
  144. {
  145. Db::startTrans();
  146. try {
  147. // 0. 验证订单和订单商品是否存在
  148. $orderId = $taskData['order_id'] ?? 0;
  149. $orderGoodsId = $taskData['order_goods_id'] ?? 0;
  150. $orderData = OrderService::validateOrderAndOrderGoods($orderId, $orderGoodsId);
  151. if (!$orderData) {
  152. throw new BusinessException('订单或订单商品不存在');
  153. }
  154. // 0.1 验证是否重复提交验货任务(如果不是更新任务的话)
  155. if (empty($taskData['task_id'])) {
  156. $existingTask = self::checkDuplicateInspectionTask($orderId, $orderGoodsId);
  157. if ($existingTask) {
  158. throw new BusinessException('该订单商品已存在验货任务,不能重复提交');
  159. }
  160. }
  161. // 1. 创建或更新验货任务
  162. $taskId = self::saveInspectionTask($taskData);
  163. if (!$taskId) {
  164. throw new BusinessException('验货任务创建失败');
  165. }
  166. // 2. 保存验货结果
  167. if (!empty($resultData)) {
  168. foreach ($resultData as $result) {
  169. $result['task_id'] = $taskId;
  170. $resultId = self::saveInspectionResult($result);
  171. // 3. 保存验货照片
  172. if (!empty($result['photos'])) {
  173. self::saveInspectionPhotos($resultId, $result['photos']);
  174. }
  175. }
  176. }
  177. // 验货结果 是 通过 还是 不通过
  178. $isPass = 1;
  179. foreach ($resultData as $result) {
  180. if ($result['is_qualified'] == 0) {
  181. $isPass = 0;
  182. break;
  183. }
  184. }
  185. // 4. 更新任务状态为已完成
  186. self::updateTaskStatus($taskId, 2, $isPass); // 2:已完成
  187. // 5. 更新订单商品的验收状态
  188. $inspectStatus = $isPass ? 1 : 2; // 1:验收通过 2:验收不通过
  189. OrderService::updateOrderGoodsInspectStatus($taskData['order_goods_id'], $inspectStatus);
  190. // 6. 检查订单是否所有商品都验收完成,决定是否更新订单状态
  191. OrderService::updateOrderStatusByInspectResult($taskData['order_id'], $taskData['inspector_id'] ?? 0);
  192. Db::commit();
  193. return [1, '验货任务提交成功', ['task_id' => $taskId]];
  194. } catch (\Exception $e) {
  195. Db::rollback();
  196. return [0, '验货任务提交失败:' . $e->getMessage(), []];
  197. }
  198. }
  199. /**
  200. * 保存验货任务
  201. * @param array $taskData 任务数据
  202. * @return int 任务ID
  203. */
  204. private static function saveInspectionTask($taskData)
  205. {
  206. $data = [
  207. 'order_id' => $taskData['order_id'] ?? 0,
  208. 'order_goods_id' => $taskData['order_goods_id'] ?? 0,
  209. 'inspector_id' => $taskData['inspector_id'] ?? 0,
  210. 'remark' => $taskData['remark'] ?? '',
  211. 'images' => $taskData['images'] ?? '',
  212. 'start_time' => $taskData['start_time'] ?? time(),
  213. 'end_time' => $taskData['end_time'] ?? time(),
  214. 'task_status' => $taskData['task_status'] ?? 1,
  215. 'status' => $taskData['status'] ?? 1,
  216. 'updatetime' => time()
  217. ];
  218. // 如果提供了task_id,则更新,否则创建
  219. if (isset($taskData['task_id']) && $taskData['task_id'] > 0) {
  220. $result = Db::table('inspection_task')
  221. ->where('id', $taskData['task_id'])
  222. ->update($data);
  223. return $result ? $taskData['task_id'] : false;
  224. } else {
  225. $data['createtime'] = time();
  226. return Db::table('inspection_task')->insertGetId($data);
  227. }
  228. }
  229. /**
  230. * 保存验货结果
  231. * @param array $resultData 结果数据
  232. * @return int 结果ID
  233. */
  234. private static function saveInspectionResult($resultData)
  235. {
  236. $data = [
  237. 'task_id' => $resultData['task_id'],
  238. 'item_id' => $resultData['item_id'],
  239. 'name' => $resultData['name'] ?? '',
  240. 'is_qualified' => $resultData['is_qualified'] ?? 1,
  241. 'remark' => $resultData['remark'] ?? '',
  242. 'status' => $resultData['status'] ?? 1,
  243. 'createtime' => time(),
  244. 'updatetime' => time()
  245. ];
  246. return Db::table('inspection_result')->insertGetId($data);
  247. }
  248. /**
  249. * 保存验货照片
  250. * @param int $resultId 结果ID
  251. * @param array $photos 照片数组
  252. * @return bool
  253. */
  254. private static function saveInspectionPhotos($resultId, $photos)
  255. {
  256. if (empty($photos) || !is_array($photos)) {
  257. return true;
  258. }
  259. $photoData = [];
  260. foreach ($photos as $photo) {
  261. $photoData[] = [
  262. 'result_id' => $resultId,
  263. 'photo_url' => $photo['photo_url'] ?? $photo,
  264. 'upload_time' => $photo['upload_time'] ?? time(),
  265. 'status' => $photo['status'] ?? 1,
  266. 'createtime' => time(),
  267. 'updatetime' => time()
  268. ];
  269. }
  270. return Db::table('inspection_photo')->insertAll($photoData);
  271. }
  272. /**
  273. * 更新任务状态
  274. * @param int $taskId 任务ID
  275. * @param int $status 状态 1:进行中 2:已完成
  276. * @param int $isPass 是否通过
  277. * @return bool
  278. */
  279. private static function updateTaskStatus($taskId, $status,$isPass)
  280. {
  281. return Db::table('inspection_task')
  282. ->where('id', $taskId)
  283. ->update([
  284. 'task_status' => $status,
  285. 'end_time' => time(),
  286. 'updatetime' => time(),
  287. 'is_qualified' => $isPass
  288. ]);
  289. }
  290. /**
  291. * 获取验货任务详情
  292. * @param int $taskId 任务ID
  293. * @return array|null
  294. */
  295. public static function getInspectionTaskDetail($taskId)
  296. {
  297. // 获取任务基本信息
  298. $task = Db::table('inspection_task')
  299. ->where('id', $taskId)
  300. ->where('deletetime', 'exp', 'IS NULL')
  301. ->find();
  302. if (!$task) {
  303. return null;
  304. }
  305. // 获取验货结果
  306. $results = Db::table('inspection_result')
  307. ->where('task_id', $taskId)
  308. ->where('deletetime', 'exp', 'IS NULL')
  309. ->select();
  310. // 为每个结果获取照片
  311. foreach ($results as &$result) {
  312. $photos = Db::table('inspection_photo')
  313. ->where('result_id', $result['id'])
  314. ->where('deletetime', 'exp', 'IS NULL')
  315. ->select();
  316. $result['photos'] = $photos;
  317. }
  318. $task['results'] = $results;
  319. return $task;
  320. }
  321. /**
  322. * 获取验货任务列表
  323. * @param array $params 查询参数
  324. * @return array
  325. */
  326. public static function getInspectionTaskList($params = [])
  327. {
  328. $where = [];
  329. $where['deletetime'] = ['exp', 'IS NULL'];
  330. // 验货员ID筛选
  331. if (isset($params['inspector_id']) && $params['inspector_id'] > 0) {
  332. $where['inspector_id'] = $params['inspector_id'];
  333. }
  334. // 订单ID筛选
  335. if (isset($params['order_id']) && $params['order_id'] > 0) {
  336. $where['order_id'] = $params['order_id'];
  337. }
  338. // 任务状态筛选
  339. if (isset($params['task_status']) && $params['task_status'] !== '') {
  340. $where['task_status'] = $params['task_status'];
  341. }
  342. // 时间范围筛选
  343. if (isset($params['start_time']) && isset($params['end_time'])) {
  344. $where['createtime'] = ['between', [$params['start_time'], $params['end_time']]];
  345. }
  346. $query = Db::name('inspection_task')->where($where);
  347. // 排序
  348. $order = $params['order'] ?? 'createtime DESC';
  349. $query->order($order);
  350. // 分页处理
  351. if (isset($params['page']) && isset($params['page_size'])) {
  352. return $query->paginate([
  353. 'page' => $params['page'],
  354. 'list_rows' => $params['page_size']
  355. ]);
  356. }
  357. return $query->select();
  358. }
  359. /**
  360. * 检查是否重复提交验货任务
  361. * @param int $orderId 订单ID
  362. * @param int $orderGoodsId 订单商品ID
  363. * @return array|null 返回已存在的任务信息,不存在返回null
  364. */
  365. private static function checkDuplicateInspectionTask($orderId, $orderGoodsId)
  366. {
  367. return Db::table('inspection_task')
  368. ->where('order_id', $orderId)
  369. ->where('order_goods_id', $orderGoodsId)
  370. ->where('deletetime', 'exp', 'IS NULL')
  371. ->find();
  372. }
  373. }