Purchin.php 54 KB

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