|
|
@@ -1,465 +0,0 @@
|
|
|
-package com.happy.action;
|
|
|
-
|
|
|
-import com.google.gson.Gson;
|
|
|
-import com.alibaba.fastjson.JSONObject;
|
|
|
-import com.google.gson.reflect.TypeToken;
|
|
|
-import com.happy.Model.*;
|
|
|
-import com.happy.Model.app.News;
|
|
|
-import com.happy.Model.weixin.*;
|
|
|
-import com.happy.Until.*;
|
|
|
-import com.happy.common.http.Get_airticle;
|
|
|
-import com.happy.common.http.HttpsClient;
|
|
|
-import com.happy.common.http.Message2;
|
|
|
-import com.happy.common.http.Message3;
|
|
|
-import com.happy.common.model.airticle.Content;
|
|
|
-import com.happy.common.model.airticle.Item_content;
|
|
|
-import com.happy.common.model.airticle.News_content;
|
|
|
-import com.happy.common.util.WechatUtil;
|
|
|
-import com.happy.common.wx.WxUtil;
|
|
|
-import com.happy.service.*;
|
|
|
-import com.opensymphony.xwork2.ActionSupport;
|
|
|
-import org.apache.struts2.ServletActionContext;
|
|
|
-import org.apache.struts2.interceptor.ServletRequestAware;
|
|
|
-
|
|
|
-import javax.annotation.Resource;
|
|
|
-import javax.servlet.http.HttpServletRequest;
|
|
|
-import javax.servlet.http.HttpServletResponse;
|
|
|
-import javax.servlet.http.HttpSession;
|
|
|
-import java.io.BufferedReader;
|
|
|
-import java.io.IOException;
|
|
|
-import java.io.PrintWriter;
|
|
|
-import java.io.UnsupportedEncodingException;
|
|
|
-import java.net.URLEncoder;
|
|
|
-import java.text.ParseException;
|
|
|
-import java.text.SimpleDateFormat;
|
|
|
-import java.util.*;
|
|
|
-
|
|
|
-public class appAction extends ActionSupport implements ServletRequestAware {
|
|
|
-
|
|
|
- private HttpServletRequest request;
|
|
|
- public HttpServletResponse response;
|
|
|
-
|
|
|
- @Resource
|
|
|
- public UserService userService;
|
|
|
- @Resource
|
|
|
- public BookService bookService;
|
|
|
- @Resource
|
|
|
- public HouseService houseService;
|
|
|
- @Resource
|
|
|
- public ConfigService configService;
|
|
|
- @Resource
|
|
|
- public AppService appService;
|
|
|
-
|
|
|
- public String wxcode;
|
|
|
- public String state;
|
|
|
- public String code;
|
|
|
- public String order_num;
|
|
|
- public String card_number;
|
|
|
- public String phone;
|
|
|
- public String admin_name;
|
|
|
- public String password;
|
|
|
- public String openid;
|
|
|
- public int page; // 当前页
|
|
|
- public int rows;// 每页显示的行数rows
|
|
|
-
|
|
|
- public HttpServletRequest getRequest() {
|
|
|
- return request;
|
|
|
- }
|
|
|
-
|
|
|
- public void setRequest(HttpServletRequest request) {
|
|
|
- this.request = request;
|
|
|
- }
|
|
|
-
|
|
|
- public void setServletRequest(HttpServletRequest request) {
|
|
|
- this.request = request;
|
|
|
- }
|
|
|
-
|
|
|
- public HttpServletResponse getResponse() {
|
|
|
- return response;
|
|
|
- }
|
|
|
-
|
|
|
- public void setResponse(HttpServletResponse response) {
|
|
|
- this.response = response;
|
|
|
- }
|
|
|
-
|
|
|
- public String getState() {
|
|
|
- return state;
|
|
|
- }
|
|
|
-
|
|
|
- public void setState(String state) {
|
|
|
- this.state = state;
|
|
|
- }
|
|
|
-
|
|
|
- public String getWxcode() {
|
|
|
- return wxcode;
|
|
|
- }
|
|
|
-
|
|
|
- public void setWxcode(String wxcode) {
|
|
|
- this.wxcode = wxcode;
|
|
|
- }
|
|
|
-
|
|
|
- public String getCode() {
|
|
|
- return code;
|
|
|
- }
|
|
|
-
|
|
|
- public void setCode(String code) {
|
|
|
- this.code = code;
|
|
|
- }
|
|
|
-
|
|
|
- public String getOrder_num() {
|
|
|
- return order_num;
|
|
|
- }
|
|
|
-
|
|
|
- public void setOrder_num(String order_num) {
|
|
|
- this.order_num = order_num;
|
|
|
- }
|
|
|
-
|
|
|
- public String getCard_number() {
|
|
|
- return card_number;
|
|
|
- }
|
|
|
-
|
|
|
- public void setCard_number(String card_number) {
|
|
|
- this.card_number = card_number;
|
|
|
- }
|
|
|
-
|
|
|
- public String getPhone() {
|
|
|
- return phone;
|
|
|
- }
|
|
|
-
|
|
|
- public void setPhone(String phone) {
|
|
|
- this.phone = phone;
|
|
|
- }
|
|
|
-
|
|
|
- public String getAdmin_name() {
|
|
|
- return admin_name;
|
|
|
- }
|
|
|
-
|
|
|
- public void setAdmin_name(String admin_name) {
|
|
|
- this.admin_name = admin_name;
|
|
|
- }
|
|
|
-
|
|
|
- public String getPassword() {
|
|
|
- return password;
|
|
|
- }
|
|
|
-
|
|
|
- public void setPassword(String password) {
|
|
|
- this.password = password;
|
|
|
- }
|
|
|
-
|
|
|
- public String getOpenid() {
|
|
|
- return openid;
|
|
|
- }
|
|
|
-
|
|
|
- public void setOpenid(String openid) {
|
|
|
- this.openid = openid;
|
|
|
- }
|
|
|
-
|
|
|
- public int getPage() {
|
|
|
- return page;
|
|
|
- }
|
|
|
-
|
|
|
- public void setPage(int page) {
|
|
|
- this.page = page;
|
|
|
- }
|
|
|
-
|
|
|
- public int getRows() {
|
|
|
- return rows;
|
|
|
- }
|
|
|
-
|
|
|
- public void setRows(int rows) {
|
|
|
- this.rows = rows;
|
|
|
- }
|
|
|
-
|
|
|
- public String test() throws Exception {
|
|
|
- JSONObject resultJson = new JSONObject();
|
|
|
- String msg = Message2.send(openid,"20231011163520","总统套房",
|
|
|
- "2023-10-11","测试","测试","");
|
|
|
- resultJson.put("message", "返回成功");
|
|
|
- resultJson.put("code", 200);
|
|
|
- resultJson.put("data",msg);
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- // 查询是否绑定
|
|
|
- public String getUser(){
|
|
|
- JSONObject resultJson = new JSONObject();
|
|
|
- if (code==null){
|
|
|
- resultJson.put("message", "code不能为空");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- JSONObject jsonObject = appService.getGCodeInfo(code);
|
|
|
- Admin admin = appService.queryByOpenid(jsonObject.get("openid").toString());
|
|
|
- if (admin==null){
|
|
|
- resultJson.put("message", "未绑定信息");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- resultJson.put("message", "返回成功");
|
|
|
- resultJson.put("code", 200);
|
|
|
- resultJson.put("data", admin);
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- // 开始绑定
|
|
|
- public String code() throws IOException {
|
|
|
- JSONObject resultJson = new JSONObject();
|
|
|
- if (code==null || admin_name==null || password==null){
|
|
|
- resultJson.put("message", "参数不能为空");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- Admin login = appService.login(admin_name,password);
|
|
|
- if (login==null){
|
|
|
- resultJson.put("message", "账户或密码错误");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- JSONObject jsonObject = appService.getGCodeInfo(code);
|
|
|
- Admin admin = appService.queryByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
|
|
|
- if (admin!=null){
|
|
|
- resultJson.put("message", "该账户已绑定,请勿重复绑定");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data",admin);
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- int m = appService.updateOpenid(jsonObject.get("openid").toString(),admin_name);
|
|
|
- if (m>0){
|
|
|
- admin = appService.queryByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
|
|
|
- resultJson.put("message", "绑定成功");
|
|
|
- resultJson.put("code", 200);
|
|
|
- resultJson.put("data",admin);
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- // 解绑
|
|
|
- public String uncode(){
|
|
|
- JSONObject resultJson = new JSONObject();
|
|
|
- if (code==null || admin_name==null || password==null){
|
|
|
- resultJson.put("message", "参数不能为空");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- Admin login = appService.login(admin_name,password);
|
|
|
- if (login==null){
|
|
|
- resultJson.put("message", "账户或密码错误");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- JSONObject jsonObject = appService.getGCodeInfo(code);
|
|
|
- Admin admin = appService.queryByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
|
|
|
- if (admin==null){
|
|
|
- resultJson.put("message", "输入信息与当前绑定账户不匹配");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- int m = appService.updateOpenidNull(jsonObject.get("openid").toString());
|
|
|
- if (m>0){
|
|
|
- resultJson.put("message", "解绑成功");
|
|
|
- resultJson.put("code", 200);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- resultJson.put("message", "解绑失败");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- /******************************商户绑定*******************************/
|
|
|
- public String get_user_ma(){
|
|
|
- JSONObject resultJson = new JSONObject();
|
|
|
- if (code==null){
|
|
|
- resultJson.put("message", "参数不能为空");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- JSONObject jsonObject = appService.getGCodeInfo(code);
|
|
|
- AdminManager admin = appService.queryMaByOpenid(jsonObject.get("openid").toString());
|
|
|
- if (admin==null){
|
|
|
- resultJson.put("message", "未绑定信息");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- resultJson.put("message", "返回成功");
|
|
|
- resultJson.put("code", 200);
|
|
|
- resultJson.put("data", admin);
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- public String manage_code(){
|
|
|
- JSONObject resultJson = new JSONObject();
|
|
|
- if (code==null || admin_name==null || password==null){
|
|
|
- resultJson.put("message", "参数不能为空");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- AdminManager login = appService.login_ma(admin_name,password);
|
|
|
- if (login==null){
|
|
|
- resultJson.put("message", "账户或密码错误");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- if (login.getLevel().equals("1")){
|
|
|
- resultJson.put("message", "管理员无权限绑定");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- JSONObject jsonObject = appService.getGCodeInfo(code);
|
|
|
- AdminManager admin = appService.queryMaByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
|
|
|
- if (admin!=null){
|
|
|
- resultJson.put("message", "该账户已绑定,请勿重复绑定");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data",admin);
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- int m = appService.updateMaOpenid(jsonObject.get("openid").toString(),admin_name);
|
|
|
- if (m>0){
|
|
|
- admin = appService.queryMaByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
|
|
|
- resultJson.put("message", "绑定成功");
|
|
|
- resultJson.put("code", 200);
|
|
|
- resultJson.put("data",admin);
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- public String uncode_ma(){
|
|
|
- JSONObject resultJson = new JSONObject();
|
|
|
- if (code==null || admin_name==null || password==null){
|
|
|
- resultJson.put("message", "参数不能为空");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- AdminManager login = appService.login_ma(admin_name,password);
|
|
|
- if (login==null){
|
|
|
- resultJson.put("message", "账户或密码错误");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- JSONObject jsonObject = appService.getGCodeInfo(code);
|
|
|
- AdminManager admin = appService.queryMaByNameAndOpenid(admin_name,jsonObject.get("openid").toString());
|
|
|
- if (admin==null){
|
|
|
- resultJson.put("message", "输入信息与当前绑定账户不匹配");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- int m = appService.updateMaOpenidNull(jsonObject.get("openid").toString());
|
|
|
- if (m>0){
|
|
|
- resultJson.put("message", "解绑成功");
|
|
|
- resultJson.put("code", 200);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
- resultJson.put("message", "解绑失败");
|
|
|
- resultJson.put("code", 205);
|
|
|
- resultJson.put("data","");
|
|
|
- ResUtil.writeJson(ServletActionContext.getResponse(), resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- /**=============================新闻资讯==============================**/
|
|
|
- public String autoInsertNews() throws Exception {
|
|
|
- int total = Get_airticle.getTotal();
|
|
|
- int rows = 10;
|
|
|
- int page = total % rows == 0 ? (total / rows)
|
|
|
- : (total / rows) + 1;
|
|
|
- for (int k = 0; k < page; k++) {
|
|
|
- List<Item_content> litem = appService.getNews(k,rows);
|
|
|
- for (int i = 0; i < litem.size(); i++) {
|
|
|
- Item_content ic = litem.get(i);
|
|
|
- Content content = ic.getContent();
|
|
|
- List<News_content> news_item = content.getNews_item();
|
|
|
- for (int j = 0; j < news_item.size(); j++) {
|
|
|
- News news = appService.queryByTit(news_item.get(j).getTitle());
|
|
|
- if (news==null){
|
|
|
- System.out.println("插入标题:"+news_item.get(j).getTitle());
|
|
|
- News nw = new News();
|
|
|
- nw.setTitle(news_item.get(j).getTitle());
|
|
|
- nw.setAuthor(news_item.get(j).getAuthor());
|
|
|
- nw.setContent(news_item.get(j).getContent());
|
|
|
- nw.setDigest(news_item.get(j).getDigest());
|
|
|
- nw.setContent_source_url(news_item.get(j).getContent_source_url());
|
|
|
- nw.setUpdate_time(TimeExchange.getTime());
|
|
|
- appService.insertNews(nw);
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- public String newlist() {
|
|
|
- JSONObject resultJson = new JSONObject();
|
|
|
- int total = appService.queryNewTotal("");// 查询表中的总记录数
|
|
|
- List<News> listPage = appService.queryNewPage(page, rows,"");// 查询分页
|
|
|
-
|
|
|
- if (listPage == null) {
|
|
|
- resultJson.put("rows", "");
|
|
|
- resultJson.put("total", 0);
|
|
|
- } else {
|
|
|
- resultJson.put("code", 200);
|
|
|
- resultJson.put("rows", listPage);
|
|
|
- // int total = listAll.size();
|
|
|
- resultJson.put("total", total);// 总记录数
|
|
|
- int totalPage = total % rows == 0 ? (total / rows)
|
|
|
- : (total / rows) + 1;// 总页数
|
|
|
- resultJson.put("totalPage", totalPage);
|
|
|
- resultJson.put("currentPage", page);// 当前页
|
|
|
- resultJson.put("numPerPage", rows);// 每页数
|
|
|
- resultJson.put("nextPage", totalPage - page == 0 ? page : page + 1);// 下一页
|
|
|
- resultJson.put("previousPage", page - 0 == 1 ? page : page - 1);// 上一页
|
|
|
- resultJson.put("hasPreviousPage", true);// 有上一页
|
|
|
- resultJson.put("hasNextPage", true);// 有下一页
|
|
|
- resultJson.put("firstPage", true);// 首页
|
|
|
- resultJson.put("lastPage", true);// 尾页
|
|
|
- }
|
|
|
- ResponseUtil.writeJson(ServletActionContext.getResponse(),
|
|
|
- resultJson.toString());
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
-}
|