From 211c3306b36db4aa48100e977ec0ae25a7ff5404 Mon Sep 17 00:00:00 2001
From: wangchao <crystal_jupiter@163.com>
Date: Tue, 11 Aug 2020 17:57:51 +0800
Subject: [PATCH] =?UTF-8?q?=E5=91=A8=E3=80=81=E6=9C=88=E6=8E=92=E5=90=8D?=
 =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=8C=E7=94=A8=E6=88=B7=E7=A7=AF=E5=88=86?=
 =?UTF-8?q?=E6=97=A5=E7=BB=9F=E8=AE=A1=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/controller/TestController.java  | 13 +++--
 .../dao/UserPointStatisticalDailyDao.java     |  9 ++++
 .../UserPointStatisticalDailyService.java     |  2 +
 .../impl/UserPointActionLogServiceImpl.java   |  1 +
 .../UserPointStatisticalDailyServiceImpl.java |  9 +++-
 .../db/migration/V0.0.2__unixKey.sql          |  1 +
 .../mapper/UserPointStatisticalDailyDao.xml   | 52 ++++++++++++++++++-
 7 files changed, 82 insertions(+), 5 deletions(-)
 create mode 100644 epmet-module/epmet-point/epmet-point-server/src/main/resources/db/migration/V0.0.2__unixKey.sql

diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/TestController.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/TestController.java
index 3418b3a5f3..b3cbf19d45 100644
--- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/TestController.java
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/controller/TestController.java
@@ -4,12 +4,12 @@ import com.epmet.commons.tools.annotation.LoginUser;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.security.user.LoginUserUtil;
 import com.epmet.commons.tools.utils.Result;
+import com.epmet.entity.UserPointStatisticalDailyEntity;
+import com.epmet.service.UserPointStatisticalDailyService;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -27,6 +27,8 @@ public class TestController {
     private Logger logger = LogManager.getLogger(TestController.class);
     @Autowired
     private LoginUserUtil loginUserUtil;
+    @Autowired
+    private UserPointStatisticalDailyService userPointStatisticalDailyService;
     @GetMapping("test")
     public Result test(@LoginUser TokenDto tokenDto){
         Map map=new HashMap<>();
@@ -42,5 +44,10 @@ public class TestController {
         result.setData("success");
         return result;
     }
+    @PostMapping("testinsert")
+    public Result testInsert(@RequestBody UserPointStatisticalDailyEntity entity){
+        userPointStatisticalDailyService.test(entity);
+        return new Result();
+    }
 }
 
diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/UserPointStatisticalDailyDao.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/UserPointStatisticalDailyDao.java
index 1c3352a090..9f9783797d 100644
--- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/UserPointStatisticalDailyDao.java
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/dao/UserPointStatisticalDailyDao.java
@@ -53,4 +53,13 @@ public interface UserPointStatisticalDailyDao extends BaseDao<UserPointStatistic
      * @date 2020.07.27 16:20
     **/
     UserPointStatisticalDailyEntity selectIfExisted(@Param("userId") String userId,@Param("dateId") String dateId,@Param("actionFlag")String actionFlag);
+
+    /**
+     * @Description 新增或修改
+     * @param entity
+     * @return
+     * @author wangc
+     * @date 2020.08.11 17:40
+    **/
+    void insertOrUpdate(UserPointStatisticalDailyEntity entity);
 }
\ No newline at end of file
diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/UserPointStatisticalDailyService.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/UserPointStatisticalDailyService.java
index 8e3616e51f..9d3f2d3ecf 100644
--- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/UserPointStatisticalDailyService.java
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/UserPointStatisticalDailyService.java
@@ -112,4 +112,6 @@ public interface UserPointStatisticalDailyService extends BaseService<UserPointS
      * @date 2020.07.27 16:10
     **/
     void insertOrUpdate(UserPointStatisticalDailyEntity entity);
+
+    void test(UserPointStatisticalDailyEntity entity);
 }
