provider_group.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280
  1. <?php
  2. require_once(BASE_CONFIG_PATH . CONFIG_PREFIX . '/refill.ini.php');
  3. require_once(BASE_HELPER_PATH . '/mtopcard/mtopcard.php');
  4. class provider_groupControl extends SystemControl
  5. {
  6. public function __construct()
  7. {
  8. parent::__construct();
  9. }
  10. public function indexOp()
  11. {
  12. $mod = Model('provider_group');
  13. $condition = [];
  14. if (trim($_GET['group_name']) != '') {
  15. $condition['group_name'] = ['like', '%' . $_GET['group_name'] . '%'];
  16. }
  17. $group_list = $mod->getGroupList($condition, 30, 'add_time desc');
  18. Tpl::output('group_list', $group_list);
  19. Tpl::output('page', $mod->showpage('2'));
  20. Tpl::showpage('provider.group.list');
  21. }
  22. public function addOp()
  23. {
  24. if (chksubmit()) {
  25. $obj_validate = new Validator();
  26. $obj_validate->validateparam = [
  27. ["input" => $_POST["group_name"], "require" => "true", "message" => '通道组名称不能为空'],
  28. ];
  29. $error = $obj_validate->validate();
  30. if ($error != '') {
  31. showMessage($error);
  32. } else {
  33. $mod = Model('provider_group');
  34. $insert['group_name'] = trim($_POST['group_name']);
  35. $insert['add_time'] = time();
  36. $result = $mod->addGroup($insert);
  37. if ($result) {
  38. showMessage('添加成功', 'index.php?act=provider_group&op=index');
  39. } else {
  40. showMessage('添加失败');
  41. }
  42. }
  43. }
  44. Tpl::showpage('provider.group.add');
  45. }
  46. public function editOp()
  47. {
  48. $group_id = $_GET['group_id'] ?? $_POST['group_id'];
  49. $mod = Model('provider_group');
  50. $group = $mod->getProviderGroup(['group_id' => $group_id]);
  51. if(empty($group)) {
  52. showMessage('通道组不存在');
  53. }
  54. if(chksubmit()) {
  55. $updata['group_name'] = trim($_POST['group_name']);
  56. $updata['bz'] = trim($_POST['bz']);
  57. $result = $mod->editGroup($group_id, $updata);
  58. if ($result) {
  59. showMessage('编辑成功', 'index.php?act=provider_group&op=index');
  60. } else {
  61. showMessage('编辑失败');
  62. }
  63. }else{
  64. Tpl::output('group', $group);
  65. Tpl::showpage('provider.group.edit');
  66. }
  67. }
  68. public function provider_chooseOp()
  69. {
  70. $group_id = $_GET['group_id']??$_POST['group_id'];
  71. $mod = Model('provider_group');
  72. $provider_group = $mod->getProviderGroup(['group_id' => $group_id]);
  73. if(empty($provider_group)) {
  74. showMessage('此通道组不存在');
  75. }
  76. if(chksubmit()) {
  77. $condition['group_id'] = $group_id;
  78. $condition['quality'] = $_POST['quality'];
  79. $condition['type'] = $_POST['type'];
  80. $is_only = $_POST['is_only']??0;
  81. $group_info = $mod->getGroupInfo($condition);
  82. if($group_info['is_only'] == $is_only) {
  83. showMessage('编辑成功');
  84. }
  85. $result = $mod->editGroupInfo($condition,['is_only' => $is_only]);
  86. if ($result) {
  87. showMessage('编辑成功');
  88. } else {
  89. showMessage('编辑失败');
  90. }
  91. } else {
  92. Tpl::output('group', $provider_group);
  93. Tpl::showpage('provider.group');
  94. }
  95. }
  96. public function get_provider_group_infoOp(){
  97. $mod = Model('provider_group');
  98. $condition['group_id'] = $_GET['group_id'];
  99. $condition['quality'] = $_GET['quality'];
  100. $condition['type'] = $_GET['type'];
  101. $group_info = $mod->getGroupInfo($condition);
  102. $infos = explode(',', $group_info['info']);
  103. if(empty($group_info['info'])) {
  104. echo(json_encode([]));
  105. exit;
  106. }
  107. $provider_list = Model('')->table('refill_provider,store')
  108. ->field('refill_provider.provider_id,store.store_name')
  109. ->join('inner')
  110. ->on('store.store_id=refill_provider.store_id')
  111. ->limit(1000)
  112. ->select();
  113. foreach ($provider_list as $provider) {
  114. $providers[$provider['provider_id']] = $provider['store_name'];
  115. }
  116. $datas = [];
  117. foreach($infos as $info) {
  118. $info = explode('-', $info);
  119. $store_name = $providers[$info[4]];
  120. $card_type = $this->scard_type($info[2]);
  121. $datas[$info[3]][] = "{$store_name}-{$card_type}-{$info[3]}元";
  122. }
  123. ksort($datas);
  124. $result['data'] = $datas;
  125. $result['is_only'] = $group_info['is_only'];
  126. echo(json_encode($result));
  127. exit;
  128. }
  129. public function set_provider_group_infoOp()
  130. {
  131. $type = $_GET['type'] ?? $_POST['type'];
  132. if(!in_array($type, [1,2])) {
  133. showMessage('通道类型有误');
  134. }
  135. if (chksubmit()){
  136. $group_id = $_POST['group_id'];
  137. $quality = $_POST['quality'];
  138. $info = $_POST['info'];
  139. $is_only = $_POST['is_only'];
  140. $inserts['group_id'] = $group_id;
  141. $inserts['type'] = $type;
  142. $inserts['quality'] = $quality;
  143. $inserts['info'] = implode(',', $info);
  144. $inserts['is_only'] = $is_only;
  145. try {
  146. $mod = Model('provider_group');
  147. $trans = new trans_wapper($mod, __METHOD__);
  148. //删除旧配置
  149. $mod->delGroupInfo(['group_id' => $group_id, 'type' => $type, 'quality' => $quality]);
  150. //更新新配置
  151. if (!empty($inserts)) {
  152. $mod->addGroupInfo($inserts);
  153. }
  154. $trans->commit();
  155. showMessage('操作成功', 'index.php?act=provider_group&op=index');
  156. } catch (Exception $e) {
  157. $trans->rollback();
  158. showMessage('操作失败', '');
  159. }
  160. }else{
  161. global $config;
  162. if($type == 1 ) {
  163. $amounts = $config['refill_oil_specs'];
  164. $operator = [mtopcard\PetroChinaCard, mtopcard\SinopecCard];
  165. }else{
  166. $amounts = $config['refill_phone_specs'];
  167. $operator = [mtopcard\ChinaMobileCard, mtopcard\ChinaUnicomCard, mtopcard\ChinaTelecomCard];
  168. }
  169. $quality = $_GET['quality'] ?? 1;
  170. $providers = Model('')->table('refill_provider,store')
  171. ->field('refill_provider.provider_id,refill_provider.name,store.store_name')
  172. ->join('inner')
  173. ->on('store.store_id=refill_provider.store_id')
  174. ->where(['type' => $type, 'opened' => 1, 'qualitys' => ['like', '%' . $quality . '%']])
  175. ->limit(1000)
  176. ->order('opened asc , provider_id desc')
  177. ->select();
  178. if(empty($providers)) {
  179. showMessage('暂无相关通道可配置', '');
  180. }
  181. $results = [];
  182. foreach ($operator as $opr) {
  183. foreach ($providers as $key => $provider) {
  184. $data['provider_id'] = $provider['provider_id'];
  185. $data['provider_name'] = $provider['name'];
  186. $data['card_type'] = $opr;
  187. $card_type = $this->scard_type($opr);
  188. $data['name'] = "{$card_type}-{$provider['store_name']}";
  189. $results[] = $data;
  190. }
  191. }
  192. $mod = Model('provider_group');
  193. $condition['group_id'] = $_GET['group_id'];
  194. $condition['quality'] = $quality;
  195. $condition['type'] = $type;
  196. $group_info = $mod->getGroupInfo($condition);
  197. $infos = explode(',', $group_info['info']);
  198. $sel_data = [];
  199. foreach($infos as $info) {
  200. $info = explode('-', $info);
  201. $sel_data[] = "{$info[0]}-{$info[1]}-{$info[2]}-{$info[3]}-{$info[4]}";
  202. }
  203. Tpl::output('is_only', $group_info['is_only']);
  204. Tpl::output('sel_data', $sel_data);
  205. Tpl::output('providers', $results);
  206. Tpl::output('amounts', $amounts);
  207. Tpl::showpage('provider.group.set');
  208. }
  209. }
  210. private function scard_type(int $card_type)
  211. {
  212. if ($card_type == mtopcard\PetroChinaCard) { //中石油
  213. return '中石油';
  214. } elseif ($card_type == mtopcard\SinopecCard) { //中石化
  215. return '中石化';
  216. } elseif ($card_type == mtopcard\ChinaMobileCard) { //中国移动
  217. return '中国移动';
  218. } elseif ($card_type == mtopcard\ChinaUnicomCard) { //中国联通
  219. return '中国联通';
  220. } elseif ($card_type == mtopcard\ChinaTelecomCard) { //中国电信
  221. return '中国电信';
  222. } else {
  223. return 'unknown';
  224. }
  225. }
  226. public function merchant_sel_groupOp()
  227. {
  228. $mchid = $_GET['mchid'] ?? $_POST['mchid'];
  229. $model_merchant = Model('merchant');
  230. $merchant = $model_merchant->getMerchantInfo(['mchid' => $mchid]);
  231. if (empty($merchant)) {
  232. showMessage('机构信息有误');
  233. }
  234. if (chksubmit()){
  235. $sel = $_POST['sel'];
  236. if(empty($sel)) {
  237. $update['group_ids'] = '';
  238. }else{
  239. $sel = implode(',', $sel);
  240. $update['group_ids'] = $sel;
  241. }
  242. $result = $model_merchant->editMerchant($update, ['mchid' => $mchid]);
  243. if ($result) {
  244. showMessage('编辑成功', 'index.php?act=merchant&op=merchant');
  245. }else{
  246. showMessage('编辑失败', 'index.php?act=merchant&op=merchant');
  247. }
  248. } else {
  249. $group_mod = Model('provider_group');
  250. $group_list = $group_mod->getGroupList(['group_id' => ['gt', 0]], 30, 'add_time desc');
  251. if(empty($group_list)) {
  252. showMessage('暂无可用通道组,请先添加。','index.php?act=provider_group&op=index');
  253. }
  254. $group_ids = explode(',', $merchant['group_ids']);
  255. Tpl::output('group_ids', $group_ids);
  256. Tpl::output('merchant', $merchant);
  257. Tpl::output('group_list', $group_list);
  258. Tpl::showpage('merchant.sel.group');
  259. }
  260. }
  261. }