基于SpringMVC的小项目

package com.paic.pad.wealth.custDetails.web.rest; import static com.paic.pad.common.utils.ConstantsEnum.MAIL_TPL_LUFAX; import static com.paic.pad.common.utils.ConstantsEnum.SMS_BENEFIT_SERIES_ID; import static com.paic.pad.common.utils.ConstantsEnum.SMS_SENDER_ID; import static com.paic.pad.common.utils.ConstantsEnum.SMS_SENDER_SERIES_ID; import static com.paic.pad.common.utils.ConstantsEnum.SMS_SENDER_VITUAL_USER; import static com.paic.pad.common.utils.ConstantsEnum.SMS_TPL_CUST_APPOINTMENT; import static com.paic.pad.common.utils.ConstantsEnum.SMS_TPL_INTENT_CONFIRM_IN; import static com.paic.pad.common.utils.ConstantsEnum.SMS_TPL_INTENT_CONFIRM_OUT; import static com.paic.pad.common.utils.ConstantsEnum.SMS_TPL_INTRODUCT_MEETING; import static com.paic.pad.common.utils.ConstantsEnum.SMS_TPL_MAIL_NOTIFICATION; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Collection; import java.util.Date; import java.util.Map; import java.util.HashMap; import java.util.List; import java.util.Set; import javax.servlet.ServletOutputStream; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import com.alibaba.fastjson.annotation.JSONField; import com.google.common.collect.LinkedHashMultimap; import com.google.common.collect.Maps; import com.google.common.collect.Multimap; import com.paic.pafa.web.BaseRest; import com.paic.pafa.web.WebException; import com.paic.pafa.web.session.Uid; import org.apache.commons.beanutils.BeanUtils; import org.apache.commons.lang.StringUtils; 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.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.multipart.MultipartHttpServletRequest; import org.springframework.web.multipart.commons.CommonsMultipartFile; import org.springframework.web.util.WebUtils; import com.paic.pafa.appclient.IServiceClient; import com.paic.pafa.appclient.ServiceResults; import com.paic.pafa.appclient.annotation.ActionClient; import com.paic.pafa.appclient.annotation.BizServicesProxy; import com.paic.pafa.biz.services.ServicesException; import com.paic.pad.common.dto.UserDTO; import com.paic.pad.common.utils.ConstantsEnum; import com.paic.pad.common.utils.UploadFileToNas; import com.paic.pad.wealth.admin.web.util.FileUtil; import com.paic.pad.wealth.sale.biz.service.AppointmentHisotryService; import com.paic.pad.wealth.sale.biz.service.AppointmentService; import com.paic.pad.wealth.sale.biz.service.CustomerBuyHistoryService; import com.paic.pad.wealth.sale.biz.service.MesgMailSendService; import com.paic.pad.wealth.sale.biz.service.ProductIntentService; import com.paic.pad.wealth.sale.biz.service.ProductStoreService; import com.paic.pad.wealth.sale.biz.service.RecommendService; import com.paic.pad.wealth.sale.biz.service.SaleFilterService; import com.paic.pad.wealth.sale.biz.service.SaleResultHistoryService; import com.paic.pad.wealth.sale.dto.BuyHistoryUploadDTO; import com.paic.pad.wealth.sale.dto.MapDTO; import com.paic.pad.wealth.sale.dto.ProductIntentDTO; import com.paic.pad.wealth.sale.dto.ProductStoreDTO; import com.paic.pad.wealth.sale.dto.RecommendDTO; import com.paic.pad.wealth.sale.dto.SaleFilterDTO; import com.paic.pad.wealth.sale.dto.SaleResultHistoryDTO; import com.paic.pad.wealth.sale.dto.SmsDTO; import com.paic.pad.wealth.sale.po.AppointmentPO; @Controller public class CustDetailsRest extends BaseRest { @BizServicesProxy AppointmentHisotryService appointmentHisotryService; @RequestMapping(value = "/custDetails/appointmentHistories/{customerId}" + ",{bizType}", method = RequestMethod.GET) public Map<String, Object> getAppointmentHistories(@PathVariable("customerId") String customerId, @PathVariable("bizType") String bizType) { Map<String, Object> responseMap = new HashMap<String, Object>(); List<Map<String, Object>> historyList = appointmentHisotryService.getAppointmentHistories(customerId, bizType); for (Map<String, Object> map : historyList) { String productSide = (String) map.get("productSide"); if ("TRUST".equals(productSide)) { responseMap.put("trustAppointList", map.get("productHistories")); } else if ("DAHUA".equals(productSide)) { responseMap.put("dahuaAppointList", map.get("productHistories")); } else if ("LUFAX".equals(productSide)) { responseMap.put("lufaxAppointList", map.get("productHistories")); } } return responseMap; } @RequestMapping(value = "/custDetails/updateVisitInfo", method = RequestMethod.POST) public void updateVisitInfo(HttpServletRequest request ) throws ParseException { SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); Map<String, Object> paramMap = new HashMap<String, Object>(); paramMap.put("appointmentId", request.getParameter("appointmentId")); paramMap.put("isVisit", request.getParameter("isVisit")); paramMap.put("visitRemark", request.getParameter("visitRemark")); String visitDate = request.getParameter("visitDate"); if(StringUtils.isNotBlank(visitDate)) { paramMap.put("visitDate", dateFormat.parse(visitDate)); } else { paramMap.put("visitDate", null); } appointmentHisotryService.updateVisitInfo(paramMap); } @ActionClient(pafaAc = "rwscPafaAcClient") private IServiceClient activateHistoryByCustIdESA; @SuppressWarnings({ "unchecked", "rawtypes" }) @RequestMapping(value = "/custDetails/customerActivateHistory/{customerId}", method = RequestMethod.GET) public List<Map<String, String>> getActivateHistoryByCustId(@PathVariable("customerId")String customerId) { Map<Object, Object> inputMap = new HashMap<Object, Object>(); inputMap.put("customerId", customerId); ServiceResults sr = getActivateHistoryByCustIdESA().invoke(inputMap); Map map = (Map) sr.get("resultMap"); List list = (List) map.get("activateHistoryList"); return list; } public IServiceClient getActivateHistoryByCustIdESA() { return activateHistoryByCustIdESA; } public void setActivateHistoryByCustIdESA(IServiceClient activateHistoryByCustIdESA) { this.activateHistoryByCustIdESA = activateHistoryByCustIdESA; } private static final String DOWNLOAD_P_PRAGMA = "Pragma"; private static final String DOWNLOAD_P_CACHE_CONTROL = "Cache-Control"; private static final String DOWNLOAD_P_CONTENT_DISPOSITION = "Content-Disposition"; private static final String DOWNLOAD_P_CONTENT_TRANSFER_ENCODING = "Content-Transfer-Encoding"; private static final String DOWNLOAD_P_CONTENTTYPE_APPLICATION_OCTET_STREAM_CHARSET_GB2312 = "application/octet-stream; charset=gb2312"; @BizServicesProxy CustomerBuyHistoryService customerBuyHistoryService; @Value("${wealth.file.uploadPath}") private String customerListFileFolder; // TODO @Value("${buy.history.upload.file.subFolder}") private String subFolder; @SuppressWarnings("rawtypes") @RequestMapping(value = "/custDetails/custBuyHis/batchUpload", method = RequestMethod.POST ) public Map<String, BuyHistoryUploadDTO> batchUpload(HttpServletRequest request,HttpServletResponse response) throws WebException { MultipartHttpServletRequest multipartHttpServletRequest = (MultipartHttpServletRequest) request; CommonsMultipartFile commonsMultipartFile = null; String bizType = multipartHttpServletRequest .getParameter("uploadBuyHistoryBizType"); String filePath = null; if (ConstantsEnum.BIZ_TYPE_TRUST.equalsIgnoreCase(bizType)) { commonsMultipartFile = (