Merge remote-tracking branch 'origin/dev-mysql' into dev-mysql

src/main/java/com/uas/platform/b2c/common/account/model/UsageLog.java

@@ -190,6 +190,18 @@ public class UsageLog extends BufferedLogable implements Serializable {
 		this.ip = SystemSession.getUser().getIp();
 	}
 
+	public UsageLog(String title, String message, String detail, String code, Long key, Long enuu, Long useruu) {
+		this.enUU = enuu;
+		this.title = title;
+		this.message = message;
+		this.detail = detail;
+		this.code = code;
+		this.key = key;
+		this.time = new Date().getTime();
+		this.userUU = useruu;
+		this.ip = SystemSession.getUser().getIp();
+	}
+
 	public UsageLog(String title, String message, Long userUU, String ip, String code, Long key) {
 		this.enUU = 0L;
 		this.title = title;

src/main/java/com/uas/platform/b2c/common/account/v2/service/UserService.java

@@ -17,5 +17,5 @@ public interface UserService {
      *
      * @param uu
      */
-    void delete(Long uu);
+    void delete(Long uu, Long enuu);
 }

src/main/java/com/uas/platform/b2c/common/account/v2/service/impl/EnterpriseServiceImpl.java

@@ -47,9 +47,9 @@ public class EnterpriseServiceImpl implements EnterpriseService {
         enterprise.setUu(Long.valueOf(userSpace.getDialectUID()));
         enterpriseDao.save(enterprise);
         if(null != oldenterprise) {
-            logger.log("更新企业信息", enterprise.getUu()+"time: " + sdf.format(new Date()));
+            logger.log("更新企业信息", enterprise.getUu()+"time: " + sdf.format(new Date()), enterprise.getUu(), 0L);
         } else {
-            logger.log("新增企业信息", enterprise.getUu()+"time: " + sdf.format(new Date()));
+            logger.log("新增企业信息", enterprise.getUu()+"time: " + sdf.format(new Date()), enterprise.getUu(), 0L);
         }
     }
 
@@ -62,7 +62,7 @@ public class EnterpriseServiceImpl implements EnterpriseService {
                 if(!CollectionUtils.isEmpty(users)) {
                     enterprise.setEnAdminuu(users.get(0).getUserUU());
                     enterpriseDao.save(enterprise);
-                    logger.log("更换管理员", enterprise.getEnName()+"," +users.get(0).getUserName() + "time:" + sdf.format(new Date()));
+                    logger.log("更换管理员", enterprise.getEnName()+"," +users.get(0).getUserName() + "time:" + sdf.format(new Date()), enterprise.getUu(), enterprise.getEnAdminuu());
                 }
             }
         }

src/main/java/com/uas/platform/b2c/common/account/v2/service/impl/UserServiceImpl.java

@@ -5,7 +5,6 @@ import com.uas.platform.b2c.common.account.dao.EnterpriseDao;
 import com.uas.platform.b2c.common.account.dao.UserDao;
 import com.uas.platform.b2c.common.account.model.Enterprise;
 import com.uas.platform.b2c.common.account.v2.service.UserService;
-import com.uas.platform.b2c.core.support.SystemSession;
 import com.uas.platform.b2c.core.support.log.UsageBufferedLogger;
 import com.uas.platform.core.logging.BufferedLoggerManager;
 import com.uas.platform.core.model.Status;
@@ -48,32 +47,33 @@ public class UserServiceImpl implements UserService {
         List<com.uas.platform.b2c.common.account.model.User> oldUsers = userDao.findUserByUserUU(u.getUserUU());
         userDao.save(u);
         if(oldUsers.size() > 0) {
-            logger.log("更新用户信息", user.getDialectUID() + "time: " + sdf.format(new Date()));
+            logger.log("更新用户信息", user.getDialectUID() + "time: " + sdf.format(new Date()), enterprise.getUu(), u.getUserUU());
         } else {
             if(null != enterprise && null == enterprise.getEnAdminuu()) {
                 enterprise.setEnAdminuu(u.getUserUU());
                 enterpriseDao.save(enterprise);
-                logger.log("设置管理员", enterprise.getEnName() + "," + u.getUserName() + "time: " + sdf.format(new Date()));
+                logger.log("设置管理员", enterprise.getEnName() + "," + u.getUserName() + "time: " + sdf.format(new Date()), enterprise.getUu(), u.getUserUU());
             }
-            logger.log("新增用户信息", user.getDialectUID() + "time: " + sdf.format(new Date()));
+            logger.log("新增用户信息", user.getDialectUID() + "time: " + sdf.format(new Date()), enterprise.getUu(), u.getUserUU());
         }
     }
 
 
     @Override
