二版

src/main/java/common/controller/ContractController.java

@@ -53,14 +53,14 @@ public class ContractController {
     @ResponseBody
     public ResultModel findAll(@CurrentAccount User loginAccount, @PathVariable String platform,
                                @RequestParam String startDate, @RequestParam String endDate) {
-        return ResultModel.OK(service.findAll(startDate, endDate, platform));
+        return ResultModel.OK(service.findAll(loginAccount,startDate, endDate, platform));
     }
 
     @RequestMapping(value = "export", method = RequestMethod.GET,produces = MediaType.APPLICATION_OCTET_STREAM_VALUE)
     @ResponseBody
     public ResponseEntity<byte[]> export(@CurrentAccount User loginAccount, @PathVariable String platform, @RequestParam String startDate
                                 , @RequestParam String endDate, HttpServletRequest request, HttpServletResponse response) {
-        List<Contract> contractList = service.findAll(startDate, endDate, platform);
+        List<Contract> contractList = service.findAll(loginAccount, startDate, endDate, platform);
         Map<String, String> map = new HashMap<>();
         map.put("wait", "未执行");
         map.put("executing", "执行中");
@@ -162,6 +162,12 @@ public class ContractController {
         return ResultModel.OK(service.findSetmeal());
     }
 
+    @RequestMapping(value = "find/increment", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel findIncrement(@CurrentAccount User loginAccount) {
+        return ResultModel.OK(service.findIncrement());
+    }
+
     @RequestMapping(value = "find/rebat", method = RequestMethod.GET)
     @ResponseBody
     public ResultModel rebat(@CurrentAccount User loginAccount, @RequestParam String product,
@@ -245,5 +251,13 @@ public class ContractController {
         return ResultModel.OK(service.findPayAll(startDate, endDate, platform));
     }
 
+    @RequestMapping(value = "build", method = RequestMethod.POST)
+    @ResponseBody
+    public ResultModel build(@RequestBody Contract contract, HttpServletRequest request) {
+
+//        ContractSendEmailThread email = new ContractSendEmailThread(contract);
+//        email.start();
+        return ResultModel.OK(service.build(contract));
+    }
 
 }

src/main/java/common/model/Account4Web.java

@@ -30,6 +30,26 @@ public class Account4Web {
     private Long bussinessMan;
     private String contractStatus;
     private Integer contractTime;
+    private String saleName;
+    private Boolean pressStatus;
+    private String saleEamil;
+    private Long sale;
+
+    public String getSaleEamil() {
+        return saleEamil;
+    }
+
+    public void setSaleEamil(String saleEamil) {
+        this.saleEamil = saleEamil;
+    }
+
+    public Long getSale() {
+        return sale;
+    }
+
+    public void setSale(Long sale) {
+        this.sale = sale;
+    }
 
     @Id
     @GeneratedValue
@@ -216,4 +236,20 @@ public class Account4Web {
     public void setContractTime(Integer contractTime) {
         this.contractTime = contractTime;
     }
+
+    public String getSaleName() {
+        return saleName;
+    }
+
+    public void setSaleName(String saleName) {
+        this.saleName = saleName;
+    }
+
+    public Boolean getPressStatus() {
+        return pressStatus;
+    }
+
+    public void setPressStatus(Boolean pressStatus) {
+        this.pressStatus = pressStatus;
+    }
 }

src/main/java/common/model/Contract.java

@@ -32,8 +32,10 @@ public class Contract {
     private Long payMoney;
     private Long invoice;
     private String createName;
-    private Long type;
+    private String type;
     private Long priceName;
+    private Boolean old;
+    private Long extraFlow;
 
     private Long modifyAccount;
     private Long createAccount;
@@ -227,14 +229,30 @@ public class Contract {
         this.invoice = invoice;
     }
 
-    public Long getType() {
+    public String getType() {
         return type;
     }
 
-    public void setType(Long type) {
+    public void setType(String type) {
         this.type = type;
     }
 
+    public Boolean getOld() {
+        return old;
+    }
+
+    public Long getExtraFlow() {
+        return extraFlow;
+    }
+
+    public void setExtraFlow(Long extraFlow) {
+        this.extraFlow = extraFlow;
+    }
+
+    public void setOld(Boolean old) {
+        this.old = old;
+    }
+
     @Transient
     public Long getPriceName() {
         return priceName;

src/main/java/common/model/ContractIncrement.java

+package common.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+
+/**
+ * Created by mxq on 2018/1/17.
+ */
+@Entity
+public class ContractIncrement {
+    private Long id;
+    private String packageName;
+    private String code;
+    private String type;
+
+    @Id
+    @GeneratedValue
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getPackageName() {
+        return packageName;
+    }
+
+    public void setPackageName(String packageName) {
+        this.packageName = packageName;
+    }
+
+    public String getCode() {
+        return code;
+    }
+
+    public void setCode(String code) {
+        this.code = code;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+}

src/main/java/common/model/IOAccount4Web.java

+package common.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import java.math.BigInteger;
+import java.util.Date;
+
+@Entity
+public class IOAccount4Web {
+    private Long id;
+    private Long accountId;
+    private String email;
+    private String company;
+    private Date createDate;
+    private String createDs;
+    private String status;
+    private String packageType;
+    private String pastDate;
+    private BigInteger track;
+    private BigInteger io;
+    private BigInteger trackLimit;
+    private BigInteger ioLimit;
+    private Integer backTime;
+    private String user;
+    private String tell;
+    private Long money;
+    private Boolean ioStatus;
+    private Boolean trackStatus;
+    private Boolean remStatus;
+    private Long bussinessMan;
+    private String contractStatus;
+    private Integer contractTime;
+    private String saleName;
+    private Boolean pressStatus;
+    private String saleEamil;
+    private Long sale;
+
+    public String getSaleEamil() {
+        return saleEamil;
+    }
+
+    public void setSaleEamil(String saleEamil) {
+        this.saleEamil = saleEamil;
+    }
+
+    public Long getSale() {
+        return sale;
+    }
+
+    public void setSale(Long sale) {
+        this.sale = sale;
+    }
+    @Id
+    @GeneratedValue
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getAccountId() {
+        return accountId;
+    }
+
+    public void setAccountId(Long accountId) {
+        this.accountId = accountId;
+    }
+
+    public String getEmail() {
+        return email;
+    }
+
+    public void setEmail(String email) {
+        this.email = email;
+    }
+
+    public String getCompany() {
+        return company;
+    }
+
+    public void setCompany(String company) {
+        this.company = company;
+    }
+
+    public Date getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Date createDate) {
+        this.createDate = createDate;
+    }
+
+    public String getStatus() {
+        return status;
+    }
+
+    public void setStatus(String status) {
+        this.status = status;
+    }
+
+    public String getPackageType() {
+        return packageType;
+    }
+
+    public void setPackageType(String packageType) {
+        this.packageType = packageType;
+    }
+
+    public String getPastDate() {
+        return pastDate;
+    }
+
+    public void setPastDate(String pastDate) {
+        this.pastDate = pastDate;
+    }
+
+    public BigInteger getTrack() {
+        return track;
+    }
+
+    public void setTrack(BigInteger track) {
+        this.track = track;
+    }
+
+    public BigInteger getIo() {
+        return io;
+    }
+
+    public void setIo(BigInteger io) {
+        this.io = io;
+    }
+
+    public BigInteger getTrackLimit() {
+        return trackLimit;
+    }
+
+    public void setTrackLimit(BigInteger trackLimit) {
+        this.trackLimit = trackLimit;
+    }
+
+    public BigInteger getIoLimit() {
+        return ioLimit;
+    }
+
+    public void setIoLimit(BigInteger ioLimit) {
+        this.ioLimit = ioLimit;
+    }
+
+    public Integer getBackTime() {
+        return backTime;
+    }
+
+    public void setBackTime(Integer backTime) {
+        this.backTime = backTime;
+    }
+
+    public String getUser() {
+        return user;
+    }
+
+    public void setUser(String user) {
+        this.user = user;
+    }
+
+    public String getTell() {
+        return tell;
+    }
+
+    public void setTell(String tell) {
+        this.tell = tell;
+    }
+
+    public Long getMoney() {
+        return money;
+    }
+
+    public void setMoney(Long money) {
+        this.money = money;
+    }
+
+    public Boolean getIoStatus() {
+        return ioStatus;
+    }
+
+    public void setIoStatus(Boolean ioStatus) {
+        this.ioStatus = ioStatus;
+    }
+
+    public Boolean getTrackStatus() {
+        return trackStatus;
+    }
+
+    public void setTrackStatus(Boolean trackStatus) {
+        this.trackStatus = trackStatus;
+    }
+
+    public Boolean getRemStatus() {
+        return remStatus;
+    }
+
+    public void setRemStatus(Boolean remStatus) {
+        this.remStatus = remStatus;
+    }
+
+    public Long getBussinessMan() {
+        return bussinessMan;
+    }
+
+    public void setBussinessMan(Long bussinessMan) {
+        this.bussinessMan = bussinessMan;
+    }
+
+    public String getCreateDs() {
+        return createDs;
+    }
+
+    public void setCreateDs(String createDs) {
+        this.createDs = createDs;
+    }
+
+    public String getContractStatus() {
+        return contractStatus;
+    }
+
+    public void setContractStatus(String contractStatus) {
+        this.contractStatus = contractStatus;
+    }
+
+    public Integer getContractTime() {
+        return contractTime;
+    }
+
+    public void setContractTime(Integer contractTime) {
+        this.contractTime = contractTime;
+    }
+
+    public String getSaleName() {
+        return saleName;
+    }
+
+    public void setSaleName(String saleName) {
+        this.saleName = saleName;
+    }
+
+    public Boolean getPressStatus() {
+        return pressStatus;
+    }
+
+    public void setPressStatus(Boolean pressStatus) {
+        this.pressStatus = pressStatus;
+    }
+}

src/main/java/common/repository/ContractIncrementRepository.java

+package common.repository;
+
+import common.model.ContractBody;
+import common.model.ContractIncrement;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.transaction.annotation.Transactional;
+
+@Transactional
+public interface ContractIncrementRepository extends JpaRepository<ContractIncrement, Long> {
+
+    @Query(value = "SELECT * from contract_increment where code = ?1", nativeQuery = true)
+    ContractIncrement findByCode(String code);
+}

src/main/java/common/repository/ContractRepository.java

@@ -18,17 +18,26 @@ public interface ContractRepository extends JpaRepository<Contract, Long> {
     @Query(value="select count(*) from contract where email = ?1 and platform = ?2",nativeQuery=true)
     BigInteger countNumByEmail(String email, String platfrom);
 
-    @Query(value="select * from contract where ds >= ?1 and ds <= ?2 and platform = ?3 order by ds desc",nativeQuery=true)
+    @Query(value="select * from contract where start_date >= ?1 and start_date <= ?2 and platform = ?3 order by ds desc",nativeQuery=true)
     List<Contract> findByDs(String startDate, String endDate, String platfrom);
 
+    @Query(value="select * from contract where start_date >= ?1 and start_date <= ?2 and platform = ?3 and sale in ?4 order by ds desc",nativeQuery=true)
+    List<Contract> findByDsAndRoile(String startDate, String endDate, String platfrom, List<Long> userids);
+
     @Query(value="select * from contract where contract_code = ?1",nativeQuery=true)
     Contract findByCode(String contract_code);
 
     @Query(value="SELECT * from contract where platform = ?1",nativeQuery=true)
     List<Contract> findByPlatform(String platform);
 
-    @Query(value="SELECT * from contract where platform = ?1 and email = ?2",nativeQuery=true)
-    List<Contract> findByPlatformAndEmail(String platform, String email);
+    @Query(value="SELECT * from contract where platform = ?1 and email = ?2 and type = ?3",nativeQuery=true)
+    List<Contract> findByPlatformAndEmail(String platform, String email, String type);
+
+    @Query(value="SELECT * from contract where platform = ?1 and email = ?2 and type = ?3 order by ds desc limit 1",nativeQuery=true)
+    Contract findByPlatformAndEmailLimit1(String platform, String email,String type);
+
+    @Query(value="SELECT * from contract where platform = ?1 and email = ?2 and (status = 'wait' or status = 'executing') and type = 'main' order by ds desc limit 1",nativeQuery=true)
+    Contract findByPlatformAndEmailLimitVaild(String platform, String email);
 
     @Query(value="SELECT * from contract where start_date = ?1  and status <> 'cancel'",nativeQuery=true)
     List<Contract> findByStartDate(String startDate);

src/main/java/common/repository/IOAccount4WebRepository.java

+package common.repository;
+
+import common.model.Account4Web;
+import common.model.IOAccount4Web;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+@Transactional
+public interface IOAccount4WebRepository extends JpaRepository<IOAccount4Web, Long> {
+
+    @Query(value = "SELECT * from account4web where email in ?1", nativeQuery = true)
+    List<IOAccount4Web> findByEmails(List<String> emails);
+
+    @Query(value = "SELECT * from account4web where past_date = ?1", nativeQuery = true)
+    List<IOAccount4Web> findByPast(String yesterday);
+
+    @Query(value = "SELECT * from account4web where status = '已过期' or status = '流量用尽'", nativeQuery = true)
+    List<IOAccount4Web> findPast();
+
+    @Query(value = "SELECT * from account4web where email = ?1", nativeQuery = true)
+    IOAccount4Web findByEmail(String email);
+
+}

src/main/java/common/repository/PressMoneyRepository.java

@@ -14,4 +14,9 @@ public interface PressMoneyRepository extends JpaRepository<PressMoney, Long> {
     @Query(value = "SELECT * from press_money where platform = ?1 and press_status is true", nativeQuery = true)
     List<PressMoney> findAllPress(String platform);
 
+    @Query(value = "SELECT * from press_money where platform = ?1 and account_id = ?2 and press_status is true", nativeQuery = true)
+    PressMoney findOnePress(String platform, Long account);
+
+    @Query(value = "SELECT * from press_money where platform = ?1 and account_id = ?2", nativeQuery = true)
+    PressMoney findOne(String platform, Long account);
 }

src/main/java/common/repository/UserRepository.java

@@ -36,6 +36,9 @@ public interface UserRepository extends JpaRepository<User, Long> {
 	@Query(value="SELECT * from `user` where role = ?1 ORDER BY role_type",nativeQuery=true)
 	List<User> findAllUserByRole(Long role);
 
+	@Query(value="SELECT * from `user` where role in ?1 ORDER BY role_type",nativeQuery=true)
+	List<User> findAllUserByRoles(List<Long> roles);
+
 	@Query(value="SELECT * from `user` where del_flag is not true and parent = ?1",nativeQuery=true)
 	List<User> findAllByParent(Long id);
 

src/main/java/common/service/ContractService.java

@@ -17,7 +17,9 @@ public interface ContractService {
 
     String getContractCode(String code);
 
-    List<PackageType> findSetmeal();
+    List findSetmeal();
+    //增值服务
+    List<ContractIncrement> findIncrement();
 
     Double getRebat(String product, Integer level, Long money);
 
@@ -27,7 +29,7 @@ public interface ContractService {
 
     Contract update(User loginUser, Contract resource);
 
-    List<Contract> findAll(String startDate, String endDate, String platfrom);
+    List<Contract> findAll(User loginAccount,String startDate, String endDate, String platfrom);
 
     Contract findOne(String code);
 
@@ -42,4 +44,6 @@ public interface ContractService {
     Contract updatePay(User loginUser, ContractMoney resource);
 
     List<ContractMoney> findPayAll(String startDate, String endDate, String platform);
-}
+
+    Contract build(Contract contract);
+}
\ No newline at end of file

src/main/java/common/service/impl/UserServiceImpl.java

@@ -15,6 +15,7 @@ import office.service.BussinussManService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import tkio.service.SalesManService;
+import userio.service.IOSalesManService;
 import util.CharacterUtils;
 import util.CipherUtil;
 import util.MailUtils;
@@ -39,6 +40,8 @@ public class UserServiceImpl implements UserService {
     BussinussManService bussinussManService;
     @Autowired
     private SalesManService salesManService;
+    @Autowired
+    private IOSalesManService ioSalesManService;
 
     @Override
     public Boolean validEmail(String email) {
@@ -65,9 +68,11 @@ public class UserServiceImpl implements UserService {
         if(resource.getRole().equals(RoleEnum.SOUTH_BUSSINUSS.getKey())){
             bussinussManService.create(login.getEmail(), save.getEmail(), save.getName(),"华北");
             salesManService.create(login.getEmail(), save.getEmail(), save.getName());
+            ioSalesManService.create(login.getEmail(), save.getEmail(), save.getName());
         } else if(resource.getRole().equals(RoleEnum.NORTH_BUSSINUSS.getKey())){
             bussinussManService.create(login.getEmail(), save.getEmail(), save.getName(),"华南");
             salesManService.create(login.getEmail(), save.getEmail(), save.getName());
+            ioSalesManService.create(login.getEmail(), save.getEmail(), save.getName());
         }
 
 

src/main/java/dic/ContractStatusEnum.java

+package dic;
+
+/**
+ * Created by mxq on 18/4/12.
+ * desc:合同状态
+ */
+public enum ContractStatusEnum {
+
+    WAIT("wait","未执行"),
+    EXECUTING("executing", "执行中"),
+    CANCEL("cancel", "作废"),
+    END("end", "已结束");
+
+    private String key;
+    private String value;
+
+    ContractStatusEnum(String key, String value) {
+        this.key = key;
+        this.value = value;
+    }
+
+    public String getKey() {
+        return key;
+    }
+
+    public String getValue() {
+        return value;
+    }
+
+}

src/main/java/dic/RoleEnum.java

@@ -10,6 +10,7 @@ public enum RoleEnum {
     NORTH_BUSSINUSS(2L,"北区商务"),
     SOUTH_BUSSINUSS(3L,"南区商务");
 
+
     private Long key;
     private String value;
 

src/main/java/security/interceptor/AuthorizationInterceptor.java

@@ -50,7 +50,8 @@ public class AuthorizationInterceptor extends HandlerInterceptorAdapter {
         if (request.getRequestURL().indexOf("login/login") != -1
                 || request.getRequestURL().indexOf("update/pwd") != -1
                 || request.getRequestURL().indexOf("user/forget") != -1
-                || request.getRequestURL().indexOf("user/code") != -1){
+                || request.getRequestURL().indexOf("user/code") != -1
+                || request.getRequestURL().indexOf("contract/build") != -1){
             return true;
         }
         //从header中得到token

src/main/java/tkio/controller/TkioAccountController.java

@@ -70,7 +70,8 @@ public class TkioAccountController {
     public ResultModel forbidenPress(@CurrentAccount User loginAccount, @RequestBody PressMoney resource, HttpServletRequest request) {
         UserLogThread userlog = new UserLogThread(loginAccount.getEmail(), loginAccount.getName(), OperateObjectTypeEnum.CUSTOMER.getKey(), resource.getEmail(), "关闭异常状态跟进", request,loginAccount.getRole());
         userlog.start();
-        return ResultModel.OK(tkioAccountService.forbidenPress(loginAccount, resource));
+        tkioAccountService.forbidenPress(loginAccount, resource);
+        return ResultModel.OK();
     }
 
     //开启缴费提醒

src/main/java/tkio/model/Crowd.java

+package tkio.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Transient;
+import java.util.Date;
+import java.util.HashMap;
+
+@Entity
+public class Crowd {
+    private Long id;
+    private Boolean hobbyLabel;
+    private Boolean payLabel;
+    private Boolean weights;
+    private String dataRange;
+    private String iosAppkey;
+    private String androidAppKey;
+    private Long rootAccount;
+    private Integer status;
+    private Date createTime;
+    private String iosAppName;
+    private String androidAppName;
+    private Integer payment;
+    private Long applyAccount;
+
+    private HashMap<String, Object> map;
+    private Long deviceid_cnt;
+    private Double price;
+    private Double total;
+
+    private String contractCode;
+
+    @Id
+    @GeneratedValue
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Boolean getHobbyLabel() {
+        return hobbyLabel;
+    }
+
+    public void setHobbyLabel(Boolean hobbyLabel) {
+        this.hobbyLabel = hobbyLabel;
+    }
+
+    public Boolean getPayLabel() {
+        return payLabel;
+    }
+
+    public void setPayLabel(Boolean payLabel) {
+        this.payLabel = payLabel;
+    }
+
+    public Boolean getWeights() {
+        return weights;
+    }
+
+    public void setWeights(Boolean weights) {
+        this.weights = weights;
+    }
+
+    public String getDataRange() {
+        return dataRange;
+    }
+
+    public void setDataRange(String dataRange) {
+        this.dataRange = dataRange;
+    }
+
+    public String getIosAppkey() {
+        return iosAppkey;
+    }
+
+    public void setIosAppkey(String iosAppkey) {
+        this.iosAppkey = iosAppkey;
+    }
+
+    public String getAndroidAppKey() {
+        return androidAppKey;
+    }
+
+    public void setAndroidAppKey(String androidAppKey) {
+        this.androidAppKey = androidAppKey;
+    }
+
+    public Long getRootAccount() {
+        return rootAccount;
+    }
+
+    public void setRootAccount(Long rootAccount) {
+        this.rootAccount = rootAccount;
+    }
+
+    public Long getApplyAccount() {
+        return applyAccount;
+    }
+
+    public void setApplyAccount(Long applyAccount) {
+        this.applyAccount = applyAccount;
+    }
+
+    public Integer getStatus() {
+        return status;
+    }
+
+    public void setStatus(Integer status) {
+        this.status = status;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public String getIosAppName() {
+        return iosAppName;
+    }
+
+    public void setIosAppName(String iosAppName) {
+        this.iosAppName = iosAppName;
+    }
+
+    public String getAndroidAppName() {
+        return androidAppName;
+    }
+
+    public void setAndroidAppName(String androidAppName) {
+        this.androidAppName = androidAppName;
+    }
+
+    public Integer getPayment() {
+        return payment;
+    }
+
+    public void setPayment(Integer payment) {
+        this.payment = payment;
+    }
+
+    @Transient
+    public HashMap<String, Object> getMap() {
+        return map;
+    }
+
+    public void setMap(HashMap<String, Object> map) {
+        this.map = map;
+    }
+
+    @Transient
+    public Long getDeviceid_cnt() {
+        return deviceid_cnt;
+    }
+
+    public void setDeviceid_cnt(Long deviceid_cnt) {
+        this.deviceid_cnt = deviceid_cnt;
+    }
+
+    @Transient
+    public Double getPrice() {
+        return price;
+    }
+
+    public void setPrice(Double price) {
+        this.price = price;
+    }
+
+    @Transient
+    public Double getTotal() {
+        return total;
+    }
+
+    public void setTotal(Double total) {
+        this.total = total;
+    }
+
+    public String getContractCode() {
+        return contractCode;
+    }
+
+    public void setContractCode(String contractCode) {
+        this.contractCode = contractCode;
+    }
+}

src/main/java/tkio/model/IncrementFlow.java

+package tkio.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Transient;
+import java.util.Date;
+import java.util.List;
+
+@Entity
+public class IncrementFlow {
+
+    private Long id;
+    private Long account;
+    private String contractCode;
+    private Long flow;
+    private String startDate;
+    private String endDate;
+
+
+    @Id
+    @GeneratedValue
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getAccount() {
+        return account;
+    }
+
+    public void setAccount(Long account) {
+        this.account = account;
+    }
+
+    public Long getFlow() {
+        return flow;
+    }
+
+    public void setFlow(Long flow) {
+        this.flow = flow;
+    }
+
+    public String getStartDate() {
+        return startDate;
+    }
+
+    public void setStartDate(String startDate) {
+        this.startDate = startDate;
+    }
+
+    public String getEndDate() {
+        return endDate;
+    }
+
+    public void setEndDate(String endDate) {
+        this.endDate = endDate;
+    }
+
+    public String getContractCode() {
+        return contractCode;
+    }
+
+    public void setContractCode(String contractCode) {
+        this.contractCode = contractCode;
+    }
+}

src/main/java/tkio/model/PackageType.java

@@ -3,6 +3,7 @@ package tkio.model;
 import javax.persistence.Entity;
 import javax.persistence.GeneratedValue;
 import javax.persistence.Id;
+import javax.persistence.Transient;
 import java.math.BigDecimal;
 import java.math.BigInteger;
 
@@ -77,6 +78,18 @@ public class PackageType {
     private Boolean platformServiceSupport; //7*24小时客户服务
     private Boolean platformCustomDataAnalysis; //专属数据分析师
 
+
+    private String type;
+
+    @Transient
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
     @Id
     @GeneratedValue
     public Long getId() {

src/main/java/tkio/repository/AccountRepository.java

@@ -22,6 +22,9 @@ public interface AccountRepository extends JpaRepository<Account, Long> {
     @Query(value = "SELECT * from account where is_super_user is true and `status` = 1 and past_date < ?1", nativeQuery = true)
     List<Account> findRootParentsPast(String today);
 
+    @Query(value = "SELECT * from account where is_super_user is true and `status` = 0", nativeQuery = true)
+    List<Account> findRootParentsForbiden();
+
     @Query(value = "SELECT * from account where is_super_user is true and  bussinessman in ?1", nativeQuery = true)
     List<Account> findBussnissMan(List<Integer> bussinussIds);
 

src/main/java/tkio/repository/CrowdRepository.java

+package tkio.repository;
+
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import tkio.model.App;
+import tkio.model.Crowd;
+
+import java.math.BigInteger;
+import java.util.List;
+
+public interface CrowdRepository extends JpaRepository<Crowd, Long> {
+
+	@Query(value = "select * from crowd where contract_code = ?1", nativeQuery = true)
+	Crowd findOne(String code);
+}

src/main/java/tkio/repository/IncrementFlowRepository.java

+package tkio.repository;
+
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import tkio.model.App;
+import tkio.model.IncrementFlow;
+
+import java.math.BigInteger;
+import java.util.List;
+
+public interface IncrementFlowRepository extends JpaRepository<IncrementFlow, Long> {
+
+	@Query(value = "select count(flow) from increment_flow where account = ?1 and end_date > ?2", nativeQuery = true)
+	BigInteger listByRootAccount(Long account, String ds);
+
+	@Query(value = "select * from increment_flow where contract_code = ?1", nativeQuery = true)
+	IncrementFlow findOne(String code);
+
+	@Query(value = "select appkey from app where account  in ?1", nativeQuery = true)
+	List<String> findAppkeys(List<Long> accountId);
+}

src/main/java/tkio/service/TkioAccountService.java

@@ -21,7 +21,7 @@ public interface TkioAccountService {
     Reminder enable(User user, Reminder resource);
 
     //催款提醒关闭
-    PressMoney forbidenPress(User user, PressMoney resource);
+    void forbidenPress(User user, PressMoney resource);
 
     //催款提醒开启
     PressMoney enablePress(User user, PressMoney resource);
@@ -47,4 +47,6 @@ public interface TkioAccountService {
     List<Contract> findContract(String email);
 
     List<ContractChange> findContractChange(String email, String startDate, String endDate);
+
+    void contractPay(User loginUser, ContractMoney resource);
 }

src/main/java/tkio/service/impl/AccountFlowRestrictServiceImpl.java

@@ -38,6 +38,9 @@ public class AccountFlowRestrictServiceImpl implements AccountFlowRestrictServic
 
     @Autowired
     private SalesManLeaderRepository salesManLeaderRepository;
+    
+    @Autowired
+    private IncrementFlowRepository incrementFlowRepository;
 
     @Override
     public AccountRestrict4Web findRestrictByAccount(Long accountId) {
@@ -127,11 +130,18 @@ public class AccountFlowRestrictServiceImpl implements AccountFlowRestrictServic
         }
         double ioRemainPercent = thisMonthRemainingFlow.doubleValue() / thisMonthAvailableTotalFlow.doubleValue();
         //String ioRemainPercent1 = decimalFormat.format(ioRemainPercent);
+
+        BigInteger num = incrementFlowRepository.listByRootAccount(accountId, DateUtil.getBeforeDays(0));
+        if(null == num){
+            num = new BigInteger("0");
+        }
+        num.add(packageType.getTrackFlow());
+
         accountRestrict4Web.setPastDate(pastDate);
         accountRestrict4Web.setPackageName(packageType.getPackageName());
         accountRestrict4Web.setOriginalName(packageType.getOriginalName());
         accountRestrict4Web.setIOLimit(packageType.getIoFlow());
-        accountRestrict4Web.setTrackLimit(packageType.getTrackFlow());
+        accountRestrict4Web.setTrackLimit(num);
         accountRestrict4Web.setThisMonthIOFlow(thisMonthEventNum);
         accountRestrict4Web.setTrackTotalFlow(clickNum);
         accountRestrict4Web.setAccountId(rootParent);

src/main/java/tkio/service/impl/TkioAccountServiceImpl.java

@@ -4,6 +4,7 @@ import com.amazonaws.services.dynamodbv2.xspec.B;
 import common.model.*;
 import common.repository.*;
 import common.service.UserService;
+import dic.ContractTypeEnum;
 import dic.RoleEnum;
 import dic.RoleTypeEnum;
 import org.apache.commons.collections.map.AbstractMapDecorator;
@@ -15,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.StringUtils;
 import tkio.model.Account;
+import tkio.model.Crowd;
 import tkio.model.PackageType;
 import tkio.model.SalesManLeader;
 import tkio.repository.*;
@@ -74,6 +76,8 @@ public class TkioAccountServiceImpl implements TkioAccountService {
     ReminderLevelRepository reminderLevelRepository;
     @Autowired
     PressMoneyRepository pressMoneyRepository;
+    @Autowired
+    CrowdRepository crowdRepository;
 
     @Override
     public List<Account4Web> findAll(User user) {
@@ -124,6 +128,16 @@ public class TkioAccountServiceImpl implements TkioAccountService {
             }
         }
 
+        List<SalesManLeader> roles = salesManLeaderRepository.findAll();
+        Map<Long, String> busMap = new HashMap<>();
+        for(SalesManLeader u : roles){
+            busMap.put((long)u.getId(),u.getName());
+        }
+        List<User> users = userRepository.findAll();
+        Map<String, Long> saleMap = new HashMap<>();
+        for(User u : users){
+            saleMap.put(u.getEmail(),u.getId());
+        }
 
         List<Reminder> reminderList = reminderRepository.findAllDistinct("tkio");
         Map<Long, Boolean> reMap = new HashMap<>();
@@ -133,6 +147,13 @@ public class TkioAccountServiceImpl implements TkioAccountService {
             }
         }
 
+        List<PressMoney> allPress = pressMoneyRepository.findAllPress("tkio");
+        Map<Long, Boolean> pressMap = new HashMap<>();
+        if(ValidateUtil.isValid(allPress)){
+            for(PressMoney re : allPress){
+                pressMap.put(re.getAccountId(), re.getPressStatus());
+            }
+        }
 
         if(ValidateUtil.isValid(account4WebList)){
             Map<String, Integer> backTimeMap = getBackTime();
@@ -146,7 +167,7 @@ public class TkioAccountServiceImpl implements TkioAccountService {
                 if(payMap.containsKey(aw.getEmail())){
                     List<Contract> contractList = payMap.get(aw.getEmail());
                     aw.setMoney(contractList.get(contractList.size() - 1 ).getPayMoney());
-                    aw.setContractStatus(contractList.get(contractList.size() - 1 ).getStatus());
+                    aw.setContractStatus(contractRepository.findByPlatformAndEmailLimit1("tkio", aw.getEmail(), ContractTypeEnum.MAIN.getKey()).getStatus());
                     aw.setContractTime(contractList.size());
                 } else{
                     aw.setContractTime(0);
@@ -158,6 +179,22 @@ public class TkioAccountServiceImpl implements TkioAccountService {
                 } else{
                     aw.setRemStatus(true);
                 }
+
+                if(pressMap.containsKey(aw.getAccountId())){
+                    aw.setPressStatus(true);
+                    aw.setContractStatus("stop");
+                } else{
+                    aw.setRemStatus(false);
+                }
+
+                if(busMap.containsKey(aw.getBussinessMan())){
+                    aw.setSaleName(busMap.get(aw.getBussinessMan()));
+                }else{
+                    aw.setSaleName("");
+                }
+                if(saleMap.containsKey(aw.getSaleEamil())){
+                    aw.setSale(saleMap.get(aw.getSaleEamil()));
+                }
                 result.add(aw);
             }
         }
@@ -182,7 +219,7 @@ public class TkioAccountServiceImpl implements TkioAccountService {
         } else{
             aw.setBackTime(0);
         }
-        List<Contract> contractList = contractRepository.findByPlatformAndEmail("tkio", email);
+        List<Contract> contractList = contractRepository.findByPlatformAndEmail("tkio", email,ContractTypeEnum.MAIN.getKey());
         if(ValidateUtil.isValid(contractList)){
             aw.setMoney(contractList.get(contractList.size() - 1 ).getPayMoney());
             aw.setContractStatus(contractList.get(contractList.size() - 1 ).getStatus());
@@ -226,23 +263,58 @@ public class TkioAccountServiceImpl implements TkioAccountService {
     }
 
     @Override
-    public PressMoney forbidenPress(User user, PressMoney resource) {
-        resource.setUser(user.getId());
-        resource.setModifyTime(new Date());
-        resource.setPlatform("tkio");
-        resource.setPressStatus(false);
-        resource.setDs(DateUtil.getBeforeDays(0));
-        return pressMoneyRepository.save(resource);
+    public void forbidenPress(User user, PressMoney resource) {
+        PressMoney pressMoney = pressMoneyRepository.findOne("tkio", resource.getAccountId());
+        pressMoney.setUser(user.getId());
+        pressMoney.setModifyTime(new Date());
+        pressMoney.setPressStatus(false);
+        pressMoney.setDs(DateUtil.getBeforeDays(0));
+
+        Contract contract = contractRepository.findByPlatformAndEmailLimit1("tkio", resource.getEmail(), ContractTypeEnum.MAIN.getKey());
+        if(null != contract){
+            contract.setStatus("executing");
+            contractRepository.save(contract);
+        }
+
+
+        Account account = accountRepository.findByEmail(resource.getEmail());
+        account.setStatus(1);
+        accountRepository.save(account);
+
+        pressMoneyRepository.save(pressMoney);
+        return ;
     }
 
     @Override
     public PressMoney enablePress(User user, PressMoney resource) {
-        resource.setUser(user.getId());
-        resource.setModifyTime(new Date());
-        resource.setPlatform("tkio");
-        resource.setPressStatus(true);
-        resource.setDs(DateUtil.getBeforeDays(0));
-        return pressMoneyRepository.save(resource);
+        PressMoney pressMoney = pressMoneyRepository.findOne("tkio", resource.getAccountId());
+        if(null == pressMoney){
+            resource.setUser(user.getId());
+            resource.setModifyTime(new Date());
+            resource.setPlatform("tkio");
+            resource.setPressStatus(true);
+            resource.setDs(DateUtil.getBeforeDays(0));
+            pressMoneyRepository.save(resource);
+        }else{
+            pressMoney.setUser(user.getId());
+            pressMoney.setModifyTime(new Date());
+            pressMoney.setPressStatus(true);
+            pressMoney.setDs(DateUtil.getBeforeDays(0));
+            pressMoneyRepository.save(pressMoney);
+        }
+
+
+        Contract contract = contractRepository.findByPlatformAndEmailLimit1("tkio", resource.getEmail(), ContractTypeEnum.MAIN.getKey());
+       if(null != contract){
+           contract.setStatus("stop");
+           contractRepository.save(contract);
+       }
+
+
+        Account account = accountRepository.findByEmail(resource.getEmail());
+        account.setStatus(0);
+        accountRepository.save(account);
+        return null;
     }
 
     @Override
@@ -260,6 +332,8 @@ public class TkioAccountServiceImpl implements TkioAccountService {
         re.setDs(DateUtil.getBeforeDays(0));
         reminderRepository.save(re);
 
+
+
         return paymentRepository.save(resource);
     }
 
@@ -415,7 +489,7 @@ public class TkioAccountServiceImpl implements TkioAccountService {
                 typeMap.put(s.getId(), s.getPackageName());
             }
         }
-        List<Contract> contractList = contractRepository.findByPlatformAndEmail("tkio", email);
+        List<Contract> contractList = contractRepository.findByPlatformAndEmail("tkio", email,ContractTypeEnum.MAIN.getKey());
         if(ValidateUtil.isValid(contractList)){
             for(Contract cm : contractList){
                 cm.setSaleName(userMap.containsKey(cm.getSale()) ? userMap.get(cm.getSale()) : "");
@@ -454,6 +528,34 @@ public class TkioAccountServiceImpl implements TkioAccountService {
         return result;
     }
 
+    @Override
+    public void contractPay(User loginUser, ContractMoney resource) {
+        Contract contract = contractRepository.findByCode(resource.getContractCode());
+        //增值服务
+        if(contract.getType().equals(ContractTypeEnum.INCREMENT.getKey())){
+            if(contract.getPriceLevel().longValue() == 1l){
+                Crowd crowd = crowdRepository.findOne(resource.getContractCode());
+                if(null != crowd){
+                    crowd.setPayment(1);
+                    crowdRepository.save(crowd);
+                }
+            }
+        }else{//基础套餐
+            Account account = accountRepository.findByEmail(resource.getEmail());
+            PressMoney press = pressMoneyRepository.findOnePress("tkio",account.getId());
+            //如果被催款了，恢复状态
+            if(press != null){
+                account.setStatus(1);
+                accountRepository.save(account);
+
+                contract.setStatus("executing");
+                contractRepository.save(contract);
+            }
+
+        }
+
+    }
+
 
     public Map<String, Integer> getBackTime(){
         Map<String, Integer> map = new HashMap<>();

src/main/java/tkio/task/AccountTask.java

@@ -46,7 +46,11 @@ public class AccountTask {
 
     public void task(){
         logger.info("tkio task start :" + System.currentTimeMillis());
-
+        List<SalesManLeader> SalesManLeader = salesManLeaderRepository.findAll();
+        Map<Long, String> saleMap = new HashMap<>();
+        for(SalesManLeader pt : SalesManLeader){
+            saleMap.put((long)pt.getId(), pt.getEmail());
+        }
         List<PackageType> packageTypeList = packageTypeRepository.findAll();
         Map<Long, String> map = new HashMap<>();
         for(PackageType pt : packageTypeList){
@@ -69,7 +73,9 @@ public class AccountTask {
                 account4Web.setUser(ac.getName());
                 account4Web.setTell(ac.getPhone());
                 account4Web.setBussinessMan(ac.getBussinessman());
-
+                if(saleMap.containsKey(ac.getBussinessman())){
+                    account4Web.setSaleEamil(saleMap.get(ac.getBussinessman()));
+                }
                 try{
                     AccountRestrict4Web restrict4Web = accountFlowRestrictService.findRestrictByAccount(ac.getId());
                     account4Web.setStatus(null == restrict4Web.getIOFlowNotified() ? "已激活" : (restrict4Web.getIOFlowNotified() ? "已激活" : "流量用尽"));
@@ -138,6 +144,33 @@ public class AccountTask {
                 account4Web.setUser(ac.getName());
                 account4Web.setTell(ac.getPhone());
                 account4Web.setBussinessMan(ac.getBussinessman());
+                if(saleMap.containsKey(ac.getBussinessman())){
+                    account4Web.setSaleEamil(saleMap.get(ac.getBussinessman()));
+                }
+                list.add(account4Web);
+            }
+        }
+
+        //禁用账号
+        List<Account> accountList = accountRepository.findRootParentsForbiden();
+        if(ValidateUtil.isValid(accountList)){
+            for(Account ac : accountList){
+                Account4Web account4Web = new Account4Web();
+                account4Web.setAccountId(ac.getId());
+                account4Web.setEmail(ac.getEmail());
+                account4Web.setCompany(ac.getCompany());
+                account4Web.setCreateDate(ac.getPubDate());
+                account4Web.setStatus("已禁用");
+                account4Web.setPackageType(map.get(ac.getPricelevel()));
+                account4Web.setPastDate(ac.getPastDate());
+                account4Web.setIoStatus(false);
+                account4Web.setTrackStatus(false);
+                account4Web.setUser(ac.getName());
+                account4Web.setTell(ac.getPhone());
+                account4Web.setBussinessMan(ac.getBussinessman());
+                if(saleMap.containsKey(ac.getBussinessman())){
+                    account4Web.setSaleEamil(saleMap.get(ac.getBussinessman()));
+                }
                 list.add(account4Web);
             }
         }

src/main/java/track/service/impl/TrackAccountServiceImpl.java

@@ -2,6 +2,7 @@ package track.service.impl;
 
 import common.model.*;
 import common.repository.*;
+import dic.ContractTypeEnum;
 import dic.RoleEnum;
 import dic.RoleTypeEnum;
 import org.apache.commons.collections4.list.TreeList;
@@ -126,7 +127,7 @@ public class TrackAccountServiceImpl implements TrackAccountService{
         } else{
             aw.setBackTime(0);
         }
-        List<Contract> contractList = contractRepository.findByPlatformAndEmail("track", email);
+        List<Contract> contractList = contractRepository.findByPlatformAndEmail("track", email, ContractTypeEnum.MAIN.getKey());
         if(ValidateUtil.isValid(contractList)){
             aw.setMoney(contractList.get(contractList.size() - 1 ).getPayMoney());
             aw.setContractStatus(contractList.get(contractList.size() - 1 ).getStatus());
@@ -306,7 +307,7 @@ public class TrackAccountServiceImpl implements TrackAccountService{
                 typeMap.put(s.getId(), s.getPackageName());
             }
         }
-        List<Contract> contractList = contractRepository.findByPlatformAndEmail("track", email);
+        List<Contract> contractList = contractRepository.findByPlatformAndEmail("track", email,ContractTypeEnum.MAIN.getKey());
         if(ValidateUtil.isValid(contractList)){
             for(Contract cm : contractList){
                 cm.setSaleName(userMap.containsKey(cm.getSale()) ? userMap.get(cm.getSale()) : "");

src/main/java/userio/controller/IoAccountController.java

+package userio.controller;
+
+
+import common.model.*;
+import dic.OperateObjectTypeEnum;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.*;
+import security.annotation.CurrentAccount;
+import userio.service.IOAccountService;
+import util.ResultModel;
+import util.ResultStatus;
+import util.UserLogThread;
+
+import javax.servlet.http.HttpServletRequest;
+
+/**
+ * Created by mxq on 2017/12/21.
+ */
+@Controller
+@RequestMapping("io/marketing/accountmng")
+public class IoAccountController {
+
+    @Autowired
+    IOAccountService tkioAccountService;
+
+    //客户列表
+    @RequestMapping(value = "/findAll", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel find(@CurrentAccount User loginAccount) {
+        return ResultModel.OK(tkioAccountService.findAll(loginAccount));
+    }
+
+    @RequestMapping(value = "/findone", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel findOne(@CurrentAccount User loginAccount, @RequestParam String email) {
+        IOAccount4Web account4Web = tkioAccountService.findOne(email);
+        if(null == account4Web){
+            return ResultModel.ERROR(ResultStatus.USER_EMPTY);
+        }
+        return ResultModel.OK(account4Web);
+    }
+    @RequestMapping(value = "/find/reminderlevel", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel findReminderlevel() {
+        return ResultModel.OK(tkioAccountService.findReminderlevel());
+    }
+
+    //关闭到期提醒
+    @RequestMapping(value = "/forbiden", method = RequestMethod.PUT)
+    @ResponseBody
+    public ResultModel forbiden(@CurrentAccount User loginAccount, @RequestBody Reminder resource, HttpServletRequest request) {
+        UserLogThread userlog = new UserLogThread(loginAccount.getEmail(), loginAccount.getName(), OperateObjectTypeEnum.CUSTOMER.getKey(), resource.getEmail(), "关闭异常状态跟进", request,loginAccount.getRole());
+        userlog.start();
+        return ResultModel.OK(tkioAccountService.forbiden(loginAccount, resource));
+    }
+
+    //开启到期提醒
+    @RequestMapping(value = "/enable", method = RequestMethod.PUT)
+    @ResponseBody
+    public ResultModel enable(@CurrentAccount User loginAccount, @RequestBody Reminder resource, HttpServletRequest request) {
+        UserLogThread userlog = new UserLogThread(loginAccount.getEmail(), loginAccount.getName(), OperateObjectTypeEnum.CUSTOMER.getKey(), resource.getEmail(), "开启异常状态跟进", request,loginAccount.getRole());
+        userlog.start();
+        return ResultModel.OK(tkioAccountService.enable(loginAccount, resource));
+    }
+
+    //关闭缴费提醒
+    @RequestMapping(value = "/forbidenpress", method = RequestMethod.PUT)
+    @ResponseBody
+    public ResultModel forbidenPress(@CurrentAccount User loginAccount, @RequestBody PressMoney resource, HttpServletRequest request) {
+        UserLogThread userlog = new UserLogThread(loginAccount.getEmail(), loginAccount.getName(), OperateObjectTypeEnum.CUSTOMER.getKey(), resource.getEmail(), "关闭异常状态跟进", request,loginAccount.getRole());
+        userlog.start();
+        return ResultModel.OK(tkioAccountService.forbidenPress(loginAccount, resource));
+    }
+
+    //开启缴费提醒
+    @RequestMapping(value = "/enablepress", method = RequestMethod.PUT)
+    @ResponseBody
+    public ResultModel enablePress(@CurrentAccount User loginAccount, @RequestBody PressMoney resource, HttpServletRequest request) {
+        UserLogThread userlog = new UserLogThread(loginAccount.getEmail(), loginAccount.getName(), OperateObjectTypeEnum.CUSTOMER.getKey(), resource.getEmail(), "开启异常状态跟进", request,loginAccount.getRole());
+        userlog.start();
+        return ResultModel.OK(tkioAccountService.enablePress(loginAccount, resource));
+    }
+
+    //缴费
+    @RequestMapping(value = "/pay", method = RequestMethod.PUT)
+    @ResponseBody
+    public ResultModel pay(@CurrentAccount User loginAccount, @RequestBody Payment resource, HttpServletRequest request) {
+        UserLogThread userlog = new UserLogThread(loginAccount.getEmail(), loginAccount.getName(), OperateObjectTypeEnum.CUSTOMER.getKey(), resource.getEmail(), "缴费", request,loginAccount.getRole());
+        userlog.start();
+        return ResultModel.OK(tkioAccountService.pay(loginAccount, resource));
+    }
+
+    //回访
+    @RequestMapping(value = "/visit", method = RequestMethod.PUT)
+    @ResponseBody
+    public ResultModel visit(@CurrentAccount User loginAccount, @RequestBody BackVisit resource, HttpServletRequest request) {
+        UserLogThread userlog = new UserLogThread(loginAccount.getEmail(), loginAccount.getName(), OperateObjectTypeEnum.CUSTOMER.getKey(), resource.getEmail(), "回访", request,loginAccount.getRole());
+        userlog.start();
+        return ResultModel.OK( tkioAccountService.visit(loginAccount, resource));
+    }
+    //功能使用查询
+    @RequestMapping(value = "/find/function/{accountId}", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel updateName(@CurrentAccount User loginAccount, @RequestParam String startDate,
+                                  @RequestParam String endDate,  @PathVariable Long accountId) {
+
+        return ResultModel.OK(tkioAccountService.findFunTimes(accountId,startDate,endDate));
+    }
+
+    //功能使用查询
+    @RequestMapping(value = "/find/pv/{accountId}", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel pv(@CurrentAccount User loginAccount, @RequestParam String startDate,
+                                  @RequestParam String endDate,  @PathVariable Long accountId) {
+
+        return ResultModel.OK(tkioAccountService.findPv(accountId,startDate,endDate));
+    }
+
+    //到期提醒查询
+    @RequestMapping(value = "/find/reminder/{accountId}", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel findRed(@CurrentAccount User loginAccount, @RequestParam String startDate,
+                          @RequestParam String endDate,  @PathVariable Long accountId) {
+
+        return ResultModel.OK(tkioAccountService.findRed(accountId,startDate,endDate));
+    }
+
+    //回访查询
+    @RequestMapping(value = "/find/visit/{accountId}", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel findVisit(@CurrentAccount User loginAccount, @RequestParam String startDate,
+                               @RequestParam String endDate,  @PathVariable Long accountId) {
+
+        return ResultModel.OK(tkioAccountService.findVisit(accountId,startDate,endDate));
+    }
+
+    //缴费查询
+    @RequestMapping(value = "/find/pay/{accountId}", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel findPay(@CurrentAccount User loginAccount, @RequestParam String startDate,
+                               @RequestParam String endDate,  @RequestParam String email,  @PathVariable Long accountId) {
+
+        return ResultModel.OK(tkioAccountService.findPay(email,startDate,endDate));
+    }
+
+    //套餐变更查询
+    @RequestMapping(value = "/find/contract/{accountId}", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel findChange(@CurrentAccount User loginAccount,  @RequestParam String email,  @PathVariable Long accountId) {
+
+        return ResultModel.OK(tkioAccountService.findContract(email));
+    }
+
+    //合同查询
+    @RequestMapping(value = "/find/change/{accountId}", method = RequestMethod.GET)
+    @ResponseBody
+    public ResultModel findContract(@CurrentAccount User loginAccount, @RequestParam String startDate,
+                                  @RequestParam String endDate,  @RequestParam String email,  @PathVariable Long accountId) {
+
+        return ResultModel.OK(tkioAccountService.findContractChange(email,startDate,endDate));
+    }
+}

src/main/java/userio/model/App.java

+package userio.model;
+
+import com.fasterxml.jackson.annotation.JsonIdentityInfo;
+import com.fasterxml.jackson.annotation.ObjectIdGenerators;
+
+import javax.persistence.*;
+import javax.validation.constraints.NotNull;
+import java.util.Date;
+import java.util.List;
+
+@JsonIdentityInfo(generator=ObjectIdGenerators.IntSequenceGenerator.class, property="@id")
+@Entity
+public class App {
+
+	private Long id;
+	@NotNull
+	private String name;
+	private String platform;
+	private String appGenre;
+	private String appGenreName;
+	private String gameGenre;
+	//private String gameCategory;
+	private String appkey;
+	private String url;
+	private Long account;
+	private boolean sync;
+	// private boolean isActive;
+	private Long origiApp;
+	private String bundleid;
+	private String token;
+	private String installtoken;
+	private boolean regedbutton;
+
+	private Date createTime = new Date();
+	private String createAccount;
+	private Date modifyTime = new Date();
+	private String modifyAccount;
+	private Boolean delFlag;
+
+    private Long installNum;
+    private Long registerNum;
+
+	private Boolean trackAndIoBothExhaust;
+    private Boolean mainAccountExpire;
+
+	private Boolean distributeTask;
+	private Date distributeTime;
+
+	private String tagType;
+
+
+	public App() {
+		super();
+	}
+
+	public App(String name, String platform, String appGenre, String gameGenre) {
+		this.name = name;
+		this.platform = platform;
+		this.appGenre = appGenre;
+		this.gameGenre = gameGenre;
+	}
+
+	public App(String name, String platform, String appGenre, String gameGenre,
+			   Long account) {
+		this.name = name;
+		this.platform = platform;
+		this.appGenre = appGenre;
+		this.gameGenre = gameGenre;
+		this.account = account;
+	}
+
+	// public boolean isActive() {
+	// return isActive;
+	// }
+	//
+	// public void setActive(boolean isActive) {
+	// this.isActive = isActive;
+	// }
+	public Long getAccount() {
+		return account;
+	}
+
+	public String getAppGenre() {
+		return appGenre;
+	}
+
+	@Transient
+	public String getAppGenreName() {
+		return appGenreName;
+	}
+
+	public void setAppGenreName(String appGenreName) {
+		this.appGenreName = appGenreName;
+	}
+
+	public String getAppkey() {
+		return appkey;
+	}
+
+	public String getGameGenre() {
+		return gameGenre;
+	}
+
+/*	@Transient
+	public String getGameCategory() {
+		return gameCategory;
+	}
+	public void setGameCategory(String gameCategory) {
+		this.gameCategory = gameCategory;
+	}*/
+
+	@Id
+	@GeneratedValue
+	public Long getId() {
+		return id;
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public String getPlatform() {
+		return platform;
+	}
+
+	public String getUrl() {
+		return url;
+	}
+
+	public boolean isSync() {
+		return sync;
+	}
+
+	public void setAccount(Long account) {
+		this.account = account;
+	}
+
+	public void setAppGenre(String appGenre) {
+		this.appGenre = appGenre;
+	}
+
+	public void setAppkey(String appkey) {
+		this.appkey = appkey;
+	}
+
+	public void setGameGenre(String gameGenre) {
+		this.gameGenre = gameGenre;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public void setPlatform(String platform) {
+		this.platform = platform;
+	}
+
+	public void setSync(boolean sync) {
+		this.sync = sync;
+	}
+
+	public void setUrl(String url) {
+		this.url = url;
+	}
+
+	public Long getOrigiApp() {
+		return origiApp;
+	}
+
+	public void setOrigiApp(Long origiApp) {
+		this.origiApp = origiApp;
+	}
+
+	public String getBundleid() {
+		return bundleid;
+	}
+
+	public void setBundleid(String bundleid) {
+		this.bundleid = bundleid;
+	}
+
+	public String getToken() {
+		return token;
+	}
+
+	public void setToken(String token) {
+		this.token = token;
+	}
+
+	public boolean isRegedbutton() {
+		return regedbutton;
+	}
+
+	public void setRegedbutton(boolean regedbutton) {
+		this.regedbutton = regedbutton;
+	}
+
+	public String getInstalltoken() {
+		return installtoken;
+	}
+
+	public void setInstalltoken(String installtoken) {
+		this.installtoken = installtoken;
+	}
+
+	public Date getCreateTime() {
+		return createTime;
+	}
+
+	public void setCreateTime(Date createTime) {
+		this.createTime = createTime;
+	}
+
+	public String getCreateAccount() {
+		return createAccount;
+	}
+
+	public void setCreateAccount(String createAccount) {
+		this.createAccount = createAccount;
+	}
+
+	public Date getModifyTime() {
+		return modifyTime;
+	}
+
+	public void setModifyTime(Date modifyTime) {
+		this.modifyTime = modifyTime;
+	}
+
+	public String getModifyAccount() {
+		return modifyAccount;
+	}
+
+	public void setModifyAccount(String modifyAccount) {
+		this.modifyAccount = modifyAccount;
+	}
+
+	public Boolean getDelFlag() {
+		return delFlag;
+	}
+
+	public void setDelFlag(Boolean delFlag) {
+		this.delFlag = delFlag;
+	}
+
+	@Transient
+	public Boolean getTrackAndIoBothExhaust() {
+		return trackAndIoBothExhaust;
+	}
+
+	public void setTrackAndIoBothExhaust(Boolean trackAndIoBothExhaust) {
+		this.trackAndIoBothExhaust = trackAndIoBothExhaust;
+	}
+
+	@Transient
+	public Boolean getMainAccountExpire() {
+		return mainAccountExpire;
+	}
+
+	public void setMainAccountExpire(Boolean mainAccountExpire) {
+		this.mainAccountExpire = mainAccountExpire;
+	}
+
+	@Transient
+    public Long getInstallNum() {
+        return installNum;
+    }
+
+    public void setInstallNum(Long installNum) {
+        this.installNum = installNum;
+    }
+
+    @Transient
+    public Long getRegisterNum() {
+        return registerNum;
+    }
+
+    public void setRegisterNum(Long registerNum) {
+        this.registerNum = registerNum;
+    }
+
+	public Boolean getDistributeTask() {
+		return distributeTask;
+	}
+
+	public void setDistributeTask(Boolean distributeTask) {
+		this.distributeTask = distributeTask;
+	}
+
+	public Date getDistributeTime() {
+		return distributeTime;
+	}
+
+	public void setDistributeTime(Date distributeTime) {
+		this.distributeTime = distributeTime;
+	}
+
+
+
+	public String getTagType() {
+		return tagType;
+	}
+
+	public void setTagType(String tagType) {
+		this.tagType = tagType;
+	}
+
+	@Override
+	public String toString() {
+		return "App [id=" + id + ", name=" + name + ", platform=" + platform
+				+ ", appGenre=" + appGenre + ", gameGenre=" + gameGenre
+				+ ", appkey=" + appkey + ", url=" + url + ", account="
+				+ account + ", sync=" + sync + ", origiApp=" + origiApp
+				+ ", bundleid=" + bundleid + ", token=" + token
+				+ ", installtoken=" + installtoken + ", regedbutton="
+				+ regedbutton + ", createTime=" + createTime
+				+ ", createAccount=" + createAccount + ", modifyTime="
+				+ modifyTime + ", modifyAccount=" + modifyAccount
+				+ ", delFlag=" + delFlag + "]";
+	}
+
+}

src/main/java/userio/model/Auth.java

+package userio.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Transient;
+import java.util.Date;
+import java.util.List;
+
+@Entity
+public class Auth {
+
+	private Long id;
+	private Long roleCategory;
+	private String controlAuth;
+	private Long app;
+	private Long account;
+	private boolean retentionAuth;
+	private boolean payAuth;
+    private Long createAccount;
+    private Date createTime;
+    private Date modifyTime = new Date();
+    private String modifyAccount;
+    private Boolean status;
+    private Boolean isNatureOpen;
+    private Boolean campaign;
+    private Boolean topAuth;
+
+
+	public Auth() {
+		super();
+	}
+
+	public Auth(Long id, Long roleCategory, String controlAuth,
+			Long app, Long account) {
+		super();
+		this.id = id;
+		this.roleCategory = roleCategory;
+		this.controlAuth = controlAuth;
+		this.app = app;
+		this.account = account;
+	}
+
+	@Id
+	@GeneratedValue
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+
+	public Long getRoleCategory() {
+		return roleCategory;
+	}
+
+	public void setRoleCategory(Long roleCategory) {
+		this.roleCategory = roleCategory;
+	}
+
+	public String getControlAuth() {
+		return controlAuth;
+	}
+
+	public void setControlAuth(String controlAuth) {
+		this.controlAuth = controlAuth;
+	}
+
+	public Long getApp() {
+		return app;
+	}
+
+	public void setApp(Long app) {
+		this.app = app;
+	}
+
+	public Long getAccount() {
+		return account;
+	}
+
+	public void setAccount(Long account) {
+		this.account = account;
+	}
+
+	public boolean isRetentionAuth() {
+		return retentionAuth;
+	}
+
+	public void setRetentionAuth(boolean retentionAuth) {
+		this.retentionAuth = retentionAuth;
+	}
+
+	public boolean isPayAuth() {
+		return payAuth;
+	}
+
+	public void setPayAuth(boolean payAuth) {
+		this.payAuth = payAuth;
+	}
+
+	public Date getModifyTime() {
+		return modifyTime;
+	}
+
+	public void setModifyTime(Date modifyTime) {
+		this.modifyTime = modifyTime;
+	}
+
+	public String getModifyAccount() {
+		return modifyAccount;
+	}
+
+	public void setModifyAccount(String modifyAccount) {
+		this.modifyAccount = modifyAccount;
+	}
+
+	public Boolean getStatus() {
+		return status;
+	}
+
+	public void setStatus(Boolean status) {
+		this.status = status;
+	}
+
+	public Boolean getIsNatureOpen() {
+		return isNatureOpen;
+	}
+
+	public void setIsNatureOpen(Boolean isNatureOpen) {
+		this.isNatureOpen = isNatureOpen;
+	}
+
+	public Boolean getCampaign() {
+		return campaign;
+	}
+
+	public void setCampaign(Boolean campaign) {
+		this.campaign = campaign;
+	}
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Long getCreateAccount() {
+        return createAccount;
+    }
+
+    public void setCreateAccount(Long createAccount) {
+        this.createAccount = createAccount;
+    }
+
+    public Boolean getTopAuth() {
+        return topAuth;
+    }
+
+    public void setTopAuth(Boolean topAuth) {
+        this.topAuth = topAuth;
+    }
+
+
+    @Override
+	public String toString() {
+		return "Auth [id=" + id + ", roleCategory=" + roleCategory
+				+ ", controlAuth=" + controlAuth + ", app=" + app
+				+ ", account=" + account + ", retentionAuth=" + retentionAuth
+				+ ", payAuth=" + payAuth + ", modifyTime=" + modifyTime
+				+ ", modifyAccount=" + modifyAccount + ", status=" + status
+				+ "]";
+	}
+	
+	
+}

src/main/java/userio/model/DataAuth.java

+package userio.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Transient;
+import java.util.Date;
+import java.util.List;
+
+@Entity
+public class DataAuth {
+
+	private Long id;
+	private Long account;
+	private Long app;
+	private Long campaign;
+	private String campaignCode;
+	private Long channel;
+    private Boolean allCampaign;
+    private Date modifyTime = new Date();
+    private String modifyAccount;
+    private Boolean delFlag;
+	private Boolean channelPermit;//子账号渠道权限是否放开
+    //Transient
+    private List<Long> campaignList;
+
+	public DataAuth() {
+		super();
+	}
+
+	public DataAuth(Long id, Long app, Long campaign, String campaignCode,
+                    Long channel, Boolean allCampaign, Boolean channelPermit) {
+		super();
+		this.id = id;
+		this.app = app;
+		this.campaign = campaign;
+		this.campaignCode = campaignCode;
+		this.channel = channel;
+        this.allCampaign = allCampaign;
+        this.channelPermit = channelPermit;
+	}
+
+	@Id
+	@GeneratedValue
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public Long getApp() {
+		return app;
+	}
+
+	public void setApp(Long app) {
+		this.app = app;
+	}
+
+	public Long getCampaign() {
+		return campaign;
+	}
+
+	public void setCampaign(Long campaign) {
+		this.campaign = campaign;
+	}
+
+	public String getCampaignCode() {
+		return campaignCode;
+	}
+
+	public void setCampaignCode(String campaignCode) {
+		this.campaignCode = campaignCode;
+	}
+
+	public Long getChannel() {
+		return channel;
+	}
+
+	public void setChannel(Long channel) {
+		this.channel = channel;
+	}
+
+	public Long getAccount() {
+		return account;
+	}
+
+	public void setAccount(Long account) {
+		this.account = account;
+	}
+
+	public Date getModifyTime() {
+		return modifyTime;
+	}
+
+	public void setModifyTime(Date modifyTime) {
+		this.modifyTime = modifyTime;
+	}
+
+	public String getModifyAccount() {
+		return modifyAccount;
+	}
+
+	public void setModifyAccount(String modifyAccount) {
+		this.modifyAccount = modifyAccount;
+	}
+
+    public Boolean getAllCampaign() {
+        return allCampaign;
+    }
+
+    public void setAllCampaign(Boolean allCampaign) {
+        this.allCampaign = allCampaign;
+    }
+
+    public Boolean getDelFlag() {
+        return delFlag;
+    }
+
+    public void setDelFlag(Boolean delFlag) {
+        this.delFlag = delFlag;
+    }
+
+	public Boolean getChannelPermit() {
+		return channelPermit;
+	}
+
+	public void setChannelPermit(Boolean channelPermit) {
+		this.channelPermit = channelPermit;
+	}
+
+	@Transient
+    public List<Long> getCampaignList() {
+        return campaignList;
+    }
+
+    public void setCampaignList(List<Long> campaignList) {
+        this.campaignList = campaignList;
+    }
+}

src/main/java/userio/model/RoleAuth.java

+package userio.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Transient;
+import java.util.Date;
+import java.util.List;
+
+@Entity
+public class RoleAuth {
+
+    private Long id;
+    private Long roleCategory;
+    private String auth;
+    private Boolean payAuth;
+    private Boolean retentionAuth;
+    private Boolean isNatureOpen;
+    private Boolean topAuth;
+    private String roleName;
+    private Long createAccount;
+    private Date createTime;
+    private Long modifyAccount;
+    private Date modifyTime;
+    private Boolean delFlag;
+
+    //@Transient
+    private List<RoleAuthDetail> roleAuthDetails;
+
+    @Id
+    @GeneratedValue
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public Long getRoleCategory() {
+        return roleCategory;
+    }
+
+    public void setRoleCategory(Long roleCategory) {
+        this.roleCategory = roleCategory;
+    }
+
+    public String getAuth() {
+        return auth;
+    }
+
+    public void setAuth(String auth) {
+        this.auth = auth;
+    }
+
+    public Boolean getPayAuth() {
+        return payAuth;
+    }
+
+    public void setPayAuth(Boolean payAuth) {
+        this.payAuth = payAuth;
+    }
+
+    public Boolean getRetentionAuth() {
+        return retentionAuth;
+    }
+
+    public void setRetentionAuth(Boolean retentionAuth) {
+        this.retentionAuth = retentionAuth;
+    }
+
+    public Boolean getIsNatureOpen() {
+        return isNatureOpen;
+    }
+
+    public void setIsNatureOpen(Boolean isNatureOpen) {
+        this.isNatureOpen = isNatureOpen;
+    }
+
+    public Boolean getTopAuth() {
+        return topAuth;
+    }
+
+    public void setTopAuth(Boolean topAuth) {
+        this.topAuth = topAuth;
+    }
+
+    public String getRoleName() {
+        return roleName;
+    }
+
+    public void setRoleName(String roleName) {
+        this.roleName = roleName;
+    }
+
+    public Long getCreateAccount() {
+        return createAccount;
+    }
+
+    public void setCreateAccount(Long createAccount) {
+        this.createAccount = createAccount;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+
+    public Long getModifyAccount() {
+        return modifyAccount;
+    }
+
+    public void setModifyAccount(Long modifyAccount) {
+        this.modifyAccount = modifyAccount;
+    }
+
+    public Date getModifyTime() {
+        return modifyTime;
+    }
+
+    public void setModifyTime(Date modifyTime) {
+        this.modifyTime = modifyTime;
+    }
+
+    public Boolean getDelFlag() {
+        return delFlag;
+    }
+
+    public void setDelFlag(Boolean delFlag) {
+        this.delFlag = delFlag;
+    }
+
+    @Transient
+    public List<RoleAuthDetail> getRoleAuthDetails() {
+        return roleAuthDetails;
+    }
+
+    public void setRoleAuthDetails(List<RoleAuthDetail> roleAuthDetails) {
+        this.roleAuthDetails = roleAuthDetails;
+    }
+
+    @Override
+    public String toString() {
+        return "RoleAuth [id=" + id + ", roleCategory=" + roleCategory
+                + ", auth=" + auth + "]";
+    }
+
+}

src/main/java/userio/model/RoleAuthDetail.java

+package userio.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+
+/**
+ * Created by sunhao on 17/6/6.
+ * description:角色权限的详情
+ */
+@Entity
+public class RoleAuthDetail {
+
+    private Long id;
+    private String auth;
+    private String authName;
+    private String parentAuth;
+    private int sort;
+    private Boolean view;
+    private Boolean edit;
+    private Long roleId;
+
+    public RoleAuthDetail() {}
+
+    public RoleAuthDetail(RoleAuthDetail roleAuthDetail) {
+        this.auth = roleAuthDetail.getAuth();
+        this.authName = roleAuthDetail.getAuthName();
+        this.parentAuth = roleAuthDetail.getParentAuth();
+        this.sort = roleAuthDetail.getSort();
+        this.view = roleAuthDetail.getView();
+        this.edit = roleAuthDetail.getEdit();
+        this.roleId = roleAuthDetail.getRoleId();
+    }
+
+    @Id
+    @GeneratedValue
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getAuth() {
+        return auth;
+    }
+
+    public void setAuth(String auth) {
+        this.auth = auth;
+    }
+
+    public String getAuthName() {
+        return authName;
+    }
+
+    public void setAuthName(String authName) {
+        this.authName = authName;
+    }
+
+    public String getParentAuth() {
+        return parentAuth;
+    }
+
+    public void setParentAuth(String parentAuth) {
+        this.parentAuth = parentAuth;
+    }
+
+    public int getSort() {
+        return sort;
+    }
+
+    public void setSort(int sort) {
+        this.sort = sort;
+    }
+
+    public Boolean getView() {
+        return view;
+    }
+
+    public void setView(Boolean view) {
+        this.view = view;
+    }
+
+    public Boolean getEdit() {
+        return edit;
+    }
+
+    public void setEdit(Boolean edit) {
+        this.edit = edit;
+    }
+
+    public Long getRoleId() {
+        return roleId;
+    }
+
+    public void setRoleId(Long roleId) {
+        this.roleId = roleId;
+    }
+}

src/main/java/userio/model/SalesManLeader.java

+package userio.model;
+
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+
+@Entity
+public class SalesManLeader {
+
+	private int id;
+	private String area;
+	private String email;
+	private String name;
+	private int leader;
+
+	@Id
+	@GeneratedValue
+	public int getId() {
+		return id;
+	}
+
+	public void setId(int id) {
+		this.id = id;
+	}
+
+	public String getArea() {
+		return area;
+	}
+
+	public void setArea(String area) {
+		this.area = area;
+	}
+
+	public String getEmail() {
+		return email;
+	}
+
+	public void setEmail(String email) {
+		this.email = email;
+	}
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public int getLeader() {
+		return leader;
+	}
+
+	public void setLeader(int leader) {
+		this.leader = leader;
+	}
+
+}

src/main/java/userio/repository/IOAccountRepository.java

+package userio.repository;
+
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.transaction.annotation.Transactional;
+import userio.model.Account;
+
+import java.math.BigInteger;
+import java.util.Date;
+import java.util.List;
+
+@Transactional
+public interface IOAccountRepository extends JpaRepository<Account, Long> {
+    @Query(value = "select root_parent from account where id=?1", nativeQuery = true)
+    BigInteger findRootParentByAccountId(Long accountId);
+
+    @Query(value = "SELECT * from account where is_super_user is true and `status` = 1 and past_date > ?1", nativeQuery = true)
+    List<Account> findRootParentsUnPast(String today);
+
+    @Query(value = "SELECT * from account where is_super_user is true and `status` = 1 and past_date < ?1", nativeQuery = true)
+    List<Account> findRootParentsPast(String today);
+
+    @Query(value = "SELECT * from account where is_super_user is true and `status` = 0", nativeQuery = true)
+    List<Account> findRootParentsForidin();
+
+    @Query(value = "SELECT * from account where is_super_user is true and  bussinessman in ?1", nativeQuery = true)
+    List<Account> findBussnissMan(List<Integer> bussinussIds);
+
+    @Query(value = "select * from account where root_parent = ?1", nativeQuery = true)
+    List<Account> findByRootParent(Long accountId);
+
+    @Query(value = "select count(*) from account where root_parent = ?1 and create_time > ?2 and create_time < ?3", nativeQuery = true)
+    BigInteger countByRootParent(Long accountId, String startDate, String endDate);
+
+    @Query(value = "select * from account where email = ?1", nativeQuery = true)
+    Account findByEmail(String email);
+}

src/main/java/userio/repository/IOAppRepository.java

+package userio.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import userio.model.App;
+
+import java.math.BigInteger;
+import java.util.List;
+
+public interface IOAppRepository extends JpaRepository<App, Long>
+{
+
+
+	@Query(value = "select * from app where account in (select id from account where parent = ?1 or id = ?1) and del_flag is not true", nativeQuery = true)
+	List<App> listAppByRootAccount(Long account);
+
+	@Query(value = "select count(*) from app where account  in ?1 and create_time >= ?2 and create_time <= ?3", nativeQuery = true)
+	BigInteger countByAccount(List<Long> accountId, String startDate, String endDate);
+
+	@Query(value = "select appkey from app where account  in ?1", nativeQuery = true)
+	List<String> findAppkeys(List<Long> accountId);
+
+}

src/main/java/userio/repository/IODataAuthRepository.java

+package userio.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.transaction.annotation.Transactional;
+import userio.model.DataAuth;
+
+import java.util.List;
+
+@Transactional
+public interface IODataAuthRepository extends JpaRepository<DataAuth, Long> {
+
+    @Query(value = "select * from data_auth where account in ?1", nativeQuery = true)
+    List<DataAuth> findDataAuthByAccount(List<Long> account);
+
+    @Query(value = "select * from data_auth where account = ?1", nativeQuery = true)
+    List<DataAuth> findDataAuthByAccount(Long account);
+
+    @Query(value = "select * from data_auth where account = ?1 and app=?2", nativeQuery = true)
+    List<DataAuth> findDataAuthByAccountAndApp(Long account, Long app);
+
+    @Query(value = "select * from data_auth where account = ?2 and app in (select app from auth where create_account in ?1 and account = ?2)", nativeQuery = true)
+    List<DataAuth> findDataAuthByCreateAccount(List<Long> createAccount, Long channelAccount);
+
+    @Transactional
+    @Modifying
+    @Query(value = "delete from data_auth where account = ?1", nativeQuery = true)
+    void deleteAuthByAccount(Long account);
+
+    @Query(value = "select * from data_auth where app = ?1 and channel =?2 and campaign =?3", nativeQuery = true)
+    List<DataAuth> listDataAuthByAppChnCam(Long app, Long channel, Long campain);
+
+    Iterable<DataAuth> findByApp(Long id);
+
+    @Query(value = "select account from data_auth where app = ?1 and channel =?2 and campaign =?3", nativeQuery = true)
+    List<Long> listAccountByAppChnCam(Long app, Long channel, Long campain);
+
+    @Query(value = "select * from data_auth where channel =?1", nativeQuery = true)
+    List<DataAuth> listDataAuthByChannel(Long channel);
+
+    @Query(value = "select * from data_auth where account = ?1 and app = ?2 and all_campaign = 1", nativeQuery = true)
+    List<DataAuth> listByAllCampaign(Long account, Long app);
+}

src/main/java/userio/repository/IOPackageTypeRepository.java

+package userio.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import userio.model.PackageType;
+
+public interface IOPackageTypeRepository extends JpaRepository<PackageType, Long> {
+    @Query(value = "select * from package_type where id=(select pricelevel from account  where id=?1)", nativeQuery = true)
+    PackageType findPackageTypeByRootParent(Long rootParent);
+
+    @Query(value = "select * from package_type where id=?1", nativeQuery = true)
+    PackageType findPackageTypeByID(Long ID);
+}

src/main/java/userio/repository/IORoleAuthDetailRepository.java

+package userio.repository;
+
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import userio.model.RoleAuthDetail;
+
+import java.util.List;
+
+/**
+ * Created by sunhao on 17/6/7.
+ * Desc:权限详情DAO
+ */
+public interface IORoleAuthDetailRepository extends JpaRepository<RoleAuthDetail,Long> {
+
+    @Query(value = "select * from role_auth_detail where role_id = ?1", nativeQuery = true)
+    List<RoleAuthDetail> findDetailByRole(Long roleId);
+
+    @Query(value = "select * from role_auth_detail where role_id = ?1 and (view is true or edit is true)", nativeQuery = true)
+    List<RoleAuthDetail> findValidDetailByRole(Long roleId);
+}

src/main/java/userio/repository/IORoleAuthRepository.java

+package userio.repository;
+
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.transaction.annotation.Transactional;
+import userio.model.RoleAuth;
+
+import java.math.BigInteger;
+import java.util.Date;
+import java.util.List;
+
+
+public interface IORoleAuthRepository extends JpaRepository<RoleAuth, Long> {
+
+	RoleAuth findByRoleCategory(Long id);
+
+    @Query(value = "select * from role_auth where id in ?1 ", nativeQuery = true)
+    List<RoleAuth> findCustomRoleList(List<Long> createAccounts);
+
+    @Query(value = "select * from role_auth where create_account in ?1 and del_flag is not true order by create_time desc ", nativeQuery = true)
+    List<RoleAuth> findAllCustomRoleList(List<Long> createAccounts);
+
+    @Query(value = "select count(*) from role_auth where create_account in ?1 and role_name = ?2 and del_flag is not true", nativeQuery = true)
+    BigInteger findByAccountAndName(List<Long> accountList, String roleName);
+
+    @Query(value = "select count(*) from role_auth where create_account in ?1 and role_category = 4 and del_flag is not true", nativeQuery = true)
+    BigInteger findCustomNumByAccount(List<Long> accountList);
+
+    @Transactional
+    @Modifying
+    @Query(value = "update role_auth set del_flag = true , modify_account = ?2, modify_time = ?3 where id = ?1 ", nativeQuery = true)
+    int deleteCustomRole(Long roleId, Long modifyAccount, Date modifyDate);
+}

src/main/java/userio/repository/IOSalesManLeaderRepository.java

+package userio.repository;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.transaction.annotation.Transactional;
+import userio.model.SalesManLeader;
+
+import java.util.List;
+
+@Transactional
+public interface IOSalesManLeaderRepository extends JpaRepository<SalesManLeader, Long> {
+    @Query(value = "select email from sales_man_leader where id=(select leader from sales_man_leader where id=?1)", nativeQuery = true)
+    String findLeaderByBussinessMan(Long bussinessMan);
+
+    @Query(value = "select * from sales_man_leader where leader = (select id from sales_man_leader where email = ?1)", nativeQuery = true)
+    List<SalesManLeader> findByEmail(String email);
+
+    @Query(value = "select * from sales_man_leader where email = ?1", nativeQuery = true)
+    SalesManLeader findOneByEmail(String email);
+
+    @Query(value = "select * from sales_man_leader where email in ?1", nativeQuery = true)
+    List<SalesManLeader> findAllByEmails(List<String> emails);
+}

src/main/java/userio/service/AccountIOService.java

+package userio.service;
+
+import common.model.Contract;
+import userio.model.Account;
+
+/**
+ * Created by mxq on 2018/1/23.
+ */
+public interface AccountIOService {
+
+    Account update(Contract contract);
+
+    Account forbiden(Contract contract);
+
+}

src/main/java/userio/service/IOAccountService.java

+package userio.service;
+
+import common.model.*;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Created by mxq on 2017/12/26.
+ */
+public interface IOAccountService {
+    List<IOAccount4Web> findAll(User user);
+
+    IOAccount4Web findOne(String email);
+
+    List<ReminderLevel> findReminderlevel();
+    //到期提醒关闭
+    Reminder forbiden(User user, Reminder resource);
+
+    //到期提醒开启
+    Reminder enable(User user, Reminder resource);
+
+    //催款提醒关闭
+    PressMoney forbidenPress(User user, PressMoney resource);
+
+    //催款提醒开启
+    PressMoney enablePress(User user, PressMoney resource);
+
+    //缴费
+    Payment pay(User user, Payment resource);
+
+    //回访
+    BackVisit visit(User user, BackVisit resource);
+
+    //查询功能使用情况
+    Map<String, Integer> findFunTimes(Long account, String startDate, String endDate);
+
+    //查询功能使用情况
+    List<Map<String, Object>>  findPv(Long account, String startDate, String endDate);
+
+    List<Reminder> findRed(Long account, String startDate, String endDate);
+
+    List<BackVisit> findVisit(Long account, String startDate, String endDate);
+
+    List<ContractMoney> findPay(String email, String startDate, String endDate);
+
+    List<Contract> findContract(String email);
+
+    List<ContractChange> findContractChange(String email, String startDate, String endDate);
+
+    void contractPay(User loginUser, ContractMoney resource);
+}

src/main/java/userio/service/IOSalesManService.java

+package userio.service;
+
+/**
+ * Created by mxq on 2018/1/2.
+ */
+public interface IOSalesManService {
+    void create(String loginEmail, String email, String name);
+}

src/main/java/userio/service/impl/AccountIOServiceImpl.java

+package userio.service.impl;
+
+import common.model.Contract;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import tkio.repository.AccountRepository;
+import tkio.service.AccountService;
+import userio.model.Account;
+import userio.repository.IOAccountRepository;
+import userio.service.AccountIOService;
+import util.DateUtil;
+import util.ValidateUtil;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * Created by mxq on 2018/1/23.
+ */
+@Service
+public class AccountIOServiceImpl implements AccountIOService {
+
+    @Autowired
+    IOAccountRepository accountRepository;
+    @Override
+    public Account update(Contract contract) {
+        Account account = accountRepository.findByEmail(contract.getEmail());
+        String today = DateUtil.getBeforeDays(0);
+        Date pubDate = DateUtil.getDate(contract.getStartDate());
+
+        account.setPastDate(contract.getEndDate());
+        account.setNewContract(true);
+        account.setPubDate(pubDate);
+        account.setModifyPricelevelTime(contract.getStartDate());
+        account.setModifyTime(new Date());
+        account.setModifyAccount(0l);
+        account.setPricelevel(contract.getPriceLevel());
+        if(!(contract.getEndDate().compareTo(today) < 0)){
+            account.setStatus(1);
+        }
+        Account save = accountRepository.save(account);
+
+        //修改子账号
+        List<Account> accountList = accountRepository.findByRootParent(account.getId());
+        if (ValidateUtil.isValid(accountList)){
+            List<Account> list = new ArrayList<>();
+            for(Account ac : accountList){
+                ac.setPastDate(contract.getEndDate());
+                ac.setPubDate(pubDate);
+                ac.setModifyPricelevelTime(contract.getStartDate());
+                ac.setPricelevel(contract.getPriceLevel());
+                list.add(ac);
+            }
+            accountRepository.save(list);
+        }
+        return save;
+    }
+
+    @Override
+    public Account forbiden(Contract contract) {
+        Account account = accountRepository.findByEmail(contract.getEmail());
+        account.setStatus(0);
+        return accountRepository.save(account);
+    }
+}

src/main/java/userio/service/impl/IOSaleManServiceImpl.java

+package userio.service.impl;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import userio.model.SalesManLeader;
+import userio.repository.IOSalesManLeaderRepository;
+import userio.service.IOSalesManService;
+
+/**
+ * Created by mxq on 2018/1/2.
+ */
+@Service
+public class IOSaleManServiceImpl implements IOSalesManService {
+    @Autowired
+    IOSalesManLeaderRepository salesManLeaderRepository;
+    @Override
+    public void create(String loginEmail, String email, String name) {
+        SalesManLeader salesManLeader = new SalesManLeader();
+        salesManLeader.setEmail(email);
+        salesManLeader.setName(name);
+
+        SalesManLeader manLeader = salesManLeaderRepository.findOneByEmail(loginEmail);
+        if(null != manLeader){
+            salesManLeader.setLeader(manLeader.getLeader());
+            salesManLeaderRepository.save(salesManLeader);
+        }else{
+            SalesManLeader save = salesManLeaderRepository.save(salesManLeader);
+            save.setLeader(save.getId());
+            salesManLeaderRepository.save(save);
+        }
+
+    }
+}

src/main/java/userio/task/IOAccountTask.java

+package userio.task;
+
+
+import common.model.IOAccount4Web;
+import common.repository.IOAccount4WebRepository;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import userio.model.Account;
+import userio.model.PackageType;
+import userio.model.SalesManLeader;
+import userio.repository.IOAccountRepository;
+import userio.repository.IOPackageTypeRepository;
+import userio.repository.IOSalesManLeaderRepository;
+import util.DateUtil;
+import util.ValidateUtil;
+
+import java.math.BigInteger;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Created by mxq on 2017/12/25.
+ */
+public class IOAccountTask {
+    private static Logger logger = LoggerFactory.getLogger(IOAccountTask.class);
+
+    @Autowired
+    IOAccountRepository accountRepository;
+
+    @Autowired
+    IOAccount4WebRepository account4WebRepository;
+
+    @Autowired
+    private IOPackageTypeRepository packageTypeRepository;
+
+    @Autowired
+    IOSalesManLeaderRepository salesManLeaderRepository;
+
+    public void task(){
+        logger.info("tkio task start :" + System.currentTimeMillis());
+
+
+        //清空前一天数据
+        account4WebRepository.deleteAll();
+        List<IOAccount4Web> list = new ArrayList<>();
+
+        //已过期的直接设置成过期
+        List<Account> pastAccountList = accountRepository.findRootParentsPast(DateUtil.getBeforeDays(0));
+        list.addAll(transform(pastAccountList, "已过期"));
+
+        //未过期
+        List<Account> unpastAccountList = accountRepository.findRootParentsUnPast(DateUtil.getBeforeDays(0));
+        list.addAll(transform(unpastAccountList, "已激活"));
+
+        List<Account> forbidenList = accountRepository.findRootParentsForidin();
+        list.addAll(transform(forbidenList, "已禁用"));
+
+        account4WebRepository.save(list);
+        logger.info("tkio task end :" + System.currentTimeMillis());
+    }
+
+    List<IOAccount4Web> transform(List<Account> accounts, String status){
+        List<SalesManLeader> SalesManLeader = salesManLeaderRepository.findAll();
+        Map<Long, String> saleMap = new HashMap<>();
+        for(SalesManLeader pt : SalesManLeader){
+            saleMap.put((long)pt.getId(), pt.getEmail());
+        }
+        List<PackageType> packageTypeList = packageTypeRepository.findAll();
+        Map<Long, String> map = new HashMap<>();
+        for(PackageType pt : packageTypeList){
+            map.put(pt.getId(), pt.getPackageName());
+        }
+
+        List<IOAccount4Web> list = new ArrayList<>();
+        if(ValidateUtil.isValid(accounts)){
+            for(Account ac : accounts){
+                IOAccount4Web account4Web = new IOAccount4Web();
+                account4Web.setStatus(status);
+
+                account4Web.setAccountId(ac.getId());
+                account4Web.setEmail(ac.getEmail());
+                account4Web.setCompany(ac.getCompany());
+                account4Web.setCreateDate(ac.getPubDate());
+                account4Web.setPackageType(map.get(ac.getPricelevel()));
+                account4Web.setPastDate(ac.getPastDate());
+                account4Web.setUser(ac.getName());
+                account4Web.setTell(ac.getPhone());
+                account4Web.setBussinessMan(ac.getBussinessman());
+                if(saleMap.containsKey(ac.getBussinessman())){
+                    account4Web.setSaleEamil(saleMap.get(ac.getBussinessman()));
+                }
+                list.add(account4Web);
+            }
+        }
+        return list;
+    }
+}

src/main/resources/rest-servlet.xml

@@ -10,6 +10,7 @@
 	<context:component-scan base-package="common.controller" />
 	<context:component-scan base-package="track.controller" />
 	<context:component-scan base-package="tkio.controller" />
+	<context:component-scan base-package="userio.controller" />
 
 	<mvc:annotation-driven>
 		<mvc:argument-resolvers>

src/main/resources/spring/applicationContext-schedule.xml

@@ -12,7 +12,7 @@
     <bean id="tkioAccountTask" class="tkio.task.AccountTask"></bean>
    <task:scheduled-tasks>
         <!--//定时同步短链数据(每5分钟执行一次)-->
-        <task:scheduled ref="tkioAccountTask" method="task" cron="0 20 0 * * ?"/>
+        <task:scheduled ref="tkioAccountTask" method="task" cron="0 10 10 * * ?"/>
     </task:scheduled-tasks>
 
     <bean id="tkioNoticeTask" class="tkio.task.NoticeTask"></bean>
@@ -45,5 +45,10 @@
         <task:scheduled ref="SyncAppDataTask" method="syncAppDeviceNum" cron="0 11 0 * * ?"/>
     </task:scheduled-tasks>
 
+    <bean id="ioAccountTask" class="userio.task.IOAccountTask"></bean>
+    <task:scheduled-tasks>
+        <!--//定时同步短链数据(每5分钟执行一次)-->
+        <task:scheduled ref="ioAccountTask" method="task" cron="0 10 10 * * ?"/>
+    </task:scheduled-tasks>
 
 </beans>