Cron.php 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733
  1. <?php
  2. namespace Shop\Lib;
  3. use Dever;
  4. class Cron
  5. {
  6. # 定时更新店铺经纬度
  7. public function geo_api()
  8. {
  9. Dever::config('base')->hook = true;
  10. $shop = Dever::db('shop/info')->select();
  11. if ($shop) {
  12. foreach ($shop as $k => $v) {
  13. $temp = explode(',', $v['area']);
  14. if (isset($temp[1]) && $v['address']) {
  15. $geo = Dever::load('shop/lib/info')->geo($temp[1], $v['address']);
  16. $update['lng'] = $geo[0];
  17. $update['lat'] = $geo[1];
  18. $update['map'] = $geo[2];
  19. $update['coord_address'] = $v['address'];
  20. $update['where_id'] = $v['id'];
  21. Dever::db('shop/info')->update($update);
  22. }
  23. }
  24. }
  25. return 'ok';
  26. }
  27. # 同步退款状态
  28. public function refund_status_api()
  29. {
  30. $order = Dever::db('shop/sell_order')->select();
  31. foreach ($order as $k => $v) {
  32. if ($v['refund_cash'] > 0) {
  33. if ($v['status'] == 6 || $v['status'] == 8) {
  34. $status = 4;
  35. } else {
  36. $status = 3;
  37. }
  38. } elseif ($v['refund_status'] == 2) {
  39. $status = 2;
  40. } else {
  41. $status = 1;
  42. }
  43. Dever::db('shop/sell_order')->update(array('where_id' => $v['id'], 'refund_status' => $status));
  44. }
  45. $order = Dever::db('shop/buy_order')->select();
  46. foreach ($order as $k => $v) {
  47. if ($v['refund_cash'] > 0) {
  48. if ($v['status'] == 6 || $v['status'] == 8) {
  49. $status = 4;
  50. } else {
  51. $status = 3;
  52. }
  53. } elseif ($v['refund_status'] == 2) {
  54. $status = 2;
  55. } else {
  56. $status = 1;
  57. }
  58. Dever::db('shop/buy_order')->update(array('where_id' => $v['id'], 'refund_status' => $status));
  59. }
  60. }
  61. # 获取7天后完成的订单 准备分账
  62. public function yspay_api()
  63. {
  64. $day = Dever::input('day', 7);
  65. $time = time();
  66. $where['status'] = '5,6';
  67. $where['withdraw'] = 1;
  68. $where['cdate'] = $time - $day*86400;
  69. $order = Dever::db('shop/sell_order')->getDataByTime($where);
  70. if ($order) {
  71. foreach ($order as $k => $v) {
  72. $this->yspayOne($v);
  73. }
  74. }
  75. }
  76. public function yspayOne($v)
  77. {
  78. $shop = Dever::db('shop/info')->find($v['shop_id']);
  79. if ($v['withdraw'] == 1 && $shop && $shop['mid'] && $shop['status'] == 1) {
  80. if ($v['refund_cash']) {
  81. $v['price'] -= $v['refund_cash'];
  82. $v['price'] = round($v['price'], 2);
  83. }
  84. $cash = $v['price'] * 100;//之后还要加上礼品卡的钱
  85. Dever::load('shop/yspay')->action($shop['mid'], $v['order_num'], $v['id'], 2, $cash);
  86. }
  87. }
  88. public function setGoodsStatus_api()
  89. {
  90. $goods = Dever::db('goods/info')->select();
  91. if ($goods) {
  92. foreach ($goods as $k => $v) {
  93. Dever::db('shop/goods')->updates(array('option_goods_id' => $v['id'], 'set_status' => $v['status']));
  94. Dever::db('store/goods')->updates(array('option_goods_id' => $v['id'], 'set_status' => $v['status']));
  95. Dever::db('factory/goods')->updates(array('option_goods_id' => $v['id'], 'set_status' => $v['status']));
  96. }
  97. }
  98. }
  99. /**
  100. * 处理优惠券到期时间
  101. *
  102. * @return mixed
  103. */
  104. public function coupon_api()
  105. {
  106. $coupon = Dever::db('shop/user_coupon')->getAll(array('status' => 1, 'edate' => time() - 86400));
  107. if ($coupon && Dever::project('message')) {
  108. foreach ($coupon as $k => $v) {
  109. $coupon_info = Dever::db('goods/coupon')->find($v['coupon_id']);
  110. $msg = $coupon_info['name'] . ",要到期啦!";
  111. $msg_param['type'] = 2;//消息类型2是优惠券
  112. $msg_param['id'] = $v['id'];
  113. $msg_param['coupon_id'] = $v['coupon_id'];
  114. $msg_param = Dever::json_encode($msg_param);
  115. Dever::load('message/lib/data')->push(-1, $v['uid'], '优惠劵到期提醒', $msg, 4, 1, false, $msg_param);
  116. if (Dever::load('wechat_applet') && $v['uid'] && $v['uid'] > 0) {
  117. $user = Dever::db('passport/wechat')->one(array('uid' => $v['uid'], 'system_id' => 1, 'system_source' => 5));
  118. if ($user && $user['openid']) {
  119. $send = array
  120. (
  121. 'thing1' => array
  122. (
  123. 'value' => $coupon_info['name'],
  124. ),
  125. 'time2' => array
  126. (
  127. 'value' => date('Y-m-d H:i', $v['edate']),
  128. ),
  129. 'thing3' => array
  130. (
  131. 'value' => '您有一张优惠券即将到期,请尽快使用',
  132. ),
  133. );
  134. $send = Dever::json_encode($send);
  135. Dever::load('wechat_applet/subscribe')->sendOne('act_2', 1, $user['openid'], 'pages/my/coupon/coupon', $send, Dever::config('base')->wechat_applet);
  136. }
  137. }
  138. }
  139. }
  140. }
  141. /**
  142. * 处理待支付订单提醒
  143. *
  144. * @return mixed
  145. */
  146. public function order_api()
  147. {
  148. # 获取超过5分钟未支付的订单
  149. $time = time();
  150. $where['status'] = 1;
  151. $where['cdate'] = $time - 300;
  152. $order = Dever::db('shop/sell_order')->getDataByTime($where);
  153. if ($order && Dever::project('message')) {
  154. $config = Dever::db('shop/sell_order')->config;
  155. foreach ($order as $k => $v) {
  156. if ($time - $v['cdate'] >= 900) {
  157. Dever::load('shop/lib/sell')->set(1, 2)->cancel($v['uid'], $v['id'], 11);
  158. Dever::db('shop/sell_order')->update(array('where_id' => $v['id'], 'status' => 11, 'notice' => 2));
  159. } elseif ($v['notice'] == 1) {
  160. Dever::db('shop/sell_order')->update(array('where_id' => $v['id'], 'notice' => 2));
  161. $msg = "您有一笔待付款订单,请及时付款。\r\n订单15分钟内未付款自动取消~";
  162. $shop = Dever::db('shop/info')->one($v['shop_id']);
  163. $msg_param = array();
  164. $msg_param['type'] = 1;//消息类型1是订单消息
  165. $msg_param['id'] = $v['id'];
  166. $msg_param['name'] = $shop['name'];
  167. $msg_param = Dever::json_encode($msg_param);
  168. Dever::load('message/lib/data')->push(-1, $v['uid'], '订单待支付提醒', $msg, 2, 1, false, $msg_param);
  169. if (Dever::load('wechat_applet') && $v['uid'] && $v['uid'] > 0) {
  170. $user = Dever::db('passport/wechat')->one(array('uid' => $v['uid'], 'system_id' => 1, 'system_source' => 5));
  171. if ($user && $user['openid']) {
  172. $v['status_name'] = $config['status'][$v['status']];
  173. $send = array
  174. (
  175. 'character_string5' => array
  176. (
  177. 'value' => $v['order_num'],
  178. ),
  179. 'amount11' => array
  180. (
  181. 'value' => $v['price'] . '元',
  182. ),
  183. 'phrase13' => array
  184. (
  185. 'value' => $v['status_name'],
  186. ),
  187. 'thing12' => array
  188. (
  189. 'value' => '您有一笔待付款订单,请及时付款。',
  190. ),
  191. );
  192. $send = Dever::json_encode($send);
  193. Dever::load('wechat_applet/subscribe')->sendOne('order_pay', 1, $user['openid'], 'pages/app/order/order?id=' . $v['id'], $send, Dever::config('base')->wechat_applet);
  194. }
  195. }
  196. }
  197. }
  198. }
  199. }
  200. /**
  201. * 处理待支付订单提醒
  202. *
  203. * @return mixed
  204. */
  205. public function buy_order_api()
  206. {
  207. $time = time();
  208. $where['status'] = 1;
  209. $where['cdate'] = $time - 7200;
  210. $order = Dever::db('shop/buy_order')->getDataByTime($where);
  211. if ($order) {
  212. foreach ($order as $k => $v) {
  213. Dever::db('shop/buy_order')->update(array('where_id' => $v['id'], 'status' => 11));
  214. }
  215. }
  216. }
  217. /**
  218. * 处理销售数据 生成每天的销量统计
  219. *
  220. * @return mixed
  221. */
  222. public function sell_api()
  223. {
  224. $num = Dever::input('num', 1);
  225. $start = Dever::input('start', date('Y-m-d', strtotime('-'.$num.' day')));
  226. $end = Dever::input('end', date('Y-m-d'));
  227. $where['status'] = '2,3,4,5,6';
  228. $start = Dever::maketime($start . ' 00:00:00');
  229. $end = Dever::maketime($end . ' 23:59:59');
  230. $day = intval(($end - $start)/86400);
  231. $shop = Dever::db('shop/info')->select();
  232. foreach ($shop as $k => $v) {
  233. $where['shop_id'] = $v['id'];
  234. for($i=0; $i<=$day; $i++) {
  235. $where['start'] = $start + 86400*$i;
  236. $where['end'] = $start + 86400*$i + 86399;
  237. $data = array();
  238. $data['shop_id'] = $v['id'];
  239. $data['day'] = $where['start'];
  240. $info = Dever::db('shop/sell_stat')->find($data);
  241. $cash = Dever::db('shop/sell_order')->getCashNum($where);
  242. $data['cash'] = round($cash['total'], 2);
  243. $data['order'] = Dever::db('shop/sell_order')->getOrderNum($where);
  244. if ($data['order'] > 0) {
  245. $goods = Dever::db('shop/sell_order')->getGoodsNum($where);
  246. $data['goods'] = $goods['total'];
  247. $data['area'] = $v['area'];
  248. $data['province'] = $v['province'];
  249. $data['city'] = $v['city'];
  250. $data['county'] = $v['county'];
  251. $data['town'] = $v['town'];
  252. if (!$info) {
  253. Dever::db('shop/sell_stat')->insert($data);
  254. } else {
  255. $data['where_id'] = $info['id'];
  256. Dever::db('shop/sell_stat')->update($data);
  257. }
  258. }
  259. }
  260. }
  261. }
  262. public function buy_api()
  263. {
  264. $num = Dever::input('num', 1);
  265. $start = Dever::input('start', date('Y-m-d', strtotime('-'.$num.' day')));
  266. $end = Dever::input('end', date('Y-m-d'));
  267. $where['status'] = '2,3,4,5,6';
  268. $start = Dever::maketime($start . ' 00:00:00');
  269. $end = Dever::maketime($end . ' 23:59:59');
  270. $day = intval(($end - $start)/86400);
  271. $shop = Dever::db('shop/info')->select();
  272. foreach ($shop as $k => $v) {
  273. $where['type'] = 1;
  274. $where['type_id'] = $v['id'];
  275. for($i=0; $i<=$day; $i++) {
  276. $where['start'] = $start + 86400*$i;
  277. $where['end'] = $start + 86400*$i + 86399;
  278. $data = array();
  279. $data['shop_id'] = $v['id'];
  280. $data['day'] = $where['start'];
  281. $info = Dever::db('shop/buy_stat')->find($data);
  282. $cash = Dever::db('shop/buy_order')->getCashNum($where);
  283. $data['cash'] = round($cash['total'], 2);
  284. $cash = Dever::db('shop/buy_order')->getPCashNum($where);
  285. $data['p_cash'] = round($cash['total'], 2);
  286. $data['order'] = Dever::db('shop/buy_order')->getOrderNum($where);
  287. if ($data['order'] > 0) {
  288. $goods = Dever::db('shop/buy_order')->getGoodsNum($where);
  289. $data['goods'] = $goods['total'];
  290. $data['area'] = $v['area'];
  291. $data['province'] = $v['province'];
  292. $data['city'] = $v['city'];
  293. $data['county'] = $v['county'];
  294. $data['town'] = $v['town'];
  295. if (!$info) {
  296. Dever::db('shop/buy_stat')->insert($data);
  297. } else {
  298. $data['where_id'] = $info['id'];
  299. Dever::db('shop/buy_stat')->update($data);
  300. }
  301. }
  302. }
  303. }
  304. }
  305. /**
  306. * 门店数据统计
  307. *
  308. * @return mixed
  309. */
  310. public function shop_api()
  311. {
  312. $num = Dever::input('num', 1);
  313. $start = Dever::input('start', date('Y-m-d', strtotime('-'.$num.' day')));
  314. $end = Dever::input('end', date('Y-m-d'));
  315. $start = Dever::maketime($start . ' 00:00:00');
  316. $end = Dever::maketime($end . ' 23:59:59');
  317. $day = intval(($end - $start)/86400);
  318. $shop = Dever::db('shop/info')->select();
  319. foreach ($shop as $k => $v) {
  320. $where = array();
  321. $where['status'] = '2,3,4,5,6';
  322. $where['shop_id'] = $v['id'];
  323. for($i=0; $i<=$day; $i++) {
  324. $where['start'] = $start + 86400*$i;
  325. $where['end'] = $start + 86400*$i + 86399;
  326. $data = array();
  327. $data['shop_id'] = $v['id'];
  328. $data['day'] = $where['start'];
  329. $info = Dever::db('shop/shop_stat')->find($data);
  330. $cash = Dever::db('shop/sell_order')->getCashNum($where);
  331. $data['sell_cash'] = round($cash['total'], 2);
  332. $data['sell_num'] = Dever::db('shop/sell_order')->getOrderNum($where);
  333. $where['type'] = 1;
  334. $where['type_id'] = $v['id'];
  335. $cash = Dever::db('shop/buy_order')->getCashNum($where);
  336. $data['buy_cash'] = round($cash['total'], 2);
  337. $data['buy_num'] = Dever::db('shop/buy_order')->getOrderNum($where);
  338. $data['sl_num'] = 0;
  339. $data['area'] = $v['area'];
  340. $data['province'] = $v['province'];
  341. $data['city'] = $v['city'];
  342. $data['county'] = $v['county'];
  343. $data['town'] = $v['town'];
  344. if ($data['buy_num'] > 0) {
  345. if (!$info) {
  346. Dever::db('shop/shop_stat')->insert($data);
  347. } else {
  348. $data['where_id'] = $info['id'];
  349. Dever::db('shop/shop_stat')->update($data);
  350. }
  351. }
  352. }
  353. }
  354. }
  355. /**
  356. * 商品数据统计
  357. *
  358. * @return mixed
  359. */
  360. public function goods_api()
  361. {
  362. $num = Dever::input('num', 1);
  363. $start = Dever::input('start', date('Y-m-d', strtotime('-'.$num.' day')));
  364. $end = Dever::input('end', date('Y-m-d'));
  365. $where['status'] = '1';
  366. $start = Dever::maketime($start . ' 00:00:00');
  367. $end = Dever::maketime($end . ' 23:59:59');
  368. $day = intval(($end - $start)/86400);
  369. $shop = Dever::db('shop/info')->select();
  370. foreach ($shop as $k => $v) {
  371. $where['shop_id'] = $v['id'];
  372. $goods = Dever::db('shop/goods')->select(array('shop_id' => $v['id']));
  373. if ($goods) {
  374. foreach ($goods as $k1 => $v1) {
  375. $where['goods_id'] = $v1['goods_id'];
  376. $goods_info = Dever::db('goods/info')->one($v1['goods_id']);
  377. for($i=0; $i<=$day; $i++) {
  378. $where['start'] = $start + 86400*$i;
  379. $where['end'] = $start + 86400*$i + 86399;
  380. $data = array();
  381. $data['shop_id'] = $v['id'];
  382. $data['goods_id'] = $v1['goods_id'];
  383. $data['day'] = $where['start'];
  384. $info = Dever::db('shop/goods_stat')->find($data);
  385. $cash = Dever::db('shop/sell_order_goods')->getCashNum($where);
  386. $data['cash'] = round($cash['total'], 2);
  387. $data['num'] = Dever::db('shop/sell_order_goods')->getOrderNum($where);
  388. if ($data['num'] > 0) {
  389. $data['area'] = $v['area'];
  390. $data['category'] = $goods_info['category'];
  391. if (!$info) {
  392. Dever::db('shop/goods_stat')->insert($data);
  393. } else {
  394. $data['where_id'] = $info['id'];
  395. Dever::db('shop/goods_stat')->update($data);
  396. }
  397. }
  398. }
  399. }
  400. }
  401. }
  402. }
  403. /**
  404. * 门店数据统计
  405. *
  406. * @return mixed
  407. */
  408. public function user_api()
  409. {
  410. $num = Dever::input('num', 1);
  411. $start = Dever::input('start', date('Y-m-d', strtotime('-'.$num.' day')));
  412. $end = Dever::input('end', date('Y-m-d'));
  413. $start = Dever::maketime($start . ' 00:00:00');
  414. $end = Dever::maketime($end . ' 23:59:59');
  415. $day = intval(($end - $start)/86400);
  416. $shop = Dever::db('shop/info')->select();
  417. foreach ($shop as $k => $v) {
  418. $where = array();
  419. $where['status'] = '2,3,4,5,6';
  420. $where['shop_id'] = $v['id'];
  421. for($i=0; $i<=$day; $i++) {
  422. $where['start'] = $start + 86400*$i;
  423. $where['end'] = $start + 86400*$i + 86399;
  424. $data = array();
  425. $data['shop_id'] = $v['id'];
  426. $data['day'] = $where['start'];
  427. $info = Dever::db('shop/user_stat')->find($data);
  428. $total = Dever::db('shop/sell_order')->getUser($where);
  429. $data['total'] = count($total);
  430. foreach ($total as $k1 => $v1) {
  431. if ($v1['total'] <= 1) {
  432. unset($total[$k1]);
  433. }
  434. }
  435. $data['num'] = count($total);
  436. $data['order_num'] = Dever::db('shop/sell_order')->getOrderNum($where);
  437. if ($data['num'] > 0 || $data['order_num'] > 0) {
  438. $data['area'] = $v['area'];
  439. if (!$info) {
  440. Dever::db('shop/user_stat')->insert($data);
  441. } else {
  442. $data['where_id'] = $info['id'];
  443. Dever::db('shop/user_stat')->update($data);
  444. }
  445. }
  446. }
  447. }
  448. }
  449. /**
  450. * 用户排名统计
  451. *
  452. * @return mixed
  453. */
  454. public function user_rank_api()
  455. {
  456. $num = Dever::input('num', 1);
  457. $start = Dever::input('start', date('Y-m-d', strtotime('-'.$num.' day')));
  458. $end = Dever::input('end', date('Y-m-d'));
  459. $start = Dever::maketime($start . ' 00:00:00');
  460. $end = Dever::maketime($end . ' 23:59:59');
  461. $day = intval(($end - $start)/86400);
  462. $w['start'] = $start;
  463. $w['end'] = $end;
  464. $w['status'] = '2,3,4,5,6';
  465. $data = Dever::db('shop/sell_order')->getAllByDate($w);
  466. if ($data) {
  467. $where = array();
  468. $result = array();
  469. foreach ($data as $k => $v) {
  470. $day = Dever::maketime(date('Y-m-d 00:00:00', $v['cdate']));
  471. $key = $v['shop_id'] . '_' . $day . '_' . $v['mobile'];
  472. if (!isset($result[$key])) {
  473. $result[$key] = array();
  474. $result[$key]['num'] = 0;
  475. $result[$key]['cash'] = 0;
  476. }
  477. $result[$key]['num'] += $v['num'];
  478. $result[$key]['cash'] = $v['total'];
  479. }
  480. if ($result) {
  481. foreach ($result as $k => $v) {
  482. $temp = explode('_', $k);
  483. $where['shop_id'] = $temp[0];
  484. $where['day'] = $temp[1];
  485. $where['mobile'] = $temp[2];
  486. $where['clear'] = true;
  487. $info = Dever::db('shop/user_rank_stat')->find($where);
  488. $up = array();
  489. if (!$info) {
  490. $up = $where;
  491. $shop = Dever::db('shop/info')->one($where['shop_id']);
  492. $up['area'] = $shop['area'];
  493. $up['num'] = $v['num'];
  494. $up['cash'] = $v['cash'];
  495. Dever::db('shop/user_rank_stat')->insert($up);
  496. } else {
  497. $up = array();
  498. $up['where_id'] = $info['id'];;
  499. $up['num'] = $v['num'];
  500. $up['cash'] = $v['cash'];
  501. Dever::db('shop/user_rank_stat')->update($up);
  502. }
  503. }
  504. }
  505. }
  506. }
  507. # 获取下单用户量
  508. public function order_user($where)
  509. {
  510. $where['status'] = '1,2,3,4,5,6';
  511. $user = Dever::db('shop/sell_order')->getUser($where);
  512. return $user;
  513. }
  514. # 处理月度对账数据 废弃,直接用结算单处理
  515. public function sell_month_api()
  516. {
  517. return;
  518. $num = Dever::input('num', -1);
  519. if ($num > 0) {
  520. $month = Dever::input('start', date('Y-m', strtotime('-'.$num.' month')));
  521. } else {
  522. $month = Dever::input('start', date('Y-m'));
  523. }
  524. $where['status'] = 2;
  525. $start = Dever::maketime($month . '-01 00:00:00');
  526. $end = Dever::maketime($month . '-31 23:59:59');
  527. $shop = Dever::db('shop/info')->select();
  528. foreach ($shop as $k => $v) {
  529. $where['shop_id'] = $v['id'];
  530. $where['start'] = $start;
  531. $where['end'] = $end;
  532. $data = array();
  533. $data['shop_id'] = $v['id'];
  534. $data['month'] = $start;
  535. $info = Dever::db('shop/sell_stat_month')->find($data);
  536. $data['cash'] = Dever::db('shop/sell_order')->getCashNum($where);
  537. $data['order'] = Dever::db('shop/sell_order')->getOrderNum($where);
  538. $data['goods'] = Dever::db('shop/sell_order')->getGoodsNum($where);
  539. if (!$info) {
  540. Dever::db('shop/sell_stat_month')->insert($data);
  541. } else {
  542. $data['where_id'] = $info['id'];
  543. Dever::db('shop/sell_stat_month')->update($data);
  544. }
  545. }
  546. }
  547. # 处理月度对账数据:门店采购 废弃,直接用结算单处理
  548. public function buy_month_api()
  549. {
  550. return;
  551. $num = Dever::input('num', -1);
  552. if ($num > 0) {
  553. $month = Dever::input('start', date('Y-m', strtotime('-'.$num.' month')));
  554. } else {
  555. $month = Dever::input('start', date('Y-m'));
  556. }
  557. $where['status'] = '5,6';
  558. $start = Dever::maketime($month . '-01 00:00:00');
  559. $end = Dever::maketime($month . '-31 23:59:59');
  560. $shop = Dever::db('shop/info')->select();
  561. foreach ($shop as $k => $v) {
  562. $where['type'] = 1;
  563. $where['type_id'] = $v['id'];
  564. $where['start'] = $start;
  565. $where['end'] = $end;
  566. $data = array();
  567. $data['shop_id'] = $v['id'];
  568. $data['month'] = $start;
  569. $info = Dever::db('shop/buy_stat_month')->find($data);
  570. $data['cash'] = Dever::db('shop/buy_order')->getCashNum($where);
  571. $data['order'] = Dever::db('shop/buy_order')->getOrderNum($where);
  572. $data['goods'] = Dever::db('shop/buy_order')->getGoodsNum($where);
  573. if (!$info) {
  574. Dever::db('shop/buy_stat_month')->insert($data);
  575. } else {
  576. $data['where_id'] = $info['id'];
  577. Dever::db('shop/buy_stat_month')->update($data);
  578. }
  579. }
  580. }
  581. # 处理月度对账数据:仓库对账 废弃,直接用结算单处理
  582. public function store_month_api()
  583. {
  584. return;
  585. $num = Dever::input('num', -1);
  586. if ($num > 0) {
  587. $month = Dever::input('start', date('Y-m', strtotime('-'.$num.' month')));
  588. } else {
  589. $month = Dever::input('start', date('Y-m'));
  590. }
  591. $where['status'] = '5,6';
  592. $start = Dever::maketime($month . '-01 00:00:00');
  593. $end = Dever::maketime($month . '-31 23:59:59');
  594. $store = Dever::db('store/info')->select();
  595. foreach ($store as $k => $v) {
  596. $where['type'] = 2;
  597. $where['type_id'] = $v['id'];
  598. $where['start'] = $start;
  599. $where['end'] = $end;
  600. $data = array();
  601. $data['store_id'] = $v['id'];
  602. $data['month'] = $start;
  603. $info = Dever::db('shop/store_stat_month')->find($data);
  604. $data['cash'] = Dever::db('shop/buy_order')->getCashNum($where);
  605. $data['order'] = Dever::db('shop/buy_order')->getOrderNum($where);
  606. $data['goods'] = Dever::db('shop/buy_order')->getGoodsNum($where);
  607. if (!$info) {
  608. Dever::db('shop/store_stat_month')->insert($data);
  609. } else {
  610. $data['where_id'] = $info['id'];
  611. Dever::db('shop/store_stat_month')->update($data);
  612. }
  613. }
  614. }
  615. # 处理月度对账数据:工厂对账 废弃,直接用结算单处理
  616. public function factory_month_api()
  617. {
  618. return;
  619. $num = Dever::input('num', -1);
  620. if ($num > 0) {
  621. $month = Dever::input('start', date('Y-m', strtotime('-'.$num.' month')));
  622. } else {
  623. $month = Dever::input('start', date('Y-m'));
  624. }
  625. $where['status'] = '5,6';
  626. $start = Dever::maketime($month . '-01 00:00:00');
  627. $end = Dever::maketime($month . '-31 23:59:59');
  628. $factory = Dever::db('factory/info')->select();
  629. foreach ($factory as $k => $v) {
  630. $where['source_type'] = 3;
  631. $where['source_id'] = $v['id'];
  632. $where['start'] = $start;
  633. $where['end'] = $end;
  634. $data = array();
  635. $data['factory_id'] = $v['id'];
  636. $data['month'] = $start;
  637. $info = Dever::db('shop/factory_stat_month')->find($data);
  638. $data['cash'] = Dever::db('shop/buy_order')->getCashNum($where);
  639. $data['order'] = Dever::db('shop/buy_order')->getOrderNum($where);
  640. $data['goods'] = Dever::db('shop/buy_order')->getGoodsNum($where);
  641. if (!$info) {
  642. Dever::db('shop/factory_stat_month')->insert($data);
  643. } else {
  644. $data['where_id'] = $info['id'];
  645. Dever::db('shop/factory_stat_month')->update($data);
  646. }
  647. }
  648. }
  649. }