|
@@ -1,11 +1,27 @@
|
|
package com.huimv.secure.service.impl;
|
|
package com.huimv.secure.service.impl;
|
|
|
|
|
|
|
|
+import cn.hutool.core.util.ObjectUtil;
|
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
|
+import com.alibaba.fastjson.JSONException;
|
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
|
+import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
|
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
+import com.huimv.secure.common.utils.DataUill;
|
|
|
|
+import com.huimv.secure.common.utils.Result;
|
|
|
|
+import com.huimv.secure.common.utils.ResultCode;
|
|
import com.huimv.secure.entity.BillPersonnelAdmission;
|
|
import com.huimv.secure.entity.BillPersonnelAdmission;
|
|
|
|
+import com.huimv.secure.entity.vo.BillAdmissionVo;
|
|
|
|
+import com.huimv.secure.entity.vo.ListAdmissionVo;
|
|
import com.huimv.secure.mapper.BillPersonnelAdmissionMapper;
|
|
import com.huimv.secure.mapper.BillPersonnelAdmissionMapper;
|
|
import com.huimv.secure.service.IBillPersonnelAdmissionService;
|
|
import com.huimv.secure.service.IBillPersonnelAdmissionService;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
|
|
|
+import javax.annotation.Resource;
|
|
|
|
+import javax.servlet.http.HttpServletRequest;
|
|
|
|
+import java.util.*;
|
|
|
|
+
|
|
/**
|
|
/**
|
|
* <p>
|
|
* <p>
|
|
* 入场申请 服务实现类
|
|
* 入场申请 服务实现类
|
|
@@ -17,4 +33,229 @@ import org.springframework.stereotype.Service;
|
|
@Service
|
|
@Service
|
|
public class BillPersonnelAdmissionServiceImpl extends ServiceImpl<BillPersonnelAdmissionMapper, BillPersonnelAdmission> implements IBillPersonnelAdmissionService {
|
|
public class BillPersonnelAdmissionServiceImpl extends ServiceImpl<BillPersonnelAdmissionMapper, BillPersonnelAdmission> implements IBillPersonnelAdmissionService {
|
|
|
|
|
|
|
|
+ @Resource
|
|
|
|
+ private BillPersonnelAdmissionMapper billPersonnelAdmissionMapper;
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public Result countAdmission(Map<String, String> paramsMap) {
|
|
|
|
+ String farmId = paramsMap.get("farmId");
|
|
|
|
+ String type = paramsMap.get("type");
|
|
|
|
+ if ("".equals(type) || type == null) {
|
|
|
|
+ type = "1";
|
|
|
|
+ }
|
|
|
|
+ List<ListAdmissionVo> admissionVo = null;
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("farm_id", farmId);
|
|
|
|
+ //默认今日
|
|
|
|
+ if ("1".equals(type)) {
|
|
|
|
+ Date timesmorning = DataUill.getTimesmorning();
|
|
|
|
+ queryWrapper.ge("sub_date", timesmorning);
|
|
|
|
+ admissionVo = billPersonnelAdmissionMapper.countAdmission(queryWrapper);
|
|
|
|
+ for (ListAdmissionVo listAdmissionVo : admissionVo) {
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
+ queryWrapper1.eq("farm_id", farmId).ge("sub_date", timesmorning)
|
|
|
|
+ .eq("vistit_type", listAdmissionVo.getType()).eq("bill_status", 1);
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper2 = new QueryWrapper<>();
|
|
|
|
+ queryWrapper2.eq("farm_id", farmId).ge("sub_date", timesmorning)
|
|
|
|
+ .eq("vistit_type", listAdmissionVo.getType()).eq("bill_status", 2);
|
|
|
|
+ listAdmissionVo.setPassCount(billPersonnelAdmissionMapper.selectCount(queryWrapper1));
|
|
|
|
+ listAdmissionVo.setRefuseCount(billPersonnelAdmissionMapper.selectCount(queryWrapper2));
|
|
|
|
+ }
|
|
|
|
+ } else if ("2".equals(type)) {
|
|
|
|
+ // 本周
|
|
|
|
+ Calendar calendar = Calendar.getInstance();
|
|
|
|
+ calendar.set(Calendar.DATE, calendar.get(Calendar.DATE) - 7);
|
|
|
|
+ queryWrapper.ge("sub_date", calendar.getTime());
|
|
|
|
+ admissionVo = billPersonnelAdmissionMapper.countAdmission(queryWrapper);
|
|
|
|
+ for (ListAdmissionVo listAdmissionVo : admissionVo) {
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
+ queryWrapper1.eq("farm_id", farmId).ge("sub_date", calendar.getTime())
|
|
|
|
+ .eq("vistit_type", listAdmissionVo.getType()).eq("bill_status", 1);
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper2 = new QueryWrapper<>();
|
|
|
|
+ queryWrapper2.eq("farm_id", farmId).ge("sub_date", calendar.getTime())
|
|
|
|
+ .eq("vistit_type", listAdmissionVo.getType()).eq("bill_status", 2);
|
|
|
|
+ listAdmissionVo.setPassCount(billPersonnelAdmissionMapper.selectCount(queryWrapper1));
|
|
|
|
+ listAdmissionVo.setRefuseCount(billPersonnelAdmissionMapper.selectCount(queryWrapper2));
|
|
|
|
+ }
|
|
|
|
+ } else if ("3".equals(type)) {
|
|
|
|
+ //本月
|
|
|
|
+ Date timesMonthmorning = DataUill.getTimesMonthmorning();
|
|
|
|
+ queryWrapper.ge("sub_date", timesMonthmorning);
|
|
|
|
+ admissionVo = billPersonnelAdmissionMapper.countAdmission(queryWrapper);
|
|
|
|
+ for (ListAdmissionVo listAdmissionVo : admissionVo) {
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper1 = new QueryWrapper<>();
|
|
|
|
+ queryWrapper1.eq("farm_id", farmId).ge("sub_date", timesMonthmorning)
|
|
|
|
+ .eq("vistit_type", listAdmissionVo.getType()).eq("bill_status", 1);
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper2 = new QueryWrapper<>();
|
|
|
|
+ queryWrapper2.eq("farm_id", farmId).ge("sub_date", timesMonthmorning)
|
|
|
|
+ .eq("vistit_type", listAdmissionVo.getType()).eq("bill_status", 2);
|
|
|
|
+ listAdmissionVo.setPassCount(billPersonnelAdmissionMapper.selectCount(queryWrapper1));
|
|
|
|
+ listAdmissionVo.setRefuseCount(billPersonnelAdmissionMapper.selectCount(queryWrapper2));
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ return new Result(ResultCode.SUCCESS, admissionVo);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public Result listTop(Map<String, String> paramsMap) {
|
|
|
|
+ String farmId = paramsMap.get("farmId");
|
|
|
|
+ String type = paramsMap.get("type");
|
|
|
|
+ if ("".equals(type) || type == null) {
|
|
|
|
+ type = "1";
|
|
|
|
+ }
|
|
|
|
+ List<ListAdmissionVo> admissionVo = null;
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("farm_id", farmId);
|
|
|
|
+ //今日
|
|
|
|
+ if ("1".equals(type)) {
|
|
|
|
+ Date timesmorning = DataUill.getTimesmorning();
|
|
|
|
+ queryWrapper.ge("sub_date", timesmorning);
|
|
|
|
+ admissionVo = billPersonnelAdmissionMapper.countAdmission(queryWrapper);
|
|
|
|
+ } else if ("2".equals(type)) {
|
|
|
|
+ // 本周
|
|
|
|
+ Calendar calendar = Calendar.getInstance();
|
|
|
|
+ calendar.set(Calendar.DATE, calendar.get(Calendar.DATE) - 7);
|
|
|
|
+ queryWrapper.ge("sub_date", calendar.getTime());
|
|
|
|
+ admissionVo = billPersonnelAdmissionMapper.countAdmission(queryWrapper);
|
|
|
|
+ } else if ("3".equals(type)) {
|
|
|
|
+ //本月
|
|
|
|
+ Date timesMonthmorning = DataUill.getTimesMonthmorning();
|
|
|
|
+ queryWrapper.ge("sub_date", timesMonthmorning);
|
|
|
|
+ admissionVo = billPersonnelAdmissionMapper.countAdmission(queryWrapper);
|
|
|
|
+ }
|
|
|
|
+ JSONArray jsonArray = new JSONArray();
|
|
|
|
+ for (ListAdmissionVo listAdmissionVo : admissionVo) {
|
|
|
|
+ JSONObject jsonObject = new JSONObject();
|
|
|
|
+ jsonObject.put("type", listAdmissionVo.getType());
|
|
|
|
+ if (listAdmissionVo.getType() == 0) {
|
|
|
|
+ jsonObject.put("name", "人员");
|
|
|
|
+ } else if (listAdmissionVo.getType() == 1) {
|
|
|
|
+ jsonObject.put("name", "环保车");
|
|
|
|
+ } else if (listAdmissionVo.getType() == 2) {
|
|
|
|
+ jsonObject.put("name", "拉猪车");
|
|
|
|
+ } else if (listAdmissionVo.getType() == 3) {
|
|
|
|
+ jsonObject.put("name", "饲料车");
|
|
|
|
+ } else if (listAdmissionVo.getType() == 4) {
|
|
|
|
+ jsonObject.put("name", "送猪车");
|
|
|
|
+ } else if (listAdmissionVo.getType() == 5) {
|
|
|
|
+ jsonObject.put("name", "物资车");
|
|
|
|
+ }
|
|
|
|
+ jsonObject.put("value", listAdmissionVo.getCount());
|
|
|
|
+ jsonArray.add(jsonObject);
|
|
|
|
+ }
|
|
|
|
+ JSONArray array = jsonArraySort(jsonArray, "value", true);
|
|
|
|
+ for (int i = 0; i < array.size(); i++) {
|
|
|
|
+ JSONObject jsonObject = array.getJSONObject(i);
|
|
|
|
+ jsonObject.put("rank", i + 1);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return new Result(ResultCode.SUCCESS, array);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public Result admissionTail(Map<String, String> paramsMap) {
|
|
|
|
+ String farmId = paramsMap.get("farmId");
|
|
|
|
+ String type = paramsMap.get("type");
|
|
|
|
+ if ("".equals(type) || type == null) {
|
|
|
|
+ type = "3";
|
|
|
|
+ }
|
|
|
|
+ //今日
|
|
|
|
+ List<BillAdmissionVo> admissionVos = null;
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ queryWrapper.eq("farm_id", farmId);
|
|
|
|
+ if ("1".equals(type)) {
|
|
|
|
+ Date timesmorning = DataUill.getTimesmorning();
|
|
|
|
+ queryWrapper.ge("sub_date", timesmorning);
|
|
|
|
+ admissionVos = billPersonnelAdmissionMapper.admissionTail(queryWrapper);
|
|
|
|
+ } else if ("2".equals(type)) {
|
|
|
|
+ // 本周
|
|
|
|
+ Calendar calendar = Calendar.getInstance();
|
|
|
|
+ calendar.set(Calendar.DATE, calendar.get(Calendar.DATE) - 7);
|
|
|
|
+ queryWrapper.ge("sub_date", calendar.getTime());
|
|
|
|
+ admissionVos = billPersonnelAdmissionMapper.admissionTail(queryWrapper);
|
|
|
|
+ } else if ("3".equals(type)) {
|
|
|
|
+ //本月
|
|
|
|
+ Date timesMonthmorning = DataUill.getTimesMonthmorning();
|
|
|
|
+ queryWrapper.ge("sub_date", timesMonthmorning);
|
|
|
|
+ admissionVos = billPersonnelAdmissionMapper.admissionTail(queryWrapper);
|
|
|
|
+ }
|
|
|
|
+ for (BillAdmissionVo admissionVo : admissionVos) {
|
|
|
|
+ admissionVo.setCommitCount(admissionVo.getPassCount() + admissionVo.getRefuseCount());
|
|
|
|
+ }
|
|
|
|
+ return new Result(ResultCode.SUCCESS, admissionVos);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ public Result selectList(Map<String, String> paramsMap) {
|
|
|
|
+ String farmId = paramsMap.get("farmId");
|
|
|
|
+ String type = paramsMap.get("type");//来访类型
|
|
|
|
+ String destId = paramsMap.get("destId");//目的地
|
|
|
|
+ String startTime = paramsMap.get("startTime");
|
|
|
|
+ String endTime = paramsMap.get("endTime");
|
|
|
|
+ String pageNum = paramsMap.get("current");
|
|
|
|
+ String pageSize = paramsMap.get("size");
|
|
|
|
+ if ("".equals(pageNum) || null == pageNum) {
|
|
|
|
+ pageNum = "1";
|
|
|
|
+ }
|
|
|
|
+ if ("".equals(pageSize) || null == pageSize) {
|
|
|
|
+ pageSize = "10";
|
|
|
|
+ }
|
|
|
|
+ QueryWrapper<BillPersonnelAdmission> queryWrapper = new QueryWrapper<>();
|
|
|
|
+ if (ObjectUtil.isNotEmpty(startTime)) {
|
|
|
|
+ startTime = startTime + " 00:00:00";
|
|
|
|
+ endTime = endTime + " 23:59:59";
|
|
|
|
+ queryWrapper.between("sub_date", startTime, endTime);
|
|
|
|
+ }
|
|
|
|
+ queryWrapper.lambda().orderByDesc(BillPersonnelAdmission::getId);
|
|
|
|
+ queryWrapper.eq("farm_id", farmId).eq(StringUtils.isNotBlank(destId), "dest_id", destId).eq(StringUtils.isNotBlank(type), "vistit_type", type);
|
|
|
|
+ Page<BillPersonnelAdmission> page = new Page<>(Integer.parseInt(pageNum), Integer.parseInt(pageSize));
|
|
|
|
+ return new Result(ResultCode.SUCCESS, billPersonnelAdmissionMapper.selectPage(page, queryWrapper));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ /*数组排序*/
|
|
|
|
+ public static JSONArray jsonArraySort(JSONArray jsonArr, String sortKey, boolean is_desc) {
|
|
|
|
+ //存放排序结果json数组
|
|
|
|
+ JSONArray sortedJsonArray = new JSONArray();
|
|
|
|
+ //用于排序的list
|
|
|
|
+ List<JSONObject> jsonValues = new ArrayList<JSONObject>();
|
|
|
|
+ //将参数json数组每一项取出,放入list
|
|
|
|
+
|
|
|
|
+ for (int i = 0; i < jsonArr.size(); i++) {
|
|
|
|
+ jsonValues.add(jsonArr.getJSONObject(i));
|
|
|
|
+ }
|
|
|
|
+ //快速排序,重写compare方法,完成按指定字段比较,完成排序
|
|
|
|
+ Collections.sort(jsonValues, new Comparator<JSONObject>() {
|
|
|
|
+ //排序字段
|
|
|
|
+ private final String KEY_NAME = sortKey;
|
|
|
|
+
|
|
|
|
+ //重写compare方法
|
|
|
|
+ @Override
|
|
|
|
+ public int compare(JSONObject a, JSONObject b) {
|
|
|
|
+ //如果用String接会导致一位数和两位数混合比对的时候不能准确比出来,要用int类型接
|
|
|
|
+ //String valA = new String();
|
|
|
|
+ //String valB = new String();
|
|
|
|
+ Float valA = 0.00f;
|
|
|
|
+ Float valB = 0.00f;
|
|
|
|
+ try {
|
|
|
|
+ valA = Float.parseFloat(a.getString(KEY_NAME));
|
|
|
|
+ valB = Float.parseFloat(b.getString(KEY_NAME));
|
|
|
|
+ } catch (JSONException e) {
|
|
|
|
+ e.printStackTrace();
|
|
|
|
+ }
|
|
|
|
+ //是升序还是降序
|
|
|
|
+ if (is_desc) {
|
|
|
|
+ return -valA.compareTo(valB);
|
|
|
|
+ } else {
|
|
|
|
+ return -valB.compareTo(valA);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ });
|
|
|
|
+ //将排序后结果放入结果jsonArray
|
|
|
|
+ for (int i = 0; i < jsonArr.size(); i++) {
|
|
|
|
+ sortedJsonArray.add(jsonValues.get(i));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return sortedJsonArray;
|
|
|
|
+ }
|
|
}
|
|
}
|