Purchin.php 30 KB

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