123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210 |
- <?php
- namespace app\admin\controller;
- use app\admin\model\OrderImportFromC as OIFCModel;
- use Exception;
- use think\facade\Db;
- use think\facade\Validate;
- //C端订单导入及处理类
- class OrderImport extends Base
- {
- //订单导入
- public function import()
- {
- $param = $this->request->only(['token', 'list'], 'post', 'trim');
- $val_params = Validate::rule(['token' => 'require', 'list' => 'require|array']);
- if (!$val_params->check($param)) throw new \think\Exception($val_params->getError());
- Db::startTrans();
- try {
- $userinfo = GetUserInfo($param['token']);
- $createrid = isset($user["data"]['id']) ? $userinfo["data"]['id'] : 0;
- $creater = isset($user["data"]['nickname']) ? $userinfo["data"]['nickname'] : "";
- $val = Validate::rule([
- 'platform_code|平台订单号' => 'require|length:0,255',
- 'po_code|其他单号' => 'length:0,255',
- 'platform_time|平台下单时间' => 'require|date',
- 'sale_source|销售渠道' => 'require|length:0,255',
- 'plat_code|平台商品编号' => 'require|length:0,255',
- 'price|单价' => 'require|float',
- 'num|数量' => 'require|number',
- 'before_discount_all_price|优惠前总金额' => 'require|float',
- 'discount_price|优惠金额' => 'require|float',
- 'after_price|商品优惠后金额' => 'require|float',
- 'activity_name|优惠活动名称' => 'require|length:0,255',
- 'mode|收费模式' => 'require|length:0,255',
- 'order_remark|订单备注' => 'length:0,255',
- 'contactor|收货人' => 'require|length:0,255',
- 'mobile|联系电话' => 'require|length:0,20',
- 'addr|联系地址' => 'require|length:0,255',
- ]);
- $insert_data = [];
- foreach ($param['list'] as $key => $value) {
- if (!$val->check($value)) throw new \think\Exception('第' . (string)($key + 1) . '行数据格式有问题,' . $val->getError());
- else {
- $value['createrid'] = $createrid;
- $value['creater'] = $creater;
- $insert_data[] = $value;
- }
- }
- $res = Db::name('order_import_from_c')
- ->limit(100)
- ->insertAll($insert_data);
- if ($res) {
- Db::commit();
- return app_show(0, "导入成功,共" . (string)$res . '条记录');
- } else {
- Db::rollback();
- return error_show(1005, '导入失败');
- }
- } catch (Exception $exception) {
- Db::rollback();
- return error_show(1005, $exception->getMessage());
- }
- }
- //查看订单录入列表
- public function getImportList()
- {
- $param = $this->request->only([
- 'status' => 0,
- 'platform_code' => '',
- 'po_code' => '',
- 'platform_time_start' => '',
- 'platform_time_end' => '',
- 'addtime_start' => '',
- 'addtime_end' => '',
- 'plat_code' => '',
- 'page' => 1,
- 'size' => 15,
- ], 'post', 'trim');
- $where = [];
- if ($param['status']) $where[] = ['c.status', '=', $param['status']];
- if ($param['platform_code']) $where[] = ['c.platform_code', 'like', '%' . $param['platform_code'] . '%'];
- if ($param['po_code']) $where[] = ['c.po_code', 'like', '%' . $param['po_code'] . '%'];
- if ($param['platform_time_start'] && $param['platform_time_end']) $where[] = ['c.platform_time', 'between', [$param['platform_time_start'], $param['platform_time_end']]];
- if ($param['addtime_start'] && $param['addtime_end']) $where[] = ['c.addtime', 'between', [$param['addtime_start'], $param['addtime_end']]];
- if ($param['plat_code']) $where[] = ['c.plat_code', 'like', '%' . $param['plat_code'] . '%'];
- $db = OIFCModel::alias('c')->where($where);
- $total = $db->count('id');
- $list = $db
- ->page($param['page'], $param['size'])
- ->order('id', 'desc')
- ->select()
- ->toArray();
- return app_show(0, "获取成功", ['list' => $list, 'count' => $total]);
- }
- //查看订单录入详情
- public function getImportInfo()
- {
- $id = $this->request->post('id/d', 0, 'trim');
- $info = OIFCModel::alias('c')
- ->field('c.*,ce.*,b.company,ci.companyName CustomerCompanyName,s.name supplierName')
- ->leftJoin('order_import_from_c_extend ce', 'ce.order_import_from_c_id=c.id')
- ->leftJoin('business b', 'b.companyNo=ce.companyNo AND b.is_del=0')
- ->leftJoin('customer_info ci', 'ci.companyNo=ce.customer_code AND ci.is_del=0')
- ->leftJoin('supplier s', 's.code=ce.supplierNo AND s.is_del=0')
- ->where('c.id', $id)
- ->find();
- $info['platform_names'] = Db::name('platform')
- ->whereIn('platform_code', $info['platform_codes'])
- ->where(['is_del' => 0, 'status' => 1])
- ->column('platform_name');
- $info['addr_name'] = GetAddr($info['addr_code']);
- //导入字段
- $res['import']=[
- 'platform_code'=>$info['platform_code'],
- 'platform_time'=>$info['platform_time'],
- 'plat_code'=>$info['plat_code'],
- 'sale_source'=>$info['sale_source'],
- 'price'=>$info['price'],
- 'num'=>$info['num'],
- 'before_discount_all_price'=>$info['before_discount_all_price'],
- 'activity_name'=>$info['activity_name'],
- 'discount_price'=>$info['discount_price'],
- 'after_price'=>$info['after_price'],
- 'mode'=>$info['mode'],
- 'order_remark'=>$info['order_remark'],
- 'contactor'=>$info['contactor'],
- 'mobile'=>$info['mobile'],
- 'addr'=>$info['addr'],
- ];
- //确认字段
- $res['confirm']=$info;
- return app_show(0, '请求成功', $res);
- }
- //用户确认订单数据(编辑)
- public function confirmImportData()
- {
- //每次编辑,都新增一条记录到extend表,同时原纪录作废,确保同一个order_import_from_c_id下只有一个正常的记录
- }
- //批量关联库存
- public function relationStockBatch()
- {
- }
- //【脚本】批量解析用户导入的数据
- public function analysisBatchDataBySystem()
- {
- //解析信息存到extend表,其中customer_code字段根据订单编号去customer_info查,其他根据商品编号查询
- $list = OIFCModel::where(['status'=>OIFCModel::$status_wait_validate])
- ->limit(10)
- ->cursor();
- foreach ($list as $value){
- //1.解析数据
- //2.判断是否库存品
- //3.判断库存
- //4.处理
- }
- return '123123123wwafa';
- }
- //【辅助1】获取线上商品详情
- //【辅助2】接口2-获取销售渠道备选数据:入参所在平台Id,响应:销售渠道备选数据
- }
|