Purchin.php 84 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428
  1. <?php
  2. namespace app\admin\controller;
  3. use app\abutment\model\SupplierRelationUser as SupplierRelationUserModel;
  4. use app\abutment\model\SupplierUser as SupplierUserModel;
  5. use app\admin\model\ActionLog;
  6. use app\admin\model\DataGroup as DataGroupModel;
  7. use app\admin\model\GoodLog;
  8. use app\admin\model\GoodStockInfo;use app\admin\model\ProcessOrder;
  9. use app\BaseController;
  10. use think\Exception;
  11. use think\facade\Db;
  12. use think\App;
  13. //采购单入库
  14. class Purchin extends Base
  15. {
  16. public function __construct(App $app)
  17. {
  18. parent::__construct($app);
  19. // $this->post=$this->request->post();
  20. }
  21. public function list(){
  22. $page = isset($this->post['page']) && $this->post['page'] !==""? intval($this->post['page']):"1";
  23. $size = isset($this->post['size']) && $this->post['size'] !==""? intval($this->post['size']):"10";
  24. $where =[['a.is_del',"=",0],['b.is_del',"=",0]];
  25. $wsm_in_code=isset($this->post['wsm_in_code']) && $this->post['wsm_in_code']!==""? trim($this->post['wsm_in_code']) :"";
  26. if($wsm_in_code!==""){
  27. $where[]=["a.wsm_in_code",'like',"%$wsm_in_code%"];
  28. }
  29. $cgdNo= isset($this->post['cgdNo']) && $this->post['cgdNo'] !==""? trim($this->post['cgdNo']) :"";
  30. if($cgdNo!==""){
  31. $where[]=['a.cgdNo','like',"%$cgdNo%"];
  32. }
  33. $apply_name = isset($this->post['apply_name']) && $this->post['apply_name'] !==""? trim($this->post['apply_name']):"";
  34. if($apply_name!==""){
  35. $where[]=['a.apply_name','like',"%$apply_name%"];
  36. }
  37. $apply_id= isset($this->post['apply_id']) && $this->post['apply_id'] !==""? trim($this->post['apply_id']):"";
  38. if($apply_id!==""){
  39. $where[]=['a.apply_id','=',$apply_id];
  40. }
  41. $status= isset($this->post['status']) && $this->post['status'] !==""? trim($this->post['status']):"";
  42. if($status!==""){
  43. $where[]=['a.status','=',$status];
  44. }
  45. $start= isset($this->post['start']) && $this->post['start'] !== "" ? $this->post['start']:"";
  46. if ($start !=="") {
  47. $where[]= ["a.sendtime",'>=',$start];
  48. }
  49. $end = isset($this->post['end']) && $this->post['end'] !== "" ? $this->post['end'] :"";
  50. if($end !==""){
  51. $where[]= ["a.sendtime",'<=',$end];
  52. }
  53. $order_type=isset($this->post['order_type']) && $this->post['order_type']!==""? intval($this->post['order_type']):"";
  54. if($order_type !==""){
  55. $where[]= ["b.order_type",'=',$order_type];
  56. }
  57. $order_source=isset($this->post['order_source']) && $this->post['order_source']!==""? intval($this->post['order_source']):"";
  58. if($order_source !=="") $where[]= ["b.order_source",'=',$order_source];
  59. $good_type_code=isset($this->post['good_type_code']) && $this->post['good_type_code']!==""? trim($this->post['good_type_code']):"";
  60. if($good_type_code !==""){
  61. $where[]= ["b.spuCode",'like',"%$good_type_code%"];
  62. }
  63. $good_name=isset($this->post['good_name']) && $this->post['good_name']!==""? trim($this->post['good_name']):"";
  64. if($good_name !==""){
  65. $where[]= ["b.good_name",'like',"%$good_name%"];
  66. }
  67. $supplie=isset($this->post['supplier']) && $this->post['supplier']!==""? trim($this->post['supplier']):"";
  68. if($supplie !==""){
  69. $where[]= ["b.supplierNo",'like',"%$supplie%"];
  70. }
  71. $wsm_code=isset($this->post['wsm_code']) && $this->post['wsm_code']!==""? trim($this->post['wsm_code']):"";
  72. if($wsm_code !==""){
  73. $where[]= ["a.wsm_code",'=',$wsm_code];
  74. }
  75. $supplierNo =isset($this->post['supplierNo']) &&$this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']):"";
  76. if($supplierNo!==""){
  77. // $supplier = Db::name("supplier")->where(["code"=>$supplierNo])->find();
  78. // if(empty($supplier)){
  79. // return error_show(1004,"未找到供应商信息");
  80. // }
  81. //不再根据供应商筛选仓库,要筛选仓库只能是业务公司
  82. // $wsmcode = Db::name("warehouse_info")
  83. // ->where(["is_del"=>0,"supplierNo"=>$supplierNo])
  84. // ->column("wsm_code");
  85. // $where[]=['a.wsm_code',"in",$wsmcode];
  86. $where[]= ["b.supplierNo",'=',$supplie];
  87. }
  88. $condition=[];
  89. $role = $this->checkDataShare();
  90. $hand = resign_hand_user($this->uid,0);
  91. if (!empty($role[DataGroupModel::$type_全部])) {
  92. $arr= array_unique(array_merge($hand,$role[DataGroupModel::$type_全部]));
  93. $condition[]= ["sip.personid","in",$arr];
  94. $condition[]= ["a.apply_id","in",$hand];
  95. $condition[]= ["c.contactor","in",$hand];
  96. // $condition.="sip.personid in (".implode(",",
  97. // $role[DataGroupModel::$type_全部]).") or a.apply_id in {$hand} or c.contactor in {$hand}";
  98. }
  99. $company_name = isset($this->post['company_name']) && $this->post['company_name'] !== "" ? trim($this->post['company_name']) : "";
  100. if ($company_name !== "") $where[] = ["a.apply_id", 'in', get_company_item_user_by_name($company_name)];
  101. $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo']!="" ? trim($this->post['relaComNo']):"";
  102. if($relaComNo!=='') $where[]=['b.companyNo','=', $relaComNo];
  103. //$count = Db::name('purchease_in')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  104. $count = Db::name('purchease_in')
  105. ->alias('a')
  106. ->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  107. ->leftJoin("warehouse_info c","a.wsm_code=c.wsm_code")
  108. ->leftJoin('supplier sip', 'sip.code=b.supplierNo')
  109. ->where($where)
  110. // ->whereOr($condition)
  111. ->where(function ($query)use ($condition){$query->whereOr($condition);})
  112. ->count();
  113. $total = ceil($count/$size);
  114. $page = $page >= $total ? $total : $page;
  115. $list = Db::name('purchease_in')
  116. ->alias('a')
  117. ->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  118. ->leftJoin('supplier sip', 'sip.code=b.supplierNo')
  119. ->leftJoin("warehouse_info c","a.wsm_code=c.wsm_code")
  120. ->where($where)
  121. ->where(function ($query)use ($condition){$query->whereOr($condition);})
  122. ->page($page,$size)
  123. ->field("a.apply_name,a.sendtime,b.order_type,b.order_source,a.status,a.cgdNo,a.wsm_in_code,a.send_num,a.wsm_code,b.good_name,b.spuCode,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,sip.personid as cgder_id,sip.person as cgder,b.good_createrid,b.good_creater")
  124. ->order("a.addtime desc")
  125. ->select()
  126. ->toArray();
  127. $all_createrid = array_column($list,'apply_id');
  128. $item = get_company_name_by_uid($all_createrid);
  129. $data=[];
  130. foreach ($list as $value){
  131. //获取规格、品牌信息
  132. if ($value['order_type'] == 3) {
  133. $temp = Db::name('good_zixun')
  134. ->alias('gz')
  135. ->field('gz.specinfo,b.brand_name')
  136. ->join('brand b', 'b.id=gz.brand_id')
  137. ->where(['gz.spuCode' => $value['spuCode'], 'gz.is_del' => 0])
  138. ->find();
  139. $value["brand_name"] = $temp['brand_name'];
  140. $value["speclist"] = json_decode($temp['specinfo'], true);
  141. } else {
  142. $value['brand_name'] = Db::name('good_basic')
  143. ->alias('gb')
  144. ->join('brand b', 'b.id=gb.brand_id')
  145. ->where(['gb.spuCode' => $value['spuCode']])
  146. ->value('b.brand_name');
  147. $spec = Db::name("good_spec")
  148. ->where(["spuCode" => $value['spuCode'], "is_del" => 0])
  149. ->select()
  150. ->toArray();
  151. $speclist = [];
  152. if (!empty($spec)) {
  153. foreach ($spec as $val) {
  154. $temp = [];
  155. $temp['id'] = $val['id'];
  156. $temp['spuCode'] = $val['spuCode'];
  157. $temp['spec_id'] = $val['spec_id'];
  158. $temp['spec_value_id'] = $val['spec_value_id'];
  159. $sp = Db::name("specs")->where(["id" => $val['spec_id']])->find();
  160. $temp['spec_name'] = isset($sp["spec_name"]) ? $sp["spec_name"] : "";
  161. $spv = Db::name("spec_value")->where(["id" => $val['spec_value_id']])->find();
  162. $temp['spec_value'] = isset($spv["spec_value"]) ? $spv["spec_value"] : "";
  163. $speclist[] = $temp;
  164. }
  165. }
  166. $value["speclist"] = empty($speclist) ? [] : $speclist;
  167. }
  168. $wsmcode = Db::name("warehouse_info")->alias("k")->leftJoin("supplier c","k.supplierNo=c.code")->where(["k.wsm_code"=>$value['wsm_code']])->field("k.name as wsm_name,c.name,c.code")->find();
  169. $value['wsm_name'] = $wsmcode['wsm_name'];
  170. $value['wsm_supplier'] = $wsmcode['name'];
  171. $value['wsm_supplierNo'] = $wsmcode['code'];
  172. $value['company_name'] = $item[$value['apply_id']]??'';
  173. //是否具有编辑权限
  174. $value['is_allow_update'] = 0;
  175. if (in_array($this->roleid, [1, 33]) || in_array($value['apply_id'], $role[DataGroupModel::$type_可编辑])) $value['is_allow_update'] = 1;
  176. $data[]=$value;
  177. }
  178. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  179. }
  180. public function add(){
  181. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!=""? trim($this->post['cgdNo']):"";
  182. if($cgdNo==""){
  183. return error_show(1005,"参数cgdNo 不能为空");
  184. }
  185. $cgdinfo = Db::name("purchease_order")->where(['cgdNo'=>$cgdNo,'is_del'=>0])->find();
  186. if(empty($cgdinfo)){
  187. return error_show(1005,"未找到采购单数据");
  188. }
  189. if($cgdinfo['status']==0){
  190. return error_show(1005,"采购单未确认");
  191. }
  192. $isreturn = cgd_sale_return($cgdNo);
  193. if($isreturn){
  194. return error_show(1005, "关联销售单存在退货单正在进行");
  195. }
  196. $wsm_in_code = makeNo("CF");
  197. $bn_code = makeNo("BN");
  198. $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  199. if(empty($wsminfo)){
  200. return error_show(1004,"未找到仓库信息");
  201. }
  202. $recep = Db::name('warehouse_addr')->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  203. $sendtype = isset($this->post['sendtype'])&&$this->post['sendtype']!="" ? intval($this->post['sendtype']):"";
  204. if($sendtype==""){
  205. return error_show(1004,"参数 sendtype 不能为空");
  206. }
  207. // $data = GetUserInfo($this->post['token']);
  208. // if((!empty($data) && $data['code']!=0) ||empty($data) ){
  209. // return error_show($data['code'],$data['message']);
  210. // }
  211. // $userinfo = $data['data'];
  212. $post_company = isset($this->post['post_company'])&&$this->post['post_company']!="" ? trim($this->post['post_company']):"";
  213. $post_code = isset($this->post['post_code'])&&$this->post['post_code']!="" ? trim($this->post['post_code']):"";
  214. $post_fee = isset($this->post['post_fee'])&&$this->post['post_fee']!="" ? $this->post['post_fee']:"0";
  215. $post_time = isset($this->post['post_time'])&&$this->post['post_time']!="" ? $this->post['post_time']:date("Y-m-d H:i:s");
  216. $send_num = isset($this->post['send_num'])&&$this->post['send_num']!="" ? intval($this->post['send_num']):"";
  217. $status = isset($this->post['status'])&&$this->post['status']!="" ? intval($this->post['status']):"1 ";
  218. if($send_num==''){
  219. return error_show(1004,"参数 send_num 不能为空或零");
  220. }
  221. $wsmin_num=Db::name("purchease_in")->where([["cgdNo","=",$cgdNo],["is_del","=",0],["status","not in",[4,6]]])
  222. ->sum("send_num");
  223. if($send_num>$cgdinfo['wsend_num']-$wsmin_num){
  224. return error_show(1009,"采购单剩余未发货数量不足");
  225. }
  226. if($sendtype==2 || $cgdinfo['order_type']!=1){
  227. $status=4;
  228. }
  229. $orin = [
  230. "wsm_in_code"=>$wsm_in_code,
  231. "cgdNo"=>$cgdNo,
  232. "bnCode"=>$bn_code,
  233. "wsm_code"=>$cgdinfo['wsm_code'],
  234. "wsm_reaper"=>isset($recep)&& $recep['wsm_name']!=''? $recep['wsm_name']:"",
  235. "send_num"=>$send_num,
  236. "post_company"=>$post_company,
  237. "post_code"=>$post_code,
  238. "post_fee"=>$post_fee,
  239. "sendtime"=>$post_time,
  240. "apply_id"=>$this->uid,
  241. "apply_name"=>$this->uname,
  242. "wait_num"=>0,
  243. "wsm_num"=>0,
  244. "sendtype"=>$sendtype,
  245. "status"=>$status,
  246. "addtime"=>date("Y-m-d H:i:s"),
  247. "updatetime"=>date("Y-m-d H:i:s")
  248. ];
  249. Db::startTrans();
  250. try{
  251. $win = Db::name("purchease_in")->insert($orin,true);
  252. if($win){
  253. $sto = ["order_code"=>$wsm_in_code,"status"=>$status,"action_remark"=>'',"action_type"=>"edit"];
  254. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$sto,"RKD",$status,$this->post);
  255. if($status==1){
  256. $uid = Db::name('user_role')
  257. ->where([
  258. ['is_del', '=', 0],
  259. ['roleid', 'in', [31, 41]],
  260. ['status', '=', 1]
  261. ])->column('uid');
  262. $handle_user_list = implode(',', $uid);
  263. }
  264. $process=["order_code"=>$wsm_in_code,"order_id"=>$win,"order_status"=>$status,"order_type"=>'RKD',"before_status"=>$status,'holder_id' => $orin['apply_id'],"handle_user_list"=>$handle_user_list??""];
  265. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  266. $order = ["order_code"=>$cgdNo,"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  267. //维护台账信息
  268. Db::execute("UPDATE `wsm_standing_book` SET `wsm_in_code`=CONCAT(IFNULL(`wsm_in_code`,''),',{$wsm_in_code}'),`updatetime`='" . date('Y-m-d H:i:s') . "' WHERE `cgdNo`='{$cgdNo}'");
  269. $is_stock = Db::name('good_basic')
  270. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  271. ->value('is_stock');
  272. // if($is_stock == 1){
  273. // //库存品,只能由库管操作
  274. // $own_roleid = Db::name('user_role')->where(['is_del' => 0, 'status' => 1, 'uid' => $this->uid])->value('roleid');
  275. // if (!in_array($own_roleid, config('app.wsm_cgder_role'))) throw new Exception('只能由库管人员操作');
  276. // }else{
  277. //非库存品,只能由供应商负责人操作(开通账号的不能操作)
  278. //判断该供应商是否开通账号
  279. //好像status==4里面的判断没用了,但是没时间修改
  280. if($is_stock==0){
  281. //全都只能由供应商负责人操作(开通账号的不能操作)
  282. $res = SupplierRelationUserModel::field('id')
  283. ->where(['is_del' => SupplierUserModel::$is_del_normal, 'supplierNo' => $cgdinfo['supplierNo'], 'status' => SupplierUserModel::$status_normal])
  284. ->findOrEmpty()
  285. ->isEmpty();
  286. if (!$res) throw new Exception('供应商已开通账号,只能由供应商端操作');
  287. }
  288. $personid = Db::name('supplier')
  289. ->where('code', $cgdinfo['supplierNo'])
  290. ->value('personid');
  291. if ($this->uid != $personid) throw new Exception('只能由供应商负责人操作');
  292. // }
  293. if($status==1){
  294. Db::commit();
  295. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  296. }
  297. if($status==4){
  298. $cgdinfo['wsend_num']-=$send_num;
  299. $cgdinfo['send_num']+=$send_num;
  300. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  301. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  302. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  303. $up=Db::name("purchease_order")->save($cgdinfo);
  304. if($up==false){
  305. Db::rollback();
  306. return error_show(1004,"新建失败");
  307. }
  308. $good = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'],"spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->lock(true)->find();
  309. if(empty($good)) {
  310. $good=[
  311. "spuCode"=>$cgdinfo['spuCode'],
  312. "wsm_code"=>$cgdinfo['wsm_code'],
  313. "usable_stock"=>0,
  314. "wait_out_stock"=>0,
  315. "wait_in_stock"=>$send_num,
  316. "total_stock"=>0,
  317. "addtime"=>date("Y-m-d H:i:s"),
  318. "updatetime"=>date("Y-m-d H:i:s"),
  319. ];
  320. }
  321. $good['wait_in_stock']-=$send_num;
  322. $good['usable_stock']+=$send_num;
  323. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  324. $good['updatetime'] = date("Y-m-d H:i:s");
  325. $upd= Db::name("good_stock")->save($good);
  326. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  327. //商品变动日志表,good_log_code字段存储采购单单号
  328. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  329. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>2,'stock'=>$send_num,"stock_name"=>"wait_in_stock"];
  330. if($upd){
  331. GoodLog::LogAdd(['id'=>$this->uid,'nickname'=>$this->uname],$good_data,'RKD');
  332. //todo:: 新增bn编号库存数据修改
  333. if($cgdinfo['order_type']==1){
  334. $bnin=GoodStockInfo::AddBn($stockid,$bn_code,$send_num,$cgdinfo['good_price']);
  335. if($bnin==false){
  336. Db::rollback();
  337. return error_show(1004,"库存bn数据新增失败");
  338. }
  339. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->find();
  340. if($bk==false){
  341. $bk=[
  342. "cgdNo"=>$cgdinfo['cgdNo'],
  343. "spuCode"=>$cgdinfo['spuCode'],
  344. "companyNo"=>$cgdinfo['companyNo'],
  345. "total_num"=>$send_num,
  346. "merge_num"=>0,
  347. "balance_num"=>$send_num,
  348. "status"=>1,
  349. "is_del"=>0,
  350. 'addtime'=>date("Y-m-d H:i:s"),
  351. "updatetime"=>date("Y-m-d H:i:s")
  352. ];
  353. $upcgd =Db::name("order_bk")->save($bk);
  354. }else{
  355. $where=['id'=>$bk['id'],'total_num'=>$bk['total_num'],'balance_num'=>$bk['balance_num']];
  356. $bk['balance_num']+=$send_num;
  357. $bk['total_num']+=$send_num;
  358. $bk['updatetime']=date("Y-m-d H:i:s");
  359. $upcgd =Db::name("order_bk")->where($where)->update($bk);
  360. }
  361. if($upcgd==false){
  362. Db::rollback();
  363. return error_show(1004,"采购单数量更新失败");
  364. }
  365. }
  366. if($cgdinfo['send_status']==3 && $cgdinfo['order_type']!=1){
  367. $send=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"status"=>1])->column("outCode");
  368. if(!empty($send)){
  369. $out =Db::name("order_out")->where(["outCode"=>$send,"status"=>0,"is_del"=>0])->select()
  370. ->toArray();
  371. if(!empty($out)){
  372. $up =Db::name("order_out")->where(["outCode"=>$send,"status"=>0,"is_del"=>0])->update(["status"=>1,'wsm_code'=>$cgdinfo['wsm_code'],"updatetime"=>date('Y-m-d H:i:s')]);
  373. if($up==false){
  374. Db::rollback();
  375. return error_show(1004,"出库单出库失败");
  376. }else{
  377. //查询是否有非库存品订单
  378. // $is_stock = Db::name('sale')
  379. // ->where([
  380. // ['is_del','=',0],
  381. // ['orderCode','in',array_column($out,'orderCode')]
  382. // ])->column('is_stock','orderCode');
  383. $supplier = Db::name('supplier')
  384. ->field('person,personid')
  385. ->where(['code'=>$cgdinfo['supplierNo'],'is_del'=>0])
  386. ->findOrEmpty();
  387. foreach ($out as $k => $v_outCode) {
  388. ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], [
  389. "order_code" => $v_outCode['outCode'],//出库单号
  390. "status" => 0,//这里的status是之前的值
  391. "action_remark" => '',//备注
  392. "action_type" => "status"//新建create,编辑edit,更改状态status
  393. ], "CKD", 1, $this->post);
  394. if ($is_stock == 1) {
  395. //库存品,推给库管和库管-张凯旋
  396. $roleid = config('app.wsm_cgder_role');
  397. $uids = Db::name('user_role')
  398. ->where('is_del', 0)
  399. ->whereIn('roleid', $roleid)
  400. ->column('uid');
  401. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
  402. "order_type" => 'CKD',
  403. "order_code" => $v_outCode['outCode'],//出库单号
  404. "order_id" => $v_outCode['id'],
  405. "order_status" => 1,
  406. "before_status" => 0,
  407. // 'wait_id' => $supplier['personid'],
  408. // 'wait_name' => $supplier['person'],
  409. // 'holder_id' => $supplier['personid'],
  410. 'handle_user_list' => implode(',', $uids)
  411. ]);
  412. } else {
  413. //非库存品和采返商品,推给供应商负责人
  414. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
  415. "order_type" => 'CKD',
  416. "order_code" => $v_outCode['outCode'],//出库单号
  417. "order_id" => $v_outCode['id'],
  418. "order_status" => 1,
  419. "before_status" => 0,
  420. 'wait_id' => $supplier['personid'],
  421. 'wait_name' => $supplier['person'],
  422. 'holder_id' => $supplier['personid'],
  423. ]);
  424. }
  425. }
  426. }
  427. $good1 = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  428. if($good1==false){
  429. Db::rollback();
  430. return error_show(1004,"未找到对应商品库存");
  431. }
  432. $out_num = intval(array_sum(array_column($out,"send_num")));
  433. if($out_num>$good1['usable_stock']){
  434. Db::rollback();
  435. return error_show(1004,"库存数量不足发货");
  436. }
  437. $good1['usable_stock']-=$out_num;
  438. $good1['wait_out_stock']+=$out_num;
  439. $good1['total_stock']=$good1['usable_stock']+$good1['wait_out_stock'];
  440. $good1['updatetime'] = date("Y-m-d H:i:s");
  441. $upd= Db::name("good_stock")->save($good1);
  442. if($upd==false){
  443. Db::rollback();
  444. return error_show(1004,"库存数量更新失败");
  445. }
  446. $stockid= isset($good['id'])?$good['id']:Db::name("good_stock")->getLastInsID();
  447. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"wait_out_stock"];
  448. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  449. GoodLog::LogAdd(['id'=>$this->uid,'nickname'=>$this->uname],$good_data,'RKD');
  450. $sendp=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"outCode"=>$send,"status"=>1])->save (["status"=>2]);
  451. if($sendp==false){
  452. Db::rollback();
  453. return error_show(1004,"库存发货失败");
  454. }
  455. }
  456. }
  457. }
  458. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  459. $personid = Db::name('supplier')
  460. ->where('is_del',0)
  461. ->where('code',$cgdinfo['supplierNo'])
  462. ->value('personid');
  463. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  464. // $is_stock = Db::name('good_basic')
  465. // ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  466. // ->value('is_stock');
  467. // if($is_stock==1){
  468. // //库存品,推给31库管人员、41库管-张凯旋
  469. // $uid = Db::name('user_role')
  470. // ->where([
  471. // ['is_del', '=', 0],
  472. // ['roleid', 'in', [31, 41]],
  473. // ['status', '=', 1]
  474. // ])->column('uid');
  475. // if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  476. //// $process = ["order_code" => $cgdNo, "order_id" => $cgdinfo['id'], "order_status" => $cgdinfo['status'], "order_type" => 'CGD', "before_status" => $order['status'], 'holder_id' => $personid,'handle_user_list'=>implode(',', $uid)];
  477. //
  478. // }else{
  479. if($this->uid != $personid)throw new Exception('只能由供应商负责人操作');
  480. // }
  481. }//else $process = ["order_code" => $cgdNo, "order_id" => $cgdinfo['id'], "order_status" => $cgdinfo['status'], "order_type" => 'CGD', "before_status" => $order['status'], 'holder_id' => $personid];
  482. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],["order_code" => $cgdNo, "order_id" => $cgdinfo['id'], "order_status" => $cgdinfo['status'], "order_type" => 'CGD', "before_status" => $order['status'], 'holder_id' => $personid]);
  483. Db::commit();
  484. return app_show(0,'商品入库成功',["wsm_in_code"=>$wsm_in_code]);
  485. }else{
  486. Db::rollback();
  487. return error_show(1002,"商品入库失败");
  488. }
  489. }
  490. Db::commit();
  491. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  492. }
  493. Db::rollback();
  494. return error_show(1004,"新建失败");
  495. }catch (\Exception $e){
  496. Db::rollback();
  497. return error_show(1004, $e->getMessage());
  498. }
  499. }
  500. public function info(){
  501. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  502. if($incode==""){
  503. return error_show(1004,"参数wsm_in_code 不为空");
  504. }
  505. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  506. if(empty($info)){
  507. return error_show(1004,"未找到数据");
  508. }
  509. $dom = Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],'is_del'=>0])->find();
  510. if($dom['order_type']==3){
  511. $goon = Db::name("good_zixun")->where(["spuCode"=>$dom['spuCode'],"is_del"=>0])->find();
  512. }else {
  513. $goon =Db::name('good_basic')->where(['spuCode'=>$dom['spuCode']])->find();
  514. }
  515. if(empty($goon)){
  516. return error_show(1002,"未找到商品数据");
  517. }
  518. $cat= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  519. $info['cgder']=Db::name("supplier")->where(["code"=>$dom['supplierNo']])->value("person",'');
  520. $info['spuCode']=$dom['spuCode'];
  521. $info['good_name']=$dom['good_name'];
  522. $info['skuCode']=$dom['skuCode'];
  523. $info['good_num']=$dom['good_num'];
  524. $info['good_price']=$dom['good_price'];
  525. $info['total_fee']=$dom['total_fee'];
  526. $info['diff_fee']=$dom['diff_fee'];
  527. $info['diff_weight']=$dom['diff_weight'];
  528. $info['gold_price']=$dom['gold_price'];
  529. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
  530. ->leftJoin("warehouse_addr c","a.wsm_code=c.wsm_code and c.is_del=0")
  531. ->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();
  532. $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  533. $info['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  534. $info['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  535. $info['wsm_contactor'] =isset($wsmcode['wsm_contactor']) ? $wsmcode['wsm_contactor']:"";
  536. $info['wsm_mobile'] =isset($wsmcode['wsm_mobile']) ? $wsmcode['wsm_mobile']:"";
  537. $info['addr_code'] =isset($wsmcode['addr_code']) ? $wsmcode['addr_code']:"";
  538. $info['wsm_addr'] =isset($wsmcode['addr_code']) ? GetAddr($wsmcode['addr_code']):"";
  539. $info['wsm_addr'].=isset($wsmcode['wsm_addr']) ? $wsmcode['wsm_addr']:"";
  540. $check = Db::name("purchease_info")->alias("a")->leftJoin("result_info b","a.error_code=b.result_code")->where
  541. (['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();
  542. $info['checkinfo']= $check;
  543. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  544. $return['return_contactor']=isset($return['return_contactor'])&&$return['return_contactor']!="" ?$return['return_contactor']:'';
  545. $return['return_addr']=isset($return['return_addr'])&&$return['return_addr']!="" ?$return['return_addr']:'';
  546. $return['return_mobile']=isset($return['return_mobile'])&&$return['return_mobile']!="" ?$return['return_mobile']:'';
  547. //以下字段临时补充到return中
  548. $return['wsm_in_code'] = $incode;
  549. $return['wsm_num'] = isset($return['wsm_num']) ? $return['wsm_num'] : 0;
  550. $return['reissue_num'] = isset($return['reissue_num']) ? $return['reissue_num'] : 0;
  551. $return['return_num'] = isset($return['return_num']) ? $return['return_num'] : 0;
  552. $return['contactor'] = $return['return_contactor'];
  553. $return['addr'] = $return['return_addr'];
  554. $return['mobile'] = $return['return_mobile'];
  555. $return['error_remark'] = isset($return['error_remark']) ? $return['error_remark'] : '';
  556. $return['remark'] = isset($return['remark']) ? $return['remark'] : '';
  557. $info['return']= $return;
  558. $info['can']=$cat;
  559. if(isset($dom['companyNo'])&&$dom['companyNo']!=""){
  560. $company = Db::name("business")->where(["companyNo"=>$dom['companyNo']])->find();
  561. }
  562. $info['company'] = isset($company['company'])?$company['company']:"";
  563. $info['companyNo'] = isset($dom['companyNo'])?$dom['companyNo']:"";
  564. $info['order_type'] = isset($dom['order_type'])?$dom['order_type']:"";
  565. return app_show(0,'获取成功',$info);
  566. }
  567. public function check(){
  568. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  569. if($incode==""){
  570. return error_show(1004,"参数wsm_in_code 不为空");
  571. }
  572. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  573. if(empty($info)){
  574. return error_show(1004,"未找到数据");
  575. }
  576. if($info['status']!=1){
  577. return error_show(1004,"发货单状态有误");
  578. }
  579. $order_num = isset($this->post['order_num']) && $this->post['order_num']!==''?intval($this->post['order_num'])
  580. :"";
  581. if($order_num===""){
  582. return error_show(1004,"参数 order_num 不为空");
  583. }
  584. $error_list = isset($this->post['error_list']) && $this->post['error_list']!==''?$this->post['error_list']:"";
  585. $result = GetUserInfo($this->post['token']);
  586. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  587. return error_show($result['code'],$result['message']);
  588. }
  589. $userinfo = $result['data'];
  590. Db::startTrans();
  591. try{
  592. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  593. $info['wsm_num'] = $order_num;
  594. $info['wait_num'] = $info['send_num'];
  595. $info['checkid'] = $userinfo['id'];
  596. $info['check_name'] = $userinfo['nickname'];
  597. $info['status'] =2;
  598. $info['error_num'] = $info['send_num']-$order_num;
  599. $info['updatetime'] = date("Y-m-d H:i:s");
  600. $up =Db::name("purchease_in")->save($info);
  601. if($up){
  602. ActionLog::logAdd($this->post['token'],$order,"RKD",2,$this->post);
  603. $uid = Db::name('user_role')
  604. ->where([
  605. ['is_del', '=', 0],
  606. ['roleid', 'in', [31, 41]],
  607. ['status', '=', 1]
  608. ])->column('uid');
  609. $handle_user_list = implode(',', $uid);
  610. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD',"before_status"=>$order['status'],'holder_id' => $info['apply_id'],"handle_user_list"=>$handle_user_list];
  611. ProcessOrder::AddProcess($this->post['token'],$process);
  612. if(!empty($error_list)){
  613. $data=[];
  614. foreach ($error_list as $value ){
  615. $temp=[];
  616. $temp['wsm_in_code']=$info['wsm_in_code'];
  617. $temp['num']=$value['num'];
  618. $temp['error_code']=$value['error_code'];
  619. $temp['error_img']=$value['error_img'];
  620. $temp['remark']=$value['remark'];
  621. $temp['is_del']=0;
  622. $temp['addtime']=date("Y-m-d H:i:s");
  623. $temp['updatetime']=date("Y-m-d H:i:s");
  624. $data[]=$temp;
  625. }
  626. $derr= Db::name("purchease_info")->insertAll($data);
  627. if($derr){
  628. Db::commit();
  629. return app_show(0,"验货完成");
  630. }else{
  631. Db::rollback();
  632. return error_show(1002,"验货数据保存失败");
  633. }
  634. }
  635. Db::commit();
  636. return app_show(0,"验货完成");
  637. }
  638. Db::rollback();
  639. return error_show(1002,"验货数据保存失败");
  640. }catch (\Exception $e){
  641. Db::rollback();
  642. return error_show(1002,$e->getMessage());
  643. }
  644. }
  645. public function status(){
  646. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  647. if($incode==""){
  648. return error_show(1004,"参数wsm_in_code 不为空");
  649. }
  650. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  651. if(empty($info)){
  652. return error_show(1004,"未找到数据");
  653. }
  654. $status = isset($this->post['status'])&&$this->post['status']!=="" ? intval($this->post['status']):"";
  655. if($status===""){
  656. return error_show(1004,"参数status 不为空");
  657. }
  658. if($info['status']==4){
  659. return error_show(1004,"入库单已完成");
  660. }
  661. $remark = isset($this->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']) :"";
  662. Db::startTrans();
  663. try{
  664. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"status"];
  665. $info['status'] = $status;
  666. $info['remark'] = $remark;
  667. $info['updatetime'] = date("Y-m-d H:i:s");
  668. $update = Db::name("purchease_in")->save($info);
  669. if($update){
  670. ActionLog::logAdd($this->post['token'],$order,"RKD",$status,$this->post);
  671. $uid = Db::name('user_role')
  672. ->where([
  673. ['is_del', '=', 0],
  674. ['roleid', 'in', [31, 41]],
  675. ['status', '=', 1]
  676. ])->column('uid');
  677. $handle_user_list = implode(',', $uid);
  678. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$status,"order_type"=>'RKD',"before_status"=>$order['status'],'holder_id' => $info['apply_id'],"handle_user_list"=>$handle_user_list];
  679. ProcessOrder::AddProcess($this->post['token'],$process);
  680. if($status==0){
  681. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  682. if(empty($cgdinfo)){
  683. Db::rollback();
  684. return error_show(1002,"未找到采购单数据");
  685. }
  686. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  687. $cgdinfo['wsend_num']+=$info['send_num'];
  688. $cgdinfo['send_num']-=$info['send_num'];
  689. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  690. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  691. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  692. $up=Db::name("purchease_order")->save($cgdinfo);
  693. if($up){
  694. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  695. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  696. // $orderinfo = Db::name('sale')
  697. // ->alias('a')
  698. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  699. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  700. // ->where([
  701. // 'a.is_del'=>0,
  702. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  703. // ])->findOrEmpty();
  704. $is_stock = Db::name('good_basic')
  705. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  706. ->value('is_stock');
  707. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  708. if($is_stock==1){
  709. //库存品,推给31库管人员、41库管-张凯旋
  710. $uid = Db::name('user_role')
  711. ->where([
  712. ['is_del', '=', 0],
  713. ['roleid', 'in', [31, 41]],
  714. ['status', '=', 1]
  715. ])->column('uid');
  716. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  717. $handle_user_list=implode(",",$uid);
  718. // $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  719. }else{
  720. //$holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  721. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  722. //$process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];
  723. }//非库存品和采返商品,推给供应商负责人
  724. }//else $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  725. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];
  726. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $process);
  727. Db::commit();
  728. return app_show(0,'取消成功');
  729. }else{
  730. Db::rollback();
  731. return error_show(1002,"取消失败");
  732. }
  733. }
  734. if($status==1){
  735. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  736. if(empty($cgdinfo)){
  737. Db::rollback();
  738. return error_show(1002,"未找到采购单数据");
  739. }
  740. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  741. $cgdinfo['wsend_num']-=$info['send_num'];
  742. $cgdinfo['send_num']+=$info['send_num'];
  743. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  744. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  745. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  746. $up=Db::name("purchease_order")->save($cgdinfo);
  747. if($up){
  748. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  749. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  750. if($cgdinfo['status'] == 1 || $cgdinfo['status']==2){
  751. // $orderinfo = Db::name('sale')
  752. // ->alias('a')
  753. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  754. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  755. // ->where([
  756. // 'a.is_del'=>0,
  757. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  758. // ])->findOrEmpty();
  759. $is_stock = Db::name('good_basic')
  760. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  761. ->value('is_stock');
  762. if($is_stock==1){
  763. //库存品,推给31库管人员、41库管-张凯旋
  764. $uid = Db::name('user_role')
  765. ->where([
  766. ['is_del', '=', 0],
  767. ['roleid', 'in', [31, 41]],
  768. ['status', '=', 1]
  769. ])->column('uid');
  770. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  771. $handle_user_list = implode(",",$uid);
  772. // $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  773. }elseif ($is_stock==0 || $cgdinfo['order_type']==3) {
  774. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  775. // $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];
  776. }//非库存品和采返商品,推给供应商负责人
  777. }//else $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  778. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];ProcessOrder::AddProcess($this->post['token'],$process);
  779. Db::commit();
  780. return app_show(0,'发货成功');
  781. }else{
  782. Db::rollback();
  783. return error_show(1002,"发货失败");
  784. }
  785. }
  786. if($status==4){
  787. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  788. if(empty($cgdinfo)){
  789. Db::rollback();
  790. return error_show(1002,"未找到采购单数据");
  791. }
  792. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  793. $cgdinfo['wsend_num']-=$info['send_num'];
  794. $cgdinfo['send_num']+=$info['send_num'];
  795. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  796. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  797. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  798. $up=Db::name("purchease_order")->save($cgdinfo);
  799. if($up==false){
  800. Db::rollback();
  801. return error_show(1002,"发货失败");
  802. }
  803. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  804. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  805. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  806. // $orderinfo = Db::name('sale')
  807. // ->alias('a')
  808. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  809. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  810. // ->where([
  811. // 'a.is_del'=>0,
  812. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  813. // ])->findOrEmpty();
  814. $is_stock = Db::name('good_basic')
  815. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  816. ->value('is_stock');
  817. if($is_stock==1){
  818. //库存品,推给31库管人员、41库管-张凯旋
  819. $uid = Db::name('user_role')
  820. ->where([
  821. ['is_del', '=', 0],
  822. ['roleid', 'in', [31, 41]],
  823. ['status', '=', 1]
  824. ])->column('uid');
  825. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  826. // $holder_id = implode(",",$uid);
  827. // $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  828. }else{
  829. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  830. // $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];
  831. }//非库存品和采返商品,推给供应商负责人
  832. }//else $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  833. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];
  834. ProcessOrder::AddProcess($this->post['token'],$process);
  835. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  836. if(empty($good)) {
  837. $good=[
  838. "spuCode"=>$cgdinfo['spuCode'],
  839. "wsm_code"=>$info['wsm_code'],
  840. "usable_stock"=>0,
  841. "wait_out_stock"=>0,
  842. "wait_in_stock"=>$info['wsm_num'],
  843. "total_stock"=>0,
  844. "addtime"=>date("Y-m-d H:i:s"),
  845. "updatetime"=>date("Y-m-d H:i:s"),
  846. ];
  847. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  848. "action_type"=>"create"];
  849. }else{
  850. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  851. }
  852. $good['wait_in_stock']-=$info['wsm_num'];
  853. $good['usable_stock']+=$info['wsm_num'];
  854. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  855. $good['updatetime'] = date("Y-m-d H:i:s");
  856. $upd= Db::name("good_stock")->save($good);
  857. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  858. //商品变动日志表,good_log_code字段存储入库单编号
  859. $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"];
  860. $good_data[] = ['good_log_code' => $incode, "stock_id" => isset($good['id']) ? $good['id'] :
  861. Db::name("good_stock")->getLastInsID(), "type" => 2, 'stock' => $info['wsm_num'], "stock_name" => "wait_in_stock"];
  862. if($upd){
  863. $bnin=GoodStockInfo::AddBn($stockid,$info['bnCode'],$info['wsm_num'],$cgdinfo['good_price']);
  864. if($bnin==false){
  865. Db::rollback();
  866. return error_show(1004,"库存bn数据新增失败");
  867. }
  868. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  869. Db::commit();
  870. return app_show(0,'商品入库成功');
  871. }else{
  872. Db::rollback();
  873. return error_show(1002,"商品入库失败");
  874. }
  875. }
  876. Db::commit();
  877. return app_show(0,"状态修改完成");
  878. }
  879. Db::rollback();
  880. return error_show(1002,"状态修改失败");
  881. }catch (\Exception $e){
  882. Db::rollback();
  883. return error_show(1002,$e->getMessage());
  884. }
  885. }
  886. /**
  887. * @return \think\response\Json|void
  888. * @throws \think\db\exception\DataNotFoundException
  889. * @throws \think\db\exception\DbException
  890. * @throws \think\db\exception\ModelNotFoundException
  891. */
  892. public function ReturnAdd(){
  893. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  894. if($incode==""){
  895. return error_show(1004,"参数wsm_in_code 不为空");
  896. }
  897. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  898. if(empty($info)){
  899. return error_show(1004,"未找到数据");
  900. }
  901. //正常入库数量
  902. $wsm_num = isset($this->post['wsm_num']) &&$this->post['wsm_num']!=="" ? intval($this->post['wsm_num']):"" ;
  903. if($wsm_num===""){
  904. return error_show(1004,"参数wsm_num 不为空");
  905. }
  906. //补货数量
  907. $reissue_num = isset($this->post['reissue_num']) &&$this->post['reissue_num']!=="" ? intval($this->post['reissue_num']):"0" ;
  908. //退货数量
  909. $return_num = isset($this->post['return_num']) &&$this->post['return_num']!=="" ? intval($this->post['return_num']):"0" ;
  910. $contactor = isset($this->post['contactor']) &&$this->post['contactor']!=="" ? trim($this->post['contactor']):"" ;
  911. if($contactor==""){
  912. return error_show(1004,"参数contactor 不为空");
  913. }
  914. $addr = isset($this->post['addr']) &&$this->post['addr']!=="" ? trim($this->post['addr']):"" ;
  915. if($addr==""){
  916. return error_show(1004,"参数addr 不为空");
  917. }
  918. $mobile = isset($this->post['mobile']) &&$this->post['mobile']!=="" ? trim($this->post['mobile']):"" ;
  919. if($mobile==""){
  920. return error_show(1004,"参数mobile 不为空");
  921. }
  922. $error_remark = isset($this->post['error_remark']) &&$this->post['error_remark']!=="" ? trim($this->post['error_remark']):"" ;
  923. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  924. $result = GetUserInfo($this->post['token']);
  925. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  926. return error_show($result['code'],$result['message']);
  927. }
  928. $userinfo = $result['data'];
  929. Db::startTrans();
  930. try{
  931. $sto = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  932. // $info['status'] =$info['wsm_num']==$wsm_num ? 4 :5;
  933. $info['status'] = $info['send_num'] == $wsm_num ? 4 : 5;//艳蓉说,这里不能用入库数量比较,应该是用入库数量,即总数来比较
  934. $info['is_th'] =$return_num>0 ?1:0;
  935. $info['wsm_num']= $wsm_num;
  936. $info['updatetime'] = date("Y-m-d H:i:s");
  937. $up= Db::name("purchease_in")->save($info);
  938. if($up){
  939. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  940. if(empty($cgdinfo)){
  941. Db::rollback();
  942. return error_show(1002,"未找到采购单数据");
  943. }
  944. //库存品,推给31库管人员、41库管-张凯旋
  945. $uid = Db::name('user_role')
  946. ->where([
  947. ['is_del', '=', 0],
  948. ['roleid', 'in', [31, 41]],
  949. ['status', '=', 1]
  950. ])->column('uid');
  951. $handle_user_list=implode(",",$uid);
  952. if($info['status']==4){
  953. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  954. $cgdinfo['wsend_num']-=$info['send_num'];
  955. $cgdinfo['send_num']+=$info['send_num'];
  956. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  957. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  958. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  959. $up=Db::name("purchease_order")->save($cgdinfo);
  960. if($up==false){
  961. Db::rollback();
  962. return error_show(1002,"发货失败");
  963. }
  964. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  965. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  966. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  967. $is_stock = Db::name('good_basic')
  968. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  969. ->value('is_stock');
  970. if($is_stock==1){
  971. //库存品,推给31库管人员、41库管-张凯旋
  972. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  973. // $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  974. }else{
  975. // $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  976. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  977. // $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];
  978. }//非库存品和采返商品,推给供应商负责人
  979. }//else $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  980. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];
  981. ProcessOrder::AddProcess($this->post['token'],$process);
  982. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  983. if(empty($good)) {
  984. $good=[
  985. "spuCode"=>$cgdinfo['spuCode'],
  986. "wsm_code"=>$info['wsm_code'],
  987. "usable_stock"=>0,
  988. "wait_out_stock"=>0,
  989. "wait_in_stock"=>$wsm_num,
  990. "total_stock"=>0,
  991. "addtime"=>date("Y-m-d H:i:s"),
  992. "updatetime"=>date("Y-m-d H:i:s"),
  993. ];
  994. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  995. "action_type"=>"create"];
  996. }else{
  997. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  998. }
  999. $good['wait_in_stock']-=$wsm_num;
  1000. // if($good['presale_stock']>0){
  1001. // if($good['presale_stock']>=$wsm_num){
  1002. // $good['presale_stock']-=$wsm_num;
  1003. // $good['wait_out_stock']+=$wsm_num;
  1004. // }else{
  1005. // $good['presale_stock']=0;
  1006. // $good['usable_stock']+=$wsm_num-$good['presale_stock'];
  1007. // $good['wait_out_stock']+=$good['presale_stock'];
  1008. // }
  1009. // }else{
  1010. $good['usable_stock']+=$wsm_num;
  1011. // }
  1012. // $good['usable_stock']+=$wsm_num;
  1013. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  1014. $good['updatetime'] = date("Y-m-d H:i:s");
  1015. $upd= Db::name("good_stock")->save($good);
  1016. if($upd==false){
  1017. Db::rollback();
  1018. return error_show(1002,"库存更新失败");
  1019. }
  1020. $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"];
  1021. $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"];
  1022. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  1023. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  1024. if($bk==false){
  1025. $bk=[
  1026. "cgdNo"=>$cgdinfo['cgdNo'],
  1027. "spuCode"=>$cgdinfo['spuCode'],
  1028. "companyNo"=>$cgdinfo['companyNo'],
  1029. "total_num"=>0,
  1030. "merge_num"=>0,
  1031. "balance_num"=>0,
  1032. "status"=>1,
  1033. "is_del"=>0,
  1034. 'addtime'=>date("Y-m-d H:i:s"),
  1035. "updatetime"=>date("Y-m-d H:i:s")
  1036. ];
  1037. }
  1038. $bk['balance_num']+=$wsm_num;
  1039. $bk['total_num']+=$wsm_num;
  1040. $bk['updatetime']=date("Y-m-d H:i:s");
  1041. $upcgd =Db::name("order_bk")->save($bk);
  1042. if($upcgd==false){
  1043. Db::rollback();
  1044. return error_show(1004,"采购单数量更新失败");
  1045. }
  1046. }
  1047. ActionLog::logAdd($this->post['token'],$sto,"RKD", $info['status'],$this->post);
  1048. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD',"before_status"=>$sto['status'],'holder_id' => $info['apply_id'],"handle_user_list"=>$handle_user_list??""];
  1049. ProcessOrder::AddProcess($this->post['token'],$process);
  1050. //需要在详情页把相关退货记录原样取出来,所以这里把if去掉,所有记录都入purchease_return表
  1051. if($info['status']==5){
  1052. $returnCode=makeNo("CR");
  1053. $data=[
  1054. "returnCode"=>$returnCode,
  1055. "wsm_in_code"=>$incode,
  1056. "cgdNo"=>$cgdinfo['cgdNo'],
  1057. "wsm_num"=>$wsm_num,
  1058. "reissue_num"=>$reissue_num,
  1059. "return_num"=>$return_num,
  1060. "return_contactor"=>$contactor,
  1061. "return_addr"=>$addr,
  1062. "return_mobile"=>$mobile,
  1063. "error_remark"=>$error_remark,
  1064. "post_code"=>"",
  1065. "post_company"=>"",
  1066. "remark"=>$remark ,
  1067. "apply_id"=>$userinfo['id'],
  1068. "apply_name"=>$userinfo['nickname'],
  1069. "status"=>0,
  1070. "addtime"=>date("Y-m-d H:i:s"),
  1071. "updatetime"=>date("Y-m-d H:i:s")
  1072. ];
  1073. $res = Db::name("purchease_return")->insert($data,true);
  1074. if($res==false){
  1075. Db::rollback();
  1076. return error_show(1002,"验货审核失败");
  1077. }
  1078. $sto = ["order_code"=>$incode,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  1079. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",0,$data);
  1080. //维护台账记录
  1081. // Db::name('standing_book')
  1082. // ->where('wsm_in_code', $incode)
  1083. // ->update([
  1084. // 'cgdReturnCode' => $returnCode,
  1085. // 'updatetime' => date('Y-m-d H:i:s'),
  1086. // ]);
  1087. Db::execute("UPDATE `wsm_standing_book` SET `cgdReturnCode`=CONCAT(IFNULL(`cgdReturnCode`,''),',{$returnCode}'),`updatetime`='" . date('Y-m-d H:i:s') . "' WHERE FIND_IN_SET('{$incode}',`wsm_in_code`)");//这里的wsm_in_code可能有多个
  1088. }
  1089. Db::commit();
  1090. return app_show(0,"验货审核完成");
  1091. }
  1092. }catch (\Exception $e){
  1093. Db::rollback();
  1094. return error_show(1002,$e->getMessage());
  1095. }
  1096. }
  1097. public function ReturnSend(){
  1098. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  1099. if($incode==""){
  1100. return error_show(1004,"参数wsm_in_code 不为空");
  1101. }
  1102. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1103. if(empty($info)){
  1104. return error_show(1004,"未找到发货单数据");
  1105. }
  1106. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1107. if(empty($return)){
  1108. return error_show(1004,"未找到退货单数据");
  1109. }
  1110. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  1111. if(empty($cgdinfo)){
  1112. Db::rollback();
  1113. return error_show(1002,"未找到采购单数据");
  1114. }
  1115. $post_code = isset($this->post['post_code']) &&$this->post['post_code']!=="" ? trim($this->post['post_code']):"" ;
  1116. if($post_code==""){
  1117. return error_show(1004,"参数 post_code 不能为空");
  1118. }
  1119. $post_company = isset($this->post['post_company']) &&$this->post['post_company']!=="" ? trim($this->post['post_company']):"" ;
  1120. if($post_company==""){
  1121. return error_show(1004,"参数 post_company 不能为空");
  1122. }
  1123. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  1124. $data=[
  1125. "post_code"=>$post_code,
  1126. "post_company"=>$post_company,
  1127. "remark"=>$remark,
  1128. "status"=>1,
  1129. "updatetime"=>date("Y-m-d H:i:s")
  1130. ];
  1131. Db::startTrans();
  1132. try{
  1133. $up =Db::name("purchease_return")->where($return)->save($data);
  1134. if($up){
  1135. $sto = ["order_code"=>$info['wsm_in_code'],"status"=>$return['status'],"action_remark"=>'', "action_type"=>"edit"];
  1136. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",1,$this->post);
  1137. $ark=$info['status'];
  1138. $info['status']=6;
  1139. $info['updatetime']=date("Y-m-d H:i:s");
  1140. $sa=Db::name("purchease_in")->save($info);
  1141. if($sa){
  1142. $stn = ["order_code"=>$info['wsm_in_code'],"status"=>$ark,"action_remark"=>'',"action_type"=>"edit"];
  1143. ActionLog::logAdd($this->post['token'],$stn,"RKD",6,$info);
  1144. $uid = Db::name('user_role')
  1145. ->where([
  1146. ['is_del', '=', 0],
  1147. ['roleid', 'in', [31, 41]],
  1148. ['status', '=', 1]
  1149. ])->column('uid');
  1150. $handle_user_list = implode(',', $uid);
  1151. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>6,"order_type"=>'RKD',"before_status"=>$stn['status'],'holder_id' => $info['apply_id'],"handle_user_list"=>$handle_user_list];
  1152. ProcessOrder::AddProcess($this->post['token'],$process);
  1153. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  1154. if(empty($good)) {
  1155. $good=[
  1156. "spuCode"=>$cgdinfo['spuCode'],
  1157. "wsm_code"=>$info['wsm_code'],
  1158. "usable_stock"=>0,
  1159. "wait_out_stock"=>0,
  1160. "wait_in_stock"=>$return['wsm_num'],
  1161. "total_stock"=>0,
  1162. "addtime"=>date("Y-m-d H:i:s"),
  1163. "updatetime"=>date("Y-m-d H:i:s"),
  1164. ];
  1165. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',"action_type"=>"create"];
  1166. }else{
  1167. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  1168. }
  1169. $good['wait_in_stock']-=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1170. $good['usable_stock']+=$return['wsm_num'];
  1171. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  1172. $good['updatetime'] = date("Y-m-d H:i:s");
  1173. $upd= Db::name("good_stock")->save($good);
  1174. if($upd==false){
  1175. Db::rollback();
  1176. return error_show(1002,"库存更新失败");
  1177. }
  1178. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  1179. $bnin=GoodStockInfo::AddBn($stockid,$info['bnCode'],$return['wsm_num'],$cgdinfo['good_price']);
  1180. if($bnin==false){
  1181. Db::rollback();
  1182. return error_show(1004,"库存bn数据新增失败");
  1183. }
  1184. $good_data[]=['good_log_code' => $incode,"stock_id"=>$stockid,"type"=>1, 'stock'=>$info['wsm_num'],"stock_name"=>"usable_stock"];
  1185. $good_data[]=['good_log_code' => $incode,"stock_id"=>$stockid,"type"=>2, 'stock'=>$good['wait_in_stock'],"stock_name"=>"wait_in_stock"];
  1186. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  1187. $order = ["order_code"=>$cgdinfo['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  1188. $cgdinfo['wsend_num']-=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1189. $cgdinfo['send_num']+=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1190. $cgdinfo['th_num']+=$return['return_num']-$return['reissue_num'];
  1191. $cgdinfo['th_fee']=round(($return['return_num']-$return['reissue_num'])*$cgdinfo['good_price'],2);
  1192. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1193. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1194. if($cgdinfo['th_num']==$cgdinfo['send_num']&& $cgdinfo['wsend_num']==0){
  1195. $cgdinfo['status']=4;
  1196. }
  1197. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  1198. $up=Db::name("purchease_order")->save($cgdinfo);
  1199. if($up==false){
  1200. Db::rollback();
  1201. return error_show(1004,"采购单数量更新失败");
  1202. }
  1203. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  1204. if($bk==false){
  1205. $bk=[
  1206. "cgdNo"=>$cgdinfo['cgdNo'],
  1207. "spuCode"=>$cgdinfo['spuCode'],
  1208. "companyNo"=>$cgdinfo['companyNo'],
  1209. "total_num"=>0,
  1210. "merge_num"=>0,
  1211. "balance_num"=>0,
  1212. "status"=>1,
  1213. "is_del"=>0,
  1214. 'addtime'=>date("Y-m-d H:i:s"),
  1215. "updatetime"=>date("Y-m-d H:i:s")
  1216. ];
  1217. }
  1218. $bk['balance_num']+=$return['wsm_num'];
  1219. $bk['total_num']+=$return['wsm_num'];
  1220. $bk['updatetime']=date("Y-m-d H:i:s");
  1221. $upcgd =Db::name("order_bk")->save($bk);
  1222. if($upcgd==false){
  1223. Db::rollback();
  1224. return error_show(1004,"采购单数量更新失败");
  1225. }
  1226. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  1227. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1228. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  1229. // $orderinfo = Db::name('sale')
  1230. // ->alias('a')
  1231. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  1232. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  1233. // ->where([
  1234. // 'a.is_del'=>0,
  1235. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  1236. // ])->findOrEmpty();
  1237. $is_stock = Db::name('good_basic')
  1238. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  1239. ->value('is_stock');
  1240. if($is_stock==1){
  1241. //库存品,推给31库管人员、41库管-张凯旋
  1242. $uid = Db::name('user_role')
  1243. ->where([
  1244. ['is_del', '=', 0],
  1245. ['roleid', 'in', [31, 41]],
  1246. ['status', '=', 1]
  1247. ])->column('uid');
  1248. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  1249. // $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  1250. // $handle_user_list = implode(",",$uid);
  1251. }else{
  1252. // $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1253. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  1254. // $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];//非库存品和采返商品,推给供应商负责人
  1255. }
  1256. }//else $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  1257. $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];//非库存品和采返商品,推给供应商负责人
  1258. ProcessOrder::AddProcess($this->post['token'],$process);
  1259. Db::commit();
  1260. return app_show(0,"退货发货成功");
  1261. }else{
  1262. Db::rollback();
  1263. return error_show(1004,"退货发货失败");
  1264. }
  1265. }else{
  1266. return error_show(1004,"退货发货失败");
  1267. }
  1268. }catch (\Exception $e){
  1269. Db::rollback();
  1270. return error_show(1004,$e->getMessage());
  1271. }
  1272. }
  1273. public function returnList(){
  1274. $page = isset($this->post['page']) && $this->post['page'] !=="" ? intval($this->post['page']):"1";
  1275. $size = isset($this->post['size']) && $this->post['size'] !=="" ? intval($this->post['size']):"10";
  1276. $where = [['a.is_del',"=",0],['b.is_del',"=",0]];
  1277. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!="" ? trim($this->post['cgdNo']):"";
  1278. if($cgdNo!=""){
  1279. $where[]=['a.cgdNo',"like", "%$cgdNo%"];
  1280. }
  1281. $returnCode= isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
  1282. if($returnCode!=""){
  1283. $where[]=['a.returnCode',"like", "%$returnCode%"];
  1284. }
  1285. $good_type_code=isset($this->post['good_type_code']) && $this->post['good_type_code']!==""? trim($this->post['good_type_code']):"";
  1286. if($good_type_code !=""){
  1287. $where[]= ["b.spuCode",'like',"%$good_type_code%"];
  1288. }
  1289. $good_name=isset($this->post['good_name']) && $this->post['good_name']!==""? trim($this->post['good_name']):"";
  1290. if($good_name !=""){
  1291. $where[]= ["b.good_name",'like',"%$good_name%"];
  1292. }
  1293. $status=isset($this->post['status']) && $this->post['status']!==""? trim($this->post['status']):"";
  1294. if($status!=""){
  1295. $where[]= ["a.status",'=',$status];
  1296. }
  1297. $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo']!="" ? trim($this->post['relaComNo']):"";
  1298. if($relaComNo!='') $where[]=['b.companyNo','=', $relaComNo];
  1299. $supplierNo = isset($this->post['supplierNo']) && $this->post['supplierNo'] != "" ? trim($this->post['supplierNo']) : "";
  1300. if ($supplierNo != '') $where[] = ['b.supplierNo', '=', $supplierNo];
  1301. // $role = $this->checkDataShare();
  1302. // if (!empty($role[DataGroupModel::$type_全部])) $where[] = ["a.apply_id", "in", $role[DataGroupModel::$type_全部]];
  1303. $role = $this->checkDataShare();
  1304. $hand = resign_hand_user($this->uid,0);
  1305. if (!empty($role[DataGroupModel::$type_全部])) {
  1306. $arr= array_unique(array_merge($hand,$role[DataGroupModel::$type_全部]));
  1307. $where[] = ['a.apply_id', 'in',$arr];
  1308. }
  1309. $count = Db::name('purchease_return')
  1310. ->alias('a')
  1311. ->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  1312. ->where($where)
  1313. ->count();
  1314. $total = ceil($count / $size);
  1315. $page = $page >= $total ? $total : $page;
  1316. $list = Db::name('purchease_return')
  1317. ->alias('a')
  1318. ->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  1319. ->where($where)
  1320. ->page($page,$size)
  1321. ->field("a.*,b.spuCode,b.good_price,b.order_type,b.good_price,b.total_fee,b.good_name")
  1322. ->order("a.addtime desc")
  1323. ->select()
  1324. ->toArray();
  1325. $data=[];
  1326. foreach ($list as $value){
  1327. if($value['order_type']==3){
  1328. $goon = Db::name("good_zixun")->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->find();
  1329. }else {
  1330. $goon =Db::name('good_basic')->where(['spuCode'=>$value['spuCode']])->find();
  1331. }
  1332. $value['can']= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  1333. $value['return_fee']= round($value['good_price']*$value['return_num'],2);
  1334. //是否具有编辑权限
  1335. $value['is_allow_update'] = 0;
  1336. if (in_array($this->roleid, [1, 33]) || in_array($value['apply_id'], $role[DataGroupModel::$type_可编辑])) $value['is_allow_update'] = 1;
  1337. $data[]=$value;
  1338. }
  1339. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  1340. }
  1341. }