| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238 | <?phpnamespace App\Service;use Illuminate\Support\Facades\Log;class JRFIDServerService extends Service{    public function loginRule($data){        if(empty($data['name'])) return [false, '请输入账号!'];        if(empty($data['password'])) return [false, '请输入密码!'];        list($status, $msg) = $this->getToken($data);        if(! $status) return [false, $msg];        return [true, ['data' => $msg]];    }    public function getToken($data){        $account = $data['name'];        $password = $data['password'];        $url = config("j_rfid.login");        $post = [            "name" => $account,            "password" => $password,            "rememberMe" => true        ];        $header = ['Content-Type:application/json'];        list($status, $result) = $this->post_helper($url,$post, $header);        if(! $status) return [$status, $result];        //登录失败        if(! empty($result['errorMessage'])) return [false, $result['errorMessage']];        return [true, $result];    }    public function getSite($data){        $url = config("j_rfid.site");        list($status,$result) = $this->get_helper($url);        if(! $status) return [$status, $result];        if(! empty($result['errorMessage'])) return [false, $result['errorMessage']];        return [true, $result];    }    public function getSite2($data,$param){        $url = config("j_rfid.site2");        $header = ["Authorization: {$param['token']}"];        list($status,$result) = $this->get_helper($url,$header);        if(! $status) return [$status, $result];        if(! empty($result['errorMessage'])) return [false, $result['errorMessage']];        return [true, $result];    }    public function getFlowByProduce($data,$param){        if(empty($data['produce_no'])) return [false, '订单号不能为空'];        if(empty($data['site'])) return [false, '站点不能为空'];        $url = config("j_rfid.get_flow_by_produce");        $post = [            'produce_no' => $data['produce_no'],            'site' => $data['site'],        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        return [true, $result['data']];    }    public function getProduceByContract($data,$param){        if(empty($data['contract_no'])) return [false, '合同不能为空'];        if(empty($data['site'])) return [false, '站点不能为空'];        $url = config("j_rfid.get_produce_by_contract");        $post = [            'contract_no' => $data['contract_no'],            'site' => $data['site'],        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        return [true, $result['data']];    }    public function getPrintData($data){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, '打印数据类型不能为空'];        $size = $data['size'] ?? 9;        $number = $data['number'] ?? 1;        $rsaService = new RsaEncryptionService();        $dataToEncrypt = [            'id' => $data['id'],            'type' => $data['type'],            'size' => $size,            'number' => $number,        ];        $this->recKSort($dataToEncrypt);        //加密        $encryptedData = $rsaService->encrypt2($dataToEncrypt);////        $return2 = $rsaService->decrypt2($return);//dd($return,$return2);//        $aa = $rsaService->aesDecrypt($aes);//        dd($aes,$aa);////        list($status, $encryptedData) = $rsaService->encrypt($dataToEncrypt);//        if(! $status) return [false, $encryptedData];        $url = config("j_rfid.get_print_data");        Log::channel('apiLog')->info('工装云POST:源数据', ["api" => $url , "param" => $dataToEncrypt]);        $post = [            'body' => $encryptedData,        ];        list($status,$result) = $this->post_helper($url,$post,['Content-Type:application/json']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['furn_pro_flow_dt_a'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function getPrintData2($data){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, '打印数据类型不能为空'];        $size = $data['size'] ?? 9;        $number = $data['number'] ?? 1;        $rsaService = new RsaEncryptionService();        $dataToEncrypt = [            'id' => $data['id'],            'type' => $data['type'],            'size' => $size,            'number' => $number,        ];        $this->recKSort($dataToEncrypt);        //加密        $encryptedData = $rsaService->encrypt2($dataToEncrypt);        $url = config("j_rfid.get_sep_order_dt_data");        Log::channel('apiLog')->info('工装云POST:源数据', ["api" => $url , "param" => $dataToEncrypt]);        $post = [            'body' => $encryptedData,        ];        list($status,$result) = $this->post_helper($url,$post,['Content-Type:application/json']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['furn_sep_order_dt_prod'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    // 关联数组排序,递归    public function recKSort(&$arr)    {        $kstring = true;        foreach ($arr as $k => &$v) {            if (!is_string($k)) {                $kstring = false;            }            if (is_array($v)) {                $this->recKSort($v);            }        }        if ($kstring) {            ksort($arr);        }    }    public function getTeam($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.get_team");        $post['rules'] = [            [                'field' => 'site',                'option' => 'LIKE_ANYWHERE',                'values' => [$data['site']]            ],            [                'field' => 'is_used',                'option' => 'IN',                'values' => ['1']            ]        ];        if(isset($data['department_code'])) {            $post['rules'] = array_merge($post['rules'], [[                'field' => 'department_code',                'option' => 'IN',                'values' => [$data['department_code']]            ]]);        }        $post['size'] = $data['size'] ?? 6;        $post['number'] = ($data['number'] ?? 1) - 1;        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function getDepart($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.get_depart");        $post['rules'] = [            [                'field' => 'is_used',                'option' => 'IN',                'values' => ['1']            ]        ];        $post['size'] = $data['size'] ?? 6;        $post['number'] = ($data['number'] ?? 1) - 1;        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function getProcedureClass($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.get_procedure_class");        $post['rules'] = [            [                'field' => 'is_used',                'option' => 'IN',                'values' => ['1']            ]        ];        $post['size'] = $data['size'] ?? 6;        $post['number'] = ($data['number'] ?? 1) - 1;        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function furnProduceScheduleList($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.furn_produce_schedule_list");        $sorts = [];        if(empty($data['sorts'])) {            //默认            $sorts = [                [                    "property" => "exe_produce_order_a.order_date",                    "direction" => "DESC",                    "sortOrderNumber" => 2                ]            ];        }        $post = [            "direction" => $data['direction'] ?? "DESC", //排序            "property" =>  $data['direction'] ?? "id", // 排序            "sorts" => $sorts        ];        $post['size'] = $data['size'] ?? 10;        $post['number'] = ($data['number'] ?? 1) - 1;        $post['rules'] = $data['rules'] ?? [];        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function completionOrders($data,$param){        if(empty($data['screenDataList'])) return [false, '完工数据不能为空'];        if(empty($data['site'])) return [false, '站点信息不能为空'];        list($date,$utc_date) = $this->getE8AndUTC();        foreach ($data['screenDataList'] as $key => $value){            if(empty($value['id']) || ! isset($value['type'])) return [false, '完工数据不能为空'];            $data['screenDataList'][$key]['completed_teams_group'] = $data['completed_teams_group'] ?? "";            $data['screenDataList'][$key]['completed_teams_group_show'] = $data['completed_teams_group_show'] ?? "";            $data['screenDataList'][$key]['completed_date'] = $utc_date;            $data['screenDataList'][$key]['completed_date_lt'] = $date;            $data['screenDataList'][$key]['procedure_code'] = $data['procedure_code'] ?? [];            $data['screenDataList'][$key]['site'] = $data['site'] ?? "";        }        $url = config("j_rfid.completion_orders");        $post = [            'screenDataList' => $data['screenDataList'],        ];        list($status,$result) = $this->post_helper($url,$post, $param['header']);        if(! $status) return [$status, $result];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, ''];    }    public function scanScreenCompleted($data,$param){        if(empty($data['screenDataList'])) return [false, '完工数据不能为空'];        if(empty($data['site'])) return [false, '站点信息不能为空'];        list($date,$utc_date) = $this->getE8AndUTC();        foreach ($data['screenDataList'] as $key => $value){            if(empty($value['id']) || ! isset($value['type'])) return [false, '完工数据不能为空'];            $data['screenDataList'][$key]['completed_teams_group'] = $data['completed_teams_group'] ?? "";            $data['screenDataList'][$key]['completed_teams_group_show'] = $data['completed_teams_group_show'] ?? "";            $data['screenDataList'][$key]['completed_date'] = $utc_date;            $data['screenDataList'][$key]['completed_date_lt'] = $date;            $data['screenDataList'][$key]['site'] = $data['site'] ?? "";        }        $url = config("j_rfid.scanScreenCompleted");        $post = [            'screenDataList' => $data['screenDataList'],        ];        list($status,$result) = $this->post_helper($url,$post, $param['header']);        if(! $status) return [$status, $result];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, ''];    }    public function qualityOrders($data,$param){        if(empty($data['screenDataList'])) return [false, '质检数据不能为空'];        if(empty($data['site'])) return [false, '站点信息不能为空'];        list($date,$utc_date) = $this->getE8AndUTC();        foreach ($data['screenDataList'] as $key => $value){            if(empty($value['id']) || ! isset($value['type'])) return [false, '质检数据不能为空'];            $data['screenDataList'][$key]['qualified_teams_group'] = $data['qualified_teams_group'] ?? "";            $data['screenDataList'][$key]['qualified_teams_group_show'] = $data['qualified_teams_group_show'] ?? "";            $data['screenDataList'][$key]['qualified_date'] = $utc_date;            $data['screenDataList'][$key]['qualified_date_lt'] = $date;            $data['screenDataList'][$key]['procedure_code'] = $data['procedure_code'] ?? [];            $data['screenDataList'][$key]['site'] = $data['site'] ?? "";        }        $url = config("j_rfid.quality_orders");        $post = [            'screenDataList' => $data['screenDataList'],        ];        list($status,$result) = $this->post_helper($url,$post, $param['header']);        if(! $status) return [$status, $result];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, ''];    }    public function screenPrint($data){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];        $rsaService = new RsaEncryptionService();        $dataToEncrypt = [            'id' => $data['id'],            'type' => $data['type']        ];        $this->recKSort($dataToEncrypt);        //加密        $encryptedData = $rsaService->encrypt2($dataToEncrypt);//        list($status, $encryptedData) = $rsaService->encrypt($dataToEncrypt);//        if(! $status) return [false, $encryptedData];        $url = config("j_rfid.screen_print");        Log::channel('apiLog')->info('工装云POST:源数据', ["api" => $url , "param" => $dataToEncrypt]);        $post = [            'body' => $encryptedData,        ];        list($status,$result) = $this->post_helper($url,$post,['Content-Type:application/json']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        return [true, ''];    }    public function screenPrintSepData($data){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];        $rsaService = new RsaEncryptionService();        $dataToEncrypt = [            'id' => $data['id'],            'type' => $data['type']        ];        $this->recKSort($dataToEncrypt);        //加密        $encryptedData = $rsaService->encrypt2($dataToEncrypt);        $url = config("j_rfid.screen_print_sep_data");        Log::channel('apiLog')->info('工装云POST:源数据', ["api" => $url , "param" => $dataToEncrypt]);        $post = [            'body' => $encryptedData,        ];        list($status,$result) = $this->post_helper($url,$post,['Content-Type:application/json']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        return [true, ''];    }    public function getE8AndUTC(){        $eastEightTimeZone = new \DateTimeZone('Asia/Shanghai'); // 东八区时区        $utcTimeZone = new \DateTimeZone('UTC'); // UTC时区        // 假设的东八区时间,没有毫秒部分        $dateTimeString = date("Y-m-d H:i:s");        $milliseconds = '000'; // 假设的毫秒值        // 创建DateTime对象并设置时区为东八区        $dateTime = new \DateTime($dateTimeString, $eastEightTimeZone);        // 将DateTime对象转换为UTC时区        $dateTime->setTimezone($utcTimeZone);        // 格式化DateTime对象为ISO 8601格式,并添加毫秒部分        $formattedDate = $dateTime->format('Y-m-d\TH:i:s') . '.' . str_pad($milliseconds, 3, '0', STR_PAD_LEFT) . 'Z';        return [$dateTimeString,$formattedDate];    }    public function getContractDrawRoom($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];        $post['site'] = $data['site'];        $post['type'] = $data['type'];        $url = config("j_rfid.get_contract_draw_room");        if(isset($data['contract_no'])) $post['contract_no'] = $data['contract_no'];        if(isset($data['room_no'])) $post['room_no'] = $data['room_no'];        if(isset($data['drawing_no'])) $post['drawing_no'] = $data['drawing_no'];        if(isset($data['procedure_calss'])) $post['procedure_calss'] = $data['procedure_calss'];        $post['size'] = $data['size'] ?? 10;        $post['number'] = $data['number'] ?? 1;        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result['data']];    }    public function screenGetProFlow($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        if(empty($data['contract_no'])) return [false, '合同不能为空'];        if(empty($data['drawing_no'])) return [false, '图号不能为空'];        if(empty($data['room_no'])) return [false, '房间号不能为空'];        $url = config("j_rfid.screen_get_pro_flow");        $post = [            'site' => $data['site'],            'contract_no' => $data['contract_no'],            'drawing_no' => $data['drawing_no'],            'room_no' => $data['room_no'],        ];        $post['size'] = $data['size'] ?? 10;        $post['number'] = $data['number'] ?? 1;        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result['data']];    }    public function getDispatchContractDrawRoom($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];        $post['site'] = $data['site'];        $post['type'] = $data['type'];        $url = config("j_rfid.get_dispatch_contract_draw_room");        if(isset($data['contract_no'])) $post['contract_no'] = $data['contract_no'];        if(isset($data['room_no'])) $post['room_no'] = $data['room_no'];        if(isset($data['drawing_no'])) $post['drawing_no'] = $data['drawing_no'];        if(isset($data['procedure_calss'])) $post['procedure_calss'] = $data['procedure_calss'];        $post['size'] = $data['size'] ?? 10;        $post['number'] = $data['number'] ?? 1;        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result['data']];    }    public function screenSend($data,$param){        if(empty($data['screenDataList'])) return [false, '收发货数据不能为空'];        if(empty($data['site']) || empty($data['site_show'])) return [false, '站点信息不能为空'];        list($date,$utc_date) = $this->getE8AndUTC();        foreach ($data['screenDataList'] as $key => $value){            if(empty($value['id']) || ! isset($value['type'])) return [false, '收发货数据不能为空'];            $data['screenDataList'][$key]['delivery_teams_group'] = $data['delivery_teams_group'];            $data['screenDataList'][$key]['delivery_teams_group_show'] = $data['delivery_teams_group_show'];            $data['screenDataList'][$key]['delivery_date'] = $utc_date;            $data['screenDataList'][$key]['delivery_date_lt'] = $date;            $data['screenDataList'][$key]['site'] = $data['site'];            $data['screenDataList'][$key]['site_show'] = $data['site_show'];        }        $url = config("j_rfid.screen_send");        $post = [            'screenDataList' => $data['screenDataList'],        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, ''];    }    public function screenReceipt($data,$param){        if(empty($data['screenDataList'])) return [false, '发货数据不能为空'];        if(empty($data['site']) || empty($data['site_show'])) return [false, '站点信息不能为空'];        list($date,$utc_date) = $this->getE8AndUTC();        foreach ($data['screenDataList'] as $key => $value){            if(empty($value['id']) || ! isset($value['type'])) return [false, '发货数据不能为空'];//            $data['screenDataList'][$key]['delivery_teams_group'] = $data['delivery_teams_group'];//            $data['screenDataList'][$key]['delivery_teams_group_show'] = $data['delivery_teams_group_show'];            $data['screenDataList'][$key]['receipt_date'] = $utc_date;            $data['screenDataList'][$key]['receipt_date_lt'] = $date;            $data['screenDataList'][$key]['site'] = $data['site'];            $data['screenDataList'][$key]['site_show'] = $data['site_show'];        }        $url = config("j_rfid.screenReceipt");        $post = [            'screenDataList' => $data['screenDataList'],        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, ''];    }    public function screenPackage($data,$param){        if(empty($data['screenDataList'])) return [false, '包装数据不能为空'];        if(empty($data['site']) || empty($data['site_show'])) return [false, '站点信息不能为空'];        list($date,$utc_date) = $this->getE8AndUTC();        foreach ($data['screenDataList'] as $key => $value){            if(empty($value['id']) || ! isset($value['type'])) return [false, '包装数据不能为空'];            $data['screenDataList'][$key]['package_teams_group'] = $data['package_teams_group'];            $data['screenDataList'][$key]['package_teams_group_show'] = $data['package_teams_group_show'];            $data['screenDataList'][$key]['package_date'] = $utc_date;            $data['screenDataList'][$key]['package_date_lt'] = $date;            $data['screenDataList'][$key]['site'] = $data['site'];            $data['screenDataList'][$key]['site_show'] = $data['site_show'];        }        $url = config("j_rfid.screen_package");        $post = [            'screenDataList' => $data['screenDataList'],        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, ['box_no' => $result['data'] ?? [], 'package_date' => $date]];    }    public function screenGetPackageData($data,$param){        if(empty($data['site'])) return [false, '站点信息不能为空'];        if(empty($data['contract_no'])) return [false, '合同不能为空'];//        if(empty($data['drawing_no'])) return [false, '图号不能为空'];//        if(empty($data['room_no'])) return [false, '房间号不能为空'];        $size = $data['size'] ?? 10;        $number = $data['number'] ?? 1;        $url = config("j_rfid.screen_get_package_data");        $post = [            'site' => $data['site'],            'contract_no' => $data['contract_no'],            'drawing_no' => $data['drawing_no'] ?? "",            'room_no' => $data['room_no'] ?? "",            'size' => $size,            'number' => $number,        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result['data']];    }    public function screenGetProDtData($data,$param){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];//        if(empty($data['contract_no'])) return [false, '合同不能为空'];//        if(empty($data['drawing_no'])) return [false, '图号不能为空'];        $url = config("j_rfid.screenGetProDtData");        $post = [            'id' => $data['id'],            'type' => $data['type'],            'contract_no' => $data['contract_no'] ?? null,            'drawing_no' => $data['drawing_no'] ?? null,        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['furn_pro_flow_dt_a'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function screenGetPackageAssem($data,$param){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];        if(empty($data['site'])) return [false, '站点不能为空'];        $url = config("j_rfid.screenGetPackageAssem");        $post = [            'id' => $data['id'],            'type' => $data['type'],            'site' => $data['site'],            'contract_no' => $data['contract_no'] ?? ""        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['assembly_list'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        foreach ($result['assembly_list'] as $key => $value){            foreach ($value['package_assembly_list'] as $kk => $vv){                $result['assembly_list'][$key]['package_assembly_list'][$kk]['package_date'] = $this->changeDateToDateMin($vv['package_date']);            }        }        return [true, $result['assembly_list']];    }    public function screenGetPackageAssemData($data,$param){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];        if(empty($data['site'])) return [false, '站点不能为空'];        if(empty($data['contract_no'])) return [false, '合同不能为空'];        $url = config("j_rfid.screenGetPackageAssemData");        $post = [            'id' => $data['id'],            'type' => $data['type'],            'site' => $data['site'],            'contract_no' => $data['contract_no'] ?? ""        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['assembly_list'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        foreach ($result['assembly_list'] as $key => $value){            foreach ($value['package_assembly_list'] as $kk => $vv){                $result['assembly_list'][$key]['package_assembly_list'][$kk]['package_date'] = $this->changeDateToDateMin($vv['package_date']);            }        }        return [true, $result['assembly_list']];    }    public function screenGetDispatchDtData($data,$param){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];        $url = config("j_rfid.screen_get_dispatch_dt_data");        $post = [            'id' => $data['id'],            'type' => $data['type'],            'contract_no' => $data['contract_no'] ?? null,            'drawing_no' => $data['drawing_no'] ?? null,            'procedure' => $data['procedure'] ?? null,        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['furn_dispatch_product_dt'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function furnSeparateOrderDtAssemList($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        if(empty($data['id'])) return [false, '芯片|组件数据不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.furn_separate_order_dt_assem_list");        $post['rules'] = [            [                'field' => 'id',                'option' => 'IN',                'values' => $data['id']            ],        ];        $post['size'] = $data['size'] ?? 10;        $post['number'] = ($data['number'] ?? 1) - 1;        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function screenPackageBySepAssem($data,$param){        if(empty($data['screenDataList'])) return [false, '包装数据不能为空'];        if(empty($data['site']) || empty($data['site_show'])) return [false, '站点信息不能为空'];        list($date,$utc_date) = $this->getE8AndUTC();        foreach ($data['screenDataList'] as $key => $value){            if(empty($value['id']) || ! isset($value['type'])) return [false, '包装数据不能为空'];            $data['screenDataList'][$key]['package_teams_group'] = $data['package_teams_group'];            $data['screenDataList'][$key]['package_teams_group_show'] = $data['package_teams_group_show'];            $data['screenDataList'][$key]['package_date'] = $utc_date;            $data['screenDataList'][$key]['package_date_lt'] = $date;            $data['screenDataList'][$key]['site'] = $data['site'];            $data['screenDataList'][$key]['site_show'] = $data['site_show'];        }        $url = config("j_rfid.screen_package_by_sep_assem");        $post = [            'screenDataList' => $data['screenDataList'],        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, ['box_no' => $result['data'] ?? [], 'package_date' => $date]];    }    public function sendAndReceiptList($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.sendAndReceiptList");        if(! empty($data['contract_no']) || ! empty($data['no']) || ! empty($data['drawing_no'])) {            $rules = [];            if(! empty($data['contract_no'])) {                $rules[] = [                    'field' => 'contract_no',                    'option' => 'IN',                    'values' => $data['contract_no']                ];            }            if(! empty($data['no'])) {                $rules[] = [                    'field' => 'no',                    'option' => 'LIKE_ANYWHERE',                    'values' => $data['no']                ];            }            if(! empty($data['drawing_no'])) {                $rules[] = [                    'field' => 'drawing_no',                    'option' => 'IN',                    'values' => $data['drawing_no']                ];            }            $post['rules'] = $rules;        }        $post['size'] = $data['size'] ?? 10;        $post['number'] = ($data['number'] ?? 1) - 1;        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function sendOrderDtAssemList($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.sendOrderDtAssemList");        if(! empty($data['send_id']) || ! empty($data['sep_dt_assem_id']) || ! empty($data['contract_no'])) {            $rules = [];            if(! empty($data['send_id'])) {                $rules[] = [                    'field' => 'furn_send_prod_dt.send_id',                    'option' => 'IN',                    'values' => $data['send_id']                ];            }            if(! empty($data['sep_dt_assem_id'])) {                $rules[] = [                    'field' => 'sep_dt_assem_id',                    'option' => 'IN',                    'values' => $data['sep_dt_assem_id']                ];            }            if(! empty($data['contract_no'])) {                $rules[] = [                    'field' => 'furn_send_prod_dt.contract_no',                    'option' => 'NOT_IN',                    'values' => $data['contract_no']                ];            }            $post['rules'] = $rules;        }        $post['size'] = $data['size'] ?? 10;        $post['number'] = ($data['number'] ?? 1) - 1;        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function packageList($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.packageList");        if(! empty($data['drawing_no']) || ! empty($data['contract_no'])) {            $rules = [];            if(! empty($data['drawing_no'])) {                $rules[] = [                    'field' => 'drawing_no',                    'option' => 'IN',                    'values' => $data['drawing_no']                ];            }            if(! empty($data['contract_no'])) {                $rules[] = [                    'field' => 'contract_no',                    'option' => 'IN',                    'values' => $data['contract_no']                ];            }            $post['rules'] = $rules;        }        $post['size'] = $data['size'] ?? 10;        $post['number'] = ($data['number'] ?? 1) - 1;        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function screenAutoCreateDispatch($data,$param){        if(empty($data['type'])) return [false, '类型不能为空'];        if(empty($data['id'])) return [false, 'ID不能为空'];        $post = [            'type' => $data['type'],            'id' => $data['id'],        ];        $url = config("j_rfid.screenAutoCreateDispatch");        if(! empty($data['procedure'])) $post['procedure'] = $data['procedure'];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! isset($result['success'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, ''];    }    public function screenGetSepData($data,$param){        if(empty($data['id'])) return [false, '数据ID不能为空'];        if(empty($data['type'])) return [false, 'TYPE不能为空'];        $url = config("j_rfid.screenGetSepData");        $post = [            'id' => $data['id'],            'type' => $data['type'],        ];        list($status,$result) = $this->post_helper($url,$post,$param['header']);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['message']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['furn_sep_order_dt_assem_list'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function furnSeparateOrderCompList($data,$param){        if(empty($data['site'])) return [false, '站点不能为空'];        $header = array_merge($param['header'], ['site:'. $data['site']]);        $url = config("j_rfid.furnSeparateOrderCompList");        if(! empty($data['drawing_no']) || ! empty($data['contract_no']) || ! empty($data['region']) || ! empty($data['room']) || ! empty($data['assembly_name']) || ! empty($data['component'])) {            $rules = [];            if(! empty($data['drawing_no'])) {                $rules[] = [                    'field' => 'exe_sep_order_a.contact_no',                    'option' => 'IN',                    'values' => $data['drawing_no']                ];            }            if(! empty($data['contract_no'])) {                $rules[] = [                    'field' => 'exe_sep_order_a.drawing_no',                    'option' => 'IN',                    'values' => $data['contract_no']                ];            }            if(! empty($data['region'])) {                $rules[] = [                    'field' => 'exe_sep_order_a.region',                    'option' => 'IN',                    'values' => $data['region']                ];            }            if(! empty($data['room'])) {                $rules[] = [                    'field' => 'exe_sep_order_dtl_b.room',                    'option' => 'IN',                    'values' => $data['room']                ];            }            if(! empty($data['assembly_name'])) {                $rules[] = [                    'field' => 'exe_sep_order_dtl_b.assembly_name',                    'option' => 'IN',                    'values' => $data['assembly_name']                ];            }            if(! empty($data['component'])) {                $rules[] = [                    'field' => 'component',                    'option' => 'IN',                    'values' => $data['component']                ];            }            $post['rules'] = $rules;        }        $post['size'] = $data['size'] ?? 10;        $post['number'] = ($data['number'] ?? 1) - 1;        list($status,$result) = $this->post_helper($url,$post,$header);        if(! $status) return [$status, $result];        if(! empty($result['status']) && $result['status'] == 'error') return [false, $result['msg']];        if(! empty($result['type']) && $result['type'] == 'errorVm') return [false, $result['message']];        if(! isset($result['content'])) {            $error = $result[0]['message'] ?? "操作失败,请刷新页面";            return [false, $error];        }        return [true, $result];    }    public function post_helper($url, $data, $header = [], $timeout = 20){        Log::channel('apiLog')->info('工装云POST', ["api" => $url , "param" => $data ,"header" => $header]);        $ch = curl_init();        curl_setopt($ch, CURLOPT_URL, $url);        curl_setopt($ch,  CURLOPT_RETURNTRANSFER, true);        curl_setopt($ch, CURLOPT_ENCODING, '');        curl_setopt($ch, CURLOPT_POST, 1);        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');        curl_setopt($ch, CURLOPT_HTTPHEADER, $header);        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);        curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);        if(!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));        $r = curl_exec($ch);        if ($r === false) {            // 获取错误号            $errorNumber = curl_errno($ch);            // 获取错误信息            $errorMessage = curl_error($ch);            $message = "cURL Error #{$errorNumber}: {$errorMessage}";            Log::channel('apiLog')->info('工装云POST结果', ["message" => $message]);            return [false, $message];        }        curl_close($ch);        $return = json_decode($r, true);        Log::channel('apiLog')->info('工装云POST结果', ["message" => $return]);        if(! empty($return['message']) && $return['message'] == 'error.unAuthorized') return [0, '登录凭证已失效或者不正确'];        return [true, $return];    }    public function get_helper($url,$header=[],$timeout = 20){        $ch = curl_init();        curl_setopt_array($ch, array(            CURLOPT_URL => $url,            CURLOPT_RETURNTRANSFER => true,            CURLOPT_ENCODING => '',            CURLOPT_MAXREDIRS => 10,            CURLOPT_TIMEOUT => $timeout,            CURLOPT_FOLLOWLOCATION => true,            CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,            CURLOPT_CUSTOMREQUEST => 'GET',            CURLOPT_SSL_VERIFYPEER => false,            CURLOPT_HTTPHEADER => $header,        ));        $r = curl_exec($ch);        if ($r === false) {            // 获取错误号            $errorNumber = curl_errno($ch);            // 获取错误信息            $errorMessage = curl_error($ch);            $message = "cURL Error #{$errorNumber}: {$errorMessage}";            Log::channel('apiLog')->info('工装云GET', ["message" => $message]);            return [false, $message];        }        curl_close($ch);        $return = json_decode($r, true);        Log::channel('apiLog')->info('工装云GET', ["message" => $return]);        if(! empty($return['message']) && $return['message'] == 'error.unAuthorized') return [0, '登录凭证已失效或者不正常'];        return [true, $return];    }}
 |