\ No newline at end of file
diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java
index 52e451ba6e..6c93c2d3d3 100644
--- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointActionLogServiceImpl.java
@@ -189,6 +189,7 @@ public class UserPointActionLogServiceImpl extends BaseServiceImpl<UserPointActi
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void grantPointByEvent(String eventCode,BasePointEventMsg event) {
+        
         if(!StringUtils.equals(EventEnum.REGISTER_VOLUNTEER.getEventTag(),eventCode) && !StringUtils.equals(EventEnum.ACTIVE_INSERT_LIVE.getEventTag(),eventCode)){
             logger.error(String.format("无法识别事件类型与积分规则，消息体->【%s】", JSON.toJSON(event)));
             throw new RenException("无法识别事件类型与积分规则");
diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointStatisticalDailyServiceImpl.java b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointStatisticalDailyServiceImpl.java
index 51537b8fac..6be4ae538e 100644
--- a/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointStatisticalDailyServiceImpl.java
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/java/com/epmet/service/impl/UserPointStatisticalDailyServiceImpl.java
@@ -210,13 +210,20 @@ public class UserPointStatisticalDailyServiceImpl extends BaseServiceImpl<UserPo
      **/
     @Override
     public void insertOrUpdate(UserPointStatisticalDailyEntity entity) {
+        baseDao.insertOrUpdate(entity);
+        /*
         UserPointStatisticalDailyEntity existed = baseDao.selectIfExisted(entity.getUserId(),entity.getDateId(),entity.getActionFlag());
         if(null != existed && StringUtils.isNotBlank(existed.getId())){
             existed.setPointChange(null == existed.getPointChange() ? entity.getPointChange() : existed.getPointChange() + entity.getPointChange());
             updateById(existed);
         }else{
             insert(entity);
-        }
+        }*/
+    }
+
+    @Override
+    public void test(UserPointStatisticalDailyEntity entity) {
+        baseDao.insertOrUpdate(entity);
     }
 
 
diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/resources/db/migration/V0.0.2__unixKey.sql b/epmet-module/epmet-point/epmet-point-server/src/main/resources/db/migration/V0.0.2__unixKey.sql
new file mode 100644
index 0000000000..444eb8ad2e
--- /dev/null
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/resources/db/migration/V0.0.2__unixKey.sql
@@ -0,0 +1 @@
+ALTER TABLE user_point_statistical_daily ADD UNIQUE USER_DATE_ACTION(USER_ID,DATE_ID,ACTION_FLAG,CUSTOMER_ID);
\ No newline at end of file
diff --git a/epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/UserPointStatisticalDailyDao.xml b/epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/UserPointStatisticalDailyDao.xml
index 70cdfc8d4f..45470e58d9 100644
--- a/epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/UserPointStatisticalDailyDao.xml
+++ b/epmet-module/epmet-point/epmet-point-server/src/main/resources/mapper/UserPointStatisticalDailyDao.xml
@@ -54,7 +54,7 @@
         AND ( daily.ACTION_FLAG = 'plus' OR daily.ACTION_FLAG = 'minus' )
         WHERE
         total.DEL_FLAG = '0'
-        AND total.DEL_FLAG = '0'
+        AND total.CUSTOMER_ID = #{customerId}
         GROUP BY
         total.USER_ID
         ORDER BY
@@ -80,4 +80,54 @@
              action_flag = #{actionFlag}
     </select>
 
+
+    <insert id="insertOrUpdate" useGeneratedKeys="true" keyColumn="id" keyProperty="id" parameterType="com.epmet.entity.UserPointStatisticalDailyEntity">
+
+        <selectKey keyProperty="id" resultType="java.lang.String" order="BEFORE">
+            SELECT replace(uuid(),'-','') AS ID
+        </selectKey>
+
+        INSERT INTO user_point_statistical_daily
+        (
+                id,
+                user_id,
+                date_id,
+                week_id,
+                month_id,
+                quarter_id,
+                year_id,
+                action_flag,
+                customer_id,
+                point_change,
+                del_flag,
+                revision,
+                created_by,
+                created_time,
+                updated_by,
+                updated_time
+        ) VALUE (
+                #{id},
+                #{userId},
+                #{dateId},
+                #{weekId},
+                #{monthId},
+                #{quarterId},
+                #{yearId},
+                #{actionFlag},
+                #{customerId},
+                #{pointChange},
+                '1',
+                0,
+                #{createdBy},
+                now(),
+                #{createdBy},
+                now()
+
+        ) ON DUPLICATE KEY UPDATE
+        POINT_CHANGE = (POINT_CHANGE + #{pointChange}),
+        UPDATED_TIME = NOW(),
+        UPDATED_BY = #{createdBy}
+
+    </insert>
+
 </mapper>
\ No newline at end of file