SyncSupplierService.php

<?php


namespace App\Http\Services;

//后台用户相关信息服务
use App\Model\LogModel;
use App\Model\RedisModel;
use App\Model\SupplierAccountModel;
use App\Model\SupplierAttachmentsModel;
use App\Model\SupplierChannelModel;
use App\Model\SupplierContactModel;
use App\Model\SupplierReceiptModel;
use App\Model\SupplierSyncModel;
use App\Model\UserInfoModel;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class SyncSupplierService
{
    //同步供应商到erp
    public function syncSupplierToErp($supplierId, $conn = null)
    {
        //先去获取供应商的信息
        $supplierModel = new SupplierChannelModel();
        $supplier = $supplierModel->where('supplier_id', $supplierId)->first();
        if (empty($supplier)) {
            return false;
        }

        if (!$supplier['group_code']) {
            return true;
        }

        //先去sync表查询记录是否存在,不存在新增,存在修改
        $supplierSyncModel = new SupplierSyncModel();
        $exist = $supplierSyncModel->where('supplier_id', $supplierId)->count();
        if (!empty($exist)) {
            $supplierSyncModel->where('supplier_id', $supplierId)->update([
                'erp_sync_status' => 0,
                'update_time' => time(),
                'last_update_source' => 2,
            ]);
        } else {
            $supplierSyncModel->insert([
                'erp_sync_status' => 0,
                'supplier_id' => $supplierId,
                'add_time' => time(),
                'last_update_source' => 2,
            ]);
        }
        $contactModel = new SupplierContactModel();
        $contact = $contactModel->where('supplier_id', $supplier['supplier_id'])->orderBy('contact_id', 'asc')->first();
        $purchases = $this->getUserCodeSn($supplier['channel_uid']);
        $message = [
            'name' => $supplier['supplier_name'],
            'PTID' => $supplier['supplier_code'],
            'STATUS' => $supplier['status'] == 2 ? 1 : 2,
        ];

        if (!empty($supplier['supplier_group'])) {
            $message['groupNumber'] = array_get(config('sync.SyncSupplierType'), $supplier['supplier_group'], '');
        }

        if (!empty($supplier['tax_number'])) {
            $message['taxRegisterNo'] = $supplier['tax_number'];
        }
        if (!empty($purchases)) {
            $message['personName'] = $purchases;
        }
        if (!empty($supplier['supplier_address'])) {
            $message['address'] = $supplier['supplier_address'];
        }
        if (!empty(array_get($contact, 'supplier_consignee'))) {
            $message['contactPerson'] = array_get($contact, 'supplier_consignee');
        }
        if (!empty(array_get($contact, 'supplier_telephone'))) {
            $message['phone'] = array_get($contact, 'supplier_telephone');
        }
        if (!empty($supplier['currency'])) {
            $message['currencyNumber'] = array_get(config('sync.SyncCurrencyType'), $supplier['currency']);
        }
        $supplierIds = SupplierChannelModel::where('supplier_name', $supplier['supplier_name'])
            ->where('is_type', 0)->where('group_code', '!=', '')
            ->pluck('supplier_id')->toArray();
        //银行信息
        $receipts = SupplierReceiptModel::with(['nation'])->whereIn('supplier_id', $supplierIds)->get()->toArray();
        //->where('bank_name', '!=', '')->where('account_no', '!=', '')->get()->toArray();
        if (!empty($receipts)) {
            $message['bankinfo'] = [];
            foreach ($receipts as $receipt) {
                $address = !empty($receipt['nation']['name_cn']) ? $receipt['nation']['name_cn'] . $receipt['account_adderss'] : $receipt['account_adderss'];
                $message['bankinfo'][] = [
                    "bank" => $receipt['bank_adderss'],
                    'bankaccount' => $receipt['account_no'],
                    'supplier' => $receipt['bank_name'],
                    'swiftCode' => $receipt['swift_code'],
                    'beneficiary' => $receipt['account_name'],
                    'bankAddress' => $address,
                    'infoEvidence' => $receipt['certificate'],
                    'recid' => $receipt['receipt_id'],
                    //'bankaccount' => $receipt['international_code'],
                ];
            }
        }

        //审核流程
        $updateLogs = (new LogService())->getLogs($supplierId, LogModel::UPDATE_OPERATE);
        $reviewProcess = [];
        if ($updateLogs) {
            foreach ($updateLogs as $log) {
                $content = is_array($log['content']) && !empty($log['content']) ? $log['content'][0] : $log['content'];
                $reviewProcess[] = [
                    'operator' => $log['admin_name'],
                    'operateDate' => $log['add_time'],
                    'operate' => mb_substr($content, 0, 200) . '...',
                ];
            }
        }
        $message['reviewProcess'] = $reviewProcess;
        if ($conn) {

        } else {
            $conn = new AMQPStreamConnection(config('database.connections.rabbitmq.host'),
                config('database.connections.rabbitmq.port'),
                config('database.connections.rabbitmq.login'),
                config('database.connections.rabbitmq.password'));
        }
        $channel = $conn->channel();
        $channel->queue_declare('supplier_sync', false, true, false, false);
        $msg = new AMQPMessage(json_encode($message),
            array('content_type' => 'text/plain'));
        $result = $channel->basic_publish($msg, '', 'supplier_sync');
//        $result = $channel->basic_publish($msg);
    }

    //获取采购人员列表
    private function getUserCodeSn($purchaseUid)
    {
        $purchaseUid = explode(',', $purchaseUid);
        if (empty($purchaseUid)) {
            return [];
        }
        $adminIds = DB::connection()->table('lie_intracode')->whereIn('code_id', $purchaseUid)->pluck('admin_id');
        return DB::connection()->table('user_info')->whereIn('userId', $adminIds)->pluck('code_sn');
    }

    /**
     * 推送参数:
     * {
     * "system_id": "1",//来源系统id  1猎芯科技,2猎芯供应链,3crm
     * "source_sn": "1", //源编码 各个系统标识公司的标识号
     * "company_type": "1",//公司类型,1客户,2供应商
     * "company_name": "测试公司", //公司名称
     * "company_tax_no": "1234567",//公司税号
     * "init_nature": "1234567",//来源公司初鉴性质
     * "region": "1",//地区,1大陆,2海外
     * "pi_file_url": "dasdsa"  //pi附件地址
     * }
     */
    //同步供应商信息到一体化中心
    public function syncSupplierToUnited($supplierId)
    {
        $supplier = SupplierChannelModel::where('supplier_id', $supplierId)->first()->toArray();
        $fileUrl = SupplierAttachmentsModel::where('supplier_id', $supplierId)
            ->where('field_name', 'registration_certificate')
            ->value('file_url');
        //构建需要同步的数据
        $syncData = [
            'system_id' => 1,
            'source_sn' => (string)$supplier['supplier_id'],
            'company_type' => 2,
            'company_name' => $supplier['supplier_name'],
            'company_tax_no' => $supplier['tax_number'],
            'init_nature' => Arr::get(config('fixed.SupplierGroup'), $supplier['supplier_group']),
            'region' => $supplier['region'] == SupplierChannelModel::REGION_CN ? 1 : 2,
            'pi_file_url' => $fileUrl ?: '',
        ];
        (new QueueDeliveryService())->push(QueueDeliveryService::PUSH_TYPE_SYNC_HTTP, '/sync/Company/syncCompany',
            $syncData);
    }

    /**
     * 推送参数为:
     * {
     * "group_code":"K0000013", //集团编码
     * "source_sn":"1",//来源id,其实就是供应商id,因为新增的时候丢过去的就是供应商id
     * "company_name":"\u6d4b\u8bd5\u516c\u53f8",//公司名
     * "init_nature":"1234567",//初鉴性质
     * "company_nature":"1234567"//公司真实性质
     * "company_category":"普通供应商"//公司类别,只要不是普"通供应商",就是要拉黑的
     * }
     **/
    //接收一体化系统处理好的供应商数据,可能是第一次新增返回的数据,也可能是一体化那边修改的数据需要同步到供应商
    public function syncSupplierToUnitedResult($syncResult)
    {
        Log::warning(json_encode($syncResult));
        $redis = new RedisModel();
        $groupCode = array_get($syncResult, 'group_code');
        $sourceSn = array_get($syncResult, 'source_sn');
        $companyCategory = array_get($syncResult, 'company_category', '');
        $supplier = SupplierChannelModel::where('supplier_id', $sourceSn)->orWhere('group_code', $groupCode)->first();
        $supplier = !empty($supplier) ? $supplier->toArray() : [];
        $supplierId = $supplier['supplier_id'];
        //$supplier = SupplierChannelModel::where('supplier_id', $supplierId)->first()->toArray();
        //if ($companyCategory != '') {
        //    //实体名单和黑名单都要拉黑,如果不属于黑名单,那么就要将状态改成审核中
        //    if ($companyCategory == '黑名单供应商') {
        //        $data['status'] = SupplierChannelModel::STATUS_BLOCK;
        //        $data['block_reason'] = '一体化系统黑名单供应商';
        //    } else if ($companyCategory == '实体名单供应商') {
        //        $this->receiveEntityResult($supplier['supplier_name'], -1);
        //    } else {
        //        $preIsEntity = $supplier['is_entity'];
        //        //判断原来是拉黑状态,才变成审核中,因为有可能不是修改公司类型,只是修改公司性质
        //        if ($supplier['status'] == SupplierChannelModel::STATUS_BLOCK) {
        //            $data['status'] = SupplierChannelModel::STATUS_IN_REVIEW;
        //        }
        //        //如果之前是禁用,并且是实体名单,那么就要恢复之前的状态
        //        if ($supplier['status'] === SupplierChannelModel::STATUS_DISABLE && $preIsEntity == SupplierChannelModel::IS_ENTITY_TRUE) {
        //            $this->receiveEntityResult($supplier['supplier_name'], 1);
        //        }
        //    }
        //}
        $data['sync_united_status'] = SupplierChannelModel::SYNC_UNITED_STATUS_OK;
        $data['group_code'] = $groupCode;
        $data['company_nature'] = $syncResult['company_nature'];
        $data['company_category'] = $companyCategory;
        //$sourceSn不为空的话,就是代表这是第一次新增的供应商,所以会回传供应商id过来
        if ($sourceSn) {
            $data['supplier_name'] = $syncResult['company_name'];
            $result = SupplierChannelModel::where('supplier_id', $supplierId)
                ->update($data);
            if ($result) {
                //再次同步供应商到金蝶
                $this->syncSupplierToErp($supplierId);
            }
            return $result;
        } else {
            return SupplierChannelModel::where('group_code', $groupCode)
                ->update($data);
        }
    }

    //接收一体化的广播信息,对供应商进行实体名单操作
    //加入实体名单后,要做很多事情,比如禁用供应商,也要禁用供应商账号等等,还要记录禁用之前的状态,等到移除实体名单以后,要恢复之前的状态
    public function receiveEntityResult($resultData)
    {
        $supplierName = $resultData['company_name'];
        $result = $resultData['result'];
        $tagList = $resultData['tag_list'];
        Log::warning('一体化拉黑结果 : ' . ($supplierName . '---' . $result));

        //根据result,修改供应商的是否是实体名单字段
        $isEntity = ($result == 1) ? false : true;
        $isEntityResult = SupplierChannelModel::IS_ENTITY_FALSE; //默认不是实体名单
        $warningType = array_get($resultData, 'warning_type') == 1 ? '供应商名称' : '地址';
        $warningKeyword = array_get($resultData, 'warning_keyword', '无');
        $warningData = array_get($resultData, 'warning_data', '无');
        //我这里的状态和一体化的结果判断有点对不上,因为我这把是(是否实体名单),而一体化那边是实体名单是否通过,所以要转换
        if ($result == 1) {
            $isEntityResult = SupplierChannelModel::IS_ENTITY_FALSE;
            $logContent = $reason = '移除实体名单';
        } else {
            if ($result == -1) {
                $isEntityResult = SupplierChannelModel::IS_ENTITY_TRUE;
                $logContent = $reason = "属于实体名单，系统自动拉入黑名单. 风险类型 : $warningType 风险词 : $warningKeyword 风险数据 : $warningData";
            }
            if ($result == 0) {
                $isEntityResult = SupplierChannelModel::IS_ENTITY_NEED_CONFIRM;
                $logContent = $reason = "待确认实体名单，系统自动拉入禁止交易，请联系“风控部门”进行确认. 风险类型 : $warningType 风险词 : $warningKeyword 风险数据 : $warningData";
            }
            if ($result == -3) {
                $handleReason = array_get($resultData, 'handle_result','无');
                $isEntityResult = SupplierChannelModel::IS_ENTITY_REJECT;
                $logContent = $reason = "被驳回供应商，系统自动拉入禁止交易，处理说明 : $handleReason . 风险类型 : $warningType 风险词 : $warningKeyword 风险数据 : $warningData";
            }
        }
        //去修改供应商入驻相关的数据
        (new ChainService())->changeChainIsEntity($supplierName, $isEntityResult);

        //先找到对应的供应商(草稿的跳过),如果没有那跳过
        $suppliers = SupplierChannelModel::where('supplier_name', $supplierName)->get()->toArray();
        if (empty($suppliers)) {
            Log::error('供应商不存在');
            return true;
        }
        foreach ($suppliers as $supplier) {
            //$supplier = $supplier->toArray();
            $supplierId = $supplier['supplier_id'];
            //先把修改之前的状态给记录下来
            $status = $supplier['status'];
            $preStatus = null;
            $redis = new RedisModel();
            if ($isEntity) {
                $cachedExists = $redis->hexists('supplier_status_before_disable', $supplierId);
                if (!$cachedExists) {
                    $redis->hset('supplier_status_before_disable', $supplierId, $status);
                }
            } else {
                $preStatus = $redis->hget('supplier_status_before_disable', $supplierId);
                if ($preStatus === null) {
                    $preStatus = $status;
                }

                $redis->hdel('supplier_status_before_disable', $supplierId);
            }

            //如果是移除实体名单,但是得到之前的状态还是禁止交易,那么强行改成审核中
            if (!$isEntity && $preStatus == SupplierChannelModel::STATUS_DISABLE) {
                $preStatus = SupplierChannelModel::STATUS_IN_REVIEW;
            }
            //修改供应商的状态
            SupplierChannelModel::where('supplier_id', $supplierId)->update([
                'is_entity' => $isEntityResult,
                'update_time' => time(),
                //这里的逻辑是,因为取消实体名单以后,如果之前的状态是黑名单的话,直接变成待提审
                'status' => $isEntity ? SupplierChannelModel::STATUS_DISABLE : ($preStatus == SupplierChannelModel::STATUS_BLOCK ? SupplierChannelModel::STATUS_IN_REVIEW : $preStatus),
                'disable_reason' => $reason,
                'united_tags' => !empty($tagList) ? implode(',', $tagList) : '',
            ]);
            $isYunxinSupplier = false;
            //还要去修改对应的供应商账号,也是要记录禁用前的状态
            $supplierAccount = SupplierAccountModel::where('supplier_id', $supplierId)->first();
            //如果是待确认,那么不需要去操作供应商账号
            if (!empty($supplierAccount) && $result != 0) {
                $isYunxinSupplier = true;
                $supplierAccount = $supplierAccount->toArray();
                $accountPreStatus = $supplierAccount['a_status'];
                if ($isEntity) {
                    $redis->hset('supplier_account_status_before_disable', $supplierId, $accountPreStatus);
                } else {
                    $accountPreStatus = $redis->hget('supplier_account_status_before_disable', $supplierId);
                    $redis->hdel('supplier_account_status_before_disable', $supplierId);
                }
                SupplierAccountModel::where('supplier_id', $supplierId)->update([
                    'update_time' => time(),
                    'a_status' => $isEntity ? SupplierAccountModel::STATUS_DISABLE : SupplierAccountModel::STATUS_ENABLE,
                ]);
            }

            //还要去打日志
            $logService = new LogService();
            $logService->AddAdminLog($supplierId, LogModel::UPDATE_OPERATE, '实体名单设置', $logContent);


            //不属于加入实体名单和移除实体名单不去发邮件
            if (!in_array($result, [1, -1])) {
                return true;
            }

            //本地
            if (isDevEnvironment()) {
                continue;
            }
            //return true;
            //还要去发送邮箱给采购员,线上采购员,采购总
            $data['data']['supplier_code'] = $supplier['supplier_code'];
            $data['data']['supplier_name'] = $supplier['supplier_name'];
            $data['data']['supplier_group_name'] = array_get(config('fixed.SupplierGroup'), $supplier['supplier_group']);
            $data['data']['operation'] = $isEntity ? '确认' : '移除';
            $data['data']['content'] = $isEntity ? ' 注意：实体名单的供应商已自动拉入禁止交易，无法使用！' : '注意：已移除实体名单的供应商，状态自动返回到前一个状态！';
            $data['data']['ps_content'] = $isEntity ? 'PS：如果该供应商为芯链商家，该供应商的芯链账号无法登录芯链系统！' : 'PS：如果该供应商为芯链商家，该供应商的芯链账号可正常登录芯链系统！';
            if ($isYunxinSupplier) {
                $data['data']['supplier_name'] .= ' (芯链商家) ';
            }
            if (!empty($supplier['yunxin_channel_uid'])) {
                $yunxinChannelUser = (new AdminUserService())->getAdminUserInfoByCodeId($supplier['yunxin_channel_uid']);
                if (!empty($yunxinChannelUser['email'])) {
                    //先发送邮件给线上采购员
                    (new MessageService())->sendMessage('supplier_entity_notice_purchase', $data, $yunxinChannelUser['email'], true);
                }
                //再找出线上采购员对应的采购总监
                $supervisorDepartmentId = $yunxinChannelUser['department_id'];
                $positionId = \DB::table('user_position')->where('department_id', $supervisorDepartmentId)
                    ->where('position_name', '采购总监')->value('position_id');
                if (!empty($positionId)) {
                    $supervisor = UserInfoModel::where('position_id', $positionId)->first()->toArray();
                    if (!empty($supervisor['email'])) {
                        (new MessageService())->sendMessage('supplier_entity_notice_purchase', $data, $supervisor['email'], true);
                    }
                }
            }

            if (!empty($supplier['channel_uid'])) {
                $supplier['channel_uid'] = explode(',', $supplier['channel_uid']);
                $channelUserList = (new AdminUserService())->getAdminUserListByCodeIds($supplier['channel_uid']);
                foreach ($channelUserList as $channelUser) {
                    if (!empty($channelUser['email'])) {
                        (new MessageService())->sendMessage('supplier_entity_notice_purchase', $data, $channelUser['email'], true);
                    }
                }
            }
        }
    }
}