Activity.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\common\Ocr;
  4. use app\admin\model\ActionLog;
  5. use app\admin\model\ProcessOrder;
  6. use app\BaseController;
  7. use think\App;
  8. use think\facade\Db;
  9. class Activity extends Base
  10. {
  11. public $noble=[];
  12. public function __construct(App $app)
  13. {
  14. parent::__construct($app);
  15. $this->noble=\think\facade\Config::get("noble");
  16. }
  17. public function list(){
  18. $page = isset($this->post['page']) && $this->post['page'] !==""? intval($this->post['page']):"1";
  19. $size = isset($this->post['size']) && $this->post['size'] !==""? intval($this->post['size']):"10";
  20. $where = [["ga.is_del","=",0]];
  21. $activity_name = isset($this->post['activity_name']) && $this->post['activity_name'] !=="" ? trim($this->post['activity_name']):"";
  22. if($activity_name!=""){
  23. $where[]=['ga.activity_name',"like","%$activity_name%"];
  24. }
  25. $status = isset($this->post['status']) && $this->post['status'] !=="" ? intval($this->post['status']):"";
  26. if($status!==""){
  27. $where[]=['ga.status',"=",$status];
  28. }
  29. $activity_code = isset($this->post['activity_code']) && $this->post['activity_code'] !=="" ? trim($this->post['activity_code']):"";
  30. if($activity_code!==""){
  31. $where[]=['ga.activity_code',"like","%$activity_code%"];
  32. }
  33. $starttime = isset($this->post['starttime']) && $this->post['starttime']!=="" ? $this->post['starttime']:"";
  34. if($starttime!==""){
  35. $where[]=['ga.start',">=",date('Y-m-d H:i:s',strtotime($starttime))];
  36. }
  37. $endtime = isset($this->post['endtime']) && $this->post['endtime']!=="" ? $this->post['endtime']:"";
  38. if($endtime!==""){
  39. $where[]=['ga.end',"<",date('Y-m-d H:i:s',strtotime($endtime)+24*3600)];
  40. }
  41. $platform_code = isset($this->post['platform_code']) && $this->post['platform_code'] !=="" ? trim($this->post['platform_code']):"";
  42. if($platform_code!==""){
  43. $where[]=['ga.platform_code',"=",$platform_code];
  44. }
  45. $company_id = isset($this->post['company_id']) && $this->post['company_id'] !=="" ? trim($this->post['company_id']):"";
  46. if($company_id!==""){
  47. $where[]=['ga.company_id',"=",$company_id];
  48. }
  49. $creater = isset($this->post['creater']) && $this->post['creater'] !=="" ? trim($this->post['creater'])
  50. :"";
  51. if($creater!=""){
  52. $where[]=['ga.creater',"like","%$creater%"];
  53. }
  54. $createrid = isset($this->post['createrid']) && $this->post['createrid'] !=="" ? trim($this->post['createrid'])
  55. :"";
  56. if($createrid!==""){
  57. $where[]=['ga.createrid',"=",$createrid];
  58. }
  59. $role=$this->checkRole();
  60. if(!empty($role['write'])){
  61. $where[]=["ga.createrid","in",$role['write']];
  62. }
  63. $company_name = isset($this->post['company_name']) && $this->post['company_name'] !== "" ? trim($this->post['company_name']) : "";
  64. if ($company_name !== "") $where[] = ["ga.createrid", 'in', get_company_item_user_by_name($company_name)];
  65. $count = Db::name('good_activity')
  66. ->alias('ga')
  67. ->where($where)
  68. ->count();
  69. $total = ceil($count / $size);
  70. $page = $page >= $total ? $total : $page;
  71. $list = Db::name('good_activity')
  72. ->alias('ga')
  73. ->field('ga.*,p.platform_name,u.itemid')
  74. ->leftJoin("depart_user u", "u.uid=ga.createrid AND u.is_del=0")
  75. ->leftJoin("platform p", "p.id=ga.platform_code")
  76. ->append(['company_name'])
  77. ->withAttr('company_name',function($val,$data){
  78. return implode('/', array_column(GetPart($data['itemid']), 'name'));
  79. })
  80. ->where($where)
  81. ->page($page,$size)
  82. ->order("ga.addtime desc")
  83. ->select()
  84. ->toArray();
  85. return app_show(0,"获取成功",['list'=>$list,'count'=>$count]);
  86. }
  87. public function linst()
  88. {
  89. $page = isset($this->post['page']) && $this->post['page'] !== "" ? intval($this->post['page']) : "1";
  90. $size = isset($this->post['size']) && $this->post['size'] !== "" ? intval($this->post['size']) : "10";
  91. $where = [["a.is_del", "=", 0]];
  92. $skuCode = isset($this->post['skuCode']) && $this->post['skuCode'] !== "" ? trim($this->post['skuCode']) : "";
  93. if ($skuCode !== "") {
  94. $where[] = ['a.skuCode', "like", "%$skuCode%"];
  95. }
  96. $good_name = isset($this->post['good_name']) && $this->post['good_name'] !== "" ? trim($this->post['good_name']) : "";
  97. if ($good_name != "") {
  98. $where[] = ['a.good_name', "like", "%$good_name%"];
  99. }
  100. $activity_code = isset($this->post['activity_code']) && $this->post['activity_code'] !=="" ? trim($this->post['activity_code']):"";
  101. if($activity_code!==""){
  102. $where[]=['a.activity_code',"like","%$activity_code%"];
  103. }
  104. $status = isset($this->post['status']) && $this->post['status'] !=="" ? intval($this->post['status']):"";
  105. if($status!==""){
  106. $where[]=['a.status',"=",$status];
  107. }
  108. $activity_name = isset($this->post['activity_name']) && $this->post['activity_name'] !=="" ? trim($this->post['activity_name']):"";
  109. if($activity_name!=""){
  110. $where[]=['b.activity_name',"like","%$activity_name%"];
  111. }
  112. $platform_code = isset($this->post['platform_code']) && $this->post['platform_code'] !=="" ? trim($this->post['platform_code']):"";
  113. if($platform_code!=""){
  114. $where[]=['b.platform_code',"=",$platform_code];
  115. }
  116. $count = Db::name('activity_info')->alias("a")
  117. ->join("good_activity b","b.activity_code=a.activity_code","left")
  118. ->join("platform c","c.id=b.platform_code","left")
  119. ->where($where)->count();
  120. $total = ceil($count / $size);
  121. $page = $page >= $total ? $total : $page;
  122. $list = Db::name('activity_info')->alias("a")
  123. ->join("good_activity b","b.activity_code=a.activity_code","left")
  124. ->join("platform c","c.id=b.platform_code","left")
  125. ->where($where)->page($page,$size)->order("a.addtime desc")->field("a.*,b.activity_name,c.platform_name,c.platform_code
  126. ")->select();
  127. return app_show(0,"获取成功",['list'=>$list,'count'=>$count]);
  128. }
  129. public function zilist(){
  130. $page = isset($this->post['page']) && $this->post['page'] !== "" ? intval($this->post['page']) : "1";
  131. $size = isset($this->post['size']) && $this->post['size'] !== "" ? intval($this->post['size']) : "10";
  132. $where = [["a.is_del", "=", 0]];
  133. $spuCode = isset($this->post['spuCode']) && $this->post['spuCode'] !== "" ? trim($this->post['spuCode']) : "";
  134. if ($spuCode != "") $where[] = ['a.spuCode', "like", "%$spuCode%"];
  135. $good_name = isset($this->post['good_name']) && $this->post['good_name'] !== "" ? trim($this->post['good_name']) : "";
  136. if ($good_name != "") $where[] = ['a.good_name', "like", "%$good_name%"];
  137. $status = isset($this->post['status']) && $this->post['status'] !=="" ? intval($this->post['status']):"";
  138. if($status!="") $where[]=['a.status',"=",$status];
  139. $supplierNo = isset($this->post['supplierNo']) && $this->post['supplierNo'] !== "" ? trim($this->post['supplierNo']) : "";
  140. if ($supplierNo != "") $where[] = ['a.supplierNo', "like", "%$supplierNo%"];
  141. $name = isset($this->post['name']) && $this->post['name'] !== "" ? trim($this->post['name']) : "";
  142. if ($name != "") $where[] = ['b.name', "like", "%$name%"];
  143. $start = isset($this->post['start']) && $this->post['start'] !== "" ? trim($this->post['start']) : "";
  144. if ($start != "") $where[] = ['a.addtime', ">=", $start];
  145. $end = isset($this->post['end']) && $this->post['end'] !== "" ? trim($this->post['end']) : "";
  146. if ($end != "") $where[] = ['a.addtime', "<=", $end.' 23:59:59'];
  147. $count = Db::name('good_zixun')
  148. ->alias("a")
  149. ->join("supplier b","b.code=a.supplierNo","left")
  150. ->where($where)
  151. ->count();
  152. $total = ceil($count / $size);
  153. $page = $page >= $total ? $total : $page;
  154. $list = Db::name('good_zixun')
  155. ->alias("a")
  156. ->join("supplier b","b.code=a.supplierNo","left")
  157. ->where($where)
  158. ->page($page,$size)
  159. ->order("a.addtime desc")
  160. ->field("a.*,b.name")
  161. ->select()
  162. ->toArray();
  163. //halt($list);
  164. $data=[];
  165. //分类/规格/品牌 等字段取出对应文字
  166. foreach ($list as $value){
  167. $value['cat_info']= made($value['cat_id'],[]);
  168. $platform = Db::name("platform")->where(["id"=>$value['platform_id']])->find();
  169. $value['platform_name'] = isset($platform['platform_name']) ? $platform['platform_name']:"";
  170. $value['platform_code_en'] = isset($platform['platform_code_en']) ? $platform['platform_code_en']:"";
  171. $supplier = Db::name("supplier")->where(["code"=>$value['supplierNo']])->find();
  172. $value['supplier_name'] = isset($supplier['name']) ? $supplier['name']:"";
  173. $brand=Db::name("brand")->where(["id"=>$value['brand_id']])->find();
  174. $value["brand_name"]=isset($brand['brand_name'])?$brand['brand_name']:"";
  175. $unit = Db::name("unit")->where(["id"=>$value['good_unit']])->find();
  176. $value['unit'] =isset($unit['unit'])?$unit['unit']:"";
  177. $company = Db::name("business")->where(["companyNo"=>$value['companyNo']])->find();
  178. $value['company'] = isset($company['company'])?$company['company']:"";
  179. // $company = Db::name("business")->where(["companyNo"=>$value['companyNo']])->find();
  180. // $value['company'] = isset($company['company'])?$company['company']:"";
  181. $value['stock_total'] = Db::name("good_stock")->where(['spuCode'=>$value['spuCode'],"is_del"=>0])->sum("usable_stock");
  182. // $value['status']=$value['exam_status'];
  183. // $value['exclusive']=makeExcluse($value['is_exclusive']);
  184. $value['good_info_img']=$value['good_info_img'];
  185. $value['good_img']=$value['good_img'];
  186. $spec = Db::name("good_spec")->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->select()->toArray();
  187. $speclist=[];
  188. if(!empty($spec)){
  189. foreach ($spec as $val){
  190. $temp=[];
  191. $temp['spec_id']=$val['spec_id'];
  192. $temp['spec_value_id']=$val['spec_value_id'];
  193. $sp = Db::name("specs")->where(["id"=>$val['spec_id']])->find();
  194. $temp['spec_name']=isset($sp["spec_name"]) ? $sp["spec_name"]:"";
  195. $spv = Db::name("spec_value")->where(["id"=>$val['spec_value_id']])->find();
  196. $temp['spec_value']=isset($spv["spec_value"]) ? $spv["spec_value"]:"";
  197. $speclist[]=$temp;
  198. }
  199. }
  200. $value['specinfo']=$speclist;
  201. $value['noble_name']=isset($value['noble_metal'])&&$value['noble_metal']!=0?$this->noble[$value['noble_metal']] :"";
  202. $data[]=$value;
  203. }
  204. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  205. }
  206. //创建活动
  207. public function create(){
  208. $activity_name = isset($this->post['activity_name'])&&$this->post['activity_name']!="" ? trim($this->post['activity_name']):"";
  209. if($activity_name==""){
  210. return error_show(1004,"参数activity_name不能为空");
  211. }
  212. $platform_code = isset($this->post['platform_code'])&&$this->post['platform_code']!="" ? trim($this->post['platform_code']):"";
  213. if($platform_code==""){
  214. return error_show(1004,"参数platform_code不能为空");
  215. }
  216. $company_id = isset($this->post['company_id'])&&$this->post['company_id']!="" ? trim($this->post['company_id']):"";
  217. if($company_id==""){
  218. return error_show(1004,"参数company_id不能为空");
  219. }
  220. $activity_start = isset($this->post['activity_start'])&&$this->post['activity_start']!="" ? $this->post['activity_start']:"";
  221. if($activity_start==""){
  222. return error_show(1004,"参数activity_start不能为空");
  223. }
  224. $activity_end = isset($this->post['activity_end'])&&$this->post['activity_end']!="" ? $this->post['activity_end']:"";
  225. if($activity_end==""){
  226. return error_show(1004,"参数activity_end不能为空");
  227. }
  228. $activity_desc = isset($this->post['activity_desc'])&&$this->post['activity_desc']!="" ?
  229. trim($this->post['activity_desc']):"";
  230. if($activity_desc==""){
  231. return error_show(1004,"参数activity_desc不能为空");
  232. }
  233. $is_stock = isset($this->post['is_stock'])&&$this->post['is_stock']!=="" ?
  234. intval($this->post['is_stock']):"";
  235. if($is_stock===""){
  236. return error_show(1004,"参数is_stock不能为空");
  237. }
  238. $good_list= isset($this->post['good_list'])&&$this->post['good_list']!=="" ?$this->post['good_list']:"";
  239. if($good_list==""){
  240. return error_show(1004,"参数good_list不能为空");
  241. }
  242. $token = isset($this->post['token'])&& $this->post['token']!='' ? trim($this->post['token']):"";
  243. if($token==''){
  244. return error_show(105,"参数token不能为空");
  245. }
  246. $user =GetUserInfo($token);
  247. if(empty($user)||$user['code']!=0){
  248. return error_show(102,"用户数据不存在");
  249. }
  250. $createrid= isset($user["data"]['id']) ? $user["data"]['id'] : "";
  251. $creater= isset($user["data"]['nickname']) ? $user["data"]['nickname'] : "";
  252. $activity_code = makeNo("AT");
  253. Db::startTrans();
  254. try{
  255. $data=[
  256. "activity_name"=>$activity_name,
  257. "activity_code"=>$activity_code,
  258. "is_stock"=>$is_stock,
  259. "start"=>$activity_start,
  260. "end"=>$activity_end,
  261. "platform_code"=>$platform_code,
  262. "activity_desc"=>$activity_desc,
  263. "company_id"=>$company_id,
  264. "creater"=>$creater,
  265. "createrid"=>$createrid,
  266. "status"=>1,
  267. "is_del"=>0,
  268. "addtime"=>date("Y-m-d H:i:s"),
  269. "updatetime"=>date("Y-m-d H:i:s")
  270. ];
  271. $inset = Db::name("good_activity")->insertGetId($data);
  272. if($inset>0){
  273. if($good_list!=""&&!empty($good_list)){
  274. $temp=[];
  275. $skuCode =array_column($good_list,"skuCode");
  276. $ist =Db::name("good_activity")->alias("a")
  277. ->leftJoin("activity_info b","a.activity_code = b.activity_code and b.is_del=0")
  278. ->where(["b.skuCode"=>$skuCode,"a.is_del"=>0])->where([["a.status","<>",8],["start|end","between",
  279. [$activity_start,$activity_end]]])->select()->toArray();
  280. if(!empty($ist)){
  281. Db::rollback();
  282. $limit=[];
  283. foreach ($ist as $value){
  284. $limit[]="活动 ".$value['activity_name']. ' 已存在商品 '. $value['good_name'];
  285. }
  286. return app_show(1007,'活动商品已存在', $limit);
  287. }
  288. foreach ($good_list as $value){
  289. $lemp=[];
  290. $good = Db::name('good')->alias("a")->leftJoin("good_platform b","a.spuCode=b.spuCode")
  291. ->where(["skuCode"=>$value['skuCode'],"a.is_del"=>0])->find();
  292. $lemp['skuCode']=$value['skuCode'];
  293. $lemp['good_name']=isset($good['good_name']) ?$good['good_name']:"" ;
  294. $lemp['activity_code']=$activity_code;
  295. $lemp['activity_stock']=$value['activity_stock'];
  296. $lemp['moq_num']=0;
  297. $lemp['cost_price']=0;
  298. $lemp['sale_price']=0;
  299. $lemp['activity_price']=0;
  300. $lemp['status']=0;
  301. $lemp['remark']="";
  302. $lemp['is_del']=0;
  303. $lemp['addtime']=date("Y-m-d H:i:s");
  304. $lemp['updatetime']=date("Y-m-d H:i:s");
  305. $temp[]=$lemp;
  306. //当是库存品的时候校验可用库存数,不满足的时候不能添加
  307. if ($is_stock == 1) {
  308. $usable_stock = Db::name('good_stock')
  309. ->where(['spuCode' => $good['spuCode'], 'is_del' => 0])
  310. ->sum('usable_stock');
  311. if ($value['activity_stock'] > $usable_stock) {
  312. Db::rollback();
  313. // throw new \Exception($lemp['good_name'] . '的库存只有' . $usable_stock);
  314. return app_show(1005,'库存不足',[$lemp['good_name']. '的库存只有' . $usable_stock]);
  315. }
  316. }
  317. }
  318. $iall=Db::name("activity_info")->insertAll($temp);
  319. if($iall==0){
  320. Db::rollback();
  321. return error_show(1005,"新建失败");
  322. }
  323. }
  324. $stn = ["order_code" => $activity_code, "status" => 0, "action_remark" => '', "action_type" => "create"];
  325. ActionLog::logAdd($this->post['token'], $stn, "HD", $data['status'], $data);
  326. $process = ["order_code" => $activity_code, "order_id" => $inset, "order_status" => $data['status'], "order_type" => 'HD', "before_status" => 0];
  327. ProcessOrder::AddProcess($this->post['token'], $process);
  328. Db::commit();
  329. return app_show(0,"新建成功");
  330. }
  331. }catch (\Exception $e){
  332. Db::rollback();
  333. return error_show(1005,$e->getMessage());
  334. }
  335. }
  336. //采购定价
  337. public function cost(){
  338. $good_list= isset($this->post['good_list'])&&!empty($this->post['good_list']) ?$this->post['good_list']:"";
  339. if($good_list==""){
  340. return error_show(1004,"参数good_list不能为空");
  341. }
  342. $activity_code= isset($this->post['activity_code'])&&$this->post['activity_code']!=="" ?trim($this->post['activity_code']):"";
  343. if($activity_code==""){
  344. return error_show(1004,"参数activity_code不能为空");
  345. }
  346. $activity = Db::name("good_activity")->where(["activity_code"=>$activity_code,"is_del"=>0])->find();
  347. if($activity==false){
  348. return error_show(1004,"未找到活动数据");
  349. }
  350. Db::startTrans();
  351. try{
  352. foreach ($good_list as $value){
  353. $temp=[];
  354. $ladd = Db::name("good_ladder")->where(["skuCode"=>$value['skuCode'],"is_del"=>0])->where
  355. ([["min_num","<=",$value['moq_num']]])->order("min_num desc")->find();
  356. $temp["id"]=$value['id'];
  357. $temp["cost_price"]=$value['cost_price'];
  358. $temp["moq_num"]=$value['moq_num'];
  359. $temp["sale_price"]=isset($ladd['sale_price'])?$ladd['sale_price']:0;
  360. $temp["updatetime"]=date("Y-m-d H:i:s");
  361. $up=Db::name("activity_info")->save($temp);
  362. if($up==false){
  363. Db::rollback();
  364. return error_show(1004,"商品数据更新失败");
  365. }
  366. }
  367. $old_activity_status = $activity['status'];
  368. $activity['status']=2;
  369. $activity['updatetime']=date("Y-m-d H:i:s");
  370. $act = Db::name("good_activity")->save($activity);
  371. if($act){
  372. $stn = ["order_code" => $activity_code, "status" => $old_activity_status, "action_remark" => '', "action_type" => "status"];
  373. ActionLog::logAdd($this->post['token'], $stn, "HD", $activity['status'], $activity);
  374. $process = ["order_code" => $activity_code, "order_id" => $activity['id'], "order_status" => $activity['status'], "order_type" => 'HD', "before_status" => $old_activity_status];
  375. ProcessOrder::AddProcess($this->post['token'], $process);
  376. Db::commit();
  377. return error_show(0,"商品数据更新成功");
  378. }else{
  379. Db::rollback();
  380. return error_show(1004,"商品数据更新失败");
  381. }
  382. }catch (\Exception $e){
  383. Db::rollback();
  384. return error_show(1004,$e->getMessage());
  385. }
  386. }
  387. //财务定价
  388. public function activity(){
  389. $good_list= isset($this->post['good_list'])&&!empty($this->post['good_list']) ?$this->post['good_list']:"";
  390. if($good_list==""){
  391. return error_show(1004,"参数good_list不能为空");
  392. }
  393. $activity_code= isset($this->post['activity_code'])&&$this->post['activity_code']!=="" ?trim($this->post['activity_code']):"";
  394. if($activity_code==""){
  395. return error_show(1004,"参数activity_code不能为空");
  396. }
  397. $activity = Db::name("good_activity")->where(["activity_code"=>$activity_code,"is_del"=>0])->find();
  398. if($activity==false){
  399. return error_show(1004,"未找到活动数据");
  400. }
  401. Db::startTrans();
  402. try{
  403. foreach ($good_list as $value){
  404. $temp=[];
  405. $temp["id"]=$value['id'];
  406. $temp["activity_price"]=$value['activity_price'];
  407. $temp["updatetime"]=date("Y-m-d H:i:s");
  408. $up=Db::name("activity_info")->save($temp);
  409. if($up==false){
  410. Db::rollback();
  411. return error_show(1004,"商品数据更新失败");
  412. }
  413. }
  414. $old_activity_status = $activity['status'];
  415. $activity['status']=3;
  416. $activity['updatetime']=date("Y-m-d H:i:s");
  417. $act = Db::name("good_activity")->save($activity);
  418. if($act){
  419. $stn = ["order_code" => $activity_code, "status" => $old_activity_status, "action_remark" => '', "action_type" => "status"];
  420. ActionLog::logAdd($this->post['token'], $stn, "HD", $activity['status'], $activity);
  421. $process = ["order_code" => $activity_code, "order_id" => $activity['id'], "order_status" => $activity['status'], "order_type" => 'HD', "before_status" => $old_activity_status];
  422. ProcessOrder::AddProcess($this->post['token'], $process);
  423. Db::commit();
  424. return error_show(0,"商品数据更新成功");
  425. }else{
  426. Db::rollback();
  427. return error_show(1004,"商品数据更新失败");
  428. }
  429. }catch (\Exception $e){
  430. Db::rollback();
  431. return error_show(1004,$e->getMessage());
  432. }
  433. }
  434. //财务审核定价
  435. public function exam(){
  436. $good_list= isset($this->post['good_list'])&&!empty($this->post['good_list']) ?$this->post['good_list']:"";
  437. if($good_list==""){
  438. return error_show(1004,"参数good_list不能为空");
  439. }
  440. $activity_code= isset($this->post['activity_code'])&&$this->post['activity_code']!=="" ?trim($this->post['activity_code']):"";
  441. if($activity_code==""){
  442. return error_show(1004,"参数activity_code不能为空");
  443. }
  444. $activity = Db::name("good_activity")->where(["activity_code"=>$activity_code,"is_del"=>0])->find();
  445. if($activity==false){
  446. return error_show(1004,"未找到活动数据");
  447. }
  448. Db::startTrans();
  449. try{
  450. foreach ($good_list as $value){
  451. $temp=[];
  452. $temp["id"]=$value['id'];
  453. $temp["status"]=$value['status'];
  454. $temp["remark"]=$value['remark'];
  455. $temp["updatetime"]=date("Y-m-d H:i:s");
  456. $up=Db::name("activity_info")->save($temp);
  457. if($up==false){
  458. Db::rollback();
  459. return error_show(1004,"商品数据更新失败");
  460. }
  461. }
  462. $old_activity_status = $activity['status'];
  463. $activity['status']=4;
  464. $activity['updatetime']=date("Y-m-d H:i:s");
  465. $act = Db::name("good_activity")->save($activity);
  466. if($act){
  467. $stn = ["order_code" => $activity_code, "status" => $old_activity_status, "action_remark" => '', "action_type" => "status"];
  468. ActionLog::logAdd($this->post['token'], $stn, "HD", $activity['status'], $activity);
  469. $process = ["order_code" => $activity_code, "order_id" => $activity['id'], "order_status" => $activity['status'], "order_type" => 'HD', "before_status" => $old_activity_status];
  470. ProcessOrder::AddProcess($this->post['token'], $process);
  471. Db::commit();
  472. return error_show(0,"商品数据审核成功");
  473. }else{
  474. Db::rollback();
  475. return error_show(1004,"商品数据审核失败");
  476. }
  477. }catch (\Exception $e){
  478. Db::rollback();
  479. return error_show(1004,$e->getMessage());
  480. }
  481. }
  482. //活动详情
  483. public function info()
  484. {
  485. $activity_code = isset($this->post['activity_code']) && $this->post['activity_code'] !== "" ? trim($this->post['activity_code']) : "";
  486. if ($activity_code == "") {
  487. return error_show(1004, "参数activity_code不能为空");
  488. }
  489. $activity = Db::name("good_activity")
  490. ->alias('ga')
  491. ->field('ga.*,p.platform_name')
  492. ->leftJoin('platform p', 'p.id=ga.platform_code AND p.is_del=0')
  493. ->where(["ga.activity_code" => $activity_code, "ga.is_del" => 0])
  494. ->find();
  495. if ($activity == false) {
  496. return error_show(1004, "未找到活动数据");
  497. }
  498. $activity_info = Db::name("activity_info")
  499. ->where(["activity_code" => $activity_code, "is_del" => 0])
  500. ->select()
  501. ->toArray();
  502. $activity['info'] = empty($activity_info) ? [] : $activity_info;
  503. return app_show(0, "获取成功", $activity);
  504. }
  505. //修改活动状态
  506. public function actstatus(){
  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. $status = isset($this->post['status'])&&$this->post['status']!=="" ?intval($this->post['status']):"";
  516. if($status==""){
  517. return error_show(1004,"参数status不能为空");
  518. }
  519. $remark =isset($tihs->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']):"";
  520. if($remark=="" &&$status==8){
  521. return error_show(1004,"参数remark不能为空");
  522. }
  523. $old_status = $activity['status'];
  524. $activity['status']=$status;
  525. $activity['remark']=$remark;
  526. $activity['updatetime']=date("Y-m-d H:i:s");
  527. $up = Db::name("good_activity")->save($activity);
  528. if($up){
  529. $stn = ["order_code" => $activity_code, "status" => $old_status, "action_remark" => '', "action_type" => "status"];
  530. ActionLog::logAdd($this->post['token'], $stn, "HD", $activity['status'], $activity);
  531. $process = ["order_code" => $activity_code, "order_id" => $activity['id'], "order_status" => $activity['status'], "order_type" => 'HD', "before_status" => $old_status];
  532. ProcessOrder::AddProcess($this->post['token'], $process);
  533. return app_show(0,"修改成功");
  534. }else{
  535. return error_show(1004,"修改失败");
  536. }
  537. }
  538. public function query(){
  539. $skuCode= isset($this->post['skuCode'])&&$this->post['skuCode']!=""?trim($this->post['skuCode']):"";
  540. if($skuCode==""){
  541. return error_show(1004,"参数skuCode不能为空");
  542. }
  543. $where=['a.is_del'=>0,"b.is_del"=>0,"a.status"=>6,"b.status"=>1,"b.skuCode"=>$skuCode];
  544. $condition=['a.skuCode' =>$skuCode,"a.is_del"=>0,'a.exam_status'=>6];
  545. $company = isset($this->post['companyNo'])&&$this->post['companyNo']!=""?trim($this->post['companyNo']):"";
  546. if($company!=""){
  547. $where['a.company_id'] = $company;
  548. $condition['companyNo'] = $company;
  549. }
  550. $plat =isset($this->post['platform_id'])&&$this->post['platform_id']!=""?intval($this->post['platform_id'])
  551. :"";
  552. if($plat!==""){
  553. $where['a.platform_code'] = $plat;
  554. $condition['platform_code'] = $plat;
  555. }
  556. $good = Db::name('good_platform')->alias('a')->join('good b', 'b.spuCode=a.spuCode', 'left')
  557. ->where($condition)->select()->toArray();
  558. $goodlist=[];
  559. if(!empty($good)){
  560. foreach ($good as $value){
  561. $temp=[];
  562. $stock =Db::name("good_stock")->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->sum('usable_stock');
  563. //如果是非库存商品,库存数改为最大(即将库存设为无限)
  564. $temp['stock_num'] = $value['is_stock'] == 1 ? intval($stock) : 9999;
  565. $temp['skuCode']=$value['skuCode'];
  566. $temp['spuCode']=$value['spuCode'];
  567. $temp['is_stock']=$value['is_stock'];
  568. $temp['good_name']=$value['good_name'];
  569. $temp['good_img']=$value['good_img'];
  570. $temp['good_info_img']=$value['good_info_img'];
  571. $temp['noble_metal']=$value['noble_metal'];
  572. $temp['noble_name']=$value['noble_metal']!=0?$this->noble[$value['noble_metal']]:"";
  573. $goodlist[]=$temp;
  574. }
  575. }
  576. $list = Db::name('good_activity')->alias("a")
  577. ->join("activity_info b","b.activity_code=a.activity_code","left")
  578. ->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,
  579. b.cost_price,b.moq_num,b.sale_price,b.activity_price')->select()->toArray();
  580. return app_show(0,"获取成功",["act"=>$list,"good"=>$goodlist]);
  581. }
  582. }