调整维护费信息推送功能

xinyb

2022-05-09 2ec5a980d44b10c040c3cc8befc7052adc7fd567

调整维护费信息推送功能

 src/com/yc/MaintenanceFee/schedule/MaintainPayMsgSchedule.java

@@ -40,6 +40,7 @@
        List<Map<String, Object>> list = null;
        try {
            SpObserver.setDBtoInstance("_" + dataSourceEntity.getDbId());
            //直接拿到少于或等于今天时间段的信息推送到客户系统内，没到时间段的数据信息会等下次再次执行
            list = maintainService.selectMaintainMsg();
            log.info(dataSourceEntity.getSystemDescribe() + "-开始执行定时拉取维护费通知信息");
        } catch (Exception e) {
@@ -48,6 +49,7 @@
            SpObserver.setDBtoInstance();
        }
        try {
            //有少于或等于当天时间段的信息进行推送并且发送短信信息给客户
            if (list != null && list.size() > 0) {
                List<Map<String, Object>> sms = new ArrayList<>();
                List<Map<String, Object>> li = DBHelper.getStreamFilter(list, "dbid");//setMaintainList(list);

 src/com/yc/MaintenanceFee/service/impl/MaintainServiceImpl.java

@@ -174,6 +174,7 @@
        try {
            String sql = "set nocount on\n" +
                    " declare @today datetime = convert(varchar(10),getdate(),120) \n" +
                    " set @today = dateadd(MILLISECOND,-2,dateadd(day,1,@today)) \n"+
                    " select a.autoid,a.messagetxt,a.refdoccode,a.refformid,a.refformtype,a.insertactioncode," +
                    " a.insertactionname,a.insertdate ,b.dbid,a.unvaliddate,a.tipcount \n" +
                    " from t150372 a join t110203 b on a.cltcode = b.cltcode \n" +