package com.ruoyi.station.service.impl;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.station.mapper.MjWorkUserMapper;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.ruoyi.station.mapper.MjDataPushLogMapper;
|
import com.ruoyi.station.domain.MjDataPushLog;
|
import com.ruoyi.station.service.IMjDataPushLogService;
|
import com.ruoyi.common.core.text.Convert;
|
|
/**
|
* 数据推送日志Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2020-08-10
|
*/
|
@Service
|
public class MjDataPushLogServiceImpl implements IMjDataPushLogService
|
{
|
@Autowired
|
private MjDataPushLogMapper mjDataPushLogMapper;
|
|
@Autowired
|
private MjWorkUserServiceImpl mjWorkUserService;
|
|
@Autowired
|
private MjWorkUserMapper MjWorkUserMapper;
|
|
/**
|
* 查询数据推送日志
|
*
|
* @param id 数据推送日志ID
|
* @return 数据推送日志
|
*/
|
@Override
|
public MjDataPushLog selectMjDataPushLogById(String id)
|
{
|
return mjDataPushLogMapper.selectMjDataPushLogById(id);
|
}
|
|
/**
|
* 查询数据推送日志列表
|
*
|
* @param mjDataPushLog 数据推送日志
|
* @return 数据推送日志
|
*/
|
@Override
|
public List<MjDataPushLog> selectMjDataPushLogList(MjDataPushLog mjDataPushLog)
|
{
|
return mjDataPushLogMapper.selectMjDataPushLogList(mjDataPushLog);
|
}
|
|
/**
|
* 新增数据推送日志
|
*
|
* @param mjDataPushLog 数据推送日志
|
* @return 结果
|
*/
|
@Override
|
public int insertMjDataPushLog(MjDataPushLog mjDataPushLog)
|
{
|
mjDataPushLog.setCreateTime(DateUtils.getNowDate());
|
return mjDataPushLogMapper.insertMjDataPushLog(mjDataPushLog);
|
}
|
|
/**
|
* 修改数据推送日志
|
*
|
* @param mjDataPushLog 数据推送日志
|
* @return 结果
|
*/
|
@Override
|
public int updateMjDataPushLog(MjDataPushLog mjDataPushLog)
|
{
|
mjDataPushLog.setUpdateTime(DateUtils.getNowDate());
|
return mjDataPushLogMapper.updateMjDataPushLog(mjDataPushLog);
|
}
|
|
/**
|
* 删除数据推送日志对象
|
*
|
* @param ids 需要删除的数据ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteMjDataPushLogByIds(String ids)
|
{
|
return mjDataPushLogMapper.deleteMjDataPushLogByIds(Convert.toStrArray(ids));
|
}
|
|
/**
|
* 删除数据推送日志信息
|
*
|
* @param id 数据推送日志ID
|
* @return 结果
|
*/
|
@Override
|
public int deleteMjDataPushLogById(String id)
|
{
|
return mjDataPushLogMapper.deleteMjDataPushLogById(id);
|
}
|
|
/**
|
* 获取授权总次数
|
* @return
|
*/
|
@Override
|
public Integer getAuthCount() {
|
List<MjDataPushLog> mjDataPushLogList = mjDataPushLogMapper.selectAuthLog();
|
int count = 0;
|
if(mjDataPushLogList != null) {
|
count = mjDataPushLogList.size();
|
}
|
return count;
|
}
|
|
/**
|
* 授权数据统计-》授权方式
|
* @return
|
*/
|
@Override
|
public Map<String, Object> getAuthDataType() {
|
Integer monthCount = null;
|
int longAuth = 0; //长期授权
|
int shortAuth = 0; //短期授权
|
int ERPAuth = 0; //ERP授权
|
|
List<MjDataPushLog> mjDataPushLogList = mjDataPushLogMapper.selectAuthLog();
|
if(mjDataPushLogList != null && mjDataPushLogList.size() > 0) {
|
for(MjDataPushLog mjDataPushLog : mjDataPushLogList) {
|
if(mjDataPushLog != null) {
|
try {
|
monthCount = mjWorkUserService.monthsBetween(mjDataPushLog.getStartTime(), mjDataPushLog.getEndTime());
|
if(monthCount != null) {
|
shortAuth++;
|
/*if(monthCount >= 12) { //判断有效年份是否超过一年，超过则为长期授权否则短期授权
|
longAuth++;
|
}else {
|
shortAuth++;
|
}*/
|
}
|
}catch (Exception e) {
|
e.printStackTrace();
|
return null;
|
}
|
}
|
}
|
}
|
Map<String, Object> map = new HashMap<>();
|
map.put("longAuth", longAuth);
|
map.put("shortAuth", shortAuth);
|
map.put("ERPAuth", ERPAuth);
|
return map;
|
}
|
|
@Override
|
public List<MjDataPushLog> selectDataPushLogList(MjDataPushLog mjDataPushLog) {
|
List<MjDataPushLog> mjDataPushLogList = mjDataPushLogMapper.selectDataPushLogList(mjDataPushLog);
|
if(CollectionUtils.isNotEmpty(mjDataPushLogList)) {
|
for(MjDataPushLog dataPushLog : mjDataPushLogList) {
|
if(StringUtils.isEmpty(dataPushLog.getTogetherUserIds())){
|
continue;
|
}
|
List<String> userNames = MjWorkUserMapper.selectUserNamesByTogetherUserIds(Convert.toStrArray(dataPushLog.getTogetherUserIds()));
|
String names = String.join(",", userNames);
|
dataPushLog.setTogetherUserNames(names);
|
}
|
}
|
return mjDataPushLogList;
|
}
|
|
@Override
|
public void deleteByWorkOrderId(String id) {
|
mjDataPushLogMapper.deleteByWorkOrderId(id);
|
}
|
}
|
