OrderImport.php 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\ActionLog;
  4. use app\admin\model\OrderImportFromC as OIFCModel;
  5. use app\admin\model\ProcessOrder;
  6. use Exception;
  7. use think\facade\Db;
  8. use think\facade\Validate;
  9. //C端订单导入及处理类
  10. class OrderImport extends Base
  11. {
  12. //订单导入
  13. public function import()
  14. {
  15. $param = $this->request->only(['token', 'list'], 'post', 'trim');
  16. $val_params = Validate::rule(['token' => 'require', 'list' => 'require|array']);
  17. if (!$val_params->check($param)) throw new \think\Exception($val_params->getError());
  18. Db::startTrans();
  19. try {
  20. $userinfo = GetUserInfo($param['token']);
  21. $createrid = isset($user["data"]['id']) ? $userinfo["data"]['id'] : 0;
  22. $creater = isset($user["data"]['nickname']) ? $userinfo["data"]['nickname'] : "";
  23. $insert_data = [];
  24. foreach ($param['list'] as $key => $value) {
  25. $value['createrid'] = $createrid;
  26. $value['creater'] = $creater;
  27. $insert_data[] = $value;
  28. }
  29. $res = Db::name('order_import_from_c')
  30. ->limit(100)
  31. ->insertAll($insert_data);
  32. if ($res) {
  33. Db::commit();
  34. return app_show(0, "导入成功,共" . (string)$res . '条记录');
  35. } else {
  36. Db::rollback();
  37. return error_show(1005, '导入失败');
  38. }
  39. } catch (Exception $exception) {
  40. Db::rollback();
  41. return error_show(1005, $exception->getMessage());
  42. }
  43. }
  44. //查看订单录入列表
  45. public function getImportList()
  46. {
  47. $param = $this->request->only([
  48. 'status' => 0,
  49. 'platform_code' => '',
  50. 'po_code' => '',
  51. 'platform_time_start' => '',
  52. 'platform_time_end' => '',
  53. 'addtime_start' => '',
  54. 'addtime_end' => '',
  55. 'plat_code' => '',
  56. 'page' => 1,
  57. 'size' => 15,
  58. ], 'post', 'trim');
  59. $where = [];
  60. if ($param['status']) $where[] = ['c.status', '=', $param['status']];
  61. if ($param['platform_code']) $where[] = ['c.platform_code', 'like', '%' . $param['platform_code'] . '%'];
  62. if ($param['po_code']) $where[] = ['c.po_code', 'like', '%' . $param['po_code'] . '%'];
  63. if ($param['platform_time_start'] && $param['platform_time_end']) $where[] = ['c.platform_time', 'between', [$param['platform_time_start'], $param['platform_time_end']]];
  64. if ($param['addtime_start'] && $param['addtime_end']) $where[] = ['c.addtime', 'between', [$param['addtime_start'], $param['addtime_end']]];
  65. if ($param['plat_code']) $where[] = ['c.plat_code', 'like', '%' . $param['plat_code'] . '%'];
  66. $db = OIFCModel::alias('c')->where($where);
  67. $total = $db->count('id');
  68. $list = $db
  69. ->page($param['page'], $param['size'])
  70. ->order('id', 'desc')
  71. ->select()
  72. ->toArray();
  73. return app_show(0, "获取成功", ['list' => $list, 'count' => $total]);
  74. }
  75. //查看订单录入详情
  76. public function getImportInfo()
  77. {
  78. $id = $this->request->post('id/d', 0, 'trim');
  79. $info = OIFCModel::alias('c')
  80. ->field('c.*,ce.*,b.company,ci.companyName CustomerCompanyName,s.name supplierName')
  81. ->leftJoin('order_import_from_c_extend ce', 'ce.order_import_from_c_id=c.id')
  82. ->leftJoin('business b', 'b.companyNo=ce.companyNo AND b.is_del=0')
  83. ->leftJoin('customer_info ci', 'ci.companyNo=ce.customer_code AND ci.is_del=0')
  84. ->leftJoin('supplier s', 's.code=ce.supplierNo AND s.is_del=0')
  85. ->where('c.id', $id)
  86. ->find();
  87. if (!empty($info)) {
  88. $info['platform_names'] = Db::name('platform')
  89. ->whereIn('platform_code', $info['platform_codes'])
  90. ->where(['is_del' => 0, 'status' => 1])
  91. ->column('platform_name');
  92. $info['addr_name'] = GetAddr($info['addr_code']);
  93. //导入字段
  94. $res['import'] = [
  95. 'platform_code' => $info['platform_code'],
  96. 'platform_time' => $info['platform_time'],
  97. 'plat_code' => $info['plat_code'],
  98. 'sale_source' => $info['sale_source'],
  99. 'price' => $info['price'],
  100. 'num' => $info['num'],
  101. 'before_discount_all_price' => $info['before_discount_all_price'],
  102. 'activity_name' => $info['activity_name'],
  103. 'discount_price' => $info['discount_price'],
  104. 'after_price' => $info['after_price'],
  105. 'mode' => $info['mode'],
  106. 'order_remark' => $info['order_remark'],
  107. 'contactor' => $info['contactor'],
  108. 'mobile' => $info['mobile'],
  109. 'addr' => $info['addr'],
  110. ];
  111. //确认字段
  112. $res['confirm'] = $info;
  113. return app_show(0, '请求成功', $res);
  114. } else return error_show(1005, '系统尚未解析完成,无法查看详情,请等待');
  115. }
  116. //用户确认订单数据(编辑)
  117. public function confirmImportData()
  118. {
  119. //每次编辑,都新增一条记录到extend表,同时原纪录作废,确保同一个order_import_from_c_id下只有一个正常的记录
  120. $param = $this->request->only([
  121. 'id',
  122. 'platform_code',
  123. 'po_code',
  124. 'platform_time',
  125. 'sale_source',
  126. 'plat_code',
  127. 'price',
  128. 'num',
  129. 'before_discount_all_price',
  130. 'discount_price',
  131. 'after_price',
  132. 'activity_name',
  133. 'mode',
  134. 'order_remark',
  135. 'contactor',
  136. 'mobile',
  137. 'addr',
  138. 'spuCode',
  139. 'companyNo',
  140. 'customer_code',
  141. 'supplierNo',
  142. 'platform_codes',
  143. 'good_name',
  144. 'discount_reason',
  145. 'addr_code',
  146. ], 'post', 'trim');
  147. $val = Validate::rule([
  148. 'id' => 'require',
  149. 'platform_code' => 'require',
  150. 'po_code' => 'require',
  151. 'platform_time' => 'require',
  152. 'sale_source' => 'require',
  153. 'plat_code' => 'require',
  154. 'price' => 'require',
  155. 'num' => 'require',
  156. 'before_discount_all_price' => 'require',
  157. 'discount_price' => 'require',
  158. 'after_price' => 'require',
  159. 'mode' => 'require',
  160. 'contactor' => 'require',
  161. 'mobile' => 'require',
  162. 'addr' => 'require',
  163. 'spuCode' => 'require',
  164. 'companyNo' => 'require',
  165. 'customer_code' => 'require',
  166. 'supplierNo' => 'require',
  167. 'platform_codes' => 'require',
  168. 'good_name' => 'require',
  169. 'discount_reason' => 'require',
  170. 'addr_code' => 'require',
  171. ]);
  172. if (!$val->check($param)) return error_show(1004, $val->getError());
  173. Db::startTrans();
  174. try {
  175. $userinfo = GetUserInfo($param['token']);
  176. Db::name('order_import_from_c')
  177. ->where(['id' => $param['id'], 'is_del' => OIFCModel::$is_del_normal, 'status' => OIFCModel::$status_wait_confirm])
  178. ->update([
  179. 'platform_code' => $param['platform_code'],
  180. 'po_code' => $param['po_code'],
  181. 'platform_time' => $param['platform_time'],
  182. 'sale_source' => $param['sale_source'],
  183. 'plat_code' => $param['plat_code'],
  184. 'price' => $param['price'],
  185. 'num' => $param['num'],
  186. 'before_discount_all_price' => $param['before_discount_all_price'],
  187. 'discount_price' => $param['discount_price'],
  188. 'after_price' => $param['after_price'],
  189. 'activity_name' => $param['activity_name'],
  190. 'mode' => $param['mode'],
  191. 'order_remark' => $param['order_remark'],
  192. 'contactor' => $param['contactor'],
  193. 'mobile' => $param['mobile'],
  194. 'addr' => $param['addr'],
  195. 'status' => OIFCModel::$status_wait_relation,
  196. 'updatetime' => date('Y-m-d H:i:s')
  197. ]);
  198. Db::name('order_import_from_c_extend')
  199. ->where(['order_import_from_c_id' => $param['id'], 'is_del' => 0])
  200. ->update(['is_del' => 1]);
  201. Db::name('order_import_from_c_extend')
  202. ->insert([
  203. 'order_import_from_c_id' => $param['id'],
  204. 'spuCode' => $param['spuCode'],
  205. 'companyNo' => $param['companyNo'],
  206. 'customer_code' => $param['customer_code'],
  207. 'supplierNo' => $param['supplierNo'],
  208. 'platform_codes' => $param['platform_codes'],
  209. 'good_name' => $param['good_name'],
  210. 'discount_reason' => $param['discount_reason'],
  211. 'addr_code' => $param['addr_code'],
  212. 'addtime' => date('Y-m-d H:i:s'),
  213. 'createrid' => isset($user["data"]['id']) ? $userinfo["data"]['id'] : 0,
  214. 'creater' => isset($user["data"]['nickname']) ? $userinfo["data"]['nickname'] : '',
  215. ]);
  216. Db::commit();
  217. return app_show(0, '修改成功');
  218. } catch (\think\Exception $exception) {
  219. Db::rollback();
  220. return error_show(1004, $exception->getMessage());
  221. }
  222. }
  223. //批量关联库存
  224. public function relationStockBatch()
  225. {
  226. }
  227. //【脚本】批量解析用户导入的数据
  228. public function analysisBatchDataBySystem()
  229. {
  230. //解析信息存到extend表,其中customer_code字段根据订单编号去customer_info查,其他根据商品编号查询
  231. Db::startTrans();
  232. try {
  233. $order_import_from_c_db = Db::name('order_import_from_c');
  234. $order_import_from_c_extend_db = Db::name('order_import_from_c_extend');
  235. // $customer_info_db = Db::name('customer_info')->field('companyNo')->where(['is_del' => 0]);
  236. $rs = $order_import_from_c_db
  237. ->where([
  238. 'is_del' => OIFCModel::$is_del_normal,
  239. 'status' => OIFCModel::$status_wait_validate
  240. ])->find();
  241. //加写锁
  242. //1.数据校验
  243. $val = Validate::rule([
  244. 'platform_code|平台订单号' => 'require|length:0,255',
  245. 'po_code|其他单号' => 'length:0,255',
  246. 'platform_time|平台下单时间' => 'require|date',
  247. 'sale_source|销售渠道' => 'require|length:0,255',
  248. 'plat_code|平台商品编号' => 'require|length:0,255',
  249. 'price|单价' => 'require|float',
  250. 'num|数量' => 'require|number',
  251. 'before_discount_all_price|优惠前总金额' => 'require|float',
  252. 'discount_price|优惠金额' => 'require|float',
  253. 'after_price|商品优惠后金额' => 'require|float',
  254. 'activity_name|优惠活动名称' => 'length:0,255',
  255. 'mode|收费模式' => 'require|length:0,255',
  256. 'order_remark|订单备注' => 'length:0,255',
  257. 'contactor|收货人' => 'require|length:0,255',
  258. 'mobile|联系电话' => 'require|length:0,20',
  259. 'addr|联系地址' => 'require|length:0,255',
  260. ]);
  261. if (!$val->check($rs)) {
  262. $order_import_from_c_db
  263. ->where('id', $rs['id'])
  264. ->update([
  265. 'updatetime' => date('Y-m-d H:i:s'),
  266. 'status' => OIFCModel::$status_wait_confirm,
  267. 'remark' => '数据格式不对,' . $val->getError()
  268. ]);
  269. //解除写锁
  270. Db::commit();
  271. return false;
  272. }
  273. $extend_insert_data = [
  274. 'order_import_from_c_id' => $rs['id'],
  275. 'createrid' => 0,
  276. 'creater' => 'system',
  277. 'discount_reason' => $rs['activity_name']
  278. ];
  279. //查找extend的数据
  280. $good_platform_info = Db::name('good_platform')
  281. ->field('id,spuCode,platform_code,skuCode')
  282. ->where(['is_del' => 0])
  283. ->where('plat_code', $rs['plat_code'])
  284. ->find();
  285. if (!empty($good_platform_info)) {
  286. $extend_insert_data['spuCode'] = $good_platform_info['spuCode'];
  287. $extend_insert_data['platform_code'] = $good_platform_info['platform_code'];
  288. } else {
  289. $order_import_from_c_db
  290. ->where('id', $rs['id'])
  291. ->update([
  292. 'updatetime' => date('Y-m-d H:i:s'),
  293. 'status' => OIFCModel::$status_wait_confirm,
  294. 'remark' => '在商品平台表中查不到平台商品编号对应的spuCode'
  295. ]);
  296. //解除写锁
  297. Db::commit();
  298. return false;
  299. }
  300. $good_info = Db::name('good')
  301. ->field('good_name,good_code,companyNo,supplierNo,is_stock,packing_fee,cert_fee,open_fee,cost_fee,mark_fee,demo_fee,cat_id')
  302. ->where(['is_del' => 0])
  303. ->where('spuCode', $extend_insert_data['spuCode'])
  304. ->find();
  305. if (!empty($good_info)) {
  306. $extend_insert_data['companyNo'] = $good_info['companyNo'];
  307. $extend_insert_data['supplierNo'] = $good_info['supplierNo'];
  308. $extend_insert_data['good_name'] = $good_info['good_name'];
  309. } else {
  310. $order_import_from_c_db
  311. ->where('id', $rs['id'])
  312. ->update([
  313. 'updatetime' => date('Y-m-d H:i:s'),
  314. 'status' => OIFCModel::$status_wait_confirm,
  315. 'remark' => '在上线商品表中查不到spuCode对应的商品信息'
  316. ]);
  317. //解除写锁
  318. Db::commit();
  319. return false;
  320. }
  321. $order_import_from_c_extend_db->insertGetId($extend_insert_data);
  322. //判断是否库存品
  323. if ($good_info['is_stock'] == 1) {
  324. //库存品,查询可用库存数量
  325. $usable_stock = Db::name('good_stock')
  326. ->where('spuCode', $extend_insert_data['spuCode'])
  327. ->sum('usable_stock');
  328. if ($usable_stock < $rs['num']) {
  329. $order_import_from_c_db
  330. ->where('id', $rs['id'])
  331. ->update([
  332. 'updatetime' => date('Y-m-d H:i:s'),
  333. 'status' => OIFCModel::$status_wait_relation,
  334. 'remark' => '库存不足'
  335. ]);
  336. //解除写锁
  337. Db::commit();
  338. return false;
  339. } else {
  340. //扣减库存
  341. //录入成功
  342. $order_import_from_c_db
  343. ->where('id', $rs['id'])
  344. ->update([
  345. 'updatetime' => date('Y-m-d H:i:s'),
  346. 'status' => OIFCModel::$status_success,
  347. ]);
  348. $this->createSaleByImportSuccess($good_info, $rs, $extend_insert_data);
  349. }
  350. } else {
  351. //非库存品
  352. //录入成功
  353. $order_import_from_c_db
  354. ->where('id', $rs['id'])
  355. ->update([
  356. 'updatetime' => date('Y-m-d H:i:s'),
  357. 'status' => OIFCModel::$status_success,
  358. ]);
  359. $orderCode = $this->createSaleByImportSuccess($good_info, $rs, $extend_insert_data);
  360. //生成采购单
  361. $cgd = [
  362. "supplierNo" => $extend_insert_data['supplierNo'],
  363. "companyNo" => $extend_insert_data['companyNo'],
  364. "orderCode" => $orderCode,
  365. "spuCode" => $extend_insert_data['spuCode'],
  366. "skuCode" => $good_platform_info['skuCode'],
  367. "good_name" => $extend_insert_data['good_name'],
  368. "sale_price" => $rs['price'],
  369. "total_fee" => $rs['price'] * $rs['num'],
  370. "pakge_fee" => $good_info['packing_fee'],
  371. "cert_fee" => $good_info['cert_fee'],
  372. "open_fee" => $good_info['open_fee'],
  373. "cost_fee" => $good_info['cost_fee'],
  374. "mark_fee" => $good_info['mark_fee'],
  375. "demo_fee" => $good_info['demo_fee'],
  376. "good_num" => $rs['num'],
  377. "good_type" => 1,//商品类型 1正常2赠品3样品
  378. "order_type" => $good_info['is_stock'] == 1 ? 1 : 2,
  379. "createrid" => $rs['createrid'],
  380. "creater" => $rs['creater'],
  381. 'send_way' => 2
  382. ];
  383. $sale_controller = new Sale();
  384. $sale_controller->createCgd($cgd);
  385. }
  386. Db::commit();
  387. return true;
  388. } catch (\think\Exception $exception) {
  389. Db::rollback();
  390. return false;
  391. }
  392. }
  393. //【辅助1】获取线上商品详情
  394. public function getOnlineGoodInfoByPlatcode()
  395. {
  396. $plat_code = $this->request->post('plat_code', '', 'trim');
  397. if (!$plat_code) return error_show(1004, '平台商品编号不能为空');
  398. $res = Db::name('good_platform')
  399. ->alias('gp')
  400. ->field('gp.platform_code,gp.plat_code,g.*')
  401. ->where(['gp.plat_code' => $plat_code, 'gp.is_del' => 0])
  402. ->leftJoin('good g', 'g.spuCode=gp.spuCode AND g.is_del=0')
  403. ->find();
  404. if ($res) return app_show(0, '', $res);
  405. else return error_show(1005, '该平台商品编号不存在对应商品');
  406. }
  407. //【辅助2】接口2-获取销售渠道备选数据:入参所在平台Id,响应:销售渠道备选数据
  408. public function getSourceDataByPlatformId()
  409. {
  410. $platform_id = $this->request->post('platform_id/d', 0, 'trim');
  411. $list = Db::name('platform_source')
  412. ->field('id,platform_id,source')
  413. ->where(['is_del' => 0, 'platform_id' => $platform_id])
  414. ->order('id', 'desc')
  415. ->select()
  416. ->toArray();
  417. return app_show(0, '获取成功', $list);
  418. }
  419. //处理库存(关联库存)
  420. public function handleStock(array $da = [])
  421. {
  422. }
  423. //C端订单导入成功后,生成销售单
  424. private function createSaleByImportSuccess(array $goodinfo = [], array $c_data = [], array $extend_data = []): string
  425. {
  426. $orderCode = makeNo("QR");
  427. $sale_insert_data = [
  428. "orderCode" => $orderCode,
  429. "good_code" => $goodinfo['good_code'],
  430. "customer_code" => $customer_code,
  431. "good_name" => $goodinfo['good_name'],
  432. "good_num" => $c_data['num'],
  433. "cat_id" => $goodinfo['cat_id'],
  434. "apply_id" => $c_data['createrid'],
  435. "apply_name" => $c_data['creater'],
  436. "origin_price" => $c_data['price'] * $c_data['num'],
  437. "sale_price" => $goodinfo['sale_price'],
  438. "post_fee" => 0,
  439. "status" => 0,
  440. "send_num" => 0,
  441. "wsend_num" => $c_data['num'],
  442. "send_status" => 1,
  443. "good_type" => 1,
  444. "send_type" => 1,//发货类型 1直接发货2延时发货
  445. "supplierNo" => $extend_data['supplierNo'],
  446. "is_del" => 0,
  447. "zxNo" => '',
  448. "platform_order" => $platform_order,
  449. "platform_id" => $extend_data['platform_codes'],
  450. "remark" => $c_data['order_remark'],
  451. "order_type" => 3,//订单类型1销售2咨询3C端导入
  452. "addtime" => date("Y-m-d H:i:s"),
  453. "updatetime" => date("Y-m-d H:i:s"),
  454. 'total_price' => round($goodinfo['sale_price'] * $c_data['num'], 2),
  455. ];
  456. $res = Db::name('sale')->insertGetId($sale_insert_data);
  457. if ($res) {
  458. //修改状态,添加待办,脚本执行,没有token
  459. // ActionLog::logAdd($this->post['token'], [
  460. // "order_code" => $orderCode,//销售单code
  461. // "status" => 0,//这里的status是之前的值
  462. // "action_remark" => '',//备注
  463. // "action_type" => "create"//新建create,编辑edit,更改状态status
  464. // ], "XSQRD", 0, $sale_insert_data);
  465. //
  466. // ProcessOrder::AddProcess($this->post['token'], [
  467. // "order_type" => 'XSQRD',
  468. // "order_code" => $orderCode,//销售单code
  469. // "order_id" => $res,
  470. // "order_status" => 0
  471. // ]);
  472. return $orderCode;
  473. } else throw new \think\Exception('创建销售单失败');
  474. }
  475. }