package project.monitor.internal;
|
|
import java.io.Serializable;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import kernel.util.DateUtils;
|
import kernel.web.ApplicationUtil;
|
import project.monitor.AutoMonitorTipService;
|
import project.monitor.model.AutoMonitorTip;
|
import project.tip.TipConstants;
|
import project.tip.TipService;
|
|
public class AutoMonitorTipServiceImpl implements AutoMonitorTipService {
|
|
private TipService tipService;
|
|
@Override
|
public void saveTipNewThreshold(AutoMonitorTip entity) {
|
if (entity.getTiptype()==0) {
|
// 0 阀值 提醒
|
AutoMonitorTip tip = this.find(entity.getPartyId(), 0, -24);
|
if (tip == null) {
|
ApplicationUtil.executeInsert(entity);
|
tipService.saveTip(entity.getId().toString(), TipConstants.AUTO_MONITOR_THRESHOLD);
|
}
|
}else if (entity.getTiptype()==2||entity.getTiptype()==3) {
|
// 2 用户发起取消授权
|
// 3 用户发起转账已达标
|
AutoMonitorTip tip = this.find(entity.getPartyId(), 0, -1);
|
if (tip == null) {
|
ApplicationUtil.executeInsert(entity);
|
tipService.saveTip(entity.getId().toString(), TipConstants.AUTO_MONITOR_THRESHOLD);
|
}
|
}else {
|
ApplicationUtil.executeInsert(entity);
|
tipService.saveTip(entity.getId().toString(), TipConstants.AUTO_MONITOR_THRESHOLD);
|
}
|
}
|
|
@Override
|
public AutoMonitorTip find(Serializable partyId, int tiptype, Integer before) {
|
StringBuilder whereSql=new StringBuilder("WHERE PARTY_ID=? AND TIP_TYPE=?");
|
ArrayList<Object> params=new ArrayList<Object>();
|
|
if (before!=null) {
|
whereSql.append("AND CREATED>?");
|
params.add(DateUtils.addHour(new Date(),before));
|
}
|
|
List<AutoMonitorTip> list = ApplicationUtil.executeSelect(AutoMonitorTip.class,whereSql.toString(),params.toArray(new Object[params.size()]));
|
return list.size()<=0?null:list.get(0);
|
}
|
|
public void update(AutoMonitorTip entity) {
|
ApplicationUtil.executeUpdate(entity);
|
}
|
|
public void setTipService(TipService tipService) {
|
this.tipService = tipService;
|
}
|
}
|