EnergyElectricityRecord2.php 9.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260
  1. <?php
  2. namespace app\admin\controller;
  3. use app\common\model\User;
  4. use think\App;
  5. use think\Db;
  6. class EnergyElectricityRecord2 extends Auth
  7. {
  8. public function __construct(App $app = null) {
  9. parent::__construct($app);
  10. $this->model = new \app\common\model\EnergyElectricityRecord();
  11. }
  12. public function index(){
  13. if(request()->isAjax()){
  14. //分页参数
  15. $length = input('rows',10,'intval'); //每页条数
  16. $page = input('page',1,'intval'); //第几页
  17. $start = ($page - 1) * $length; //分页开始位置
  18. //排序
  19. $sortRow = input('sidx','sort','trim'); //排序列
  20. $sort = input('sord','asc','trim'); //排序方式
  21. $order = $sortRow.' '.$sort.' ,id desc';
  22. $sn = input('sn','','trim');
  23. if($sn){
  24. $map[] = ['sn','=',$sn];
  25. }
  26. $ids = Db::name('energy_electricity')
  27. ->where('org_id',$this->orgId)
  28. ->where('del',0)
  29. ->where('parent_id',0)
  30. ->column('number');
  31. if (!empty($ids)) {
  32. $map[] = ['sn','in',$ids];
  33. }
  34. $map[] = ['org_id','=',$this->orgId];
  35. $map[] = ['del','=',0];
  36. $map= empty($map) ? true: $map;
  37. //数据查询
  38. $lists = Db::name('energy_electricity_record')
  39. ->where($map)->limit($start,$length)
  40. ->order($order)->select();
  41. foreach($lists as $k=>$v){
  42. $lists[$k]['user_id'] = Db::name('user')->where('id',$v['user_id'])->value('real_name');
  43. }
  44. //数据返回
  45. $totalCount = db('energy_electricity_record')->where($map)->count();
  46. $totalPage = ceil($totalCount/$length);
  47. $result['page'] = $page;
  48. $result['total'] = $totalPage;
  49. $result['records'] = $totalCount;
  50. $result['rows'] = $lists;
  51. return json($result);
  52. }else{
  53. $this->assign('meta_title','电表抄表记录');
  54. return $this->fetch();
  55. }
  56. }
  57. /**
  58. * 新增/编辑
  59. */
  60. public function add($id=0){
  61. $model = $this->model;
  62. $userId = is_login();
  63. if(request()->isPost()){
  64. $res = $model->updates($userId,0);
  65. if($res){
  66. $this->success('操作成功',url('index'));
  67. }else{
  68. $this->error($model->getError());
  69. }
  70. }else{
  71. if($id){
  72. $info = db('energy_electricity_record')->where('id',$id)->find();
  73. $this->assign('info',$info);
  74. }
  75. return $this->fetch();
  76. }
  77. }
  78. /**
  79. * 删除记录
  80. * @param int $id
  81. */
  82. public function del($id=0){
  83. if(!$id){
  84. $this->error('参数错误');
  85. }
  86. $res = Db::name('energy_electricity_record')->where('id',$id)->update(['del'=>1]);
  87. if($res){
  88. $this->success('删除成功');
  89. }else{
  90. $this->error('删除失败');
  91. }
  92. }
  93. public function import(){
  94. return $this->fetch();
  95. }
  96. /**
  97. * 下载点模板
  98. */
  99. public function downloadtem(){
  100. set_time_limit(0);
  101. ini_set("memory_limit","512M");
  102. include_once env('root_path').'/extend/phpexcel/Classes/PHPExcel.php';
  103. $types = model('Address')->getTypes();
  104. ksort($types);
  105. $fileName = '电表抄表记录模板.xlsx';
  106. $excel = new \PHPExcel();
  107. $sheet = $excel->setActiveSheetIndex(0);
  108. $arr = array('A','B','C','D','E','F','G');
  109. foreach($arr as $k=>$v){
  110. $excel->getActiveSheet()->getStyle($v)->getAlignment()->setWrapText(true);//换行
  111. $excel->getActiveSheet()->getStyle($v.'1')->getFont()->setBold(true);
  112. $excel->getActiveSheet()->getColumnDimension($v)->setWidth(18);
  113. }
  114. $sheet->setCellValueByColumnAndRow(0,1,'日期');
  115. $sheet->setCellValueByColumnAndRow(1,1,'表号');
  116. $sheet->setCellValueByColumnAndRow(2,1,'倍率');
  117. $sheet->setCellValueByColumnAndRow(3,1,'抄表读数');
  118. $sheet->setCellValueByColumnAndRow(4,1,'最低温度 (℃))');
  119. $sheet->setCellValueByColumnAndRow(5,1,'最高温度 (℃))');
  120. $sheet->setCellValueByColumnAndRow(6,1,'床位数量');
  121. $excel->getActiveSheet()->setCellValue('A2', '2024/09/23');
  122. $excel->getActiveSheet()->setCellValue('B2', 'D1101');
  123. $excel->getActiveSheet()->setCellValue('C2', '10');
  124. $excel->getActiveSheet()->setCellValue('D2', '100');
  125. $excel->getActiveSheet()->setCellValue('E2', '10');
  126. $excel->getActiveSheet()->setCellValue('F2', '22');
  127. $excel->getActiveSheet()->setCellValue('G2', '120');
  128. ob_end_clean();//清除缓冲区,避免乱码
  129. header('Content-Type: application/vnd.ms-excel');
  130. header('Content-Disposition: attachment;filename="'.$fileName.'"');
  131. header('Cache-Control: max-age=0');
  132. $objWriter = \PHPExcel_IOFactory::createWriter($excel, 'Excel2007');
  133. $objWriter->save('php://output'); //文件通过浏览器下载
  134. }
  135. /**
  136. * 导入
  137. */
  138. public function importexcel(){
  139. set_time_limit(0);
  140. ini_set("memory_limit", -1);
  141. ob_flush();//清空缓存
  142. flush();//刷新缓存
  143. include_once env('root_path').'/extend/phpexcel/Classes/PHPExcel.php';
  144. $orgId = $this->orgId;
  145. if(request()->file()) {
  146. $file = request()->file('file');
  147. //获取文件后缀
  148. $e = explode('.',$_FILES['file']['name']);
  149. $ext = $e[count($e)-1];
  150. if($ext == 'xls'){
  151. \PHPExcel_IOFactory::createReader( 'Excel5');
  152. }else{
  153. \PHPExcel_IOFactory::createReader('Excel2007');
  154. }
  155. $newArr=['xls','xlsx'];
  156. if(!in_array($ext,$newArr)){
  157. exit('文件格式不正确');
  158. }
  159. // 移动到框架应用根目录/uploads/ 目录下
  160. $info = $file->validate([ 'size'=>config('app.max_upload_file_size') ])
  161. ->move(env('root_path') . 'public' . DIRECTORY_SEPARATOR . 'uploads'. DIRECTORY_SEPARATOR . 'files');
  162. if(!$info){
  163. exit('文件上传失败');
  164. }
  165. $img = './uploads/files/' . $info->getSaveName();
  166. $filePath = str_replace('\\', '/', $img);
  167. $newPath = \PHPExcel_IOFactory::load($filePath);
  168. $excelArray = $newPath->getsheet(0)->toArray(); //转换为数组格式
  169. array_shift($excelArray); //删除第一个数组(标题);
  170. if(empty($excelArray)){
  171. exit('文件内容为空');
  172. }
  173. $ids = Db::name('energy_electricity')
  174. ->where('org_id',$this->orgId)
  175. ->where('del',0)
  176. ->where('parent_id',0)
  177. ->column('number');
  178. $flag = 0;
  179. foreach ($excelArray as $k => $v) {
  180. if (!$v[0] || !$v[1] || !$v[2] || !$v[3]) {
  181. $flag = 1;
  182. echo "<font color=\"red\" style='margin-left: 20px;font-size: 17px'>第" . ($k + 1) . "行,有数据为空,请修改后重新导入</font><br />";
  183. continue;
  184. }
  185. if (!in_array($v[1], $ids)) {
  186. $flag = 1;
  187. echo "<font color=\"red\" style='margin-left: 20px;font-size: 17px'>第" . ($k + 1) . "行,表号不存在或非总表表号,请修改后重新导入</font><br />";
  188. continue;
  189. }
  190. }
  191. if ($flag > 0) {
  192. exit();
  193. }
  194. $data = [];
  195. foreach ($excelArray as $k => $v) {
  196. $degree = trim($v[3]);
  197. $change = Db::name('energy_change_log')
  198. ->where('org_id',$this->orgId)
  199. ->where('sn',$v[1])
  200. ->order('id desc')
  201. ->value('degree');
  202. if ($change){
  203. $degree += $change;
  204. }
  205. $data[] = [
  206. 'org_id'=>$this->orgId,
  207. 'read_time'=>date('Y-m-d',strtotime($v[0])),
  208. 'sn'=>$v[1],
  209. 'rate'=>$v[2],
  210. 'degree'=>$degree,
  211. 'min_temperature'=>$v[4],
  212. 'max_temperature'=>$v[5],
  213. 'user_id'=>is_login(),
  214. 'read_yyyy'=>date('Y',strtotime($v[0])),
  215. 'read_yyyymm'=>date('Ym',strtotime($v[0])),
  216. 'read_yyyymmdd'=>date('Ymd',strtotime($v[0])),
  217. 'create_time'=>getTime(),
  218. ];
  219. }
  220. $ret=Db::name('energy_electricity_record')->insertAll($data);
  221. if(!$ret){
  222. echo "<font color=\"red\" style='margin-left: 20px;font-size: 17px'>批量导入失败</font><br />";
  223. }else{
  224. echo "<font color=\"green\" style='margin-left:20px;font-size: 17px'>批量导入成功</font><br />";
  225. }
  226. }else{
  227. exit('请上传文件');
  228. }
  229. }
  230. public function multiDel() {
  231. $ids = input('ids', [], 'trim');
  232. if (empty($ids)) {
  233. $this->error('未选择记录');
  234. }
  235. $res = Db::name('energy_electricity_record')->whereIn('id', $ids)->update(['del'=>1]);
  236. if (!$res) $this->error('批量删除失败');
  237. $this->success('批量删除传成功');
  238. }
  239. }