Purchin.php 61 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126
  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. //采购单入库
  10. class Purchin extends Base
  11. {
  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.spuCode",'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. $role=$this->checkRole();
  80. if(!empty($role['write'])){
  81. $where[]=["apply_id","in",$role['write']];
  82. }
  83. $count = Db::name('purchease_in')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  84. ->where($where)->count();
  85. $total = ceil($count/$size);
  86. $page = $page >= $total ? $total : $page;
  87. $list = Db::name('purchease_in')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  88. ->where($where)->page($page,$size)
  89. ->field("a.apply_name,a.sendtime,b.order_type,a.status,a.cgdNo,a.wsm_in_code,a.send_num,a.wsm_code,b.good_name,b.spuCode,
  90. 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")
  91. ->order("a.addtime desc")->select();
  92. $data=[];
  93. foreach ($list as $value){
  94. //获取规格、品牌信息
  95. if ($value['order_type'] == 3 || $value['order_type'] == 4) {
  96. $temp = Db::name('good_zixun')
  97. ->alias('gz')
  98. ->field('gz.specinfo,b.brand_name')
  99. ->join('brand b', 'b.id=gz.brand_id')
  100. ->where(['gz.spuCode' => $value['spuCode'], 'gz.is_del' => 0])
  101. ->find();
  102. $value["brand_name"] = $temp['brand_name'];
  103. $value["speclist"] = json_decode($temp['specinfo'], true);
  104. } else {
  105. $value['brand_name'] = Db::name('good_basic')
  106. ->alias('gb')
  107. ->join('brand b', 'b.id=gb.brand_id')
  108. ->where(['gb.spuCode' => $value['spuCode']])
  109. ->value('b.brand_name');
  110. $spec = Db::name("good_spec")
  111. ->where(["spuCode" => $value['spuCode'], "is_del" => 0])
  112. ->select()
  113. ->toArray();
  114. $speclist = [];
  115. if (!empty($spec)) {
  116. foreach ($spec as $val) {
  117. $temp = [];
  118. $temp['id'] = $val['id'];
  119. $temp['spuCode'] = $val['spuCode'];
  120. $temp['spec_id'] = $val['spec_id'];
  121. $temp['spec_value_id'] = $val['spec_value_id'];
  122. $sp = Db::name("specs")->where(["id" => $val['spec_id']])->find();
  123. $temp['spec_name'] = isset($sp["spec_name"]) ? $sp["spec_name"] : "";
  124. $spv = Db::name("spec_value")->where(["id" => $val['spec_value_id']])->find();
  125. $temp['spec_value'] = isset($spv["spec_value"]) ? $spv["spec_value"] : "";
  126. $speclist[] = $temp;
  127. }
  128. }
  129. $value["speclist"] = empty($speclist) ? [] : $speclist;
  130. }
  131. $wsmcode = Db::name("warehouse_info")->alias("k")->leftJoin("supplier c","k.supplierNo=c.code")
  132. ->where(["k.wsm_code"=>$value['wsm_code']])->field("k.name as wsm_name,c.name,c.code")->find();
  133. $value['wsm_name'] = $wsmcode['wsm_name'];
  134. $value['wsm_supplier'] = $wsmcode['name'];
  135. $value['wsm_supplierNo'] = $wsmcode['code'];
  136. $data[]=$value;
  137. }
  138. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  139. }
  140. public function add(){
  141. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!=""? trim($this->post['cgdNo']):"";
  142. if($cgdNo==""){
  143. return error_show(1005,"参数cgdNo 不能为空");
  144. }
  145. $cgdinfo = Db::name("purchease_order")->where(['cgdNo'=>$cgdNo,'is_del'=>0])->find();
  146. if(empty($cgdinfo)){
  147. return error_show(1005,"未找到采购单数据");
  148. }
  149. if($cgdinfo['status']==0){
  150. return error_show(1005,"采购单未发货");
  151. }
  152. $wsm_in_code = makeNo("CF");
  153. // $wsm_code = isset($this->post['wsm_code'])&&$this->post['wsm_code']!="" ? trim($this->post['wsm_code']):"";
  154. // if($wsm_code==""){
  155. // return error_show(1004,"参数 wsm_code 不能为空");
  156. // }
  157. $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  158. if(empty($wsminfo)){
  159. return error_show(1004,"未找到仓库信息");
  160. }
  161. $recep = Db::name('warehouse_addr')->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  162. $sendtype = isset($this->post['sendtype'])&&$this->post['sendtype']!="" ? intval($this->post['sendtype']):"";
  163. if($sendtype==""){
  164. return error_show(1004,"参数 sendtype 不能为空");
  165. }
  166. $data = GetUserInfo($this->post['token']);
  167. if((!empty($data) && $data['code']!=0) ||empty($data) ){
  168. return error_show($data['code'],$data['message']);
  169. }
  170. $userinfo = $data['data'];
  171. $post_company = isset($this->post['post_company'])&&$this->post['post_company']!="" ? trim($this->post['post_company']):"";
  172. $post_code = isset($this->post['post_code'])&&$this->post['post_code']!="" ? trim($this->post['post_code']):"";
  173. $post_fee = isset($this->post['post_fee'])&&$this->post['post_fee']!="" ? $this->post['post_fee']:"0";
  174. $post_time = isset($this->post['post_time'])&&$this->post['post_time']!="" ? $this->post['post_time']:date("Y-m-d H:i:s");
  175. $send_num = isset($this->post['send_num'])&&$this->post['send_num']!="" ? intval($this->post['send_num']):"";
  176. $status = isset($this->post['status'])&&$this->post['status']!="" ? intval($this->post['status']):"1 ";
  177. if($send_num==''){
  178. return error_show(1004,"参数 send_num 不能为空或零");
  179. }
  180. $wsmin_num=Db::name("purchease_in")->where([["cgdNo","=",$cgdNo],["is_del","=",0],["status","not in",[4,6]]])
  181. ->sum("send_num");
  182. if($send_num>$cgdinfo['wsend_num']-$wsmin_num){
  183. return error_show(1009,"采购单剩余未发货数量不足");
  184. }
  185. // if($cgdinfo['order_type']==1||$cgdinfo['order_type']==2 ){
  186. // $goodinfo = Db::name("good_basic")->where(["spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  187. // if($goodinfo==false){
  188. // return error_show(1004,"商品数据未找到");
  189. // }
  190. // if($goodinfo['is_stock']==0){
  191. // $status=4;
  192. // }
  193. // } else {
  194. // $send_way = Db::name("good_zixun")->where(["spuCode" => $cgdinfo['spuCode'], "is_del" => 0])->value('send_way');
  195. // if ($send_way) $status = 4;
  196. // }
  197. if($sendtype==2 || $cgdinfo['order_type']!=1){
  198. $status=4;
  199. }
  200. $orin = [
  201. "wsm_in_code"=>$wsm_in_code,
  202. "cgdNo"=>$cgdNo,
  203. "wsm_code"=>$cgdinfo['wsm_code'],
  204. "wsm_reaper"=>isset($recep)&& $recep['wsm_name']!=''? $recep['wsm_name']:"",
  205. "send_num"=>$send_num,
  206. "post_company"=>$post_company,
  207. "post_code"=>$post_code,
  208. "post_fee"=>$post_fee,
  209. "sendtime"=>$post_time,
  210. "apply_id"=>$userinfo['id'],
  211. "apply_name"=>$userinfo['nickname'],
  212. "wait_num"=>0,
  213. "wsm_num"=>0,
  214. "sendtype"=>$sendtype,
  215. "status"=>$status,
  216. "addtime"=>date("Y-m-d H:i:s"),
  217. "updatetime"=>date("Y-m-d H:i:s")
  218. ];
  219. Db::startTrans();
  220. try{
  221. $win = Db::name("purchease_in")->insert($orin,true);
  222. if($win){
  223. $sto = ["order_code"=>$wsm_in_code,"status"=>$status,"action_remark"=>'',"action_type"=>"edit"];
  224. ActionLog::logAdd($this->post['token'],$sto,"RKD",$status,$this->post);
  225. $process=["order_code"=>$wsm_in_code,"order_id"=>$win,"order_status"=>$status,"order_type"=>'RKD',"before_status"=>$status];
  226. ProcessOrder::AddProcess($this->post['token'],$process);
  227. $order = ["order_code"=>$cgdNo,"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  228. if($status==1){
  229. // $cgdinfo['wsend_num']-=$send_num;
  230. // $cgdinfo['send_num']+=$send_num;
  231. // $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  232. // $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  233. // $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  234. // $up=Db::name("purchease_order")->save($cgdinfo);
  235. // if($up){
  236. // if($cgdinfo['order_type']!=1){
  237. // $good = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'],"spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  238. // if(empty($good)) {
  239. // $good=[
  240. // "spuCode"=>$cgdinfo['spuCode'],
  241. // "wsm_code"=>$cgdinfo['wsm_code'],
  242. // "usable_stock"=>0,
  243. // "wait_out_stock"=>0,
  244. // "wait_in_stock"=>0,
  245. // "total_stock"=>0,
  246. // "addtime"=>date("Y-m-d H:i:s"),
  247. // "updatetime"=>date("Y-m-d H:i:s"),
  248. // ];
  249. // // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  250. // // "action_type"=>"create"];
  251. // }else{
  252. // // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  253. // // "action_type"=>"edit"];
  254. // }
  255. // $good['wait_in_stock']+=$send_num;
  256. // $good['updatetime'] = date("Y-m-d H:i:s");
  257. // $upd= Db::name("good_stock")->save($good);
  258. // if($upd==false){
  259. // Db::rollback();
  260. // return error_show(1004,"新建失败");
  261. // }
  262. // $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$send_num,"stock_name"=>"wait_in_stock"];
  263. // GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  264. // }
  265. Db::commit();
  266. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  267. }
  268. if($status==4){
  269. $cgdinfo['wsend_num']-=$send_num;
  270. $cgdinfo['send_num']+=$send_num;
  271. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  272. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  273. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  274. $up=Db::name("purchease_order")->save($cgdinfo);
  275. if($up==false){
  276. Db::rollback();
  277. return error_show(1004,"新建失败");
  278. }
  279. $good = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'],"spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  280. if(empty($good)) {
  281. $good=[
  282. "spuCode"=>$cgdinfo['spuCode'],
  283. "wsm_code"=>$cgdinfo['wsm_code'],
  284. "usable_stock"=>0,
  285. "wait_out_stock"=>0,
  286. "wait_in_stock"=>$send_num,
  287. "total_stock"=>0,
  288. "addtime"=>date("Y-m-d H:i:s"),
  289. "updatetime"=>date("Y-m-d H:i:s"),
  290. ];
  291. // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  292. // "action_type"=>"create"];
  293. }else{
  294. // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  295. // "action_type"=>"edit"];
  296. }
  297. $good['wait_in_stock']-=$send_num;
  298. $good['usable_stock']+=$send_num;
  299. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  300. $good['updatetime'] = date("Y-m-d H:i:s");
  301. $upd= Db::name("good_stock")->save($good);
  302. //商品变动日志表,good_log_code字段存储采购单单号
  303. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  304. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>2,'stock'=>$send_num,"stock_name"=>"wait_in_stock"];
  305. if($upd){
  306. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  307. if($cgdinfo['order_type']==1){
  308. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  309. if($bk==false){
  310. $bk=[
  311. "cgdNo"=>$cgdinfo['cgdNo'],
  312. "spuCode"=>$cgdinfo['spuCode'],
  313. "companyNo"=>$cgdinfo['companyNo'],
  314. "total_num"=>0,
  315. "merge_num"=>0,
  316. "balance_num"=>0,
  317. "status"=>1,
  318. "is_del"=>0,
  319. 'addtime'=>date("Y-m-d H:i:s"),
  320. "updatetime"=>date("Y-m-d H:i:s")
  321. ];
  322. }
  323. $bk['balance_num']+=$send_num;
  324. $bk['total_num']+=$send_num;
  325. $bk['updatetime']=date("Y-m-d H:i:s");
  326. $upcgd =Db::name("order_bk")->save($bk);
  327. if($upcgd==false){
  328. Db::rollback();
  329. return error_show(1004,"采购单数量更新失败");
  330. }
  331. }
  332. if($cgdinfo['send_status']==3 && $cgdinfo['order_type']!=1){
  333. $send=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"status"=>1])->column("outCode");
  334. if(!empty($send)){
  335. $out =Db::name("order_out")->where(["outCode"=>$send,"status"=>0])->select()
  336. ->toArray();
  337. if(!empty($out)){
  338. $up =Db::name("order_out")->where(["outCode"=>$send,"status"=>0])->update
  339. (["status"=>1,'wsm_code'=>$cgdinfo['wsm_code'],"updatetime"=>date('Y-m-d H:i:s')]);
  340. if($up==false){
  341. Db::rollback();
  342. return error_show(1004,"出库单出库失败");
  343. }else{
  344. foreach ($out as $k => $v_outCode) {
  345. //修改状态,添加待办
  346. ActionLog::logAdd($this->post['token'], [
  347. "order_code" => $v_outCode['outCode'],//出库单号
  348. "status" => 0,//这里的status是之前的值
  349. "action_remark" => '',//备注
  350. "action_type" => "status"//新建create,编辑edit,更改状态status
  351. ], "CKD", 1, $this->post);
  352. ProcessOrder::AddProcess($this->post['token'], [
  353. "order_type" => 'CKD',
  354. "order_code" => $v_outCode['outCode'],//出库单号
  355. "order_id" => $v_outCode['id'],
  356. "order_status" => 1,"before_status"=>0
  357. ]);
  358. }
  359. }
  360. $good1 = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  361. if($good1==false){
  362. Db::rollback();
  363. return error_show(1004,"未找到对应商品库存");
  364. }
  365. $out_num = intval(array_sum(array_column($out,"send_num")));
  366. if($out_num>$good1['usable_stock']){
  367. Db::rollback();
  368. return error_show(1004,"库存数量不足发货");
  369. }
  370. $good1['usable_stock']-=$out_num;
  371. $good1['wait_out_stock']+=$out_num;
  372. $good1['total_stock']=$good1['usable_stock']+$good1['wait_out_stock'];
  373. $good1['updatetime'] = date("Y-m-d H:i:s");
  374. $upd= Db::name("good_stock")->save($good1);
  375. if($upd==false){
  376. Db::rollback();
  377. return error_show(1004,"库存数量更新失败");
  378. }
  379. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])?$good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$send_num,"stock_name"=>"wait_out_stock"];
  380. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])?$good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  381. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  382. $sendp=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"outCode"=>$send,"status"=>1])->save (["status"=>2]);
  383. if($sendp==false){
  384. Db::rollback();
  385. return error_show(1004,"库存发货失败");
  386. }
  387. }
  388. }
  389. }
  390. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  391. $process=["order_code"=>$cgdNo,"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  392. ProcessOrder::AddProcess($this->post['token'],$process);
  393. Db::commit();
  394. return app_show(0,'商品入库成功',["wsm_in_code"=>$wsm_in_code]);
  395. }else{
  396. Db::rollback();
  397. return error_show(1002,"商品入库失败");
  398. }
  399. }
  400. Db::commit();
  401. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  402. }
  403. Db::rollback();
  404. return error_show(1004,"新建失败");
  405. }catch (\Exception $e){
  406. Db::rollback();
  407. return error_show(1004, $e->getMessage() . '|' . $e->getFile() . '|' . $e->getLine());
  408. }
  409. }
  410. public function info(){
  411. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  412. if($incode==""){
  413. return error_show(1004,"参数wsm_in_code 不为空");
  414. }
  415. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  416. if(empty($info)){
  417. return error_show(1004,"未找到数据");
  418. }
  419. $dom = Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],'is_del'=>0])->find();
  420. if($dom['order_type']==3|| $dom['order_type']==4){
  421. $goon = Db::name("good_zixun")->where(["spuCode"=>$dom['spuCode'],"is_del"=>0])->find();
  422. }else {
  423. $goon =Db::name('good_basic')->where(['spuCode'=>$dom['spuCode']])->find();
  424. }
  425. if(empty($goon)){
  426. return error_show(1002,"未找到商品数据");
  427. }
  428. $cat= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  429. $info['cgder']=$dom['cgder'];
  430. $info['spuCode']=$dom['spuCode'];
  431. $info['good_name']=$dom['good_name'];
  432. $info['skuCode']=$dom['skuCode'];
  433. $info['good_num']=$dom['good_num'];
  434. $info['good_price']=$dom['good_price'];
  435. $info['total_fee']=$dom['total_fee'];
  436. $info['diff_fee']=$dom['diff_fee'];
  437. $info['diff_weight']=$dom['diff_weight'];
  438. $info['gold_price']=$dom['gold_price'];
  439. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
  440. ->leftJoin("warehouse_addr c","a.wsm_code=c.wsm_code and c.is_del=0")
  441. ->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();
  442. $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  443. $info['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  444. $info['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  445. $info['wsm_contactor'] =isset($wsmcode['wsm_contactor']) ? $wsmcode['wsm_contactor']:"";
  446. $info['wsm_mobile'] =isset($wsmcode['wsm_mobile']) ? $wsmcode['wsm_mobile']:"";
  447. $info['addr_code'] =isset($wsmcode['addr_code']) ? $wsmcode['addr_code']:"";
  448. $info['wsm_addr'] =isset($wsmcode['addr_code']) ? GetAddr($wsmcode['addr_code']):"";
  449. $info['wsm_addr'].=isset($wsmcode['wsm_addr']) ? $wsmcode['wsm_addr']:"";
  450. $check = Db::name("purchease_info")->alias("a")->leftJoin("result_info b","a.error_code=b.result_code")->where
  451. (['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();
  452. $info['checkinfo']= $check;
  453. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  454. $return['return_contactor']=isset($return['return_contactor'])&&$return['return_contactor']!="" ?$return['return_contactor']:'';
  455. $return['return_addr']=isset($return['return_addr'])&&$return['return_addr']!="" ?$return['return_addr']:'';
  456. $return['return_mobile']=isset($return['return_mobile'])&&$return['return_mobile']!="" ?$return['return_mobile']:'';
  457. //以下字段临时补充到return中
  458. $return['wsm_in_code'] = $incode;
  459. $return['wsm_num'] = isset($return['wsm_num']) ? $return['wsm_num'] : 0;
  460. $return['reissue_num'] = isset($return['reissue_num']) ? $return['reissue_num'] : 0;
  461. $return['return_num'] = isset($return['return_num']) ? $return['return_num'] : 0;
  462. $return['contactor'] = $return['return_contactor'];
  463. $return['addr'] = $return['return_addr'];
  464. $return['mobile'] = $return['return_mobile'];
  465. $return['error_remark'] = isset($return['error_remark']) ? $return['error_remark'] : '';
  466. $return['remark'] = isset($return['remark']) ? $return['remark'] : '';
  467. $info['return']= $return;
  468. $info['can']=$cat;
  469. if(isset($dom['companyNo'])&&$dom['companyNo']!=""){
  470. $company = Db::name("business")->where(["companyNo"=>$dom['companyNo']])->find();
  471. }
  472. $info['company'] = isset($company['company'])?$company['company']:"";
  473. $info['companyNo'] = isset($dom['companyNo'])?$dom['companyNo']:"";
  474. $info['order_type'] = isset($dom['order_type'])?$dom['order_type']:"";
  475. return app_show(0,'获取成功',$info);
  476. }
  477. public function check(){
  478. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  479. if($incode==""){
  480. return error_show(1004,"参数wsm_in_code 不为空");
  481. }
  482. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  483. if(empty($info)){
  484. return error_show(1004,"未找到数据");
  485. }
  486. if($info['status']!=1){
  487. return error_show(1004,"发货单状态有误");
  488. }
  489. $order_num = isset($this->post['order_num']) && $this->post['order_num']!==''?intval($this->post['order_num'])
  490. :"";
  491. if($order_num===""){
  492. return error_show(1004,"参数 order_num 不为空");
  493. }
  494. $error_list = isset($this->post['error_list']) && $this->post['error_list']!==''?$this->post['error_list']:"";
  495. $result = GetUserInfo($this->post['token']);
  496. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  497. return error_show($result['code'],$result['message']);
  498. }
  499. $userinfo = $result['data'];
  500. Db::startTrans();
  501. try{
  502. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  503. $info['wsm_num'] = $order_num;
  504. $info['wait_num'] = $info['send_num'];
  505. $info['checkid'] = $userinfo['id'];
  506. $info['check_name'] = $userinfo['nickname'];
  507. $info['status'] =2;
  508. $info['error_num'] = $info['send_num']-$order_num;
  509. $info['updatetime'] = date("Y-m-d H:i:s");
  510. $up =Db::name("purchease_in")->save($info);
  511. if($up){
  512. ActionLog::logAdd($this->post['token'],$order,"RKD",2,$this->post);
  513. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD',"before_status"=>$order['status']];
  514. ProcessOrder::AddProcess($this->post['token'],$process);
  515. if(!empty($error_list)){
  516. $data=[];
  517. foreach ($error_list as $value ){
  518. $temp=[];
  519. $temp['wsm_in_code']=$info['wsm_in_code'];
  520. $temp['num']=$value['num'];
  521. $temp['error_code']=$value['error_code'];
  522. $temp['error_img']=$value['error_img'];
  523. $temp['remark']=$value['remark'];
  524. $temp['is_del']=0;
  525. $temp['addtime']=date("Y-m-d H:i:s");
  526. $temp['updatetime']=date("Y-m-d H:i:s");
  527. $data[]=$temp;
  528. }
  529. $derr= Db::name("purchease_info")->insertAll($data);
  530. if($derr){
  531. Db::commit();
  532. return app_show(0,"验货完成");
  533. }else{
  534. Db::rollback();
  535. return error_show(1002,"验货数据保存失败");
  536. }
  537. }
  538. Db::commit();
  539. return app_show(0,"验货完成");
  540. }
  541. Db::rollback();
  542. return error_show(1002,"验货数据保存失败");
  543. }catch (\Exception $e){
  544. Db::rollback();
  545. return error_show(1002,$e->getMessage());
  546. }
  547. }
  548. public function status(){
  549. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  550. if($incode==""){
  551. return error_show(1004,"参数wsm_in_code 不为空");
  552. }
  553. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  554. if(empty($info)){
  555. return error_show(1004,"未找到数据");
  556. }
  557. $status = isset($this->post['status'])&&$this->post['status']!=="" ? intval($this->post['status']):"";
  558. if($status===""){
  559. return error_show(1004,"参数status 不为空");
  560. }
  561. if($info['status']==4){
  562. return error_show(1004,"入库单已完成");
  563. }
  564. $remark = isset($this->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']) :"";
  565. Db::startTrans();
  566. try{
  567. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"status"];
  568. $info['status'] = $status;
  569. $info['remark'] = $remark;
  570. $info['updatetime'] = date("Y-m-d H:i:s");
  571. $update = Db::name("purchease_in")->save($info);
  572. if($update){
  573. ActionLog::logAdd($this->post['token'],$order,"RKD",$status,$this->post);
  574. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$status,"order_type"=>'RKD',"before_status"=>$order['status']];
  575. ProcessOrder::AddProcess($this->post['token'],$process);
  576. if($status==0){
  577. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  578. if(empty($cgdinfo)){
  579. Db::rollback();
  580. return error_show(1002,"未找到采购单数据");
  581. }
  582. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  583. $cgdinfo['wsend_num']+=$info['send_num'];
  584. $cgdinfo['send_num']-=$info['send_num'];
  585. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  586. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  587. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  588. $up=Db::name("purchease_order")->save($cgdinfo);
  589. if($up){
  590. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  591. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  592. ProcessOrder::AddProcess($this->post['token'],$process);
  593. Db::commit();
  594. return app_show(0,'取消成功');
  595. }else{
  596. Db::rollback();
  597. return error_show(1002,"取消失败");
  598. }
  599. }
  600. if($status==1){
  601. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  602. if(empty($cgdinfo)){
  603. Db::rollback();
  604. return error_show(1002,"未找到采购单数据");
  605. }
  606. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  607. $cgdinfo['wsend_num']-=$info['send_num'];
  608. $cgdinfo['send_num']+=$info['send_num'];
  609. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  610. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  611. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  612. $up=Db::name("purchease_order")->save($cgdinfo);
  613. if($up){
  614. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  615. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  616. ProcessOrder::AddProcess($this->post['token'],$process);
  617. Db::commit();
  618. return app_show(0,'发货成功');
  619. }else{
  620. Db::rollback();
  621. return error_show(1002,"发货失败");
  622. }
  623. }
  624. if($status==4){
  625. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  626. if(empty($cgdinfo)){
  627. Db::rollback();
  628. return error_show(1002,"未找到采购单数据");
  629. }
  630. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  631. $cgdinfo['wsend_num']-=$info['send_num'];
  632. $cgdinfo['send_num']+=$info['send_num'];
  633. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  634. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  635. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  636. $up=Db::name("purchease_order")->save($cgdinfo);
  637. if($up==false){
  638. Db::rollback();
  639. return error_show(1002,"发货失败");
  640. }
  641. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  642. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  643. ProcessOrder::AddProcess($this->post['token'],$process);
  644. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  645. if(empty($good)) {
  646. $good=[
  647. "spuCode"=>$cgdinfo['spuCode'],
  648. "wsm_code"=>$info['wsm_code'],
  649. "usable_stock"=>0,
  650. "wait_out_stock"=>0,
  651. "wait_in_stock"=>$info['wsm_num'],
  652. "total_stock"=>0,
  653. "addtime"=>date("Y-m-d H:i:s"),
  654. "updatetime"=>date("Y-m-d H:i:s"),
  655. ];
  656. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  657. "action_type"=>"create"];
  658. }else{
  659. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  660. }
  661. $good['usable_stock']+=$info['wsm_num'];
  662. $good['wait_in_stock']-=$info['wsm_num'];
  663. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  664. $good['updatetime'] = date("Y-m-d H:i:s");
  665. $upd= Db::name("good_stock")->save($good);
  666. //商品变动日志表,good_log_code字段存储入库单编号
  667. $good_data[] = ['good_log_code' => $incode, "stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1, 'stock' => $info['wsm_num'], "stock_name" => "usable_stock"];
  668. $good_data[] = ['good_log_code' => $incode, "stock_id" => isset($good['id']) ? $good['id'] :
  669. Db::name("good_stock")->getLastInsID(), "type" => 2, 'stock' => $info['wsm_num'], "stock_name" => "wait_in_stock"];
  670. if($upd){
  671. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  672. Db::commit();
  673. return app_show(0,'商品入库成功');
  674. }else{
  675. Db::rollback();
  676. return error_show(1002,"商品入库失败");
  677. }
  678. }
  679. Db::commit();
  680. return app_show(0,"状态修改完成");
  681. }
  682. Db::rollback();
  683. return error_show(1002,"状态修改失败");
  684. }catch (\Exception $e){
  685. Db::rollback();
  686. return error_show(1002,$e->getMessage());
  687. }
  688. }
  689. /**
  690. * @return \think\response\Json|void
  691. * @throws \think\db\exception\DataNotFoundException
  692. * @throws \think\db\exception\DbException
  693. * @throws \think\db\exception\ModelNotFoundException
  694. */
  695. public function ReturnAdd(){
  696. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  697. if($incode==""){
  698. return error_show(1004,"参数wsm_in_code 不为空");
  699. }
  700. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  701. if(empty($info)){
  702. return error_show(1004,"未找到数据");
  703. }
  704. //正常入库数量
  705. $wsm_num = isset($this->post['wsm_num']) &&$this->post['wsm_num']!=="" ? intval($this->post['wsm_num']):"" ;
  706. if($wsm_num===""){
  707. return error_show(1004,"参数wsm_num 不为空");
  708. }
  709. //补货数量
  710. $reissue_num = isset($this->post['reissue_num']) &&$this->post['reissue_num']!=="" ? intval($this->post['reissue_num']):"0" ;
  711. //退货数量
  712. $return_num = isset($this->post['return_num']) &&$this->post['return_num']!=="" ? intval($this->post['return_num']):"0" ;
  713. $contactor = isset($this->post['contactor']) &&$this->post['contactor']!=="" ? trim($this->post['contactor']):"" ;
  714. if($contactor==""){
  715. return error_show(1004,"参数contactor 不为空");
  716. }
  717. $addr = isset($this->post['addr']) &&$this->post['addr']!=="" ? trim($this->post['addr']):"" ;
  718. if($addr==""){
  719. return error_show(1004,"参数addr 不为空");
  720. }
  721. $mobile = isset($this->post['mobile']) &&$this->post['mobile']!=="" ? trim($this->post['mobile']):"" ;
  722. if($mobile==""){
  723. return error_show(1004,"参数mobile 不为空");
  724. }
  725. $error_remark = isset($this->post['error_remark']) &&$this->post['error_remark']!=="" ? trim($this->post['error_remark']):"" ;
  726. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  727. $result = GetUserInfo($this->post['token']);
  728. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  729. return error_show($result['code'],$result['message']);
  730. }
  731. $userinfo = $result['data'];
  732. Db::startTrans();
  733. try{
  734. $sto = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  735. // $info['status'] =$info['wsm_num']==$wsm_num ? 4 :5;
  736. $info['status'] = $info['send_num'] == $wsm_num ? 4 : 5;//艳蓉说,这里不能用入库数量比较,应该是用入库数量,即总数来比较
  737. $info['is_th'] =$return_num>0 ?1:0;
  738. $info['wsm_num']= $wsm_num;
  739. $info['updatetime'] = date("Y-m-d H:i:s");
  740. $up= Db::name("purchease_in")->save($info);
  741. if($up){
  742. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  743. if(empty($cgdinfo)){
  744. Db::rollback();
  745. return error_show(1002,"未找到采购单数据");
  746. }
  747. if($info['status']==4){
  748. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  749. $cgdinfo['wsend_num']-=$info['send_num'];
  750. $cgdinfo['send_num']+=$info['send_num'];
  751. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  752. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  753. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  754. $up=Db::name("purchease_order")->save($cgdinfo);
  755. if($up==false){
  756. Db::rollback();
  757. return error_show(1002,"发货失败");
  758. }
  759. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  760. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  761. ProcessOrder::AddProcess($this->post['token'],$process);
  762. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  763. if(empty($good)) {
  764. $good=[
  765. "spuCode"=>$cgdinfo['spuCode'],
  766. "wsm_code"=>$info['wsm_code'],
  767. "usable_stock"=>0,
  768. "wait_out_stock"=>0,
  769. "wait_in_stock"=>$wsm_num,
  770. "total_stock"=>0,
  771. "addtime"=>date("Y-m-d H:i:s"),
  772. "updatetime"=>date("Y-m-d H:i:s"),
  773. ];
  774. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  775. "action_type"=>"create"];
  776. }else{
  777. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  778. }
  779. $good['usable_stock']+=$wsm_num;
  780. $good['wait_in_stock']-=$wsm_num;
  781. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  782. $good['updatetime'] = date("Y-m-d H:i:s");
  783. $upd= Db::name("good_stock")->save($good);
  784. if($upd==false){
  785. Db::rollback();
  786. return error_show(1002,"库存更新失败");
  787. }
  788. $good_data[]=['good_log_code' => $incode,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1, 'stock'=>$info['wsm_num'],"stock_name"=>"usable_stock"];
  789. $good_data[]=['good_log_code' => $incode,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>2, 'stock'=>$info['wsm_num'],"stock_name"=>"wait_in_stock"];
  790. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  791. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  792. if($bk==false){
  793. $bk=[
  794. "cgdNo"=>$cgdinfo['cgdNo'],
  795. "spuCode"=>$cgdinfo['spuCode'],
  796. "companyNo"=>$cgdinfo['companyNo'],
  797. "total_num"=>0,
  798. "merge_num"=>0,
  799. "balance_num"=>0,
  800. "status"=>1,
  801. "is_del"=>0,
  802. 'addtime'=>date("Y-m-d H:i:s"),
  803. "updatetime"=>date("Y-m-d H:i:s")
  804. ];
  805. }
  806. $bk['balance_num']+=$wsm_num;
  807. $bk['total_num']+=$wsm_num;
  808. $bk['updatetime']=date("Y-m-d H:i:s");
  809. $upcgd =Db::name("order_bk")->save($bk);
  810. if($upcgd==false){
  811. Db::rollback();
  812. return error_show(1004,"采购单数量更新失败");
  813. }
  814. }
  815. ActionLog::logAdd($this->post['token'],$sto,"RKD", $info['status'],$this->post);
  816. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD',"before_status"=>$sto['status']];
  817. ProcessOrder::AddProcess($this->post['token'],$process);
  818. //需要在详情页把相关退货记录原样取出来,所以这里把if去掉,所有记录都入purchease_return表
  819. if($info['status']==5){
  820. $returnCode=makeNo("CR");
  821. $data=[
  822. "returnCode"=>$returnCode,
  823. "wsm_in_code"=>$incode,
  824. "cgdNo"=>$cgdinfo['cgdNo'],
  825. "wsm_num"=>$wsm_num,
  826. "reissue_num"=>$reissue_num,
  827. "return_num"=>$return_num,
  828. "return_contactor"=>$contactor,
  829. "return_addr"=>$addr,
  830. "return_mobile"=>$mobile,
  831. "error_remark"=>$error_remark,
  832. "post_code"=>"",
  833. "post_company"=>"",
  834. "remark"=>$remark ,
  835. "apply_id"=>$userinfo['id'],
  836. "apply_name"=>$userinfo['nickname'],
  837. "status"=>0,
  838. "addtime"=>date("Y-m-d H:i:s"),
  839. "updatetime"=>date("Y-m-d H:i:s")
  840. ];
  841. $res = Db::name("purchease_return")->insert($data,true);
  842. if($res==false){
  843. Db::rollback();
  844. return error_show(1002,"验货审核失败");
  845. }
  846. $sto = ["order_code"=>$incode,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  847. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",0,$data);
  848. }
  849. Db::commit();
  850. return app_show(0,"验货审核完成");
  851. }
  852. }catch (\Exception $e){
  853. Db::rollback();
  854. return error_show(1002,$e->getMessage());
  855. }
  856. }
  857. public function ReturnSend(){
  858. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  859. if($incode==""){
  860. return error_show(1004,"参数wsm_in_code 不为空");
  861. }
  862. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  863. if(empty($info)){
  864. return error_show(1004,"未找到发货单数据");
  865. }
  866. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  867. if(empty($return)){
  868. return error_show(1004,"未找到退货单数据");
  869. }
  870. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  871. if(empty($cgdinfo)){
  872. Db::rollback();
  873. return error_show(1002,"未找到采购单数据");
  874. }
  875. $post_code = isset($this->post['post_code']) &&$this->post['post_code']!=="" ? trim($this->post['post_code']):"" ;
  876. if($post_code==""){
  877. return error_show(1004,"参数 post_code 不能为空");
  878. }
  879. $post_company = isset($this->post['post_company']) &&$this->post['post_company']!=="" ? trim($this->post['post_company']):"" ;
  880. if($post_company==""){
  881. return error_show(1004,"参数 post_company 不能为空");
  882. }
  883. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  884. $data=[
  885. "post_code"=>$post_code,
  886. "post_company"=>$post_company,
  887. "remark"=>$remark,
  888. "status"=>1,
  889. "updatetime"=>date("Y-m-d H:i:s")
  890. ];
  891. Db::startTrans();
  892. try{
  893. $up =Db::name("purchease_return")->where($return)->save($data);
  894. if($up){
  895. $sto = ["order_code"=>$info['wsm_in_code'],"status"=>$return['status'],"action_remark"=>'', "action_type"=>"edit"];
  896. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",1,$this->post);
  897. $ark=$info['status'];
  898. $info['status']=6;
  899. $info['updatetime']=date("Y-m-d H:i:s");
  900. $sa=Db::name("purchease_in")->save($info);
  901. if($sa){
  902. $stn = ["order_code"=>$info['wsm_in_code'],"status"=>$ark,"action_remark"=>'',"action_type"=>"edit"];
  903. ActionLog::logAdd($this->post['token'],$stn,"RKD",6,$info);
  904. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>6,"order_type"=>'RKD',"before_status"=>$stn['status']];
  905. ProcessOrder::AddProcess($this->post['token'],$process);
  906. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  907. if(empty($good)) {
  908. $good=[
  909. "spuCode"=>$cgdinfo['spuCode'],
  910. "wsm_code"=>$info['wsm_code'],
  911. "usable_stock"=>0,
  912. "wait_out_stock"=>0,
  913. "wait_in_stock"=>$return['wsm_num'],
  914. "total_stock"=>0,
  915. "addtime"=>date("Y-m-d H:i:s"),
  916. "updatetime"=>date("Y-m-d H:i:s"),
  917. ];
  918. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  919. "action_type"=>"create"];
  920. }else{
  921. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  922. }
  923. $good['usable_stock']+=$return['wsm_num'];
  924. $good['wait_in_stock']-=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  925. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  926. $good['updatetime'] = date("Y-m-d H:i:s");
  927. $upd= Db::name("good_stock")->save($good);
  928. if($upd==false){
  929. Db::rollback();
  930. return error_show(1002,"库存更新失败");
  931. }
  932. $good_data[]=['good_log_code' => $incode,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1, 'stock'=>$info['wsm_num'],"stock_name"=>"usable_stock"];
  933. $good_data[]=['good_log_code' => $incode,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>2, 'stock'=>$good['wait_in_stock'],"stock_name"=>"wait_in_stock"];
  934. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  935. $order = ["order_code"=>$cgdinfo['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  936. $cgdinfo['wsend_num']-=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  937. $cgdinfo['send_num']+=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  938. $cgdinfo['th_num']+=$return['return_num']-$return['reissue_num'];
  939. $cgdinfo['th_fee']=round(($return['return_num']-$return['reissue_num'])*$cgdinfo['good_price'],2);
  940. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  941. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  942. if($cgdinfo['th_num']==$cgdinfo['send_num']&& $cgdinfo['wsend_num']==0){
  943. $cgdinfo['status']=4;
  944. }
  945. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  946. $up=Db::name("purchease_order")->save($cgdinfo);
  947. if($up==false){
  948. Db::rollback();
  949. return error_show(1004,"采购单数量更新失败");
  950. }
  951. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  952. if($bk==false){
  953. $bk=[
  954. "cgdNo"=>$cgdinfo['cgdNo'],
  955. "spuCode"=>$cgdinfo['spuCode'],
  956. "companyNo"=>$cgdinfo['companyNo'],
  957. "total_num"=>0,
  958. "merge_num"=>0,
  959. "balance_num"=>0,
  960. "status"=>1,
  961. "is_del"=>0,
  962. 'addtime'=>date("Y-m-d H:i:s"),
  963. "updatetime"=>date("Y-m-d H:i:s")
  964. ];
  965. }
  966. $bk['balance_num']+=$return['wsm_num'];
  967. $bk['total_num']+=$return['wsm_num'];
  968. $bk['updatetime']=date("Y-m-d H:i:s");
  969. $upcgd =Db::name("order_bk")->save($bk);
  970. if($upcgd==false){
  971. Db::rollback();
  972. return error_show(1004,"采购单数量更新失败");
  973. }
  974. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  975. $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  976. ProcessOrder::AddProcess($this->post['token'],$process);
  977. Db::commit();
  978. return app_show(0,"退货发货成功");
  979. }else{
  980. Db::rollback();
  981. return error_show(1004,"退货发货失败");
  982. }
  983. }else{
  984. return error_show(1004,"退货发货失败");
  985. }
  986. }catch (\Exception $e){
  987. Db::rollback();
  988. return error_show(1004,$e->getMessage());
  989. }
  990. }
  991. public function returnList(){
  992. $page = isset($this->post['page']) && $this->post['page'] !=="" ? intval($this->post['page']):"1";
  993. $size = isset($this->post['size']) && $this->post['size'] !=="" ? intval($this->post['size']):"10";
  994. $where = [['a.is_del',"=",0],['b.is_del',"=",0]];
  995. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!="" ? trim($this->post['cgdNo']):"";
  996. if($cgdNo!=""){
  997. $where[]=['a.cgdNo',"like", "%$cgdNo%"];
  998. }
  999. $returnCode= isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
  1000. if($returnCode!=""){
  1001. $where[]=['a.returnCode',"like", "%$returnCode%"];
  1002. }
  1003. $good_type_code=isset($this->post['good_type_code']) && $this->post['good_type_code']!==""? trim($this->post['good_type_code']):"";
  1004. if($good_type_code !=""){
  1005. $where[]= ["b.spuCode",'like',"%$good_type_code%"];
  1006. }
  1007. $good_name=isset($this->post['good_name']) && $this->post['good_name']!==""? trim($this->post['good_name']):"";
  1008. if($good_name !=""){
  1009. $where[]= ["b.good_name",'like',"%$good_name%"];
  1010. }
  1011. $status=isset($this->post['status']) && $this->post['status']!==""? trim($this->post['status']):"";
  1012. if($status!=""){
  1013. $where[]= ["a.status",'=',$status];
  1014. }
  1015. $count = Db::name('purchease_return')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  1016. ->where($where)->count();
  1017. $total = ceil($count / $size);
  1018. $page = $page >= $total ? $total : $page;
  1019. $list = Db::name('purchease_return')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  1020. ->where($where)->page($page,$size)
  1021. ->field("a.*,b.spuCode,b.good_price,b.order_type,b.good_price,b.total_fee,b.good_name")->order("a.addtime desc")
  1022. ->select();
  1023. $data=[];
  1024. foreach ($list as $value){
  1025. if($value['order_type']==3|| $value['order_type']==4){
  1026. $goon = Db::name("good_zixun")->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->find();
  1027. }else {
  1028. $goon =Db::name('good_basic')->where(['spuCode'=>$value['spuCode']])->find();
  1029. }
  1030. $value['can']= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  1031. $value['return_fee']= round($value['good_price']*$value['return_num'],2);
  1032. $data[]=$value;
  1033. }
  1034. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  1035. }
  1036. // public function ReturnStatus(){
  1037. // $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  1038. // if($incode==""){
  1039. // return error_show(1004,"参数wsm_in_code 不为空");
  1040. // }
  1041. // $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1042. // if(empty($info)){
  1043. // return error_show(1004,"未找到发货单数据");
  1044. // }
  1045. // $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1046. // if(empty($return)){
  1047. // return error_show(1004,"未找到数据");
  1048. // }
  1049. // if($info['status']<4){
  1050. // return error_show(1004,"入库单未完成");
  1051. // }
  1052. // $status = isset($this->post['status'])&&$this->post['status']!="" ?$this->post['status']:"";
  1053. // if($status==""){
  1054. // return error_show(1004,"参数status 不为空");
  1055. // }
  1056. // Db::startTrans();
  1057. // try{
  1058. // $data=[
  1059. // "status"=>$status,
  1060. // "updatetime"=>date("Y-m-d H:i:s")
  1061. // ];
  1062. // $up =Db::name("purchease_return")->where($return)->save($data);
  1063. // if($up){
  1064. // $info['status']=$status==1?5:6;
  1065. // $info['updatetime']=date("Y-m-d H:i:s");
  1066. // $sa=Db::name("purchease_in")->save($info);
  1067. // if($sa){
  1068. // Db::commit();
  1069. // return app_show(0,"更新成功");
  1070. // }else{
  1071. // Db::rollback();
  1072. // return error_show(1004,"更新失败");
  1073. // }
  1074. // }else{
  1075. // Db::rollback();
  1076. // return error_show(1004,"更新失败");
  1077. // }
  1078. // }catch (\Exception $e){
  1079. // Db::rollback();
  1080. // return error_show(1004,$e->getMessage());
  1081. // }
  1082. //
  1083. // }
  1084. }