ROrderController.php 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760
  1. <?php
  2. class ROrderController extends AdminController{
  3. public function actionIndex()
  4. {
  5. $status_option = ROrder::$status_option;
  6. $status = CommonFn::getComboboxData($status_option, 100, true, 100);
  7. $channel_option = ROrder::$channel_option;
  8. $channels = CommonFn::getComboboxData($channel_option, 100, true, 100);
  9. // 服务信息
  10. $criteria_main = new EMongoCriteria();
  11. $criteria_main->status('==', 1);
  12. $cursor_main = Product::model()->findAll($criteria_main);
  13. $rows_main = CommonFn::getRowsFromCursor($cursor_main);
  14. $main_row = array();
  15. foreach($rows_main as $row){
  16. $ids = (string)$row['_id'];
  17. $main_row[$ids] = array('name' =>$row['name']);
  18. }
  19. $main_products = CommonFn::getComboboxData($main_row, 100, true, 100);
  20. // 服务点信息
  21. $criteria_station = new EMongoCriteria();
  22. $cursor = Station::model()->findAll($criteria_station);
  23. $rows = CommonFn::getRowsFromCursor($cursor);
  24. $parsedRows = Station::model()->parse($rows);
  25. $station_data = array();
  26. foreach ($parsedRows as $key => $v) {
  27. $station_data = array_merge($station_data, array($v['id'] => array('name' => $v['name'])));
  28. }
  29. $station = CommonFn::getComboboxData($station_data, 'all', true, 'all');
  30. // 订单类型
  31. $type_data = Yii::app()->params['o2o_service'];
  32. $type = CommonFn::getComboboxData($type_data, 100, true, 100);
  33. $this->render('index', array(
  34. 'status' => $status,
  35. 'main_products'=> $main_products,
  36. 'channels' => $channels,
  37. 'station' => $station,
  38. 'type' => $type
  39. ));
  40. }
  41. public function actionList(){
  42. $filter_status = intval(Yii::app()->request->getParam('status', 100));
  43. $search = Yii::app()->request->getParam('search', '');
  44. $id = Yii::app()->request->getParam('id', '');
  45. $date_start_order = Yii::app()->request->getParam('date_start_order');
  46. $date_end_order = Yii::app()->request->getParam('date_end_order');
  47. $date_start_book= Yii::app()->request->getParam('date_start_book');
  48. $date_end_book = Yii::app()->request->getParam('date_end_book');
  49. $type = Yii::app()->request->getParam('type', 100);
  50. $have_pay = Yii::app()->request->getParam('have_pay', 0);
  51. $channel = Yii::app()->request->getParam('channel', 100);
  52. //$station = Yii::app()->request->getParam('station', 'all');
  53. $params = CommonFn::getPageParams();
  54. $criteria = new EMongoCriteria($params);
  55. if ($filter_status != 100){
  56. $criteria->status('==', $filter_status);
  57. }
  58. if ($id != ''){
  59. $order_id = new MongoId($id);
  60. $criteria->_id('==', $order_id);
  61. }
  62. if ($channel != 100){
  63. $criteria->channel('==', $channel);
  64. }
  65. if ($type != 100) {
  66. $criteria->type = $type;
  67. }
  68. if ($search != ''){
  69. if(CommonFn::isMongoId($search)){
  70. //$criteria->_id('==', new MongoId($search));
  71. $criteria->addCond('_id','or',new MongoId($search));
  72. $criteria->addCond('user','or',new MongoId($search));
  73. }
  74. else if(preg_match('/\d{8,11}/', $search)){
  75. $criteria->addCond('address.mobile','==',$search);
  76. if($have_pay){
  77. $criteria->addCond('status','>',0);
  78. }
  79. }else if(strlen($search) == 27){
  80. $criteria->charge_id('==', $search);
  81. }else{
  82. $criteria->addCond('address.name','==',$search);
  83. }
  84. }
  85. // 下单时间处理
  86. if (!empty($date_start_order) && !empty($date_end_order)) {
  87. // 开始时间处理
  88. $timestamp_start_order = strtotime($date_start_order);
  89. // 结束时间处理,需通过strototime()增加一天
  90. $timestamp_end_order = strtotime('+1 day', strtotime($date_end_order));
  91. $criteria->order_time('>=', $timestamp_start_order);
  92. $criteria->order_time('<=', $timestamp_end_order);
  93. }
  94. // 预约时间处理
  95. if (!empty($date_start_book) && !empty($date_end_book)) {
  96. // 开始时间处理
  97. $timestamp_start_book = strtotime($date_start_book);
  98. // 结束时间处理,需通过strototime()增加一天
  99. $timestamp_end_book = strtotime('+1 day', strtotime($date_end_book));
  100. $criteria->booking_time('>=', $timestamp_start_book);
  101. $criteria->booking_time('<=', $timestamp_end_book);
  102. }
  103. // 服务站处理
  104. // if ($station != 'all') {
  105. // $criteria->station = new MongoId($station);
  106. //}
  107. $cursor = ROrder::model()->findAll($criteria);
  108. $total = $cursor->count();
  109. $rows = CommonFn::getRowsFromCursor($cursor);
  110. $parsedRows = ROrder::model()->parse($rows);
  111. echo CommonFn::composeDatagridData($parsedRows, $total);
  112. }
  113. public function actionEdit(){
  114. $id = Yii::app()->request->getParam('id', '');
  115. $status = intval(Yii::app()->request->getParam('status',1));
  116. $counts = intval(Yii::app()->request->getParam('count',1));
  117. $booking_time = intval(Yii::app()->request->getParam('booking_time', time()));
  118. $deal_time = intval(Yii::app()->request->getParam('deal_time', time()));
  119. $remark = Yii::app()->request->getParam('remark', '');
  120. //$station = Yii::app()->request->getParam('station_id', '');
  121. $technician_ids = array();
  122. $technician_names = array();
  123. $technicians = array();
  124. $nums = Yii::app()->request->getParam('tech_nums');
  125. for($i=0;$i<=$nums;$i++) {
  126. if(Yii::app()->request->getParam('extra_add_info_'.$i)) {
  127. $technician_ids[] = Yii::app()->request->getParam('extra_add_info_id_'.$i);
  128. $technician_names[] = Yii::app()->request->getParam('extra_add_info_'.$i);
  129. }
  130. }
  131. if(!$counts){
  132. CommonFn::requestAjax(false, '购买数量错误');
  133. }
  134. // 保洁师信息检查
  135. // 根据ID直接查询保洁师信息(优先使用联想功能)
  136. if (isset($technician_ids)) {
  137. foreach($technician_ids as $key => $technician_id){
  138. $technician_obj = TechInfo::get($technician_id);
  139. if ($technician_obj) {
  140. $technicians[$key]['technician_id'] = $technician_obj->_id;
  141. $technicians[$key]['technician_name'] = $technician_obj->name;
  142. } else {
  143. CommonFn::requestAjax(false, '保洁师不存在');
  144. break;
  145. }
  146. }
  147. // ID为0时根据输入框信息查询
  148. } else if (isset($technician_names)) {
  149. $criteria = new EMongoCriteria();
  150. foreach($technician_names as $key => $technician_name) {
  151. $criteria->name = $technician_name;
  152. $technician_obj = TechInfo::model()->find($criteria);
  153. if ($technician_obj) {
  154. $technicians[$key]['technician_id'] = $technician_obj->_id;
  155. $technicians[$key]['technician_name'] = $technician_obj->name;
  156. } else {
  157. CommonFn::requestAjax(false, '保洁师不存在');
  158. break;
  159. }
  160. }
  161. } else {
  162. $technician_obj = null;
  163. //$technician_id = 0;
  164. // $technician_name = '';
  165. foreach($technicians as $key => $value) {
  166. $technicians[$key]['$technician_id'] = 0;
  167. $technicians[$key]['$technician_name'] = 0;
  168. }
  169. }
  170. //var_dump($technicians);exit;
  171. if($status == 100){
  172. CommonFn::requestAjax(false, '必须指定状态!');
  173. }
  174. $criteria = new EMongoCriteria();
  175. $criteria->_id = new MongoId($id);
  176. $order = ROrder::model()->find($criteria);
  177. // if($order->status == -1 || $order->status == -2){
  178. // CommonFn::requestAjax(false, '已取消,已退款订单不支持更改');
  179. // }
  180. // 获取用户信息,修改用户订单统计
  181. // 2015-11-16
  182. $user_id = $order->user;
  183. if (!empty($user_id)) {
  184. $user = RUser::get($user_id);
  185. } else {
  186. $user = '';
  187. }
  188. if (empty($order)){
  189. CommonFn::requestAjax(false, '订单不存在');
  190. }
  191. if(($order->status!=-1||$order->status!=-2)&&($status==-1||$status==-2)){
  192. foreach ($order->coupons as $user_coupon) {
  193. $user_coupon = UserCoupon::get($user_coupon);
  194. $user_coupon->status = 1;
  195. $user_coupon->update(array('status'),true);
  196. }
  197. }
  198. if($order->status!=-2 && $status == -2) {
  199. $order->refund_time = time();
  200. $order_info = $order->parseRow($order);
  201. $month = date('m', $order_info['booking_time']);
  202. $day = date('d', $order_info['booking_time']);
  203. $address = $order_info['address']['poi']['name'] . $order_info['address']['detail'];
  204. $result = Service::factory('PayService')->retrieve($order->charge_id);
  205. if($result === false){
  206. CommonFn::requestAjax(false,'退款遇到点问题了,请稍候再试');
  207. }else{
  208. CommonSMS::send('order_retrieve', array('month' => $month, 'day' => $day, 'address' => $address, 'mobile' => $order_info['address']['mobile']));
  209. // 申请退款处理完成后通知保洁师
  210. foreach ($technician_ids as $key => $technician_id) {
  211. $technician_obj = TechInfo::get($technician_id);
  212. if ($technician_obj && $technician_obj->weixin_userid) {
  213. $url_prefix = ENVIRONMENT == 'product' ? 'http://api.yiguanjia.me' : 'http://apitest.yiguanjia.me';
  214. $wechat = O2oApp::getWechatActive();
  215. $wechat_data = array(
  216. 'touser' => $technician_obj->weixin_userid,
  217. 'msgtype' => 'news',
  218. 'agentid' => '1',
  219. 'news' => array(
  220. 'articles' => array(
  221. array(
  222. 'title' => '壹管家提示-订单退款完成',
  223. 'description' => $technician_obj->name . '你好!用户于' . date('m月d日H:i', $order->apply_refund_time) . '申请退款的订单已处理完成。',
  224. //'url' => $url_prefix . '/index.php?r=o2o/myOrder/info&order=' . $id . '&user=' . $technician_id,
  225. 'url' => $url_prefix . '/index.php?r=o2o/myOrder/index'
  226. ),
  227. ),
  228. ),
  229. );
  230. if (!empty($order->append_orders)) {
  231. $count = count($order->append_orders);
  232. $wechat_data['news']['articles'][0]['description'] .= "\n\n本订单包含" . $count . "个追加订单,请注意查看。";
  233. }
  234. $wechat->sendMessage($wechat_data);
  235. }
  236. }
  237. }
  238. }
  239. //取消订单
  240. if($order->status!=-1 && $status == -1){
  241. // 已完成订单不能取消
  242. if ($order->status == 6) {
  243. CommonFn::requestAjax(false, '已完成订单不可取消');
  244. }
  245. $order->cancel_time = time();
  246. $order_info = $order->parseRow($order);
  247. }
  248. //确认接单
  249. if($order->status!=3 && $status == 3){
  250. $order_info = $order->parseRow($order);
  251. }
  252. //订单完成后执行
  253. if($order->status!=6 && $status == 6 ){
  254. $order->finish_time = time();
  255. $order_info = $order->parseRow($order);
  256. /*$result = Service::factory('ScoreService')->changeScore((string)$order->user,intval($order->final_price),'下单奖爪币');
  257. if($result){
  258. $z_message = new ZMessage();
  259. $from_user = Yii::app()->params['sys_user'];
  260. $message_data = array(
  261. 'from_user' => $from_user,
  262. 'to_user' => (string)$order->user,
  263. 'content' => '您成功下单,获得了'.intval($order->final_price).'个爪币的奖励。',
  264. 'pics' => array(),
  265. 'voice' => array(),
  266. 'video'=> array()
  267. );
  268. $z_message->addMessage($message_data);
  269. CommonSMS::send('final_order',array('name' =>$order_info['address']['name'],'num' =>intval($order->final_price),'mobile'=>$order_info['address']['mobile']));
  270. }*/
  271. // 保洁师订单统计处理
  272. foreach($technician_ids as $key => $technician_id) {
  273. $technician_obj = TechInfo::get($technician_id);
  274. if ($technician_obj) {
  275. $tech_order_count = $technician_obj->order_count + 1;
  276. $technician_obj->order_count = $tech_order_count;
  277. $technician_obj->save();
  278. }
  279. }
  280. }
  281. $order->status = $status;
  282. $order->booking_time = $booking_time;
  283. $order->deal_time = $deal_time;
  284. $order->remark = $remark;
  285. $order->counts = $counts;
  286. //$order->station = new MongoId($station);
  287. // 是否通知保洁师
  288. $toTech = !empty($order->technicians)? true : false;
  289. //$order->technician = $technician_id;
  290. //$order->technician_name = $technician_name;
  291. $order->technicians = $technicians;
  292. //var_dump($order);exit;
  293. $arr_order = array('cancel_time','refund_time','finish_time','status','booking_time','deal_time','remark', 'station', 'technicians');
  294. $success = $order->save(true,$arr_order);
  295. $char = false;
  296. // 通知保洁师
  297. if (in_array($status, array(1,2,3,4,5)) && $toTech && $success) {
  298. foreach($technician_ids as $key => $technician_id) {
  299. $technician_obj = TechInfo::get($technician_id);
  300. if ($technician_obj && $technician_obj->weixin_userid) {
  301. $url_prefix = ENVIRONMENT == 'product' ? 'http://api.yiguanjia.me' : 'http://apitest.yiguanjia.me';
  302. $wechat = O2oApp::getWechatActive();
  303. $wechat_data = array(
  304. 'touser' => $technician_obj->weixin_userid,
  305. 'msgtype' => 'news',
  306. 'agentid' => 1,
  307. 'news' => array(
  308. 'articles' => array(
  309. array(
  310. 'title' => '壹管家提示-新订单',
  311. 'description' => $technician_obj->name . '你好!刚刚有一个新的订单被分配给你,请点击查看。',
  312. //'url' => $url_prefix . '/index.php?r=o2o/myOrder/info&order=' . $id . '&user=' . $technician_id,
  313. 'url' => $url_prefix . '/index.php?r=o2o/myOrder/index'
  314. ),
  315. ),
  316. ),
  317. );
  318. $char = $wechat->sendMessage($wechat_data);
  319. }
  320. }
  321. }
  322. CommonFn::requestAjax($success, '微信'.$char, array());
  323. }
  324. // 根据手机号 获取对应用户的地址信息
  325. public function actionGetUserInfo(){
  326. $mobile = Yii::app()->request->getParam('mobile', '');
  327. $length = strlen($mobile);
  328. if ($length < 11) {
  329. $result[] = array(
  330. 'id' => 0,
  331. 'data' => '',
  332. 'description' => '请继续输入',
  333. 'content' => array()
  334. );
  335. echo json_encode($result);exit;
  336. }
  337. // $mobile_regex = new MongoRegex($mobile);
  338. $criteria = new EMongoCriteria();
  339. $criteria->sort('order_time', EMongoCriteria::SORT_DESC);
  340. $criteria->addCond('address.mobile', '==', $mobile);
  341. $cursor = ROrder::model()->findAll($criteria);
  342. $rows = CommonFn::getRowsFromCursor($cursor);
  343. if (empty($rows)) {
  344. $result[] = array(
  345. 'id' => 0,
  346. 'data' => '',
  347. 'description' => '没有匹配信息',
  348. 'content' => array()
  349. );
  350. echo json_encode($result);exit;
  351. }
  352. $result = array();
  353. $details = array();
  354. $index = 0;
  355. foreach($rows as $row){
  356. // 加入根据detail筛选,避免产生重复信息
  357. if (in_array($row['address']['detail'], $details)) continue;
  358. $details[] = $row['address']['detail'];
  359. $pio = isset($row['address']['poi']['name'])?$row['address']['poi']['name']:'';
  360. // 坐标获取(根据不同的来源)
  361. if ($row['channel'] == 'dianping') {
  362. $latitude = $row['address']['position']['lat'];
  363. $longitude = $row['address']['position']['lng'];
  364. } else {
  365. $latitude = isset($row['address']['position']['1'])?$row['address']['position']['1']:'';
  366. $longitude = isset($row['address']['position']['0'])?$row['address']['position']['0']:'';
  367. }
  368. // poi获取
  369. $poi_name = isset($row['address']['poi']['name']) ? $row['address']['poi']['name'] : '';
  370. $poi_uid = isset($row['address']['poi']['uid']) ? $row['address']['poi']['uid'] : '';
  371. $result[] = array(
  372. 'id' => $index,
  373. 'data' => $row['address']['mobile'],
  374. 'description' => $row['address']['province'].' '.$row['address']['city'].' '.$row['address']['area'].' '.$pio.$row['address']['detail'],
  375. 'content' => array(
  376. 'name' => $row['address']['name'],
  377. 'latitude' => $latitude,
  378. 'longitude' => $longitude,
  379. 'province' => $row['address']['province'],
  380. 'city' => $row['address']['city'],
  381. 'area' => $row['address']['area'],
  382. 'detail' => $row['address']['detail'],
  383. 'poi_name' => $poi_name,
  384. 'poi_uid' => $poi_uid,
  385. 'memo' => $row['memo']
  386. )
  387. );
  388. $index++;
  389. }
  390. echo json_encode($result);exit;
  391. }
  392. public function actionAdd () {
  393. // ------ 必须传入的数值 ------
  394. // --------- 订单信息 ---------
  395. $channel = Yii::app()->request->getParam('channel', '');
  396. $booking_time = Yii::app()->request->getParam('booking_time_add', '');
  397. $order_time = Yii::app()->request->getParam('order_time_add', '');
  398. $main_products = Yii::app()->request->getParam('main_products', '');
  399. $price = floatval(Yii::app()->request->getParam('price', 0));
  400. $final_price = floatval(Yii::app()->request->getParam('final_price', 0));
  401. $status = Yii::app()->request->getParam('status', -3);
  402. $station = Yii::app()->request->getParam('station', '57db39709f5160bb048b456a');
  403. // --------- 地址信息 ---------
  404. $mobile = Yii::app()->request->getParam('mobile', 0);
  405. $latitude = Yii::app()->request->getParam('latitude', 0);
  406. $longitude = Yii::app()->request->getParam('longitude', 0);
  407. $province = Yii::app()->request->getParam('province', '');
  408. $city = Yii::app()->request->getParam('city', '');
  409. $area = Yii::app()->request->getParam('area', '');
  410. $poi_name = Yii::app()->request->getParam('poi_name', '');
  411. $detail = Yii::app()->request->getParam('detail', '');
  412. $counts = intval(Yii::app()->request->getParam('counts', 1));
  413. $counts = $counts?$counts:1;
  414. $extra = Yii::app()->request->getParam('extra','[]');
  415. $extra = json_decode($extra);
  416. // 数据完整性检查
  417. // 2015-11-02 因存在赠送订单,删除金额的数据检查 : $price == 0 || $final_price == 0 ||
  418. // 2015-11-16 取消服务点录入,删除服务点数据检查 : || empty($station)
  419. $flag = empty($channel) || empty($booking_time) || empty($order_time);
  420. $flag = $flag || $status == -3;
  421. $flag = $flag || $mobile == 0 || $latitude == 0 || $longitude == 0;
  422. $flag = $flag || empty($province) || empty($city) || empty($area) || empty($poi_name) || empty($detail);
  423. if ($flag) {
  424. CommonFn::requestAjax(false, '请检查数据完整性', array());
  425. exit;
  426. }
  427. //if($channel == 'wz_app' || $channel == 'wx_pub'){
  428. //CommonFn::requestAjax(false, '不能录入渠道为壹管家微信||壹管家APP的订单', array());
  429. //exit;
  430. //}
  431. // 时间处理
  432. $booking_time = strtotime($booking_time);
  433. $order_time = strtotime($order_time);
  434. // ------ 可以留空的数值 ------
  435. $box = Yii::app()->request->getParam('box', array());
  436. $coupons = Yii::app()->request->getParam('coupons', array());
  437. $memo = Yii::app()->request->getParam('memo', '');
  438. $remark = Yii::app()->request->getParam('remark', '');
  439. $precedence = Yii::app()->request->getParam('precedence', 0);
  440. $have_comment = Yii::app()->request->getParam('have_comment', 0);
  441. $name = Yii::app()->request->getParam('name', '');
  442. $type = Yii::app()->request->getParam('type', 0);
  443. $user = Yii::app()->request->getParam('user', '');
  444. $poi_uid = Yii::app()->request->getParam('poi_uid', '');
  445. // 用户名的判断
  446. $channel_option = ROrder::$channel_option;
  447. $name = empty($name) ? $channel_option[$channel]['name'].'用户' : $name;
  448. // 支付渠道
  449. $pay_channel = $channel;
  450. // 服务数据整合
  451. $products[] = array(
  452. 'product' => new MongoId($main_products),
  453. 'count' => 1,
  454. 'extra' =>$extra
  455. );
  456. if (!empty($box)) {
  457. foreach ($box as $key => $value) {
  458. $products[] = array(
  459. 'product' => new MongoId($value),
  460. 'count' => 1,
  461. 'extra' =>$extra
  462. );
  463. }
  464. }
  465. // 地址数据整合
  466. $address = array(
  467. 'province' => $province,
  468. 'city' => $city,
  469. 'area' => $area,
  470. 'detail' => $detail,
  471. 'mobile' => $mobile,
  472. 'position' => array(
  473. // 'lat' => (float)$latitude,
  474. // 'lng' => (float)$longitude,
  475. 0 => (float)$longitude,
  476. 1 => (float)$latitude
  477. ),
  478. 'poi' => array(
  479. 'name' => $poi_name,
  480. 'uid' => $poi_uid
  481. ),
  482. 'name' => $name
  483. );
  484. // 订单类型判断
  485. if ($type == 0) {
  486. $criteria = new EMongoCriteria();
  487. $criteria->_id = new MongoId($main_products);
  488. $cursor = Product::model()->find($criteria);
  489. $type = $cursor->type;
  490. }
  491. $rOrder = new ROrder();
  492. $rOrder->channel = $channel;
  493. $rOrder->booking_time = intval($booking_time);
  494. $rOrder->order_time = intval($order_time);
  495. $rOrder->products = $products;
  496. $rOrder->price = floatval($price);
  497. $rOrder->final_price = floatval($final_price);
  498. $rOrder->precedence = intval($precedence);
  499. $rOrder->counts = $counts;
  500. $rOrder->coupons = $coupons;
  501. $rOrder->user = $user;
  502. $rOrder->status = intval($status);
  503. $rOrder->memo = $memo;
  504. $rOrder->remark = $remark;
  505. $rOrder->type = strval($type); // 数据库内使用string类型
  506. $rOrder->have_comment = intval($have_comment);
  507. $rOrder->station = new MongoId($station);
  508. $rOrder->address = $address;
  509. $rOrder->pay_channel = $pay_channel;
  510. $addROrder_arr = array('channel', 'booking_time', 'order_time', 'price','products', 'final_price', 'counts','precedence', 'coupons', 'user', 'status', 'memo', 'remark', 'type', 'have_comment', 'station', 'address', 'pay_channel');
  511. $success = $rOrder->save(true, $addROrder_arr);
  512. CommonFn::requestAjax($success, '', array());
  513. }
  514. /**
  515. * 请求申请退款订单接口
  516. */
  517. public function actionCheckRefundOrder() {
  518. $criteria = new EMongoCriteria();
  519. $criteria->status('==', -3);
  520. $cursor = ROrder::model()->findAll($criteria);
  521. $count = $cursor->count();
  522. if ($count > 0) {
  523. $data = array('code' => 1, 'count' => $count);
  524. } else {
  525. $data = array('code' => 0, 'count' => $count);
  526. }
  527. $list = new ARedisList('append_order_list');
  528. if($list->getCount() > 0){
  529. $key = $list->shift();
  530. $list->unshift($key);
  531. $data['procession_append_order_id'] = $key;
  532. $data['code'] = 2;
  533. }
  534. echo json_encode($data);
  535. }
  536. public function actionCancelProcess() {
  537. $orderid = Yii::app()->request->getParam('orderid','');
  538. $list = new ARedisList('append_order_list');
  539. $key = $list->shift();
  540. }
  541. /**
  542. * 重新选择保洁师接口
  543. */
  544. public function actionResetTech() {
  545. $id = Yii::app()->request->getParam('id', '');
  546. $nums = Yii::app()->request->getParam('nums', '');
  547. $technicians = array();
  548. $technician_ids = array();
  549. $technician_names = array();
  550. for($i=1;$i<=$nums;$i++) {
  551. if(Yii::app()->request->getParam('reset_extra_add_info_'.$i)) {
  552. $technician_ids[] = Yii::app()->request->getParam('reset_extra_add_info_id_'.$i);
  553. $technician_names[] = Yii::app()->request->getParam('reset_extra_add_info_'.$i);
  554. }
  555. }
  556. // 保洁师信息检查
  557. // 根据ID直接查询保洁师信息(优先使用联想功能)
  558. $technician_objs = array();
  559. foreach($technician_ids as $key => $technician_id) {
  560. if ($technician_id != 0) {
  561. $technician_obj = TechInfo::get($technician_id);
  562. if ($technician_obj) {
  563. $technicians[$key]['technician_id'] = $technician_obj->_id;
  564. $technicians[$key]['technician_name'] = $technician_obj->name;
  565. } else {
  566. CommonFn::requestAjax(false, '保洁师不存在');
  567. }
  568. // ID为0时根据输入框信息查询
  569. } else {
  570. foreach ($technician_names as $key => $technician_name)
  571. if ($technician_name != '') {
  572. $criteria = new EMongoCriteria();
  573. $criteria->name = $technician_name;
  574. $technician_obj = TechInfo::model()->find($criteria);
  575. if ($technician_obj) {
  576. $technicians[$key]['technician_id'] = $technician_obj->_id;
  577. $technicians[$key]['technician_name'] = $technician_obj->name;
  578. } else {
  579. CommonFn::requestAjax(false, '保洁师不存在');
  580. }
  581. } else {
  582. CommonFn::requestAjax(false, '保洁师姓名不能为空');
  583. }
  584. }
  585. $technician_objs[] = $technician_obj;
  586. }
  587. $orderid = new MongoId($id);
  588. $order = ROrder::model()->get($orderid);
  589. $toTech = isset($order->technicians) ? true : false;
  590. $fromTechs = $technician_names;
  591. //$order->technician = $technician_id;
  592. //$order->technician_name = $technician_name;
  593. $order->technicians = $technicians;
  594. $success = $order->save(true, array('technicians'));
  595. if ($toTech && $success) {
  596. foreach ($technician_objs as $technician_obj) {
  597. // 发送给被分配保洁师
  598. $wechat = O2oApp::getWechatActive();
  599. $url_prefix = ENVIRONMENT == 'product' ? 'http://api.yiguanjia.me' : 'http://apitest.yiguanjia.me';
  600. if (!empty($technician_obj->weixin_userid)) {
  601. $wechat_data = array(
  602. 'touser' => $technician_obj->weixin_userid,
  603. 'msgtype' => 'news',
  604. 'agentid' => '1',
  605. 'news' => array(
  606. 'articles' => array(
  607. array(
  608. 'title' => '壹管家提示-新订单',
  609. 'description' => $technician_obj->name . '你好!刚刚有一个新的订单被分配给你,请点击查看。',
  610. //'url' => $url_prefix . '/index.php?r=o2o/myOrder/info&order=' . $id . '&user=' . $technician_obj->_id,
  611. 'url' => $url_prefix . '/index.php?r=o2o/myOrder/index'
  612. ),
  613. ),
  614. ),
  615. );
  616. $wechat->sendMessage($wechat_data);
  617. }
  618. }
  619. // 发送给原保洁师
  620. foreach ($fromTechs as $fromTech) {
  621. $fromTechObj = TechInfo::get($fromTech);
  622. if (!empty($fromTechObj) && !empty($fromTechObj->weixin_userid)) {
  623. $wechat_data = array(
  624. 'touser' => $fromTechObj->weixin_userid,
  625. 'msgtype' => 'news',
  626. 'agentid' => '1',
  627. 'news' => array(
  628. 'articles' => array(
  629. array(
  630. 'title' => '壹管家提示-订单已被重新分配',
  631. 'description' => $fromTechObj->name . '你好!预定时间在' . date('m月d日H:i', $order->booking_time) . '的订单已被分配给其他保洁师。',
  632. 'url' => $url_prefix . '/index.php?r=o2o/myOrder/info&order=' . $id . '&user=' . $technician_obj->_id,
  633. ),
  634. ),
  635. ),
  636. );
  637. $wechat->sendMessage($wechat_data);
  638. }
  639. }
  640. }
  641. CommonFn::requestAjax($success, '', array());
  642. }
  643. public function actionDelOrder(){
  644. $delOrder = array('5826a4c89f5160d1048b52bf');
  645. $total = 0;
  646. foreach($delOrder as $value){
  647. $order = ROrder::model()->get(new MongoId($value));
  648. if($order->delete()){
  649. $total += 1;
  650. }
  651. }
  652. echo $total;
  653. }
  654. }