Purchin.php 120 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022
  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. use think\facade\Validate;
  14. //采购单入库
  15. class Purchin extends Base
  16. {
  17. public function __construct(App $app)
  18. {
  19. parent::__construct($app);
  20. // $this->post=$this->request->post();
  21. }
  22. public function list(){
  23. $page = isset($this->post['page']) && $this->post['page'] !==""? intval($this->post['page']):"1";
  24. $size = isset($this->post['size']) && $this->post['size'] !==""? intval($this->post['size']):"10";
  25. $where =[['a.is_del',"=",0],['b.is_del',"=",0]];
  26. $wsm_in_code=isset($this->post['wsm_in_code']) && $this->post['wsm_in_code']!==""? trim($this->post['wsm_in_code']) :"";
  27. if($wsm_in_code!==""){
  28. $where[]=["a.wsm_in_code",'like',"%$wsm_in_code%"];
  29. }
  30. $cgdNo= isset($this->post['cgdNo']) && $this->post['cgdNo'] !==""? trim($this->post['cgdNo']) :"";
  31. if($cgdNo!==""){
  32. $where[]=['a.cgdNo','like',"%$cgdNo%"];
  33. }
  34. $apply_name = isset($this->post['apply_name']) && $this->post['apply_name'] !==""? trim($this->post['apply_name']):"";
  35. if($apply_name!==""){
  36. $where[]=['a.apply_name','like',"%$apply_name%"];
  37. }
  38. $apply_id= isset($this->post['apply_id']) && $this->post['apply_id'] !==""? trim($this->post['apply_id']):"";
  39. if($apply_id!==""){
  40. $where[]=['a.apply_id','=',$apply_id];
  41. }
  42. $status= isset($this->post['status']) && $this->post['status'] !==""? trim($this->post['status']):"";
  43. if($status!==""){
  44. $where[]=['a.status','=',$status];
  45. }
  46. $start= isset($this->post['start']) && $this->post['start'] !== "" ? $this->post['start']:"";
  47. if ($start !=="") {
  48. $where[]= ["a.sendtime",'>=',$start];
  49. }
  50. $end = isset($this->post['end']) && $this->post['end'] !== "" ? $this->post['end'] :"";
  51. if($end !==""){
  52. $where[]= ["a.sendtime",'<=',$end];
  53. }
  54. $order_type=isset($this->post['order_type']) && $this->post['order_type']!==""? intval($this->post['order_type']):"";
  55. if($order_type !==""){
  56. $where[]= ["b.order_type",'=',$order_type];
  57. }
  58. $order_source=isset($this->post['order_source']) && $this->post['order_source']!==""? intval($this->post['order_source']):"";
  59. if($order_source !=="") $where[]= ["b.order_source",'=',$order_source];
  60. $good_type_code=isset($this->post['good_type_code']) && $this->post['good_type_code']!==""? trim($this->post['good_type_code']):"";
  61. if($good_type_code !==""){
  62. $where[]= ["b.spuCode",'like',"%$good_type_code%"];
  63. }
  64. $good_name=isset($this->post['good_name']) && $this->post['good_name']!==""? trim($this->post['good_name']):"";
  65. if($good_name !==""){
  66. $where[]= ["b.good_name",'like',"%$good_name%"];
  67. }
  68. $supplie=isset($this->post['supplier']) && $this->post['supplier']!==""? trim($this->post['supplier']):"";
  69. if($supplie !==""){
  70. $where[]= ["b.supplier_name",'like',"%$supplie%"];
  71. }
  72. $wsm_code=isset($this->post['wsm_code']) && $this->post['wsm_code']!==""? trim($this->post['wsm_code']):"";
  73. if($wsm_code !==""){
  74. $where[]= ["a.wsm_code",'=',$wsm_code];
  75. }
  76. $supplierNo =isset($this->post['supplierNo']) &&$this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']):"";
  77. if($supplierNo!==""){
  78. // $supplier = Db::name("supplier")->where(["code"=>$supplierNo])->find();
  79. // if(empty($supplier)){
  80. // return error_show(1004,"未找到供应商信息");
  81. // }
  82. //不再根据供应商筛选仓库,要筛选仓库只能是业务公司
  83. // $wsmcode = Db::name("warehouse_info")
  84. // ->where(["is_del"=>0,"supplierNo"=>$supplierNo])
  85. // ->column("wsm_code");
  86. // $where[]=['a.wsm_code',"in",$wsmcode];
  87. $where[]= ["b.supplierNo",'=',$supplierNo];
  88. }
  89. $condition=[];
  90. //只有level2的账号过滤数据权限
  91. // if ($this->level == 2) {
  92. // $role = $this->checkDataShare();
  93. // $hand = resign_hand_user($this->uid, 0);
  94. // if (!empty($role[DataGroupModel::$type_全部])) {
  95. // $arr = array_unique(array_merge($hand, $role[DataGroupModel::$type_全部]));
  96. //
  97. // if($arr){
  98. // $sys_supplier = Db::connect('mysql_sys')
  99. // ->name('supplier')
  100. // ->where(['is_del'=>0,'personid'=>$arr])
  101. // ->column('code');
  102. // $condition[] = ["b.supplierNo", "in", $sys_supplier];
  103. // }
  104. //
  105. // $condition[] = ["a.apply_id", "in", $hand];
  106. // $condition[] = ["c.contactor", "in", $hand];
  107. //// $condition.="sip.personid in (".implode(",",
  108. //// $role[DataGroupModel::$type_全部]).") or a.apply_id in {$hand} or c.contactor in {$hand}";
  109. // }
  110. // }
  111. $company_name = isset($this->post['company_name']) && $this->post['company_name'] !== "" ? trim($this->post['company_name']) : "";
  112. if ($company_name !== "") $where[] = ["a.apply_id", 'in', get_company_item_user_by_name($company_name)];
  113. $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo']!="" ? trim($this->post['relaComNo']):"";
  114. if($relaComNo!=='') $where[]=['b.companyNo','=', $relaComNo];
  115. //$count = Db::name('purchease_in')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  116. $count = Db::name('purchease_in')
  117. ->alias('a')
  118. ->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  119. ->leftJoin("warehouse_info c","a.wsm_code=c.wsm_code")
  120. // ->leftJoin('supplier sip', 'sip.code=b.supplierNo')
  121. ->where($where)
  122. // ->whereOr($condition)
  123. ->where(function ($query)use ($condition){$query->whereOr($condition);})
  124. ->count();
  125. $total = ceil($count/$size);
  126. $page = $page >= $total ? $total : $page;
  127. $list = Db::name('purchease_in')
  128. ->alias('a')
  129. ->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  130. // ->leftJoin('supplier sip', 'sip.code=b.supplierNo')
  131. ->leftJoin("warehouse_info c","a.wsm_code=c.wsm_code")
  132. ->where($where)
  133. ->where(function ($query)use ($condition){$query->whereOr($condition);})
  134. ->page($page,$size)
  135. ->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,'' cgder_id,'' cgder,b.good_createrid,b.good_creater,c.name wsm_name,b.supplierNo,b.supplier_name,c.supplierNo wsm_supplierNo,c.supplierName wsm_supplier,b.companyNo,b.companyName")
  136. ->order("a.addtime desc")
  137. ->select()
  138. ->toArray();
  139. $all_createrid = array_column($list,'apply_id');
  140. $item = get_company_name_by_uid($all_createrid);
  141. //获取采购单供应商和仓库供应商的名称
  142. $userCommon = \app\admin\common\User::getIns();
  143. // $names = $userCommon->handle('getCodeAndName',['code'=>array_unique(array_column($list,'wsm_supplierNo'))]);
  144. $all_supplierNos = array_unique(array_column($list,'supplierNo'));
  145. $all_supplier = $userCommon->handle('sGetList',['more_code'=>$all_supplierNos,'page'=>1,'size'=>$size]);
  146. $all_supplier_list = array_column($all_supplier['data']['list'],null,'code');
  147. //校验是否开通了供应商账号
  148. $supp_account = checkHasAccountBySupplierNos($all_supplierNos);
  149. $data=[];
  150. foreach ($list as $value){
  151. $value['cgder_id'] = $all_supplier_list[$value['supplierNo']]['personid']??'';
  152. $value['cgder'] = $all_supplier_list[$value['supplierNo']]['person']??'';
  153. //获取规格、品牌信息
  154. if ($value['order_type'] == 3 || $value['order_type'] == 4 ) {
  155. $temp = Db::name('good_zixun')
  156. ->alias('gz')
  157. ->field('gz.specinfo,b.brand_name')
  158. ->join('brand b', 'b.id=gz.brand_id')
  159. ->where(['gz.spuCode' => $value['spuCode'], 'gz.is_del' => 0])
  160. ->find();
  161. $value["brand_name"] = $temp['brand_name'];
  162. $value["speclist"] = json_decode($temp['specinfo'], true);
  163. } else {
  164. $value['brand_name'] = Db::name('good_basic')
  165. ->alias('gb')
  166. ->join('brand b', 'b.id=gb.brand_id')
  167. ->where(['gb.spuCode' => $value['spuCode']])
  168. ->value('b.brand_name');
  169. $spec = Db::name("good_spec")
  170. ->where(["spuCode" => $value['spuCode'], "is_del" => 0])
  171. ->select()
  172. ->toArray();
  173. $speclist = [];
  174. if (!empty($spec)) {
  175. foreach ($spec as $val) {
  176. $temp = [];
  177. $temp['id'] = $val['id'];
  178. $temp['spuCode'] = $val['spuCode'];
  179. $temp['spec_id'] = $val['spec_id'];
  180. $temp['spec_value_id'] = $val['spec_value_id'];
  181. $sp = Db::name("specs")->where(["id" => $val['spec_id']])->find();
  182. $temp['spec_name'] = isset($sp["spec_name"]) ? $sp["spec_name"] : "";
  183. $spv = Db::name("spec_value")->where(["id" => $val['spec_value_id']])->find();
  184. $temp['spec_value'] = isset($spv["spec_value"]) ? $spv["spec_value"] : "";
  185. $speclist[] = $temp;
  186. }
  187. }
  188. $value["speclist"] = empty($speclist) ? [] : $speclist;
  189. }
  190. // $wsmcode = Db::name("warehouse_info")
  191. // ->alias("k")
  192. // ->leftJoin("supplier c","k.supplierNo=c.code")
  193. // ->where(["k.wsm_code"=>$value['wsm_code']])
  194. // ->field("k.name as wsm_name,c.name,c.code")
  195. // ->find();
  196. // $value['wsm_name'] = $wsmcode['wsm_name'];
  197. // $value['wsm_supplier'] = $names['data'][$value['wsm_supplierNo']]??'';
  198. // $value['companyName'] = $names['data'][$value['companyNo']]??'';
  199. // $value['wsm_supplierNo'] = $wsmcode['code'];
  200. $value['company_name'] = $item[$value['apply_id']]??'';
  201. //是否具有编辑权限
  202. // $value['is_allow_update'] = 0;
  203. // if (in_array($this->roleid, [1, 33]) || in_array($value['apply_id'], $role[DataGroupModel::$type_可编辑])) $value['is_allow_update'] = 1;
  204. $value['has_account'] = (int)isset($supp_account[$value['supplierNo']]);
  205. $data[]=$value;
  206. }
  207. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  208. }
  209. public function add(){
  210. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!=""? trim($this->post['cgdNo']):"";
  211. if($cgdNo==""){
  212. return error_show(1005,"参数cgdNo 不能为空");
  213. }
  214. $cgdinfo = Db::name("purchease_order")->where(['cgdNo'=>$cgdNo,'is_del'=>0])->find();
  215. if(empty($cgdinfo)){
  216. return error_show(1005,"未找到采购单数据");
  217. }
  218. if($cgdinfo['status']==0){
  219. return error_show(1005,"采购单未确认");
  220. }
  221. $isreturn = cgd_sale_return($cgdNo);
  222. if($isreturn){
  223. return error_show(1005, "关联销售单存在退货单正在进行");
  224. }
  225. $wsm_in_code = makeNo("CF");
  226. $bn_code = makeNo("BN");
  227. $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  228. if(empty($wsminfo)){
  229. return error_show(1004,"未找到仓库信息");
  230. }
  231. $recep = Db::name('warehouse_addr')->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  232. $sendtype = isset($this->post['sendtype'])&&$this->post['sendtype']!="" ? intval($this->post['sendtype']):"";
  233. if($sendtype==""){
  234. return error_show(1004,"参数 sendtype 不能为空");
  235. }
  236. $post_company = isset($this->post['post_company'])&&$this->post['post_company']!="" ? trim($this->post['post_company']):"";
  237. $post_code = isset($this->post['post_code'])&&$this->post['post_code']!="" ? trim($this->post['post_code']):"";
  238. $post_fee = isset($this->post['post_fee'])&&$this->post['post_fee']!="" ? $this->post['post_fee']:"0";
  239. $post_time = isset($this->post['post_time'])&&$this->post['post_time']!="" ? $this->post['post_time']:date("Y-m-d H:i:s");
  240. $send_num = isset($this->post['send_num'])&&$this->post['send_num']!="" ? intval($this->post['send_num']):"";
  241. $status = isset($this->post['status'])&&$this->post['status']!="" ? intval($this->post['status']):"1 ";
  242. if($send_num==''){
  243. return error_show(1004,"参数 send_num 不能为空或零");
  244. }
  245. $wsmin_num=Db::name("purchease_in")->where([["cgdNo","=",$cgdNo],["is_del","=",0],["status","=",1]])
  246. ->sum("send_num");
  247. if($send_num>$cgdinfo['wsend_num']-$wsmin_num){
  248. return error_show(1009,"采购单剩余未发货数量不足");
  249. }
  250. if($cgdinfo['order_type']!=1){
  251. $status=2;
  252. }
  253. $orin = [
  254. "wsm_in_code"=>$wsm_in_code,
  255. "cgdNo"=>$cgdNo,
  256. "bnCode"=>$bn_code,
  257. "wsm_code"=>$cgdinfo['wsm_code'],
  258. "wsm_reaper"=>isset($recep)&& $recep['wsm_name']!=''? $recep['wsm_name']:"",
  259. "send_num"=>$send_num,
  260. "post_company"=>$post_company,
  261. "post_code"=>$post_code,
  262. "post_fee"=>$post_fee,
  263. "sendtime"=>$post_time,
  264. "apply_id"=>$this->uid,
  265. "apply_name"=>$this->uname,
  266. "wait_num"=>0,
  267. "wsm_num"=>0,
  268. "sendtype"=>$sendtype,
  269. "status"=>$status,
  270. "addtime"=>date("Y-m-d H:i:s"),
  271. "updatetime"=>date("Y-m-d H:i:s")
  272. ];
  273. Db::startTrans();
  274. try{
  275. //
  276. if ($this->level == 2) {
  277. //如果开通了供应商账号,则只允许level3账号操作,level2账号不允许操作
  278. $all_has_supplier_account = checkHasAccountBySupplierNos([$cgdinfo['supplierNo']]);
  279. if (isset($all_has_supplier_account[$cgdinfo['supplierNo']])) throw new Exception('已开通供应商账号,当前账号不能操作');
  280. }
  281. $win = Db::name("purchease_in")->insert($orin,true);
  282. if($win){
  283. $sto = ["order_code"=>$wsm_in_code,"status"=>$status,"action_remark"=>'',"action_type"=>"edit"];
  284. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$sto,"RKD",$status,$this->post);
  285. if($status==1){
  286. // $uid = Db::name('user_role')
  287. // ->where([
  288. // ['is_del', '=', 0],
  289. // ['roleid', 'in', [31, 41]],
  290. // ['status', '=', 1]
  291. // ])->column('uid');
  292. // $handle_user_list = implode(',', $uid);
  293. }
  294. $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??""];
  295. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  296. $order = ["order_code"=>$cgdNo,"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  297. //维护台账信息
  298. 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}'");
  299. $is_stock = Db::name('good_basic')
  300. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  301. ->value('is_stock');
  302. $userCommon = \app\admin\common\User::getIns();
  303. $supplier_temp = $userCommon->handle('sInfo',['code'=>$cgdinfo['supplierNo']]);
  304. $person = $supplier_temp['data'];
  305. // if ($this->level == 2 && $this->uid != $person['personid']) throw new Exception('只能由供应商负责人操作');
  306. if($status==1){
  307. Db::commit();
  308. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  309. }
  310. if($status==2){
  311. $cgdinfo['wsend_num']-=$send_num;
  312. $cgdinfo['send_num']+=$send_num;
  313. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  314. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  315. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  316. $up=Db::name("purchease_order")->save($cgdinfo);
  317. if($up==false){
  318. Db::rollback();
  319. return error_show(1004,"新建失败");
  320. }
  321. $good = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'],"spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->lock(true)->find();
  322. if(empty($good)) {
  323. $good=[
  324. "spuCode"=>$cgdinfo['spuCode'],
  325. "wsm_code"=>$cgdinfo['wsm_code'],
  326. "usable_stock"=>0,
  327. "wait_out_stock"=>0,
  328. "wait_in_stock"=>$send_num,
  329. "total_stock"=>0,
  330. "addtime"=>date("Y-m-d H:i:s"),
  331. "updatetime"=>date("Y-m-d H:i:s"),
  332. ];
  333. }
  334. $good['wait_in_stock']-=$send_num;
  335. $good['usable_stock']+=$send_num;
  336. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  337. $good['updatetime'] = date("Y-m-d H:i:s");
  338. $upd= Db::name("good_stock")->save($good);
  339. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  340. //商品变动日志表,good_log_code字段存储采购单单号
  341. $good_data=[];
  342. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  343. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>2,'stock'=>$send_num,"stock_name"=>"wait_in_stock"];
  344. if($upd){
  345. GoodLog::LogAdd(['id'=>$this->uid,'nickname'=>$this->uname],$good_data,'RKD');
  346. $bnin=GoodStockInfo::AddBn($stockid,$bn_code,$send_num,$cgdinfo['good_price']);
  347. if($bnin==false){
  348. Db::rollback();
  349. return error_show(1004,"库存bn数据新增失败");
  350. }
  351. //todo:: 新增bn编号库存数据修改
  352. if($cgdinfo['order_type']==1){
  353. //商品表里的'可用总库存数'增加
  354. Db::name('good')
  355. ->data(['updatetime' => date('Y-m-d H:i:s')])
  356. ->where(['is_del' => 0, 'spuCode' => $cgdinfo['spuCode']])
  357. ->inc('usable_stock', $send_num)
  358. ->update();
  359. }
  360. if($cgdinfo['send_status']==3 && $cgdinfo['order_type']!=1){
  361. $send=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"status"=>1])->column("outCode");
  362. if(!empty($send)){
  363. $out =Db::name("order_out")->where(["outCode"=>$send,"status"=>0,"is_del"=>0])->select()
  364. ->toArray();
  365. if(!empty($out)){
  366. $up =Db::name("order_out")->where(["outCode"=>$send,"status"=>0,"is_del"=>0])->update(["status"=>1,'send_status'=>1,'wsm_code'=>$cgdinfo['wsm_code'],"updatetime"=>date('Y-m-d H:i:s')]);
  367. //2023-03-14 17:34修改,增加'send_status'=>1 by 武
  368. if($up==false){
  369. Db::rollback();
  370. return error_show(1004,"出库单出库失败");
  371. }else{
  372. foreach ($out as $k => $v_outCode) {
  373. \app\admin\model\OrderOutChild::makeChild($v_outCode['outCode']);
  374. ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], [
  375. "order_code" => $v_outCode['outCode'],//出库单号
  376. "status" => 0,//这里的status是之前的值
  377. "action_remark" => '',//备注
  378. "action_type" => "status"//新建create,编辑edit,更改状态status
  379. ], "CKD", 1, $this->post);
  380. if ($is_stock == 1) {
  381. //库存品,推给库管和库管-张凯旋
  382. $roleid = config('app.wsm_cgder_role');
  383. $uids = Db::name('user_role')
  384. ->where('is_del', 0)
  385. ->whereIn('roleid', $roleid)
  386. ->column('uid');
  387. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
  388. "order_type" => 'CKD',
  389. "order_code" => $v_outCode['outCode'],//出库单号
  390. "order_id" => $v_outCode['id'],
  391. "order_status" => 1,
  392. "before_status" => 0,
  393. // 'wait_id' => $supplier['personid'],
  394. // 'wait_name' => $supplier['person'],
  395. // 'holder_id' => $supplier['personid'],
  396. 'handle_user_list' => implode(',', $uids)
  397. ]);
  398. } else {
  399. //非库存品和采返商品,推给供应商负责人
  400. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
  401. "order_type" => 'CKD',
  402. "order_code" => $v_outCode['outCode'],//出库单号
  403. "order_id" => $v_outCode['id'],
  404. "order_status" => 1,
  405. "before_status" => 0,
  406. 'wait_id' => $person['personid']??0,
  407. 'wait_name' => $person['person']??'',
  408. 'holder_id' =>$person['personid']??0,
  409. ]);
  410. }
  411. }
  412. }
  413. // $good1 = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  414. // if($good1==false){
  415. // Db::rollback();
  416. // return error_show(1004,"未找到对应商品库存");
  417. // }
  418. // $out_num = intval(array_sum(array_column($out,"send_num")));
  419. // if($out_num>$good1['usable_stock']){
  420. // Db::rollback();
  421. // return error_show(1004,"库存数量不足发货");
  422. // }
  423. // $good1['usable_stock']-=$out_num;
  424. // $good1['wait_out_stock']+=$out_num;
  425. // $good1['total_stock']=$good1['usable_stock']+$good1['wait_out_stock'];
  426. // $good1['updatetime'] = date("Y-m-d H:i:s");
  427. // $upd= Db::name("good_stock")->save($good1);
  428. // if($upd==false){
  429. // Db::rollback();
  430. // return error_show(1004,"库存数量更新失败");
  431. // }
  432. // $stockid= isset($good['id'])?$good['id']:Db::name("good_stock")->getLastInsID();
  433. //
  434. // $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"wait_out_stock"];
  435. // $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  436. // GoodLog::LogAdd(['id'=>$this->uid,'nickname'=>$this->uname],$good_data,'RKD');
  437. $sendp=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"outCode"=>$send,"status"=>1])->save (["status"=>2]);
  438. if($sendp==false){
  439. Db::rollback();
  440. return error_show(1004,"库存发货失败");
  441. }
  442. }
  443. }
  444. if ($cgdinfo['order_type'] == 2) Db::name('good')
  445. ->data(['updatetime' => date('Y-m-d H:i:s')])
  446. ->where(['is_del' => 0, 'spuCode' => $cgdinfo['spuCode']])
  447. ->inc('usable_stock', $send_num)
  448. ->update();
  449. else Db::name('good_zixun')
  450. ->data(['updatetime' => date('Y-m-d H:i:s')])
  451. ->where(['is_del' => 0, 'spuCode' => $cgdinfo['spuCode']])
  452. ->inc('usable_stock', $send_num)
  453. ->update();
  454. }
  455. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  456. // $personid = Db::name('supplier')
  457. // ->where('is_del',0)
  458. // ->where('code',$cgdinfo['supplierNo'])
  459. // ->value('personid');
  460. // if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  461. // $is_stock = Db::name('good_basic')
  462. // ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  463. // ->value('is_stock');
  464. // if($is_stock==1){
  465. // //库存品,推给31库管人员、41库管-张凯旋
  466. // $uid = Db::name('user_role')
  467. // ->where([
  468. // ['is_del', '=', 0],
  469. // ['roleid', 'in', [31, 41]],
  470. // ['status', '=', 1]
  471. // ])->column('uid');
  472. // if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  473. //// $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)];
  474. //
  475. // }else{
  476. // if (($this->level == 2) && ($this->uid != $person['personid'])) throw new Exception('只能由供应商负责人操作');
  477. // }
  478. // }//else $process = ["order_code" => $cgdNo, "order_id" => $cgdinfo['id'], "order_status" => $cgdinfo['status'], "order_type" => 'CGD', "before_status" => $order['status'], 'holder_id' => $personid];
  479. 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' => $person['personid']??0]);
  480. Db::commit();
  481. return app_show(0,'商品入库成功',["wsm_in_code"=>$wsm_in_code]);
  482. }else{
  483. Db::rollback();
  484. return error_show(1002,"商品入库失败");
  485. }
  486. }
  487. Db::commit();
  488. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  489. }
  490. Db::rollback();
  491. return error_show(1004,"新建失败");
  492. }catch (\Exception $e){
  493. Db::rollback();
  494. return error_show(1004, $e->getMessage());
  495. }
  496. }
  497. //批量添加入库单
  498. public function addBatch()
  499. {
  500. $param = $this->request->filter('trim')->only(['cgdNo'], 'post');
  501. $val = Validate::rule(['cgdNo|订单编号' => 'require|array|max:100']);
  502. //入库方式 供应商包邮,
  503. //运费 0
  504. if (!$val->check($param)) return json_show(1004, $val->getError());
  505. $cgdinfo = Db::name("purchease_order")
  506. ->whereIn('cgdNo', $param['cgdNo'])
  507. ->where(['is_del' => 0])
  508. ->where('status', 'in', [1, 2])//1待入库,2部分入库
  509. ->column('id,wsm_code,good_num,good_price,spuCode,order_type,send_status,status,supplierNo', 'cgdNo');
  510. if (empty($cgdinfo)) return json_show(1005, "未找到采购单数据或采购单未发货");
  511. $all_wsm_code = array_column($cgdinfo, 'wsm_code');
  512. $recep = Db::name('warehouse_addr')
  513. ->where('is_del', 0)
  514. ->whereIn('wsm_code', $all_wsm_code)
  515. ->column('wsm_name', 'wsm_code');
  516. $uid = $this->uid;
  517. $nickname = $this->uname;
  518. Db::startTrans();
  519. try {
  520. $date = date('Y-m-d H:i:s');
  521. // $supplier_cgderid = Db::name('supplier')
  522. // ->where('is_del',0)
  523. // ->whereIn('code',array_column($cgdinfo,'supplierNo'))
  524. // ->column('personid,person','code');
  525. $codes = array_unique(array_column($cgdinfo, 'supplierNo'));
  526. $temp = \app\admin\common\User::getIns()->handle('sGetList', ['more_code' => $codes, 'size' => count($codes)]);
  527. $supplier_cgderid = [];
  528. foreach ($temp['data']['list'] as $da) {
  529. if (!isset($supplier_cgderid[$da['code']])) $supplier_cgderid[$da['code']] = [
  530. 'personid' => $da['personid'],
  531. 'person' => $da['person'],
  532. ];
  533. }
  534. $i = 0;
  535. $status = 2;//4入库完成
  536. foreach ($param['cgdNo'] as $cgdNo) {
  537. $isreturn = cgd_sale_return($cgdNo);
  538. if ($isreturn) {
  539. throw new Exception("{$cgdNo}关联销售单存在退货单正在进行");
  540. }
  541. if (empty($cgdinfo[$cgdNo])) throw new Exception('未找到采购单数据或采购单未发货');
  542. $wsm_in_code = makeNo("CF");
  543. $bn_code = makeNo("BN");
  544. $send_num = $cgdinfo[$cgdNo]['good_num'];
  545. //改变编码规则,将原编码后两位换成序列号
  546. //str_pad字符串填充
  547. $wsm_in_code = substr($wsm_in_code, 0, -2) . str_pad($i, 2, '0', STR_PAD_LEFT);
  548. $i++;
  549. //入库单
  550. $win = Db::name("purchease_in")->insertGetId([
  551. "wsm_in_code" => $wsm_in_code,
  552. "cgdNo" => $cgdNo,
  553. "bnCode" => $bn_code,
  554. "wsm_code" => $cgdinfo[$cgdNo]['wsm_code'],
  555. "wsm_reaper" => isset($recep[$cgdinfo[$cgdNo]['wsm_code']]) ? $recep[$cgdinfo[$cgdNo]['wsm_code']] : '',
  556. "send_num" => $cgdinfo[$cgdNo]['good_num'],
  557. "post_company" => '',
  558. "post_code" => '',
  559. "post_fee" => 0,//运费固定值:0
  560. "sendtime" => $date,
  561. "apply_id" => $uid,
  562. "apply_name" => $nickname,
  563. "wait_num" => 0,
  564. "wsm_num" => 0,
  565. "sendtype" => 2,//发货方式,固定值,供应商包邮2
  566. "status" => $status,
  567. "addtime" => $date,
  568. "updatetime" => $date
  569. ]);
  570. if ($win) {
  571. $sto = ["order_code" => $wsm_in_code, "status" => $status, "action_remark" => '', "action_type" => "edit"];
  572. ActionLog::logAdd(['id' => $uid, 'nickname' => $nickname], $sto, "RKD", $status, $this->request->filter('trim')->post());
  573. $process = ["order_code" => $wsm_in_code, "order_id" => $win, "order_status" => $status, "order_type" => 'RKD', "before_status" => $status, 'holder_id' => $uid];
  574. ProcessOrder::AddProcess(['id' => $uid, 'nickname' => $nickname], $process);
  575. $order = ["order_code" => $cgdNo, "status" => $cgdinfo[$cgdNo]['status'], "action_remark" => '', "action_type" => "edit"];
  576. //维护台账信息
  577. Db::execute("UPDATE `wsm_standing_book` SET `wsm_in_code`=CONCAT(IFNULL(`wsm_in_code`,''),',{$wsm_in_code}'),`updatetime`='" . $date . "' WHERE `cgdNo`='{$cgdNo}'");
  578. //////////////////
  579. $good = Db::name("good_stock")
  580. ->where(["wsm_code" => $cgdinfo[$cgdNo]['wsm_code'], "spuCode" => $cgdinfo[$cgdNo]['spuCode'], "is_del" => 0])
  581. ->lock(true)
  582. ->find();
  583. if (empty($good)) {
  584. $good = [
  585. "spuCode" => $cgdinfo[$cgdNo]['spuCode'],
  586. "wsm_code" => $cgdinfo[$cgdNo]['wsm_code'],
  587. "usable_stock" => 0,
  588. "wait_out_stock" => 0,
  589. "wait_in_stock" => $send_num,
  590. "total_stock" => 0,
  591. "addtime" => date("Y-m-d H:i:s"),
  592. "updatetime" => date("Y-m-d H:i:s"),
  593. ];
  594. // $order = ["order_code" => $good['spuCode'], "status" => 1, "action_remark" => '', "action_type" => "create"];
  595. } else {
  596. // $order = ["order_code" => $good['spuCode'], "status" => 1, "action_remark" => '', "action_type" => "edit"];
  597. }
  598. $good['wait_in_stock'] -= $send_num;
  599. // if ($good['presale_stock'] > 0) {
  600. // if ($good['presale_stock'] >= $send_num) {
  601. // $good['presale_stock'] -= $send_num;
  602. // $good['wait_out_stock'] += $send_num;
  603. // } else {
  604. // $good['presale_stock'] = 0;
  605. // $good['usable_stock'] += $send_num - $good['presale_stock'];
  606. // $good['wait_out_stock'] += $good['presale_stock'];
  607. // }
  608. // } else {
  609. $good['usable_stock'] += $send_num;
  610. // }
  611. $good['total_stock'] = $good['usable_stock'] + $good['wait_out_stock'];
  612. $good['updatetime'] = date("Y-m-d H:i:s");
  613. $upd = Db::name("good_stock")->save($good);
  614. $stockid = $good['id'] ?? Db::name("good_stock")->getLastInsID();
  615. //商品变动日志表,good_log_code字段存储采购单单号
  616. $good_data[] = ['good_log_code' => $wsm_in_code, "stock_id" => $stockid, "type" => 1, 'stock' => $send_num, "stock_name" => "usable_stock"];
  617. $good_data[] = ['good_log_code' => $wsm_in_code, "stock_id" => $stockid, "type" => 2, 'stock' => $send_num, "stock_name" => "wait_in_stock"];
  618. if ($upd) {
  619. GoodLog::LogAdd(['id' => $uid, 'nickname' => $nickname], $good_data, 'RKD');
  620. $bnin = GoodStockInfo::AddBn($stockid, $bn_code, $send_num, $cgdinfo[$cgdNo]['good_price']);
  621. if ($bnin == false) {
  622. Db::rollback();
  623. return error_show(1004, "库存bn数据新增失败");
  624. }
  625. if ($cgdinfo[$cgdNo]['order_type'] == 1) {
  626. $bk = Db::name("order_bk")->where(['cgdNo' => $cgdNo])->find();
  627. if ($bk == false) {
  628. $bk = [
  629. "cgdNo" => $cgdNo,
  630. "spuCode" => $cgdinfo[$cgdNo]['spuCode'],
  631. "companyNo" => $cgdinfo[$cgdNo]['companyNo'],
  632. "total_num" => $send_num,
  633. "merge_num" => 0,
  634. "balance_num" => $send_num,
  635. "status" => 1,
  636. "is_del" => 0,
  637. 'addtime' => date("Y-m-d H:i:s"),
  638. "updatetime" => date("Y-m-d H:i:s")
  639. ];
  640. $upcgd = Db::name("order_bk")->save($bk);
  641. } else {
  642. $where = ['id' => $bk['id'], 'total_num' => $bk['total_num'], 'balance_num' => $bk['balance_num']];
  643. $bk['balance_num'] += $send_num;
  644. $bk['total_num'] += $send_num;
  645. $bk['updatetime'] = date("Y-m-d H:i:s");
  646. $upcgd = Db::name("order_bk")->where($where)->update($bk);
  647. }
  648. if ($upcgd == false) throw new Exception('采购单数量更新失败');
  649. }
  650. if (in_array($cgdinfo[$cgdNo]['send_status'], [1, 2]) && $cgdinfo[$cgdNo]['order_type'] != 1) {
  651. $send = Db::name("order_send")->where(["cgdNo" => $cgdNo, "status" => 1])->column("outCode");
  652. if (!empty($send)) {
  653. $out = Db::name("order_out")->where(["outCode" => $send, "status" => 0,'is_del'=>0])->select()->toArray();
  654. if (!empty($out)) {
  655. $up = Db::name("order_out")->where(["outCode" => $send, "status" => 0,'is_del'=>0])->update(["status" => 1,'send_status'=>1, 'wsm_code' => $cgdinfo[$cgdNo]['wsm_code'], "updatetime" => date('Y-m-d H:i:s')]);
  656. //2023-03-14 17:34修改,增加'send_status'=>1 by 武
  657. if ($up == false) throw new Exception('出库单出库失败');
  658. else {
  659. //查询是否有非库存品订单
  660. $is_stock = Db::name('sale')
  661. ->where([
  662. ['is_del', '=', 0],
  663. ['orderCode', 'in', array_column($out, 'orderCode')]
  664. ])->column('is_stock', 'orderCode');
  665. foreach ($out as $k => $v_outCode) {
  666. \app\admin\model\OrderOutChild::makeChild($v_outCode['outCode']);
  667. //修改状态,添加待办
  668. ActionLog::logAdd(['id' => $uid, 'nickname' => $nickname], [
  669. "order_code" => $v_outCode['outCode'],//出库单号
  670. "status" => 0,//这里的status是之前的值
  671. "action_remark" => '',//备注
  672. "action_type" => "status"//新建create,编辑edit,更改状态status
  673. ], "CKD", 1, $param);
  674. //库存品,推给库管和库管-张凯旋
  675. if ($is_stock[$v_outCode['orderCode']] == 1) {
  676. $roleid = config('app.wsm_cgder_role');
  677. $uids = Db::name('user_role')
  678. ->where('is_del', 0)
  679. ->whereIn('roleid', $roleid)
  680. ->column('uid');
  681. ProcessOrder::AddProcess(['id' => $uid, 'nickname' => $nickname], [
  682. "order_type" => 'CKD',
  683. "order_code" => $v_outCode['outCode'],//出库单号
  684. "order_id" => $v_outCode['id'],
  685. "order_status" => 1,
  686. "before_status" => 0,
  687. // 'wait_id' => $wait['personid'],
  688. // 'wait_name' => $wait['person'],
  689. // 'holder_id' => $wait['personid'],
  690. 'handle_user_list' => implode(',', $uids)
  691. ]);
  692. } else {
  693. //推给供应商负责人
  694. $wait = $supplier_cgderid[$cgdinfo[$cgdNo]['supplierNo']];
  695. ProcessOrder::AddProcess(['id' => $uid, 'nickname' => $nickname], [
  696. "order_type" => 'CKD',
  697. "order_code" => $v_outCode['outCode'],//出库单号
  698. "order_id" => $v_outCode['id'],
  699. "order_status" => 1,
  700. "before_status" => 0,
  701. 'wait_id' => $wait['personid'],
  702. 'wait_name' => $wait['person'],
  703. 'holder_id' => $wait['personid'],
  704. ]);
  705. }
  706. }
  707. }
  708. // $good1 = Db::name("good_stock")->where(["wsm_code" => $cgdinfo[$cgdNo]['wsm_code'], "spuCode" => $cgdinfo[$cgdNo]['spuCode'], "is_del" => 0])->find();
  709. // if ($good1 == false) throw new Exception('未找到对应商品库存');
  710. // $out_num = intval(array_sum(array_column($out, "send_num")));
  711. // if ($out_num > $good1['usable_stock']) throw new Exception('库存数量不足发货');
  712. //
  713. // $good1['usable_stock'] -= $out_num;
  714. // $good1['wait_out_stock'] += $out_num;
  715. // $good1['total_stock'] = $good1['usable_stock'] + $good1['wait_out_stock'];
  716. // $good1['updatetime'] = date("Y-m-d H:i:s");
  717. // $upd = Db::name("good_stock")->save($good1);
  718. // if ($upd == false) throw new Exception('库存数量更新失败');
  719. //
  720. // $good_data[] = ['good_log_code' => $wsm_in_code, "stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1, 'stock' => $send_num, "stock_name" => "wait_out_stock"];
  721. // $good_data[] = ['good_log_code' => $wsm_in_code, "stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1, 'stock' => $send_num, "stock_name" => "usable_stock"];
  722. // GoodLog::LogAdd(['id' => $uid, 'nickname' => $nickname], $good_data, 'RKD');
  723. $sendp = Db::name("order_send")->where(["cgdNo" => $cgdNo, "outCode" => $send, "status" => 1])->save(["status" => 2]);
  724. if ($sendp == false) throw new Exception('库存发货失败');
  725. }
  726. }
  727. }
  728. ActionLog::logAdd(['id' => $uid, 'nickname' => $nickname], $order, "CGD", $cgdinfo[$cgdNo]['status'], $cgdinfo[$cgdNo]);
  729. $process = ["order_code" => $cgdNo, "order_id" => $cgdinfo[$cgdNo]['id'], "order_status" => $cgdinfo[$cgdNo]['status'], "order_type" => 'CGD', "before_status" => $order['status'], 'holder_id' => isset($supplier_cgderid[$cgdinfo[$cgdNo]['supplierNo']]['personid']) ? $supplier_cgderid[$cgdinfo[$cgdNo]['supplierNo']]['personid'] : 0];
  730. ProcessOrder::AddProcess(['id' => $uid, 'nickname' => $nickname], $process);
  731. // Db::commit();
  732. // return json_show(0, '商品入库成功', ["wsm_in_code" => $wsm_in_code]);
  733. } else throw new Exception('商品入库失败');
  734. //////////////////
  735. } else throw new Exception('新建入库单失败');
  736. }
  737. //维护原有采购单信息
  738. Db::name("purchease_order")
  739. ->whereIn('id', array_column($cgdinfo, 'id'))
  740. ->update([
  741. 'wsend_num' => 0,
  742. 'send_num' => Db::raw('good_num'),
  743. 'send_status' => 3,
  744. 'status' => 3,
  745. 'updatetime' => date("Y-m-d H:i:s"),
  746. ]);
  747. Db::commit();
  748. return json_show(0, '新建入库单成功');
  749. // $win = Db::name("purchease_in")->insert($orin, true);
  750. // if ($win) {
  751. // $sto = ["order_code" => $wsm_in_code, "status" => $status, "action_remark" => '', "action_type" => "edit"];
  752. // ActionLog::logAdd($this->post['token'], $sto, "RKD", $status, $this->post);
  753. // $process = ["order_code" => $wsm_in_code, "order_id" => $win, "order_status" => $status, "order_type" => 'RKD', "before_status" => $status];
  754. // ProcessOrder::AddProcess($this->post['token'], $process);
  755. // $order = ["order_code" => $cgdNo, "status" => $cgdinfo['status'], "action_remark" => '', "action_type" => "edit"];
  756. //维护台账信息
  757. // 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}'");
  758. // if ($status == 1) {
  759. // Db::commit();
  760. // return json_show(0, '新建成功', ["wsm_in_code" => $wsm_in_code]);
  761. // }
  762. // if ($status == 4) {
  763. // $cgdinfo['wsend_num'] -= $send_num;
  764. // $cgdinfo['send_num'] += $send_num;
  765. // $cgdinfo['send_status'] = $cgdinfo['wsend_num'] == 0 ? 3 : ($cgdinfo['send_num'] == 0 ? 1 : 2);
  766. // $cgdinfo['status'] = $cgdinfo['wsend_num'] == 0 ? 3 : ($cgdinfo['send_num'] == 0 ? 1 : 2);
  767. // $cgdinfo['updatetime'] = date("Y-m-d H:i:s");
  768. // $up = Db::name("purchease_order")->save($cgdinfo);
  769. // if ($up == false) {
  770. // Db::rollback();
  771. // return json_show(1004, "新建失败");
  772. // }
  773. // $good = Db::name("good_stock")
  774. // ->where(["wsm_code" => $cgdinfo['wsm_code'], "spuCode" => $cgdinfo['spuCode'], "is_del" => 0])
  775. // ->lock(true)
  776. // ->find();
  777. // if (empty($good)) {
  778. // $good = [
  779. // "spuCode" => $cgdinfo['spuCode'],
  780. // "wsm_code" => $cgdinfo['wsm_code'],
  781. // "usable_stock" => 0,
  782. // "wait_out_stock" => 0,
  783. // "wait_in_stock" => $send_num,
  784. // "total_stock" => 0,
  785. // "addtime" => date("Y-m-d H:i:s"),
  786. // "updatetime" => date("Y-m-d H:i:s"),
  787. // ];
  788. // // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  789. // // "action_type"=>"create"];
  790. // } else {
  791. // // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  792. // // "action_type"=>"edit"];
  793. // }
  794. // $good['wait_in_stock'] -= $send_num;
  795. // if ($good['presale_stock'] > 0) {
  796. // if ($good['presale_stock'] >= $send_num) {
  797. // $good['presale_stock'] -= $send_num;
  798. // $good['wait_out_stock'] += $send_num;
  799. // } else {
  800. // $good['presale_stock'] = 0;
  801. // $good['usable_stock'] += $send_num - $good['presale_stock'];
  802. // $good['wait_out_stock'] += $good['presale_stock'];
  803. // }
  804. // } else {
  805. // $good['usable_stock'] += $send_num;
  806. // }
  807. //
  808. // $good['total_stock'] = $good['usable_stock'] + $good['wait_out_stock'];
  809. // $good['updatetime'] = date("Y-m-d H:i:s");
  810. // $upd = Db::name("good_stock")->save($good);
  811. // //商品变动日志表,good_log_code字段存储采购单单号
  812. // $good_data[] = ['good_log_code' => $wsm_in_code, "stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1, 'stock' => $send_num, "stock_name" => "usable_stock"];
  813. // $good_data[] = ['good_log_code' => $wsm_in_code, "stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 2, 'stock' => $send_num, "stock_name" => "wait_in_stock"];
  814. // if ($upd) {
  815. // GoodLog::LogAdd($this->post['token'], $good_data, 'RKD');
  816. // if ($cgdinfo['order_type'] == 1) {
  817. // $bk = Db::name("order_bk")->where(['cgdNo' => $cgdinfo['cgdNo']])->find();
  818. // if ($bk == false) {
  819. // $bk = [
  820. // "cgdNo" => $cgdinfo['cgdNo'],
  821. // "spuCode" => $cgdinfo['spuCode'],
  822. // "companyNo" => $cgdinfo['companyNo'],
  823. // "total_num" => $send_num,
  824. // "merge_num" => 0,
  825. // "balance_num" => $send_num,
  826. // "status" => 1,
  827. // "is_del" => 0,
  828. // 'addtime' => date("Y-m-d H:i:s"),
  829. // "updatetime" => date("Y-m-d H:i:s")
  830. // ];
  831. // $upcgd = Db::name("order_bk")->save($bk);
  832. // } else {
  833. // $where = ['id' => $bk['id'], 'total_num' => $bk['total_num'], 'balance_num' => $bk['balance_num']];
  834. // $bk['balance_num'] += $send_num;
  835. // $bk['total_num'] += $send_num;
  836. // $bk['updatetime'] = date("Y-m-d H:i:s");
  837. // $upcgd = Db::name("order_bk")->where($where)->update($bk);
  838. // }
  839. //
  840. // if ($upcgd == false) {
  841. // Db::rollback();
  842. // return json_show(1004, "采购单数量更新失败");
  843. // }
  844. // }
  845. // if ($cgdinfo['send_status'] == 3 && $cgdinfo['order_type'] != 1) {
  846. // $send = Db::name("order_send")->where(["cgdNo" => $cgdNo, "status" => 1])->column("outCode");
  847. // if (!empty($send)) {
  848. // $out = Db::name("order_out")->where(["outCode" => $send, "status" => 0])->select()
  849. // ->toArray();
  850. // if (!empty($out)) {
  851. // $up = Db::name("order_out")->where(["outCode" => $send, "status" => 0])->update
  852. // (["status" => 1, 'wsm_code' => $cgdinfo['wsm_code'], "updatetime" => date('Y-m-d H:i:s')]);
  853. // if ($up == false) {
  854. // Db::rollback();
  855. // return json_show(1004, "出库单出库失败");
  856. // } else {
  857. // foreach ($out as $k => $v_outCode) {
  858. // //修改状态,添加待办
  859. // ActionLog::logAdd($this->post['token'], [
  860. // "order_code" => $v_outCode['outCode'],//出库单号
  861. // "status" => 0,//这里的status是之前的值
  862. // "action_remark" => '',//备注
  863. // "action_type" => "status"//新建create,编辑edit,更改状态status
  864. // ], "CKD", 1, $this->post);
  865. //
  866. // ProcessOrder::AddProcess($this->post['token'], [
  867. // "order_type" => 'CKD',
  868. // "order_code" => $v_outCode['outCode'],//出库单号
  869. // "order_id" => $v_outCode['id'],
  870. // "order_status" => 1, "before_status" => 0
  871. // ]);
  872. // }
  873. // }
  874. // $good1 = Db::name("good_stock")->where(["wsm_code" => $cgdinfo['wsm_code'], "spuCode" => $cgdinfo['spuCode'], "is_del" => 0])->find();
  875. // if ($good1 == false) {
  876. // Db::rollback();
  877. // return json_show(1004, "未找到对应商品库存");
  878. // }
  879. // $out_num = intval(array_sum(array_column($out, "send_num")));
  880. // if ($out_num > $good1['usable_stock']) {
  881. // Db::rollback();
  882. // return json_show(1004, "库存数量不足发货");
  883. // }
  884. // $good1['usable_stock'] -= $out_num;
  885. // $good1['wait_out_stock'] += $out_num;
  886. // $good1['total_stock'] = $good1['usable_stock'] + $good1['wait_out_stock'];
  887. // $good1['updatetime'] = date("Y-m-d H:i:s");
  888. // $upd = Db::name("good_stock")->save($good1);
  889. // if ($upd == false) {
  890. // Db::rollback();
  891. // return json_show(1004, "库存数量更新失败");
  892. // }
  893. // $good_data[] = ['good_log_code' => $wsm_in_code, "stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1, 'stock' => $send_num, "stock_name" => "wait_out_stock"];
  894. // $good_data[] = ['good_log_code' => $wsm_in_code, "stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1, 'stock' => $send_num, "stock_name" => "usable_stock"];
  895. // GoodLog::LogAdd($this->post['token'], $good_data, 'RKD');
  896. // $sendp = Db::name("order_send")->where(["cgdNo" => $cgdNo, "outCode" => $send, "status" => 1])->save(["status" => 2]);
  897. // if ($sendp == false) {
  898. // Db::rollback();
  899. // return json_show(1004, "库存发货失败");
  900. // }
  901. // }
  902. // }
  903. // }
  904. // ActionLog::logAdd($this->post['token'], $order, "CGD", $cgdinfo['status'], $cgdinfo);
  905. // $process = ["order_code" => $cgdNo, "order_id" => $cgdinfo['id'], "order_status" => $cgdinfo['status'], "order_type" => 'CGD', "before_status" => $order['status']];
  906. // ProcessOrder::AddProcess($this->post['token'], $process);
  907. // Db::commit();
  908. // return json_show(0, '商品入库成功', ["wsm_in_code" => $wsm_in_code]);
  909. // } else {
  910. // Db::rollback();
  911. // return json_show(1002, "商品入库失败");
  912. // }
  913. // }
  914. // Db::commit();
  915. // return json_show(0, '新建成功', ["wsm_in_code" => $wsm_in_code]);
  916. // }
  917. // Db::rollback();
  918. // return json_show(1004, "新建失败");
  919. } catch (Exception $e) {
  920. Db::rollback();
  921. return json_show(1004, $e->getMessage().'|'.$e->getFile().'|'.$e->getLine());
  922. }
  923. }
  924. public function info(){
  925. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  926. if($incode==""){
  927. return error_show(1004,"参数wsm_in_code 不为空");
  928. }
  929. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  930. if(empty($info)){
  931. return error_show(1004,"未找到数据");
  932. }
  933. $dom = Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],'is_del'=>0])->find();
  934. if($dom['order_type']==3|| $dom['order_type']==4){
  935. $goon = Db::name("good_zixun")->where(["spuCode"=>$dom['spuCode'],"is_del"=>0])->find();
  936. }else {
  937. $goon =Db::name('good_basic')->where(['spuCode'=>$dom['spuCode']])->find();
  938. }
  939. if(empty($goon)){
  940. return error_show(1002,"未找到商品数据");
  941. }
  942. $cat= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  943. $info['cgder']=$dom['cgder'];
  944. $info['spuCode']=$dom['spuCode'];
  945. $info['good_name']=$dom['good_name'];
  946. $info['skuCode']=$dom['skuCode'];
  947. $info['good_num']=$dom['good_num'];
  948. $info['good_price']=$dom['good_price'];
  949. $info['total_fee']=$dom['total_fee'];
  950. $info['diff_fee']=$dom['diff_fee'];
  951. $info['diff_weight']=$dom['diff_weight'];
  952. $info['gold_price']=$dom['gold_price'];
  953. $wsmcode = Db::name("warehouse_info")
  954. ->alias("a")
  955. // ->leftJoin("supplier b","a.supplierNo=b.code")
  956. ->leftJoin("warehouse_addr c","a.wsm_code=c.wsm_code and c.is_del=0")
  957. ->where(["a.wsm_code"=>$info['wsm_code']])
  958. ->field("a.name as wsm_name,a.contactor,a.contactor_name,a.supplierNo,c.wsm_name as wsm_contactor,c.wsm_mobile,c.wsm_addr,c.addr_code")
  959. ->find();
  960. $names = \app\admin\common\User::getIns()->handle('getCodeAndName',['code'=>$wsmcode['supplierNo']]);
  961. $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  962. $info['wsm_supplier'] =$names['data'][$wsmcode['supplierNo']]??'';
  963. $info['wsm_supplierNo'] =$wsmcode['supplierNo']??"";
  964. $info['wsm_contactor'] =isset($wsmcode['wsm_contactor']) ? $wsmcode['wsm_contactor']:"";
  965. $info['wsm_mobile'] =isset($wsmcode['wsm_mobile']) ? $wsmcode['wsm_mobile']:"";
  966. $info['addr_code'] =isset($wsmcode['addr_code']) ? $wsmcode['addr_code']:"";
  967. $info['wsm_addr'] =isset($wsmcode['addr_code']) ? GetAddr($wsmcode['addr_code']):"";
  968. $info['wsm_addr'].=isset($wsmcode['wsm_addr']) ? $wsmcode['wsm_addr']:"";
  969. $info['contactor'] =$wsmcode['contactor']??"";
  970. $info['contactor_name'] =$wsmcode['contactor_name']??"";
  971. $check = Db::name("purchease_info")->alias("a")->leftJoin("result_info b","a.error_code=b.result_code")->where
  972. (['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();
  973. $info['checkinfo']= $check;
  974. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  975. $return['return_contactor']=isset($return['return_contactor'])&&$return['return_contactor']!="" ?$return['return_contactor']:'';
  976. $return['return_addr']=isset($return['return_addr'])&&$return['return_addr']!="" ?$return['return_addr']:'';
  977. $return['return_mobile']=isset($return['return_mobile'])&&$return['return_mobile']!="" ?$return['return_mobile']:'';
  978. //以下字段临时补充到return中
  979. $return['wsm_in_code'] = $incode;
  980. $return['wsm_num'] = isset($return['wsm_num']) ? $return['wsm_num'] : 0;
  981. $return['reissue_num'] = isset($return['reissue_num']) ? $return['reissue_num'] : 0;
  982. $return['return_num'] = isset($return['return_num']) ? $return['return_num'] : 0;
  983. $return['contactor'] = $return['return_contactor'];
  984. $return['addr'] = $return['return_addr'];
  985. $return['mobile'] = $return['return_mobile'];
  986. $return['error_remark'] = isset($return['error_remark']) ? $return['error_remark'] : '';
  987. $return['remark'] = isset($return['remark']) ? $return['remark'] : '';
  988. $info['return']= $return;
  989. $info['can']=$cat;
  990. $info['company'] = '';
  991. if(isset($dom['companyNo'])&&$dom['companyNo']!=""){
  992. // $company = Db::name("business")->where(["companyNo"=>$dom['companyNo']])->find();
  993. $userCommon = \app\admin\common\User::getIns();
  994. $tmp = $userCommon->handle('getCodeAndName', ['code' => [$dom['companyNo']]]);
  995. $info['company'] = $tmp['data'][$dom['companyNo']]??'';
  996. }
  997. // $info['company'] = isset($company['company'])?$company['company']:"";
  998. $info['companyNo'] = isset($dom['companyNo'])?$dom['companyNo']:"";
  999. $info['order_type'] = isset($dom['order_type'])?$dom['order_type']:"";
  1000. return app_show(0,'获取成功',$info);
  1001. }
  1002. public function check(){
  1003. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  1004. if($incode==""){
  1005. return error_show(1004,"参数wsm_in_code 不为空");
  1006. }
  1007. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1008. if(empty($info)){
  1009. return error_show(1004,"未找到数据");
  1010. }
  1011. if($info['status']!=1){
  1012. return error_show(1004,"发货单状态有误");
  1013. }
  1014. $order_num = isset($this->post['order_num']) && $this->post['order_num']!==''?intval($this->post['order_num'])
  1015. :"";
  1016. if($order_num===""){
  1017. return error_show(1004,"参数 order_num 不为空");
  1018. }
  1019. $error_list = isset($this->post['error_list']) && $this->post['error_list']!==''?$this->post['error_list']:"";
  1020. Db::startTrans();
  1021. try{
  1022. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  1023. $info['wsm_num'] = $order_num;
  1024. $info['wait_num'] = $info['send_num'];
  1025. $info['checkid'] = $this->uid;
  1026. $info['check_name'] = $this->uname;
  1027. $info['status'] =2;
  1028. $info['error_num'] = $info['send_num']-$order_num;
  1029. $info['updatetime'] = date("Y-m-d H:i:s");
  1030. $up =Db::name("purchease_in")->save($info);
  1031. if($up){
  1032. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"RKD",2,$this->post);
  1033. $uid = Db::name('user_role')
  1034. ->where([
  1035. ['is_del', '=', 0],
  1036. ['roleid', 'in', [31, 41]],
  1037. ['status', '=', 1]
  1038. ])->column('uid');
  1039. $handle_user_list = implode(',', $uid);
  1040. $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];
  1041. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  1042. if(!empty($error_list)){
  1043. $data=[];
  1044. foreach ($error_list as $value ){
  1045. $temp=[];
  1046. $temp['wsm_in_code']=$info['wsm_in_code'];
  1047. $temp['num']=$value['num'];
  1048. $temp['error_code']=$value['error_code'];
  1049. $temp['error_img']=$value['error_img'];
  1050. $temp['remark']=$value['remark'];
  1051. $temp['is_del']=0;
  1052. $temp['addtime']=date("Y-m-d H:i:s");
  1053. $temp['updatetime']=date("Y-m-d H:i:s");
  1054. $data[]=$temp;
  1055. }
  1056. $derr= Db::name("purchease_info")->insertAll($data);
  1057. if($derr){
  1058. Db::commit();
  1059. return app_show(0,"验货完成");
  1060. }else{
  1061. Db::rollback();
  1062. return error_show(1002,"验货数据保存失败");
  1063. }
  1064. }
  1065. Db::commit();
  1066. return app_show(0,"验货完成");
  1067. }
  1068. Db::rollback();
  1069. return error_show(1002,"验货数据保存失败");
  1070. }catch (\Exception $e){
  1071. Db::rollback();
  1072. return error_show(1002,$e->getMessage());
  1073. }
  1074. }
  1075. public function status(){
  1076. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  1077. if($incode==""){
  1078. return error_show(1004,"参数wsm_in_code 不为空");
  1079. }
  1080. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1081. if(empty($info)){
  1082. return error_show(1004,"未找到数据");
  1083. }
  1084. $status = isset($this->post['status'])&&$this->post['status']!=="" ? intval($this->post['status']):"";
  1085. if($status===""){
  1086. return error_show(1004,"参数status 不为空");
  1087. }
  1088. if($info['status']==4){
  1089. return error_show(1004,"入库单已完成");
  1090. }
  1091. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  1092. if(empty($cgdinfo)){
  1093. return error_show(1002,"未找到采购单数据");
  1094. }
  1095. $remark = isset($this->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']) :"";
  1096. $userCommon= \app\admin\common\User::getIns();
  1097. $supplier_temp =$userCommon->handle("sInfo",["code"=>$cgdinfo['supplierNo']]);
  1098. if($supplier_temp['code']!=0 || empty($supplier_temp['data']) ) return error_show(1002,"采购单供应商不存在");
  1099. $holder_id=$supplier_temp['data']['personid']??0;
  1100. Db::startTrans();
  1101. try{
  1102. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"status"];
  1103. $info['status'] = $status;
  1104. $info['remark'] = $remark;
  1105. $info['updatetime'] = date("Y-m-d H:i:s");
  1106. $update = Db::name("purchease_in")->save($info);
  1107. if($update){
  1108. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"RKD",$status,$this->post);
  1109. $uid = Db::name('user_role')
  1110. ->where([
  1111. ['is_del', '=', 0],
  1112. ['roleid', 'in', [31, 41]],
  1113. ['status', '=', 1]
  1114. ])->column('uid');
  1115. $handle_user_list = implode(',', $uid);
  1116. $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];
  1117. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  1118. if($status==0){
  1119. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  1120. $cgdinfo['wsend_num']+=$info['send_num'];
  1121. $cgdinfo['send_num']-=$info['send_num'];
  1122. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1123. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1124. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  1125. $up=Db::name("purchease_order")->save($cgdinfo);
  1126. if($up){
  1127. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  1128. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  1129. // $orderinfo = Db::name('sale')
  1130. // ->alias('a')
  1131. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  1132. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  1133. // ->where([
  1134. // 'a.is_del'=>0,
  1135. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  1136. // ])->findOrEmpty();
  1137. $is_stock = Db::name('good_basic')
  1138. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  1139. ->value('is_stock');
  1140. if($is_stock==1){
  1141. //库存品,推给31库管人员、41库管-张凯旋
  1142. $uid = Db::name('user_role')
  1143. ->where([
  1144. ['is_del', '=', 0],
  1145. ['roleid', 'in', [31, 41]],
  1146. ['status', '=', 1]
  1147. ])->column('uid');
  1148. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  1149. $handle_user_list=implode(",",$uid);
  1150. // $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)];
  1151. }else{
  1152. //$holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1153. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  1154. //$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];
  1155. }//非库存品和采返商品,推给供应商负责人
  1156. }//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)];
  1157. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];
  1158. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $process);
  1159. Db::commit();
  1160. return app_show(0,'取消成功');
  1161. }else{
  1162. Db::rollback();
  1163. return error_show(1002,"取消失败");
  1164. }
  1165. }
  1166. if($status==1){
  1167. // $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  1168. // if(empty($cgdinfo)){
  1169. // Db::rollback();
  1170. // return error_show(1002,"未找到采购单数据");
  1171. // }
  1172. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  1173. $cgdinfo['wsend_num']-=$info['send_num'];
  1174. $cgdinfo['send_num']+=$info['send_num'];
  1175. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1176. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1177. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  1178. $up=Db::name("purchease_order")->save($cgdinfo);
  1179. if($up){
  1180. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  1181. // $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1182. if($cgdinfo['status'] == 1 || $cgdinfo['status']==2){
  1183. // $orderinfo = Db::name('sale')
  1184. // ->alias('a')
  1185. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  1186. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  1187. // ->where([
  1188. // 'a.is_del'=>0,
  1189. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  1190. // ])->findOrEmpty();
  1191. $is_stock = Db::name('good_basic')
  1192. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  1193. ->value('is_stock');
  1194. if($is_stock==1){
  1195. //库存品,推给31库管人员、41库管-张凯旋
  1196. $uid = Db::name('user_role')
  1197. ->where([
  1198. ['is_del', '=', 0],
  1199. ['roleid', 'in', [31, 41]],
  1200. ['status', '=', 1]
  1201. ])->column('uid');
  1202. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  1203. $handle_user_list = implode(",",$uid);
  1204. // $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)];
  1205. }elseif ($is_stock==0 || $cgdinfo['order_type']==3) {
  1206. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  1207. // $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];
  1208. }//非库存品和采返商品,推给供应商负责人
  1209. }//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)];
  1210. $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(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  1211. Db::commit();
  1212. return app_show(0,'发货成功');
  1213. }else{
  1214. Db::rollback();
  1215. return error_show(1002,"发货失败");
  1216. }
  1217. }
  1218. if($status==4){
  1219. // $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  1220. // if(empty($cgdinfo)){
  1221. // Db::rollback();
  1222. // return error_show(1002,"未找到采购单数据");
  1223. // }
  1224. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  1225. $cgdinfo['wsend_num']-=$info['send_num'];
  1226. $cgdinfo['send_num']+=$info['send_num'];
  1227. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1228. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1229. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  1230. $up=Db::name("purchease_order")->save($cgdinfo);
  1231. if($up==false){
  1232. Db::rollback();
  1233. return error_show(1002,"发货失败");
  1234. }
  1235. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  1236. // $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1237. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  1238. // $orderinfo = Db::name('sale')
  1239. // ->alias('a')
  1240. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  1241. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  1242. // ->where([
  1243. // 'a.is_del'=>0,
  1244. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  1245. // ])->findOrEmpty();
  1246. $is_stock = Db::name('good_basic')
  1247. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  1248. ->value('is_stock');
  1249. if($is_stock==1){
  1250. //库存品,推给31库管人员、41库管-张凯旋
  1251. $uid = Db::name('user_role')
  1252. ->where([
  1253. ['is_del', '=', 0],
  1254. ['roleid', 'in', [31, 41]],
  1255. ['status', '=', 1]
  1256. ])->column('uid');
  1257. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  1258. // $holder_id = implode(",",$uid);
  1259. // $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)];
  1260. }else{
  1261. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  1262. // $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];
  1263. }//非库存品和采返商品,推给供应商负责人
  1264. }//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)];
  1265. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];
  1266. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  1267. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  1268. if(empty($good)) {
  1269. $good=[
  1270. "spuCode"=>$cgdinfo['spuCode'],
  1271. "wsm_code"=>$info['wsm_code'],
  1272. "usable_stock"=>0,
  1273. "wait_out_stock"=>0,
  1274. "wait_in_stock"=>$info['wsm_num'],
  1275. "total_stock"=>0,
  1276. "addtime"=>date("Y-m-d H:i:s"),
  1277. "updatetime"=>date("Y-m-d H:i:s"),
  1278. ];
  1279. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  1280. "action_type"=>"create"];
  1281. }else{
  1282. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  1283. }
  1284. $good['wait_in_stock']-=$info['wsm_num'];
  1285. $good['usable_stock']+=$info['wsm_num'];
  1286. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  1287. $good['updatetime'] = date("Y-m-d H:i:s");
  1288. $upd= Db::name("good_stock")->save($good);
  1289. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  1290. //商品变动日志表,good_log_code字段存储入库单编号
  1291. $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"];
  1292. $good_data[] = ['good_log_code' => $incode, "stock_id" => isset($good['id']) ? $good['id'] :
  1293. Db::name("good_stock")->getLastInsID(), "type" => 2, 'stock' => $info['wsm_num'], "stock_name" => "wait_in_stock"];
  1294. if($upd){
  1295. $bnin=GoodStockInfo::AddBn($stockid,$info['bnCode'],$info['wsm_num'],$cgdinfo['good_price']);
  1296. if($bnin==false){
  1297. Db::rollback();
  1298. return error_show(1004,"库存bn数据新增失败");
  1299. }
  1300. GoodLog::LogAdd(['id'=>$this->uid,'nickname'=>$this->uname],$good_data,'RKD');
  1301. Db::commit();
  1302. return app_show(0,'商品入库成功');
  1303. }else{
  1304. Db::rollback();
  1305. return error_show(1002,"商品入库失败");
  1306. }
  1307. }
  1308. Db::commit();
  1309. return app_show(0,"状态修改完成");
  1310. }
  1311. Db::rollback();
  1312. return error_show(1002,"状态修改失败");
  1313. }catch (\Exception $e){
  1314. Db::rollback();
  1315. return error_show(1002,$e->getMessage());
  1316. }
  1317. }
  1318. /** 0代发货 1库管验货 2仓库主管审核 3 采购审核 4 入库完成 5填写物流 6 退货完成
  1319. /** 0代发货 1待库管验货 2入库完成
  1320. * @return \think\response\Json|void
  1321. * @throws \think\db\exception\DataNotFoundException
  1322. * @throws \think\db\exception\DbException
  1323. * @throws \think\db\exception\ModelNotFoundException
  1324. */
  1325. public function ReturnAdd(){
  1326. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  1327. if($incode==""){
  1328. return error_show(1004,"参数wsm_in_code 不为空");
  1329. }
  1330. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1331. if(empty($info)){
  1332. return error_show(1004,"未找到数据");
  1333. }
  1334. //正常入库数量
  1335. $wsm_num = isset($this->post['wsm_num']) &&$this->post['wsm_num']!=="" ? intval($this->post['wsm_num']):"" ;
  1336. if($wsm_num===""){
  1337. return error_show(1004,"参数wsm_num 不为空");
  1338. }
  1339. //补货数量
  1340. $reissue_num = isset($this->post['reissue_num']) &&$this->post['reissue_num']!=="" ? intval($this->post['reissue_num']):"0" ;
  1341. //退货数量
  1342. $return_num = isset($this->post['return_num']) &&$this->post['return_num']!=="" ? intval($this->post['return_num']):"0" ;
  1343. $contactor = isset($this->post['contactor']) &&$this->post['contactor']!=="" ? trim($this->post['contactor']):"" ;
  1344. if($contactor==""){
  1345. return error_show(1004,"参数contactor 不为空");
  1346. }
  1347. $addr = isset($this->post['addr']) &&$this->post['addr']!=="" ? trim($this->post['addr']):"" ;
  1348. if($addr==""){
  1349. return error_show(1004,"参数addr 不为空");
  1350. }
  1351. $mobile = isset($this->post['mobile']) &&$this->post['mobile']!=="" ? trim($this->post['mobile']):"" ;
  1352. if($mobile==""){
  1353. return error_show(1004,"参数mobile 不为空");
  1354. }
  1355. $error_remark = isset($this->post['error_remark']) &&$this->post['error_remark']!=="" ? trim($this->post['error_remark']):"" ;
  1356. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  1357. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  1358. if(empty($cgdinfo)){
  1359. return error_show(1002,"未找到采购单数据");
  1360. }
  1361. $userCommon= \app\admin\common\User::getIns();
  1362. $supplier_temp =$userCommon->handle("sInfo",["code"=>$cgdinfo['supplierNo']]);
  1363. if($supplier_temp['code']!=0 || empty($supplier_temp['data']) ) return error_show(1002,"采购单供应商不存在");
  1364. $holder_id=$supplier_temp['data']['personid']??0;
  1365. Db::startTrans();
  1366. try{
  1367. $sto = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  1368. $info['status'] = $info['send_num'] == $wsm_num ? 4 : 5;//艳蓉说,这里不能用入库数量比较,应该是用入库数量,即总数来比较
  1369. $info['is_th'] =$return_num>0 ?1:0;
  1370. $info['wsm_num']= $wsm_num;
  1371. $info['updatetime'] = date("Y-m-d H:i:s");
  1372. $up= Db::name("purchease_in")->save($info);
  1373. if($up){
  1374. //库存品,推给仓库对应的管理员
  1375. $uid = Db::name('warehouse_info')
  1376. ->where(['wsm_code' => $info['wsm_code'], 'is_del' => 0])
  1377. ->column('contactor');
  1378. $handle_user_list=implode(",",$uid);
  1379. if($info['status']==4){
  1380. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  1381. $cgdinfo['wsend_num']-=$info['send_num'];
  1382. $cgdinfo['send_num']+=$info['send_num'];
  1383. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1384. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1385. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  1386. $up=Db::name("purchease_order")->save($cgdinfo);
  1387. if($up==false){
  1388. Db::rollback();
  1389. return error_show(1002,"发货失败");
  1390. }
  1391. ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], $order, "CGD", $cgdinfo['status'], $cgdinfo);
  1392. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  1393. $is_stock = Db::name('good_basic')
  1394. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  1395. ->value('is_stock');
  1396. if($is_stock==1){
  1397. //库存品,推给仓库对应的负责人
  1398. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  1399. }else{
  1400. // $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1401. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  1402. // $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];
  1403. }//非库存品和采返商品,推给供应商负责人
  1404. }//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)];
  1405. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];
  1406. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname],$process);
  1407. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  1408. if(empty($good)) {
  1409. $good=[
  1410. "spuCode"=>$cgdinfo['spuCode'],
  1411. "wsm_code"=>$info['wsm_code'],
  1412. "usable_stock"=>0,
  1413. "wait_out_stock"=>0,
  1414. "wait_in_stock"=>$wsm_num,
  1415. "total_stock"=>0,
  1416. "addtime"=>date("Y-m-d H:i:s"),
  1417. "updatetime"=>date("Y-m-d H:i:s"),
  1418. ];
  1419. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  1420. "action_type"=>"create"];
  1421. }else{
  1422. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  1423. }
  1424. $good['wait_in_stock']-=$wsm_num;
  1425. $good['usable_stock']+=$wsm_num;
  1426. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  1427. $good['updatetime'] = date("Y-m-d H:i:s");
  1428. $upd= Db::name("good_stock")->save($good);
  1429. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  1430. if($upd){
  1431. $bnin=GoodStockInfo::AddBn($stockid,$info['bnCode'],$info['wsm_num'],$cgdinfo['good_price']);
  1432. if($bnin==false){
  1433. Db::rollback();
  1434. return error_show(1004,"库存bn数据新增失败");
  1435. }
  1436. }else{
  1437. Db::rollback();
  1438. return error_show(1002,"商品入库失败");
  1439. }
  1440. $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"];
  1441. $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"];
  1442. GoodLog::LogAdd(['id' => $this->uid, 'nickname' => $this->uname],$good_data,'RKD');
  1443. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  1444. if($bk==false){
  1445. $bk=[
  1446. "cgdNo"=>$cgdinfo['cgdNo'],
  1447. "spuCode"=>$cgdinfo['spuCode'],
  1448. "companyNo"=>$cgdinfo['companyNo'],
  1449. "total_num"=>0,
  1450. "merge_num"=>0,
  1451. "balance_num"=>0,
  1452. "status"=>1,
  1453. "is_del"=>0,
  1454. 'addtime'=>date("Y-m-d H:i:s"),
  1455. "updatetime"=>date("Y-m-d H:i:s")
  1456. ];
  1457. }
  1458. $bk['balance_num']+=$wsm_num;
  1459. $bk['total_num']+=$wsm_num;
  1460. $bk['updatetime']=date("Y-m-d H:i:s");
  1461. $upcgd =Db::name("order_bk")->save($bk);
  1462. if($upcgd==false){
  1463. Db::rollback();
  1464. return error_show(1004,"采购单数量更新失败");
  1465. }
  1466. }
  1467. ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname],$sto,"RKD", $info['status'],$this->post);
  1468. $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??""];
  1469. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname],$process);
  1470. //需要在详情页把相关退货记录原样取出来,所以这里把if去掉,所有记录都入purchease_return表
  1471. if($info['status']==5){
  1472. $returnCode=makeNo("CR");
  1473. $data=[
  1474. "returnCode"=>$returnCode,
  1475. "wsm_in_code"=>$incode,
  1476. "cgdNo"=>$cgdinfo['cgdNo'],
  1477. "wsm_num"=>$wsm_num,
  1478. "reissue_num"=>$reissue_num,
  1479. "return_num"=>$return_num,
  1480. "return_contactor"=>$contactor,
  1481. "return_addr"=>$addr,
  1482. "return_mobile"=>$mobile,
  1483. "error_remark"=>$error_remark,
  1484. "post_code"=>"",
  1485. "post_company"=>"",
  1486. "remark"=>$remark ,
  1487. "apply_id"=>$this->uid,
  1488. "apply_name"=>$this->uname,
  1489. "status"=>0,
  1490. "addtime"=>date("Y-m-d H:i:s"),
  1491. "updatetime"=>date("Y-m-d H:i:s")
  1492. ];
  1493. $res = Db::name("purchease_return")->insert($data,true);
  1494. if($res==false){
  1495. Db::rollback();
  1496. return error_show(1002,"验货审核失败");
  1497. }
  1498. $sto = ["order_code"=>$incode,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  1499. ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname],$sto,"RKTHD",0,$data);
  1500. //维护台账记录
  1501. // Db::name('standing_book')
  1502. // ->where('wsm_in_code', $incode)
  1503. // ->update([
  1504. // 'cgdReturnCode' => $returnCode,
  1505. // 'updatetime' => date('Y-m-d H:i:s'),
  1506. // ]);
  1507. 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可能有多个
  1508. }
  1509. Db::commit();
  1510. return app_show(0,"验货审核完成");
  1511. }
  1512. }catch (\Exception $e){
  1513. Db::rollback();
  1514. return error_show(1002,$e->getMessage());
  1515. }
  1516. }
  1517. public function ReturnSend(){
  1518. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  1519. if($incode==""){
  1520. return error_show(1004,"参数wsm_in_code 不为空");
  1521. }
  1522. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1523. if(empty($info)){
  1524. return error_show(1004,"未找到发货单数据");
  1525. }
  1526. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1527. if(empty($return)){
  1528. return error_show(1004,"未找到退货单数据");
  1529. }
  1530. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  1531. if(empty($cgdinfo)){
  1532. return error_show(1002,"未找到采购单数据");
  1533. }
  1534. $post_code = isset($this->post['post_code']) &&$this->post['post_code']!=="" ? trim($this->post['post_code']):"" ;
  1535. if($post_code==""){
  1536. return error_show(1004,"参数 post_code 不能为空");
  1537. }
  1538. $post_company = isset($this->post['post_company']) &&$this->post['post_company']!=="" ? trim($this->post['post_company']):"" ;
  1539. if($post_company==""){
  1540. return error_show(1004,"参数 post_company 不能为空");
  1541. }
  1542. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  1543. $data=[
  1544. "post_code"=>$post_code,
  1545. "post_company"=>$post_company,
  1546. "remark"=>$remark,
  1547. "status"=>1,
  1548. "updatetime"=>date("Y-m-d H:i:s")
  1549. ];
  1550. $userCommon= \app\admin\common\User::getIns();
  1551. $supplier_temp =$userCommon->handle("sInfo",["code"=>$cgdinfo['supplierNo']]);
  1552. if($supplier_temp['code']!=0 || empty($supplier_temp['data']) ) return error_show(1002,"采购单供应商不存在");
  1553. $holder_id=$supplier_temp['data']['personid']??0;
  1554. Db::startTrans();
  1555. try{
  1556. $up =Db::name("purchease_return")->where($return)->save($data);
  1557. if($up){
  1558. $sto = ["order_code"=>$info['wsm_in_code'],"status"=>$return['status'],"action_remark"=>'', "action_type"=>"edit"];
  1559. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$sto,"RKTHD",1,$this->post);
  1560. $ark=$info['status'];
  1561. $info['status']=6;
  1562. $info['updatetime']=date("Y-m-d H:i:s");
  1563. $sa=Db::name("purchease_in")->save($info);
  1564. if($sa){
  1565. $stn = ["order_code"=>$info['wsm_in_code'],"status"=>$ark,"action_remark"=>'',"action_type"=>"edit"];
  1566. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$stn,"RKD",6,$info);
  1567. // $uid = Db::name('user_role')
  1568. // ->where([
  1569. // ['is_del', '=', 0],
  1570. // ['roleid', 'in', [31, 41]],
  1571. // ['status', '=', 1]
  1572. // ])->column('uid');
  1573. //库管人员取仓库管理员
  1574. $uid = Db::name('warehouse_info')->where(['is_del'=>0,'wsm_code'=>$info['wsm_code']])->column('contactor');
  1575. $handle_user_list = implode(',', $uid);
  1576. $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];
  1577. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  1578. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  1579. if(empty($good)) {
  1580. $good=[
  1581. "spuCode"=>$cgdinfo['spuCode'],
  1582. "wsm_code"=>$info['wsm_code'],
  1583. "usable_stock"=>0,
  1584. "wait_out_stock"=>0,
  1585. "wait_in_stock"=>$return['wsm_num'],
  1586. "total_stock"=>0,
  1587. "addtime"=>date("Y-m-d H:i:s"),
  1588. "updatetime"=>date("Y-m-d H:i:s"),
  1589. ];
  1590. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',"action_type"=>"create"];
  1591. }else{
  1592. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  1593. }
  1594. $good['wait_in_stock']-=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1595. $good['usable_stock']+=$return['wsm_num'];
  1596. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  1597. $good['updatetime'] = date("Y-m-d H:i:s");
  1598. $upd= Db::name("good_stock")->save($good);
  1599. if($upd==false){
  1600. Db::rollback();
  1601. return error_show(1002,"库存更新失败");
  1602. }
  1603. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  1604. $bnin=GoodStockInfo::AddBn($stockid,$info['bnCode'],$return['wsm_num'],$cgdinfo['good_price']);
  1605. if($bnin==false){
  1606. Db::rollback();
  1607. return error_show(1004,"库存bn数据新增失败");
  1608. }
  1609. $good_data[]=['good_log_code' => $incode,"stock_id"=>$stockid,"type"=>1, 'stock'=>$info['wsm_num'],"stock_name"=>"usable_stock"];
  1610. $good_data[]=['good_log_code' => $incode,"stock_id"=>$stockid,"type"=>2, 'stock'=>$good['wait_in_stock'],"stock_name"=>"wait_in_stock"];
  1611. GoodLog::LogAdd(['id'=>$this->uid,'nickname'=>$this->uname],$good_data,'RKD');
  1612. $order = ["order_code"=>$cgdinfo['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  1613. $cgdinfo['wsend_num']-=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1614. $cgdinfo['send_num']+=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1615. $cgdinfo['th_num']+=$return['return_num']-$return['reissue_num'];
  1616. $cgdinfo['th_fee']=round(($return['return_num']-$return['reissue_num'])*$cgdinfo['good_price'],2);
  1617. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1618. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1619. if($cgdinfo['th_num']==$cgdinfo['send_num']&& $cgdinfo['wsend_num']==0){
  1620. $cgdinfo['status']=4;
  1621. }
  1622. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  1623. $up=Db::name("purchease_order")->save($cgdinfo);
  1624. if($up==false){
  1625. Db::rollback();
  1626. return error_show(1004,"采购单数量更新失败");
  1627. }
  1628. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  1629. if($bk==false){
  1630. $bk=[
  1631. "cgdNo"=>$cgdinfo['cgdNo'],
  1632. "spuCode"=>$cgdinfo['spuCode'],
  1633. "companyNo"=>$cgdinfo['companyNo'],
  1634. "total_num"=>0,
  1635. "merge_num"=>0,
  1636. "balance_num"=>0,
  1637. "status"=>1,
  1638. "is_del"=>0,
  1639. 'addtime'=>date("Y-m-d H:i:s"),
  1640. "updatetime"=>date("Y-m-d H:i:s")
  1641. ];
  1642. }
  1643. $bk['balance_num']+=$return['wsm_num'];
  1644. $bk['total_num']+=$return['wsm_num'];
  1645. $bk['updatetime']=date("Y-m-d H:i:s");
  1646. $upcgd =Db::name("order_bk")->save($bk);
  1647. if($upcgd==false){
  1648. Db::rollback();
  1649. return error_show(1004,"采购单数量更新失败");
  1650. }
  1651. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  1652. // $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1653. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  1654. // $orderinfo = Db::name('sale')
  1655. // ->alias('a')
  1656. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  1657. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  1658. // ->where([
  1659. // 'a.is_del'=>0,
  1660. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  1661. // ])->findOrEmpty();
  1662. $is_stock = Db::name('good_basic')
  1663. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  1664. ->value('is_stock');
  1665. if($is_stock==1){
  1666. //库存品,推给31库管人员、41库管-张凯旋
  1667. // $uid = Db::name('user_role')
  1668. // ->where([
  1669. // ['is_del', '=', 0],
  1670. // ['roleid', 'in', [31, 41]],
  1671. // ['status', '=', 1]
  1672. // ])->column('uid');
  1673. if(!in_array($this->uid,$uid)) throw new Exception('库存品订单只能由库管人员操作');
  1674. // $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)];
  1675. // $handle_user_list = implode(",",$uid);
  1676. }else{
  1677. // $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1678. if($this->uid != $holder_id)throw new Exception('非库存品和采返商品只能由供应商负责人操作');
  1679. // $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];//非库存品和采返商品,推给供应商负责人
  1680. }
  1681. }//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)];
  1682. $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id];//非库存品和采返商品,推给供应商负责人
  1683. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  1684. Db::commit();
  1685. return app_show(0,"退货发货成功");
  1686. }else{
  1687. Db::rollback();
  1688. return error_show(1004,"退货发货失败");
  1689. }
  1690. }else{
  1691. return error_show(1004,"退货发货失败");
  1692. }
  1693. }catch (\Exception $e){
  1694. Db::rollback();
  1695. return error_show(1004,$e->getMessage());
  1696. }
  1697. }
  1698. public function returnList(){
  1699. $page = isset($this->post['page']) && $this->post['page'] !=="" ? intval($this->post['page']):"1";
  1700. $size = isset($this->post['size']) && $this->post['size'] !=="" ? intval($this->post['size']):"10";
  1701. $where = [['a.is_del',"=",0],['b.is_del',"=",0]];
  1702. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!="" ? trim($this->post['cgdNo']):"";
  1703. if($cgdNo!=""){
  1704. $where[]=['a.cgdNo',"like", "%$cgdNo%"];
  1705. }
  1706. $returnCode= isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
  1707. if($returnCode!=""){
  1708. $where[]=['a.returnCode',"like", "%$returnCode%"];
  1709. }
  1710. $good_type_code=isset($this->post['good_type_code']) && $this->post['good_type_code']!==""? trim($this->post['good_type_code']):"";
  1711. if($good_type_code !=""){
  1712. $where[]= ["b.spuCode",'like',"%$good_type_code%"];
  1713. }
  1714. $good_name=isset($this->post['good_name']) && $this->post['good_name']!==""? trim($this->post['good_name']):"";
  1715. if($good_name !=""){
  1716. $where[]= ["b.good_name",'like',"%$good_name%"];
  1717. }
  1718. $status=isset($this->post['status']) && $this->post['status']!==""? trim($this->post['status']):"";
  1719. if($status!=""){
  1720. $where[]= ["a.status",'=',$status];
  1721. }
  1722. $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo']!="" ? trim($this->post['relaComNo']):"";
  1723. if($relaComNo!='') $where[]=['b.companyNo','=', $relaComNo];
  1724. $supplierNo = isset($this->post['supplierNo']) && $this->post['supplierNo'] != "" ? trim($this->post['supplierNo']) : "";
  1725. if ($supplierNo != '') $where[] = ['b.supplierNo', '=', $supplierNo];
  1726. $order_source = isset($this->post['order_source']) && $this->post['order_source'] != "" ? intval($this->post['order_source']) : "";
  1727. if ($order_source != '') $where[] = ['b.order_source', '=', $order_source];
  1728. $order_type = isset($this->post['order_type']) && $this->post['order_type'] != "" ? intval($this->post['order_type']) : "";
  1729. if ($order_type !== '') $where[] = ['b.order_type', '=', $order_type];
  1730. // $role = $this->checkDataShare();
  1731. // if (!empty($role[DataGroupModel::$type_全部])) $where[] = ["a.apply_id", "in", $role[DataGroupModel::$type_全部]];
  1732. //只有level2的账号过滤数据权限
  1733. if ($this->level == 2) {
  1734. $role = $this->checkDataShare();
  1735. $hand = resign_hand_user($this->uid, 0);
  1736. if (!empty($role[DataGroupModel::$type_全部])) {
  1737. $arr = array_unique(array_merge($hand, $role[DataGroupModel::$type_全部]));
  1738. $where[] = ['a.apply_id', 'in', $arr];
  1739. }
  1740. }
  1741. $count = Db::name('purchease_return')
  1742. ->alias('a')
  1743. ->leftJoin("purchease_order b","b.cgdNo=a.cgdNo")
  1744. ->leftJoin("good_basic c","c.spuCode=b.spuCode")
  1745. ->where($where)
  1746. ->count();
  1747. $total = ceil($count / $size);
  1748. $page = $page >= $total ? $total : $page;
  1749. $list = Db::name('purchease_return')
  1750. ->alias('a')
  1751. ->leftJoin("purchease_order b","b.cgdNo=a.cgdNo")
  1752. ->leftJoin("good_basic c","c.spuCode=b.spuCode")
  1753. ->where($where)
  1754. ->page($page,$size)
  1755. ->field("a.*,b.spuCode,b.good_price,b.order_type,b.good_price,b.total_fee,b.good_name,b.order_source,c.is_stock,b.supplierNo,b.supplier_name,b.companyNo,b.companyName")
  1756. ->order("a.addtime desc")
  1757. ->select()
  1758. ->toArray();
  1759. $data=[];
  1760. // $userCommon = \app\admin\common\User::getIns();
  1761. // $names = $userCommon->handle('getCodeAndName',['code'=>array_unique(array_column($list,'companyNo'))]);
  1762. //校验是否开通了供应商账号
  1763. $supp_account = checkHasAccountBySupplierNos(array_unique(array_column($list,'supplierNo')));
  1764. foreach ($list as $value){
  1765. if (in_array($value['order_type'], [3, 4])) {
  1766. $goon = Db::name("good_zixun")->field('cat_id')->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->find();
  1767. }else {
  1768. $goon =Db::name('good_basic')->field('cat_id')->where(['spuCode'=>$value['spuCode']])->find();
  1769. }
  1770. $value['can']= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  1771. $value['return_fee']= round($value['good_price']*$value['return_num'],2);
  1772. $value['has_account'] = (int)isset($supp_account[$value['supplierNo']]);
  1773. $data[]=$value;
  1774. }
  1775. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  1776. }
  1777. //库管验货 0待发货 1 待验货 2验货完成
  1778. public function checkOrder(){
  1779. $post =$this->request->only(["wsm_in_code"=>"","wsm_num"=>0],"post","trim");
  1780. $valide= Validate::rule([
  1781. "wsm_in_code|入库单号"=>"require|max:255",
  1782. "wsm_num|入库数量"=>"require|number"
  1783. ]);
  1784. if($valide->check($post)==false)return error_show(1004,$valide->getError());
  1785. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$post['wsm_in_code'],"is_del"=>0])->findOrEmpty();
  1786. if(empty($info)) return error_show(1004,"未找到入库单数据");
  1787. if($info['status']!=1) return error_show(1004,"入库单状态有误");
  1788. if($info['send_num'] <$post['wsm_num'])return error_show(1004,"入库数量不可大于发货单总数量");
  1789. $cgdinfo = Db::name("purchease_order")->where(["cgdNo"=>$info['cgdNo'],"is_del"=>0])->findOrEmpty();
  1790. if(empty($cgdinfo)) return error_show(1004,"未找到采购单信息");
  1791. if ($cgdinfo['order_type'] == 1) {
  1792. //库存品,只能由仓库管理员操作
  1793. $contactor = Db::name('warehouse_info')->where(['is_del' => 0, 'wsm_code' => $info['wsm_code']])->value('contactor', 0);
  1794. if ($this->uid != $contactor) return json_show(1004, '库存品只能由仓库管理员操作');
  1795. }
  1796. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->findOrEmpty();
  1797. if(empty($good)) {
  1798. $good=[
  1799. "spuCode"=>$cgdinfo['spuCode'],
  1800. "wsm_code"=>$info['wsm_code'],
  1801. "usable_stock"=>0,
  1802. "wait_out_stock"=>0,
  1803. "wait_in_stock"=>$cgdinfo['wsend_num'],
  1804. "total_stock"=>0,
  1805. "addtime"=>date("Y-m-d H:i:s"),
  1806. "updatetime"=>date("Y-m-d H:i:s"),
  1807. ];
  1808. }
  1809. Db::startTrans();
  1810. try{
  1811. $upsend=[
  1812. "wsm_num"=>$post['wsm_num'],
  1813. "error_num"=>$info['send_num'] - $post['wsm_num'],
  1814. "checkid"=>$this->uid,
  1815. "check_name"=>$this->uname,
  1816. "status"=>2,
  1817. "updatetime"=>date("Y-m-d H:i:s")
  1818. ];
  1819. $up=Db::name("purchease_in")->where($info)->update($upsend);
  1820. if($up==false) throw new \Exception("入库失败");
  1821. $order = ["order_code"=>$post['wsm_in_code'],"status"=>2,"action_remark"=>'',"action_type"=>"status"];
  1822. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"RKD", $info['status'], $info);
  1823. $cgdstatus=$cgdinfo['status'];
  1824. $cgdinfo['wsend_num']-=$info['send_num'];
  1825. $cgdinfo['send_num']+=$info['send_num'];
  1826. $cgdinfo['th_num']+=$info['send_num'] - $post['wsm_num'];
  1827. $cgdinfo['th_fee']= round($cgdinfo['th_num']*$cgdinfo['good_price'],2);
  1828. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1829. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1830. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  1831. $upOrder=Db::name("purchease_order")->save($cgdinfo);
  1832. if($upOrder==false)throw new \Exception("入库失败");
  1833. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"status"];
  1834. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"RKD",$cgdstatus, $cgdinfo);
  1835. $good['wait_in_stock']-=$info['send_num'];
  1836. $good['usable_stock']+=$post['wsm_num'];
  1837. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  1838. $good['updatetime'] = date("Y-m-d H:i:s");
  1839. $upstock = Db::name("good_stock")->save($good);
  1840. if($upstock==false) throw new \Exception("库存更新失败");
  1841. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  1842. $buadd= GoodStockInfo::AddBn($stockid,$info['bnCode'],$post['wsm_num'],$cgdinfo['good_price']);
  1843. if($buadd==false) throw new \Exception("库存bn更新失败");
  1844. //商品表里的'可用总库存数'增加
  1845. $isGood= Db::name('good')->where(['is_del' => 0, 'spuCode' => $cgdinfo['spuCode']])->findOrEmpty();
  1846. if(!empty($isGood)){
  1847. $upgood = Db::name('good')
  1848. ->data(['updatetime' => date('Y-m-d H:i:s')])
  1849. ->where(['is_del' => 0, 'spuCode' => $cgdinfo['spuCode']])
  1850. ->inc('usable_stock', $post['wsm_num'])
  1851. ->update();
  1852. if($upgood ==false) throw new \Exception("商品库存更新失败");
  1853. }
  1854. if($upsend['error_num']>0){
  1855. $returnCode=makeNo("CR");
  1856. $data=[
  1857. "returnCode"=>$returnCode,
  1858. "wsm_in_code"=>$post['wsm_in_code'],
  1859. "cgdNo"=>$cgdinfo['cgdNo'],
  1860. "wsm_num"=>$post['wsm_num'],
  1861. "reissue_num"=>0,
  1862. "return_num"=>$upsend['error_num'],
  1863. "return_contactor"=>'',
  1864. "return_addr"=>'',
  1865. "return_mobile"=>'',
  1866. "error_remark"=>'',
  1867. "post_code"=>"",
  1868. "post_company"=>"",
  1869. "remark"=>'' ,
  1870. "apply_id"=>$this->uid,
  1871. "apply_name"=>$this->uname,
  1872. "status"=>0,
  1873. "addtime"=>date("Y-m-d H:i:s"),
  1874. "updatetime"=>date("Y-m-d H:i:s")
  1875. ];
  1876. $res = Db::name("purchease_return")->insert($data);
  1877. if($res==false) throw new \Exception("退货单生成失败");
  1878. }
  1879. Db::commit();
  1880. return app_show(0,"验货入库完成");
  1881. }catch (\Exception $exception){
  1882. Db::rollback();
  1883. return error_show(1004,$exception->getMessage());
  1884. }
  1885. }
  1886. }