Salezx.php 39 KB

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