-    public void delete(Long uu) {
+    public void delete(Long uu, Long enuu) {
         com.uas.platform.b2c.common.account.model.User user = userDao.findOne(uu);
-        if(null != user) {
-            if (user.getEnterprises().contains(SystemSession.getUser().getEnterprise())) {
-                user.removeEnterprise(SystemSession.getUser().getEnterprise());
+        Enterprise enterprise = enterpriseDao.findByUu(enuu);
+        if(null != user && null != enterprise) {
+            if (user.getEnterprises().contains(enterprise)) {
+                user.removeEnterprise(enterprise);
                 if (user.getEnterprises().size() != 0) {
                     user.setEnable((short) Status.DISABLED.value());
-                    logger.log("删除用户", "禁用" + user.getUserUU());
+                    logger.log("删除用户", "禁用" + user.getUserUU(), 0L, 0L);
                     userDao.save(user);
                 }
                 if (user.getEnterprises().size() == 0) {
                     userDao.delete(user);
-                    logger.log("删除用户", "删除" + user.getUserUU());
+                    logger.log("删除用户", "删除" + user.getUserUU(), 0L, 0L);
                 }
             }
         }

src/main/java/com/uas/platform/b2c/core/support/log/UsageBufferedLogger.java

@@ -31,6 +31,18 @@ public class UsageBufferedLogger extends BufferedLogger<UsageLog> {
 		log(new UsageLog(title, message, null, null, null));
 	}
 
+	/**
+	 * 未登录记录平台使用日志
+	 *
+	 * @param title
+	 *            消息标题
+	 * @param message
+	 *            消息
+	 */
+	public void log(String title, String message, Long enuu, Long useruu) {
+		log(new UsageLog(title, message, null, null, null, enuu, useruu));
+	}
+
 	/**
 	 * 记录平台密码找回日志
 	 * 

src/main/java/com/uas/platform/b2c/trade/order/dao/OrderDao.java

@@ -69,13 +69,14 @@ public interface OrderDao extends JpaSpecificationExecutor<Order>, JpaRepository
 	List<Order> findByOrderIds(@Param("orderids") List<String> orderids);
 
 	/**
-	 * 根据某个状态之后的订单
-	 *
-	 * @param status the status
+	 * 查询未评价的订单
 	 * @return  orders
 	 */
-	@Query(nativeQuery = true, value="selcet * from trade$order a where a.or_status >=:status ")
-	List<Order> findByAfterStatus(@Param("status") Integer status);
+	@Query(nativeQuery = true, value=" select o.* from trade$order o " +
+							     	 " left join b2c$rate$vendor v " +
+									 " on o.or_id = v.order_id where locate('405',o.or_statushistory)>0  and v.id is null;")
+	List<Order> findByNotRate();
+
 
 	/**
 	 * Gets count by buyeruu and status.

src/main/java/com/uas/platform/b2c/trade/order/dao/PurchaseDao.java

@@ -29,14 +29,15 @@ public interface PurchaseDao extends JpaSpecificationExecutor<Purchase>, JpaRepo
 	 */
 	List<Purchase> findByStatus(Integer status);
 
+
 	/**
-	 * 根据之后的状态查找采购单
-	 *
-	 * @param status the status
-	 * @return list
+	 * 查询未评价的订单
+	 * @return  orders
 	 */
-	@Query(nativeQuery = true, value = "select * from trade$purchase where pu_status >= :status")
-	List<Purchase> findByAfterStatus(@Param("status") Integer status);
+	@Query(nativeQuery = true, value=" select o.* from trade$purchase o " +
+			" left join b2c$rate$buyer v " +
+			" on o.or_id = v.order_id left join trade$order t on o.or_id = t.or_orderid where locate('405',t.or_statushistory)>0  and v.id is null;")
+	List<Purchase> findByNotRate();
 
 	/**
 	 * 根据状态和企业UU查询采购单

src/main/java/com/uas/platform/b2c/trade/order/service/OrderService.java

@@ -288,13 +288,10 @@ public interface OrderService {
 	List<Order> findByStatus(Integer status);
 
 	/**
-	 * 根据类别查找
-	 *
-	 * @param status the status
-	 * @return list list
-	 * @TODO 查找某个状态之后的订单
+	 * 查找买家未评价的订单
 	 */
-	List<Order> findByAfterStatus(Integer status);
+	List<Order> findByNotRateVendor();
+
 
 	/**
 	 * 通过批次号查询到对应商品

src/main/java/com/uas/platform/b2c/trade/order/service/PurchaseService.java

@@ -140,12 +140,9 @@ public interface PurchaseService {
 	List<Purchase> findByStatus(Integer status);
 
 	/**
-	 * 根据之后的状态查找采购单
-	 *
-	 * @param status the status
-	 * @return list
+	 * 查找买家未评价的订单
 	 */
-	List<Purchase> findByAfterStatus(Integer status);
+	List<Purchase> findByNotRateVendor();
 
 	/**
 	 * 平台管理员获取采购单

src/main/java/com/uas/platform/b2c/trade/order/service/impl/OrderServiceImpl.java

@@ -1533,8 +1533,8 @@ public class OrderServiceImpl implements OrderService {
     }
 
     @Override
-    public List<Order> findByAfterStatus(Integer status) {
-        return orderDao.findByAfterStatus(status);
+    public List<Order> findByNotRateVendor() {
+        return orderDao.findByNotRate();
     }
 
     @Override

src/main/java/com/uas/platform/b2c/trade/order/service/impl/PurchaseServiceImpl.java

@@ -664,8 +664,8 @@ public class PurchaseServiceImpl implements PurchaseService {
 	}
 
 	@Override
-	public List<Purchase> findByAfterStatus(Integer status) {
-		return purchaseDao.findByAfterStatus(status);
+	public List<Purchase> findByNotRateVendor() {
+		return purchaseDao.findByNotRate();
 	}
 
 	@Override

src/main/java/com/uas/platform/b2c/trade/rate/task/RateTask.java

@@ -102,7 +102,7 @@ public class RateTask {
             //先写在代码上，20个工作日自动好评
             automaticReceipt = 20;
 
-            List<Order> orderList = orderService.findByAfterStatus(Status.RECEIVED.value());
+            List<Order> orderList = orderService.findByNotRateVendor();
             String ids = "-";
             for (Order order : orderList) {
                 List<StatusHistory> statusHistories = FastjsonUtils.fromJsonArray(order.getStatushistory(), StatusHistory.class);
@@ -161,7 +161,7 @@ public class RateTask {
             }
 //          //先写在代码上，180个工作日自动追评价
             automaticReceipt = 180;
-            List<Order> orderList = orderService.findByAfterStatus(Status.RECEIVED.value());
+            List<Order> orderList = orderService.findByNotRateVendor();
             String ids = "-";
             for (Order order : orderList) {
                 List<StatusHistory> statusHistories = FastjsonUtils.fromJsonArray(order.getStatushistory(), StatusHistory.class);
@@ -204,7 +204,7 @@ public class RateTask {
     private void autoVendorRate(Integer automaticReceipt,boolean isFirst) {
         try {
             //采购单的自动初评
-            List<Purchase> purchasesList = purchaseService.findByAfterStatus(Status.TOBEPAID.value());
+            List<Purchase> purchasesList = purchaseService.findByNotRateVendor();
             String pids = "-";
             for (Purchase purchase : purchasesList) {
                 List<StatusHistory> statusHistories = FastjsonUtils.fromJsonArray(purchase.getStatushistory(), StatusHistory.class);