Activity.php 39 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\common\Ocr;
  4. use app\admin\model\ActionLog;
  5. use app\admin\model\DataGroup as DataGroupModel;
  6. use app\admin\model\GoodTax;
  7. use app\admin\model\GoodZixun;
  8. use app\admin\model\OrderTax;
  9. use app\admin\model\ProcessOrder;
  10. use app\BaseController;
  11. use app\model\TaxCategory;use think\App;
  12. use think\facade\Db;use think\facade\Validate;
  13. class Activity extends Base
  14. {
  15. public $noble=[];
  16. public function __construct(App $app)
  17. {
  18. parent::__construct($app);
  19. $this->noble=\think\facade\Config::get("noble");
  20. }
  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 = [["ga.is_del","=",0]];
  26. $activity_name = isset($this->post['activity_name']) && $this->post['activity_name'] !=="" ? trim($this->post['activity_name']):"";
  27. if($activity_name!=""){
  28. $where[]=['ga.activity_name',"like","%$activity_name%"];
  29. }
  30. $status = isset($this->post['status']) && $this->post['status'] !=="" ? intval($this->post['status']):"";
  31. if($status!==""){
  32. $where[]=['ga.status',"=",$status];
  33. }
  34. $activity_code = isset($this->post['activity_code']) && $this->post['activity_code'] !=="" ? trim($this->post['activity_code']):"";
  35. if($activity_code!==""){
  36. $where[]=['ga.activity_code',"like","%$activity_code%"];
  37. }
  38. $starttime = isset($this->post['starttime']) && $this->post['starttime']!=="" ? $this->post['starttime']:"";
  39. if($starttime!==""){
  40. $where[]=['ga.start',">=",date('Y-m-d H:i:s',strtotime($starttime))];
  41. }
  42. $endtime = isset($this->post['endtime']) && $this->post['endtime']!=="" ? $this->post['endtime']:"";
  43. if($endtime!==""){
  44. $where[]=['ga.end',"<",date('Y-m-d H:i:s',strtotime($endtime)+24*3600)];
  45. }
  46. $platform_code = isset($this->post['platform_code']) && $this->post['platform_code'] !=="" ? trim($this->post['platform_code']):"";
  47. if($platform_code!==""){
  48. $where[]=['ga.platform_code',"=",$platform_code];
  49. }
  50. $company_id = isset($this->post['company_id']) && $this->post['company_id'] !=="" ? trim($this->post['company_id']):"";
  51. if($company_id!==""){
  52. $where[]=['ga.company_id',"=",$company_id];
  53. }
  54. $creater = isset($this->post['creater']) && $this->post['creater'] !=="" ? trim($this->post['creater']) :"";
  55. if($creater!=""){
  56. $where[]=['ga.creater',"like","%$creater%"];
  57. }
  58. $createrid = isset($this->post['createrid']) && $this->post['createrid'] !=="" ? trim($this->post['createrid']) :"";
  59. if($createrid!==""){
  60. $where[]=['ga.createrid',"=",$createrid];
  61. }
  62. // $role=$this->checkRole();
  63. // if(!empty($role['write'])){
  64. // $where[]=["ga.createrid","in",$role['write']];
  65. // }
  66. // $role = $this->checkDataShare();
  67. // if (!empty($role[DataGroupModel::$type_全部])) $where[] = ['ga.createrid', 'in', $role[DataGroupModel::$type_全部]];
  68. $role = $this->checkDataShare();
  69. $hand = resign_hand_user($this->uid,0);
  70. if (!empty($role[DataGroupModel::$type_全部])) {
  71. $arr= array_unique(array_merge($hand,$role[DataGroupModel::$type_全部]));
  72. $where[] = ['ga.createrid', 'in',$arr];
  73. }
  74. $company_name = isset($this->post['company_name']) && $this->post['company_name'] !== "" ? trim($this->post['company_name']) : "";
  75. if ($company_name !== "") $where[] = ["ga.createrid", 'in', get_company_item_user_by_name($company_name)];
  76. $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo']!="" ? trim($this->post['relaComNo']):"";
  77. if($relaComNo!="") $where[]=['ga.company_id','=', $relaComNo];
  78. $count = Db::name('good_activity')
  79. ->alias('ga')
  80. ->leftJoin("platform p", "p.id=ga.platform_code")
  81. ->where($where)
  82. ->count();
  83. $total = ceil($count / $size);
  84. $page = $page >= $total ? $total : $page;
  85. $list = Db::name('good_activity')
  86. ->alias('ga')
  87. ->field('ga.*,ga.company_id companyNo,p.platform_name')
  88. ->leftJoin("platform p", "p.id=ga.platform_code")
  89. ->withAttr('is_allow_update',function($val,$data)use($role){
  90. return (in_array($this->roleid, [1, 33]) || in_array($data['createrid'], $role[DataGroupModel::$type_可编辑])) ? 1 : 0;//是否具有编辑权限
  91. })->where($where)
  92. ->page($page,$size)
  93. ->order("ga.addtime desc")
  94. ->select()
  95. ->toArray();
  96. $all_createrid = array_column($list,'createrid');
  97. $item = get_company_name_by_uid($all_createrid);
  98. $names = get_headquarters_code_and_name(array_unique(array_column($list,'companyNo')));
  99. foreach ($list as &$value){
  100. $value['company_name']=$item[$value['createrid']]??'';
  101. $value['companyName']=$names[$value['companyNo']]??'';
  102. }
  103. return app_show(0,"获取成功",['list'=>$list,'count'=>$count]);
  104. }
  105. //活动商品列表
  106. public function linst()
  107. {
  108. $page = isset($this->post['page']) && $this->post['page'] !== "" ? intval($this->post['page']) : "1";
  109. $size = isset($this->post['size']) && $this->post['size'] !== "" ? intval($this->post['size']) : "10";
  110. $where = [["a.is_del", "=", 0],["b.is_del", "=", 0]];
  111. $skuCode = isset($this->post['skuCode']) && $this->post['skuCode'] !== "" ? trim($this->post['skuCode']) : "";
  112. if ($skuCode !== "") {
  113. $where[] = ['a.skuCode', "like", "%$skuCode%"];
  114. }
  115. $good_name = isset($this->post['good_name']) && $this->post['good_name'] !== "" ? trim($this->post['good_name']) : "";
  116. if ($good_name != "") {
  117. $where[] = ['a.good_name', "like", "%$good_name%"];
  118. }
  119. $activity_code = isset($this->post['activity_code']) && $this->post['activity_code'] !=="" ? trim($this->post['activity_code']):"";
  120. if($activity_code!==""){
  121. $where[]=['a.activity_code',"like","%$activity_code%"];
  122. }
  123. $status = isset($this->post['status']) && $this->post['status'] !=="" ? intval($this->post['status']):"";
  124. if($status!==""){
  125. $where[]=['b.status',"=",$status];
  126. }
  127. $activity_name = isset($this->post['activity_name']) && $this->post['activity_name'] !=="" ? trim($this->post['activity_name']):"";
  128. if($activity_name!=""){
  129. $where[]=['b.activity_name',"like","%$activity_name%"];
  130. }
  131. $platform_code = isset($this->post['platform_code']) && $this->post['platform_code'] !=="" ? trim($this->post['platform_code']):"";
  132. if($platform_code!=""){
  133. $where[]=['b.platform_code',"=",$platform_code];
  134. }
  135. $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo']!="" ? trim($this->post['relaComNo']):"";
  136. if($relaComNo!="") $where[]=['b.company_id','=', $relaComNo];
  137. $count = Db::name('activity_info')->alias("a")
  138. ->join("good_activity b","b.activity_code=a.activity_code","left")
  139. ->join("platform c","c.id=b.platform_code","left")
  140. ->where($where)->count();
  141. $total = ceil($count / $size);
  142. $page = $page >= $total ? $total : $page;
  143. $list = Db::name('activity_info')
  144. ->alias("a")
  145. ->join("good_activity b","b.activity_code=a.activity_code","left")
  146. ->join("platform c","c.id=b.platform_code","left")
  147. ->where($where)
  148. ->page($page,$size)
  149. ->order("a.addtime desc")
  150. ->field("a.*,b.activity_name,c.platform_name,c.platform_code,b.company_id companyNo,b.status activity_status")
  151. ->select()
  152. ->toArray();
  153. $names = get_headquarters_code_and_name(array_column($list,'companyNo'));
  154. foreach ($list as &$value){
  155. $value['companyName'] = $names[$value['companyNo']] ?? '';
  156. }
  157. return app_show(0,"获取成功",['list'=>$list,'count'=>$count]);
  158. }
  159. public function zilist(){
  160. $page = isset($this->post['page']) && $this->post['page'] !== "" ? intval($this->post['page']) : "1";
  161. $size = isset($this->post['size']) && $this->post['size'] !== "" ? intval($this->post['size']) : "10";
  162. $where = [["a.is_del", "=", 0]];
  163. $spuCode = isset($this->post['spuCode']) && $this->post['spuCode'] !== "" ? trim($this->post['spuCode']) : "";
  164. if ($spuCode != "") $where[] = ['a.spuCode', "like", "%$spuCode%"];
  165. $good_name = isset($this->post['good_name']) && $this->post['good_name'] !== "" ? trim($this->post['good_name']) : "";
  166. if ($good_name != "") $where[] = ['a.good_name', "like", "%$good_name%"];
  167. $status = isset($this->post['status']) && $this->post['status'] !=="" ? intval($this->post['status']):"";
  168. if($status!="") $where[]=['a.status',"=",$status];
  169. $supplierNo = isset($this->post['supplierNo']) && $this->post['supplierNo'] !== "" ? trim($this->post['supplierNo']) : "";
  170. if ($supplierNo != "") $where[] = ['a.supplierNo', "like", "%$supplierNo%"];
  171. $name = isset($this->post['name']) && $this->post['name'] !== "" ? trim($this->post['name']) : "";
  172. if ($name != "") $where[] = ['a.supplierName', "like", "%$name%"];
  173. $start = isset($this->post['start']) && $this->post['start'] !== "" ? trim($this->post['start']) : "";
  174. if ($start != "") $where[] = ['a.addtime', ">=", $start];
  175. $end = isset($this->post['end']) && $this->post['end'] !== "" ? trim($this->post['end']) : "";
  176. if ($end != "") $where[] = ['a.addtime', "<=", $end.' 23:59:59'];
  177. $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo']!="" ? trim($this->post['relaComNo']):"";
  178. if($relaComNo!="") $where[]=['a.supplierNo|a.companyNo','=', $relaComNo];
  179. $orderSource= isset($this->post['order_source']) && $this->post['order_source']!='' ? $this->post['order_source']:[];
  180. if(!empty($orderSource)) $where[]=['a.order_source','in', $orderSource];
  181. $tax_status= isset($this->post['tax_status']) && $this->post['tax_status']!=='' ? $this->post['tax_status']:'';
  182. if($tax_status!==''){
  183. $where[] = ['b.status', '=', $tax_status==0?null :$tax_status];
  184. }
  185. $orderCode= isset($this->post['orderCode']) && $this->post['orderCode']!='' ? $this->post['orderCode']:'';
  186. if($orderCode!==''){
  187. $where[]=['a.spuCode',"=",\app\admin\model\Sale::where('orderCode','=',$orderCode)->value('good_code','')];
  188. }
  189. $count = Db::name('good_zixun')
  190. ->alias("a")
  191. ->leftJoin("good_tax b","a.spuCode=b.spuCode")
  192. ->where($where)
  193. ->count();
  194. $total = ceil($count / $size);
  195. $page = $page >= $total ? $total : $page;
  196. $list = Db::name('good_zixun')
  197. ->alias("a")
  198. ->leftJoin('good_tax b','a.spuCode=b.spuCode')
  199. ->where($where)
  200. ->page($page,$size)
  201. ->order("a.addtime desc")
  202. ->field("a.*,ifnull(b.status,0) tax_status")
  203. ->select()
  204. ->toArray();
  205. $all_platform_id = array_column($list,'platform_id');
  206. $all_platform = Db::name('platform')
  207. ->where(['is_del'=>0,'id'=>$all_platform_id])
  208. ->column('platform_name','id');
  209. $all_brand_id = array_column($list,'brand_id');
  210. $all_brand = Db::name('brand')
  211. ->where(['is_del'=>0,'id'=>$all_brand_id])
  212. ->column('brand_name','id');
  213. $all_good_unit = array_column($list,'good_unit');
  214. $all_unit = Db::name('unit')
  215. ->where(['is_del'=>0,'id'=>$all_good_unit])
  216. ->column('unit','id');
  217. $orderCoderArr=\app\admin\model\Sale::where('good_code','in',array_unique(array_column($list,'spuCode')))->column('orderCode','good_code');
  218. $all_code = array_merge(array_column($list,'supplierNo'),array_column($list,'companyNo'));
  219. $userCommon = \app\admin\common\User::getIns();
  220. $tmp = $userCommon->handle('getCodeAndName',['code'=>$all_code]);
  221. $depart = get_company_name_by_uid( array_unique(array_column($list,'order_createrid')));
  222. $data=[];
  223. //分类/规格/品牌 等字段取出对应文字
  224. $goodbasice = Db::name('good_basic')->where(['spuCode'=>array_column($list,"spuCode")])->column('status',"spuCode");
  225. $good_online = Db::name('good_platform')->where(['spuCode'=>array_column($list,"spuCode")])->column('id',"spuCode");
  226. foreach ($list as $value){
  227. $value['cat_info']= made($value['cat_id'],[]);
  228. $value['is_basic']=$goodbasice[$value['spuCode']]??null;
  229. $value['order_creater_depart']=$depart[$value['order_createrid']]??'';
  230. $value['is_online']=isset($good_online[$value['spuCode']])?1:0;
  231. $value['platform_name'] = $all_platform[$value['platform_id']]??'';//isset($platform['platform_name']) ? $platform['platform_name']:"";
  232. $value['platform_code_en'] = '';//isset($platform['platform_code_en']) ? $platform['platform_code_en']:"";
  233. $value['supplier_name'] = $tmp[$value['supplierNo']] ?? '';//isset($supplier['name']) ? $supplier['name']:"";
  234. $value["brand_name"]=$all_brand[$value['brand_id']]??'';//isset($brand['brand_name'])?$brand['brand_name']:"";
  235. $value['unit'] =$all_unit[$value['good_unit']]??'';//isset($unit['unit'])?$unit['unit']:"";
  236. $value['company'] = $tmp[$value['companyNo']]??'';//isset($company['company'])?$company['company']:"";
  237. $value['stock_total'] = Db::name("good_stock")
  238. ->where(['spuCode'=>$value['spuCode'],"is_del"=>0])
  239. ->sum("usable_stock");
  240. $value['orderCode']=$orderCoderArr[$value['spuCode']]??'';
  241. $spec = Db::name("good_spec")->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->select()->toArray();
  242. $speclist=[];
  243. if(!empty($spec)){
  244. foreach ($spec as $val){
  245. $temp=[];
  246. $temp['spec_id']=$val['spec_id'];
  247. $temp['spec_value_id']=$val['spec_value_id'];
  248. $sp = Db::name("specs")->where(["id"=>$val['spec_id']])->find();
  249. $temp['spec_name']=isset($sp["spec_name"]) ? $sp["spec_name"]:"";
  250. $spv = Db::name("spec_value")->where(["id"=>$val['spec_value_id']])->find();
  251. $temp['spec_value']=isset($spv["spec_value"]) ? $spv["spec_value"]:"";
  252. $speclist[]=$temp;
  253. }
  254. }
  255. $value['specinfo']=$speclist;
  256. $value['noble_name']=isset($value['noble_metal'])&&$value['noble_metal']!=0?$this->noble[$value['noble_metal']] :"";
  257. $data[]=$value;
  258. }
  259. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  260. }
  261. //创建活动
  262. public function create(){
  263. $activity_name = isset($this->post['activity_name'])&&$this->post['activity_name']!="" ? trim($this->post['activity_name']):"";
  264. if($activity_name==""){
  265. return error_show(1004,"参数activity_name不能为空");
  266. }
  267. $ist =Db::name("good_activity")->where([["activity_name","=",$activity_name],["status","<",7],["is_del","=",
  268. 0]])->findOrEmpty();
  269. if(!empty($ist)){
  270. return error_show(1004,"活动名称已存在");
  271. }
  272. $platform_code = isset($this->post['platform_code'])&&$this->post['platform_code']!="" ? trim($this->post['platform_code']):"";
  273. if($platform_code==""){
  274. return error_show(1004,"参数platform_code不能为空");
  275. }
  276. $company_id = isset($this->post['company_id'])&&$this->post['company_id']!="" ? trim($this->post['company_id']):"";
  277. if($company_id==""){
  278. return error_show(1004,"参数company_id不能为空");
  279. }
  280. $activity_start = isset($this->post['activity_start'])&&$this->post['activity_start']!="" ? $this->post['activity_start']:"";
  281. if($activity_start==""){
  282. return error_show(1004,"参数activity_start不能为空");
  283. }
  284. $activity_end = isset($this->post['activity_end'])&&$this->post['activity_end']!="" ? $this->post['activity_end']:"";
  285. if($activity_end==""){
  286. return error_show(1004,"参数activity_end不能为空");
  287. }
  288. $activity_desc = isset($this->post['activity_desc'])&&$this->post['activity_desc']!="" ?
  289. trim($this->post['activity_desc']):"";
  290. if($activity_desc==""){
  291. return error_show(1004,"参数activity_desc不能为空");
  292. }
  293. $is_stock = isset($this->post['is_stock'])&&$this->post['is_stock']!=="" ?
  294. intval($this->post['is_stock']):"";
  295. if($is_stock===""){
  296. return error_show(1004,"参数is_stock不能为空");
  297. }
  298. $good_list= isset($this->post['good_list'])&&$this->post['good_list']!=="" ?$this->post['good_list']:"";
  299. if($good_list==""){
  300. return error_show(1004,"参数good_list不能为空");
  301. }
  302. $token = isset($this->post['token'])&& $this->post['token']!='' ? trim($this->post['token']):"";
  303. if($token==''){
  304. return error_show(105,"参数token不能为空");
  305. }
  306. $user =GetUserInfo($token);
  307. if(empty($user)||$user['code']!=0){
  308. return error_show(102,"用户数据不存在");
  309. }
  310. $createrid= isset($user["data"]['id']) ? $user["data"]['id'] : "";
  311. $creater= isset($user["data"]['nickname']) ? $user["data"]['nickname'] : "";
  312. $activity_code = makeNo("AT");
  313. Db::startTrans();
  314. try{
  315. $data=[
  316. "activity_name"=>$activity_name,
  317. "activity_code"=>$activity_code,
  318. "is_stock"=>$is_stock,
  319. "start"=>$activity_start,
  320. "end"=>$activity_end,
  321. "platform_code"=>$platform_code,
  322. "activity_desc"=>$activity_desc,
  323. "company_id"=>$company_id,
  324. "creater"=>$creater,
  325. "createrid"=>$createrid,
  326. "status"=>1,
  327. "is_del"=>0,
  328. "addtime"=>date("Y-m-d H:i:s"),
  329. "updatetime"=>date("Y-m-d H:i:s")
  330. ];
  331. $inset = Db::name("good_activity")->insertGetId($data);
  332. if($inset>0){
  333. if($good_list!=""&&!empty($good_list)){
  334. $temp=[];
  335. $skuCode =array_column($good_list,"skuCode");
  336. $ist = Db::name("good_activity")
  337. ->alias("a")
  338. ->leftJoin("activity_info b", "a.activity_code = b.activity_code and b.is_del=0")
  339. ->where(["b.skuCode" => $skuCode, "a.is_del" => 0])
  340. ->where([["a.status", "<>", 8]])
  341. ->where(function ($query) use ($activity_end, $activity_start) {
  342. return $query->whereOr([[["start", "<=", $activity_start], ["end", ">=", $activity_end]], ["start|end", "between", [$activity_start, $activity_end]]]);
  343. })
  344. ->select()
  345. ->toArray();
  346. if(!empty($ist)){
  347. Db::rollback();
  348. $limit=[];
  349. foreach ($ist as $value){
  350. $limit[]="活动 ".$value['activity_name']. ' 已存在商品 '. $value['good_name'];
  351. }
  352. return app_show(1007,'活动商品已存在', $limit);
  353. }
  354. foreach ($good_list as $value){
  355. $lemp = [];
  356. $good = Db::name('good')->alias("a")->leftJoin("good_platform b", "a.spuCode=b.spuCode")->where(["skuCode" => $value['skuCode'], "a.is_del" => 0])->findOrEmpty();
  357. $lemp['skuCode']=$value['skuCode'];
  358. $lemp['good_name']=isset($good['good_name']) ?$good['good_name']:"" ;
  359. $lemp['activity_code']=$activity_code;
  360. $lemp['activity_stock']=$value['activity_stock'];
  361. $lemp['moq_num']=0;
  362. $lemp['cost_price']=0;
  363. $lemp['sale_price']=0;
  364. $lemp['activity_price']=0;
  365. $lemp['status']=0;
  366. $lemp['remark']="";
  367. $lemp['is_del']=0;
  368. $lemp['addtime']=date("Y-m-d H:i:s");
  369. $lemp['updatetime']=date("Y-m-d H:i:s");
  370. $temp[]=$lemp;
  371. //当是库存品的时候校验可用库存数,不满足的时候不能添加
  372. if ($is_stock == 1) {
  373. // $usable_stock = Db::name('good_stock')
  374. // ->where(['spuCode' => $good['spuCode'], 'is_del' => 0])
  375. // ->sum('usable_stock');
  376. if ($value['activity_stock'] > $good['usable_stock']) {
  377. Db::rollback();
  378. // throw new \Exception($lemp['good_name'] . '的库存只有' . $usable_stock);
  379. return app_show(1005,'库存不足',[$lemp['good_name']. '的库存只有' . $good['usable_stock']]);
  380. }
  381. }
  382. }
  383. $iall=Db::name("activity_info")->insertAll($temp);
  384. if($iall==0){
  385. Db::rollback();
  386. return error_show(1005,"新建失败");
  387. }
  388. }
  389. $stn = ["order_code" => $activity_code, "status" => 0, "action_remark" => '', "action_type" => "create"];
  390. ActionLog::logAdd($this->post['token'], $stn, "HD", $data['status'], $data);
  391. $process = ["order_code" => $activity_code, "order_id" => $inset, "order_status" => $data['status'], "order_type" => 'HD', "before_status" => 0, 'holder_id' => $data['createrid']];
  392. ProcessOrder::AddProcess($this->post['token'], $process);
  393. Db::commit();
  394. return app_show(0,"新建成功");
  395. }
  396. }catch (\Exception $e){
  397. Db::rollback();
  398. return error_show(1005,$e->getMessage());
  399. }
  400. }
  401. //采购定价
  402. public function cost(){
  403. $good_list= isset($this->post['good_list'])&&!empty($this->post['good_list']) ?$this->post['good_list']:"";
  404. if($good_list==""){
  405. return error_show(1004,"参数good_list不能为空");
  406. }
  407. $activity_code= isset($this->post['activity_code'])&&$this->post['activity_code']!=="" ?trim($this->post['activity_code']):"";
  408. if($activity_code==""){
  409. return error_show(1004,"参数activity_code不能为空");
  410. }
  411. $activity = Db::name("good_activity")->where(["activity_code"=>$activity_code,"is_del"=>0])->find();
  412. if($activity==false){
  413. return error_show(1004,"未找到活动数据");
  414. }
  415. Db::startTrans();
  416. try{
  417. foreach ($good_list as $value){
  418. $temp=[];
  419. $ladd = Db::name("good_ladder")->where(["skuCode"=>$value['skuCode'],"is_del"=>0])->where
  420. ([["min_num","<=",$value['moq_num']]])->order("min_num desc")->find();
  421. $temp["id"]=$value['id'];
  422. $temp["cost_price"]=$value['cost_price'];
  423. $temp["moq_num"]=$value['moq_num'];
  424. $temp["sale_price"]=isset($ladd['sale_price'])?$ladd['sale_price']:0;
  425. $temp["updatetime"]=date("Y-m-d H:i:s");
  426. $up=Db::name("activity_info")->save($temp);
  427. if($up==false){
  428. Db::rollback();
  429. return error_show(1004,"商品数据更新失败");
  430. }
  431. }
  432. $old_activity_status = $activity['status'];
  433. $activity['status']=2;
  434. $activity['updatetime']=date("Y-m-d H:i:s");
  435. $act = Db::name("good_activity")->save($activity);
  436. if($act){
  437. $stn = ["order_code" => $activity_code, "status" => $old_activity_status, "action_remark" => '', "action_type" => "status"];
  438. ActionLog::logAdd($this->post['token'], $stn, "HD", $activity['status'], $activity);
  439. $process = ["order_code" => $activity_code, "order_id" => $activity['id'], "order_status" => $activity['status'], "order_type" => 'HD', "before_status" => $old_activity_status, 'holder_id' => $activity['createrid']];
  440. ProcessOrder::AddProcess($this->post['token'], $process);
  441. Db::commit();
  442. return error_show(0,"商品数据更新成功");
  443. }else{
  444. Db::rollback();
  445. return error_show(1004,"商品数据更新失败");
  446. }
  447. }catch (\Exception $e){
  448. Db::rollback();
  449. return error_show(1004,$e->getMessage());
  450. }
  451. }
  452. //财务定价
  453. public function activity(){
  454. $good_list= isset($this->post['good_list'])&&!empty($this->post['good_list']) ?$this->post['good_list']:"";
  455. if($good_list==""){
  456. return error_show(1004,"参数good_list不能为空");
  457. }
  458. $activity_code= isset($this->post['activity_code'])&&$this->post['activity_code']!=="" ?trim($this->post['activity_code']):"";
  459. if($activity_code==""){
  460. return error_show(1004,"参数activity_code不能为空");
  461. }
  462. $activity = Db::name("good_activity")->where(["activity_code"=>$activity_code,"is_del"=>0])->find();
  463. if($activity==false){
  464. return error_show(1004,"未找到活动数据");
  465. }
  466. Db::startTrans();
  467. try{
  468. foreach ($good_list as $value){
  469. $temp=[];
  470. $temp["id"]=$value['id'];
  471. $temp["activity_price"]=$value['activity_price'];
  472. $temp['is_activity'] = $value['is_activity'];
  473. $temp['settle_price'] = $value['settle_price'];
  474. $temp["updatetime"]=date("Y-m-d H:i:s");
  475. $up=Db::name("activity_info")->save($temp);
  476. if($up==false){
  477. Db::rollback();
  478. return error_show(1004,"商品数据更新失败");
  479. }
  480. }
  481. $old_activity_status = $activity['status'];
  482. $activity['status']=3;
  483. $activity['updatetime']=date("Y-m-d H:i:s");
  484. $act = Db::name("good_activity")->save($activity);
  485. if($act){
  486. $stn = ["order_code" => $activity_code, "status" => $old_activity_status, "action_remark" => '', "action_type" => "status"];
  487. ActionLog::logAdd($this->post['token'], $stn, "HD", $activity['status'], $activity);
  488. $process = ["order_code" => $activity_code, "order_id" => $activity['id'], "order_status" => $activity['status'], "order_type" => 'HD', "before_status" => $old_activity_status, 'holder_id' => $activity['createrid']];
  489. ProcessOrder::AddProcess($this->post['token'], $process);
  490. Db::commit();
  491. return error_show(0,"商品数据更新成功");
  492. }else{
  493. Db::rollback();
  494. return error_show(1004,"商品数据更新失败");
  495. }
  496. }catch (\Exception $e){
  497. Db::rollback();
  498. return error_show(1004,$e->getMessage());
  499. }
  500. }
  501. //财务审核定价
  502. public function exam(){
  503. $good_list= isset($this->post['good_list'])&&!empty($this->post['good_list']) ?$this->post['good_list']:"";
  504. if($good_list==""){
  505. return error_show(1004,"参数good_list不能为空");
  506. }
  507. $activity_code= isset($this->post['activity_code'])&&$this->post['activity_code']!=="" ?trim($this->post['activity_code']):"";
  508. if($activity_code==""){
  509. return error_show(1004,"参数activity_code不能为空");
  510. }
  511. $activity = Db::name("good_activity")->where(["activity_code"=>$activity_code,"is_del"=>0])->find();
  512. if($activity==false){
  513. return error_show(1004,"未找到活动数据");
  514. }
  515. Db::startTrans();
  516. try{
  517. $isRejectAll = true;//是否全部驳回
  518. foreach ($good_list as $value){
  519. $temp=[];
  520. $temp["id"]=$value['id'];
  521. $temp["status"]=$value['status'];
  522. $temp["remark"]=$value['remark'];
  523. $temp["updatetime"]=date("Y-m-d H:i:s");
  524. $up=Db::name("activity_info")->save($temp);
  525. if($up==false){
  526. Db::rollback();
  527. return error_show(1004,"商品数据更新失败");
  528. }
  529. if ($isRejectAll && ($value['status'] == 1)) $isRejectAll = false;//只要有一个商品通过,即不能全部驳回
  530. }
  531. $old_activity_status = $activity['status'];
  532. $activity['status'] = $isRejectAll ? 8 : 4;//4审核通过,8审核未通过
  533. $activity['updatetime']=date("Y-m-d H:i:s");
  534. $act = Db::name("good_activity")->save($activity);
  535. if($act){
  536. $stn = ["order_code" => $activity_code, "status" => $old_activity_status, "action_remark" => '', "action_type" => "status"];
  537. ActionLog::logAdd($this->post['token'], $stn, "HD", $activity['status'], $activity);
  538. $process = ["order_code" => $activity_code, "order_id" => $activity['id'], "order_status" => $activity['status'], "order_type" => 'HD', "before_status" => $old_activity_status, 'holder_id' => $activity['createrid']];
  539. ProcessOrder::AddProcess($this->post['token'], $process);
  540. Db::commit();
  541. return error_show(0,"商品数据审核成功");
  542. }else{
  543. Db::rollback();
  544. return error_show(1004,"商品数据审核失败");
  545. }
  546. }catch (\Exception $e){
  547. Db::rollback();
  548. return error_show(1004,$e->getMessage());
  549. }
  550. }
  551. //活动详情
  552. public function info()
  553. {
  554. $activity_code = isset($this->post['activity_code']) && $this->post['activity_code'] !== "" ? trim($this->post['activity_code']) : "";
  555. if ($activity_code == "") {
  556. return error_show(1004, "参数activity_code不能为空");
  557. }
  558. $activity = Db::name("good_activity")
  559. ->alias('ga')
  560. ->field('ga.*,p.platform_name,p.platform_type')
  561. ->leftJoin('platform p', 'p.id=ga.platform_code AND p.is_del=0')
  562. ->where(["ga.activity_code" => $activity_code, "ga.is_del" => 0])
  563. ->find();
  564. if ($activity == false) {
  565. return error_show(1004, "未找到活动数据");
  566. }
  567. $activity_info = Db::name("activity_info")
  568. ->where(["activity_code" => $activity_code, "is_del" => 0])
  569. ->select()
  570. ->toArray();
  571. if (!empty($activity_info)) {
  572. //状态不是(0待产品部审核,1待采购定价),才会有起订量,才可以考虑计算售价
  573. if ($activity['status'] > 1) {
  574. //判断是否是启用实时金价的贵金属
  575. $rs = Db::name('good_platform')
  576. ->alias('a')
  577. ->join('good g', 'g.spuCode=a.spuCode')
  578. ->join('good_nake c', 'c.spuCode=a.spuCode')
  579. ->whereIn('a.skuCode', array_column($activity_info, 'skuCode'))
  580. ->column('g.cat_id,g.is_gold_price,g.demo_fee,g.open_fee,g.weight,c.cost_fee,c.package_fee,c.mark_fee,c.cert_fee,g.noble_metal,c.nake_fee,c.delivery_fee', 'a.skuCode');
  581. foreach ($activity_info as &$value) {
  582. //如果启用了实时金价,且是贵金属
  583. if (isset($rs[$value['skuCode']])) {
  584. $top_cat = made($rs[$value['skuCode']]['cat_id']);
  585. if (isset($top_cat[0]['id']) && $top_cat[0]['id'] == 6 && $rs[$value['skuCode']]['is_gold_price'] == 1) {
  586. $gold_price = Db::name("gold_price1")->where(["type" => $rs[$value['skuCode']]['noble_metal'], "is_del" => 0, "status" => 1])->order("addtime desc")->value('price');
  587. $value['sale_price'] = round($rs[$value['skuCode']]['demo_fee'] / $value['moq_num'] + $rs[$value['skuCode']]['open_fee'] / $value['moq_num'] + $rs[$value['skuCode']]['weight'] * $gold_price + $rs[$value['skuCode']]['cost_fee'] * $rs[$value['skuCode']]['weight'] + $rs[$value['skuCode']]['package_fee'] + $rs[$value['skuCode']]['mark_fee'] + $rs[$value['skuCode']]['cert_fee'] + $rs[$value['skuCode']]['nake_fee'] + $rs[$value['skuCode']]['delivery_fee'], 2);
  588. }
  589. }
  590. }
  591. }
  592. $activity['info'] = $activity_info;
  593. } else $activity['info'] = [];
  594. // $activity['info'] = empty($activity_info) ? [] : $activity_info;
  595. return app_show(0, "获取成功", $activity);
  596. }
  597. //修改活动状态
  598. public function actstatus(){
  599. $activity_code= isset($this->post['activity_code'])&&$this->post['activity_code']!=="" ?trim($this->post['activity_code']):"";
  600. if($activity_code==""){
  601. return error_show(1004,"参数activity_code不能为空");
  602. }
  603. $activity = Db::name("good_activity")->where(["activity_code"=>$activity_code,"is_del"=>0])->find();
  604. if($activity==false){
  605. return error_show(1004,"未找到活动数据");
  606. }
  607. $status = isset($this->post['status'])&&$this->post['status']!=="" ?intval($this->post['status']):"";
  608. if($status==""){
  609. return error_show(1004,"参数status不能为空");
  610. }
  611. $remark =isset($tihs->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']):"";
  612. if($remark=="" &&$status==8){
  613. return error_show(1004,"参数remark不能为空");
  614. }
  615. $old_status = $activity['status'];
  616. $activity['status']=$status;
  617. $activity['remark']=$remark;
  618. $activity['updatetime']=date("Y-m-d H:i:s");
  619. $up = Db::name("good_activity")->save($activity);
  620. if($up){
  621. $stn = ["order_code" => $activity_code, "status" => $old_status, "action_remark" => '', "action_type" => "status"];
  622. ActionLog::logAdd($this->post['token'], $stn, "HD", $activity['status'], $activity);
  623. $process = ["order_code" => $activity_code, "order_id" => $activity['id'], "order_status" => $activity['status'], "order_type" => 'HD', "before_status" => $old_status, 'holder_id' => $activity['createrid']];
  624. ProcessOrder::AddProcess($this->post['token'], $process);
  625. return app_show(0,"修改成功");
  626. }else{
  627. return error_show(1004,"修改失败");
  628. }
  629. }
  630. public function query(){
  631. $skuCode= isset($this->post['skuCode'])&&$this->post['skuCode']!=""?trim($this->post['skuCode']):"";
  632. if($skuCode==""){
  633. return error_show(1004,"参数skuCode不能为空");
  634. }
  635. $where=['a.is_del'=>0,"b.is_del"=>0,"a.status"=>6,"b.status"=>1,"b.skuCode"=>$skuCode];
  636. $condition=['a.skuCode' =>$skuCode,"a.is_del"=>0,'a.exam_status'=>3];
  637. $company = isset($this->post['companyNo'])&&$this->post['companyNo']!=""?trim($this->post['companyNo']):"";
  638. if($company!=""){
  639. $where['a.company_id'] = $company;
  640. $condition['companyNo'] = $company;
  641. }
  642. $plat =isset($this->post['platform_id'])&&$this->post['platform_id']!=""?intval($this->post['platform_id'])
  643. :"";
  644. if($plat!==""){
  645. $where['a.platform_code'] = $plat;
  646. $condition['platform_code'] = $plat;
  647. }
  648. $good = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
  649. ->where($condition)->select()->toArray();
  650. $goodlist=[];
  651. if(!empty($good)){
  652. foreach ($good as $value){
  653. $temp=[];
  654. //如果是非库存商品,库存数改为最大(即将库存设为无限)
  655. $temp['stock_num'] = $value['is_stock'] == 1 ? intval($value['usable_stock']) : 9999;
  656. $temp['skuCode']=$value['skuCode'];
  657. $temp['spuCode']=$value['spuCode'];
  658. $temp['is_stock']=$value['is_stock'];
  659. $temp['good_name']=$value['good_name'];
  660. $temp['good_img']=$value['good_img'];
  661. $temp['good_info_img']=$value['good_info_img'];
  662. $temp['noble_metal']=$value['noble_metal'];
  663. $temp['noble_name']=$value['noble_metal']!=0?$this->noble[$value['noble_metal']]:"";
  664. $goodlist[]=$temp;
  665. }
  666. }
  667. $list = Db::name('good_activity')->alias("a")
  668. ->join("activity_info b","b.activity_code=a.activity_code","left")
  669. ->where($where)->field('b.id,a.activity_name,a.activity_code,a.is_stock,a.start,a.end,b.skuCode,b.good_name,b.activity_stock,
  670. b.cost_price,b.moq_num,b.sale_price,b.activity_price')->select()->toArray();
  671. return app_show(0,"获取成功",["act"=>$list,"good"=>$goodlist]);
  672. }
  673. //新增库存
  674. public function editStock(){
  675. $actCode=isset($this->post['actCode'])&&$this->post['actCode']!='' ? trim($this->post['actCode']):"";
  676. if($actCode==''){
  677. return error_show(1004,"参数 actCode 不能为空");
  678. }
  679. $skuCode=isset($this->post['skuCode'])&&$this->post['skuCode']!='' ? trim($this->post['skuCode']):"";
  680. if($skuCode==''){
  681. return error_show(1004,"参数 skuCode 不能为空");
  682. }
  683. $act_stock=isset($this->post['act_stock'])&&$this->post['act_stock']!='' ? intval($this->post['act_stock']):"";
  684. if($act_stock==''){
  685. return error_show(1004,"参数 act_stock 不能为空");
  686. }
  687. $act =Db::name("good_activity")->where(["activity_code"=>$actCode,"is_del"=>0])->findOrEmpty();
  688. if(empty($act)){
  689. return error_show(1005,"活动信息不存在");
  690. }
  691. if(!in_array($act['status'],[4,5,6]))return error_show(1005,"活动暂时不能修改");
  692. $goodinfo=Db::name("activity_info")->where(["activity_code"=>$actCode,"skuCode"=>$skuCode,"is_del"=>0])
  693. ->findOrEmpty();
  694. if(empty($goodinfo)){
  695. return error_show(1005,"活动商品信息不存在");
  696. }
  697. $good = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
  698. ->where(['a.skuCode' =>$skuCode,"a.is_del"=>0,'a.exam_status'=>3])->findOrEmpty();
  699. if(empty($good)){
  700. return error_show(1005,"商品信息不存在或已下架");
  701. }
  702. if($good['is_stock']==1){
  703. // $stock =Db::name("good_stock")->where(["spuCode"=>$good['spuCode'],"is_del"=>0])->sum('usable_stock');
  704. if($act_stock+$goodinfo['activity_stock']> $good['usable_stock']){
  705. return error_show(1005,"商品库存不足");
  706. }
  707. }
  708. $update =["activity_stock"=>$act_stock+$goodinfo['activity_stock'],"updatetime"=>date("Y-m-d H:i:s")];
  709. $up=Db::name("activity_info")->where($goodinfo)->update($update);
  710. return $up ? app_show(0,"活动库存增加成功"):error_show(1006,"活动库存增加失败");
  711. }
  712. }