123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245 |
- package com.agent.action.audit;
- import com.agent.action.common.AbstractController;
- import com.agent.constans.CommonConstants;
- import com.agent.constans.ConfigConstants;
- import com.agent.constans.TemplateConstants;
- import com.agent.model.audit.bean.DisplaceAuditBean;
- import com.agent.model.audit.service.DisplaceAuditService;
- import com.agent.model.bms.bean.UserBean;
- import com.agent.model.common.bean.PageResultBean;
- import com.agent.model.common.bean.ResultBean;
- import com.agent.model.digger.bean.DiggerBean;
- import com.agent.model.digger.service.DiggerBeanService;
- import com.agent.model.offer.service.OfferBeanService;
- import com.agent.model.pushrecord.bean.PushRecordBean;
- import com.agent.model.pushrecord.service.PushRecordBeanService;
- import com.agent.model.sale.bean.SalesBean;
- import com.agent.model.sale.service.SaleBeanService;
- import com.agent.model.shop.bean.AgentBean;
- import com.agent.model.shop.service.AgentBeanService;
- import com.agent.model.usercolumn.bean.UserColumnRoleBean;
- import com.agent.model.usermanage.service.UserManageService;
- import com.agent.model.wxInterface.bean.TemplateData;
- import com.agent.util.*;
- import com.alibaba.fastjson.JSON;
- import com.alibaba.fastjson.JSONObject;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.stereotype.Controller;
- import org.springframework.web.bind.annotation.ModelAttribute;
- import org.springframework.web.bind.annotation.RequestMapping;
- import org.springframework.web.bind.annotation.RequestParam;
- import org.springframework.web.bind.annotation.ResponseBody;
- import org.springframework.web.servlet.ModelAndView;
- import javax.servlet.http.HttpServletRequest;
- import javax.servlet.http.HttpServletResponse;
- import javax.servlet.http.HttpSession;
- import java.io.File;
- import java.io.IOException;
- import java.util.*;
- /**
- * 置换审核controller
- *
- */
- @Controller
- @RequestMapping("/audit")
- public class AuditController extends AbstractController{
- private static Logger log = LoggerFactory.getLogger(AuditController.class);
- /**
- * 置换审核service
- */
- @Autowired
- private DisplaceAuditService displaceAuditService;
- /**
- * 报价service
- */
- @Autowired
- private OfferBeanService offerBeanService;
- @Value("${wjj.api.domain}")
- private String wjjDomain;
- /**
- * 置换审核列表页(后台)
- */
- private final String PLAT_AUDIT_LIST = "audit/platAuditList";
- /**
- * 置换审核列表页(超级管理员)
- */
- private final String SUPER_ADMIN_AUDIT_LIST = "audit/superAdminAuditList";
- /**
- * 置换审核列表页(代理商-代运营)
- */
- private final String AGENT_AUDIT_LIST = "audit/agentAuditList";
- /**
- * 置换审核列表页(代理商-自运营)
- */
- private final String SINCE_AGENT_AUDIT_LIST = "audit/sinceAgentAuditList";
- /**
- * 置换审核列表页(管理员)
- */
- private final String ADMIN_AUDIT_LIST = "audit/adminAuditList";
- /**
- * 置换审核列表页(精品机)
- */
- private final String GOOD_AUDIT_LIST = "audit/goodAdminAuditList";
- /**
- * 登录页
- */
- private final String LOGIN_INDEX = "login/index";
- /**
- * 车商service
- */
- @Autowired
- private DiggerBeanService diggerBeanService;
- /**
- * 信息记录service
- */
- @Autowired
- private PushRecordBeanService pushRecordBeanService;
- /**
- * 销售员service
- */
- @Autowired
- private SaleBeanService saleBeanService;
- /**
- * 代理商service
- */
- @Autowired
- private AgentBeanService agentBeanService;
- //精品机配置
- @Value("${jpjgh}")
- private String jpjgh;
- /**
- * 载入置换审核列表页面
- * @param request
- * @param response
- * @return
- * @throws IOException
- */
- @RequestMapping("/toAuditList.do")
- public ModelAndView showShopList(HttpServletRequest request,
- HttpServletResponse response) throws Exception{
- //页面跳转
- ModelAndView mv;
- //获取登录信息
- HttpSession session = request.getSession();
- UserBean user = (UserBean)session.getAttribute(CommonConstants.USER_INFO);
- //如果是管理员,跳转到平台列表页,否则跳转到商家列表页
- if(user == null){
- //如果未登录,跳转到登录页
- return super.createJspView(LOGIN_INDEX);
- }
- log.info("进入置换审核页面,当前登录人信息 userAccount:" + user.getUserAccount() + ", userRank:" + user.getUserRank() + ", isAdmin:" + user.getIsAdmin() + ", agentType:" + user.getAgentType());
- if (UserBean.USER_RANK_SUPER_ADMIN.equals(user.getUserRank())) {
- mv = super.createJspView(SUPER_ADMIN_AUDIT_LIST);
- } else if (UserBean.USER_RANK_ADMIN.equals(user.getUserRank())) {
- mv = super.createJspView(ADMIN_AUDIT_LIST);
- }else if (UserBean.USER_RANK_GOOD.equals(user.getUserRank())) {
- mv = super.createJspView(GOOD_AUDIT_LIST);
- } else {
- // 判断是 自运营 还是 代运营
- if (UserBean.AGENT_TYPE_SINCE == user.getAgentType()) {
- mv = super.createJspView(SINCE_AGENT_AUDIT_LIST);
- } else {
- mv = super.createJspView(AGENT_AUDIT_LIST);
- }
- }
- //查询设备品牌
- //List<DbResultBean> ppList = offerBeanService.queryFlList(ConfigConstants.SBPP,"");
- //查询设备类型
- //List<DbResultBean> lxList = offerBeanService.queryFlList(ConfigConstants.SBLX,"");
- //页面跳转
- //mv.addObject("deviceBrands", ppList);
- //mv.addObject("deviceTypes", lxList);
- return mv;
- }
- @RequestMapping("/pushDisplaceAuditMessage.do")
- public void pushDisplaceAuditMessage(@RequestParam String agentId, @RequestParam String saleId, @RequestParam String displaceId,
- HttpServletRequest request, HttpServletResponse response) {
- log.info("调用推送置换审核微信信息(/audit/pushDisplaceAuditMessage.do)接口, agentId:" + agentId + ", saleId:" + saleId + ", displaceId:" + displaceId);
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE, "成功");
- try {
- HttpSession session = request.getSession();
- UserBean user = (UserBean)session.getAttribute(CommonConstants.USER_INFO);
- if(user == null) {
- resultBean = new ResultBean(PageResultBean.FAIL_CODE, "请先登录!");
- return;
- }
- final String apiUrl = wjjDomain + "wechat/pushDisplaceAuditMessage";
- // final String apiUrl = "http://localhost:8082/" + "wechat/pushDisplaceAuditMessage";
- Map<String, Object> requestParams = new HashMap<>();
- requestParams.put("agentId", agentId);
- requestParams.put("saleId", saleId);
- requestParams.put("displaceId", displaceId);
- final HttpResult httpResult = HttpUtils.post(apiUrl, requestParams);
- if (httpResult.getStatusCode() != 200) {
- log.info("调用wjj-api推送置换审核微信消息失败, statusCode:{}", httpResult.getStatusCode());
- resultBean= new ResultBean(PageResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- } else {
- final String content = httpResult.getContent();
- log.info("调用wjj-api推送置换审核微信消息, 响应内容:{}", content);
- if (org.apache.commons.lang3.StringUtils.isBlank(content)) {
- log.info("调用wjj-api推送置换审核微信消息, 响应内容为空");
- } else {
- final JSONObject jsonObject = JSON.parseObject(content);
- final Integer code = jsonObject.getInteger("code");
- String message = jsonObject.getString("message");
- message = StringUtils.isBlank(message) ? "系统繁忙,请稍后再来!" : message;
- if (code == 0) {
- resultBean = new ResultBean(ResultBean.FAIL_CODE, message);
- }
- }
- }
- } catch (Exception e) {
- resultBean= new ResultBean(PageResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- log.error("调用推送置换审核微信信息异常", e);
- }finally{
- super.printResult(request, response, resultBean.toString());
- }
- }
- @RequestMapping("/showDaili.do")
- public void showDaili(@RequestParam String agentId, HttpServletRequest request, HttpServletResponse response){
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE, "成功");
- AgentBean bean=agentBeanService.getAgentBeanByAgentId(agentId);
- if(bean.getIsAttent().equals("1")){
- super.printResult(request,response,resultBean.toString());
- }else{
- resultBean.setResult("该设备没有同步到微工程,不能同步推送");
- super.printResult(request,response,resultBean.toString());
- }
- }
- @RequestMapping("/showDailiAll.do")
- public void showDailiAll(HttpServletRequest request, HttpServletResponse response,@RequestParam String agentIds){
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE, "成功");
- String [] allstr=agentIds.split("=");
- String agentId=allstr[0];
- String zhihuanId=allstr[1];
- int pageszie=Integer.parseInt( request.getParameter("pagesize"));
- int page =Integer.parseInt(request.getParameter("page"));
- String mutiStatus=request.getParameter("mutiStatus");
- String focusBrandNames=request.getParameter("focusBrandNames");
- if(StringUtils.isNotBlank(agentId)){
- AgentBean bean=agentBeanService.getAgentBeanByAgentId(agentId);
- if(bean.getIsAttent().equals("1")) {
- List<AgentBean> all= agentBeanService.findAgent();
- List<DiggerBean> alldig=new ArrayList<>();
- List<DiggerBean> list = diggerBeanService.getDiggerss(agentId,page,pageszie,mutiStatus,focusBrandNames);
- // List<DiggerBean> list = diggerBeanService.getDiggerss("WGC000",page,pageszie,mutiStatus,focusBrandNames);
- Map<String,Object> map=new HashMap<>();
- map.put("list",list);
- map.put("zhihuanId",zhihuanId);
- map.put("totalNum",diggerBeanService.getDiggersss(agentId,page,pageszie,mutiStatus,focusBrandNames).size());
- resultBean.setResult(map);
- super.printResult(request,response,resultBean.toString());
- }else {
- resultBean.setResult("该设备没有同步到微工程,不能同步推送");
- super.printResult(request,response,resultBean.toString());
- }
- }
- }
- @RequestMapping("/selectDailiAll.do")
- public void selectDailiAll(HttpServletRequest request, HttpServletResponse response,@RequestParam String agentIds){
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE, "成功");
- // String displaceid=request.getParameter("displaceId");
- String mutiStatus=request.getParameter("mutiStatus");
- String focusBrandNames=request.getParameter("focusBrandNames");
- String [] allstr=agentIds.split("=");
- String agentId=allstr[0];
- String zhihuanId=allstr[1];
- if(StringUtils.isNotBlank(agentId)) {
- AgentBean bean=agentBeanService.getAgentBeanByAgentId(agentId);
- if(bean.getIsAttent().equals("1")) {
- List<DiggerBean> list=diggerBeanService.getDiggersss(agentId, 0, 0, mutiStatus, focusBrandNames);
- resultBean.setResult(list);
- resultBean.setMessage(zhihuanId);
- super.printResult(request,response,resultBean.toString());
- }else {
- resultBean.setResult("该设备没有同步到微工程,不能同步推送");
- super.printResult(request,response,resultBean.toString());
- }
- }
- }
- /**
- * 搜索置换审核记录分页列表-自运营
- * @param request
- * @param response
- */
- @RequestMapping("/sinceAuditList.do")
- public void sinceAuditList(HttpServletRequest request, HttpServletResponse response){
- //返回页面数据
- PageResultBean resultBean = null;
- try {
- //获取登录信息
- HttpSession session = request.getSession();
- UserBean user = (UserBean)session.getAttribute(CommonConstants.USER_INFO);
- if(user == null) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "请先登录!");
- return;
- }
- //如果不是平台用户的话,则只能搜索到他本身的商家报价信息
- String agentId = "";
- if(!"1".equals(user.getIsAdmin())){
- agentId = user.getAgentId();
- }else {
- agentId = super.getParameter(request, "agentId");
- }
- // 当前页码
- String currentPage = super.getParameter(request, "currentPage");
- // 分页记录数
- String pageSize = super.getParameter(request, "pageSize");
- int currentPageInt = 1;
- int pageSizeInt = 10;
- if(StringUtils.isNotEmpty(currentPage)){
- try {
- currentPageInt = Integer.parseInt(currentPage);
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入正确的页数!");
- return;
- }
- }
- if(StringUtils.isNotEmpty(pageSize)){
- try {
- pageSizeInt = Integer.parseInt(pageSize);
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入正确的分页数!");
- return;
- }
- }
- // 条件查询参数
- String brandCode = "sbpp";
- String brandContent = super.getParameter(request, "brandContent");
- String typeCode = "sblx";
- String typeContent = super.getParameter(request, "typeContent");
- String auditStatus = super.getParameter(request, "auditStatus");
- String startTimeStr = super.getParameter(request, "startTime");
- String endTimeStr = super.getParameter(request, "endTime");
- String displaceId = super.getParameter(request, "displaceId");
- String journalistName = super.getParameter(request, "journalistName");
- String agentName = super.getParameter(request, "agentName");
- // 时间转换
- Date startTime = null;
- Date endTime = null;
- try {
- if(StringUtils.isNotBlank(startTimeStr)) {
- startTime = DateUtil.parse(startTimeStr, DateUtil.DEFAULT);
- }
- if(StringUtils.isNotBlank(endTimeStr)) {
- endTime = DateUtil.parse(endTimeStr, DateUtil.DEFAULT);
- }
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入正确查询时间!");
- return;
- }
- // 查询结果
- resultBean = displaceAuditService.queryAuditPage(agentId, agentName, brandCode, brandContent, typeCode, typeContent, auditStatus,
- startTime, endTime, displaceId, journalistName, currentPageInt, pageSizeInt);
- //获取用户session信息中的字段权限,并组装成map带回页面
- List<UserColumnRoleBean> roleList = user.getUserColumnRoleBeans();
- Map<String,String> columnMap = new HashMap<String,String>();
- if(roleList!=null && !roleList.isEmpty()){
- for(UserColumnRoleBean role:roleList){
- if(role!=null){
- if(ConfigConstants.DISPLACE_LIST.equals(role.getListCode())){
- columnMap.put(role.getColumnCode(), role.getColumnName());
- }
- }
- }
- }
- resultBean.setColumnMap(columnMap);
- } catch (Exception e) {
- resultBean= new PageResultBean(PageResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- log.error("auditList error!",e);
- }finally{
- super.printResult(request, response, resultBean.toString());
- }
- }
- /**
- * 搜索置换审核记录分页列表
- * @param request
- * @param response
- */
- @RequestMapping("/auditList.do")
- public void auditList(HttpServletRequest request, HttpServletResponse response){
- //返回页面数据
- PageResultBean resultBean = null;
- try {
- //获取登录信息
- HttpSession session = request.getSession();
- UserBean user = (UserBean)session.getAttribute(CommonConstants.USER_INFO);
- if(user == null) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "请先登录!");
- return;
- }
- log.info("调用置换审核列表接口,当前登录人信息 userAccount:" + user.getUserAccount() + ", userRank:" + user.getUserRank() + ", isAdmin:" + user.getIsAdmin());
- // 1、超级管理员可以看到所有审核列表 2、管理员可以看到隶属自己的商家的审核列表 3、代理商可以看到自己商家的审核列表
- String agentId = "";
- if (UserBean.USER_RANK_SUPER_ADMIN.equals(user.getUserRank()) || UserBean.USER_RANK_ADMIN.equals(user.getUserRank())) {
- agentId = super.getParameter(request, "agentId");
- } else {
- agentId = user.getAgentId();
- }
- // 当前页码
- String currentPage = super.getParameter(request, "currentPage");
- // 分页记录数
- String pageSize = super.getParameter(request, "pageSize");
- int currentPageInt = 1;
- int pageSizeInt = 10;
- if(StringUtils.isNotEmpty(currentPage)){
- try {
- currentPageInt = Integer.parseInt(currentPage);
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入正确的页数!");
- return;
- }
- }
- if(StringUtils.isNotEmpty(pageSize)){
- try {
- pageSizeInt = Integer.parseInt(pageSize);
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入正确的分页数!");
- return;
- }
- }
- // 条件查询参数
- String brandCode = "sbpp";
- String brandContent = super.getParameter(request, "brandContent");
- String typeCode = "sblx";
- String typeContent = super.getParameter(request, "typeContent");
- //上架状态 审核状态(1-已审核已上架,0-待审核待上架,2-已驳回,3-重新上架成功的,4-已审核待上架)
- String auditStatus = super.getParameter(request, "auditStatus");
- //已删除 记录是否显示(1-显示,0-不显示,,2-取消发布)
- String status = super.getParameter(request, "status");
- String startTimeStr = super.getParameter(request, "startTime");
- String endTimeStr = super.getParameter(request, "endTime");
- String displaceId = super.getParameter(request, "displaceId");
- String journalistName = super.getParameter(request, "journalistName");
- String agentName = super.getParameter(request, "agentName");
- // 时间转换
- Date startTime = null;
- Date endTime = null;
- try {
- if(StringUtils.isNotBlank(startTimeStr)) {
- startTime = DateUtil.parse(startTimeStr, DateUtil.DEFAULT);
- }
- if(StringUtils.isNotBlank(endTimeStr)) {
- endTime = DateUtil.parse(endTimeStr, DateUtil.DEFAULT);
- }
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入正确查询时间!");
- return;
- }
- // 查询结果
- //精品机查询
- String isGood="1";
- if(jpjgh.equals(agentId)){
- isGood="2";
- }
- log.info("jpjgh="+jpjgh);
- log.info("jpjgh="+isGood);
- resultBean = displaceAuditService.queryAuditPageByType(agentId, agentName, brandCode, brandContent, typeCode, typeContent, auditStatus,status,startTime, endTime, displaceId, journalistName, currentPageInt, pageSizeInt, user.getUserRank(), user.getId(),isGood);
- // resultBean = displaceAuditService.queryAuditPage2(agentId, agentName, brandCode, brandContent, typeCode, typeContent, auditStatus,status,startTime, endTime, displaceId, journalistName, currentPageInt, pageSizeInt, user.getUserRank(), user.getId());
- //获取用户session信息中的字段权限,并组装成map带回页面
- List<UserColumnRoleBean> roleList = user.getUserColumnRoleBeans();
- Map<String,String> columnMap = new HashMap<String,String>();
- if(roleList!=null && !roleList.isEmpty()){
- for(UserColumnRoleBean role:roleList){
- if(role!=null){
- if(ConfigConstants.DISPLACE_LIST.equals(role.getListCode())){
- columnMap.put(role.getColumnCode(), role.getColumnName());
- }
- }
- }
- }
- resultBean.setColumnMap(columnMap);
- } catch (Exception e) {
- resultBean= new PageResultBean(PageResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- log.error("auditList error!",e);
- }finally{
- super.printResult(request, response, resultBean.toString());
- }
- }
- /**
- * 导出置换审核记录--自运营
- * @param request
- * @param response
- */
- @RequestMapping("/expSinceAuditList.do")
- public void expSinceAuditList(HttpServletRequest request, HttpServletResponse response){
- //返回页面数据
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE,"成功!");
- try {
- //获取登录信息
- HttpSession session = request.getSession();
- UserBean user = (UserBean)session.getAttribute(CommonConstants.USER_INFO);
- if(user == null) {
- resultBean = new ResultBean(PageResultBean.FAIL_CODE, "请先登录!");
- return;
- }
- //如果不是平台用户的话,则只能搜索到他本身的商家报价信息
- String agentId = "";
- if(!"1".equals(user.getIsAdmin())){
- agentId = user.getAgentId();
- }else {
- agentId = super.getParameter(request, "agentId");
- }
- // 条件查询参数
- String brandCode = "sbpp";
- String brandContent = super.getParameter(request, "brandContent");
- String typeCode = "sblx";
- String typeContent = super.getParameter(request, "typeContent");
- String auditStatus = super.getParameter(request, "auditStatus");
- String startTimeStr = super.getParameter(request, "startTime");
- String endTimeStr = super.getParameter(request, "endTime");
- String displaceId = super.getParameter(request, "displaceId");
- String journalistName = super.getParameter(request, "journalistName");
- String agentName = super.getParameter(request, "agentName");
- String ids = super.getParameter(request, "ids");
- // 时间转换
- Date startTime = null;
- Date endTime = null;
- try {
- if(StringUtils.isNotBlank(startTimeStr)) {
- startTime = DateUtil.parse(startTimeStr, DateUtil.DEFAULT);
- }
- if(StringUtils.isNotBlank(endTimeStr)) {
- endTime = DateUtil.parse(endTimeStr, DateUtil.DEFAULT);
- }
- } catch (Exception e) {
- resultBean = new ResultBean(PageResultBean.FAIL_CODE,"请输入正确导出时间!");
- return;
- }
- // 查询结果
- String path = request.getSession().getServletContext().getRealPath("/")+ "/auditexcel/";;
- resultBean = displaceAuditService.createSinceAuditXlsx(agentId, agentName, brandCode, brandContent, typeCode, typeContent,
- auditStatus, startTime, endTime, displaceId, journalistName, path, user, ids);
- if(!ResultBean.SUCCESS_CODE.equals(resultBean.getCode())){
- resultBean = new ResultBean(ResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- return;
- }
- String filename = resultBean.getMessage();
- String[] tempArr= filename.split("\\.");
- //设置文件下载格式XLS
- ExcelFileUtil.setXLSXHeader(request, response, tempArr[0]);
- //获取文件
- File upfile = new File(path+filename);
- ExcelFileUtil.downloadFile(response.getOutputStream(),upfile);
- } catch (Exception e) {
- resultBean = new ResultBean(ResultBean.FAIL_CODE, "系统繁忙,请稍后再来!");
- log.error("exportOffer error!",e);
- }
- }
- /**
- * 导出置换审核记录
- * @param request
- * @param response
- */
- @RequestMapping("/expAuditList.do")
- public void expAuditList(HttpServletRequest request, HttpServletResponse response){
- //返回页面数据
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE,"成功!");
- try {
- //获取登录信息
- HttpSession session = request.getSession();
- UserBean user = (UserBean)session.getAttribute(CommonConstants.USER_INFO);
- if(user == null) {
- resultBean = new ResultBean(PageResultBean.FAIL_CODE, "请先登录!");
- return;
- }
- log.info("调用导出置换审核列表xlsx接口,当前登录人信息 userAccount:" + user.getUserAccount() + ", userRank:" + user.getUserRank() + ", isAdmin:" + user.getIsAdmin());
- // 1、超级管理员可以看到所有审核列表 2、管理员可以看到隶属自己的商家的审核列表 3、代理商可以看到自己商家的审核列表
- String agentId = "";
- if (UserBean.USER_RANK_SUPER_ADMIN.equals(user.getUserRank()) || UserBean.USER_RANK_ADMIN.equals(user.getUserRank())) {
- agentId = super.getParameter(request, "agentId");
- } else {
- agentId = user.getAgentId();
- }
- // 条件查询参数
- String brandCode = "sbpp";
- String brandContent = super.getParameter(request, "brandContent");
- String typeCode = "sblx";
- String typeContent = super.getParameter(request, "typeContent");
- String auditStatus = super.getParameter(request, "auditStatus");
- String startTimeStr = super.getParameter(request, "startTime");
- String endTimeStr = super.getParameter(request, "endTime");
- String displaceId = super.getParameter(request, "displaceId");
- String journalistName = super.getParameter(request, "journalistName");
- String agentName = super.getParameter(request, "agentName");
- String ids = super.getParameter(request, "ids");
- // 时间转换
- Date startTime = null;
- Date endTime = null;
- try {
- if(StringUtils.isNotBlank(startTimeStr)) {
- startTime = DateUtil.parse(startTimeStr, DateUtil.DEFAULT);
- }
- if(StringUtils.isNotBlank(endTimeStr)) {
- endTime = DateUtil.parse(endTimeStr, DateUtil.DEFAULT);
- }
- } catch (Exception e) {
- resultBean = new ResultBean(PageResultBean.FAIL_CODE,"请输入正确导出时间!");
- return;
- }
- // 查询结果
- String path = request.getSession().getServletContext().getRealPath("/")+ "/auditexcel/";;
- resultBean = displaceAuditService.createAuditXlsx(agentId, agentName, brandCode, brandContent, typeCode, typeContent,
- auditStatus, startTime, endTime, displaceId, journalistName, path, user, ids);
- if(!ResultBean.SUCCESS_CODE.equals(resultBean.getCode())){
- resultBean = new ResultBean(ResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- return;
- }
- String filename = resultBean.getMessage();
- String[] tempArr= filename.split("\\.");
- //设置文件下载格式XLS
- ExcelFileUtil.setXLSXHeader(request, response, tempArr[0]);
- //获取文件
- File upfile = new File(path+filename);
- ExcelFileUtil.downloadFile(response.getOutputStream(),upfile);
- } catch (Exception e) {
- resultBean = new ResultBean(ResultBean.FAIL_CODE, "系统繁忙,请稍后再来!");
- log.error("exportOffer error!",e);
- }
- }
- /**
- * 删除置换记录
- * @param request
- * @param response
- */
- @RequestMapping("/deleteAudit.do")
- public void deleteShop(HttpServletRequest request, HttpServletResponse response){
- //返回页面数据
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE,"成功!");
- String ids = super.getParameter(request, "ids");
- try {
- //判断必要参数是否传递到后台
- if(StringUtils.isEmpty(ids)){
- resultBean = new ResultBean(ResultBean.FAIL_CODE,"请选择要删除的置换记录!");
- return;
- }
- String[] queryCondition = ids.split(",");
- if(queryCondition==null || queryCondition.length<=0){
- resultBean = new ResultBean(ResultBean.FAIL_CODE,"请选择要删除的置换记录!");
- return;
- }
- if(resultBean.getCode().equals(ResultBean.SUCCESS_CODE)){
- boolean flag = true;
- // 任务项数量 查询条件
- StringBuilder conditionSql = new StringBuilder();
- // 任务项 条件值
- List<Object> conditions = new ArrayList<Object>();
- for (int i = 0; i < queryCondition.length; i++) {
- conditions.add(queryCondition[i]);
- conditionSql.append("?");
- if(i<queryCondition.length-1) {
- conditionSql.append(",");
- }
- }
- flag = displaceAuditService.deleteAudit(conditionSql.toString(),conditions);
- if(!flag){
- resultBean = new ResultBean(ResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- }
- }
- } catch (Exception e) {
- resultBean = new ResultBean(ResultBean.FAIL_CODE, "系统繁忙,请稍后再来!");
- log.error("deleteActivityType error!",e);
- }finally{
- super.printResult(request, response, resultBean.toString());
- }
- }
- /**
- * 恢复置换记录
- * @param request
- * @param response
- */
- @RequestMapping("/recoveryAudit.do")
- public void recovery(HttpServletRequest request, HttpServletResponse response){
- //返回页面数据
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE,"成功!");
- String ids = super.getParameter(request, "ids");
- try {
- //判断必要参数是否传递到后台
- if(StringUtils.isEmpty(ids)){
- resultBean = new ResultBean(ResultBean.FAIL_CODE,"请选择要恢复的置换记录!");
- return;
- }
- String[] queryCondition = ids.split(",");
- if(queryCondition==null || queryCondition.length<=0){
- resultBean = new ResultBean(ResultBean.FAIL_CODE,"请选择要恢复的置换记录!");
- return;
- }
- if(resultBean.getCode().equals(ResultBean.SUCCESS_CODE)){
- boolean flag = true;
- // 任务项数量 查询条件
- StringBuilder conditionSql = new StringBuilder();
- // 任务项 条件值
- List<Object> conditions = new ArrayList<Object>();
- for (int i = 0; i < queryCondition.length; i++) {
- conditions.add(queryCondition[i]);
- conditionSql.append("?");
- if(i<queryCondition.length-1) {
- conditionSql.append(",");
- }
- }
- flag = displaceAuditService.recoveryAudit(conditionSql.toString(),conditions);
- if(!flag){
- resultBean = new ResultBean(ResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- }
- }
- } catch (Exception e) {
- resultBean = new ResultBean(ResultBean.FAIL_CODE, "系统繁忙,请稍后再来!");
- log.error("deleteActivityType error!",e);
- }finally{
- super.printResult(request, response, resultBean.toString());
- }
- }
- /**
- * 重新上架
- * @param request
- * @param response
- */
- @RequestMapping("/againUp.do")
- public void againUp(HttpServletRequest request, HttpServletResponse response, @ModelAttribute DisplaceAuditBean displaceAuditBean){
- //返回页面数据
- PageResultBean resultBean = new PageResultBean(PageResultBean.SUCCESS_CODE,"成功!");;
- try {
- //获取登录信息
- HttpSession session = request.getSession();
- UserBean user = (UserBean)session.getAttribute(CommonConstants.USER_INFO);
- if(user == null) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "请先登录!");
- return;
- }
- if(StringUtils.isEmpty(displaceAuditBean.getId())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "请选择要重新上架的记录!");
- return;
- }
- // 上架形式
- if(StringUtils.isBlank(displaceAuditBean.getUpType())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入上架形式!");
- return;
- }
- // 保证金
- if(StringUtils.isBlank(displaceAuditBean.getBail())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入保证金额度!");
- return;
- }
- try {
- Double.parseDouble(displaceAuditBean.getBail());
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"保证金格式不正确!");
- return;
- }
- // 报价额度
- if(StringUtils.isBlank(displaceAuditBean.getMoneyRange())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入报价额度!");
- return;
- }
- try {
- Double.parseDouble(displaceAuditBean.getMoneyRange());
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"报价额度格式不正确!");
- return;
- }
- if("3".equals(displaceAuditBean.getUpType())){
- log.info("displaceAuditBean.getMinPrice()="+displaceAuditBean.getMinPrice());
- if(StringUtils.isBlank(displaceAuditBean.getMinPrice())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入最低价额度!");
- return;
- }
- try {
- Double.parseDouble(displaceAuditBean.getMinPrice());
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"最低价格式不正确!");
- return;
- }
- log.info("displaceAuditBean.getMaxPrice()="+displaceAuditBean.getMaxPrice());
- if(StringUtils.isBlank(displaceAuditBean.getMaxPrice())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入最高价额度!");
- return;
- }
- try {
- Double.parseDouble(displaceAuditBean.getMaxPrice());
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"最高价格式不正确!");
- return;
- }
- log.info("displaceAuditBean.getPersistPrice()="+displaceAuditBean.getPersistPrice());
- if(StringUtils.isBlank(displaceAuditBean.getPersistPrice())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入保留价额度!");
- return;
- }
- try {
- Double.parseDouble(displaceAuditBean.getPersistPrice());
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"保留价格式不正确!");
- return;
- }
- if(Double.parseDouble(displaceAuditBean.getPersistPrice())>Double.parseDouble(displaceAuditBean.getMaxPrice())||Double.parseDouble(displaceAuditBean.getPersistPrice())<Double.parseDouble(displaceAuditBean.getMinPrice())) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "保留价格应该在最低价和最高价之间!");
- return;
- }
- }else{
- // 起拍价
- if(StringUtils.isBlank(displaceAuditBean.getMinMoney())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入起拍价!");
- return;
- }
- try {
- Double.parseDouble(displaceAuditBean.getMinMoney());
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"起拍价格式不正确!");
- return;
- }
- // 报价延时
- if(StringUtils.isBlank(displaceAuditBean.getTimeDelay())){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请输入报价延时!");
- return;
- }
- try {
- Double.parseDouble(displaceAuditBean.getTimeDelay());
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"报价延时格式不正确!");
- return;
- }
- }
- // 开始结束时间
- String startTimeStr = super.getParameter(request, "startTimeStr");
- String endTimeStr = super.getParameter(request, "endTimeStr");
- if(StringUtils.isBlank(startTimeStr)){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请选择开始时间!");
- return;
- }
- if(StringUtils.isBlank(endTimeStr)){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"请选择结束时间!");
- return;
- }
- Date startTime = null;
- Date endTime = null;
- try {
- startTime = DateUtil.parse(startTimeStr, DateUtil.DEFAULT);
- endTime = DateUtil.parse(endTimeStr, DateUtil.DEFAULT);
- } catch (Exception e) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"时间格式不正确!");
- return;
- }
- // 代理商信息
- String agentId = super.getParameter(request, "agentId");
- AgentBean agentBean = agentBeanService.getAgentBeanByAgentId(agentId);
- if(agentBean == null) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "未查询到代理商信息!");
- return;
- }
- // 记录id
- String id = super.getParameter(request, "id");
- // 车商ID
- String ids = super.getParameter(request, "ids");
- // 微工程ID
- String wgcids = super.getParameter(request, "wgcids");
- if(StringUtils.isEmpty(ids) && StringUtils.isEmpty(wgcids)) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "请选择推送车商!");
- return;
- }
- // 销售员ID
- String saleId = super.getParameter(request, "saleId");
- // 发送方式
- String pushWx = super.getParameter(request,"pushWx");
- // 发送方式
- String pushSms = super.getParameter(request,"pushSms");
- if(StringUtils.isBlank(pushWx)&& StringUtils.isBlank(pushSms)){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "请选择推送方式!");
- return;
- }
- // 发布时间
- String pubTimeStr = super.getParameter(request, "pubTimeStr");
- Date pubTime = null;
- try {
- pubTime = DateUtil.parse(pubTimeStr, DateUtil.DEFAULT);
- pubTimeStr = DateUtil.format(pubTime, "yyyy年MM月dd日 HH:mm");
- } catch (Exception e) {
- pubTimeStr = "";
- }
- //取出带过来的置换ID
- String displaceId = super.getParameter(request, "displaceId");
- DisplaceAuditBean displace = displaceAuditService.queryAuditPageByDisplaceId(displaceId);
- //设备名称
- String sbmc = displace.getAttrContent().get("sbpp") + " " + displace.getAttrContent().get("sbxh") + " " + displace.getAttrContent().get("sblx");
- // 反馈内容
- String sms = super.getParameter(request, "sms");
- if(StringUtils.isBlank(sms)){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "请输入要发送的短信内容");
- return;
- }
- if(sms.length()>1500){
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE, "短信内容过长");
- return;
- }
- displaceAuditBean.setStartTime(startTime);
- displaceAuditBean.setEndTime(endTime);
- displaceAuditBean.setAuditTime(new Date());
- displaceAuditBean.setAuditUser(user.getUserAccount());
- // 补充信息
- String oldDis=displaceAuditService.findOldDis(displace.getId());
- System.out.println(oldDis+"这是查出来的old");
- String oldDisplace="";
- int count=0;
- if(oldDis.equals("0")){
- count=displaceAuditService.findCount(displace.getDisplaceId());
- oldDisplace=displace.getDisplaceId();
- }else{
- count=displaceAuditService.findCountByOld(oldDisplace)+1;
- oldDisplace=oldDis;
- }
- boolean flag = displaceAuditService.createNewAudit(displaceAuditBean,oldDisplace,count);
- System.out.println(displaceAuditBean.getId()+"这是id"+displaceAuditBean.getDisplaceId()+"这是置换id");
- if(!flag) {
- resultBean = new PageResultBean(PageResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- return;
- }
- String agentName = agentBean.getAgentName();
- String appId = agentBean.getPubAppId();
- String appSecret = agentBean.getPubAppSecret();
- //String diggerUrl = TemplateConstants.ZHSH_DIGGER_URL + "?agentId=" + agentId + "&id=" + id;
- String diggerUrl = "https://www.weigongcheng.net/wjj-api/index.html#/join" + "?agentId=" + agentId + "&displaceId="+displaceId+"&status="+displaceAuditBean+"&id=" + id;
- String wxsms = TemplateConstants.ZHSH_DIGGER_TEMPLATE_CONTENT;
- wxsms = wxsms.replaceAll("first", "有一台设备正在寻找买家");
- wxsms = wxsms.replaceAll("keyword1", sbmc+"");
- wxsms = wxsms.replaceAll("keyword2", displaceAuditBean.getMinPrice()+"万元");
- wxsms = wxsms.replaceAll("keyword3", displaceAuditBean.getMoneyRange()+"万元");
- wxsms = wxsms.replaceAll("keyword4", DateUtil.format(startTime, "yyyy年MM月dd日 HH:mm"));
- wxsms = wxsms.replaceAll("keyword5", displaceAuditBean.getBail()+"万元");
- wxsms = wxsms.replaceAll("remark", "点击【详情】前往查看!");
- List<PushRecordBean> list = new ArrayList<PushRecordBean>();
- PushRecordBean pushRecord = null;
- // 发送车商信息
- if(StringUtils.isNotBlank(ids)) {
- String[] diggers = ids.substring(0, ids.lastIndexOf(",")).split(",");
- for (int i = 0; i < diggers.length; i++) {
- //获取车商bean,并获取车商微信openid和其他信息
- DiggerBean digger = diggerBeanService.queryDiggerByID(diggers[i]);
- String openId = digger.getWxOpenID();
- String wxnc = digger.getDaWxnc();
- String wxh = digger.getDaWxh();
- String name = digger.getDaName();
- String phone = digger.getDaPhone();
- // 组装车商微信内容
- Map<String,TemplateData> param1 = new HashMap<String,TemplateData>();
- param1.put("first",new TemplateData("有一台设备正在寻找买家","#696969"));
- param1.put("keyword1",new TemplateData(sbmc+"","#696969"));
- param1.put("keyword2",new TemplateData(displaceAuditBean.getMinPrice()+"万元","#696969"));
- param1.put("keyword3",new TemplateData(displaceAuditBean.getMoneyRange()+"万元","#696969"));
- param1.put("keyword4",new TemplateData(DateUtil.format(startTime, "yyyy年MM月dd日 HH:mm"),"#696969"));
- param1.put("keyword5",new TemplateData(displaceAuditBean.getBail()+"万元","#696969"));
- param1.put("remark",new TemplateData("点击【详情】前往查看!","#696969"));
- if(StringUtils.isNotBlank(pushWx)){
- pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, agentId, agentName, openId, wxnc, wxh, name, phone, ConfigConstants.TSFS_WXXX, ConfigConstants.XXLB_SBSJ,
- appId, appSecret, sms, wxsms, param1, diggerUrl, "拍品上架通知");
- list.add(pushRecord);
- }
- if(StringUtils.isNotBlank(pushSms)){
- pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, agentId, agentName, openId, wxnc, wxh, name, phone, ConfigConstants.TSFS_DXX, ConfigConstants.XXLB_SBSJ,
- appId, appSecret, sms, wxsms, param1, diggerUrl, "拍品上架通知");
- list.add(pushRecord);
- }
- }
- }
- // 发送微工程信息
- if(StringUtils.isNotBlank(wgcids)) {
- String wgcAgentName = "";
- String wgcAppId = "";
- String wgcAppSecret = "";
- String wgcPriceLink = "";
- if("1".equals(agentBean.getIsAttent()) || "y".equals(agentBean.getIsAttent()) || ConfigConstants.WGC_ID.equals(agentId)) {
- // 微工程信息
- AgentBean wgcBean = agentBeanService.getAgentBeanByAgentId(ConfigConstants.WGC_ID);
- wgcAgentName = wgcBean.getAgentName();;
- wgcAppId = wgcBean.getPubAppId();
- wgcAppSecret = wgcBean.getPubAppSecret();
- wgcPriceLink = wgcBean.getPriceLink();
- String[] wgcdiggers = wgcids.substring(0, wgcids.lastIndexOf(",")).split(",");
- for (int i = 0; i < wgcdiggers.length; i++) {
- //获取车商bean,并获取车商微信openid和其他信息
- DiggerBean digger = diggerBeanService.queryDiggerByID(wgcdiggers[i]);
- String openId = digger.getWxOpenID();
- String wxnc = digger.getDaWxnc();
- String wxh = digger.getDaWxh();
- String name = digger.getDaName();
- String phone = digger.getDaPhone();
- // 组装车商微信内容
- Map<String,TemplateData> param2 = new HashMap<String,TemplateData>();
- param2.put("first",new TemplateData("有一台设备正在寻找买家","#696969"));
- param2.put("keyword1",new TemplateData(sbmc+"","#696969"));
- param2.put("keyword2",new TemplateData(displaceAuditBean.getMinPrice()+"万元","#696969"));
- param2.put("keyword3",new TemplateData(displaceAuditBean.getMoneyRange()+"万元","#696969"));
- param2.put("keyword4",new TemplateData(DateUtil.format(startTime, "yyyy年MM月dd日 HH:mm"),"#696969"));
- param2.put("keyword5",new TemplateData(displaceAuditBean.getBail()+"万元","#696969"));
- param2.put("remark",new TemplateData("点击【详情】前往查看!","#696969"));
- wxsms = wxsms.replaceAll("keyword1", wxnc+"");
- if(StringUtils.isNotBlank(pushWx)){
- pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, ConfigConstants.WGC_ID, wgcAgentName, openId, wxnc, wxh, name, phone, ConfigConstants.TSFS_WXXX,ConfigConstants.XXLB_SBSJ,
- wgcAppId, wgcAppSecret, sms, wxsms, param2, wgcPriceLink, "拍品上架通知");
- list.add(pushRecord);
- }
- if(StringUtils.isNotBlank(pushSms)){
- pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, ConfigConstants.WGC_ID, wgcAgentName, openId, wxnc, wxh, name, phone, ConfigConstants.TSFS_DXX,ConfigConstants.XXLB_SBSJ,
- wgcAppId, wgcAppSecret, sms, wxsms, param2, wgcPriceLink, "拍品上架通知");
- list.add(pushRecord);
- }
- }
- }
- }
- // 发送销售员信息
- if(StringUtils.isNotBlank(saleId)) {
- SalesBean salesBean = saleBeanService.getSaleBeanBySaleId(saleId);
- if(salesBean != null){
- String openId = salesBean.getWxOpenid();
- String wxnc = salesBean.getSaleWxnc();
- String wxh = salesBean.getSaleWxh();
- String name = salesBean.getSaleName();
- String phone = salesBean.getSalePhone();
- String saleUrl = TemplateConstants.ZHSH_SALE_URL + "?agentId=" + agentId + "&id=" + id;
- // 组装销售员微信内容
- Map<String,TemplateData> param3 = new HashMap<String,TemplateData>();
- param3.put("first",new TemplateData("您上传的设备已上架成功,等待买家出价","#696969"));
- param3.put("keyword1",new TemplateData(wxnc,"#696969"));
- param3.put("keyword2",new TemplateData(sbmc,"#696969"));
- param3.put("keyword3",new TemplateData(pubTimeStr,"#696969"));
- param3.put("keyword4",new TemplateData("上架成功","#696969"));
- param3.put("remark",new TemplateData("赶快点击“详情”分享给大家吧!","#696969"));
- String upsms = TemplateConstants.ZHSH_SALE_UP_SMS;
- upsms = upsms.replace("sbmc", sbmc+"");
- String wxsms1 = TemplateConstants.ZHSH_SALE_TEMPLATE_CONTENT;
- wxsms1 = wxsms1.replaceAll("first", "您上传的设备已上架成功,等待买家出价");
- wxsms1 = wxsms1.replaceAll("keyword1", wxnc+"");
- wxsms1 = wxsms1.replaceAll("keyword2", sbmc+"");
- wxsms1 = wxsms1.replaceAll("keyword3", pubTimeStr);
- wxsms1 = wxsms1.replaceAll("keyword4", "上架成功");
- wxsms1 = wxsms1.replaceAll("remark", "赶快点击“详情”分享给大家吧!");
- if(StringUtils.isNotBlank(pushWx)){
- pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, agentId, agentName, openId, wxnc, wxh, name, phone, ConfigConstants.TSFS_WXXX,ConfigConstants.XXLB_SBSJ,
- appId, appSecret, upsms,wxsms1, param3, saleUrl, "审核结果通知");
- list.add(pushRecord);
- }
- if(StringUtils.isNotBlank(pushSms)){
- pushRecord = displaceAuditService.pushSms(displaceId, id, sbmc, ConfigConstants.CDMC_ZHSH, agentId, agentName, openId, wxnc, wxh, name, phone, ConfigConstants.TSFS_DXX,ConfigConstants.XXLB_SBSJ,
- appId, appSecret, upsms,wxsms1, param3, saleUrl, "审核结果通知");
- list.add(pushRecord);
- }
- }
- }
- // 保存推送消息
- pushRecordBeanService.saveRecords(list);
- } catch (Exception e) {
- resultBean= new PageResultBean(PageResultBean.FAIL_CODE,"系统繁忙,请稍后再来!");
- log.error("addInfo error!",e);
- }finally{
- super.printResult(request, response, resultBean.toString());
- }
- }
- @RequestMapping("/pushAdmin.do")
- public void pushAdmin(HttpServletRequest request, HttpServletResponse response,@RequestParam("arrayDaili") String arrayDaili,String shebeiId){
- System.out.println(arrayDaili+"======"+shebeiId);
- ResultBean resultBean = new ResultBean(ResultBean.SUCCESS_CODE,"成功!");
- try {
- if (StringUtils.isNotBlank(arrayDaili) && StringUtils.isNotBlank(shebeiId)) {
- List<PushRecordBean> list = new ArrayList<PushRecordBean>();
- PushRecordBean pushRecord = null;
- AgentBean wgcBean = agentBeanService.getAgentBeanByAgentId(ConfigConstants.WGC_ID);
- String wgcAgentName = wgcBean.getAgentName();
- String wgcAppId = wgcBean.getPubAppId();
- String wgcAppSecret = wgcBean.getPubAppSecret();
- //String wgcPriceLink = wgcBean.getPriceLink()
- String xqurl="https://www.xxinjiyuan.com/wjj-api/index.html#/join?agentId=GZZSNJ&displaceId=GZZSNJ-ZH0044&status=finished&id=5c8adc199c7f44a8ac398d9edbcd4914";
- DisplaceAuditBean displace = displaceAuditService.queryAuditPageByDisplaceId(shebeiId);
- String wgcPriceLink ="https://www.weigongcheng.net/wjj-api/index.html#/join?agentId=WGC000"+"&status="+displace.getAuditStatus()+"&id="+displace.getId();
- String sbmc = displace.getAttrContent().get("sbpp") + " " + displace.getAttrContent().get("sbxh") + " " + displace.getAttrContent().get("sblx");
- String[] chrstr = arrayDaili.split("#");
- System.out.println("============================>2");
- for (int i = 0; i < chrstr.length; i++) {
- DiggerBean digger = diggerBeanService.queryDiggerByID(chrstr[i]);
- String openId = digger.getWxOpenID();
- String wxnc = digger.getDaWxnc();
- String wxh = digger.getDaWxh();
- String name = digger.getDaName();
- String phone = digger.getDaPhone();
- String wxsms = TemplateConstants.ZHSH_DIGGER_TEMPLATE_CONTENT;
- System.out.println(openId + "+++openid");
- System.out.println(wxnc + "+++wxnc");
- // 组装车商微信内容
- System.out.println(displace.getStartTime()+"------------------------");
- Map<String, TemplateData> param2 = new HashMap<String, TemplateData>();
- param2.put("first", new TemplateData("有一台设备正在寻找买家", "#696969"));
- param2.put("keyword1", new TemplateData(sbmc + "", "#696969"));
- param2.put("keyword2", new TemplateData(displace.getMinPrice() + "万元", "#696969"));
- param2.put("keyword3", new TemplateData(displace.getMoneyRange(), "#696969"));
- param2.put("keyword4", new TemplateData(DateUtil.format(displace.getStartTime(), "yyyy年MM月dd日 HH:mm"), "#696969"));
- param2.put("keyword5", new TemplateData(displace.getBail() + "万元", "#696969"));
- param2.put("remark", new TemplateData("点击【详情】前往查看!", "#696969"));
- wxsms = wxsms.replaceAll("keyword1", wxnc + "");
- pushRecord = displaceAuditService.pushSms(shebeiId, "", sbmc, ConfigConstants.CDMC_ZHSH, ConfigConstants.WGC_ID, wgcAgentName, openId, wxnc, wxh, name, phone, ConfigConstants.TSFS_WXXX, ConfigConstants.XXLB_SBSJ,
- wgcAppId, wgcAppSecret, "", wxsms, param2, wgcPriceLink, "拍品上架通知");
- list.add(pushRecord);
- }
- pushRecordBeanService.saveRecords(list);
- resultBean.setMessage("发送成功");
- super.printResult(request, response, resultBean.toString());
- }
- ;
- }catch (Exception e) {
- log.error("addInfo error!",e);
- }finally{
- super.printResult(request, response, resultBean.toString());
- }
- }
- }
|