diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskService.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskService.java new file mode 100644 index 00000000..4af015f1 --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskService.java @@ -0,0 +1,5 @@ +package com.infincash.statistics.risk; + +public interface RiskService { + int countRecentRisk(); +} diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskServiceImpl.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskServiceImpl.java new file mode 100644 index 00000000..f5f993ff --- /dev/null +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskServiceImpl.java @@ -0,0 +1,19 @@ +package com.infincash.statistics.risk; + +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import com.infincash.statistics.risk.mapper.TRiskRuleMapper; + +@Service +public class RiskServiceImpl implements RiskService { + + @Autowired + private TRiskRuleMapper mapper;//这里会报错,但是并不会影响 + + @Override + public int countRecentRisk() { + return mapper.countRiskRule(); + } + +} diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TRiskRuleMapper.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TRiskRuleMapper.java index cb5f2062..9c632794 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TRiskRuleMapper.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TRiskRuleMapper.java @@ -1,17 +1,5 @@ package com.infincash.statistics.risk.mapper; -import com.infincash.statistics.risk.table.TRiskRule; - public interface TRiskRuleMapper { - int deleteByPrimaryKey(String id); - - int insert(TRiskRule record); - - int insertSelective(TRiskRule record); - - TRiskRule selectByPrimaryKey(String id); - - int updateByPrimaryKeySelective(TRiskRule record); - - int updateByPrimaryKey(TRiskRule record); + int countRiskRule(); } \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserMapper.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserMapper.java deleted file mode 100644 index 823ac6d3..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserMapper.java +++ /dev/null @@ -1,17 +0,0 @@ -package com.infincash.statistics.risk.mapper; - -import com.infincash.statistics.risk.table.TUser; - -public interface TUserMapper { - int deleteByPrimaryKey(String id); - - int insert(TUser record); - - int insertSelective(TUser record); - - TUser selectByPrimaryKey(String id); - - int updateByPrimaryKeySelective(TUser record); - - int updateByPrimaryKey(TUser record); -} \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserRiskMapper.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserRiskMapper.java deleted file mode 100644 index 2873b503..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/TUserRiskMapper.java +++ /dev/null @@ -1,17 +0,0 @@ -package com.infincash.statistics.risk.mapper; - -import com.infincash.statistics.risk.table.TUserRisk; - -public interface TUserRiskMapper { - int deleteByPrimaryKey(String id); - - int insert(TUserRisk record); - - int insertSelective(TUserRisk record); - - TUserRisk selectByPrimaryKey(String id); - - int updateByPrimaryKeySelective(TUserRisk record); - - int updateByPrimaryKey(TUserRisk record); -} \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TRiskRule.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TRiskRule.java deleted file mode 100644 index 14bb9e03..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TRiskRule.java +++ /dev/null @@ -1,93 +0,0 @@ -package com.infincash.statistics.risk.table; - -public class TRiskRule { - private String id; - - private String typeCode; - - private String type; - - private String nameCode; - - private String value; - - private String express; - - private String status; - - private String expressDesc; - - private String expressType; - - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id == null ? null : id.trim(); - } - - public String getTypeCode() { - return typeCode; - } - - public void setTypeCode(String typeCode) { - this.typeCode = typeCode == null ? null : typeCode.trim(); - } - - public String getType() { - return type; - } - - public void setType(String type) { - this.type = type == null ? null : type.trim(); - } - - public String getNameCode() { - return nameCode; - } - - public void setNameCode(String nameCode) { - this.nameCode = nameCode == null ? null : nameCode.trim(); - } - - public String getValue() { - return value; - } - - public void setValue(String value) { - this.value = value == null ? null : value.trim(); - } - - public String getExpress() { - return express; - } - - public void setExpress(String express) { - this.express = express == null ? null : express.trim(); - } - - public String getStatus() { - return status; - } - - public void setStatus(String status) { - this.status = status == null ? null : status.trim(); - } - - public String getExpressDesc() { - return expressDesc; - } - - public void setExpressDesc(String expressDesc) { - this.expressDesc = expressDesc == null ? null : expressDesc.trim(); - } - - public String getExpressType() { - return expressType; - } - - public void setExpressType(String expressType) { - this.expressType = expressType == null ? null : expressType.trim(); - } -} \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUser.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUser.java deleted file mode 100644 index 88401a25..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUser.java +++ /dev/null @@ -1,276 +0,0 @@ -package com.infincash.statistics.risk.table; - -import java.math.BigDecimal; -import java.util.Date; - -public class TUser { - private String id; - - private String userId; - - private String userName; - - private String loginName; - - private String password; - - private String tranPassword; - - private String phone; - - private String creditRuleId; - - private String imageUrl; - - private BigDecimal score; - - private BigDecimal borrowingLines; - - private BigDecimal creditLines; - - private String source; - - private String userType; - - private Integer errrorNumber; - - private Integer tranPwdErrorNum; - - private String explains; - - private String isLocked; - - private String isBlacklist; - - private String inviteCode; - - private String registerIp; - - private Date registerTime; - - private String lastLoginIp; - - private Date lastLoginTime; - - private Date updateTime; - - private String email; - - private Date creditTime; - - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id == null ? null : id.trim(); - } - - public String getUserId() { - return userId; - } - - public void setUserId(String userId) { - this.userId = userId == null ? null : userId.trim(); - } - - public String getUserName() { - return userName; - } - - public void setUserName(String userName) { - this.userName = userName == null ? null : userName.trim(); - } - - public String getLoginName() { - return loginName; - } - - public void setLoginName(String loginName) { - this.loginName = loginName == null ? null : loginName.trim(); - } - - public String getPassword() { - return password; - } - - public void setPassword(String password) { - this.password = password == null ? null : password.trim(); - } - - public String getTranPassword() { - return tranPassword; - } - - public void setTranPassword(String tranPassword) { - this.tranPassword = tranPassword == null ? null : tranPassword.trim(); - } - - public String getPhone() { - return phone; - } - - public void setPhone(String phone) { - this.phone = phone == null ? null : phone.trim(); - } - - public String getCreditRuleId() { - return creditRuleId; - } - - public void setCreditRuleId(String creditRuleId) { - this.creditRuleId = creditRuleId == null ? null : creditRuleId.trim(); - } - - public String getImageUrl() { - return imageUrl; - } - - public void setImageUrl(String imageUrl) { - this.imageUrl = imageUrl == null ? null : imageUrl.trim(); - } - - public BigDecimal getScore() { - return score; - } - - public void setScore(BigDecimal score) { - this.score = score; - } - - public BigDecimal getBorrowingLines() { - return borrowingLines; - } - - public void setBorrowingLines(BigDecimal borrowingLines) { - this.borrowingLines = borrowingLines; - } - - public BigDecimal getCreditLines() { - return creditLines; - } - - public void setCreditLines(BigDecimal creditLines) { - this.creditLines = creditLines; - } - - public String getSource() { - return source; - } - - public void setSource(String source) { - this.source = source == null ? null : source.trim(); - } - - public String getUserType() { - return userType; - } - - public void setUserType(String userType) { - this.userType = userType == null ? null : userType.trim(); - } - - public Integer getErrrorNumber() { - return errrorNumber; - } - - public void setErrrorNumber(Integer errrorNumber) { - this.errrorNumber = errrorNumber; - } - - public Integer getTranPwdErrorNum() { - return tranPwdErrorNum; - } - - public void setTranPwdErrorNum(Integer tranPwdErrorNum) { - this.tranPwdErrorNum = tranPwdErrorNum; - } - - public String getExplains() { - return explains; - } - - public void setExplains(String explains) { - this.explains = explains == null ? null : explains.trim(); - } - - public String getIsLocked() { - return isLocked; - } - - public void setIsLocked(String isLocked) { - this.isLocked = isLocked == null ? null : isLocked.trim(); - } - - public String getIsBlacklist() { - return isBlacklist; - } - - public void setIsBlacklist(String isBlacklist) { - this.isBlacklist = isBlacklist == null ? null : isBlacklist.trim(); - } - - public String getInviteCode() { - return inviteCode; - } - - public void setInviteCode(String inviteCode) { - this.inviteCode = inviteCode == null ? null : inviteCode.trim(); - } - - public String getRegisterIp() { - return registerIp; - } - - public void setRegisterIp(String registerIp) { - this.registerIp = registerIp == null ? null : registerIp.trim(); - } - - public Date getRegisterTime() { - return registerTime; - } - - public void setRegisterTime(Date registerTime) { - this.registerTime = registerTime; - } - - public String getLastLoginIp() { - return lastLoginIp; - } - - public void setLastLoginIp(String lastLoginIp) { - this.lastLoginIp = lastLoginIp == null ? null : lastLoginIp.trim(); - } - - public Date getLastLoginTime() { - return lastLoginTime; - } - - public void setLastLoginTime(Date lastLoginTime) { - this.lastLoginTime = lastLoginTime; - } - - public Date getUpdateTime() { - return updateTime; - } - - public void setUpdateTime(Date updateTime) { - this.updateTime = updateTime; - } - - public String getEmail() { - return email; - } - - public void setEmail(String email) { - this.email = email == null ? null : email.trim(); - } - - public Date getCreditTime() { - return creditTime; - } - - public void setCreditTime(Date creditTime) { - this.creditTime = creditTime; - } -} \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUserRisk.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUserRisk.java deleted file mode 100644 index 0be2ea9b..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/TUserRisk.java +++ /dev/null @@ -1,43 +0,0 @@ -package com.infincash.statistics.risk.table; - -public class TUserRisk { - private String id; - - private String userId; - - private String riskRuleId; - - private String checkId; - - public String getId() { - return id; - } - - public void setId(String id) { - this.id = id == null ? null : id.trim(); - } - - public String getUserId() { - return userId; - } - - public void setUserId(String userId) { - this.userId = userId == null ? null : userId.trim(); - } - - public String getRiskRuleId() { - return riskRuleId; - } - - public void setRiskRuleId(String riskRuleId) { - this.riskRuleId = riskRuleId == null ? null : riskRuleId.trim(); - } - - public String getCheckId() { - return checkId; - } - - public void setCheckId(String checkId) { - this.checkId = checkId == null ? null : checkId.trim(); - } -} \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java index 6bafe975..7d98f862 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java @@ -1,9 +1,9 @@ package com.xxl.job.executor.service.jobhandler; -import java.util.concurrent.TimeUnit; - +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; +import com.infincash.statistics.risk.RiskService; import com.xxl.job.core.biz.model.ReturnT; import com.xxl.job.core.handler.IJobHandler; import com.xxl.job.core.handler.annotation.JobHandler; @@ -22,10 +22,13 @@ import com.xxl.job.core.log.XxlJobLogger; @JobHandler(value = "risk-count-statistics") @Component public class RiskCountStatisticsJobHandler extends IJobHandler { + @Autowired + RiskService service; @Override public ReturnT execute(String param) throws Exception { - XxlJobLogger.log("XXL-JOB, 1 Hello World."); + int aa = service.countRecentRisk(); + XxlJobLogger.log("aa: " + aa); XxlJobLogger.log("beat at:"); return SUCCESS; } diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TRiskRuleMapper.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TRiskRuleMapper.xml index 189e6315..a7e679c9 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TRiskRuleMapper.xml +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TRiskRuleMapper.xml @@ -1,278 +1,9 @@ - - - - - - - - - - - - - id, type_code, type, name_code, value, express, status, express_desc, express_type - - select - + count(1) from t_risk_rule - where id = #{id,jdbcType=VARCHAR} - - delete from t_risk_rule - where id = #{id,jdbcType=VARCHAR} - - - insert into t_risk_rule (id, type_code, type, - name_code, value, express, - status, express_desc, express_type - ) - values (#{id,jdbcType=VARCHAR}, #{typeCode,jdbcType=VARCHAR}, #{type,jdbcType=VARCHAR}, - #{nameCode,jdbcType=VARCHAR}, #{value,jdbcType=VARCHAR}, #{express,jdbcType=VARCHAR}, - #{status,jdbcType=CHAR}, #{expressDesc,jdbcType=VARCHAR}, #{expressType,jdbcType=CHAR} - ) - - - insert into t_risk_rule - - - id, - - - type_code, - - - type, - - - name_code, - - - value, - - - express, - - - status, - - - express_desc, - - - express_type, - - - - - #{id,jdbcType=VARCHAR}, - - - #{typeCode,jdbcType=VARCHAR}, - - - #{type,jdbcType=VARCHAR}, - - - #{nameCode,jdbcType=VARCHAR}, - - - #{value,jdbcType=VARCHAR}, - - - #{express,jdbcType=VARCHAR}, - - - #{status,jdbcType=CHAR}, - - - #{expressDesc,jdbcType=VARCHAR}, - - - #{expressType,jdbcType=CHAR}, - - - - - update t_risk_rule - - - type_code = #{typeCode,jdbcType=VARCHAR}, - - - type = #{type,jdbcType=VARCHAR}, - - - name_code = #{nameCode,jdbcType=VARCHAR}, - - - value = #{value,jdbcType=VARCHAR}, - - - express = #{express,jdbcType=VARCHAR}, - - - status = #{status,jdbcType=CHAR}, - - - express_desc = #{expressDesc,jdbcType=VARCHAR}, - - - express_type = #{expressType,jdbcType=CHAR}, - - - where id = #{id,jdbcType=VARCHAR} - - - update t_risk_rule - set type_code = #{typeCode,jdbcType=VARCHAR}, - type = #{type,jdbcType=VARCHAR}, - name_code = #{nameCode,jdbcType=VARCHAR}, - value = #{value,jdbcType=VARCHAR}, - express = #{express,jdbcType=VARCHAR}, - status = #{status,jdbcType=CHAR}, - express_desc = #{expressDesc,jdbcType=VARCHAR}, - express_type = #{expressType,jdbcType=CHAR} - where id = #{id,jdbcType=VARCHAR} - - - - - - - - - - - - - - id, type_code, type, name_code, value, express, status, express_desc, express_type - - - - delete from t_risk_rule - where id = #{id,jdbcType=VARCHAR} - - - insert into t_risk_rule (id, type_code, type, - name_code, value, express, - status, express_desc, express_type - ) - values (#{id,jdbcType=VARCHAR}, #{typeCode,jdbcType=VARCHAR}, #{type,jdbcType=VARCHAR}, - #{nameCode,jdbcType=VARCHAR}, #{value,jdbcType=VARCHAR}, #{express,jdbcType=VARCHAR}, - #{status,jdbcType=CHAR}, #{expressDesc,jdbcType=VARCHAR}, #{expressType,jdbcType=CHAR} - ) - - - insert into t_risk_rule - - - id, - - - type_code, - - - type, - - - name_code, - - - value, - - - express, - - - status, - - - express_desc, - - - express_type, - - - - - #{id,jdbcType=VARCHAR}, - - - #{typeCode,jdbcType=VARCHAR}, - - - #{type,jdbcType=VARCHAR}, - - - #{nameCode,jdbcType=VARCHAR}, - - - #{value,jdbcType=VARCHAR}, - - - #{express,jdbcType=VARCHAR}, - - - #{status,jdbcType=CHAR}, - - - #{expressDesc,jdbcType=VARCHAR}, - - - #{expressType,jdbcType=CHAR}, - - - - - update t_risk_rule - - - type_code = #{typeCode,jdbcType=VARCHAR}, - - - type = #{type,jdbcType=VARCHAR}, - - - name_code = #{nameCode,jdbcType=VARCHAR}, - - - value = #{value,jdbcType=VARCHAR}, - - - express = #{express,jdbcType=VARCHAR}, - - - status = #{status,jdbcType=CHAR}, - - - express_desc = #{expressDesc,jdbcType=VARCHAR}, - - - express_type = #{expressType,jdbcType=CHAR}, - - - where id = #{id,jdbcType=VARCHAR} - - - update t_risk_rule - set type_code = #{typeCode,jdbcType=VARCHAR}, - type = #{type,jdbcType=VARCHAR}, - name_code = #{nameCode,jdbcType=VARCHAR}, - value = #{value,jdbcType=VARCHAR}, - express = #{express,jdbcType=VARCHAR}, - status = #{status,jdbcType=CHAR}, - express_desc = #{expressDesc,jdbcType=VARCHAR}, - express_type = #{expressType,jdbcType=CHAR} - where id = #{id,jdbcType=VARCHAR} - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserMapper.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserMapper.xml deleted file mode 100644 index bbec7fa2..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserMapper.xml +++ /dev/null @@ -1,704 +0,0 @@ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - id, user_id, user_name, login_name, password, tran_password, phone, credit_rule_id, - image_url, score, borrowing_lines, credit_lines, source, user_type, errror_number, - tran_pwd_error_num, explains, is_locked, is_blacklist, invite_code, register_ip, - register_time, last_login_ip, last_login_time, update_time, email, credit_time - - - - delete from t_user - where id = #{id,jdbcType=VARCHAR} - - - insert into t_user (id, user_id, user_name, - login_name, password, tran_password, - phone, credit_rule_id, image_url, - score, borrowing_lines, credit_lines, - source, user_type, errror_number, - tran_pwd_error_num, explains, is_locked, - is_blacklist, invite_code, register_ip, - register_time, last_login_ip, last_login_time, - update_time, email, credit_time - ) - values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{userName,jdbcType=VARCHAR}, - #{loginName,jdbcType=VARCHAR}, #{password,jdbcType=VARCHAR}, #{tranPassword,jdbcType=VARCHAR}, - #{phone,jdbcType=VARCHAR}, #{creditRuleId,jdbcType=VARCHAR}, #{imageUrl,jdbcType=VARCHAR}, - #{score,jdbcType=DECIMAL}, #{borrowingLines,jdbcType=DECIMAL}, #{creditLines,jdbcType=DECIMAL}, - #{source,jdbcType=CHAR}, #{userType,jdbcType=CHAR}, #{errrorNumber,jdbcType=INTEGER}, - #{tranPwdErrorNum,jdbcType=INTEGER}, #{explains,jdbcType=VARCHAR}, #{isLocked,jdbcType=CHAR}, - #{isBlacklist,jdbcType=CHAR}, #{inviteCode,jdbcType=VARCHAR}, #{registerIp,jdbcType=VARCHAR}, - #{registerTime,jdbcType=TIMESTAMP}, #{lastLoginIp,jdbcType=VARCHAR}, #{lastLoginTime,jdbcType=TIMESTAMP}, - #{updateTime,jdbcType=TIMESTAMP}, #{email,jdbcType=VARCHAR}, #{creditTime,jdbcType=TIMESTAMP} - ) - - - insert into t_user - - - id, - - - user_id, - - - user_name, - - - login_name, - - - password, - - - tran_password, - - - phone, - - - credit_rule_id, - - - image_url, - - - score, - - - borrowing_lines, - - - credit_lines, - - - source, - - - user_type, - - - errror_number, - - - tran_pwd_error_num, - - - explains, - - - is_locked, - - - is_blacklist, - - - invite_code, - - - register_ip, - - - register_time, - - - last_login_ip, - - - last_login_time, - - - update_time, - - - email, - - - credit_time, - - - - - #{id,jdbcType=VARCHAR}, - - - #{userId,jdbcType=VARCHAR}, - - - #{userName,jdbcType=VARCHAR}, - - - #{loginName,jdbcType=VARCHAR}, - - - #{password,jdbcType=VARCHAR}, - - - #{tranPassword,jdbcType=VARCHAR}, - - - #{phone,jdbcType=VARCHAR}, - - - #{creditRuleId,jdbcType=VARCHAR}, - - - #{imageUrl,jdbcType=VARCHAR}, - - - #{score,jdbcType=DECIMAL}, - - - #{borrowingLines,jdbcType=DECIMAL}, - - - #{creditLines,jdbcType=DECIMAL}, - - - #{source,jdbcType=CHAR}, - - - #{userType,jdbcType=CHAR}, - - - #{errrorNumber,jdbcType=INTEGER}, - - - #{tranPwdErrorNum,jdbcType=INTEGER}, - - - #{explains,jdbcType=VARCHAR}, - - - #{isLocked,jdbcType=CHAR}, - - - #{isBlacklist,jdbcType=CHAR}, - - - #{inviteCode,jdbcType=VARCHAR}, - - - #{registerIp,jdbcType=VARCHAR}, - - - #{registerTime,jdbcType=TIMESTAMP}, - - - #{lastLoginIp,jdbcType=VARCHAR}, - - - #{lastLoginTime,jdbcType=TIMESTAMP}, - - - #{updateTime,jdbcType=TIMESTAMP}, - - - #{email,jdbcType=VARCHAR}, - - - #{creditTime,jdbcType=TIMESTAMP}, - - - - - update t_user - - - user_id = #{userId,jdbcType=VARCHAR}, - - - user_name = #{userName,jdbcType=VARCHAR}, - - - login_name = #{loginName,jdbcType=VARCHAR}, - - - password = #{password,jdbcType=VARCHAR}, - - - tran_password = #{tranPassword,jdbcType=VARCHAR}, - - - phone = #{phone,jdbcType=VARCHAR}, - - - credit_rule_id = #{creditRuleId,jdbcType=VARCHAR}, - - - image_url = #{imageUrl,jdbcType=VARCHAR}, - - - score = #{score,jdbcType=DECIMAL}, - - - borrowing_lines = #{borrowingLines,jdbcType=DECIMAL}, - - - credit_lines = #{creditLines,jdbcType=DECIMAL}, - - - source = #{source,jdbcType=CHAR}, - - - user_type = #{userType,jdbcType=CHAR}, - - - errror_number = #{errrorNumber,jdbcType=INTEGER}, - - - tran_pwd_error_num = #{tranPwdErrorNum,jdbcType=INTEGER}, - - - explains = #{explains,jdbcType=VARCHAR}, - - - is_locked = #{isLocked,jdbcType=CHAR}, - - - is_blacklist = #{isBlacklist,jdbcType=CHAR}, - - - invite_code = #{inviteCode,jdbcType=VARCHAR}, - - - register_ip = #{registerIp,jdbcType=VARCHAR}, - - - register_time = #{registerTime,jdbcType=TIMESTAMP}, - - - last_login_ip = #{lastLoginIp,jdbcType=VARCHAR}, - - - last_login_time = #{lastLoginTime,jdbcType=TIMESTAMP}, - - - update_time = #{updateTime,jdbcType=TIMESTAMP}, - - - email = #{email,jdbcType=VARCHAR}, - - - credit_time = #{creditTime,jdbcType=TIMESTAMP}, - - - where id = #{id,jdbcType=VARCHAR} - - - update t_user - set user_id = #{userId,jdbcType=VARCHAR}, - user_name = #{userName,jdbcType=VARCHAR}, - login_name = #{loginName,jdbcType=VARCHAR}, - password = #{password,jdbcType=VARCHAR}, - tran_password = #{tranPassword,jdbcType=VARCHAR}, - phone = #{phone,jdbcType=VARCHAR}, - credit_rule_id = #{creditRuleId,jdbcType=VARCHAR}, - image_url = #{imageUrl,jdbcType=VARCHAR}, - score = #{score,jdbcType=DECIMAL}, - borrowing_lines = #{borrowingLines,jdbcType=DECIMAL}, - credit_lines = #{creditLines,jdbcType=DECIMAL}, - source = #{source,jdbcType=CHAR}, - user_type = #{userType,jdbcType=CHAR}, - errror_number = #{errrorNumber,jdbcType=INTEGER}, - tran_pwd_error_num = #{tranPwdErrorNum,jdbcType=INTEGER}, - explains = #{explains,jdbcType=VARCHAR}, - is_locked = #{isLocked,jdbcType=CHAR}, - is_blacklist = #{isBlacklist,jdbcType=CHAR}, - invite_code = #{inviteCode,jdbcType=VARCHAR}, - register_ip = #{registerIp,jdbcType=VARCHAR}, - register_time = #{registerTime,jdbcType=TIMESTAMP}, - last_login_ip = #{lastLoginIp,jdbcType=VARCHAR}, - last_login_time = #{lastLoginTime,jdbcType=TIMESTAMP}, - update_time = #{updateTime,jdbcType=TIMESTAMP}, - email = #{email,jdbcType=VARCHAR}, - credit_time = #{creditTime,jdbcType=TIMESTAMP} - where id = #{id,jdbcType=VARCHAR} - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - id, user_id, user_name, login_name, password, tran_password, phone, credit_rule_id, - image_url, score, borrowing_lines, credit_lines, source, user_type, errror_number, - tran_pwd_error_num, explains, is_locked, is_blacklist, invite_code, register_ip, - register_time, last_login_ip, last_login_time, update_time, email, credit_time - - - - delete from t_user - where id = #{id,jdbcType=VARCHAR} - - - insert into t_user (id, user_id, user_name, - login_name, password, tran_password, - phone, credit_rule_id, image_url, - score, borrowing_lines, credit_lines, - source, user_type, errror_number, - tran_pwd_error_num, explains, is_locked, - is_blacklist, invite_code, register_ip, - register_time, last_login_ip, last_login_time, - update_time, email, credit_time - ) - values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{userName,jdbcType=VARCHAR}, - #{loginName,jdbcType=VARCHAR}, #{password,jdbcType=VARCHAR}, #{tranPassword,jdbcType=VARCHAR}, - #{phone,jdbcType=VARCHAR}, #{creditRuleId,jdbcType=VARCHAR}, #{imageUrl,jdbcType=VARCHAR}, - #{score,jdbcType=DECIMAL}, #{borrowingLines,jdbcType=DECIMAL}, #{creditLines,jdbcType=DECIMAL}, - #{source,jdbcType=CHAR}, #{userType,jdbcType=CHAR}, #{errrorNumber,jdbcType=INTEGER}, - #{tranPwdErrorNum,jdbcType=INTEGER}, #{explains,jdbcType=VARCHAR}, #{isLocked,jdbcType=CHAR}, - #{isBlacklist,jdbcType=CHAR}, #{inviteCode,jdbcType=VARCHAR}, #{registerIp,jdbcType=VARCHAR}, - #{registerTime,jdbcType=TIMESTAMP}, #{lastLoginIp,jdbcType=VARCHAR}, #{lastLoginTime,jdbcType=TIMESTAMP}, - #{updateTime,jdbcType=TIMESTAMP}, #{email,jdbcType=VARCHAR}, #{creditTime,jdbcType=TIMESTAMP} - ) - - - insert into t_user - - - id, - - - user_id, - - - user_name, - - - login_name, - - - password, - - - tran_password, - - - phone, - - - credit_rule_id, - - - image_url, - - - score, - - - borrowing_lines, - - - credit_lines, - - - source, - - - user_type, - - - errror_number, - - - tran_pwd_error_num, - - - explains, - - - is_locked, - - - is_blacklist, - - - invite_code, - - - register_ip, - - - register_time, - - - last_login_ip, - - - last_login_time, - - - update_time, - - - email, - - - credit_time, - - - - - #{id,jdbcType=VARCHAR}, - - - #{userId,jdbcType=VARCHAR}, - - - #{userName,jdbcType=VARCHAR}, - - - #{loginName,jdbcType=VARCHAR}, - - - #{password,jdbcType=VARCHAR}, - - - #{tranPassword,jdbcType=VARCHAR}, - - - #{phone,jdbcType=VARCHAR}, - - - #{creditRuleId,jdbcType=VARCHAR}, - - - #{imageUrl,jdbcType=VARCHAR}, - - - #{score,jdbcType=DECIMAL}, - - - #{borrowingLines,jdbcType=DECIMAL}, - - - #{creditLines,jdbcType=DECIMAL}, - - - #{source,jdbcType=CHAR}, - - - #{userType,jdbcType=CHAR}, - - - #{errrorNumber,jdbcType=INTEGER}, - - - #{tranPwdErrorNum,jdbcType=INTEGER}, - - - #{explains,jdbcType=VARCHAR}, - - - #{isLocked,jdbcType=CHAR}, - - - #{isBlacklist,jdbcType=CHAR}, - - - #{inviteCode,jdbcType=VARCHAR}, - - - #{registerIp,jdbcType=VARCHAR}, - - - #{registerTime,jdbcType=TIMESTAMP}, - - - #{lastLoginIp,jdbcType=VARCHAR}, - - - #{lastLoginTime,jdbcType=TIMESTAMP}, - - - #{updateTime,jdbcType=TIMESTAMP}, - - - #{email,jdbcType=VARCHAR}, - - - #{creditTime,jdbcType=TIMESTAMP}, - - - - - update t_user - - - user_id = #{userId,jdbcType=VARCHAR}, - - - user_name = #{userName,jdbcType=VARCHAR}, - - - login_name = #{loginName,jdbcType=VARCHAR}, - - - password = #{password,jdbcType=VARCHAR}, - - - tran_password = #{tranPassword,jdbcType=VARCHAR}, - - - phone = #{phone,jdbcType=VARCHAR}, - - - credit_rule_id = #{creditRuleId,jdbcType=VARCHAR}, - - - image_url = #{imageUrl,jdbcType=VARCHAR}, - - - score = #{score,jdbcType=DECIMAL}, - - - borrowing_lines = #{borrowingLines,jdbcType=DECIMAL}, - - - credit_lines = #{creditLines,jdbcType=DECIMAL}, - - - source = #{source,jdbcType=CHAR}, - - - user_type = #{userType,jdbcType=CHAR}, - - - errror_number = #{errrorNumber,jdbcType=INTEGER}, - - - tran_pwd_error_num = #{tranPwdErrorNum,jdbcType=INTEGER}, - - - explains = #{explains,jdbcType=VARCHAR}, - - - is_locked = #{isLocked,jdbcType=CHAR}, - - - is_blacklist = #{isBlacklist,jdbcType=CHAR}, - - - invite_code = #{inviteCode,jdbcType=VARCHAR}, - - - register_ip = #{registerIp,jdbcType=VARCHAR}, - - - register_time = #{registerTime,jdbcType=TIMESTAMP}, - - - last_login_ip = #{lastLoginIp,jdbcType=VARCHAR}, - - - last_login_time = #{lastLoginTime,jdbcType=TIMESTAMP}, - - - update_time = #{updateTime,jdbcType=TIMESTAMP}, - - - email = #{email,jdbcType=VARCHAR}, - - - credit_time = #{creditTime,jdbcType=TIMESTAMP}, - - - where id = #{id,jdbcType=VARCHAR} - - - update t_user - set user_id = #{userId,jdbcType=VARCHAR}, - user_name = #{userName,jdbcType=VARCHAR}, - login_name = #{loginName,jdbcType=VARCHAR}, - password = #{password,jdbcType=VARCHAR}, - tran_password = #{tranPassword,jdbcType=VARCHAR}, - phone = #{phone,jdbcType=VARCHAR}, - credit_rule_id = #{creditRuleId,jdbcType=VARCHAR}, - image_url = #{imageUrl,jdbcType=VARCHAR}, - score = #{score,jdbcType=DECIMAL}, - borrowing_lines = #{borrowingLines,jdbcType=DECIMAL}, - credit_lines = #{creditLines,jdbcType=DECIMAL}, - source = #{source,jdbcType=CHAR}, - user_type = #{userType,jdbcType=CHAR}, - errror_number = #{errrorNumber,jdbcType=INTEGER}, - tran_pwd_error_num = #{tranPwdErrorNum,jdbcType=INTEGER}, - explains = #{explains,jdbcType=VARCHAR}, - is_locked = #{isLocked,jdbcType=CHAR}, - is_blacklist = #{isBlacklist,jdbcType=CHAR}, - invite_code = #{inviteCode,jdbcType=VARCHAR}, - register_ip = #{registerIp,jdbcType=VARCHAR}, - register_time = #{registerTime,jdbcType=TIMESTAMP}, - last_login_ip = #{lastLoginIp,jdbcType=VARCHAR}, - last_login_time = #{lastLoginTime,jdbcType=TIMESTAMP}, - update_time = #{updateTime,jdbcType=TIMESTAMP}, - email = #{email,jdbcType=VARCHAR}, - credit_time = #{creditTime,jdbcType=TIMESTAMP} - where id = #{id,jdbcType=VARCHAR} - - \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserRiskMapper.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserRiskMapper.xml deleted file mode 100644 index b8996b12..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/TUserRiskMapper.xml +++ /dev/null @@ -1,160 +0,0 @@ - - - - - - - - - - - id, user_id, risk_rule_id, check_id - - - - delete from t_user_risk - where id = #{id,jdbcType=VARCHAR} - - - insert into t_user_risk (id, user_id, risk_rule_id, - check_id) - values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{riskRuleId,jdbcType=VARCHAR}, - #{checkId,jdbcType=VARCHAR}) - - - insert into t_user_risk - - - id, - - - user_id, - - - risk_rule_id, - - - check_id, - - - - - #{id,jdbcType=VARCHAR}, - - - #{userId,jdbcType=VARCHAR}, - - - #{riskRuleId,jdbcType=VARCHAR}, - - - #{checkId,jdbcType=VARCHAR}, - - - - - update t_user_risk - - - user_id = #{userId,jdbcType=VARCHAR}, - - - risk_rule_id = #{riskRuleId,jdbcType=VARCHAR}, - - - check_id = #{checkId,jdbcType=VARCHAR}, - - - where id = #{id,jdbcType=VARCHAR} - - - update t_user_risk - set user_id = #{userId,jdbcType=VARCHAR}, - risk_rule_id = #{riskRuleId,jdbcType=VARCHAR}, - check_id = #{checkId,jdbcType=VARCHAR} - where id = #{id,jdbcType=VARCHAR} - - - - - - - - - id, user_id, risk_rule_id, check_id - - - - delete from t_user_risk - where id = #{id,jdbcType=VARCHAR} - - - insert into t_user_risk (id, user_id, risk_rule_id, - check_id) - values (#{id,jdbcType=VARCHAR}, #{userId,jdbcType=VARCHAR}, #{riskRuleId,jdbcType=VARCHAR}, - #{checkId,jdbcType=VARCHAR}) - - - insert into t_user_risk - - - id, - - - user_id, - - - risk_rule_id, - - - check_id, - - - - - #{id,jdbcType=VARCHAR}, - - - #{userId,jdbcType=VARCHAR}, - - - #{riskRuleId,jdbcType=VARCHAR}, - - - #{checkId,jdbcType=VARCHAR}, - - - - - update t_user_risk - - - user_id = #{userId,jdbcType=VARCHAR}, - - - risk_rule_id = #{riskRuleId,jdbcType=VARCHAR}, - - - check_id = #{checkId,jdbcType=VARCHAR}, - - - where id = #{id,jdbcType=VARCHAR} - - - update t_user_risk - set user_id = #{userId,jdbcType=VARCHAR}, - risk_rule_id = #{riskRuleId,jdbcType=VARCHAR}, - check_id = #{checkId,jdbcType=VARCHAR} - where id = #{id,jdbcType=VARCHAR} - - \ No newline at end of file