Skip to content

G
gdtel-gztel-school-center
Commit cbe23d20 by 陈浩建
Options

一人一码订单调整（部分）

parent 4918f6fb
Showing with 321 additions and 509 deletions
common/src/main/java/com/winsun/mapper/Basemapper.java deleted 100644 → 0
package com.winsun.mapper;
import com.winsun.bean.Page;
import com.winsun.utils.Is;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.support.lob.DefaultLobHandler;
import org.springframework.jdbc.support.lob.LobHandler;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
/**
* springjdbc baseDao
* @author lisilin
* @since 0.1
*/
public abstract class Basemapper<T> {
@Autowired
protected JdbcTemplate jdbcTemplate;
public LobHandler lobHandler = new DefaultLobHandler();
/**
* 适用于更新数据库,insert,update, delete
*
* @param namedSql:命名参数的ＳＱＬ语句，而且参数的命名必须和ＪａｖａＢｅａｎ中的属性名对应
* @param javaBean
* @return
*/
/**
* 带参数更新
* @param sql
* @param paramValue
* @return
*/
protected int update(String sql, Object... paramValue) {
return jdbcTemplate.update(sql, paramValue);
}
/**
* 批量带参数更新（针对更新SQL一致，参数不一致）
* @param sql
* @param paramValue
* @return
*/
protected int[] batchUpdate(String sql, List<Object[]> paramValue) {
return jdbcTemplate.batchUpdate(sql, paramValue);
}
/**
* 批量sql更新（针对更新SQL不一致）
* @param sql
* @return
*/
protected int[] batchUpdate(String[] sql) {
return jdbcTemplate.batchUpdate(sql);
}
@SuppressWarnings("unchecked")
protected Page<?> findDwon (@SuppressWarnings("rawtypes") Page page, String sql, Object[] pars,RowMapper<T> rowMapper) throws Exception{
String pageQueryString = getMysqlPageSQL(sql);
String countSql = this.getCountQuerySQL(sql);
if(null==rowMapper){
List<Map<String,Object>> list = jdbcTemplate.queryForList(pageQueryString, pars);
page.setResult(list);
}else{
List<T> list = jdbcTemplate.query(pageQueryString, pars, rowMapper);
page.setResult(list);
}
int count = jdbcTemplate.queryForObject(countSql, pars, Integer.class);
if (count > 0) {
page.setTotalCount(count);
} else {
page.setTotalCount(0);
}
return page;
}
/**
* 构造Mysql数据分页SQL
* @param queryString
* @param startIndex
* @param pageSize
* @return
*/
protected String getMysqlPageSQL(String queryString, Integer startIndex, Integer pageSize) {
if (StringUtils.isEmpty(queryString))
{
return null;
}
startIndex = (startIndex - 1) * pageSize;
int endIndex = pageSize;
String endSql = queryString;
if(endIndex>0){
endSql += " limit " + startIndex +"," + endIndex;
}
return endSql;
}
protected String getMysqlPageSQL(String queryString) {
if (StringUtils.isEmpty(queryString))
{
return null;
}
return queryString;
}
/**
* 构造 Oracle数据分页SQL
* @param queryString
* @param startIndex
* @param pageSize
* @return
*/
protected String getOraclePageSQL(String queryString, Integer startIndex, Integer pageSize)
{
if (StringUtils.isEmpty(queryString))
{
return null;
}
// String itemSource =
queryString.toLowerCase();
startIndex = (startIndex - 1) * pageSize;
int endIndex = startIndex + pageSize + 1;
String endSql = "select * from (select rOraclePageSQL.*,ROWNUM as currentRow from (" +
queryString + ") rOraclePageSQL where rownum <=" + endIndex + ") where currentRow>" + startIndex;
return endSql;
}
/**
* 构造统计SQL
* @param queryString
* @return
*/
protected String getCountQuerySQL(String queryString) {
String sql = "";
if (StringUtils.isNotEmpty(queryString))
{
sql = "select count(*) from (" + queryString + ") xCount";
}
return sql;
}
/**
* 带条件查询,组装并返回sql
* @param map
* @return
* @throws Exception
*/
public Map<String,Object> select(String table,Map<String,Object> map)throws Exception{
StringBuffer sf = new StringBuffer();
List<Object> pars = new ArrayList<Object>();
sf.append("select * from "+table+" where 1=1");
if(null!=map){
/*Set<String> set = map.keySet();
Iterator<String> iter = set.iterator();
while(iter.hasNext()){
String key = (String)iter.next();
if(Is.isNoEmpty(map.get(key))){
sf.append(" and "+key+" like ? ");
pars.add("%"+map.get(key)+"%");
}
}*/
for (Entry<String, Object> entry : map.entrySet()) {
String key = entry.getKey();
if(Is.isNoEmpty(entry.getValue())){
sf.append(" and "+key+" like ? ");
pars.add("%"+entry.getValue()+"%");
}
}
/* for (Entry<String, Object> entry : map.entrySet()) {
if(!entry.getKey().equals("id")){
sf.append(entry.getKey()+"=?,");
pars.add(entry.getValue());
}
}*/
}
map.put("sql", sf.toString());
map.put("pars", pars);
return map;
}
/**
* 带条件查询
* @param map
* @return
* @throws Exception
*/
public List<Map<String,Object>> selectList(String table,Map<String,Object> map)throws Exception{
StringBuffer sf = new StringBuffer();
List<Object> pars = new ArrayList<Object>();
sf.append("select * from "+table+" where 1=1");
if(null!=map){
/* Set<String> set = map.keySet();
Iterator<String> iter = set.iterator();
while(iter.hasNext()){
String key = (String)iter.next();
if(Is.isNoEmpty(map.get(key))){
sf.append(" and "+key+" like ? ");
pars.add("%"+map.get(key)+"%");
}
}*/
for (Entry<String, Object> entry : map.entrySet()) {
String key = entry.getKey();
if(Is.isNoEmpty(entry.getValue())){
sf.append(" and "+key+" like ? ");
pars.add("%"+entry.getValue()+"%");
}
}
}
return jdbcTemplate.queryForList(sf.toString(), pars.toArray());
}
/**
* 带条件查询
* @param map
* @return
* @throws Exception
*/
public List<Map<String,Object>> selectListForEquest(String table,Map<String,Object> map)throws Exception{
StringBuffer sf = new StringBuffer();
List<Object> pars = new ArrayList<Object>();
sf.append("select * from "+table+" where 1=1");
if(null!=map){
/*Set<String> set = map.keySet();
Iterator<String> iter = set.iterator();
while(iter.hasNext()){
String key = (String)iter.next();
if(Is.isNoEmpty(map.get(key))){
sf.append(" and "+key+" = ? ");
pars.add(map.get(key));
}
}*/
for (Entry<String, Object> entry : map.entrySet()) {
String key = entry.getKey();
if(Is.isNoEmpty(entry.getValue())){
sf.append(" and "+key+" = ? ");
pars.add(entry.getValue());
}
}
}
return jdbcTemplate.queryForList(sf.toString(), pars.toArray());
}
/**
* 带参数插入
* @param map
* @throws Exception
*/
public void insert(String table,Map<String,Object> map)throws Exception{
StringBuffer sf = new StringBuffer();
map.remove("color");//去除多余的参数
map.remove("phoneLogo");
map.remove("rom");
map.remove("price");
map.remove("packageName");
String sql=" values(";
List<Object> pars = new ArrayList<Object>();
sf.append("insert into "+table+"(");
if(null!=map){
/*Set<String> set = map.keySet();
Iterator<String> iter = set.iterator();
while(iter.hasNext()){
String key = (String)iter.next();
sf.append(key+",");
sql+="?,";
pars.add(map.get(key)==null?"":map.get(key));
}*/
for (Entry<String, Object> entry : map.entrySet()) {
String key = entry.getKey();
sf.append(key+",");
sql+="?,";
pars.add(entry.getValue()==null?"":entry.getValue());
}
sql=sql.substring(0, sql.length()-1)+")";
sql=sf.substring(0,sf.length()-1).toString()+")"+sql;
}
jdbcTemplate.update(sql, pars.toArray());
}
/**
* 带参数插入
* @param table
* @param list
* @param pars
* @throws Exception
*/
public void insert(String table,List<Object> list,List<Object[]> pars)throws Exception{
StringBuffer sf = new StringBuffer();
String sql=" values(";
sf.append("insert into "+table+"(");
if(null!=list){
for(int i=0;i<list.size();i++){
sf.append(list.get(i)+",");
sql+="?,";
}
sql=sql.substring(0, sql.length()-1)+")";
sql=sf.substring(0,sf.length()-1).toString()+")"+sql;
}
jdbcTemplate.batchUpdate(sql, pars);
}
/**
* 修改
* @param map
* @throws Exception
*/
public int update(String table,Map<String,Object> map)throws Exception{
StringBuffer sf = new StringBuffer();
String sql="";
List<Object> pars = new ArrayList<Object>();
sf.append("update "+table+" set ");
if(null!=map){
/* Set<String> set = map.keySet();
Iterator<String> iter = set.iterator();
while(iter.hasNext()){
String key = (String)iter.next();
if(!key.equals("id")){
sf.append(key+"=?,");
pars.add(map.get(key));
}
}*/
for (Entry<String, Object> entry : map.entrySet()) {
if(!entry.getKey().equals("id")){
sf.append(entry.getKey()+"=?,");
pars.add(entry.getValue());
}
}
pars.add(map.get("id"));
sql = sf.substring(0, sf.length()-1)+" where id=?";
}
return jdbcTemplate.update(sql, pars.toArray());
}
public int updateOrderView(String table,Map<String,Object> map)throws Exception{
StringBuffer sf = new StringBuffer();
String sql="";
List<Object> pars = new ArrayList<Object>();
sf.append("update "+table+" set ");
if(null!=map){
for (Entry<String, Object> entry : map.entrySet()) {
if(!entry.getKey().equals("order_id")){
sf.append(entry.getKey()+"=?,");
pars.add(entry.getValue());
}
}
pars.add(map.get("order_id"));
sql = sf.substring(0, sf.length()-1)+" where order_id=?";
}
return jdbcTemplate.update(sql, pars.toArray());
}
/**
* 修改
* @throws Exception
*/
public void updateBatch(String sql,List<Object[]> pars)throws Exception{
jdbcTemplate.batchUpdate(sql, pars);
}
/**
* 带参数修改，自带where条件
* @param table
* @param map
* @param id
* @throws Exception
*/
public void update(String table,Map<String,Object> map,String id)throws Exception{
StringBuffer sf = new StringBuffer();
String sql="";
List<Object> pars = new ArrayList<Object>();
sf.append("update "+table+" set ");
if(null!=map){
/*Set<String> set = map.keySet();
Iterator<String> iter = set.iterator();
while(iter.hasNext()){
String key = (String)iter.next();
if(!key.equals(id)){
sf.append(key+"=?,");
pars.add(map.get(key));
}
}*/
for (Entry<String, Object> entry : map.entrySet()) {
String key = entry.getKey();
if(!key.equals("id")){
sf.append(key+"=?,");
pars.add(entry.getValue());
}
}
pars.add(map.get(id));
sql = sf.substring(0, sf.length()-1)+" where "+id+"=?";
}
jdbcTemplate.update(sql, pars.toArray());
}
public int updatebyId(String table,Map<String,Object> map,String id)throws Exception{
StringBuffer sf = new StringBuffer();
String sql="";
List<Object> pars = new ArrayList<Object>();
sf.append("update "+table+" set ");
if(null!=map){
for (Entry<String, Object> entry : map.entrySet()) {
String key = entry.getKey();
String value = entry.getValue().toString();
sf.append(key+"=");
sf.append("'");
sf.append(value);
sf.append("'");
sf.append(",");
}
pars.add(id);
sql = sf.substring(0, sf.length()-1)+" where id='"+id+"'";
}
return jdbcTemplate.update(sql);
}
public void delete(String table,String id)throws Exception{
String sql = "delete from "+table+" where id=?";
if(StringUtils.isNotBlank(id)){
jdbcTemplate.update(sql, id);
}
}
public void delete(String table,Map<String,Object> map)throws Exception{
StringBuffer sf = new StringBuffer();
List<Object> pars = new ArrayList<Object>();
sf.append("delete from "+table+" where 1=1 ");
if(null!=map){
/*Set<String> set = map.keySet();
Iterator<String> iter = set.iterator();
while(iter.hasNext()){
String key = (String)iter.next();
if(Is.isNoEmpty(map.get(key))){
sf.append(" and "+key+" = ? ");
pars.add(map.get(key));
}
}*/
for (Entry<String, Object> entry : map.entrySet()) {
String key = entry.getKey();
if(Is.isNoEmpty(entry.getValue())){
sf.append(" and "+key+" = ? ");
pars.add(entry.getValue());
}
}
}
jdbcTemplate.update(sf.toString(), pars.toArray());
}
public void createField(String table,List<Map<String,Object>> fieldName){
String sql = "SELECT COLUMN_NAME FROM information_schema.columns WHERE table_schema = DATABASE() AND table_name = '"+table+"' ";
List<Map<String,Object>> list = jdbcTemplate.queryForList(sql);
StringBuffer sb = new StringBuffer();
sb.append("alter table "+table);
int i=0;
for(i=0;i<fieldName.size();i++){
boolean falg = true;
for(int j=0;j<list.size();j++){
if(fieldName.get(i).get("fieldEngName").equals(list.get(j).get("COLUMN_NAME"))) falg = false;
}
if(falg){
sb.append(" add "+fieldName.get(i).get("fieldEngName")+" VARCHAR(100) DEFAULT NULL COMMENT '"+fieldName.get(i).get("fieldName")+"'");
if(i<fieldName.size()-1){
sb.append(",");
}
}
}
jdbcTemplate.update(sb.toString());
}
}
\ No newline at end of file
common/src/main/java/com/winsun/mapper/OrderMapper.java
......@@ -78,4 +78,19 @@ public interface OrderMapper extends BaseMapper<Order> {
@Select("select ysm from `hhr_user` where id = #{id}")
String selectYsmById(String id);
@Select("SELECT * FROM hhr_order WHERE id = #{id}")
List<Map<String,Object>> findHhrOrderId(String id);
@Select("select * from product_manage where product_title = #{productTitle} and product_region = #{universityRegion} and product_university = #{universityName} and product_state=0")
List<Map<String,Object>> queExiteProductNameData(String productTitle, String universityRegion, String universityName);
@Select("select * from university_info where university_name = #{universityName} and university_region =#{universityRegion}")
List<Map<String,Object>> queUniversityNameData(String universityName, String universityRegion);
@Select("select ui.* from product_manage pm " +
" join university_info ui on ui.university_id = pm.university_id " +
" and product_title = #{productTitle} and product_region = #{universityRegion} and product_university = #{universityName} and product_state=0 ")
List<Map<String,Object>> queProductNameDataToUniversityNameData(String productTitle, String universityRegion, String universityName);
}
service-manager/src/main/java/com/winsun/controller/OrderController.java
......@@ -4,6 +4,7 @@ import com.alibaba.excel.EasyExcel;
import com.alibaba.excel.ExcelWriter;
import com.alibaba.excel.support.ExcelTypeEnum;
import com.alibaba.excel.write.metadata.WriteSheet;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.enums.SqlLike;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
......@@ -43,25 +44,22 @@ import org.apache.poi.xssf.usermodel.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;
import javax.net.ssl.SSLHandshakeException;
import javax.servlet.ServletOutputStream;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
import java.io.*;
import java.net.URLEncoder;
import java.nio.charset.Charset;
import java.security.NoSuchAlgorithmException;
import java.text.SimpleDateFormat;
import java.time.LocalDate;
import java.util.*;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
/**
* @Author: dongyp
......@@ -111,7 +109,6 @@ public class OrderController extends BaseController {
protected ThreadPoolTaskExecutor threadPool;
protected static Basemapper basemapper;
@Autowired
private RabbitProducer taskImport;
......@@ -171,12 +168,12 @@ public class OrderController extends BaseController {
/**
* 修改为异常单
*/
@Permission(menuname = "修改为异常单", value = "abnormal", method = RequestMethod.POST)
public ResponseData<String> abnormal(@RequestParam("orderId") String orderId) {
@Permission(menuname = "修改为异常单", value = "setAbnormal", method = RequestMethod.POST)
public ResponseData<String> abnormal(@RequestParam("orderId") String orderId,@RequestParam("errorMsg") String errorMsg) {
ShiroUser user = getShiroUser();
/*if (!user.getRoleNames().stream().anyMatch(roleName -> StringUtils.equalsAny(roleName, "超级管理员"))) {
if (user.getRoleNames().stream().anyMatch(roleName -> StringUtils.equalsAny(roleName, "受理人员","楼长"))) {
return ResponseData.error("无数据权限");
}*/
}
Wrapper wrapper = new EntityWrapper<>();
wrapper.eq("id", orderId);
Map<String, Object> dataMapping = new HashMap<>();
......@@ -184,7 +181,7 @@ public class OrderController extends BaseController {
dataMapping.put("success_time", new Date());
Integer integer = orderMapper.updateForSet(MyBatisPlusUpdateUtils.toUpdateSet(dataMapping), wrapper);
if (integer == 1) {
appMapper.inserOrderHis(orderId, "异常单!", new Date(), user.getName());
appMapper.inserOrderHis(orderId, "设置异常单,原因："+errorMsg, new Date(), user.getName());
return ResponseData.success("设为异常单成功！");
}
return ResponseData.error("设为异常单失败！");
......@@ -251,6 +248,115 @@ public class OrderController extends BaseController {
return ResponseData.success(page, "查询完毕！");
}
/**
* 编辑订单
*
* @return
*/
@Permission(menuname = "编辑订单", value = "editOrder", method = RequestMethod.POST)
public ResponseData<String> editOrder(@RequestParam("id") String id,@RequestParam(value = "studentNumber",required = false) String student_number,
@RequestParam(value = "classNumber",required = false) String class_number,@RequestParam(value = "parentName",required = false) String parent_name,
@RequestParam(value = "contactNumber",required = false) String contact_number, @RequestParam(value = "idCard",required = false) String id_card,
@RequestParam(value = "studentCard",required = false) String student_card,@RequestParam(value = "address",required = false) String address,
@RequestParam(value = "site",required = false) String site, @RequestParam(value = "remarks",required = false) String remarks,@RequestParam(value = "orderStatus",required = false) String order_status) {
ShiroUser user = getShiroUser();
List<Map<String, Object>> hhrOrderId = orderMapper.findHhrOrderId(id);
if(hhrOrderId.size()!=1){
return ResponseData.error("无数据查询");
}
Map<String, Object> order = hhrOrderId.get(0);
StringBuffer sf = new StringBuffer();
int num = 0;
if (StringUtils.isNotBlank(student_card)) {
try {
String hhr_img = prop.getProperty("hhr_img");
prop.load(in);
//重新上传图片
String base64Data = student_card.split(",")[1];
String houzhui = student_card.split(",")[0].split("/")[1].split(";")[0];
/**
* 2.解码成字节数组
*/
String filePath = hhrOrderId.get(0).get("studen_card").toString();
Base64.Decoder decoder = Base64.getDecoder();
byte[] bytes = decoder.decode(base64Data);
FileOutputStream fos = null;
try {
fos = new FileOutputStream(filePath);
fos.write(bytes);
} catch (IOException e) {
e.printStackTrace();
} finally {
if (fos != null){
try {
fos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
} catch (Exception e) {
e.printStackTrace();
return ResponseData.error("服务器出错！");
}
sf.append(",重新上传学生证");
}
Wrapper wrapper = new EntityWrapper<>();
wrapper.eq("id", id);
Map<String, Object> dataMapping = new HashMap<>();
if(StringUtils.isNoneBlank(student_number) && !student_number.equals(hhrOrderId.get(0).get("student_number"))){
dataMapping.put("student_number",student_number);
sf.append(",用户学号由"+order.get("student_number")+"修改为"+student_number);
}
if(StringUtils.isNoneBlank(class_number) && !class_number.equals(hhrOrderId.get(0).get("class_number"))){
dataMapping.put("class_number",class_number);
sf.append(",用户班级由"+order.get("class_number")+"修改为"+class_number);
}
if(StringUtils.isNoneBlank(parent_name) && !parent_name.equals(hhrOrderId.get(0).get("parent_name"))){
dataMapping.put("parent_name",parent_name);
sf.append(",用户家长姓名由"+order.get("parent_name")+"修改为"+parent_name);
}
if(StringUtils.isNoneBlank(contact_number) && !contact_number.equals(hhrOrderId.get(0).get("contact_number"))){
dataMapping.put("contact_number",contact_number);
sf.append(",联系号码由"+order.get("contact_number")+"修改为"+contact_number);
}
if(StringUtils.isNoneBlank(id_card) && !id_card.equals(hhrOrderId.get(0).get("id_card"))){
dataMapping.put("id_card",id_card);
sf.append(",身份证号由"+order.get("id_card")+"修改为"+id_card);
}
if(StringUtils.isNoneBlank(address) && !address.equals(hhrOrderId.get(0).get("address"))){
dataMapping.put("address",address);
sf.append(",地址由"+order.get("address")+"修改为"+address);
}
if(StringUtils.isNoneBlank(site) && !site.equals(hhrOrderId.get(0).get("site"))){
dataMapping.put("site",site);
sf.append(",区域由"+order.get("site")+"修改为"+site);
}
if(StringUtils.isNoneBlank(remarks) && !remarks.equals(hhrOrderId.get(0).get("remarks"))){
dataMapping.put("remarks",remarks);
sf.append(",备注由"+order.get("remarks")+"修改为"+remarks);
}
if(StringUtils.isNoneBlank(order_status) && !order_status.equals(hhrOrderId.get(0).get("order_status"))){
dataMapping.put("order_status",order_status);
sf.append(",订单状态由"+order.get("order_status")+"修改为"+order_status);
}
try {
Integer integer = orderMapper.updateForSet(MyBatisPlusUpdateUtils.toUpdateSet(dataMapping), wrapper);
if(integer == 1){
orderMapper.inserOrderHis(id,"用户资料修改:"+sf.toString(),new Date(),user.getName());
return ResponseData.success("编辑完毕！");
}
} catch (Exception e) {
e.printStackTrace();
return ResponseData.error("服务器出错！");
}
return ResponseData.success("编辑完毕！");
}
@Permission(menuname = "导出订单", value = "download", method = RequestMethod.POST)
public ResponseData<String> downloadOrderView(
@RequestParam(name = "createTimeStart", required = false) String createTimeStart,
......@@ -903,7 +1009,7 @@ public class OrderController extends BaseController {
}
}
try {
basemapper.update("hhr_order",map3);
// basemapper.update("hhr_order",map3);
} catch (Exception e) {
e.printStackTrace();
}
......@@ -912,7 +1018,7 @@ public class OrderController extends BaseController {
});
int num = 0;
try {
num = basemapper.update("hhr_order",map1) > 0 ? 1 : 0;
// num = basemapper.update("hhr_order",map1) > 0 ? 1 : 0;
number+=num;
} catch (Exception e) {
e.printStackTrace();
......@@ -925,7 +1031,7 @@ public class OrderController extends BaseController {
history.put("create_date", sdf.format(new Date()));
history.put("status", "实名验证中");
try {
basemapper.insert("hhr_order_history", history);
// basemapper.insert("hhr_order_history", history);
} catch (Exception e) {
e.printStackTrace();
}
......@@ -1423,4 +1529,187 @@ public class OrderController extends BaseController {
return resultStr;
}
@Permission(menuname = "业务预受理表参数返回", method = RequestMethod.GET, value = "findReportMap")
public void findReportMap(HttpServletRequest request,HttpServletResponse response,String callback) throws IOException {
String prices = null;
String byStr = null;
String mealStr = null;
String month = null;
String expenses = "";
String product_price = ""; // 资费
String identifying = ""; // 提速包：
String identifying_price = ""; // 提速包资费
String identifyingStr = ""; // 提速包
String tyMeal = "";
String university_domain_name = ""; // 后缀
boolean speed_up = false;
boolean product_price_CB = false;
boolean new_clothes_CB = false;
boolean setMealCB = false;
Map<String, Object> QueUniversityData ;
String isFromRh = request.getParameter("isFromRh"); // 融合
String partner = request.getParameter("partner"); // 合伙人id
String productTitle = request.getParameter("productTitle"); // 宽带标题
String universityRegion = request.getParameter("universityRegion"); // 县份
String universityName = request.getParameter("universityName"); // 学校名
String setMeal = request.getParameter("setMeal");
String setMealIndex = request.getParameter("setMealIndex");
String sl = request.getParameter("sl"); // 宽带提速速率
String ex = request.getParameter("ex"); // 宽带速率
Map<String, Object> QueProductIdData = orderMapper.queExiteProductNameData(productTitle, universityRegion, universityName).get(0);
QueUniversityData = orderMapper.queUniversityNameData(universityName, universityRegion).get(0);
if(QueUniversityData != null && QueUniversityData.size()>1){
QueUniversityData = orderMapper.queProductNameDataToUniversityNameData(productTitle, universityRegion, universityName).get(0);
}
String[] rateArry = ((String) QueProductIdData.get("product_rate")).split(","); // 年月（包年,包月）
String[] mealArry = ((String)QueProductIdData.get("product_meal")).split(","); // 套餐 （4M，8M，20M等）
String[] priceArry = ((String) QueProductIdData.get("product_price")).split(","); // 金额（300,30）
if(StringUtils.isNotBlank(isFromRh) && isFromRh=="true") {
rateArry = ((String) QueProductIdData.get("product_rh_rate")).split(","); // 年月（包年,包月）
priceArry = ((String) QueProductIdData.get("product_rh_price")).split(","); // 金额（300,30）
}
Integer index = 0;
if(StringUtils.isNotBlank(setMealIndex)){
index = Integer.parseInt(setMealIndex);
}
byStr = rateArry[index];
mealStr = mealArry[index];
prices = priceArry[index];
if(byStr.equals("包年")){
month = "12";
}else{
month = "1";
}
new_clothes_CB = true;
tyMeal = "预付费校园";
setMealCB = true;
// 融合/提速 提速包：
String regEx="[^0-9]";
Pattern p = Pattern.compile(regEx);
identifying = QueUniversityData.get("identifying").toString();
expenses = (String) QueUniversityData.get("expenses");
if(StringUtils.isNotBlank(expenses)){
expenses = expenses.replace("M","");
}
university_domain_name = (String)QueUniversityData.get("university_domain_name");
if(StringUtils.isNotBlank(university_domain_name)){
university_domain_name = university_domain_name.replace("@","");
}
product_price_CB = true;
if(identifying.contains("免费")){
identifying_price = "0";
identifyingStr = identifying;
}else{
Matcher m = p.matcher(identifying);
identifying_price = m.replaceAll("").trim();
if(StringUtils.isNotBlank(identifying)){
identifyingStr = identifying.substring(0,8);
}
}
if(StringUtils.isNotBlank(sl)){
new_clothes_CB = false;
}
// 单宽
if(StringUtils.isBlank(isFromRh) && StringUtils.isBlank(sl)){
identifying_price = "";
identifyingStr = "";
tyMeal = "";
setMealCB = false;
product_price_CB = false;
expenses = "";
university_domain_name = "";
}
String seal = "";
// String url = "D:\\Projects\\wxProject\\gdtel-xyzx-hhr\\WebContent\\images\\seal\\seal.png";
String url = this.getClass().getResource("/").getPath();
int num = url.indexOf("gdtel-xyzx-hhr");
url = url.substring(0,num);
url = url + "gdtel-xyzx-hhr/images/seal/seal.png";
// 获取协议印章图片
seal = getPhoto(url);
// 返回的参数
Map<String, Object> mapData = new HashMap<>();
mapData.put("channel_number",""); // 渠道工号
mapData.put("student_name",""); // 姓名
mapData.put("student_number",""); // 学号
mapData.put("contact_number",""); // 联系方式
mapData.put("id_card",""); // 身份证号码
mapData.put("universityName",universityName); //学校：
mapData.put("department",""); // 系
mapData.put("setClass",""); // 班级
mapData.put("dormitory",""); // 宿舍
mapData.put("setMealCB",setMealCB); // 我要办理天翼@_@套餐 checkbox
mapData.put("tyMeal",tyMeal); // 我要办理天翼@_@套餐
mapData.put("setMealIndex",setMealIndex); // 套餐下标
mapData.put("upgradeCB",false); // 我要办理老用户套餐升级： checkbox
mapData.put("upgrade",""); // 我要办理老用户套餐升级：
mapData.put("original_package",""); // 原套餐：
mapData.put("new_package",""); // 转新套餐：
mapData.put("new_clothes_CB",new_clothes_CB); // 新装 checkbox
mapData.put("change_CB",""); // 变更 checkbox
mapData.put("product_price",prices); // 资费
mapData.put("month",month); // 包年/包月 12/1
mapData.put("product_other",""); // （其他）
mapData.put("speed_up",speed_up); // 我要办理宽带提速： checkbox
mapData.put("product_price_CB",product_price_CB); // 在原基础宽带资费外每月低消/加价 checkbox
mapData.put("product_price_up",identifying_price); // 在原基础宽带资费外每月低消/加价____元
mapData.put("expenses",expenses); // 宽带提速 ______M
mapData.put("university_domain_name",university_domain_name); // 账号为______@______后缀
mapData.put("phone_CB",false); // 只为手机号 checkbox
mapData.put("phone_TD",""); // 只为手机号____退订
mapData.put("phone_TD_price",""); // 退订每月____元
mapData.put("phone_product_meal",""); // 提速至____M
mapData.put("acceleration_package_CB",false); // 办理加速包 checkbox
mapData.put("business_number",""); // 办理加速包 手机号为：
mapData.put("identifying",identifying); // 办理加速包:
mapData.put("identifying_price",identifying_price); // 办理__元
mapData.put("identifyingStr",identifyingStr); // 办理加速包
mapData.put("university_package_number",""); // 揽装工号：
mapData.put("remarks",""); // 其他备注：
mapData.put("seal",seal); // 印章
response.setContentType("text/json; charset=utf-8");
response.setHeader("Access-Control-Allow-Origin", "*");
PrintWriter writer = response.getWriter();
//需要把jsonp生成的参数带回前台，jsonp才能解析
writer.print(callback + "("+ JSON.toJSONString(mapData)+")");
writer.close();
}
//path 为图片在服务器的绝对路径
public String getPhoto(String url) {
try {
File file = new File(url);
FileInputStream fis;
fis = new FileInputStream(file);
long size = file.length();
byte[] temp = new byte[(int) size];
fis.read(temp, 0, (int) size);
fis.close();
byte[] data = temp;
return new String(org.apache.commons.codec.binary.Base64.encodeBase64(data));
} catch (IOException e) {
e.printStackTrace();
return null;
}
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment