Salezx.php 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\GoodLog;
  4. use app\admin\model\ProcessOrder;
  5. use think\App;
  6. use think\facade\Db;
  7. use app\admin\model\ActionLog;
  8. class Salezx extends \app\BaseController
  9. {
  10. public $post="";
  11. public function __construct(App $app)
  12. {
  13. parent::__construct($app);
  14. $this->post=$this->request->post();
  15. }
  16. public function create(){
  17. $token = isset($this->post['token']) && $this->post['token'] !=="" ?trim($this->post['token']):"";
  18. $orderCode=makeNo("QR");
  19. $customer_code= isset($this->post['customer_code'])&& $this->post['customer_code'] !=="" ? trim($this->post['customer_code']) :"";
  20. if($customer_code==""){
  21. return error_show(1002,"客户code不能为空");
  22. }
  23. $zxinfoNo= isset($this->post['zxinfoNo'])&& $this->post['zxinfoNo'] !=="" ? trim($this->post['zxinfoNo']) :"";
  24. if($zxinfoNo==""){
  25. return error_show(1002,"参数zxinfoNo 不能为空");
  26. }
  27. $customer=Db::name("customer_info")->where(["companyNo"=>$customer_code])->find();
  28. if($customer==false){
  29. return error_show(1004,"未找到客户数据");
  30. }
  31. $supplierNo= isset($this->post['supplierNo']) && $this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']) :"";
  32. if($supplierNo==""){
  33. return error_show(1002,"参数supplierNo不能为空");
  34. }
  35. $supplier=Db::name("business")->where(["companyNo"=>$supplierNo])->find();
  36. if($supplier==false){
  37. return error_show(1004,"未找到平台供应商数据");
  38. }
  39. $sendtype =isset($this->post['sendtype']) && $this->post['sendtype'] !=="" ?trim($this->post['sendtype']):"";
  40. if($sendtype==''){
  41. return error_show(1004,"参数sendtype不能为空");
  42. }
  43. $platform_id =isset($this->post['platform_id']) && $this->post['platform_id'] !=="" ?intval($this->post['platform_id']):"";
  44. if($platform_id==''){
  45. return error_show(1004,"参数platform_id不能为空");
  46. }
  47. $platform_order =isset($this->post['platform_order']) && $this->post['platform_order'] !=="" ?trim($this->post['platform_order']):"";
  48. if($platform_order==''){
  49. return error_show(1004,"参数platform_order不能为空");
  50. }
  51. $good_code =isset($this->post['good_code']) && $this->post['good_code'] !=="" ?trim($this->post['good_code']):"";
  52. if($good_code==''){
  53. return error_show(1004,"参数good_code不能为空");
  54. }
  55. $good=Db::name("good_zixun")->where(["spuCode"=>$good_code])->find();
  56. if($good==false){
  57. return error_show(1004,"未找到商品数据");
  58. }
  59. $goodinfo = Db::name("consult_bids")->where(["spuCode"=>$good['spuCode'],"is_del"=>0])->find();
  60. if($goodinfo==false){
  61. return error_show(1004,"未找到商品数据");
  62. }
  63. $good_num =isset($this->post['good_num']) && $this->post['good_num'] !=="" ?intval($this->post['good_num']):"";
  64. if($good_num===''){
  65. return error_show(1004,"参数good_num不能为空");
  66. }
  67. $good_num =isset($this->post['p']) && $this->post['good_num'] !=="" ?intval($this->post['good_num']):"";
  68. if($good_num===''){
  69. return error_show(1004,"参数good_num不能为空");
  70. }
  71. // $goodtype =isset($this->post['goodtype']) && $this->post['goodtype'] !=="" ?intval($this->post['goodtype']):"";
  72. // if($goodtype===''){
  73. // return error_show(1004,"参数goodtype不能为空");
  74. // }
  75. $arrtime = isset($this->post['arrtime'])&&$this->post['arrtime']!="" ?$this->post['arrtime']:"";
  76. if($arrtime==""){
  77. return error_show(1004,"参数arrtime不能为空");
  78. }
  79. $remark =isset($this->post['remark']) && $this->post['remark'] !=="" ?trim($this->post['remark']):"";
  80. if($sendtype==1){
  81. $addrlist = isset($this->post['addrlist']) && $this->post['addrlist'] !=="" ?$this->post['addrlist']:"";
  82. if($addrlist=="" || empty($addrlist) ||!is_array($addrlist)){
  83. return error_show(1004,"参数addrlist不能为空");
  84. }
  85. }
  86. $apply_id =GetUserInfo($token);
  87. if(empty($apply_id)||$apply_id['code']!=0){
  88. return error_show(1002,"申请人数据不存在");
  89. }
  90. $rm= isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
  91. $ri= isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
  92. Db::startTrans();
  93. try {
  94. $data=[
  95. "orderCode"=>$orderCode,
  96. "good_code"=>$good_code,
  97. "customer_code"=>$customer_code,
  98. "good_name"=>isset($good['good_name'])&&$good['good_name']!==''?$good['good_name']:'',
  99. "good_num"=>$good_num,
  100. "cat_id"=>$goodinfo['cat_id'],
  101. "apply_id"=>$rm,
  102. "apply_name"=>$ri,
  103. "origin_price"=>$goodinfo['total_fee'],
  104. "sale_price"=>$goodinfo['sale_price'],
  105. "post_fee"=>0,
  106. "status"=>0,
  107. "send_num"=>0,
  108. "wsend_num"=>$good_num,
  109. "send_status"=>1,
  110. "good_type"=>1,
  111. "send_type"=>$sendtype,
  112. "supplierNo"=>$supplierNo,
  113. "is_del"=>0,
  114. "zxNo"=>$zxinfoNo,
  115. "platform_order"=>$platform_order,
  116. "platform_id"=>$platform_id,
  117. "remark"=>$remark,
  118. "order_type"=>2,//非库存品
  119. "order_source"=>2,//咨询
  120. "addtime"=>date("Y-m-d H:i:s"),
  121. "updatetime"=>date("Y-m-d H:i:s"),
  122. 'total_price'=>round($goodinfo['sale_price']*$good_num,2),
  123. ];
  124. $datainfo = Db::name('sale')->insert($data,true);
  125. $vat=[];
  126. if($datainfo>0){
  127. $standing_bood_data=[
  128. "orderCode"=>$orderCode,
  129. "sale_id"=>$datainfo,
  130. "customer_code"=>$customer_code,
  131. "supplierNo"=>$supplierNo,
  132. "order_type"=>$data['order_type'],
  133. "order_source"=>$data['order_source'],
  134. "spuCode"=>$good_code,
  135. 'updatetime'=>date("Y-m-d H:i:s"),
  136. ];
  137. $bol= $this->createCgd($data,$good,$goodinfo,$standing_bood_data);
  138. if($bol==false){
  139. Db::rollback();
  140. return error_show(1002,"咨询订单创建失败");
  141. }
  142. if($sendtype!=2){
  143. foreach ($addrlist as $value){
  144. $temp=[];
  145. $addrs=[];
  146. if($value['addr_code']!==''&&is_array($value['addr_code'])){
  147. $addrs['provice_code'] = $value['addr_code'][0];
  148. $addrs['city_code'] = $value['addr_code'][1];
  149. $addrs['area_code'] = $value['addr_code'][2];
  150. $addr = json_encode($addrs);
  151. }else{
  152. $addr = isset($value['addr_code'])?$value['addr_code']:'';
  153. }
  154. $temp['orderCode']=$orderCode;
  155. $temp['contactor']=$value['contactor'];
  156. $temp['mobile'] = $value['mobile'];
  157. $temp['addr'] = $value['addr'];
  158. $temp['addr_code']=$addr;
  159. $temp['customer_code'] =$customer_code;
  160. $temp['receipt_quantity']=$value['receipt_quantity'];
  161. $temp['post_fee'] =0;
  162. $temp['is_del'] =0;
  163. $temp['addtime'] =date("Y-m-d H:i:s");
  164. $temp['updatetime'] =date("Y-m-d H:i:s");
  165. $temp['arrive_time']=$value['arrive_time'];
  166. $vmp = Db::name('order_addr')->insert($temp,true);
  167. if($vmp>0){
  168. $outCode=makeNo("DF");
  169. $out=[
  170. "orderCode"=>$orderCode,
  171. "outCode"=>$outCode,
  172. "apply_id"=>$rm,
  173. "apply_name"=>$ri,
  174. "addrid"=>$vmp,
  175. "post_name"=>"",
  176. "post_code"=>"",
  177. "post_fee"=>0,
  178. "sendtime"=>date("Y-m-d H:i:s"),
  179. "send_num"=>$value['receipt_quantity'],
  180. "check_num"=>0,
  181. "error_num"=>0,
  182. "wsm_code"=>"",
  183. "order_type"=>2,
  184. "status"=>0,
  185. "addtime"=>date("Y-m-d H:i:s"),
  186. "updatetime"=>date("Y-m-d H:i:s")
  187. ];
  188. $ou =Db::name("order_out")->insert($out);
  189. if($ou==false){
  190. Db::rollback();
  191. return error_show(1002,"咨询订单创建失败");
  192. }else{
  193. //修改状态,添加待办
  194. ActionLog::logAdd($this->post['token'], [
  195. "order_code" => $outCode,//出库单号
  196. "status" => $out['status'],//这里的status是之前的值
  197. "action_remark" => '',//备注
  198. "action_type" => "create"//新建create,编辑edit,更改状态status
  199. ], "CKD", $out['status'], $out);
  200. ProcessOrder::AddProcess($this->post['token'], [
  201. "order_type" => 'CKD',
  202. "order_code" => $outCode,//出库单号
  203. "order_id" => 0,
  204. "order_status" => $out['status']
  205. ]);
  206. }
  207. }else{
  208. Db::rollback();
  209. return error_show(1002,"咨询订单创建失败");
  210. }
  211. }
  212. }
  213. //修改状态,添加待办
  214. ActionLog::logAdd($this->post['token'], [
  215. "order_code" => $orderCode,//销售单code
  216. "status" => 0,//这里的status是之前的值
  217. "action_remark" => '',//备注
  218. "action_type" => "create"//新建create,编辑edit,更改状态status
  219. ], "XSQRD", 0, $data);
  220. ProcessOrder::AddProcess($this->post['token'], [
  221. "order_type" => 'XSQRD',
  222. "order_code" => $orderCode,//销售单code
  223. "order_id" => $datainfo,
  224. "order_status" => 0
  225. ]);
  226. //根据zxinfoNo查找infoNo,找到则更新台账,否则就新增台账
  227. $infoNo = Db::name('consult_bids')->where('bidNo', $zxinfoNo)->value('infoNo');
  228. if (empty($infoNo)) Db::name('standing_book')->insert(array_merge($standing_bood_data, ['addtime' => date('Y-m-d H:i:s'), 'standBookNo' => makeNo("IO")]));
  229. else Db::name('standing_book')->where('infoNo', $infoNo)->update($standing_bood_data);
  230. Db::commit();
  231. return error_show(0,"咨询订单创建成功");
  232. }
  233. Db::rollback();
  234. return error_show(1002,"咨询订单创建失败");
  235. }catch(\Exception $e){
  236. Db::rollback();
  237. return error_show(1005,$e->getMessage());
  238. }
  239. }
  240. public function createCgd($data,$good,$good_info,array &$standing_bood_data=[]){
  241. $cgdCode = makeNo("CG");
  242. $supplier=Db::name("supplier")->where(["code"=>$good['supplierNo'],"is_del"=>0])->find();
  243. if($supplier==false){
  244. return false;
  245. }
  246. $wsm= Db::name("warehouse_info")->where(["supplierNo"=>$good["supplierNo"],"companyNo"=>$data['supplierNo'],"is_del"=>0])->find();
  247. if($wsm==false){
  248. $wsm_code = makeNo("WSM");
  249. $inwsm=[
  250. "wsm_code"=>$wsm_code,
  251. "name"=>$supplier['name'],
  252. "wsm_type"=>2,
  253. "supplierNo"=>$supplier['code'],
  254. "addr"=>"",
  255. "addrs_code"=>"",
  256. "contactor"=>0,
  257. "contactor_name"=>0,
  258. "mobile"=>"",
  259. "position"=>"",
  260. "companyNo"=>$data['supplierNo'],
  261. "status"=>1,
  262. "is_del"=>0,
  263. "addtime"=>date("Y-m-d H:i:s"),
  264. "updatetime"=>date("Y-m-d H:i:s")
  265. ];
  266. $in = Db::name("warehouse_info")->insert($inwsm);
  267. if($in==false){
  268. return false;
  269. }
  270. }else{
  271. $wsm_code =$wsm['wsm_code'];
  272. }
  273. $cg =["cgdNo"=>$cgdCode,
  274. "bkcode"=>"",
  275. "wsm_code"=>$wsm_code,
  276. "cgder"=>$supplier['person'],
  277. "cgder_id"=>$supplier['personid'],
  278. "good_code"=>$good['spuCode'],
  279. "good_name"=>$good['good_name'],
  280. "good_num"=>$data['good_num'],
  281. "good_price"=>$good_info['sale_price'],
  282. "total_fee"=>$good_info['total_fee'],
  283. "pakge_fee"=>$good_info['pakge_fee'],
  284. "cert_fee"=>$good_info['cert_fee'],
  285. "open_fee"=>$good_info['open_fee'],
  286. "delivery_fee"=>$good_info['delivery_fee'],
  287. "mark_fee"=>$good_info['mark_fee'],
  288. "demo_fee"=>$good_info['demo_fee'],
  289. #"weight"=>$data['weight'],
  290. "diff_weight"=>"0",
  291. "diff_fee"=>"0",
  292. "gold_price"=>"0",
  293. "supplierNo"=>$good['supplierNo'],
  294. "supplier_name"=>$supplier['name'],
  295. "send_status"=>1,
  296. "send_num"=>"0",
  297. "wsend_num"=>$data['good_num'],
  298. "remark"=>"",
  299. "status"=>0,
  300. "lasttime"=>date("Y-m-d H:i:s"),
  301. "is_del"=>0,
  302. "order_type"=>$data['order_type'],
  303. "order_source"=>$data['order_source'],
  304. "good_type"=>$good['good_type'],
  305. "addtime"=>date("Y-m-d H:i:s"),
  306. "updatetime"=>date("Y-m-d H:i:s")
  307. ];
  308. $up =Db::name("purchease_order")->insert($cg,true);
  309. if($up){
  310. //修改状态,添加待办
  311. ActionLog::logAdd($this->post['token'], [
  312. "order_code" => $cg['cgdNo'],//销售单code
  313. "status" => 0,//这里的status是之前的值
  314. "action_remark" => '',//备注
  315. "action_type" => "create"//新建create,编辑edit,更改状态status
  316. ], "CGD", $cg['status'], $cg);
  317. ProcessOrder::AddProcess($this->post['token'], [
  318. "order_type" => 'CGD',
  319. "order_code" => $cg['cgdNo'],//销售单code
  320. "order_id" => $up,
  321. "order_status" => $cg['status']
  322. ]);
  323. $standing_bood_data['cgdNo']=$cgdCode;
  324. return true;
  325. }else{
  326. return false;
  327. }
  328. }
  329. // public function edit(){
  330. // $token = isset($this->post['token']) && $this->post['token'] !=="" ?trim($this->post['token']):"";
  331. //
  332. // $zxNo=isset($this->post['id']) && $this->post['id'] !=="" ?intval($this->post['id']):"";
  333. // if($zxNo==''){
  334. // return error_show(1004,"参数id不能为空");
  335. // }
  336. // $saleinfo = Db::name("sale")->where(["id"=>$zxNo,"is_del"=>0])->find();
  337. // if($saleinfo==false){
  338. // return error_show(1003,"未找到咨询单数据");
  339. // }
  340. // $zxinfo = Db::name("consult")->where(["zxNo"=>$saleinfo['zxNo'],"is_del"=>0])->find();
  341. // if($zxinfo==false){
  342. // return error_show(1004,"未找到咨询单数据");
  343. // }
  344. // $customer_code= $this->post['customer_code'] && $this->post['customer_code'] !=="" ? trim($this->post['customer_code']) :"";
  345. // if($customer_code==""){
  346. // return error_show(1002,"客户code不能为空");
  347. // }
  348. // $customer=Db::name("customer_info")->where(["companyNo"=>$customer_code])->find();
  349. // if($customer==false){
  350. // return error_show(1004,"未找到客户数据");
  351. // }
  352. // $supplierNo= $this->post['supplierNo'] && $this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']) :"";
  353. // if($supplierNo==""){
  354. // return error_show(1002,"参数supplierNo不能为空");
  355. // }
  356. // $supplier=Db::name("supplier")->where(["code"=>$supplierNo])->find();
  357. // if($supplier==false){
  358. // return error_show(1004,"未找到平台供应商数据");
  359. // }
  360. // $wsm=Db::name("warehouse_info")->where(["supplierNo"=>$zxinfo['gysNo'],"wsm_type"=>2])->find();
  361. // if(empty($wsm)){
  362. // return error_show(1004,"未找到供应商仓库数据");
  363. // }
  364. // $sendtype =isset($this->post['sendtype']) && $this->post['sendtype'] !=="" ?trim($this->post['sendtype']):"";
  365. // if($sendtype==''){
  366. // return error_show(1004,"参数sendtype不能为空");
  367. // }
  368. // $good_num =isset($this->post['good_num']) && $this->post['good_num'] !=="" ?intval($this->post['good_num']):"";
  369. // if($good_num===''){
  370. // return error_show(1004,"参数good_num不能为空");
  371. // }
  372. // $goodtype =isset($this->post['goodtype']) && $this->post['goodtype'] !=="" ?intval($this->post['goodtype']):"";
  373. // if($goodtype===''){
  374. // return error_show(1004,"参数goodtype不能为空");
  375. // }
  376. // $remark =isset($this->post['remark']) && $this->post['remark'] !=="" ?trim($this->post['remark']):"";
  377. // if($sendtype!=2){
  378. // $addrlist = isset($this->post['addrlist']) && $this->post['addrlist'] !=="" ?$this->post['addrlist']:"";
  379. // if($addrlist=="" || empty($addrlist)){
  380. // return error_show(1004,"参数addrlist不能为空");
  381. // }
  382. // }
  383. // $apply_id =GetUserInfo($token);
  384. // if(empty($apply_id)||$apply_id['code']!=0){
  385. // return error_show(1002,"申请人数据不存在");
  386. // }
  387. // $rm= isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
  388. // $ri= isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
  389. // Db::startTrans();
  390. // try {
  391. // $data=[
  392. // "customer_code"=>$customer_code,
  393. // "good_num"=>$good_num,
  394. // "apply_id"=>$rm,
  395. // "apply_name"=>$ri,
  396. // "wsend_num"=>$good_num,
  397. // "good_type"=>$goodtype,
  398. // "send_type"=>$sendtype,
  399. // "supplierNo"=>$supplierNo,
  400. // "remark"=>$remark,
  401. // "updatetime"=>date("Y-m-d H:i:s"),
  402. // 'total_price'=>round($zxinfo['last_price']*$good_num,2),
  403. // ];
  404. // $datainfo = Db::name('sale')->where(["id"=>$zxNo])->save($data);
  405. // if($datainfo!=false){
  406. // $st = ["order_code"=>$saleinfo['orderCode'],"status"=>0,"action_remark"=>'',"action_type"=>"edit"];
  407. // ActionLog::logAdd($this->post['token'],$st,"ZXQRD",0,$data);
  408. // $order=["order_type"=>"ZXQRD","order_code"=>$saleinfo['orderCode'],"order_id"=>$saleinfo['id'],"order_status"=>$saleinfo['status']];
  409. // ProcessOrder::AddProcess($this->post['token'],$order);
  410. // $saleinfos=[
  411. // "wsm_code"=>$wsm['wsm_code'],
  412. // "num"=>$good_num,
  413. // "sale_price"=>$zxinfo['last_price'],
  414. // "total_price"=>round($zxinfo['last_price']*$good_num,2),
  415. // "updatetime"=>date("Y-m-d H:i:s"),
  416. // ];
  417. // $info = Db::name("sale_info")->where(["orderCode"=>$saleinfo['orderCode']])->save($saleinfos);
  418. // if($info==false){
  419. // Db::rollback();
  420. // return error_show(1002,"咨询订单创建失败");
  421. // }
  422. // if($sendtype!=2){
  423. // foreach ($addrlist as $value){
  424. // $temp=[];
  425. // $addrs=[];
  426. // if($value['addr_code']!==''&&is_array($value['addr_code'])){
  427. // $addrs['provice_code'] = $value['addr_code'][0];
  428. // $addrs['city_code'] = $value['addr_code'][1];
  429. // $addrs['area_code'] = $value['addr_code'][2];
  430. // $addr = json_encode($addrs);
  431. // }else{
  432. // $addr = isset($value['addr_code'])?$value['addr_code']:'';
  433. // }
  434. // isset($value["id"])&&$value["id"]!=""? $temp['id']=$value['id']:"";
  435. // $temp['contactor']=$value['contactor'];
  436. // $temp['mobile'] = $value['mobile'];
  437. // $temp['addr'] = $value['addr'];
  438. // $temp['addr_code']=$addr;
  439. // $temp['orderCode']=$saleinfo['orderCode'];
  440. // $temp['customer_code'] =$customer_code;
  441. // $temp['receipt_quantity']=$value['receipt_quantity'];
  442. // $temp['post_fee'] =0;
  443. // $temp['is_del'] =$value['is_del'];
  444. // $temp['updatetime'] =date("Y-m-d H:i:s");
  445. // isset($value["id"])&&$value["id"]!=""?"":$temp['addtime'] =date("Y-m-d H:i:s");
  446. // $temp['arrive_time']=$value['arrive_time'];
  447. // $vmp = Db::name('order_addr')->save($temp);
  448. // if(!$vmp){
  449. // Db::rollback();
  450. // return error_show(0,"咨询订单地址更新失败");
  451. // }
  452. // }
  453. // }else{
  454. // if($saleinfo['send_type']==1 && $sendtype==2){
  455. // $up=Db::name('order_addr')->where(["orderCode"=>$saleinfo['orderCode']])->save(["is_del"=>1,"updatetime"=>date("Y-m-d H:i:s")]);
  456. // if(!$up){
  457. // Db::rollback();
  458. // return error_show(0,"咨询订单地址更新失败");
  459. // }
  460. // }
  461. // }
  462. // Db::commit();
  463. // return error_show(0,"咨询订单更新成功");
  464. // }
  465. // Db::rollback();
  466. // return error_show(1002,"咨询订单更新失败");
  467. // }catch(\Exception $e){
  468. // Db::rollback();
  469. // return error_show(1005,$e->getMessage());
  470. // }
  471. // }
  472. public function out(){
  473. $token= isset($this->post['token']) && $this->post['token'] !=="" ? trim($this->post['token']) :"";
  474. $outCode = isset($this->post['outCode']) && $this->post['outCode'] !=="" ? trim($this->post['outCode']) :"";
  475. if($outCode==""){
  476. return error_show(1002,"参数outCode不能为空");
  477. }
  478. $der = Db::name('order_out')->where(['outCode'=>$outCode])->find();
  479. if($der==""){
  480. return error_show(1002,"未找到出库单数据");
  481. }
  482. $order= Db::name('sale')->where(['orderCode'=>$der['orderCode']])->find();
  483. if(empty($order)){
  484. return error_show(1002,"未找到咨询订单信息");
  485. }
  486. $stock= Db::name("good_stock")->where(["spuCode"=>$order['good_code'],"wsm_code"=>$der['wsm_code']])
  487. ->find();
  488. if(empty($stock)){
  489. return error_show(1002,"未找到仓库库存信息");
  490. }
  491. if($der['send_num'] > $stock['wait_out_stock']){
  492. return error_show(1002,"仓库库存不足");
  493. }
  494. $post_name= isset($this->post['post_name']) && $this->post['post_name'] !=="" ? trim($this->post['post_name']) :"";
  495. if($post_name==""){
  496. return error_show(1002,"物流公司不能为空");
  497. }
  498. $post_code = isset($this->post['post_code']) && $this->post['post_code'] !=="" ? trim($this->post['post_code']) :"";
  499. if($post_code==""){
  500. return error_show(1002,"物流单号不能为空");
  501. }
  502. $post_fee = isset($this->post['post_fee']) && $this->post['post_fee'] !=="" ? intval($this->post['post_fee']) :"";
  503. if($post_fee==""){
  504. return error_show(1002,"物流费不能为空");
  505. }
  506. $sendtime = isset($this->post['sendtime']) && $this->post['sendtime'] !=="" ? $this->post['sendtime']:date("Y-m-d H:i:s");
  507. // $status = isset($this->post['status']) && $this->post['status'] !=="" ? $this->post['status'] :"1";
  508. Db::startTrans();
  509. try {
  510. $var = $der['status'];
  511. $der['post_name'] = $post_name;
  512. $der['post_code'] = $post_code;
  513. $der['post_fee'] = $post_fee;
  514. $der['sendtime'] = $sendtime;
  515. $der['status'] = 1;
  516. $der['updatetime'] = date("Y-m-d H:i:s");
  517. $datainfo = Db::name('order_out')->save($der);
  518. $st = ["order_code"=>$outCode,"status"=>$var,"action_remark"=>'',"action_type"=>"edit"];
  519. ActionLog::logAdd($this->post['token'],$st,"resign_info",$der['status'] ,$st);
  520. if($datainfo) {
  521. $st = ["order_code"=>$der['outCode'],"status"=>$var,"action_remark"=>'',"action_type"=>"edit"];
  522. ActionLog::logAdd($this->post['token'],$st,"CKD",1,$der);
  523. $ord=["order_type"=>"CKD","order_code"=>$der['outCode'],"order_id"=>$der['id'], "order_status"=>$der['status']];
  524. ProcessOrder::AddProcess($this->post['token'],$ord);
  525. // $send =Db::name("order_out")->where(["wsm_code"=>$der['wsm_code'],'orderCode'=>$der['orderCode']])->sum("send_num");
  526. // $order['send_num']+= $der['send_num'];
  527. // $order['wsend_num']-=$der['send_num'] ;//($der['send_num'])?$der['wsend_num'] =="" ? $der['send']
  528. // $order['send_status']=$order['send_num']==0 ? 1 :($order['wsend_num']==0?3:2);
  529. // $order['status']=$order['send_num']==0 ? 2 :($order['wsend_num']==0?4:3);
  530. // $order['updatetime'] = date("Y-m-d H:i:s");
  531. // $si = Db::name('sale')->save($order);
  532. // if($si==false){
  533. // Db::rollback();
  534. // return error_show(1003,"更新失败");
  535. // }
  536. $str = Db::name('good_stock')->where(['wsm_code' => $der['wsm_code'],'spuCode'=>$order['good_code']])
  537. ->find();
  538. if ($str == false) {
  539. Db::rollback();
  540. return error_show(1002, "商品数据未找到");
  541. }
  542. if ($der['send_num'] > $str['wait_out_stock']) {
  543. Db::rollback();
  544. return error_show(1002, "超出库存数量");
  545. }
  546. $str['wait_out_stock'] -= $der['send_num'];
  547. $str['intra_stock'] += $der['send_num'];
  548. $str['updatetime'] = date("Y-m-d H:i:s");
  549. $stre = Db::name('good_stock')->save($str);
  550. if ($stre == false) {
  551. Db::rollback();
  552. return error_show(1002, "状态更新失败");
  553. }
  554. //商品变动日志表,good_log_code字段存储销售订单编号
  555. $good_data[] = ['good_log_code' => $outCode, "stock_id" => $str['id'], "type" => 1, 'stock' => $der['send_num'], "stock_name" => "intra_stock"];
  556. $good_data[] = ['good_log_code' => $outCode, "stock_id" => $str['id'], "type" => 2, 'stock' => $der['send_num'], "stock_name" => "wait_out_stock"];
  557. GoodLog::LogAdd($this->post['token'], $good_data, 'CKD');
  558. Db::commit();
  559. return error_show(0,"创建成功");
  560. }else{
  561. Db::rollback();
  562. return error_show(1003,"创建失败");
  563. }
  564. }catch (\Exception $e) {
  565. Db::rollback();
  566. return error_show(1005, $e->getMessage());
  567. }
  568. }
  569. public function outaddr(){
  570. $token= isset($this->post['token']) && $this->post['token'] !=="" ? trim($this->post['token']) :"";
  571. $outCode=makeNo("DF");
  572. $orderCode = isset($this->post['orderCode']) && $this->post['orderCode'] !=="" ? trim($this->post['orderCode']) :"";
  573. if($orderCode==""){
  574. return error_show(1002,"参数orderCoder不能为空");
  575. }
  576. $der = Db::name('sale')->where(['orderCode'=>$orderCode])->find();
  577. if($der==""){
  578. return error_show(1002,"未找到出库订单单号");
  579. }
  580. if($der['order_type']!=2){
  581. return error_show(1002,"订单不是咨询单无法出库");
  582. }
  583. $wsm= Db::name('sale_info')->where(['orderCode'=>$der['orderCode']])->find();
  584. if(empty($wsm)){
  585. return error_show(1002,"未找到仓库信息");
  586. }
  587. $apply_id =GetUserInfo($token);
  588. if(empty($apply_id)||$apply_id['code']!=0){
  589. return error_show(1002,"申请人数据不存在");
  590. }
  591. $rm= isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
  592. $ri= isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
  593. if($der['send_type']==2){
  594. $contactor= isset($this->post['contactor']) && $this->post['contactor'] !=="" ? trim($this->post['contactor'])
  595. :"";
  596. if($contactor==""){
  597. return error_show(1002,"收货人不能为空");
  598. }
  599. $mobile = isset($this->post['mobile']) && $this->post['mobile'] !=="" ? trim($this->post['mobile'])
  600. :"";
  601. if($mobile==""){
  602. return error_show(1002,"收货人联系方式不能为空");
  603. }
  604. $addr = isset($this->post['addr']) && $this->post['addr'] !=="" ? trim($this->post['addr']) :"";
  605. if($addr==""){
  606. return error_show(1002,"参数addr不能为空");
  607. }
  608. $receipt_quantity= isset($this->post['receipt_quantity']) && $this->post['receipt_quantity'] !=="" ? intval
  609. ($this->post['receipt_quantity']) :"";
  610. if($receipt_quantity===""){
  611. return error_show(1002,"参数receipt_quantity不能为空");
  612. }
  613. $addrcode = isset($this->post['addr_code']) && $this->post['addr_code'] !=="" ? $this->post['addr_code'] :"";
  614. if($addrcode==""){
  615. return error_show(1002,"参数addr_code不能为空");
  616. }
  617. $addrs=[];
  618. if(is_array($addrcode)){
  619. $addrs['provice_code'] = $addrcode['addr_code'][0];
  620. $addrs['city_code'] = $addrcode['addr_code'][1];
  621. $addrs['area_code'] = $addrcode['addr_code'][2];
  622. $addrstr = json_encode($addrs);
  623. }else{
  624. $addrstr = $addrcode;
  625. }
  626. }else{
  627. $addrid = isset($this->post['addrid']) && $this->post['addrid'] !=="" ? intval($this->post['addrid']) :"";
  628. $dr = Db::name('order_addr')->where(['id'=>$addrid,"orderCode"=>$orderCode,'is_del'=>0])->find();
  629. if(empty($dr)){
  630. return error_show(1003,"收货人信息未找到");
  631. }
  632. $receipt_quantity = $dr['receipt_quantity'];
  633. }
  634. // if($send_num>$stock['usable_stock']){
  635. // return error_show(1002,"超出可发货数量");
  636. // }
  637. $sendtime = isset($this->post['sendtime']) && $this->post['sendtime'] !=="" ? $this->post['sendtime']:date("Y-m-d H:i:s");
  638. // $status = isset($this->post['status']) && $this->post['status'] !=="" ? $this->post['status'] :"1";
  639. Db::startTrans();
  640. try {
  641. if($der['send_type']==2){
  642. $addr=[
  643. "orderCode"=>$orderCode,
  644. "addr"=>$addr,
  645. "addr_code"=>$addrstr,
  646. "contactor"=>$contactor,
  647. "mobile"=>$mobile,
  648. "customer_code"=>$der['customer_code'],
  649. "post_fee"=>0,
  650. "is_del"=>0,
  651. "receipt_quantity"=>$receipt_quantity,
  652. "addtime"=>date("Y-m-d H:i:s"),
  653. "updatetime"=>date("Y-m-d H:i:s"),
  654. "arrive_time"=>date("Y-m-d H:i:s"),
  655. ];
  656. $addrid = Db::name('order_addr')->insert($addr,true);
  657. if($addrid<=0){
  658. $st = ["order_code"=>$orderCode,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  659. ActionLog::logAdd($this->post['token'],$st,"zxd",0,$st);
  660. Db::rollback();
  661. return error_show(1003,"创建失败");
  662. }
  663. }
  664. $data=[
  665. "wsm_code"=>$wsm['wsm_code'],
  666. "orderCode"=>$orderCode,
  667. "outCode"=>$outCode,
  668. "order_type"=>$der['order_type'],
  669. "apply_id"=>$rm,
  670. "apply_name"=>$ri,
  671. "addrid"=>$addrid,
  672. "post_name"=>'',
  673. "post_code"=>'',
  674. "post_fee"=>'',
  675. "sendtime"=>$sendtime,
  676. "send_num"=>$receipt_quantity,
  677. "check_num"=>0,
  678. "error_num"=>0,
  679. "status"=>0,
  680. "addtime"=>date("Y-m-d H:i:s"),
  681. "updatetime"=>date("Y-m-d H:i:s")
  682. ];
  683. $datainfo = Db::name('order_out')->insert($data,true);
  684. if($datainfo<=0){
  685. Db::rollback();
  686. return error_show(1003,"创建失败");
  687. }
  688. $sio = ["order_code"=>$outCode,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  689. ActionLog::logAdd($this->post['token'],$sio,"CKD",0,$data);
  690. $order=["order_type"=>"CKD","order_code"=>$data['outCode'],"order_id"=>$datainfo,"order_status"=>$data['status']];
  691. ProcessOrder::AddProcess($this->post['token'],$order);
  692. $item = $der['status'];
  693. $der['send_num']+= $receipt_quantity;
  694. $der['wsend_num']-=$receipt_quantity;//($der['send_num'])?$der['wsend_num'] =="" ? $der['send']
  695. $der['send_status']=$der['send_num']==0 ? 1 :($der['wsend_num']==0?3:2);
  696. $der['status']=$der['send_num']==0 ? 2 :($der['wsend_num']==0?4:3);
  697. $der['updatetime'] = date("Y-m-d H:i:s");
  698. $si = Db::name('sale')->save($der);
  699. if($si==false){
  700. Db::rollback();
  701. return error_show(1003,"创建失败");
  702. }else{
  703. //修改状态,添加待办
  704. ActionLog::logAdd($this->post['token'], [
  705. "order_code" => $der['orderCode'],//销售单code
  706. "status" => $item,//这里的status是之前的值
  707. "action_remark" => '',//备注
  708. "action_type" => "status"//新建create,编辑edit,更改状态status
  709. ], "XSQRD", $der['status'], $der);
  710. ProcessOrder::AddProcess($this->post['token'], [
  711. "order_type" => 'XSQRD',
  712. "order_code" => $der['orderCode'],//销售单code
  713. "order_id" => $der['id'],
  714. "order_status" => $der['status']
  715. ]);
  716. }
  717. $sio = ["order_code"=>$orderCode,"status"=>$item,"action_remark"=>'',"action_type"=>"edit"];
  718. ActionLog::logAdd($this->post['token'],$sio,"zxd",$der['status'],$der);
  719. $order=["order_type"=>"CKD","order_code"=>$orderCode,"order_id"=>$der['id'],"order_status"=>$der['status']];
  720. ProcessOrder::AddProcess($this->post['token'],$order);
  721. Db::commit();
  722. return error_show(0,"创建成功");
  723. }catch (\Exception $e) {
  724. Db::rollback();
  725. return error_show(1005, $e->getMessage());
  726. }
  727. }
  728. }