|
@@ -4,59 +4,86 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
|
|
|
import org.apache.ibatis.annotations.SelectProvider;
|
|
import org.apache.ibatis.annotations.SelectProvider;
|
|
|
import org.jeecg.modules.smscheck.entity.SmsCheckCustomerInfo;
|
|
import org.jeecg.modules.smscheck.entity.SmsCheckCustomerInfo;
|
|
|
|
|
+import org.jeecg.modules.smscheck.entity.SmsCustomerInfoGroupByCheckState;
|
|
|
import org.jeecg.modules.smscheck.vo.SmsCheckCustomerInfoTaskVo;
|
|
import org.jeecg.modules.smscheck.vo.SmsCheckCustomerInfoTaskVo;
|
|
|
import org.jeecg.modules.smscheck.vo.SmsCheckTaskVo;
|
|
import org.jeecg.modules.smscheck.vo.SmsCheckTaskVo;
|
|
|
|
|
|
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
- * @description 客户信息
|
|
|
|
|
* @author jeecg-boot
|
|
* @author jeecg-boot
|
|
|
- * @date 2022-06-22
|
|
|
|
|
* @version V1.0
|
|
* @version V1.0
|
|
|
|
|
+ * @description 客户信息
|
|
|
|
|
+ * @date 2022-06-22
|
|
|
*/
|
|
*/
|
|
|
public interface SmsCheckCustomerInfoMapper extends BaseMapper<SmsCheckCustomerInfo> {
|
|
public interface SmsCheckCustomerInfoMapper extends BaseMapper<SmsCheckCustomerInfo> {
|
|
|
|
|
|
|
|
- @SelectProvider(type = ProviderClass.class,method = "selectCompanyList")
|
|
|
|
|
|
|
+ @SelectProvider(type = ProviderClass.class, method = "selectCompanyList")
|
|
|
List<SmsCheckCustomerInfo> selectCompanyList(SmsCheckCustomerInfo smsCheckCustomerInfo);
|
|
List<SmsCheckCustomerInfo> selectCompanyList(SmsCheckCustomerInfo smsCheckCustomerInfo);
|
|
|
|
|
|
|
|
- @SelectProvider(type = ProviderClass.class,method = "checkInfoWarningCount")
|
|
|
|
|
|
|
+ @SelectProvider(type = ProviderClass.class, method = "checkInfoWarningCount")
|
|
|
Integer checkInfoWarningCount(SmsCheckCustomerInfo smsCheckCustomerInfo);
|
|
Integer checkInfoWarningCount(SmsCheckCustomerInfo smsCheckCustomerInfo);
|
|
|
|
|
|
|
|
- @SelectProvider(type = ProviderClass.class,method = "checkInfoWarningCountTime")
|
|
|
|
|
|
|
+ @SelectProvider(type = ProviderClass.class, method = "checkInfoWarningCountTime")
|
|
|
List<SmsCheckTaskVo> checkInfoWarningCountTime(SmsCheckCustomerInfo smsCheckCustomerInfo);
|
|
List<SmsCheckTaskVo> checkInfoWarningCountTime(SmsCheckCustomerInfo smsCheckCustomerInfo);
|
|
|
|
|
|
|
|
- @SelectProvider(type = ProviderClass.class,method = "checkInfoWarningCountStaff")
|
|
|
|
|
|
|
+ @SelectProvider(type = ProviderClass.class, method = "checkInfoWarningCountStaff")
|
|
|
List<SmsCheckTaskVo> checkInfoWarningCountStaff(SmsCheckCustomerInfo smsCheckCustomerInfo);
|
|
List<SmsCheckTaskVo> checkInfoWarningCountStaff(SmsCheckCustomerInfo smsCheckCustomerInfo);
|
|
|
|
|
|
|
|
- @SelectProvider(type = ProviderClass.class,method = "checkInfoWarningCountStaff")
|
|
|
|
|
|
|
+ @SelectProvider(type = ProviderClass.class, method = "checkInfoWarningCountStaff")
|
|
|
List<SmsCheckCustomerInfoTaskVo> checkInfoWarningPageList(Integer pageNo, Integer pageSize);
|
|
List<SmsCheckCustomerInfoTaskVo> checkInfoWarningPageList(Integer pageNo, Integer pageSize);
|
|
|
|
|
|
|
|
- class ProviderClass{
|
|
|
|
|
- public String checkInfoWarningCount(SmsCheckCustomerInfo smsCheckCustomerInfo){
|
|
|
|
|
|
|
+ @SelectProvider(type = ProviderClass.class, method = "groupCheckState")
|
|
|
|
|
+ List<SmsCustomerInfoGroupByCheckState> groupCheckState(String startDate, String endDate,String taskId);
|
|
|
|
|
+
|
|
|
|
|
+ class ProviderClass {
|
|
|
|
|
+
|
|
|
|
|
+ public String groupCheckState(String startDate, String endDate, String taskId) {
|
|
|
|
|
+ StringBuilder sql = new StringBuilder();
|
|
|
|
|
+
|
|
|
|
|
+ sql.append("SELECT COUNT(id) as count ,check_state as checkState " +
|
|
|
|
|
+ "from sms_check_customer_info ");
|
|
|
|
|
+
|
|
|
|
|
+ if (StringUtils.isNotBlank(startDate) && StringUtils.isNotBlank(endDate)){
|
|
|
|
|
+ sql.append(" WHERE create_time >= '" + startDate + "'");
|
|
|
|
|
+ sql.append(" and create_time <= '" + endDate + "'");
|
|
|
|
|
+
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ if (StringUtils.isNotBlank(taskId)){
|
|
|
|
|
+ sql.append(" and task_id = '" + taskId + "'");
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ sql.append(" GROUP BY check_state ");
|
|
|
|
|
+
|
|
|
|
|
+ return sql.toString();
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+
|
|
|
|
|
+ public String checkInfoWarningCount(SmsCheckCustomerInfo smsCheckCustomerInfo) {
|
|
|
StringBuilder sql = new StringBuilder();
|
|
StringBuilder sql = new StringBuilder();
|
|
|
sql.append("SELECT COUNT(1) " +
|
|
sql.append("SELECT COUNT(1) " +
|
|
|
"FROM sms_check_customer_info scci " +
|
|
"FROM sms_check_customer_info scci " +
|
|
|
"LEFT JOIN sms_check_task sct ON sct.id = scci.task_id");
|
|
"LEFT JOIN sms_check_task sct ON sct.id = scci.task_id");
|
|
|
sql.append(" where NOW() > sct.task_end_time");
|
|
sql.append(" where NOW() > sct.task_end_time");
|
|
|
- if(StringUtils.isNotBlank(smsCheckCustomerInfo.getStaffNo())){
|
|
|
|
|
|
|
+ if (StringUtils.isNotBlank(smsCheckCustomerInfo.getStaffNo())) {
|
|
|
sql.append(" AND scci.staff_no = '" + smsCheckCustomerInfo.getStaffNo() + "'");
|
|
sql.append(" AND scci.staff_no = '" + smsCheckCustomerInfo.getStaffNo() + "'");
|
|
|
}
|
|
}
|
|
|
- if (smsCheckCustomerInfo.getCheckState() != null){
|
|
|
|
|
|
|
+ if (smsCheckCustomerInfo.getCheckState() != null) {
|
|
|
sql.append(" AND scci.check_state = " + smsCheckCustomerInfo.getCheckState());
|
|
sql.append(" AND scci.check_state = " + smsCheckCustomerInfo.getCheckState());
|
|
|
}
|
|
}
|
|
|
return sql.toString();
|
|
return sql.toString();
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public String checkInfoWarningCountTime(SmsCheckCustomerInfo smsCheckCustomerInfo){
|
|
|
|
|
|
|
+ public String checkInfoWarningCountTime(SmsCheckCustomerInfo smsCheckCustomerInfo) {
|
|
|
StringBuilder sql = new StringBuilder();
|
|
StringBuilder sql = new StringBuilder();
|
|
|
sql.append("SELECT COUNT(1) count,DATE_FORMAT( sct.task_end_time, '%Y%m%d' ) date");
|
|
sql.append("SELECT COUNT(1) count,DATE_FORMAT( sct.task_end_time, '%Y%m%d' ) date");
|
|
|
sql.append(" FROM sms_check_customer_info scci");
|
|
sql.append(" FROM sms_check_customer_info scci");
|
|
|
sql.append(" LEFT JOIN sms_check_task sct ON sct.id = scci.task_id");
|
|
sql.append(" LEFT JOIN sms_check_task sct ON sct.id = scci.task_id");
|
|
|
sql.append(" WHERE NOW() > sct.task_end_time");
|
|
sql.append(" WHERE NOW() > sct.task_end_time");
|
|
|
sql.append(" AND scci.check_state IN (0,1,4)");
|
|
sql.append(" AND scci.check_state IN (0,1,4)");
|
|
|
- if(StringUtils.isNotBlank(smsCheckCustomerInfo.getStaffNo())){
|
|
|
|
|
|
|
+ if (StringUtils.isNotBlank(smsCheckCustomerInfo.getStaffNo())) {
|
|
|
sql.append(" AND scci.staff_no = '" + smsCheckCustomerInfo.getStaffNo() + "'");
|
|
sql.append(" AND scci.staff_no = '" + smsCheckCustomerInfo.getStaffNo() + "'");
|
|
|
}
|
|
}
|
|
|
sql.append(" GROUP BY sct.task_end_time");
|
|
sql.append(" GROUP BY sct.task_end_time");
|
|
@@ -65,7 +92,7 @@ public interface SmsCheckCustomerInfoMapper extends BaseMapper<SmsCheckCustomerI
|
|
|
return sql.toString();
|
|
return sql.toString();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public String checkInfoWarningCountStaff(SmsCheckCustomerInfo smsCheckCustomerInfo){
|
|
|
|
|
|
|
+ public String checkInfoWarningCountStaff(SmsCheckCustomerInfo smsCheckCustomerInfo) {
|
|
|
StringBuilder sql = new StringBuilder();
|
|
StringBuilder sql = new StringBuilder();
|
|
|
sql.append(" SELECT COUNT(1) count,scci.staff_info staffInfo");
|
|
sql.append(" SELECT COUNT(1) count,scci.staff_info staffInfo");
|
|
|
sql.append(" FROM sms_check_customer_info scci");
|
|
sql.append(" FROM sms_check_customer_info scci");
|
|
@@ -76,7 +103,7 @@ public interface SmsCheckCustomerInfoMapper extends BaseMapper<SmsCheckCustomerI
|
|
|
return sql.toString();
|
|
return sql.toString();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private String checkInfoWarningCountStaff(Integer pageNo, Integer pageSize){
|
|
|
|
|
|
|
+ private String checkInfoWarningCountStaff(Integer pageNo, Integer pageSize) {
|
|
|
StringBuilder sql = new StringBuilder();
|
|
StringBuilder sql = new StringBuilder();
|
|
|
sql.append("SELECT sct.task_name taskName,sct.task_end_time taskEndTime," +
|
|
sql.append("SELECT sct.task_name taskName,sct.task_end_time taskEndTime," +
|
|
|
"scci.customer_no customerNo,scci.customer_name customerName," +
|
|
"scci.customer_no customerNo,scci.customer_name customerName," +
|
|
@@ -85,27 +112,27 @@ public interface SmsCheckCustomerInfoMapper extends BaseMapper<SmsCheckCustomerI
|
|
|
sql.append(" LEFT JOIN sms_check_task sct ON sct.id=scci.task_id ");
|
|
sql.append(" LEFT JOIN sms_check_task sct ON sct.id=scci.task_id ");
|
|
|
sql.append(" WHERE NOW()> sct.task_end_time");
|
|
sql.append(" WHERE NOW()> sct.task_end_time");
|
|
|
sql.append(" AND scci.check_state IN (0,1,4)");
|
|
sql.append(" AND scci.check_state IN (0,1,4)");
|
|
|
- sql.append(" LIMIT "+ (pageNo-1)*pageSize + ","+pageSize);
|
|
|
|
|
|
|
+ sql.append(" LIMIT " + (pageNo - 1) * pageSize + "," + pageSize);
|
|
|
return sql.toString();
|
|
return sql.toString();
|
|
|
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- public String selectCompanyList(SmsCheckCustomerInfo smsCheckCustomerInfo){
|
|
|
|
|
|
|
+ public String selectCompanyList(SmsCheckCustomerInfo smsCheckCustomerInfo) {
|
|
|
StringBuilder sql = new StringBuilder();
|
|
StringBuilder sql = new StringBuilder();
|
|
|
sql.append("SELECT any_value(id) id, any_value(customer_no) customer_no,`customer_name`,any_value(account_manager) account_manager,any_value(account_manager_phone) account_manager_phone,any_value(network_access_time) network_access_time FROM `sms_check_customer_info`");
|
|
sql.append("SELECT any_value(id) id, any_value(customer_no) customer_no,`customer_name`,any_value(account_manager) account_manager,any_value(account_manager_phone) account_manager_phone,any_value(network_access_time) network_access_time FROM `sms_check_customer_info`");
|
|
|
String customerNo = smsCheckCustomerInfo.getCustomerNo();
|
|
String customerNo = smsCheckCustomerInfo.getCustomerNo();
|
|
|
String customerName = smsCheckCustomerInfo.getCustomerName();
|
|
String customerName = smsCheckCustomerInfo.getCustomerName();
|
|
|
- if (!StringUtils.isEmpty(customerNo)){
|
|
|
|
|
|
|
+ if (!StringUtils.isEmpty(customerNo)) {
|
|
|
String customerNoNow = customerNo.replace("*", "%");
|
|
String customerNoNow = customerNo.replace("*", "%");
|
|
|
- sql.append(" WHERE `customer_no` like '"+customerNoNow+"'");
|
|
|
|
|
- if (!StringUtils.isEmpty(customerName)){
|
|
|
|
|
|
|
+ sql.append(" WHERE `customer_no` like '" + customerNoNow + "'");
|
|
|
|
|
+ if (!StringUtils.isEmpty(customerName)) {
|
|
|
String customerNameNow = customerName.replace("*", "%");
|
|
String customerNameNow = customerName.replace("*", "%");
|
|
|
- sql.append(" AND `customer_name` like '"+customerNameNow+"'");
|
|
|
|
|
|
|
+ sql.append(" AND `customer_name` like '" + customerNameNow + "'");
|
|
|
}
|
|
}
|
|
|
- }else{
|
|
|
|
|
- if (!StringUtils.isEmpty(customerName)){
|
|
|
|
|
|
|
+ } else {
|
|
|
|
|
+ if (!StringUtils.isEmpty(customerName)) {
|
|
|
String customerNameNow = customerName.replace("*", "%");
|
|
String customerNameNow = customerName.replace("*", "%");
|
|
|
- sql.append(" WHERE `customer_name` like '"+customerNameNow+"'");
|
|
|
|
|
|
|
+ sql.append(" WHERE `customer_name` like '" + customerNameNow + "'");
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
sql.append(" GROUP BY `customer_name`");
|
|
sql.append(" GROUP BY `customer_name`");
|