OrderImport.php 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\OrderImportFromC as OIFCModel;
  4. use Exception;
  5. use think\facade\Config;
  6. use think\facade\Db;
  7. use think\facade\Validate;
  8. //C端订单导入及处理类
  9. class OrderImport extends Base
  10. {
  11. //订单导入
  12. public function import()
  13. {
  14. $param = $this->request->only(['token', 'list'], 'post', 'trim');
  15. $val_params = Validate::rule(['token' => 'require', 'list' => 'require|array']);
  16. if (!$val_params->check($param)) throw new \think\Exception($val_params->getError());
  17. Db::startTrans();
  18. try {
  19. $userinfo = GetUserInfo($param['token']);
  20. $createrid = isset($user["data"]['id']) ? $userinfo["data"]['id'] : 0;
  21. $creater = isset($user["data"]['nickname']) ? $userinfo["data"]['nickname'] : "";
  22. $insert_data = [];
  23. foreach ($param['list'] as $key => $value) {
  24. $value['createrid'] = $createrid;
  25. $value['creater'] = $creater;
  26. $insert_data[] = $value;
  27. }
  28. $res = Db::name('order_import_from_c')
  29. ->limit(100)
  30. ->insertAll($insert_data);
  31. if ($res) {
  32. Db::commit();
  33. return app_show(0, "导入成功,共" . (string)$res . '条记录');
  34. } else {
  35. Db::rollback();
  36. return error_show(1005, '导入失败');
  37. }
  38. } catch (Exception $exception) {
  39. Db::rollback();
  40. return error_show(1005, $exception->getMessage());
  41. }
  42. }
  43. //查看订单录入列表
  44. public function getImportList()
  45. {
  46. $param = $this->request->only([
  47. 'status' => 0,
  48. 'platform_code' => '',
  49. 'po_code' => '',
  50. 'platform_time_start' => '',
  51. 'platform_time_end' => '',
  52. 'addtime_start' => '',
  53. 'addtime_end' => '',
  54. 'plat_code' => '',
  55. 'page' => 1,
  56. 'size' => 15,
  57. ], 'post', 'trim');
  58. $where = [];
  59. if ($param['status']) $where[] = ['c.status', '=', $param['status']];
  60. if ($param['platform_code']) $where[] = ['c.platform_code', 'like', '%' . $param['platform_code'] . '%'];
  61. if ($param['po_code']) $where[] = ['c.po_code', 'like', '%' . $param['po_code'] . '%'];
  62. if ($param['platform_time_start'] && $param['platform_time_end']) $where[] = ['c.platform_time', 'between', [$param['platform_time_start'], $param['platform_time_end']]];
  63. if ($param['addtime_start'] && $param['addtime_end']) $where[] = ['c.addtime', 'between', [$param['addtime_start'], $param['addtime_end']]];
  64. if ($param['plat_code']) $where[] = ['c.plat_code', 'like', '%' . $param['plat_code'] . '%'];
  65. $db = OIFCModel::alias('c')->where($where);
  66. $total = $db->count('id');
  67. $list = $db
  68. ->page($param['page'], $param['size'])
  69. ->order('id', 'desc')
  70. ->select()
  71. ->toArray();
  72. return app_show(0, "获取成功", ['list' => $list, 'count' => $total]);
  73. }
  74. //查看订单录入详情
  75. public function getImportInfo()
  76. {
  77. $id = $this->request->post('id/d', 0, 'trim');
  78. $info = OIFCModel::alias('c')
  79. ->field('c.*,ce.*,b.company,ci.companyName CustomerCompanyName,s.name supplierName,a.activity_code')
  80. ->leftJoin('order_import_from_c_extend ce', 'ce.order_import_from_c_id=c.id')
  81. ->leftJoin('business b', 'b.companyNo=ce.companyNo AND b.is_del=0')
  82. ->leftJoin('customer_info ci', 'ci.companyNo=ce.customer_code AND ci.is_del=0')
  83. ->leftJoin('supplier s', 's.code=ce.supplierNo AND s.is_del=0')
  84. ->leftJoin('activity_info a', 'a.id=ce.activity_id AND a.is_del=0')
  85. ->where('c.id', $id)
  86. ->findOrEmpty()
  87. ->toArray();//因为这里用的是模型,查询结果是一个对象
  88. if (!empty($info)) {
  89. $info['platform_names'] = Db::name('platform')
  90. ->whereIn('platform_code', $info['platform_codes'])
  91. ->where(['is_del' => 0, 'status' => 1])
  92. ->column('platform_name');
  93. $info['addr_name'] = GetAddr($info['addr_code']);
  94. $res['id'] = $info['id'];
  95. $res['status'] = $info['status'];
  96. $res['createrid'] = $info['createrid'];
  97. $res['creater'] = $info['creater'];
  98. $res['updateid'] = $info['updateid'];
  99. $res['updater'] = $info['updater'];
  100. //导入字段
  101. $res['import'] = [
  102. 'platform_code' => $info['platform_code'],
  103. 'platform_time' => $info['platform_time'],
  104. 'plat_code' => $info['plat_code'],
  105. 'sale_source' => $info['sale_source'],
  106. 'price' => $info['price'],
  107. 'num' => $info['num'],
  108. 'before_discount_all_price' => $info['before_discount_all_price'],
  109. 'activity_name' => $info['activity_name'],
  110. 'mode' => $info['mode'],
  111. 'order_remark' => $info['order_remark'],
  112. 'contactor' => $info['contactor'],
  113. 'mobile' => $info['mobile'],
  114. 'addr' => $info['addr'],
  115. ];
  116. //确认字段
  117. $res['confirm'] = $info;
  118. //用户编辑字段
  119. $user_update = Db::name('order_import_from_c_extend')
  120. ->alias('ce')
  121. ->field('ce.*,b.company,ci.companyName CustomerCompanyName,s.name supplierName,a.activity_code')
  122. ->leftJoin('business b', 'b.companyNo=ce.companyNo AND b.is_del=0')
  123. ->leftJoin('customer_info ci', 'ci.companyNo=ce.customer_code AND ci.is_del=0')
  124. ->leftJoin('supplier s', 's.code=ce.supplierNo AND s.is_del=0')
  125. ->leftJoin('activity_info a', 'a.id=ce.activity_id AND a.is_del=0')
  126. ->where(['ce.order_import_from_c_id' => $id, 'ce.is_del' => 1])
  127. ->order('ce.addtime', 'desc')
  128. ->find();
  129. if (empty($user_update)) $res['user_update'] = $res['confirm'];
  130. else $res['user_update'] = array_merge($res['confirm'], $user_update);
  131. return app_show(0, '请求成功', $res);
  132. } else return error_show(1005, '系统尚未解析完成,无法查看详情,请等待');
  133. }
  134. //用户确认订单数据(编辑)
  135. public function confirmImportData()
  136. {
  137. //每次编辑,都新增一条记录到extend表,同时原纪录作废,确保同一个order_import_from_c_id下只有一个正常的记录
  138. $param = $this->request->only([
  139. 'id',
  140. 'platform_code',
  141. 'po_code',
  142. 'platform_time',
  143. 'sale_source',
  144. 'plat_code',
  145. 'price',
  146. 'num',
  147. 'before_discount_all_price',
  148. 'activity_id' => 0,
  149. 'activity_name' => '',
  150. 'mode',
  151. 'order_remark',
  152. 'contactor',
  153. 'mobile',
  154. 'addr',
  155. 'addr_code',
  156. 'token'
  157. ], 'post', 'trim');
  158. $val = Validate::rule([
  159. 'id' => 'require',
  160. 'platform_code' => 'require',
  161. 'po_code' => 'require',
  162. 'platform_time' => 'require',
  163. 'sale_source' => 'require',
  164. 'plat_code' => 'require',
  165. 'price' => 'require',
  166. 'num' => 'require',
  167. 'before_discount_all_price' => 'require',
  168. 'mode' => 'require',
  169. 'contactor' => 'require',
  170. 'mobile' => 'require',
  171. 'addr' => 'require',
  172. 'addr_code' => 'require',
  173. ]);
  174. if (!$val->check($param)) return error_show(1004, $val->getError());
  175. Db::startTrans();
  176. try {
  177. $rs = Db::name('order_import_from_c')
  178. ->where(['id' => $param['id'], 'is_del' => OIFCModel::$is_del_normal, 'status' => OIFCModel::$status_wait_confirm])
  179. ->find();
  180. if (empty($rs)) throw new \think\Exception('该记录不存在或不允许用户确认');
  181. $userinfo = GetUserInfo($param['token']);
  182. Db::name('order_import_from_c')
  183. ->where(['id' => $param['id'], 'is_del' => OIFCModel::$is_del_normal, 'status' => OIFCModel::$status_wait_confirm])
  184. ->update([
  185. 'platform_code' => $param['platform_code'],
  186. 'po_code' => $param['po_code'],
  187. 'platform_time' => $param['platform_time'],
  188. 'sale_source' => $param['sale_source'],
  189. 'plat_code' => $param['plat_code'],
  190. 'price' => $param['price'],
  191. 'num' => $param['num'],
  192. 'before_discount_all_price' => $param['before_discount_all_price'],
  193. 'activity_name' => $param['activity_name'],
  194. 'mode' => $param['mode'],
  195. 'order_remark' => $param['order_remark'],
  196. 'contactor' => $param['contactor'],
  197. 'mobile' => $param['mobile'],
  198. 'addr' => $param['addr'],
  199. 'status' => OIFCModel::$status_wait_relation,
  200. 'updatetime' => date('Y-m-d H:i:s')
  201. ]);
  202. Db::name('order_import_from_c_extend')
  203. ->where(['order_import_from_c_id' => $param['id'], 'is_del' => 0])
  204. ->update(['is_del' => 1]);
  205. Db::name('order_import_from_c_extend')
  206. ->insert([
  207. 'order_import_from_c_id' => $param['id'],
  208. 'addr_code' => $param['addr_code'],
  209. 'activity_id' => $param['activity_id'],
  210. 'addtime' => date('Y-m-d H:i:s'),
  211. 'createrid' => isset($user["data"]['id']) ? $userinfo["data"]['id'] : 0,
  212. 'creater' => isset($user["data"]['nickname']) ? $userinfo["data"]['nickname'] : '',
  213. ]);
  214. Db::commit();
  215. return app_show(0, '修改成功');
  216. } catch (\think\Exception $exception) {
  217. Db::rollback();
  218. return error_show(1004, $exception->getMessage() . '|' . $exception->getFile() . '|' . $exception->getLine());
  219. }
  220. }
  221. //批量关联库存
  222. public function relationStockBatch()
  223. {
  224. $param = $this->request->only(['ids', 'plat_code'], 'post', 'trim');
  225. $val = Validate::rule([
  226. 'ids' => 'require',
  227. 'plat_code|平台商品编号' => 'require',
  228. ]);
  229. if (!$val->check($param)) return error_show(1004, $val->getError());
  230. $info = Db::name('order_import_from_c_extend')
  231. ->field('id,spuCode,companyNo')
  232. ->whereIn('id', $param['ids'])
  233. ->find();
  234. //判断库存是否充足
  235. $num = Db::name('order_import_from_c')
  236. ->whereIn('id', $param['ids'])
  237. ->where(['is_del' => OIFCModel::$is_del_normal, 'status' => OIFCModel::$status_stock_not_enough])
  238. ->sum('num');
  239. $wsm_code = Db::name('warehouse_info')
  240. ->where(['companyNo' => $info['companyNo'], 'is_del' => 0])
  241. ->value('wsm_code');
  242. $usable_stock = Db::name('good_stock')
  243. ->where(['spuCode' => $info['spuCode'], 'wsm_code' => $wsm_code, 'is_del' => 0])
  244. ->value('usable_stock', 0);
  245. if ($usable_stock < $num) return error_show(1005, '可用库存只有' . $usable_stock . ',库存不足,关联失败');
  246. else {
  247. $userinfo = GetUserInfo($this->post['token']);
  248. $res = Db::name('order_import_from_c')
  249. ->whereIn('id', $param['ids'])
  250. ->where(['is_del' => OIFCModel::$is_del_normal, 'status' => OIFCModel::$status_stock_not_enough])
  251. ->update([
  252. 'status' => OIFCModel::$status_wait_relation,
  253. 'updatetime' => date('Y-m-d H:i:s'),
  254. 'updateid' => isset($user["data"]['id']) ? $userinfo["data"]['id'] : 0,
  255. 'updater' => isset($user["data"]['nickname']) ? $userinfo["data"]['nickname'] : '',
  256. ]);
  257. if ($res) return app_show(0, '批量关联库存成功');
  258. else return error_show(1005, '批量关联库存失败');
  259. }
  260. }
  261. //【辅助1】获取线上商品详情
  262. public function getOnlineGoodInfoByPlatcode()
  263. {
  264. $plat_code = isset($this->post['plat_code']) && $this->post['plat_code'] != "" ? trim($this->post['plat_code']) : "";
  265. if ($plat_code == "") {
  266. return error_show(1005, "参数plat_code不能为空");
  267. }
  268. $good_platform = Db::name("good_platform")->where(['plat_code' => $plat_code, "is_del" => 0])->find();
  269. if ($good_platform == false) {
  270. return error_show(1004, "未找到商品数据");
  271. }
  272. $data = Db::name("good")->where(["spuCode" => $good_platform['spuCode'], "is_del" => 0])->find();
  273. if ($data == false) {
  274. return error_show(1004, "未找到商品数据");
  275. }
  276. $plat = Db::name("platform")->where(["id" => $good_platform['platform_code']])->find();
  277. $data['skuCode'] = $good_platform['skuCode'];
  278. $data['platform_code'] = $good_platform['platform_code'];
  279. $data['platform_code_en'] = isset($plat['platform_code']) ? $plat['platform_code'] : "";
  280. $data['platform_name'] = isset($plat['platform_name']) ? $plat['platform_name'] : "";
  281. $data['online_reason'] = $good_platform['online_reason'];
  282. $data['online_time'] = $good_platform['online_time'];
  283. $data['online_remark'] = $good_platform['online_remark'];
  284. $data['exam_status'] = $good_platform['exam_status'];
  285. $data['is_online'] = $good_platform['is_online'];
  286. $data['plat_code'] = $good_platform['plat_code'];
  287. $data['exclusive'] = makeExcluse($data['is_exclusive']);
  288. $unit = Db::name("unit")->where(["id" => $data['good_unit']])->find();
  289. $data['unit'] = isset($unit['unit']) ? $unit['unit'] : '';
  290. $data['cat_info'] = made($data['cat_id'], []);
  291. $spec = Db::name("good_spec")->where(["spuCode" => $good_platform['spuCode'], "is_del" => 0])->select()->toArray();
  292. $supplier = Db::name("supplier")->where(["code" => $data['supplierNo']])->find();
  293. $data['supplierName'] = isset($supplier['name']) ? $supplier['name'] : "";
  294. $noble = Config::get('noble');
  295. $data['noble_name'] = isset($data['noble_metal']) && $data['noble_metal'] != 0 ? $noble[$data['noble_metal']] : "";
  296. $company = Db::name("business")->where(["companyNo" => $data['companyNo']])->find();
  297. $data['company'] = isset($company['company']) ? $company['company'] : "";
  298. if ($data['brand_id'] != 0) {
  299. $brand = Db::name("brand")->where(["id" => $data['brand_id']])->find();
  300. $data["brand_name"] = isset($brand['brand_name']) ? $brand['brand_name'] : "";
  301. } else {
  302. $data["brand_name"] = "";
  303. $data["brand_id"] = "";
  304. }
  305. $data['origin_place_cn'] = "";
  306. $data['delivery_place_cn'] = "";
  307. if ($data['delivery_place'] !== "") {
  308. $place = ["provice_code" => "", "city_code" => "", "area_code" => ""];
  309. list($place['provice_code'], $place['city_code'], $place['area_code']) = explode(",", $data['delivery_place']);
  310. $data['delivery_place_cn'] = GetAddr(json_encode($place));
  311. }
  312. if ($data['origin_place'] !== "") {
  313. $place = ["provice_code" => "", "city_code" => "", "area_code" => ""];
  314. list($place['provice_code'], $place['city_code'], $place['area_code']) = explode(",", $data['origin_place']);
  315. $data['origin_place_cn'] = GetAddr(json_encode($place));
  316. }
  317. $excluse = makeExcluse($data['is_exclusive']);
  318. $data['exclusive'] = $excluse;
  319. $data["good_info_img"] = $data['good_info_img'] != "" ? $data['good_info_img'] : [];
  320. $data["good_img"] = $data['good_img'] != "" ? $data['good_img'] : [];
  321. $speclist = [];
  322. if (!empty($spec)) {
  323. foreach ($spec as $value) {
  324. $temp = [];
  325. $temp['id'] = $value['id'];
  326. $temp['spuCode'] = $value['spuCode'];
  327. $temp['spec_id'] = $value['spec_id'];
  328. $temp['spec_value_id'] = $value['spec_value_id'];
  329. $temp['is_del'] = $value['is_del'];
  330. $sp = Db::name("specs")->where(["id" => $value['spec_id']])->find();
  331. $temp['spec_name'] = isset($sp["spec_name"]) ? $sp["spec_name"] : "";
  332. $spv = Db::name("spec_value")->where(["id" => $value['spec_value_id']])->find();
  333. $temp['spec_value'] = isset($spv["spec_value"]) ? $spv["spec_value"] : "";
  334. $speclist[] = $temp;
  335. }
  336. }
  337. $data["speclist"] = empty($speclist) ? [] : $speclist;
  338. $ladder = Db::name("good_ladder")->where(['skuCode' => $good_platform['spuCode'], "is_del" => 0])->select()->toArray();
  339. $data["ladderlist"] = !empty($ladder) ? $ladder : [];
  340. $nakelist = Db::name("good_nake")->where(['spuCode' => $good_platform['spuCode'], "is_del" => 0])->select()->toArray();
  341. $cat_top_list = made($data['cat_id']);
  342. $cat_top_id = isset($cat_top_list[0]['id']) ? $cat_top_list[0]['id'] : 0;
  343. $nakearry = [];
  344. if (!empty($nakelist)) {
  345. //实时金价
  346. $gold_price = Db::name("gold_price1")->where(["type" => $data['noble_metal'], "status" => 1, "is_del" => 0])->order("addtime desc")->value('price', 0);
  347. foreach ($nakelist as $value) {
  348. $value['sale_price'] = $value['nake_total'];
  349. //计算最终售价
  350. if ($data['is_gold_price'] == 1 && $cat_top_id == 6) {
  351. //普通商品:直接用财务提交的售价字段;
  352. //贵金属( 商品重量* 最新金价 + 工艺费(财务定价提交的)* 商品重量+包装费+加标费+证书费+产品裸价+其他费用)=商品库商品直接下单的售价
  353. $value['sale_price'] = ($data['weight'] * $gold_price + $value['cost_fee'] * $data['weight'] + $value['package_fee'] + $value['mark_fee'] + $value['cert_fee'] + $value['nake_fee'] + $value['other_fee']);
  354. }
  355. $nakearry[] = $value;
  356. }
  357. }
  358. $proof = Db::name("good_proof")->where(["spuCode" => $good_platform['spuCode'], "is_del" => 0])->order("updatetime desc")->field("id,proof_type,proof_url")->find();
  359. $data['proof'] = isset($proof) && $proof != false ? $proof : [];
  360. $data["nakelist"] = $nakearry;
  361. //补充采购员字段
  362. //成本表里的创建人,也是线上商品的采购人,为了防止混淆,给creater取个别名
  363. $temp_basic_info = Db::name('good_basic')
  364. ->field('id,createrid purchase_id,creater purchase')
  365. ->where(['spuCode' => $data['spuCode'], 'is_del' => 0])
  366. ->find();
  367. $data['purchase_id'] = $temp_basic_info['purchase_id'];
  368. $data['purchase'] = $temp_basic_info['purchase'];
  369. return app_show(0, "获取成功", $data);
  370. }
  371. //【辅助2】接口2-获取销售渠道备选数据:入参所在平台Id,响应:销售渠道备选数据
  372. public function getSourceDataByPlatformId()
  373. {
  374. $platform_id = $this->request->post('platform_id/d', 0, 'trim');
  375. $list = Db::name('platform_source')
  376. ->field('id,platform_id,source')
  377. ->where(['is_del' => 0, 'platform_id' => $platform_id])
  378. ->order('id', 'desc')
  379. ->select()
  380. ->toArray();
  381. return app_show(0, '获取成功', $list);
  382. }
  383. }