补充提交
This commit is contained in:
tangfutang
parent
e66f0a694a
commit
21ff59ede9
@ -133,4 +133,22 @@ VALUES ('e6c678657a4f11eaae2500163e0ad612', 'ST_CREDIT_AUDIT_HOLIDAY', '1', '2',
|
||||
INSERT INTO `apzl`.`code_library` (`codeno`, `itemno`, `itemname`, `bankno`, `sortno`, `isinuse`, `itemdescribe`, `itemattribute`, `relativecode`, `attribute1`, `attribute2`, `attribute3`, `attribute4`, `attribute5`, `attribute6`, `attribute7`, `attribute8`, `inputuser`, `inputorg`, `inputtime`, `updateuser`, `updatetime`, `remark`, `helptext`)
|
||||
VALUES ('MissionName', 'com.tenwa.lease.app.quartzmession.CreditAuditHolidayBatch', '信审考核统计处理', '5101001', '5101001', '1', '信审考核统计处理', '', '', '', '', '', '', '', '', '', '', 'SYS_Designer', NULL, '2019/12/26 10:13:04', 'SYS_Designer', '2019/12/26 10:14:07', '', '');
|
||||
|
||||
-- ----------------------------------------------
|
||||
|
||||
|
||||
-- 结清证明添加天津主体模板 ---------------------------
|
||||
-- 添加结清证明列表-主体id查询
|
||||
INSERT INTO `apzl`.`awe_do_library`(`dono`, `colindex`, `sortno`, `isinuse`, `coltablename`, `colactualname`, `colname`, `coltype`, `coldefaultvalue`, `colheader`, `colunit`, `colcolumntype`, `coleditstyle`, `colcheckformat`, `colalign`, `coleditsourcetype`, `coleditsource`, `colhtmlstyle`, `collimit`, `colvisible`, `colreadonly`, `colrequired`, `colsortable`, `isfilter`, `colspan`, `isautocomplete`, `groupid`, `colfilterrefid`, `inputuser`, `inputtime`, `updateuser`, `updatetime`, `isaudit`, `colfilterattrs`, `isupdate`, `parentcolindex`, `tips`, `colinnerbtevent`, `colfilteroptions`) VALUES ('rightsFileList', '105030', '105030', '1', 'O', 'SUBJECTID', 'SUBJECTID', 'String', NULL, '主体ID', NULL, '1', 'Text', '1', '1', NULL, NULL, NULL, '32', '0', '0', '0', '1', '0', 0, NULL, NULL, NULL, 'SYS_Designer', '2018/08/10 15:48:47', 'SYS_Designer', '2018/08/29 21:09:29', NULL, NULL, '1', NULL, NULL, NULL, NULL);
|
||||
|
||||
|
||||
-- 添加标签-车辆信息【85ef6c805b8d41da993cd553e83012b4】
|
||||
INSERT INTO `apzl`.`bf_lableconfig`(`ID`, `TAGNUMBER`, `TAGNAME`, `TITLE`, `TAGTYPE`, `VALUETYPE`, `VALUEFIELD`, `VALUEMETHOD`, `THOUSANDSFIELD`, `ISSHOEINDEX`, `REMARK`, `INPUTUSERID`, `INPUTORGID`, `UPDATEUSERID`, `UPDATEORGID`, `INPUTTIME`, `UPDATETIME`, `OPERATORCLASS`) VALUES ('85ef6c805b8d41da993cd553e83012b4', '00050101', 'settlement_car', '结清证明-汽车基本信息', 'tag_type2', 'value_type3', 'FRAME_NUMBER,ENGINE_NUMBER,PLATE_NUMBER', 'SELECT FRAME_NUMBER,ENGINE_NUMBER,PLATE_NUMBER FROM LB_EQUIPMENT_CAR\r\nWHERE CONTRACT_ID =:{CONTRACT_ID};', '', 'N', '', '', '', '', '', '', '', '');
|
||||
|
||||
-- 添加模板-结清证明-天津【8e24641585f511ea8e2300163e0e11e6】
|
||||
INSERT INTO `apzl`.`bf_template`(`ID`, `SERIALNO`, `SORTNUMBER`, `TEMPLATENAME`, `TEMPLATESHOWNAME`, `TEMPLATEPATH`, `TEMPLATETYPE`, `OPERATETYPE`, `CALLBACK`, `CREATEMETHOD`, `DOCTYPE`, `ONECLASSIFY`, `TWOCLASSIFY`, `THREECLASSIFY`, `FOURCLASSIFY`, `TEMPLATEVERSION`, `STATUS`, `REMARK`, `INPUTUSERID`, `INPUTORGID`, `INPUTTIME`, `UPDATEUSERID`, `UPDATEORGID`, `UPDATETIME`, `CREATECONDITION`, `CREATESHEETCONDITION`) VALUES ('8e24641585f511ea8e2300163e0e11e6', NULL, NULL, '结清证明-天津', '结清证明_{CUSTOMER_NAME}.docx', '结清证明-天津.docx', 'word', 'create', NULL, NULL, NULL, NULL, NULL, NULL, NULL, '1', NULL, NULL, 'administrator', '8009001', '2018/07/30 11:42:48', 'administrator', '8009001', '2020/04/24 11:27:14', NULL, NULL);
|
||||
|
||||
-- 模板和标签关联关系添加
|
||||
INSERT INTO `apzl`.`bf_templatelable`(`ID`, `LABLEID`, `TEMPLATEID`, `INPUTUSERID`, `INPUTORGID`, `UPDATEUSERID`, `UPDATEORGID`, `INPUTTIME`, `UPDATETIME`) VALUES (replace(uuid(),"-",""), '85ef6c805b8d41da993cd553e83012b4', '8e24641585f511ea8e2300163e0e11e6', NULL, NULL, NULL, NULL, NULL, NULL);
|
||||
INSERT INTO `apzl`.`bf_templatelable`(`ID`, `LABLEID`, `TEMPLATEID`, `INPUTUSERID`, `INPUTORGID`, `UPDATEUSERID`, `UPDATEORGID`, `INPUTTIME`, `UPDATETIME`) VALUES (replace(uuid(),"-",""), 'abcf338955fe42f98910100a8723e230', '8e24641585f511ea8e2300163e0e11e6', NULL, NULL, NULL, NULL, NULL, NULL);
|
||||
-- -------------------------------------------------------------------------
|
||||
|
||||
|
||||
@ -42,6 +42,7 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
private void deleteCreditAudit(){
|
||||
Transaction Sqlca=null;
|
||||
try{
|
||||
logger.info("【信审考核统计】【deleteCreditAudit】数据清空执行开始<<<<<<<<<<<<<");
|
||||
Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource());
|
||||
//初始化信审考核明细表
|
||||
String delSql="truncate table st_credit_audit_order_detail";
|
||||
@ -49,7 +50,7 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
Sqlca.executeSQL(new SqlObject(delSql));
|
||||
Sqlca.executeSQL(new SqlObject(delSql2));
|
||||
Sqlca.commit();
|
||||
logger.info("【信审考核统计】【deleteCreditAudit】数据清空执行完成<<<<<<<<<<<<<: ");
|
||||
logger.info("【信审考核统计】【deleteCreditAudit】数据清空执行完成<<<<<<<<<<<<<");
|
||||
}catch(Exception e){
|
||||
logger.error("<<<<<<<<<<<<<<<<<<<<<<【信审考核统计】【deleteCreditAudit】数据清空执行异常>>>>>>>>>>>>>>>>>>>>>>>");
|
||||
logger.error("<<<<<<<<<<<<<<<<<<<<<<【信审考核统计】【deleteCreditAudit】数据清空执行异常>>>>>>>>>>>>>>>>>>>>>>>");
|
||||
@ -79,11 +80,12 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
private void initDetail(){
|
||||
Transaction Sqlca=null;
|
||||
try{
|
||||
logger.info("【信审考核统计】【initDetail】初始化订单明细记录执行开始<<<<<<<<<<<<<");
|
||||
Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource());
|
||||
//初始化信审考核明细表
|
||||
String result1 = initDetail(Sqlca);
|
||||
Sqlca.commit();
|
||||
logger.info("【信审考核统计】【initDetail】初始化订单明细记录<<<<<<<<<<<<<: "+result1);
|
||||
logger.info("【信审考核统计】【initDetail】初始化订单明细记录执行完成<<<<<<<<<<<<<："+result1);
|
||||
}catch(Exception e){
|
||||
logger.error("<<<<<<<<<<<<<<<<<<<<<<【信审考核统计】【initDetail】初始化订单明细记录>>>>>>>>>>>>>>>>>>>>>>>");
|
||||
logger.error("<<<<<<<<<<<<<<<<<<<<<<【信审考核统计】【initDetail】初始化订单明细记录>>>>>>>>>>>>>>>>>>>>>>>");
|
||||
@ -113,11 +115,12 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
private void updateDetail(){
|
||||
Transaction Sqlca=null;
|
||||
try{
|
||||
logger.info("【信审考核统计】【updateDetail】修改订单明细中的创建时间执行开始<<<<<<<<<<<<<");
|
||||
Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource());
|
||||
//初始化信审考核明细表
|
||||
String result1 = updateDetail(Sqlca);
|
||||
Sqlca.commit();
|
||||
logger.info("【信审考核统计】【updateDetail】修改订单明细中的创建时间执行完成<<<<<<<<<<<<<: "+result1);
|
||||
logger.info("【信审考核统计】【updateDetail】修改订单明细中的创建时间执行完成<<<<<<<<<<<<<："+result1);
|
||||
}catch(Exception e){
|
||||
logger.error("<<<<<<<<<<<<<<<<<<<<<<【信审考核统计】【updateDetail】修改订单明细中的创建时间执行异常>>>>>>>>>>>>>>>>>>>>>>>");
|
||||
logger.error("<<<<<<<<<<<<<<<<<<<<<<【信审考核统计】【updateDetail】修改订单明细中的创建时间执行异常>>>>>>>>>>>>>>>>>>>>>>>");
|
||||
@ -147,6 +150,7 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
private void initOrderAuditDay(){
|
||||
Transaction Sqlca=null;
|
||||
try{
|
||||
logger.info("【信审考核统计】【initOrderAuditDay】初始化订单表审核数据统计执行开始<<<<<<<<<<<<<");
|
||||
Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource());
|
||||
//初始化信审考核明细表
|
||||
String result1 = initOrderAuditDay(Sqlca);
|
||||
@ -181,6 +185,7 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
private void saveOrderAuditDay(){
|
||||
Transaction Sqlca=null;
|
||||
try{
|
||||
logger.info("【信审考核统计】【saveOrderAuditDay】根据进单时间新增和修改订单统计表执行开始<<<<<<<<<<<<<");
|
||||
Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource());
|
||||
//初始化信审考核明细表
|
||||
String result1 = saveOrderCreateDay(Sqlca);
|
||||
@ -215,6 +220,7 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
private void updateOrderAuditDay(){
|
||||
Transaction Sqlca=null;
|
||||
try{
|
||||
logger.info("【信审考核统计】【updateOrderAuditDay】计算信审考核统计表审核时间执行开始<<<<<<<<<<<<<");
|
||||
Sqlca = Transaction.createTransaction(CacheLoaderFactory.getDataSource());
|
||||
//初始化信审考核明细表
|
||||
String result1 = updateOrderAuditDay(Sqlca);
|
||||
@ -428,7 +434,6 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
*/
|
||||
public String initOrderAuditDay(Transaction Sqlca) throws Exception {
|
||||
String insertSql="INSERT INTO st_credit_audit_order(\n" +
|
||||
" id,\n" +
|
||||
" every_day,\n" +
|
||||
" userid,\n" +
|
||||
" username,\n" +
|
||||
@ -445,7 +450,6 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
" count_audit_refuse6\n" +
|
||||
" )\n" +
|
||||
" SELECT \n" +
|
||||
" replace(uuid(),'-',''),\n" +
|
||||
" st2.every_day,\n" +
|
||||
" st2.userid,\n" +
|
||||
" st2.username,\n" +
|
||||
@ -483,6 +487,7 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
return "-1";
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* 根据查询进单统计数据，添加或者更新统计订单数据
|
||||
* @return
|
||||
@ -501,9 +506,22 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
String selSql2 = "";
|
||||
int con=0;
|
||||
// 查询所有需要发送还款提醒的数据
|
||||
String selSql="SELECT count(1) as order_count,std1.every_day,std1.userid,std1.username,std1.auditFlowType,std1.auditFlowTypeDes \n" +
|
||||
" from (SELECT min(create_day) AS every_day,userid,username,auditFlowType,auditFlowTypeDes from st_credit_audit_order_detail GROUP BY objectno) AS std1 \n" +
|
||||
" GROUP BY std1.every_day ";
|
||||
String selSql="SELECT count(1) as order_count,\n" +
|
||||
" min(std1.every_day) AS every_day,\n" +
|
||||
" std1.userid,\n" +
|
||||
" std1.username,\n" +
|
||||
" std1.auditFlowType,\n" +
|
||||
" std1.auditFlowTypeDes\n" +
|
||||
" from (\n" +
|
||||
" SELECT \n" +
|
||||
" min(create_day) AS every_day,\n" +
|
||||
" userid,\n" +
|
||||
" username,\n" +
|
||||
" auditFlowType,\n" +
|
||||
" auditFlowTypeDes\n" +
|
||||
" from st_credit_audit_order_detail \n" +
|
||||
" GROUP BY objectno,userid\n" +
|
||||
" ) AS std1 GROUP BY std1.every_day,std1.userid ";
|
||||
ASResultSet rs = Sqlca.getASResultSet(new SqlObject(selSql));
|
||||
while(rs.next()) {
|
||||
id = UUID.randomUUID().toString().replace("-", "");
|
||||
@ -516,16 +534,17 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
auditFlowType = rs.getString("auditFlowType"); // 流程创建时间
|
||||
auditFlowTypeDes = rs.getString("auditFlowTypeDes"); // 流程创建时间
|
||||
|
||||
selSql2="SELECT count(1) as countNum FROM st_credit_audit_order WHERE every_day ='" + every_day +"'";
|
||||
selSql2="SELECT count(1) as countNum FROM st_credit_audit_order WHERE every_day ='" + every_day
|
||||
+"' and userid='" + userid +"'";
|
||||
ASResultSet rs2 = Sqlca.getASResultSet(new SqlObject(selSql2));
|
||||
if(rs2.next()) {
|
||||
if(rs2.getInt("countNum") > 0){
|
||||
updSql="UPDATE st_credit_audit_order SET order_count='"+order_count+"', " +
|
||||
"UPDATETIME=DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s') WHERE every_day='"+every_day+"' ";
|
||||
"UPDATETIME=DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s') WHERE every_day='"+every_day +"' and userid='" + userid +"'";
|
||||
Sqlca.executeSQL(new SqlObject(updSql));
|
||||
logger.info("【信审考核统计】【saveOrderCreateDay】更新记录保存进单数量<<<<<<<<<<<<<");
|
||||
}else {
|
||||
String insertSql = "INSERT INTO st_credit_audit_order(\n" +
|
||||
" id,\n" +
|
||||
" every_day,\n" +
|
||||
" userid,\n" +
|
||||
" username,\n" +
|
||||
@ -536,16 +555,17 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
" UPDATETIME " +
|
||||
" ) " +
|
||||
" VALUES ( " +
|
||||
" '" + id + "', " +
|
||||
" '" + every_day + "', " +
|
||||
" '" + userid + "', " +
|
||||
" '" + userid + "', " +
|
||||
" '" + username + "', " +
|
||||
" '" + auditFlowType + "', " +
|
||||
" '" + auditFlowTypeDes + "', " +
|
||||
" '" + order_count + "', " +
|
||||
"DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s'), " +
|
||||
"DATE_FORMAT(NOW(),'%Y/%m/%d %H:%i:%s') " +
|
||||
")";
|
||||
Sqlca.executeSQL(new SqlObject(insertSql));
|
||||
logger.info("【信审考核统计】【saveOrderCreateDay】新增记录保存进单数量<<<<<<<<<<<<<");
|
||||
}
|
||||
}
|
||||
id = "";
|
||||
@ -634,18 +654,6 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
return String.valueOf(con);
|
||||
}
|
||||
|
||||
|
||||
|
||||
/**
|
||||
* 0010 信用不良
|
||||
* 0020 法院执行
|
||||
* 0030 虚假信息
|
||||
* 0040 身份核实异常
|
||||
* 0050 购车目的异常
|
||||
* 0060 综合评分不足
|
||||
* 0070 同意
|
||||
* 0080 附条件通过
|
||||
*/
|
||||
/**
|
||||
* 根据当前时间获得跳过节假日的工作日时间
|
||||
* @param date
|
||||
@ -762,10 +770,45 @@ public class CreditAuditHolidayBatch implements Job{
|
||||
return diffMinute(beginDate.getTime(), beginDateAfter.getTime());
|
||||
}
|
||||
|
||||
private long diffMinute(long begin, long end){
|
||||
if(begin > end){
|
||||
return -1;
|
||||
/**
|
||||
* 经过处理过的时间开始和结束时间在一天
|
||||
* @param begin
|
||||
* @param end
|
||||
* @return
|
||||
* @throws ParseException
|
||||
*/
|
||||
private long diffMinute(long begin, long end) throws ParseException {
|
||||
Date beginDate = new Date(begin);
|
||||
SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");
|
||||
String timeBefore = sdf.format(beginDate).substring(0, 11) + "12:00:00";
|
||||
String timeAfter = sdf.format(beginDate).substring(0, 11) + "12:30:00";
|
||||
Date timeBeforeDate = sdf.parse(timeBefore);
|
||||
Date timeAfterDate = sdf.parse(timeAfter);
|
||||
//确认是否需要扣除午休30分钟
|
||||
boolean b = false;
|
||||
//如果开始时间小于12:00 并且 结束时间大于12:30
|
||||
if(begin <= timeBeforeDate.getTime() && end >= timeAfterDate.getTime()){
|
||||
b = true;
|
||||
}
|
||||
return (end - begin)/1000/60;
|
||||
//如果开始时间，大于12 小于 12:30 则 开始时间为 12:30
|
||||
if(begin > timeBeforeDate.getTime() && begin < timeAfterDate.getTime()){
|
||||
begin = timeAfterDate.getTime();
|
||||
}
|
||||
//如果结束时间，大于12 小于 12:30 则 开始时间为 12:00
|
||||
if(end > timeBeforeDate.getTime() && end < timeAfterDate.getTime()){
|
||||
end = timeBeforeDate.getTime();
|
||||
}
|
||||
long res = (end - begin)/1000/60;
|
||||
if(b){
|
||||
res = res - 30;
|
||||
}
|
||||
return res <= 0 ? 1 : res;
|
||||
}
|
||||
|
||||
// private long diffMinute(long begin, long end){
|
||||
// if(begin > end){
|
||||
// return -1;
|
||||
// }
|
||||
// return (end - begin)/1000/60;
|
||||
// }
|
||||
}
|
||||
|
||||
@ -92,8 +92,7 @@ public class WechatMessagePush implements Job{
|
||||
int con=0;
|
||||
|
||||
// 查询所有需要发送还款提醒的数据
|
||||
//String selSql="SELECT CI.CUSTOMERNAME AS CUST_NAME,WUI.MOBILE_,WUI.CERTID_,LCI.CONTRACT_NUMBER,CI.CUSTOMER_NUM,LRP.PLAN_LIST,LCI.ID AS CONTRACT_ID,CI.CUSTOMERID,WUI.OPENID,CONCAT('/wechat/menu?type=payments&id=',LCI.CONTRACT_NUMBER) AS LINK,CONCAT(CONVERT(YEAR(LRP.PLAN_DATE), CHAR),'年',CONVERT(MONTH(LRP.PLAN_DATE), CHAR),'月',CONVERT(DAY(LRP.PLAN_DATE), CHAR),'日') AS KEYWORD1,CONCAT('第', LRP.PLAN_LIST, '期') KEYWORD2,CONCAT(IFNULL(LRP.RENT, 0) - IFNULL(LRI.RENT, 0),'元') KEYWORD3 FROM WECHAT_USER_INFO WUI LEFT JOIN CUSTOMER_INFO CI ON CI.CERTID = WUI.CERTID_ LEFT JOIN LB_UNION_LESSEE LUL ON LUL.CUSTOMER_ID = CI.CUSTOMERID AND LUL.IS_MAIN = 'Y' LEFT JOIN LB_CONTRACT_INFO LCI ON LCI.ID = LUL.CONTRACT_ID AND LCI.CONTRACT_STATUS = '31' LEFT JOIN DISTRIBUTOR_INFO DI ON DI.DISTRIBUTOR_NO=LCI.DISTRIBUTOR_ID LEFT JOIN LC_RENT_PLAN LRP ON LRP.CONTRACT_ID = LCI.ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,SUM(RENT) AS RENT FROM LC_RENT_INCOME GROUP BY CONTRACT_ID,PLAN_LIST) LRI ON LRI.CONTRACT_ID = LRP.CONTRACT_ID AND LRI.PLAN_LIST = LRP.PLAN_LIST WHERE WUI.BINDING_STATUS = 'Y' AND IFNULL(WUI.ATTENTION_STATUS, 'Y') <> 'N' AND DI.DISTRIBUTOR_NAME<>'辉煌国际融资租赁（天津）有限公司' AND (TIMESTAMPDIFF(DAY,DATE_FORMAT(NOW(), '%Y-%m-%d'),DATE_FORMAT(LRP.PLAN_DATE, '%Y-%m-%d')) <= 2 AND TIMESTAMPDIFF(DAY,DATE_FORMAT(NOW(), '%Y-%m-%d'),DATE_FORMAT(LRP.PLAN_DATE, '%Y-%m-%d')) >= 0) AND IFNULL(LRP.RENT, 0) - IFNULL(LRI.RENT, 0) > 0 AND NOT EXISTS (SELECT 1 FROM WECHAT_MESSAGE_RECORD WHERE OPENID = WUI.OPENID AND SEND_TYPE = '1' AND CONTRACT_NUMBER = LCI.CONTRACT_NUMBER AND PLAN_LIST = LRP.PLAN_LIST AND SEND_STATUS = 'Y') LIMIT 0, 50000 ";
|
||||
String selSql="SELECT CI.CUSTOMERNAME AS CUST_NAME,WUI.MOBILE_,WUI.CERTID_,LCI.CONTRACT_NUMBER,CI.CUSTOMER_NUM,LRP.PLAN_LIST,LCI.ID AS CONTRACT_ID,CI.CUSTOMERID,WUI.OPENID,CONCAT('/wechat/menu?type=payments&id=',LCI.CONTRACT_NUMBER) AS LINK,CONCAT(CONVERT(YEAR(LRP.PLAN_DATE), CHAR),'年',CONVERT(MONTH(LRP.PLAN_DATE), CHAR),'月',CONVERT(DAY(LRP.PLAN_DATE), CHAR),'日') AS KEYWORD1,CONCAT('第', LRP.PLAN_LIST, '期') KEYWORD2,CONCAT(IFNULL(LRP.RENT, 0) - IFNULL(LRI.RENT, 0),'元') KEYWORD3 FROM WECHAT_USER_INFO WUI LEFT JOIN CUSTOMER_INFO CI ON CI.CERTID = WUI.CERTID_ LEFT JOIN LB_UNION_LESSEE LUL ON LUL.CUSTOMER_ID = CI.CUSTOMERID AND LUL.IS_MAIN = 'Y' LEFT JOIN LB_CONTRACT_INFO LCI ON LCI.ID = LUL.CONTRACT_ID AND LCI.CONTRACT_STATUS = '31' LEFT JOIN DISTRIBUTOR_INFO DI ON DI.DISTRIBUTOR_NO=LCI.DISTRIBUTOR_ID LEFT JOIN LC_RENT_PLAN LRP ON LRP.CONTRACT_ID = LCI.ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,SUM(RENT) AS RENT FROM LC_RENT_INCOME GROUP BY CONTRACT_ID,PLAN_LIST) LRI ON LRI.CONTRACT_ID = LRP.CONTRACT_ID AND LRI.PLAN_LIST = LRP.PLAN_LIST WHERE WUI.BINDING_STATUS = 'Y' AND DI.DISTRIBUTOR_NAME<>'辉煌国际融资租赁（天津）有限公司' AND (TIMESTAMPDIFF(DAY,DATE_FORMAT(NOW(), '%Y-%m-%d'),DATE_FORMAT(LRP.PLAN_DATE, '%Y-%m-%d')) <= 2 AND TIMESTAMPDIFF(DAY,DATE_FORMAT(NOW(), '%Y-%m-%d'),DATE_FORMAT(LRP.PLAN_DATE, '%Y-%m-%d')) >= 0) AND IFNULL(LRP.RENT, 0) - IFNULL(LRI.RENT, 0) > 0 AND NOT EXISTS (SELECT 1 FROM WECHAT_MESSAGE_RECORD WHERE OPENID = WUI.OPENID AND SEND_TYPE = '1' AND CONTRACT_NUMBER = LCI.CONTRACT_NUMBER AND PLAN_LIST = LRP.PLAN_LIST AND SEND_STATUS = 'Y') LIMIT 0, 50000 ";
|
||||
String selSql="SELECT CI.CUSTOMERNAME AS CUST_NAME,WUI.MOBILE_,WUI.CERTID_,LCI.CONTRACT_NUMBER,CI.CUSTOMER_NUM,LRP.PLAN_LIST,LCI.ID AS CONTRACT_ID,CI.CUSTOMERID,WUI.OPENID,CONCAT('/wechat/menu?type=payments&id=',LCI.CONTRACT_NUMBER) AS LINK,CONCAT(CONVERT(YEAR(LRP.PLAN_DATE), CHAR),'年',CONVERT(MONTH(LRP.PLAN_DATE), CHAR),'月',CONVERT(DAY(LRP.PLAN_DATE), CHAR),'日') AS KEYWORD1,CONCAT('第', LRP.PLAN_LIST, '期') KEYWORD2,CONCAT(IFNULL(LRP.RENT, 0) - IFNULL(LRI.RENT, 0),'元') KEYWORD3 FROM WECHAT_USER_INFO WUI LEFT JOIN CUSTOMER_INFO CI ON CI.CERTID = WUI.CERTID_ LEFT JOIN LB_UNION_LESSEE LUL ON LUL.CUSTOMER_ID = CI.CUSTOMERID AND LUL.IS_MAIN = 'Y' LEFT JOIN LB_CONTRACT_INFO LCI ON LCI.ID = LUL.CONTRACT_ID AND LCI.CONTRACT_STATUS = '31' LEFT JOIN DISTRIBUTOR_INFO DI ON DI.DISTRIBUTOR_NO=LCI.DISTRIBUTOR_ID LEFT JOIN LC_RENT_PLAN LRP ON LRP.CONTRACT_ID = LCI.ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,SUM(RENT) AS RENT FROM LC_RENT_INCOME GROUP BY CONTRACT_ID,PLAN_LIST) LRI ON LRI.CONTRACT_ID = LRP.CONTRACT_ID AND LRI.PLAN_LIST = LRP.PLAN_LIST WHERE WUI.BINDING_STATUS = 'Y' AND IFNULL(WUI.ATTENTION_STATUS, 'Y') <> 'N' AND DI.DISTRIBUTOR_NAME<>'辉煌国际融资租赁（天津）有限公司' AND (TIMESTAMPDIFF(DAY,DATE_FORMAT(NOW(), '%Y-%m-%d'),DATE_FORMAT(LRP.PLAN_DATE, '%Y-%m-%d')) <= 3 AND TIMESTAMPDIFF(DAY,DATE_FORMAT(NOW(), '%Y-%m-%d'),DATE_FORMAT(LRP.PLAN_DATE, '%Y-%m-%d')) >= 0) AND IFNULL(LRP.RENT, 0) - IFNULL(LRI.RENT, 0) > 0 AND NOT EXISTS (SELECT 1 FROM WECHAT_MESSAGE_RECORD WHERE OPENID = WUI.OPENID AND SEND_TYPE = '1' AND CONTRACT_NUMBER = LCI.CONTRACT_NUMBER AND PLAN_LIST = LRP.PLAN_LIST AND SEND_STATUS = 'Y') LIMIT 0, 50000 ";
|
||||
|
||||
ASResultSet rs = Sqlca.getASResultSet(new SqlObject(selSql));
|
||||
|
||||
@ -175,7 +174,7 @@ public class WechatMessagePush implements Job{
|
||||
|
||||
// 查询所有需要发送还款提醒的数据
|
||||
//String selSql="SELECT CI.CUSTOMERNAME AS CUST_NAME,WUI.MOBILE_,WUI.CERTID_,LCI.CONTRACT_NUMBER,CI.CUSTOMER_NUM,LRP.PLAN_LIST,LCI.ID AS CONTRACT_ID,CI.CUSTOMERID,WUI.OPENID,CONCAT('/wechat/menu?type=payments&id=',LCI.CONTRACT_NUMBER) AS LINK,CONCAT(CONVERT(YEAR(LRP.PLAN_DATE), CHAR),'年',CONVERT(MONTH(LRP.PLAN_DATE), CHAR),'月',CONVERT(DAY(LRP.PLAN_DATE), CHAR),'日') AS KEYWORD1,CONCAT(ROUND((LRP.RENT + ROUND(IFNULL(getRentPenalty3(LRP.PAYMENT_NUMBER,LRP.PLAN_LIST,IFNULL(LRI.HIRE_DATE,DATE_FORMAT(NOW(), '%y/%m/%d'))),0),2)) - (IFNULL(LRI.RENT, 0) + IFNULL(LRI.PENALTY, 0)),2),'元') AS KEYWORD2,CONCAT((LRP.RENT - IFNULL(LRI.RENT, 0)),'元') AS KEYWORD3,CONCAT(ROUND(IFNULL(getRentPenalty(LRP.PAYMENT_NUMBER,LRP.PLAN_LIST,IFNULL(LRI.HIRE_DATE,DATE_FORMAT(NOW(), '%y/%m/%d'))),0),2),'元') AS KEYWORD4 FROM WECHAT_USER_INFO WUI LEFT JOIN CUSTOMER_INFO CI ON CI.CERTID = WUI.CERTID_ LEFT JOIN LB_UNION_LESSEE LUL ON LUL.CUSTOMER_ID = CI.CUSTOMERID AND LUL.IS_MAIN = 'Y' LEFT JOIN LB_CONTRACT_INFO LCI ON LCI.ID = LUL.CONTRACT_ID AND LCI.CONTRACT_STATUS = '31' LEFT JOIN DISTRIBUTOR_INFO DI ON DI.DISTRIBUTOR_NO=LCI.DISTRIBUTOR_ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,MAX(PLAN_DATE) AS PLAN_DATE,MAX(PAYMENT_NUMBER) AS PAYMENT_NUMBER,SUM(RENT) AS RENT,SUM(IFNULL(PENALTY, 0)) AS PENALTY FROM LC_RENT_PLAN WHERE TIMESTAMPDIFF(DAY,DATE_FORMAT(PLAN_DATE, '%Y-%m-%d'),DATE_FORMAT(NOW(), '%Y-%m-%d')) >= 3 GROUP BY CONTRACT_ID,PLAN_LIST) LRP ON LRP.CONTRACT_ID = LCI.ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,SUM(RENT) AS RENT,SUM(IFNULL(PENALTY, 0)) AS PENALTY,MAX(HIRE_DATE) AS HIRE_DATE FROM LC_RENT_INCOME GROUP BY CONTRACT_ID,PLAN_LIST) LRI ON LRI.CONTRACT_ID = LRP.CONTRACT_ID AND LRI.PLAN_LIST = LRP.PLAN_LIST WHERE WUI.BINDING_STATUS = 'Y' AND IFNULL(WUI.ATTENTION_STATUS,'Y')<>'N' AND DI.DISTRIBUTOR_NAME<>'辉煌国际融资租赁（天津）有限公司' AND (IFNULL(LRP.RENT, 0)+ ROUND(IFNULL(getRentPenalty3(LRP.PAYMENT_NUMBER,LRP.PLAN_LIST,IFNULL(LRI.HIRE_DATE,DATE_FORMAT(NOW(), '%y/%m/%d'))),0),2)- IFNULL(LRI.RENT, 0) - IFNULL(LRI.PENALTY, 0)) > 0 AND NOT EXISTS (SELECT 1 FROM WECHAT_MESSAGE_RECORD WHERE OPENID = WUI.OPENID AND SEND_TYPE = '2' AND CONTRACT_NUMBER = LCI.CONTRACT_NUMBER AND PLAN_LIST = LRP.PLAN_LIST AND SEND_STATUS = 'Y') ORDER BY LRP.PLAN_LIST LIMIT 0, 50000 ";
|
||||
String selSql="SELECT CI.CUSTOMERNAME AS CUST_NAME,WUI.MOBILE_,WUI.CERTID_,LCI.CONTRACT_NUMBER,CI.CUSTOMER_NUM,LRP.PLAN_LIST,LCI.ID AS CONTRACT_ID,CI.CUSTOMERID,WUI.OPENID,CONCAT('/wechat/menu?type=payments&id=',LCI.CONTRACT_NUMBER) AS LINK,CONCAT(CONVERT(YEAR(LRP.PLAN_DATE), CHAR),'年',CONVERT(MONTH(LRP.PLAN_DATE), CHAR),'月',CONVERT(DAY(LRP.PLAN_DATE), CHAR),'日') AS KEYWORD1,CONCAT(ROUND((LRP.RENT + ROUND(IFNULL(getRentPenalty3(LRP.PAYMENT_NUMBER,LRP.PLAN_LIST,IFNULL(LRI.HIRE_DATE,DATE_FORMAT(NOW(), '%y/%m/%d'))),0),2)) - (IFNULL(LRI.RENT, 0) + IFNULL(LRI.PENALTY, 0)),2),'元') AS KEYWORD2,CONCAT((LRP.RENT - IFNULL(LRI.RENT, 0)),'元') AS KEYWORD3,CONCAT(ROUND(IFNULL(getRentPenalty(LRP.PAYMENT_NUMBER,LRP.PLAN_LIST,IFNULL(LRI.HIRE_DATE,DATE_FORMAT(NOW(), '%y/%m/%d'))),0),2),'元') AS KEYWORD4 FROM WECHAT_USER_INFO WUI LEFT JOIN CUSTOMER_INFO CI ON CI.CERTID = WUI.CERTID_ LEFT JOIN LB_UNION_LESSEE LUL ON LUL.CUSTOMER_ID = CI.CUSTOMERID AND LUL.IS_MAIN = 'Y' LEFT JOIN LB_CONTRACT_INFO LCI ON LCI.ID = LUL.CONTRACT_ID AND LCI.CONTRACT_STATUS = '31' LEFT JOIN DISTRIBUTOR_INFO DI ON DI.DISTRIBUTOR_NO=LCI.DISTRIBUTOR_ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,MAX(PLAN_DATE) AS PLAN_DATE,MAX(PAYMENT_NUMBER) AS PAYMENT_NUMBER,SUM(RENT) AS RENT,SUM(IFNULL(PENALTY, 0)) AS PENALTY FROM LC_RENT_PLAN WHERE TIMESTAMPDIFF(DAY,DATE_FORMAT(PLAN_DATE, '%Y-%m-%d'),DATE_FORMAT(NOW(), '%Y-%m-%d')) >= 3 GROUP BY CONTRACT_ID,PLAN_LIST) LRP ON LRP.CONTRACT_ID = LCI.ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,SUM(RENT) AS RENT,SUM(IFNULL(PENALTY, 0)) AS PENALTY,MAX(HIRE_DATE) AS HIRE_DATE FROM LC_RENT_INCOME GROUP BY CONTRACT_ID,PLAN_LIST) LRI ON LRI.CONTRACT_ID = LRP.CONTRACT_ID AND LRI.PLAN_LIST = LRP.PLAN_LIST WHERE WUI.BINDING_STATUS = 'Y' AND DI.DISTRIBUTOR_NAME<>'辉煌国际融资租赁（天津）有限公司' AND (IFNULL(LRP.RENT, 0)- IFNULL(LRI.RENT, 0)) > 0 AND NOT EXISTS (SELECT 1 FROM WECHAT_MESSAGE_RECORD WHERE OPENID = WUI.OPENID AND SEND_TYPE = '2' AND CONTRACT_NUMBER = LCI.CONTRACT_NUMBER AND PLAN_LIST = LRP.PLAN_LIST AND SEND_STATUS = 'Y') ORDER BY LRP.PLAN_LIST LIMIT 0, 50000 ";
|
||||
String selSql="SELECT CI.CUSTOMERNAME AS CUST_NAME,WUI.MOBILE_,WUI.CERTID_,LCI.CONTRACT_NUMBER,CI.CUSTOMER_NUM,LRP.PLAN_LIST,LCI.ID AS CONTRACT_ID,CI.CUSTOMERID,WUI.OPENID,CONCAT('/wechat/menu?type=payments&id=',LCI.CONTRACT_NUMBER) AS LINK,CONCAT(CONVERT(YEAR(LRP.PLAN_DATE), CHAR),'年',CONVERT(MONTH(LRP.PLAN_DATE), CHAR),'月',CONVERT(DAY(LRP.PLAN_DATE), CHAR),'日') AS KEYWORD1,CONCAT(ROUND((LRP.RENT + ROUND(IFNULL(getRentPenalty3(LRP.PAYMENT_NUMBER,LRP.PLAN_LIST,IFNULL(LRI.HIRE_DATE,DATE_FORMAT(NOW(), '%y/%m/%d'))),0),2)) - (IFNULL(LRI.RENT, 0) + IFNULL(LRI.PENALTY, 0)),2),'元') AS KEYWORD2,CONCAT((LRP.RENT - IFNULL(LRI.RENT, 0)),'元') AS KEYWORD3,CONCAT(ROUND(IFNULL(getRentPenalty(LRP.PAYMENT_NUMBER,LRP.PLAN_LIST,IFNULL(LRI.HIRE_DATE,DATE_FORMAT(NOW(), '%y/%m/%d'))),0),2),'元') AS KEYWORD4 FROM WECHAT_USER_INFO WUI LEFT JOIN CUSTOMER_INFO CI ON CI.CERTID = WUI.CERTID_ LEFT JOIN LB_UNION_LESSEE LUL ON LUL.CUSTOMER_ID = CI.CUSTOMERID AND LUL.IS_MAIN = 'Y' LEFT JOIN LB_CONTRACT_INFO LCI ON LCI.ID = LUL.CONTRACT_ID AND LCI.CONTRACT_STATUS = '31' LEFT JOIN DISTRIBUTOR_INFO DI ON DI.DISTRIBUTOR_NO=LCI.DISTRIBUTOR_ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,MAX(PLAN_DATE) AS PLAN_DATE,MAX(PAYMENT_NUMBER) AS PAYMENT_NUMBER,SUM(RENT) AS RENT,SUM(IFNULL(PENALTY, 0)) AS PENALTY FROM LC_RENT_PLAN WHERE TIMESTAMPDIFF(DAY,DATE_FORMAT(PLAN_DATE, '%Y-%m-%d'),DATE_FORMAT(NOW(), '%Y-%m-%d')) >= 3 GROUP BY CONTRACT_ID,PLAN_LIST) LRP ON LRP.CONTRACT_ID = LCI.ID LEFT JOIN (SELECT CONTRACT_ID,PLAN_LIST,SUM(RENT) AS RENT,SUM(IFNULL(PENALTY, 0)) AS PENALTY,MAX(HIRE_DATE) AS HIRE_DATE FROM LC_RENT_INCOME GROUP BY CONTRACT_ID,PLAN_LIST) LRI ON LRI.CONTRACT_ID = LRP.CONTRACT_ID AND LRI.PLAN_LIST = LRP.PLAN_LIST WHERE WUI.BINDING_STATUS = 'Y' AND IFNULL(WUI.ATTENTION_STATUS,'Y')<>'N' AND DI.DISTRIBUTOR_NAME<>'辉煌国际融资租赁（天津）有限公司' AND (IFNULL(LRP.RENT, 0)- IFNULL(LRI.RENT, 0)) > 0 AND NOT EXISTS (SELECT 1 FROM WECHAT_MESSAGE_RECORD WHERE OPENID = WUI.OPENID AND SEND_TYPE = '2' AND CONTRACT_NUMBER = LCI.CONTRACT_NUMBER AND PLAN_LIST = LRP.PLAN_LIST AND SEND_STATUS = 'Y') ORDER BY LRP.PLAN_LIST LIMIT 0, 50000 ";
|
||||
|
||||
ASResultSet rs = Sqlca.getASResultSet(new SqlObject(selSql));
|
||||
// 循环, 逐条发送
|
||||
|
||||
@ -23,8 +23,8 @@ public class GenerateBackOpinionLog extends BaseBussiness{
|
||||
String channel = this.getAttribute("channel").toString();
|
||||
String applyType = this.getAttribute("ApplyType").toString();
|
||||
String flowunid = this.getAttribute("FlowUnid").toString();
|
||||
String projectNo = this.getAttribute("ProjectNo").toString();
|
||||
String applicationNo = this.getAttribute("applicationNo").toString();
|
||||
String projectNo = this.getAttribute("ProjectNo")==null?"":this.getAttribute("ProjectNo").toString();
|
||||
String applicationNo = this.getAttribute("applicationNo")==null?"":this.getAttribute("applicationNo").toString();
|
||||
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss") ;
|
||||
String thisDate = dateFormat.format(new Date());
|
||||
BizObjectManager ftBm = JBOFactory.getBizObjectManager(FLOW_TASK.CLASS_NAME,Sqlca);
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user