diff --git a/xhpc-modules/pom.xml b/xhpc-modules/pom.xml index 498e62f6..bb11e8aa 100644 --- a/xhpc-modules/pom.xml +++ b/xhpc-modules/pom.xml @@ -24,6 +24,7 @@ xhpc-data-big-screen xhpc-workorder xhpc-tenant + xhpc-activity xhpc-log diff --git a/xhpc-modules/xhpc-activity/.gitignore b/xhpc-modules/xhpc-activity/.gitignore new file mode 100644 index 00000000..54283dd4 --- /dev/null +++ b/xhpc-modules/xhpc-activity/.gitignore @@ -0,0 +1,35 @@ +HELP.md +target/ +.mvn/ +!.mvn/wrapper/maven-wrapper.jar +!**/src/main/**/target/ +!**/src/test/**/target/ + +### STS ### +.apt_generated +.classpath +.factorypath +.project +.settings +.springBeans +.sts4-cache + +### IntelliJ IDEA ### +.idea/ +.idea +*.iws +*.iml +*.ipr + +### NetBeans ### +/nbproject/private/ +/nbbuild/ +/dist/ +/nbdist/ +/.nb-gradle/ +build/ +!**/src/main/**/build/ +!**/src/test/**/build/ + +### VS Code ### +.vscode/ diff --git a/xhpc-modules/xhpc-activity/pom.xml b/xhpc-modules/xhpc-activity/pom.xml new file mode 100644 index 00000000..66f6c9cd --- /dev/null +++ b/xhpc-modules/xhpc-activity/pom.xml @@ -0,0 +1,136 @@ + + + + com.ruoyi + xhpc-modules + 3.0.0 + + 4.0.0 + + xhpc-activity + + + 活动服务 + + + 8 + 8 + + + + + org.mybatis.spring.boot + mybatis-spring-boot-starter + + + org.mybatis + mybatis + 3.5.6 + + + com.github.pagehelper + pagehelper-spring-boot-starter + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-config + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-sentinel + + + + org.springframework.boot + spring-boot-starter-actuator + + + + org.springframework.boot + spring-boot-starter-web + + + + + mysql + mysql-connector-java + + + + + com.ruoyi + ruoyi-common-datasource + + + + + com.ruoyi + ruoyi-common-core + + + + com.ruoyi + xhpc-common + 3.0.0 + compile + + + + org.apache.ant + ant + 1.10.12 + + + com.aliyun.oss + aliyun-sdk-oss + 3.10.2 + compile + + + com.ruoyi + ruoyi-common-log + + + + + + ${project.artifactId} + + + src/main/resources + + + src/main/java + + **/*.xml + + + + + + org.springframework.boot + spring-boot-maven-plugin + 2.4.0 + + + + repackage + + + + + + + + diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/XhpcActivityApplication.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/XhpcActivityApplication.java new file mode 100644 index 00000000..8ee7ac02 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/XhpcActivityApplication.java @@ -0,0 +1,24 @@ +package com.xhpc; + +import com.xhpc.common.security.annotation.EnableCustomConfig; +import com.xhpc.common.security.annotation.EnableRyFeignClients; +import org.mybatis.spring.annotation.MapperScan; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.cloud.openfeign.EnableFeignClients; + + +@EnableCustomConfig +@EnableRyFeignClients +@EnableFeignClients +@SpringBootApplication +@MapperScan("com.xhpc.activity.mapper") +public class XhpcActivityApplication { + + public static void main(String[] args) { + + + SpringApplication.run(XhpcActivityApplication.class, args); + + } +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityCashController.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityCashController.java new file mode 100644 index 00000000..c7183db0 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityCashController.java @@ -0,0 +1,152 @@ +package com.xhpc.activity.controller; + + +import com.xhpc.activity.domain.XhpcActivityCashDomain; +import com.xhpc.activity.domain.XhpcActivityRecordDomain; +import com.xhpc.activity.service.XhpcActivityCashService; +import com.xhpc.common.core.domain.R; +import com.xhpc.common.core.web.controller.BaseController; +import com.xhpc.common.core.web.page.TableDataInfo; +import com.xhpc.common.log.annotation.Log; +import com.xhpc.common.log.enums.BusinessType; +import com.xhpc.common.util.LogUserUtils; +import com.xhpc.system.api.model.LoginUser; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import java.util.HashMap; +import java.util.Map; + +@RestController +@RequestMapping("/activity/cash") +public class XhpcActivityCashController extends BaseController { + + @Resource + XhpcActivityCashService cashService; + + @Resource + LogUserUtils logUserUtils; + + + @GetMapping("/getPage") + public TableDataInfo getPage(HttpServletRequest request, + String status) { + + LoginUser loginUser = logUserUtils.getLogUser(request); + startPage(); + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + params.put("status", status); + return getDataTable(cashService.getPage(params)); + } + + + @GetMapping("/getNameList") + public R getNameList(HttpServletRequest request) { + + LoginUser loginUser = logUserUtils.getLogUser(request); + + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + return R.ok(cashService.getNameList(params)); + } + + + @GetMapping("/detail") + public R getDetail(@RequestParam("activityId") Integer activityId) { + + return R.ok(cashService.getDomainByPk(activityId)); + } + + + @Log(title = "活动管理-新增现金红包活动", businessType = BusinessType.INSERT) + @PostMapping("/") + public R insertDomain(HttpServletRequest request, @RequestBody XhpcActivityCashDomain domain) { + + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setCreateBy(loginUser.getUserid().toString()); + domain.setUpdateBy(loginUser.getUserid().toString()); + domain.setTenantId(loginUser.getTenantId()); + return R.ok(cashService.insertDomain(domain)); + } + + + @Log(title = "活动管理-更新现金红包活动", businessType = BusinessType.UPDATE) + @PutMapping("/detail") + public R updateDomain(HttpServletRequest request, @RequestBody XhpcActivityCashDomain domain) { + + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setUpdateBy(loginUser.getUserid().toString()); + return R.ok(cashService.updateDomain(domain)); + } + + + @Log(title = "活动管理-审核现金红包活动", businessType = BusinessType.UPDATE) + @PutMapping("/check") + public R updateDomainConfig(HttpServletRequest request, @RequestBody XhpcActivityCashDomain domain) { + + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setCheckBy(loginUser.getUserid().toString()); + return R.ok(cashService.checkDomain(domain)); + } + + + @Log(title = "活动管理-更新现金红包活动状态", businessType = BusinessType.UPDATE) + @PutMapping("/status") + public R updateDomainStatus(HttpServletRequest request, @RequestBody XhpcActivityCashDomain domain) { + + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setUpdateBy(loginUser.getUserid().toString()); + return R.ok(cashService.updateDomainStatus(domain)); + } + + + @Log(title = "活动管理-删除现金红包活动", businessType = BusinessType.DELETE) + @DeleteMapping("/{activityId}") + public R deleteDomainByPk(@PathVariable("activityId") Integer activityId) { + + return R.ok(cashService.deleteByPk(activityId)); + } + + + @GetMapping("/userList") + public TableDataInfo getUserList(@RequestParam("activityId")Integer activityId, + @RequestParam("userType") String userType, + @RequestParam("userAccount")String userAccount, + @RequestParam("pageNum")Integer pageNum, + @RequestParam("pageSize")Integer pageSize){ + + Map params = new HashMap<>(); + params.put("activityId", activityId); + params.put("userType", userType); + params.put("userAccount", userAccount); + params.put("pageNum", pageNum); + params.put("pageSize", pageSize); + + return getDataTable(cashService.getUserList(params)); + } + + + + @Log(title = "活动管理-领取红包", businessType = BusinessType.INSERT) + @PostMapping("/receive") + public R insertCashReceive(@RequestBody XhpcActivityRecordDomain domain) { + + return R.ok(cashService.insertReceiveDomain(domain)); + } + + + @GetMapping("/getReceivePage") + public TableDataInfo getReceivePage(HttpServletRequest request, + Integer activityId) { + + LoginUser loginUser = logUserUtils.getLogUser(request); + startPage(); + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + params.put("activityId", activityId); + return getDataTable(cashService.getReceivePage(params)); + } + +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityDiscountController.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityDiscountController.java new file mode 100644 index 00000000..2f52d576 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityDiscountController.java @@ -0,0 +1,122 @@ +package com.xhpc.activity.controller; + + +import com.xhpc.activity.domain.XhpcActivityDiscountDomain; +import com.xhpc.activity.service.XhpcActivityDiscountService; +import com.xhpc.common.core.domain.R; +import com.xhpc.common.core.web.controller.BaseController; +import com.xhpc.common.core.web.page.TableDataInfo; +import com.xhpc.common.log.annotation.Log; +import com.xhpc.common.log.enums.BusinessType; +import com.xhpc.common.util.LogUserUtils; +import com.xhpc.system.api.model.LoginUser; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import java.util.HashMap; +import java.util.Map; + +@RestController +@RequestMapping("/activity/discount") +public class XhpcActivityDiscountController extends BaseController { + + @Resource + XhpcActivityDiscountService discountService; + + @Resource + LogUserUtils logUserUtils; + + + @GetMapping("/getPage") + public TableDataInfo getPage(HttpServletRequest request, + String status){ + LoginUser loginUser = logUserUtils.getLogUser(request); + startPage(); + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + params.put("status", status); + return getDataTable(discountService.getPage(params)); + } + + + @GetMapping("/getNameList") + public R getNameList(HttpServletRequest request){ + LoginUser loginUser = logUserUtils.getLogUser(request); + + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + return R.ok(discountService.getNameList(params)); + } + + + @GetMapping("/detail") + public R getDetail(@RequestParam("activityId")Integer activityId){ + return R.ok(discountService.getDomainByPk(activityId)); + } + + + @GetMapping("/userList") + public TableDataInfo getUserList(@RequestParam("activityId")Integer activityId, + @RequestParam("userType") String userType, + @RequestParam("userAccount")String userAccount, + @RequestParam("pageNum")Integer pageNum, + @RequestParam("pageSize")Integer pageSize){ + + Map params = new HashMap<>(); + params.put("activityId", activityId); + params.put("userType", userType); + params.put("userAccount", userAccount); + params.put("pageNum", pageNum); + params.put("pageSize", pageSize); + + return getDataTable(discountService.getUserList(params)); + } + + + @Log(title = "活动管理-新增折扣活动", businessType = BusinessType.INSERT) + @PostMapping("/") + public R insertDomain(HttpServletRequest request, @RequestBody XhpcActivityDiscountDomain domain){ + + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setCreateBy(loginUser.getUserid().toString()); + domain.setUpdateBy(loginUser.getUserid().toString()); + domain.setTenantId(loginUser.getTenantId()); + + return R.ok(discountService.insertDomain(domain)); + } + + + @Log(title = "活动管理-更新折扣活动", businessType = BusinessType.UPDATE) + @PutMapping("/detail") + public R updateDomain(HttpServletRequest request, @RequestBody XhpcActivityDiscountDomain domain){ + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setUpdateBy(loginUser.getUserid().toString()); + return R.ok(discountService.updateDomain(domain)); + } + + + @Log(title = "活动管理-审核折扣活动", businessType = BusinessType.UPDATE) + @PutMapping("/check") + public R updateDomainConfig(HttpServletRequest request, @RequestBody XhpcActivityDiscountDomain domain){ + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setCheckBy(loginUser.getUserid().toString()); + return R.ok(discountService.checkDomain(domain)); + } + + + @Log(title = "活动管理-更新折扣活动状态", businessType = BusinessType.UPDATE) + @PutMapping("/status") + public R updateDomainStatus(HttpServletRequest request, @RequestBody XhpcActivityDiscountDomain domain){ + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setUpdateBy(loginUser.getUserid().toString()); + return R.ok(discountService.updateDomainStatus(domain)); + } + + + @Log(title = "活动管理-删除折扣活动", businessType = BusinessType.DELETE) + @DeleteMapping("/{activityId}") + public R deleteDomainByPk(@PathVariable("activityId")Integer activityId){ + return R.ok(discountService.deleteByPk(activityId)); + } +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityInternetController.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityInternetController.java new file mode 100644 index 00000000..49967b43 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityInternetController.java @@ -0,0 +1,107 @@ +package com.xhpc.activity.controller; + + +import com.xhpc.activity.domain.XhpcActivityInternetDomain; +import com.xhpc.activity.service.XhpcActivityInternetService; +import com.xhpc.common.core.domain.R; +import com.xhpc.common.core.web.controller.BaseController; +import com.xhpc.common.core.web.page.TableDataInfo; +import com.xhpc.common.log.annotation.Log; +import com.xhpc.common.log.enums.BusinessType; +import com.xhpc.common.util.LogUserUtils; +import com.xhpc.system.api.model.LoginUser; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import java.util.HashMap; +import java.util.Map; + +@RestController +@RequestMapping("/activity/internet") +public class XhpcActivityInternetController extends BaseController { + + @Resource + XhpcActivityInternetService internetService; + + @Resource + LogUserUtils logUserUtils; + + + @GetMapping("/getPage") + public TableDataInfo getPage(HttpServletRequest request, + String status){ + LoginUser loginUser = logUserUtils.getLogUser(request); + startPage(); + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + params.put("status", status); + return getDataTable(internetService.getPage(params)); + } + + + @GetMapping("/getNameList") + public R getNameList(HttpServletRequest request){ + LoginUser loginUser = logUserUtils.getLogUser(request); + + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + return R.ok(internetService.getNameList(params)); + } + + + @GetMapping("/detail") + public R getDetail(@RequestParam("activityId")Integer activityId){ + return R.ok(internetService.getDomainByPk(activityId)); + } + + + @Log(title = "活动管理-新增流量方活动", businessType = BusinessType.INSERT) + @PostMapping("/") + public R insertDomain(HttpServletRequest request, @RequestBody XhpcActivityInternetDomain domain){ + + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setCreateBy(loginUser.getUserid().toString()); + domain.setUpdateBy(loginUser.getUserid().toString()); + domain.setTenantId(loginUser.getTenantId()); + domain.setStatus(Short.valueOf("1")); + + return R.ok(internetService.insertDomain(domain)); + } + + + @Log(title = "活动管理-更新流量方活动模板", businessType = BusinessType.UPDATE) + @PutMapping("/detail") + public R updateDomain(HttpServletRequest request, @RequestBody XhpcActivityInternetDomain domain){ + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setUpdateBy(loginUser.getUserid().toString()); + return R.ok(internetService.updateDomain(domain)); + } + + + @Log(title = "活动管理-更新流量方活动状态", businessType = BusinessType.UPDATE) + @PutMapping("/status") + public R updateDomainStatus(HttpServletRequest request, @RequestBody XhpcActivityInternetDomain domain){ + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setUpdateBy(loginUser.getUserid().toString()); + return R.ok(internetService.updateDomainStatus(domain)); + } + + + @Log(title = "活动管理-审核流量方活动", businessType = BusinessType.UPDATE) + @PutMapping("/check") + public R checkDomain(HttpServletRequest request, @RequestBody XhpcActivityInternetDomain domain){ + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setCheckBy(loginUser.getUserid().toString()); + return R.ok(internetService.checkDomain(domain)); + } + + + @Log(title = "活动管理-删除流量方活动", businessType = BusinessType.DELETE) + @DeleteMapping("/{activityId}") + public R deleteDomainByPk(@PathVariable("activityId")Integer activityId){ + return R.ok(internetService.deleteByPk(activityId)); + } + + +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityTemplateController.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityTemplateController.java new file mode 100644 index 00000000..69eb78b5 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/controller/XhpcActivityTemplateController.java @@ -0,0 +1,96 @@ +package com.xhpc.activity.controller; + + +import com.xhpc.activity.domain.XhpcActivityTemplateDomain; +import com.xhpc.activity.service.XhpcActivityTemplateService; +import com.xhpc.common.core.domain.R; +import com.xhpc.common.core.web.controller.BaseController; +import com.xhpc.common.core.web.page.TableDataInfo; +import com.xhpc.common.log.annotation.Log; +import com.xhpc.common.log.enums.BusinessType; +import com.xhpc.common.util.LogUserUtils; +import com.xhpc.system.api.model.LoginUser; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; +import java.util.HashMap; +import java.util.Map; + +@RestController +@RequestMapping("/activity/template") +public class XhpcActivityTemplateController extends BaseController { + + @Resource + XhpcActivityTemplateService templateService; + + @Resource + LogUserUtils logUserUtils; + + + @GetMapping("/getPage") + public TableDataInfo getPage(HttpServletRequest request, + String status){ + LoginUser loginUser = logUserUtils.getLogUser(request); + startPage(); + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + params.put("status", status); + return getDataTable(templateService.getPage(params)); + } + + + @GetMapping("/getNameList") + public R getNameList(HttpServletRequest request){ + LoginUser loginUser = logUserUtils.getLogUser(request); + + Map params = new HashMap<>(); + params.put("tenantId", loginUser.getTenantId()); + return R.ok(templateService.getNameList(params)); + } + + + @GetMapping("/detail") + public R getDetail(@RequestParam("templateId")Integer templateId){ + return R.ok(templateService.getDomainByPk(templateId)); + } + + + @Log(title = "活动管理-新增折扣活动模版", businessType = BusinessType.INSERT) + @PostMapping("/") + public R insertDomain(HttpServletRequest request, @RequestBody XhpcActivityTemplateDomain domain){ + + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setCreateBy(loginUser.getUserid().toString()); + domain.setUpdateBy(loginUser.getUserid().toString()); + domain.setTenantId(loginUser.getTenantId()); + + return R.ok(templateService.insertDomain(domain)); + } + + + @Log(title = "活动管理-更新折扣活动模板", businessType = BusinessType.UPDATE) + @PutMapping("/detail") + public R updateDomain(HttpServletRequest request, @RequestBody XhpcActivityTemplateDomain domain){ + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setUpdateBy(loginUser.getUserid().toString()); + return R.ok(templateService.updateDomain(domain)); + } + + + @Log(title = "活动管理-更新折扣活动模板状态", businessType = BusinessType.UPDATE) + @PutMapping("/status") + public R updateDomainStatus(HttpServletRequest request, @RequestBody XhpcActivityTemplateDomain domain){ + LoginUser loginUser = logUserUtils.getLogUser(request); + domain.setUpdateBy(loginUser.getUserid().toString()); + return R.ok(templateService.updateDomainStatus(domain)); + } + + + @Log(title = "活动管理-删除折扣活动模板", businessType = BusinessType.DELETE) + @DeleteMapping("/{templateId}") + public R deleteDomainByPk(@PathVariable("templateId")Integer templateId){ + return R.ok(templateService.deleteByPk(templateId)); + } + +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityCashDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityCashDomain.java new file mode 100644 index 00000000..423b9781 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityCashDomain.java @@ -0,0 +1,110 @@ +package com.xhpc.activity.domain; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.Date; +import java.util.List; + +import lombok.Data; + +/** + * xhpc_activity_cash + * @author + */ +@Data +public class XhpcActivityCashDomain implements Serializable { + /** + * 活动ID + */ + private Integer activityId; + + /** + * 活动名称 + */ + private String activityName; + + /** + * 开始时间 + */ + private Date startTime; + + /** + * 结束时间 + */ + private Date endTime; + + /** + * 领取次数 + */ + private Integer receiveCount; + + /** + * 红包金额 + */ + private BigDecimal amount; + + /** + * C端用户ID（-1表示全部） + */ + private String appUserList; + + /** + * 社区用户ID列表（-1表示全部） + */ + private String comUserList; + + /** + * B端用户ID列表（-1表示全部） + */ + private String cusUserList; + + /** + * 租户ID + */ + private String tenantId; + + /** + * 状态（0-编辑，1-提交待审核，2-审核失败，3-审核通过，4-立即失效） + */ + private Short status; + + /** + * 删除标记（0-正常，2-已删除） + */ + private Short delFlag; + + /** + * 创建人 + */ + private String createBy; + + /** + * 更新时间 + */ + private Date createTime; + + /** + * 更新人 + */ + private String updateBy; + + /** + * 更新时间 + */ + private Date updateTime; + + /** + * 审核人 + */ + private String checkBy; + + /** + * 审核时间 + */ + private Date checkTime; + + + private List checkImgList; + + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityDiscountDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityDiscountDomain.java new file mode 100644 index 00000000..51fd0d39 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityDiscountDomain.java @@ -0,0 +1,119 @@ +package com.xhpc.activity.domain; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.Date; +import lombok.Data; + +/** + * xhpc_activity_discount + * @author + */ +@Data +public class XhpcActivityDiscountDomain implements Serializable { + /** + * 活动ID + */ + private Integer activityId; + + /** + * 活动名称 + */ + private String activityName; + + /** + * 模板ID + */ + private Integer templateId; + + /** + * C端用户列表(以逗号分隔，-1表示全部用户) + */ + private String appUserList; + + /** + * 社区用户列表(以逗号分隔，-1表示全部用户) + */ + private String comUserList; + + /** + * B端用户列表(以逗号分隔，-1表示全部用户) + */ + private String cusUserList; + + /** + * 场站列表 + */ + private String stationList; + + /** + * 租户ID + */ + private String tenantId; + + + /** + * 开始时间 + */ + private Date startTime; + + /** + * 结束时间 + */ + private Date endTime; + + /** + * 状态（0-编辑，1-提交待审核，2-审核失败，3-审核通过，4-立即失效） + */ + private Short status = 0; + + /** + * 删除标识（0-正常，2-删除） + */ + private Short delFlag = 0; + + /** + * 创建人 + */ + private String createBy; + + /** + * 创建时间 + */ + private Date createTime; + + /** + * 更新人 + */ + private String updateBy; + + /** + * 更新时间 + */ + private Date updateTime; + + + /** + * 审核人 + */ + private String checkBy; + + /** + * 审核时间 + */ + private Date checkTime; + + private XhpcActivityTemplateDomain templateDomain; + + /** + * 优惠类型（1-总金额，2-服务费，3-电量） + */ + private Short discountType; + + /** + * 优惠比率 + */ + private BigDecimal discountRate; + + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityFormulaDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityFormulaDomain.java new file mode 100644 index 00000000..668a2525 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityFormulaDomain.java @@ -0,0 +1,65 @@ +package com.xhpc.activity.domain; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.Date; +import lombok.Data; + +/** + * xhpc_activity_formula + * @author + */ +@Data +public class XhpcActivityFormulaDomain implements Serializable { + /** + * 活动计算ID + */ + private Long activityFormulaId; + + /** + * 活动ID + */ + private Integer activityId; + + /** + * 开始时间 + */ + private String startTime; + + /** + * 结束时间 + */ + private String endTime; + + /** + * 服务费 + */ + private BigDecimal servicePrice; + + /** + * 计算公式 + */ + private String computeFormula; + + /** + * 创建时间 + */ + private Date createTime; + + /** + * 创建人 + */ + private String createBy; + + /** + * 更新时间 + */ + private Date updateTime; + + /** + * 更新人 + */ + private String updateBy; + + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityImgDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityImgDomain.java new file mode 100644 index 00000000..b105c329 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityImgDomain.java @@ -0,0 +1,54 @@ +package com.xhpc.activity.domain; + +import java.io.Serializable; +import java.util.Date; +import lombok.Data; + +/** + * xhpc_activity_img + * @author + */ +@Data +public class XhpcActivityImgDomain implements Serializable { + /** + * 图片ID + */ + private Long activityImgId; + + /** + * 活动类型（CASH, DISCOUNT） + */ + private String activityType; + + /** + * 活动ID + */ + private Integer activityId; + + /** + * 图片名称 + */ + private String imgName; + + /** + * 图片地址 + */ + private String imgUrl; + + /** + * 删除标志（0-正常，2-已删除） + */ + private Short delFlag; + + /** + * 创建人 + */ + private String createBy; + + /** + * 创建时间 + */ + private Date createTime; + + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityInternetDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityInternetDomain.java new file mode 100644 index 00000000..6edf8b32 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityInternetDomain.java @@ -0,0 +1,112 @@ +package com.xhpc.activity.domain; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.Date; +import java.util.List; + +import lombok.Data; + +/** + * xhpc_activity_internet + * @author + */ +@Data +public class XhpcActivityInternetDomain implements Serializable { + /** + * 活动ID + */ + private Integer activityId; + + /** + * 活动名称 + */ + private String activityName; + + /** + * 流量方名称 + */ + private String internetName; + + /** + * 计算类型（1-总金额，2-服务费，3-电量） + */ + private Short computeType; + + /** + * 服务费 + */ + private BigDecimal servicePrice; + + /** + * 计算公式 + */ + private String computeFormula; + + /** + * 开始时间 + */ + private Date startTime; + + /** + * 结束时间 + */ + private Date endTime; + + /** + * 参与场站列表 + */ + private String stationList; + + /** + * 租户ID + */ + private String tenantId; + + /** + * 状态（0-编辑，1-提交生效，2-审核失败，3-审核成功，4-失效） + */ + private Short status; + + /** + * 删除标志（0-正常，2-删除） + */ + private Short delFlag; + + /** + * 创建人 + */ + private String createBy; + + /** + * 创建时间 + */ + private Date createTime; + + /** + * 更新人 + */ + private String updateBy; + + /** + * 更新时间 + */ + private Date updateTime; + + /** + * 审核人 + */ + private String checkBy; + + /** + * 审核时间 + */ + private Date checkTime; + + /** + * 分时段费用计算公式列表 + */ + List formulaList; + + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityRecordDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityRecordDomain.java new file mode 100644 index 00000000..6aeadcdd --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityRecordDomain.java @@ -0,0 +1,50 @@ +package com.xhpc.activity.domain; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.Date; +import lombok.Data; + +/** + * xhpc_activity_record + * @author + */ +@Data +public class XhpcActivityRecordDomain implements Serializable { + /** + * 活动参与记录ID + */ + private Long activityRecordId; + + /** + * 活动类型（CASH,DISCOUNT） + */ + private String activityType; + + /** + * 活动ID + */ + private Integer activityId; + + /** + * 人员类型（0 C端用户 1 流量方用户 2社区用户 3B端用户） + */ + private Short source; + + /** + * 用户ID + */ + private String userId; + + /** + * 红包金额 + */ + private BigDecimal amount; + + /** + * 领取时间 + */ + private Date createTime; + + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityTemplateDomain.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityTemplateDomain.java new file mode 100644 index 00000000..a3bd2f64 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/domain/XhpcActivityTemplateDomain.java @@ -0,0 +1,95 @@ +package com.xhpc.activity.domain; + +import java.io.Serializable; +import java.math.BigDecimal; +import java.util.Date; +import lombok.Data; + +/** + * xhpc_activity_template + * @author + */ +@Data +public class XhpcActivityTemplateDomain implements Serializable { + /** + * 模板ID + */ + private Integer activityTemplateId; + + /** + * 模板名称 + */ + private String templateName; + + /** + * 优惠类型（1-总金额，2-服务费，3-电量） + */ + private Short discountType; + + /** + * 优惠比率 + */ + private BigDecimal discountRate; + + /** + * 开始时间 + */ + private Date startTime; + + /** + * 结束时间 + */ + private Date endTime; + + /** + * 折扣次数 + */ + private Short discountCount; + + /** + * 小程序弹出次数 + */ + private Short miniDisplay; + + /** + * 活动背景图 + */ + private String backgroundUrl; + + /** + * 状态（0-编辑未发布,1-已发布，2-已失效） + */ + private Short status; + + /** + * 删除标识（0-正常，2-删除） + */ + private Short delFlag; + + /** + * 租户ID + */ + private String tenantId; + + /** + * 创建人 + */ + private String createBy; + + /** + * 创建时间 + */ + private Date createTime; + + /** + * 更新人 + */ + private String updateBy; + + /** + * 更新时间 + */ + private Date updateTime; + + private static final long serialVersionUID = 1L; +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/enums/ActivityTypeEnum.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/enums/ActivityTypeEnum.java new file mode 100644 index 00000000..841fd551 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/enums/ActivityTypeEnum.java @@ -0,0 +1,51 @@ +package com.xhpc.activity.enums; + + + +public enum ActivityTypeEnum { + + CASH("CASH", "现金活动"), + DISCOUNT("DISCOUNT", "折扣活动"), + ; + + + private final String code; + private final String name; + + ActivityTypeEnum(String code, String name){ + this.code = code; + this.name = name; + } + + //根据code获取name + public static String getNameByCode(String code) { + for (ActivityTypeEnum typeEnum : ActivityTypeEnum.values()) { + //移除交办 + if (typeEnum.code.equals(code)) { + return typeEnum.name; + } + } + return ""; + } + + //根据name获取code + public static String getCodeByName(String name) { + for (ActivityTypeEnum typeEnum : ActivityTypeEnum.values()) { + //移除交办 + if (typeEnum.name.equals(name)) { + return typeEnum.code; + } + } + return null; + } + + public String getCode() { + + return code; + } + + public String getName() { + + return name; + } +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityCashMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityCashMapper.java new file mode 100644 index 00000000..baf78e32 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityCashMapper.java @@ -0,0 +1,39 @@ +package com.xhpc.activity.mapper; + + +import com.xhpc.activity.domain.XhpcActivityCashDomain; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityCashMapper { + + List selectByParams(@Param("params") Map params); + + List> selectNameMapList(@Param("params")Map params); + + int deleteLogicByPrimaryKey(Integer activity_id); + + int deleteByPrimaryKey(Integer activity_id); + + int insert(XhpcActivityCashDomain record); + + XhpcActivityCashDomain selectByPrimaryKey(Integer activity_id); + + int updateByPrimaryKey(XhpcActivityCashDomain record); + + int updateStatusByPrimaryKey(XhpcActivityCashDomain record); + + int checkByPrimaryKey(XhpcActivityCashDomain record); + + int updateReceiveCountByActivityId(XhpcActivityCashDomain record); + + List> selectAPPUserListByUserIds(@Param("userIds") String userIds); + + List> selectComUserListByUserIds(@Param("userIds") String userIds); + + List> selectBUserListByUserIds(@Param("userIds") String userIds); + + List> selectUserListByParams(@Param("params")Map params); +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityDiscountMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityDiscountMapper.java new file mode 100644 index 00000000..534fb10f --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityDiscountMapper.java @@ -0,0 +1,39 @@ +package com.xhpc.activity.mapper; + + +import com.xhpc.activity.domain.XhpcActivityDiscountDomain; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityDiscountMapper { + + List selectByParams(@Param("params") Map params); + + List> selectNameMapList(@Param("params")Map params); + + int deleteLogicByPrimaryKey(Integer activity_id); + + int deleteByPrimaryKey(Integer activity_id); + + int insert(XhpcActivityDiscountDomain record); + + XhpcActivityDiscountDomain selectByPrimaryKey(Integer activity_id); + + int updateByPrimaryKey(XhpcActivityDiscountDomain record); + + int checkByPrimaryKey(XhpcActivityDiscountDomain record); + + int updateStatusByPrimaryKey(XhpcActivityDiscountDomain record); + + int updateStatusByTemplateId(@Param("templateId") Integer templateId, @Param("status") Short status); + + List> selectAPPUserListByUserIds(@Param("userIds") String userIds); + + List> selectComUserListByUserIds(@Param("userIds") String userIds); + + List> selectBUserListByUserIds(@Param("userIds") String userIds); + + List> selectUserListByParams(@Param("params")Map params); +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityFormulaMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityFormulaMapper.java new file mode 100644 index 00000000..4a0dbfa0 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityFormulaMapper.java @@ -0,0 +1,19 @@ +package com.xhpc.activity.mapper; + +import com.xhpc.activity.domain.XhpcActivityFormulaDomain; + +import java.util.List; + +public interface XhpcActivityFormulaMapper { + int deleteByPrimaryKey(Long activityFormulaId); + + int insert(XhpcActivityFormulaDomain record); + + XhpcActivityFormulaDomain selectByPrimaryKey(Long activityFormulaId); + + int updateByPrimaryKey(XhpcActivityFormulaDomain record); + + List selectByActivityId(Integer activityId); + + int deleteByActivityId(Integer activityId); +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityImgMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityImgMapper.java new file mode 100644 index 00000000..d8a301e2 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityImgMapper.java @@ -0,0 +1,24 @@ +package com.xhpc.activity.mapper; + + +import com.xhpc.activity.domain.XhpcActivityImgDomain; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +public interface XhpcActivityImgMapper { + + List selectListByActivityId(@Param("activityId") Integer activityId, @Param("activityType") String activityType); + + int deleteLogicByActivityId(@Param("activityId") Integer activityId, @Param("activityType") String activityType); + + int deleteLogicByPrimaryKey(Long activity_img_id); + + int deleteByPrimaryKey(Long activity_img_id); + + int insert(XhpcActivityImgDomain record); + + XhpcActivityImgDomain selectByPrimaryKey(Long activity_img_id); + + int updateByPrimaryKey(XhpcActivityImgDomain record); +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityInternetMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityInternetMapper.java new file mode 100644 index 00000000..9193e779 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityInternetMapper.java @@ -0,0 +1,30 @@ +package com.xhpc.activity.mapper; + + +import com.xhpc.activity.domain.XhpcActivityInternetDomain; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityInternetMapper { + + List selectByParams(@Param("params") Map params); + + List> selectNameMapList(@Param("params")Map params); + + int deleteLogicByPrimaryKey(Integer activity_id); + + int deleteByPrimaryKey(Integer activity_id); + + int insert(XhpcActivityInternetDomain record); + + XhpcActivityInternetDomain selectByPrimaryKey(Integer activity_id); + + int updateByPrimaryKey(XhpcActivityInternetDomain record); + + int updateStatusByPrimaryKey(XhpcActivityInternetDomain record); + + int checkByPrimaryKey(XhpcActivityInternetDomain record); + +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityRecordMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityRecordMapper.java new file mode 100644 index 00000000..52b068f7 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityRecordMapper.java @@ -0,0 +1,29 @@ +package com.xhpc.activity.mapper; + +import com.xhpc.activity.domain.XhpcActivityRecordDomain; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityRecordMapper { + + XhpcActivityRecordDomain selectByActivityAndUser(@Param("activityType") String activityType, + @Param("activityId") Integer activityId, + @Param("userId") String userId); + + List selectByActivity(@Param("activityType") String activityType, + @Param("activityId") Integer activityId); + + List> selectByParams(@Param("params") Map params); + + int deleteLogicByPrimaryKey(Long activity_record_id); + + int deleteByPrimaryKey(Long activity_record_id); + + int insert(XhpcActivityRecordDomain record); + + XhpcActivityRecordDomain selectByPrimaryKey(Long activity_record_id); + + int updateByPrimaryKey(XhpcActivityRecordDomain record); +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityTemplateMapper.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityTemplateMapper.java new file mode 100644 index 00000000..fc55598e --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/mapper/XhpcActivityTemplateMapper.java @@ -0,0 +1,26 @@ +package com.xhpc.activity.mapper; + +import com.xhpc.activity.domain.XhpcActivityTemplateDomain; +import org.apache.ibatis.annotations.Param; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityTemplateMapper { + + List selectByParams(@Param("params") Map params); + + List> selectNameMapList(@Param("params")Map params); + + int deleteLogicByPrimaryKey(Integer activity_temlpate_id); + + int deleteByPrimaryKey(Integer activity_temlpate_id); + + int insert(XhpcActivityTemplateDomain record); + + XhpcActivityTemplateDomain selectByPrimaryKey(Integer activity_temlpate_id); + + int updateByPrimaryKey(XhpcActivityTemplateDomain record); + + int updateStatusByPrimaryKey(XhpcActivityTemplateDomain record); +} \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityCashService.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityCashService.java new file mode 100644 index 00000000..ad7adf04 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityCashService.java @@ -0,0 +1,34 @@ +package com.xhpc.activity.service; + +import com.xhpc.activity.domain.XhpcActivityCashDomain; +import com.xhpc.activity.domain.XhpcActivityRecordDomain; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityCashService { + + List getPage(Map params); + + List> getNameList(Map params); + + XhpcActivityCashDomain getDomainByPk(Integer activityId); + + boolean insertDomain(XhpcActivityCashDomain domain); + + boolean updateDomain(XhpcActivityCashDomain domain); + + boolean checkDomain(XhpcActivityCashDomain domain); + + boolean updateDomainStatus(XhpcActivityCashDomain domain); + + boolean deleteByPk(Integer activityId); + + List> getUserList(Map params); + + // ---------- 红包领取 -------- + boolean insertReceiveDomain(XhpcActivityRecordDomain domain); + + List> getReceivePage(Map params); + +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityDiscountService.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityDiscountService.java new file mode 100644 index 00000000..c283a8fd --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityDiscountService.java @@ -0,0 +1,27 @@ +package com.xhpc.activity.service; + +import com.xhpc.activity.domain.XhpcActivityDiscountDomain; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityDiscountService { + + List getPage(Map params); + + List> getNameList(Map params); + + XhpcActivityDiscountDomain getDomainByPk(Integer activityId); + + boolean insertDomain(XhpcActivityDiscountDomain domain); + + boolean updateDomain(XhpcActivityDiscountDomain domain); + + boolean checkDomain(XhpcActivityDiscountDomain domain); + + boolean updateDomainStatus(XhpcActivityDiscountDomain domain); + + boolean deleteByPk(Integer activityId); + + List> getUserList(Map params); +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityInternetService.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityInternetService.java new file mode 100644 index 00000000..fe8abc56 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityInternetService.java @@ -0,0 +1,25 @@ +package com.xhpc.activity.service; + +import com.xhpc.activity.domain.XhpcActivityInternetDomain; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityInternetService { + + List getPage(Map params); + + List> getNameList(Map params); + + XhpcActivityInternetDomain getDomainByPk(Integer activityId); + + boolean insertDomain(XhpcActivityInternetDomain domain); + + boolean updateDomain(XhpcActivityInternetDomain domain); + + boolean updateDomainStatus(XhpcActivityInternetDomain domain); + + boolean checkDomain(XhpcActivityInternetDomain domain); + + boolean deleteByPk(Integer activityId); +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityTemplateService.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityTemplateService.java new file mode 100644 index 00000000..9510c6fa --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/XhpcActivityTemplateService.java @@ -0,0 +1,23 @@ +package com.xhpc.activity.service; + +import com.xhpc.activity.domain.XhpcActivityTemplateDomain; + +import java.util.List; +import java.util.Map; + +public interface XhpcActivityTemplateService { + + List getPage(Map params); + + List> getNameList(Map params); + + XhpcActivityTemplateDomain getDomainByPk(Integer templateId); + + boolean insertDomain(XhpcActivityTemplateDomain domain); + + boolean updateDomain(XhpcActivityTemplateDomain domain); + + boolean updateDomainStatus(XhpcActivityTemplateDomain domain); + + boolean deleteByPk(Integer templateId); +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityCashServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityCashServiceImpl.java new file mode 100644 index 00000000..e39fc63c --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityCashServiceImpl.java @@ -0,0 +1,167 @@ +package com.xhpc.activity.service.impl; + +import com.xhpc.activity.domain.XhpcActivityCashDomain; +import com.xhpc.activity.domain.XhpcActivityImgDomain; +import com.xhpc.activity.domain.XhpcActivityRecordDomain; +import com.xhpc.activity.enums.ActivityTypeEnum; +import com.xhpc.activity.mapper.XhpcActivityCashMapper; +import com.xhpc.activity.mapper.XhpcActivityImgMapper; +import com.xhpc.activity.mapper.XhpcActivityRecordMapper; +import com.xhpc.activity.service.XhpcActivityCashService; +import com.xhpc.common.core.exception.CustomException; +import com.xhpc.common.core.web.service.BaseService; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; + + +@Service +@Transactional +public class XhpcActivityCashServiceImpl extends BaseService implements XhpcActivityCashService { + + + @Resource + XhpcActivityCashMapper cashMapper; + + @Resource + XhpcActivityImgMapper imgMapper; + + @Resource + XhpcActivityRecordMapper recordMapper; + + + @Override + public List getPage(Map params){ + + List domainList = cashMapper.selectByParams(params); + + return domainList; + } + + + @Override + public List> getNameList(Map params){ + return cashMapper.selectNameMapList(params); + } + + @Override + public XhpcActivityCashDomain getDomainByPk(Integer activityId){ + XhpcActivityCashDomain domain = cashMapper.selectByPrimaryKey(activityId); + List checkImgList = imgMapper.selectListByActivityId(activityId, ActivityTypeEnum.CASH.getCode()); + domain.setCheckImgList(checkImgList); + return domain; + } + + + @Override + public boolean insertDomain(XhpcActivityCashDomain domain){ + + cashMapper.insert(domain); + + for(XhpcActivityImgDomain imgDomain: domain.getCheckImgList()){ + imgDomain.setActivityType(ActivityTypeEnum.CASH.getCode()); + imgDomain.setActivityId(domain.getActivityId()); + imgMapper.insert(imgDomain); + } + + return true; + } + + + @Override + public boolean updateDomain(XhpcActivityCashDomain domain){ + cashMapper.updateByPrimaryKey(domain); + + imgMapper.deleteLogicByActivityId(domain.getActivityId(), ActivityTypeEnum.CASH.getCode()); + for(XhpcActivityImgDomain imgDomain: domain.getCheckImgList()){ + imgDomain.setActivityType(ActivityTypeEnum.CASH.getCode()); + imgDomain.setActivityId(domain.getActivityId()); + imgMapper.insert(imgDomain); + } + return true; + } + + + @Override + public boolean checkDomain(XhpcActivityCashDomain domain){ + return cashMapper.checkByPrimaryKey(domain) > 0; + } + + + @Override + public boolean updateDomainStatus(XhpcActivityCashDomain domain){ + return cashMapper.updateStatusByPrimaryKey(domain) > 0; + } + + + @Override + public boolean deleteByPk(Integer activityId){ + + return cashMapper.deleteLogicByPrimaryKey(activityId) > 0; + } + + + + @Override + public List> getUserList(Map params){ + XhpcActivityCashDomain cashDomain = cashMapper.selectByPrimaryKey(Integer.parseInt(params.get("activityId").toString())); + + + String appUserIds = ""; + if(cashDomain.getAppUserList() != null){ + appUserIds = cashDomain.getAppUserList(); + } + + String comUserIds = ""; + if(cashDomain.getComUserList() != null){ + comUserIds = cashDomain.getComUserList(); + } + + String bUserIds = ""; + if(cashDomain.getCusUserList() != null){ + bUserIds = cashDomain.getCusUserList(); + } + + params.put("appUserIds", appUserIds); + params.put("comUserIds", comUserIds); + params.put("bUserIds", bUserIds); + + startPage(); + List> userList = cashMapper.selectUserListByParams(params); + return userList; + } + + + // ---------- 红包领取 -------- + @Override + public boolean insertReceiveDomain(XhpcActivityRecordDomain domain){ + + XhpcActivityCashDomain cashDomain = cashMapper.selectByPrimaryKey(domain.getActivityId()); + if(cashDomain == null){ + throw new CustomException("活动不存在"); + } + + XhpcActivityRecordDomain recordDomain = recordMapper.selectByActivityAndUser(domain.getActivityType(), + domain.getActivityId(), domain.getUserId()); + if(recordDomain != null){ + throw new CustomException("您已参与该活动，请勿重复领取"); + } + + recordMapper.insert(domain); + + cashDomain.setReceiveCount(cashDomain.getReceiveCount() + 1); + cashMapper.updateReceiveCountByActivityId(cashDomain); + + return true; + } + + + @Override + public List> getReceivePage(Map params){ + params.put("activityType", ActivityTypeEnum.CASH.getCode()); + return recordMapper.selectByParams(params); + } +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityDiscountServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityDiscountServiceImpl.java new file mode 100644 index 00000000..aa483605 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityDiscountServiceImpl.java @@ -0,0 +1,123 @@ +package com.xhpc.activity.service.impl; + +import com.xhpc.activity.domain.XhpcActivityDiscountDomain; +import com.xhpc.activity.domain.XhpcActivityTemplateDomain; +import com.xhpc.activity.mapper.XhpcActivityDiscountMapper; +import com.xhpc.activity.mapper.XhpcActivityTemplateMapper; +import com.xhpc.activity.service.XhpcActivityDiscountService; +import com.xhpc.common.core.exception.CustomException; +import com.xhpc.common.core.web.service.BaseService; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; + + +@Service +@Transactional +public class XhpcActivityDiscountServiceImpl extends BaseService implements XhpcActivityDiscountService { + + + @Resource + XhpcActivityDiscountMapper discountMapper; + + @Resource + XhpcActivityTemplateMapper templateMapper; + + + @Override + public List getPage(Map params){ + return discountMapper.selectByParams(params); + } + + + @Override + public List> getNameList(Map params){ + return discountMapper.selectNameMapList(params); + } + + + @Override + public XhpcActivityDiscountDomain getDomainByPk(Integer activityId) { + XhpcActivityDiscountDomain discountDomain = discountMapper.selectByPrimaryKey(activityId); + discountDomain.setTemplateDomain(templateMapper.selectByPrimaryKey(discountDomain.getTemplateId())); + return discountDomain; + } + + + @Override + public boolean insertDomain(XhpcActivityDiscountDomain domain){ + + XhpcActivityTemplateDomain templateDomain = templateMapper.selectByPrimaryKey(domain.getTemplateId()); + if(templateDomain == null){ + throw new CustomException("折扣模版不存在"); + } + + if(templateDomain.getStatus() != 0){ + throw new CustomException("折扣模版不能重复发布"); + } + + discountMapper.insert(domain); + + templateDomain.setStatus(Short.valueOf("1")); + templateDomain.setUpdateBy(domain.getCheckBy()); + templateMapper.updateStatusByPrimaryKey(templateDomain); + return true; + } + + + @Override + public boolean updateDomain(XhpcActivityDiscountDomain domain){ + return discountMapper.updateByPrimaryKey(domain) > 0; + } + + + @Override + public boolean checkDomain(XhpcActivityDiscountDomain domain){ + return discountMapper.checkByPrimaryKey(domain) > 0; + } + + + @Override + public boolean updateDomainStatus(XhpcActivityDiscountDomain domain){ + return discountMapper.updateStatusByPrimaryKey(domain) > 0; + } + + + @Override + public boolean deleteByPk(Integer activityId){ + return discountMapper.deleteLogicByPrimaryKey(activityId) > 0; + } + + + @Override + public List> getUserList(Map params){ + XhpcActivityDiscountDomain discountDomain = discountMapper.selectByPrimaryKey(Integer.parseInt(params.get("activityId").toString())); + + + String appUserIds = ""; + if(discountDomain.getAppUserList() != null){ + appUserIds = discountDomain.getAppUserList(); + } + + String comUserIds = ""; + if(discountDomain.getComUserList() != null){ + comUserIds = discountDomain.getComUserList(); + } + + String bUserIds = ""; + if(discountDomain.getCusUserList() != null){ + bUserIds = discountDomain.getCusUserList(); + } + + params.put("appUserIds", appUserIds); + params.put("comUserIds", comUserIds); + params.put("bUserIds", bUserIds); + + startPage(); + List> userList = discountMapper.selectUserListByParams(params); + return userList; + } +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityInternetServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityInternetServiceImpl.java new file mode 100644 index 00000000..b4912b03 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityInternetServiceImpl.java @@ -0,0 +1,95 @@ +package com.xhpc.activity.service.impl; + +import com.xhpc.activity.domain.XhpcActivityFormulaDomain; +import com.xhpc.activity.domain.XhpcActivityInternetDomain; +import com.xhpc.activity.mapper.XhpcActivityFormulaMapper; +import com.xhpc.activity.mapper.XhpcActivityInternetMapper; +import com.xhpc.activity.service.XhpcActivityInternetService; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; + + +@Service +@Transactional +public class XhpcActivityInternetServiceImpl implements XhpcActivityInternetService { + + @Resource + XhpcActivityInternetMapper internetMapper; + + @Resource + XhpcActivityFormulaMapper formulaMapper; + + + @Override + public List getPage(Map params) { + return internetMapper.selectByParams(params); + } + + + @Override + public List> getNameList(Map params) { + return internetMapper.selectNameMapList(params); + } + + + @Override + public XhpcActivityInternetDomain getDomainByPk(Integer activityId) { + + XhpcActivityInternetDomain domain = internetMapper.selectByPrimaryKey(activityId); + domain.setFormulaList(formulaMapper.selectByActivityId(activityId)); + return domain; + } + + + @Override + public boolean insertDomain(XhpcActivityInternetDomain domain) { + internetMapper.insert(domain); + for (XhpcActivityFormulaDomain formulaDomain : domain.getFormulaList()) { + formulaDomain.setActivityId(domain.getActivityId()); + formulaDomain.setCreateBy(domain.getCreateBy()); + formulaDomain.setUpdateBy(domain.getUpdateBy()); + formulaMapper.insert(formulaDomain); + } + + return true; + } + + + @Override + public boolean updateDomain(XhpcActivityInternetDomain domain) { + internetMapper.updateByPrimaryKey(domain); + formulaMapper.deleteByActivityId(domain.getActivityId()); + + for (XhpcActivityFormulaDomain formulaDomain : domain.getFormulaList()) { + formulaDomain.setActivityId(domain.getActivityId()); + formulaDomain.setCreateBy(domain.getCreateBy()); + formulaDomain.setUpdateBy(domain.getUpdateBy()); + formulaMapper.insert(formulaDomain); + } + + + return true; + } + + + @Override + public boolean updateDomainStatus(XhpcActivityInternetDomain domain) { + return internetMapper.updateStatusByPrimaryKey(domain) > 0; + } + + + @Override + public boolean checkDomain(XhpcActivityInternetDomain domain){ + return internetMapper.checkByPrimaryKey(domain) > 0; + } + + + @Override + public boolean deleteByPk(Integer activityId) { + return internetMapper.deleteLogicByPrimaryKey(activityId) > 0; + } +} diff --git a/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityTemplateServiceImpl.java b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityTemplateServiceImpl.java new file mode 100644 index 00000000..7e720874 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/java/com/xhpc/activity/service/impl/XhpcActivityTemplateServiceImpl.java @@ -0,0 +1,70 @@ +package com.xhpc.activity.service.impl; + +import com.xhpc.activity.domain.XhpcActivityTemplateDomain; +import com.xhpc.activity.mapper.XhpcActivityDiscountMapper; +import com.xhpc.activity.mapper.XhpcActivityTemplateMapper; +import com.xhpc.activity.service.XhpcActivityTemplateService; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Map; + + +@Service +@Transactional +public class XhpcActivityTemplateServiceImpl implements XhpcActivityTemplateService { + + @Resource + XhpcActivityTemplateMapper templateMapper; + + + @Resource + XhpcActivityDiscountMapper discountMapper; + + + @Override + public List getPage(Map params){ + return templateMapper.selectByParams(params); + } + + + @Override + public List> getNameList(Map params){ + return templateMapper.selectNameMapList(params); + } + + + @Override + public XhpcActivityTemplateDomain getDomainByPk(Integer templateId) { + return templateMapper.selectByPrimaryKey(templateId); + } + + + @Override + public boolean insertDomain(XhpcActivityTemplateDomain domain){ + return templateMapper.insert(domain) > 0; + } + + + @Override + public boolean updateDomain(XhpcActivityTemplateDomain domain){ + return templateMapper.updateByPrimaryKey(domain) > 0; + } + + + @Override + public boolean updateDomainStatus(XhpcActivityTemplateDomain domain){ + if(domain.getStatus() == 2){ + discountMapper.updateStatusByTemplateId(domain.getActivityTemplateId(), Short.valueOf("4")); + } + + return templateMapper.updateStatusByPrimaryKey(domain) > 0; + } + + @Override + public boolean deleteByPk(Integer templateId){ + return templateMapper.deleteLogicByPrimaryKey(templateId) > 0; + } +} diff --git a/xhpc-modules/xhpc-activity/src/main/resources/banner.txt b/xhpc-modules/xhpc-activity/src/main/resources/banner.txt new file mode 100644 index 00000000..aef6befe --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/banner.txt @@ -0,0 +1,8 @@ +Spring Boot Version: ${spring-boot.version} +Spring Application Name: ${spring.application.name} + + __ ___ _ ____ ____ _ ____ _____ _____ _____ _______ __ + \ \/ / | | | _ \ / ___| / \ / ___|_ _|_ _\ \ / /_ _|_ _\ \ / / + \ /| |_| | |_) | | / _ \| | | | | | \ \ / / | | | | \ V / + / \| _ | __/| |___ / ___ \ |___ | | | | \ V / | | | | | | + /_/\_\_| |_|_| \____| /_/ \_\____| |_| |___| \_/ |___| |_| |_| diff --git a/xhpc-modules/xhpc-activity/src/main/resources/bootstrap.yml b/xhpc-modules/xhpc-activity/src/main/resources/bootstrap.yml new file mode 100644 index 00000000..3b6e66ea --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/bootstrap.yml @@ -0,0 +1,30 @@ + +# Tomcat +server: + port: 8912 + +# Spring +spring: + application: + # 应用名称 + name: xhpc-activity + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 127.0.0.1:8848 + config: + # 配置中心地址 + server-addr: 127.0.0.1:8848 + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} +logging: + level: + root: info + com.xhpc.activity.mapper: debug diff --git a/xhpc-modules/xhpc-activity/src/main/resources/logback.xml b/xhpc-modules/xhpc-activity/src/main/resources/logback.xml new file mode 100644 index 00000000..36669b77 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/logback.xml @@ -0,0 +1,75 @@ + + + + + + + + + + + ${log.pattern} + + + + + + ${log.path}/info.log + + + + ${log.path}/info.%d{yyyy-MM-dd}.log + + 60 + + + ${log.pattern} + + + + INFO + + ACCEPT + + DENY + + + + + ${log.path}/error.log + + + + ${log.path}/error.%d{yyyy-MM-dd}.log + + 60 + + + ${log.pattern} + + + + ERROR + + ACCEPT + + DENY + + + + + + + + + + + + + + + + + + diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityCashMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityCashMapper.xml new file mode 100644 index 00000000..04d4167a --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityCashMapper.xml @@ -0,0 +1,190 @@ + + + + + + + + + + + + + + + + + + + + + + + + + activity_id, activity_name, start_time, end_time, receive_count, amount, app_user_list, com_user_list, cus_user_list, + tenant_id, `status`, del_flag, create_by, create_time, update_by, update_time, check_by, + check_time + + + + + + + + + + + + + + update xhpc_activity_cash set del_flag=2 + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + delete from xhpc_activity_cash + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + insert into xhpc_activity_cash (start_time, end_time, amount, receive_count, + app_user_list, com_user_list, cus_user_list, + tenant_id, `status`, del_flag, + create_by, create_time, update_by, + update_time, check_by, check_time + ) + values (#{startTime,jdbcType=TIMESTAMP}, #{endTime,jdbcType=TIMESTAMP}, #{amount,jdbcType=DECIMAL}, 0, + #{appUserList,jdbcType=VARCHAR}, #{comUserList,jdbcType=VARCHAR}, #{cusUserList,jdbcType=VARCHAR}, + #{tenantId,jdbcType=VARCHAR}, 1, 0, + #{createBy,jdbcType=VARCHAR}, sysdate(), #{updateBy,jdbcType=VARCHAR}, + sysdate(), null, null + ) + + + + + update xhpc_activity_cash + set start_time = #{startTime,jdbcType=TIMESTAMP}, + end_time = #{endTime,jdbcType=TIMESTAMP}, + amount = #{amount,jdbcType=DECIMAL}, + app_user_list = #{appUserList,jdbcType=VARCHAR}, + com_user_list = #{comUserList,jdbcType=VARCHAR}, + cus_user_list = #{cusUserList,jdbcType=VARCHAR}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + update xhpc_activity_cash + set `status` = #{status,jdbcType=SMALLINT}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + update xhpc_activity_cash + set `status` = #{status,jdbcType=SMALLINT}, + check_by = #{checkBy,jdbcType=VARCHAR}, + check_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + update xhpc_activity_cash + set receive_count = #{receiveCount} + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityDiscountMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityDiscountMapper.xml new file mode 100644 index 00000000..35ed33cb --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityDiscountMapper.xml @@ -0,0 +1,198 @@ + + + + + + + + + + + + + + + + + + + + + + + + + ad.activity_id, ad.activity_name, ad.template_id, ad.app_user_list, ad.com_user_list, ad.cus_user_list, + ad.station_list,ad.tenant_id, ad.start_time, ad.end_time, + ad.`status`, ad.del_flag, ad.create_by, ad.create_time, ad.update_by, ad.update_time, ad.check_by, ad.check_time + + + + + + + + + + + + + + update xhpc_activity_discount + set del_flag=2 + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + delete + from xhpc_activity_discount + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + insert into xhpc_activity_discount (activity_name, template_id, app_user_list, com_user_list, cus_user_list, + station_list, tenant_id, `status`, start_time, end_time, + del_flag, create_by, create_time, + update_by, update_time, + check_by, check_time) + values (#{activityName, jdbcType=VARCHAR}, #{templateId, jdbcType=INTEGER}, #{appUserList,jdbcType=VARCHAR}, + #{comUserList,jdbcType=VARCHAR}, #{cusUserList,jdbcType=VARCHAR}, + #{stationList,jdbcType=VARCHAR}, #{tenantId,jdbcType=VARCHAR}, #{status,jdbcType=SMALLINT}, + #{startTime, jdbcType=TIMESTAMP}, #{endTime, jdbcType=TIMESTAMP}, + 0, #{createBy,jdbcType=VARCHAR}, sysdate(), + #{updateBy,jdbcType=VARCHAR}, sysdate(), null, null) + + + + + update xhpc_activity_discount + set activity_name = #{activityName,jdbcType=VARCHAR}, + app_user_list = #{appUserList,jdbcType=VARCHAR}, + com_user_list = #{comUserList,jdbcType=VARCHAR}, + cus_user_list = #{cusUserList,jdbcType=VARCHAR}, + station_list = #{stationList,jdbcType=VARCHAR}, + start_time = #{startTime, jdbcType=TIMESTAMP}, + end_time = #{endTime, jdbcType=TIMESTAMP}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + update xhpc_activity_discount + set `status` = #{status,jdbcType=SMALLINT}, + check_by = #{checkBy,jdbcType=VARCHAR}, + check_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + update xhpc_activity_discount + set `status` = #{status,jdbcType=SMALLINT}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + update xhpc_activity_discount + set status=#{status} + where status = 3 + and template_id = #{templateId} + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityFormulaMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityFormulaMapper.xml new file mode 100644 index 00000000..651be528 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityFormulaMapper.xml @@ -0,0 +1,77 @@ + + + + + + + + + + + + + + + + + activity_formula_id + , activity_id, start_time, end_time, service_price, compute_formula, create_time, + create_by, update_time, update_by + + + + + + + + delete + from xhpc_activity_formula + where activity_id = #{activityId} + + + + + + + + delete + from xhpc_activity_formula + where activity_formula_id = #{activityFormulaId,jdbcType=BIGINT} + + + + + insert into xhpc_activity_formula (activity_id, start_time, end_time, + service_price, compute_formula, create_time, create_by, + update_time, update_by) + values (#{activityId,jdbcType=INTEGER}, #{startTime}, #{endTime}, + #{servicePrice}, #{computeFormula,jdbcType=VARCHAR}, sysdate(), #{createBy,jdbcType=VARCHAR}, + sysdate(), #{updateBy,jdbcType=VARCHAR}) + + + + + update xhpc_activity_formula + set activity_id = #{activityId,jdbcType=INTEGER}, + start_time = #{startTime}, + end_time = #{endTime}, + service_price = #{servicePrice}, + compute_formula = #{computeFormula,jdbcType=VARCHAR}, + update_time = sysdate(), + update_by = #{updateBy,jdbcType=VARCHAR} + where activity_formula_id = #{activityComputeId,jdbcType=BIGINT} + + + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityImgMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityImgMapper.xml new file mode 100644 index 00000000..17f4b6ff --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityImgMapper.xml @@ -0,0 +1,75 @@ + + + + + + + + + + + + + + + activity_img_id, activity_type, activity_id, img_name, img_url, del_flag, create_by, + create_time + + + + + + + + update xhpc_activity_img set del_flag=2 + where activity_type=#{activityType} and activity_id=#{activityId} + + + + + + + + update xhpc_activity_img set del_flag=2 + where activity_img_id = #{activityImgId,jdbcType=BIGINT} + + + + + delete from xhpc_activity_img + where activity_img_id = #{activityImgId,jdbcType=BIGINT} + + + + + insert into xhpc_activity_img (activity_type, activity_id, img_name, + img_url, del_flag, create_by, + create_time) + values (#{activityType,jdbcType=VARCHAR}, #{activityId,jdbcType=INTEGER}, #{imgName,jdbcType=VARCHAR}, + #{imgUrl,jdbcType=VARCHAR}, 0, #{createBy,jdbcType=VARCHAR}, + sysdate()) + + + + + update xhpc_activity_img + set activity_type = #{activityType,jdbcType=VARCHAR}, + activity_id = #{activityId,jdbcType=INTEGER}, + img_name = #{imgName,jdbcType=VARCHAR}, + img_url = #{imgUrl,jdbcType=VARCHAR}, + create_by = #{createBy,jdbcType=VARCHAR}, + create_time = sysdate() + where activity_img_id = #{activityImgId,jdbcType=BIGINT} + + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityInternetMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityInternetMapper.xml new file mode 100644 index 00000000..20df3925 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityInternetMapper.xml @@ -0,0 +1,130 @@ + + + + + + + + + + + + + + + + + + + + + + + + + activity_id + , activity_name, internet_name, compute_type, service_price, compute_formula, start_time, + end_time, station_list, tenant_id, `status`, del_flag, create_by, create_time, update_by, + update_time, check_by, check_time + + + + + + + + + + + + + + update xhpc_activity_internet + set del_flag=2 + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + delete + from xhpc_activity_internet + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + insert into xhpc_activity_internet (activity_name, internet_name, compute_type, + service_price, compute_formula, start_time, end_time, + station_list, tenant_id, `status`, + del_flag, create_by, create_time, + update_by, update_time, check_by, check_time) + values (#{activityName,jdbcType=VARCHAR}, #{internetName,jdbcType=VARCHAR}, #{computeType,jdbcType=SMALLINT}, + #{servicePrice}, #{computeFormula,jdbcType=VARCHAR}, #{startTime,jdbcType=TIMESTAMP}, + #{endTime,jdbcType=TIMESTAMP}, + #{stationList,jdbcType=VARCHAR}, #{tenantId,jdbcType=VARCHAR}, #{status,jdbcType=SMALLINT}, + 0, #{createBy,jdbcType=VARCHAR}, sysdate(), + #{updateBy,jdbcType=VARCHAR}, sysdate(), null, null) + + + + + update xhpc_activity_internet + set activity_name = #{activityName,jdbcType=VARCHAR}, + internet_name = #{internetName,jdbcType=VARCHAR}, + compute_type = #{computeType,jdbcType=SMALLINT}, + service_price = #{servicePrice}, + compute_formula = #{computeFormula,jdbcType=VARCHAR}, + start_time = #{startTime,jdbcType=TIMESTAMP}, + end_time = #{endTime,jdbcType=TIMESTAMP}, + station_list = #{stationList,jdbcType=VARCHAR}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + update xhpc_activity_internet + set `status` = #{status,jdbcType=SMALLINT}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + + update xhpc_activity_internet + set `status` = #{status,jdbcType=SMALLINT}, + check_by = #{updateBy,jdbcType=VARCHAR}, + check_time = sysdate() + where activity_id = #{activityId,jdbcType=INTEGER} + + + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityRecordMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityRecordMapper.xml new file mode 100644 index 00000000..068e95c8 --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityRecordMapper.xml @@ -0,0 +1,106 @@ + + + + + + + + + + + + + + activity_record_id, activity_type, activity_id, `source`, user_id, amount, create_time + + + + + + + + + + + + + + + + + update xhpc_activity_record set del_flag=2 + where activity_record_id = #{activityRecordId,jdbcType=BIGINT} + + + + + delete from xhpc_activity_record + where activity_record_id = #{activityRecordId,jdbcType=BIGINT} + + + + + insert into xhpc_activity_record (activity_type, activity_id, `source`, + user_id, amount, create_time + ) + values (#{activityType,jdbcType=VARCHAR}, #{activityId,jdbcType=INTEGER}, #{source,jdbcType=SMALLINT}, + #{userId,jdbcType=VARCHAR}, #{amount,jdbcType=DECIMAL}, sysdate() + ) + + + + + update xhpc_activity_record + set activity_type = #{activityType,jdbcType=VARCHAR}, + activity_id = #{activityId,jdbcType=INTEGER}, + `source` = #{source,jdbcType=SMALLINT}, + user_id = #{userId,jdbcType=VARCHAR}, + amount = #{amount,jdbcType=DECIMAL}, + create_time = sysdate() + where activity_record_id = #{activityRecordId,jdbcType=BIGINT} + + \ No newline at end of file diff --git a/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityTemplateMapper.xml b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityTemplateMapper.xml new file mode 100644 index 00000000..e7b59fdf --- /dev/null +++ b/xhpc-modules/xhpc-activity/src/main/resources/mapper/XhpcActivityTemplateMapper.xml @@ -0,0 +1,118 @@ + + + + + + + + + + + + + + + + + + + + + + + activity_template_id, template_name, discount_type, discount_rate, start_time, end_time, + discount_count, mini_display, background_url, `status`, del_flag, tenant_id, create_by, + create_time, update_by, update_time + + + + + + + + + + + + + + + update xhpc_activity_template set del_flag=2 + where activity_template_id = #{activityTemplateId} + + + + + delete from xhpc_activity_template + where activity_template_id = #{activityTemplateId} + + + + + insert into xhpc_activity_template (template_name, discount_type, discount_rate, + start_time, end_time, discount_count, + mini_display, background_url, `status`, + del_flag, tenant_id, create_by, + create_time, update_by, update_time + ) + values (#{templateName,jdbcType=VARCHAR}, #{discountType,jdbcType=SMALLINT}, #{discountRate,jdbcType=DECIMAL}, + #{startTime,jdbcType=TIMESTAMP}, #{endTime,jdbcType=TIMESTAMP}, #{discountCount,jdbcType=SMALLINT}, + #{miniDisplay,jdbcType=SMALLINT}, #{backgroundUrl,jdbcType=VARCHAR}, #{status,jdbcType=SMALLINT}, + 0, #{tenantId,jdbcType=VARCHAR}, #{createBy,jdbcType=VARCHAR}, + sysdate(), #{updateBy,jdbcType=VARCHAR}, sysdate() + ) + + + + + update xhpc_activity_template + set template_name = #{templateName,jdbcType=VARCHAR}, + discount_type = #{discountType,jdbcType=SMALLINT}, + discount_rate = #{discountRate,jdbcType=DECIMAL}, + start_time = #{startTime,jdbcType=TIMESTAMP}, + end_time = #{endTime,jdbcType=TIMESTAMP}, + discount_count = #{discountCount,jdbcType=SMALLINT}, + mini_display = #{miniDisplay,jdbcType=SMALLINT}, + background_url = #{backgroundUrl,jdbcType=VARCHAR}, + `status` = #{status,jdbcType=SMALLINT}, + tenant_id = #{tenantId,jdbcType=VARCHAR}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = sysdate() + where activity_template_id = #{activityTemplateId} + + + + + update xhpc_activity_template + set `status` = #{status,jdbcType=SMALLINT}, + update_by = #{updateBy,jdbcType=VARCHAR}, + update_time = sysdate() + where activity_template_id = #{activityTemplateId} + + + \ No newline at end of file