JRFIDServerService.php 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721
  1. <?php
  2. namespace App\Service;
  3. use Illuminate\Support\Facades\Log;
  4. class JRFIDServerService extends Service
  5. {
  6. public function loginRule($data){
  7. if(empty($data['name'])) return [false, '请输入账号!'];
  8. if(empty($data['password'])) return [false, '请输入密码!'];
  9. list($status, $msg) = $this->getToken($data);
  10. if(! $status) return [false, $msg];
  11. return [true, ['data' => $msg]];
  12. }
  13. public function getToken($data){
  14. $account = $data['name'];
  15. $password = $data['password'];
  16. $url = config("j_rfid.login");
  17. $post = [
  18. "name" => $account,
  19. "password" => $password,
  20. "rememberMe" => true
  21. ];
  22. $header = ['Content-Type:application/json'];
  23. list($status, $result) = $this->post_helper($url,$post, $header);
  24. if(! $status) return [$status, $result];
  25. //登录失败
  26. if(! empty($result['errorMessage'])) return [false, $result['errorMessage']];
  27. return [true, $result];
  28. }
  29. public function getSite($data){
  30. $url = config("j_rfid.site");
  31. list($status,$result) = $this->get_helper($url);
  32. if(! $status) return [$status, $result];
  33. if(! empty($result['errorMessage'])) return [false, $result['errorMessage']];
  34. return [true, $result];
  35. }
  36. public function getSite2($data,$param){
  37. $url = config("j_rfid.site2");
  38. $header = ["Authorization: {$param['token']}"];
  39. list($status,$result) = $this->get_helper($url,$header);
  40. if(! $status) return [$status, $result];
  41. if(! empty($result['errorMessage'])) return [false, $result['errorMessage']];
  42. return [true, $result];
  43. }
  44. public function getFlowByProduce($data,$param){
  45. if(empty($data['produce_no'])) return [false, '订单号不能为空'];
  46. if(empty($data['site'])) return [false, '站点不能为空'];
  47. $url = config("j_rfid.get_flow_by_produce");
  48. $post = [
  49. 'produce_no' => $data['produce_no'],
  50. 'site' => $data['site'],
  51. ];
  52. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  53. if(! $status) return [$status, $result];
  54. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  55. return [true, $result['data']];
  56. }
  57. public function getProduceByContract($data,$param){
  58. if(empty($data['contract_no'])) return [false, '合同不能为空'];
  59. if(empty($data['site'])) return [false, '站点不能为空'];
  60. $url = config("j_rfid.get_produce_by_contract");
  61. $post = [
  62. 'contract_no' => $data['contract_no'],
  63. 'site' => $data['site'],
  64. ];
  65. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  66. if(! $status) return [$status, $result];
  67. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  68. return [true, $result['data']];
  69. }
  70. public function getPrintData($data){
  71. if(empty($data['id'])) return [false, '数据ID不能为空'];
  72. if(empty($data['type'])) return [false, '打印数据类型不能为空'];
  73. $size = $data['size'] ?? 9;
  74. $number = $data['number'] ?? 1;
  75. $rsaService = new RsaEncryptionService();
  76. $dataToEncrypt = [
  77. 'id' => $data['id'],
  78. 'type' => $data['type'],
  79. 'size' => $size,
  80. 'number' => $number,
  81. ];
  82. $this->recKSort($dataToEncrypt);
  83. //加密
  84. $encryptedData = $rsaService->encrypt2($dataToEncrypt);
  85. //
  86. // $return2 = $rsaService->decrypt2($return);
  87. //dd($return,$return2);
  88. // $aa = $rsaService->aesDecrypt($aes);
  89. // dd($aes,$aa);
  90. //
  91. // list($status, $encryptedData) = $rsaService->encrypt($dataToEncrypt);
  92. // if(! $status) return [false, $encryptedData];
  93. $url = config("j_rfid.get_print_data");
  94. Log::channel('apiLog')->info('工装云POST:源数据', ["api" => $url , "param" => $dataToEncrypt]);
  95. $post = [
  96. 'body' => $encryptedData,
  97. ];
  98. list($status,$result) = $this->post_helper($url,$post,['Content-Type:application/json']);
  99. if(! $status) return [$status, $result];
  100. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];
  101. if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];
  102. if(! isset($result['furn_pro_flow_dt_a'])) {
  103. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  104. return [false, $error];
  105. }
  106. return [true, $result];
  107. }
  108. // 关联数组排序,递归
  109. public function recKSort(&$arr)
  110. {
  111. $kstring = true;
  112. foreach ($arr as $k => &$v) {
  113. if (!is_string($k)) {
  114. $kstring = false;
  115. }
  116. if (is_array($v)) {
  117. $this->recKSort($v);
  118. }
  119. }
  120. if ($kstring) {
  121. ksort($arr);
  122. }
  123. }
  124. public function getTeam($data,$param){
  125. if(empty($data['site'])) return [false, '站点不能为空'];
  126. $header = array_merge($param['header'], ['site:'. $data['site']]);
  127. $url = config("j_rfid.get_team");
  128. $post['rules'] = [
  129. [
  130. 'field' => 'site',
  131. 'option' => 'LIKE_ANYWHERE',
  132. 'values' => [$data['site']]
  133. ],
  134. [
  135. 'field' => 'is_used',
  136. 'option' => 'IN',
  137. 'values' => ['1']
  138. ]
  139. ];
  140. if(isset($data['department_code'])) {
  141. $post['rules'] = array_merge($post['rules'], [[
  142. 'field' => 'department_code',
  143. 'option' => 'IN',
  144. 'values' => [$data['department_code']]
  145. ]]);
  146. }
  147. $post['size'] = $data['size'] ?? 6;
  148. $post['number'] = ($data['number'] ?? 1) - 1;
  149. list($status,$result) = $this->post_helper($url,$post,$header);
  150. if(! $status) return [$status, $result];
  151. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  152. if(! isset($result['content'])) {
  153. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  154. return [false, $error];
  155. }
  156. return [true, $result];
  157. }
  158. public function getDepart($data,$param){
  159. if(empty($data['site'])) return [false, '站点不能为空'];
  160. $header = array_merge($param['header'], ['site:'. $data['site']]);
  161. $url = config("j_rfid.get_depart");
  162. $post['rules'] = [
  163. [
  164. 'field' => 'is_used',
  165. 'option' => 'IN',
  166. 'values' => ['1']
  167. ]
  168. ];
  169. $post['size'] = $data['size'] ?? 6;
  170. $post['number'] = ($data['number'] ?? 1) - 1;
  171. list($status,$result) = $this->post_helper($url,$post,$header);
  172. if(! $status) return [$status, $result];
  173. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  174. if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];
  175. if(! isset($result['content'])) {
  176. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  177. return [false, $error];
  178. }
  179. return [true, $result];
  180. }
  181. public function getProcedureClass($data,$param){
  182. if(empty($data['site'])) return [false, '站点不能为空'];
  183. $header = array_merge($param['header'], ['site:'. $data['site']]);
  184. $url = config("j_rfid.get_procedure_class");
  185. $post['rules'] = [
  186. [
  187. 'field' => 'is_used',
  188. 'option' => 'IN',
  189. 'values' => ['1']
  190. ]
  191. ];
  192. $post['size'] = $data['size'] ?? 6;
  193. $post['number'] = ($data['number'] ?? 1) - 1;
  194. list($status,$result) = $this->post_helper($url,$post,$header);
  195. if(! $status) return [$status, $result];
  196. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  197. if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];
  198. if(! isset($result['content'])) {
  199. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  200. return [false, $error];
  201. }
  202. return [true, $result];
  203. }
  204. public function furnProduceScheduleList($data,$param){
  205. if(empty($data['site'])) return [false, '站点不能为空'];
  206. $header = array_merge($param['header'], ['site:'. $data['site']]);
  207. $url = config("j_rfid.furn_produce_schedule_list");
  208. $sorts = [];
  209. if(empty($data['sorts'])) {
  210. //默认
  211. $sorts = [
  212. [
  213. "property" => "exe_produce_order_a.order_date",
  214. "direction" => "DESC",
  215. "sortOrderNumber" => 2
  216. ]
  217. ];
  218. }
  219. $post = [
  220. "direction" => $data['direction'] ?? "DESC", //排序
  221. "property" => $data['direction'] ?? "id", // 排序
  222. "sorts" => $sorts
  223. ];
  224. $post['size'] = $data['size'] ?? 10;
  225. $post['number'] = ($data['number'] ?? 1) - 1;
  226. $post['rules'] = $data['rules'] ?? [];
  227. list($status,$result) = $this->post_helper($url,$post,$header);
  228. if(! $status) return [$status, $result];
  229. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  230. if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];
  231. if(! isset($result['content'])) {
  232. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  233. return [false, $error];
  234. }
  235. return [true, $result];
  236. }
  237. public function completionOrders($data,$param){
  238. //{"type":"","id":[],"completed_teams_group":"","completed_teams_group_show":"","completed_date":"","completed_date_lt":""}
  239. // $p = [
  240. // 'screenDataList' =>[
  241. // [
  242. // 'id' => [], //产品
  243. // 'type' => ''
  244. // ],
  245. // [
  246. // 'id' => [],//组件
  247. // 'type' => ''
  248. // ],
  249. // [
  250. // 'id' => [],//部件
  251. // 'type' => ''
  252. // ],
  253. // ],
  254. // 'completed_teams_group' => "",
  255. // 'completed_teams_group_show' => "",
  256. // 'procedure_code' => [],
  257. // 'site' => ""
  258. // ];dd(json_encode($p));
  259. if(empty($data['screenDataList'])) return [false, '完工数据不能为空'];
  260. if(empty($data['site'])) return [false, '站点信息不能为空'];
  261. list($date,$utc_date) = $this->getE8AndUTC();
  262. foreach ($data['screenDataList'] as $key => $value){
  263. if(empty($value['id']) || ! isset($value['type'])) return [false, '完工数据不能为空'];
  264. $data['screenDataList'][$key]['completed_teams_group'] = $data['completed_teams_group'] ?? "";
  265. $data['screenDataList'][$key]['completed_teams_group_show'] = $data['completed_teams_group_show'] ?? "";
  266. $data['screenDataList'][$key]['completed_date'] = $utc_date;
  267. $data['screenDataList'][$key]['completed_date_lt'] = $date;
  268. $data['screenDataList'][$key]['procedure_code'] = $data['procedure_code'] ?? [];
  269. $data['screenDataList'][$key]['site'] = $data['site'] ?? "";
  270. }
  271. $url = config("j_rfid.completion_orders");
  272. $post = [
  273. 'screenDataList' => $data['screenDataList'],
  274. ];
  275. list($status,$result) = $this->post_helper($url,$post, $param['header']);
  276. if(! $status) return [$status, $result];
  277. if(! isset($result['success'])) {
  278. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  279. return [false, $error];
  280. }
  281. return [true, ''];
  282. }
  283. public function qualityOrders($data,$param){
  284. if(empty($data['screenDataList'])) return [false, '质检数据不能为空'];
  285. if(empty($data['site'])) return [false, '站点信息不能为空'];
  286. list($date,$utc_date) = $this->getE8AndUTC();
  287. foreach ($data['screenDataList'] as $key => $value){
  288. if(empty($value['id']) || ! isset($value['type'])) return [false, '质检数据不能为空'];
  289. $data['screenDataList'][$key]['qualified_teams_group'] = $data['qualified_teams_group'] ?? "";
  290. $data['screenDataList'][$key]['qualified_teams_group_show'] = $data['qualified_teams_group_show'] ?? "";
  291. $data['screenDataList'][$key]['qualified_date'] = $utc_date;
  292. $data['screenDataList'][$key]['qualified_date_lt'] = $date;
  293. $data['screenDataList'][$key]['procedure_code'] = $data['procedure_code'] ?? [];
  294. $data['screenDataList'][$key]['site'] = $data['site'] ?? "";
  295. }
  296. $url = config("j_rfid.quality_orders");
  297. $post = [
  298. 'screenDataList' => $data['screenDataList'],
  299. ];
  300. list($status,$result) = $this->post_helper($url,$post, $param['header']);
  301. if(! $status) return [$status, $result];
  302. if(! isset($result['success'])) {
  303. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  304. return [false, $error];
  305. }
  306. return [true, ''];
  307. }
  308. public function screenPrint($data){
  309. if(empty($data['id'])) return [false, '数据ID不能为空'];
  310. if(empty($data['type'])) return [false, 'TYPE不能为空'];
  311. $rsaService = new RsaEncryptionService();
  312. $dataToEncrypt = [
  313. 'id' => $data['id'],
  314. 'type' => $data['type']
  315. ];
  316. $this->recKSort($dataToEncrypt);
  317. //加密
  318. $encryptedData = $rsaService->encrypt2($dataToEncrypt);
  319. // list($status, $encryptedData) = $rsaService->encrypt($dataToEncrypt);
  320. // if(! $status) return [false, $encryptedData];
  321. $url = config("j_rfid.screen_print");
  322. Log::channel('apiLog')->info('工装云POST:源数据', ["api" => $url , "param" => $dataToEncrypt]);
  323. $post = [
  324. 'body' => $encryptedData,
  325. ];
  326. list($status,$result) = $this->post_helper($url,$post,['Content-Type:application/json']);
  327. if(! $status) return [$status, $result];
  328. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];
  329. if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];
  330. return [true, ''];
  331. }
  332. public function getE8AndUTC(){
  333. $eastEightTimeZone = new \DateTimeZone('Asia/Shanghai'); // 东八区时区
  334. $utcTimeZone = new \DateTimeZone('UTC'); // UTC时区
  335. // 假设的东八区时间,没有毫秒部分
  336. $dateTimeString = date("Y-m-d H:i:s");
  337. $milliseconds = '000'; // 假设的毫秒值
  338. // 创建DateTime对象并设置时区为东八区
  339. $dateTime = new \DateTime($dateTimeString, $eastEightTimeZone);
  340. // 将DateTime对象转换为UTC时区
  341. $dateTime->setTimezone($utcTimeZone);
  342. // 格式化DateTime对象为ISO 8601格式,并添加毫秒部分
  343. $formattedDate = $dateTime->format('Y-m-d\TH:i:s') . '.' . str_pad($milliseconds, 3, '0', STR_PAD_LEFT) . 'Z';
  344. return [$dateTimeString,$formattedDate];
  345. }
  346. public function getContractDrawRoom($data,$param){
  347. if(empty($data['site'])) return [false, '站点不能为空'];
  348. if(empty($data['type'])) return [false, 'TYPE不能为空'];
  349. $post['site'] = $data['site'];
  350. $post['type'] = $data['type'];
  351. $url = config("j_rfid.get_contract_draw_room");
  352. if(isset($data['contract_no'])) $post['contract_no'] = $data['contract_no'];
  353. if(isset($data['room_no'])) $post['room_no'] = $data['room_no'];
  354. if(isset($data['drawing_no'])) $post['drawing_no'] = $data['drawing_no'];
  355. if(isset($data['procedure_calss'])) $post['procedure_calss'] = $data['procedure_calss'];
  356. $post['size'] = $data['size'] ?? 10;
  357. $post['number'] = $data['number'] ?? 1;
  358. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  359. if(! $status) return [$status, $result];
  360. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  361. if(! isset($result['success'])) {
  362. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  363. return [false, $error];
  364. }
  365. return [true, $result['data']];
  366. }
  367. public function screenGetProFlow($data,$param){
  368. if(empty($data['site'])) return [false, '站点不能为空'];
  369. if(empty($data['contract_no'])) return [false, '合同不能为空'];
  370. if(empty($data['drawing_no'])) return [false, '图号不能为空'];
  371. if(empty($data['room_no'])) return [false, '房间号不能为空'];
  372. $url = config("j_rfid.screen_get_pro_flow");
  373. $post = [
  374. 'site' => $data['site'],
  375. 'contract_no' => $data['contract_no'],
  376. 'drawing_no' => $data['drawing_no'],
  377. 'room_no' => $data['room_no'],
  378. ];
  379. $post['size'] = $data['size'] ?? 10;
  380. $post['number'] = $data['number'] ?? 1;
  381. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  382. if(! $status) return [$status, $result];
  383. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  384. if(! isset($result['success'])) {
  385. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  386. return [false, $error];
  387. }
  388. return [true, $result['data']];
  389. }
  390. public function screenSend($data,$param){
  391. if(empty($data['screenDataList'])) return [false, '收发货数据不能为空'];
  392. if(empty($data['site']) || empty($data['site_show'])) return [false, '站点信息不能为空'];
  393. list($date,$utc_date) = $this->getE8AndUTC();
  394. foreach ($data['screenDataList'] as $key => $value){
  395. if(empty($value['id']) || ! isset($value['type'])) return [false, '收发货数据不能为空'];
  396. $data['screenDataList'][$key]['delivery_teams_group'] = $data['delivery_teams_group'];
  397. $data['screenDataList'][$key]['delivery_teams_group_show'] = $data['delivery_teams_group_show'];
  398. $data['screenDataList'][$key]['delivery_date'] = $utc_date;
  399. $data['screenDataList'][$key]['delivery_date_lt'] = $date;
  400. $data['screenDataList'][$key]['site'] = $data['site'];
  401. $data['screenDataList'][$key]['site_show'] = $data['site_show'];
  402. }
  403. $url = config("j_rfid.screen_send");
  404. $post = [
  405. 'screenDataList' => $data['screenDataList'],
  406. ];
  407. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  408. if(! $status) return [$status, $result];
  409. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  410. if(! isset($result['success'])) {
  411. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  412. return [false, $error];
  413. }
  414. return [true, ''];
  415. }
  416. public function screenPackage($data,$param){
  417. if(empty($data['screenDataList'])) return [false, '包装数据不能为空'];
  418. if(empty($data['site']) || empty($data['site_show'])) return [false, '站点信息不能为空'];
  419. list($date,$utc_date) = $this->getE8AndUTC();
  420. foreach ($data['screenDataList'] as $key => $value){
  421. if(empty($value['id']) || ! isset($value['type'])) return [false, '包装数据不能为空'];
  422. $data['screenDataList'][$key]['package_teams_group'] = $data['package_teams_group'];
  423. $data['screenDataList'][$key]['package_teams_group_show'] = $data['package_teams_group_show'];
  424. $data['screenDataList'][$key]['package_date'] = $utc_date;
  425. $data['screenDataList'][$key]['package_date_lt'] = $date;
  426. $data['screenDataList'][$key]['site'] = $data['site'];
  427. $data['screenDataList'][$key]['site_show'] = $data['site_show'];
  428. }
  429. $url = config("j_rfid.screen_package");
  430. $post = [
  431. 'screenDataList' => $data['screenDataList'],
  432. ];
  433. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  434. if(! $status) return [$status, $result];
  435. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  436. if(! isset($result['success'])) {
  437. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  438. return [false, $error];
  439. }
  440. return [true, ['box_no' => $result['data'] ?? [], 'package_date' => $date]];
  441. }
  442. public function screenGetPackageData($data,$param){
  443. if(empty($data['site'])) return [false, '站点信息不能为空'];
  444. if(empty($data['contract_no'])) return [false, '合同不能为空'];
  445. // if(empty($data['drawing_no'])) return [false, '图号不能为空'];
  446. // if(empty($data['room_no'])) return [false, '房间号不能为空'];
  447. $size = $data['size'] ?? 10;
  448. $number = $data['number'] ?? 1;
  449. $url = config("j_rfid.screen_get_package_data");
  450. $post = [
  451. 'site' => $data['site'],
  452. 'contract_no' => $data['contract_no'],
  453. 'drawing_no' => $data['drawing_no'] ?? "",
  454. 'room_no' => $data['room_no'] ?? "",
  455. 'size' => $size,
  456. 'number' => $number,
  457. ];
  458. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  459. if(! $status) return [$status, $result];
  460. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];
  461. if(! isset($result['success'])) {
  462. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  463. return [false, $error];
  464. }
  465. return [true, $result['data']];
  466. }
  467. public function screenGetProDtData($data,$param){
  468. if(empty($data['id'])) return [false, '数据ID不能为空'];
  469. if(empty($data['type'])) return [false, 'TYPE不能为空'];
  470. // if(empty($data['contract_no'])) return [false, '合同不能为空'];
  471. // if(empty($data['drawing_no'])) return [false, '图号不能为空'];
  472. $url = config("j_rfid.screenGetProDtData");
  473. $post = [
  474. 'id' => $data['id'],
  475. 'type' => $data['type'],
  476. 'contract_no' => $data['contract_no'] ?? null,
  477. 'drawing_no' => $data['drawing_no'] ?? null,
  478. ];
  479. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  480. if(! $status) return [$status, $result];
  481. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];
  482. if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];
  483. if(! isset($result['furn_pro_flow_dt_a'])) {
  484. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  485. return [false, $error];
  486. }
  487. return [true, $result];
  488. }
  489. public function screenGetPackageAssem($data,$param){
  490. if(empty($data['id'])) return [false, '数据ID不能为空'];
  491. if(empty($data['type'])) return [false, 'TYPE不能为空'];
  492. if(empty($data['site'])) return [false, '站点不能为空'];
  493. $url = config("j_rfid.screenGetPackageAssem");
  494. $post = [
  495. 'id' => $data['id'],
  496. 'type' => $data['type'],
  497. 'site' => $data['site'],
  498. 'contract_no' => $data['contract_no'] ?? ""
  499. ];
  500. list($status,$result) = $this->post_helper($url,$post,$param['header']);
  501. if(! $status) return [$status, $result];
  502. if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];
  503. if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];
  504. if(! isset($result['assembly_list'])) {
  505. $error = $result[0]['message'] ?? "操作失败,请刷新页面";
  506. return [false, $error];
  507. }
  508. foreach ($result['assembly_list'] as $key => $value){
  509. foreach ($value['package_assembly_list'] as $kk => $vv){
  510. $result['assembly_list'][$key]['package_assembly_list'][$kk]['package_date'] = $this->changeDateToDateMin($vv['package_date']);
  511. }
  512. }
  513. return [true, $result['assembly_list']];
  514. }
  515. public function post_helper($url, $data, $header = [], $timeout = 20){
  516. Log::channel('apiLog')->info('工装云POST', ["api" => $url , "param" => $data ,"header" => $header]);
  517. $ch = curl_init();
  518. curl_setopt($ch, CURLOPT_URL, $url);
  519. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  520. curl_setopt($ch, CURLOPT_ENCODING, '');
  521. curl_setopt($ch, CURLOPT_POST, 1);
  522. curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
  523. curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
  524. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
  525. curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
  526. if(!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
  527. $r = curl_exec($ch);
  528. if ($r === false) {
  529. // 获取错误号
  530. $errorNumber = curl_errno($ch);
  531. // 获取错误信息
  532. $errorMessage = curl_error($ch);
  533. $message = "cURL Error #{$errorNumber}: {$errorMessage}";
  534. Log::channel('apiLog')->info('工装云POST结果', ["message" => $message]);
  535. return [false, $message];
  536. }
  537. curl_close($ch);
  538. $return = json_decode($r, true);
  539. Log::channel('apiLog')->info('工装云POST结果', ["message" => $return]);
  540. if(! empty($return['message']) && $return['message'] == 'error.unAuthorized') return [0, '登录凭证已失效或者不正确'];
  541. return [true, $return];
  542. }
  543. public function get_helper($url,$header=[],$timeout = 20){
  544. $ch = curl_init();
  545. curl_setopt_array($ch, array(
  546. CURLOPT_URL => $url,
  547. CURLOPT_RETURNTRANSFER => true,
  548. CURLOPT_ENCODING => '',
  549. CURLOPT_MAXREDIRS => 10,
  550. CURLOPT_TIMEOUT => $timeout,
  551. CURLOPT_FOLLOWLOCATION => true,
  552. CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  553. CURLOPT_CUSTOMREQUEST => 'GET',
  554. CURLOPT_SSL_VERIFYPEER => false,
  555. CURLOPT_HTTPHEADER => $header,
  556. ));
  557. $r = curl_exec($ch);
  558. if ($r === false) {
  559. // 获取错误号
  560. $errorNumber = curl_errno($ch);
  561. // 获取错误信息
  562. $errorMessage = curl_error($ch);
  563. $message = "cURL Error #{$errorNumber}: {$errorMessage}";
  564. Log::channel('apiLog')->info('工装云GET', ["message" => $message]);
  565. return [false, $message];
  566. }
  567. curl_close($ch);
  568. $return = json_decode($r, true);
  569. Log::channel('apiLog')->info('工装云GET', ["message" => $return]);
  570. if(! empty($return['message']) && $return['message'] == 'error.unAuthorized') return [0, '登录凭证已失效或者不正常'];
  571. return [true, $return];
  572. }
  573. }