12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084 |
- <?php
- namespace App\Service\Box;
- use App\Jobs\BoxAddJob;
- use App\Model\ApplyOrder;
- use App\Model\ApplyOrderForYy;
- use App\Model\Box;
- use App\Model\BoxDetail;
- use App\Model\BoxWithDispatch;
- use App\Model\DispatchSub;
- use App\Model\EmployeeTeamPermission;
- use App\Model\Header_ext;
- use App\Model\OrdersProduct;
- use App\Model\OrdersProductProcess;
- use App\Model\Process;
- use App\Model\ReportMessage;
- use App\Model\ReportWorking;
- use App\Model\ReportWorkingDetail;
- use App\Model\SaleOrdersProduct;
- use App\Model\ScrappCount;
- use App\Model\Setting;
- use App\Model\Team;
- use App\Service\ApplyOrderService;
- use App\Service\EmployeeService;
- use App\Service\FinishedOrderService;
- use App\Service\FyyOrderService;
- use App\Service\FyySqlServerService;
- use App\Service\Service;
- use Illuminate\Support\Facades\DB;
- use Illuminate\Support\Facades\Log;
- /**
- * 包装相关
- * @package App\Models
- */
- class BoxService extends Service
- {
- protected static $instance;
- protected static $box_header;
- protected static $box_detail_header;
- protected static $box_hook;
- public $lock_key = 'hc_box_new_add';
- public function __construct()
- {
- self::$box_header = Header_ext::where('type', 'box')->pluck('value', 'key')->toArray();
- self::$box_detail_header = Header_ext::where('type', 'box_detail')->pluck('value', 'key')->toArray();
- self::$box_hook = BoxHookService::getInstance();
- }
- public function boxIn($data,$user)
- {
- list($status, $msg) = $this->boxInRule($data, $user);
- if(! $status) return [false, $msg];
- $data['zt'] = Request()->header('zt');
- //list($status, $msg) = $this->boxInSettle($data,$user);dd($status,$msg);
- //限制频率
- $limit_key = $this->lock_key;
- list($status,$msg) = $this->limitingSendRequestBackgNeed($limit_key);
- if(! $status) return [false, '请稍后操作'];
- $job = BoxAddJob::dispatch($data,$user)->onQueue(BoxAddJob::job);
- if(! $job) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- return [false,'任务未进入后台队列,请联系管理员'];
- }
- return [true, ''];
- }
- public function boxInRule($data,$user)
- {
- try{
- $ids = [];
- $sale_ids = [];
- $data = $data['param'];
- $key_list = [];
- foreach ($data as $v) {
- if($v['id'] < 0) $sale_ids[] = -$v['id'];
- else $ids[] = $v['id'];
- if($v['id'] < 0) $v['id'] = -$v['id'];
- $total = 0;
- foreach ($v['params'] as $vv) {
- $total += $vv;
- }
- $key_list[$v['id']] = [
- 'detail' => $v['params'],
- 'total' => $total,
- 'team_id' => isset($v['team_id']) ? $v['team_id'] : 0,
- ];
- }
- //数据获取
- $product_list = OrdersProduct::wherein('id', $ids)->get()->toArray();
- //校验
- $flag = "";
- foreach ($product_list as $value){
- $key = $value['out_order_no'] . $value['product_no'] . $value['technology_name'];
- if(! empty($flag)){
- if($flag != $key) return [false , "一次包装只允许包一种产品的一种颜色!"];
- }else{
- $flag = $key;
- }
- $num_list = $key_list[$value['id']];
- $total = $num_list['total'];
- $un_box_num = bcsub($value['dispatch_complete_quantity'] , $value['box_num'],3);
- if ($total > $un_box_num) return [false, $value['product_title'] . ' ' . $value['technology_name'] . ' 可包装的数量不足'];
- }
- return [true, ''];
- }catch (\Throwable $e){
- return [false,$e->getFile() . '|' . $e->getLine(). '|' .$e->getMessage()];
- }
- }
- public function boxInSettle($data, $user){
- //设置数据库连接
- $this->setConnect($data);
- $zt = $data['zt'] ?? "";
- $ids = [];
- $sale_ids = [];
- $top_order_no = $data['order_no'];
- $box_no = isset($data['box_no']) ? $data['box_no'] : '';
- $transport_no = isset($data['transport_no']) ? $data['transport_no'] : '';
- $data = $data['param'];
- $key_list = [];
- foreach ($data as $v) {
- if($v['id'] < 0) $sale_ids[] = -$v['id'];
- else $ids[] = $v['id'];
- if($v['id'] < 0) $v['id'] = -$v['id'];
- $total = 0;
- foreach ($v['params'] as $vv) {
- $total += $vv;
- }
- $key_list[$v['id']] = [
- 'detail' => $v['params'],
- 'total' => $total,
- 'team_id' => isset($v['team_id']) ? $v['team_id'] : 0,
- ];
- }
- $insert = [];
- //锁
- $limit_key = $this->lock_key;
- try{
- DB::beginTransaction();
- //数据获取
- $product_list = OrdersProduct::whereIn('id', $ids)->get()->toArray();
- $sale_product_list = SaleOrdersProduct::whereIn('id', $sale_ids)->get()->toArray();
- //生产订单包装----------------
- $box_insert = [];
- foreach ($product_list as $v) {
- $num_list = $key_list[$v['id']];
- $total = $num_list['total'];
- $detail = $num_list['detail'];
- $team_id = $num_list['team_id'];
- $ext_1 = $v['product_no'];//产品编号
- $ext_2 = $v['technology_material']; //工艺材质 废弃
- $ext_3 = $v['technology_name'];//工艺名称 改为颜色
- $ext_4 = $v['wood_name'];//木皮 废弃
- $ext_5 = $v['process_mark'];//工艺备注 废弃
- $ext_8 = $v['product_title'];//产品名称
- $out_order_no = $insert['out_order_no'] = $v['out_order_no'];
- $top_id = $v['sale_orders_product_id'];
- foreach ($detail as $vv){
- $box_insert[] = [
- 'out_order_no' => $out_order_no,
- 'top_id' => $top_id,
- 'orders_product_id' => $v['id'],
- 'ext_1' => $ext_1,//产品编号
- 'ext_2' => $ext_2,
- 'ext_3' => $ext_3,//颜色
- 'ext_4' => $ext_4,
- 'ext_5' => $ext_5,
- 'ext_8' => $ext_8,//产品名称
- 'num' => $vv,
- 'price' => $v['price'],
- 'box_type' => 1,
- 'team_id' => $team_id,
- 'shipment_order_no' => $transport_no,
- ];
- }
- //修改销售订单 生产订单 包装数量
- SaleOrdersProduct::where('id',$v['sale_orders_product_id'])->update([
- 'box_num' => DB::raw('box_num + '.$total),
- ]);
- OrdersProduct::where('id',$v['id'])->update([
- 'box_num' => DB::raw('box_num + '.$total),
- ]);
- }
- //客户名称
- $ext_1 = "";
- if(empty($ext_1) && isset($sale_product_list[0]['customer_name'])) $ext_1 = $sale_product_list[0]['customer_name'];
- if(empty($ext_1) && isset($product_list[0]['customer_name'])) $ext_1 = $product_list[0]['customer_name'];
- $insert['ext_1'] = $ext_1;
- $insert['detail'] = $box_insert;
- $insert['top_order_no'] = $top_order_no;
- $insert['order_no'] = $box_no;
- $insert['shipment_order_no'] = $transport_no;
- //生成包装单
- list($status,$msg) = self::$box_hook->boxInsert($insert,$user);
- if(! $status) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- DB::rollBack();
- return [false, $msg];
- }
- //反写数量
- $em = new EmployeeService();
- $auto = $em->is_auto($user, "bzwg_auto");
- if($auto){
- list($status, $msg1) = $this->updateFinishNew($product_list,$key_list,$user);
- if(! $status) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- DB::rollBack();
- return [false, $msg1];
- }
- }
- //包装单
- $package_data = $msg->toArray();
- $dispatch_list = $msg1 ?? [];
- if(! empty($dispatch_list)){
- foreach ($dispatch_list as $key => $value){
- $dispatch_list[$key]['dispatch_id'] = $value['id'];
- unset($dispatch_list[$key]['id']);
- $dispatch_list[$key]['box_id'] = $package_data['id'];
- }
- BoxWithDispatch::insert($dispatch_list);
- }
- //包装单产品
- $boxDetail = new BoxDetail(['channel'=>$package_data['top_order_no']]);
- $boxDetail = $boxDetail->where('del_time',0)
- ->where('order_no',$package_data['order_no'])
- ->select('ext_1 as product_no', 'ext_3 as technology_name', 'ext_8 as product_title', 'ext_9 as product_size', 'num as quantity')
- ->get()->toArray();
- //生成半成品出库申请单
- list($status, $msg1) = $this->createbcpllSQ($package_data,$boxDetail, $user);
- if(! $status) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- DB::rollBack();
- return [false, $msg1];
- }
- //生成包装领料申请单
- list($status, $msg1) = $this->createllSQ($package_data,$boxDetail, $user);
- if(! $status) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- DB::rollBack();
- return [false, $msg1];
- }
- //生成包装入库申请单
- list($status, $msg) = $this->createBZSQ($package_data,$boxDetail, $user);
- if(! $status) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- DB::rollBack();
- return [false, $msg];
- }
- //是否自动审核 包装入库申请单 如果是测试的不写用友
- $auto = $em->is_auto($user,"bzsq_auto");
- if(! empty($package_data) && $auto && $zt != 'cs') {
- //用友 ------产成品入库
- $service = new FinishedOrderService();
- list($status,$msg) = $service->U8Rdrecord10Save($package_data,$user);
- if(! $status) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- DB::rollBack();
- return [false, $msg];
- }
- }
- DB::commit();
- $this->dellimitingSendRequestBackgNeed($limit_key);
- return [true, ['package_data' => $package_data]];
- }catch (\Throwable $e){
- DB::rollBack();
- $this->dellimitingSendRequestBackgNeed($limit_key);
- if (str_contains($e->getMessage(), '1062') || str_contains($e->getMessage(), 'Duplicate entry')) {
- return [false, '网络波动,请重新操作!'];
- }
- return [false, $e->getFile(). '|' .$e->getLine().'|'.$e->getMessage()];
- }
- }
- private function setConnect($data){
- $storeCode = $data['zt'] ?? '';
- $connectionName = "mysql";
- if($storeCode == 'cs') $connectionName = "mysql_" . $storeCode;
- if (in_array($connectionName, array_keys(config('database.connections')))) {
- // 切换默认数据库连接
- config(['database.default' => $connectionName]);
- // 重新解析 DB Facade 使用新的连接
- app()->forgetInstance('db');
- $db = app('db');
- // 如果用到了模型,还要重置模型连接
- \Illuminate\Database\Eloquent\Model::setConnectionResolver($db);
- }
- }
- public function createbcpllSQ($package_data, $insert_id, $user){
- //是否自动审核 半成品出库申请单
- $em = new EmployeeService();
- $auto = $em->is_auto($user,"bcpckllsq_auto");
- //组织包装原材料写入数据
- $insert = [];
- $box_id = $package_data['id'] ?? 0;
- foreach ($insert_id as $value){
- $insert[] = [
- 'id' => $box_id,
- 'quantity' => $value['quantity'] ?? 0,
- 'product_no' => $value['product_no'],
- 'product_title' => $value['product_title'],
- 'product_size' => "",
- 'product_unit' => "",
- 'technology_name' => $value['technology_name'],
- ];
- }
- try {
- DB::beginTransaction();
- //生成申请单
- $service = new ApplyOrderService();
- list($status, $msg) = $service->createSQ($insert, $user, ApplyOrder::type_six, $auto);
- if(! $status) {
- DB::rollBack();
- return [false, $msg];
- }
- if($auto) {
- //生成流水
- list($status, $msg) = $service->createRecord($msg);
- if(! $status) {
- DB::rollBack();
- return [false, $msg];
- }
- }
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getFile() . $exception->getMessage() . $exception->getLine()];
- }
- return [true, ''];
- }
- public function createllSQ($package_data, $insert_id, $user){
- //是否自动审核 包装领料申请单
- $em = new EmployeeService();
- $auto = $em->is_auto($user,"bzllsq_auto");
- $return = [];
- $product_no = array_unique(array_column($insert_id,'product_no'));
- //获取包装原料
- $service = new FyyOrderService();
- list($status, $msg) = $service->getProductBzDataFromSqlServer(['product_no' => $product_no], $user);
- if($status) $return = $msg;
- //组织包装原材料写入数据
- $insert = [];
- $box_id = $package_data['id'] ?? 0;
- foreach ($insert_id as $value){
- $t = $return[$value['product_no']] ?? [];
- $tmp = [
- 'id' => $box_id,
- 'quantity' => $value['quantity'] ?? 0,
- 'product_no' => "",
- 'product_title' => "",
- 'product_size' => "",
- 'product_unit' => "",
- 'top_product_no' => $value['product_no'],
- 'top_product_title' => $value['product_title'],
- 'technology_name' => $value['technology_name'],
- ];
- if(! empty($t)){
- foreach ($t as $v){
- $tmp['product_no'] = $v['product_no'];
- $tmp['product_title'] = $v['product_title'];
- $tmp['product_size'] = $v['product_size'];
- $tmp['product_unit'] = $v['product_unit'];
- $insert[] = $tmp;
- }
- }else{
- $tmp['quantity'] = 0;
- $insert[] = $tmp;
- }
- }
- try {
- DB::beginTransaction();
- //生成申请单
- $service = new ApplyOrderService();
- list($status, $msg) = $service->createSQ($insert, $user, ApplyOrder::type_four, $auto);
- if(! $status) {
- DB::rollBack();
- return [false, $msg];
- }
- if($auto) {
- //生成流水
- list($status, $msg) = $service->createRecord($msg);
- if(! $status) {
- DB::rollBack();
- return [false, $msg];
- }
- }
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getFile() . $exception->getMessage() . $exception->getLine()];
- }
- return [true, ''];
- }
- public function createBZSQ($package_data, $insert_id, $user){
- //是否自动审核 包装入库申请单
- $em = new EmployeeService();
- $auto = $em->is_auto($user,"bzsq_auto");
- try {
- DB::beginTransaction();
- $box_id = $package_data['id'] ?? 0;
- foreach ($insert_id as $key => $value){
- $insert_id[$key]['id'] = $box_id;
- }
- //生成申请单
- $service = new ApplyOrderService();
- list($status, $msg) = $service->createSQ($insert_id, $user, ApplyOrder::type_three, $auto);
- if(! $status) {
- DB::rollBack();
- return [false, $msg];
- }
- //用友写入数据信息
- $apply_order_id = $msg;
- ApplyOrderForYy::insert([
- 'apply_order_id' => $apply_order_id,
- 'crt_time' => time(),
- 'post' => json_encode($package_data),
- ]);
- if($auto) {
- //生成流水
- list($status, $msg) = $service->createRecord($msg);
- if(! $status) {
- DB::rollBack();
- return [false, $msg];
- }
- }
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getFile() . $exception->getMessage() . $exception->getLine()];
- }
- return [true, ''];
- }
- public function delBoxLock(){
- $this->dellimitingSendRequestBackgNeed($this->lock_key);
- }
- //新的完工
- public function updateFinishNew($production_list = [], $map, $user){
- if(empty($production_list)) return [true, ''];
- $order_product_id = array_column($production_list,'id');
- $order = OrdersProduct::where('del_time',0)
- ->where('id', $order_product_id)
- ->select('id', 'process_id')
- ->get()->toArray();
- $order_map = [];
- //生产订单 =》 工序
- foreach ($order as $value){
- $order_map[$value['id']] = explode(',', $value['process_id']);
- }
- //组织派工数据
- $dispatch = DispatchSub::where('del_time',0)
- ->whereIn('order_product_id', array_column($production_list,'id'))
- ->get()->toArray();
- if(empty($dispatch)) return [true,''];
- $sale_order_id = array_unique(array_column($dispatch,'sale_orders_product_id'));
- $dispatch_map = [];
- foreach ($dispatch as $value){
- $key = $value['order_product_id'] . '|' . $value['crt_time']; //同一次下的派工单
- $dispatch_map[$key][] = $value;
- }
- $result = []; $tmp = [];
- foreach ($dispatch_map as $key => $value){
- $dispatch_quantity = array_sum(array_column($value, 'dispatch_quantity'));
- $finished_num = array_sum(array_column($value, 'finished_num'));
- //同一批派工 且 全部完工的 跳过
- if($dispatch_quantity == $finished_num) continue;
- $order_id = explode('|', $key)[0];
- // 生产订单id存在 跳过(原因 同一个生产订单可能下多次派工,那么这一次包装数量只需要一次派工的数据)
- if(in_array($order_id, $tmp)) continue;
- foreach ($value as $val){
- $num = bcadd($val['finished_num'], $val['waste_num'], 3);
- if($num >= $val['dispatch_quantity']) continue; //某一个工序完工
- //包装数量
- $tmp_num = $map[$val['order_product_id']]['total'] ?? 0;
- if($tmp_num <= 0) continue;
- $tmp_num2 = bcsub($val['dispatch_quantity'] , $val['finished_num'],3);
- if($tmp_num2 >= $tmp_num){
- $val['quantity'] = $tmp_num;
- }else{
- $val['quantity'] = $tmp_num2;
- }
- $result[] = $val;
- $tmp[] = $order_id;
- }
- }
- if(empty($result)) return [true,''];
- try {
- DB::beginTransaction();
- //班组下的人
- $team_man = [];
- $team_array = EmployeeTeamPermission::select('employee_id','team_id')->get()->toArray();
- foreach ($team_array as $value){
- //拿班组里的一个人
- if(! isset($team_man[$value['team_id']])) $team_man[$value['team_id']] = $value['employee_id'];
- }
- //工序 班组
- $process_map = [
- 12 => 65,
- 11 => 66,
- 15 => 69,
- 14 => 67,
- 13 => 68,
- ];
- $service = new FinishedOrderService();
- $service1 = new ApplyOrderService();
- $dispatch_time = $c_time = $result[0]['crt_time']; //派工单创建时间
- $date = date("Ymd", $c_time);
- // //派工和包装不在同一天 质检单日期加一天
- // if($date != date("Ymd")){
- // $c_time = strtotime("+1 day", strtotime($date));
- // $date = date("Ymd", $c_time);
- // }
- $max_id = $service1->getDailyId($c_time);
- //是否需要质检
- list($status, $return) = $service->isNeedZJ($sale_order_id);
- $flag = $return;
- //根据派工数据组织
- $last_update = $last_update2 = $str_tmp = $insert = $get_order_number = $return_dispatch = [];
- foreach ($result as $value){
- $need_zj_process = $flag[$value['sale_orders_product_id']] ?? 0;
- $bad_quantity = $scrapp_id = $for_r = 0;
- $warehouse_no = $warehouse_title = "";
- if(! empty($need_zj_process) && $value['process_id'] == $need_zj_process){
- $numbers = [0.08, 0.09, 0.1, 0.11, 0.12];
- $bad_quantity = $numbers[array_rand($numbers)];
- $flag[$value['sale_orders_product_id']] = 0;
- if($need_zj_process == 12){
- $scrapp_id = 19;
- $for_r = ReportWorking::type_two;
- $warehouse_no = "005";
- $warehouse_title = "报废仓";
- }else{
- $scrapp_id = mt_rand(10, 18);
- $for_r = ReportWorking::type_one;
- }
- }
- $quantity = bcsub($value['quantity'], $bad_quantity, 3);
- //质检
- $max_id += 1;
- $order_number = $date . str_pad($max_id,3,'0',STR_PAD_LEFT);
- $get_order_number[] = $order_number;
- $insert[] = [
- 'sale_orders_product_id' => $value['sale_orders_product_id'],
- 'order_product_id' => $value['order_product_id'],
- 'dispatch_sub_id' => $value['id'],
- 'out_order_no' => $value['out_order_no'],
- 'order_no' => $value['order_no'],
- 'customer_no' => $value['customer_no'],
- 'customer_name' => $value['customer_name'],
- 'product_no' => $value['product_no'],
- 'product_title' => $value['product_title'],
- 'product_size' => $value['product_size'],
- 'product_unit' => $value['product_unit'],
- 'technology_material' => $value['technology_material'],
- 'technology_name' => $value['technology_name'],
- 'wood_name' => $value['wood_name'],
- 'price' => $value['price'],
- 'process_mark' => $value['process_mark'],
- 'table_body_mark' => $value['table_body_mark'],
- 'table_header_mark' => $value['table_header_mark'],
- 'crt_id' => $user['id'],
- 'crt_time' => $c_time,
- 'scrapp_num' => $bad_quantity,
- 'scrapp_id' => $scrapp_id,
- 'team_id' => 73,
- 'finished_id' => $user['id'],
- 'equipment_id' => $value['device_id'],
- 'order_number' => $order_number,
- 'process_id' => $value['process_id'],
- 'quantity' => $quantity,
- 'report_id' => 0,
- 'result' => $for_r,
- 'warehouse_no' => $warehouse_no,
- 'warehouse_title' => $warehouse_title,
- 'daily_id' => $max_id,
- ];
- $tmp = [
- 'id' => $value['id'],
- 'quantity' => $value['quantity'],
- 'product_no' => $value['product_no'] ?? "",
- 'product_title' => $value['product_title'] ?? "",
- 'product_size' => $value['product_size'] ?? "",
- 'product_unit' => $value['product_unit'] ?? "",
- ];
- $str = $value['order_product_id'] . $value['crt_time'] . $value['product_no'] . $value['technology_name'];
- if(! in_array($str, $str_tmp)){
- $last_update[] = $tmp;
- $str_tmp[] = $str;
- }
- $tmp['process_id'] = $value['process_id'];
- $tmp['quantity'] = $quantity;
- $team_tmp = $process_map[$value['process_id']] ?? 0; // 班组
- $t_m = $team_man[$team_tmp] ?? 0; //班组下的人
- $tmp['finished_id'] = $t_m;
- $tmp['team_id'] = $team_tmp;
- $last_update2[] = $tmp;
- if($value['process_id'] == 14) {
- $return_dispatch[] = [
- 'id' => $value['id'],
- 'num' => $value['quantity'],
- ];
- }
- }
- //生成报工单
- list($status, $msg) = $this->createbg($last_update2, $user,$dispatch_time);
- if(! $status) return [false, $msg];
- //报工单id数组
- list($report_id, $report_order_number) = $msg;
- if(empty($report_id)) return [false, '报工单返回信息异常'];
- //根据报工单创建质检单
- list($status,$msg) = $service->createZJFirst($report_id, $insert);
- if(! $status) return [false, $msg];
- //生成因为有不良品需要的返工的业务单据
- list($status, $msg) = $service->createZJSecond($get_order_number, $user, $dispatch_time, $c_time,$max_id,$team_man,$report_order_number,$return_dispatch);
- if(! $status) return [false, $msg];
- $get_order_number_result = $msg;
- //生成完工入库申请单
- list($status, $msg) = $this->createWGSQ($last_update, $user, $c_time);
- if(! $status) return [false, $msg];
- //反写 根据质检单上的派工单id 反写上游单据
- $this->writeDispatchQuantity($get_order_number_result);
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getLine().':'.$exception->getMessage() . ':' . $exception->getFile()];
- }
- return [true, $return_dispatch];
- }
- public function createbg($insert, $user,$dispatch_time = 0, $order_number = ""){
- //报工单
- $em = new EmployeeService();
- $auto = $em->is_auto($user, "wgbg_auto");
- if(empty($order_number)){
- $order_number = (new ApplyOrderService())->setOrderNO2($dispatch_time);
- if(empty($order_number)) return [false, '报工单编号生成失败'];
- $is_first = true;
- }else{
- $is_first = false;
- }
- $process = Process::where('del_time',0)
- ->where('is_need_remain',1)
- ->select('id')
- ->get()->toArray();
- $process_id = array_column($process,'id');
- try {
- DB::beginTransaction();
- if(empty($dispatch_time)){
- $time = time();
- }else{
- $time = $dispatch_time;
- }
- $prefix = substr($order_number, 0, -3);// "20250611"
- $startNum = (int)substr($order_number, -3); // 7
- $return = $get_order_number = [];
- foreach ($insert as $v){
- if(! $is_first){
- $startNum += 1;
- $number = str_pad($startNum,3,'0',STR_PAD_LEFT);
- $number = $prefix . $number;
- $dispatch_no_t = $number;
- }else{
- $dispatch_no_t = $order_number;
- $is_first = false;
- }
- $get_order_number[] = $dispatch_no_t;
- $model = new ReportWorking();
- $model->order_number = $dispatch_no_t;
- $model->report_time = $time;
- $model->crt_id = $user['id'];
- $model->status = $auto;
- $model->save();
- $id = $model->id;
- ReportWorkingDetail::insert([
- 'report_working_id' => $id,
- 'data_id' => $v['id'],
- 'quantity' => $v['quantity'] ?? 0,
- 'finished_id' => $v['finished_id'] ?? 0,
- 'process_id' => $v['process_id'] ?? 0,
- 'team_id' => $v['team_id'] ?? 0,
- 'crt_time' => $time,
- ]);
- $return[$v['id']] = $id;
- if(in_array($v['process_id'], $process_id)){
- ReportMessage::insert([
- 'order_id' => $v['id'],
- 'quantity' => $v['quantity'] ?? 0,
- 'opt_case' => ReportMessage::type_one,
- 'crt_time' => $time,
- 'user_id' => $user['id'],
- 'is_use' => 1
- ]);
- }
- }
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getFile() . $exception->getMessage() . $exception->getLine()];
- }
- return [true, [$return, $get_order_number]];
- }
- //反写
- public function writeDispatchQuantity($get_order_number_result){
- $result = ScrappCount::whereIn('order_number',$get_order_number_result)
- ->select('dispatch_sub_id','quantity','scrapp_num as num','crt_time','process_id','order_product_id')
- ->get()->toArray();
- //是否最后一道工序
- $orders = OrdersProduct::whereIn('id', array_unique(array_column($result, 'order_product_id')))
- ->select('id','process_id')
- ->get()->toArray();
- $map = [];
- foreach ($orders as $value){
- $p = explode(",", $value['process_id']);
- $lastElement = end($p);
- $map[$value['id']] = $lastElement;
- }
- //汇总这个派工单一共质检良品数量 但是同一时间下的 只取一次
- $update = $flag = $need_update = [];
- foreach ($result as $value){
- if(isset($map[$value['order_product_id']]) && $map[$value['order_product_id']] == $value['process_id'] && ! in_array($value['order_product_id'], $need_update)){
- $need_update[] = [
- 'order_product_id' => $value['order_product_id'],
- 'process_id' => $value['process_id'],
- ];
- }
- $key = $value['dispatch_sub_id'] . $value['crt_time'];
- if(isset($flag[$key])) continue;
- if(isset($update[$value['dispatch_sub_id']])){
- $tmp = bcadd($value['quantity'], $update[$value['dispatch_sub_id']]['finished_num'], 3);
- $tmp1 = bcadd($value['num'], $update[$value['dispatch_sub_id']]['waste_num'], 3);
- $update[$value['dispatch_sub_id']] = [
- 'finished_num' => $tmp,
- 'waste_num' => $tmp1,
- ];
- }else{
- $update[$value['dispatch_sub_id']] = [
- 'finished_num' => $value['quantity'],
- 'waste_num' => $value['num'],
- ];
- }
- $flag[$key] = 1;
- }
- unset($flag);
- //更新派工单完工数量----------------------------------------------------
- foreach ($update as $id => $value){
- DispatchSub::where('id', $id)->update([
- 'finished_num' => DB::raw('finished_num + '.$value['finished_num']),
- 'waste_num' => DB::raw('waste_num + '.$value['waste_num']),
- ]);
- }
- if(! empty($need_update)){
- //更新生产订单的完工数量--------------------------------------------------
- $list = DispatchSub::where("del_time",0)
- ->when(! empty($need_update), function ($query) use ($need_update) {
- return $query->where(function ($q) use ($need_update) {
- foreach ($need_update as $value) {
- $order_product_id = $value['order_product_id'];
- $process_id = $value['process_id'];
- $q->orWhere(function ($subQ) use ($order_product_id, $process_id) {
- $subQ->where('order_product_id', $order_product_id)
- ->where('process_id', $process_id);
- });
- }
- });
- })
- ->select('order_product_id', 'finished_num', 'sale_orders_product_id')
- ->get()->toArray();
- $map2 = [];
- foreach ($list as $value){
- if(isset($map2[$value['order_product_id']])){
- $tmp = bcadd($map2[$value['order_product_id']], $value['finished_num'], 3);
- $map2[$value['order_product_id']] = $tmp;
- }else{
- $map2[$value['order_product_id']] = $value['finished_num'];
- }
- }
- foreach ($map2 as $id => $num){
- OrdersProduct::where('id', $id)->update([
- 'finished_num' => $num
- ]);
- }
- //更新销售订单完工数量-------------------------------------------------------
- $list2 = OrdersProduct::where('del_time',0)
- ->whereIn('sale_orders_product_id', array_unique(array_column($list, 'sale_orders_product_id')))
- ->select('finished_num','sale_orders_product_id')
- ->get()->toArray();
- $map3 = [];
- foreach ($list2 as $value){
- if(isset($map3[$value['sale_orders_product_id']])){
- $tmp = bcadd($map3[$value['sale_orders_product_id']], $value['finished_num'], 3);
- $map3[$value['sale_orders_product_id']] = $tmp;
- }else{
- $map3[$value['sale_orders_product_id']] = $value['finished_num'];
- }
- }
- foreach ($map3 as $id => $num){
- SaleOrdersProduct::where('id', $id)->update([
- 'finished_num' => $num
- ]);
- }
- }
- }
- //旧的完工
- public function updateFinish($production_list = [], $map,$user){
- if(empty($production_list)) return [true,''];
- $order_product_id = array_column($production_list,'id');
- $order = OrdersProduct::where('del_time',0)
- ->where('id', $order_product_id)
- ->select('id', 'process_id')
- ->get()->toArray();
- $order_map = [];
- foreach ($order as $value){
- $order_map[$value['id']] = explode(',', $value['process_id']);
- }
- //组织派工数据
- $dispatch = DispatchSub::where('del_time',0)
- ->whereIn('order_product_id', array_column($production_list,'id'))
- ->get()->toArray();
- if(empty($dispatch)) return [true,''];
- $dispatch_map = [];
- foreach ($dispatch as $value){
- $key = $value['order_product_id'] . '|' . $value['crt_time']; //同一次下的派工单
- $dispatch_map[$key][] = $value;
- }
- $result = []; $tmp = [];
- foreach ($dispatch_map as $key => $value){
- $dispatch_quantity = array_sum(array_column($value, 'dispatch_quantity'));
- $finished_num = array_sum(array_column($value, 'finished_num'));
- if($dispatch_quantity == $finished_num) continue; //同一批派工 且 全部完工的 跳过
- $order_id = explode('|', $key)[0];
- if(in_array($order_id, $tmp)) continue;// 生产订单id存在 跳过
- foreach ($value as $val){
- if($val['dispatch_quantity'] <= $val['finished_num']) continue; //某一个工序完工
- //包装数量
- $tmp_num = $map[$val['order_product_id']]['total'] ?? 0;
- if($tmp_num <= 0) continue;
- $tmp_num2 = bcsub($val['dispatch_quantity'] , $val['finished_num'],3);
- if($tmp_num2 >= $tmp_num){
- $val['quantity'] = $tmp_num;
- }else{
- $val['quantity'] = $tmp_num2;
- }
- $result[] = $val;
- $tmp[] = $order_id;
- }
- }
- if(empty($result)) return [true,''];
- $time = time();
- try {
- DB::beginTransaction();
- //班组下的人
- $team_man = [];
- $team_array = EmployeeTeamPermission::select('employee_id','team_id')->get()->toArray();
- foreach ($team_array as $value){
- $team_man[$value['team_id']][] = $value['employee_id'];
- }
- //工序 班组
- $process_map = [
- 12 => 65,
- 11 => 66,
- 15 => 69,
- 14 => 67,
- 13 => 68,
- ];
- //根据派工数据回写
- $last_update = $last_update2 = $str_tmp = [];
- foreach ($result as $value){
- $finished_num = $value['quantity'] + $value['finished_num'];
- DispatchSub::where('id',$value['id'])->update([
- 'finished_num' => $finished_num,
- 'wg_status' => 1,
- ]);
- $tmp = [
- 'id' => $value['id'],
- 'quantity' => $value['quantity'],
- 'product_no' => $value['product_no'] ?? "",
- 'product_title' => $value['product_title'] ?? "",
- 'product_size' => $value['product_size'] ?? "",
- 'product_unit' => $value['product_unit'] ?? "",
- ];
- $str = $value['order_product_id'] . $value['crt_time'] . $value['product_no'] . $value['technology_name'];
- if(! in_array($str, $str_tmp)){
- $last_update[] = $tmp;
- $str_tmp[] = $str;
- }
- $tmp['process_id'] = $value['process_id'];
- $team_tmp = $process_map[$value['process_id']] ?? 0; // 班组
- if(empty($team_tmp)){
- $tmp['finished_id'] = 0;
- $tmp['team_id'] = 0;
- $last_update2[] = $tmp;
- }else{
- $t_m = $team_man[$team_tmp] ?? []; //班组下的人
- if(empty($t_m)) {
- $tmp['finished_id'] = 0;
- $tmp['team_id'] = $team_tmp;
- $last_update2[] = $tmp;
- }else{
- foreach ($t_m as $m_v){
- $tmp['finished_id'] = $m_v;
- $tmp['team_id'] = $team_tmp;
- $last_update2[] = $tmp;
- }
- }
- }
- $quantity = $value['quantity'] * 1000;
- //工序表
- $process_model = new OrdersProductProcess(['channel' => date("Ymd",$value['out_order_no_time'])]);
- $process_model->where('order_product_id',$value['order_product_id'])
- ->where('process_id',$value['process_id'])
- ->where('dispatch_no',$value['dispatch_no'])
- ->where('status', 1)
- ->take($quantity)
- ->update([
- 'finished_time' => $time,
- 'status' => 2,
- 'finished_id' => 1,
- 'team_id' => $team_tmp,
- 'equipment_id' => 13,
- ]);
- }
- $service = new FinishedOrderService();
- //反写数量
- //生产订单
- $id = array_column($result,'order_product_id');
- $service->writeFinishedQuantityByOrdersProductId($id);
- //销售订单
- $service->writeFinishedQuantity($id);
- //生成完工入库申请单
- // list($status, $msg) = $this->createWGSQ($last_update, $user);
- // if(! $status) return [false, $msg];
- //生成报工单
- $service = new FinishedOrderService();
- list($status, $msg) = $service->createbg($last_update2, $user);
- if(! $status) return [false, $msg];
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getLine().':'.$exception->getMessage() . ':' . $exception->getFile()];
- }
- return [true, ''];
- }
- public function createWGSQ($insert_id, $user, $time = 0){
- //完工入库申请单自动审核并同步用友
- $em = new EmployeeService();
- $auto = $em->is_auto($user, "wgsq_auto");
- try {
- DB::beginTransaction();
- //生成申请单
- $service = new ApplyOrderService();
- list($status, $msg) = $service->createSQ($insert_id, $user, ApplyOrder::type_two, $auto, $time);
- if(! $status) {
- DB::rollBack();
- return [false, $msg];
- }
- if($auto) {
- //生成流水
- list($status, $msg) = $service->createRecord($msg);
- if(! $status) {
- DB::rollBack();
- return [false, $msg];
- }
- }
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getFile() . $exception->getMessage() . $exception->getLine()];
- }
- return [true, ''];
- }
- public function saveOutOrder($data,$user){
- list($status,$msg) = $this->saveOutOrderRule($data,$user);
- if(! $status) return [false, $msg];
- $limit_key = "saveOutOrder" . $user['id'];
- list($status,$msg) = $this->limitingSendRequestBackgNeed($limit_key);
- if(! $status) return [false, '正在生成销售出库订单数据,请稍后尝试!'];
- //不超时
- ini_set('max_execution_time', 0);
- try {
- DB::beginTransaction();
- //组织数据
- $yongyou_data = $update = [];
- foreach ($data['out_data'] as $value){
- $pro_tmp = [];
- foreach ($value['product'] as $p){
- $t_k = $p['cinvcode'] . $p['cfree1'];
- $pro_tmp[$t_k] = [
- 'cinvcode' => $p['cinvcode'],
- 'cfree1' => $p['cfree1'],
- 'iquantity' => $p['iquantity'],
- 'line' => $p['line'],
- ];
- }
- if(isset($yongyou_data[$value['customer_code']])){
- $yongyou_data[$value['customer_code']]['cdlcode_string'] .= ',' . $value['cdlcode'];
- foreach ($pro_tmp as $k => $v){
- if(isset($yongyou_data[$value['customer_code']]['product'][$k])){
- $yongyou_data[$value['customer_code']]['product'][$k]['iquantity'] += $v['iquantity'];
- }else{
- $yongyou_data[$value['customer_code']]['product'][$k] = $v;
- }
- }
- }else{
- $yongyou_data[$value['customer_code']] = [
- 'customer_code' => $value['customer_code'],
- 'cdlcode_string' => $value['cdlcode'],
- 'product' => $pro_tmp
- ];
- }
- foreach ($value['box_no'] as $box_no){
- $update[$box_no] = $value['cdlcode'];
- }
- }
- if(empty($yongyou_data)) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- return [false, '暂无写入用友发货出库数据!'];
- }
- //用友 ------发货出库
- $service = new FinishedOrderService();
- list($status,$msg) = $service->U8Rdrecord32Save($yongyou_data,$user);
- if(! $status) {
- $this->dellimitingSendRequestBackgNeed($limit_key);
- return [false, $msg];
- }
- //本地数据更新
- if(! empty($update)){
- foreach ($update as $key => $value){
- Box::where('order_no', $key)->update([
- 'shipment_order_no' => $value
- ]);
- }
- }
- DB::commit();
- $this->dellimitingSendRequestBackgNeed($limit_key);
- }catch (\Throwable $exception){
- $this->dellimitingSendRequestBackgNeed($limit_key);
- DB::rollBack();
- return [false, $exception->getFile() . $exception->getFile() . $exception->getMessage()];
- }
- return [true, ''];
- }
- public function saveOutOrderRule($data,$user){
- if(empty($data['out_data'])) return [false, '未获取到发货数据,操作失败!'];
- Log::channel('sendData')->info('发货:提交包装单数据', ["param" => $data]);
- //客户校验
- $customer_code = array_column($data['out_data'],'customer_code');
- $isAllSame = count(array_unique($customer_code)) === 1;
- if(! $isAllSame) return [false, '发货出库,请选择同一个客户的订单!'];
- $box_no = array_column($data['out_data'],'box_no');
- if(empty($box_no)) return [false, '包装单信息不能为空'];
- $box_arr = [];
- foreach ($box_no as $value){
- foreach ($value as $val){
- $box_arr[] = $val;
- }
- }
- $box_map = Box::where('del_time',0)
- ->whereIn('order_no',$box_arr)
- ->pluck('shipment_order_no', "order_no")
- ->toArray();
- foreach ($box_arr as $value){
- $tmp = $box_map[$value] ?? "";
- if($tmp != "") return [false, "包装单:" . $value . "已在发货单(" . $tmp .")中发出!"];
- }
- //用友发货数据查询
- $cdlcode = array_column($data['out_data'],'cdlcode');
- $service = new FyySqlServerService($user);
- if($service->error) return [false, $service->error];
- $out_data_map = $service->getDataFromDispatchListForCheck(['cdlcode' => $cdlcode]);
- if(empty($out_data_map)) return [false, '未在用友发货数据中查找到相关数据!'];
- //数据校验
- foreach ($data['out_data'] as $value){
- if(empty($value['cdlcode'])) return [false, '发货单号不能为空!'];
- if(! isset($out_data_map[$value['cdlcode']])) return [false, '发货单号:' . $value['cdlcode'] . '不存在或已被删除!'];
- $tmp = $out_data_map[$value['cdlcode']];
- if(empty($value['customer_code'])) return [false, '客户编码不能为空!'];
- if($tmp['customer_code'] != $value['customer_code']) return [false, '客户编码与用友数据中不一致!'];
- if(empty($tmp['product'])) return [false, '发货单号:' . $value['cdlcode'] . '未查找到用友的发货产品数据!'];
- $tmp_pro = [];
- foreach ($tmp['product'] as $t){
- $t_k = $t['cinvcode'] . $t['cfree1'];
- $tmp_pro[$t_k] = bcsub($t['iquantity'] , $t['out_quantity'],3);//未发货数量
- }
- if(empty($value['product'])) return [false, '发货产品不能为空!'];
- foreach ($value['product'] as $p){
- if(empty($p['line'])) return [false, '存货行号不能为空!'];
- if(empty($p['cinvcode'])) return [false, '存货编码不能为空!'];
- if(empty($p['cfree1'])) return [false, '存货颜色不能为空!'];
- $p_k = $p['cinvcode'] . $p['cfree1'];
- if(! isset($tmp_pro[$p_k])) return [false, '发货单号:' . $value['cdlcode'] . '下无该发货产品:编码为' . $p['cinvcode'] . ',颜色为:' . $p['cfree1']];
- if(empty($p['iquantity']) || $p['iquantity'] <= 0) return [false, '发货数量不能为空!'];
- $last = $tmp_pro[$p_k];
- if($p['iquantity'] > $last) return [false, '发货单号:' . $value['cdlcode'] . '下的发货产品:编码为' . $p['cinvcode'] . ',颜色为' . $p['cfree1'] . '的未发货数量为' . $last];
- }
- }
- return [true, ''];
- }
- /**
- * 根据发货单包装(恒成塑业不需要 如果有调用 直接返回)
- * @param $data
- * @return array
- */
- public function transportBoxIn($data)
- {
- return [true,''];
- $param = $data['params'];
- $shipment_order_no = $data['transport_no'];
- $sale_order_nos = [];
- $key_list = [];
- foreach ($param as $v){
- if(!in_array($v['order_no'],$sale_order_nos)) $sale_order_nos[] = $v['order_no'];
- $key = $this->getKey($v);
- $key_list[$key] = [
- 'num' => $v['num'],
- 'order_no' => $v['order_no'],
- 'team_id' => isset($v['team_id']) ? $v['team_id'] : 0,
- ];
- }
- $sale_order_product_list = SaleOrdersProduct::wherein('out_order_no',$sale_order_nos)->get()->toArray();
- $sale_order_product_key_list = [];
- foreach ($sale_order_product_list as $v){
- $key = $this->getKey($v);
- $sale_order_product_key_list[$key] = $v['id'];
- }
- $param = [];
- foreach ($key_list as $k=>$v){
- if(!isset($sale_order_product_key_list[$k])) return [false,$k.' 不存在!'];
- $param[$v['order_no']][] = [
- 'id' => -(intval($sale_order_product_key_list[$k])),
- 'team_id' => $v['team_id'],
- 'params' => [$v['num']]
- ];
- }
- // $box_no = self::$box_hook->setOrderNo(); todo
- foreach ($param as $k=>$v){
- $top_order_no = SaleOrdersProduct::where('out_order_no',$k)->value('order_no');
- $postParam = [
- 'order_no' => $top_order_no,
- 'param' => $v,
- 'box_no' => $box_no,
- 'transport_no' => $shipment_order_no,
- ];
- $this->boxIn($postParam);
- }
- return [true,''];
- }
- protected function getKey($data){
- return $data['product_no'].'_'.$data['technology_material'].'_'.$data['technology_name'].'_'.$data['wood_name'].'_'.$data['process_mark'];
- }
- /**
- * 包装详情1用于包装前
- * @param $data
- * @return array
- */
- public function boxDetail($data)
- {
- list($status, $data) = self::$box_hook->boxDetail($data);
- if (!$status) return [false, $data];
- $return = [];
- foreach ($data as $v){
- $key = $v['ext_1'] . $v['ext_3'];
- if(! isset($return[$key])){
- $return[$key] = $v;
- }else{
- $return[$key]['num'] += $v['num'];
- }
- }
- $sale_orders_product_ids = array_unique(array_column($data,'top_id'));
- $list = SaleOrdersProduct::wherein('id',$sale_orders_product_ids)->get()->toArray();
- $key_list = [];
- foreach ($list as $v){
- $key_list[$v['id']] = $v;
- }
- foreach ($return as &$v){
- $detail = $key_list[$v['top_id']];
- $v['customer_no'] = $detail['customer_no'];
- $v['customer_name'] = $detail['customer_name'];
- }
- return [true, array_values($return)];
- }
- public function boxProductList($data){
- if(empty($data['id']) && empty($data['out_order_no'])) return [false,'请选择数据!'];
- if(! empty($data['id'])){
- $sale_order_ids = $data['id'];
- }else{
- $ids = SaleOrdersProduct::where('del_time',0)
- ->where('out_order_no','Like','%'. $data['out_order_no'] . '%')
- ->select('id')
- ->get()->toArray();
- $sale_order_ids = array_column($ids,'id');
- if(empty($sale_order_ids)) return [false, '暂无数据!'];
- }
- $model = SaleOrdersProduct::where('del_time',0)
- ->whereIn('id',$sale_order_ids)
- ->select('id','out_order_no','order_no','customer_no','customer_name','product_no','product_title','product_size','crt_time as production_time','id as sale_orders_product_id','finished_num as dispatch_complete_quantity','box_num','technology_name','wood_name','crt_time','order_quantity','technology_material','technology_name','wood_name','process_mark')
- ->orderBy('id','desc')
- ->get()->toArray();
- //原先按照完工数量 未包装 = 完工数量 - 已包数量
- $product_list = ordersProduct::where('del_time',0)
- ->whereIn('sale_orders_product_id',$sale_order_ids)->select('id','out_order_no','customer_no','customer_name','product_no','sale_orders_product_id','product_title','product_size','box_num','technology_name','wood_name','crt_time','production_quantity','dispatch_complete_quantity','technology_material','technology_name','wood_name','process_mark',"production_no")
- ->get()->toArray();
- $model_key_list = [];
- foreach ($model as $v){
- $model_key_list[$v['id']] = $v;
- }
- $model = [];
- //存在生产订单,组织数据
- if(! empty($product_list)){
- $product_key_num_list = [];
- foreach ($product_list as $v){
- //下派工数量 就是 能包的数量 相等以后 踢掉数据
- if($v['dispatch_complete_quantity'] == $v['box_num']) continue;
- if(!isset($product_key_num_list[$v['sale_orders_product_id']][$v['id']])) {
- $product_key_num_list[$v['sale_orders_product_id']][$v['id']] = [
- 'product_num' => 0 ,
- 'box_num' => 0 ,
- ];
- }
- $product_key_num_list[$v['sale_orders_product_id']][$v['id']]['product_num'] += $v['production_quantity'];
- $product_key_num_list[$v['sale_orders_product_id']][$v['id']]['box_num'] += $v['box_num'];
- $detail = $model_key_list[$v['sale_orders_product_id']];
- $detail['box_type'] = 1;
- $detail['id'] = $v['id'];
- $detail['box_num'] = $v['box_num'];
- $detail['dispatch_complete_quantity'] = $v['dispatch_complete_quantity'];
- $detail['un_box_num'] = bcsub($v['dispatch_complete_quantity'] , $v['box_num'],3);
- $detail['type'] = 1;
- $detail['production_no'] = $v['production_no'];
- $detail['production_quantity'] = $v['production_quantity'];
- $model[] = $detail;
- }
- }
- $return = [];
- foreach ($model as $v){
- if(!isset($v['box_type'])) {continue; //没有销售订单直接包了。
- $product_num = 0;
- $box_num = 0;
- if(isset($product_key_num_list[$v['id']])){
- foreach ($product_key_num_list[$v['id']] as $vv){
- $product_num += $vv['product_num'];
- $box_num += $vv['box_num'];
- }
- }
- if(($v['order_quantity'] - $product_num) === 0) continue;
- $product_key_list[$v['sale_orders_product_id']] = [
- 'out_order_no' => $v['out_order_no'],
- 'order_no' => $v['order_no'],
- 'production_no' => "",
- 'production_time' => '未下生产',
- 'customer_no' => $v['customer_no'],
- 'customer_name' => $v['customer_name'],
- 'product_no' => $v['product_no'],
- 'product_title' => $v['product_title'],
- 'product_size' => $v['product_size'],
- 'id' => -$v['sale_orders_product_id'],
- 'technology_material' => $v['technology_material'],
- 'technology_name' => $v['technology_name'],
- 'wood_name' => $v['wood_name'],
- 'process_mark' => $v['process_mark'],
- 'type' => '2',
- 'is_box_num' => $v['box_num'] - $box_num,
- 'un_box_num' => $v['order_quantity'] - ($v['box_num'] - $box_num) - $product_num,
- 'sale_num' => $v['order_quantity'],
- ];
- }else{
- $return[] = [
- 'id' => $v['id'],
- 'technology_material' => $v['technology_material'],
- 'technology_name' => $v['technology_name'],
- 'wood_name' => $v['wood_name'],
- 'order_no' => $v['order_no'],
- 'production_no' => $v['production_no'],
- 'process_mark' => $v['process_mark'],
- 'out_order_no' => $v['out_order_no'],
- 'production_time' => date('Y-m-d',$v['crt_time']),
- 'customer_no' => $v['customer_no'],
- 'customer_name' => $v['customer_name'],
- 'product_no' => $v['product_no'],
- 'product_title' => $v['product_title'],
- 'product_size' => $v['product_size'],
- 'type' => '1',
- 'is_box_num' => $v['box_num'],
- 'un_box_num' => $v['un_box_num'],
- 'sale_num' => $v['order_quantity'],
- 'production_num' => $v['production_quantity'],
- 'dispatch_complete_quantity' => $v['dispatch_complete_quantity']
- ];
- }
- }
- return [true,$return];
- }
- /**
- * 包装详情2用于包装后
- * @param $data
- * @return array
- */
- public function boxOrderDetail($data)
- {
- list($status, $data) = self::$box_hook->boxDetail($data);
- $sale_orders_product_ids = [];
- foreach ($data as $v){
- $sale_orders_product_ids[] = $v['top_id'];
- }
- $list = SaleOrdersProduct::wherein('id',$sale_orders_product_ids)->get()->toArray();
- $key_list = [];
- foreach ($list as $v){
- $key_list[$v['id']] = $v;
- }
- foreach ($data as &$v){
- $v['ext_3'] = $key_list[$v['top_id']]['product_no'];
- $v['wood_name'] = $key_list[$v['top_id']]['wood_name'];
- $v['technology_name'] = $key_list[$v['top_id']]['technology_name'];
- $v['process_mark'] = $key_list[$v['top_id']]['process_mark'];
- $v['technology_material'] = $key_list[$v['top_id']]['technology_material'];
- }
- if (!$status) return [false, $data];
- return [true, $data];
- }
- /**
- * 通过销售单号获取包装单
- * @param $data
- * @return array
- */
- public function boxOrderDetailByTop($data){
- $list = new Box();
- if(isset($data['top_order_no'])&&!empty($data['top_order_no'])) $list = $list->wherein('top_order_no',$data['top_order_no']);
- if(isset($data['transport_no'])&&!empty($data['transport_no'])) $list = $list->wherein('shipment_order_no',$data['transport_no']);
- // if(isset($data['top_order_no'])) $list = $list->wherein('top_order_no',$data['top_order_no']);
- // if(isset($data['transport_no'])) $list = $list->wherein('shipment_order_no',$data['transport_no']);
- $list = $list->select('top_order_no','order_no','crt_time')->where('del_time',0)->groupBy('order_no')->get()->toArray();
- return [true,$list];
- }
- /**
- * 通过包装单获取包装详情
- * @param $data
- * @return array
- */
- public function boxOrderDetailByOrderNo($data){
- $order_nos = $data['order_nos'];
- $order_nos = array_unique($order_nos);
- $list = Box::where('del_time',0)->wherein('order_no',$order_nos)->select('order_no','out_order_no','top_order_no','shipment_order_no as transport_no')->get()->toArray();
- $detail_list = [];
- foreach ($list as $v){
- $model = new BoxDetail(['channel'=>$v['top_order_no']]);
- $detail_list = array_merge($detail_list,$model->where('order_no',$v['order_no'])->where('top_order_no',$v['top_order_no'])->get()->toArray());
- }
- $list = $detail_list;
- $ids = [];
- foreach ($list as $v){
- $ids[] = $v['top_id'];
- }
- $sale_orders_product = SaleOrdersProduct::wherein('id',$ids)->get()->toArray();
- $sale_orders_key_product = [];
- foreach ($sale_orders_product as $v){
- $sale_orders_key_product[$v['id']] = $v;
- }
- $team_key_list = Team::pluck('title','id')->toArray();
- foreach ($list as &$v){
- $detail = $sale_orders_key_product[$v['top_id']];
- $v['customer_name'] = $detail['customer_name'];
- $v['table_body_mark'] = $detail['table_body_mark'];
- $v['ext_4'] = $detail['product_title'];
- $v['ext_5'] = $detail['product_size'];
- $v['customer_name'] = $detail['customer_name'];
- $v['technology_material'] = $detail['technology_material'];
- $v['transport_no'] = $v['shipment_order_no'];
- $v['wood_name'] = $detail['wood_name'];
- $v['team_name'] = isset($team_key_list[$v['team_id']]) ? $team_key_list[$v['team_id']] : '' ;
- }
- return [true,$list];
- }
- public function boxOrderGroup($data){
- $list = new Box();
- if(empty($data['top_order_no']) && empty($data['transport_no'])) return [false,'请输入单号!'];
- if(! empty($data['top_order_no'])) $list = $list->whereIn('top_order_no',$data['top_order_no']);
- if(! empty($data['transport_no'])) {
- if(is_array($data['transport_no'])){
- $list = $list->whereIn('shipment_order_no',$data['transport_no']);
- }else{
- $list = $list->where('shipment_order_no','Like','%'. $data['transport_no'] . '%');
- }
- }
- $list = $list->select('top_order_no','order_no as box_no','crt_time','shipment_order_no','out_order_no')->where('del_time',0)
- ->get()->toArray();
- foreach ($list as $key => $value){
- $model = new BoxDetail(['channel'=> $value['top_order_no']]);
- $tmp = $model->where('del_time',0)
- ->where('order_no',$value['box_no'])
- ->where('out_order_no',$value['out_order_no'])
- ->select('order_no','out_order_no','orders_product_id')
- ->first();
- $production_no = "";
- if(! empty($tmp)){
- $production_no = OrdersProduct::where('id',$tmp->orders_product_id)->select('production_no')->pluck('production_no')->toArray();
- $production_no = $production_no[0];
- }
- $list[$key]['production_no'] = $production_no;
- $list[$key]['crt_time'] = date('Y-m-d H:i:s',$value['crt_time']);
- }
- return [true,$list];
- }
- public function boxOrderGroupGwp($data){
- $out_order_no = $data['out_order_no'] ?? "";
- $model = Box::where('del_time',0)
- ->when(! empty($out_order_no), function ($query) use ($out_order_no) {
- return $query->where('out_order_no','Like','%'. $out_order_no . '%');
- })
- ->select('out_order_no','ext_1','top_order_no','order_no','crt_time','shipment_order_no',DB::raw("count(id) as package_num"))
- ->groupBy('out_order_no');
- $list = $this->limit($model,'',$data);
- $list = $this->fillData($list);
- return [true, $list];
- }
- public function fillData($data){
- if(empty($data['data'])) return $data;
- foreach ($data['data'] as $key => $value){
- $model = new BoxDetail(['channel'=> $value['top_order_no']]);
- $tmp = $model->where('del_time',0)
- ->where('out_order_no',$value['out_order_no'])
- ->select('num')
- ->get()->toArray();
- $data['data'][$key]['num'] = $this->getTotal($tmp, 'num');
- }
- return $data;
- }
- public function boxOrderGroupGwpDetail($data){
- if(empty($data['top_order_no']) || empty($data['out_order_no'])) return [false, '请选择数据!'];
- $top_order_no = $data['top_order_no'];
- $model = new BoxDetail(['channel'=> $top_order_no]);
- $detail_list = $model->where('del_time',0)
- ->where('out_order_no',$data['out_order_no'])
- ->get()->toArray();
- $map = Box::whereIn('order_no',array_unique(array_column($detail_list,'order_no')))
- ->pluck('ext_1','order_no')
- ->toArray();
- $return = [];
- foreach ($detail_list as $value){
- //销售订单号 包装单号 产品编码 颜色
- $key = $value['out_order_no'] . $value['order_no'] . $value['ext_1'] . $value['ext_3'];
- if(isset($return[$key])){
- $return[$key]['num'] += $value['num'];
- }else{
- $return[$key] = [
- 'box_no' => $value['order_no'],
- 'out_order_no' => $value['out_order_no'],
- 'ext_8' => $value['ext_8'],
- 'ext_3' => $value['ext_3'],
- 'num' => $value['num'],
- 'crt_time' => date("Y-m-d",$value['crt_time']),
- 'top_order_no' => $value['top_order_no'],
- 'customer_name' => $map[$value['order_no']] ?? "",
- ];
- }
- }
- return [true, array_values($return)];
- }
- public function transportNo(){
- $list = Box::where('del_time',0)->where('shipment_order_no','<>','')->groupBy('shipment_order_no')->pluck('shipment_order_no')->toArray();
- return [true,$list];
- }
- public function delBoxDetail($data){
- if(empty($data['order_nos'])) return [false, '请选择包装单!'];
- $order_nos = $data['order_nos'];
- try {
- DB::beginTransaction();
- //更新销售订单 生产订单数据
- $orders_product_id_map = [];
- foreach ($order_nos as $v){
- $list = self::$box_hook->delBox($v);
- if(empty($list)) continue;
- foreach ($list as $vv){
- SaleOrdersProduct::where('id',$vv['top_id'])->update([
- 'box_num' => DB::raw('box_num - '.$vv['num']),
- 'finished_num' => DB::raw('finished_num - '.$vv['num'])
- ]);
- OrdersProduct::where('id',$vv['orders_product_id'])->update([
- 'box_num' => DB::raw('box_num - '.$vv['num']),
- 'finished_num' => DB::raw('finished_num - '.$vv['num'])
- ]);
- if(isset($orders_product_id_map[$vv['orders_product_id']])){
- $num = bcadd($orders_product_id_map[$vv['orders_product_id']], $vv['num'],3);
- $orders_product_id_map[$vv['orders_product_id']] = $num;
- }else{
- $orders_product_id_map[$vv['orders_product_id']] = $vv['num'];
- }
- }
- }
- //更新完工数据 和 底表数据
- list($status,$msg) = $this->updateFinishDel($orders_product_id_map);
- if(! $status) return [false, $msg];
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getMessage()];
- }
- return [true, ''];
- }
- public function updateFinishDel($orders_product_id_map){
- if(empty($orders_product_id_map)) return [true,''];
- $production_list = array_keys($orders_product_id_map);
- $dispatch = $this->getDispatch($production_list, $orders_product_id_map);
- if(empty($dispatch)) return [true,''];
- try {
- DB::beginTransaction();
- //根据派工数据回写
- foreach ($dispatch as $value){
- $finished_num = bcsub($value['finished_num'], $value['out_number'],3);
- DispatchSub::where('id',$value['id'])->update([
- 'finished_num' => $finished_num
- ]);
- $quantity = $value['out_number'] * 1000;
- //工序表
- $process_model = new OrdersProductProcess(['channel' => date("Ymd",$value['out_order_no_time'])]);
- $process_model->where('order_product_id',$value['order_product_id'])
- ->where('process_id',$value['process_id'])
- ->where('dispatch_no',$value['dispatch_no'])
- ->where('status', 2)
- ->take($quantity)
- ->update([
- 'finished_time' => 0,
- 'status' => 1,
- 'finished_id' => 0,
- 'team_id' => 0,
- 'equipment_id' => 0,
- ]);
- }
- DB::commit();
- }catch (\Throwable $exception){
- DB::rollBack();
- return [false, $exception->getLine().':'.$exception->getMessage() . ':' . $exception->getFile()];
- }
- return [true, ''];
- }
- public function getDispatch($order_product_id,$map){
- $order = OrdersProduct::where('del_time',0)
- ->where('id', $order_product_id)
- ->select('id', 'process_id')
- ->get()->toArray();
- $order_map = [];
- foreach ($order as $value){
- $order_map[$value['id']] = explode(',', $value['process_id']);
- }
- //组织派工数据
- $dispatch = DispatchSub::where('del_time',0)
- ->whereIn('order_product_id', $order_product_id)
- ->where('finished_num','>',0)
- ->get()->toArray();
- if(empty($dispatch)) return [];
- $dispatch_map = [];
- foreach ($dispatch as $value){
- $key = $value['order_product_id'] . '|' . $value['crt_time']; //同一次下的派工单
- $dispatch_map[$key][] = $value;
- }
- $result = []; $tmp = [];
- foreach ($dispatch_map as $key => $value){
- foreach ($value as $v){
- $process = $order_map[$v['order_product_id']] ?? [];
- $num = $map[$v['order_product_id']];
- if(in_array($v['process_id'], $process)){
- $str = $v['order_product_id'] . $v['process_id'];
- $tmp_v = $tmp[$str] ?? 0;
- $num = bcsub($num, $tmp_v,3);
- if($num <= 0) continue;
- if($v['finished_num'] >= $num){
- $v['out_number'] = $num;
- $result[] = $v;
- }else{
- $v['out_number'] = $v['finished_num'];
- $result[] = $v;
- }
- if(isset($tmp[$str])){
- $num = bcadd($tmp[$str], $v['out_number'],3);
- $tmp[$str] = $num;
- }else{
- $tmp[$str] = $v['out_number'];
- }
- }
- }
- }unset($tmp);
- return $result;
- }
- public function boxAdd($data)
- {
- list($status,$msg) = $this->boxAddRule($data);
- if(! $status) return [false,$msg];
- try{
- DB::beginTransaction();
- $box = new Box();
- $box->order_no = $msg['order_no'];
- $box->save();
- DB::table('box_detail')->insert($msg['detail']);
- DB::commit();
- return [true,''];
- }catch (\Exception $e){
- DB::rollBack();
- return [false,$e->getLine().':'.$e->getMessage()];
- }
- }
- public function boxAddRule($data)
- {
- if(empty($data['param'])) return [false,'请选择包装数据'];
- // $order_no = (new BoxHookService())->setOrderNo();
- $order_no = "";
- if(empty($order_no)) return [false,'包装单号不能为空'];
- $detail = [];
- foreach ($data['param'] as $value) {
- $key = $this->lock_key.'_'.$value['idlsid'];
- list($status,$msg) = $this->limitingSendRequestBackg($key);
- if(! $status) return [false,$msg];
- // if(empty($value['submit_quantity']) || ! is_numeric($value['submit_quantity']) || $value['submit_quantity'] > $value['quantity']) return [false,'包装数量错误'];
- if(empty($value['team_id'])) return [false,'班组必须选择'];
- $tmp = $value;
- $tmp['iquantity'] = $value['submit_quantity'];
- $detail[] = [
- 'order_no' => $order_no,
- 'out_order_no' => $value['csocode']??'',
- 'crt_time' => time(),
- 'upd_time' => time(),
- 'type' => 1,
- 'ext_1' => $value['cinvcode'],
- 'ext_2' => $value['technology_material'],
- 'ext_3' => $value['cfree1'] ?? "",
- 'ext_4' => $value['cfree2'] ?? "",
- 'ext_5' => $value['process_mark'],
- 'ext_6' => $value['customer_name'] ?? "",
- 'ext_7' => $value['cuscode'] ?? "",
- 'ext_8' => $value['product_title'],
- 'ext_9' => $value['product_size'],
- 'ext_10' => $value['table_header_mark'],
- 'ext_11' => $value['table_body_mark'],
- 'top_id' => $value['idlsid'],
- 'state' => 0,
- 'num' => $value['submit_quantity'],
- 'box_type' => 2,
- 'team_id' => $value['team_id'],
- 'shipment_order_no' => $value['cdlcode'],
- 'post' => json_encode($tmp),
- ];
- }
- return [true,['order_no' => $order_no, 'detail' => $detail]];
- }
- public function boxFhDetail($data){
- if(empty($data['idlsid'])) return [false,'请选择数据'];
- $result = DB::table('box_detail')->where('del_time',0)
- ->where('top_id',$data['idlsid'])
- ->select('order_no','ext_6','ext_7','ext_1','ext_8','ext_9','num','ext_2','ext_3','ext_4','ext_5','ext_10','ext_11')
- ->get()->toArray();
- if(! empty($result)){
- foreach ($result as $key => $value){
- $result[$key] = (array)$value;
- }
- }
- return [true,$result];
- }
- public function boxFhDel($data){
- if(empty($data['order_nos'])) return [false,'包装单号不能为空'];
- $box = Box::whereIn('order_no',$data['order_nos'])->update(['del_time' => time()]);
- DB::table('box_detail')->whereIn('order_no',$data['order_nos'])->where('del_time',0)->update([
- 'del_time' => time()
- ]);
- return [true,''];
- }
- public function transportDetail($data){
- if(empty($data['order_nos'])) return [false,'包装单号不能为空'];
- $order_nos = $data['order_nos'];
- $list = BoxDetail::wherein('order_no',$order_nos)->select('ext_1','ext_2','ext_3','ext_4','ext_5','ext_6','ext_7','ext_8','ext_9','num','order_no','shipment_order_no','post')->get()->toArray();
- foreach ($list as &$v){
- $v['product_no'] = $v['ext_1'];
- $v['technology_material'] = $v['ext_2'];
- $v['technology_name'] = $v['ext_3'];
- $v['wood_name'] = $v['ext_4'];
- $v['process_mark'] = $v['ext_5'];
- $v['customer_no'] = $v['ext_6'];
- $v['customer_name'] = $v['ext_7'];
- $v['product_title'] = $v['ext_8'];
- $v['product_size'] = $v['ext_9'];
- $v['post'] = json_decode($v['post'],true);
- }
- return [200,$list];
- }
- public function boxFhBzDetail($data){
- if(empty($data['order_no'])) return [false,'请选择包装单数据'];
- $result = DB::table('box_detail')->where('del_time',0)
- ->whereIn('order_no',$data['order_no'])
- ->select('order_no','ext_6','ext_7','ext_1','ext_8','ext_9','num','ext_2','ext_3','ext_4','ext_5','shipment_order_no','crt_time','team_id','ext_10','ext_11')
- ->get()->toArray();
- if(! empty($result)){
- foreach ($result as $key => $value){
- $result[$key] = (array)$value;
- }
- $map = Team::where('id',array_unique(array_column($result,'team_id')))->pluck('title','id')->toArray();
- foreach ($result as $key => $value){
- $result[$key]['team_name'] = $map[$value['team_id']] ?? '';
- }
- }
- return [true,$result];
- }
- public function boxFhBzList($data){
- if(empty($data['shipment_order_no'])) return [false, '请输入发货单号'];
- $model = DB::table('box_detail')->where('del_time',0)
- ->where('shipment_order_no','LIKE', '%'.$data['shipment_order_no'].'%')
- ->select('order_no','crt_time','shipment_order_no');
- $return = [];
- $result = $model->get()->toArray();
- if(! empty($result)){
- foreach ($result as $value){
- $return[$value->order_no] = [
- 'order_no' => $value->order_no,
- 'shipment_order_no' => $value->shipment_order_no,
- 'crt_time' => date("Y-m-d H:i:s",$value->crt_time)
- ];
- }
- }
- return [true,array_values($return)];
- }
- public function boxOrderDetailByOrderNoNew($data){
- if(empty($data['order_nos'])) return [false, '包装单号不能为空'];
- $order_nos = $data['order_nos'];
- $order_nos = array_unique($order_nos);
- Log::channel('sendData')->info('发货:扫码包装单数据', ["param" => $order_nos]);
- $list = Box::where('del_time',0)
- ->whereIn('order_no',$order_nos)
- ->where('shipment_order_no','')
- ->select('order_no','out_order_no','top_order_no','shipment_order_no as transport_no','upd_time')
- ->get()->toArray();
- $detail_list = [];
- foreach ($list as $v){
- // if(! empty($v['transport_no'])) return [false, "包装单号:" . $v['order_no'] . "已在发货单(" . $v['transport_no'] .")中发出!"];
- $model = new BoxDetail(['channel'=>$v['top_order_no']]);
- $detail_list = array_merge($detail_list,$model->where('order_no',$v['order_no'])->where('top_order_no',$v['top_order_no'])->get()->toArray());
- }
- $return = [];
- foreach ($detail_list as $value){
- //销售订单号 产品编码 颜色
- $return[] = [
- 'ext_1' => $value['ext_1'],
- 'ext_3' => $value['ext_3'],
- 'ext_8' => $value['ext_8'],
- 'num' => $value['num'],
- 'out_order_no' => $value['out_order_no'],
- 'box_no' => $value['order_no']
- ];
- }
- return [true, array_values($return)];
- }
- public function boxList($data,$user){
- $model = Box::where('del_time',0)
- ->select('id','order_no','out_order_no','top_order_no','crt_time','status','shipment_order_no')
- ->orderBy('id','desc');
- if(! empty($data['order_no'])) $model->where('order_no', 'LIKE', '%'.$data['order_no'].'%');
- if(! empty($data['shipment_order_no'])) $model->where('shipment_order_no', 'LIKE', '%'.$data['shipment_order_no'].'%');
- if(! empty($data['out_order_no'])) $model->where('out_order_no', 'LIKE', '%'.$data['out_order_no'].'%');
- if(! empty($data['crt_time'][0]) && ! empty($data['crt_time'][1])) $model->whereBetween('crt_time',[$data['crt_time'][0],$data['crt_time'][1]]);
- if(isset($data['status'])) $model->where('status',$data['status']);
- $list = $this->limit($model,'',$data);
- $list = $this->fillBoxListData($list, $data,$user);
- return [true, $list];
- }
- public function fillBoxListData($data, $erg,$user){
- if(empty($data['data'])) return $data;
- $product = $material = [];
- if(! empty($erg['box'])){
- //获取包装单里的产品
- $id = array_column($data['data'], 'id');
- list($product,$product_no) = $this->getBoxDetail($id);
- if(! empty($erg['box_material'])){
- //产品的包装材料
- $service = new FyyOrderService();
- list($status, $msg) = $service->getProductBzDataFromSqlServer(['product_no' => $product_no], $user);
- if($status) $material = $msg;
- }
- }
- foreach ($data['data'] as $key => $value){
- $data['data'][$key]['crt_time'] = $value['crt_time'] ? date('Y-m-d H:i:s',$value['crt_time']) : '';
- $data['data'][$key]['status_title'] = Box::$status_name[$value['status']] ?? "";
- $p = $product[$value['id']] ?? [];
- if(! empty($p)){
- foreach ($p as $k => $v){
- $p[$k]['box_material'] = $material[$v['product_no']] ?? [];
- }
- }
- $data['data'][$key]['product'] = $p;
- }
- return $data;
- }
- public function getBoxDetail($id = []){
- $return = $product_no= [];
- if(empty($id)) return [$return,$product_no];
- $box = Box::where('del_time',0)
- ->whereIn('id', $id)
- ->select('id', 'order_no','top_order_no')
- ->get()->toArray();
- if (empty($box)) return [$return,$product_no];
- $map = array_column($box,'id','order_no');
- $result = [];
- foreach ($box as $v){
- $model = new BoxDetail(['channel'=>$v['top_order_no']]);
- $result = array_merge($result,$model->where('del_time',0)
- ->where('order_no',$v['order_no'])
- ->select('order_no', 'ext_1 as product_no', 'ext_8 as product_title', 'ext_9 as product_size','num as quantity','ext_3 as technology_name')->get()->toArray());
- }
- foreach ($result as $value){
- $value['id'] = $map[$value['order_no']] ?? 0;
- $value['product_unit'] = "吨";
- $return[$value['id']][] = $value;
- if(! in_array($value['product_no'], $product_no)) $product_no[] = $value['product_no'];
- }
- return [$return, $product_no];
- }
- public function searchDetail($data){
- $out_order_no = $data['out_order_no'] ?? '';
- $box = Box::where('del_time',0)
- ->where('out_order_no', 'LIKE', '%'. $out_order_no .'%')
- ->select('top_order_no')
- ->get()->toArray();
- if(empty($box)) return [];
- $order_no = [];
- foreach ($box as $value){
- $model = new BoxDetail(['channel'=> $value['top_order_no']]);
- $result = $model->where('del_time',0)
- ->where('order_no',$box['order_no'])
- ->select('order_no')
- ->get()->toArray();
- $detail_list = array_merge($order_no, array_column($result, 'order_no'));
- }
- $result = BoxDetail::where('del_time',0)
- ->when(! empty($out_order_no), function ($query) use ($out_order_no) {
- return $query->where('out_order_no', 'LIKE', '%'. $out_order_no .'%');
- })
- ->when(! empty($shipment_order_no), function ($query) use ($shipment_order_no) {
- return $query->where('shipment_order_no', 'LIKE', '%'. $shipment_order_no .'%');
- })
- ->select('order_no')
- ->get()->toArray();
- return array_unique(array_column($result,'order_no'));
- }
- public function boxFhDetailNew($data){
- if(empty($data['id'])) return [false,'请选择数据'];
- $box = Box::where('id', $data['id'])->where('del_time',0)->first();
- if(empty($box)) return [false, '包装单不存在或已被删除'];
- $box = $box->toArray();
- $model = new BoxDetail(['channel'=>$box['top_order_no']]);
- $result = $model->where('del_time',0)
- ->where('order_no',$box['order_no'])
- ->select('order_no', 'ext_1 as product_no', 'ext_8 as product_title', 'ext_9 as product_size','num as quantity','ext_3 as technology_name','out_order_no')->get()->toArray();
- foreach ($result as $key => $value){
- $result[$key]['product_unit'] = "吨";
- }
- return [true,$result];
- }
- }
|