记得上下班打卡 | git大法好,push需谨慎

Commit 8b8de87e authored by jiangxiulong's avatar jiangxiulong

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

parents 71797416 4b3a3992
...@@ -33,7 +33,7 @@ public class KylinMemberAuditController extends BaseController { ...@@ -33,7 +33,7 @@ public class KylinMemberAuditController extends BaseController {
@Autowired @Autowired
private IKylinPerformancesAdminService kylinPerformancesService; private IKylinPerformancesAdminService kylinPerformancesService;
@RequiresPermissions("kylin:performances:memberAudit") //@RequiresPermissions("kylin:performances:member")
@GetMapping() @GetMapping()
public String memberAudit() { public String memberAudit() {
return prefix + "/memberAudit"; return prefix + "/memberAudit";
...@@ -42,7 +42,7 @@ public class KylinMemberAuditController extends BaseController { ...@@ -42,7 +42,7 @@ public class KylinMemberAuditController extends BaseController {
/** /**
* 会员待审核列表 * 会员待审核列表
*/ */
@RequiresPermissions("kylin:performances:recommend:list") //@RequiresPermissions("kylin:performances:member")
@PostMapping("/list") @PostMapping("/list")
@ResponseBody @ResponseBody
public TableDataInfo list(@RequestParam("title") String title, @RequestParam("pageNum") int page, @RequestParam("pageSize") int size) { public TableDataInfo list(@RequestParam("title") String title, @RequestParam("pageNum") int page, @RequestParam("pageSize") int size) {
...@@ -51,7 +51,7 @@ public class KylinMemberAuditController extends BaseController { ...@@ -51,7 +51,7 @@ public class KylinMemberAuditController extends BaseController {
return getDataTable(result); return getDataTable(result);
} }
@RequiresPermissions("kylin:performances:memberAudit:edit") //@RequiresPermissions("kylin:performances:member")
@GetMapping("/edit/{performancesId}") @GetMapping("/edit/{performancesId}")
public String edit(@PathVariable("performancesId") String performancesId, Integer status, ModelMap mmap) { public String edit(@PathVariable("performancesId") String performancesId, Integer status, ModelMap mmap) {
PerformanceMemberAuditDao result = kylinPerformancesService.performanceMemberAuditInfo(performancesId, status); PerformanceMemberAuditDao result = kylinPerformancesService.performanceMemberAuditInfo(performancesId, status);
...@@ -59,7 +59,7 @@ public class KylinMemberAuditController extends BaseController { ...@@ -59,7 +59,7 @@ public class KylinMemberAuditController extends BaseController {
return prefix + "/edit"; return prefix + "/edit";
} }
@RequiresPermissions("kylin:performances:memberAudit:save") //@RequiresPermissions("kylin:performances:member")
@PostMapping("/save") @PostMapping("/save")
@ResponseBody @ResponseBody
public AjaxResult save(@RequestParam("performancesId") String performancesId, @RequestParam("status")Integer status, @RequestParam("rejectTxt")String rejectTxt) { public AjaxResult save(@RequestParam("performancesId") String performancesId, @RequestParam("status")Integer status, @RequestParam("rejectTxt")String rejectTxt) {
......
...@@ -48,7 +48,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -48,7 +48,7 @@ public class KylinPerformancesController extends BaseController {
@Autowired @Autowired
private DamaiService damaiService; private DamaiService damaiService;
@RequiresPermissions("kylin:performances:view") //@RequiresPermissions("kylin:performances:view")
@GetMapping() @GetMapping()
public String performances() { public String performances() {
return prefix + "/performances"; return prefix + "/performances";
...@@ -57,7 +57,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -57,7 +57,7 @@ public class KylinPerformancesController extends BaseController {
/** /**
* 查询演出列表 * 查询演出列表
*/ */
@RequiresPermissions("kylin:performances:list") //@RequiresPermissions("kylin:performances:view")
@PostMapping("/list") @PostMapping("/list")
@ResponseBody @ResponseBody
public TableDataInfo list(PerformanceAdminListParam performanceAdminListParam) { public TableDataInfo list(PerformanceAdminListParam performanceAdminListParam) {
...@@ -69,7 +69,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -69,7 +69,7 @@ public class KylinPerformancesController extends BaseController {
return rspData; return rspData;
} }
@RequiresPermissions("kylin:performances:detail") //@RequiresPermissions("kylin:performances:view")
@GetMapping(value = "/details/{performancesId}") @GetMapping(value = "/details/{performancesId}")
public String performanceDetails(@PathVariable("performancesId") String performancesId, ModelMap mmap) { public String performanceDetails(@PathVariable("performancesId") String performancesId, ModelMap mmap) {
KylinPerformanceMisVo result = null; KylinPerformanceMisVo result = null;
...@@ -79,21 +79,21 @@ public class KylinPerformancesController extends BaseController { ...@@ -79,21 +79,21 @@ public class KylinPerformancesController extends BaseController {
} }
@PostMapping(value = "/audit") @PostMapping(value = "/audit")
@RequiresPermissions("kylin:performances:audit") //@RequiresPermissions("kylin:performances:view")
@ResponseBody @ResponseBody
public AjaxResult performanceAudit(@RequestParam("performancesId") String performancesId, @RequestParam("status") int status, @RequestParam(value = "rejectTxt", required = false) String rejectTxt) { public AjaxResult performanceAudit(@RequestParam("performancesId") String performancesId, @RequestParam("status") int status, @RequestParam(value = "rejectTxt", required = false) String rejectTxt) {
boolean result = kylinPerformancesService.performanceAudit(performancesId, status, rejectTxt); boolean result = kylinPerformancesService.performanceAudit(performancesId, status, rejectTxt);
return toAjax(result); return toAjax(result);
} }
@RequiresPermissions("kylin:performances:change") //@RequiresPermissions("kylin:performances:view")
@PostMapping(value = "/isShow") @PostMapping(value = "/isShow")
@ResponseBody @ResponseBody
public AjaxResult setIsShow(String performancesId, Integer isShow) { public AjaxResult setIsShow(String performancesId, Integer isShow) {
return toAjax(kylinPerformancesService.setIsShow(performancesId, isShow)); return toAjax(kylinPerformancesService.setIsShow(performancesId, isShow));
} }
@RequiresPermissions("kylin:performances:member") //@RequiresPermissions("kylin:performances:view")
@GetMapping(value = "/memberInfo/{performancesId}") @GetMapping(value = "/memberInfo/{performancesId}")
public String memberInfo(@PathVariable("performancesId") String performancesId, ModelMap mmap) { public String memberInfo(@PathVariable("performancesId") String performancesId, ModelMap mmap) {
PerformanceMemberAuditDao result = kylinPerformancesService.performanceMemberInfo(performancesId); PerformanceMemberAuditDao result = kylinPerformancesService.performanceMemberInfo(performancesId);
...@@ -101,7 +101,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -101,7 +101,7 @@ public class KylinPerformancesController extends BaseController {
return prefix + "/memberInfo"; return prefix + "/memberInfo";
} }
@RequiresPermissions("kylin:performances:member:change") //@RequiresPermissions("kylin:performances:view")
@PostMapping(value = "/memberInfo/submit") @PostMapping(value = "/memberInfo/submit")
@ResponseBody @ResponseBody
public AjaxResult memberInfo(PerformanceMemberAuditParam performanceMemberAuditParam) { public AjaxResult memberInfo(PerformanceMemberAuditParam performanceMemberAuditParam) {
...@@ -109,7 +109,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -109,7 +109,7 @@ public class KylinPerformancesController extends BaseController {
return toAjax(result); return toAjax(result);
} }
@RequiresPermissions("kylin:performances:performanceStatic") //@RequiresPermissions("kylin:performances:view")
@GetMapping(value = "/performanceStatic/{performancesId}") @GetMapping(value = "/performanceStatic/{performancesId}")
public String performanceStatic(@PathVariable("performancesId") String performancesId, ModelMap mmap) { public String performanceStatic(@PathVariable("performancesId") String performancesId, ModelMap mmap) {
//获取演出详情 //获取演出详情
...@@ -136,7 +136,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -136,7 +136,7 @@ public class KylinPerformancesController extends BaseController {
return prefix + "/performancesStatic"; return prefix + "/performancesStatic";
} }
@RequiresPermissions("kylin:performances:damai") //@RequiresPermissions("kylin:performances:view")
@GetMapping(value = "/damai/{performancesId}") @GetMapping(value = "/damai/{performancesId}")
public String damai(@PathVariable("performancesId") String performancesId, ModelMap mmap) { public String damai(@PathVariable("performancesId") String performancesId, ModelMap mmap) {
KylinPerformanceDamaiVo result = kylinPerformancesService.getPerformanceDamai(performancesId); KylinPerformanceDamaiVo result = kylinPerformancesService.getPerformanceDamai(performancesId);
...@@ -144,7 +144,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -144,7 +144,7 @@ public class KylinPerformancesController extends BaseController {
return prefix + "/damai"; return prefix + "/damai";
} }
@RequiresPermissions("kylin:performances:agent") //@RequiresPermissions("kylin:performances:view")
@GetMapping(value = "/agent/{performancesId}") @GetMapping(value = "/agent/{performancesId}")
public String agent(@PathVariable("performancesId") String performancesId, ModelMap mmap) { public String agent(@PathVariable("performancesId") String performancesId, ModelMap mmap) {
KylinPerformanceAgentVo result = kylinPerformancesService.getPerformanceAgent(performancesId); KylinPerformanceAgentVo result = kylinPerformancesService.getPerformanceAgent(performancesId);
...@@ -152,7 +152,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -152,7 +152,7 @@ public class KylinPerformancesController extends BaseController {
return prefix + "/agent"; return prefix + "/agent";
} }
@RequiresPermissions("kylin:performances:agent") //@RequiresPermissions("kylin:performances:view")
@PostMapping(value = "/agent/change") @PostMapping(value = "/agent/change")
@ResponseBody @ResponseBody
public AjaxResult changeTicketAgent(@RequestParam("performancesId") String performancesId, @RequestParam("ticketsId") String ticketsId, @RequestParam("status") Integer status) { public AjaxResult changeTicketAgent(@RequestParam("performancesId") String performancesId, @RequestParam("ticketsId") String ticketsId, @RequestParam("status") Integer status) {
...@@ -160,7 +160,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -160,7 +160,7 @@ public class KylinPerformancesController extends BaseController {
return toAjax(result); return toAjax(result);
} }
@RequiresPermissions("kylin:performances:damai") //@RequiresPermissions("kylin:performances:view")
@PostMapping(value = "/damai/change") @PostMapping(value = "/damai/change")
@ResponseBody @ResponseBody
public AjaxResult changeSysDamai(@RequestParam("params") String params) { public AjaxResult changeSysDamai(@RequestParam("params") String params) {
...@@ -170,7 +170,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -170,7 +170,7 @@ public class KylinPerformancesController extends BaseController {
return toAjax(result); return toAjax(result);
} }
@RequiresPermissions("kylin:performances:damai") //@RequiresPermissions("kylin:performances:view")
@PostMapping(value = "/sync/damai") @PostMapping(value = "/sync/damai")
@ResponseBody @ResponseBody
public AjaxResult syncDamai(@RequestParam("performancesId") String performancesId) { public AjaxResult syncDamai(@RequestParam("performancesId") String performancesId) {
...@@ -178,7 +178,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -178,7 +178,7 @@ public class KylinPerformancesController extends BaseController {
return toAjax(result); return toAjax(result);
} }
@RequiresPermissions("kylin:performances:refundConfig") //@RequiresPermissions("kylin:performances:view")
@GetMapping(value = "/refundConfig/{performancesId}") @GetMapping(value = "/refundConfig/{performancesId}")
public String getRefundConfig(@PathVariable("performancesId") String performancesId, ModelMap mmap) { public String getRefundConfig(@PathVariable("performancesId") String performancesId, ModelMap mmap) {
PerformanceRefundConfigVo result = kylinPerformancesService.getRefundConfig(performancesId); PerformanceRefundConfigVo result = kylinPerformancesService.getRefundConfig(performancesId);
...@@ -186,7 +186,7 @@ public class KylinPerformancesController extends BaseController { ...@@ -186,7 +186,7 @@ public class KylinPerformancesController extends BaseController {
return prefix + "/refundConfig"; return prefix + "/refundConfig";
} }
@RequiresPermissions("kylin:performances:refundConfig") //@RequiresPermissions("kylin:performances:view")
@PostMapping(value = "/refundConfig/change") @PostMapping(value = "/refundConfig/change")
@ResponseBody @ResponseBody
public AjaxResult changeRefundConfig(@RequestParam("performancesId") String performancesId, public AjaxResult changeRefundConfig(@RequestParam("performancesId") String performancesId,
......
...@@ -36,7 +36,7 @@ public class KylinPerformancesRecommendController extends BaseController { ...@@ -36,7 +36,7 @@ public class KylinPerformancesRecommendController extends BaseController {
@Autowired @Autowired
private IKylinPerformancesAdminService kylinPerformancesService; private IKylinPerformancesAdminService kylinPerformancesService;
@RequiresPermissions("kylin:performances:recommend") // @RequiresPermissions("kylin:performances:recommend")
@GetMapping() @GetMapping()
public String recommend() { public String recommend() {
return prefix + "/recommend"; return prefix + "/recommend";
...@@ -45,7 +45,7 @@ public class KylinPerformancesRecommendController extends BaseController { ...@@ -45,7 +45,7 @@ public class KylinPerformancesRecommendController extends BaseController {
/** /**
* 查询演出列表 * 查询演出列表
*/ */
@RequiresPermissions("kylin:performances:recommend:list") // @RequiresPermissions("kylin:performances:recommend:list")
@PostMapping("/list") @PostMapping("/list")
@ResponseBody @ResponseBody
public TableDataInfo list() { public TableDataInfo list() {
...@@ -64,7 +64,7 @@ public class KylinPerformancesRecommendController extends BaseController { ...@@ -64,7 +64,7 @@ public class KylinPerformancesRecommendController extends BaseController {
/** /**
* 修改 * 修改
*/ */
@RequiresPermissions("kylin:performances:recommend:change") // @RequiresPermissions("kylin:performances:recommend:change")
@PostMapping("/change") @PostMapping("/change")
@ResponseBody @ResponseBody
public AjaxResult setRecommend(@RequestParam(value = "ids") String performancesId,@RequestParam(value = "isRecommend",required = false) Integer isRecommend) { public AjaxResult setRecommend(@RequestParam(value = "ids") String performancesId,@RequestParam(value = "isRecommend",required = false) Integer isRecommend) {
...@@ -82,7 +82,7 @@ public class KylinPerformancesRecommendController extends BaseController { ...@@ -82,7 +82,7 @@ public class KylinPerformancesRecommendController extends BaseController {
return prefix + "/edit"; return prefix + "/edit";
} }
@RequiresPermissions("kylin:performances:recommend:change") // @RequiresPermissions("kylin:performances:recommend:change")
@GetMapping(value = "/performance/status") @GetMapping(value = "/performance/status")
@ResponseBody @ResponseBody
public AjaxResult listByStatus(@RequestParam(value = "status") String status,@RequestParam(value = "title",required = false) String title) { public AjaxResult listByStatus(@RequestParam(value = "status") String status,@RequestParam(value = "title",required = false) String title) {
......
...@@ -41,13 +41,13 @@ public class KylinRoadShowController extends BaseController { ...@@ -41,13 +41,13 @@ public class KylinRoadShowController extends BaseController {
@Autowired @Autowired
private IKylinPerformancesAdminService kylinPerformancesService; private IKylinPerformancesAdminService kylinPerformancesService;
@RequiresPermissions("kylin:performances:roadShow") // @RequiresPermissions("kylin:performances:roadShow")
@GetMapping() @GetMapping()
public String roadShow() { public String roadShow() {
return prefix + "/roadShow"; return prefix + "/roadShow";
} }
@RequiresPermissions("kylin:performances:roadShow:list") // @RequiresPermissions("kylin:performances:roadShow:list")
@PostMapping("/list") @PostMapping("/list")
@ResponseBody @ResponseBody
public TableDataInfo listRoadShow(@RequestParam(value = "title", required = false) String title, public TableDataInfo listRoadShow(@RequestParam(value = "title", required = false) String title,
...@@ -66,7 +66,7 @@ public class KylinRoadShowController extends BaseController { ...@@ -66,7 +66,7 @@ public class KylinRoadShowController extends BaseController {
return prefix + "/add"; return prefix + "/add";
} }
@RequiresPermissions("kylin:performances:roadShow:add") // @RequiresPermissions("kylin:performances:roadShow:add")
@Log(title = "巡演", businessType = BusinessType.INSERT) @Log(title = "巡演", businessType = BusinessType.INSERT)
@PostMapping("/add") @PostMapping("/add")
@ResponseBody @ResponseBody
...@@ -74,7 +74,7 @@ public class KylinRoadShowController extends BaseController { ...@@ -74,7 +74,7 @@ public class KylinRoadShowController extends BaseController {
return toAjax(!kylinRoadShowsAdminService.createRoadShow(createRoadShowParam).equals("")); return toAjax(!kylinRoadShowsAdminService.createRoadShow(createRoadShowParam).equals(""));
} }
@RequiresPermissions("kylin:performances:roadShow:details") // @RequiresPermissions("kylin:performances:roadShow:details")
@GetMapping(value = "/details/{roadShowId}") @GetMapping(value = "/details/{roadShowId}")
public String detailsRoadShow(@PathVariable("roadShowId") String roadShowId, ModelMap mmap) { public String detailsRoadShow(@PathVariable("roadShowId") String roadShowId, ModelMap mmap) {
KylinRoadShowAdminVo result = kylinRoadShowsAdminService.detailsRoadShow(roadShowId); KylinRoadShowAdminVo result = kylinRoadShowsAdminService.detailsRoadShow(roadShowId);
...@@ -82,7 +82,7 @@ public class KylinRoadShowController extends BaseController { ...@@ -82,7 +82,7 @@ public class KylinRoadShowController extends BaseController {
return prefix + "/edit"; return prefix + "/edit";
} }
@RequiresPermissions("kylin:performances:roadShow:edit") // @RequiresPermissions("kylin:performances:roadShow:edit")
@Log(title = "巡演", businessType = BusinessType.UPDATE) @Log(title = "巡演", businessType = BusinessType.UPDATE)
@PostMapping("/edit") @PostMapping("/edit")
@ResponseBody @ResponseBody
...@@ -100,7 +100,7 @@ public class KylinRoadShowController extends BaseController { ...@@ -100,7 +100,7 @@ public class KylinRoadShowController extends BaseController {
return prefix + "/details"; return prefix + "/details";
} }
@RequiresPermissions("kylin:performances:roadShow:addPerformance") // @RequiresPermissions("kylin:performances:roadShow:addPerformance")
@GetMapping(value = "/performance/{roadShowId}") @GetMapping(value = "/performance/{roadShowId}")
@ResponseBody @ResponseBody
public TableDataInfo listByRoadShowId(@PathVariable("roadShowId") String roadShowId) { public TableDataInfo listByRoadShowId(@PathVariable("roadShowId") String roadShowId) {
...@@ -109,7 +109,7 @@ public class KylinRoadShowController extends BaseController { ...@@ -109,7 +109,7 @@ public class KylinRoadShowController extends BaseController {
} }
@RequiresPermissions("kylin:performances:roadShow:change:performance") // @RequiresPermissions("kylin:performances:roadShow:change:performance")
@PostMapping(value = "/roadShow/relation") @PostMapping(value = "/roadShow/relation")
@ResponseBody @ResponseBody
public AjaxResult changeRoadShowId(@RequestParam(value = "ids") String performancesId,@RequestParam(value = "roadShowId",required = false) String roadShowId) { public AjaxResult changeRoadShowId(@RequestParam(value = "ids") String performancesId,@RequestParam(value = "roadShowId",required = false) String roadShowId) {
...@@ -126,7 +126,7 @@ public class KylinRoadShowController extends BaseController { ...@@ -126,7 +126,7 @@ public class KylinRoadShowController extends BaseController {
return prefix + "/addPerformances"; return prefix + "/addPerformances";
} }
@RequiresPermissions("kylin:performances:roadShow:change:performance") // @RequiresPermissions("kylin:performances:roadShow:change:performance")
@GetMapping(value = "/performance/status") @GetMapping(value = "/performance/status")
@ResponseBody @ResponseBody
public AjaxResult listByStatus(@RequestParam(value = "status") String status,@RequestParam(value = "title",required = false) String title) { public AjaxResult listByStatus(@RequestParam(value = "status") String status,@RequestParam(value = "title",required = false) String title) {
......
...@@ -133,7 +133,7 @@ create table adam_addresses ...@@ -133,7 +133,7 @@ create table adam_addresses
province varchar(60) not null comment '省份', province varchar(60) not null comment '省份',
city varchar(60) not null comment '城市', city varchar(60) not null comment '城市',
county varchar(60) not null comment '区县', county varchar(60) not null comment '区县',
address tinytext not null comment '详细地址', address text not null comment '详细地址',
is_default boolean not null default false comment '是否为默认:0-否,1-是,第一个默认1', is_default boolean not null default false comment '是否为默认:0-否,1-是,第一个默认1',
state tinyint not null comment '状态:0-INIT,1-NORMAL,2-INVALID', state tinyint not null comment '状态:0-INIT,1-NORMAL,2-INVALID',
created_at datetime(3) not null, created_at datetime(3) not null,
......
...@@ -52,13 +52,13 @@ public class KylinCheckUserPartnerController { ...@@ -52,13 +52,13 @@ public class KylinCheckUserPartnerController {
return checkUserPartnerService.del(merchantId, checkUserId); return checkUserPartnerService.del(merchantId, checkUserId);
} }
@PutMapping(value = "") @PostMapping(value = "change")
@ApiOperation(value = "修改验票账号", position = 1) @ApiOperation(value = "修改验票账号", position = 1)
@ApiResponse(code = 200, message = "接口返回对象参数") @ApiResponse(code = 200, message = "接口返回对象参数")
public ResponseDto<String> change(@RequestParam("merchantId") @NotNull String merchantId, public ResponseDto<String> change(@RequestParam("merchantId") @NotNull String merchantId,
@RequestParam("checkUserId") @NotNull String checkUserId, @RequestParam("checkUserId") @NotNull String checkUserId,
@RequestParam("name") @NotNull String name, @RequestParam("name") @NotNull String name,
@RequestParam(value = "pwd",required = false) @NotNull String pwd, @RequestParam(value = "pwd",required = false) String pwd,
@RequestParam("mobile") @Length(max = 11) String mobile) { @RequestParam("mobile") @Length(max = 11) String mobile) {
return checkUserPartnerService.change(merchantId, checkUserId, name, pwd, mobile); return checkUserPartnerService.change(merchantId, checkUserId, name, pwd, mobile);
} }
......
...@@ -35,8 +35,8 @@ public class DMEntersProcessor extends DataMigrationProcessorService { ...@@ -35,8 +35,8 @@ public class DMEntersProcessor extends DataMigrationProcessorService {
// log.info("DM.flush.AdamEntersVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamEntersVo.class.getSimpleName()).getDeletedCount()); // log.info("DM.flush.AdamEntersVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamEntersVo.class.getSimpleName()).getDeletedCount());
} }
String sqlCount = "select count(1) from (\n" + String sqlCount = "select count(1) from (" +
" select row_number() over (partition by user_id,type,idcode,name order by updated_at desc) rn,e.* from enters e where e.is_certification = 'yes' and e.deleted_at is null and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt)) + "\n" + " select row_number() over (partition by user_id,type,idcode,name order by updated_at desc) rn,e.* from enters e where e.is_certification = 'yes' and e.deleted_at is null and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt)) +
" ) tk where tk.rn=1 "; " ) tk where tk.rn=1 ";
if (null != dg) { if (null != dg) {
sqlCount = sqlCount + " and id%" + dG + "=" + dg; sqlCount = sqlCount + " and id%" + dG + "=" + dg;
......
...@@ -37,8 +37,8 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService { ...@@ -37,8 +37,8 @@ public class DMThirdPartsProcessor extends DataMigrationProcessorService {
// log.info("DM.flush.AdamThirdPartInfoVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamThirdPartInfoVo.class.getSimpleName()).getDeletedCount()); // log.info("DM.flush.AdamThirdPartInfoVo:{}", mongoTemplate.remove(Query.query(Criteria.where("_id").exists(true)), AdamThirdPartInfoVo.class.getSimpleName()).getDeletedCount());
} }
String sqlCount = "select count(1) from (\n" + String sqlCount = "select count(1) from (" +
" select row_number() over (partition by uid,type order by created_at desc) rn,id,uid,open_id,avatar,nickname,type,created_at,updated_at from user_third_parts where `status`=1 and delete_tag in (0,1) and open_id<>'' and uid>0 and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt)) + "\n" + " select row_number() over (partition by uid,type order by created_at desc) rn,id,uid,open_id,avatar,nickname,type,created_at,updated_at from user_third_parts where `status`=1 and delete_tag in (0,1) and open_id<>'' and uid>0 and created_at" + (StringUtils.isBlank(incrDt) ? "<curdate()" : (">=curdate()-" + incrDt)) +
" ) t where t.rn=1"; " ) t where t.rn=1";
if (null != dg) { if (null != dg) {
sqlCount = sqlCount + " and id%" + dG + "=" + dg; sqlCount = sqlCount + " and id%" + dG + "=" + dg;
......
...@@ -75,7 +75,7 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService { ...@@ -75,7 +75,7 @@ public class DMUserInformationProcessor extends DataMigrationProcessorService {
ResultSetImpl row = null; ResultSetImpl row = null;
try { try {
Class.forName(DB_DRIVER); Class.forName(DB_DRIVER);
// connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD); connection = DriverManager.getConnection(DB_URL + DB_NAME_PASSPORT, DB_USER, DB_PWD);
statement = connection.prepareStatement(sqlCount); statement = connection.prepareStatement(sqlCount);
row = (ResultSetImpl) statement.executeQuery(); row = (ResultSetImpl) statement.executeQuery();
row.first(); row.first();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment