xky/app/Jobs/ProcessDataJob.php

<?php

namespace App\Jobs;

use App\Model\DDEmployee;
use App\Model\Inventory;
use App\Model\Record;
use App\Model\U8State;
use App\Model\Vendor;
use App\Service\U8DatabaseServerService;
use App\Service\U8ThirdPartyService;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Symfony\Component\Console\Output\ConsoleOutput;
use Symfony\Component\Console\Output\OutputInterface;

class ProcessDataJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $data;
    public $timeout = 30;

    public function __construct($data)
    {
        //record表
        $this->data = $data;
    }

    public function handle()
    {
        try {
            list($bool, $msg) = $this->syncApprovedRecords($this->data);
            if(! $bool) $this->finalDo($msg, $this->data);
        } catch (\Throwable $e) {
            $this->finalDo("异常：" . $e->getMessage());
            $this->delete();
        }
    }

    private function finalDo($msg, $record){
        //进入到队列的数据 都是审核通过的  但是业务有没有成功就是另一回事
        Record::where('id', $record['id'])
            ->update(['result' => $msg]);
        U8State::where('del_time',0)
            ->where('type', $record['type'])
            ->where('login_type', $record['login_type'])
            ->where('order_number', $record['order_number'])
            ->update(['state' => U8State::state_one, 'result' => $msg]);
    }

    private function syncApprovedRecords1($record)
    {
        try {
            $LoginType = $record['login_type'];
            $database = $record['database'];

            $service = new U8DatabaseServerService(['zt_database' => $database]);
            if ($service->error) return [false, $service->error];

            $time = date("Y-m-d H:i:s");
            $time1 = date("Y-m-d 00:00:00");

            if($record['del_time'] == 2){
                $type = $record['type'];
                $order_number = $record['order_number'];
                $system_name = "system";
                $name = DDEmployee::where('userid', $record['userid'])->where('login_type', $LoginType)->value('name');
                if(! empty($name)) $system_name = $name;

                if($type == Record::type_one){
                    $service->db->table("PO_Pomain")
                        ->where("cPOID", $order_number)
                        ->update([
                            "cVerifier" => $system_name,
                            "iverifystateex" => 1,
                            "cState" => 1,
                            "cAuditTime" => $time . ".000",
                            "cAuditDate" => $time1 . ".000",
                        ]);
                }elseif($type == Record::type_two){
                    $service->db->table("PU_AppVouch")
                        ->where("cCode", $order_number)
                        ->update([
                            "iverifystateex" => 2,
                            "cVerifier" => $system_name,
                            "cAuditTime" => $time . ".000",
                            "cAuditDate" => $time1 . ".000",
                        ]);
                }elseif($type == Record::type_three){
                    $service->db->table("RdRecord01")
                        ->where("cCode", $order_number)
                        ->update([
                            "cHandler" => $system_name,
                            "dnverifytime" => $time . ".000",
                            "dVeriDate" => $time1 . ".000",
                        ]);
                }elseif($type == Record::type_four){
                    list($status, $msg) = $this->inventoryAddToU8($record, $name, $service->db);
                    if(! $status) return [false, $msg];
                }elseif($type == Record::type_five){
                    list($status, $msg) = $this->vendorAddToU8($record, $name, $service->db);
                    if(! $status) return [false, $msg];
                }

                // 更新本地数据 通过状态
                Record::where("id", $record['id'])->update(['del_time' => 3]);

                // 更新状态为 通过状态
                U8State::updateOrCreate(
                    ['order_number' => $record['order_number'], 'login_type' => $record['login_type'], 'type' => $record['type']],
                    ['state' => U8State::state_one]
                );
            }

            $service->close();
        } catch (\Throwable $e) {
            return [false, $e->getMessage()];
        }

        return [true, ''];
    }

    private function syncApprovedRecords($record)
    {
        try {
            $LoginType = $record['login_type'];
            $database = $record['database'];

            $service = new U8DatabaseServerService(['zt_database' => $database]);
            if ($service->error) return [false, $service->error];
            $service2 = new U8ThirdPartyService();

            $time = date("Y-m-d H:i:s");
            $time1 = date("Y-m-d 00:00:00");

            if($record['del_time'] == 2){
                $type = $record['type'];
                $order_number = $record['order_number'];
                $system_name = "system";
                $name = DDEmployee::where('userid', $record['userid'])->where('login_type', $LoginType)->value('name');
                if(! empty($name)) $system_name = $name;

                if($type == Record::type_one){
                    list($status, $msg) = $service2->poPomain($record);
                    if(! $status) return [false, $msg];
                }elseif($type == Record::type_two){
                    list($status, $msg) = $service2->puAppVouch($record);
                    if(! $status) return [false, $msg];
                }elseif($type == Record::type_three){
                    list($status, $msg) = $service2->purchaseInAdd($record);
                    if(! $status) return [false, $msg];
                }elseif($type == Record::type_four){
                    list($status, $msg) = $this->inventoryAddToU8($record, $name, $service->db);
                    if(! $status) return [false, $msg];
                }elseif($type == Record::type_five){
                    list($status, $msg) = $this->vendorAddToU8($record, $name, $service->db);
                    if(! $status) return [false, $msg];
                }

                // 更新本地数据 通过状态
                Record::where("id", $record['id'])->update(['del_time' => 3]);

                // 更新状态为 通过状态
                U8State::updateOrCreate(
                    ['order_number' => $record['order_number'], 'login_type' => $record['login_type'], 'type' => $record['type']],
                    ['state' => U8State::state_one]
                );
            }

            $service->close();
        } catch (\Throwable $e) {
            return [false, $e->getMessage()];
        }

        return [true, ''];
    }

    public function inventoryAddToU8($data, $username, $service)
    {
        // 1. 获取本地存货记录
        $inventory = Inventory::where('del_time', 0)
            ->where('order_number', $data['order_number'])
            ->where('login_type', $data['login_type'])
            ->first();

        if (empty($inventory)) {
            return [false, '本地存货记录不存在或已被删除'];
        }
        $inventory = $inventory->toArray();

        // 2. 提取核心属性变量
        $bSale     = (int)($inventory['bSale'] ?? 0);
        $bExpSale  = (int)($inventory['bExpSale'] ?? 0);
        $bPurchase = (int)($inventory['bPurchase'] ?? 0);
        $bSelf     = (int)($inventory['bSelf'] ?? 0);
        $bComsume  = (int)($inventory['bComsume'] ?? 0);
        $bProxy    = (int)($inventory['bProxy'] ?? 0);

        // --- 用友业务规则动态计算 ---
        $iPlanDefault = $bSelf ? 1 : ($bProxy ? 2 : ($bPurchase ? 3 : 0));
        $bBomMain     = ($bSelf || $bProxy) ? 1 : 0;
        $bBomSub      = ($bSelf || $bProxy || $bPurchase || $bComsume) ? 1 : 0;
        $bProductBill = $bSelf ? 1 : 0;
        $cPlanMethod  = 'R';
        $bInTotalCost = 1;
        if (!$bSale && !$bExpSale && !$bComsume && $bBomSub) {
            $cPlanMethod = 'N';
            $bInTotalCost = 0;
        }

        // 3. 编码生成逻辑
        $category_code = $inventory['category_code'];
        $serialInfo = null;
        if (!empty($data['code'])) {
            $no = $data['code'];
            $flag_title = "重填";
        } else {
            list($status, $res) = $this->generate('inventory', $category_code, $service);
            if (!$status) return [false, "生成存货编码失败: " . $res];
            $no = $res['finalCode'];
            $serialInfo = $res;
            $flag_title = "重试";
        }

        // 4. 构建 Inventory 主表数据
        $inventoryData = [
            'cInvCode'          => $no,
            'cInvName'          => $inventory['title'],
            'cInvCCode'         => $category_code,
            'cInvStd'           => $inventory['size'] ?? null,
            'bSale'             => $bSale,
            'bExpSale'          => $bExpSale,
            'bPurchase'         => $bPurchase,
            'bSelf'             => $bSelf,
            'bComsume'          => $bComsume,
            'bProxyForeign'     => $bProxy,
            'iGroupType'        => $inventory['unit_group_type'],
            'cGroupCode'        => $inventory['unit_group_code'],
            'cComUnitCode'      => $inventory['unit_code'],
            'cShopUnit'         => $inventory['unit_code'],
            'iImpTaxRate'       => $inventory['iImpTaxRate'],
            'iTaxRate'          => $inventory['iTaxRate'],
            'dSDate'            => date("Y-m-d 00:00:00.000"),
            'cEnterprise'       => $inventory['vendor_code_title'] ?? null,
            'iSupplyType'       => '0',
            'fConvertRate'      => '1.0',
            'bInTotalCost'      => $bInTotalCost,
            'cPlanMethod'       => $cPlanMethod,
            'cSRPolicy'         => 'PE',
            'bBomMain'          => $bBomMain,
            'bBomSub'           => $bBomSub,
            'bProductBill'      => $bProductBill,
            'iPlanDefault'      => $iPlanDefault,
            'iAllocatePrintDgt' => '4',
            'bService'          => '0',
            'bAccessary'        => '0',
            'iInvAdvance'       => '0.0',
            'bInvQuality'       => '0',
            'bInvBatch'         => '0',
            'bInvEntrust'       => '0',
            'bInvOverStock'     => '0',
            'cCreatePerson'     => $username,
            'dModifyDate'       => date("Y-m-d H:i:s.000"),
            'bPlanInv'          => '0',
            'bATOModel'         => '0',
            'bPTOModel'         => '0',
            'bMPS'              => ($iPlanDefault == 1 || $iPlanDefault == 2) ? '1' : '0',
            'bROP'              => '0',
            'bRePlan'           => '0',
            'bCutMantissa'      => '0',
            'bCheckBSATP'       => '0',
            'iCheckATP'         => '0',
            'bFree1' => '0', 'bFree2' => '0', 'bFree3' => '0', 'bFree4' => '0', 'bFree5' => '0',
            'bFree6' => '0', 'bFree7' => '0', 'bFree8' => '0', 'bFree9' => '0', 'bFree10' => '0',
            'bConfigFree1' => '0', 'bConfigFree2' => '0', 'bConfigFree3' => '0', 'bConfigFree4' => '0',
            'bConfigFree5' => '0', 'bConfigFree6' => '0', 'bConfigFree7' => '0', 'bConfigFree8' => '0',
            'bConfigFree9' => '0', 'bConfigFree10' => '0',
        ];

        // 5. 构建 Inventory_sub 表数据
        $inventorySubData = [
            'cInvSubCode'        => $no,
            'iSurenessType'      => '1',
            'bIsAttachFile'      => '0',
            'bInByProCheck'      => '1',
            'iRequireTrackStyle' => '0',
            'iExpiratDateCalcu'  => '0',
            'iBOMExpandUnitType' => '1',
            'iDrawType'          => $inventory['iDrawType'] ?? 0,
            'fInvCIQExch'        => $inventory['customs_change_rate'] ?? 1,
            'bInvKeyPart'        => '1',
            'iAcceptEarlyDays'   => '999',
            'dInvCreateDatetime' => date("Y-m-d H:i:s.000"),
            'bPUQuota'           => '0',
            'bInvROHS'           => '0',
            'bPrjMat'            => '0',
            'bInvAsset'          => '0',
            'bSrvProduct'        => '0',
            'iAcceptDelayDays'   => '0',
            'bSCkeyProjections'  => '0',
            'iSupplyPeriodType'  => '1',
            'iAvailabilityDate'  => '1',
            'bImport'            => '0',
            'bCheckSubitemCost'  => '1',
            'fRoundFactor'       => '0.0',
            'bConsiderFreeStock' => '1',
            'bSuitRetail'        => '0',
            'bFeatureMatch'      => '0',
            'bProduceByFeatureAllocate' => '0',
            'bMaintenance'       => '0',
            'iMaintenanceCycleUnit'     => '0',
            'bCoupon'            => '0',
            'bStoreCard'         => '0',
            'bProcessProduct'    => '0',
            'bProcessMaterial'   => '0',
            'bPurPriceFree1' => '0', 'bOMPriceFree1' => '0', 'bSalePriceFree1' => '0',
            'bControlFreeRange1' => '0', 'bBatchProperty1' => '0',
            'bBondedInv'         => '0',
            'bBatchCreate'       => '0',
        ];

        // 6. 执行同步
        try {
            $service->beginTransaction();

            $exists = $service->table('Inventory')->where('cInvCode', $no)->lockForUpdate()->exists();
            if ($exists) {
                $service->rollBack();
                return [false, '存货编码 [' . $no . '] 在用友系统中已存在，请' . $flag_title];
            }

            // --- 核心插入操作 ---
            $service->table('Inventory')->insert($inventoryData);
            $service->table('Inventory_sub')->insert($inventorySubData);

            // --- 新增：插入 bas_part 表 ---
            // 1. 获取 U8 内部最大 PartId (或者从 bas_part_seq 获取，这里采用最大值+1的简易方案)
            $maxPartId = $service->table('bas_part')->max('PartId');
            $newPartId = (int)$maxPartId + 1;

            $basPartData = [
                'PartId'         => $newPartId,
                'InvCode'        => $no,
                'Free1' => '', 'Free2' => '', 'Free3' => '', 'Free4' => '', 'Free5' => '',
                'Free6' => '', 'Free7' => '', 'Free8' => '', 'Free9' => '', 'Free10' => '',
                'SafeQty'        => null,
                'MinQty'         => null,
                'MulQty'         => null,
                'FixQty'         => null,
                'bVirtual'       => 1, // 默认非虚仓，如果是虚拟件请改为 1
                'DrawCode'       => null,
                'LLC'            => 0,   // 低层码，新增时默认为 0，U8全检时会更新
                'iSurenessType'  => 1,   // 对应 Inventory_sub 的设置
                'RoundingFactor' => '0',
                'FreeStockFlag'  => '0',
                'bFreeStop'      => '0'
            ];
            $service->table('bas_part')->insert($basPartData);

            // 更新流水号表
            if ($serialInfo) {
                $service->table('VoucherHistory')->updateOrInsert(
                    ['CardNumber' => 'inventory', 'cContent' => '存货分类编码', 'cSeed' => $category_code],
                    ['cNumber' => $serialInfo['serial']]
                );
            }

            $service->commit();

            Inventory::where('del_time', 0)
                ->where('order_number', $data['order_number'])
                ->where('login_type', $data['login_type'])
                ->update(['code' => $no]);
        } catch (\Throwable $exception) {
            $service->rollBack();
            return [false, "同步用友数据库失败: " . $exception->getMessage()];
        }

        return [true, '同步成功'];
    }

    /**
     * U8 供应商新增 (全量版)
     */
    public function vendorAddToU8($data, $username, $service)
    {
        $vendor = Vendor::where('del_time', 0)
            ->where('order_number', $data['order_number'])
            ->where('login_type', $data['login_type'])
            ->first();
        if (empty($vendor)) return [false, '供应商记录不存在或已被删除'];
        $vendor = $vendor->toArray();

        $serialInfo = null;
        if (!empty($vendor['code'])) {
            $no = $vendor['code'];
            $flag_title = "重填";
        } else {
            list($status, $res) = $this->generate('vendor', '', $service);
            if (!$status) return [false, $res];
            $no = $res['finalCode'];
            $serialInfo = $res;
            $flag_title = "重试";
        }

        $vendorData = [
            'cVenCode' => $no,
            'cVenName' => $vendor['title'],
            'cVenAbbName' => $vendor['easy_title'],
            'cVCCode' => $vendor['category_code'],
            'dVenDevDate' => date("Y-m-d 00:00:00.000"),
            'iVenDisRate' => '0.0',
            'iVenCreLine' => '0.0',
            'iVenCreDate' => '0',
            'cVenHeadCode' => $no,
            'iAPMoney' => '0.0',
            'iLastMoney' => '0.0',
            'iLRMoney' => '0.0',
            'iFrequency' => '0',
            'bVenTax' => '1',
            'cCreatePerson' => $username,
            'cModifyPerson' => $username,
            'dModifyDate' => date("Y-m-d H:i:s.000"),
            'iGradeABC' => '-1',
            'bLicenceDate' => '0',
            'bBusinessDate' => '0',
            'bProxyDate' => '0',
            'bPassGMP' => '0',
            'bVenCargo' => '1',
            'bProxyForeign' => '0',
            'bVenService' => '0',
            'bVenOverseas' => '0',
            'cVenExch_name' => '人民币',
            'iVenGSPType' => '0',
            'iVenGSPAuth' => '-1',
            'bVenAccPeriodMng' => '0',
            'bVenHomeBranch' => '0',
            'dVenCreateDatetime' => date("Y-m-d H:i:s.000"),
            'bIsVenAttachFile' => '0',
            'bRetail' => '0',
        ];

        try {
            $service->beginTransaction();

            $exists = $service->table('Vendor')->where('cVenCode', $no)->lockForUpdate()->exists();
            if ($exists) {
                $service->rollBack();
                return [false, '供应商编码已存在，请' . $flag_title];
            }

            $service->table('Vendor')->insert($vendorData);

            // 更新流水号表
            if ($serialInfo) {
                $service->table('VoucherHistory')->updateOrInsert(
                    ['CardNumber' => 'Vendor', 'cContent' => NULL, 'cSeed' => NULL],
                    ['cNumber' => $serialInfo['serial']]
                );
            }

            $service->commit();

            Vendor::where('del_time', 0)
                ->where('order_number', $data['order_number'])
                ->where('login_type', $data['login_type'])
                ->update(['code' => $no]);
        } catch (\Throwable $exception) {
            $service->rollBack();
            return [false, "创建供应商失败: " . $exception->getMessage()];
        }

        return [true, '同步成功'];
    }

    /**
     * 编码生成器 (增加流水数据返回)
     */
    public function generate($type, $classCode = "", $service)
    {
        try {
            $cardNumber = ($type === 'inventory') ? 'inventory' : 'Vendor';
            $table = ($type === 'inventory') ? 'Inventory' : 'Vendor';
            $codeField = ($type === 'inventory') ? 'cInvCode' : 'cVenCode';

            $rule = $service->table('VoucherNumber')->where('CardNumber', $cardNumber)->first();
            if (!$rule) return [false, "未找到规则定义"];

            $prefix = "";
            for ($i = 1; $i <= 3; $i++) {
                $ruleField = "Prefix{$i}Rule";
                $valField = "Prefix{$i}";
                $ruleDesc = $rule->$ruleField ?? '';
                $staticVal = $rule->$valField ?? '';

                if (str_contains($ruleDesc, '分类') || str_contains($staticVal, '分类')) {
                    $prefix .= $classCode;
                } elseif (!empty($ruleDesc) && !in_array($ruleDesc, ['手工输入', '无'])) {
                    $prefix .= $ruleDesc;
                }
            }

            $glideLen = $rule->GlideLen ?: 4;
            $startNum = $rule->iStartNumber ?: 1;

            $lastCode = $service->table($table)
                ->where($codeField, 'like', $prefix . '%')
                ->whereRaw("LEN($codeField) = " . (strlen($prefix) + $glideLen))
                ->orderBy($codeField, 'desc')
                ->value($codeField);

            $nextSerial = (!$lastCode) ? (int)$startNum : (int)substr($lastCode, -$glideLen) + 1;
            $finalCode = $prefix . str_pad($nextSerial, $glideLen, '0', STR_PAD_LEFT);

            return [true, [
                'finalCode' => $finalCode,
                'prefix'    => $prefix,
                'serial'    => $nextSerial
            ]];
        } catch (\Throwable $e) {
            return [false, "生成失败: " . $e->getMessage()];
        }
    }

    protected function echoMessage(OutputInterface $output)
    {
        //输出消息
        $output->writeln(json_encode($this->data));
    }
}