Skip to content

黄成意 / php_frq_api

Go to a project
Commit d7b747b6 by 朱继来
Options

fix

parents 118f94fb 5061ce52
Inline Side-by-side
Showing with 668 additions and 322 deletions
app/Http/Controllers/ApiController.php
......@@ -4,6 +4,7 @@ namespace App\Http\Controllers;
use App\Model\CommonModel;
use App\Model\InquiryItemsAssignModel;
use App\Model\InquiryItemsReportModel;
use App\Model\InquiryModel;
use App\Model\InquiryItemsModel;
......@@ -99,6 +100,41 @@ class ApiController extends Controller
ExportLayui((new QuoteModel())->ItemsList($input));
}
// 已领取列表
private function GetAssignList($input, $id){
$inquiry_items_id = $input['inquiry_items_id'];
$p = $input['p'] ? $input['p'] : 1;
$limit = $input['limit'] ? $input['limit'] : 10;
$InquiryItemsAssignModel = new InquiryItemsAssignModel;
$list = $InquiryItemsAssignModel->GetAssignList($inquiry_items_id, $p, $limit);
if ($list['data'] && is_array($list['data'])){
$InquiryItemsModel = new InquiryItemsModel();
$inquire_item_info = $InquiryItemsModel->where('id', $inquiry_items_id)->first()->toArray();
if ($inquire_item_info){
// 获取领取了询价单后已报价的uids
$QuoteModel = new QuoteModel();
$assign_uids = array_column($list['data'], 'assign_uid');
$quoted_uids = $QuoteModel->GetQuotedUids($inquiry_items_id, $assign_uids);
foreach ($list['data'] as $k => &$assign_item){
$assign_item['goods_name'] = $inquire_item_info['goods_name'];
$assign_item['brand_name'] = $inquire_item_info['brand_name'];
$assign_item['status_name'] = "已领取";
$assign_item['create_time'] = date("Y-m-d H:i:s", $assign_item['create_time']);
}
// 判断当前用户是否有对该询价单报价，如果有报价，那么过滤
if (in_array($assign_item['assign_uid'], $quoted_uids)){
unset($list['data'][$k]);
}
}
}
$data = [0, '成功', $list['data'], $list['total']];
ExportLayui($data);
}
//搜索品牌
private function ApiBrandList($input, $id){
(new CommonModel())->BrandList($input['k'],@$input["types"] ? @$input["types"] : 1);
......@@ -143,6 +179,7 @@ class ApiController extends Controller
private function ApiInquiryExport($input){
(new ExportModel())->InquiryExport($input,$this->user_id);
}
//生成报价pdf
private function ApiOfferPdf($request){
(new CommonModel())->Pdf();
......@@ -194,6 +231,8 @@ class ApiController extends Controller
Export((new InquiryItemsModel())->import($input));
}
// 删除报价草稿
public function ApiDeleteQuoteDraft($input, $id)
{
......
app/Http/Controllers/ServerController.php
......@@ -41,6 +41,7 @@ class ServerController extends Controller
$server->addMethod('InquiryServer',$this);
$server->handle();
}
public function InquiryServer($info){
$res= (new InquiryModel())->getList(json_decode($info,true),1);
return ExportLayuiReturn($res);
......
app/Http/LogReport.php
......@@ -8,7 +8,7 @@ defined('REPORT_APP_NAME') or define('REPORT_APP_NAME', 'frq_api');
defined('LOG_FILE_SIZE') or define('LOG_FILE_SIZE', 2097152); //2MB
// 设定错误和异常处理
error_reporting(0);
error_reporting(E_ERROR);
LogReport::auto();
......
app/Model/BestGoodsModel.php 0 → 100644
<?php
namespace App\Model;
use Illuminate\Database\Eloquent\Model;
class BestGoodsModel extends Model
{
protected $connection = 'rfq';
protected $table = 'best_goods';
protected $primaryKey = 'id';
const STATUS_ENABLE = 1; // 有效
const STATUS_DISABLE = 2; // 无效
public $timestamps = true;
const CREATED_AT = 'create_time';
const UPDATED_AT = 'update_time';
public function GetList($where = [], $page = 1, $limit = 10)
{
if ($where) {
$list = $this->where($where)->orderBy('id', 'desc')->paginate($limit, ['*'], 'p', $page)->toArray();
} else {
$list = $this->select()->orderBy('id', 'desc')->paginate($limit, ['*'], 'p', $page)->toArray();
}
return $list;
}
public function getCountByWhere($where = [])
{
if ($where) {
return $this->where($where)->count();
} else {
return $this->count();
}
}
public function GetListByIds($ids)
{
return $this->whereIn("id", $ids)->get()->toArray();
}
public function updateByIds($ids, $data)
{
return $this->whereIn("id", $ids)->update($data);
}
}
\ No newline at end of file
app/Model/ExportModel.php
......@@ -63,5 +63,4 @@ class ExportModel
echo self::push($data);
}
}
\ No newline at end of file
app/Model/InquiryItemsAssignModel.php
......@@ -11,6 +11,12 @@ class InquiryItemsAssignModel extends Model
protected $primaryKey = 'id';
public $timestamps = false;
// 领取类型 1 指定 2 领取
const ASSIGN_TYPE_BIND = 1;
const ASSIGN_TYPE_SELECTED = 2;
// 领取询价
public function assign($inquiry_items_id, $assign_uid, $types=1)
{
......@@ -27,6 +33,24 @@ class InquiryItemsAssignModel extends Model
return $this->insert($data);
}
public function GetAssignList($inquiry_items_id, $p, $limit)
{
return $this
->where("inquiry_items_id", $inquiry_items_id)
->where("assign_type", self::ASSIGN_TYPE_SELECTED)
->orderBy('id','desc')
->paginate($limit ? $limit : 10, ['*'], 'p', $p ? $p : 1)
->toArray();
}
public function GetAssignCountByInquiryId($inquiry_items_id)
{
return $this
->where("inquiry_items_id", $inquiry_items_id)
->count();
}
// 删除
public function delAssign($inquiry_items_id, $assign_uid, $types=1)
{
......
app/Model/InquiryItemsModel.php
......@@ -25,6 +25,12 @@ class InquiryItemsModel extends Model
return strtotime(parent::fromDateTime($value));
}
public function GetInquireItemsListByIds($ids)
{
return $this->whereIn("id", $ids)->get()->toArray();
}
//生成报价单详情
public function ItemsOfferDetail($inquiry_id)
{
......@@ -109,6 +115,11 @@ class InquiryItemsModel extends Model
// 添加操作日志
$inquiry_items = $this->find($id);
// 检查询价单状态，如果状态为默认的 待报价 状态，那么更改为 已领取状态
if ($inquiry_items['status'] == InquiryMap::status_ready){
$this->where('id', $id)->update(['status' => InquiryMap::status_fix]);
}
$data = [];
$data['types'] = 1;
$data['relation_id'] = $id;
......@@ -250,6 +261,8 @@ class InquiryItemsModel extends Model
if(count($assignInsert) >0){ #插入指定人
(new InquiryItemsAssignModel())->insert($assignInsert);
}
$this->where('id', $inquiryItemsId)->update(['status' => 4]); // 存在指定采购，则标记状态为已领取
}
#日志
......@@ -331,6 +344,8 @@ class InquiryItemsModel extends Model
if(count($assignInsert) >0){ #插入指定人
$InquiryItemsAssignModel->insert($assignInsert);
}
$this->where('id', $inquiry_items_id)->update(['status' => 4]); // 存在指定采购，则标记状态为已领取
}
#发送消息
......
app/Model/InquiryItemsReportModel.php
......@@ -217,7 +217,7 @@ class InquiryItemsReportModel extends Model
* 判断是否能生成销售单
*/
public function checkOrder($input){
$check = $this->where(["price_origin"=>0,"price_rmb"=>0])->whereIn("id",explode(",",$input["inquiry_items_id"]))->count();
$check = $this->where(["price_origin"=>0,"price_rmb"=>0])->whereIn("id",explode(",",$input["report_ids"]))->count();
return $check >0 ? [1001,"没有销售报价的报价单不能生成销售订单"] : [0,"通过"];
}
/*
......
app/Model/InquiryModel.php
......@@ -20,6 +20,12 @@ class InquiryModel extends Model
protected $primaryKey = 'id';
public $timestamps = false;
public function GetInquiryListByIds($ids)
{
return $this->whereIn("id", $ids)->get()->toArray();
}
/**
* 询价列表
*/
......@@ -77,7 +83,6 @@ class InquiryModel extends Model
}
}
});
#不同类别查询
switch (@$input["types"]) {
case "1": //我的询价
......@@ -119,6 +124,8 @@ class InquiryModel extends Model
$QuoteModel = new QuoteModel();
$InquiryItemsAssignModel = new InquiryItemsAssignModel();
$BestGoodsModel = new BestGoodsModel();
$Redis = \RedisDB::connection();
foreach ($list['data'] as $k => &$v) {
$inquiry_items_id = $v["id"]; #明细id
......@@ -166,6 +173,11 @@ class InquiryModel extends Model
$v['inquiry_sn_origin'] = $v["inquiry_sn"];
// 查询历史报价数
$v['history_quote_count'] = $QuoteModel->GetHistoryQuotedCount($v['goods_name']);
// 查询优选匹配数
$v['best_count'] = $BestGoodsModel->getCountByWhere([["goods_name", '=', $v['goods_name']], ["g_status", '=', BestGoodsModel::STATUS_ENABLE]]);
// 在Redis集合中检查是否有新的报价
if ($export == 0){
$res = $Redis->SISMEMBER('frq_quote_urge', $v['id']);
......@@ -246,8 +258,7 @@ class InquiryModel extends Model
->join('inquiry_items_urge as u', 'b.id', '=', 'u.inquiry_items_id')
->where('c.assign_uid', $user_id);
}
$list = $list->select(DB::Raw("lie_a.inquiry_sn,lie_a.currency,lie_a.status as status_a,lie_a.user_name,lie_a.com_name,lie_a.create_name,lie_a.create_time as inquiry_ctime, lie_b.*, lie_c.id as c_id, lie_c.assign_type as c_assign_type"))
$list = $list->select(DB::Raw("lie_a.inquiry_sn,lie_a.currency,lie_a.status as status_a,lie_a.user_name,lie_a.com_name,lie_a.create_name,lie_a.create_time as inquiry_ctime, lie_a.remark as inquiry_remark, lie_b.*, lie_c.id as c_id, lie_c.assign_type as c_assign_type"))
->where(function ($query) use ($input, $type, $user_id) {
foreach ($input as $k => $v) {
$v = trim($v);
......@@ -310,7 +321,6 @@ class InquiryModel extends Model
// $tmp = vsprintf($tmp, $list->getBindings());
// echo $tmp;
// exit;
$page = isset($input['p']) ? $input['p'] : $input['page'];
$list = $list->orderBy('b.id', 'desc')->paginate(@$input['limit'] ? $input["limit"] : 10, ['*'], 'p', @$page ? $page : 1)->toArray();
......@@ -318,6 +328,8 @@ class InquiryModel extends Model
$QuoteModel = new QuoteModel();
$InquiryItemsUrgeModel = new InquiryItemsUrgeModel;
$InquiryItemsAssignModel = new InquiryItemsAssignModel;
foreach ($list['data'] as $k => &$v) {
//报价
......@@ -353,6 +365,9 @@ class InquiryModel extends Model
}
}
$v['assign_count'] = $InquiryItemsAssignModel->GetAssignCountByInquiryId($v['id']);
$v['delivery_time'] = $v['delivery_time'] > 6 ? ($v['delivery_time']/7).'周' : $v['delivery_time']."天";
}
return [0, '成功', $list['data'], $list['total']];
......
app/Model/QuoteModel.php
......@@ -24,35 +24,58 @@ use Excel;
class QuoteModel extends Model
{
protected $connection = 'rfq';
protected $table = 'quote';
protected $table = 'quote';
protected $primaryKey = 'id';
protected $guarded = ['id'];
public $timestamps = true;
const CREATED_AT = 'create_time';
const UPDATED_AT = 'update_time';
protected $guarded = ['id'];
public $timestamps = true;
const CREATED_AT = 'create_time';
const UPDATED_AT = 'update_time';
const STATUS_OFFER = 1; // 已报价
const STATUS_SELECTED = 2; // 已选中
const STATUS_SURE = 3; // 已确认
public function fromDateTime($value)
{
return strtotime(parent::fromDateTime($value));
}
public function GetHistoryQuotedCount($goods_name)
{
return $this->whereIn("status", [self::STATUS_OFFER, self::STATUS_SELECTED, self::STATUS_SURE])->where('goods_name', $goods_name)->count();
}
public function GetQuotedUids($inquiry_items_id, $assign_uids)
{
return $this->where("inquiry_items_id", $inquiry_items_id)
->whereIn("create_uid", $assign_uids)
->whereIn("status", [self::STATUS_OFFER, self::STATUS_SELECTED, self::STATUS_SURE])
->lists("create_uid")->toArray();
}
//单个明细分页列表
public function ItemsList($input)
{
$list = $this
->where("inquiry_items_id",$input["inquiry_items_id"])
->orderBy('status','desc')
->orderBy('price_rmb','asc')
->whereNotIn("status",[-1,0])
->where("inquiry_items_id", $input["inquiry_items_id"])
->orderBy('status', 'desc')
->orderBy('price_rmb', 'asc')
->whereNotIn("status", [-1, 0])
->paginate(@$input['limit'] ? $input["limit"] : 10, ['*'], 'p', @$input['p'] ? $input["p"] : 1)
->toArray();
if (!$list) return [20001, '没有数据'];
foreach ($list['data'] as $k=>&$v){
$v["price_origin"] = $v["currency"] >1 ? InquiryMap::$currency_sign[$v["currency"]].$v["price_origin"] : "--";
$v["price_rmb"] = $v["currency"] == 1 ? "￥".$v["price_rmb"]:"--";
if (!$list) {
return [20001, '没有数据'];
}
foreach ($list['data'] as $k => &$v) {
$v["price_origin"] = $v["currency"] > 1 ? InquiryMap::$currency_sign[$v["currency"]] . $v["price_origin"] : "--";
$v["price_rmb"] = $v["currency"] == 1 ? "￥" . $v["price_rmb"] : "--";
$v['status'] = QuoteMap::$status[$v["status"]];
if ($v["raw_goods_packing"] != ""){
$v["create_name"] = $v["create_name"]."(包装：".$v["raw_goods_packing"].")";
if ($v["raw_goods_packing"] != "") {
$v["create_name"] = $v["create_name"] . "(包装：" . $v["raw_goods_packing"] . ")";
}
}
return [0, '成功', $list['data'], $list['total']];
......@@ -62,90 +85,96 @@ class QuoteModel extends Model
public function ItemsListGroup($inquiry_items_id)
{
$list = $this
->where("inquiry_items_id",$inquiry_items_id)
->orderBy('status','desc')
->where("inquiry_items_id", $inquiry_items_id)
->orderBy('status', 'desc')
->get()
->toArray();
if (!$list) return [20001, '没有数据'];
if (!$list) {
return [20001, '没有数据'];
}
// 状态 -1：已撤销 1：已报价 2：已选中 3：已确认
$dataSure = []; //已确认
$dataCheck = []; //已选中
$dataDelete = []; //删除
$dataReady = []; //已报价
foreach ($list as $k=>&$v){
switch ($v["status"]){
foreach ($list as $k => &$v) {
switch ($v["status"]) {
case -1:
array_push($dataDelete,$v);
array_push($dataDelete, $v);
break;
case 1:
array_push($dataReady,$v);
array_push($dataReady, $v);
break;
case 2:
array_push($dataCheck,$v);
array_push($dataCheck, $v);
break;
case 3:
array_push($dataSure,$v);
array_push($dataSure, $v);
break;
}
$v['status'] = QuoteMap::$status[$v["status"]];
}
return ["dataSure"=>$dataSure,"dataCheck"=>$dataCheck,"dataDelete"=>$dataDelete,"dataReady"=>$dataReady];
return [
"dataSure" => $dataSure,
"dataCheck" => $dataCheck,
"dataDelete" => $dataDelete,
"dataReady" => $dataReady
];
}
// 获取报价列表
public function lists($input, $export='')
public function lists($input, $export = '')
{
$page = $input['page'];
$limit = $input['limit'];
$type = $input['type']; // 1-我的报价，2-所有报价，3-报价草稿
$type = $input['type']; // 1-我的报价，2-所有报价，3-报价草稿，4-销售首页
$map['inquiry_sn'] = isset($input['inquiry_sn']) ? trim($input['inquiry_sn']) : ''; // 询价单号
$map['goods_name'] = isset($input['goods_name']) ? trim($input['goods_name']) : ''; // 型号
$map['brand_name'] = isset($input['brand_name']) ? trim($input['brand_name']) : ''; // 品牌
$map['quote_sn'] = isset($input['quote_sn']) ? trim($input['quote_sn']) : ''; // 报价单号
$map['status'] = isset($input['status']) ? $input['status'] : ''; // 报价状态
$map['create_uid'] = isset($input['create_uid']) ? $input['create_uid'] : ''; // 报价制单人
$map['quote_sn'] = isset($input['quote_sn']) ? trim($input['quote_sn']) : ''; // 报价单号
$map['status'] = isset($input['status']) ? $input['status'] : ''; // 报价状态
$map['start_time'] = !empty($input['start_time']) ? strtotime($input['start_time']) : '';
$map['end_time'] = !empty($input['end_time']) ? strtotime($input['end_time']) + 86399 : '';
$field = ['q.id', 'q.inquiry_id', 'q.inquiry_sn', 'q.inquiry_items_id', 'q.quote_sn', 'q.source', 'q.price_origin', 'q.price_rmb', 'q.price_other', 'q.currency', 'q.goods_name as quote_goods_name', 'q.brand_name as quote_brand_name', 'q.supplier_id', 'q.supplier_name', 'q.quote_number', 'q.status', 'q.create_uid', 'q.create_name', 'q.delivery_time', 'q.batch', 'q.create_time', 'it.goods_name', 'it.brand_name', 'it.inquiry_number'];
$list = $this->from('quote as q')
->join('inquiry_items as it', 'q.inquiry_items_id', '=', 'it.id')
->where(function($query) use ($map) {
if ($map['inquiry_sn']) {
$query->where('q.inquiry_sn', '=', $map['inquiry_sn']);
}
if ($map['goods_name']) {
$query->where('it.goods_name', 'like', $map['goods_name'].'%');
}
if ($map['brand_name']) {
$query->where('it.brand_name', 'like', $map['brand_name'].'%');
}
if ($map['quote_sn']) {
$query->where('q.quote_sn', '=', $map['quote_sn']);
}
if ($map['status']) {
$query->where('q.status', '=', $map['status']);
}
// 创建时间
if(!empty($map['start_time']) && !empty($map['end_time'])) {
$query->whereBetween('q.create_time', [$map['start_time'], $map['end_time']]);
} else if(!empty($map['start_time'])) {
$query->where('q.create_time', '>=', $map['start_time']);
} else if(!empty($map['end_time'])) {
$query->where('q.create_time', '<=', $map['end_time']);
}
});
$map['end_time'] = !empty($input['end_time']) ? strtotime($input['end_time']) + 86399 : '';
// $map = array_filter($map) ? $map : [];
$field = [
'q.id',
'q.inquiry_id',
'q.inquiry_sn',
'q.inquiry_items_id',
'q.quote_sn',
'q.source',
'q.price_origin',
'q.price_rmb',
'q.price_other',
'q.currency',
'q.goods_name as quote_goods_name',
'q.brand_name as quote_brand_name',
'q.supplier_id',
'q.supplier_name',
'q.quote_number',
'q.status',
'q.create_uid',
'q.create_name',
'q.delivery_time',
'q.batch',
'q.create_time',
'it.goods_name',
'it.brand_name',
'it.inquiry_number'
];
if ($map) {
$list = $this->commonQuery($map, $input);
} else {
$list = $this->from('quote as q')
->join('inquiry_items as it', 'q.inquiry_items_id', '=', 'it.id');
}
$map['create_uid'] = isset($input['create_uid']) ? $input['create_uid'] : ''; // 报价制单人
if ($type == 1) {
$list = $list->where('q.create_uid', $input['user_id'])->where('q.status', '<>', 0); // 过滤报价草稿
} else if ($type == 2) {
$list = $list->where('q.create_uid', $input['user_id'])->whereNotIn('q.status', [0, -1]); // 过滤报价草稿
} elseif ($type == 2) {
$perm = new PermController;
$role = $perm->getUserRole($input['user_id'], $input['email']); // 用户角色
......@@ -154,9 +183,15 @@ class QuoteModel extends Model
$list = $list->whereIn('q.create_uid', $sub_sale_ids);
}
$list = $list->where('q.status', '<>', 0); // 过滤报价草稿
} elseif(@$input['inquiry_items_id'] > 0) {
$list = $list->where('q.status', 0)->where('q.inquiry_items_id', $input['inquiry_items_id']);
$list = $list->whereNotIn('q.status', [0, -1]); // 过滤报价草稿
} elseif ($type == 3) {
$list = $list->where('q.status', 0)->whereIn('q.inquiry_items_id', explode(',', $input['inquiry_items_ids']));
} elseif (@$input['inquiry_items_id'] > 0) {
$list = $list->whereNotIn('q.status', [0, -1])->where('q.inquiry_items_id', $input['inquiry_items_id']);
} elseif (isset($input['inquiry_items_ids']) && $input['inquiry_items_ids']) {
$inquiry_items_ids = explode(",", $input['inquiry_items_ids']);
$inquiry_items_ids = array_values(array_filter($inquiry_items_ids));
$list = $list->whereNotIn('q.status', [0, -1])->whereIn('q.inquiry_items_id', $inquiry_items_ids);
}
if ($map['create_uid']) { // 制单人
......@@ -164,12 +199,18 @@ class QuoteModel extends Model
}
$list = $list->select($field)->orderBy('id', 'desc');
// dump($list->getBindings());
// dump($list->toSql());
// $tmp = str_replace('?', '"'.'%s'.'"', $list->toSql());
// $tmp = vsprintf($tmp, $list->getBindings());
// echo $tmp;
// exit;
if ($export) {
$list = $list->get()->toArray();
if (empty($list)) {
echo '<script>alert("导出数据为空");history.go(-1);</script>';die;
echo '<script>alert("导出数据为空");history.go(-1);</script>';
die;
}
return $list;
......@@ -178,115 +219,216 @@ class QuoteModel extends Model
$list['data'] = $this->handleData($list['data'], $type);
return [0, '获取成功', $list['data'], $list['total']];
$msg = '成功';
if ($type == 1) { // 我的报价
if ($map['status']) {
switch($map['status']) {
case 1:
$list['count']['quoted_status'] = $this->commonQuery($map, $input, 2);
$list['count']['selected_status'] = 0;
$list['count']['confirmed_status'] = 0;
break;
case 2:
$list['count']['quoted_status'] = 0;
$list['count']['selected_status'] = $this->commonQuery($map, $input, 2);
$list['count']['confirmed_status'] = 0;
break;
case 3:
$list['count']['quoted_status'] = 0;
$list['count']['selected_status'] = 0;
$list['count']['confirmed_status'] = $this->commonQuery($map, $input, 2);
break;
}
} else {
$map['status'] = 1;
$list['count']['quoted_status'] = $this->commonQuery($map, $input, 2);
$map['status'] = 2;
$list['count']['selected_status'] = $this->commonQuery($map, $input, 2);
$map['status'] = 3;
$list['count']['confirmed_status'] = $this->commonQuery($map, $input, 2);
}
$msg = $list['count'];
}
// return [0, '获取成功', $list['data'], $list['total']];
return [0, $msg, $list['data'], $list['total']];
}
}
// 获取历史报价
public function historyList($input)
{
$page = $input['page'];
$page = $input['page'];
$limit = $input['limit'];
$list = $this->from('quote as q')
->select("q.*")
->join('inquiry_items as it', 'q.inquiry_items_id', '=', 'it.id')
->where(function($query) use ($input) {
foreach ($input as $k=>$b){
switch ($k){
->where(function ($query) use ($input) {
foreach ($input as $k => $b) {
switch ($k) {
case "goods_name":
$query->where('it.goods_name', 'like', $b.'%');
$query->where('q.goods_name', 'like', $b . '%');
break;
case "brand_name":
$query->where('it.brand_name', 'like',$b.'%');
$query->where('q.brand_name', 'like', $b . '%');
break;
case "inquiry_items_id":
$query->where('it.id', '<>',$b);
$query->where('q.inquiry_items_id', '<>', $b);
break;
}
}
$query->whereIn('q.status', [1,2,3]);
$query->whereIn('q.status', [1, 2, 3]);
});
$list = $list->orderBy('id', 'desc')->paginate($limit, ['*'], 'page', $page)->toArray();
foreach ($list['data'] as $b=>&$v) {
if ($v['currency'] == 1){
foreach ($list['data'] as $b => &$v) {
if ($v['currency'] == 1) {
$v["price_origin"] = "--";
}else{
} else {
$v["price_rmb"] = "--";
}
$v["currency"] = InquiryMap::$currency[$v["currency"]];
if ($v['delivery_time'] > 6) {
$v['delivery_time'] = intval($v['delivery_time'] / 7).'周';
$v['delivery_time'] = intval($v['delivery_time'] / 7) . '周';
} else {
$v['delivery_time'] = $v['delivery_time'].'天';
$v['delivery_time'] = $v['delivery_time'] . '天';
}
$v["effect_days"] = $v["effect_days"]."天";
$v["effect_days"] = $v["effect_days"] . "天";
$v['price_rmb'] = $v['currency'] == 1 ? $v['price_rmb'] : '';
$v["digikey"] = "包装：".$v["raw_goods_packing"];
$v["digikey"] = "包装：" . $v["raw_goods_packing"];
}
return [0, '获取成功', $list['data'], $list['total']];
}
// 处理数据
public function handleData($data, $type)
{
if (empty($data)) return $data;
if (empty($data)) {
return $data;
}
foreach ($data as &$v) {
$v["inquiry_sn_origin"] = $v["inquiry_sn"];
$currency_sign = array_get(Config('quote.currency_sign'), $v['currency'], '￥');
$v['currency_val'] = array_get(Config('quote.currency'), $v['currency'], '人民币');
$v['price'] = $v['currency'] == 1 ? $currency_sign.$v['price_rmb'] : $currency_sign.$v['price_origin'];
$v['status_val'] = array_get(Config('quote.quote_status'), $v['status'], '');
$v['currency_val'] = array_get(Config('quote.currency'), $v['currency'], '人民币');
$v['price'] = $v['currency'] == 1 ? $currency_sign . $v['price_rmb'] : $currency_sign . $v['price_origin'];
$v['status_val'] = array_get(Config('quote.quote_status'), $v['status'], '');
if ($type == 3) { // 报价草稿
if ($v['delivery_time'] > 6) {
$v['delivery_time'] = intval($v['delivery_time'] / 7).'周';
$v['delivery_time'] = intval($v['delivery_time'] / 7) . '周';
} else {
$v['delivery_time'] = $v['delivery_time'].'天';
$v['delivery_time'] = $v['delivery_time'] . '天';
}
$v['price_rmb'] = $v['currency'] == 1 ? $v['price_rmb'] : '';
}
$v["digikey"] = "包装".@$v["raw_goods_packing"];
$v["digikey"] = "包装" . @$v["raw_goods_packing"];
}
return $data;
}
// 通用查询
public function commonQuery($map, $input, $type=1)
{
$list = $this->from('quote as q')->join('inquiry_items as it', 'q.inquiry_items_id', '=', 'it.id');
if (isset($type) && $type == 4) {
$list = $list->leftJoin('inquiry as i', 'it.inquiry_id', '=', 'i.id');
$perm = new PermController;
$role = $perm->getUserRole($input['user_id'], $input['user_name']); // 用户角色
switch ($role) {
case 2: // 销售查看下级
$sub_sale_ids = $perm->getSubSaleId($input['user_id']);
$list = $list->whereIn('i.create_uid', $sub_sale_ids);
break;
case 3: // 销售查看自己
$list = $list->where('i.create_uid', $input['user_id']);
break;
}
}
$list = $list->where(function ($query) use ($map) {
if ($map['inquiry_sn']) {
$query->where('q.inquiry_sn', '=', $map['inquiry_sn']);
}
if ($map['goods_name']) {
$query->where('it.goods_name', 'like', $map['goods_name'] . '%');
}
if ($map['brand_name']) {
$query->where('it.brand_name', 'like', $map['brand_name'] . '%');
}
if ($map['quote_sn']) {
$query->where('q.quote_sn', '=', $map['quote_sn']);
}
if ($map['status']) {
$query->where('q.status', '=', $map['status']);
}
// 创建时间
if(!empty($map['start_time']) && !empty($map['end_time'])) {
$query->whereBetween('q.create_time', [$map['start_time'], $map['end_time']]);
} else if(!empty($map['start_time'])) {
$query->where('q.create_time', '>=', $map['start_time']);
} else if(!empty($map['end_time'])) {
$query->where('q.create_time', '<=', $map['end_time']);
}
});
if ($type == 1) return $list;
return $list->where('q.create_uid', $input['user_id'])->whereNotIn('q.status', [0, -1])->count();
}
// 撤销报价
public function cancel($input)
{
$id = $input['id'];
$cancel_reason = $input['cancel_reason'];
if (!$id) return [-1, '参数缺失'];
if (!$id) {
return [-1, '参数缺失'];
}
try {
$quote_info = $this->find($id);
if ($quote_info['status'] == -1) return [1, '撤销失败，该报价已撤销，请刷新页面查看'];
if ($quote_info['status'] == 3) return [1, '撤销失败，该报价已确认，请刷新页面查看'];
if ($quote_info['status'] == -1) {
return [1, '撤销失败，该报价已撤销，请刷新页面查看'];
}
if ($quote_info['status'] == 3) {
return [1, '撤销失败，该报价已确认，请刷新页面查看'];
}
$res = $this->where('id', $id)->update(['status' => -1, 'cancel_reason'=>$cancel_reason]);
$res = $this->where('id', $id)->update(['status' => -1, 'cancel_reason' => $cancel_reason]);
// 需要删除当前用户的领取记录
$InquiryItemsAssignModel = new InquiryItemsAssignModel;
$InquiryItemsAssignModel->delAssign($quote_info['inquiry_items_id'], $quote_info['create_uid']);
// 查看当前询价明细的报价数量，若为0，则更新询价明细状态为待报价
$count = $this->where('inquiry_items_id', $quote_info['inquiry_items_id'])->where('status', '<>', -1)->count();
$count = $this->where('inquiry_items_id', $quote_info['inquiry_items_id'])->where('status', '<>',
-1)->count();
$InquiryItemsModel = new InquiryItemsModel;
if (!$count) {
$InquiryItemsModel->where('id', $quote_info['inquiry_items_id'])->update(['status' => 1]);
} else { // 若不为0，且该询价明细状态为‘已选中’，则更新为已报价
$status = $InquiryItemsModel->where('inquiry_items_id', $quote_info['inquiry_items_id'])->value('status');
$status = $InquiryItemsModel->where('inquiry_items_id',
$quote_info['inquiry_items_id'])->value('status');
if ($status == 3) {
$InquiryItemsModel->where('id', $quote_info['inquiry_items_id'])->update(['status' => 2]);
......@@ -294,11 +436,11 @@ class QuoteModel extends Model
}
$data = [];
$data['types'] = 2;
$data['types'] = 2;
$data['relation_id'] = $id;
$data['relation_sn'] = $quote_info['quote_sn'];
$data['content'] = '撤销报价，撤销原因：'.$cancel_reason.'，报价单号：'.$quote_info['quote_sn'];
$data['create_uid'] = $input['user_id'];
$data['content'] = '撤销报价，撤销原因：' . $cancel_reason . '，报价单号：' . $quote_info['quote_sn'];
$data['create_uid'] = $input['user_id'];
$data['create_name'] = $input['user_name'];
OpLogModel::log($data);
......@@ -307,8 +449,8 @@ class QuoteModel extends Model
$InquiryModel = new InquiryModel;
$inquiry_uid = $InquiryModel->where('id', $quote_info['inquiry_id'])->value('create_uid'); // 询价人
$contents = $input['user_name'].'已撤销报价，请及时查看！报价单号：'.$quote_info['quote_sn'].'，型号：'.$quote_info['goods_name'];
$contents = $input['user_name'] . '已撤销报价，请及时查看！报价单号：' . $quote_info['quote_sn'] . '，型号：' . $quote_info['goods_name'];
$CommonModel = new CommonModel;
$CommonModel->send_msg($inquiry_uid, $contents);
} catch (Exception $e) {
......@@ -317,79 +459,87 @@ class QuoteModel extends Model
return [0, '撤销成功'];
}
/*
* 批量新增报价
*
*/
public function addBatch($indata)
{
$input = json_decode($indata,true);
if (!$input || count($input) == 0 ) return [1, '数据不得为空'];
$input = json_decode($indata, true);
if (!$input || count($input) == 0) {
return [1, '数据不得为空'];
}
// 询价明细单状态
$inquiry_items_id = current($input)['inquiry_items_id'];
$inquiry_items_id = current($input)['inquiry_items_id'];
$inquiry_items_status = InquiryItemsModel::where('id', $inquiry_items_id)->value('status');
if ($inquiry_items_status == -1) return [1, '新增报价失败，该询价明细已关闭'];
if ($inquiry_items_status == -1) {
return [1, '新增报价失败，该询价明细已关闭'];
}
try{
try {
$con = DB::connection('rfq');
$con->beginTransaction();
$QuoteModel = new QuoteModel();
#批量获取品牌
$param = [];
foreach ($input as $a=>$b){
array_push($param,["spu_name"=>strtoupper($b["goods_name"]),"brand_name"=>strtoupper($b["brand_name"])]);
foreach ($input as $a => $b) {
array_push($param,
["spu_name" => strtoupper($b["goods_name"]), "brand_name" => strtoupper($b["brand_name"])]);
}
$classArr = (new SearchModel())->getClassName(\GuzzleHttp\json_encode($param));
$CommonModel = new CommonModel;
#拼接批量插入明细
foreach ($input as $k=>&$v){
if ($classArr !== false){
$classInfo = @$classArr[strtoupper($v["goods_name"])."#".strtoupper($v["brand_name"])];
foreach ($input as $k => &$v) {
if ($classArr !== false) {
$classInfo = @$classArr[strtoupper($v["goods_name"]) . "#" . strtoupper($v["brand_name"])];
if (count($classInfo) > 0){
if (count($classInfo) > 0) {
$v["class_id2"] = $classInfo["class_id2"];
$v["class_id2_name"] = $classInfo["class_id2_name"];
}
}
}
if ($v['currency'] != 1) {
$rate = $CommonModel->getRate($v['currency']);
$v['price_rmb'] = $rate ? number_format($v['price_origin'] * $rate, 6) : 0; // 需计算汇率（排序用）
}
if (@$v["supplier_name"] == "猎芯自营"){
$quote_sn = $this->where(["inquiry_items_id"=>$inquiry_items_id,"goods_id"=>$v["goods_id"],"supplier_name"=>"猎芯自营"])->value("quote_sn");
}else{
$quote_sn = $this->where(["inquiry_items_id"=>$inquiry_items_id,"raw_goods_sn"=>$v["raw_goods_sn"]])->value("quote_sn");
}
if ($quote_sn){ #存在更新
$quote_sn = $this->where([
"inquiry_items_id" => $inquiry_items_id,
"raw_goods_sn" => $v["raw_goods_sn"]
])->value("quote_sn");
if ($quote_sn) { #存在更新
$v["create_time"] = time();
$this->where(["quote_sn"=>$quote_sn])->update($v) ;
$this->where([
"inquiry_items_id" => $inquiry_items_id,
"raw_goods_sn" => $v["raw_goods_sn"]
])->update($v);
$currency_sign = array_get(Config('quote.currency_sign'), $v['currency'], '￥');
OpLogModel::log([
'types'=>2,
'relation_id'=>$inquiry_items_id,
'relation_sn'=>$quote_sn,
'content'=>'自动报价-更新，价格：'+($v["currency"] == "1" ? "¥".$v["price_rmb"] : $currency_sign.$v["price_origin"]),
'create_name'=>"系统",
'types' => 2,
'relation_id' => $inquiry_items_id,
'relation_sn' => $quote_sn,
'content' => '自动报价-更新，价格：' + ($v["currency"] == "1" ? "¥" . $v["price_rmb"] : $currency_sign . $v["price_origin"]),
'create_name' => "系统",
]);
}else{
} else {
$v["quote_sn"] = createSn($QuoteModel, 'quote_sn', 'B');
$v["create_time"] = time();
$v["update_time"] = time();
$this->insert($v);
OpLogModel::log([
'types'=>2,
'relation_id'=>$inquiry_items_id,
'relation_sn'=>$v["quote_sn"],
'content'=>'自动报价-插入',
'create_name'=>"系统",
'types' => 2,
'relation_id' => $inquiry_items_id,
'relation_sn' => $v["quote_sn"],
'content' => '自动报价-插入',
'create_name' => "系统",
]);
}
}
......@@ -411,10 +561,10 @@ class QuoteModel extends Model
$contents = '您有新报价，请及时查看！';
$CommonModel->send_msg($inquiry_uid, $contents);
return [0,"新增成功"];
}catch (\Exception $e) {
return [0, "新增成功"];
} catch (\Exception $e) {
$con->rollBack();
return [1001,"新增失败".$e->getMessage()];
return [1001, "新增失败" . $e->getMessage()];
}
}
......@@ -422,17 +572,20 @@ class QuoteModel extends Model
public function add($input)
{
$quote_info = $input['quote_info'];
if (!$quote_info) {
return [1, '报价数据不存在'];
}
if (!$quote_info) return [1, '报价数据不存在'];
try {
try {
// 询价明细单状态
$inquiry_items_status = InquiryItemsModel::where('id', $quote_info['inquiry_items_id'])->value('status');
if ($inquiry_items_status == -1) return [1, '新增报价失败，该询价明细已关闭'];
if ($inquiry_items_status == -1) {
return [1, '新增报价失败，该询价明细已关闭'];
}
$brand = json_decode($quote_info['brand_s'], true);
$quote_info['brand_id'] = $brand[0]['brand_id'];
$quote_info['brand_id'] = $brand[0]['brand_id'];
$quote_info['brand_name'] = $brand[0]['brand_name'];
unset($quote_info['brand_s']);
......@@ -452,21 +605,23 @@ class QuoteModel extends Model
$SearchModel = new SearchModel;
$res = $SearchModel->getClassName(json_encode([$params])); // 获取型号分类
if (isset($res[$params['spu_name']."#".strtoupper($params["brand_name"])])) {
$classInfo = $res[$params['spu_name']."#".strtoupper($params["brand_name"])];
if (isset($res[$params['spu_name'] . "#" . strtoupper($params["brand_name"])])) {
$classInfo = $res[$params['spu_name'] . "#" . strtoupper($params["brand_name"])];
$quote_info['class_id2'] = $classInfo['class_id2'];
$quote_info['class_id2'] = $classInfo['class_id2'];
$quote_info['class_id2_name'] = $classInfo['class_id2_name'];
}
$quote_info['status'] = 1; // 已报价
$quote_info['create_uid'] = $input['user_id'];
$quote_info['create_name'] = $input['user_name'];
$quote_info['status'] = 1; // 已报价
$quote_info['create_uid'] = $input['user_id'];
$quote_info['create_name'] = $input['user_name'];
$quote_info['delivery_time'] = $quote_info['delivery_time_unit'] == '天' ? $quote_info['delivery_time'] : $quote_info['delivery_time'] * 7;
unset($quote_info['delivery_time_unit']);
$res = $this->create($quote_info);
if ($res === false) return [2, '新增报价失败'];
if ($res === false) {
return [2, '新增报价失败'];
}
if ($inquiry_items_status == 1) { // 询价明细为待报价时，更新为已报价
InquiryItemsModel::where('id', $quote_info['inquiry_items_id'])->update(['status' => 2]);
......@@ -476,7 +631,7 @@ class QuoteModel extends Model
$InquiryItemsAssignModel = new InquiryItemsAssignModel;
$map = [];
$map['inquiry_items_id'] = $quote_info['inquiry_items_id'];
$map['assign_uid'] = $input['user_id'];
$map['assign_uid'] = $input['user_id'];
$assign_id = $InquiryItemsAssignModel->where($map)->value('id');
if (!$assign_id) {
......@@ -487,11 +642,11 @@ class QuoteModel extends Model
RedisDB::sadd('frq_quote_urge', $quote_info['inquiry_items_id']);
$data = [];
$data['types'] = 2;
$data['types'] = 2;
$data['relation_id'] = $res->id;
$data['relation_sn'] = $quote_info['quote_sn'];
$data['content'] = '新增报价，报价单号：'.$quote_info['quote_sn'];
$data['create_uid'] = $input['user_id'];
$data['content'] = '新增报价，报价单号：' . $quote_info['quote_sn'];
$data['create_uid'] = $input['user_id'];
$data['create_name'] = $input['user_name'];
OpLogModel::log($data);
......@@ -500,9 +655,10 @@ class QuoteModel extends Model
$InquiryModel = new InquiryModel;
$inquiry_uid = $InquiryModel->where('id', $quote_info['inquiry_id'])->value('create_uid'); // 询价人
$price = array_get(Config('quote.currency_sign'), $quote_info['currency'], '￥').$quote_info['price_origin'];
$price = array_get(Config('quote.currency_sign'), $quote_info['currency'],
'￥') . $quote_info['price_origin'];
$contents = $input['user_name'].'已报价，请及时查看！报价单号：'.$quote_info['quote_sn'].'，型号：'.$quote_info['goods_name'].'，单价：'.$price;
$contents = $input['user_name'] . '已报价，请及时查看！报价单号：' . $quote_info['quote_sn'] . '，型号：' . $quote_info['goods_name'] . '，单价：' . $price;
$CommonModel->send_msg($inquiry_uid, $contents);
} catch (Exception $e) {
return [1, $e->getMessage()];
......@@ -515,42 +671,50 @@ class QuoteModel extends Model
{
// 询价明细单状态
$inquiry_items_status = InquiryItemsModel::where('id', $input['inquiry_items_id'])->value('status');
if ($inquiry_items_status == -1) return [1, '导入报价失败，该询价明细已关闭'];
if ($inquiry_items_status == -1) {
return [1, '导入报价失败，该询价明细已关闭'];
}
$file = $_FILES['file']; // $request->file('file')
$filePath = $file['tmp_name']; // 临时路径
// 获取导入内容
$excel = [];
Excel::load($filePath, function($reader) use(&$excel){
Excel::load($filePath, function ($reader) use (&$excel) {
$data = $reader->getSheet(0);
$excel = $data->toArray();
}, 'GBK');
if (empty($excel)) return [1, '未获取到模板内容，请检查模板内容数据格式'];
if (empty($excel)) {
return [1, '未获取到模板内容，请检查模板内容数据格式'];
}
$map = Config('quote.import_quote_map');
if (count($map) != count($excel[0])) return [2, '导入模板错误'];
if (count($map) != count($excel[2])) {
return [2, '导入模板错误'];
}
$excel = $this->handleExcelData($excel, $map); // 处理数据
$valid = $this->excelValid($excel); // 验证excel内容
if ($valid[0] != 0) return $valid;
if ($valid[0] != 0) {
return $valid;
}
array_shift($excel); // 删除第一行
// 插入到报价表 -- 状态：草稿
try {
$ApiController = new ApiController;
$CommonModel = new CommonModel;
$CommonModel = new CommonModel;
foreach ($excel as &$v) {
if ($v['currency'] == '人民币') {
if ($v['currency'] == '人民币') {
$v['currency'] = 1;
} else {
$rate = $CommonModel->getRate($v['currency']); // 获取汇率
$v['currency'] = array_search($v['currency'], Config('quote.currency'));
$v['currency'] = array_search($v['currency'], Config('quote.currency'));
$v['price_rmb'] = $rate ? number_format($v['price_origin'] * $rate, 6) : 0;
}
......@@ -561,26 +725,28 @@ class QuoteModel extends Model
$v['delivery_time'] = intval(str_replace("天", "", $v['delivery_time']));
}
$v['quote_sn'] = $ApiController->createSn($this, 'quote_sn', 'B');
$v['inquiry_id'] = $input['inquiry_id'];
$v['inquiry_sn'] = $input['inquiry_sn'];
$v['quote_sn'] = $ApiController->createSn($this, 'quote_sn', 'B');
$v['inquiry_id'] = $input['inquiry_id'];
$v['inquiry_sn'] = $input['inquiry_sn'];
$v['inquiry_items_id'] = $input['inquiry_items_id'];
$v['status'] = 0;
$v['create_uid'] = $input['user_id'];
$v['create_name'] = $input['user_name'];
$v['create_time'] = time();
$v['update_time'] = time();
$v['status'] = 0;
$v['create_uid'] = $input['user_id'];
$v['create_name'] = $input['user_name'];
$v['create_time'] = time();
$v['update_time'] = time();
}
$res = $this->insert($excel); // 批量插入
if ($res === false) return [1, '添加报价草稿失败'];
if ($res === false) {
return [1, '添加报价草稿失败'];
}
$data = [];
$data['types'] = 2;
$data['types'] = 2;
$data['relation_id'] = $input['inquiry_items_id'];
$data['relation_sn'] = '';
$data['content'] = '批量导入报价';
$data['create_uid'] = $input['user_id'];
$data['content'] = '批量导入报价';
$data['create_uid'] = $input['user_id'];
$data['create_name'] = $input['user_name'];
OpLogModel::log($data);
......@@ -594,8 +760,8 @@ class QuoteModel extends Model
// 处理导入内容---赋上字段
public function handleExcelData($excel, $map)
{
$goods_info = array_map(function($val) use($map) {
foreach ($val as $k=>$v) {
$goods_info = array_map(function ($val) use ($map) {
foreach ($val as $k => $v) {
$tmp[$map[$k]] = trim($v);
}
......@@ -610,10 +776,12 @@ class QuoteModel extends Model
{
$count = count($excel);
if ($count == 1) return [3, '未填写报价信息'];
if ($count == 3) {
return [3, '未填写报价信息'];
}
// 获取excel菜单栏必填项
$required = array_filter($excel[0], function($v) {
$required = array_filter($excel[0], function ($v) {
return strpos($v, '*') === false ? false : true;
});
......@@ -621,14 +789,14 @@ class QuoteModel extends Model
$CommonModel = new CommonModel();
$err = []; // 提示信息
array_walk($excel, function($val, $key) use($CommonModel, $required, $required_keys, &$err) {
array_walk($excel, function ($val, $key) use ($CommonModel, $required, $required_keys, &$err) {
// 跳过第一条
if ($key != 0) {
if ($val['goods_name']) { // 判断型号是否存在
$res = $CommonModel->isGoodsNameExists($val['goods_name']);
if (!$res) {
$err[] = '第'.($key+1).'行，型号'.$val['goods_name'].'不存在于系统';
$err[] = '第' . ($key + 1) . '行，型号' . $val['goods_name'] . '不存在于系统';
return;
}
}
......@@ -637,7 +805,7 @@ class QuoteModel extends Model
$res = $CommonModel->isBrandNameExists($val['brand_name']);
if (!$res) {
$err[] = '第'.($key+1).'行，品牌'.$val['brand_name'].'不存在于系统';
$err[] = '第' . ($key + 1) . '行，品牌' . $val['brand_name'] . '不存在于系统';
return;
}
}
......@@ -646,62 +814,62 @@ class QuoteModel extends Model
$res = $CommonModel->isSupplierNameExists($val['supplier_name']);
if (!$res) {
$err[] = '第'.($key+1).'行，供应商'.$val['supplier_name'].'不存在于系统';
$err[] = '第' . ($key + 1) . '行，供应商' . $val['supplier_name'] . '不存在于系统';
return;
}
}
if ($val['currency'] != '人民币' && $val['price_origin'] <= 0) {
$err[] = '第'.($key+1).'行，单价等于或小于0';
$err[] = '第' . ($key + 1) . '行，单价等于或小于0';
return;
}
if ($val['currency'] != '人民币' && !preg_match('/^\d{0,9}(\.\d{0,6})?$/', $val['price_origin'])) {
$err[] = '第'.($key+1).'行，单价格式错误';
$err[] = '第' . ($key + 1) . '行，单价格式错误';
return;
}
if ($val['currency'] == '人民币' && $val['price_rmb'] <= 0) {
$err[] = '第'.($key+1).'行，含税价格等于或小于0';
$err[] = '第' . ($key + 1) . '行，含税价格等于或小于0';
return;
}
if ($val['currency'] == '人民币' && !preg_match('/^\d{0,9}(\.\d{0,6})?$/', $val['price_rmb'])) {
$err[] = '第'.($key+1).'行，含税价格格式错误';
$err[] = '第' . ($key + 1) . '行，含税价格格式错误';
return;
}
if (!preg_match('/^\d{1,9}$/', intval($val['quote_number']))) {
$err[] = '第'.($key+1).'行，报价数量格式错误，请填写整数';
$err[] = '第' . ($key + 1) . '行，报价数量格式错误，请填写整数';
return;
}
if (intval($val['quote_number']) <= 0) {
$err[] = '第'.($key+1).'行，报价数量等于或小于0';
$err[] = '第' . ($key + 1) . '行，报价数量等于或小于0';
return;
}
if (strpos($val['delivery_time'], "天") === false && strpos($val['delivery_time'], "周") === false) {
$err[] = '第'.($key+1).'行，交期输入有误，请以天或周结尾';
$err[] = '第' . ($key + 1) . '行，交期输入有误，请以天或周结尾';
return;
}
$delivery_time_day = intval(str_replace("天", "", $val['delivery_time']));
if ($delivery_time_day > 6) {
$err[] = '第'.($key+1).'行，交期输入有误，单位为天时，不能大于6，请按周计数';
$err[] = '第' . ($key + 1) . '行，交期输入有误，单位为天时，不能大于6，请按周计数';
return;
}
$delivery_time_week = intval(str_replace("周", "", $val['delivery_time']));
if ($delivery_time_week > 108) {
$err[] = '第'.($key+1).'行，交期输入有误，单位为周时，不能大于108周';
$err[] = '第' . ($key + 1) . '行，交期输入有误，单位为周时，不能大于108周';
return;
}
foreach ($val as $k=>$v) {
foreach ($val as $k => $v) {
if (in_array($k, $required_keys)) {
if (empty($v)) { // 若必填项值为空，返回提示信息
$err[] = $required[$k].'列，第'.($key+1).'行不能为空';
$err[] = $required[$k] . '列，第' . ($key + 1) . '行不能为空';
break;
}
}
......@@ -709,7 +877,9 @@ class QuoteModel extends Model
}
});
if (!empty($err)) return [1, implode('; ', $err)];
if (!empty($err)) {
return [1, implode('; ', $err)];
}
return [0, '验证成功'];
}
......@@ -719,29 +889,31 @@ class QuoteModel extends Model
{
$id = $input['id'];
if (!$id) return [-1, '参数缺失'];
if (!$id) {
return [-1, '参数缺失'];
}
try {
$draft_info = $this->find($id);
if ($draft_info['currency'] == 1) {
$currency_val = 'RMB';
$price = '，单价：'.$draft_info['price_origin'].'，含税单价：'.$draft_info['price_rmb'];
$price = '，单价：' . $draft_info['price_origin'] . '，含税单价：' . $draft_info['price_rmb'];
} else {
$currency_val = 'USD';
$price = '，单价：'.$draft_info['price_origin'];
$price = '，单价：' . $draft_info['price_origin'];
}
$content = '删除报价草稿，草稿报价型号：'.$draft_info['goods_name'].'，品牌：'.$draft_info['brand_name'].'，供应商：'.$draft_info['supplier_name'].'，币种：'.$currency_val.$price;
$content = '删除报价草稿，草稿报价型号：' . $draft_info['goods_name'] . '，品牌：' . $draft_info['brand_name'] . '，供应商：' . $draft_info['supplier_name'] . '，币种：' . $currency_val . $price;
$res = $this->where('id', $id)->delete();
$data = [];
$data['types'] = 2;
$data['types'] = 2;
$data['relation_id'] = $input['inquiry_items_id'];
$data['relation_sn'] = '';
$data['content'] = $content;
$data['create_uid'] = $input['user_id'];
$data['content'] = $content;
$data['create_uid'] = $input['user_id'];
$data['create_name'] = $input['user_name'];
OpLogModel::log($data);
......@@ -755,71 +927,82 @@ class QuoteModel extends Model
// 批量提交报价
public function batchQuote($input)
{
if (!$input['inquiry_items_id']) return [-1, '参数缺失'];
if (empty($input['inquiry_items_ids'])) {
return [-1, '参数缺失'];
}
// 询价明细单状态
$inquiry_items_status = InquiryItemsModel::where('id', $input['inquiry_items_id'])->value('status');
if ($inquiry_items_status == -1) return [1, '批量提交报价失败，该询价明细已关闭'];
$inquiry_items_ids = explode(",", $input['inquiry_items_ids']);
$inquiry_items_ids = array_unique(array_values(array_filter($inquiry_items_ids)));
try {
$map = [];
$map['inquiry_items_id'] = $input['inquiry_items_id'];
$map['status'] = 0; // 草稿状态
foreach ($inquiry_items_ids as $inquiry_items_id){
// 询价明细单状态
$inquiry_items_status = InquiryItemsModel::where('id', $inquiry_items_id)->value('status');
if ($inquiry_items_status == -1) {
return [1, '批量提交报价失败，该询价明细已关闭'];
}
$count = $this->where($map)->count();
$map = [];
$map['inquiry_items_id'] = $inquiry_items_id;
$map['status'] = 0; // 草稿状态
if (!$count) return [1, '当前没有导入报价单'];
$count = $this->where($map)->count();
$quote_info = $this->where($map)->get()->toArray(); // 获取草稿信息
if (!$count) {
return [1, '当前没有导入报价单'];
}
$this->where($map)->update(['status' => 1]);
$quote_info = $this->where($map)->get()->toArray(); // 获取草稿信息
if ($inquiry_items_status == 1) { // 询价明细为待报价时，更新为已报价
InquiryItemsModel::where('id', $input['inquiry_items_id'])->update(['status' => 2]);
}
$this->where($map)->update(['status' => 1]);
// 从询价池过来的，自动领取
$InquiryItemsAssignModel = new InquiryItemsAssignModel;
$where = [];
$where['inquiry_items_id'] = $input['inquiry_items_id'];
$where['assign_uid'] = $input['user_id'];
$assign_id = $InquiryItemsAssignModel->where($where)->value('id');
if ($inquiry_items_status == 1) { // 询价明细为待报价时，更新为已报价
InquiryItemsModel::where('id', $inquiry_items_id)->update(['status' => 2]);
}
if (!$assign_id) {
$InquiryItemsAssignModel->assign($input['inquiry_items_id'], $input['user_id']);
}
// 从询价池过来的，自动领取
$InquiryItemsAssignModel = new InquiryItemsAssignModel;
$where = [];
$where['inquiry_items_id'] = $inquiry_items_id;
$where['assign_uid'] = $input['user_id'];
$assign_id = $InquiryItemsAssignModel->where($where)->value('id');
// 通知询价人，放入redis
RedisDB::sadd('frq_quote_urge', $input['inquiry_items_id']);
if (!$assign_id) {
$InquiryItemsAssignModel->assign($inquiry_items_id, $input['user_id']);
}
// 推送消息
$InquiryModel = new InquiryModel;
$inquiry_uid = $InquiryModel->where('id', $quote_info[0]['inquiry_id'])->value('create_uid'); // 询价人
// 通知询价人，放入redis
RedisDB::sadd('frq_quote_urge', $inquiry_items_id);
$contents = $input['user_name'].'已报价，请及时查看！';
// 推送消息
$InquiryModel = new InquiryModel;
$inquiry_uid = $InquiryModel->where('id', $quote_info[0]['inquiry_id'])->value('create_uid'); // 询价人
foreach ($quote_info as $v) {
$data = [];
$data['types'] = 2;
$data['relation_id'] = $v['id'];
$data['relation_sn'] = '';
$data['content'] = '批量提交报价，报价单号：'.$v['quote_sn'];
$data['create_uid'] = $input['user_id'];
$data['create_name'] = $input['user_name'];
$contents = $input['user_name'] . '已报价，请及时查看！';
OpLogModel::log($data);
foreach ($quote_info as $v) {
$data = [];
$data['types'] = 2;
$data['relation_id'] = $v['id'];
$data['relation_sn'] = '';
$data['content'] = '批量提交报价，报价单号：' . $v['quote_sn'];
$data['create_uid'] = $input['user_id'];
$data['create_name'] = $input['user_name'];
if ($v['currency'] == 1) {
$price = '￥'.$v['price_rmb'];
} else {
$price = '$'.$v['price_origin'];
OpLogModel::log($data);
if ($v['currency'] == 1) {
$price = '￥' . $v['price_rmb'];
} else {
$price = '$' . $v['price_origin'];
}
$contents .= '报价单号：' . $v['quote_sn'] . '，单价：' . $price . '；';
}
$contents .= '报价单号：'.$v['quote_sn'].'，单价：'.$price.'；';
$CommonModel = new CommonModel;
$CommonModel->send_msg($inquiry_uid, trim($contents, '；'));
}
$CommonModel = new CommonModel;
$CommonModel->send_msg($inquiry_uid, trim($contents, '；'));
} catch (Exception $e) {
return [1, $e->getMessage()];
}
......@@ -830,13 +1013,19 @@ class QuoteModel extends Model
// 修改报价
public function edit($input)
{
if (!$input['quote_id']) return [-1, '参数缺失'];
if (!$input['quote_id']) {
return [-1, '参数缺失'];
}
try {
$info = $this->find($input['quote_id']);
if ($info['status'] == -1) return [1, '修改失败，报价已撤销，请刷新查看'];
if ($info['status'] == 3) return [1, '修改失败，报价已确认，请刷新查看'];
if ($info['status'] == -1) {
return [1, '修改失败，报价已撤销，请刷新查看'];
}
if ($info['status'] == 3) {
return [1, '修改失败，报价已确认，请刷新查看'];
}
$quote_info = $input['quote_info'];
......@@ -850,26 +1039,26 @@ class QuoteModel extends Model
}
$brand = json_decode($quote_info['brand_s'], true);
$quote_info['brand_id'] = $brand[0]['brand_id'];
$quote_info['brand_id'] = $brand[0]['brand_id'];
$quote_info['brand_name'] = $brand[0]['brand_name'];
unset($quote_info['brand_s']);
$params = [];
$params['spu_name'] = strtoupper($quote_info['goods_name']);
$params['spu_name'] = strtoupper($quote_info['goods_name']);
$params['brand_name'] = $quote_info['brand_name'];
$SearchModel = new SearchModel;
$res = $SearchModel->getClassName(json_encode([$params])); // 获取型号分类
if (isset($res[$params['spu_name']."#".strtoupper($params["brand_name"])])) {
$classInfo = $res[$params['spu_name']."#".strtoupper($params["brand_name"])];
if (isset($res[$params['spu_name'] . "#" . strtoupper($params["brand_name"])])) {
$classInfo = $res[$params['spu_name'] . "#" . strtoupper($params["brand_name"])];
$quote_info['class_id2'] = $classInfo['class_id2'];
$quote_info['class_id2'] = $classInfo['class_id2'];
$quote_info['class_id2_name'] = $classInfo['class_id2_name'];
}
$delivery_time = $quote_info['delivery_time'].$quote_info['delivery_time_unit'];
$delivery_time = $quote_info['delivery_time'] . $quote_info['delivery_time_unit'];
$quote_info['delivery_time'] = $quote_info['delivery_time_unit'] == '天' ? $quote_info['delivery_time'] : $quote_info['delivery_time'] * 7;
unset($quote_info['delivery_time_unit']);
......@@ -877,19 +1066,20 @@ class QuoteModel extends Model
$this->where('id', $input['quote_id'])->update($quote_info);
if ($quote_info['currency'] == 1) {
$price_log = '含税单价：￥'.$quote_info['price_rmb'];
$price_log = '含税单价：￥' . $quote_info['price_rmb'];
} else {
$price_log = '单价：'.array_get(Config('quote.currency_sign'), $quote_info['currency'], '￥').$quote_info['price_origin'];
$price_log = '单价：' . array_get(Config('quote.currency_sign'), $quote_info['currency'],
'￥') . $quote_info['price_origin'];
}
$content = '修改报价，报价单号：'.$input['quote_sn'].'，型号：'.$quote_info['goods_name'].'，'.$price_log.'，批次：'.$quote_info['batch'].'，货期：'.$delivery_time;
$content = '修改报价，报价单号：' . $input['quote_sn'] . '，型号：' . $quote_info['goods_name'] . '，' . $price_log . '，批次：' . $quote_info['batch'] . '，货期：' . $delivery_time;
$data = [];
$data['types'] = 2;
$data['types'] = 2;
$data['relation_id'] = $input['quote_id'];
$data['relation_sn'] = $input['quote_sn'];
$data['content'] = $content;
$data['create_uid'] = $input['user_id'];
$data['content'] = $content;
$data['create_uid'] = $input['user_id'];
$data['create_name'] = $input['user_name'];
OpLogModel::log($data);
......@@ -898,7 +1088,7 @@ class QuoteModel extends Model
$InquiryModel = new InquiryModel;
$inquiry_uid = $InquiryModel->where('id', $input['inquiry_id'])->value('create_uid'); // 询价人
$contents = $input['user_name'].$content;
$contents = $input['user_name'] . $content;
$CommonModel->send_msg($inquiry_uid, $contents);
} catch (Exception $e) {
......@@ -915,40 +1105,40 @@ class QuoteModel extends Model
$curr_zero_time = strtotime(date('Y-m-d', time())); // 当日0点
switch ($input['time_day']) {
case 1:
case 1:
for ($i = 0; $i < 24; $i++) {
$start_time = $curr_zero_time + $i * 3600;
$end_time = $start_time + 3600;
$end_time = $start_time + 3600;
$data['today_quote'][] = $this->getTodayQoutCount($input, $start_time, $end_time);
$data['today_quote'][] = $this->getTodayQoutCount($input, $start_time, $end_time);
$data['today_no_quote'][] = $this->getTodayNoQoutCount($input, $start_time, $end_time);
$data['x_axis_data'][] = $i.'点';
$data['x_axis_data'][] = $i . '点';
}
break;
case 7:
for ($i = 7; $i > 0; $i--) {
$start_time = $curr_zero_time - $i * 86400;
$end_time = $start_time + 86399;
$end_time = $start_time + 86399;
$data['today_quote'][] = $this->getTodayQoutCount($input, $start_time, $end_time);
$data['today_quote'][] = $this->getTodayQoutCount($input, $start_time, $end_time);
$data['today_no_quote'][] = $this->getTodayNoQoutCount($input, $start_time, $end_time);
$data['x_axis_data'][] = date('Y-m-d', $curr_zero_time - $i * 86400);
$data['x_axis_data'][] = date('Y-m-d', $curr_zero_time - $i * 86400);
}
break;
case 30:
for ($i = 30; $i > 0; $i--) {
$start_time = $curr_zero_time - $i * 86400;
$end_time = $start_time + 86399;
$end_time = $start_time + 86399;
$data['today_quote'][] = $this->getTodayQoutCount($input, $start_time, $end_time);
$data['today_quote'][] = $this->getTodayQoutCount($input, $start_time, $end_time);
$data['today_no_quote'][] = $this->getTodayNoQoutCount($input, $start_time, $end_time);
$data['x_axis_data'][] = date('Y-m-d', $curr_zero_time - $i * 86400);
$data['x_axis_data'][] = date('Y-m-d', $curr_zero_time - $i * 86400);
}
break;
}
}
return [0, '', $data];
}
......@@ -956,19 +1146,20 @@ class QuoteModel extends Model
// 当日报价数
public function getTodayQoutCount($input, $start_time, $end_time)
{
return $this->where('create_uid', $input['user_id'])->whereBetween('create_time', [$start_time, $end_time])->count();
return $this->where('create_uid', $input['user_id'])->whereBetween('create_time',
[$start_time, $end_time])->count();
}
// 当日未报价数
public function getTodayNoQoutCount($input, $start_time, $end_time)
{
return $this->from('inquiry_items as it')
return $this->from('inquiry_items as it')
->join('inquiry_items_assign as ia', 'it.id', '=', 'ia.inquiry_items_id')
->leftJoin('quote as q', 'it.id', '=', 'q.inquiry_items_id')
->where('ia.assign_uid', $input['user_id']) // 指定或领取给当前用户
->where('ia.assign_uid', $input['user_id'])// 指定或领取给当前用户
->whereBetween('ia.create_time', [$start_time, $end_time])
->where('it.status', 1) // 未报价
->orWhereRaw("(lie_it.status in (2, 3, 4) and lie_q.create_uid != {$input['user_id']})") // 已报价且非当前用户
->where('it.status', 1)// 未报价
->orWhereRaw("(lie_it.status in (2, 3, 4) and lie_q.create_uid != {$input['user_id']})")// 已报价且非当前用户
->count();
}
......@@ -977,31 +1168,36 @@ class QuoteModel extends Model
{
$quote_id = $input['id'];
$status = $input['status'];
if (!$quote_id) return [-1, '参数缺失'];
if (!$quote_id) {
return [-1, '参数缺失'];
}
try {
$QuoteModel = new QuoteModel();
$InquiryItemsModel = new InquiryItemsModel();
$QuoteModel = new QuoteModel();
$InquiryItemsModel = new InquiryItemsModel();
$info = $QuoteModel->select("status","inquiry_items_id")->where("id",$quote_id)->first()->toArray();
$info = $QuoteModel->select("status", "inquiry_items_id")->where("id", $quote_id)->first()->toArray();
$inquiry_items_id = $info["inquiry_items_id"];
#更新询价明细表状态
$InquiryItemsModel->where("id",$inquiry_items_id)->update(["status"=>2, 'update_time'=>time()]); #更新报价待报价
$InquiryItemsModel->where("id", $inquiry_items_id)->update([
"status" => 2,
'update_time' => time()
]); #更新报价待报价
#更新
if ($info["status"] == 2){ #撤销选中
$QuoteModel->where("inquiry_items_id",$inquiry_items_id)->whereNotIn("status",[-1,0,3])
->update(["status"=>1, 'update_time'=>time()]); #重启其他所有状态为 已报价
if ($info["status"] == 2) { #撤销选中
$QuoteModel->where("inquiry_items_id", $inquiry_items_id)->whereNotIn("status", [-1, 0, 3])
->update(["status" => 1, 'update_time' => time()]); #重启其他所有状态为 已报价
}
if ($info["status"] == 3){ #撤销确认
$QuoteModel->where("inquiry_items_id",$inquiry_items_id)->whereNotIn("status",[-1,0,2])
->update(["status"=>1, 'update_time'=>time()]); #重启其他所有状态为 已报价
if ($info["status"] == 3) { #撤销确认
$QuoteModel->where("inquiry_items_id", $inquiry_items_id)->whereNotIn("status", [-1, 0, 2])
->update(["status" => 1, 'update_time' => time()]); #重启其他所有状态为 已报价
}
$data = [];
$data['types'] = 1;
$data['types'] = 1;
$data['relation_id'] = $inquiry_items_id;
$data['content'] = '撤销报价：'.QuoteMap::$status[$status];
$data['create_uid'] = $input['user_id'];
$data['content'] = '撤销报价：' . QuoteMap::$status[$status];
$data['create_uid'] = $input['user_id'];
$data['create_name'] = $input["user_name"];
OpLogModel::log($data);
......
app/map/InquiryMap.php
......@@ -3,7 +3,7 @@ namespace App\map;
//询价枚举
class InquiryMap{
//状态 -1：已关闭 1：待报价 2：已报价 3：已选中 4：已固定 5：已确认
//状态 -1：已关闭 1：待报价 2：已报价 3：已选中 4：已领取 5：已确认
const status_close = -1;
const status_ready = 1;
const status_replay = 2;
......@@ -15,7 +15,7 @@ class InquiryMap{
self::status_ready => "待报价",
self::status_replay => "已报价",
self::status_check => "已选中",
self::status_fix => "已固定",
self::status_fix => "已领取",
self::status_sure => "已确认",
];
......
bootstrap/app.php
......@@ -41,6 +41,7 @@ $app->singleton(
App\Exceptions\Handler::class
);
$app->useStoragePath(APP_STORAGE_PATH);
/*
|--------------------------------------------------------------------------
| Return The Application
......
config/database.php
......@@ -122,11 +122,11 @@ return [
],
'mongodb' => [
'driver' => 'mongodb',
'host' => get_resource_config_section('rabbit', 'rabbit')['host'],
'database' => get_resource_config_section('rabbit', 'rabbit')['db'],
'username' => get_resource_config_section('rabbit', 'rabbit')['user'],
'password' => get_resource_config_section('rabbit', 'rabbit')['passwd'],
'port' => get_resource_config_section('rabbit', 'rabbit')['port'],
'host' => get_resource_config_section('mongodb', 'mongo')['host'],
'database' => get_resource_config_section('mongodb', 'mongo')['db'],
'username' => get_resource_config_section('mongodb', 'mongo')['user'],
'password' => get_resource_config_section('mongodb', 'mongo')['passwd'],
'port' => get_resource_config_section('mongodb', 'mongo')['port'],
// 'options' => [
// 'database' => 'ichunt' // sets the authentication database required by mongo 3
// ]
......
config/define.php
......@@ -12,10 +12,14 @@ define('STATUS_ILLEGAL_PARAM',300); //操作被拒绝，可能是参数不合法
define('STATUS_ERROR',400); //列表的数据已被穷尽，没有更多数据
define('STATUS_UNKNOWN',500); //服务器未知错误
$EnvLoader = new Loader(dirname( $_SERVER['DOCUMENT_ROOT'] ) . '/.env');
$EnvLoader->load();
$RESOURCE_CONFIG_DIR = $EnvLoader->getEnvironmentVariable("RESOURCE_CONFIG_DIR");
$APP_STORAGE_PATH = $EnvLoader->getEnvironmentVariable("APP_STORAGE_PATH");
$default_env_file = dirname( $_SERVER['DOCUMENT_ROOT'] ) . '/.env';
$RESOURCE_CONFIG_DIR = $APP_STORAGE_PATH = '';
if (file_exists($default_env_file)){
$EnvLoader = new Loader($default_env_file);
$EnvLoader->load();
$RESOURCE_CONFIG_DIR = $EnvLoader->getEnvironmentVariable("RESOURCE_CONFIG_DIR");
$APP_STORAGE_PATH = $EnvLoader->getEnvironmentVariable("APP_STORAGE_PATH");
}
// 定义资源配置文件目录
define('RESOURCE_CONFIG_DIR' , ($RESOURCE_CONFIG_DIR) ? $RESOURCE_CONFIG_DIR : '/data2/liexin_config');
......
config/quote.php
<?php
return [
'quote_status' => [ // 报价状态
-1 => '已撤销',
0 => '草稿',
1 => '已报价',
2 => '已选中',
......
public/index.php
......@@ -18,7 +18,6 @@ ini_set('mongo.long_as_object', 1);
| loading any of our classes later on. It feels nice to relax.
|
*/
require __DIR__.'/../bootstrap/autoload.php';
/*
......
public/pdf/sale_report_1620901457.pdf 0 → 100644
No preview for this file type
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment