OrderImport.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\OrderImportFromC as OIFCModel;
  4. use Exception;
  5. use think\facade\Db;
  6. use think\facade\Validate;
  7. //C端订单导入及处理类
  8. class OrderImport extends Base
  9. {
  10. //订单导入
  11. public function import()
  12. {
  13. $param = $this->request->only(['token', 'list'], 'post', 'trim');
  14. $val_params = Validate::rule(['token' => 'require', 'list' => 'require|array']);
  15. if (!$val_params->check($param)) throw new \think\Exception($val_params->getError());
  16. Db::startTrans();
  17. try {
  18. $userinfo = GetUserInfo($param['token']);
  19. $createrid = isset($user["data"]['id']) ? $userinfo["data"]['id'] : 0;
  20. $creater = isset($user["data"]['nickname']) ? $userinfo["data"]['nickname'] : "";
  21. $insert_data = [];
  22. foreach ($param['list'] as $key => $value) {
  23. $value['createrid'] = $createrid;
  24. $value['creater'] = $creater;
  25. $insert_data[] = $value;
  26. }
  27. $res = Db::name('order_import_from_c')
  28. ->limit(100)
  29. ->insertAll($insert_data);
  30. if ($res) {
  31. Db::commit();
  32. return app_show(0, "导入成功,共" . (string)$res . '条记录');
  33. } else {
  34. Db::rollback();
  35. return error_show(1005, '导入失败');
  36. }
  37. } catch (Exception $exception) {
  38. Db::rollback();
  39. return error_show(1005, $exception->getMessage());
  40. }
  41. }
  42. //查看订单录入列表
  43. public function getImportList()
  44. {
  45. $param = $this->request->only([
  46. 'status' => 0,
  47. 'platform_code' => '',
  48. 'po_code' => '',
  49. 'platform_time_start' => '',
  50. 'platform_time_end' => '',
  51. 'addtime_start' => '',
  52. 'addtime_end' => '',
  53. 'plat_code' => '',
  54. 'page' => 1,
  55. 'size' => 15,
  56. ], 'post', 'trim');
  57. $where = [];
  58. if ($param['status']) $where[] = ['c.status', '=', $param['status']];
  59. if ($param['platform_code']) $where[] = ['c.platform_code', 'like', '%' . $param['platform_code'] . '%'];
  60. if ($param['po_code']) $where[] = ['c.po_code', 'like', '%' . $param['po_code'] . '%'];
  61. if ($param['platform_time_start'] && $param['platform_time_end']) $where[] = ['c.platform_time', 'between', [$param['platform_time_start'], $param['platform_time_end']]];
  62. if ($param['addtime_start'] && $param['addtime_end']) $where[] = ['c.addtime', 'between', [$param['addtime_start'], $param['addtime_end']]];
  63. if ($param['plat_code']) $where[] = ['c.plat_code', 'like', '%' . $param['plat_code'] . '%'];
  64. $db = OIFCModel::alias('c')->where($where);
  65. $total = $db->count('id');
  66. $list = $db
  67. ->page($param['page'], $param['size'])
  68. ->order('id', 'desc')
  69. ->select()
  70. ->toArray();
  71. return app_show(0, "获取成功", ['list' => $list, 'count' => $total]);
  72. }
  73. //查看订单录入详情
  74. public function getImportInfo()
  75. {
  76. $id = $this->request->post('id/d', 0, 'trim');
  77. $info = OIFCModel::alias('c')
  78. ->field('c.*,ce.*,b.company,ci.companyName CustomerCompanyName,s.name supplierName')
  79. ->leftJoin('order_import_from_c_extend ce', 'ce.order_import_from_c_id=c.id')
  80. ->leftJoin('business b', 'b.companyNo=ce.companyNo AND b.is_del=0')
  81. ->leftJoin('customer_info ci', 'ci.companyNo=ce.customer_code AND ci.is_del=0')
  82. ->leftJoin('supplier s', 's.code=ce.supplierNo AND s.is_del=0')
  83. ->where('c.id', $id)
  84. ->find();
  85. if (!empty($info)) {
  86. $info['platform_names'] = Db::name('platform')
  87. ->whereIn('platform_code', $info['platform_codes'])
  88. ->where(['is_del' => 0, 'status' => 1])
  89. ->column('platform_name');
  90. $info['addr_name'] = GetAddr($info['addr_code']);
  91. //导入字段
  92. $res['import'] = [
  93. 'platform_code' => $info['platform_code'],
  94. 'platform_time' => $info['platform_time'],
  95. 'plat_code' => $info['plat_code'],
  96. 'sale_source' => $info['sale_source'],
  97. 'price' => $info['price'],
  98. 'num' => $info['num'],
  99. 'before_discount_all_price' => $info['before_discount_all_price'],
  100. 'activity_name' => $info['activity_name'],
  101. 'discount_price' => $info['discount_price'],
  102. 'after_price' => $info['after_price'],
  103. 'mode' => $info['mode'],
  104. 'order_remark' => $info['order_remark'],
  105. 'contactor' => $info['contactor'],
  106. 'mobile' => $info['mobile'],
  107. 'addr' => $info['addr'],
  108. ];
  109. //确认字段
  110. $res['confirm'] = $info;
  111. return app_show(0, '请求成功', $res);
  112. } else return error_show(1005, '系统尚未解析完成,无法查看详情,请等待');
  113. }
  114. //用户确认订单数据(编辑)
  115. public function confirmImportData()
  116. {
  117. //每次编辑,都新增一条记录到extend表,同时原纪录作废,确保同一个order_import_from_c_id下只有一个正常的记录
  118. }
  119. //批量关联库存
  120. public function relationStockBatch()
  121. {
  122. }
  123. //【脚本】批量解析用户导入的数据
  124. public function analysisBatchDataBySystem()
  125. {
  126. //解析信息存到extend表,其中customer_code字段根据订单编号去customer_info查,其他根据商品编号查询
  127. $order_import_from_c_db = Db::name('order_import_from_c');
  128. $good_platform_db = Db::name('good_platform')->field('id,spuCode,platform_code')->where(['is_del' => 0]);
  129. $good_db = Db::name('good')->field('good_name,companyNo,supplierNo,is_stock')->where(['is_del' => 0]);
  130. $order_import_from_c_extend_db = Db::name('order_import_from_c_extend');
  131. $good_stock_db = Db::name('good_stock');
  132. // $customer_info_db = Db::name('customer_info')->field('companyNo')->where(['is_del' => 0]);
  133. $list = $order_import_from_c_db
  134. ->where([
  135. 'is_del' => OIFCModel::$is_del_normal,
  136. 'status' => OIFCModel::$status_wait_validate
  137. ])
  138. ->limit(10)
  139. ->cursor();
  140. /**
  141. * $val = Validate::rule([
  142. * 'platform_code|平台订单号' => 'require|length:0,255',
  143. * 'po_code|其他单号' => 'length:0,255',
  144. * 'platform_time|平台下单时间' => 'require|date',
  145. * 'sale_source|销售渠道' => 'require|length:0,255',
  146. * 'plat_code|平台商品编号' => 'require|length:0,255',
  147. * 'price|单价' => 'require|float',
  148. * 'num|数量' => 'require|number',
  149. * 'before_discount_all_price|优惠前总金额' => 'require|float',
  150. * 'discount_price|优惠金额' => 'require|float',
  151. * 'after_price|商品优惠后金额' => 'require|float',
  152. * 'activity_name|优惠活动名称' => 'length:0,255',
  153. * 'mode|收费模式' => 'require|length:0,255',
  154. * 'order_remark|订单备注' => 'length:0,255',
  155. * 'contactor|收货人' => 'require|length:0,255',
  156. * 'mobile|联系电话' => 'require|length:0,20',
  157. * 'addr|联系地址' => 'require|length:0,255',
  158. * ]);
  159. */
  160. foreach ($list as $value) {
  161. Db::startTrans();
  162. try {
  163. $extend_insert_data = [
  164. 'order_import_from_c_id' => $value->id,
  165. 'createrid' => 0,
  166. 'creater' => 'system',
  167. ];
  168. //1.解析数据
  169. $good_platform_info = $good_platform_db->where('plat_code', $value->plat_code)->find();
  170. if (!empty($good_platform_info)) {
  171. $extend_insert_data['spuCode'] = $good_platform_info['spuCode'];
  172. $extend_insert_data['platform_code'] = $good_platform_info['platform_code'];
  173. } else {
  174. $order_import_from_c_db->where('id', $value->id)->update(['updatetime' => date('Y-m-d H:i:s'), 'status' => OIFCModel::$status_wait_confirm, 'remark' => '在商品平台表中查不到平台商品编号对应的spuCode']);
  175. Db::commit();
  176. continue;
  177. }
  178. $good_info = $good_db->where('spuCode', $extend_insert_data['spuCode'])->find();
  179. if (!empty($good_info)) {
  180. $extend_insert_data['companyNo'] = $good_info['companyNo'];
  181. $extend_insert_data['supplierNo'] = $good_info['supplierNo'];
  182. $extend_insert_data['good_name'] = $good_info['good_name'];
  183. } else {
  184. $order_import_from_c_db->where('id', $value->id)->update(['updatetime' => date('Y-m-d H:i:s'), 'status' => OIFCModel::$status_wait_confirm, 'remark' => '在上线商品表中查不到spuCode对应的商品信息']);
  185. Db::commit();
  186. continue;
  187. }
  188. // $extend_insert_data['customer_code'] = $good_info['companyNo'];
  189. $extend_insert_data['discount_reason'] = $value->activity_name;
  190. $order_import_from_c_extend_db->insertGetId($extend_insert_data);
  191. //2.判断是否库存品
  192. if ($good_info['is_stock'] == 1) {
  193. //库存品,查询可用库存数量
  194. $usable_stock = $good_stock_db
  195. ->where('spuCode', $extend_insert_data['spuCode'])
  196. ->sum('usable_stock');
  197. if ($usable_stock < $value->num) {
  198. $order_import_from_c_db->where('id', $value->id)->update(['updatetime' => date('Y-m-d H:i:s'), 'status' => OIFCModel::$status_wait_confirm, 'remark' => '库存不足']);
  199. Db::commit();
  200. continue;
  201. }
  202. }
  203. //3.判断库存
  204. //4.处理
  205. Db::commit();
  206. } catch (\think\Exception $exception) {
  207. Db::rollback();
  208. return error_show(1005, $exception->getMessage());
  209. }
  210. }
  211. return '123123123wwafa';
  212. }
  213. //【辅助1】获取线上商品详情
  214. public function getOnlineGoodInfoByPlatcode()
  215. {
  216. $plat_code = $this->request->post('plat_code', '', 'trim');
  217. if (!$plat_code) return error_show(1004, '平台商品编号不能为空');
  218. $res = Db::name('good_platform')
  219. ->alias('gp')
  220. ->field('gp.platform_code,gp.plat_code,g.*')
  221. ->where(['gp.plat_code' => $plat_code, 'gp.is_del' => 0])
  222. ->leftJoin('good g', 'g.spuCode=gp.spuCode AND g.is_del=0')
  223. ->find();
  224. if ($res) return app_show(0, '', $res);
  225. else return error_show(1005, '该平台商品编号不存在对应商品');
  226. }
  227. //【辅助2】接口2-获取销售渠道备选数据:入参所在平台Id,响应:销售渠道备选数据
  228. public function getSourceDataByPlatformId()
  229. {
  230. $platform_id = $this->request->post('platform_id/d', 0, 'trim');
  231. }
  232. }