1;历史数据更新
This commit is contained in:
parent
5b8c303259
commit
462bc22b5b
|
@ -71,6 +71,7 @@ public class MeituanController {
|
|||
/*
|
||||
店铺history
|
||||
*/
|
||||
@ApiOperation("店铺history")
|
||||
@GetMapping("/getReturnInfo")
|
||||
public R getReturnInfo(){
|
||||
iMeituanService.getReturnInfo(null);//店铺id
|
||||
|
|
|
@ -70,7 +70,7 @@ spring:
|
|||
druid:
|
||||
# 主库数据源
|
||||
master:
|
||||
url: jdbc:mysql://bj-cdb-7ezuofce.sql.tencentcdb.com:21965/youshi_test?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
|
||||
url: jdbc:mysql://bj-cdb-7ezuofce.sql.tencentcdb.com:21965/youshi_test?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&allowMultiQueries=true
|
||||
username: youshi
|
||||
password: youshi@2024
|
||||
# 从库数据源
|
||||
|
|
|
@ -71,7 +71,7 @@ spring:
|
|||
druid:
|
||||
# 主库数据源
|
||||
master:
|
||||
url: jdbc:mysql://bj-cdb-7ezuofce.sql.tencentcdb.com:21965/ry_vue?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
|
||||
url: jdbc:mysql://bj-cdb-7ezuofce.sql.tencentcdb.com:21965/ry_vue?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&allowMultiQueries=true
|
||||
username: youshi
|
||||
password: youshi@2024
|
||||
# 从库数据源
|
||||
|
|
|
@ -54,7 +54,6 @@ public class RyTask {
|
|||
public void getReturnInfo() {
|
||||
log.error("***********history************************");
|
||||
iMeituanService.getComments(null);
|
||||
iMeituanService.getReturnInfo(null);
|
||||
log.error("***********historyEnd************************");
|
||||
|
||||
}
|
||||
|
|
|
@ -222,7 +222,6 @@ public class MeituanServiceImpl implements IMeituanService {
|
|||
* @return
|
||||
*/
|
||||
@Override
|
||||
@Transactional(rollbackFor = Exception.class)
|
||||
public String getComments(String accountName) {
|
||||
BusStoreInfo busStoreInfo = new BusStoreInfo();
|
||||
busStoreInfo.setGrantStatus("1");
|
||||
|
@ -240,6 +239,10 @@ public class MeituanServiceImpl implements IMeituanService {
|
|||
countDownLatch.await(); //保证之前的所有的线程都执行完成,才会走下面的;
|
||||
long endTime = System.currentTimeMillis(); //结束时间
|
||||
log.error(("executeDayAsync一共耗时time: " + (endTime - startTime) / 1000 + " s"));
|
||||
|
||||
long endTime1 = System.currentTimeMillis(); //结束时间
|
||||
getReturnInfo(null);
|
||||
log.error(("更新history 耗时: " + (endTime1 - endTime) / 1000 + " s"));
|
||||
// 这样就可以在下面拿到所有线程执行完的集合结果
|
||||
} catch (Exception e) {
|
||||
log.error("executeDayAsync阻塞异常:"+e.getMessage());
|
||||
|
|
|
@ -154,8 +154,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
|||
<update id="updateBatchStoreDayHistoryInfo">
|
||||
<foreach collection="editList" item="item" separator=";">
|
||||
update bus_store_day_history_info
|
||||
<trim prefix="SET" suffixOverrides=",">
|
||||
<if test="item.storeId != null">store_id = #{item.storeId},</if>
|
||||
<set>
|
||||
<if test="item.lastOrderNum != null">store_id = #{item.storeId},</if>
|
||||
<if test="item.lastOrderNum != null">last_order_num = #{item.lastOrderNum},</if>
|
||||
<if test="item.lastPositiveReviewsNum != null">last_positive_reviews_num = #{item.lastPositiveReviewsNum},</if>
|
||||
<if test="item.lastFiveStarReviewsNum != null">last_five_star_reviews_num = #{item.lastFiveStarReviewsNum},</if>
|
||||
|
@ -164,7 +164,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
|
|||
<if test="item.todayReturnVisitNum != null">today_return_visit_num = #{item.todayReturnVisitNum},</if>
|
||||
<if test="item.score != null">score = #{item.score},</if>
|
||||
<if test="item.createTime != null">create_time = #{item.createTime},</if>
|
||||
</trim>
|
||||
</set>
|
||||
where id = #{item.id}
|
||||
</foreach>
|
||||
</update>
|
||||
|
|
Loading…
Reference in New Issue