Purchin.php 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\ActionLog;
  4. use app\admin\model\GoodLog;
  5. use app\admin\model\ProcessOrder;
  6. use app\BaseController;
  7. use think\facade\Db;
  8. use think\App;
  9. class Purchin extends BaseController
  10. {
  11. public $post="";
  12. public function __construct(App $app)
  13. {
  14. parent::__construct($app);
  15. $this->post=$this->request->post();
  16. }
  17. public function list(){
  18. $page = isset($this->post['page']) && $this->post['page'] !==""? intval($this->post['page']):"1";
  19. $size = isset($this->post['size']) && $this->post['size'] !==""? intval($this->post['size']):"10";
  20. $where =[['a.is_del',"=",0],['b.is_del',"=",0]];
  21. $wsm_in_code=isset($this->post['wsm_in_code']) && $this->post['wsm_in_code']!==""? trim($this->post['wsm_in_code']) :"";
  22. if($wsm_in_code!=""){
  23. $where[]=["a.wsm_in_code",'like',"%$wsm_in_code%"];
  24. }
  25. $cgdNo= isset($this->post['cgdNo']) && $this->post['cgdNo'] !==""? trim($this->post['cgdNo']) :"";
  26. if($cgdNo!=""){
  27. $where[]=['a.cgdNo','like',"%$cgdNo%"];
  28. }
  29. $apply_name = isset($this->post['apply_name']) && $this->post['apply_name'] !==""? trim($this->post['apply_name']):"";
  30. if($apply_name!=""){
  31. $where[]=['a.apply_name','like',"%$apply_name%"];
  32. }
  33. $apply_id= isset($this->post['apply_id']) && $this->post['apply_id'] !==""? trim($this->post['apply_id']):"";
  34. if($apply_id!=""){
  35. $where[]=['a.apply_id','=',$apply_id];
  36. }
  37. $status= isset($this->post['status']) && $this->post['status'] !==""? trim($this->post['status']):"";
  38. if($status!=""){
  39. $where[]=['a.status','=',$status];
  40. }
  41. $start= isset($this->post['start']) && $this->post['start'] !== "" ? $this->post['start']:"";
  42. if ($start !="") {
  43. $where[]= ["a.sendtime",'>=',$start];
  44. }
  45. $end = isset($this->post['end']) && $this->post['end'] !== "" ? $this->post['end'] :"";
  46. if($end !=""){
  47. $where[]= ["a.sendtime",'<=',$end];
  48. }
  49. $order_type=isset($this->post['order_type']) && $this->post['order_type']!==""? intval($this->post['order_type']):"";
  50. if($order_type !=""){
  51. $where[]= ["b.order_type",'=',$order_type];
  52. }
  53. $good_type_code=isset($this->post['good_type_code']) && $this->post['good_type_code']!==""? trim($this->post['good_type_code']):"";
  54. if($good_type_code !=""){
  55. $where[]= ["b.good_type_code",'like',"%$good_type_code%"];
  56. }
  57. $good_name=isset($this->post['good_name']) && $this->post['good_name']!==""? trim($this->post['good_name']):"";
  58. if($good_name !=""){
  59. $where[]= ["b.good_name",'like',"%$good_name%"];
  60. }
  61. $supplie=isset($this->post['supplier']) && $this->post['supplier']!==""? trim($this->post['supplier']):"";
  62. if($supplie !=""){
  63. $where[]= ["b.supplierNo",'like',"%$supplie%"];
  64. }
  65. $wsm_code=isset($this->post['wsm_code']) && $this->post['wsm_code']!==""? trim($this->post['wsm_code']):"";
  66. if($wsm_code !=""){
  67. $where[]= ["a.wsm_code",'=',$wsm_code];
  68. }
  69. $supplierNo =isset($this->post['supplierNo']) &&$this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']):"";
  70. if($supplierNo!=""){
  71. $supplier = Db::name("supplier")->where(["code"=>$supplierNo])->find();
  72. if(empty($supplier)){
  73. return error_show(1004,"未找到供应商信息");
  74. }
  75. $wsmcode = Db::name("warehouse_info")->where([
  76. "is_del"=>0,"supplierNo"=>$supplierNo])->column("wsm_code");
  77. $where[]=['a.wsm_code',"in",$wsmcode];
  78. }
  79. $count = Db::name('purchease_in')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  80. ->where($where)->count();
  81. $total = ceil($count/$size);
  82. $page = $page >= $total ? $total : $page;
  83. $list = Db::name('purchease_in')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  84. ->where($where)->page($page,$size)
  85. ->field("a.apply_name,a.sendtime,b.order_type,a.status,a.cgdNo,a.wsm_in_code,b.good_name,a.send_num,a.wsm_code,b.good_name,b.good_code,
  86. a.post_company,a.post_code,a.post_fee,a.apply_id,a.wsm_num,a.error_num,a.wait_num,a.status,a.check_name,a.checkid,b.bkcode,b.supplierNo")
  87. ->order("a.addtime desc")->select();
  88. $data=[];
  89. foreach ($list as $value){
  90. $wsmcode = Db::name("warehouse_info")->alias("k")->leftJoin("supplier c","k.supplierNo=c.code")
  91. ->where(["k.wsm_code"=>$value['wsm_code']])->field("k.name as wsm_name,c.name,c.code")->find();
  92. $value['wsm_name'] = $wsmcode['wsm_name'];
  93. $value['wsm_supplier'] = $wsmcode['name'];
  94. $value['wsm_supplierNo'] = $wsmcode['code'];
  95. $data[]=$value;
  96. }
  97. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  98. }
  99. public function add(){
  100. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!=""? trim($this->post['cgdNo']):"";
  101. if($cgdNo==""){
  102. return error_show(1005,"参数cgdNo 不能为空");
  103. }
  104. $cgdinfo = Db::name("purchease_order")->where(['cgdNo'=>$cgdNo,'is_del'=>0])->find();
  105. if(empty($cgdinfo)){
  106. return error_show(1005,"未找到采购单数据");
  107. }
  108. if($cgdinfo['status']==0){
  109. return error_show(1005,"采购单未发货");
  110. }
  111. $wsm_in_code = makeNo("IC");
  112. // $wsm_code = isset($this->post['wsm_code'])&&$this->post['wsm_code']!="" ? trim($this->post['wsm_code']):"";
  113. // if($wsm_code==""){
  114. // return error_show(1004,"参数 wsm_code 不能为空");
  115. // }
  116. $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  117. if(empty($wsminfo)){
  118. return error_show(1004,"未找到仓库信息");
  119. }
  120. $recep = Db::name('warehouse_addr')->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  121. $sendtype = isset($this->post['sendtype'])&&$this->post['sendtype']!="" ? intval($this->post['sendtype']):"";
  122. if($sendtype==""){
  123. return error_show(1004,"参数 sendtype 不能为空");
  124. }
  125. $data = GetUserInfo($this->post['token']);
  126. if((!empty($data) && $data['code']!=0) ||empty($data) ){
  127. return error_show($data['code'],$data['message']);
  128. }
  129. $userinfo = $data['data'];
  130. $post_company = isset($this->post['post_company'])&&$this->post['post_company']!="" ? trim($this->post['post_company']):"";
  131. $post_code = isset($this->post['post_code'])&&$this->post['post_code']!="" ? trim($this->post['post_code']):"";
  132. $post_fee = isset($this->post['post_fee'])&&$this->post['post_fee']!="" ? $this->post['post_fee']:"0";
  133. $post_time = isset($this->post['post_time'])&&$this->post['post_time']!="" ? $this->post['post_time']:date("Y-m-d H:i:s");
  134. $send_num = isset($this->post['send_num'])&&$this->post['send_num']!="" ? intval($this->post['send_num']):"";
  135. $status = isset($this->post['status'])&&$this->post['status']!="" ? intval($this->post['status']):"0";
  136. if($send_num==''){
  137. return error_show(1004,"参数 send_num 不能为空或零");
  138. }
  139. if($send_num>$cgdinfo['wsend_num']){
  140. return error_show(1004,"采购单剩余未发货数量不足");
  141. }
  142. $orin = [
  143. "wsm_in_code"=>$wsm_in_code,
  144. "cgdNo"=>$cgdNo,
  145. "wsm_code"=>$cgdinfo['wsm_code'],
  146. "wsm_reaper"=>isset($recep)&& $recep['wsm_name']!=''? $recep['wsm_name']:"",
  147. "send_num"=>$send_num,
  148. "post_company"=>$post_company,
  149. "post_code"=>$post_code,
  150. "post_fee"=>$post_fee,
  151. "sendtime"=>$post_time,
  152. "apply_id"=>$userinfo['id'],
  153. "apply_name"=>$userinfo['nickname'],
  154. "wait_num"=>0,
  155. "sendtype"=>$sendtype,
  156. "status"=>$status,
  157. "addtime"=>date("Y-m-d H:i:s"),
  158. "updatetime"=>date("Y-m-d H:i:s")
  159. ];
  160. Db::startTrans();
  161. try{
  162. $win = Db::name("purchease_in")->insert($orin,true);
  163. $sto = ["order_code"=>$wsm_in_code,"status"=>$status,"action_remark"=>'',"action_type"=>"edit"];
  164. ActionLog::logAdd($this->post['token'],$sto,"RKD",$status,$sto);
  165. $process=["order_code"=>$wsm_in_code,"order_id"=>$win,"order_status"=>$status,"order_type"=>'RKD'];
  166. ProcessOrder::AddProcess($this->post['token'],$process);
  167. if($win){
  168. $order = ["order_code"=>$wsm_in_code,"status"=>$status,"action_remark"=>'',"action_type"=>"create"];
  169. ActionLog::logAdd($this->post['token'],$order,"rkd",$status,$this->post);
  170. if($status==1){
  171. $order = ["order_code"=>$cgdNo,"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  172. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  173. $cgdinfo['wsend_num']-=$send_num;
  174. $cgdinfo['send_num']+=$send_num;
  175. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  176. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  177. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  178. $up=Db::name("purchease_order")->save($cgdinfo);
  179. if($up){
  180. // $good = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'],"spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  181. // if(empty($good)) {
  182. // $good=[
  183. // "spuCode"=>$cgdinfo['skpuCode'],
  184. // "wsm_code"=>$cgdinfo['wsm_code'],
  185. // "usable_stock"=>0,
  186. // "wait_out_stock"=>0,
  187. // "wait_in_stock"=>0,
  188. // "total_stock"=>0,
  189. // "addtime"=>date("Y-m-d H:i:s"),
  190. // "updatetime"=>date("Y-m-d H:i:s"),
  191. // ];
  192. // $order = ["order_code"=>$good['good_type_code'],"status"=>1,"action_remark"=>'',
  193. // "action_type"=>"create"];
  194. //
  195. // }else{
  196. // $order = ["order_code"=>$good['good_type_code'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  197. // }
  198. // $good['wait_in_stock']+=$send_num;
  199. // $good['updatetime'] = date("Y-m-d H:i:s");
  200. // $upd= Db::name("good_stock")->save($good);
  201. // $good_data[]=["stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,
  202. // 'stock'=>$send_num,"stock_name"=>"wait_in_stock"];
  203. // if($upd){
  204. // GoodLog::LogAdd($this->post['token'],$good_data,'入库单');
  205. // ActionLog::logAdd($this->post['token'],$order,"仓库库存", 1,$good );
  206. $process=["order_code"=>$cgdNo,"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD'];
  207. ProcessOrder::AddProcess($this->post['token'],$process);
  208. Db::commit();
  209. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  210. // }else{
  211. // Db::rollback();
  212. // return error_show(1002,"商品入库失败");
  213. // }
  214. // Db::commit();
  215. // return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  216. }else{
  217. Db::rollback();
  218. return error_show(1004,"新建失败");
  219. }
  220. }
  221. Db::commit();
  222. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  223. }
  224. Db::rollback();
  225. return error_show(1004,"新建失败");
  226. }catch (\Exception $e){
  227. Db::rollback();
  228. return error_show(1004,$e->getMessage());
  229. }
  230. }
  231. public function info(){
  232. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  233. if($incode==""){
  234. return error_show(1004,"参数wsm_in_code 不为空");
  235. }
  236. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  237. if(empty($info)){
  238. return error_show(1004,"未找到数据");
  239. }
  240. $dom = Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],'is_del'=>0])->find();
  241. $goon = Db::name('good')->where(['good_code'=>$dom['good_code']])->field("cat_id")->find();
  242. if(empty($goon)){
  243. return error_show(1002,"未找到商品数据");
  244. }
  245. $cat= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  246. $info['cgder']=$dom['cgder'];
  247. $info['spuCode']=$dom['spuCode'];
  248. $info['good_name']=$dom['good_name'];
  249. $info['skuCode']=$dom['skuCode'];
  250. $info['good_num']=$dom['good_num'];
  251. $info['good_price']=$dom['good_price'];
  252. $info['total_fee']=$dom['total_fee'];
  253. $info['diff_fee']=$dom['diff_fee'];
  254. $info['diff_weight']=$dom['diff_weight'];
  255. $info['gold_price']=$dom['gold_price'];
  256. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
  257. ->leftJoin("warehouse_addr c","a.wsm_code=c.wsm_code and c.is_del=0")
  258. ->where(["a.wsm_code"=>$info['wsm_code']])->field("a.name as wsm_name,b.name,b.code,c.wsm_name as wsm_contactor,c.wsm_mobile,c.wsm_addr,c.addr_code")->find();
  259. $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  260. $info['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  261. $info['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  262. $info['wsm_contactor'] =isset($wsmcode['wsm_contactor']) ? $wsmcode['wsm_contactor']:"";
  263. $info['wsm_mobile'] =isset($wsmcode['wsm_mobile']) ? $wsmcode['wsm_mobile']:"";
  264. $info['addr_code'] =isset($wsmcode['addr_code']) ? $wsmcode['addr_code']:"";
  265. $info['wsm_addr'] =isset($wsmcode['addr_code']) ? GetAddr($wsmcode['addr_code']):"";
  266. $info['wsm_addr'].=isset($wsmcode['wsm_addr']) ? $wsmcode['wsm_addr']:"";
  267. $check = Db::name("purchease_info")->alias("a")->leftJoin("result_info b","a.error_code=b.result_code")->where
  268. (['wsm_in_code'=>$incode,"a.is_del"=>0])->field("a.id,a.wsm_in_code,a.num,a.error_code,b.result as error_msg,a.error_img,remark,a.is_del")->select();
  269. $info['checkinfo']= $check;
  270. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  271. $return['return_contactor']=isset($return['return_contactor'])&&$return['return_contactor']!="" ?$return['return_contactor']:$info['wsm_contactor'];
  272. $return['return_addr']=isset($return['return_addr'])&&$return['return_addr']!="" ?$return['return_addr']:$info['wsm_addr'];
  273. $return['return_mobile']=isset($return['return_mobile'])&&$return['return_mobile']!="" ?$return['return_mobile']:$info['wsm_mobile'];
  274. $info['return']= $return;
  275. $info['can']=$cat;
  276. return app_show(0,'获取成功',$info);
  277. }
  278. public function check(){
  279. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  280. if($incode==""){
  281. return error_show(1004,"参数wsm_in_code 不为空");
  282. }
  283. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  284. if(empty($info)){
  285. return error_show(1004,"未找到数据");
  286. }
  287. if($info['status']!=1){
  288. return error_show(1004,"发货单状态有误");
  289. }
  290. $order_num = isset($this->post['order_num']) && $this->post['order_num']!==''?intval($this->post['order_num'])
  291. :"";
  292. if($order_num===""){
  293. return error_show(1004,"参数 order_num 不为空");
  294. }
  295. $error_list = isset($this->post['error_list']) && $this->post['error_list']!==''?$this->post['error_list']:"";
  296. // $wait_num = isset($this->post['wait_num']) && $this->post['wait_num']!==''?intval($this->post['wait_num'])
  297. // :"";
  298. // if($wait_num===''){
  299. // return error_show(1004,"参数 wait_num 不为空");
  300. // }
  301. $result = GetUserInfo($this->post['token']);
  302. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  303. return error_show($result['code'],$result['message']);
  304. }
  305. $userinfo = $result['data'];
  306. Db::startTrans();
  307. try{
  308. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  309. $info['wsm_num'] = $order_num;
  310. $info['wait_num'] = $info['send_num'];
  311. $info['checkid'] = $userinfo['id'];
  312. $info['check_name'] = $userinfo['nickname'];
  313. $info['status'] =2;
  314. $info['error_num'] = $info['send_num']-$order_num;
  315. $info['updatetime'] = date("Y-m-d H:i:s");
  316. $up =Db::name("purchease_in")->save($info);
  317. if($up){
  318. ActionLog::logAdd($this->post['token'],$order,"rkd",2,$this->post);
  319. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD'];
  320. ProcessOrder::AddProcess($this->post['token'],$process);
  321. if(!empty($error_list)){
  322. $data=[];
  323. foreach ($error_list as $value ){
  324. $temp=[];
  325. $temp['wsm_in_code']=$info['wsm_in_code'];
  326. $temp['num']=$value['num'];
  327. $temp['error_code']=$value['error_code'];
  328. $temp['error_img']=$value['error_img'];
  329. $temp['remark']=$value['remark'];
  330. $temp['is_del']=0;
  331. $temp['addtime']=date("Y-m-d H:i:s");
  332. $temp['updatetime']=date("Y-m-d H:i:s");
  333. $data[]=$temp;
  334. }
  335. $derr= Db::name("purchease_info")->insertAll($data);
  336. // echo Db::name("purchease_info")->getLastSql();
  337. if($derr){
  338. Db::commit();
  339. return app_show(0,"验货完成");
  340. }else{
  341. Db::rollback();
  342. return error_show(1002,"验货数据保存失败");
  343. }
  344. }
  345. Db::commit();
  346. return app_show(0,"验货完成");
  347. }
  348. Db::rollback();
  349. return error_show(1002,"验货数据保存失败");
  350. }catch (\Exception $e){
  351. Db::rollback();
  352. return error_show(1002,$e->getMessage());
  353. }
  354. }
  355. public function status(){
  356. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  357. if($incode==""){
  358. return error_show(1004,"参数wsm_in_code 不为空");
  359. }
  360. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  361. if(empty($info)){
  362. return error_show(1004,"未找到数据");
  363. }
  364. $status = isset($this->post['status'])&&$this->post['status']!=="" ? intval($this->post['status']):"";
  365. if($status===""){
  366. return error_show(1004,"参数status 不为空");
  367. }
  368. if($info['status']==4){
  369. return error_show(1004,"入库单已完成");
  370. }
  371. $remark = isset($this->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']) :"";
  372. Db::startTrans();
  373. try{
  374. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"status"];
  375. $info['status'] = $status;
  376. $info['remark'] = $remark;
  377. $info['updatetime'] = date("Y-m-d H:i:s");
  378. $update = Db::name("purchease_in")->save($info);
  379. if($update){
  380. ActionLog::logAdd($this->post['token'],$order,"入库单",$status,$this->post);
  381. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$status,"order_type"=>'RKD'];
  382. ProcessOrder::AddProcess($this->post['token'],$process);
  383. if($status==0){
  384. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  385. if(empty($cgdinfo)){
  386. Db::rollback();
  387. return error_show(1002,"未找到采购单数据");
  388. }
  389. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  390. $cgdinfo['wsend_num']+=$info['send_num'];
  391. $cgdinfo['send_num']-=$info['send_num'];
  392. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  393. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  394. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  395. $up=Db::name("purchease_order")->save($cgdinfo);
  396. if($up){
  397. ActionLog::logAdd($this->post['token'],$order,"cgd", $cgdinfo['status'],$cgdinfo);
  398. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD'];
  399. ProcessOrder::AddProcess($this->post['token'],$process);
  400. Db::commit();
  401. return app_show(0,'取消成功');
  402. }else{
  403. Db::rollback();
  404. return error_show(1002,"取消失败");
  405. }
  406. }
  407. if($status==1){
  408. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  409. if(empty($cgdinfo)){
  410. Db::rollback();
  411. return error_show(1002,"未找到采购单数据");
  412. }
  413. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  414. $cgdinfo['wsend_num']-=$info['send_num'];
  415. $cgdinfo['send_num']+=$info['send_num'];
  416. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  417. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  418. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  419. $up=Db::name("purchease_order")->save($cgdinfo);
  420. if($up){
  421. ActionLog::logAdd($this->post['token'],$order,"cgd", $cgdinfo['status'],$cgdinfo);
  422. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD'];
  423. ProcessOrder::AddProcess($this->post['token'],$process);
  424. Db::commit();
  425. return app_show(0,'发货成功');
  426. }else{
  427. Db::rollback();
  428. return error_show(1002,"发货失败");
  429. }
  430. }
  431. if($status==4){
  432. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  433. if(empty($cgdinfo)){
  434. Db::rollback();
  435. return error_show(1002,"未找到采购单数据");
  436. }
  437. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'],"good_type_code"=>$cgdinfo['skuCode'],"is_del"=>0])->find();
  438. if(empty($good)) {
  439. $good=[
  440. "good_type_code"=>$cgdinfo['skuCode'],
  441. "wsm_code"=>$info['wsm_code'],
  442. "usable_stock"=>0,
  443. "wait_out_stock"=>0,
  444. "wait_in_stock"=>0,
  445. "total_stock"=>0,
  446. "addtime"=>date("Y-m-d H:i:s"),
  447. "updatetime"=>date("Y-m-d H:i:s"),
  448. ];
  449. $order = ["order_code"=>$good['good_type_code'],"status"=>1,"action_remark"=>'',
  450. "action_type"=>"create"];
  451. }else{
  452. $order = ["order_code"=>$good['good_type_code'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  453. }
  454. $good['usable_stock']+=$info['wsm_num'];
  455. $good['wait_in_stock']-=$info['wsm_num'];
  456. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  457. $good['updatetime'] = date("Y-m-d H:i:s");
  458. $upd= Db::name("good_stock")->save($good);
  459. $good_data[]=["stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,
  460. 'stock'=>$info['wsm_num'],"stock_name"=>"usable_stock"];
  461. if($upd){
  462. GoodLog::LogAdd($this->post['token'],$good_data,'入库单');
  463. ActionLog::logAdd($this->post['token'],$order,"仓库库存", 1,$good );
  464. Db::commit();
  465. return app_show(0,'商品入库成功');
  466. }else{
  467. Db::rollback();
  468. return error_show(1002,"商品入库失败");
  469. }
  470. }
  471. Db::commit();
  472. return app_show(0,"状态修改完成");
  473. }
  474. Db::rollback();
  475. return error_show(1002,"状态修改失败");
  476. }catch (\Exception $e){
  477. Db::rollback();
  478. return error_show(1002,$e->getMessage());
  479. }
  480. }
  481. /**
  482. * @return \think\response\Json|void
  483. * @throws \think\db\exception\DataNotFoundException
  484. * @throws \think\db\exception\DbException
  485. * @throws \think\db\exception\ModelNotFoundException
  486. */
  487. public function ReturnAdd(){
  488. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  489. if($incode==""){
  490. return error_show(1004,"参数wsm_in_code 不为空");
  491. }
  492. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  493. if(empty($info)){
  494. return error_show(1004,"未找到数据");
  495. }
  496. $wsm_num = isset($this->post['wsm_num']) &&$this->post['wsm_num']!=="" ? intval($this->post['wsm_num']):"" ;
  497. if($wsm_num===""){
  498. return error_show(1004,"参数wsm_num 不为空");
  499. }
  500. $reissue_num = isset($this->post['reissue_num']) &&$this->post['reissue_num']!=="" ? intval($this->post['reissue_num']):"0" ;
  501. $return_num = isset($this->post['return_num']) &&$this->post['return_num']!=="" ? intval($this->post['return_num']):"0" ;
  502. $contactor = isset($this->post['contactor']) &&$this->post['contactor']!=="" ? trim($this->post['contactor']):"" ;
  503. if($contactor==""){
  504. return error_show(1004,"参数contactor 不为空");
  505. }
  506. $addr = isset($this->post['addr']) &&$this->post['addr']!=="" ? trim($this->post['addr']):"" ;
  507. if($addr==""){
  508. return error_show(1004,"参数addr 不为空");
  509. }
  510. $mobile = isset($this->post['mobile']) &&$this->post['mobile']!=="" ? trim($this->post['mobile']):"" ;
  511. if($mobile==""){
  512. return error_show(1004,"参数mobile 不为空");
  513. }
  514. $error_remark = isset($this->post['error_remark']) &&$this->post['error_remark']!=="" ? trim($this->post['error_remark']):"" ;
  515. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  516. $result = GetUserInfo($this->post['token']);
  517. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  518. return error_show($result['code'],$result['message']);
  519. }
  520. $userinfo = $result['data'];
  521. Db::startTrans();
  522. try{
  523. $info['status'] =3;
  524. $info['is_th'] =$return_num>0 ?1:0;
  525. $info['updatetime'] = date("Y-m-d H:i:s");
  526. $up= Db::name("purchease_in")->save($info);
  527. if($up){
  528. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD'];
  529. ProcessOrder::AddProcess($this->post['token'],$process);
  530. $data=[
  531. "wsm_in_code"=>$incode,
  532. "wsm_num"=>$wsm_num,
  533. "reissue_num"=>$reissue_num,
  534. "return_num"=>$return_num,
  535. "return_contactor"=>$contactor,
  536. "return_addr"=>$addr,
  537. "return_mobile"=>$mobile,
  538. "error_remark"=>$error_remark,
  539. "post_code"=>"",
  540. "post_company"=>"",
  541. "remark"=>$remark ,
  542. "apply_id"=>$userinfo['id'],
  543. "apply_name"=>$userinfo['nickname'],
  544. "status"=>0,
  545. "addtime"=>date("Y-m-d H:i:s"),
  546. "updatetime"=>date("Y-m-d H:i:s")
  547. ];
  548. $res = Db::name("purchease_return")->insert($data,true);
  549. if($res){
  550. $sto = ["order_code"=>$incode,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  551. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",0,$sto);
  552. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$res,"order_status"=>0,"order_type"=>'RKTHD'];
  553. ProcessOrder::AddProcess($this->post['token'],$process);
  554. Db::commit();
  555. return app_show(0,"验货审核完成");
  556. }else{
  557. Db::rollback();
  558. return error_show(1002,"验货审核失败");
  559. }
  560. }
  561. }catch (\Exception $e){
  562. Db::rollback();
  563. return error_show(1002,$e->getMessage());
  564. }
  565. }
  566. public function ReturnSend(){
  567. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  568. if($incode==""){
  569. return error_show(1004,"参数wsm_in_code 不为空");
  570. }
  571. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  572. if(empty($info)){
  573. return error_show(1004,"未找到发货单数据");
  574. }
  575. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  576. if(empty($return)){
  577. return error_show(1004,"未找到退货单数据");
  578. }
  579. $post_code = isset($this->post['post_code']) &&$this->post['post_code']!=="" ? trim($this->post['post_code']):"" ;
  580. if($post_code==""){
  581. return error_show(1004,"参数 post_code 不能为空");
  582. }
  583. $post_company = isset($this->post['post_company']) &&$this->post['post_company']!=="" ? trim($this->post['post_company']):"" ;
  584. if($post_company==""){
  585. return error_show(1004,"参数 post_company 不能为空");
  586. }
  587. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  588. $data=[
  589. "post_code"=>$post_code,
  590. "post_company"=>$post_company,
  591. "remark"=>$remark,
  592. "status"=>1,
  593. "updatetime"=>date("Y-m-d H:i:s")
  594. ];
  595. Db::startTrans();
  596. try{
  597. $up =Db::name("purchease_return")->where($return)->save($data);
  598. if($up){
  599. $sto = ["order_code"=>$info['wsm_in_code'],"status"=>1,"action_remark"=>'',"action_type"=>"edit"];
  600. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",1,$sto);
  601. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$return['id'],"order_status"=>1,"order_type"=>'RKTHD'];
  602. ProcessOrder::AddProcess($this->post['token'],$process);
  603. $ark=$info['status'];
  604. $info['status']=5;
  605. $info['updatetime']=date("Y-m-d H:i:s");
  606. $sa=Db::name("purchease_in")->save($info);
  607. if($sa){
  608. $stn = ["order_code"=>$info['wsm_in_code'],"status"=>$ark,"action_remark"=>'',"action_type"=>"edit"];
  609. ActionLog::logAdd($this->post['token'],$stn,"RKD",5,$stn);
  610. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>5,"order_type"=>'RKD'];
  611. ProcessOrder::AddProcess($this->post['token'],$process);
  612. Db::commit();
  613. return app_show(0,"退货发货成功");
  614. }else{
  615. Db::rollback();
  616. return error_show(1004,"退货发货失败");
  617. }
  618. }else{
  619. return error_show(1004,"退货发货失败");
  620. }
  621. }catch (\Exception $e){
  622. Db::rollback();
  623. return error_show(1004,$e->getMessage());
  624. }
  625. }
  626. // public function ReturnStatus(){
  627. // $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  628. // if($incode==""){
  629. // return error_show(1004,"参数wsm_in_code 不为空");
  630. // }
  631. // $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  632. // if(empty($info)){
  633. // return error_show(1004,"未找到发货单数据");
  634. // }
  635. // $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  636. // if(empty($return)){
  637. // return error_show(1004,"未找到数据");
  638. // }
  639. // if($info['status']<4){
  640. // return error_show(1004,"入库单未完成");
  641. // }
  642. // $status = isset($this->post['status'])&&$this->post['status']!="" ?$this->post['status']:"";
  643. // if($status==""){
  644. // return error_show(1004,"参数status 不为空");
  645. // }
  646. // Db::startTrans();
  647. // try{
  648. // $data=[
  649. // "status"=>$status,
  650. // "updatetime"=>date("Y-m-d H:i:s")
  651. // ];
  652. // $up =Db::name("purchease_return")->where($return)->save($data);
  653. // if($up){
  654. // $info['status']=$status==1?5:6;
  655. // $info['updatetime']=date("Y-m-d H:i:s");
  656. // $sa=Db::name("purchease_in")->save($info);
  657. // if($sa){
  658. // Db::commit();
  659. // return app_show(0,"更新成功");
  660. // }else{
  661. // Db::rollback();
  662. // return error_show(1004,"更新失败");
  663. // }
  664. // }else{
  665. // Db::rollback();
  666. // return error_show(1004,"更新失败");
  667. // }
  668. // }catch (\Exception $e){
  669. // Db::rollback();
  670. // return error_show(1004,$e->getMessage());
  671. // }
  672. //
  673. // }
  674. }